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