yujian
2019-06-28 c097060a6b55204e7d2fc20774be0a0beaa7a8fb
打印动态删除日志
2个文件已修改
10 ■■■■ 已修改文件
fanli/src/main/java/com/yeshi/fanli/dao/dynamic/DynamicInfoDao.java 6 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
fanli/src/main/java/com/yeshi/fanli/job/DynamicInfoJob.java 4 ●●●● 补丁 | 查看 | 原始文档 | 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 {