From b9d9c0e91d8bbdf411540daa0d5887140d6327f9 Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期二, 28 十月 2025 21:34:28 +0800
Subject: [PATCH] 添加提示信息前端弹窗显示
---
新建文件夹/WIDESEA_WMSServer/ClassLibrary2/MessageInfoService.cs | 87 ++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 85 insertions(+), 2 deletions(-)
diff --git "a/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/ClassLibrary2/MessageInfoService.cs" "b/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/ClassLibrary2/MessageInfoService.cs"
index 2af9277..ea8b9de 100644
--- "a/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/ClassLibrary2/MessageInfoService.cs"
+++ "b/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/ClassLibrary2/MessageInfoService.cs"
@@ -1,4 +1,9 @@
-锘縰sing SqlSugar.Extensions;
+锘縰sing HslCommunication.WebSocket;
+using NetTaste;
+using Newtonsoft.Json;
+using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
+using Quartz.Util;
+using SqlSugar.Extensions;
using System;
using System.Collections.Generic;
using System.Linq;
@@ -8,16 +13,22 @@
using WIDESEA_Core;
using WIDESEA_Core.BaseRepository;
using WIDESEA_Core.BaseServices;
+using WIDESEA_Core.Caches;
using WIDESEA_Core.Enums;
using WIDESEA_IWMsInfoServices;
using WIDESEA_Model.Models;
+using static WIDESEA_Core.WebSocketHostedService;
namespace WIDESEA_WMsInfoServices
{
public class MessageInfoService : ServiceBase<Dt_MessageInfo, IRepository<Dt_MessageInfo>>, IMessageInfoService
{
- public MessageInfoService(IRepository<Dt_MessageInfo> BaseDal) : base(BaseDal)
+ private readonly ICacheService _cacheService;
+ private readonly WebSocketServer _webSocketServer;
+ public MessageInfoService(IRepository<Dt_MessageInfo> BaseDal, ICacheService cacheService, WebSocketServer webSocketServer) : base(BaseDal)
{
+ _cacheService = cacheService;
+ _webSocketServer = webSocketServer;
}
public IRepository<Dt_MessageInfo> Repository => BaseDal;
@@ -87,5 +98,77 @@
}
return content;
}
+
+ public void GetMessageInfo()
+ {
+ try
+ {
+ List<int> keys = new List<int>();
+ List<Message> messagesinfo = new List<Message>();
+ string MessageInfo = _cacheService.Get("MessageInfo");
+ if (!string.IsNullOrEmpty(MessageInfo))
+ {
+ List<Message>? messages = JsonConvert.DeserializeObject<List<Message>>(MessageInfo);
+ if (messages != null)
+ {
+ messagesinfo = messages;
+ keys = messages.Select(x => x.Id).ToList();
+ }
+ }
+ var messinfo = BaseDal.QueryData(x => !keys.Contains(x.Id));
+ foreach (var item in messinfo)
+ {
+ Message message = new Message()
+ {
+ Id = item.Id,
+ MessageGroupBy = GetMessageGroupBy(item.MessageGroupBy),
+ MessageInfo = item.MessageInfo,
+ MessageName = item.MessageName,
+ Date = item.CreateDate,
+ };
+ messagesinfo.Add(message);
+ object obj = new
+ {
+ title = message.MessageGroupBy,
+ name = item.MessageName,
+ message = item.MessageInfo,
+ date = item.CreateDate,
+ };
+ if (_webSocketServer.OnlineCount > 0)
+ _webSocketServer.PublishAllClientPayload(JsonConvert.SerializeObject(obj));
+ }
+ _cacheService.AddOrUpdate("MessageInfo", JsonConvert.SerializeObject(messagesinfo));
+ }
+ catch (Exception ex)
+ {
+
+ }
+ }
+ public string GetMessageGroupBy(int GroupBy)
+ {
+ string MessageGroupBy = GroupBy.ToString();
+ switch (GroupBy)
+ {
+ case (int)MessageGroupByEnum.EquipmentAlarm:
+ MessageGroupBy = "璁惧鎶ヨ";
+ break;
+ case (int)MessageGroupByEnum.InventoryExceedAlarm:
+ MessageGroupBy = "搴撳瓨杩囨湡棰勮";
+ break;
+ case (int)MessageGroupByEnum.InventoryLowAlarm:
+ MessageGroupBy = "浣庡簱瀛橀璀�";
+ break;
+ case (int)MessageGroupByEnum.MaterielAlarm:
+ MessageGroupBy = "鐗╂枡寰呯淮鎶ゆ姤璀�";
+ break;
+ case (int)MessageGroupByEnum.InOrderAlarm:
+ MessageGroupBy = "鍏ュ簱鍗曟姤璀�";
+ break;
+ case (int)MessageGroupByEnum.OutOrderAlarm:
+ MessageGroupBy = "鍑哄簱鍗曟姤璀�";
+ break;
+ }
+ return MessageGroupBy;
+ }
}
}
--
Gitblit v1.9.3