From 6b24ae48c664c25676672ece72d134474c6af817 Mon Sep 17 00:00:00 2001
From: liaoxujun@qq.com <liaoxujun@qq.com>
Date: 星期二, 12 九月 2023 15:00:23 +0800
Subject: [PATCH] 消息发送
---
DocumentServiceApi.InitQMessage/MessageReceive.cs | 26 ++++++++++++++++++++++++--
1 files changed, 24 insertions(+), 2 deletions(-)
diff --git a/DocumentServiceApi.InitQMessage/MessageReceive.cs b/DocumentServiceApi.InitQMessage/MessageReceive.cs
index dee9c00..272bf15 100644
--- a/DocumentServiceApi.InitQMessage/MessageReceive.cs
+++ b/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);
+ }
+
}
+
+
}
--
Gitblit v1.9.1