pinganxiaoyuan/SafeCampus.API/SafeCampus.Plugin/SafeCampus.Plugin.Mqtt/Service/Notice/MqttNoticeService.cs

namespace SafeCampus.Plugin.Mqtt
{
    /// <summary>
    /// <inheritdoc cref="INoticeService"/>
    /// </summary>
    [Injection(Named = "mqtt")]
    public class MqttNoticeService : INoticeService
    {
        public MqttNoticeService()
        {
        }

        /// <inheritdoc/>
        public async Task UpdatePassWord(string userId, List<string> clientIds, string message)
        {
            var _mqttClientManager = GetMqttClientManager();
            //发送修改密码消息
            await _mqttClientManager.GetClient().PublishAsync(MqttConst.Mqtt_TopicPrefix + userId, new MqttMessage
            {
                Data = new { Message = message, ClientIds = clientIds },
                MsgType = MqttConst.Mqtt_Message_UpdatePassword
            });
        }

        /// <inheritdoc/>
        public async Task NewMesage(List<string> userIds, List<string> clientIds, string message)
        {
            var _mqttClientManager = GetMqttClientManager();
            //遍历用户Id
            foreach (var userId in userIds)
            {
                //发送消息
                await _mqttClientManager.GetClient().PublishAsync(MqttConst.Mqtt_TopicPrefix + userId, new MqttMessage
                {
                    Data = new { Message = message },
                    MsgType = MqttConst.Mqtt_Message_New
                });
            }
        }

        /// <inheritdoc/>
        public async Task UserLoginOut(string userId, List<string> clientIds, string message)
        {
            var _mqttClientManager = GetMqttClientManager();
            //发送通知下线消息
            await _mqttClientManager.GetClient().PublishAsync(MqttConst.Mqtt_TopicPrefix + userId, new MqttMessage
            {
                Data = new { Message = message, ClientIds = clientIds },
                MsgType = MqttConst.Mqtt_Message_LoginOut
            });
        }

        /// <summary>
        /// 获取hubContext
        /// </summary>
        /// <returns></returns>
        private IMqttClientManager GetMqttClientManager()
        {
            //解析服务
            var service = App.GetService<IMqttClientManager>();
            return service;
        }
    }
}