用户注册信息

yujian

2020-01-18 f4a0f2acc63d7785eab108419a4e16f5f688cb95

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

@@ -13,41 +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;

@@ -61,6 +71,9 @@


   @Resource

   private RedisManager redisManager;



   @Resource

   private ConfigService configService;



   @Resource

   private UserTaoLiJinRecordMapper userTaoLiJinRecordMapper;

@@ -101,14 +114,20 @@
   @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");

@@ -130,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);

@@ -144,7 +161,7 @@
         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();

@@ -153,13 +170,13 @@
         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 {

@@ -218,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 {

@@ -375,7 +392,7 @@
            // 使用成功消息

            try {

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

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

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

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

               MsgOtherTaoLiJinContentDTO content = new MsgOtherTaoLiJinContentDTO();

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

@@ -496,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;

   }



}