admin
2019-05-14 744c4998b33ca1e6010bbdce1bf7fd36e8c388f8
fanli/src/main/java/com/yeshi/fanli/controller/client/SearchController.java
@@ -3,6 +3,7 @@
import java.io.PrintWriter;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
@@ -22,7 +23,6 @@
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.HistorySearch;
import com.yeshi.fanli.entity.bus.search.HotSearch;
import com.yeshi.fanli.entity.bus.su.search.SuperHotSearch;
import com.yeshi.fanli.entity.system.BusinessSystem;
@@ -34,6 +34,8 @@
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.exception.taobao.TaobaoGoodsDownException;
import com.yeshi.fanli.service.inter.config.BusinessSystemService;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.config.SuperHotSearchService;
@@ -41,12 +43,17 @@
import com.yeshi.fanli.service.inter.lable.QualityGoodsService;
import com.yeshi.fanli.service.inter.lable.TaoKeGoodsService;
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.util.Constant;
import com.yeshi.fanli.util.EhcacheUtil;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.ThreadUtil;
import com.yeshi.fanli.util.cache.TaoBaoGoodsCacheUtil;
import com.yeshi.fanli.util.taobao.DaTaoKeUtil;
import com.yeshi.fanli.util.taobao.SearchFilterUtil;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
import net.sf.ehcache.Element;
import net.sf.json.JSONArray;
@@ -80,9 +87,16 @@
   @Resource
   private QualityGoodsService qualityGoodsService;
   @Resource
   private TaoBaoGoodsCacheUtil taoBaoGoodsCacheUtil;
   @Resource
   private DaTaoKeGoodsDetailService daTaoKeGoodsDetailService;
   @RequestMapping(value = "gethotsearch", method = RequestMethod.POST)
   public void getHotSearch(AcceptData acceptData, PrintWriter out) {
      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(), acceptData.getPackages());
      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),
            acceptData.getPackages());
      if (system == null) {
         out.print(JsonUtil.loadFalseResult("系统不存在"));
         return;
@@ -96,7 +110,8 @@
      List<HotSearch> hotSearchList = new ArrayList<HotSearch>();
      for (SuperHotSearch superHotSearch : superHotSearchList) {
         HotSearch hotSearch = superHotSearch.getHotSearch();
         hotSearchList.add(hotSearch);
         if (hotSearch != null)
            hotSearchList.add(hotSearch);
      }
      JSONObject data = new JSONObject();
@@ -160,7 +175,8 @@
         String endprice, String fastFilter, PrintWriter out) {
      String bid = getHistorySearchBid(acceptData);
      historySearchService.addHistorySearch(kw, bid);
      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(), acceptData.getPackages());
      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),
            acceptData.getPackages());
      if (system == null) {
         out.print(JsonUtil.loadFalseResult("系统不存在"));
         return;
@@ -398,7 +414,8 @@
      historySearchService.addHistorySearch(kw, bid);
      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(), acceptData.getPackages());
      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),
            acceptData.getPackages());
      if (system == null) {
         out.print(JsonUtil.loadFalseResult("系统不存在"));
         return;
@@ -590,9 +607,53 @@
      }
      TaoBaoSearchResult result = TaoBaoUtil.search(sf);
      // 大淘客过滤
      List<DaTaoKeDetail> detaokeList = daTaoKeGoodsDetailService.listByDtitle(kw);
      if (detaokeList != null)
         for (DaTaoKeDetail detail : detaokeList) {
            for (int i = 0; i < result.getTaoBaoGoodsBriefs().size(); i++) {
               if (detail.getGoodsId().longValue() == result.getTaoBaoGoodsBriefs().get(i).getAuctionId()) {
                  result.getTaoBaoGoodsBriefs().set(i,
                        DaTaoKeUtil.filterTaoBaoGoods(result.getTaoBaoGoodsBriefs().get(i), detail));
                  break;
               }
            }
         }
      // result.setTaoBaoGoodsBriefs(daTaoKeGoodsDetailService.filterTaoBaoGoods(result.getTaoBaoGoodsBriefs()));
      if (result == null) {
         return null;
      }
      // 搜索是否在营销主商品库
      if (result != null && result.getTaoBaoGoodsBriefs() != null && result.getTaoBaoGoodsBriefs().size() > 0) {
         String numIds = "";
         for (TaoBaoGoodsBrief goods : result.getTaoBaoGoodsBriefs()) {
            numIds += goods.getAuctionId() + ",";
         }
         if (numIds.endsWith(","))
            numIds = numIds.substring(0, numIds.length() - 1);
         try {
            List<TaoBaoGoodsBrief> goodsList = TaoKeApiUtil.getBatchGoodsInfos(numIds);
            Map<Long, Integer> map = new HashMap<>();
            for (TaoBaoGoodsBrief g : goodsList)
               map.put(g.getAuctionId(), g.getMaterialLibType());
            for (TaoBaoGoodsBrief goods : result.getTaoBaoGoodsBriefs())
               goods.setMaterialLibType(map.get(goods.getAuctionId()));
            ThreadUtil.run(new Runnable() {
               @Override
               public void run() {
                  // 更新到緩存
                  for (TaoBaoGoodsBrief goods : result.getTaoBaoGoodsBriefs())
                     taoBaoGoodsCacheUtil.saveCommonTaoBaoGoodsInfo(goods);
               }
            });
         } catch (TaobaoGoodsDownException e) {
            e.printStackTrace();
         }
      }
      List<TaoBaoSearchNav> navList = TaoBaoUtil.getBaseNav();
      if (result.getNavList() != null)