将CMQ替换为rabbitmq

admin

2024-10-16 62a447d89331aee1feae7724c7616aa1bb2cfe79

 fanli/src/main/java/com/yeshi/fanli/service/impl/brand/BrandClassShopServiceImpl.java

@@ -17,7 +17,7 @@
import org.yeshi.utils.JsonUtil;

import com.yeshi.fanli.dao.mybatis.brand.BrandClassShopMapper;
import com.yeshi.fanli.dto.ConfigParamsDTO;
import com.yeshi.fanli.dto.GoodsMoneyConfigParamsDTO;
import com.yeshi.fanli.entity.brand.BrandClass;
import com.yeshi.fanli.entity.brand.BrandClassShop;
import com.yeshi.fanli.entity.goods.CommonGoods;
@@ -320,7 +320,7 @@
      }

      // 淘宝商品信息过滤
      Map<Long, TaoBaoGoodsBrief> goodsMap = getFilterTaoBaoGoods(listInfo);
      Map<String, TaoBaoGoodsBrief> goodsMap = getFilterTaoBaoGoods(listInfo);

      BigDecimal proportion = hongBaoManageService.getFanLiRate(system);
      for (TaoBaoShopVO taoBaoShopVO : listInfo) {
@@ -360,14 +360,14 @@
    * @param listInfo
    * @return
    */
   private Map<Long, TaoBaoGoodsBrief> getFilterTaoBaoGoods(List<TaoBaoShopVO> listInfo) {
   private Map<String, TaoBaoGoodsBrief> getFilterTaoBaoGoods(List<TaoBaoShopVO> listInfo) {
      // 过滤商品
      List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();
      for (TaoBaoShopVO taoBaoShopVO : listInfo) {
         goodsList.addAll(taoBaoShopVO.getListGoodsBrief());
      }
      goodsList = taoBaoGoodsUpdateService.filterImportantTaoBaoGoods(goodsList);
      Map<Long, TaoBaoGoodsBrief> goodsMap = new HashMap<>();
      Map<String, TaoBaoGoodsBrief> goodsMap = new HashMap<>();
      for (TaoBaoGoodsBrief goods : goodsList)
         goodsMap.put(goods.getAuctionId(), goods);
      return goodsMap;
@@ -382,7 +382,7 @@
         cid = null;
      }

      List<TaoBaoShop> listShop = new ArrayList<TaoBaoShop>();
      List<TaoBaoShop> listShop = new ArrayList<>();
      // 第一页 查询全部分类下店铺
      if (page == 1 && cid != null) {
         List<BrandClassShop> list = brandClassShopMapper.listEffective(cid,system);
@@ -436,10 +436,10 @@
         count = taoBaoShopService.countBrandShopinfo(cid);
      }

      ConfigParamsDTO paramsDTO =    orderHongBaoMoneyComputeService.getShowComputeRate(platform, version,system);
      GoodsMoneyConfigParamsDTO paramsDTO =    orderHongBaoMoneyComputeService.getShowComputeRate(platform, version,system);

      // 淘宝商品信息过滤
      Map<Long, TaoBaoGoodsBrief> goodsMap = getFilterTaoBaoGoods(listInfo);
      Map<String, TaoBaoGoodsBrief> goodsMap = getFilterTaoBaoGoods(listInfo);

      for (TaoBaoShopVO taoBaoShopVO : listInfo) {

@@ -509,7 +509,7 @@
            sf.setKey(shop.getShop().getShopName().replace("官方旗舰店", "").replace("旗舰店", ""));
            sf.setPage(1);
            sf.setPageSize(100);
            TaoBaoSearchResult result = TaoKeApiUtil.searchWuLiao(sf,null,null);
            TaoBaoSearchResult result = TaoKeApiUtil.searchWuLiaoNew(sf,null,null);
            List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();
            if (result != null && result.getTaoBaoGoodsBriefs() != null)
               for (TaoBaoGoodsBrief goods : result.getTaoBaoGoodsBriefs()) {
@@ -541,10 +541,10 @@
         return listInfo;
      

      ConfigParamsDTO paramsDTO = 
      GoodsMoneyConfigParamsDTO paramsDTO =
            orderHongBaoMoneyComputeService.getShowComputeRate(platform, version,system);
      // 淘宝商品信息过滤
      Map<Long, TaoBaoGoodsBrief> goodsMap = getFilterTaoBaoGoods(listInfo);
      Map<String, TaoBaoGoodsBrief> goodsMap = getFilterTaoBaoGoods(listInfo);

      for (TaoBaoShopVO taoBaoShopVO : listInfo) {
         String shopNameCustom = taoBaoShopVO.getShopNameCustom();