yujian
2019-10-21 d085ca89e39b4cda025a9a53d3797fbe8b242ae7
fanli/src/main/java/com/yeshi/fanli/controller/client/v1/GoodsController.java
@@ -16,27 +16,34 @@
import com.yeshi.fanli.entity.taobao.ClientTBPid;
import com.yeshi.fanli.entity.taobao.PidUser;
import com.yeshi.fanli.entity.taobao.TBPid;
import com.yeshi.fanli.entity.taobao.TLJBuyGoods;
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.entity.taobao.TaoKeAppInfo;
import com.yeshi.fanli.exception.share.ShareGoodsException;
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
import com.yeshi.fanli.exception.tlj.TaoLiJinCreateException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.goods.ShareGoodsService;
import com.yeshi.fanli.service.inter.goods.recommend.RecommendGoodsDeleteHistoryService;
import com.yeshi.fanli.service.inter.monitor.BusinessEmergent110Service;
import com.yeshi.fanli.service.inter.monitor.MonitorService;
import com.yeshi.fanli.service.inter.taobao.TLJBuyGoodsService;
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.service.inter.user.integral.IntegralGetService;
import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TaoBaoConstant;
import com.yeshi.fanli.util.TimeUtil;
import com.yeshi.fanli.util.factory.MonitorFactory;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
import net.sf.json.JSONObject;
@@ -78,11 +85,34 @@
   @Resource
   private UserTaoLiJinRecordService userTaoLiJinRecordService;
   private void doTaoLiJinBuy(Long uid, Long auctionId, PrintWriter out) {
   @Resource
   private TLJBuyGoodsService tljBuyGoodsService;
   @Resource
   private IntegralGetService integralGetService;
   private void doTaoLiJinBuy(AcceptData acceptData, Long uid, Long auctionId, PrintWriter out) {
      JSONObject data = new JSONObject();
      TaoBaoLink taoBaoLink;
      TaoBaoLink taoBaoLink = null;
      try {
         taoBaoLink = shareGoodsService.getTaoLiJinLinkForBuyWithOutFanLi(uid, auctionId);
         // 根据日期与商品ID查询
         TLJBuyGoods tljBuyGoods = tljBuyGoodsService.selectByAuctionIdAndDay(auctionId,
               TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd"));
         if (tljBuyGoods == null) {
            out.print(JsonUtil.loadFalseResult(1, "商品不存在"));
            return;
         }
         String appKey = tljBuyGoods.getAppKey();
         TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppKeyCache(appKey);
         if (config == null) {
            out.print(JsonUtil.loadFalseResult(2, "生成推广链接失败"));
            return;
         }
         TaoKeAppInfo app = new TaoKeAppInfo(config.getAppKey(), config.getAppSecret(), config.getDefaultPid());
         taoBaoLink = shareGoodsService.getTaoLiJinLinkForBuyWithOutFanLi(uid, auctionId, app);
      } catch (TaoLiJinCreateException e1) {
         out.print(JsonUtil.loadFalseResult(e1.getCode(), "淘礼金红包创建失败"));
         return;
      } catch (ShareGoodsException e) {
         out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMessage()));
         return;
@@ -94,6 +124,8 @@
      data.put("type", 1);
      data.put("link", link);
      out.print(JsonUtil.loadTrueResult(data));
      integralGetService.addTaoLiJinBuy(uid, auctionId);
   }
   /**
@@ -124,6 +156,14 @@
         return;
      }
      try {
         // 日志记录
         String info = String.format("type=buy&uid=%s&goodsId=%s&source=%s&goodsType=%s", uid, auctionId, source,
               Constant.SOURCE_TYPE_TAOBAO);
         LogHelper.orderInfo(info);
      } catch (Exception e) {
      }
      TaoBaoGoodsBrief goods = null;
      try {
@@ -140,9 +180,22 @@
      }
      if ("taolijin_buy".equalsIgnoreCase(source)) {
         doTaoLiJinBuy(uid, auctionId, out);
         doTaoLiJinBuy(acceptData, uid, auctionId, out);
         return;
      }
      ClientTBPid clientTBPid = null;
      String dpid = null;
      if (TaoBaoUtil.isSpecialGoods(goods.getMaterialLibType())) {
         dpid = TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT;
      } else {
         dpid = TaoBaoConstant.TAOBAO_RELATION_AS_SPECIAL_PID;
      }
      String psiteId = dpid.split("_")[2];
      String padzoneId = dpid.split("_")[3];
      TaoBaoUnionConfig config1 = taoBaoUnionConfigService.getConfigByAppIdCache(psiteId);
      clientTBPid = new ClientTBPid(config1.getAppKey(), dpid, psiteId, padzoneId);
      JSONObject data = new JSONObject();
      boolean isNative = false;
@@ -150,7 +203,7 @@
      boolean specialConvert = false;
      if (goods.getMaterialLibType() != null && goods.getMaterialLibType() == 1) {
      if (TaoBaoUtil.isSpecialGoods(goods.getMaterialLibType())) {
         specialConvert = true;
      } else
         specialConvert = false;
@@ -256,7 +309,12 @@
         link.put("couponUrl", taoBaoLink.getCouponLink());
         data.put("type", 1);
         data.put("link", link);
         if (clientTBPid != null)
            data.put("tbPidInfo", clientTBPid);
         out.print(JsonUtil.loadTrueResult(data));
         // 获得金币
         integralGetService.addCouponRebate(uid);
      } catch (Exception e) {
@@ -297,14 +355,13 @@
               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);
               ClientTBPid clientTBPid1 = new ClientTBPid(config.getAppKey(), tbPid.getPid(), siteId, adzoneId);
               data.put("type", 2);
               data.put("tbPidInfo", clientTBPid);
               data.put("tbPidInfo", clientTBPid1);
               data.put("native", true);
            }
@@ -390,6 +447,9 @@
      history.setGoodsId(goodsId);
      recommendGoodsDeleteHistoryService.addRecommendGoodsDeleteHistory(history);
      out.print(JsonUtil.loadTrueResult(""));
      // 获得金币
      integralGetService.addCloseRecommendGoods(uid);
   }
}