Browse Source

Merge remote-tracking branch 'origin/feature/pointsReset'

master
liuchuang 4 years ago
parent
commit
8c887a05bc
  1. 10
      epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/UserFeignClient.java
  2. 4
      epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/fallback/UserFeignClientFallback.java
  3. 32
      epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/user/ScreenUserPointsResetTask.java

10
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();
}

4
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");
}
}

32
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;
/**
* 用户积分重置模块
*
* @Authorliuchuang
* @Date2020/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 + "|用户积分季度重置>定时任务结束");
}
}
Loading…
Cancel
Save