独立淘宝商品缓存，增加分享模板

admin

2019-04-11 6f3eb63c05041b388a7252bdd42494848f237b3c

 fanli/src/main/java/com/yeshi/fanli/controller/client/RecommendController.java

@@ -62,6 +62,7 @@
import com.yeshi.fanli.entity.taobao.TaoKeAppInfo;

import com.yeshi.fanli.exception.goods.CommonGoodsException;

import com.yeshi.fanli.exception.goods.ScanHistoryException;

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

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

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

import com.yeshi.fanli.exception.user.UserCustomSettingsException;

@@ -103,6 +104,7 @@
import com.yeshi.fanli.util.TaoBaoConstant;

import com.yeshi.fanli.util.ThreadUtil;

import com.yeshi.fanli.util.TimeUtil;

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

import com.yeshi.fanli.util.factory.MonitorFactory;

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

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

@@ -221,6 +223,9 @@


   @Resource

   private UserInfoExtraService userInfoExtraService;



   @Resource

   private TaoBaoGoodsCacheUtil taoBaoGoodsCacheUtil;



   @RequestMapping(value = "getHonestList")

   public void getHonestList(AcceptData acceptData, PrintWriter out) {

@@ -1622,105 +1627,98 @@


      LogHelper.test("获取PID耗时：" + (java.lang.System.currentTimeMillis() - startTime));



      final String clientPid = clientTBPid.getPid();

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

      // 是否在服务端进行转链

      boolean convertInServer = configService.isConvertTaoBaoLinkInServer();



      List<String> taskList = new ArrayList<>();

      // 获取商品基本信息

      taskList.add("goods");

      JSONObject ticket = new JSONObject();

      TaoBaoGoodsBrief goods = null;



      taskList.stream().parallel().forEach(task -> {

         if (task.equalsIgnoreCase("goods")) {

            JSONObject ticket = new JSONObject();

            TaoBaoGoodsBrief goods = null;



            if (!convertInServer) {



               try {

                  goods = redisManager.getTaoBaoGoodsBrief(Long.parseLong(id));

                  if (goods.getTkRate() == null || new BigDecimal(0).compareTo(goods.getTkRate()) == 0) {

                     String appId = clientPid.split("_")[2];

                     TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppIdCache(appId);

                     TaoKeAppInfo app = new TaoKeAppInfo();

                     app.setAdzoneId(clientPid.split("_")[3]);

                     app.setAppKey(config.getAppKey());

                     app.setAppSecret(config.getAppSecret());

                     app.setPid(clientPid);

                     TaoBaoGoodsBrief linkInfo = TaoKeApiUtil.specialConvertCoupon(goods.getAuctionId(), app);

                     if (linkInfo != null) {

                        goods.setAuctionUrl(linkInfo.getAuctionUrl());

                        goods.setCouponLink(linkInfo.getCouponLink());

                        goods.setTkRate(linkInfo.getTkRate());

                     }

                  }

               } catch (TaobaoGoodsDownException e) {

                  // 商品下架

                  ThreadUtil.run(new Runnable() {

                     public void run() {

                        taoBaoGoodsUpdateService.offlineTaoBaoGoods(Long.parseLong(id));

                     }

                  });



               }



            } else {

               String appId = clientPid.split("_")[2];

               TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppIdCache(appId);

      if (!convertInServer) {

         try {

            goods = taoBaoGoodsCacheUtil.getCommonTaoBaoGoodsInfo(Long.parseLong(id));

            if (goods == null) {

               TaoKeAppInfo app = new TaoKeAppInfo();

               app.setAdzoneId(clientPid.split("_")[3]);

               app.setAppKey(config.getAppKey());

               app.setAppSecret(config.getAppSecret());

               app.setPid(clientPid);



               try {

                  goods = TaoKeApiUtil.searchGoodsDetail(Long.parseLong(id), app);

                  if (goods != null) {

                     ticket.put("clickUrl", goods.getAuctionUrl());

                     // 测试使用

                     ticket.put("couponUrl", goods.getCouponLink());

                     data.put("ticket", ticket);

                  }



                  if (goods.getTkRate() == null || new BigDecimal(0).compareTo(goods.getTkRate()) == 0) {

                     TaoBaoGoodsBrief linkInfo = TaoKeApiUtil.specialConvertCoupon(goods.getAuctionId(), app);

                     if (linkInfo != null) {

                        goods.setAuctionUrl(linkInfo.getAuctionUrl());

                        goods.setCouponLink(linkInfo.getCouponLink());

                        goods.setTkRate(linkInfo.getTkRate());

                     }

                  }



               } catch (NumberFormatException e) {

                  e.printStackTrace();

               } catch (TaobaoGoodsDownException e) {

               app.setAppKey(TaoBaoConstant.TAOBAO_COMMON_APPKEY);

               app.setAppSecret(TaoBaoConstant.TAOBAO_COMMON_APPSECRET);

               app.setPid(TaoBaoConstant.TAOBAO_COMMON_PID);

               app.setAdzoneId(TaoBaoConstant.TAOBAO_COMMON_PID.split("_")[3]);

               goods = TaoKeApiUtil.searchGoodsDetail(Long.parseLong(id), app);

               final TaoBaoGoodsBrief finalGoods = goods;

               if (goods != null) {

                  ThreadUtil.run(new Runnable() {

                     @Override

                     public void run() {

                        taoBaoGoodsUpdateService.offlineTaoBaoGoods(Long.parseLong(id));

                        taoBaoGoodsCacheUtil.saveCommonTaoBaoGoodsInfo(finalGoods);

                     }

                  });

               }



            }

         } catch (TaobaoGoodsDownException e) {

            // 商品下架

            ThreadUtil.run(new Runnable() {

               public void run() {

                  taoBaoGoodsUpdateService.offlineTaoBaoGoods(Long.parseLong(id));

               }

            });



            if (goods != null) {

               goodsList.add(goods);

               final TaoBaoGoodsBrief newGoods = goods;

               ThreadUtil.run(new Runnable() {

                  public void run() {

                     try {

                        // 更新商品

                        LogHelper.test("更新商品详情:" + newGoods.getAuctionId());

                        taoBaoGoodsUpdateService.updateTaoBaoGoods(newGoods);

                     } catch (TaobaoGoodsUpdateException e) {



                     }

                  }

               });

            }

         }

      });



      } else {

         final String clientPid = clientTBPid.getPid();

         String appId = clientPid.split("_")[2];

         TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppIdCache(appId);

         TaoKeAppInfo app = new TaoKeAppInfo();

         app.setAdzoneId(clientPid.split("_")[3]);

         app.setAppKey(config.getAppKey());

         app.setAppSecret(config.getAppSecret());

         app.setPid(clientPid);



         try {

            goods = TaoKeApiUtil.searchGoodsDetail(Long.parseLong(id), app);

            if (goods != null) {

               ticket.put("clickUrl", goods.getAuctionUrl());

               // 测试使用

               ticket.put("couponUrl", goods.getCouponLink());

               data.put("ticket", ticket);

            }



            if (goods.getTkRate() == null || new BigDecimal(0).compareTo(goods.getTkRate()) == 0) {

               TaoBaoGoodsBrief linkInfo = TaoKeApiUtil.specialConvertCoupon(goods.getAuctionId(), app);

               if (linkInfo != null) {

                  goods.setAuctionUrl(linkInfo.getAuctionUrl());

                  goods.setCouponLink(linkInfo.getCouponLink());

                  goods.setTkRate(linkInfo.getTkRate());

               }

            }



         } catch (NumberFormatException e) {

            e.printStackTrace();

         } catch (TaobaoGoodsDownException e) {

            ThreadUtil.run(new Runnable() {

               public void run() {

                  taoBaoGoodsUpdateService.offlineTaoBaoGoods(Long.parseLong(id));

               }

            });

         }



      }



      if (goods != null) {

         goodsList.add(goods);

         final TaoBaoGoodsBrief newGoods = goods;

         ThreadUtil.run(new Runnable() {

            public void run() {

               try {

                  // 更新商品

                  LogHelper.test("更新商品详情:" + newGoods.getAuctionId());

                  taoBaoGoodsUpdateService.updateTaoBaoGoods(newGoods);

               } catch (TaobaoGoodsUpdateException e) {



               }

            }

         });

      }



      TaoBaoGoodsBrief tb = null;

      if (goodsList.size() > 0) {

@@ -1743,17 +1741,19 @@
      for (String img : tb.getImgList()) {

         finalImgList.add(TbImgUtil.getTBSizeImg(img, 600));

      }

      if (!StringUtil.isNullOrEmpty(tb.getPictUrlWhite()))

         finalImgList.add(0, tb.getPictUrlWhite());



      JSONObject goods = new JSONObject();

      goods.put("auctionId", tb.getAuctionId());

      goods.put("imgList", finalImgList);

      goods.put("title", tb.getTitle());

      goods.put("userType", tb.getUserType() == 1 ? 2 : 1);

      goods.put("price", tb.getReservePrice().toString());

      goods.put("zkPrice", tb.getZkPrice().toString());

      JSONObject goodsJson = new JSONObject();

      goodsJson.put("auctionId", tb.getAuctionId());

      goodsJson.put("imgList", finalImgList);

      goodsJson.put("title", tb.getTitle());

      goodsJson.put("userType", tb.getUserType() == 1 ? 2 : 1);

      goodsJson.put("price", tb.getReservePrice().toString());

      goodsJson.put("zkPrice", tb.getZkPrice().toString());



      // 30天销量

      goods.put("saleCount", TaoBaoUtil.getSaleCount(tb.getBiz30day()));

      goodsJson.put("saleCount", TaoBaoUtil.getSaleCount(tb.getBiz30day()));



      // 分享赚

      BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(tb);

@@ -1787,7 +1787,7 @@
      LogHelper.test(String.format("PID: uid-%s  pid-%s", uid + "", pid));



      // 是否有券

      goods.put("coupon", StringUtil.isNullOrEmpty(tb.getCouponInfo()) ? false : true);

      goodsJson.put("coupon", StringUtil.isNullOrEmpty(tb.getCouponInfo()) ? false : true);



      // 领券人列表

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

@@ -1816,19 +1816,21 @@
         tb.setCouponLinkTaoToken(token);



         // 服务端转链

//         if (convertInServer && !StringUtil.isNullOrEmpty(tb.getCouponLink())) {

            couponInfo.put("couponUrl", tb.getCouponLink());

//         } else {

//            couponInfo.put("couponUrl",

//                  TaoBaoCouponUtil.getCoupleUrl(tb.getCouponActivityId() + "", pid, tb.getAuctionId() + ""));

//         }

         // if (convertInServer &&

         // !StringUtil.isNullOrEmpty(tb.getCouponLink())) {

         couponInfo.put("couponUrl", tb.getCouponLink());

         // } else {

         // couponInfo.put("couponUrl",

         // TaoBaoCouponUtil.getCoupleUrl(tb.getCouponActivityId() + "", pid,

         // tb.getAuctionId() + ""));

         // }



         couponInfo.put("couponAmount", NumberUtil.subZeroAndDot(tb.getCouponAmount().toString()));

         couponInfo.put("couponTime", "使用期限：" + tb.getCouponEffectiveStartTime().replace("-", ".") + "-"

               + tb.getCouponEffectiveEndTime().replace("-", "."));

         // 券的口令

         couponInfo.put("couponToken", token);

         goods.put("couponInfo", couponInfo);

         goodsJson.put("couponInfo", couponInfo);



         if (tb.getBiz30day() >= 1000) {

            // 领券人列表

@@ -1841,7 +1843,7 @@
         BigDecimal proportion = manageService.getFanLiRate();

         hongBao = TaoBaoUtil.getGoodsHongBaoInfo(tb, proportion);

      }

      goods.put("hongBao", hongBao);

      goodsJson.put("hongBao", hongBao);



      data.put("tbPidInfo", clientTBPid);



@@ -1859,7 +1861,7 @@
         else

            jumpUrl = tb.getAuctionUrl();

      }

      goods.put("jumpUrl", jumpUrl);

      goodsJson.put("jumpUrl", jumpUrl);



      TaoBaoShopInfo tbShopInfo = redisManager.getTBShopInfo(tb.getShopTitle(), tb.getSellerId(), tb.getAuctionId());

      if (tbShopInfo != null) {

@@ -1871,7 +1873,7 @@
         }

      }

      // 店铺

      goods.put("shopInfo", tbShopInfo);

      goodsJson.put("shopInfo", tbShopInfo);



      // 分享路径

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

@@ -1885,7 +1887,7 @@
      data.put("storageState", storageState);

      data.put("shareUrl", shareUrl);



      data.put("goods", goods);

      data.put("goods", goodsJson);

      data.put("shareUsers", listShareUser);

      data.put("couponUsers", listCouponUser);

      data.put("detailWebUrl", "http://apph5.yeshitv.com/apppage/goods_img.html?id=" + id);

@@ -2009,20 +2011,48 @@


      List<TaoBaoGoodsBriefExtra> listExtra = new ArrayList<TaoBaoGoodsBriefExtra>();



      goodsList.parallelStream().forEach(goods -> {

         // 获取详情

         TaoBaoGoodsBrief taoBaoGoodsBrief = null;

         try {

            taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(goods.getAuctionId());

         } catch (Exception e) {

            e.printStackTrace();

         }

      TaoKeAppInfo app = new TaoKeAppInfo();

      app.setAppKey(TaoBaoConstant.TAOBAO_AUTH_APPKEY);

      app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET);

      app.setAdzoneId(TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT.split("_")[3]);

      app.setPid(TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT);



         if (taoBaoGoodsBrief != null) {

            listExtra.add(TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), ""));

         }

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

      for (TaoBaoGoodsBrief goods : goodsList)

         ids.add(goods.getAuctionId());



      });

      try {

         goodsList = TaoKeApiUtil.getBatchGoodsInfo(ids);

      } catch (TaoKeApiException e1) {

         e1.printStackTrace();

      } catch (TaobaoGoodsDownException e1) {

         e1.printStackTrace();

      }



      if (goodsList != null)

         goodsList.parallelStream().forEach(goods -> {



            // 获取详情

            TaoBaoGoodsBrief taoBaoGoodsBrief = null;

            try {

               taoBaoGoodsBrief = taoBaoGoodsCacheUtil.getCommonTaoBaoGoodsInfo(goods.getAuctionId());

            } catch (Exception e) {

               e.printStackTrace();

            }



            if (taoBaoGoodsBrief == null) {

               TaoBaoGoodsBrief newGoods = TaoKeApiUtil.specialConvertCoupon(goods.getAuctionId(), app);

               goods.setCouponInfo(newGoods.getCouponInfo());

               goods.setCouponLink(newGoods.getCouponLink());

               goods.setTkRate(newGoods.getTkRate());

               taoBaoGoodsBrief = goods;

            }



            if (taoBaoGoodsBrief != null) {

               listExtra.add(TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), ""));

            }



         });



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

      // 删除推荐