淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
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);
    }
 
}