测试bug修改

single-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/SingleApplyreviewService.java

@@ -77,16 +77,26 @@ public class SingleApplyreviewService implements IApplicationStartedService {
                             Map<Long,MatterDatumEntity> datumEntityMap = datumEntityList.stream().collect(Collectors.toMap(datumEntity->datumEntity.getId(), Function.identity()));
                             for(MatterApplyDatumEntity item:datumList){
                                 MatterDatumEntity matterDatumEntity = datumEntityMap.get(item.getDatumId());
+                                if(matterDatumEntity==null){
+                                    item.setReviewStatus(1);
+                                    item.setUpdateTime(new Date());
+                                    matterApplyDatumService.update(item);
+                                    continue;
+                                }
                                 if(StringUtils.isNotEmpty(matterDatumEntity.getSystemPrompt())&&StringUtils.isNotEmpty(matterDatumEntity.getPrompt())) {
+                                    try {
                                         CustomerWebSocketClient webSocketClient = new CustomerWebSocketClient(uri);
                                         webSocketClient.connect();
                                         webSocketClient.setMatterApplyDatumService(matterApplyDatumService);
                                         webSocketClient.setMatterApplyService(matterApplyService);
                                         if (!webSocketClient.isOpen()) {
+                                            try {
                                                 Thread.sleep(2000);
+                                            } catch (InterruptedException e2) {
+
+                                            }
                                         }
                                         webSocketClient.setApplyDatumId(item.getId());
-                                    //TODO
                                         Map<String, String> processUserImage = new HashMap<>();
                                         processUserImage.put("action", "pre_review");
                                         processUserImage.put("system_prompt", matterDatumEntity.getSystemPrompt());
@@ -100,12 +110,25 @@ public class SingleApplyreviewService implements IApplicationStartedService {
                                             webSocketClient.setCurrentTime(System.currentTimeMillis());
                                             webSocketClient.send(JSONObject.toJSONString(processUserImage));
                                             //log.info("发送消息: " + JSONObject.toJSONString(processUserImage));
+                                        }else {
+                                            item.setReviewStatus(1);
+                                            item.setUpdateTime(new Date());
+                                            matterApplyDatumService.update(item);
                                         }
                                         try {
                                             Thread.sleep(15000);
                                         } catch (InterruptedException e2) {
+
                                         }
                                         webSocketClient.close();
+
+                                    }catch (Exception e){
+                                        log.info("预审异常:" + e.getMessage());
+                                        item.setReviewStatus(1);
+                                        item.setUpdateTime(new Date());
+                                        matterApplyDatumService.update(item);
+                                    }
+
                                 }else {
                                     item.setReviewStatus(1);
                                     item.setUpdateTime(new Date());
@@ -129,6 +152,12 @@ public class SingleApplyreviewService implements IApplicationStartedService {
                             }
                             update.setUpdateTime(new Date());
 
+                            matterApplyService.getDao().update(update);
+                        }else {
+                            MatterApplyEntity update = new MatterApplyEntity();
+                            update.setId(applyId);
+                            update.setApplyState(2);
+                            update.setUpdateTime(new Date());
                             matterApplyService.getDao().update(update);
                         }