admin
2019-09-08 2db0485ab8aa814499adf49112c5aa9e4c9e78b2
fanli/src/main/java/com/yeshi/fanli/controller/client/v1/SearchController.java
@@ -19,11 +19,11 @@
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.yeshi.fanli.dto.dataoke.DaTaoKeGoodsResult;
import com.yeshi.fanli.entity.accept.AcceptData;
import com.yeshi.fanli.entity.bus.lable.QualityFactory;
import com.yeshi.fanli.entity.bus.recommend.Honest;
import com.yeshi.fanli.entity.bus.search.HotSearch;
import com.yeshi.fanli.entity.bus.su.search.SuperHotSearch;
import com.yeshi.fanli.entity.system.BusinessSystem;
import com.yeshi.fanli.entity.taobao.PidUser;
import com.yeshi.fanli.entity.taobao.SearchFilter;
@@ -34,9 +34,10 @@
import com.yeshi.fanli.entity.taobao.TaoBaoSearchResult;
import com.yeshi.fanli.entity.taobao.TaoBaoUnionConfig;
import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetail;
import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetailV2;
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.config.HotSearchService;
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
import com.yeshi.fanli.service.inter.lable.QualityGoodsService;
import com.yeshi.fanli.service.inter.lable.TaoKeGoodsService;
@@ -49,6 +50,7 @@
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.ThreadUtil;
import com.yeshi.fanli.util.cache.TaoBaoGoodsCacheUtil;
import com.yeshi.fanli.util.dataoke.DaTaoKeApiUtil;
import com.yeshi.fanli.util.taobao.SearchFilterUtil;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
import com.yeshi.fanli.vo.brand.TaoBaoShopVO;
@@ -68,10 +70,10 @@
   private ConfigService configService;
   @Resource
   private SuperHotSearchService superHotSearchSerivce;
   private HotSearchService hotSearchService;
   @Resource
   private HistorySearchService historySearchService;
   private HistorySearchService  historySearchService;
   @Resource
   private HongBaoManageService manageService;
@@ -87,41 +89,37 @@
   @Resource
   private TaoBaoGoodsCacheUtil taoBaoGoodsCacheUtil;
   @Resource
   private TaoBaoShopService taoBaoShopService;
   @Resource
   private DaTaoKeGoodsDetailService daTaoKeGoodsDetailService;
   /**
    * 热门搜索
    * @param acceptData
    * @param goodsType
    * @param out
    */
   @RequestMapping(value = "gethotsearch", method = RequestMethod.POST)
   public void getHotSearch(AcceptData acceptData, PrintWriter out) {
      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),
            acceptData.getPackages());
      if (system == null) {
         out.print(JsonUtil.loadFalseResult("系统不存在"));
         return;
   public void getHotSearch(AcceptData acceptData, Integer goodsType, PrintWriter out) {
      // 默认淘宝
      if (goodsType == null) {
         goodsType = Constant.SOURCE_TYPE_TAOBAO;
      }
      List<SuperHotSearch> superHotSearchList = superHotSearchSerivce
            .getSuperHotSearchBySystemIdCache(system.getId());
      if (superHotSearchList == null || superHotSearchList.size() == 0) {
      List<HotSearch> list = hotSearchService.getHotSearchCache(goodsType);
      if (list == null || list.size() == 0) {
         out.print(JsonUtil.loadFalseResult("没有数据"));
         return;
      }
      List<HotSearch> hotSearchList = new ArrayList<HotSearch>();
      for (SuperHotSearch superHotSearch : superHotSearchList) {
         HotSearch hotSearch = superHotSearch.getHotSearch();
         if (hotSearch != null)
            hotSearchList.add(hotSearch);
      }
      JSONObject data = new JSONObject();
      data.put("count", hotSearchList.size());
      data.put("hotSearchList", hotSearchList);
      String result = JsonUtil.loadTrueResult(data);
      out.print(result);
      return;
      data.put("count", list.size());
      data.put("hotSearchList", list);
      out.print(JsonUtil.loadTrueResult(data));
   }
   @RequestMapping("specialSearch")
@@ -416,15 +414,20 @@
      historySearchService.addHistorySearch(kw, bid);
//      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),
//            acceptData.getPackages());
//      if (system == null) {
//         out.print(JsonUtil.loadFalseResult("系统不存在"));
//         return;
//      }
      // BusinessSystem system =
      // businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),
      // acceptData.getPackages());
      // if (system == null) {
      // out.print(JsonUtil.loadFalseResult("系统不存在"));
      // return;
      // }
      if (!StringUtil.isNullOrEmpty(kw) && (kw.startsWith("http://") || kw.startsWith("https://"))) {
         out.print(JsonUtil.loadFalseResult("无法搜索链接"));
         JSONObject data = new JSONObject();
         data.put("result", new JSONArray());
         data.put("count", 0);
         data.put("nav", new JSONArray());
         out.print(JsonUtil.loadTrueResult(data));
         return;
      }
@@ -460,7 +463,9 @@
         data = searchGoods(kw, page, filter, order, startprice, endprice);
      } else {
         // 推荐:精选库
         data = searchQualityGoods(kw, page, filter, order, startprice, endprice);
         // data = searchQualityGoods(kw, page, filter, order, startprice,
         // endprice);
         data = searchDaTaoKeGoods(kw, page, filter, order, startprice, endprice);
      }
      // 获取推荐词
@@ -471,9 +476,10 @@
         if (listRecommendWords == null || listRecommendWords.size() == 0) {
            listRecommendWords = new ArrayList<String>();
         }
         List<TaoBaoShopVO> listShop = taoBaoShopService.getShopByKey(kw);
         if (listShop != null && listShop.size() > 0) {
         List<TaoBaoShopVO> listShop =taoBaoShopService.getShopByKey(kw);
         if (listShop != null && listShop.size() > 0 && listShop.get(0).getListGoods() != null
               && listShop.get(0).getListGoods().size() > 2) {
            data.put("shop", JsonUtil.getApiCommonGson().toJson(listShop.get(0)));
         }
      }
@@ -670,7 +676,7 @@
         if (daTaoKeList != null && daTaoKeList.size() > 0) {
            Collections.reverse(daTaoKeList);
            for (DaTaoKeDetail detail : daTaoKeList) {
               taoBaoGoodsBriefs.add(0,TaoBaoUtil.convert(detail));
               taoBaoGoodsBriefs.add(0, TaoBaoUtil.convert(detail));
            }
         }
      } catch (Exception e) {
@@ -939,6 +945,43 @@
      return data;
   }
   private JSONObject searchDaTaoKeGoods(String key, int page, String filter, String order, String startprice,
         String endprice) {
      page = page + 1;
      int sort = DaTaoKeApiUtil.SORT_DEFAULT;
      if ("5".equalsIgnoreCase(order)) {
         sort = DaTaoKeApiUtil.SORT_COMMISSION;
      } else if ("1".equalsIgnoreCase(order)) {
         sort = DaTaoKeApiUtil.SORT_SALES;
      } else if ("2".equalsIgnoreCase(order)) {
         sort = DaTaoKeApiUtil.SORT_PRICE_HIGH_TO_LOW;
      } else if ("3".equalsIgnoreCase(order)) {
         sort = DaTaoKeApiUtil.SORT_PRICE_LOW_TO_HIGH;
      }
      List<TaoBaoGoodsBriefExtra> listExtra = new ArrayList<TaoBaoGoodsBriefExtra>();
      BigDecimal proportion = manageService.getFanLiRate();
      DaTaoKeGoodsResult result = DaTaoKeApiUtil.search(key, null, null, null, page, 20, sort);
      if (result != null && result.getGoodsList() != null)
         for (DaTaoKeDetailV2 goods : result.getGoodsList()) {
            listExtra.add(
                  TaoBaoUtil.getTaoBaoGoodsBriefExtra(TaoBaoUtil.convert(goods), proportion.toString(), null));
         }
      List<TaoBaoSearchNav> navList = new ArrayList<>();
      Gson gson = new GsonBuilder().create();
      Gson gson2 = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
            .excludeFieldsWithoutExposeAnnotation().create();
      JSONObject data = new JSONObject();
      data.put("nav", gson.toJson(navList));
      data.put("result", gson2.toJson(listExtra));
      data.put("count", result.getTotalCount());
      return data;
   }
   /**
    * 设置查询佣金比例范围
    *