fanli/src/main/java/com/yeshi/fanli/dao/goods/taobao/dataoke/DaTaoKeGoodsDetailV2Dao.java
@@ -160,4 +160,21 @@ return mongoTemplate.find(query, getEntityClass()); } /** * 查询删除更新时间超过一段时间的 * * @param minUpdateTime * @param start * @param count * @return */ public int listAndRemoveByMinUpdateTime(Date minUpdateTime, int start, int count) { Query query = new Query(); query.addCriteria(Criteria.where("updateTime").lt(minUpdateTime)); query.skip(start); query.limit(count); List<DaTaoKeDetailV2> list = mongoTemplate.findAllAndRemove(query, DaTaoKeDetailV2.class); return list.size(); } }