diff --git a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/UserFeignClient.java b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/UserFeignClient.java index 975afbe..10d2d9c 100644 --- a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/UserFeignClient.java +++ b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/UserFeignClient.java @@ -45,4 +45,14 @@ public interface UserFeignClient { @PostMapping("app-user/epdc-app/user/updateUserInfo") Result updateUserInfo(UserDTO userDTO); + /** + * 重置积分 + * + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @params [userDTO] + * @author syp + * @since 2019/10/25 17:07 + */ + @PostMapping("app-user/user/resetPoints") + Result resetPoints(); } diff --git a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/fallback/UserFeignClientFallback.java b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/fallback/UserFeignClientFallback.java index d3ab4b7..e68fe4e 100644 --- a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/fallback/UserFeignClientFallback.java +++ b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/fallback/UserFeignClientFallback.java @@ -34,4 +34,8 @@ public class UserFeignClientFallback implements UserFeignClient { public Result updateUserInfo(UserDTO userDTO) { return ModuleUtils.feignConError(ServiceConstant.EPDC_USER_SERVER, "updateUserInfo", userDTO); } + @Override + public Result resetPoints() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_USER_SERVER, "resetPoints"); + } } diff --git a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/user/ScreenUserPointsResetTask.java b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/user/ScreenUserPointsResetTask.java new file mode 100644 index 0000000..deb8679 --- /dev/null +++ b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/user/ScreenUserPointsResetTask.java @@ -0,0 +1,32 @@ +package com.elink.esua.epdc.task.user; + +import com.elink.esua.epdc.feign.UserFeignClient; +import com.elink.esua.epdc.task.ITask; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * 用户积分重置模块 + * + * @Author:liuchuang + * @Date:2020/9/9 15:20 + */ +@Component("screenUserPointsResetTask") +public class ScreenUserPointsResetTask implements ITask { + + private final Logger logger = LoggerFactory.getLogger(getClass()); + + @Autowired + private UserFeignClient userFeignClient; + + @Override + public void run(String param) { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|用户积分季度重置>定时任务开始"); + userFeignClient.resetPoints(); + logger.info("<" + methodName + "|用户积分季度重置>定时任务结束"); + } +}