From b957cfb89c9968f47cc5ce9795e6ffb05bc57fd8 Mon Sep 17 00:00:00 2001
From: 啊鑫 <t2856754968@163.com>
Date: 星期三, 30 十月 2024 16:05:48 +0800
Subject: [PATCH] 11
---
MES.Service/service/MessageCenterManager.cs | 78 +++++++++++++++++++++++++++++++++++++++
1 files changed, 78 insertions(+), 0 deletions(-)
diff --git a/MES.Service/service/MessageCenterManager.cs b/MES.Service/service/MessageCenterManager.cs
new file mode 100644
index 0000000..754a16d
--- /dev/null
+++ b/MES.Service/service/MessageCenterManager.cs
@@ -0,0 +1,78 @@
+锘縰sing MES.Service.DB;
+using MES.Service.Modes;
+using SqlSugar;
+
+namespace MES.Service.service;
+
+public class MessageCenterManager : Repository<MessageCenter>
+{
+ //褰撳墠绫诲凡缁忕户鎵夸簡 Repository 澧炪�佸垹銆佹煡銆佹敼鐨勬柟娉�
+
+ public List<MessageCenter> GetPushFailedPage(MessageCenter query)
+ {
+ return Context.Queryable<MessageCenter>()
+ .Where(it =>
+ it.Result == 0 && it.Status == 1 &&
+ it.Seq == 1 && it.Title != null)
+ .WhereIF(query.isShow == 1, it => it.DealWith == 0)
+ .OrderByDescending(it => it.CreateDate)
+ .ToPageList(1, 20);
+ }
+
+ public int save(MessageCenter entity)
+ {
+ entity.Guid = Guid.NewGuid();
+ entity.CreateDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
+ entity.Method = "POST";
+ return Db.Insertable(entity).ExecuteReturnIdentity();
+ }
+
+ public bool SetError(MessageCenter entity)
+ {
+ entity.CreateDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
+ entity.Method = "POST";
+ entity.Result = 0;
+ entity.DealWith = 0;
+ entity.Status = 1;
+ return base.Insert(entity);
+ }
+
+ //鑾峰彇鎵�鏈夋病鏈夋垚鍔熺殑璇锋眰
+ public List<MessageCenter> ErrorMsg()
+ {
+ return Context.Queryable<MessageCenter>()
+ .GroupBy(a => new
+ {
+ a.TableName, a.Pid, a.Title, a.PageName
+ })
+ .Where(a =>
+ a.DealWith == 0 && a.Status == 0 && a.Result == 0 &&
+ a.Title == null)
+ .Select<MessageCenter>(a => new MessageCenter
+ {
+ TableName = a.TableName,
+ Pid = a.Pid,
+ Title = a.Title,
+ PageName = a.PageName,
+ Count = SqlFunc.AggregateCount(a.Guid)
+ }).ToList();
+ }
+ //鏍规嵁鍑犵鎯呭喌鏇存柊 淇濇寔椤甸潰id鏄浐瀹氱殑
+
+
+ //鍓嶅彴閲嶆柊鍙戦��
+ public int ResetUpdate(MessageCenter entity)
+ {
+ return UseTransaction(db =>
+ {
+ return db.Updateable<MessageCenter>()
+ .SetColumns(a => a.Data == entity.Data)
+ .SetColumns(a => a.Result == entity.Result)
+ .SetColumns(a => a.ResultData == entity.ResultData)
+ .SetColumns(a => a.Status == entity.Status)
+ .SetColumns(a => a.DealWith == entity.DealWith)
+ .Where(a => a.Guid == entity.Guid)
+ .ExecuteCommand();
+ });
+ }
+}
\ No newline at end of file
--
Gitblit v1.9.3