From db0b018fc17807947b9d1297eac71cb8430891bb Mon Sep 17 00:00:00 2001
From: zrg <z1873@LAPTOP-EAVL132E>
Date: 星期三, 25 二月 2026 15:10:48 +0800
Subject: [PATCH] 新增系统参数用于区分发送消息类型 新增桌面端 异常反馈发送信息方法， 老的控制台不知道app消息推送
---
DingDingMsg/DingDingMsg/Program.cs | 244 +++++++++++++++++++++++++++++-------------------
1 files changed, 149 insertions(+), 95 deletions(-)
diff --git a/DingDingMsg/DingDingMsg/Program.cs b/DingDingMsg/DingDingMsg/Program.cs
index 6c4209a..a433fbf 100644
--- a/DingDingMsg/DingDingMsg/Program.cs
+++ b/DingDingMsg/DingDingMsg/Program.cs
@@ -12,6 +12,8 @@
//寮傚父鍙嶉鍗�,寮傚父宸ヨ壓鍙傛暟棰勮 鍙戦�侀拤閽夋秷鎭�
static DBHelper oCN = new DBHelper();
static DataSet dt = new DataSet();
+ static DataSet dt1 = new DataSet();
+ static DataSet dt2 = new DataSet(); //鏌ヨ绯荤粺鍙傛暟
static async Task Main(string[] args)
{
//鏈湴
@@ -20,13 +22,21 @@
//鏂帿灏�
string appKey = "dingkdddbhdcssk7jduw";
string appSecret = "iv07c-GLfJPnzfJaNAAOfJDl3Z-eODvDAhlInMZCZhGorkle5Evbaxx3ImylvdjQ";
+ //涔濊彵
+ //string appKey = "ding8hkfpspnpoteenk3";
+ //string appSecret = "-AwplMi-44dA39rNXUiBvDAQl_oAhhrBRQmMtDvSkN44biLh8C1Gb2MCtyzxJ6uF";
Console.WriteLine("瀹夌伅绋嬪簭姝ｅ湪鎵ц,璇蜂笉瑕佸叧闂�!!!!");
+
+ //鑾峰彇绯荤粺鍙傛暟
+ string sqls = "select HValue from xt_SystemParameter where HKey='OA_AndengFlowRule_XT'";
+ dt2 = oCN.RunProcReturn(sqls, "xt_SystemParameter");
+
// 璁板綍涓婃鎵ц鏂板畾鏃朵换鍔＄殑鏃堕棿
DateTime lastNewTaskExecution = DateTime.MinValue;
while (true)
{
- //鏌ユ暟鎹�
- string sql = "select a.HInterID,a.HReceiveMan 鎺ユ敹浜�,c.HDingDingUserID 閽夐拤id,b.HDescription 鍐呭 from OA_ErrMsgBackBillSub2" +
+ #region 鏌ヨ寮傚父鍙嶉鍗曡鍙戦�佷俊鎭殑浜�
+ string sql = "select a.HInterID,b.HBillType,a.HReceiveMan 鎺ユ敹浜�,c.HDingDingUserID 閽夐拤id,b.HDescription 鍐呭 from OA_ErrMsgBackBillSub2" +
" 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");
@@ -34,57 +44,86 @@
if (dt.Tables[0].Rows.Count > 0)
{
string HContext = "";
+ //娣诲姞绯荤粺鍙傛暟鍒ゆ柇鏄拤閽�/APP
- for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
- {
- HContext = dt.Tables[0].Rows[i]["鍐呭"].ToString();
- 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)
+ if (dt2.Tables[0].Rows[0]["HValue"].ToString() == "APP")
+ {
+ for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
{
- //鏇存柊鐘舵��
- string sql1 = "update OA_ErrMsgBackBillSub2 set HSendFlag='1' where HReceiveMan in ('" + Stares + "')";
- oCN.RunProc(sql1);
- DBHelper.CustomWriteLog("閽夐拤杩斿洖淇℃伅:"+response+" 鏇存柊瀛愯〃璇彞:"+sql1, DateTime.Now.ToString("yyyy-MM-dd"));
+ string HName = dt.Tables[0].Rows[i]["鎺ユ敹浜�"].ToString();
+ Console.WriteLine("exec h_p_CreateOAWorkLinkBill_Andon" + dt.Tables[0].Rows[0]["HInterID"].ToString() + ",'"+ HName+"'");
+ var ds = oCN.RunProcReturn("exec h_p_CreateOAWorkLinkBill_Andon " + dt.Tables[0].Rows[0]["HInterID"].ToString() + ",'" + HName + "'", "h_p_CreateOAWorkLinkBill_Andon");
+ if (ds != null && ds.Tables[0].Rows.Count > 0)
+ {
+ // 绗竴姝ワ細鍏堣幏鍙栧瓧绗︿覆骞跺垽鏂槸鍚︿负"0"锛屾槸鍒欑洿鎺ヨ烦杩�
+ int HInterID = int.Parse(ds.Tables[0].Rows[0]["HInterID"].ToString());
+ if (HInterID != 0)
+ {
+ Console.WriteLine("鎵ц娑堟伅鎺ㄩ��..." + HInterID);
+ }
+ }
+
}
- else
+
+ }
+ else if (dt2.Tables[0].Rows[0]["HValue"].ToString() == "閽夐拤")
+ {
+ for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
{
- Console.WriteLine(responseData.errcode);
- DBHelper.CustomWriteLog("閽夐拤杩斿洖淇℃伅:" + response, DateTime.Now.ToString("yyyy-MM-dd"));
+ HContext = dt.Tables[0].Rows[i]["鍐呭"].ToString();
+ 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 agentId = "3910708781";//閽夐拤鍚庡彴寤虹珛鐨勫皬绋嬪簭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)
+ {
+ //鏇存柊鐘舵��
+ string sql1 = "update OA_ErrMsgBackBillSub2 set HSendFlag='1' where HReceiveMan in ('" + Stares + "')";
+ oCN.RunProc(sql1);
+ DBHelper.CustomWriteLog("閽夐拤杩斿洖淇℃伅:" + response + " 鏇存柊瀛愯〃璇彞:" + sql1, DateTime.Now.ToString("yyyy-MM-dd"));
+ }
+ else
+ {
+ Console.WriteLine(responseData.errcode);
+ DBHelper.CustomWriteLog("閽夐拤杩斿洖淇℃伅:" + response, DateTime.Now.ToString("yyyy-MM-dd"));
+ }
}
- }
+ }
+
}
+ #endregion
- //寮傚父宸ヨ壓鍙傛暟棰勮锛堟瘡 5 鍒嗛挓鎵ц涓�娆★級
- DBHelper.CustomWriteLog("寮�濮嬭繘鍏ユ墽琛屽惊鐜�:", DateTime.Now.ToString("yyyy-MM-dd"));
+
+ #region 寮傚父宸ヨ壓鍙傛暟棰勮锛堟瘡 5 鍒嗛挓鎵ц涓�娆★級
+ DBHelper.CustomWriteLog("寮�濮嬭繘鍏ユ墽琛屽惊鐜� :", DateTime.Now.ToString("yyyy-MM-dd"));
if ((DateTime.Now - lastNewTaskExecution).TotalMinutes >= 4)
{
DBHelper.CustomWriteLog("宸茶繘鍏ユ墽琛屽惊鐜�:", DateTime.Now.ToString("yyyy-MM-dd"));
//鏌ヨ鍑鸿鏇存柊宸茬粡鍙戦�佺殑寮傚父鍙傛暟
string Sql = "select HItemID from Sb_EquipMentCollectionTechParam_ERR where HCreateTime>=DATEADD(minute, - 1, GETDATE()) AND HSendFlag = 0";
- DBHelper.CustomWriteLog("鏌ヨ鍑哄紓甯哥殑鍙傛暟:"+Sql, DateTime.Now.ToString("yyyy-MM-dd"));
- dt = oCN.RunProcReturn(Sql, "Sb_EquipMentCollectionTechParam_ERR");
+ DBHelper.CustomWriteLog("鏌ヨ鍑哄紓甯哥殑鍙傛暟:" + Sql, DateTime.Now.ToString("yyyy-MM-dd"));
+ dt = oCN.RunProcReturn(Sql, "Sb_EquipMentCollectionTechParam_ERR");
if (dt != null && dt.Tables[0].Rows.Count > 0)
{
List<string> itemIds = new List<string>();
@@ -113,70 +152,85 @@
// 鍙互鍦ㄨ繖閲屾坊鍔犻�傚綋鐨勫鐞嗭紝姣斿璁板綍鏃ュ織琛ㄦ槑娌℃湁鍙鐞嗙殑鏁版嵁琛�
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 鍐呭";
- string newSql = @"SELECT 杞﹂棿, STUFF(( SELECT '; ' + 璁惧缂栫爜 + ' - ' + 宸ヨ壓鍙傛暟鍚嶇О + ' - 鏁伴噰鍊�: ' + CAST(鏁伴噰鍊� AS VARCHAR(10)) + ' - 涓婇檺鍊�: ' + CAST(涓婇檺鍊� AS VARCHAR(10)) + ' - 涓嬮檺鍊�: ' + CAST(涓嬮檺鍊� AS VARCHAR(10))
- FROM h_v_Sb_EquipMentCollectionTechParam_ERRList AS InnerTable WHERE InnerTable.杞﹂棿 = OuterTable.杞﹂棿 AND 鍙戠幇寮傚父鏃堕棿 >= DATEADD(minute, -1, GETDATE())
- FOR XML PATH('') ), 1, 2, '') AS 鍐呭 FROM h_v_Sb_EquipMentCollectionTechParam_ERRList AS OuterTable GROUP BY 杞﹂棿 ";
- DBHelper.CustomWriteLog("鏌ヨ鍑鸿鍙戜俊鎭殑寮傚父鍙傛暟"+newSql, DateTime.Now.ToString("yyyy-MM-dd"));
- dt = oCN.RunProcReturn(newSql, "h_v_Sb_EquipMentCollectionTechParam_ERRList");
- string HContext = ""; string HDeptName = "";
- HContext = dt.Tables[0].Rows[0]["鍐呭"].ToString();
- HDeptName= dt.Tables[0].Rows[0]["杞﹂棿"].ToString();
- DBHelper.CustomWriteLog("鏌ヨ鍑鸿鍙戜俊鎭殑鍐呭" + HContext, DateTime.Now.ToString("yyyy-MM-dd"));
- //鏌ヨ鍑鸿鍙戦�佺殑浜�
- 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 = '"+ HDeptName + "宸ヨ壓寮傚父棰勮鎺ユ敹浜�'";
- DBHelper.CustomWriteLog("鏌ヨ鍑鸿鍙戦�佺殑浜�:" + newSql1, DateTime.Now.ToString("yyyy-MM-dd"));
- dt = oCN.RunProcReturn(newSql1, "Gy_Czygl");
- DBHelper.CustomWriteLog("寮�濮嬭繘鍏ュ彂淇℃伅", DateTime.Now.ToString("yyyy-MM-dd"));
- if (dt.Tables[0].Rows.Count > 0)
+ //娣诲姞绯荤粺鍙傛暟鍒ゆ柇鏄拤閽�/APP
+ if (dt2.Tables[0].Rows[0]["HValue"].ToString() == "APP")
{
- DBHelper.CustomWriteLog("杩涘叆鍙戜俊鎭�", DateTime.Now.ToString("yyyy-MM-dd"));
- for (int i = 0; i < dt.Tables[0].Rows.Count; i++)
+
+ }
+ else if (dt2.Tables[0].Rows[0]["HValue"].ToString() == "閽夐拤")
+ {
+ //鏌ヨ鍑鸿鍙戜俊鎭殑寮傚父鍙傛暟
+ string newSql = @"SELECT 宸ュ簭鍚嶇О, STUFF(( SELECT DISTINCT '; ' + 璁惧缂栫爜 + ' - ' + 宸ヨ壓鍙傛暟鍚嶇О + ' - 鏁伴噰鍊�: ' + CAST(鏁伴噰鍊� AS VARCHAR(10)) + ' - 涓婇檺鍊�: ' + CAST(涓婇檺鍊� AS VARCHAR(10)) + ' - 涓嬮檺鍊�: ' + CAST(涓嬮檺鍊� AS VARCHAR(10))
+ FROM h_v_Sb_EquipMentCollectionTechParam_ERRList AS InnerTable WHERE InnerTable.宸ュ簭鍚嶇О = OuterTable.宸ュ簭鍚嶇О AND 鍙戠幇寮傚父鏃堕棿 >= DATEADD(minute, -1, GETDATE())
+ FOR XML PATH('') ), 1, 2, '') AS 鍐呭 FROM h_v_Sb_EquipMentCollectionTechParam_ERRList AS OuterTable GROUP BY 宸ュ簭鍚嶇О ";
+ DBHelper.CustomWriteLog("鏌ヨ鍑鸿鍙戜俊鎭殑寮傚父鍙傛暟" + newSql, DateTime.Now.ToString("yyyy-MM-dd"));
+ dt1 = oCN.RunProcReturn(newSql, "h_v_Sb_EquipMentCollectionTechParam_ERRList");
+ string HContext = ""; string HDeptName = "";
+ for (int j = 0; j < dt1.Tables[0].Rows.Count; j++)
{
- 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("寮傚父鍐呭鏁伴噺 " + dt1.Tables[0].Rows.Count, DateTime.Now.ToString("yyyy-MM-dd"));
+ HContext = dt1.Tables[0].Rows[j]["鍐呭"].ToString();
+ HDeptName = dt1.Tables[0].Rows[j]["宸ュ簭鍚嶇О"].ToString();
+ DBHelper.CustomWriteLog("寮傚父鍐呭鍊� " + HContext, DateTime.Now.ToString("yyyy-MM-dd"));
+ DBHelper.CustomWriteLog("寮傚父杞﹂棿鍊� " + HDeptName, DateTime.Now.ToString("yyyy-MM-dd"));
+ if (!string.IsNullOrEmpty(HContext) && HContext.ToLower() != "null")
{
- DBHelper.CustomWriteLog("閽夐拤寮傚父棰勮鍙戦�佹垚鍔�", DateTime.Now.ToString("yyyy-MM-dd"));
- }
- else
- {
- Console.WriteLine(responseData.errcode);
- DBHelper.CustomWriteLog("閽夐拤杩斿洖淇℃伅:" + response, DateTime.Now.ToString("yyyy-MM-dd"));
- }
+ DBHelper.CustomWriteLog("鏌ヨ鍑鸿鍙戜俊鎭殑鍐呭" + HContext, DateTime.Now.ToString("yyyy-MM-dd"));
+ //鏌ヨ鍑鸿鍙戦�佺殑浜�
+ 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 = '" + HDeptName + "宸ヨ壓寮傚父棰勮鎺ユ敹浜�'";
+ DBHelper.CustomWriteLog("鏌ヨ鍑鸿鍙戦�佺殑浜�:" + newSql1, DateTime.Now.ToString("yyyy-MM-dd"));
+ dt = oCN.RunProcReturn(newSql1, "Gy_Czygl");
+ DBHelper.CustomWriteLog("寮�濮嬭繘鍏ュ彂淇℃伅", DateTime.Now.ToString("yyyy-MM-dd"));
+ if (dt.Tables[0].Rows.Count > 0)
+ {
+ DBHelper.CustomWriteLog("杩涘叆鍙戜俊鎭�", DateTime.Now.ToString("yyyy-MM-dd"));
+ 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;
}
-
+ #endregion
// 绛夊緟涓�鍒嗛挓
await Task.Delay(TimeSpan.FromMinutes(1));
--
Gitblit v1.9.1