From b8df53771425ac543c4cb094186cd2e39ea1fd11 Mon Sep 17 00:00:00 2001
From: yangle <admin@YINMOU>
Date: 星期四, 05 十二月 2024 13:02:43 +0800
Subject: [PATCH] 钉钉 参数预警

---
 DingDingMsg_EarlyWarning/Program.cs |  122 ++++++++++++++++++++++++++++++++++++++--
 1 files changed, 116 insertions(+), 6 deletions(-)

diff --git a/DingDingMsg_EarlyWarning/Program.cs b/DingDingMsg_EarlyWarning/Program.cs
index 0d62411..98a5e2e 100644
--- a/DingDingMsg_EarlyWarning/Program.cs
+++ b/DingDingMsg_EarlyWarning/Program.cs
@@ -15,13 +15,15 @@
         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姝e湪鎵ц,璇蜂笉瑕佸叧闂�!!!!");
             string HDeptName = "";
+            string HWarningDate = "10";
+            string HRecordDate = DateTime.MinValue.ToString(); ;
             // 璁板綍涓婃鎵ц鏂板畾鏃朵换鍔$殑鏃堕棿
             while (true)
             {
@@ -123,9 +125,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 +148,114 @@
                         }
                     }
                 }
+
+
+                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"));
+
                 // 绛夊緟涓�鍒嗛挓
                 await Task.Delay(TimeSpan.FromMinutes(1));
             }

--
Gitblit v1.9.1