消息发送

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,8 +24,12 @@
    /// </summary>
    public class MessageReceive: IRedisSubscribe
    {

         
        private InitQ.Cache.ICacheService _cacheService;
      public    MessageReceive(InitQ.Cache.ICacheService cacheService)
        {
            _cacheService = cacheService;
        }
       
        /// <summary>
        /// 初始化订单处理
        /// </summary>
@@ -55,6 +60,7 @@
                PayTime = obj.PayTime,
                ZcUserID = obj.ZcUserID,
                ITCode = obj.ITCode,
                 HasDocumentPermission=obj.HasDocumentPermission
                 
            };
            TenantInfo? Tinfo = await _db.Queryable<TenantInfo>().Where(x=>x.ZcUserID==obj.ZcUserID).SingleAsync();
@@ -79,6 +85,8 @@
                    Description = obj.Description,
                    EmployeeMaxCount = obj.EmployeeCount ?? 0,
                    UnitMaxCount = obj.UnitCount ?? 0,
                     
                     HasDocumentPermission=obj.HasDocumentPermission,
                    OverTime = DateTime.Now.AddMonths(obj.MonthCount ?? 0),


@@ -236,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);
        }

    }


}