From 45e3e2f4b3a55c3949c8a5bc5e6928f0cc2cacb1 Mon Sep 17 00:00:00 2001 From: heyuntao <heyuntao@LAPTOP-MP4HD5NS> Date: 星期一, 23 十月 2023 10:45:25 +0800 Subject: [PATCH] no message --- api/SmsSendTool/Program.cs | 35 +++++++++++++++++++++++++++++++++++ 1 files changed, 35 insertions(+), 0 deletions(-) diff --git a/api/SmsSendTool/Program.cs b/api/SmsSendTool/Program.cs index e3c53ff..34ae045 100644 --- a/api/SmsSendTool/Program.cs +++ b/api/SmsSendTool/Program.cs @@ -4,6 +4,8 @@ using SqlSugar; using System; using System.Threading; +using System.Collections.Generic; +using CommonUtil.Web; namespace SmsSendTool { @@ -28,6 +30,24 @@ sendMain.SendSms(smssend.Id); } } + //鏌ヨ闀挎椂闂存湭瀹屾垚鐨勪换鍔� + List<int?> sstaus =new List<int?>{0,1,2,3,4,5 }; + var send_where_expression1 = Expressionable.Create<SmsSend>().And(m => sstaus.Contains(m.Sendstatus)).And(m=>m.Wantsendtime>DateTime.Now.AddMinutes(30)).And(m => m.Isshowsend == 0).ToExpression(); + var smssendlist1 = new SmsSendDAL().ListGet(send_where_expression1, t => t.Createtime, DbEnum.OrderType.Asc); + if (smssendlist1 != null && smssendlist1.Count > 0) + { + Console.WriteLine("鍙戦�侀暱鏃堕棿鏈畬鎴愪换鍔℃秷鎭�"); + var timer = new Timer(v => SendMessage(smssendlist1.Count, 1), null, 0, 5 * 60 * 1000); + } + //鏌ヨ寰呭鏍哥殑浠诲姟 + var send_where_expression2 = Expressionable.Create<SmsSend>().And( m => m.Sendstatus == 0).And(m => m.Isshowsend == 0).ToExpression(); + var smssendlist2 = new SmsSendDAL().ListGet(send_where_expression2, t => t.Createtime, DbEnum.OrderType.Asc); + if (smssendlist2 != null && smssendlist2.Count > 0) + { + Console.WriteLine("鍙戦�佸緟瀹℃牳浠诲姟娑堟伅"); + var timer = new Timer(v => SendMessage(smssendlist2.Count, 2), null, 0, 5 * 60 * 1000); + } + } catch (Exception ex) @@ -44,5 +64,20 @@ Console.ReadLine(); } + + public static void SendMessage(int strcount,int type) + { + switch (type) + { + case 1: + string warStr1 = "闀挎椂闂存湭鍙戦�佸畬鎴愪换鍔n>绫诲瀷锛氫换鍔″紓甯竆n>鏁伴噺:" + strcount; + SendQwGroup.SendMessage(warStr1); + break; + case 2: + string warStr2 = "鎮ㄦ湁寰呭鏍哥殑浠诲姟\n>绫诲瀷锛氬緟瀹℃牳\n>鏁伴噺:" + strcount + "\n>鏌ョ湅:[鐐瑰嚮澶勭悊](https://open.weixin.qq.com/connect/oauth2/authorize?appid=wx7a9a40880081340d&redirect_uri=https%3A%2F%2Fsms.ushopvip.com%2Fpages%2Fad_page%2Ftrans&response_type=code&scope=snsapi_base&state=gzh#wechat_redirect)"; + SendQwGroup.SendMessage(warStr2); + break; + } + } } } -- Gitblit v1.9.3