【pc端 -新增用户指标展示管理】【定时任务接口修改】魏凯 2020-11-25

esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/AdminFeign.java

@@ -0,0 +1,29 @@
+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.feign.fallback.AdminFeignClientFallback;
+import com.elink.esua.epdc.feign.fallback.AnalysisFeignClientFallback;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+
+
+/**
+ *
+ * 调用数据分析模块
+ *
+ * @Author：wanggongfeng
+ * @Date：2020/08/25 09:36
+ */
+@FeignClient(name = ServiceConstant.EPDC_ADMIN_SERVER, fallback = AdminFeignClientFallback.class)
+public interface AdminFeign {
+
+    /**
+     * @describe: 定时发送指标指数 - 短信接口 -每月一次
+     * @author wk
+     * @date 2020/11/25 11:00
+     * @return com.elink.esua.epdc.commons.tools.utils.Result
+     */
+    @PostMapping("sys/analysis/send")
+    Result sendNoteByIndex();
+}

esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/AdminFeignClientFallback.java

@@ -0,0 +1,21 @@
+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.feign.AdminFeign;
+import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import org.springframework.stereotype.Component;
+
+/**
+ *  @author: qushutong
+ *  @Date: 2020/3/25 10:22
+ *  @Description: 用户数据分析
+ */
+@Component
+public class AdminFeignClientFallback implements AdminFeign {
+    @Override
+    public Result sendNoteByIndex() {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "sendNoteByIndex");
+    }
+}

esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/indicator/AnalyssisIndexNoteMonthTask.java

@@ -0,0 +1,18 @@
+package com.elink.esua.epdc.task.indicator;
+
+/*
+ *
+ * @describe: 管理员查看指标指数短信-每月发送一次
+ * @author wk
+ * @date 2020-11-25 10:45
+ */
+public interface AnalyssisIndexNoteMonthTask {
+    /**
+     * @describe: 管理员查看指标指数短信
+     * @author wk
+     * @date 2020-11-25 10:45
+     * @params [param]
+     * @return void
+     */
+    void run(String param);
+}

esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/indicator/impl/AnalyssisIndexNoteMonthTaskImpl.java

@@ -0,0 +1,36 @@
+package com.elink.esua.epdc.task.indicator.impl;
+
+import com.elink.esua.epdc.feign.AdminFeign;
+import com.elink.esua.epdc.task.indicator.AnalyssisIndexNoteMonthTask;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * TODO
+ *  管理员查看指标指数短信-每月发送一次
+ * @author wk
+ * @version 1.0
+ * @date 2020-11-25 10:47
+ */
+@Component("AnalyssisIndexNoteMonthTask")
+@Slf4j
+public class AnalyssisIndexNoteMonthTaskImpl  implements AnalyssisIndexNoteMonthTask {
+
+    @Autowired
+    private AdminFeign adminFeign;
+   /*
+    *
+    * 调用发送短信接口
+    * @param param
+    * @author wk
+    * @date 2020-11-25 10:49
+    * @return void
+    */
+    @Override
+    public void run(String param) {
+        log.info("< 发送指标指数短信>定时任务开始执行");
+        adminFeign.sendNoteByIndex();
+        log.info("<发送指标指数短信>定时任务执行结束");
+    }
+}