mec/mec-im/src/main/java/com/ym/service/Impl/MessageServiceImpl.java

package com.ym.service.Impl;

import com.ym.service.MessageService;
import io.rong.methods.message._private.Private;
import io.rong.methods.message.chatroom.Chatroom;
import io.rong.methods.message.group.Group;
import io.rong.methods.message.history.History;
import io.rong.methods.message.system.MsgSystem;
import io.rong.methods.push.Push;
import io.rong.models.Result;
import io.rong.models.message.*;
import io.rong.models.push.BroadcastModel;
import io.rong.models.push.PushModel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

@Slf4j
@Service
public class MessageServiceImpl implements MessageService {

    @Value("${cn.rongcloud.im.appkey}")
    private String appKey;
    @Value("${cn.rongcloud.im.secret}")
    private String appSecret;

    private Private getPrivate(){
        return new Private(appKey,appSecret);
    }
    private Group getGroup(){
        return new Group(appKey,appSecret);
    }
    private Chatroom getChatroom(){
        return new Chatroom(appKey,appSecret);
    }
    private MsgSystem getMsgSystem(){
        return new MsgSystem(appKey,appSecret);
    }
    private History getHistory(){
        return new History(appKey,appSecret);
    }
    private Push getPush(){
        return new Push(appKey,appSecret);
    }

    @Override
    public Result privateSend(PrivateMessage privateMessage) throws Exception {
        return getPrivate().send(privateMessage);
    }

    @Override
    public Result privateRecall(RecallMessage recallMessage) throws Exception {
        return getPrivate().recall(recallMessage);
    }

    @Override
    public Result privateSendTemplate(TemplateMessage templateMessage) throws Exception {
        return getPrivate().sendTemplate(templateMessage);
    }

    @Override
    public Result groupSend(GroupMessage groupMessage) throws Exception {
        return getGroup().send(groupMessage);
    }

    @Override
    public Result groupSendDirection(GroupMessage groupMessage) throws Exception {
        return getGroup().sendDirection(groupMessage);
    }

    @Override
    public Result groupSendMention(MentionMessage mentionMessage) throws Exception {
        return getGroup().sendMention(mentionMessage);
    }

    @Override
    public Result groupRecall(RecallMessage recallMessage) throws Exception {
        return getGroup().recall(recallMessage);
    }

    @Override
    public Result chatroomSend(ChatroomMessage chatroomMessage) throws Exception {
        return getChatroom().send(chatroomMessage);
    }

    @Override
    public Result chatroomBroadcast(ChatroomMessage chatroomMessage) throws Exception {
        return getChatroom().broadcast(chatroomMessage);
    }

    @Override
    public Result systemSend(SystemMessage systemMessage) throws Exception {
        return getMsgSystem().send(systemMessage);
    }

    @Override
    public Result systemBroadcast(BroadcastMessage broadcastMessage) throws Exception {
        return getMsgSystem().broadcast(broadcastMessage);
    }

    @Override
    public Result systemSendTemplate(TemplateMessage templateMessage) throws Exception {
        return getMsgSystem().sendTemplate(templateMessage);
    }

    @Override
    public Result historyGet(String date) throws Exception {
        return getHistory().get(date);
    }

    @Override
    public Result historyRemove(String date) throws Exception {
        return getHistory().remove(date);
    }

    @Override
    public Result pushPush(PushModel pushModel) throws Exception {
        return getPush().push(pushModel);
    }

    @Override
    public Result pushMessage(BroadcastModel broadcastModel) throws Exception {
        return getPush().message(broadcastModel);
    }
}