admin
2019-08-27 fe879975a3e8a0a1aa280fb839e02d159bfbcff8
fanli/src/main/java/com/yeshi/fanli/controller/client/v1/GoodsController.java
@@ -16,16 +16,21 @@
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.entity.taobao.TaoKeAppInfo;
import com.yeshi.fanli.exception.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.integral.IntegralGetService;
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;
@@ -36,6 +41,7 @@
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.TaoKeApiUtil;
@@ -78,11 +84,32 @@
   @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"));
         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 +121,8 @@
      data.put("type", 1);
      data.put("link", link);
      out.print(JsonUtil.loadTrueResult(data));
      integralGetService.addTaoLiJinBuy(uid, auctionId);
   }
   /**
@@ -140,7 +169,7 @@
      }
      if ("taolijin_buy".equalsIgnoreCase(source)) {
         doTaoLiJinBuy(uid, auctionId, out);
         doTaoLiJinBuy(acceptData, uid, auctionId, out);
         return;
      }
@@ -258,6 +287,9 @@
         data.put("link", link);
         out.print(JsonUtil.loadTrueResult(data));
         // 获得金币
         integralGetService.addCouponRebate(uid);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
@@ -297,7 +329,6 @@
               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];
@@ -390,6 +421,9 @@
      history.setGoodsId(goodsId);
      recommendGoodsDeleteHistoryService.addRecommendGoodsDeleteHistory(history);
      out.print(JsonUtil.loadTrueResult(""));
      // 获得金币
      integralGetService.addCloseRecommendGoods(uid);
   }
}