添加任务删除超过180天的极验日志

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

@@ -3,9 +3,15 @@ package cn.quantgroup.xyqb.repository;
 import cn.quantgroup.xyqb.entity.GeetestLogEntity;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Date;
 
 /**
  * Created by 11 on 2016/12/30.
  */
 public interface IGeetestLogRepository extends JpaRepository<GeetestLogEntity, Long>, JpaSpecificationExecutor<GeetestLogEntity> {
+
+    @Transactional
+    void deleteByCreatedAtIsBefore(Date dt);
 }

src/main/java/cn/quantgroup/xyqb/service/captcha/IGeetestLogService.java

@@ -12,4 +12,6 @@ public interface IGeetestLogService {
     void updateGeetestLog(String geetestLogId, String initializeDt, String registerDt, String registerReDt, Map<String, Object> result);
 
     void updateByUidGeetestLog(Long geetestLogId, Long id);
+
+    void executeTask();
 }

src/main/java/cn/quantgroup/xyqb/service/captcha/impl/GeetestLogServiceImpl.java

@@ -11,6 +11,7 @@ import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
 import java.text.SimpleDateFormat;
+import java.util.Calendar;
 import java.util.Date;
 import java.util.Map;
 
@@ -69,4 +70,19 @@ public class GeetestLogServiceImpl implements IGeetestLogService {
         }
     }
 
+    @Override
+    public void executeTask() {
+        try {
+            Date dt = new Date();
+            Calendar c = Calendar.getInstance();
+            c.setTime(dt);
+            c.add(Calendar.DATE, -180);
+            dt = c.getTime();
+            log.info("执行删除超过180天的极验即日记录--{}", dt);
+            geetestLogRepository.deleteByCreatedAtIsBefore(dt);
+        } catch (Exception e) {
+            log.error("执行删除超过180天的极验即日记录--{}", e.getMessage());
+        }
+    }
+
 }

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

+package cn.quantgroup.xyqb.xxlJob;
+
+import cn.quantgroup.xyqb.service.captcha.IGeetestLogService;
+import cn.quantgroup.xyqb.service.register.IUserDeregisterService;
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.IJobHandler;
+import com.xxl.job.core.handler.annotation.JobHandler;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * 删除极验验证时间大于180天的记录
+ */
+@Component
+@JobHandler(value = "GeetestLogTimeJobHandler")
+public class GeetestLogTimeJobHandler extends IJobHandler {
+    @Autowired
+    private IGeetestLogService geetestLogService;
+
+    @Override
+    public ReturnT<String> execute(String s) throws Exception {
+        geetestLogService.executeTask();
+        return SUCCESS;
+    }
+}