From 7ca0d964d2df19bf56e8a8a96f34f26a139b078d Mon Sep 17 00:00:00 2001
From: zrg <z1873@LAPTOP-EAVL132E>
Date: 星期五, 27 二月 2026 15:23:57 +0800
Subject: [PATCH] 增加异常工艺参数预警通知
---
DingDingMsg/MesMessage/MesMessageList.cs | 56 ++++++++++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 52 insertions(+), 4 deletions(-)
diff --git a/DingDingMsg/MesMessage/MesMessageList.cs b/DingDingMsg/MesMessage/MesMessageList.cs
index b707021..2b65617 100644
--- a/DingDingMsg/MesMessage/MesMessageList.cs
+++ b/DingDingMsg/MesMessage/MesMessageList.cs
@@ -145,14 +145,14 @@
return;
}
- #region 寮傚父宸ヨ壓鍙傛暟棰勮锛堟瘡 5 鍒嗛挓鎵ц涓�娆★紝浣嗗畾鏃跺櫒涓�1鍒嗛挓锛屾墍浠ュ唴閮ㄥ垽鏂椂闂村樊锛�
+ #region 寮傚父宸ヨ壓鍙傛暟棰勮锛堟瘡 1 鍒嗛挓鎵ц涓�娆★紝浣嗗畾鏃跺櫒涓�1鍒嗛挓锛屾墍浠ュ唴閮ㄥ垽鏂椂闂村樊锛�
DBHelper.CustomWriteLog("寮�濮嬭繘鍏ユ墽琛屽惊鐜� :", DateTime.Now.ToString("yyyy-MM-dd"));
#endregion
#region 寮傚父宸ヨ壓鍙傛暟棰勮澶勭悊锛堟瘡鍒嗛挓鎵ц锛�
- // 鏌ヨ鍑鸿鏇存柊鐨勫紓甯稿弬鏁帮紙鏈�杩�5鍒嗛挓鍐呯殑鏈彂閫佹暟鎹級
- string Sql = "select HItemID from Sb_EquipMentCollectionTechParam_ERR where HCreateTime>=DATEADD(minute, - 4, GETDATE()) AND HSendFlag = 0";
+ // 鏌ヨ鍑鸿鏇存柊鐨勫紓甯稿弬鏁帮紙鏈�杩�1鍒嗛挓鍐呯殑鏈彂閫佹暟鎹級
+ string Sql = "select HItemID from Sb_EquipMentCollectionTechParam_ERR where HCreateTime>=DATEADD(minute, - 1, GETDATE()) AND HSendFlag = 0";
DBHelper.CustomWriteLog("鏌ヨ鍑哄紓甯哥殑鍙傛暟:" + Sql, DateTime.Now.ToString("yyyy-MM-dd"));
DataSet dsErr = oCN.RunProcReturn(Sql, "Sb_EquipMentCollectionTechParam_ERR");
if (dsErr != null && dsErr.Tables[0].Rows.Count > 0)
@@ -242,7 +242,55 @@
}
else if (rule == "APP")
{
-
+ // 鏌ヨ鍑鸿鍙戜俊鎭殑寮傚父鍙傛暟
+ string newSql = @"SELECT 宸ュ簭鍚嶇О, STUFF((
+ SELECT DISTINCT '; ' + 璁惧缂栫爜 + ' - ' + 宸ヨ壓鍙傛暟鍚嶇О + ' - 鏁伴噰鍊�: ' + CAST(鏁伴噰鍊� AS VARCHAR(10))
+ + ' - 涓婇檺鍊�: ' + CAST(涓婇檺鍊� AS VARCHAR(10)) + ' - 涓嬮檺鍊�: ' + CAST(涓嬮檺鍊� AS VARCHAR(10))
+ FROM h_v_Sb_EquipMentCollectionTechParam_ERRList AS InnerTable
+ WHERE InnerTable.宸ュ簭鍚嶇О = OuterTable.宸ュ簭鍚嶇О
+ AND 鍙戠幇寮傚父鏃堕棿 >= DATEADD(minute, -1, GETDATE())
+ FOR XML PATH('')), 1, 2, '') AS 鍐呭
+ FROM h_v_Sb_EquipMentCollectionTechParam_ERRList AS OuterTable
+ GROUP BY 宸ュ簭鍚嶇О";
+
+ DataSet dsContent = oCN.RunProcReturn(newSql, "h_v_Sb_EquipMentCollectionTechParam_ERRList");
+
+ for (int j = 0; j < dsContent.Tables[0].Rows.Count; j++)
+ {
+ DBHelper.CustomWriteLog("寮傚父鍐呭鏁伴噺 " + dsContent.Tables[0].Rows.Count, DateTime.Now.ToString("yyyy-MM-dd"));
+ string HContext = dsContent.Tables[0].Rows[j]["鍐呭"].ToString();
+ string HDeptName = dsContent.Tables[0].Rows[j]["宸ュ簭鍚嶇О"].ToString();
+ if (!string.IsNullOrEmpty(HContext) && HContext.ToLower() != "null")
+ {
+ // 鏌ヨ鍑鸿鍙戦�佺殑浜�
+ string newSql1 = $@"select a.HDingDingUserID 閽夐拤id, a.Czymc 鎺ユ敹浜�
+ from Gy_Czygl a
+ left join System_UserGroupInfo b on a.Czybm = b.UserId
+ left join System_UserGroup c on b.GroupId = c.GroupID
+ where c.GroupName = '{HDeptName}宸ヨ壓寮傚父棰勮鎺ユ敹浜�'";
+ DataSet dsUsers = oCN.RunProcReturn(newSql1, "Gy_Czygl");
+ if (dsUsers.Tables[0].Rows.Count > 0)
+ {
+
+ for (int i = 0; i < dsUsers.Tables[0].Rows.Count; i++)
+ {
+ string HName = dsUsers.Tables[0].Rows[i]["閽夐拤id"].ToString();
+
+ var ds = oCN.RunProcReturn($"exec h_p_OA_WorkLinkBill_TechParam_ERR_Create '{HContext}','{HName}'", "h_p_OA_WorkLinkBill_TechParam_ERR_Create");
+ if (ds != null && ds.Tables[0].Rows.Count > 0)
+ {
+ // 绗竴姝ワ細鍏堣幏鍙栧瓧绗︿覆骞跺垽鏂槸鍚︿负"0"锛屾槸鍒欑洿鎺ヨ烦杩�
+ int newHInterID = int.Parse(ds.Tables[0].Rows[0]["HInterID"].ToString());
+ if (newHInterID != 0)
+ {
+ DBHelper.CustomWriteLog($"鎵ц娑堟伅鎺ㄩ��...{newHInterID}", DateTime.Now.ToString("yyyy-MM-dd"));
+ GeTuiService.PubishSingle(newHInterID); // 鍚屾鏂规硶锛岃嫢鑰楁椂杈冮暱鍙�冭檻寮傛浼樺寲
+ }
+ }
+ }
+ }
+ }
+ }
}
}
#endregion
--
Gitblit v1.9.1