From 381e42e1c835aa57590fe0566423373e06ce0e46 Mon Sep 17 00:00:00 2001
From: zhangyongzhangyong <2012005003@qq.com>
Date: Sat, 12 Feb 2022 17:14:40 +0800
Subject: [PATCH] =?UTF-8?q?=E7=A7=AF=E5=88=86=E9=87=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../esua/epdc/feign/UserFeignClient.java      | 10 ++++++
 .../fallback/UserFeignClientFallback.java     |  4 +++
 .../task/user/ScreenUserPointsResetTask.java  | 32 +++++++++++++++++++
 3 files changed, 46 insertions(+)
 create mode 100644 epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/user/ScreenUserPointsResetTask.java

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 + "|用户积分季度重置>定时任务结束");
+    }
+}