WEP_V2.1.3/SourceCode/We.Engine/WeEngine.Runtime/Module/Message/WeMessageSender.cs

using System.Collections.Generic;
using System.Linq;
using Abp.Dependency;
using IwbZero.Messages;
using IwbZero.ToolCommon;
using IwbZero.ToolCommon.StringModel;
using WeEngine.Enum;

namespace WeEngine.Module.Message
{
    public class WeMessageSender: IWeMessageSender, ISingletonDependency
    {
        public static WeMessageSender Instance = new WeMessageSender();
        public WeMessageSender()
        {
            Listener = new MsgListener<WeMessage>();
            if (!MsgListener<WeMessage>.IsDelegateRegister("Send"))
            {
                MsgListener<WeMessage>.SendMsg += SendWeMessage;
            }
        }
        private MsgListener<WeMessage> Listener { get; set; }

        public void SendMsg(string msg, MessageType msgType)
        {
            var message= new WeMessage()
            {
                MsgContent = msg,
                MsgType = msgType
            };
            SendMsg(message);
        }


        public  void SendMsg(WeMessage msg)
        {
            Listener.AddSendMsg(msg);
        }
        public  void ReceiveMsg(string msgId)
        {
            Listener.AddReceiveMsg(msgId);
        }

        protected  void SendWeMessage(WeMessage msg)
        {
            if (msg.MsgType != MessageType.InternalMessage)
            {
                var urls = GetSubscriptionUrl(msg.MsgType);
                if (urls != null && urls.Any())
                {
                    foreach (var url in urls)
                    {
                        url.RequestPost(msg.Obj2String(),new Dictionary<string, string>()
                        {
                            ["MessageId"] = msg.Id,
                            ["CallBackUrl"]="",
                        });
                    }
                }
            }
            else
            {

            }
            
        }

        /// <summary>
        /// 获取订阅消息的URL
        /// </summary>
        /// <returns></returns>
        public List<string> GetSubscriptionUrl(MessageType messageType)
        {
            var urls = new List<string>();

            return urls;
        }
    }
}