用户注册排行定时任务

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

@@ -1,6 +1,9 @@
 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.UserFeignClintFallback;
+import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.GetMapping;
 
 /**
@@ -8,6 +11,7 @@ import org.springframework.web.bind.annotation.GetMapping;
  *  @Date: 2020/3/25 10:20
  *  @Description: 用户数据分析
  */
+@FeignClient(name = ServiceConstant.EPDC_ANALYSIS_SERVER, fallback = UserFeignClintFallback.class)
 public interface UserFeignClint {
 
     /***
@@ -17,6 +21,17 @@ public interface UserFeignClint {
      * @author qushutong
      * @date 2020/3/25 10:19
      */
-    @GetMapping("analysis/user/tolead")
+    @GetMapping("analysis/metausergridopining/tolead")
     Result createUserAnalysisData();
+
+    /***
+     * 用户注册排行导入数据
+     * @param
+     * @return com.elink.esua.epdc.commons.tools.utils.Result
+     * @author qushutong
+     * @date 2020/3/26 17:45
+     */
+    @GetMapping("analysis/metauserregisterrank/toLeadUserRegisterRandData")
+    Result toLeadUserRegisterRandData();
+
 }

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

@@ -16,4 +16,9 @@ public class UserFeignClintFallback implements UserFeignClint {
     public Result createUserAnalysisData() {
         return  ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "createUserAnalysisData", "");
     }
+
+    @Override
+    public Result toLeadUserRegisterRandData() {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "toLeadUserRegisterRandData", "");
+    }
 }

esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/impl/ScheduleJobUserServiceImpl.java

@@ -3,18 +3,23 @@ package com.elink.esua.epdc.service.impl;
 import com.elink.esua.epdc.feign.UserFeignClint;
 import com.elink.esua.epdc.service.ScheduleJobUserService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
 
 /**
  *  @author: qushutong
  *  @Date: 2020/3/25 10:15
  *  @Description: 用户数据数据分析
  */
+@Service
 public class ScheduleJobUserServiceImpl implements ScheduleJobUserService {
     @Autowired
     private UserFeignClint userFeignClint;
 
     @Override
     public void createUserAnalysisData() {
+        // 网格开通
         userFeignClint.createUserAnalysisData();
+        // 用户注册
+        userFeignClint.toLeadUserRegisterRandData();
     }
 }