using CommonUtil;
using CommonUtil.Web;
using Operater.DAL;
using Quartz;
using System;
using System.Collections.Generic;
using System.Data;
using System.Text;
using System.Threading.Tasks;

namespace ScheduledTasks.Handle
{
    public class SmsWarningHandle : IJob
    {
        public async Task Execute(IJobExecutionContext context)
        {
            await Synchronize(context);
        }
        public static async Task Synchronize(IJobExecutionContext context)
        {
            try
            {
                //查询超过3分钟未审核的
                string searchSql = $"select count(1) as count from sms_send where sendstatus=0 and isshowsend=0 and TIMESTAMPDIFF(MINUTE, now(),createtime)>3";
                DataTable shDt = new YzOrderinfoDAL().SearchBySqlDataTable("Sms", searchSql);
                int shCount = int.Parse(shDt.Rows[0]["count"].ToString());
                if (shCount > 0)
                {//发预警
                    string warStr = "您有待审核的任务\n>类型：待审核\n>数量:" + shCount + "\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(warStr);

                }
                //查询长时间未发送成功
                searchSql = $"select count(1) as count from sms_send where isshowsend=0 and wantsendtime>now() and sendstatus=0 and TIMESTAMPDIFF(MINUTE, now(),wantsendtime)>5";
                DataTable wfDt = new YzOrderinfoDAL().SearchBySqlDataTable("Sms", searchSql);
                int wfCount = int.Parse(wfDt.Rows[0]["count"].ToString());
                if (wfCount > 0)
                {//发预警
                    string warStr = "长时间未发送完成任务\n>类型：任务异常\n>数量:" + wfCount;
                    SendQwGroup.SendMessage(warStr);
                }
            }
            catch (Exception e)
            {
                LogUtil.Info(e.ToString(), "短信预警error");
                Console.WriteLine($"短信预警error", e.ToString());
            }
        }
    }
}