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/AnalysisFeignClint.java similarity index 88% rename from esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/UserFeignClint.java rename to esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClint.java index c0b7e2ec5..3907e37de 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/AnalysisFeignClint.java @@ -2,7 +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.feign.fallback.UserFeignClintFallback; +import com.elink.esua.epdc.feign.fallback.AnalysisFeignClintFallback; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.GetMapping; @@ -11,8 +11,8 @@ 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 { +@FeignClient(name = ServiceConstant.EPDC_ANALYSIS_SERVER, fallback = AnalysisFeignClintFallback.class) +public interface AnalysisFeignClint { /*** * 生成用户分析数据导入临时表 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/AnalysisFeignClintFallback.java similarity index 87% rename from esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/UserFeignClintFallback.java rename to esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClintFallback.java index 8a2a066dc..dc3783417 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/AnalysisFeignClintFallback.java @@ -3,7 +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.feign.UserFeignClint; +import com.elink.esua.epdc.feign.AnalysisFeignClint; import org.springframework.stereotype.Component; /** @@ -12,7 +12,7 @@ import org.springframework.stereotype.Component; * @Description: 用户数据分析 */ @Component -public class UserFeignClintFallback implements UserFeignClint { +public class AnalysisFeignClintFallback implements AnalysisFeignClint { @Override public Result createUserAnalysisData() { 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 7a0726756..c25f91290 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 @@ -1,10 +1,9 @@ package com.elink.esua.epdc.service.impl; -import com.elink.esua.epdc.feign.UserFeignClint; +import com.elink.esua.epdc.feign.AnalysisFeignClint; import com.elink.esua.epdc.service.ScheduleJobUserService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; -import org.springframework.stereotype.Service; /** * @author: qushutong @@ -14,7 +13,7 @@ import org.springframework.stereotype.Service; @Component public class ScheduleJobUserServiceImpl implements ScheduleJobUserService { @Autowired - private UserFeignClint userFeignClint; + private AnalysisFeignClint userFeignClint; @Override public void createUserAnalysisData() { diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/analysis/UserAnalysisTask.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/analysis/UserAnalysisTask.java index d02458b5d..40e9c69c5 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/analysis/UserAnalysisTask.java +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/analysis/UserAnalysisTask.java @@ -1,18 +1,23 @@ package com.elink.esua.epdc.task.analysis; +import com.elink.esua.epdc.service.ScheduleJobUserService; +import com.elink.esua.epdc.task.ITask; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + /** - * @author: qushutong - * @Date: 2020/3/25 10:04 - * @Description: 用户分析 + * @author: qushutong + * @Date: 2020/3/25 10:12 + * @Description: */ -public interface UserAnalysisTask { +@Component("userAnalysisTask") +public class UserAnalysisTask implements ITask { + + @Autowired + private ScheduleJobUserService scheduleJobUserService; - /*** - * 网格开通情况 - * @param - * @return void - * @author qushutong - * @date 2020/3/25 10:11 - */ - void run(String params); + @Override + public void run(String params) { + scheduleJobUserService.createUserAnalysisData(); + } } diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/analysis/UserAnalysisTaskImpl.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/analysis/UserAnalysisTaskImpl.java deleted file mode 100644 index 2430504cc..000000000 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/analysis/UserAnalysisTaskImpl.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.elink.esua.epdc.task.analysis; - -import com.elink.esua.epdc.service.ScheduleJobUserService; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Component; - -/** - * @author: qushutong - * @Date: 2020/3/25 10:12 - * @Description: - */ -@Component("UserAnalysisTask") -public class UserAnalysisTaskImpl implements UserAnalysisTask { - @Autowired - private ScheduleJobUserService scheduleJobUserService; - - @Override - public void run(String params) { - scheduleJobUserService.createUserAnalysisData(); - } -} diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/KpiManualScoreTask.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/kpi/KpiManualScoreTask.java similarity index 90% rename from esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/KpiManualScoreTask.java rename to esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/kpi/KpiManualScoreTask.java index 613b2e967..b3be673c6 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/KpiManualScoreTask.java +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/kpi/KpiManualScoreTask.java @@ -1,6 +1,7 @@ -package com.elink.esua.epdc.task; +package com.elink.esua.epdc.task.kpi; import com.elink.esua.epdc.service.ScheduleJobKpiService; +import com.elink.esua.epdc.task.ITask; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/KpiMetaDataTask.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/kpi/KpiMetaDataTask.java similarity index 91% rename from esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/KpiMetaDataTask.java rename to esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/kpi/KpiMetaDataTask.java index 43fd263f7..ce333be77 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/KpiMetaDataTask.java +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/kpi/KpiMetaDataTask.java @@ -1,6 +1,7 @@ -package com.elink.esua.epdc.task; +package com.elink.esua.epdc.task.kpi; import com.elink.esua.epdc.service.ScheduleJobKpiService; +import com.elink.esua.epdc.task.ITask; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/KpiRuleTask.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/kpi/KpiRuleTask.java similarity index 91% rename from esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/KpiRuleTask.java rename to esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/kpi/KpiRuleTask.java index 6c5edf27a..e7b921342 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/KpiRuleTask.java +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/kpi/KpiRuleTask.java @@ -1,6 +1,7 @@ -package com.elink.esua.epdc.task; +package com.elink.esua.epdc.task.kpi; import com.elink.esua.epdc.service.ScheduleJobKpiService; +import com.elink.esua.epdc.task.ITask; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component;