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

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)