加入任务

admin

2019-09-06 2012b3b5db3c6b06535a68f775bcc81b16151b90

 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.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.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,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 +123,8 @@
      data.put("type", 1);

      data.put("link", link);

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



      integralGetService.addTaoLiJinBuy(uid, auctionId);

   }



   /**

@@ -140,7 +171,7 @@
      }



      if ("taolijin_buy".equalsIgnoreCase(source)) {

         doTaoLiJinBuy(uid, auctionId, out);

         doTaoLiJinBuy(acceptData, uid, auctionId, out);

         return;

      }



@@ -193,7 +224,7 @@
                     // 新人只要使用了新人红包，也就是那1块钱，那么，他看到的分享爆款中的商品-就只能分享。

                     long countRecord = userTaoLiJinRecordService.countRecordByUid(uid);

                     if (countRecord == 0) {

                        taoBaoLink = shareGoodsService.getTaoLiJinLinkForBuy(uid, specialId, auctionId);

                        taoBaoLink = shareGoodsService.getTaoLiJinLinkForBuy(uid, specialId, auctionId, null);

                     }

                  }

               }

@@ -223,8 +254,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)

@@ -244,7 +289,13 @@
         data.put("link", link);

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



         // 获得金币

         integralGetService.addCouponRebate(uid);



      } catch (Exception e) {



         LogHelper.errorDetailInfo(e);



         isNative = false;

         try {

            monitorService.addClientAPIMonitor(MonitorFactory.createClientAPI(request, 0, 0, "购买淘宝商品转链出错"));

@@ -280,7 +331,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];

@@ -373,6 +423,9 @@
      history.setGoodsId(goodsId);

      recommendGoodsDeleteHistoryService.addRecommendGoodsDeleteHistory(history);

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



      // 获得金币

      integralGetService.addCloseRecommendGoods(uid);

   }



}