blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
admin
2024-10-15 4995469ae28ce99f5e682895c0708d15f4dc63cd 
 fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java


@@ -1,24 +1,9 @@


package com.yeshi.fanli.service.impl.taobao;




import java.math.BigDecimal;


import java.util.ArrayList;


import java.util.Date;


import java.util.HashMap;


import java.util.List;


import java.util.Map;




import javax.annotation.Resource;




import org.springframework.context.annotation.Lazy;


import org.springframework.scheduling.annotation.Async;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import com.google.gson.Gson;


import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoGoodsBriefMapper;


import com.yeshi.fanli.dao.taobao.TaoBaoGoodsUpdateDao;


import com.yeshi.fanli.entity.goods.CommonGoods;


import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;


import com.yeshi.fanli.exception.goods.CommonGoodsException;


import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;


import com.yeshi.fanli.exception.taobao.TaobaoGoodsUpdateException;


@@ -31,11 +16,20 @@


import com.yeshi.fanli.service.inter.taobao.TLJBuyGoodsUpdateService;


import com.yeshi.fanli.service.inter.taobao.TLJFreeBuyGoodsUpdateService;


import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;


import com.yeshi.fanli.util.CMQManager;


import com.yeshi.fanli.util.StringUtil;


import com.yeshi.fanli.util.cache.TaoBaoGoodsCacheUtil;


import com.yeshi.fanli.util.factory.CommonGoodsFactory;


import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;


import com.yeshi.fanli.util.taobao.TaoKeApiUtil;


import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;


import org.springframework.context.annotation.Lazy;


import org.springframework.scheduling.annotation.Async;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import javax.annotation.Resource;


import java.math.BigDecimal;


import java.util.*;




@Service


public class TaoBaoGoodsUpdateServiceImpl implements TaoBaoGoodsUpdateService {


@@ -72,6 +66,9 @@


    @Lazy


    @Resource


    private GoodsEvaluateService goodsEvaluateService;




    @Resource


    private RabbitmqManager rabbitmqManager;




    @Override


    public void startUpdate() {


@@ -330,7 +327,7 @@


        try {


            if (taoBaoGoodsCacheUtil.canAddToUpdateQueue(auctionId)) {


                // 添加到更新队列


                CMQManager.getInstance().addTBImpGoodsUpdate(auctionId);


                rabbitmqManager.addTBImpGoodsUpdate(auctionId);


                taoBaoGoodsCacheUtil.addAddToQueueHistory(auctionId);


            }


        } catch (Exception e) {