From 3fc51e7cbdabb7dcd1615c6efac52323f6ca8adb Mon Sep 17 00:00:00 2001 From: liusheng <337615773@qq.com> Date: 星期三, 03 七月 2024 18:28:34 +0800 Subject: [PATCH] 代码提交 --- smartor/src/main/java/com/smartor/service/impl/CommonTaskServiceImpl.java | 38 +++++++++++++++++++------------------- 1 files changed, 19 insertions(+), 19 deletions(-) diff --git a/smartor/src/main/java/com/smartor/service/impl/CommonTaskServiceImpl.java b/smartor/src/main/java/com/smartor/service/impl/CommonTaskServiceImpl.java index 0067dc4..ca3dcf8 100644 --- a/smartor/src/main/java/com/smartor/service/impl/CommonTaskServiceImpl.java +++ b/smartor/src/main/java/com/smartor/service/impl/CommonTaskServiceImpl.java @@ -36,7 +36,7 @@ private IServiceTaskService ivrTaskService; @Autowired - private ISvyTaskService iSvyTaskService; + private IServiceTaskService iServiceTaskService; @Autowired private RedisCache redisCache; @@ -131,40 +131,40 @@ } public int wjSend(SendTaskVO sendTaskVO) { - SvyTask svyTask = iSvyTaskService.selectSvyTaskByTaskid(sendTaskVO.getTaskId()); + ServiceTask serviceTask1 = iServiceTaskService.selectServiceTaskByTaskid(sendTaskVO.getTaskId()); if (sendTaskVO.getSendState() != null && sendTaskVO.getSendState() == 3 || sendTaskVO.getSendState() != null && sendTaskVO.getSendState() == 4) { //浠诲姟鏆傚仠鎴栫粓姝� - SvyTask serviceTask = new SvyTask(); + ServiceTask serviceTask = new ServiceTask(); serviceTask.setTaskid(sendTaskVO.getTaskId()); - serviceTask.setStopState(svyTask.getStopState() + 1); - serviceTask.setSendState(sendTaskVO.getSendState().toString()); - iSvyTaskService.updateSvyTask(serviceTask); + serviceTask.setStopState(serviceTask1.getStopState() + 1); + serviceTask.setSendState(sendTaskVO.getSendState()); + iServiceTaskService.updateServiceTask(serviceTask); return 0; } //鍒ゆ柇鍙戦�佺姸鎬佹槸鍚︿负绌� if (StringUtils.isEmpty(sendTaskVO.getSendType())) { - sendTaskVO.setSendType(svyTask.getSendType().toString()); + sendTaskVO.setSendType(serviceTask1.getSendType().toString()); } //鍒ゆ柇浠诲姟鏄惁鏄珛鍗冲彂閫� if (StringUtils.isNotEmpty(sendTaskVO.getSendType()) && sendTaskVO.getSendType().equals("2")) { - String content = sendMQContent(sendTaskVO, svyTask.getTemplateid(), svyTask.getPreachform(), svyTask.getStopState(), null); + String content = sendMQContent(sendTaskVO, serviceTask1.getTemplateid().toString(), serviceTask1.getPreachform(), serviceTask1.getStopState(), null); //绔嬪嵆鍙戦�� redisCache.setCacheObject(content, content, 1, TimeUnit.SECONDS); //灏嗕换鍔$姸鎬佷慨鏀规垚鎵ц涓� - SvyTask serviceTask = new SvyTask(); - serviceTask.setTaskid(svyTask.getTaskid()); - serviceTask.setSendState("2"); - iSvyTaskService.updateSvyTask(serviceTask); + ServiceTask serviceTask = new ServiceTask(); + serviceTask.setTaskid(serviceTask1.getTaskid()); + serviceTask.setSendState(2); + iServiceTaskService.updateServiceTask(serviceTask); } else if (StringUtils.isNotEmpty(sendTaskVO.getSendType()) && sendTaskVO.getSendType().equals("1") || StringUtils.isNotEmpty(sendTaskVO.getSendType()) && sendTaskVO.getSendType().equals("3")) { //鏃堕棿娈靛彂閫� ObjectMapper objectMapper = new ObjectMapper(); - if (StringUtils.isNotEmpty(svyTask.getSendTimeSlot())) { + if (StringUtils.isNotEmpty(serviceTask1.getSendTimeSlot())) { List<TaskSendTimeVO> taskSendTimeVOList = null; try { - taskSendTimeVOList = objectMapper.readValue(svyTask.getSendTimeSlot(), new TypeReference<List<TaskSendTimeVO>>() { + taskSendTimeVOList = objectMapper.readValue(serviceTask1.getSendTimeSlot(), new TypeReference<List<TaskSendTimeVO>>() { }); } catch (JsonProcessingException e) { log.error("JsonProcessingException鎶ラ敊浜嗭細{}", e.getMessage()); @@ -189,14 +189,14 @@ SendTaskVO sendTaskVO1 = DtoConversionUtils.sourceToTarget(sendTaskVO, SendTaskVO.class); sendTaskVO1.setSendType("1"); - String content = sendMQContent(sendTaskVO1, svyTask.getTemplateid(), svyTask.getPreachform(), svyTask.getStopState(), list); + String content = sendMQContent(sendTaskVO1, serviceTask1.getTemplateid().toString(), serviceTask1.getPreachform(), serviceTask1.getStopState(), list); redisCache.setCacheObject(content, content, milliseconds / 1000, TimeUnit.SECONDS); } //灏嗕换鍔$姸鎬佷慨鏀规垚鎵ц涓� - SvyTask serviceTask = new SvyTask(); - serviceTask.setTaskid(svyTask.getTaskid()); - serviceTask.setSendState("2"); - iSvyTaskService.updateSvyTask(serviceTask); + ServiceTask serviceTask = new ServiceTask(); + serviceTask.setTaskid(serviceTask1.getTaskid()); + serviceTask.setSendState(2); + iServiceTaskService.updateServiceTask(serviceTask); } } return 1; -- Gitblit v1.9.3