动态删除3天之前数据

yujian

2019-06-27 c8112d757b901efc582633e49423c81482555ea9

动态删除3天之前数据

 fanli/src/main/java/com/yeshi/fanli/dao/dynamic/DynamicInfoDao.java

@@ -123,19 +123,20 @@
     * @return

     */

    public void removeByDate(Date createTime) {

        Query query = new Query();

        query.addCriteria(Criteria.where("createTime").lt(createTime));

        
        List<DynamicInfo> list = mongoTemplate.find(query, DynamicInfo.class);

        if (list == null || list.size() == 0) {

            return;

        }

        
        for (DynamicInfo info: list) {

            mongoTemplate.remove(info);

        }

        
        LogHelper.test("已执行完成动态删除");

        for(int i = 0; i < 20; i++) {

            Query query = new Query();

            query.addCriteria(Criteria.where("createTime").lt(createTime));

            query.skip(0).limit(100);

	        
            List<DynamicInfo> list = mongoTemplate.find(query, DynamicInfo.class);

            if (list == null || list.size() == 0) {

                break;

            }

	        
            for (DynamicInfo info: list) {

                mongoTemplate.remove(info);

            }

        }

    }

    

    


 fanli/src/main/java/com/yeshi/fanli/job/DynamicInfoJob.java

@@ -158,7 +158,7 @@
        

        try {

            LogHelper.test("开始执行态删除");

            dynamicInfoService.removeByDate(DateUtil.reduceDay(3, new Date()));

            dynamicInfoService.removeByDate(DateUtil.reduceDay(2, new Date()));

        } catch (Exception e) {

            try {

                LogHelper.errorDetailInfo(e);