admin
2019-11-03 788deca1b4a24f8a24e49c24f7d89975a1d74bbe
fanli/src/main/java/com/yeshi/fanli/controller/client/v2/SearchControllerV2.java
@@ -16,12 +16,15 @@
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.yeshi.utils.HttpUtil;
import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.NumberUtil;
import org.yeshi.utils.taobao.TbImgUtil;
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;
import com.yeshi.fanli.dto.jd.JDSearchResult;
@@ -41,21 +44,23 @@
import com.yeshi.fanli.service.inter.config.BusinessSystemService;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.config.SuperHotSearchService;
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
import com.yeshi.fanli.service.inter.integral.IntegralGetService;
import com.yeshi.fanli.service.inter.lable.QualityGoodsService;
import com.yeshi.fanli.service.inter.lable.TaoKeGoodsService;
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoShopService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailService;
import com.yeshi.fanli.service.inter.user.HistorySearchService;
import com.yeshi.fanli.service.inter.user.TokenRecordService;
import com.yeshi.fanli.service.inter.user.integral.IntegralGetService;
import com.yeshi.fanli.tag.PageEntity;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.DouYinUtil;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.ThreadUtil;
import com.yeshi.fanli.util.Utils;
import com.yeshi.fanli.util.VersionUtil;
import com.yeshi.fanli.util.annotation.RequestSerializableByKey;
import com.yeshi.fanli.util.cache.IntegralGetCacheManager;
import com.yeshi.fanli.util.cache.TaoBaoGoodsCacheUtil;
import com.yeshi.fanli.util.factory.CommonGoodsFactory;
@@ -67,6 +72,7 @@
import com.yeshi.fanli.util.taobao.SearchFilterUtil;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
import com.yeshi.fanli.vo.brand.BrandInfoVO;
import com.yeshi.fanli.vo.brand.TaoBaoShopVO;
import com.yeshi.fanli.vo.goods.GoodsDetailVO;
import com.yeshi.fanli.vo.msg.TokenVO;
@@ -174,12 +180,14 @@
            return;
         }
         if (analysisTaoToken(text, out)) {
         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();
         data.put("title", text);
@@ -188,6 +196,7 @@
         return;
      }
      int type = 3;
      CommonGoods commonGoods = null;
      text = matcher.group();
@@ -213,7 +222,8 @@
         }
         tb = TaoBaoUtil.isAlimama(id);
         if (tb == null) {
            tb = TaoBaoUtil.parsePhoneTmAndTb(id);
            type = 4;
            tb = TaoBaoUtil.getTmallGoodsInfo(id);
         }
      } else if (text.contains("http://zmnxbc.com")) { // 手机端天猫APP分享
         tb = TaoBaoUtil.parsePhoneShareUrlByTM(text);
@@ -224,23 +234,61 @@
         id = map.get("id").replace("}", "");
         tb = TaoBaoUtil.isAlimama(id);
         if (tb == null) {
            tb = TaoBaoUtil.parsePhoneTmAndTb(id);
            type = 4;
            tb = TaoBaoUtil.getTmallGoodsInfo(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 = TaoBaoUtil.getTmallGoodsInfo(goodsId);
               if (tb != null)
                  type = 4;
            }
         }
         if (tb == null)// 淘宝是空值
         {
            String jdId = JDUtil.getJDGoodsId(text);
            if (!StringUtil.isNullOrEmpty(jdId)) {
               JDGoods goods = JDApiUtil.getGoodsDetail(Long.parseLong(jdId));
               if (goods != null)
                  commonGoods = CommonGoodsFactory.create(goods);
               if (goods != null) {
                  // 高级接口 -- 信息更完整
                  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);
                  if (goods != null) {
                     commonGoods = new CommonGoods();
                     commonGoods.setTitle(goods.getSkuName());
                     commonGoods.setPicture(goods.getPicUrl());
                  }
               }
            } else {
               String pddId = PinDuoDuoUtil.getPDDGoodsId(text);
               if (!StringUtil.isNullOrEmpty(pddId)) {
                  PDDGoodsDetail goods = PinDuoDuoApiUtil.getGoodsDetail(Long.parseLong(pddId));
                  if (goods != null)
                  if (goods != null) {
                     commonGoods = CommonGoodsFactory.create(goods);
                  } else {
                     type = 4;
                     goods = PinDuoDuoUtil.getPDDGoodsInfo(pddId);
                     if (goods != null) {
                        commonGoods = new CommonGoods();
                        commonGoods.setTitle(goods.getGoodsName());
                        commonGoods.setPicture(goods.getGoodsThumbnailUrl());
                     }
                  }
               }
            }
         }
@@ -251,8 +299,37 @@
         return;
      }
      JSONObject data = new JSONObject();
      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())) {
            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) {
            TaoBaoGoodsBrief goodsBrief = null;
@@ -267,13 +344,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", 3);
         data.put("type", type);
         data.put("goods",
               gson.toJson(GoodsDetailVOFactory.convertCommonGoods(commonGoods, null, fanLiRate, shareRate)));
               gson.toJson(GoodsDetailVOFactory.convertCommonGoods(commonGoods, new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE))));
         out.print(JsonUtil.loadTrueResult(data));
         return;
      }
@@ -309,7 +387,50 @@
      out.print(JsonUtil.loadTrueResult(root));
   }
   private boolean analysisTaoToken(String text, PrintWriter out) {
   /**
    * 解析抖音链接
    *
    * @param acceptData
    * @param text
    * @param out
    * @return
    */
   private void analysisDouYin(AcceptData acceptData, String text, PrintWriter out) {
      String location = HttpUtil.getLocation(text);
      if (!StringUtil.isNullOrEmpty(location)) {
         if (location.contains("taobao.com")) { // 淘宝商品
            String realUrl = TaoBaoUtil.getRealUrl(location);
            if (!StringUtil.isNullOrEmpty(realUrl)) {
               getRecommendInfo(acceptData, realUrl, null, out);
               return;
            }
         } else if (location.contains("haohuo.jinritemai.com")) { // 抖音商品
            DouYinGoods goods = DouYinUtil.getGoodsInfo(location);
            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", "该商品无推广信息");
            data.put("goods", goodsJSON);
            out.print(JsonUtil.loadTrueResult(data));
            return;
         }
      }
      out.println(JsonUtil.loadFalseResult("暂未找到该商品,请稍后再试!"));
      return;
   }
   /**
    * 解析淘口令
    *
    * @param acceptData
    * @param text
    * @param out
    * @return
    */
   private boolean analysisTaoToken(AcceptData acceptData, String text, PrintWriter out) {
      String token = StringUtil.picUpTaoToken(text);
      if (!StringUtil.isNullOrEmpty(token)) {
         Long auctionId = TaoKeApiUtil.tokenConvertAuctionId(token);
@@ -322,6 +443,32 @@
            }
            if (tb != null) {
               if (VersionUtil.greaterThan_1_6_5(acceptData.getPlatform(), acceptData.getVersion())) {
                  TaoBaoGoodsBrief goodsBrief = null;
                  try {
                     goodsBrief = TaoKeApiUtil.searchGoodsDetail(tb.getAuctionId());
                  } 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, new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE))));
                  out.print(JsonUtil.loadTrueResult(data));
                  return true;
               }
               JSONObject data = new JSONObject();
               JSONObject taoBaoGoodsJSON = new JSONObject();
               taoBaoGoodsJSON.put("title", tb.getTitle());
@@ -355,6 +502,7 @@
    * @param goodsType
    * @param out
    */
   @RequestSerializableByKey(key = "'tokenReceive-'+#uid")
   @RequestMapping(value = "tokenReceive", method = RequestMethod.POST)
   public void tokenReceive(AcceptData acceptData, Long uid, String token, PrintWriter out) {
      try {
@@ -479,18 +627,18 @@
      /*--------- 京东商品  -------*/
      if (goodsType.intValue() == Constant.SOURCE_TYPE_JD) {
         searchJDGoods(searchkey, page, filter, order, out);
         searchJDGoods(acceptData, searchkey, page, filter, order, out);
         return;
      }
      /*-------- 拼多多商品  -------*/
      if (goodsType.intValue() == Constant.SOURCE_TYPE_PDD) {
         searchPDDGoods(searchkey, page, filter, order, out);
         searchPDDGoods(acceptData, searchkey, page, filter, order, out);
         return;
      }
      /*-------- 淘宝商品  -------*/
      searchTaoBaoGoods(searchkey, page, filter, order, out);
      searchTaoBaoGoods(acceptData, searchkey, page, filter, order, out);
   }
   /**
@@ -504,7 +652,8 @@
    * @param endprice
    * @return
    */
   private void searchTaoBaoGoods(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);
@@ -587,8 +736,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);
      for (TaoBaoGoodsBrief goods : taoBaoGoodsBriefs) {
         list.add(GoodsDetailVOFactory.convertTaoBao(goods, null, fanLiRate, shareRate));
         list.add(GoodsDetailVOFactory.convertTaoBao(goods, paramsDTO));
      }
      Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
@@ -598,12 +749,24 @@
      data.put("result", gson.toJson(list));
      data.put("count", result.getTaoBaoHead().getDocsfound());
      if (page == 1) {
         // 第一页返回店铺信息
      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) {
            data.put("shop", JsonUtil.getApiCommonGson().toJson(listShop.get(0)));
            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());
               data.put("shop", JsonUtil.getApiCommonGson().toJson(brandInfoVO));
            } else {
               data.put("shop", JsonUtil.getApiCommonGson().toJson(taoBaoShop));
            }
         }
      }
      out.print(JsonUtil.loadTrueResult(data));
@@ -620,7 +783,8 @@
    * @param endprice
    * @return
    */
   private void searchJDGoods(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;
@@ -766,8 +930,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);
            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));
@@ -795,7 +961,8 @@
    * @param endprice
    * @return
    */
   private void searchPDDGoods(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);
@@ -847,9 +1014,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);
            for (PDDGoodsDetail goods : goodsList) {
               GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertPDDGoods(goods, fanLiRate, shareRate);
               GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertPDDGoods(goods, paramsDTO);
               array.add(gson.toJson(goodsDetailVO));
            }
         }