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

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

@@ -5,6 +5,7 @@ import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.sql.Timestamp;
 import java.util.Date;
 
 /**
@@ -12,6 +13,6 @@ import java.util.Date;
  */
 public interface IGeetestLogRepository extends JpaRepository<GeetestLogEntity, Long>, JpaSpecificationExecutor<GeetestLogEntity> {
 
-    @Transactional
-    void deleteByCreatedAtIsBefore(Date dt);
+    @Transactional(rollbackFor = Exception.class)
+    void deleteByCreatedAtIsBefore(Timestamp dt);
 }

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

@@ -8,8 +8,10 @@ import cn.quantgroup.xyqb.service.captcha.IGeetestLogService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
+import java.sql.Timestamp;
 import java.text.SimpleDateFormat;
 import java.util.Calendar;
 import java.util.Date;
@@ -78,8 +80,10 @@ public class GeetestLogServiceImpl implements IGeetestLogService {
             c.setTime(dt);
             c.add(Calendar.DATE, -180);
             dt = c.getTime();
-            log.info("执行删除超过180天的极验即日记录--{}", dt);
-            geetestLogRepository.deleteByCreatedAtIsBefore(dt);
+
+            log.info("执行删除超过180天的极验日志记录--{}", dt);
+            Timestamp ts=new Timestamp(dt.getTime());
+            geetestLogRepository.deleteByCreatedAtIsBefore(ts);
         } catch (Exception e) {
             log.error("执行删除超过180天的极验即日记录--{}", e.getMessage());
         }