配置文件修改

admin

2019-11-23 51a4ff5d777028d52a19c314a99f796334cb7b51

 fanli/src/main/java/com/yeshi/fanli/service/impl/goods/ShareGoodsServiceImpl.java

@@ -23,6 +23,7 @@
import com.yeshi.fanli.dao.mybatis.UserInfoMapper;

import com.yeshi.fanli.dao.mybatis.UserShareGoodsHistoryMapper;

import com.yeshi.fanli.dao.mybatis.share.PidUserMapper;

import com.yeshi.fanli.dto.taobao.TaoLiJinDTO;

import com.yeshi.fanli.entity.bus.share.UserShareGoodsHistory;

import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinRecord;

import com.yeshi.fanli.entity.bus.user.UserInfo;

@@ -33,20 +34,25 @@
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.entity.taobao.UserTLJBuyHistory;

import com.yeshi.fanli.exception.share.ShareGoodsException;

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

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

import com.yeshi.fanli.exception.tlj.TaoLiJinCreateException;

import com.yeshi.fanli.exception.tlj.UserTaoLiJinRecordException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.goods.CommonGoodsService;

import com.yeshi.fanli.service.inter.goods.ShareGoodsService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.money.UserMoneyExtraService;

import com.yeshi.fanli.service.inter.monitor.BusinessEmergent110Service;

import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;

import com.yeshi.fanli.service.inter.taobao.TLJBuyGoodsService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;

import com.yeshi.fanli.service.inter.tlj.GoodsTaoLiJinRateService;

import com.yeshi.fanli.service.inter.taobao.UserTLJBuyHistoryService;

import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinRecordService;

import com.yeshi.fanli.service.inter.user.TBPidService;

import com.yeshi.fanli.service.inter.user.UserAccountService;

import com.yeshi.fanli.service.inter.user.UserMoneyExtraService;

import com.yeshi.fanli.service.inter.user.UserShareGoodsRecordService;

import com.yeshi.fanli.util.AESUtil;

import com.yeshi.fanli.util.Constant;

@@ -55,6 +61,7 @@
import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TaoBaoConstant;

import com.yeshi.fanli.util.TimeUtil;

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

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



@@ -99,14 +106,19 @@


   @Resource

   private UserMoneyExtraService userMoneyExtraService;

	
   @Resource

   private GoodsTaoLiJinRateService goodsTaoLiJinRateService;

	


   @Resource

   private UserTaoLiJinRecordService userTaoLiJinRecordService;

	
	


   @Resource

   private UserTLJBuyHistoryService userTLJBuyHistoryService;



   @Resource

   private TLJBuyGoodsService tljBuyGoodsService;



   @Resource

   private BusinessEmergent110Service businessEmergent110Service;



   @Override

   public void addShareGoodsHistory(UserShareGoodsHistory history) {

      UserShareGoodsHistory userShareGoodsHistory = userShareGoodsHistoryMapper

@@ -192,10 +204,10 @@
      }



      UserShareGoodsHistory history = new UserShareGoodsHistory();

      history.setTkCode(tbLink.getTaoToken());

      history.setTkCode(TaoBaoUtil.filterTaoToken(tbLink.getTaoToken()));

      history.setLink(tbLink.getClickUrl());

      history.setQuanLink(tbLink.getCouponLink());

      history.setTkCode(tbLink.getTaoToken());

      history.setTkCode(TaoBaoUtil.filterTaoToken(tbLink.getTaoToken()));



      history.setCreateTime(new Date());

      history.setGoodsId(goods.getAuctionId());

@@ -234,7 +246,7 @@
         // throw new ShareGoodsException(4, "生成二维码失败");

         // }

         // 获取到用户的头像

         UserInfo user = userinfoMapper.selectByPrimaryKey(uid);

         UserInfo user = userinfoMapper.selectAvailableByPrimaryKey(uid);

         InputStream portrait = null;

         if (!StringUtil.isNullOrEmpty(user.getPortrait())) {

            try {

@@ -354,16 +366,16 @@


         UserShareGoodsHistory history = new UserShareGoodsHistory();

         history.setId(userShareGoodsHistory.getId());

         history.setTkCode(tbLink.getTaoToken());

         history.setTkCode(TaoBaoUtil.filterTaoToken(tbLink.getTaoToken()));

         history.setLink(tbLink.getClickUrl());

         history.setQuanLink(tbLink.getCouponLink());

         history.setTkCode(tbLink.getTaoToken());

         history.setTkCode(TaoBaoUtil.filterTaoToken(tbLink.getTaoToken()));

         userShareGoodsHistoryMapper.updateByPrimaryKeySelective(history);



         userShareGoodsHistory.setTkCode(tbLink.getTaoToken());

         userShareGoodsHistory.setTkCode(TaoBaoUtil.filterTaoToken(tbLink.getTaoToken()));

         userShareGoodsHistory.setLink(tbLink.getClickUrl());

         userShareGoodsHistory.setQuanLink(tbLink.getCouponLink());

         userShareGoodsHistory.setTkCode(tbLink.getTaoToken());

         userShareGoodsHistory.setTkCode(TaoBaoUtil.filterTaoToken(tbLink.getTaoToken()));

      }



      return userShareGoodsHistory;

@@ -406,8 +418,8 @@
      }

      TaoBaoGoodsBrief goods = null;

      try {

         //测试

//         info.setAdzoneId("123");

         // 测试

         // info.setAdzoneId("123");

         goods = TaoKeApiUtil.searchGoodsDetail(auctionId, info);

      } catch (TaobaoGoodsDownException e) {

         throw new ShareGoodsException(4, "商品已下架");

@@ -559,12 +571,12 @@
      taoBaoLink.setAuctionId(auctionId);

      taoBaoLink.setClickUrl(goods.getAuctionUrl());

      taoBaoLink.setCouponLink(goods.getCouponLink());

      if (!StringUtil.isNullOrEmpty(goods.getYsylClickUrl()))

         taoBaoLink.setCouponLink(goods.getYsylClickUrl());

      taoBaoLink.setGoods(goods);



      return taoBaoLink;

   }



	
   @Override

   public UserShareGoodsHistory getShareGoodsHistory(Long uid, Long auctionId) {

      return userShareGoodsHistoryMapper.selectByUidAndAuctionId(uid, auctionId);

@@ -638,6 +650,8 @@
      tbLink.setAuctionId(goods.getAuctionId());

      tbLink.setClickUrl(goods.getAuctionUrl());

      tbLink.setCouponLink(goods.getCouponLink());

      if (!StringUtil.isNullOrEmpty(goods.getYsylClickUrl()))

         tbLink.setCouponLink(goods.getYsylClickUrl());



      if (!StringUtil.isNullOrEmpty(tbLink.getCouponLink())) {// 通过立即推广方式获取淘口令成功

         String quanToken = TaoKeApiUtil.getTKToken(goods.getPictUrl(), goods.getTitle(), tbLink.getCouponLink());

@@ -660,9 +674,9 @@
      return tbLink;

   }



	
   @Override

   public TaoBaoLink getTaoLiJinLinkForBuy(Long uid, String specialId, Long auctionId) throws ShareGoodsException {

   public TaoBaoLink getTaoLiJinLinkForBuy(Long uid, String specialId, Long auctionId, String pid)

         throws ShareGoodsException {

      if (uid == null || uid <= 0) {

         throw new ShareGoodsException(1, "用户ID不能为空");

      }

@@ -673,30 +687,31 @@


      // 用户剩余可以淘礼金验证

      UserMoneyExtra userMoneyExtra = userMoneyExtraService.selectByPrimaryKey(uid);

      if (userMoneyExtra == null ||  userMoneyExtra.getTlj() == null) {

      if (userMoneyExtra == null || userMoneyExtra.getTlj() == null) {

         throw new ShareGoodsException(101, "红包余额不足");

      }

		
		


      TaoKeAppInfo app = new TaoKeAppInfo();

      app.setAppKey(TaoBaoConstant.TAOBAO_AUTH_APPKEY);

      app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET);

      app.setPid(TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT);

      if (pid == null)

         app.setPid(TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT);

      else

         app.setPid(pid);

      TaoBaoGoodsBrief goods = TaoKeApiUtil.specialConvertCoupon(auctionId, app);

      if (goods == null) {

         throw new ShareGoodsException(1, "");

      }

		


      String taoLiJinLink = null;

      try {

          goods.setAuctionId(auctionId);

          UserTaoLiJinRecord createUserTaoLiJin = userTaoLiJinRecordService.createSelfBuyTaoLiJin(uid, 1, goods);

          taoLiJinLink = createUserTaoLiJin.getSendUrl();

         goods.setAuctionId(auctionId);

         UserTaoLiJinRecord createUserTaoLiJin = userTaoLiJinRecordService.createSelfBuyTaoLiJin(uid, 1, goods);

         taoLiJinLink = createUserTaoLiJin.getSendUrl();

      } catch (UserTaoLiJinRecordException e) {

         throw new ShareGoodsException(e.getCode(), e.getMsg());

      }

		
		


      TaoBaoLink taoBaoLink = new TaoBaoLink();

      taoBaoLink.setAuctionId(auctionId);

      taoBaoLink.setClickUrl(goods.getAuctionUrl());

@@ -705,8 +720,7 @@


      return taoBaoLink;

   }

	
	


   @Override

   public TaoBaoLink getTaoLiJinLinkForShare(Long uid, Long auctionId, String relationId) throws ShareGoodsException {



@@ -771,8 +785,6 @@
            goods.setCouponLink(goods.getCouponLink() + "&relationId=" + relationId);

      }



      // 保存商品详情



      // 创建淘口令

      TaoBaoLink tbLink = new TaoBaoLink();

      tbLink.setAuctionId(goods.getAuctionId());

@@ -786,4 +798,72 @@


      return tbLink;

   }



   @Override

   public TaoBaoLink getTaoLiJinLinkForBuyWithOutFanLi(Long uid, Long auctionId, TaoKeAppInfo app)

         throws ShareGoodsException, TaoLiJinCreateException {

      if (uid == null || uid <= 0) {

         throw new ShareGoodsException(1, "用户ID不能为空");

      }



      if (auctionId == null || auctionId <= 0) {

         throw new ShareGoodsException(2, "商品ID不能为空");

      }



      boolean canBuy = userTLJBuyHistoryService.canBuy(uid, auctionId);

      if (!canBuy) {

         throw new ShareGoodsException(3, "立减红包已抢光，请稍后再试");

      }



      long currentTime = System.currentTimeMillis();

      Date sendEndTime = new Date(TimeUtil.convertToTimeTemp(

            TimeUtil.getGernalTime(currentTime + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));

      TaoBaoGoodsBrief goods = null;

      try {

         goods = TaoKeApiUtil.searchGoodsDetail(auctionId);

      } catch (TaobaoGoodsDownException e) {

         throw new ShareGoodsException(4, "商品已下架");

      }



      BigDecimal perface = TaoBaoUtil.getGoodsHongBaoMoney(goods, new BigDecimal(70));

      TaoLiJinDTO taoLiJinDTO = null;

      try {

         taoLiJinDTO = TaoKeApiUtil.createTaoLiJin(auctionId, "自购立减", perface, 1,

               new Date(currentTime - 1000 * 60 * 10L), sendEndTime, new Date(currentTime - 1000 * 60 * 10L),

               sendEndTime, app);

      } catch (TaoLiJinCreateException e1) {

         if (e1.getCode() == TaoLiJinCreateException.CODE_TLJ_NO_MONEY) {// 资金不足

            TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppKeyCache(app.getAppKey());

            businessEmergent110Service.tljNoMoney(config.getAccount());

         } else if (e1.getCode() == TaoLiJinCreateException.CODE_TLJ_FORBIDDEN) {// 商品不允许创建淘礼金

            tljBuyGoodsService.removeGoods(auctionId);

         }

         LogHelper.errorDetailInfo(e1, e1.getMessage(), null);

      } catch (TaoKeApiException e) {

         LogHelper.errorDetailInfo(e, e.getMessage(), null);

         throw new ShareGoodsException(5, "生成推广链接失败");

      }



      if (taoLiJinDTO == null)

         throw new ShareGoodsException(5, "生成推广链接失败");



      // 减去剩余个数(随机减去8到10个)

      tljBuyGoodsService.subHongBaoLeftCount(auctionId, TimeUtil.getGernalTime(currentTime, "yyyy-MM-dd"),

            8 + (int) (3 * Math.random()));



      // 插入记录

      try {

         userTLJBuyHistoryService.addHistory(new UserTLJBuyHistory(null, uid, auctionId,

               TimeUtil.getGernalTime(currentTime, "yyyy-MM-dd"), taoLiJinDTO.getRightsId(), new Date()));

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }



      TaoBaoLink taoBaoLink = new TaoBaoLink();

      taoBaoLink.setAuctionId(auctionId);

      taoBaoLink.setClickUrl(goods.getAuctionUrl());

      taoBaoLink.setCouponLink(taoLiJinDTO.getSendUrl());

      taoBaoLink.setGoods(goods);

      return taoBaoLink;

   }

}