yujian
2020-04-02 1dc1b5e88283c2ea8cf53c9f014300b3ad0f53de
fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java
@@ -14,6 +14,7 @@
import com.yeshi.fanli.dao.mybatis.user.vip.UserVIPPreInfoMapper;
import com.yeshi.fanli.dto.msg.MsgAccountVipDTO;
import com.yeshi.fanli.dto.msg.MsgOtherSystemGiveDTO;
import com.yeshi.fanli.entity.bus.user.HongBaoV2;
import com.yeshi.fanli.entity.bus.user.ThreeSale;
import com.yeshi.fanli.entity.bus.user.UserInfo;
@@ -27,7 +28,9 @@
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.count.HongBaoV2CountService;
import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService;
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
import com.yeshi.fanli.service.inter.user.UserInfoService;
import com.yeshi.fanli.service.inter.user.UserInviteSeparateService;
import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
import com.yeshi.fanli.service.inter.user.integral.IntegralDetailService;
@@ -77,6 +80,12 @@
   @Resource
   private UserInviteSeparateService userInviteSeparateService;
   
   @Resource
   private UserInfoService userInfoService;
   @Resource
   private UserOtherMsgNotificationService userOtherMsgNotificationService;
   @Override
   public void addUserVIPPreInfo(UserVIPPreInfo info) throws UserVIPPreInfoException {
@@ -108,6 +117,12 @@
      Collections.sort(infoList, cm);
      return infoList.get(0);
   }
   @Override
   public UserVIPPreInfo getVipByProcess(Long uid, int process){
      return userVIPPreInfoMapper.selectByUidAndProcess(uid, process);
   }
   @Override
   public UserVIPPreInfo getProcessInfo(Long uid, Date time) {
@@ -261,17 +276,26 @@
            // 赠送金币
            String goldcoin = userVipConfigService.getValueByKey("vip_pre_3_gift_goldcoin");
            if (!StringUtil.isNullOrEmpty(goldcoin)) {
               int goldcoinNum = Integer.parseInt(goldcoin);
               // 添加金币明细
               IntegralDetail detail = new IntegralDetail();
               detail.setTitle("升级VIP福利");
               detail.setUid(uid);
               detail.setMoney(Constant.VIP_COLDCOIN_NUM);
               detail.setMoney(Integer.parseInt(goldcoin));
               detail.setCreateTime(new Date());
               detail.setUniqueKey("VIP-3-" + uid);
               integralDetailService.insertSelective(detail);
               
               // 添加金币
               userInfoExtraService.addGoldCoinByUid(uid, Integer.parseInt(goldcoin));
               // 消息
               MsgOtherSystemGiveDTO dto = new MsgOtherSystemGiveDTO();
               dto.setName("系统赠送 ");
               dto.setReason("恭喜你!成功升级为普通会员");
               dto.setDesc("获得金币" + goldcoinNum+"枚");
               userOtherMsgNotificationService.vipUpgradeReward(uid, "详情查看,对应会员权益", dto);
            }
            
            // 是否存在下级脱离期限 -更新不脱离
@@ -294,7 +318,13 @@
      if (threeSale == null)
         return;
      
      // 验证上级是否正常
      Long bossId = threeSale.getBoss().getId();
      UserInfo userInfo = userInfoService.getUserById(bossId);
      if (userInfo == null || userInfo.getState() != UserInfo.STATE_NORMAL) {
         return;
      }
      // 验证上级是否已是会员
      UserVIPPreInfo oldInfo = userVIPPreInfoMapper.selectByUidAndProcess(bossId, UserVIPPreInfo.PROCESS_1);
      if (oldInfo != null) {
@@ -303,9 +333,6 @@
      
      // 添加脱离关系倒计时
      userInviteSeparateService.addPreSeparateRecord(uid, bossId);
      // TODO 消息
   }
   
   
@@ -383,6 +410,13 @@
                  userSystemCouponService.insertUserCoupon(uid, CouponTypeEnum.rebatePercentCoupon.name(),
                        UserSystemCoupon.SOURCE_SYSTEM_PUSH, percent, false);
               }
               // 消息
               MsgOtherSystemGiveDTO dto = new MsgOtherSystemGiveDTO();
               dto.setName("系统赠送 ");
               dto.setReason("恭喜你!成功升级为高级会员");
               dto.setDesc("获得返利奖励券" + num +"张");
               userOtherMsgNotificationService.vipUpgradeReward(uid, "详情查看,对应会员权益", dto);
            }
         } catch (Exception e) {
            e.printStackTrace();