admin
2020-04-09 aa774af6df16ef11e1e34ac5aeed9aae0cb3e8e2
fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java
@@ -1,6 +1,7 @@
package com.yeshi.fanli.service.impl.user.vip;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.Date;
@@ -14,6 +15,7 @@
import com.yeshi.fanli.dao.mybatis.user.vip.UserVIPPreInfoMapper;
import com.yeshi.fanli.dto.msg.MsgAccountVipDTO;
import com.yeshi.fanli.entity.bus.msg.MsgOtherDetail.MsgTypeOtherTypeEnum;
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 +29,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;
@@ -39,6 +43,9 @@
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.annotation.RequestSerializableByKeyService;
import com.yeshi.fanli.vo.msg.ClientTextStyleVO;
import com.yeshi.fanli.vo.msg.CommonMsgItemVO;
import com.yeshi.fanli.vo.msg.CommonMsgItemVOFactory;
@Service
public class UserVIPPreInfoServiceImpl implements UserVIPPreInfoService {
@@ -77,6 +84,12 @@
   @Resource
   private UserInviteSeparateService userInviteSeparateService;
   
   @Resource
   private UserInfoService userInfoService;
   @Resource
   private UserOtherMsgNotificationService userOtherMsgNotificationService;
   @Override
   public void addUserVIPPreInfo(UserVIPPreInfo info) throws UserVIPPreInfoException {
@@ -108,6 +121,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) {
@@ -204,6 +223,11 @@
    */
   @Transactional(rollbackFor = Exception.class)
   private boolean oneProcess(Long uid, long countZiGou, long countShare, long firstTeam, long secondTeam) {
      UserVIPPreInfo oldInfo = userVIPPreInfoMapper.selectByUidAndProcess(uid, UserVIPPreInfo.PROCESS_1);
      if (oldInfo != null) {
         return true;
      }
      boolean process = false;
      String msg = "";
      
@@ -261,17 +285,29 @@
            // 赠送金币
            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));
               // 消息
               List<CommonMsgItemVO> listMsg = new ArrayList<>();
               listMsg.add(CommonMsgItemVOFactory.createMsgItemVO(new ClientTextStyleVO("状        态", ClientTextStyleVO.COLOR_TITLE),
                     new ClientTextStyleVO("恭喜你!成功升级为普通会员", ClientTextStyleVO.COLOR_CONTENT)));
               listMsg.add(CommonMsgItemVOFactory.createMsgItemVO(new ClientTextStyleVO("奖        励", ClientTextStyleVO.COLOR_TITLE),
                     new ClientTextStyleVO("获得金币" + goldcoinNum+"枚", ClientTextStyleVO.COLOR_CONTENT)));
               listMsg.add(CommonMsgItemVOFactory.createMsgItemVO(new ClientTextStyleVO("备        注", ClientTextStyleVO.COLOR_TITLE),
                     new ClientTextStyleVO("详情查看,对应会员权益", ClientTextStyleVO.COLOR_CONTENT)));
               userOtherMsgNotificationService.createMsgOtherDetail(uid, listMsg, MsgTypeOtherTypeEnum.vipUpgradeReward);
            }
            
            // 是否存在下级脱离期限 -更新不脱离
@@ -294,7 +330,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 +345,6 @@
      
      // 添加脱离关系倒计时
      userInviteSeparateService.addPreSeparateRecord(uid, bossId);
      // TODO 消息
   }
   
   
@@ -324,11 +363,11 @@
      boolean process = false;
      String msg = "";
      
      long limitZiGou = 0;
      String zigou = userVipConfigService.getValueByKey("vip_pre_7_zigou_order_count");
      if (!StringUtil.isNullOrEmpty(zigou)) {
         limitZiGou = Long.parseLong(zigou);
      }
      long limitZiGou = 10;
//      String zigou = userVipConfigService.getValueByKey("vip_pre_7_zigou_order_count");
//      if (!StringUtil.isNullOrEmpty(zigou)) {
//         limitZiGou = Long.parseLong(zigou);
//      }
      
      long limitShare = 0;
      String share = userVipConfigService.getValueByKey("vip_pre_7_share_order_count");
@@ -383,6 +422,15 @@
                  userSystemCouponService.insertUserCoupon(uid, CouponTypeEnum.rebatePercentCoupon.name(),
                        UserSystemCoupon.SOURCE_SYSTEM_PUSH, percent, false);
               }
               List<CommonMsgItemVO> listMsg = new ArrayList<>();
               listMsg.add(CommonMsgItemVOFactory.createMsgItemVO(new ClientTextStyleVO("状        态", ClientTextStyleVO.COLOR_TITLE),
                     new ClientTextStyleVO("恭喜你!成功升级为高级会员", ClientTextStyleVO.COLOR_CONTENT)));
               listMsg.add(CommonMsgItemVOFactory.createMsgItemVO(new ClientTextStyleVO("奖        励", ClientTextStyleVO.COLOR_TITLE),
                     new ClientTextStyleVO("获得返利奖励券" + num +"张", ClientTextStyleVO.COLOR_CONTENT)));
               listMsg.add(CommonMsgItemVOFactory.createMsgItemVO(new ClientTextStyleVO("备        注", ClientTextStyleVO.COLOR_TITLE),
                     new ClientTextStyleVO("详情查看,对应会员权益", ClientTextStyleVO.COLOR_CONTENT)));
               userOtherMsgNotificationService.createMsgOtherDetail(uid, listMsg, MsgTypeOtherTypeEnum.vipUpgradeReward);
            }
         } catch (Exception e) {
            e.printStackTrace();