From b45bcc0b4f181111567a5d54913d32106e4e72a0 Mon Sep 17 00:00:00 2001 From: yinzuomei <576302893@qq.com> Date: Thu, 25 May 2023 09:45:37 +0800 Subject: [PATCH] =?UTF-8?q?job=E6=B7=BB=E5=8A=A0=EF=BC=9AXxxdFeedBackQuest?= =?UTF-8?q?ionTask?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../form/XxxdFeedBackQuestionTaskFormDTO.java | 25 +++++++++++ .../esua/epdc/feign/ItemFeignClient.java | 9 ++++ .../fallback/ItemFeignClientFallback.java | 11 +++++ .../task/events/XxxdFeedBackQuestionTask.java | 18 ++++++++ .../events/XxxdFeedBackQuestionTaskImpl.java | 42 +++++++++++++++++++ 5 files changed, 105 insertions(+) create mode 100644 esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/form/XxxdFeedBackQuestionTaskFormDTO.java create mode 100644 esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTask.java create mode 100644 esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTaskImpl.java diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/form/XxxdFeedBackQuestionTaskFormDTO.java b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/form/XxxdFeedBackQuestionTaskFormDTO.java new file mode 100644 index 000000000..e951f99c8 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/events/form/XxxdFeedBackQuestionTaskFormDTO.java @@ -0,0 +1,25 @@ +package com.elink.esua.epdc.dto.events.form; + +import lombok.Data; + +/** + * @Description 新新向党随手拍的接收数据 + * @Author yzm + * @Date 2023/5/25 9:27 + */ +@Data +public class XxxdFeedBackQuestionTaskFormDTO { + /** + * 问题标识，可唯一识别用户问题的id + */ + private String questionId; + /** + * 开始日期:yyyy-MM-dd + */ + private String startDateStr; + /** + * 结束日期:yyyy-MM-dd + */ + private String endDateStr; +} + diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/ItemFeignClient.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/ItemFeignClient.java index 6cb1bc129..c01f49716 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/ItemFeignClient.java +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/ItemFeignClient.java @@ -2,6 +2,7 @@ package com.elink.esua.epdc.feign; import com.elink.esua.epdc.commons.tools.constant.ServiceConstant; import com.elink.esua.epdc.commons.tools.utils.Result; +import com.elink.esua.epdc.dto.events.form.XxxdFeedBackQuestionTaskFormDTO; import com.elink.esua.epdc.dto.item.form.GetAbnormalDataFormDTO; import com.elink.esua.epdc.dto.screen.form.DataStatisticsFormDTO; import com.elink.esua.epdc.feign.fallback.ItemFeignClientFallback; @@ -79,4 +80,12 @@ public interface ItemFeignClient { @PostMapping("events/PushToCity/getAbnormalData") Result getAbnormalData(@RequestBody GetAbnormalDataFormDTO formDTO); + /** + * 新新向党_随手拍处理反馈定时任务，job调用此方法 + * + * @return + */ + @PostMapping("events/xxxd/question/xxxdFeedBackQuestionTask") + Result xxxdFeedBackQuestionTask(@RequestBody XxxdFeedBackQuestionTaskFormDTO formDTO); + } diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/ItemFeignClientFallback.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/ItemFeignClientFallback.java index 939a95461..086db236c 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/ItemFeignClientFallback.java +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/ItemFeignClientFallback.java @@ -3,6 +3,7 @@ package com.elink.esua.epdc.feign.fallback; import com.elink.esua.epdc.commons.tools.constant.ServiceConstant; import com.elink.esua.epdc.commons.tools.utils.ModuleUtils; import com.elink.esua.epdc.commons.tools.utils.Result; +import com.elink.esua.epdc.dto.events.form.XxxdFeedBackQuestionTaskFormDTO; import com.elink.esua.epdc.dto.item.form.GetAbnormalDataFormDTO; import com.elink.esua.epdc.dto.screen.form.DataStatisticsFormDTO; import com.elink.esua.epdc.feign.ItemFeignClient; @@ -68,4 +69,14 @@ public class ItemFeignClientFallback implements ItemFeignClient { return ModuleUtils.feignConError(ServiceConstant.EPDC_EVENTS_SERVER, "getAbnormalData", formDTO); } + /** + * 新新向党_随手拍处理反馈定时任务，job调用此方法 + * + * @param formDTO + * @return + */ + @Override + public Result xxxdFeedBackQuestionTask(XxxdFeedBackQuestionTaskFormDTO formDTO) { + return ModuleUtils.feignConError(ServiceConstant.EPDC_EVENTS_SERVER, "xxxdFeedBackQuestionTask", formDTO); + } } diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTask.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTask.java new file mode 100644 index 000000000..5297b0ade --- /dev/null +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTask.java @@ -0,0 +1,18 @@ +package com.elink.esua.epdc.task.events; + +/** + * 新新向党_随手拍处理反馈定时任务 + * + * @author yzm + * @date 2023/05/25 09:19 + */ +public interface XxxdFeedBackQuestionTask { + + /** + * @param params + * @return void + * @author yzm + * @date 2023/05/25 09:19 + */ + void run(String params); +} diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTaskImpl.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTaskImpl.java new file mode 100644 index 000000000..bf3d4a384 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/events/XxxdFeedBackQuestionTaskImpl.java @@ -0,0 +1,42 @@ +package com.elink.esua.epdc.task.events; + +import com.alibaba.fastjson.JSON; +import com.elink.esua.epdc.dto.events.form.XxxdFeedBackQuestionTaskFormDTO; +import com.elink.esua.epdc.feign.ItemFeignClient; +import org.apache.commons.lang3.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * @Description 新新向党_随手拍处理反馈定时任务 + * @Author yzm + * @Date 2023/5/25 9:20 + */ +@Component("XxxdFeedBackQuestionTask") +public class XxxdFeedBackQuestionTaskImpl implements XxxdFeedBackQuestionTask { + private Logger logger = LoggerFactory.getLogger(getClass()); + + @Autowired + private ItemFeignClient itemFeignClient; + + /** + * @param params + * @return void + * @author yzm + * @date 2023/05/25 09:19 + */ + @Override + public void run(String params) { + logger.debug("XxxdFeedBackQuestionTask定时任务正在执行，参数为：{}", params); + XxxdFeedBackQuestionTaskFormDTO formDTO = new XxxdFeedBackQuestionTaskFormDTO(); + if (StringUtils.isNotBlank(params)) { + formDTO = JSON.parseObject(params, XxxdFeedBackQuestionTaskFormDTO.class); + } + itemFeignClient.xxxdFeedBackQuestionTask(formDTO); + } + + +} +