多系统兼容优化

admin

2020-07-04 9d35ba657fa5e3add766405d76e3ff8c4dcd4ad4

 fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/GoodsEvaluateServiceImpl.java

@@ -1447,7 +1447,6 @@
   }
   
   
	
   @Override
   public void saveComment(String pid, CommentInfo commentInfo) throws GoodsEvaluateException {
      GoodsEvaluate goodsEvaluate = goodsEvaluateDao.getById(pid);
@@ -1565,20 +1564,20 @@

   @Override
   public List<GoodsEvaluate> query(int start, int count, String key, Integer state, int dynamicType,
         String typeEnum) {
      return goodsEvaluateDao.query(start, count, key, state, dynamicType, typeEnum);
                                     String typeEnum, SystemEnum system) {
        return goodsEvaluateDao.query(start, count, key, state, dynamicType, typeEnum, system);
   }

   @Override
   public long count(String key, Integer state, int dynamicType, String typeEnum) {
      return goodsEvaluateDao.count(key, state, dynamicType, typeEnum);
    public long count(String key, Integer state, int dynamicType, String typeEnum, SystemEnum system) {
        return goodsEvaluateDao.count(key, state, dynamicType, typeEnum, system);
   }

   @Override
   public void addRanDomShareCount() {
    public void addRanDomShareCount(SystemEnum system) {
      // 发圈
      try {
         List<GoodsEvaluate> list = goodsEvaluateDao.queryValid(0, Integer.MAX_VALUE, 1);
            List<GoodsEvaluate> list = goodsEvaluateDao.queryValid(0, Integer.MAX_VALUE, 1, system);
         if (list != null) {
            for (GoodsEvaluate goodsEvaluate : list) {
               Integer shareNum = goodsEvaluate.getShareNum();
@@ -1595,7 +1594,7 @@

      // 素材
      try {
         List<GoodsEvaluate> list = goodsEvaluateDao.queryValid(0, Integer.MAX_VALUE, 2);
            List<GoodsEvaluate> list = goodsEvaluateDao.queryValid(0, Integer.MAX_VALUE, 2, system);
         if (list != null) {
            for (GoodsEvaluate goodsEvaluate : list) {
               Integer shareNum = goodsEvaluate.getShareNum();
@@ -1613,8 +1612,8 @@

   @Override
   @Cacheable(value = "dynamicCache", key = "'queryValidEvaluateCache-'+#start")
   public List<GoodsEvaluate> queryValidEvaluateCache(int start, int count) {
      List<GoodsEvaluate> list = goodsEvaluateDao.queryValid(start, count, 1);
    public List<GoodsEvaluate> queryValidEvaluateCache(int start, int count, SystemEnum system) {
        List<GoodsEvaluate> list = goodsEvaluateDao.queryValid(start, count, 1, system);

      // 更新商品信息
      executor.execute(new Runnable() {
@@ -1634,14 +1633,14 @@
   }

   @Override
   public long countValid() {
      return goodsEvaluateDao.countValid(1);
    public long countValid(SystemEnum system) {
        return goodsEvaluateDao.countValid(1, system);
   }

   @Override
   @Cacheable(value = "dynamicCache", key = "'queryMaterialsCache-'+#start+'-'+#type")
   public List<GoodsEvaluate> queryMaterialsCache(int start, int count, int type) throws Exception {
      List<GoodsEvaluate> list = goodsEvaluateDao.queryValid(start, count, type);
    public List<GoodsEvaluate> queryMaterialsCache(int start, int count, int type, SystemEnum system) throws Exception {
        List<GoodsEvaluate> list = goodsEvaluateDao.queryValid(start, count, type, system);
      if (list == null) {
         list = new ArrayList<>();
      }
@@ -1803,8 +1802,8 @@
   }

   @Override
   public long countValidMaterials(int type) {
      return goodsEvaluateDao.countValid(type);
    public long countValidMaterials(int type, SystemEnum system) {
        return goodsEvaluateDao.countValid(type, system);
   }

   /**
@@ -2081,7 +2080,6 @@
   }


	
   @Override
   public int addGoodsEvaluate(TaoBaoGoodsBrief goodsBrief, List<String> imgs, ActivityUser user, String title,SystemEnum system) throws GoodsEvaluateException {
      if (goodsBrief == null || user == null || StringUtil.isNullOrEmpty(title)) {
@@ -2239,7 +2237,7 @@
   @Override
   public void addGoodsEvaluateByDaTaoKe(SystemEnum system) {
      List<Long> listId = null;
      List<GoodsEvaluate> listExist = goodsEvaluateDao.querySingleExist();
        List<GoodsEvaluate> listExist = goodsEvaluateDao.querySingleExist(system);
      if (listExist != null && listExist.size() > 0) {
         listId = new ArrayList<Long>();
         for (GoodsEvaluate goodsEvaluate : listExist) {
@@ -2466,6 +2464,7 @@

   /**
    * 发圈标题 加入表情
     *
    * @param desc
    * @return
    */
@@ -2510,16 +2509,17 @@
         if (goods == null) {
            return;
         }
            for (SystemEnum system : SystemEnum.values()) {
         List<GoodsEvaluate> queryExist = goodsEvaluateDao.queryExist(Constant.SOURCE_TYPE_TAOBAO,
               goods.getAuctionId()+"");
                        goods.getAuctionId() + "", system);
         if (queryExist == null || queryExist.size() == 0) {
            return;
                    continue;
         }

         ConfigParamsDTO paramsDTO = orderHongBaoMoneyComputeService.getShowComputeRate("android", "55");
         paramsDTO.setBaseFanliRate(hongBaoManageService.getBaseFanliRate());
         GoodsDetailVO goodsNew = GoodsDetailVOFactory.convertTaoBao(goods, paramsDTO);
         updateGoods(queryExist, goodsNew);
            }

      } catch (Exception e) {
         e.printStackTrace();
@@ -2531,9 +2531,10 @@
      if (jdGoods == null) {
         return;
      }
      List<GoodsEvaluate> queryExist = goodsEvaluateDao.queryExist(Constant.SOURCE_TYPE_JD, jdGoods.getSkuId()+"");
        for (SystemEnum system : SystemEnum.values()) {
            List<GoodsEvaluate> queryExist = goodsEvaluateDao.queryExist(Constant.SOURCE_TYPE_JD, jdGoods.getSkuId() + "", system);
      if (queryExist == null || queryExist.size() == 0) {
         return;
                continue;
      }

      ConfigParamsDTO paramsDTO = orderHongBaoMoneyComputeService.getShowComputeRate("android", "55");
@@ -2542,15 +2543,17 @@

      updateGoods(queryExist, goodsNew);
   }
    }

   @Override
   public void updatePDDGoods(PDDGoodsDetail pddGoods) {
      if (pddGoods == null) {
         return;
      }
      List<GoodsEvaluate> queryExist = goodsEvaluateDao.queryExist(Constant.SOURCE_TYPE_PDD, pddGoods.getGoodsId()+"");
        for (SystemEnum system : SystemEnum.values()) {
            List<GoodsEvaluate> queryExist = goodsEvaluateDao.queryExist(Constant.SOURCE_TYPE_PDD, pddGoods.getGoodsId() + "", system);
      if (queryExist == null || queryExist.size() == 0) {
         return;
                continue;
      }

      ConfigParamsDTO paramsDTO = orderHongBaoMoneyComputeService.getShowComputeRate("android", "55");
@@ -2558,16 +2561,18 @@
      GoodsDetailVO goodsNew = GoodsDetailVOFactory.convertPDDGoods(pddGoods, paramsDTO);
      updateGoods(queryExist, goodsNew);
   }
    }

   @Override
   public void updateVIPGoods(VIPGoodsInfo goods) {
      if (goods == null) {
         return;
      }
        for (SystemEnum system : SystemEnum.values()) {
      List<GoodsEvaluate> queryExist = goodsEvaluateDao.queryExist(Constant.SOURCE_TYPE_VIP,
            goods.getGoodsId());
                    goods.getGoodsId(), system);
      if (queryExist == null || queryExist.size() == 0) {
         return;
                continue;
      }

      ConfigParamsDTO paramsDTO = orderHongBaoMoneyComputeService.getShowComputeRate("android", "55");
@@ -2575,22 +2580,25 @@
      GoodsDetailVO goodsNew = GoodsDetailVOFactory.convertVIPGoods(goods, paramsDTO);
      updateGoods(queryExist, goodsNew);
   }
    }

   @Override
   public void updateSuningGoods(SuningGoodsInfo goods) {
      if (goods == null) {
         return;
      }
        for (SystemEnum system : SystemEnum.values()) {
      List<GoodsEvaluate> queryExist = goodsEvaluateDao.queryExist(Constant.SOURCE_TYPE_SUNING,
            goods.getCommodityInfo().getCommodityCode());
                    goods.getCommodityInfo().getCommodityCode(), system);
      if (queryExist == null || queryExist.size() == 0) {
         return;
                continue;
      }

      ConfigParamsDTO paramsDTO = orderHongBaoMoneyComputeService.getShowComputeRate("android", "55");
      paramsDTO.setBaseFanliRate(hongBaoManageService.getBaseFanliRate());
      GoodsDetailVO goodsNew = GoodsDetailVOFactory.convertSuningGoods(goods, paramsDTO);
      updateGoods(queryExist, goodsNew);
        }
   }

   private void updateGoods(List<GoodsEvaluate> listExist, GoodsDetailVO goodsNew) {
@@ -2642,13 +2650,15 @@
         if (goodsId == null) {
            return;
         }
         List<GoodsEvaluate> list = goodsEvaluateDao.queryExist(Constant.SOURCE_TYPE_TAOBAO,goodsId);
         if (list == null || list.size() == 0) {
            return;
         }

            for (SystemEnum system : SystemEnum.values()) {
                List<GoodsEvaluate> list = goodsEvaluateDao.queryExist(Constant.SOURCE_TYPE_TAOBAO, goodsId, system);
                if (list == null || list.size() == 0) {
                    continue;
                }
         // 下架商品
         offlineGoods(list, Constant.SOURCE_TYPE_TAOBAO, goodsId);
            }
      } catch (Exception e) {
         e.printStackTrace();
      }
@@ -2738,8 +2748,8 @@

   
   @Override
   public GoodsEvaluate queryExistSingle(String goodsId, int goodsType) {
      List<GoodsEvaluate> list = goodsEvaluateDao.queryExistSingle(goodsType, goodsId);
    public GoodsEvaluate queryExistSingle(String goodsId, int goodsType,SystemEnum system) {
        List<GoodsEvaluate> list = goodsEvaluateDao.queryExistSingle(goodsType, goodsId,system);
      if (list != null && list.size() > 0)
         return list.get(0);
      return null;