diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/UserFeignClint.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/UserFeignClint.java index aa3393b8b..335871ed3 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/UserFeignClint.java +++ b/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(); + } diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/UserFeignClintFallback.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/UserFeignClintFallback.java index 43636d315..0fc95fe4e 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/UserFeignClintFallback.java +++ b/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", ""); + } } diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/impl/ScheduleJobUserServiceImpl.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/impl/ScheduleJobUserServiceImpl.java index a19d0ef7e..115c30485 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/impl/ScheduleJobUserServiceImpl.java +++ b/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(); } }