sourcecode/server/gateway-api/src/main/java/com/qxgmat/service/extend/MessageExtendService.java

package com.qxgmat.service.extend;

import com.nuliji.tools.exception.ParameterException;
import com.nuliji.tools.exception.SystemException;
import com.qxgmat.data.constants.enums.MessageCategory;
import com.qxgmat.data.constants.enums.MessageMethod;
import com.qxgmat.data.constants.enums.MessageType;
import com.qxgmat.data.dao.entity.*;
import com.qxgmat.help.MailHelp;
import com.qxgmat.help.WechatHelp;
import com.qxgmat.service.inline.MessageTemplateService;
import com.qxgmat.service.inline.UserMessageService;
import org.apache.logging.log4j.util.Strings;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.*;
import java.util.stream.Collectors;

@Service
public class MessageExtendService {

    @Resource
    private MailHelp mailHelp;

    @Resource
    private WechatHelp wechatHelp;

    @Resource
    private UserMessageService userMessageService;

    @Resource
    private MessageTemplateService messageTemplateService;

    @Resource
    private ToolsService toolsService;

    private void send(User user, MessageCategory category, Map<String, String>params){
        List<MessageTemplate> templateList = messageTemplateService.listByCategory(category);
        for(MessageTemplate template : templateList){
            MessageMethod messageMethod = MessageMethod.ValueOf(template.getMessageMethod());
            String title = replaceBody(template.getTitle(), params);
            String content = replaceBody(template.getContent(), params);
            switch(messageMethod){
                case EMAIL:
                    sendEmail(params.getOrDefault("emails", user.getEmail()), title, content);
                    break;
                case INSIDE:
                    sendInside(user.getId(), title, content, template.getLink(), category);
                    break;
                case WECHAT:
                    sendWechat(user.getWechatOpenidWechat(), category, params);
                    break;
                default:
                    throw new ParameterException("消息发送方式错误");
            }
            messageTemplateService.accumulation(template.getId(), 1);
        }
    }

    private UserMessage sendInside(Integer userId, String title, String content, String link, MessageCategory category){
        // 根据模版创建
        return userMessageService.add(UserMessage.builder()
                .userId(userId)
                .title(title)
                .content(content)
                .link(link)
                .type(MessageType.FromCategory(category).key)
                .isRead(0)
                .build());
    }

    private void sendEmail(String emails, String title, String body){
        mailHelp.sendBaseMail(emails, title, body);
    }

    private void sendWechat(String openId, MessageCategory category, Map<String, String> params){
        wechatHelp.sendMessage(openId, category, params);
    }

    public void sendCustom(User user, MessageTemplate template, Map<String, String>params){
        MessageMethod messageMethod = MessageMethod.ValueOf(template.getMessageMethod());
        String title = replaceBody(template.getTitle(), params);
        String content = replaceBody(template.getContent(), params);
        switch(messageMethod){
            case EMAIL:
                sendEmail(user.getEmail(), title, content);
                break;
            case INSIDE:
                sendInside(user.getId(), title, content, template.getLink(), MessageCategory.CUSTOM);
                break;
            default:
                throw new ParameterException("消息发送方式错误");
        }
    }

    /**
     * 发送邀请邮件
     * @param emails
     */
    public void sendInviteEmail(User user, String[] emails, String code){
        Map<String, String> map = new HashMap<>();
        map.put("emails", Strings.join(Arrays.stream(emails).collect(Collectors.toList()), ';'));
        map.put("code", code);
        send(user, MessageCategory.INVITED, map);
    }

    /**
     * 发送机经更新
     */
    public void sendTextbookUpdate(User user, TextbookLibrary textbookLibrary){
        Map<String, String> map = new HashMap<>();
        send(user, MessageCategory.TEXTBOOK_UPDATE, map);
    }

    /**
     * 发送登录异常
     */
    public void sendLoginAbnormal(User user, UserAbnormal userAbnormal){
        Map<String, String> map = new HashMap<>();
        send(user, MessageCategory.LOGIN_ABNORMAL, map);
    }

    /**
     * 发送预习作业到期通知：6小时，去除夜间12-7点
     * 课程名称：{courseTitle}
     * 作业名称：{assignTitle}
     */
    public void sendPreviewNotice(User user, Course course, PreviewAssign previewAssign){
        Map<String, String> map = new HashMap<>();
        send(user, MessageCategory.PREVIEW_NOTICE, map);
    }

    /**
     * 购买成功提醒
     * 购买服务，课程名：{title}
     * 支付金额：{money}
     * 开通有效期：{expireTime}
     */
    public void sendPayed(User user, UserOrder userOrder){
        Map<String, String> map = new HashMap<>();
        send(user, MessageCategory.PAYED, map);
    }

    /**
     * 发送资料更新
     * 资料名称：{title}
     * 更新时间：{updateTime}
     */
    public void sendDataUpdate(User user, CourseData data, CourseDataHistory history){
        Map<String, String> map = new HashMap<>();
        send(user, MessageCategory.DATA_UPDATE, map);
    }

    /**
     * 提问回复
     * 提问简介:{content}
     * 提问时间:{askTime}
     * 提问状态:{status}, 精选、隐藏
     */
    public void sendAskQuestion(User user,UserAskQuestion userAskQuestion){
        Map<String, String> map = new HashMap<>();
        send(user, MessageCategory.ASK_QUESTION, map);
    }

    /**
     * 提问回复
     * 提问简介:{content}
     * 提问时间:{askTime}
     * 提问状态:{status}, 精选、隐藏
     */
    public void sendAskCourse(User user, UserAskCourse userAskCourse){
        Map<String, String> map = new HashMap<>();
        send(user, MessageCategory.ASK_COURSE, map);
    }

    /**
     * 咨询回复
     * 咨询板块
     * 咨询简介
     */
    public void sendFaqCallback(User user, Faq faq){
        Map<String, String> map = new HashMap<>();
        send(user, MessageCategory.FAQ_CALLBACK, map);
    }

    /**
     * 纠错回复
     * 咨询板块
     * 咨询简介
     */
    public void sendFeedbackAnswer(User user, UserFeedbackError feedbackError){
        Map<String, String> map = new HashMap<>();
        send(user, MessageCategory.FEEDBACK_CALLBACK, map);
    }

    /**
     * 注册成功通知
     * @param user
     */
    public void sendRegister(User user){
        Map<String, String> map = new HashMap<>();
        send(user, MessageCategory.REGISTER, map);
    }

    /**
     * 邮箱变更
     * @param user
     */
    public void sendEmailChange(User user){
        Map<String, String> map = new HashMap<>();
        send(user, MessageCategory.EMAIL_CHANGE, map);
    }

    private String replaceBody(String body, Map<String, String> params){
        for(String key :params.keySet()){
            body = body.replaceAll("{"+key+"}", params.get(key));
        }
        return body;
    }
}