| | |
| | | private ICollectHISService ichService; |
| | | |
| | | @Autowired |
| | | private IPatSpecificArchiveGenerateService patSpecificArchiveGenerateService; |
| | | |
| | | @Autowired |
| | | private com.ruoyi.task.event.FollowupCompletedEventPublisher followupCompletedEventPublisher; |
| | | |
| | | @Autowired |
| | | private ISysConfigService configService; |
| | | |
| | | @Autowired |
| | |
| | | if (finishState) { |
| | | serviceSubtask.setSendstate(6L); |
| | | serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); |
| | | followupCompletedEventPublisher.publish(serviceSubtask.getId()); |
| | | continue; |
| | | } |
| | | |
| | |
| | | //说明,在某种方式发送失败后,又成功了(例如短信或公众号,在规定时间外患者做完了,这个时候,状态改成了9) |
| | | serviceSubtask.setSendstate(6L); |
| | | serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); |
| | | followupCompletedEventPublisher.publish(serviceSubtask.getId()); |
| | | return "-1"; |
| | | } |
| | | // 当sort等于列表size时,并且所有sendstate都不等于9,则返回-1 |
| | |
| | | serviceSubtask.setRemark(StringUtils.isNotEmpty(serviceSubtask.getRemark()) ? serviceSubtask.getRemark() + "," + remark : remark); |
| | | log.info("serviceSubtask的入参是:{}",serviceSubtask); |
| | | serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); |
| | | if (Long.valueOf(6L).equals(serviceSubtask.getSendstate())) { |
| | | followupCompletedEventPublisher.publish(serviceSubtask.getId()); |
| | | } |
| | | return true; |
| | | } |
| | | |
| | |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 住院随访完成生成专科档案补偿任务。 |
| | | * |
| | | * <p>扫描近 7 天已完成但未生成日志的住院随访,按配置补生成妇科/儿科档案。</p> |
| | | */ |
| | | public void generateInhospFollowupArchive() { |
| | | try { |
| | | int generated = patSpecificArchiveGenerateService.compensateInhospFollowups(); |
| | | log.info("【generateInhospFollowupArchive】住院随访专科档案补偿完成,生成数量={}", generated); |
| | | } catch (Exception e) { |
| | | log.error("【generateInhospFollowupArchive】住院随访专科档案补偿失败", e); |
| | | } |
| | | } |
| | | |
| | | } |