From f4a0f2acc63d7785eab108419a4e16f5f688cb95 Mon Sep 17 00:00:00 2001 From: yujian <yujian@163.com> Date: 星期六, 18 一月 2020 12:06:27 +0800 Subject: [PATCH] 用户注册信息 --- fanli/src/main/java/com/yeshi/fanli/dao/taobao/TLJBuyGoodsDao.java | 26 ++++++++++++++++++++++++-- 1 files changed, 24 insertions(+), 2 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 5bb02f2..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 @@ -12,15 +12,25 @@ @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) { @@ -46,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