订单商品类型处理

yujian

2019-07-29 cdd852f8e8eff7eb2e8f7c3fceaa955b9fc3f9d3

 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/GoodsControllerV2.java

@@ -14,9 +14,13 @@
import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.taobao.TbImgUtil;



import com.yeshi.fanli.dto.jd.JDCouponInfo;

import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;

import com.yeshi.fanli.dto.pdd.PDDGoodsResult;

import com.yeshi.fanli.dto.pdd.PDDSearchFilter;

import com.yeshi.fanli.entity.accept.AcceptData;

import com.yeshi.fanli.entity.bus.user.ShamUser;

import com.yeshi.fanli.entity.bus.user.UserInfo;

import com.yeshi.fanli.entity.bus.user.UserMoneyExtra;

import com.yeshi.fanli.entity.goods.CollectionGoodsV2;

import com.yeshi.fanli.entity.jd.JDGoods;

@@ -51,6 +55,7 @@
import com.yeshi.fanli.service.inter.user.TBPidService;

import com.yeshi.fanli.service.inter.user.UserGoodsStorageService;

import com.yeshi.fanli.service.inter.user.UserInfoExtraService;

import com.yeshi.fanli.service.inter.user.UserInfoService;

import com.yeshi.fanli.service.inter.user.UserMoneyExtraService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisManager;

@@ -58,11 +63,15 @@
import com.yeshi.fanli.util.TaoBaoConstant;

import com.yeshi.fanli.util.ThreadUtil;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.cache.JDGoodsCacheUtil;

import com.yeshi.fanli.util.cache.PinDuoDuoCacheUtil;

import com.yeshi.fanli.util.cache.TaoBaoGoodsCacheUtil;

import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;

import com.yeshi.fanli.util.factory.goods.ShopInfoVOFactory;

import com.yeshi.fanli.util.jd.JDApiUtil;

import com.yeshi.fanli.util.jd.JDUtil;

import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;

import com.yeshi.fanli.util.pinduoduo.PinDuoDuoUtil;

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

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

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

@@ -70,7 +79,8 @@
import com.yeshi.fanli.vo.goods.GoodsDetailVO;

import com.yeshi.fanli.vo.goods.MoneyInfoVO;

import com.yeshi.fanli.vo.goods.OtherInfo;

import com.yeshi.fanli.vo.goods.ShareInfoVO;

import com.yeshi.fanli.vo.goods.ShareVO;

import com.yeshi.fanli.vo.goods.ShopInfoVO;

import com.yeshi.fanli.vo.msg.ClientTextStyleVO;

import com.yeshi.fanli.vo.tlj.ReduceHongBao;

import com.yeshi.fanli.vo.tlj.SpreadHongBao;

@@ -147,43 +157,15 @@
   @Resource

   private TLJBuyGoodsService tljBuyGoodsService;

   

   @Resource

   private UserInfoService userInfoService;

   

   /**

    * 获取商品详情

    * 
    * @param acceptData

    * @param id

    * @param source

    * @param uid

    * @param from

    * @param out

    */

   @RequestMapping(value = "getDetail", method = RequestMethod.POST)

   public void getDetail(AcceptData acceptData, Long id, Integer goodsType, Long uid, String from, PrintWriter out) {

      if (id == null || goodsType == null) {

         out.print(JsonUtil.loadFalseResult(1, "商品id和商品平台不能为空"));

         return;

      }

   @Resource

   private JDGoodsCacheUtil jdGoodsCacheUtil;



      // 淘宝商品

      if (Constant.SOURCE_TYPE_TAOBAO == goodsType) {

         getTaoBaoGoodsDetial(acceptData, id, uid, from, out);

         return;

      }

   @Resource

   private PinDuoDuoCacheUtil pinDuoDuoCacheUtil;



      // 京东商品

      if (Constant.SOURCE_TYPE_JD == goodsType) {

         getJDGoodsDetial(acceptData, id, uid, from, out);

         return;

      }



      // 拼多多商品

      if (Constant.SOURCE_TYPE_PDD == goodsType) {

         getPDDGoodsDetial(acceptData, id, uid, from, out);

         return;

      }

   }

	
   

   /**

    * 淘宝商品详情

@@ -193,12 +175,13 @@
    * @param from

    * @param out

    */

   public void getTaoBaoGoodsDetial(AcceptData acceptData, Long id, Long uid, String from, PrintWriter out) {

   @RequestMapping(value = "getDetailTB", method = RequestMethod.POST)

   public void getDetialTB(AcceptData acceptData, Long id, Long uid, String from, PrintWriter out) {

      if (id == null) {

         out.print(JsonUtil.loadFalseResult(1, "请上传id"));

         out.print(JsonUtil.loadFalseResult(1, "商品id不能为空"));

         return;

      }



		
      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),

            acceptData.getPackages());

      if (system == null) {

@@ -347,10 +330,10 @@
      

      BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();

      BigDecimal shareRate = hongBaoManageService.getShareRate();

      GoodsDetailVO goodsDetail = GoodsDetailVOFactory.convertTaoBao(tb, null, fanLiRate, shareRate);

      GoodsDetailVO goodsDetail = GoodsDetailVOFactory.convertTaoBao(goods, null, fanLiRate, shareRate);

      

      // 店铺信息

      TaoBaoShop shop = taoBaoShopService.getTaoBaoShop(goods.getAuctionId(), goods.getSellerId());

      TaoBaoShop shop = taoBaoShopService.getTaoBaoShop(id, goods.getSellerId());

      if (shop != null) {

         String shopLink = shop.getShopLink();

         if (StringUtil.isNullOrEmpty(shopLink)) {

@@ -451,11 +434,11 @@


         SpreadHongBao spreadHongBao = new SpreadHongBao();

         if (isNewUser) {

            spreadHongBao.setMoney("¥1");

            spreadHongBao.setMoney("1");

         } else {

            moneyType = 2;

            fanliValid = false;

            spreadHongBao.setMoney("¥" + spreadMoney.toString());

            spreadHongBao.setMoney(spreadMoney.toString());

            

            ClientTextStyleVO textStyleVO1 = new ClientTextStyleVO();

            textStyleVO1.setContent("分享");

@@ -512,7 +495,7 @@
         ReduceHongBao reduceHongBao = new ReduceHongBao();

         reduceHongBao.setLeft(buyGoods.getLeftHongBaoCount());

         reduceHongBao.setMoney(tljHongBao);

         reduceHongBao.setName("付款立减 ¥" + tljHongBao);

         reduceHongBao.setName("付款立减 ");

         reduceHongBao.setTip("当日领取，当日内使用，过期失效");

         reduceHongBao.setTotal(buyGoods.getTotalHongBaoCount());

         

@@ -537,7 +520,7 @@
      

      // 分享路径

      String shareUrl = String.format("%s?id=" + id, Constant.systemCommonConfig.getAppShareInfoUrl());

      ShareInfoVO shareInfoVO = new ShareInfoVO();

      ShareVO shareInfoVO = new ShareVO();

      shareInfoVO.setUrl(shareUrl);

      shareInfoVO.setHelpLink(helpLink);

      extraVO.setShare(shareInfoVO);

@@ -570,7 +553,8 @@
    * @param from

    * @param out

    */

   public void getJDGoodsDetial(AcceptData acceptData, Long id, Long uid, String from, PrintWriter out) {

   @RequestMapping(value = "getDetailJD", method = RequestMethod.POST)

   public void getDetialJD(AcceptData acceptData, Long id, Long uid, String from, PrintWriter out) {

      // 系统验证

      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),

            acceptData.getPackages());

@@ -579,20 +563,38 @@
         return;

      }



      JDGoods jdGoods = JDApiUtil.queryGoodsDetail(id);

      JDGoods jdGoods = JDApiUtil.queryGoodsDetail(id); // 高级接口

      if (jdGoods == null) {

         jdGoods = JDApiUtil.getGoodsDetail(id);

         jdGoods = JDUtil.getGoodsDetail(id); // 爬取网页

         //jdGoods = JDApiUtil.getGoodsDetail(id); // 普通接口

      }

      

      if (jdGoods == null) {

         out.print(JsonUtil.loadFalseResult(2, "商品不存在"));

         return;

      }

		
      List<String> imageList = jdGoods.getImageList();

      if (imageList == null) {

         imageList = new ArrayList<String>();

         imageList.add(jdGoods.getPicUrl());

      }

		
      // 保存缓存

      jdGoodsCacheUtil.saveGoodsInfo(jdGoods);



      BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();

      BigDecimal shareRate = hongBaoManageService.getShareRate();

      GoodsDetailVO goodsDetail = GoodsDetailVOFactory.convertJDGoods(jdGoods, null, fanLiRate, shareRate);



      ShopInfoVO shopInfo = goodsDetail.getShopInfo();

      if (shopInfo != null) {

         if (shopInfo.getId() == null || shopInfo.getScoreGoods() == null || shopInfo.getScoreLogistics() == null

               || shopInfo.getScoreSeller() == null) {

            goodsDetail.setShopInfo(null);

         }

      }

		
      

      GoodsDetailExtraVO extraVO = new GoodsDetailExtraVO();

      extraVO.setIsNative(false);

@@ -665,7 +667,7 @@
      // 分享路径

      String shareUrl = String.format("%s?id=" + jdGoods.getSkuId(),

            Constant.systemCommonConfig.getAppShareInfoUrl());

      ShareInfoVO shareInfoVO = new ShareInfoVO();

      ShareVO shareInfoVO = new ShareVO();

      shareInfoVO.setUrl(shareUrl);

      shareInfoVO.setHelpLink(helpLink);

      extraVO.setShare(shareInfoVO);

@@ -689,7 +691,7 @@
   }



   /**

    * 京东商品详情

    * 拼多多商品详情

    * 

    * @param acceptData

    * @param id

@@ -697,7 +699,8 @@
    * @param from

    * @param out

    */

   public void getPDDGoodsDetial(AcceptData acceptData, Long id, Long uid, String from, PrintWriter out) {

   @RequestMapping(value = "getDetailPDD", method = RequestMethod.POST)

   public void getDetialPDD(AcceptData acceptData, Long id, Long uid, String from, PrintWriter out) {

      // 系统验证

      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),

            acceptData.getPackages());

@@ -716,6 +719,14 @@
      BigDecimal shareRate = hongBaoManageService.getShareRate();

      GoodsDetailVO goodsDetail = GoodsDetailVOFactory.convertPDDGoods(pddGoods, null, fanLiRate, shareRate);



      ShopInfoVO shopInfo = goodsDetail.getShopInfo();

      if (shopInfo != null) {

         if (shopInfo.getId() == null || shopInfo.getScoreGoods() == null || shopInfo.getScoreLogistics() == null

               || shopInfo.getScoreSeller() == null) {

            goodsDetail.setShopInfo(null);

         }

      }

		
      GoodsDetailExtraVO extraVO = new GoodsDetailExtraVO();

      extraVO.setIsNative(false);

      // IOS是否正在上线

@@ -723,26 +734,38 @@
         String version = acceptData.getVersion();

         extraVO.setIosOnling(configService.iosOnLining(Integer.parseInt(version)));

      }



      

      Long inOrderCount30Days = pddGoods.getSoldQuantity();

      List<ShamUser> listShareUser = new ArrayList<ShamUser>();

      MoneyInfoVO moneyInfo = goodsDetail.getMoneyInfo();

      if (moneyInfo != null) {

         String shareMoney = moneyInfo.getShareMoney().replaceAll("¥", "");

         if (Integer.parseInt(inOrderCount30Days.toString()) >= 50000) {

            listShareUser = shamUserService.listRandShareUser(10, new BigDecimal(shareMoney), 1, 5);

      // 图文详情

      extraVO.setDetailUrl("http://apph5.yeshitv.com/apppage/goods_img_pdd.html?id="+ id);

		
      String salesTip = pddGoods.getSalesTip();

      if (!StringUtil.isNullOrEmpty(salesTip)) {

         int totalSales = 0;

         if (salesTip.contains("万")) {

            salesTip = salesTip.substring(0, salesTip.indexOf("万"));

            totalSales= (int) (Float.parseFloat(salesTip) * 10000);

         } else {

            totalSales = Integer.parseInt(salesTip);

         }

      }

      extraVO.setListShareUser(listShareUser);

			
         List<ShamUser> listShareUser = new ArrayList<ShamUser>();

         MoneyInfoVO moneyInfo = goodsDetail.getMoneyInfo();

         if (moneyInfo != null) {

            String shareMoney = moneyInfo.getShareMoney().replaceAll("¥", "");

            if (totalSales >= 50000) {

               listShareUser = shamUserService.listRandShareUser(10, new BigDecimal(shareMoney), 1, 5);

            }

         }

         extraVO.setListShareUser(listShareUser);



      // 领券人列表

      List<ShamUser> listCouponUser = new ArrayList<ShamUser>();

      if (goodsDetail.isHasCoupon() && Integer.parseInt(inOrderCount30Days.toString()) >= 50000) {

         listCouponUser = shamUserService.listRandCouponUser(5, 1, 300);

         // 领券人列表

         List<ShamUser> listCouponUser = new ArrayList<ShamUser>();

         if (goodsDetail.isHasCoupon() && totalSales >= 50000) {

            listCouponUser = shamUserService.listRandCouponUser(5, 1, 300);

         }

         extraVO.setListCouponUser(listCouponUser);

      }

      extraVO.setListCouponUser(listCouponUser);



		
      if (uid != null) {

         // 是否加入收藏

         CollectionGoodsV2 collectionGoods = collectionGoodsV2Service.findByUidAndAuctionId(uid, id,

@@ -777,7 +800,7 @@
      }

      // 分享路径

      String shareUrl = String.format("%s?id=" + id, Constant.systemCommonConfig.getAppShareInfoUrl());

      ShareInfoVO shareInfoVO = new ShareInfoVO();

      ShareVO shareInfoVO = new ShareVO();

      shareInfoVO.setUrl(shareUrl);

      shareInfoVO.setHelpLink(helpLink);

      extraVO.setShare(shareInfoVO);

@@ -816,8 +839,29 @@
      // 京东

      if (goodsType == Constant.SOURCE_TYPE_JD) {

         JSONObject data = new JSONObject();

         data.put("listQuality", JsonUtil.getApiCommonGson().toJson(new ArrayList<GoodsDetailVO>()));

         data.put("listGuess", JsonUtil.getApiCommonGson().toJson(new ArrayList<GoodsDetailVO>()));

		
         List<JDGoods> list = JDUtil.getRecommendGoodsById(id);

         if (list == null) {

            list = new ArrayList<JDGoods>();

         } else if (list.size() > 10) {

            list = list.subList(0, 10);

         }

			
         BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();

         BigDecimal shareRate = hongBaoManageService.getShareRate();

         List<GoodsDetailVO> listDetailVO = new ArrayList<GoodsDetailVO>();

			
         for (JDGoods goods: list) {

            listDetailVO.add(GoodsDetailVOFactory.convertJDGoods(goods, null, fanLiRate, shareRate));

         }

			
         // 取偶数个数据

         if (listDetailVO.size() % 2 != 0) {

            listDetailVO.remove(listDetailVO.size() - 1);

         }

						
         data.put("listQuality", JsonUtil.getApiCommonGson().toJson(listDetailVO));

         out.print(JsonUtil.loadTrueResult(data));

         return;

      }

@@ -825,8 +869,42 @@
      // 拼多多

      if (goodsType == Constant.SOURCE_TYPE_PDD) {

         JSONObject data = new JSONObject();

         data.put("listQuality", JsonUtil.getApiCommonGson().toJson(new ArrayList<GoodsDetailVO>()));

         data.put("listGuess", JsonUtil.getApiCommonGson().toJson(new ArrayList<GoodsDetailVO>()));

			
         List<GoodsDetailVO> listDetailVO = new ArrayList<GoodsDetailVO>();

			
         List<Long> goodsIdList = PinDuoDuoUtil.getRecommendGoodsId(id);

         if (goodsIdList != null && goodsIdList.size() > 0) {

            PDDSearchFilter pddfilter = new PDDSearchFilter();

            pddfilter.setPage(1);

            pddfilter.setPageSize(Constant.PAGE_SIZE);

            Long[] strings = new Long[goodsIdList.size()];

            pddfilter.setGoodsIdList(goodsIdList.toArray(strings));

				
            PDDGoodsResult result = PinDuoDuoApiUtil.searchGoods(pddfilter);

            if (result != null) {

               List<PDDGoodsDetail> goodsList = result.getGoodsList();

               if (goodsList != null && goodsList.size() > 0) {

						
                  if (goodsList.size() > 10) {

                     goodsList = goodsList.subList(0, 10);

                  }

						
                  BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();

                  BigDecimal shareRate = hongBaoManageService.getShareRate();

                  for (PDDGoodsDetail goods : goodsList) {

                     listDetailVO.add(GoodsDetailVOFactory.convertPDDGoods(goods, null, fanLiRate, shareRate));

                  }

               }

            }

         }

			
         // 取偶数个数据

         if (listDetailVO.size() % 2 != 0) {

            listDetailVO.remove(listDetailVO.size() - 1);

         }

			
         data.put("listQuality", JsonUtil.getApiCommonGson().toJson(listDetailVO));

         out.print(JsonUtil.loadTrueResult(data));

         return;

      }

@@ -905,5 +983,93 @@
      out.print(JsonUtil.loadTrueResult(data));

   }



	
	
   /**

    * 京东购买链接

    * @param acceptData

    * @param uid

    * @param id

    * @param source

    * @param request

    * @param out

    */

   @RequestMapping(value = "getJDLink")

   public void getJDLink(AcceptData acceptData, Long uid, Long id, String source, PrintWriter out) {

      if (uid == null || uid <= 0) {

         out.print(JsonUtil.loadFalseResult(1, "用户ID不能为空"));

         return;

      }



      if (id == null || id <= 0) {

         out.print(JsonUtil.loadFalseResult(1, "商品ID不能为空"));

         return;

      }

		
      UserInfo user = userInfoService.getUserByIdWithMybatis(uid);

      if (user != null && user.getState() != UserInfo.STATE_NORMAL) {

         out.print(JsonUtil.loadFalseResult(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC));

         return;

      }



      JDGoods goods = jdGoodsCacheUtil.getGoodsInfo(id);

      if (goods == null) {

         out.print(JsonUtil.loadFalseResult(2, "商品已下架"));

         return;

      }



      String couponUrl = null;

      String materialId = "https://item.jd.com/" + id + ".html";

      JDCouponInfo couponInfo = goods.getCouponInfo();

      if (couponInfo != null) {

         couponUrl = couponInfo.getLink();

      }

      String jumpLink = JDApiUtil.convertLink(materialId, couponUrl, JDApiUtil.POSITION_FANLI + "", id + "");

		
      JSONObject data = new JSONObject();

      data.put("native", true);

      data.put("jumpLink", jumpLink);

      out.print(JsonUtil.loadTrueResult(data));

   }



	
   /**

    * 拼多多购买链接

    * @param acceptData

    * @param uid

    * @param id

    * @param source

    * @param request

    * @param out

    */

   @RequestMapping(value = "getPDDLink")

   public void getPDDLink(AcceptData acceptData, Long uid, Long id, String source, PrintWriter out) {

      if (uid == null || uid <= 0) {

         out.print(JsonUtil.loadFalseResult(1, "用户ID不能为空"));

         return;

      }



      if (id == null || id <= 0) {

         out.print(JsonUtil.loadFalseResult(1, "商品ID不能为空"));

         return;

      }

		
      UserInfo user = userInfoService.getUserByIdWithMybatis(uid);

      if (user != null && user.getState() != UserInfo.STATE_NORMAL) {

         out.print(JsonUtil.loadFalseResult(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC));

         return;

      }



      PDDGoodsDetail goods = pinDuoDuoCacheUtil.getGoodsInfo(id);

      if (goods == null) {

         out.print(JsonUtil.loadFalseResult(2, "商品已下架"));

         return;

      }



      String jumpLink = PinDuoDuoApiUtil.convert(id, PinDuoDuoApiUtil.PID_FANLI + "", uid + "");

      JSONObject data = new JSONObject();

      data.put("native", true);

      data.put("jumpLink", jumpLink);

      out.print(JsonUtil.loadTrueResult(data));

   }

}