job添加：XxxdFeedBackQuestionTask

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

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

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

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

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