From 51a4ff5d777028d52a19c314a99f796334cb7b51 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期六, 23 十一月 2019 18:30:01 +0800 Subject: [PATCH] 配置文件修改 --- fanli/src/main/java/com/yeshi/fanli/dao/taobao/TLJBuyGoodsDao.java | 25 ++++++++++++++++++++++++- 1 files changed, 24 insertions(+), 1 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/dao/taobao/TLJBuyGoodsDao.java b/fanli/src/main/java/com/yeshi/fanli/dao/taobao/TLJBuyGoodsDao.java index 51b2403..173cfca 100644 --- a/fanli/src/main/java/com/yeshi/fanli/dao/taobao/TLJBuyGoodsDao.java +++ b/fanli/src/main/java/com/yeshi/fanli/dao/taobao/TLJBuyGoodsDao.java @@ -13,13 +13,24 @@ @Repository public class TLJBuyGoodsDao extends MongodbBaseDao<TLJBuyGoods> { - public List<TLJBuyGoods> listByDayOrderByUpdateTime(String day, int page, int pageSize) { + public List<TLJBuyGoods> listByDayOrderByUpdateTime(String appKey, String day, int page, int pageSize) { Query query = new Query(); Criteria ca = Criteria.where("day").is(day); + if (appKey != null) + ca = ca.and("appKey").is(appKey); query.addCriteria(ca); query.limit(pageSize); query.skip((page - 1) * pageSize).with(new Sort(Sort.Direction.DESC, "updateTime")); return mongoTemplate.find(query, TLJBuyGoods.class); + } + + public long countByDayAndAppKey(String appKey, String day) { + Query query = new Query(); + Criteria ca = Criteria.where("day").is(day); + if (appKey != null) + ca = ca.and("appKey").is(appKey); + query.addCriteria(ca); + return mongoTemplate.count(query, TLJBuyGoods.class); } public void deleteByGoodsId(Long goodsId) { @@ -45,6 +56,18 @@ } /** + * 鏍规嵁鍟嗗搧ID鍒犻櫎 + * + * @param auctionId + */ + public void deleteByAuctionId(Long auctionId) { + Query query = new Query(); + Criteria ca = Criteria.where("goods.auctionId").is(auctionId); + query.addCriteria(ca); + mongoTemplate.findAndRemove(query, TLJBuyGoods.class); + } + + /** * 鍑忕孩鍖呬釜鏁� * * @param id -- Gitblit v1.8.0