| | |
| | | //2判断一下,当前的sort是不是等于需要执行的总个数,如果等于的话,说明是最后一个,直接将servuce_subtask的状态改成5,执行失败就行了 |
| | | Long cs = currentSort.get(); |
| | | if (cs.equals(serviceSubtaskPreachforms.size())) { |
| | | if(serviceSubtask.getPreachform().equals("1")){ |
| | | serviceSubtask.setSendstate(7L); |
| | | serviceSubtask.setRemark("处理补偿任务,当前处理最后补偿 人工超时"); |
| | | }else { |
| | | serviceSubtask.setSendstate(5L); |
| | | serviceSubtask.setRemark("处理补偿任务,当前处理最后补偿,全部执行失败"); |
| | | } |
| | | |
| | | serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); |
| | | //修改发送方式的状态为失败 |
| | | if(serviceSubtaskPreachform.getPreachform().equals("1")){ |
| | | serviceSubtaskPreachform.setSendstate("7"); |
| | | serviceSubtaskPreachform.setId(id.get()); |
| | | }else { |
| | | serviceSubtaskPreachform.setSendstate("5"); |
| | | serviceSubtaskPreachform.setId(id.get()); |
| | | } |
| | | serviceSubtaskPreachformMapper.updateServiceSubtaskPreachform(serviceSubtaskPreachform); |
| | | continue; |
| | | } |
| | |
| | | } |
| | | } |
| | | } else if (descByCode.equals("人工")) { |
| | | setSuccessPreachForm(serviceSubtask, sendPreachform, "人工待执行", "2"); |
| | | setSuccessPreachForm(serviceSubtask, sendPreachform, "人工超时", "7"); |
| | | } |
| | | |
| | | } |
| | |
| | | //说明全发送失败了 |
| | | serviceSubtask.setSendstate(5L); |
| | | log.error("getSendPreachform方法 检查是否所有sendstate不等于9, 全失败了"); |
| | | //人工发送超时 |
| | | if(ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("1")){ |
| | | serviceSubtask.setSendstate(7L); |
| | | serviceSubtask.setRemark("getSendPreachform方法 检查是否所有sendstate不等于9, 人工发送超时"); |
| | | } |
| | | serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); |
| | | //修改发送状态 |
| | | setFail(serviceSubtaskPreachforms, serviceSubtask); |
| | |
| | | ServiceSubtaskPreachform subtaskPreachform = new ServiceSubtaskPreachform(); |
| | | subtaskPreachform.setSendstate("5"); |
| | | subtaskPreachform.setId(id.get()); |
| | | //人工发送超时 |
| | | if(ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("1")){ |
| | | subtaskPreachform.setSendstate("7"); |
| | | subtaskPreachform.setRemark("人工发送超时"); |
| | | } |
| | | return serviceSubtaskPreachformMapper.updateServiceSubtaskPreachform(subtaskPreachform); |
| | | } |
| | | return 0; |
| | |
| | | if (failSendstate.equals("2")) serviceSubtaskPreachform1.setSendstate("9"); |
| | | } |
| | | serviceSubtaskPreachform1.setRemark(remark); |
| | | if(ObjectUtils.isNotEmpty(preachform) && preachform.equals("1")){ |
| | | serviceSubtaskPreachform1.setSendstate("7"); |
| | | serviceSubtaskPreachform1.setRemark("人工发送超时"); |
| | | } |
| | | serviceSubtaskPreachformMapper.updateServiceSubtaskPreachform(serviceSubtaskPreachform1); |
| | | |
| | | //如果当前的preachform已经是最后一个了,那直接将serviceSubtask的sendstate状态改成5就行了(全失败了) |
| | | if (serviceSubtaskPreachform1.getSort() == sspCount.size()) { |
| | | if(ObjectUtils.isNotEmpty(preachform) && preachform.equals("1")){ |
| | | serviceSubtask.setCurrentPreachform(preachform); |
| | | serviceSubtask.setSendstate(7L); |
| | | serviceSubtask.setRemark("setSuccessPreachForm方法,人工发送超时"); |
| | | serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); |
| | | return true; |
| | | }else { |
| | | if (failSendstate.equals("4") || failSendstate.equals("5")) { |
| | | serviceSubtask.setCurrentPreachform(preachform); |
| | | serviceSubtask.setSendstate(5L); |
| | |
| | | return true; |
| | | } |
| | | } |
| | | |
| | | } |
| | | } else { |
| | | log.error("【定时任务中该患者没有查询到属于他的发送方式,subid:{},prechform:{},orgid:{}】", serviceSubtask.getId(), preachform, serviceSubtask.getOrgid()); |
| | | return false; |
| | |
| | | //将下一次的随访时间与当前执行方式记录一下 |
| | | serviceSubtask.setVisitTime(getNextVisitTime(serviceSubtask.getId(), serviceSubtask.getTaskid(), serviceSubtask.getVisitTime())); |
| | | serviceSubtask.setCurrentPreachform(preachform); |
| | | if(ObjectUtils.isNotEmpty(preachform) && preachform.equals("1")){ |
| | | serviceSubtask.setSendstate(7L); |
| | | serviceSubtask.setRemark("人工发送超时"); |
| | | }else { |
| | | serviceSubtask.setSendstate(3L); |
| | | } |
| | | if (serviceSubtask.getType().equals("3") || serviceSubtask.getType().equals("4")) { |
| | | //如果是宣教或通知,并且发送成功,则直接将serviceSubtask状态改成6L(这个患者是没有题做的,不会再触发接口进行状态修改) |
| | | if (failSendstate.equals("2")) { |