用户注册信息

yujian

2020-01-18 f4a0f2acc63d7785eab108419a4e16f5f688cb95

 fanli/src/main/java/com/yeshi/fanli/service/impl/tlj/UserTaoLiJinRecordServiceImpl.java

@@ -13,36 +13,51 @@
import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.yeshi.utils.BigDecimalUtil;

import org.yeshi.utils.DateUtil;



import com.yeshi.fanli.dao.mybatis.tlj.UserTaoLiJinRecordMapper;

import com.yeshi.fanli.dto.msg.MsgOtherTaoLiJinContentDTO;

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

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

import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinDetail.TaoLiJinDetailTypeEnum;

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

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

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

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

import com.yeshi.fanli.entity.bus.user.TokenRecord.TokenTypeEnum;

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

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

import com.yeshi.fanli.entity.system.ConfigKeyEnum;

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.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.hongbao.HongBaoManageService;

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

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

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

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.UserTaoLiJinGiveRecordService;

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.TokenRecordService;

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

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

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

import com.yeshi.fanli.util.Constant;

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.TokenUtil;

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

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

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

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

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

@@ -56,6 +71,9 @@


   @Resource

   private RedisManager redisManager;



   @Resource

   private ConfigService configService;



   @Resource

   private UserTaoLiJinRecordMapper userTaoLiJinRecordMapper;

@@ -93,15 +111,23 @@
   @Resource

   private TaoBaoBuyRelationMapService taoBaoBuyRelationMapService;



   @Resource

   private ShareHotGoodsService shareHotGoodsService;



   @Resource

   private TokenRecordService tokenRecordService;



   @Resource

   private UserTaoLiJinGiveRecordService userTaoLiJinGiveRecordService;



   @Override

   public UserTaoLiJinRecord selectByPrimaryKey(Long id) {

      return userTaoLiJinRecordMapper.selectByPrimaryKey(id);

   }



	
   @Transactional

   @Transactional(rollbackFor=Exception.class)

   @Override

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

   public UserTaoLiJinRecord createSelfBuyTaoLiJin(Long uid, BigDecimal couplePrice, TaoBaoGoodsBrief goods)

         throws UserTaoLiJinRecordException {

      Date date = new Date();

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

@@ -123,10 +149,8 @@
      } catch (ParseException e2) {

         e2.printStackTrace();

      }

      // 新人红包 自购一元

      BigDecimal perface = new BigDecimal(1);



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

      if (!TaoBaoUtil.isSpecialGoods(goods.getMaterialLibType())) {// 非返利库商品

         String relationId = null;

         try {

            relationId = taoBaoBuyRelationMapService.getRelationId(uid);

@@ -137,22 +161,22 @@
         if (StringUtil.isNullOrEmpty(relationId)) {

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

         }

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

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

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

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

         UserTaoLiJinRecord updateRecoed=new UserTaoLiJinRecord();

         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,

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

               useEndTime, TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT);

      }



   }



   @Transactional

   @Transactional(rollbackFor=Exception.class)

   @Override

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

         throws UserTaoLiJinRecordException {

@@ -195,15 +219,15 @@
         perface = new BigDecimal(1);

      } else {

         // 计算推广红包

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

         String warningRate = configTaoLiJinService.getValueByKey("warning_value", new Date());

         perface = TaoLiJinUtil.getSpreadMoney(warningRate, goods);

      }



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

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

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

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

      record.setSendUrl(sendUrl);

      UserTaoLiJinRecord updateRecoed=new UserTaoLiJinRecord();

      UserTaoLiJinRecord updateRecoed = new UserTaoLiJinRecord();

      updateRecoed.setId(record.getId());

      updateRecoed.setSendUrl(sendUrl);

      userTaoLiJinRecordMapper.updateByPrimaryKeySelective(record);

@@ -211,7 +235,7 @@
   }



   @Override

   @Transactional

   @Transactional(rollbackFor=Exception.class)

   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 {

@@ -222,32 +246,50 @@
         throw new UserTaoLiJinRecordException(101, "红包余额不足");

      }



      // 过期

      userTaoLiJinOriginService.overdueHongBao(uid);

		
      // 过期 -取消收回

      // userTaoLiJinOriginService.overdueHongBao(uid);



      // 总推广红包

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

		


      // 自购时的红包余额

      if (origin == 1) {

         BigDecimal tljSelf = userMoneyExtra.getTljSelf();

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

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

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

         }

      } 
		
      }



      // 分享时的红包余额

      BigDecimal tlj = userMoneyExtra.getTlj();

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

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

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

      }

		


      // 创建淘礼金红包

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

            sendEndTime, useStartTime, useEndTime, pid);

      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 (TaoLiJinCreateException e) {

         LogHelper.errorDetailInfo(e);

         executor.execute(new Runnable() {

            @Override

            public void run() {

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

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

                  shareHotGoodsService.deleteByGoodsId(auctionId);

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

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

               }

            }

         });

      } catch (TaoKeApiException e1) {

      }



      if (taoLiJinDTO == null) {

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

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

      }



      // 保存记录

@@ -264,17 +306,21 @@
      record.setRightsId(taoLiJinDTO.getRightsId());

      record.setSendUrl(taoLiJinDTO.getSendUrl());

      record.setCreateTime(new Date());

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

         record.setUseType(1);

      } else { // 分享

         record.setUseType(2);

      }



      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));

      } 
		
      // 剩余淘礼金

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

      }

      updateExtra.setTlj(surplusTlj);

      updateExtra.setUpdateTime(new Date());

      userMoneyExtraService.updateByPrimaryKeySelective(updateExtra);

@@ -332,11 +378,21 @@
               LogHelper.errorDetailInfo(e);

            }



            // 创建报告

            try {

               userTaoLiJinReportService.insertDefault(rightsId);

            } catch (Exception e) {

               LogHelper.errorDetailInfo(e);

            }



            if (origin == 1) {

               return; // 自购不推送消息

            }



            // 使用成功消息

            try {

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



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

               String beizhu = "未被领取或领取后未使用部分退回";

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

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

               MsgOtherTaoLiJinContentDTO content = new MsgOtherTaoLiJinContentDTO();

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

@@ -344,13 +400,6 @@
               content.setMoney(totalMoney);



               userOtherMsgNotificationService.taoLiJinMsg(uid, beizhu, content);

            } catch (Exception e) {

               LogHelper.errorDetailInfo(e);

            }



            // 创建报告

            try {

               userTaoLiJinReportService.insertDefault(rightsId);

            } catch (Exception e) {

               LogHelper.errorDetailInfo(e);

            }

@@ -390,7 +439,7 @@
         return null;

      }



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

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

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

         return null;

      }

@@ -423,9 +472,9 @@
         // 计算分享奖金

         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")),

            shareMoney = MoneyBigDecimalUtil.mul(commission,

                  MoneyBigDecimalUtil.div(shareRate, new BigDecimal(100)));

            shareMoney = BigDecimalUtil.getWithNoZera(shareMoney);

         }

@@ -445,6 +494,11 @@
   }



   @Override

   public long countShareRecordByUid(Long uid) {

      return userTaoLiJinRecordMapper.countShareRecordByUid(uid);

   }



   @Override

   public long countTodayNum(Long uid) {

      return userTaoLiJinRecordMapper.countTodayNum(uid);

   }

@@ -459,4 +513,115 @@
      return userTaoLiJinRecordMapper.getByRightsId(rightsId);

   }



   @Override

   public String giveTaolijin(Long uid, BigDecimal amount) throws UserTaoLiJinRecordException {

      if (uid == null || amount == null)

         throw new UserTaoLiJinRecordException(1, "参数不正确");



      String giveMin = configTaoLiJinService.getValueByKey("give_min_amount");

      if (amount.compareTo(new BigDecimal(giveMin)) < 0)

         throw new UserTaoLiJinRecordException(1, "赠送推广红包金额至少" + giveMin + "元");



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

      UserMoneyExtra userMoneyExtra = userMoneyExtraService.selectByPrimaryKey(uid);

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

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



      BigDecimal tlj = userMoneyExtra.getTlj();

      if (amount.compareTo(tlj) > 0)

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



      Date nowDate = new Date();

      // 赠送记录

      UserTaoLiJinGiveRecord giveRecord = new UserTaoLiJinGiveRecord();

      giveRecord.setAmount(amount);

      giveRecord.setGiveUid(uid);

      giveRecord.setState(UserTaoLiJinGiveRecord.STATE_INIT);

      giveRecord.setGiveTime(nowDate);

      giveRecord.setEndTime(DateUtil.plusDayDate(Constant.GIVE_DAYS, new Date()));

      userTaoLiJinGiveRecordService.insertSelective(giveRecord);



      // 口令记录

      TokenRecord tokenRecord = new TokenRecord();

      tokenRecord.setUid(uid);

      tokenRecord.setIdentify(giveRecord.getId() + "");

      tokenRecord.setType(TokenTypeEnum.taoLiJin);

      tokenRecord.setStartTime(nowDate);

      tokenRecord.setEndTime(DateUtil.plusDayDate(Constant.TOKEN_DAYS, new Date()));

      tokenRecord.setState(0);

      tokenRecordService.insertSelective(tokenRecord);



      // 创建口令

      String token = TokenUtil.createToken(tokenRecord.getId());

      tokenRecord.setToken(token);

      tokenRecordService.updateByPrimaryKeySelective(tokenRecord);



      // 更新余额

      UserMoneyExtra updateExtra = new UserMoneyExtra();

      updateExtra.setUid(uid);

      updateExtra.setTlj(MoneyBigDecimalUtil.sub(tlj, amount));

      updateExtra.setUpdateTime(new Date());

      userMoneyExtraService.updateByPrimaryKeySelective(updateExtra);



      String tips = configTaoLiJinService.getValueByKey("give_taolijin_tips");

      String projectChineseName = Constant.systemCommonConfig.getProjectChineseName();

      while (tips.contains("{APP名称}")) {

         tips = tips.replace("{APP名称}", projectChineseName);

      }

      tips = tips.replace("{口令}", token).replace("{下载链接}", configService.get(ConfigKeyEnum.appDownLink.getKey())).replace("{面额}",

            amount.setScale(0).toString());



      executor.execute(new Runnable() {

         @Override

         public void run() {

            try {

               // 插入明细

               UserTaoLiJinDetail detail = new UserTaoLiJinDetail();

               detail.setUid(uid);

               detail.setMoney(new BigDecimal("-" + amount));

               detail.setTitle(TaoLiJinDetailTypeEnum.give.getDesc());

               detail.setType(TaoLiJinDetailTypeEnum.give);

               detail.setCreateTime(new Date());

               userTaoLiJinDetailService.insertSelective(detail);

            } catch (Exception e) {

               LogHelper.errorDetailInfo(e);

            }



            // 成功使用红包

            try {

               BigDecimal total = amount;

               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) {

                        break;

                     }

                     BigDecimal moneySurplus = taoLiJinOrigin.getMoneySurplus();

                     lastMoney = total;

                     total = MoneyBigDecimalUtil.sub(total, moneySurplus);

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

                        moneySurplus = zero;

                     } else {

                        moneySurplus = MoneyBigDecimalUtil.sub(moneySurplus, lastMoney);

                     }



                     UserTaoLiJinOrigin usertlj = new UserTaoLiJinOrigin();

                     usertlj.setId(taoLiJinOrigin.getId());

                     usertlj.setMoneySurplus(moneySurplus);

                     usertlj.setUpdateTime(new Date());

                     userTaoLiJinOriginService.updateByPrimaryKeySelective(usertlj);

                  }

               }

            } catch (Exception e) {

               LogHelper.errorDetailInfo(e);

            }

         }

      });



      return tips;

   }



}