xinyilu/PostDischargePatientManage
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

注释

Browse Source
This commit is contained in:
zhuangyuanke 2024-11-04 16:10:21 +08:00
parent 984eb00163
commit 503fdcdab1
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
postdischarge-quartz/src/main/java/com/xinelu/quartz/service/impl/subscribeTaskServiceImpl.java
View File

@ -75,7 +75,7 @@ public class subscribeTaskServiceImpl implements SubscribeTaskService {
List<PatientVO> patientVOList = new ArrayList<>(); List<PatientVO> patientVOList = new ArrayList<>();
//发送消息到期节点id集合 //发送消息到期节点id集合
List<Long> expiredManageRouteNodeIds = new ArrayList<>(); List<Long> expiredManageRouteNodeIds = new ArrayList<>();
//开始遍历患者任务,组装数据 //2.1 开始遍历患者任务,组装数据
for (PatientVO signPatientManageRouteNode : signPatientManageRouteNodes) { for (PatientVO signPatientManageRouteNode : signPatientManageRouteNodes) {
//判断推送状态 //判断推送状态
if (Objects.isNull(signPatientManageRouteNode.getAppletPushSign()) || signPatientManageRouteNode.getAppletPushSign() != 1) { if (Objects.isNull(signPatientManageRouteNode.getAppletPushSign()) || signPatientManageRouteNode.getAppletPushSign() != 1) {
@ -108,7 +108,7 @@ public class subscribeTaskServiceImpl implements SubscribeTaskService {
patientVOList.add(signPatientManageRouteNode); patientVOList.add(signPatientManageRouteNode);
} }
} }
//更改过期执行状态 //2.2 对过期的任务，更改过期执行状态
if (CollectionUtils.isNotEmpty(expiredManageRouteNodeIds)) { if (CollectionUtils.isNotEmpty(expiredManageRouteNodeIds)) {
signPatientManageRouteNodeMapper.updateNodeExecuteStatusByIds(expiredManageRouteNodeIds, NodeExecuteStatusEnum.EXECUTED.getInfo(), NodeExecuteResultStatusEnum.EXPIRED.getInfo(), null, null); signPatientManageRouteNodeMapper.updateNodeExecuteStatusByIds(expiredManageRouteNodeIds, NodeExecuteStatusEnum.EXECUTED.getInfo(), NodeExecuteResultStatusEnum.EXPIRED.getInfo(), null, null);
} }
@ -162,7 +162,7 @@ public class subscribeTaskServiceImpl implements SubscribeTaskService {
if (CollectionUtils.isEmpty(patientVOList)) { if (CollectionUtils.isEmpty(patientVOList)) {
return; return;
} }
//2.2 节点推送数量 //2.3 节点推送数量，用于判断失败次数，若达到最大值，则认为失败；
List<Long> collect = patientVOList.stream().filter(Objects::nonNull).map(PatientVO::getSignPatientManageRouteNodeId) List<Long> collect = patientVOList.stream().filter(Objects::nonNull).map(PatientVO::getSignPatientManageRouteNodeId)
.filter(Objects::nonNull).distinct().collect(Collectors.toList()); .filter(Objects::nonNull).distinct().collect(Collectors.toList());
//RecordNum，manageRouteNodeId：任务ID，num：已推送次数 //RecordNum，manageRouteNodeId：任务ID，num：已推送次数
@ -201,6 +201,7 @@ public class subscribeTaskServiceImpl implements SubscribeTaskService {
subscribeMessageSendRecord.setAppletId(weChatAppletChatConfig.getAppletId()); subscribeMessageSendRecord.setAppletId(weChatAppletChatConfig.getAppletId());
subscribeMessageSendRecord.setTemplateId(weChatAppletChatConfig.getHealthyPropagandaId()); subscribeMessageSendRecord.setTemplateId(weChatAppletChatConfig.getHealthyPropagandaId());
subscribeMessageSendRecord.setCreateTime(LocalDateTime.now()); subscribeMessageSendRecord.setCreateTime(LocalDateTime.now());
//3.1 托送记录入库
subscribeMessageSendRecordMapper.insertSubscribeMessageSendRecord(subscribeMessageSendRecord); subscribeMessageSendRecordMapper.insertSubscribeMessageSendRecord(subscribeMessageSendRecord);
} }