From ea9bc943bdf7c382f3dd609582e7518c6f9a5841 Mon Sep 17 00:00:00 2001
From: zrg <z18737863051@163.com>
Date: 星期四, 14 十一月 2024 09:20:06 +0800
Subject: [PATCH] 修改成可前端自动配置角色,进行发送预警
---
DingDingMsg_EarlyWarning/Program.cs | 47 +++++++++++++++++++++++++++--------------------
1 files changed, 27 insertions(+), 20 deletions(-)
diff --git a/DingDingMsg_EarlyWarning/Program.cs b/DingDingMsg_EarlyWarning/Program.cs
index b11be21..0d62411 100644
--- a/DingDingMsg_EarlyWarning/Program.cs
+++ b/DingDingMsg_EarlyWarning/Program.cs
@@ -15,20 +15,23 @@
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("绋嬪簭姝ｅ湪鎵ц,璇蜂笉瑕佸叧闂�!!!!");
+ //string appKey = "dingkdddbhdcssk7jduw";
+ //string appSecret = "iv07c-GLfJPnzfJaNAAOfJDl3Z-eODvDAhlInMZCZhGorkle5Evbaxx3ImylvdjQ";
+ Console.WriteLine("绋嬪簭2姝ｅ湪鎵ц,璇蜂笉瑕佸叧闂�!!!!");
+ string HDeptName = "";
// 璁板綍涓婃鎵ц鏂板畾鏃朵换鍔＄殑鏃堕棿
while (true)
{
//鏌ユ壘璁惧淇濆吇棰勮
- string sql = "SELECT a.HInterID,b.HEntryID,c.HEquipFileNo 璁惧缂栫爜, c.HName 璁惧鍚嶇О FROM Sb_EquipMaintainPlanBillMain a " +
+ string sql = "SELECT a.HInterID,b.HEntryID,c.HEquipFileNo 璁惧缂栫爜, c.HName 璁惧鍚嶇О,d.HName 璁惧閮ㄩ棬 FROM Sb_EquipMaintainPlanBillMain a " +
"INNER JOIN Sb_EquipMaintainPlanBillSub_Plan b ON a.HInterID = b.HInterID " +
"LEFT JOIN Gy_EquipFileBillMain c ON a.HEquipID = c.HInterID " +
- "WHERE CAST(CONVERT(datetime, b.HErrBeginTime, 120) AS DATE) = CAST(GETDATE() AS DATE) and HSendFlag = '0'";
+ "LEFT JOIN Gy_Department d ON a.HDeptID = d.HItemID " +
+ " WHERE CONVERT(date, b.HErrBeginTime, 120) = CONVERT(date, GETDATE(), 120) and HSendFlag = '0'";
+ DBHelper.CustomWriteLog("鏌ヨ璁惧淇濆吇璁″垝:" + sql, DateTime.Now.ToString("yyyy-MM-dd"));
dt = oCN.RunProcReturn(sql, "Sb_EquipMaintainPlanBillMain");
//璁惧淇濆吇棰勮鑷姩鍙戜俊鎭�
if (dt.Tables[0].Rows.Count > 0)
@@ -37,14 +40,15 @@
for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
{
- HContext = "璁惧缂栫爜涓�:"+dt.Tables[0].Rows[i]["璁惧缂栫爜"].ToString()+ ",璁惧鍚嶇О涓�:"+dt.Tables[0].Rows[i]["璁惧鍚嶇О"].ToString()+",宸插埌淇濆吇棰勮鏃ユ湡,闇�灏藉揩杩涜淇濆吇";
+ HContext = "璁惧缂栫爜涓�:" + dt.Tables[0].Rows[i]["璁惧缂栫爜"].ToString() + ",璁惧鍚嶇О涓�:" + dt.Tables[0].Rows[i]["璁惧鍚嶇О"].ToString() + ",宸插埌淇濆吇棰勮鏃ユ湡,闇�灏藉揩杩涜淇濆吇";
//鏇存柊璁惧淇濆吇璁″垝棰勮 瀛愯〃
- string sql1 = "update Sb_EquipMaintainPlanBillSub_Plan set HSendFlag='1' where HInterID="+ dt.Tables[0].Rows[i]["HInterID"].ToString() + " and HEntryID=" + dt.Tables[0].Rows[i]["HEntryID"].ToString()+""; ;
+ string sql1 = "update Sb_EquipMaintainPlanBillSub_Plan set HSendFlag='1' where HInterID=" + dt.Tables[0].Rows[i]["HInterID"].ToString() + " and HEntryID=" + dt.Tables[0].Rows[i]["HEntryID"].ToString() + ""; ;
oCN.RunProc(sql1);
DBHelper.CustomWriteLog("璁惧淇濆吇璁″垝棰勮:" + sql1 + " 鏇存柊瀛愯〃璇彞:" + sql1, DateTime.Now.ToString("yyyy-MM-dd"));
-
+ HDeptName = dt.Tables[0].Rows[i]["璁惧閮ㄩ棬"].ToString();
string sql2 = "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("璁惧淇濆吇璁″垝棰勮鎺ユ敹浜�:" + sql2, DateTime.Now.ToString("yyyy-MM-dd"));
dts = oCN.RunProcReturn(sql2, "Gy_Czygl");
for (int j = 0; j < dts.Tables[0].Rows.Count; j++)
{
@@ -70,7 +74,7 @@
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
@@ -78,15 +82,17 @@
Console.WriteLine(responseData.errcode);
DBHelper.CustomWriteLog("閽夐拤杩斿洖淇℃伅:" + response, DateTime.Now.ToString("yyyy-MM-dd"));
}
- }
+ }
}
}
//鏌ユ壘妯″叿淇濆吇棰勮
- string newsql = "SELECT a.HInterID,b.HEntryID,c.HMouldNo 妯″叿缂栫爜, c.HName 妯″叿鍚嶇О,B.HErrBeginQty,HSendFlag FROM Sc_MouldMaintainPlanBillMain a " +
+ string newsql = "SELECT a.HInterID,b.HEntryID,c.HMouldNo 妯″叿缂栫爜, c.HName 妯″叿鍚嶇О,B.HErrBeginQty,HSendFlag,d.HName 妯″叿閮ㄩ棬 FROM Sc_MouldMaintainPlanBillMain a " +
"INNER JOIN Sc_MouldMaintainPlanBillSub_Plan b ON a.HInterID = b.HInterID " +
"LEFT JOIN Gy_MouldFileMain c ON a.HMouldID = c.HInterID " +
- "WHERE b.HErrBeginQty >= (select sum(HUseLife) from Sc_MouldLifeUseBillSub WHERE HMaterID = a.HMouldID) and b.HSendFlag = '0'";
+ "LEFT JOIN Gy_Department d ON a.HDeptID = d.HItemID " +
+ " WHERE b.HErrBeginQty <= (select b.HUseNowQty+sum(HUseLife) from Sc_MouldLifeUseBillSub WHERE HMaterID = a.HMouldID) and b.HSendFlag = '0'";
+ DBHelper.CustomWriteLog("鏌ヨ妯″叿淇濆吇璁″垝:"+newsql, DateTime.Now.ToString("yyyy-MM-dd"));
dt = oCN.RunProcReturn(newsql, "Sb_EquipMaintainPlanBillMain");
//妯″叿淇濆吇棰勮鑷姩鍙戜俊鎭�
if (dt.Tables[0].Rows.Count > 0)
@@ -95,14 +101,15 @@
for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
{
- HContext = "妯″叿缂栫爜涓�:" + dt.Tables[0].Rows[i]["妯″叿缂栫爜"].ToString() + ",妯″叿鍚嶇О涓�:" + dt.Tables[0].Rows[i]["妯″叿鍚嶇О"].ToString() + ",宸插埌淇濆吇棰勮鏃ユ湡,闇�灏藉揩杩涜淇濆吇";
+ HContext = "妯″叿缂栫爜涓�:" + dt.Tables[0].Rows[i]["妯″叿缂栫爜"].ToString() + ",妯″叿鍚嶇О涓�:" + dt.Tables[0].Rows[i]["妯″叿鍚嶇О"].ToString() + ",宸插埌淇濆吇棰勮娆℃暟,闇�灏藉揩杩涜淇濆吇";
//鏇存柊妯″叿淇濆吇璁″垝棰勮 瀛愯〃
string sql1 = "update Sc_MouldMaintainPlanBillSub_Plan set HSendFlag='1' where HInterID=" + dt.Tables[0].Rows[i]["HInterID"].ToString() + " and HEntryID=" + dt.Tables[0].Rows[i]["HEntryID"].ToString() + ""; ;
oCN.RunProc(sql1);
DBHelper.CustomWriteLog("妯″叿淇濆吇璁″垝棰勮:" + sql1 + " 鏇存柊瀛愯〃璇彞:" + sql1, DateTime.Now.ToString("yyyy-MM-dd"));
-
+ HDeptName = dt.Tables[0].Rows[i]["妯″叿閮ㄩ棬"].ToString();
string sql2 = "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 = '妯″叿淇濆吇璁″垝棰勮鎺ユ敹浜�'";
+ DBHelper.CustomWriteLog("妯″叿淇濆吇璁″垝棰勮鎺ユ敹浜�:" + sql2, DateTime.Now.ToString("yyyy-MM-dd"));
dts = oCN.RunProcReturn(sql2, "Gy_Czygl");
for (int j = 0; j < dts.Tables[0].Rows.Count; j++)
{
@@ -116,9 +123,9 @@
string accessToken = responseJson["accessToken"].ToString();
//璋冪敤鏂规硶鍙戦�佹秷鎭�
- //string agentId = "3118119317";//閽夐拤鍚庡彴寤虹珛鐨勫皬绋嬪簭id
+ string agentId = "3118119317";//閽夐拤鍚庡彴寤虹珛鐨勫皬绋嬪簭id
//鏂帿灏�
- string agentId = "3151454458";//閽夐拤鍚庡彴寤虹珛鐨勫皬绋嬪簭id
+ //string agentId = "3151454458";//閽夐拤鍚庡彴寤虹珛鐨勫皬绋嬪簭id
string userIdList = HName;//閽夐拤浜哄憳鐨刬d
string deptIdList = "0"; // 绌哄瓧绗︿覆琛ㄧず涓嶆寚瀹氶儴闂�
string toAllUser = "false";
--
Gitblit v1.9.1