using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using AutoCheckSMS.Common;
|
|
namespace AutoCheckSMS
|
{
|
class Program
|
{
|
/// <summary>
|
/// 模板列表
|
/// </summary>
|
static List<A_template> _Templates;
|
static Thread _auditThread;//审核线程
|
static Thread _templateThread;//模板线程
|
static List<int> tempTaskList=new List<int>();//不处理的列表
|
|
static void Main(string[] args)
|
{
|
//设置控制台前景/背景色
|
Console.ForegroundColor = ConsoleColor.White;
|
Console.BackgroundColor = ConsoleColor.DarkBlue;
|
|
Console.Title = "【自动审核】AutoCheckSMS";
|
Console.SetBufferSize(1000, 1000);
|
|
|
System.Timers.Timer timer = new System.Timers.Timer(1000 * 60 * 5);
|
timer.Elapsed += new System.Timers.ElapsedEventHandler(DealClean);
|
timer.AutoReset = true;
|
timer.Enabled = true;
|
|
//多线程处理，一个线程处理审核，一个线程处理模板录入等，注意线程间通信
|
_Templates = SQLHelper.Instance.GetTemplates();
|
Log4netService.Debug($"加载模板...{_Templates.Count}");
|
|
if (_auditThread != null)
|
{
|
_auditThread.Abort();
|
_auditThread = null;
|
}
|
if (_auditThread == null || _auditThread.ThreadState == ThreadState.Aborted || _auditThread.ThreadState == ThreadState.Stopped)
|
{
|
ThreadStart thr_start_func = new ThreadStart(AuditThread);
|
_auditThread = new Thread(thr_start_func);
|
_auditThread.Start();
|
}
|
|
|
if (_templateThread != null)
|
{
|
_templateThread.Abort();
|
_templateThread = null;
|
}
|
if (_templateThread == null || _templateThread.ThreadState == ThreadState.Aborted || _templateThread.ThreadState == ThreadState.Stopped)
|
{
|
ThreadStart thr_start_func = new ThreadStart(TemplateThread);
|
_templateThread = new Thread(thr_start_func);
|
_templateThread.Start();
|
}
|
|
|
|
|
}
|
|
|
/// <summary>
|
/// 审核线程
|
/// </summary>
|
public static void AuditThread()
|
{
|
Console.WriteLine($"审核处理线程启动...线程ID:{Thread.CurrentThread.ManagedThreadId}");
|
while(true)
|
{
|
List<tbl_sms_task> list = SQLHelper.Instance.GetSmsConent();
|
Log4netService.Debug($"获取待审核的记录:{list.Count}");
|
if (list.Count > 0)
|
{
|
foreach (tbl_sms_task sms in list)
|
{
|
//表示内容已经处理过了
|
if (tempTaskList!=null && tempTaskList.Contains(sms.TaskID))
|
{
|
continue;
|
}
|
|
Log4netService.Debug($"[调试] 当前处理的taskid={sms.TaskID}");
|
|
//线程间通信，如果模板列表清空或正在更新中，这里暂停处理
|
if(_Templates.Count<=0)
|
{
|
Log4netService.Debug($"[模板更新中]-不处理，直至模板线程完成更新...");
|
continue;
|
}
|
|
bool result = Match.Instance.IsMatchByWildcard(_Templates,sms.MsgContent);
|
if (result)
|
{
|
Log4netService.Debug($"{sms.TaskID}-匹配通过：{sms.MsgContent}");
|
//todo更新审核状态
|
SQLHelper.Instance.UpdateSmsTask(2, sms.TaskID);
|
Log4netService.Debug($"审核通过=内容:{sms.MsgContent}");
|
}
|
else
|
{
|
tempTaskList.Add(sms.TaskID);//匹配不到模板，下次不再处理
|
}
|
|
}
|
}
|
Thread.Sleep(1000*10);
|
}
|
}
|
|
|
/// <summary>
|
/// 模板处理
|
/// </summary>
|
public static void TemplateThread()
|
{
|
Log4netService.Debug($"模板处理线程启动...线程ID:{Thread.CurrentThread.ManagedThreadId}");
|
while (true)
|
{
|
|
Log4netService.Debug($"模板处理");
|
List<string> tmpList = new List<string>();
|
List<tbl_sms_task> smsList = SQLHelper.Instance.GetSmsLogContent();
|
if (smsList.Count > 0)
|
{
|
Log4netService.Debug($"获取到审核内容：{smsList.Count}");
|
foreach (tbl_sms_task sms in smsList)
|
{
|
if (tempTaskList.Contains(sms.TaskID)) continue;//已经处理过了
|
|
//匹配模板-判断模板是否存在
|
if (Match.Instance.IsMatchByWildcard(_Templates, sms.MsgContent))
|
{
|
Console.WriteLine($"模板已经存在-不处理-{sms.MsgContent}");
|
tempTaskList.Add(sms.TaskID);
|
continue;
|
}
|
|
//生成模板
|
string _template = GenerateTemplate.Instance.GenerateTemplates(sms.MsgContent);
|
tmpList.Add(_template);
|
}
|
}
|
|
//模板入库
|
if (tmpList.Count > 0)
|
{
|
tmpList = tmpList.Distinct().ToList();
|
foreach (string str in tmpList)
|
{
|
//Log4netService.Debug($"[模板]-内容：{str}");
|
int num = _Templates.FindIndex(c => c.Template == str);
|
if (num >= 0)
|
{
|
continue;
|
}
|
|
//插入数据库
|
int numAdd = SQLHelper.Instance.AddTemplate(str, 0);
|
|
if (numAdd > 0)
|
{
|
Log4netService.Debug($"[模板插入成功]-内容：{str}");
|
}
|
else
|
{
|
Log4netService.Debug($"[模板插入失败]-内容：{str}");
|
}
|
}
|
}
|
|
|
|
//模板更新处理
|
List<A_template> a_Templates = SQLHelper.Instance.GetTemplates();
|
if (a_Templates.Count != _Templates.Count)
|
{
|
Log4netService.Debug($"模板更新成功-{_Templates.Count}");
|
_Templates = a_Templates;
|
}
|
|
Thread.Sleep(1000 * 60);
|
}
|
|
}
|
|
|
/// <summary>
|
/// 清理列表
|
/// </summary>
|
/// <param name="sender"></param>
|
/// <param name="e"></param>
|
private static void DealClean(object sender, System.Timers.ElapsedEventArgs e)
|
{
|
tempTaskList.Clear();
|
Log4netService.Debug("清理列表");
|
}
|
}
|
}
|
