admin
2019-07-30 573c491b4a1ba60e12a5678a01c1546c0077c1ee
fanli/src/main/java/com/yeshi/fanli/dao/dynamic/DynamicInfoDao.java
@@ -13,6 +13,7 @@
import org.springframework.stereotype.Repository;
import com.yeshi.fanli.entity.dynamic.DynamicInfo;
import com.yeshi.fanli.log.LogHelper;
@Repository
public class DynamicInfoDao  {
@@ -63,9 +64,16 @@
      Query query = new Query();
      query.addCriteria(Criteria.where("id").is(record.getId()));
      
      // 更新分享次数
      Update update = Update.update("imgs", record.getImgs()).set("desc", record.getDesc());
      mongoTemplate.updateMulti(query, update, DynamicInfo.class);
      if (record.getClassId() == 1) {
         Update update = Update.update("imgs", record.getImgs()).set("desc", record.getDesc());
         mongoTemplate.updateMulti(query, update, DynamicInfo.class);
      } else {
         Update update = Update.update("imgs", record.getImgs());
         mongoTemplate.updateMulti(query, update, DynamicInfo.class);
      }
   }
   
   /**
@@ -115,17 +123,25 @@
    * @return
    */
   public void removeByDate(Date createTime) {
      Query query = new Query();
        query.addCriteria(Criteria.where("createTime").lt(createTime));
        query.addCriteria(
               new Criteria().andOperator(
                   Criteria.where("createTime").lt(createTime),
                   Criteria.where("classId").ne(4L)
                   )
            );
      mongoTemplate.remove(query);
      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--结束动态删除---");
   }
   
   
   /**