admin
2019-07-11 3824cbcaec6e6c67418d5280a53e9c2fedeef6f9
fanli/src/main/java/com/yeshi/fanli/controller/client/v1/GoodsController.java
@@ -19,6 +19,7 @@
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.entity.taobao.TaoBaoLink;
import com.yeshi.fanli.entity.taobao.TaoBaoUnionConfig;
import com.yeshi.fanli.exception.ShareGoodsException;
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.goods.ShareGoodsService;
@@ -27,8 +28,10 @@
import com.yeshi.fanli.service.inter.monitor.MonitorService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoBuyRelationMapService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;
import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinRecordService;
import com.yeshi.fanli.service.inter.user.TBPidService;
import com.yeshi.fanli.service.inter.user.UserExtraTaoBaoInfoService;
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
import com.yeshi.fanli.service.inter.user.UserInfoService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
@@ -69,6 +72,30 @@
   @Resource
   private RecommendGoodsDeleteHistoryService recommendGoodsDeleteHistoryService;
   @Resource
   private UserInfoExtraService userInfoExtraService;
   @Resource
   private UserTaoLiJinRecordService userTaoLiJinRecordService;
   private void doTaoLiJinBuy(Long uid, Long auctionId, PrintWriter out) {
      JSONObject data = new JSONObject();
      TaoBaoLink taoBaoLink;
      try {
         taoBaoLink = shareGoodsService.getTaoLiJinLinkForBuyWithOutFanLi(uid, auctionId);
      } catch (ShareGoodsException e) {
         out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMessage()));
         return;
      }
      data.put("native", true);
      JSONObject link = new JSONObject();
      link.put("clickUrl", taoBaoLink.getClickUrl());
      link.put("couponUrl", taoBaoLink.getCouponLink());
      data.put("type", 1);
      data.put("link", link);
      out.print(JsonUtil.loadTrueResult(data));
   }
   /**
    * 获取淘宝的分享链接
    * 
@@ -79,8 +106,8 @@
    * @param out
    */
   @RequestMapping(value = "gettaobaolink")
   public void getTaoBaoLink(AcceptData acceptData, Long uid, Long auctionId, String from, HttpServletRequest request,
         PrintWriter out) {
   public void getTaoBaoLink(AcceptData acceptData, Long uid, Long auctionId, String from, String source,
         HttpServletRequest request, PrintWriter out) {
      if (uid == null || uid <= 0) {
         out.print(JsonUtil.loadFalseResult(1, "用户ID不能为空"));
         return;
@@ -110,6 +137,11 @@
         } catch (Exception e1) {
            e1.printStackTrace();
         }
      }
      if ("taolijin_buy".equalsIgnoreCase(source)) {
         doTaoLiJinBuy(uid, auctionId, out);
         return;
      }
      JSONObject data = new JSONObject();
@@ -150,202 +182,26 @@
         pidType = PidUser.TYPE_FANLI_IOS;
      try {
         TaoBaoLink taoBaoLink = null;
         // 是返利商品库的商品
         if (specialConvert) {
            if (!StringUtil.isNullOrEmpty(specialId)) {
               taoBaoLink = shareGoodsService.getTaoBaoLinkForBuyWithSpecial(uid, specialId, auctionId);
               data.put("native", true);
            } else {
               if (!specialConvert && !isNative) {
                  if (pidType == PidUser.TYPE_FANLI_ANDROID)
                     taoBaoLink = shareGoodsService.getTaoBaoLink(uid, auctionId,
                           tbPidService.getAndroidDefault().getPid());
                  else
                     taoBaoLink = shareGoodsService.getTaoBaoLink(uid, auctionId,
                           tbPidService.getIOSDefault().getPid());
               if (source != null && "taolijin".equals(source)) {
                  boolean isNewUser = userInfoExtraService.isNewUser(uid);
                  if (isNewUser) {
                     // 判定为老用户:
                     // 新人只要使用了新人红包,也就是那1块钱,那么,他看到的分享爆款中的商品-就只能分享。
                     long countRecord = userTaoLiJinRecordService.countRecordByUid(uid);
                     if (countRecord == 0) {
                        taoBaoLink = shareGoodsService.getTaoLiJinLinkForBuy(uid, specialId, auctionId, null);
                     }
                  }
               }
               } else
                  taoBaoLink = shareGoodsService.getTaoBaoLinkForBuy(uid, auctionId, pidType);
               LogHelper.test("购买转链:默认PID转链-" + uid + ":" + auctionId);
            }
         } else {// 不是返利库的商品,用特殊PID替代
            try {
               relationId = taoBaoBuyRelationMapService.getRelationId(uid);
            } catch (Exception e) {
               LogHelper.errorDetailInfo(e, "uid:" + uid, null);
            }
            if (!StringUtil.isNullOrEmpty(relationId)) {//
               taoBaoLink = shareGoodsService.getTaoBaoLinkForShare(uid, auctionId, relationId,
                     TaoBaoConstant.TAOBAO_RELATION_AS_SPECIAL_PID);
               data.put("native", true);
            } else {
               if (pidType == PidUser.TYPE_FANLI_ANDROID)
                  taoBaoLink = shareGoodsService.getTaoBaoLink(uid, auctionId,
                        tbPidService.getAndroidDefault().getPid());
               else
                  taoBaoLink = shareGoodsService.getTaoBaoLink(uid, auctionId,
                        tbPidService.getIOSDefault().getPid());
               LogHelper.test("购买转链:默认PID转链-非返利库商品-" + uid + ":" + auctionId);
            }
         }
         JSONObject link = new JSONObject();
         link.put("clickUrl", taoBaoLink.getClickUrl());
         link.put("couponUrl", taoBaoLink.getCouponLink());
         data.put("type", 1);
         data.put("link", link);
         out.print(JsonUtil.loadTrueResult(data));
      } catch (Exception e) {
         isNative = false;
         try {
            monitorService.addClientAPIMonitor(MonitorFactory.createClientAPI(request, 0, 0, "购买淘宝商品转链出错"));
         } catch (Exception e1) {
            e1.printStackTrace();
         }
         TBPid tbPid = null;
         if (acceptData.getPlatform().equalsIgnoreCase("android")) {
            tbPid = tbPidService.getTBPid(uid, PidUser.TYPE_FANLI_ANDROID);
         } else {
            tbPid = tbPidService.getTBPid(uid, PidUser.TYPE_FANLI_IOS);
         }
         LogHelper.test("购买转链:默认PID转链-异常商品-" + uid + ":" + auctionId);
         data.put("native", isNative);
         if (tbPid != null) {
            try {
               TaoBaoLink taoBaoLink = null;
               if (pidType == PidUser.TYPE_FANLI_ANDROID)
                  taoBaoLink = shareGoodsService.getTaoBaoLink(uid, auctionId,
                        tbPidService.getAndroidDefault().getPid());
               else
                  taoBaoLink = shareGoodsService.getTaoBaoLink(uid, auctionId,
                        tbPidService.getIOSDefault().getPid());
               JSONObject link = new JSONObject();
               link.put("clickUrl", taoBaoLink.getClickUrl());
               link.put("couponUrl", taoBaoLink.getCouponLink());
               data.put("type", 1);
               data.put("link", link);
               data.put("native", true);
            } catch (Exception e1) {
               String siteId = tbPid.getPid().split("_")[2];
               String adzoneId = tbPid.getPid().split("_")[3];
               TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppIdCache(siteId);
               ClientTBPid clientTBPid = new ClientTBPid(config.getAppKey(), tbPid.getPid(), siteId, adzoneId);
               data.put("type", 2);
               data.put("tbPidInfo", clientTBPid);
               data.put("native", true);
            }
            out.print(JsonUtil.loadTrueResult(data));
         } else {
            out.print(JsonUtil.loadFalseResult(1, "请求失败"));
         }
         businessEmergent110Service.buyTaoBaoGoodsError(StringUtil.Md5(auctionId + ""));
      }
   }
   /**
    * 获取淘宝的分享链接 (淘礼金新建)
    *
    * @param acceptData
    * @param uid
    *            -用户ID
    * @param auctionId-商品ID
    * @param out
    */
   @RequestMapping(value = "getTaoBaoGoodsLink")
   public void getTaoBaoGoodsLink(AcceptData acceptData, Long uid, Long auctionId, String from, HttpServletRequest request,
         PrintWriter out) {
      if (uid == null || uid <= 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;
      }
      if (auctionId == null || auctionId <= 0) {
         out.print(JsonUtil.loadFalseResult(2, "商品ID不能为空"));
         return;
      }
      TaoBaoGoodsBrief goods = null;
      try {
         goods = TaoKeApiUtil.getSimpleGoodsInfo(auctionId);
      } catch (TaobaoGoodsDownException e) {
         out.print(JsonUtil.loadFalseResult(3, "商品已下架"));
         return;
      } catch (Exception e) {
         try {
            LogHelper.errorDetailInfo(e, "获取商品简版详情出错", auctionId + "");
         } catch (Exception e1) {
            e1.printStackTrace();
         }
      }
      JSONObject data = new JSONObject();
      boolean isNative = false;
      String pid = null;
      boolean specialConvert = false;
      if (goods.getMaterialLibType() != null && goods.getMaterialLibType() == 1) {
         specialConvert = true;
      } else
         specialConvert = false;
      String specialId = null;
      String relationId = null;
      // 查询用户ID是否绑定了会员运营ID
      UserExtraTaoBaoInfo userInfo = userExtraTaoBaoInfoService.getByUid(uid);
      if (userInfo != null && !StringUtil.isNullOrEmpty(userInfo.getSpecialId()) && userInfo.getSpecialValid() != null
            && userInfo.getSpecialValid() == true) {
         specialId = userInfo.getSpecialId();
         relationId = userInfo.getRelationId();
         // 已经绑定
         if (specialConvert) {
            isNative = true;
         } else
            isNative = false;
         pid = TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT;
      } else {// 尚未绑定
         isNative = true;
      }
      data.put("native", isNative);
      int pidType = PidUser.TYPE_FANLI_ANDROID;
      if (acceptData.getPlatform().equalsIgnoreCase("ios"))
         pidType = PidUser.TYPE_FANLI_IOS;
      try {
         TaoBaoLink taoBaoLink = null;
         // 是返利商品库的商品
         if (specialConvert) {
            if (!StringUtil.isNullOrEmpty(specialId)) {
               if (from != null && from.equals("taolijin")) {
                  taoBaoLink = shareGoodsService.getTaoLiJinLinkForBuy(uid, specialId, auctionId);
               } else {
               if (taoBaoLink == null) {
                  taoBaoLink = shareGoodsService.getTaoBaoLinkForBuyWithSpecial(uid, specialId, auctionId);
               }
               data.put("native", true);
            } else {
               if (!specialConvert && !isNative) {
@@ -367,8 +223,22 @@
               LogHelper.errorDetailInfo(e, "uid:" + uid, null);
            }
            if (!StringUtil.isNullOrEmpty(relationId)) {//
               taoBaoLink = shareGoodsService.getTaoBaoLinkForShare(uid, auctionId, relationId,
                     TaoBaoConstant.TAOBAO_RELATION_AS_SPECIAL_PID);
               if (source != null && "taolijin".equals(source)) {
                  boolean isNewUser = userInfoExtraService.isNewUser(uid);
                  if (isNewUser) {
                     // 判定为老用户:
                     // 新人只要使用了新人红包,也就是那1块钱,那么,他看到的分享爆款中的商品-就只能分享。
                     long countRecord = userTaoLiJinRecordService.countRecordByUid(uid);
                     if (countRecord == 0) {
                        taoBaoLink = shareGoodsService.getTaoLiJinLinkForBuy(uid, specialId, auctionId,
                              TaoBaoConstant.TAOBAO_RELATION_AS_SPECIAL_PID);
                     }
                  }
               } else {
                  taoBaoLink = shareGoodsService.getTaoBaoLinkForShare(uid, auctionId, relationId,
                        TaoBaoConstant.TAOBAO_RELATION_AS_SPECIAL_PID);
               }
               data.put("native", true);
            } else {
               if (pidType == PidUser.TYPE_FANLI_ANDROID)
@@ -389,6 +259,9 @@
         out.print(JsonUtil.loadTrueResult(data));
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
         isNative = false;
         try {
            monitorService.addClientAPIMonitor(MonitorFactory.createClientAPI(request, 0, 0, "购买淘宝商品转链出错"));
@@ -442,9 +315,7 @@
         businessEmergent110Service.buyTaoBaoGoodsError(StringUtil.Md5(auctionId + ""));
      }
   }
   /**
    * 是否在参与推广