From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 25 二月 2025 16:41:22 +0800
Subject: [PATCH] 淘宝转链接口更新
---
fanli/src/main/java/com/yeshi/fanli/dao/taobao/TaoBaoGoodsUpdateDao.java | 190 ++++++++++++++++++++++++-----------------------
1 files changed, 96 insertions(+), 94 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/dao/taobao/TaoBaoGoodsUpdateDao.java b/fanli/src/main/java/com/yeshi/fanli/dao/taobao/TaoBaoGoodsUpdateDao.java
index 214fa9f..bfcc07f 100644
--- a/fanli/src/main/java/com/yeshi/fanli/dao/taobao/TaoBaoGoodsUpdateDao.java
+++ b/fanli/src/main/java/com/yeshi/fanli/dao/taobao/TaoBaoGoodsUpdateDao.java
@@ -1,94 +1,96 @@
-package com.yeshi.fanli.dao.taobao;
-
-import java.util.Date;
-import java.util.List;
-
-import org.springframework.data.mongodb.core.query.Criteria;
-import org.springframework.data.mongodb.core.query.Query;
-import org.springframework.stereotype.Repository;
-
-import com.mongodb.BasicDBObject;
-import com.yeshi.fanli.dao.MongodbBaseDao;
-import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
-
-@Repository
-public class TaoBaoGoodsUpdateDao extends MongodbBaseDao<TaoBaoGoodsBrief> {
-
- /**
- * 鏍规嵁鍟嗗搧ID鍒犻櫎
- *
- * @param auctionid
- */
- public void deleteByAuctionId(Long auctionid) {
- Query query = new Query();
- Criteria ca = Criteria.where("auctionId").is(auctionid);
- query.addCriteria(ca);
- mongoTemplate.remove(query, TaoBaoGoodsBrief.class);
- }
-
- /**
- * 鏍规嵁鍟嗗搧ID鑾峰彇
- *
- * @param auctionid
- * @return
- */
- public TaoBaoGoodsBrief selectByAuctionId(Long auctionid) {
- Query query = new Query();
- Criteria ca = Criteria.where("auctionId").is(auctionid);
- query.addCriteria(ca);
- return mongoTemplate.findOne(query, TaoBaoGoodsBrief.class);
- }
-
- /**
- * 鎵归噺鏌ヨ
- *
- * @param auctionIds
- * @return
- */
- public List<TaoBaoGoodsBrief> listByAuctionIds(List<Long> auctionIds) {
- if (auctionIds == null || auctionIds.size() == 0)
- return null;
- Query query = new Query();
- Criteria ca = new Criteria();
- Criteria[] cas = new Criteria[auctionIds.size()];
- for (int i = 0; i < auctionIds.size(); i++) {
- cas[i] = Criteria.where("auctionId").is(auctionIds.get(i));
- }
- query.addCriteria(ca.orOperator(cas));
- return mongoTemplate.find(query, TaoBaoGoodsBrief.class);
- }
-
- /**
- * 鏌ヨ鍒犻櫎鏁版嵁
- *
- * @param date
- * @param start
- * @param count
- * @return
- */
- public int listAndRemoveByMaxUpdateTime(Date date, int start, int count) {
- BasicDBObject fieldsObject = new BasicDBObject();
- fieldsObject.put("auctionId", 1);
- Query query = new Query();
- Criteria ca = Criteria.where("updatetime").lt(date);
- query.skip(start);
- query.limit(count);
- query.addCriteria(ca);
- List<TaoBaoGoodsBrief> goodsList = mongoTemplate.findAllAndRemove(query, TaoBaoGoodsBrief.class);
- return goodsList.size();
- }
-
- /**
- * 鏍规嵁鏈�澶ф洿鏂版椂闂磋幏鍙栨暟鎹潯鏁�
- *
- * @param date
- * @return
- */
- public long countByMaxUpdateTime(Date date) {
- Query query = new Query();
- Criteria ca = Criteria.where("updatetime").lt(date);
- query.addCriteria(ca);
- return mongoTemplate.count(query, TaoBaoGoodsBrief.class);
- }
-
-}
+package com.yeshi.fanli.dao.taobao;
+
+import java.util.Date;
+import java.util.List;
+
+import com.yeshi.fanli.util.taobao.TaoBaoUtil;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.stereotype.Repository;
+
+import com.mongodb.BasicDBObject;
+import com.yeshi.common.MongodbBaseDao;
+import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;
+
+@Repository
+public class TaoBaoGoodsUpdateDao extends MongodbBaseDao<TaoBaoGoodsBrief> {
+
+ /**
+ * 鏍规嵁鍟嗗搧ID鍒犻櫎
+ *
+ * @param auctionId
+ */
+ public void deleteByAuctionId(String auctionId) {
+ Query query = new Query();
+ query.addCriteria(TaoBaoUtil.getAuctionIdEqualCriteria("goodsId",auctionId));
+ mongoTemplate.remove(query, TaoBaoGoodsBrief.class);
+ }
+
+ /**
+ * 鏍规嵁鍟嗗搧ID鑾峰彇
+ *
+ * @param auctionid
+ * @return
+ */
+ public TaoBaoGoodsBrief selectByAuctionId(String auctionId) {
+ Query query = new Query();
+ query.addCriteria(TaoBaoUtil.getAuctionIdEqualCriteria("auctionId",auctionId));
+
+
+ return mongoTemplate.findOne(query, TaoBaoGoodsBrief.class);
+ }
+
+ /**
+ * 鎵归噺鏌ヨ
+ *
+ * @param auctionIds
+ * @return
+ */
+ public List<TaoBaoGoodsBrief> listByAuctionIds(List<String> auctionIds) {
+ if (auctionIds == null || auctionIds.size() == 0)
+ return null;
+ Query query = new Query();
+ Criteria ca = new Criteria();
+ Criteria[] cas = new Criteria[auctionIds.size()];
+ for (int i = 0; i < auctionIds.size(); i++) {
+ cas[i] = TaoBaoUtil.getAuctionIdEqualCriteria("auctionId", auctionIds.get(i));
+ }
+ query.addCriteria(ca.orOperator(cas));
+ return mongoTemplate.find(query, TaoBaoGoodsBrief.class);
+ }
+
+ /**
+ * 鏌ヨ鍒犻櫎鏁版嵁
+ *
+ * @param date
+ * @param start
+ * @param count
+ * @return
+ */
+ public int listAndRemoveByMaxUpdateTime(Date date, int start, int count) {
+ BasicDBObject fieldsObject = new BasicDBObject();
+ fieldsObject.put("auctionId", 1);
+ Query query = new Query();
+ // 鏃跺尯闂锛岄渶鍔�8灏忔椂
+ Criteria ca = Criteria.where("updatetime").lt(new Date(date.getTime() + 1000 * 60 * 60 * 8L));
+ query.skip(start);
+ query.limit(count);
+ query.addCriteria(ca);
+ List<TaoBaoGoodsBrief> goodsList = mongoTemplate.findAllAndRemove(query, TaoBaoGoodsBrief.class);
+ return goodsList.size();
+ }
+
+ /**
+ * 鏍规嵁鏈�澶ф洿鏂版椂闂磋幏鍙栨暟鎹潯鏁�
+ *
+ * @param date
+ * @return
+ */
+ public long countByMaxUpdateTime(Date date) {
+ Query query = new Query();
+ Criteria ca = Criteria.where("updatetime").lt(date);
+ query.addCriteria(ca);
+ return mongoTemplate.count(query, TaoBaoGoodsBrief.class);
+ }
+
+}
--
Gitblit v1.8.0