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); + } + + +} +