blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
admin
2019-07-11 3824cbcaec6e6c67418d5280a53e9c2fedeef6f9 
 fanli/src/main/java/com/yeshi/fanli/service/impl/tlj/UserTaoLiJinRecordServiceImpl.java


@@ -24,22 +24,30 @@


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



import com.yeshi.fanli.entity.goods.CommonGoods;



import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;



import com.yeshi.fanli.entity.taobao.TaoKeAppInfo;



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



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



import com.yeshi.fanli.log.LogHelper;



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



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



import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService;



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



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



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



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



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



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



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



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



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



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



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



import com.yeshi.fanli.util.MoneyBigDecimalUtil;



import com.yeshi.fanli.util.RedisManager;



import com.yeshi.fanli.util.StringUtil;



import com.yeshi.fanli.util.TaoBaoConstant;



import com.yeshi.fanli.util.factory.CommonGoodsFactory;



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



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



import com.yeshi.fanli.vo.msg.ClientTextStyleVO;



import com.yeshi.fanli.vo.user.UserTaoLiJinRecordVO;







@@ -48,49 +56,59 @@






   @Resource(name = "taskExecutor")



   private TaskExecutor executor;



	






   @Resource



   private RedisManager redisManager;



	






   @Resource



   private UserTaoLiJinRecordMapper userTaoLiJinRecordMapper;



	






   @Resource



   private CommonGoodsService commonGoodsService;



	






   @Resource



   private HongBaoManageService hongBaoManageService;



	






   @Resource



   private UserMoneyExtraService userMoneyExtraService;



	 






   @Resource



   private UserTaoLiJinReportService userTaoLiJinReportService;



	






   @Resource



   private UserTaoLiJinDetailService userTaoLiJinDetailService;



	






   @Resource



   private UserTaoLiJinOriginService userTaoLiJinOriginService;



	






   @Resource



   private GoodsTaoLiJinRateService goodsTaoLiJinRateService;



	


   private ConfigTaoLiJinService configTaoLiJinService;







   @Resource



   private UserOtherMsgNotificationService userOtherMsgNotificationService;



	






   @Resource



   private UserInfoExtraService userInfoExtraService;



	






   @Resource



   private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;







   @Resource



   private TaoBaoBuyRelationMapService taoBaoBuyRelationMapService;







   @Resource



   private ShareHotGoodsService shareHotGoodsService;



   



   @Override



   public UserTaoLiJinRecord  selectByPrimaryKey(Long id){



   public UserTaoLiJinRecord selectByPrimaryKey(Long id) {



      return userTaoLiJinRecordMapper.selectByPrimaryKey(id);



   }







   



	


   @Transactional



   @Override



   public UserTaoLiJinRecord createSelfBuyTaoLiJin(Long uid, int totalNum, TaoBaoGoodsBrief goods) throws UserTaoLiJinRecordException{



   public UserTaoLiJinRecord createSelfBuyTaoLiJin(Long uid, int totalNum, TaoBaoGoodsBrief goods)



         throws UserTaoLiJinRecordException {



      Date date = new Date();



      SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");



      SimpleDateFormat formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");



@@ -113,14 +131,41 @@


      }



      // 新人红包 自购一元



      BigDecimal perface = new BigDecimal(1);



		


      return createUserTaoLiJin(1, uid, goods.getAuctionId(), perface, 1, name, sendStartTime,



               sendEndTime, null, useEndTime);







      if (goods.getMaterialLibType() == null || goods.getMaterialLibType() == 0) {// 非返利库商品



         String relationId = null;



         try {



            relationId = taoBaoBuyRelationMapService.getRelationId(uid);



         } catch (Exception e) {



            LogHelper.errorDetailInfo(e, "uid:" + uid, null);



         }







         if (StringUtil.isNullOrEmpty(relationId)) {



            throw new UserTaoLiJinRecordException(101, "渠道未备案");



         }



         UserTaoLiJinRecord record = createUserTaoLiJin(1, uid, goods.getAuctionId(), perface, 1, name,



               sendStartTime, sendEndTime, null, useEndTime, TaoBaoConstant.TAOBAO_RELATION_AS_SPECIAL_PID);



         record.setSendUrl(record.getSendUrl() + "&relationId=" + relationId);



         UserTaoLiJinRecord updateRecoed=new UserTaoLiJinRecord();



         updateRecoed.setId(record.getId());



         updateRecoed.setSendUrl(record.getSendUrl());



         userTaoLiJinRecordMapper.updateByPrimaryKeySelective(record);



         return record;



      } else {// 返利库商品



         return createUserTaoLiJin(1, uid, goods.getAuctionId(), perface, 1, name, sendStartTime, sendEndTime, null,



               useEndTime, TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT);



      }







   }



	


	






   @Transactional



   @Override



   public UserTaoLiJinRecord createShareTaoLiJin(Long uid, int totalNum, TaoBaoGoodsBrief goods) throws UserTaoLiJinRecordException{



   public UserTaoLiJinRecord createShareTaoLiJin(Long uid, int totalNum, TaoBaoGoodsBrief goods)



         throws UserTaoLiJinRecordException {



      String relationId = userExtraTaoBaoInfoService.getRelationIdByUid(uid);



      if (StringUtil.isNullOrEmpty(relationId))



         throw new UserTaoLiJinRecordException(101, "渠道未授权");







      Date date = new Date();



      SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");



      SimpleDateFormat formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");



@@ -141,7 +186,7 @@


      } catch (ParseException e2) {



         e2.printStackTrace();



      }



		






      boolean isNewUser = userInfoExtraService.isNewUser(uid);



      if (isNewUser) {



         // 判定为老用户： 新人只要使用了新人红包，也就是那1块钱，那么，他看到的分享爆款中的商品-就只能分享。



@@ -150,46 +195,85 @@


            isNewUser = false;



         }



      }



		






      BigDecimal perface = null;



      if (isNewUser) {



         perface = new BigDecimal(1);



      } else {



         perface = goodsTaoLiJinRateService.getGoodsSpreadMoney(goods);



         // 计算推广红包



         String warningRate = configTaoLiJinService.getValueByKey("warning_value");



         perface = TaoLiJinUtil.getSpreadMoney(warningRate, goods);



      }



		


      return createUserTaoLiJin(2, uid, goods.getAuctionId(), perface, totalNum, name, sendStartTime,



               sendEndTime, null, useEndTime);







      UserTaoLiJinRecord record = createUserTaoLiJin(2, uid, goods.getAuctionId(), perface, totalNum, name,



            sendStartTime, sendEndTime, null, useEndTime, TaoBaoConstant.TAOBAO_RELATION_PID_DEFAULT);



      String sendUrl = record.getSendUrl() + "&relationId=" + relationId;



      record.setSendUrl(sendUrl);



      UserTaoLiJinRecord updateRecoed=new UserTaoLiJinRecord();



      updateRecoed.setId(record.getId());



      updateRecoed.setSendUrl(sendUrl);



      userTaoLiJinRecordMapper.updateByPrimaryKeySelective(record);



      return record;



   }



	


	






   @Override



   @Transactional



   public UserTaoLiJinRecord createUserTaoLiJin(int origin, Long uid, Long auctionId, BigDecimal perface, int totalNum, String name,



         Date sendStartTime, Date sendEndTime, Date useStartTime, Date useEndTime) throws UserTaoLiJinRecordException{



		


   public UserTaoLiJinRecord createUserTaoLiJin(int origin, Long uid, Long auctionId, BigDecimal perface, int totalNum,



         String name, Date sendStartTime, Date sendEndTime, Date useStartTime, Date useEndTime, String pid)



         throws UserTaoLiJinRecordException {







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



      UserMoneyExtra userMoneyExtra = userMoneyExtraService.selectByPrimaryKey(uid);



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



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



      }



		






      // 过期



      userTaoLiJinOriginService.overdueHongBao(uid);



				


      BigDecimal tlj = userMoneyExtra.getTlj();



		


      // 总推广红包



      BigDecimal totalMoney = MoneyBigDecimalUtil.mul(perface, new BigDecimal(totalNum));



      if (totalMoney.compareTo(tlj) > 0) {



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



		


      // 自购时的红包余额



      if (origin == 1) {



         BigDecimal tljSelf = userMoneyExtra.getTljSelf();



         if (tljSelf == null || tljSelf.compareTo(totalMoney) < 0) {



            throw new UserTaoLiJinRecordException(101, "自购红包余额不足");



         }



      } 


		


      // 分享时的红包余额



      BigDecimal tlj = userMoneyExtra.getTlj();



      if (tlj == null || tlj.compareTo(totalMoney) < 0) {



         throw new UserTaoLiJinRecordException(101, "分享红包余额不足");



      }



      







      // 创建淘礼金红包



      TaoLiJinDTO taoLiJinDTO = TaoKeApiUtil.createTaoLiJin(auctionId, name, perface, totalNum, sendStartTime, sendEndTime, useStartTime, useEndTime);



      if (taoLiJinDTO == null) {



         throw new UserTaoLiJinRecordException(101, "红包创建失败");



      TaoLiJinDTO taoLiJinDTO = null;



      try {



         taoLiJinDTO = TaoKeApiUtil.createTaoLiJin(auctionId, name, perface, totalNum, sendStartTime,



               sendEndTime, useStartTime, useEndTime,   new TaoKeAppInfo(TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET, pid));



      } catch (TaoKeApiException e) {



         LogHelper.errorDetailInfo(e);



         executor.execute(new Runnable() {



            @Override



            public void run() {



               if (e.getCode() == TaoKeApiException.CODE_TLJ_FORBIDDEN) {



                  // 该商品不支持创建淘礼金红包



                  shareHotGoodsService.deleteByGoodsId(auctionId);



               } else if (e.getCode() == TaoKeApiException.CODE_TLJ_NO_MONEY) {



                  // 官方玩法钱包余额不足  TODO



               }



            }



         });



      }



      



      //  保存记录



      if (taoLiJinDTO == null) {



         throw new UserTaoLiJinRecordException(101, "淘宝API推广红包创建失败");



      }







      // 保存记录



      UserTaoLiJinRecord record = new UserTaoLiJinRecord();



      record.setUid(uid);



      record.setGoodsId(auctionId);



@@ -203,18 +287,27 @@


      record.setRightsId(taoLiJinDTO.getRightsId());



      record.setSendUrl(taoLiJinDTO.getSendUrl());



      record.setCreateTime(new Date());



      userTaoLiJinRecordMapper.insertSelective(record);



      if (origin == 1) { //  自购



         record.setUseType(1);



      } else { //  分享



         record.setUseType(2);



      }



      



      // 剩余淘礼金



      BigDecimal surplusTlj = MoneyBigDecimalUtil.sub(tlj, totalMoney);



      userTaoLiJinRecordMapper.insertSelective(record);







      BigDecimal surplusTlj = MoneyBigDecimalUtil.sub(tlj, totalMoney); 


		


      UserMoneyExtra updateExtra = new UserMoneyExtra();



      updateExtra.setUid(uid);



      if (origin == 1) { // 剩余淘礼金-- 自购



         updateExtra.setTljSelf(MoneyBigDecimalUtil.sub(userMoneyExtra.getTljSelf(), totalMoney));



      } 


      updateExtra.setTlj(surplusTlj);



      updateExtra.setUpdateTime(new Date());



      userMoneyExtraService.updateByPrimaryKeySelective(updateExtra);



		






      record.setSurplusMoney(surplusTlj);



		






      // 异步



      String rightsId = taoLiJinDTO.getRightsId();



      executor.execute(new Runnable() {



@@ -232,30 +325,29 @@


            } catch (Exception e) {



               LogHelper.errorDetailInfo(e);



            }



				


				






            // 成功使用红包



            try {



               BigDecimal total = totalMoney;



               BigDecimal lastMoney = null;



               BigDecimal zero = new BigDecimal(0);



					






               // 修改余额



               List<UserTaoLiJinOrigin> list = userTaoLiJinOriginService.getSurplusLiJin(uid);



               if (list != null && list.size() > 0) {



                  for (UserTaoLiJinOrigin taoLiJinOrigin: list) {



                     if (total.compareTo(zero) < 1 ) {



                  for (UserTaoLiJinOrigin taoLiJinOrigin : list) {



                     if (total.compareTo(zero) < 1) {



                        break;



                     }



                     BigDecimal moneySurplus = taoLiJinOrigin.getMoneySurplus();



                     lastMoney = total;



                     total = MoneyBigDecimalUtil.sub(total, moneySurplus);



                     if (total.compareTo(zero) >= 0 ) {



                     if (total.compareTo(zero) >= 0) {



                        moneySurplus = zero;



                     } else {



                        moneySurplus = MoneyBigDecimalUtil.sub(moneySurplus, lastMoney);



                     }



							






                     UserTaoLiJinOrigin usertlj = new UserTaoLiJinOrigin();



                     usertlj.setId(taoLiJinOrigin.getId());



                     usertlj.setMoneySurplus(moneySurplus);



@@ -266,25 +358,7 @@


            } catch (Exception e) {



               LogHelper.errorDetailInfo(e);



            }



				


				


				


            // 使用成功消息



            try {



               String beizhu = "未被领取/使用的部分将会退回";



					


               SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd hh.mm");



               String time = sd.format(new Date());



               MsgOtherTaoLiJinContentDTO content = new MsgOtherTaoLiJinContentDTO();



               content.setState("红包扣除");



               content.setSource(time + " 创建的分享记录");



               content.setMoney(totalMoney);



					


               userOtherMsgNotificationService.taoLiJinMsg(uid, beizhu, content);



            } catch (Exception e) {



               LogHelper.errorDetailInfo(e);



            }



				






            // 创建报告



            try {



               userTaoLiJinReportService.insertDefault(rightsId);



@@ -292,9 +366,32 @@


               LogHelper.errorDetailInfo(e);



            }



            



				


            if (origin == 1) { 


               return; //  自购不推送消息



            }



				


				


            // 使用成功消息



            try {



               String beizhu = "未被领取/使用的部分将会退回";







               SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd hh.mm");



               String time = sd.format(new Date());



               MsgOtherTaoLiJinContentDTO content = new MsgOtherTaoLiJinContentDTO();



               content.setState("红包扣除");



               content.setSource(time + " 创建的分享记录");



               content.setMoney(totalMoney);







               userOtherMsgNotificationService.taoLiJinMsg(uid, beizhu, content);



            } catch (Exception e) {



               LogHelper.errorDetailInfo(e);



            }







            // 检测商品是否存在



            try {



               CommonGoods commonGoods = commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType(auctionId, CommonGoods.GOODS_TYPE_TB);



               CommonGoods commonGoods = commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType(auctionId,



                     CommonGoods.GOODS_TYPE_TB);



               if (commonGoods == null) {



                  TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);



                  if (taoBaoGoodsBrief != null) {



@@ -306,46 +403,43 @@


            }



         }



      });



		






      return record;



   }







	


   @Override



   public List<UserTaoLiJinRecordVO> getRecordByUid(long start, int count, Long uid){



   public List<UserTaoLiJinRecordVO> getRecordByUid(long start, int count, Long uid) {



      List<UserTaoLiJinRecordVO> list = userTaoLiJinRecordMapper.getRecordByUid(start, count, uid);



      if (list == null || list.size() == 0) {



         return list;



      }



		


		






      List<Long> listGoodsId = new ArrayList<Long>();



      for (UserTaoLiJinRecordVO userTaoLiJinRecordVO: list) {



      for (UserTaoLiJinRecordVO userTaoLiJinRecordVO : list) {



         listGoodsId.add(userTaoLiJinRecordVO.getAuctionId());



      }



		






      if (listGoodsId.size() == 0) {



         return null;



      }



		






      List<CommonGoods> listGoods = commonGoodsService.getByListGoodsId(listGoodsId);



      if (listGoods == null || listGoods.size() == 0) {



         return null;



      }



		


		






      // 组织相关数据



      for (UserTaoLiJinRecordVO userTaoLiJinRecordVO: list) {



      for (UserTaoLiJinRecordVO userTaoLiJinRecordVO : list) {



         long auctionId = userTaoLiJinRecordVO.getAuctionId().longValue();



			






         // 商品信息



         for (int i = 0; i< listGoods.size(); i++) {



         for (int i = 0; i < listGoods.size(); i++) {



            CommonGoods commonGoods = listGoods.get(i);



            long goodsId = commonGoods.getGoodsId().longValue();



            if (auctionId == goodsId) {



               userTaoLiJinRecordVO.setTitle(commonGoods.getTitle());



               userTaoLiJinRecordVO.setPictUrl(commonGoods.getPicture());



               if(CommonGoods.SHOP_TYPE_TB == commonGoods.getShopType()) {



               if (CommonGoods.SHOP_TYPE_TB == commonGoods.getShopType()) {



                  userTaoLiJinRecordVO.setUserType(0);



               } else {



                  userTaoLiJinRecordVO.setUserType(1);



@@ -353,22 +447,21 @@


               break;



            }



         }



			






         // 计算剩余未领取数量



         int winNum = userTaoLiJinRecordVO.getWinNum();



         int totalNum = userTaoLiJinRecordVO.getTotalNum();



         userTaoLiJinRecordVO.setSurplusNum(totalNum - winNum);



			


			






         // 计算分享奖金



         BigDecimal shareMoney = new BigDecimal(0);



         BigDecimal commission = userTaoLiJinRecordVO.getCommission();



         if (commission != null && commission.compareTo(shareMoney) > 1) {



         if (commission != null && commission.compareTo(shareMoney) > 0) {



            BigDecimal shareRate = hongBaoManageService.getShareRate();



            shareMoney = MoneyBigDecimalUtil.mul(MoneyBigDecimalUtil.mul(commission, new BigDecimal("0.01")), MoneyBigDecimalUtil.div(shareRate, new BigDecimal(100)));



            shareMoney = MoneyBigDecimalUtil.mul(commission, MoneyBigDecimalUtil.div(shareRate, new BigDecimal(100)));



            shareMoney = BigDecimalUtil.getWithNoZera(shareMoney);



         }



			






         ClientTextStyleVO desc = new ClientTextStyleVO();



         desc.setColor("#FFFFFF");



         desc.setContent("预估分享奖金：￥" + shareMoney);



@@ -377,26 +470,31 @@


      }



      return list;



   }



	






   @Override



   public long countRecordByUid(Long uid) {



      return userTaoLiJinRecordMapper.countRecordByUid(uid);



   }







   @Override



   public long countShareRecordByUid(Long uid) {



      return userTaoLiJinRecordMapper.countShareRecordByUid(uid);



   }



	


   



   @Override



   public long countTodayNum(Long uid) {



      return userTaoLiJinRecordMapper.countTodayNum(uid);



   }



	


	






   @Override



   public BigDecimal getShareHongBaoByUidAndGoodsId(Long uid, Long goodsId) {



      return userTaoLiJinRecordMapper.getShareHongBaoByUidAndGoodsId(uid, goodsId);



   }



	






   @Override



   public UserTaoLiJinRecord getByRightsId(String rightsId) {



      return userTaoLiJinRecordMapper.getByRightsId(rightsId);



   }



	






}