diff --git a/epmet-module/epmet-job/epmet-job-server/pom.xml b/epmet-module/epmet-job/epmet-job-server/pom.xml index 16bcd6516e..3e887eeb7a 100644 --- a/epmet-module/epmet-job/epmet-job-server/pom.xml +++ b/epmet-module/epmet-job/epmet-job-server/pom.xml @@ -33,6 +33,11 @@ data-statistical-client 2.0.0 + + com.epmet + epmet-third-client + 2.0.0 + org.springframework.boot spring-boot-starter-web diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/ComponentAccessTokenService.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/ComponentAccessTokenService.java new file mode 100644 index 0000000000..197bb6d59d --- /dev/null +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/ComponentAccessTokenService.java @@ -0,0 +1,13 @@ +package com.epmet.service; + +import com.epmet.commons.tools.utils.Result; + +/** + * @Author zxc + * @CreateTime 2020/7/20 10:21 + */ +public interface ComponentAccessTokenService { + + Result componentAccessTokenJob(); + +} diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/RefreshAuthAccessTokenService.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/RefreshAuthAccessTokenService.java new file mode 100644 index 0000000000..9a460f0ceb --- /dev/null +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/RefreshAuthAccessTokenService.java @@ -0,0 +1,13 @@ +package com.epmet.service; + +import com.epmet.commons.tools.utils.Result; + +/** + * @Author zxc + * @CreateTime 2020/7/20 10:44 + */ +public interface RefreshAuthAccessTokenService { + + Result refreshAuthorizerAccessTokenJob(); + +} diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/ComponentAccessTokenServiceImpl.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/ComponentAccessTokenServiceImpl.java new file mode 100644 index 0000000000..dbf0375a29 --- /dev/null +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/ComponentAccessTokenServiceImpl.java @@ -0,0 +1,25 @@ +package com.epmet.service.impl; + +import com.epmet.commons.tools.utils.Result; +import com.epmet.feign.EpmetThirdFeignClient; +import com.epmet.service.ComponentAccessTokenService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +/** + * @Author zxc + * @CreateTime 2020/7/20 10:22 + */ +@Slf4j +@Service +public class ComponentAccessTokenServiceImpl implements ComponentAccessTokenService { + + @Autowired + private EpmetThirdFeignClient epmetThirdFeignClient; + + @Override + public Result componentAccessTokenJob() { + return epmetThirdFeignClient.getComponentAccessTokenJob(); + } +} diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/RefreshAuthAccessTokenServiceImpl.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/RefreshAuthAccessTokenServiceImpl.java new file mode 100644 index 0000000000..5edb9725a2 --- /dev/null +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/RefreshAuthAccessTokenServiceImpl.java @@ -0,0 +1,23 @@ +package com.epmet.service.impl; + +import com.epmet.commons.tools.utils.Result; +import com.epmet.feign.EpmetThirdFeignClient; +import com.epmet.service.RefreshAuthAccessTokenService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +/** + * @Author zxc + * @CreateTime 2020/7/20 10:44 + */ +@Service +public class RefreshAuthAccessTokenServiceImpl implements RefreshAuthAccessTokenService { + + @Autowired + private EpmetThirdFeignClient epmetThirdFeignClient; + + @Override + public Result refreshAuthorizerAccessTokenJob() { + return epmetThirdFeignClient.refreshAuthorizerAccessTokenJob(); + } +} diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/ComponentAccessTokenTask.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/ComponentAccessTokenTask.java new file mode 100644 index 0000000000..1ae759af83 --- /dev/null +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/ComponentAccessTokenTask.java @@ -0,0 +1,34 @@ +package com.epmet.task; + +import com.epmet.commons.tools.utils.Result; +import com.epmet.service.ComponentAccessTokenService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + + +/** + * @Author zxc + * @CreateTime 2020/7/20 10:28 + */ +@Component("componentAccessToken") +public class ComponentAccessTokenTask implements ITask{ + + @Autowired + private ComponentAccessTokenService componentAccessTokenService; + + private Logger logger = LoggerFactory.getLogger(getClass()); + + + @Override + public void run(String params) { + logger.info("ComponentAccessTokenTask正在执行定时任务,参数为{}",params); + Result result = componentAccessTokenService.componentAccessTokenJob(); + if (result.success()){ + logger.info("ComponentAccessTokenTask定时任务执行成功"); + }else { + logger.error("ComponentAccessTokenTask定时任务执行失败:" + result.getMsg()); + } + } +} diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/RefreshAuthAccessTokenTask.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/RefreshAuthAccessTokenTask.java new file mode 100644 index 0000000000..40033447b2 --- /dev/null +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/RefreshAuthAccessTokenTask.java @@ -0,0 +1,32 @@ +package com.epmet.task; + +import com.epmet.commons.tools.utils.Result; +import com.epmet.service.RefreshAuthAccessTokenService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * @Author zxc + * @CreateTime 2020/7/20 10:46 + */ +@Component("refreshAuthAccessTokenTask") +public class RefreshAuthAccessTokenTask implements ITask { + + private Logger logger = LoggerFactory.getLogger(getClass()); + + @Autowired + private RefreshAuthAccessTokenService refreshAuthAccessTokenService; + + @Override + public void run(String params) { + logger.info("RefreshAuthAccessTokenTask正在执行定时任务,参数为{}",params); + Result result = refreshAuthAccessTokenService.refreshAuthorizerAccessTokenJob(); + if (result.success()){ + logger.info("RefreshAuthAccessTokenTask定时任务执行成功"); + }else { + logger.error("RefreshAuthAccessTokenTask定时任务执行失败:" + result.getMsg()); + } + } +} diff --git a/epmet-module/epmet-third/epmet-third-client/src/main/java/com/epmet/feign/EpmetThirdFeignClient.java b/epmet-module/epmet-third/epmet-third-client/src/main/java/com/epmet/feign/EpmetThirdFeignClient.java index 996a70e9b2..b73e33cb7d 100644 --- a/epmet-module/epmet-third/epmet-third-client/src/main/java/com/epmet/feign/EpmetThirdFeignClient.java +++ b/epmet-module/epmet-third/epmet-third-client/src/main/java/com/epmet/feign/EpmetThirdFeignClient.java @@ -68,4 +68,20 @@ public interface EpmetThirdFeignClient { **/ @PostMapping(value = "third/pacustomer/updatecustomer/{customerId}") Result updateCustomer(@PathVariable("customerId") String customerId); + + /** + * @Description 获取【component_access_token】的定时任务 15min/次 + * @param + * @author zxc + */ + @PostMapping(value = "third/wechatthird/componentaccesstoken") + Result getComponentAccessTokenJob(); + + /** + * @Description 获取/刷新接口调用令牌 15min/次 + * @param + * @author zxc + */ + @PostMapping(value = "third/wechatthird/refreshtoken") + Result refreshAuthorizerAccessTokenJob(); } diff --git a/epmet-module/epmet-third/epmet-third-client/src/main/java/com/epmet/feign/fallback/EpmetThirdFeignClientFallback.java b/epmet-module/epmet-third/epmet-third-client/src/main/java/com/epmet/feign/fallback/EpmetThirdFeignClientFallback.java index a1b0cd0ace..0a08750106 100644 --- a/epmet-module/epmet-third/epmet-third-client/src/main/java/com/epmet/feign/fallback/EpmetThirdFeignClientFallback.java +++ b/epmet-module/epmet-third/epmet-third-client/src/main/java/com/epmet/feign/fallback/EpmetThirdFeignClientFallback.java @@ -42,4 +42,14 @@ public class EpmetThirdFeignClientFallback implements EpmetThirdFeignClient { public Result updateCustomer(String customerId) { return ModuleUtils.feignConError(ServiceConstant.EPMET_THIRD_SERVER, "updateCustomer", customerId); } + + @Override + public Result getComponentAccessTokenJob() { + return ModuleUtils.feignConError(ServiceConstant.EPMET_THIRD_SERVER, "getComponentAccessTokenJob"); + } + + @Override + public Result refreshAuthorizerAccessTokenJob() { + return ModuleUtils.feignConError(ServiceConstant.EPMET_THIRD_SERVER, "refreshAuthorizerAccessTokenJob"); + } }