diff --git a/src/main/java/com/example/duplicate/service/impl/MedicalAdviceServiceImpl.java b/src/main/java/com/example/duplicate/service/impl/MedicalAdviceServiceImpl.java index 1145379..cb29230 100644 --- a/src/main/java/com/example/duplicate/service/impl/MedicalAdviceServiceImpl.java +++ b/src/main/java/com/example/duplicate/service/impl/MedicalAdviceServiceImpl.java @@ -93,7 +93,13 @@ public class MedicalAdviceServiceImpl implements MedicalAdviceService { GenerateQueue(tasks, printParam, 5, collectId); log.info("轮询增加任务成功,id为:" + tasks.getId()); } + }else { + //存在任务将任务表状态改为0为开始 + archiveOtherExtMapper.updateStatic(tasks.getId(), collectId); + //存放队列消息 + GenerateQueue(tasks, printParam, 5, collectId); } + log.info("轮询增加任务成功,id为:" + tasks.getId()); } catch (Exception e) { log.error("轮询增加任务失败,id为:" + tasks.getId(), e); } diff --git a/src/main/java/com/example/duplicate/service/impl/TaskServiceImpl.java b/src/main/java/com/example/duplicate/service/impl/TaskServiceImpl.java index 1b17296..285707d 100644 --- a/src/main/java/com/example/duplicate/service/impl/TaskServiceImpl.java +++ b/src/main/java/com/example/duplicate/service/impl/TaskServiceImpl.java @@ -162,7 +162,7 @@ public class TaskServiceImpl implements TaskService { archiveOtherExtMapper.updateStatic(masterId, collectId); } GenerateQueue(archiveMasters.get(0), printParam, 10, collectId); - log.info("补偿患者单个采集器成功masterId为:" + masterId + "的患者住院信息补偿失败"); + log.info("补偿患者单个采集器成功masterId为:" + masterId + "的患者住院信息补偿成功"); return CommonResult.success("补偿患者单个采集器成功"); }