using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Threading.Tasks;
|
|
namespace DingDingMsg_MES
|
{
|
class Program
|
{
|
//内部任务汇报 发送钉钉消息
|
static DBHelper oCN = new DBHelper();
|
static DataSet dt = new DataSet();
|
static async Task Main(string[] args)
|
{
|
string sExeReturnInfo = "";
|
string BillType = "4510";
|
//本地
|
string appKey = "dingrsrzhdyn3mlaof95";
|
string appSecret = "RAqH6YtZnPLCpDbuqfaYQkKkVtVdS0wqfC8I26X6qiS-8eoCJCNrzx3fubGND4Sq";
|
|
MSG msg = new MSG();
|
|
Console.WriteLine("钉钉消息推送正在执行,请不要关闭!!!!");
|
|
while (true)
|
{
|
//获取企业的access_token的值
|
string response = msg.GetAccessToken(appKey, appSecret);
|
JObject responseJson = JObject.Parse(response);
|
// 获取access_token的值
|
string accessToken = responseJson["accessToken"].ToString();
|
|
DateTime now = DateTime.Now;
|
|
// 如果当前时间是周六（6）或周日（7），跳过
|
if (now.DayOfWeek == DayOfWeek.Saturday || now.DayOfWeek == DayOfWeek.Sunday)
|
{
|
// 等待直到下一个周一
|
await WaitUntilNextMonday();
|
continue;
|
}
|
// 如果是每天的 16:45 执行操作
|
if (now.Hour == 16 && now.Minute == 45)
|
{
|
|
//查数据
|
string sql = @"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 = '每日任务与每周计划钉钉提醒'";
|
dt = oCN.RunProcReturn(sql, "Gy_Czygl");
|
|
if (dt.Tables[0].Rows.Count > 0)
|
{
|
foreach (DataRow row in dt.Tables[0].Rows)
|
{
|
string userId = row["钉钉id"].ToString();
|
string receiverName = row["接收人"].ToString();
|
string HContext = $"人员：{receiverName} 请及时编制当日的工作汇报！发送人为admin，接收人为 {receiverName}";
|
|
//获取单据内码
|
long HInterID = oCN.CreateBillID_Prod(BillType, ref sExeReturnInfo);
|
string HBillNo = oCN.CreateBillCode(BillType, ref sExeReturnInfo, true);
|
//插入主子数据
|
string sql2 = "INSERT INTO OA_EmpMessageBillMain (HYear,HPeriod,HBillType,HInterID,HDate,HBillNo,HBillStatus,HSendMan,HReceiveMan,HDescription,HMaker,HMakeDate)" +
|
"VALUES('"+DateTime.Now.Year+ "','" + DateTime.Now.Month + "','"+ BillType + "','" + HInterID+"',getdate(),'"+HBillNo+"','1','admin','"+ receiverName + "','"+ HContext + "','自动生成',getdate())";
|
string sql3 = "INSERT INTO OA_EmpMessageBillSub (HInterID,HEntryID,HReceiveMan,HReadFlag,HSendFlag)" +
|
"VALUES('" + HInterID + "','1','" + receiverName + "',0,0)";
|
oCN.RunProc(sql2);
|
oCN.RunProc(sql3);
|
|
//调用方法发送消息
|
string agentId = "3118119317";//钉钉后台建立的小程序id
|
string userIdList = userId;//钉钉人员的id
|
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_EmpMessageBillSub set HSendFlag='1' where HReceiveMan ='" + receiverName + "'";
|
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"));
|
}
|
}
|
}
|
}
|
|
// 如果是每周一上午 9:00 执行操作
|
if (now.DayOfWeek == DayOfWeek.Monday && now.Hour == 9 && now.Minute == 0)
|
{
|
//查数据
|
string sql = @"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 = '每日任务与每周计划钉钉提醒'";
|
dt = oCN.RunProcReturn(sql, "Gy_Czygl");
|
|
if (dt.Tables[0].Rows.Count > 0)
|
{
|
foreach (DataRow row in dt.Tables[0].Rows)
|
{
|
string userId = row["钉钉id"].ToString();
|
string receiverName = row["接收人"].ToString();
|
string HContext = $"人员：{receiverName} 请及时编制本周的周计划！发送人为admin，接收人为 {receiverName}";
|
|
//获取单据内码
|
long HInterID = oCN.CreateBillID_Prod(BillType, ref sExeReturnInfo);
|
string HBillNo = oCN.CreateBillCode(BillType, ref sExeReturnInfo, true);
|
//插入主子数据
|
string sql2 = "INSERT INTO OA_EmpMessageBillMain (HYear,HPeriod,HBillType,HInterID,HDate,HBillNo,HBillStatus,HSendMan,HReceiveMan,HDescription,HMaker,HMakeDate)" +
|
"VALUES('" + DateTime.Now.Year + "','" + DateTime.Now.Month + "','" + BillType + "','" + HInterID + "',getdate(),'" + HBillNo + "','1','admin','" + receiverName + "','" + HContext + "','自动生成',getdate())";
|
string sql3 = "INSERT INTO OA_EmpMessageBillSub (HInterID,HEntryID,HReceiveMan,HReadFlag,HSendFlag)" +
|
"VALUES('" + HInterID + "','1','" + receiverName + "',0,0)";
|
oCN.RunProc(sql2);
|
oCN.RunProc(sql3);
|
|
//调用方法发送消息
|
string agentId = "3118119317";//钉钉后台建立的小程序id
|
string userIdList = userId;//钉钉人员的id
|
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_EmpMessageBillSub set HSendFlag='1' where HReceiveMan ='" + receiverName + "'";
|
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"));
|
}
|
}
|
}
|
}
|
// 等待一分钟
|
await Task.Delay(TimeSpan.FromMinutes(1));
|
}
|
|
}
|
|
// 等待直到下一个周一上午9点
|
private static async Task WaitUntilNextMonday()
|
{
|
DateTime now = DateTime.Now;
|
// 获取下一个周一的日期
|
DateTime nextMonday = now.AddDays((int)DayOfWeek.Monday - (int)now.DayOfWeek + 7) // 通过添加7天获取下一个周一
|
.Date.AddHours(9); // 设置为上午9点
|
|
TimeSpan delay = nextMonday - now;
|
|
await Task.Delay(delay); // 等待直到下一个周一上午9点
|
}
|
|
public class ResponseData
|
{
|
public int errcode { get; set; }
|
public string errmsg { get; set; }
|
public long task_id { get; set; }
|
public string request_id { get; set; }
|
}
|
}
|
}
|
