消息发送

liaoxujun@qq.com

2023-09-12 6b24ae48c664c25676672ece72d134474c6af817

 DocumentServiceApi.InitQMessage/MessageReceive.cs

@@ -8,6 +8,7 @@
using Furion.Schedule;
using InitQ.Abstractions;
using InitQ.Attributes;
using InitQ.Cache;
using Microsoft.Extensions.Options;
using SqlSugar;
using System;
@@ -23,7 +24,11 @@
    /// </summary>
    public class MessageReceive: IRedisSubscribe
    {

        private InitQ.Cache.ICacheService _cacheService;
      public    MessageReceive(InitQ.Cache.ICacheService cacheService)
        {
            _cacheService = cacheService;
        }
         
        /// <summary>
        /// 初始化订单处理
@@ -239,5 +244,19 @@

        }

        /// <summary>
        /// 发送消息给用户中，用户中心会响应这个消息
        /// </summary>
        /// <param name="msg"></param>
        /// <returns></returns>
        [SubscribeDelay(INITQMessageDefine.DTSendMessage)]
        private async Task  SendMessage(string msg)
        {
            
          await  _cacheService.ListRightPushAsync(INITQMessageDefine.DTSendMessage, msg);
    }

    }


}