fanli/src/main/java/com/yeshi/fanli/dao/dynamic/DynamicInfoDao.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
fanli/src/main/java/com/yeshi/fanli/job/DynamicInfoJob.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
fanli/src/main/java/com/yeshi/fanli/dao/dynamic/DynamicInfoDao.java
@@ -123,20 +123,24 @@ * @return */ public void removeByDate(Date createTime) { LogHelper.test("removeByDate--开始执行动态删除---"); for(int i = 0; i < 20; i++) { Query query = new Query(); query.addCriteria(Criteria.where("createTime").lt(createTime)); query.skip(0).limit(100); LogHelper.test("removeByDate--查询---"); List<DynamicInfo> list = mongoTemplate.find(query, DynamicInfo.class); if (list == null || list.size() == 0) { break; } LogHelper.test("removeByDate--for删除---" + list.size()); for (DynamicInfo info: list) { mongoTemplate.remove(info); } } LogHelper.test("removeByDate--结束动态删除---"); } fanli/src/main/java/com/yeshi/fanli/job/DynamicInfoJob.java
@@ -149,7 +149,7 @@ /** * 每天零点删除3天之前数据 */ @Scheduled(cron = "0 0 0,10 * * ?") @Scheduled(cron = "0 0 1,10 * * ?") public void remove() { if (!Constant.IS_TASK) { @@ -157,7 +157,7 @@ } try { LogHelper.test("开始执行态删除"); LogHelper.test("DynamicInfoJob-remove-开始执行态"); dynamicInfoService.removeByDate(DateUtil.reduceDay(2, new Date())); } catch (Exception e) { try {