yujian
2019-09-25 3b67318adb6ee3854cca9ef4134b3747bddb44df
fanli/src/main/java/com/yeshi/fanli/controller/client/v2/SearchControllerV2.java
@@ -10,12 +10,14 @@
import java.util.regex.Pattern;
import javax.annotation.Resource;
import javax.servlet.http.HttpSession;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.NumberUtil;
import org.yeshi.utils.taobao.TbImgUtil;
import com.google.gson.Gson;
@@ -39,20 +41,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.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.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;
import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;
@@ -63,6 +68,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;
@@ -109,9 +115,15 @@
   @Resource(name = "taskExecutor")
   private TaskExecutor executor;
   @Resource
   private TokenRecordService tokenRecordService;
   @Resource
   private IntegralGetService integralGetService;
   @Resource
   private IntegralGetCacheManager integralGetCacheManager;
   /**
    * 粘贴板信息推荐
@@ -129,7 +141,7 @@
      }
      // 去除前后空格
      text = text.trim();
      try {
         TokenVO tokenVO = tokenRecordService.discernToken(text, uid);
         out.print(JsonUtil.loadTrueResult(tokenVO));
@@ -140,7 +152,6 @@
            return;
         }
      }
      TaoBaoGoodsBrief tb = null;
      String URL_REGEX = "(((http|https)://)|(www\\.))[a-zA-Z0-9\\._-]+\\.[a-zA-Z]{2,6}(:[0-9]{1,4})?(/[a-zA-Z0-9\\&%_\\./-~-]*)?";
@@ -153,7 +164,7 @@
            return;
         }
         String pattern = "^[A-Za-z0-9-]+$";
         if (Pattern.matches(pattern, text.replace(" ", ""))) {//删除空格
         if (Pattern.matches(pattern, text.replace(" ", ""))) {// 删除空格
            out.println(JsonUtil.loadFalseResult("不支持推荐"));
            return;
         }
@@ -179,9 +190,17 @@
         return;
      }
      int type = 3;
      CommonGoods commonGoods = null;
      text = matcher.group();
      if (text.contains("ju.taobao.com") || text.contains(".juhuasuan.com")) {// 聚划算
      if (text.startsWith("https://a.m.taobao.com/i"))// 淘宝账号未登录状态
      {
         text = text.substring("https://a.m.taobao.com/i".length(), text.indexOf(".htm"));
         if (NumberUtil.isNumeric(text)) {
            tb = TaoBaoUtil.isAlimama(text);
         }
      } else if (text.contains("ju.taobao.com") || text.contains(".juhuasuan.com")) {// 聚划算
         int index = text.indexOf("item_id");
         if (index < 0) {
            out.println(JsonUtil.loadFalseResult("暂未找到该商品,请稍后再试!"));
@@ -197,7 +216,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);
@@ -208,7 +228,8 @@
         id = map.get("id").replace("}", "");
         tb = TaoBaoUtil.isAlimama(id);
         if (tb == null) {
            tb = TaoBaoUtil.parsePhoneTmAndTb(id);
            type = 4;
            tb = TaoBaoUtil.getTmallGoodsInfo(id);
         }
      } else {
         tb = TaoBaoUtil.parsePhoneShareUrlByTB(text);
@@ -217,8 +238,17 @@
            String jdId = JDUtil.getJDGoodsId(text);
            if (!StringUtil.isNullOrEmpty(jdId)) {
               JDGoods goods = JDApiUtil.getGoodsDetail(Long.parseLong(jdId));
               if (goods != null)
               if (goods != null) {
                  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)) {
@@ -229,16 +259,45 @@
            }
         }
      }
      if (tb == null && commonGoods == null) {
         out.println(JsonUtil.loadFalseResult("暂未找到该商品,请稍后再试!"));
         return;
      }
      JSONObject data = new JSONObject();
      
      if(VersionUtil.greaterThan_1_6_5(acceptData.getPlatform(), acceptData.getVersion())) {
      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;
            try {
@@ -250,18 +309,20 @@
               out.println(JsonUtil.loadFalseResult("暂未找到该商品,请稍后再试!"));
               return;
            }
            commonGoods = CommonGoodsFactory.create(goodsBrief);
            commonGoods = CommonGoodsFactory.create(tb);
         }
         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("goods", gson.toJson(GoodsDetailVOFactory.convertCommonGoods(commonGoods, null, fanLiRate, shareRate)));
         data.put("type", type);
         data.put("goods",
               gson.toJson(GoodsDetailVOFactory.convertCommonGoods(commonGoods, null, fanLiRate, shareRate)));
         out.print(JsonUtil.loadTrueResult(data));
         return;
      }
      if (tb != null) {
         commonGoods = new CommonGoods();
         commonGoods.setPrice(tb.getZkPrice());
@@ -270,7 +331,7 @@
         commonGoods.setGoodsType(Constant.SOURCE_TYPE_TAOBAO);
         commonGoods.setPicture(tb.getPictUrl());
      }
      JSONObject taoBaoGoodsJSON = new JSONObject();
      taoBaoGoodsJSON.put("title", commonGoods.getTitle());
      taoBaoGoodsJSON.put("zkPrice", commonGoods.getPrice() + "");
@@ -331,26 +392,25 @@
      return false;
   }
   /**
    * 口令领取
    * 
    * @param acceptData
    * @param kw
    * @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 {
         tokenRecordService.receiveToken(token, uid);
         out.print(JsonUtil.loadTrueResult("领取成功"));
         String msg = tokenRecordService.receiveToken(token, uid);
         out.print(JsonUtil.loadTrueResult(msg));
      } catch (TokenRecordException e) {
         out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
      }
   }
   /**
    * 搜索候选词
    * 
@@ -403,7 +463,8 @@
    */
   @RequestMapping(value = "searchGoods")
   public void searchGoods(AcceptData acceptData, Integer goodsType, String key, Integer page, String filter,
         Integer order, PrintWriter out) {
         Integer order, Long uid, HttpSession session, PrintWriter out) {
      if (goodsType == null || goodsType < 1 || goodsType > 3) {
         out.print(JsonUtil.loadFalseResult(1, "请传递正确平台参数"));
         return;
@@ -419,6 +480,24 @@
         return;
      }
      final String searchkey = key.trim();
      if (uid != null) {
         if (page == 1) {
            integralGetCacheManager.cacheSearchGoods(acceptData.getDevice(), System.currentTimeMillis());
         } else if (page > 1) {
            Long lastTime = integralGetCacheManager.getLastSearchTime(acceptData.getDevice());
            if (lastTime != null && System.currentTimeMillis() - lastTime >= 15 * 1000L) {// 超过15s浏览
               integralGetCacheManager.clearSearchTime(acceptData.getDevice());
               ThreadUtil.run(new Runnable() {
                  @Override
                  public void run() {
                     // 增加金币
                     integralGetService.addSearchResultScan(uid, key);
                  }
               });
            }
         }
      }
      executor.execute(new Runnable() {
         @Override
@@ -446,18 +525,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);
   }
   /**
@@ -471,7 +550,7 @@
    * @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);
@@ -565,12 +644,23 @@
      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));
@@ -587,9 +677,10 @@
    * @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;
      String way = configService.get("jd_api_search_key");
      if ("1".equals(way)) {
         JDFilter filterAPI = new JDFilter();
@@ -625,6 +716,7 @@
            JSONObject jsonfilter = JSONObject.fromObject(filter);
            Boolean coupon = jsonfilter.optBoolean("coupon");
            if (coupon != null && coupon) {
               hasCoupon = true;
               filterAPI.setIsCoupon(1); // 有券
            }
@@ -680,6 +772,7 @@
            JSONObject jsonfilter = JSONObject.fromObject(filter);
            Boolean coupon = jsonfilter.optBoolean("coupon");
            if (coupon != null && coupon) {
               hasCoupon = true;
               jdfilter.setHasCoupon(1); // 有券
            }
@@ -732,7 +825,13 @@
                  .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
            for (JDGoods goods : goodsList) {
               GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, fanLiRate, shareRate);
               array.add(gson.toJson(goodsDetailVO));
               if (hasCoupon) {
                  if (goodsDetailVO.isHasCoupon()) {
                     array.add(gson.toJson(goodsDetailVO));
                  }
               } else {
                  array.add(gson.toJson(goodsDetailVO));
               }
            }
         }
      }
@@ -753,7 +852,7 @@
    * @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);