| | |
|---|
| | | patArchiveVO.setIsoperation(2); |
|---|
| | | patArchiveMapper.updatePatArchive(patArchive); |
|---|
| | | if (StringUtils.isNotEmpty(patArchive.getNotrequiredFlag()) && patArchive.getNotrequiredFlag().equals("1")) { |
|---|
| | | //不需要服务了，需要通过patid和sendstate=2或者sendstate=1去查询一下，service_subtask里是否有正在执行的任务，有的话，立即停了 |
|---|
| | | //不需要服务了，需要通过patid和sendstate=1,2,3,5,7去查询一下，service_subtask里是否有正在执行的任务，有的话，立即停了 |
|---|
| | | List<Long> list = Arrays.asList(1L, 2L, 3L, 5L, 7L); |
|---|
| | | List<ServiceSubtask> serviceSubtaskList = new ArrayList<>(); |
|---|
| | | ServiceSubtaskEntity serviceSubtaskVO = new ServiceSubtaskEntity(); |
|---|
| | | serviceSubtaskVO.setPatid(patArchive.getId()); |
|---|
| | | serviceSubtaskVO.setSendstate(2L); |
|---|
| | | List<ServiceSubtask> serviceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskVO); |
|---|
| | | serviceSubtaskVO.setSendstate(1L); |
|---|
| | | List<ServiceSubtask> serviceSubtaskList1 = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskVO); |
|---|
| | | if (CollectionUtils.isNotEmpty(serviceSubtaskList)) { |
|---|
| | | if (CollectionUtils.isNotEmpty(serviceSubtaskList1)) serviceSubtaskList.addAll(serviceSubtaskList1); |
|---|
| | | } else { |
|---|
| | | if (CollectionUtils.isNotEmpty(serviceSubtaskList1)) serviceSubtaskList = serviceSubtaskList1; |
|---|
| | | for (Long ss : list) { |
|---|
| | | serviceSubtaskVO.setSendstate(ss); |
|---|
| | | List<ServiceSubtask> serviceSubtasks = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskVO); |
|---|
| | | serviceSubtaskList.addAll(serviceSubtasks); |
|---|
| | | } |
|---|
| | | //去redis中，查询是否有subid，有的话移除cache-exist |
|---|
| | | if (CollectionUtils.isNotEmpty(serviceSubtaskList)) { |
|---|
| | | for (ServiceSubtask serviceSubtask : serviceSubtaskList) { |
|---|
| | | log.info("需要移除的subId为：{}", serviceSubtask.getId().toString()); |
|---|
| | | serviceSubtaskMapper.deleteServiceSubtaskById(serviceSubtask.getId()); |
|---|
| | | serviceSubtask.setSendstate(4L); |
|---|
| | | serviceSubtask.setRemark(patArchiveVO.getNotrequiredreason()); |
|---|
| | | serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); |
|---|
| | | redisCache.removeElementFromList("cache-exist", serviceSubtask.getId().toString()); |
|---|
| | | redisCache.removeElementFromList("cache-0", serviceSubtask.getId().toString()); |
|---|
| | | redisCache.removeElementFromList("cache-1", serviceSubtask.getId().toString()); |
|---|
