yujian
2019-12-19 626d711cb15896055c13fe344eb7fcc824589715
fanli/src/main/java/com/yeshi/fanli/controller/client/v2/SearchControllerV2.java
@@ -23,6 +23,7 @@
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.yeshi.fanli.dto.ConfigParamsDTO;
import com.yeshi.fanli.dto.douyin.DouYinGoods;
import com.yeshi.fanli.dto.jd.JDFilter;
import com.yeshi.fanli.dto.jd.JDSearchFilter;
@@ -40,6 +41,7 @@
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
import com.yeshi.fanli.exception.user.TokenRecordException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.brand.BrandInfoService;
import com.yeshi.fanli.service.inter.config.BusinessSystemService;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.config.SuperHotSearchService;
@@ -127,6 +129,11 @@
   @Resource
   private IntegralGetCacheManager integralGetCacheManager;
   @Resource
   private BrandInfoService brandInfoService;
   /**
    * 粘贴板信息推荐
@@ -146,7 +153,7 @@
      text = text.trim();
      try {
         TokenVO tokenVO = tokenRecordService.discernToken(text, uid);
         TokenVO tokenVO = tokenRecordService.discernToken(text, uid, acceptData);
         out.print(JsonUtil.loadTrueResult(tokenVO));
         return;
      } catch (TokenRecordException e) {
@@ -182,7 +189,10 @@
         if (analysisTaoToken(acceptData, text, out)) {
            return;
         }
         if (!StringUtil.isNullOrEmpty(TaoBaoUtil.parseSystemTaoToken(text))) {
            out.print(JsonUtil.loadFalseResult("不支持推荐"));
            return;
         }
         JSONObject root = new JSONObject();
         root.put("type", 2);
         JSONObject data = new JSONObject();
@@ -219,7 +229,7 @@
         tb = TaoBaoUtil.isAlimama(id);
         if (tb == null) {
            type = 4;
            tb = TaoBaoUtil.getTmallGoodsInfo(id);
            tb = getTaoBaoGoodsBriefFromGoodsId(id);
         }
      } else if (text.contains("http://zmnxbc.com")) { // 手机端天猫APP分享
         tb = TaoBaoUtil.parsePhoneShareUrlByTM(text);
@@ -231,20 +241,47 @@
         tb = TaoBaoUtil.isAlimama(id);
         if (tb == null) {
            type = 4;
            tb = TaoBaoUtil.getTmallGoodsInfo(id);
            tb = getTaoBaoGoodsBriefFromGoodsId(id);
         }
      } else if (text.contains("v.douyin.com")) { // 抖音
         analysisDouYin(acceptData, text, out);
         return;
      } else {
         tb = TaoBaoUtil.parsePhoneShareUrlByTB(text);
         if (tb == null) {
            String goodsId = TaoBaoUtil.getGoodsIdByPhoneShareUrl(text);
            if (!StringUtil.isNullOrEmpty(goodsId)) {
               tb = getTaoBaoGoodsBriefFromGoodsId(goodsId);
               if (tb != null)
                  type = 4;
            }
         }
         if (tb == null)// 淘宝是空值
         {
            String jdId = JDUtil.getJDGoodsId(text);
            // 微信链接
            if (StringUtil.isNullOrEmpty(jdId)) {
               jdId = JDUtil.getJDGoodsIdByWeiXin(text);
            }
            // 领券短连接
            if (StringUtil.isNullOrEmpty(jdId) && text.contains("u.jd.com")) {
               jdId = JDUtil.getJDGoodsIdByUJD(text);
            }
            if (!StringUtil.isNullOrEmpty(jdId)) {
               JDGoods goods = JDApiUtil.getGoodsDetail(Long.parseLong(jdId));
               if (goods != null) {
                  commonGoods = CommonGoodsFactory.create(goods);
                  // 高级接口 -- 信息更完整
                  JDGoods jdGoods = JDApiUtil.queryGoodsDetail(Long.parseLong(jdId));
                  if (jdGoods != null) {
                     commonGoods = CommonGoodsFactory.create(jdGoods);
                  } else {
                     commonGoods = CommonGoodsFactory.create(goods);
                  }
               } else {
                  type = 4;
                  goods = JDUtil.getSimpleGoodsInfo(jdId);
@@ -263,7 +300,7 @@
                  } else {
                     type = 4;
                     goods = PinDuoDuoUtil.getPDDGoodsInfo(pddId);
                     if(goods != null) {
                     if (goods != null) {
                        commonGoods = new CommonGoods();
                        commonGoods.setTitle(goods.getGoodsName());
                        commonGoods.setPicture(goods.getGoodsThumbnailUrl());
@@ -273,42 +310,42 @@
            }
         }
      }
      if (tb == null && commonGoods == null) {
         out.println(JsonUtil.loadFalseResult("暂未找到该商品,请稍后再试!"));
         return;
      }
      if (type == 4) {
         if (!VersionUtil.greaterThan_2_0_1(acceptData.getPlatform(), acceptData.getVersion())) {
            out.println(JsonUtil.loadFalseResult("暂未找到该商品,请稍后再试!"));
            return;
         }
         }
         JSONObject data = new JSONObject();
         if (tb != null) {
            commonGoods = new CommonGoods();
            commonGoods.setTitle(tb.getTitle());
            commonGoods.setPicture(tb.getPictUrl());
         }
         if (StringUtil.isNullOrEmpty(commonGoods.getTitle()) || StringUtil.isNullOrEmpty(commonGoods.getPicture())) {
         if (StringUtil.isNullOrEmpty(commonGoods.getTitle())
               || StringUtil.isNullOrEmpty(commonGoods.getPicture())) {
            out.println(JsonUtil.loadFalseResult("暂未找到该商品,请稍后再试!"));
            return;
         }
         JSONObject goodsJSON = new JSONObject();
         goodsJSON.put("title", commonGoods.getTitle());
         goodsJSON.put("pictUrl", commonGoods.getPicture());
         data.put("type", type);
         data.put("desc", "该商品无推广信息");
         data.put("goods", goodsJSON);
         out.print(JsonUtil.loadTrueResult(data));
         return;
      }
      }
      JSONObject data = new JSONObject();
      if (VersionUtil.greaterThan_1_6_5(acceptData.getPlatform(), acceptData.getVersion())) {
         if (tb != null) {
@@ -324,14 +361,14 @@
            }
            commonGoods = CommonGoodsFactory.create(goodsBrief);
         }
         BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
         BigDecimal shareRate = hongBaoManageService.getShareRate();
         Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
               .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
         data.put("type", type);
         data.put("goods",
               gson.toJson(GoodsDetailVOFactory.convertCommonGoods(commonGoods, null, fanLiRate, shareRate)));
         data.put("goods", gson.toJson(GoodsDetailVOFactory.convertCommonGoods(commonGoods,
               new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE,hongBaoManageService.getVIPFanLiRate()))));
         out.print(JsonUtil.loadTrueResult(data));
         return;
      }
@@ -366,9 +403,21 @@
      root.put("data", data);
      out.print(JsonUtil.loadTrueResult(root));
   }
   private TaoBaoGoodsBrief getTaoBaoGoodsBriefFromGoodsId(String goodsId) {
      TaoBaoGoodsBrief tb = TaoBaoUtil.getTmallGoodsInfo(goodsId);
      if (tb == null && NumberUtil.isNumeric(goodsId)) {// 是数字
         tb = TaoBaoUtil.getSimpleGoodsBrief(Long.parseLong(goodsId));
         if (tb != null) {
            tb.setPictUrl(TbImgUtil.getTBSize220Img(tb.getPictUrl()));
         }
      }
      return tb;
   }
   /**
    * 解析抖音链接
    *
    * @param acceptData
    * @param text
    * @param out
@@ -388,7 +437,7 @@
            JSONObject goodsJSON = new JSONObject();
            goodsJSON.put("title", goods.getName());
            goodsJSON.put("pictUrl", goods.getImg());
            JSONObject data = new JSONObject();
            data.put("type", 4);
            data.put("desc", "该商品无推广信息");
@@ -401,10 +450,9 @@
      return;
   }
   /**
    * 解析淘口令
    *
    * @param acceptData
    * @param text
    * @param out
@@ -430,25 +478,25 @@
                  } catch (TaobaoGoodsDownException e) {
                     e.printStackTrace();
                  }
                  if (goodsBrief == null) {
                     out.println(JsonUtil.loadFalseResult("暂未找到该商品,请稍后再试!"));
                     return false;
                  }
                  BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
                  BigDecimal shareRate = hongBaoManageService.getShareRate();
                  Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
                        .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
                  JSONObject data = new JSONObject();
                  data.put("type", 3);
                  data.put("goods", gson.toJson(GoodsDetailVOFactory.convertTaoBao(goodsBrief, null, fanLiRate, shareRate)));
                  data.put("goods", gson.toJson(GoodsDetailVOFactory.convertTaoBao(goodsBrief,
                        new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE,hongBaoManageService.getVIPFanLiRate()))));
                  out.print(JsonUtil.loadTrueResult(data));
                  return true;
               }
               JSONObject data = new JSONObject();
               JSONObject taoBaoGoodsJSON = new JSONObject();
               taoBaoGoodsJSON.put("title", tb.getTitle());
@@ -486,7 +534,7 @@
   @RequestMapping(value = "tokenReceive", method = RequestMethod.POST)
   public void tokenReceive(AcceptData acceptData, Long uid, String token, PrintWriter out) {
      try {
         String msg = tokenRecordService.receiveToken(token, uid);
         String msg = tokenRecordService.receiveToken(token, uid, acceptData);
         out.print(JsonUtil.loadTrueResult(msg));
      } catch (TokenRecordException e) {
         out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
@@ -632,7 +680,8 @@
    * @param endprice
    * @return
    */
   private void searchTaoBaoGoods(AcceptData acceptData, String key, Integer page, String filter, Integer order, PrintWriter out) {
   private void searchTaoBaoGoods(AcceptData acceptData, String key, Integer page, String filter, Integer order,
         PrintWriter out) {
      SearchFilter sf = new SearchFilter();
      sf.setKey(SearchFilterUtil.filterSearchContent(key));
      sf.setPage(page);
@@ -715,8 +764,10 @@
      List<GoodsDetailVO> list = new ArrayList<GoodsDetailVO>();
      BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
      BigDecimal shareRate = hongBaoManageService.getShareRate();
      ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE,hongBaoManageService.getVIPFanLiRate());
      for (TaoBaoGoodsBrief goods : taoBaoGoodsBriefs) {
         list.add(GoodsDetailVOFactory.convertTaoBao(goods, null, fanLiRate, shareRate));
         list.add(GoodsDetailVOFactory.convertTaoBao(goods, paramsDTO));
      }
      Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
@@ -727,24 +778,33 @@
      data.put("count", result.getTaoBaoHead().getDocsfound());
      if (page == 1) { // 第一页返回店铺信息
         List<TaoBaoShopVO> listShop = taoBaoShopService.getShopByKeyV2(key);
         if (listShop != null && listShop.size() > 0 && listShop.get(0).getListGoodsVO() != null
               && listShop.get(0).getListGoodsVO().size() > 2) {
            String platform = acceptData.getPlatform();
            TaoBaoShopVO taoBaoShop = listShop.get(0);
            if (("ios".equalsIgnoreCase(platform) && VersionUtil.greaterThan_2_0(platform, acceptData.getVersion()))
               || ("android".equalsIgnoreCase(platform) && VersionUtil.greaterThan_2_0_1(platform, acceptData.getVersion()))) {
               BrandInfoVO brandInfoVO = new BrandInfoVO();
               brandInfoVO.setId(taoBaoShop.getId());
               brandInfoVO.setName(taoBaoShop.getShopName());
               brandInfoVO.setIcon(taoBaoShop.getShopIcon());
               brandInfoVO.setListGoods(taoBaoShop.getListGoodsVO());
         String platform = acceptData.getPlatform();
         String version = acceptData.getVersion();
         if (("ios".equalsIgnoreCase(platform) && VersionUtil.greaterThan_2_1(platform, version))
               || ("android".equalsIgnoreCase(platform) && VersionUtil.greaterThan_2_0_2(platform, version))) {
            BrandInfoVO brandInfoVO = brandInfoService.listByAlikeName(key);
            if (brandInfoVO != null)
               data.put("shop", JsonUtil.getApiCommonGson().toJson(brandInfoVO));
            } else {
               data.put("shop", JsonUtil.getApiCommonGson().toJson(taoBaoShop));
         } else {
            List<TaoBaoShopVO> listShop = taoBaoShopService.getShopByKeyV2(key);
            if (listShop != null && listShop.size() > 0 && listShop.get(0).getListGoodsVO() != null
                  && listShop.get(0).getListGoodsVO().size() > 2) {
               TaoBaoShopVO taoBaoShop = listShop.get(0);
               if (("ios".equalsIgnoreCase(platform) && VersionUtil.greaterThan_2_0(platform, version))
                  || ("android".equalsIgnoreCase(platform) && VersionUtil.greaterThan_2_0_1(platform, version))) {
                  BrandInfoVO brandInfoVO = new BrandInfoVO();
                  brandInfoVO.setId(taoBaoShop.getId());
                  brandInfoVO.setName(taoBaoShop.getShopName());
                  brandInfoVO.setIcon(taoBaoShop.getShopIcon());
                  brandInfoVO.setListGoods(taoBaoShop.getListGoodsVO());
                  data.put("shop", JsonUtil.getApiCommonGson().toJson(brandInfoVO));
               } else {
                  data.put("shop", JsonUtil.getApiCommonGson().toJson(taoBaoShop));
               }
            }
         }
      }
      out.print(JsonUtil.loadTrueResult(data));
   }
@@ -759,7 +819,8 @@
    * @param endprice
    * @return
    */
   private void searchJDGoods(AcceptData acceptData, String key, Integer page, String filter, Integer order, PrintWriter out) {
   private void searchJDGoods(AcceptData acceptData, String key, Integer page, String filter, Integer order,
         PrintWriter out) {
      JDSearchResult result = null;
      boolean hasCoupon = false;
@@ -905,8 +966,10 @@
            BigDecimal shareRate = hongBaoManageService.getShareRate();
            Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
                  .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
            ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE,hongBaoManageService.getVIPFanLiRate());
            for (JDGoods goods : goodsList) {
               GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, fanLiRate, shareRate);
               GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, paramsDTO);
               if (hasCoupon) {
                  if (goodsDetailVO.isHasCoupon()) {
                     array.add(gson.toJson(goodsDetailVO));
@@ -934,7 +997,8 @@
    * @param endprice
    * @return
    */
   private void searchPDDGoods(AcceptData acceptData, String key, Integer page, String filter, Integer order, PrintWriter out) {
   private void searchPDDGoods(AcceptData acceptData, String key, Integer page, String filter, Integer order,
         PrintWriter out) {
      PDDSearchFilter pddfilter = new PDDSearchFilter();
      pddfilter.setKw(SearchFilterUtil.filterSearchContent(key));
      pddfilter.setPage(page);
@@ -986,9 +1050,10 @@
         if (goodsList != null && goodsList.size() > 0) {
            BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
            BigDecimal shareRate = hongBaoManageService.getShareRate();
            ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE,hongBaoManageService.getVIPFanLiRate());
            for (PDDGoodsDetail goods : goodsList) {
               GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertPDDGoods(goods, fanLiRate, shareRate);
               GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertPDDGoods(goods, paramsDTO);
               array.add(gson.toJson(goodsDetailVO));
            }
         }