admin
2020-07-03 651a15c78f668bef3859d9ed1bb7ad0b669d3600
fanli/src/main/java/com/yeshi/fanli/controller/client/v1/SearchController.java
@@ -10,12 +10,12 @@
import javax.annotation.Resource;
import com.yeshi.fanli.entity.SystemEnum;
import org.springframework.cache.annotation.Cacheable;
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.taobao.TaoBaoAuthUtil;
import org.yeshi.utils.taobao.TbImgUtil;
import com.google.gson.Gson;
@@ -25,8 +25,8 @@
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.system.ConfigKeyEnum;
import com.yeshi.fanli.entity.taobao.PidUser;
import com.yeshi.fanli.entity.taobao.SearchFilter;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
@@ -35,17 +35,16 @@
import com.yeshi.fanli.entity.taobao.TaoBaoSearchNav;
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.hongbao.HongBaoManageService;
import com.yeshi.fanli.service.inter.config.HotSearchService;
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.taobao.dataoke.DaTaoKeGoodsDetailV2Service;
import com.yeshi.fanli.service.inter.user.HistorySearchService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.EhcacheUtil;
@@ -72,19 +71,16 @@
   private ConfigService configService;
   @Resource
   private SuperHotSearchService superHotSearchSerivce;
   private HotSearchService hotSearchService;
   @Resource
   private HistorySearchService historySearchService;
   private HistorySearchService  historySearchService;
   @Resource
   private HongBaoManageService manageService;
   @Resource
   private TaoBaoUnionConfigService taoBaoUnionConfigService;
   @Resource
   private TaoKeGoodsService taoKeGoodsService;
   @Resource
   private QualityGoodsService qualityGoodsService;
@@ -96,35 +92,32 @@
   private TaoBaoShopService taoBaoShopService;
   @Resource
   private DaTaoKeGoodsDetailService daTaoKeGoodsDetailService;
   private DaTaoKeGoodsDetailV2Service daTaoKeGoodsDetailV2Service;
   /**
    * 热门搜索
    * @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")
@@ -463,9 +456,8 @@
      JSONObject data = null;
      if (!recommend) {
         // 淘宝接口请求
         data = searchGoods(kw, page, filter, order, startprice, endprice);
         data = searchGoods(kw, page, filter, order, startprice, endprice,acceptData.getSystem());
      } else {
         // 推荐:精选库
         // data = searchQualityGoods(kw, page, filter, order, startprice,
@@ -482,7 +474,7 @@
            listRecommendWords = new ArrayList<String>();
         }
         List<TaoBaoShopVO> listShop = taoBaoShopService.getShopByKey(kw);
         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)));
@@ -508,7 +500,7 @@
    * @return
    */
   private JSONObject searchGoods(String kw, int page, String filter, String order, String startprice,
         String endprice) {
         String endprice,SystemEnum system) {
      page = page + 1;
      SearchFilter sf = new SearchFilter();
@@ -611,24 +603,24 @@
               int id = array.optJSONObject(i).optInt("id");
               sf.setProvinceId(id);
            } else if ("tkRate1".equalsIgnoreCase(ty)) {
               setSearchTkRate(0, sf);
               setSearchTkRate(0, sf,system);
            } else if ("tkRate2".equalsIgnoreCase(ty)) {
               setSearchTkRate(1, sf);
               setSearchTkRate(1, sf,system);
            } else if ("tkRate3".equalsIgnoreCase(ty)) {
               setSearchTkRate(2, sf);
               setSearchTkRate(2, sf,system);
            } else if ("tkRate4".equalsIgnoreCase(ty)) {
               setSearchTkRate(3, sf);
               setSearchTkRate(3, sf,system);
            } else if ("tkRate5".equalsIgnoreCase(ty)) {
               setSearchTkRate(4, sf);
               setSearchTkRate(4, sf,system);
            }
         }
         sf.setParams(params);
      }
      // 搜索大淘客
      List<DaTaoKeDetail> daTaoKeList = null;
      List<DaTaoKeDetailV2> daTaoKeList = null;
      if (page == 1)
         daTaoKeList = daTaoKeGoodsDetailService.listByDtitle(kw);
         daTaoKeList = daTaoKeGoodsDetailV2Service.listByDtitle(kw);
      TaoBaoSearchResult result = TaoBaoUtil.search(sf);
      if (result == null) {
@@ -680,7 +672,7 @@
      try {
         if (daTaoKeList != null && daTaoKeList.size() > 0) {
            Collections.reverse(daTaoKeList);
            for (DaTaoKeDetail detail : daTaoKeList) {
            for (DaTaoKeDetailV2 detail : daTaoKeList) {
               taoBaoGoodsBriefs.add(0, TaoBaoUtil.convert(detail));
            }
         }
@@ -735,7 +727,7 @@
   /**
    * 执行搜索精选库
    * 
    * @param kw
    * @param key
    * @param page
    * @param filter
    * @param order
@@ -744,7 +736,7 @@
    * @return
    */
   private JSONObject searchQualityGoods(String key, int page, String filter, String order, String startprice,
         String endprice) {
                                String endprice, SystemEnum system) {
      Integer hasQuan = null;
      Integer userType = null;
@@ -793,7 +785,7 @@
               provinceId = array.optJSONObject(i).optInt("id");
            } else if ("tkRate1".equalsIgnoreCase(ty)) {
               // 获取对应参数
               String value = configService.get("tkRate_range");
               String value = configService.getValue(ConfigKeyEnum.tkRateRange.getKey(),system);
               if (!StringUtil.isNullOrEmpty(value)) {
                  JSONArray tkRatearray = JSONArray.fromObject(value);
                  if (tkRatearray != null) {
@@ -809,7 +801,7 @@
               }
            } else if ("tkRate2".equalsIgnoreCase(ty)) {
               // 获取对应参数
               String value = configService.get("tkRate_range");
               String value = configService.getValue(ConfigKeyEnum.tkRateRange.getKey(),system);
               if (!StringUtil.isNullOrEmpty(value)) {
                  JSONArray tkRatearray = JSONArray.fromObject(value);
                  if (tkRatearray != null) {
@@ -825,7 +817,7 @@
               }
            } else if ("tkRate3".equalsIgnoreCase(ty)) {
               // 获取对应参数
               String value = configService.get("tkRate_range");
               String value = configService.getValue(ConfigKeyEnum.tkRateRange.getKey(),system);
               if (!StringUtil.isNullOrEmpty(value)) {
                  JSONArray tkRatearray = JSONArray.fromObject(value);
                  if (tkRatearray != null) {
@@ -841,7 +833,7 @@
               }
            } else if ("tkRate4".equalsIgnoreCase(ty)) {
               // 获取对应参数
               String value = configService.get("tkRate_range");
               String value = configService.getValue(ConfigKeyEnum.tkRateRange.getKey(),system);
               if (!StringUtil.isNullOrEmpty(value)) {
                  JSONArray tkRatearray = JSONArray.fromObject(value);
                  if (tkRatearray != null) {
@@ -857,7 +849,7 @@
               }
            } else if ("tkRate5".equalsIgnoreCase(ty)) {
               // 获取对应参数
               String value = configService.get("tkRate_range");
               String value = configService.getValue(ConfigKeyEnum.tkRateRange.getKey(),system);
               if (!StringUtil.isNullOrEmpty(value)) {
                  JSONArray tkRatearray = JSONArray.fromObject(value);
                  if (tkRatearray != null) {
@@ -993,9 +985,9 @@
    * @param i
    * @param sf
    */
   public void setSearchTkRate(int i, SearchFilter sf) {
   public void setSearchTkRate(int i, SearchFilter sf,SystemEnum system) {
      // 获取对应参数
      String value = configService.get("tkRate_range");
      String value = configService.getValue(ConfigKeyEnum.tkRateRange.getKey(),system);
      if (!StringUtil.isNullOrEmpty(value)) {