用户注销改造

src/main/java/cn/quantgroup/xyqb/controller/internal/user/InnerController.java

@@ -53,6 +53,7 @@ import javax.validation.constraints.Min;
 import javax.validation.constraints.NotNull;
 import java.io.UnsupportedEncodingException;
 import java.text.ParseException;
+import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -1623,13 +1624,13 @@ public class InnerController implements IBaseController {
     }
 
 
-//    /**
-//     * 测试定时删除注销记录
-//     * @return
-//     */
-//    @PostMapping("/user/deleteDeregister")
-//    public JsonResult<?> deleteDeregister() {
-//        userDeregisterService.executeTask();
-//        return JsonResult.buildSuccessResult("用户销户成功1231", true);
-//    }
+    /**
+     * 测试定时删除注销记录
+     * @return
+     */
+    @PostMapping("/user/deleteDeregister")
+    public JsonResult<?> deleteDeregister() {
+        userDeregisterService.executeTask();
+        return JsonResult.buildSuccessResult("用户销户成功1231" , true);
+    }
 }
\ No newline at end of file

src/main/java/cn/quantgroup/xyqb/repository/IUserDeregisterRecordRepository.java

@@ -2,7 +2,9 @@ package cn.quantgroup.xyqb.repository;
 
 import cn.quantgroup.xyqb.entity.UserDeregisterRecord;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.transaction.annotation.Transactional;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -24,5 +26,6 @@ public interface IUserDeregisterRecordRepository extends JpaRepository<UserDereg
     /**
      * 删除注销时间大于90天数据
      */
-//    void deleteByDeregisterTimeIsBefore();
+    @Transactional
+    void deleteByDeregisterTimeIsBefore(Date dt);
 }

src/main/java/cn/quantgroup/xyqb/service/register/IUserDeregisterService.java

@@ -3,6 +3,7 @@ package cn.quantgroup.xyqb.service.register;
 import cn.quantgroup.xyqb.entity.User;
 import cn.quantgroup.xyqb.entity.UserDeregisterRecord;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -28,5 +29,5 @@ public interface IUserDeregisterService {
      */
     void save(User user);
 
-//    void executeTask();
+    void executeTask();
 }

src/main/java/cn/quantgroup/xyqb/service/register/impl/IUserDeregisterServiceImpl.java

@@ -42,19 +42,18 @@ public class IUserDeregisterServiceImpl implements IUserDeregisterService {
 
     }
 
-//    @Override
-//    public void executeTask() {
-//        try {
-//            Date dt = new Date();
-//            System.out.println("Today: "+ dt);
-//            Calendar c = Calendar.getInstance();
-//            c.setTime(dt);
-//            c.add(Calendar.DATE, -90);
-//            dt = c.getTime();
-//            System.out.println("Tomorrow: "+ dt);
-//        } catch (Exception e) {
-//
-//        }
-//
-//    }
+    @Override
+    public void executeTask() {
+        try {
+            Date dt = new Date();
+            Calendar c = Calendar.getInstance();
+            c.setTime(dt);
+            c.add(Calendar.DATE, -90);
+            dt = c.getTime();
+            log.info("执行删除超过90天注销记录--{}", dt);
+            userDeregisterRecordRepository.deleteByDeregisterTimeIsBefore(dt);
+        } catch (Exception e) {
+            log.error("执行删除超过90天注销记录失败--{}", e.getMessage());
+        }
+    }
 }

src/main/java/cn/quantgroup/xyqb/xxlJob/DeregisterTimeJobHandler.java

@@ -19,7 +19,7 @@ public class DeregisterTimeJobHandler extends IJobHandler {
 
     @Override
     public ReturnT<String> execute(String s) throws Exception {
-//        userDeregisterService.executeTask();
+        userDeregisterService.executeTask();
         return SUCCESS;
     }
 }