yujian
2020-01-18 f4a0f2acc63d7785eab108419a4e16f5f688cb95
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--结束动态删除---");
   }
   
   
@@ -215,5 +219,22 @@
      return (List<DynamicInfo>) mongoTemplate.findAll(DynamicInfo.class);
   }
   
   /**
    * 查询所有数据
    * @param clazz
    * @return
    */
   public List<DynamicInfo> queryExistsAuctionId() {
      Query query = new Query();
      query.addCriteria(
               new Criteria().andOperator(
                   Criteria.where("imgs.goods").exists(true),
                   Criteria.where("imgs.goods.auctionId").exists(false)
                   )
            );
        List<DynamicInfo> list = mongoTemplate.find(query, DynamicInfo.class);
      return list;
   }
}