From 3b815e0d4eb3b378ca31bfb603a92b0b69d499fe Mon Sep 17 00:00:00 2001
From: zrg <z18737863051@163.com>
Date: 星期一, 23 九月 2024 18:16:57 +0800
Subject: [PATCH] 优化安灯增加工艺参数预警信息,增加模具设备保养预警
---
DingDingMsg/DingDingMsg/Program.cs | 99 ++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 93 insertions(+), 6 deletions(-)
diff --git a/DingDingMsg/DingDingMsg/Program.cs b/DingDingMsg/DingDingMsg/Program.cs
index b42f385..0a23638 100644
--- a/DingDingMsg/DingDingMsg/Program.cs
+++ b/DingDingMsg/DingDingMsg/Program.cs
@@ -9,14 +9,20 @@
{
class Program
{
-
+ //寮傚父鍙嶉鍗�,寮傚父宸ヨ壓鍙傛暟棰勮 鍙戦�侀拤閽夋秷鎭�
static DBHelper oCN = new DBHelper();
static DataSet dt = new DataSet();
static async Task Main(string[] args)
{
- string appKey = "dingrsrzhdyn3mlaof95";
- string appSecret = "RAqH6YtZnPLCpDbuqfaYQkKkVtVdS0wqfC8I26X6qiS-8eoCJCNrzx3fubGND4Sq";
+ //鏈湴
+ //string appKey = "dingrsrzhdyn3mlaof95";
+ //string appSecret = "RAqH6YtZnPLCpDbuqfaYQkKkVtVdS0wqfC8I26X6qiS-8eoCJCNrzx3fubGND4Sq";
+ //鏂帿灏�
+ string appKey = "dingkdddbhdcssk7jduw";
+ string appSecret = "iv07c-GLfJPnzfJaNAAOfJDl3Z-eODvDAhlInMZCZhGorkle5Evbaxx3ImylvdjQ";
Console.WriteLine("绋嬪簭姝ｅ湪鎵ц,璇蜂笉瑕佸叧闂�!!!!");
+ // 璁板綍涓婃鎵ц鏂板畾鏃朵换鍔＄殑鏃堕棿
+ DateTime lastNewTaskExecution = DateTime.MinValue;
while (true)
{
//鏌ユ暟鎹�
@@ -24,10 +30,10 @@
" a inner join OA_ErrMsgBackBillMain b on a.HInterID=b.HInterID left join Gy_Czygl c " +
"on a.HReceiveMan = c.Czymc where HSendFlag = '0' order by a.HInterID";
dt = oCN.RunProcReturn(sql, "OA_ErrMsgBackBillSub2");
+ //寮傚父鍙嶉鍗曡嚜鍔ㄥ彂淇℃伅
if (dt.Tables[0].Rows.Count > 0)
{
string HContext = "";
-
for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
{
@@ -44,7 +50,9 @@
string accessToken = responseJson["accessToken"].ToString();
//璋冪敤鏂规硶鍙戦�佹秷鎭�
- string agentId = "3118119317";//閽夐拤鍚庡彴寤虹珛鐨勫皬绋嬪簭id
+ //string agentId = "3118119317";//閽夐拤鍚庡彴寤虹珛鐨勫皬绋嬪簭id
+ //鏂帿灏�
+ string agentId = "3151454458";//閽夐拤鍚庡彴寤虹珛鐨勫皬绋嬪簭id
string userIdList = HName;//閽夐拤浜哄憳鐨刬d
string deptIdList = "0"; // 绌哄瓧绗︿覆琛ㄧず涓嶆寚瀹氶儴闂�
string toAllUser = "false";
@@ -58,7 +66,6 @@
//鏇存柊鐘舵��
string sql1 = "update OA_ErrMsgBackBillSub2 set HSendFlag='1' where HReceiveMan in ('" + Stares + "')";
oCN.RunProc(sql1);
- Console.WriteLine(sql1);
DBHelper.CustomWriteLog("閽夐拤杩斿洖淇℃伅:"+response+" 鏇存柊瀛愯〃璇彞:"+sql1, DateTime.Now.ToString("yyyy-MM-dd"));
}
else
@@ -68,7 +75,87 @@
}
}
}
+
+ //寮傚父宸ヨ壓鍙傛暟棰勮锛堟瘡 5 鍒嗛挓鎵ц涓�娆★級
+ if ((DateTime.Now - lastNewTaskExecution).TotalMinutes >= 5)
+ {
+ //鏌ヨ鍑鸿鏇存柊宸茬粡鍙戦�佺殑寮傚父鍙傛暟
+ string Sql = "select HItemID from Sb_EquipMentCollectionTechParam_ERR where HCreateTime>=DATEADD(minute, - 1, GETDATE());";
+ dt = oCN.RunProcReturn(Sql, "Sb_EquipMentCollectionTechParam_ERR");
+ if (dt.Tables[0].Rows.Count > 0)
+ {
+ //鏇存柊瑕佸彂閫佺殑鍗曞瓙
+ 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"));
+ oCN.RunProc(ycSql);
+ }
+ }
+ else
+ {
+ // 鍙互鍦ㄨ繖閲屾坊鍔犻�傚綋鐨勫鐞嗭紝姣斿璁板綍鏃ュ織琛ㄦ槑娌℃湁鍙鐞嗙殑鏁版嵁琛�
+ 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 鍐呭";
+ dt = oCN.RunProcReturn(newSql, "h_v_Sb_EquipMentCollectionTechParam_ERRList");
+ string HContext = "";
+ HContext = dt.Tables[0].Rows[0]["鍐呭"].ToString();
+ //鏌ヨ鍑鸿鍙戦�佺殑浜�
+ 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 = '宸ヨ壓寮傚父棰勮鎺ユ敹浜�'";
+ DBHelper.CustomWriteLog("鏌ヨ鍑鸿鍙戦�佺殑浜�:" + newSql1, DateTime.Now.ToString("yyyy-MM-dd"));
+ dt = oCN.RunProcReturn(newSql1, "Gy_Czygl");
+ if (dt.Tables[0].Rows.Count > 0)
+ {
+ for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
+ {
+ string HName = dt.Tables[0].Rows[i]["閽夐拤id"].ToString();
+ string Stares = dt.Tables[0].Rows[i]["鎺ユ敹浜�"].ToString();
+
+ MSG msg = new MSG();
+
+ //鑾峰彇浼佷笟鐨刟ccess_token鐨勫��
+ string response = msg.GetAccessToken(appKey, appSecret);
+ JObject responseJson = JObject.Parse(response);
+ // 鑾峰彇access_token鐨勫��
+ string accessToken = responseJson["accessToken"].ToString();
+
+ //璋冪敤鏂规硶鍙戦�佹秷鎭�
+ //string agentId = "3118119317";//閽夐拤鍚庡彴寤虹珛鐨勫皬绋嬪簭id
+ //鏂帿灏�
+ string agentId = "3151454458";//閽夐拤鍚庡彴寤虹珛鐨勫皬绋嬪簭id
+ string userIdList = HName;//閽夐拤浜哄憳鐨刬d
+ string deptIdList = "0"; // 绌哄瓧绗︿覆琛ㄧず涓嶆寚瀹氶儴闂�
+ string toAllUser = "false";
+ string message = HContext;
+
+ // 璋冪敤鏂规硶鍙戦�佹秷鎭�
+ response = await msg.SendTextMessage(accessToken, agentId, userIdList, deptIdList, toAllUser, message);
+ ResponseData responseData = JsonConvert.DeserializeObject<ResponseData>(response);
+ if (responseData.errcode == 0)
+ {
+ DBHelper.CustomWriteLog("閽夐拤寮傚父棰勮鍙戦�佹垚鍔�", DateTime.Now.ToString("yyyy-MM-dd"));
+ }
+ else
+ {
+ Console.WriteLine(responseData.errcode);
+ DBHelper.CustomWriteLog("閽夐拤杩斿洖淇℃伅:" + response, DateTime.Now.ToString("yyyy-MM-dd"));
+ }
+
+ }
+ }
+ }
+
+ lastNewTaskExecution = DateTime.Now;
+ }
+
+
// 绛夊緟涓�鍒嗛挓
await Task.Delay(TimeSpan.FromMinutes(1));
}
--
Gitblit v1.9.1