消息发送

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,8 @@
                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();
            if(Tinfo==null)
@@ -66,7 +73,7 @@
                    CreatBy = "消息队列 InitTenantOder",
                    CreatTime = DateTime.Now,
                    Description = obj.Description,
                    Name = obj.Name??obj.ITCode+"集团账号",
                    Name =obj.TenantName ,
                    PsW = obj.ITCode.Substring(obj.ITCode.Length - 4),


@@ -78,6 +85,8 @@
                    Description = obj.Description,
                    EmployeeMaxCount = obj.EmployeeCount ?? 0,
                    UnitMaxCount = obj.UnitCount ?? 0,
                     
                     HasDocumentPermission=obj.HasDocumentPermission,
                    OverTime = DateTime.Now.AddMonths(obj.MonthCount ?? 0),


@@ -107,7 +116,7 @@

                Document_TenderUnit tenderUnit = new Document_TenderUnit()
                {
                    UnitName = obj.Name ?? "集团公司",
                    UnitName = obj.TenantName ?? "集团公司",
                    AdviseFlag = 2,
                    UserId = 0,
                    CreatTime = DateTime.Now.ToString("yyyy MM dd"),
@@ -235,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);
        }

    }


}