From ea9bc943bdf7c382f3dd609582e7518c6f9a5841 Mon Sep 17 00:00:00 2001
From: zrg <z18737863051@163.com>
Date: 星期四, 14 十一月 2024 09:20:06 +0800
Subject: [PATCH] 修改成可前端自动配置角色,进行发送预警
---
DingDingMsg/DingDingMsg/Program.cs | 46 ++++++++++++++++++++++++++++++++++------------
1 files changed, 34 insertions(+), 12 deletions(-)
diff --git a/DingDingMsg/DingDingMsg/Program.cs b/DingDingMsg/DingDingMsg/Program.cs
index 0a23638..6c4209a 100644
--- a/DingDingMsg/DingDingMsg/Program.cs
+++ b/DingDingMsg/DingDingMsg/Program.cs
@@ -20,7 +20,7 @@
//鏂帿灏�
string appKey = "dingkdddbhdcssk7jduw";
string appSecret = "iv07c-GLfJPnzfJaNAAOfJDl3Z-eODvDAhlInMZCZhGorkle5Evbaxx3ImylvdjQ";
- Console.WriteLine("绋嬪簭姝ｅ湪鎵ц,璇蜂笉瑕佸叧闂�!!!!");
+ Console.WriteLine("瀹夌伅绋嬪簭姝ｅ湪鎵ц,璇蜂笉瑕佸叧闂�!!!!");
// 璁板綍涓婃鎵ц鏂板畾鏃朵换鍔＄殑鏃堕棿
DateTime lastNewTaskExecution = DateTime.MinValue;
while (true)
@@ -77,41 +77,63 @@
}
//寮傚父宸ヨ壓鍙傛暟棰勮锛堟瘡 5 鍒嗛挓鎵ц涓�娆★級
- if ((DateTime.Now - lastNewTaskExecution).TotalMinutes >= 5)
+ DBHelper.CustomWriteLog("寮�濮嬭繘鍏ユ墽琛屽惊鐜�:", DateTime.Now.ToString("yyyy-MM-dd"));
+ if ((DateTime.Now - lastNewTaskExecution).TotalMinutes >= 4)
{
+ DBHelper.CustomWriteLog("宸茶繘鍏ユ墽琛屽惊鐜�:", DateTime.Now.ToString("yyyy-MM-dd"));
//鏌ヨ鍑鸿鏇存柊宸茬粡鍙戦�佺殑寮傚父鍙傛暟
- string Sql = "select HItemID from Sb_EquipMentCollectionTechParam_ERR where HCreateTime>=DATEADD(minute, - 1, GETDATE());";
- dt = oCN.RunProcReturn(Sql, "Sb_EquipMentCollectionTechParam_ERR");
+ 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"));
+ dt = oCN.RunProcReturn(Sql, "Sb_EquipMentCollectionTechParam_ERR");
+ if (dt != null && dt.Tables[0].Rows.Count > 0)
+ {
+ List<string> itemIds = new List<string>();
+ foreach (DataRow row in dt.Tables[0].Rows)
+ {
+ itemIds.Add(row["HItemID"].ToString());
+ }
+ DBHelper.CustomWriteLog("杩斿洖鐨勫紓甯稿弬鏁伴泦鍚堬細" + string.Join(", ", itemIds), DateTime.Now.ToString("yyyy-MM-dd"));
+ }
+ DBHelper.CustomWriteLog("瑕佽繘鍏ユ洿鏂扮殑璇彞", DateTime.Now.ToString("yyyy-MM-dd"));
if (dt.Tables[0].Rows.Count > 0)
{
+ DBHelper.CustomWriteLog("杩涘叆鏇存柊鐨勮鍙�", DateTime.Now.ToString("yyyy-MM-dd"));
//鏇存柊瑕佸彂閫佺殑鍗曞瓙
if (dt != null && dt.Tables != null && dt.Tables.Count > 0)
{
for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
{
string ycSql = "update Sb_EquipMentCollectionTechParam_ERR set HSendFlag = 1 where HItemID = " + dt.Tables[0].Rows[i]["HItemID"].ToString();
- DBHelper.CustomWriteLog("閽夐拤寮傚父棰勮鏇存柊璇彞:" + ycSql, DateTime.Now.ToString("yyyy - MM - dd"));
+ DBHelper.CustomWriteLog("閽夐拤寮傚父棰勮鏇存柊璇彞:" + ycSql, DateTime.Now.ToString("yyyy-MM-dd"));
oCN.RunProc(ycSql);
}
}
else
{
// 鍙互鍦ㄨ繖閲屾坊鍔犻�傚綋鐨勫鐞嗭紝姣斿璁板綍鏃ュ織琛ㄦ槑娌℃湁鍙鐞嗙殑鏁版嵁琛�
- DBHelper.CustomWriteLog("娌℃湁鍙敤浜庡鐞嗙殑鏁版嵁琛�", DateTime.Now.ToString("yyyy - MM - dd"));
- }
+ DBHelper.CustomWriteLog("娌℃湁鏇存柊鐨勮鍙�", DateTime.Now.ToString("yyyy-MM-dd"));
+ }
//鏌ヨ鍑鸿鍙戜俊鎭殑寮傚父鍙傛暟
- string newSql = @"select STUFF((SELECT '; ' + 璁惧缂栫爜 + ' - ' + 宸ヨ壓鍙傛暟鍚嶇О + ' - 鏁伴噰鍊�: ' + CAST(鏁伴噰鍊� as VARCHAR(10)) + ' - 涓婇檺鍊�: ' + CAST(涓婇檺鍊� as VARCHAR(10)) + ' - 涓嬮檺鍊�: ' + CAST(涓嬮檺鍊� as VARCHAR(10))
- FROM h_v_Sb_EquipMentCollectionTechParam_ERRList WHERE 鍙戠幇寮傚父鏃堕棿 >= DATEADD(minute, -1, GETDATE()) FOR XML PATH('')), 1, 2, '') as 鍐呭";
+ //string newSql = @"select STUFF((SELECT '; ' + 璁惧缂栫爜 + ' - ' + 宸ヨ壓鍙傛暟鍚嶇О + ' - 鏁伴噰鍊�: ' + CAST(鏁伴噰鍊� as VARCHAR(10)) + ' - 涓婇檺鍊�: ' + CAST(涓婇檺鍊� as VARCHAR(10)) + ' - 涓嬮檺鍊�: ' + CAST(涓嬮檺鍊� as VARCHAR(10))
+ //FROM h_v_Sb_EquipMentCollectionTechParam_ERRList WHERE 鍙戠幇寮傚父鏃堕棿 >= DATEADD(minute, -1, GETDATE()) FOR XML PATH('')), 1, 2, '') as 鍐呭";
+ string newSql = @"SELECT 杞﹂棿, STUFF(( SELECT '; ' + 璁惧缂栫爜 + ' - ' + 宸ヨ壓鍙傛暟鍚嶇О + ' - 鏁伴噰鍊�: ' + 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 杞﹂棿 ";
+ DBHelper.CustomWriteLog("鏌ヨ鍑鸿鍙戜俊鎭殑寮傚父鍙傛暟"+newSql, DateTime.Now.ToString("yyyy-MM-dd"));
dt = oCN.RunProcReturn(newSql, "h_v_Sb_EquipMentCollectionTechParam_ERRList");
- string HContext = "";
+ string HContext = ""; string HDeptName = "";
HContext = dt.Tables[0].Rows[0]["鍐呭"].ToString();
+ HDeptName= dt.Tables[0].Rows[0]["杞﹂棿"].ToString();
+ DBHelper.CustomWriteLog("鏌ヨ鍑鸿鍙戜俊鎭殑鍐呭" + HContext, DateTime.Now.ToString("yyyy-MM-dd"));
//鏌ヨ鍑鸿鍙戦�佺殑浜�
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 = '宸ヨ壓寮傚父棰勮鎺ユ敹浜�'";
+ left join System_UserGroup c on b.GroupId = c.GroupID where c.GroupName = '"+ HDeptName + "宸ヨ壓寮傚父棰勮鎺ユ敹浜�'";
DBHelper.CustomWriteLog("鏌ヨ鍑鸿鍙戦�佺殑浜�:" + newSql1, DateTime.Now.ToString("yyyy-MM-dd"));
- dt = oCN.RunProcReturn(newSql1, "Gy_Czygl");
+ dt = oCN.RunProcReturn(newSql1, "Gy_Czygl");
+ DBHelper.CustomWriteLog("寮�濮嬭繘鍏ュ彂淇℃伅", DateTime.Now.ToString("yyyy-MM-dd"));
if (dt.Tables[0].Rows.Count > 0)
{
+ DBHelper.CustomWriteLog("杩涘叆鍙戜俊鎭�", DateTime.Now.ToString("yyyy-MM-dd"));
for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
{
string HName = dt.Tables[0].Rows[i]["閽夐拤id"].ToString();
--
Gitblit v1.9.1