From 466389402ca3cf120e3206195bcade5f7590c05f Mon Sep 17 00:00:00 2001
From: yangle <admin@YINMOU>
Date: 星期五, 28 二月 2025 15:03:23 +0800
Subject: [PATCH] spc 钉钉发消息预警
---
DingDingMsg_EarlyWarning/Program.cs | 85 ++++++++++++++++++++++++++++++++++++++++--
1 files changed, 80 insertions(+), 5 deletions(-)
diff --git a/DingDingMsg_EarlyWarning/Program.cs b/DingDingMsg_EarlyWarning/Program.cs
index 98a5e2e..58a2195 100644
--- a/DingDingMsg_EarlyWarning/Program.cs
+++ b/DingDingMsg_EarlyWarning/Program.cs
@@ -23,7 +23,8 @@
Console.WriteLine("绋嬪簭2姝ｅ湪鎵ц,璇蜂笉瑕佸叧闂�!!!!");
string HDeptName = "";
string HWarningDate = "10";
- string HRecordDate = DateTime.MinValue.ToString(); ;
+ string HRecordDate = DateTime.MinValue.ToString();
+ string HRecordDate_spc = "";
// 璁板綍涓婃鎵ц鏂板畾鏃朵换鍔＄殑鏃堕棿
while (true)
{
@@ -94,12 +95,12 @@
"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++)
{
@@ -169,10 +170,10 @@
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)
{
@@ -256,6 +257,80 @@
}
DBHelper.CustomWriteLog("璁惧閲囬泦寮傚父缁撴潫!", DateTime.Now.ToString("yyyy-MM-dd"));
+
+
+ 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();
+ }
+
+ 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"));
+
// 绛夊緟涓�鍒嗛挓
await Task.Delay(TimeSpan.FromMinutes(1));
}
--
Gitblit v1.9.1