From 7ca0d964d2df19bf56e8a8a96f34f26a139b078d Mon Sep 17 00:00:00 2001
From: zrg <z1873@LAPTOP-EAVL132E>
Date: 星期五, 27 二月 2026 15:23:57 +0800
Subject: [PATCH] 增加异常工艺参数预警通知
---
DingDingMsg_EarlyWarning/Program.cs | 212 ++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 202 insertions(+), 10 deletions(-)
diff --git a/DingDingMsg_EarlyWarning/Program.cs b/DingDingMsg_EarlyWarning/Program.cs
index 0d62411..44302e6 100644
--- a/DingDingMsg_EarlyWarning/Program.cs
+++ b/DingDingMsg_EarlyWarning/Program.cs
@@ -15,17 +15,20 @@
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";
+ string appKey = "dingkdddbhdcssk7jduw";
+ string appSecret = "iv07c-GLfJPnzfJaNAAOfJDl3Z-eODvDAhlInMZCZhGorkle5Evbaxx3ImylvdjQ";
Console.WriteLine("绋嬪簭2姝ｅ湪鎵ц,璇蜂笉瑕佸叧闂�!!!!");
string HDeptName = "";
+ string HWarningDate = "10";
+ string HRecordDate = DateTime.MinValue.ToString();
+ string HRecordDate_spc = "";
// 璁板綍涓婃鎵ц鏂板畾鏃朵换鍔＄殑鏃堕棿
while (true)
{
- //鏌ユ壘璁惧淇濆吇棰勮
+ #region 鏌ユ壘璁惧淇濆吇棰勮
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 " +
@@ -86,18 +89,20 @@
}
}
- //鏌ユ壘妯″叿淇濆吇棰勮
+ #endregion
+
+ #region 鏌ユ壘妯″叿淇濆吇棰勮
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 " +
"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"));
+ DBHelper.CustomWriteLog("鏌ヨ妯″叿淇濆吇璁″垝:" + newsql, DateTime.Now.ToString("yyyy-MM-dd"));
dt = oCN.RunProcReturn(newsql, "Sb_EquipMaintainPlanBillMain");
//妯″叿淇濆吇棰勮鑷姩鍙戜俊鎭�
if (dt.Tables[0].Rows.Count > 0)
{
- string HContext = "";
+ string HContext = "";
for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
{
@@ -123,9 +128,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";
@@ -146,6 +151,193 @@
}
}
}
+ #endregion
+
+ #region 璁惧閲囬泦寮傚父
+ DBHelper.CustomWriteLog("璁惧閲囬泦寮傚父寮�濮�!", DateTime.Now.ToString("yyyy-MM-dd"));
+ //璁惧閲囬泦寮傚父鏃讹紙寮�宸ュ悗锛岃澶囨寔缁�10鍒嗛挓鏈噰闆嗭級锛岃繘琛屾秷鎭璀�
+ //鑾峰彇 涓洪璀� 骞朵笖鐘舵�佷负寮�宸ョ殑 璁惧 鍜屽伐鑹哄弬鏁�
+ dt = oCN.RunProcReturn("exec h_p_Sb_EquiMessageWarn", "h_p_Sb_EquiMessageWarn");
+
+
+ if (dt.Tables[0].Rows.Count > 0 && (DateTime.Now - DateTime.Parse(HRecordDate)).TotalMinutes >= int.Parse(HWarningDate))
+ {
+ string HEquipFileName = "";
+ string HRemark = "";
+
+ //涓洪璀︾殑璁惧 鍜� 宸ヨ壓鍙傛暟 杩涜寰幆
+ for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
+ {
+ HRecordDate = dt.Tables[0].Rows[i]["HRecordDate"].ToString();//璁板綍鏃堕棿
+ HWarningDate = dt.Tables[0].Rows[i]["HWarningDate"].ToString();//棰勮鏃堕棿
+ string HCollectionDate = dt.Tables[0].Rows[i]["HCollectionDate"].ToString();//閲囬泦鏃堕棿
+ string HEquipFileNo = dt.Tables[0].Rows[i]["HEquipFileNo"].ToString();//璁惧缂栧彿
+ string HParameterName = dt.Tables[0].Rows[i]["HName"].ToString();//宸ヨ壓鍙傛暟
+
+ if ((DateTime.Now - DateTime.Parse(HRecordDate)).TotalMinutes >= int.Parse(HWarningDate))
+ {
+ //鏍规嵁 璁惧+宸ヨ壓鍙傛暟+閲囬泦鏃堕棿 鏌ヨ宸ヨ壓鍙傛暟涓存椂琛ㄧ殑鏁版嵁
+ DataSet ds = oCN.RunProcReturn("exec h_p_Sb_EquipMentTechParam_Temp '" + HEquipFileNo + "', '" + HParameterName + "', '" + HCollectionDate + "'", "h_p_Sb_EquipMentTechParam_Temp");
+ if (ds.Tables[0].Rows.Count > 0)
+ {
+ string HMaxCreateTime = ds.Tables[0].Rows[0]["HCreateTime"].ToString();
+ // 鍒ゆ柇 褰撳墠鏃堕棿-鍙傛暟鐨勫垱寤烘椂闂� 鏄惁澶т簬棰勮鏃堕棿 濡傛灉 澶т簬棰勮鏃堕棿鍒欓渶瑕侀拤閽夊彂娑堟伅
+ if ((DateTime.Now - DateTime.Parse(HMaxCreateTime)).TotalMinutes >= int.Parse(HWarningDate))
+ {
+ if (HEquipFileName != HEquipFileNo)
+ {
+ HRemark += "璁惧缂栫爜:" + HEquipFileNo + "---";
+ HEquipFileName = HEquipFileNo;
+ }
+
+ DBHelper.CustomWriteLog("鏈�澶ф椂闂�:" + HMaxCreateTime + "," + i, DateTime.Now.ToString("yyyy-MM-dd"));
+ //鍙戦�佹秷鎭�
+ HRemark += HParameterName + ",";
+ DBHelper.CustomWriteLog("鏇存柊鏃堕棿:" + HEquipFileNo, DateTime.Now.ToString("yyyy-MM-dd"));
+ //鏇存柊璁板綍鏃堕棿
+ oCN.RunProc("update Gy_EquipFileBillMain set HRecordDate=getdate() where HEquipFileNo='" + HEquipFileNo + "'");
+ }
+ DBHelper.CustomWriteLog("璁惧閲囬泦寮傚父寮�濮�---涓嶉渶瑕侀璀�!", DateTime.Now.ToString("yyyy-MM-dd"));
+ }
+ else
+ {
+ if (HEquipFileName != HEquipFileNo)
+ {
+ HRemark += "璁惧缂栫爜:" + HEquipFileNo + "---";
+ HEquipFileName = HEquipFileNo;
+ }
+ //鍙戦�佹秷鎭�
+ HRemark += HParameterName + ",";
+ //鏇存柊璁板綍鏃堕棿
+ oCN.RunProc("update Gy_EquipFileBillMain set HRecordDate=getdate() where HEquipFileNo='" + HEquipFileNo + "'");
+ }
+ }
+ }
+
+ HRecordDate = DateTime.Now.ToString();
+
+ if (HRemark.Length > 0)
+ {
+ HRemark += "娌℃湁閲囬泦鍒版暟鎹�!";
+
+ // 鏍规嵁 瑙掕壊 鍘绘煡璇㈤渶瑕佸彂娑堟伅鐨勯拤閽夊彿
+ 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 = '璁惧鏈噰闆嗗埌鍙傛暟棰勮'";
+ dts = oCN.RunProcReturn(sql2, "Gy_Czygl");
+ for (int j = 0; j < dts.Tables[0].Rows.Count; j++)
+ {
+ string HName = dts.Tables[0].Rows[j]["閽夐拤id"].ToString();
+ string Stares = dts.Tables[0].Rows[j]["鎺ユ敹浜�"].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 = HRemark;
+
+ // 璋冪敤鏂规硶鍙戦�佹秷鎭�
+ 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"));
+ }
+ }
+ }
+
+ }
+ DBHelper.CustomWriteLog("璁惧閲囬泦寮傚父缁撴潫!", DateTime.Now.ToString("yyyy-MM-dd"));
+
+ #endregion
+
+ #region
+ DBHelper.CustomWriteLog("spc寮傚父鍙戞秷鎭�!", DateTime.Now.ToString("yyyy-MM-dd"));
+ //spc 寮傚父琛ㄦ湁鏈彂娑堟伅鐨勬暟鎹椂 涓�灏忔椂 鍙戦�佷竴娆℃秷鎭�
+ //鑾峰彇 寮傚父琛� 鏈夋湭鍙戞秷鎭殑鏁版嵁
+ dt = oCN.RunProcReturn("select * from h_v_QC_SendMessageList", "h_v_QC_SendMessageList");
+
+
+ if (HRecordDate_spc == "")
+ {
+ HRecordDate_spc = DateTime.Now.ToString();
+ }
+ //鏍规嵁30鍒嗛挓鏃堕棿 鍘诲彂閫佹秷鎭�
+ if (dt.Tables[0].Rows.Count > 0 && (DateTime.Now - DateTime.Parse(HRecordDate_spc)).TotalMinutes >= 30)
+ {
+
+ //涓洪璀︾殑璁惧 鍜� 宸ヨ壓鍙傛暟 杩涜寰幆
+ for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
+ {
+ string HMaterID = dt.Tables[0].Rows[i]["HMaterID"].ToString();
+ string HQCCheckItemID = dt.Tables[0].Rows[i]["HQCCheckItemID"].ToString();
+ //string HMaterNumber = dt.Tables[0].Rows[i]["鐗╂枡浠ｇ爜"].ToString();
+ //string HQCCheckItemNumber = dt.Tables[0].Rows[i]["椤圭洰浠ｇ爜"].ToString();
+ string HMouldNum = dt.Tables[0].Rows[i]["绌村彿"].ToString();
+ string HRemark = dt.Tables[0].Rows[i]["閿欒鏁版嵁"].ToString();
+
+ if (HRemark.Length > 0)
+ {
+ // 鏍规嵁 瑙掕壊 鍘绘煡璇㈤渶瑕佸彂娑堟伅鐨勯拤閽夊彿
+ 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 = 'SPC鏁版嵁寮傚父棰勮'";
+ dts = oCN.RunProcReturn(sql2, "Gy_Czygl");
+ for (int j = 0; j < dts.Tables[0].Rows.Count; j++)
+ {
+ string HName = dts.Tables[0].Rows[j]["閽夐拤id"].ToString();
+ string Stares = dts.Tables[0].Rows[j]["鎺ユ敹浜�"].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 = HRemark;
+ DBHelper.CustomWriteLog("spc寮傚父 褰撳墠鏃堕棿:"+ HRecordDate_spc, DateTime.Now.ToString("yyyy-MM-dd"));
+
+ // 璋冪敤鏂规硶鍙戦�佹秷鎭�
+ response = await msg.SendTextMessage(accessToken, agentId, userIdList, deptIdList, toAllUser, message);
+ ResponseData responseData = JsonConvert.DeserializeObject<ResponseData>(response);
+ if (responseData.errcode == 0)
+ {
+ DBHelper.CustomWriteLog("spc寮傚父鍙戞伅鎴愬姛!", DateTime.Now.ToString("yyyy-MM-dd"));
+ string sql3 = "update QC_SendMessage set HMessageIsSend=1 where HMaterID=" + HMaterID + " and HQCCheckItemID=" + HQCCheckItemID + " and HMouldNum='" + HMouldNum + "'";
+ oCN.RunProc(sql3);
+ }
+ else
+ {
+ Console.WriteLine(responseData.errcode);
+ DBHelper.CustomWriteLog("spc寮傚父杩斿洖淇℃伅:" + response, DateTime.Now.ToString("yyyy-MM-dd"));
+ }
+ }
+
+ HRecordDate_spc = DateTime.Now.ToString();
+ }
+ }
+ }
+ DBHelper.CustomWriteLog("spc寮傚父鍙戞伅缁撴潫!", DateTime.Now.ToString("yyyy-MM-dd"));
+ #endregion
// 绛夊緟涓�鍒嗛挓
await Task.Delay(TimeSpan.FromMinutes(1));
}
--
Gitblit v1.9.1