用户申请超级会员发送邮件

admin

2020-05-06 9392cd85c0c04fac4889b723a79085ad7c911372

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPInfoServiceImpl.java

@@ -23,8 +23,13 @@
import com.yeshi.fanli.entity.bus.user.vip.UserLevelUpgradedNotify;

import com.yeshi.fanli.entity.bus.user.vip.UserVIPInfo;

import com.yeshi.fanli.entity.bus.user.vip.UserVIPPreInfo;

import com.yeshi.fanli.entity.common.AdminUser;

import com.yeshi.fanli.entity.common.Config;

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

import com.yeshi.fanli.exception.user.vip.UserVIPInfoException;

import com.yeshi.fanli.exception.user.vip.UserVIPPreInfoException;

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.user.UserInfoService;

import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

@@ -38,6 +43,7 @@
import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.email.MailSenderUtil;

import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;

import com.yeshi.fanli.util.rocketmq.MQTopicName;



@@ -77,6 +83,9 @@


   @Resource(name = "producer")

   private Producer producer;



   @Resource

   private ConfigService configService;



   @Override

   @Transactional(rollbackFor = Exception.class)

@@ -172,6 +181,22 @@
      info.setState(UserVIPInfo.STATE_VERIFING);

      info.setUpdateTime(new Date());

      userVIPInfoMapper.updateByPrimaryKeySelective(info);

      // 发送邮件通知

      try {

         Config config = configService.getConfig(ConfigKeyEnum.extractCodeEmailFrom.getKey());

         String[] sts = config.getValue().split(",");

         String account = sts[0];

         String pwd = sts[1];



         String msg = String.format("用户ID:%s 申请超级会员", uid + "");

         String email = userVipConfigService.getValueByKey("apply_vip_email");

         String[] emails = email.split(",");

         for (String e : emails) {

            MailSenderUtil.sendEmail(e, account, pwd, msg, msg);

         }

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }

   }



   @Transactional(rollbackFor = Exception.class)