Merge remote-tracking branch 'origin/div' into 2.1.2

admin

2020-05-20 98b1a0affd69bbe63223c21fdd2c404e8bedfccb

 fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CommonTemplateContentServiceImpl.java

@@ -3,7 +3,9 @@
import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.Collections;

import java.util.HashMap;

import java.util.List;

import java.util.Map;



import javax.annotation.Resource;



@@ -19,23 +21,26 @@
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.TaobaoMeterial;

import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetailV2;

import com.yeshi.fanli.exception.taobao.TaoKeApiException;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.service.inter.goods.CommonTemplateContentService;

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.TaoBaoGoodsUpdateService;

import com.yeshi.fanli.service.inter.taobao.TaobaoMeterialService;

import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailService;

import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailV2Service;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.dataoke.DaTaoKeApiUtil;

import com.yeshi.fanli.util.taobao.DaTaoKeUtil;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;



@Service

public class CommonTemplateContentServiceImpl implements CommonTemplateContentService {



   @Resource

   private DaTaoKeGoodsDetailService daTaoKeGoodsDetailService;

   private DaTaoKeGoodsDetailV2Service daTaoKeGoodsDetailV2Service;



   @Resource

   private TaobaoMeterialService taobaoMeterialService;

@@ -130,6 +135,8 @@
         navList = getCommonNav();

      } else if (type == CommonContentTypeEnum.chaoPinReMai) {

         navList = getCommonNav();

      } else if (type == CommonContentTypeEnum.mianDan) {

         navList = new ArrayList<>();

      }



      return navList;

@@ -167,7 +174,10 @@
         result = getCaoShengContent(cid, page, pageSize);

      } else if (type == CommonContentTypeEnum.haoQuan) {

         result = getHaoQuanContent(cid, page, pageSize);

      } else if (type == CommonContentTypeEnum.mianDan) {

         result = getMianDanContent(page, pageSize);

      }



      if (result != null) {// 商品信息过滤

         List<TaoBaoGoodsBrief> goodsList = taoBaoGoodsUpdateService

               .filterImportantTaoBaoGoods(result.getGoodsList());

@@ -191,17 +201,38 @@


      DaTaoKeGoodsResult result = null;

      if ("-1".equalsIgnoreCase(cid)) {

         result = DaTaoKeApiUtil.search("", null, null, new BigDecimal("10"), page, pageSize,

         result = DaTaoKeApiUtil.getGoodsList("", null, null, new BigDecimal("10"), null, page, pageSize,

               DaTaoKeApiUtil.SORT_DEFAULT);



         if (result == null || result.getGoodsList() == null || result.getGoodsList().size() == 0) {

            result = new DaTaoKeGoodsResult();

            result.setGoodsList(

                  daTaoKeGoodsDetailV2Service.listByMaxPrice(null, new BigDecimal("10"), null, page, pageSize));

            result.setTotalCount(daTaoKeGoodsDetailV2Service.countByMaxPrice(null, new BigDecimal("10")));

         }



      } else if ("0".equalsIgnoreCase(cid)) {

         result = DaTaoKeApiUtil.search("", null, null, new BigDecimal("10"), page, pageSize,

         result = DaTaoKeApiUtil.getGoodsList("", null, null, new BigDecimal("10"), null, page, pageSize,

               DaTaoKeApiUtil.SORT_CREATETIME);

         if (result == null || result.getGoodsList() == null || result.getGoodsList().size() == 0) {

            result = new DaTaoKeGoodsResult();

            result.setGoodsList(daTaoKeGoodsDetailV2Service.listByMaxPrice(null, new BigDecimal("10"), "createTime",

                  page, pageSize));

            result.setTotalCount(daTaoKeGoodsDetailV2Service.countByMaxPrice(null, new BigDecimal("10")));

         }

      } else {

         List<Integer> cidList = new ArrayList<>();

         cidList.add(Integer.parseInt(cid));

         result = DaTaoKeApiUtil.search("", cidList, null, new BigDecimal("10"), page, pageSize,

         result = DaTaoKeApiUtil.getGoodsList("", cidList, null, new BigDecimal("10"), null, page, pageSize,

               DaTaoKeApiUtil.SORT_DEFAULT);



         if (result == null || result.getGoodsList() == null || result.getGoodsList().size() == 0) {

            result = new DaTaoKeGoodsResult();

            result.setGoodsList(daTaoKeGoodsDetailV2Service.listByMaxPrice(Integer.parseInt(cid),

                  new BigDecimal("10"), null, page, pageSize));

            result.setTotalCount(

                  daTaoKeGoodsDetailV2Service.countByMaxPrice(Integer.parseInt(cid), new BigDecimal("10")));

         }

      }



      List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();

@@ -355,7 +386,7 @@
      List<Integer> cidList = new ArrayList<>();

      cidList.add(4);// 居家生活

      int sort = getCommonSort(cid);

      result = DaTaoKeApiUtil.search("", cidList, null, null, page, pageSize, sort);

      result = DaTaoKeApiUtil.getGoodsList("", cidList, null, null, null, page, pageSize, sort);

      List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();

      long count = 0;

      if (result != null) {

@@ -380,7 +411,7 @@
      List<Integer> cidList = new ArrayList<>();

      cidList.add(6);// 美食

      int sort = getCommonSort(cid);

      result = DaTaoKeApiUtil.search("", cidList, null, null, page, pageSize, sort);

      result = DaTaoKeApiUtil.getGoodsList("", cidList, null, null, null, page, pageSize, sort);

      List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();

      long count = 0;

      if (result != null) {

@@ -429,7 +460,9 @@
      if ("1".equalsIgnoreCase(cid)) {// 大淘客数据

         List<Integer> cidList = new ArrayList<>();

         cidList.add(2);// 母婴

         result = DaTaoKeApiUtil.search("", cidList, null, null, page, pageSize, DaTaoKeApiUtil.SORT_DEFAULT);

         result = DaTaoKeApiUtil.getGoodsList("", cidList, null, null, null, page, pageSize,

               DaTaoKeApiUtil.SORT_DEFAULT);



         List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();

         long count = 0;

         if (result != null) {

@@ -477,7 +510,8 @@
      List<Integer> cidList = new ArrayList<>();

      cidList.add(1);// 女装

      int sort = getCommonSort(cid);

      result = DaTaoKeApiUtil.search("内衣 女", cidList, null, null, page, pageSize, sort);

      result = DaTaoKeApiUtil.getGoodsList("", cidList, null, null, null, page, pageSize, sort);



      List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();

      long count = 0;

      if (result != null) {

@@ -637,7 +671,7 @@
      cidList.add(7);

      cidList.add(13);

      int sort = getCommonSort(cid);

      result = DaTaoKeApiUtil.search("", cidList, null, null, page, pageSize, sort);

      result = DaTaoKeApiUtil.getGoodsList("", cidList, null, null, null, page, pageSize, sort);

      DaTaoKeGoodsResult result1 = DaTaoKeApiUtil.search("运动 男", cidList, null, null, page, pageSize, sort);

      List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();

      long count = 0;

@@ -654,4 +688,58 @@
      return new CommonContentResult(goodsList, count);

   }



   /**

    * 获取免单商品

    * 
    * @return

    */

   private CommonContentResult getMianDanContent(int page, int pageSize) {

      CommonContentResult result = new CommonContentResult();

      List<QualityFactory> listQuery = qualityGoodsService.listFreeGoods((page - 1) * pageSize, pageSize);

      long count = qualityGoodsService.countFreeGoods();

      result.setCount(count);

      List<Long> listGid = new ArrayList<Long>();

      List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();

      for (QualityFactory qualityFactory : listQuery) {

         TaoBaoGoodsBrief taoBaoGoodsBrief = qualityFactory.getTaoBaoGoodsBrief();

         if (taoBaoGoodsBrief == null) {

            continue;

         }

         listGid.add(taoBaoGoodsBrief.getAuctionId());

         goodsList.add(taoBaoGoodsBrief);

      }

      // 去掉已经不在售的商品

      List<TaoBaoGoodsBrief> listTaoKeGoods = null;

      try {

         listTaoKeGoods = TaoKeApiUtil.getBatchGoodsInfo(listGid);

      } catch (TaoKeApiException e) {

         e.printStackTrace();

      } catch (TaobaoGoodsDownException e) {

         e.printStackTrace();

      } catch (Exception e) {

         e.printStackTrace();

      }

      Map<Long, TaoBaoGoodsBrief> goodsMap = new HashMap<>();

      if (listTaoKeGoods != null)

         for (TaoBaoGoodsBrief goods : listTaoKeGoods)

            goodsMap.put(goods.getAuctionId(), goods);

      for (int i = 0; i < goodsList.size(); i++) {

         if (goodsMap.get(goodsList.get(i).getAuctionId()) == null) {

            goodsList.remove(i--);

         }

      }

      // 过滤基本商品信息

      goodsList = taoBaoGoodsUpdateService.filterImportantTaoBaoGoods(goodsList);



      for (int i = 0; i < goodsList.size(); i++) {

         TaoBaoGoodsBrief goods = goodsList.get(i);

         BigDecimal price = TaoBaoUtil.getAfterUseCouplePrice(goods);

         if (price.compareTo(new BigDecimal(10)) >= 0) {

            goodsList.remove(i--);

         }

      }

      result.setGoodsList(goodsList);

      return result;

   }



}