using System.Linq;
using System.Timers;
using System;
using System.Net.Mail;
using System.Net;
using System.Collections.Generic;
using Model;
using System.Data.SqlClient;
using System.Data;
using NPOI.SS.Formula.Functions;
using System.Reflection;
using System.Text;
using System.Net.Security;
using System.Security.Cryptography.X509Certificates;
using System.Threading.Tasks;
using System.Threading;
using Quartz.Util;


namespace BLL
{
    public static class GJSXMonitorService
    {
        //public static Model.SGGLDB db = Funs.DB;

        /// <summary>
        /// 关键事项通知提醒责任人
        /// </summary>
        /// <param name="userId"></param>
        /// <param name="gjsxId"></param>
        public static void GJSXNoticeSendEmail(string userId, string gjsxId)
        {
            string strSql = $@"select 
                                    DATEDIFF(DAY, CompleteDate, isnull(CloseDate,getdate())) AS DateDiffDays
                                    ,a.GJSXID,a.ProjectId,a.Detail,a.createDate,Base_Project.ProjectName,Base_Unit.UnitName,a.CloseDate,a.IsManypeople,a.CompleteDate,a.AttachUrl
                                    ,case a.state when 2 then '正在进行' when 3 then '待办' when 0 then '已关闭' when 1 then '开放' end as state
                                    ,CNProfessionalName = STUFF((SELECT ',' + Base_CNProfessional.ProfessionalName FROM dbo.Base_CNProfessional where PATINDEX('%,' + RTRIM(Base_CNProfessional.CNProfessionalId) + ',%', ',' + a.CNProfessional_ID + ',') > 0 FOR XML PATH('')), 1, 1,'')
                                    ,QuestionTypeName = STUFF((SELECT ',' + Base_QuestionType.QuestionTypeName FROM dbo.Base_QuestionType where PATINDEX('%,' + RTRIM(Base_QuestionType.QuestionTypeID) + ',%', ',' + a.QuestionTypeID + ',') > 0 FOR XML PATH('')), 1, 1,'')
                                    ,GJSXTypeName = STUFF((SELECT ',' + Base_GJSXType.GJSXTypeName FROM dbo.Base_GJSXType where PATINDEX('%,' + RTRIM(Base_GJSXType.GJSXTypeID) + ',%', ',' + a.GJSXTypeID + ',') > 0 FOR XML PATH('')), 1, 1,'')
                                    ,a.UserID,b.UserName 
                                    --,b.Email as UserEmail
                                    ,a.User_ReceiveID as User_ReceiveUserId
                                    ,User_ReceiveUserName = STUFF((SELECT ',' + p2.UserName FROM dbo.Sys_User as p2 where PATINDEX('%,' + RTRIM(p2.UserId) + ',%', ',' + a.User_ReceiveID + ',') > 0 FOR XML PATH('')), 1, 1,'') 
                                    --,User_ReceiveUserEmail = STUFF((SELECT ',' + p2.Email FROM dbo.Sys_User as p2 where PATINDEX('%,' + RTRIM(p2.UserId) + ',%', ',' + a.User_ReceiveID + ',') > 0 FOR XML PATH('')), 1, 1,'') 
                                    ,a.user_Acceptance as User_AcceptanceUserId
                                    ,User_AcceptanceUserName = STUFF((SELECT ',' + p2.UserName FROM dbo.Sys_User as p2 where PATINDEX('%,' + RTRIM(p2.UserId) + ',%', ',' + a.user_Acceptance + ',') > 0 FOR XML PATH('')), 1, 1,'') 
                                    --,User_AcceptanceUserEmail = STUFF((SELECT ',' + p2.Email FROM dbo.Sys_User as p2 where PATINDEX('%,' + RTRIM(p2.UserId) + ',%', ',' + a.user_Acceptance + ',') > 0 FOR XML PATH('')), 1, 1,'') 
                                    ,a.CsUsers as User_CsUserIds
                                    ,User_CsUsers = STUFF((SELECT ',' + p2.UserName FROM dbo.Sys_User as p2 where PATINDEX('%,' + RTRIM(p2.UserId) + ',%', ',' + a.CsUsers + ',') > 0 FOR XML PATH('')), 1, 1,'') 
                                    --,User_CsUsersUserEmail = STUFF((SELECT ',' + p2.Email FROM dbo.Sys_User as p2 where PATINDEX('%,' + RTRIM(p2.UserId) + ',%', ',' + a.CsUsers + ',') > 0 FOR XML PATH('')), 1, 1,'') 
                                    from GJSX as a 
                                    left join Sys_User as b on a.UserId = b.UserId
                                    left join[dbo].[Base_Project] on a.ProjectId = Base_Project.ProjectId
                                    left join[dbo].[Base_Unit] on a.UnitId = Base_Unit.UnitId
                                where 1=1 and a.GJSXID = '{gjsxId}'  ";

            List<SqlParameter> listStr = new List<SqlParameter>();
            SqlParameter[] parameter = listStr.ToArray();

            DataTable table = SQLHelper.GetDataTableRunText(strSql, parameter);

            // 使用LINQ将DataTable转换为List<GJSXItem>
            var lstOverdue = table.AsEnumerable().Select(row => new GJSXItem
            {
                DateDiffDays = Convert.ToInt32(row["DateDiffDays"]),
                GJSXID = row["GJSXID"].ToString(),
                ProjectId = row["ProjectId"].ToString(),
                ProjectName = row["ProjectName"].ToString(),
                UnitName = row["UnitName"].ToString(),
                Detail = row["Detail"].ToString(),
                CNProfessionalName = row["CNProfessionalName"].ToString(),
                QuestionTypeName = row["QuestionTypeName"].ToString(),
                GJSXTypeName = row["GJSXTypeName"].ToString(),
                UserID = row["UserID"].ToString(),
                UserName = row["UserName"].ToString(),
                //UserEmail = row["UserEmail"].ToString(),
                User_ReceiveUserId = row["User_ReceiveUserId"].ToString(),
                User_ReceiveUserName = row["User_ReceiveUserName"].ToString(),
                //User_ReceiveUserEmail = row["User_ReceiveUserEmail"].ToString(),
                User_AcceptanceUserId = row["User_AcceptanceUserId"].ToString(),
                User_AcceptanceUserName = row["User_AcceptanceUserName"].ToString(),
                //User_AcceptanceUserEmail = row["User_AcceptanceUserEmail"].ToString(),
                User_CsUserIds = row["User_CsUserIds"].ToString(),
                User_CsUsers = row["User_CsUsers"].ToString(),
                //User_CsUsersUserEmail = row["User_CsUsersUserEmail"].ToString(),
                CompleteDate = Convert.ToDateTime(row["CompleteDate"].ToString())
            }).ToList();

            var gItem = lstOverdue.FirstOrDefault();
            var user = UserService.GetUserByUserId(userId);
            if (gItem != null && !string.IsNullOrWhiteSpace(user.Email))
            {
                MailMessage mail = new MailMessage();
                //邮件主题
                mail.Subject = $"你有新的关键事项了——{gItem.ProjectName}";
                mail.To.Add(user.Email);
                //mail.To.Add("test@test.com");
                mail.IsBodyHtml = true;//确保邮件正文被当作HTML解析
                //邮件正文
                string bodyStr = $@"<html>
<head>
<style>

</style>
</head>
<body>
<h2>新的关键事项信息</h2>
<p>项目名称：{gItem.ProjectName}</p>
<p>事项编号：{gItem.GJSXID}</p>
<p>责任单位：{gItem.UnitName}</p>
<p>专业：{gItem.CNProfessionalName}</p>
<p>事项类别：{gItem.GJSXTypeName}</p>
<p>紧急程度：{gItem.QuestionTypeName}</p>
<p>事项描述：{gItem.Detail}</p>
<p>提出人：{gItem.UserName}</p>
<p>责任人：{gItem.User_AcceptanceUserName}</p>
<p>跟踪人：{gItem.User_ReceiveUserName}</p>
<p>抄送人：{gItem.User_CsUsers}</p>
<p>约定完成日期：{gItem.CompleteDate.ToShortDateString()}</p>

<h2>智慧施工管理信息系统</h2>
<a href='https://zhgd.cwcec.com/'>请点击此处，进入智慧施工管理信息系统，查看事项详情</a>
<p>登录账号：{user.Account}</p>
<p>登录密码：CWCEC.+身份证号后四位（示例：CWCEC.1234）</p>

</body>
</html>";
//< p > 登录密码：{ user.RawPassword}</ p >
                mail.Body = bodyStr;

                try
                {
                    bool send = PushEmail(mail);
                }
                catch (Exception ex)
                {
                    ErrLogInfo.WriteLog($"关键事项通知提醒责任人；项目名称：{gItem.ProjectName}，事项编号：{gItem.GJSXID}", ex);
                }
            }
        }


        /// <summary>
        /// 关键事项超期预警定时提醒发送邮箱
        /// </summary>
        public static void OverdueWarningSendEmail()
        {
            try
            {
                Model.SGGLDB db = Funs.DB;
                //取未关闭且已经超期的数据

                string strSql = @"select 
                                    DATEDIFF(DAY, CompleteDate, isnull(CloseDate,getdate())) AS DateDiffDays
                                    ,a.GJSXID,a.ProjectId,a.Detail,a.createDate,Base_Project.ProjectName,Base_Unit.UnitName,a.CloseDate,a.IsManypeople,a.CompleteDate,a.AttachUrl
                                    ,case a.state when 2 then '正在进行' when 3 then '待办' when 0 then '已关闭' when 1 then '开放' end as state
                                    ,CNProfessionalName = STUFF((SELECT ',' + Base_CNProfessional.ProfessionalName FROM dbo.Base_CNProfessional where PATINDEX('%,' + RTRIM(Base_CNProfessional.CNProfessionalId) + ',%', ',' + a.CNProfessional_ID + ',') > 0 FOR XML PATH('')), 1, 1,'')
                                    ,QuestionTypeName = STUFF((SELECT ',' + Base_QuestionType.QuestionTypeName FROM dbo.Base_QuestionType where PATINDEX('%,' + RTRIM(Base_QuestionType.QuestionTypeID) + ',%', ',' + a.QuestionTypeID + ',') > 0 FOR XML PATH('')), 1, 1,'')
                                    ,GJSXTypeName = STUFF((SELECT ',' + Base_GJSXType.GJSXTypeName FROM dbo.Base_GJSXType where PATINDEX('%,' + RTRIM(Base_GJSXType.GJSXTypeID) + ',%', ',' + a.GJSXTypeID + ',') > 0 FOR XML PATH('')), 1, 1,'')
                                    ,a.UserID,b.UserName 
                                    --,b.Email as UserEmail
                                    ,a.User_ReceiveID as User_ReceiveUserId
                                    ,User_ReceiveUserName = STUFF((SELECT ',' + p2.UserName FROM dbo.Sys_User as p2 where PATINDEX('%,' + RTRIM(p2.UserId) + ',%', ',' + a.User_ReceiveID + ',') > 0 FOR XML PATH('')), 1, 1,'') 
                                    --,User_ReceiveUserEmail = STUFF((SELECT ',' + p2.Email FROM dbo.Sys_User as p2 where PATINDEX('%,' + RTRIM(p2.UserId) + ',%', ',' + a.User_ReceiveID + ',') > 0 FOR XML PATH('')), 1, 1,'') 
                                    ,a.user_Acceptance as User_AcceptanceUserId
                                    ,User_AcceptanceUserName = STUFF((SELECT ',' + p2.UserName FROM dbo.Sys_User as p2 where PATINDEX('%,' + RTRIM(p2.UserId) + ',%', ',' + a.user_Acceptance + ',') > 0 FOR XML PATH('')), 1, 1,'') 
                                    --,User_AcceptanceUserEmail = STUFF((SELECT ',' + p2.Email FROM dbo.Sys_User as p2 where PATINDEX('%,' + RTRIM(p2.UserId) + ',%', ',' + a.user_Acceptance + ',') > 0 FOR XML PATH('')), 1, 1,'') 
                                    ,a.CsUsers as User_CsUserIds
                                    ,User_CsUsers = STUFF((SELECT ',' + p2.UserName FROM dbo.Sys_User as p2 where PATINDEX('%,' + RTRIM(p2.UserId) + ',%', ',' + a.CsUsers + ',') > 0 FOR XML PATH('')), 1, 1,'') 
                                    --,User_CsUsersUserEmail = STUFF((SELECT ',' + p2.Email FROM dbo.Sys_User as p2 where PATINDEX('%,' + RTRIM(p2.UserId) + ',%', ',' + a.CsUsers + ',') > 0 FOR XML PATH('')), 1, 1,'') 
                                    from GJSX as a 
                                    left join Sys_User as b on a.UserId = b.UserId
                                    left join[dbo].[Base_Project] on a.ProjectId = Base_Project.ProjectId
                                    left join[dbo].[Base_Unit] on a.UnitId = Base_Unit.UnitId
                                where 1=1 and a.state<>'0' and GETDATE()>a.CompleteDate  ";

                List<SqlParameter> listStr = new List<SqlParameter>();
                SqlParameter[] parameter = listStr.ToArray();

                DataTable table = SQLHelper.GetDataTableRunText(strSql, parameter);

                // 使用LINQ将DataTable转换为List<GJSXItem>
                var lstOverdue = table.AsEnumerable().Select(row => new GJSXItem
                {
                    DateDiffDays = Convert.ToInt32(row["DateDiffDays"]),
                    GJSXID = row["GJSXID"].ToString(),
                    ProjectId = row["ProjectId"].ToString(),
                    ProjectName = row["ProjectName"].ToString(),
                    UnitName = row["UnitName"].ToString(),
                    Detail = row["Detail"].ToString(),
                    CNProfessionalName = row["CNProfessionalName"].ToString(),
                    QuestionTypeName = row["QuestionTypeName"].ToString(),
                    GJSXTypeName = row["GJSXTypeName"].ToString(),
                    UserID = row["UserID"].ToString(),
                    UserName = row["UserName"].ToString(),
                    //UserEmail = row["UserEmail"].ToString(),
                    User_ReceiveUserId = row["User_ReceiveUserId"].ToString(),
                    User_ReceiveUserName = row["User_ReceiveUserName"].ToString(),
                    //User_ReceiveUserEmail = row["User_ReceiveUserEmail"].ToString(),
                    User_AcceptanceUserId = row["User_AcceptanceUserId"].ToString(),
                    User_AcceptanceUserName = row["User_AcceptanceUserName"].ToString(),
                    //User_AcceptanceUserEmail = row["User_AcceptanceUserEmail"].ToString(),
                    User_CsUserIds = row["User_CsUserIds"].ToString(),
                    User_CsUsers = row["User_CsUsers"].ToString(),
                    //User_CsUsersUserEmail = row["User_CsUsersUserEmail"].ToString(),
                    CompleteDate = Convert.ToDateTime(row["CompleteDate"].ToString())
                }).ToList();

                #region 根据用户聚合推送，多个事项合并推送

                //获取有邮箱的用户
                var userIds = BLL.UserService.GetUserHaveEmailList();
                if (userIds.Any() && lstOverdue.Any())
                {
                    //int allnum = 0;
                    var lstProject = lstOverdue.Select(x => new { x.ProjectId, x.ProjectName }).Distinct().ToList();
                    foreach (var pro in lstProject)
                    {
                        //if (allnum > 50) { break; }
                        var lstProjectOverdue = lstOverdue.Where(x => x.ProjectId == pro.ProjectId).ToList();
                        if (lstProjectOverdue.Any())
                        {
                            string projectName = pro.ProjectName;
                            foreach (var user in userIds)
                            {
                                //if (allnum > 100) { break; }
                                MailMessage mail = new MailMessage();
                                //邮件主题
                                mail.Subject = $"关键事项超期预警提醒——{projectName}";
                                mail.To.Add(user.Email);
                                //mail.To.Add("test@test.com");
                                mail.IsBodyHtml = true;//确保邮件正文被当作HTML解析

                                StringBuilder tbodyStr = new StringBuilder();
                                int index = 1;
                                //责任人为本人
                                var acceptanceItems = lstProjectOverdue.Where(x => x.User_AcceptanceUserId.Contains(user.UserId)).OrderByDescending(x => x.DateDiffDays).ToList();
                                if (acceptanceItems.Any())
                                {
                                    foreach (var item in acceptanceItems)
                                    {
                                        tbodyStr.Append($"<tr><td>{index}</td><td>本人负责</td><td>{item.UnitName}</td><td>{item.GJSXID}</td><td>{item.Detail}</td><td>{item.GJSXTypeName}</td><td>{item.UserName}</td><td>{item.User_AcceptanceUserName}</td><td>{item.CompleteDate.ToShortDateString()}</td><td>{(item.DateDiffDays > 0 ? item.DateDiffDays.ToString() : "半")}</td></tr>");
                                        index++;
                                    }
                                }
                                //发起人为本人
                                var userItems = lstProjectOverdue.Where(x => x.UserID == user.UserId).OrderByDescending(x => x.DateDiffDays).ToList();
                                if (userItems.Any())
                                {
                                    foreach (var item in userItems)
                                    {
                                        tbodyStr.Append($"<tr><td>{index}</td><td>本人发起</td><td>{item.UnitName}</td><td>{item.GJSXID}</td><td>{item.Detail}</td><td>{item.GJSXTypeName}</td><td>{item.UserName}</td><td>{item.User_AcceptanceUserName}</td><td>{item.CompleteDate.ToShortDateString()}</td><td>{(item.DateDiffDays > 0 ? item.DateDiffDays.ToString() : "半")}</td></tr>");
                                        index++;
                                    }
                                }
                                //跟踪人为本人--x.User_ReceiveUserId != null && x.User_ReceiveUserId != "" &&
                                var receiveItems = lstProjectOverdue.Where(x => x.User_ReceiveUserId.Contains(user.UserId)).OrderByDescending(x => x.DateDiffDays).ToList();
                                if (receiveItems.Any())
                                {
                                    foreach (var item in receiveItems)
                                    {
                                        tbodyStr.Append($"<tr><td>{index}</td><td>本人跟踪</td><td>{item.UnitName}</td><td>{item.GJSXID}</td><td>{item.Detail}</td><td>{item.GJSXTypeName}</td><td>{item.UserName}</td><td>{item.User_AcceptanceUserName}</td><td>{item.CompleteDate.ToShortDateString()}</td><td>{(item.DateDiffDays > 0 ? item.DateDiffDays.ToString() : "半")}</td></tr>");
                                        index++;
                                    }
                                }
                                //抄送人为本人
                                var csUserItems = lstProjectOverdue.Where(x => x.User_CsUserIds.Contains(user.UserId)).OrderByDescending(x => x.DateDiffDays).ToList();
                                if (csUserItems.Any())
                                {
                                    foreach (var item in csUserItems)
                                    {
                                        tbodyStr.Append($"<tr><td>{index}</td><td>抄送本人</td><td>{item.UnitName}</td><td>{item.GJSXID}</td><td>{item.Detail}</td><td>{item.GJSXTypeName}</td><td>{item.UserName}</td><td>{item.User_AcceptanceUserName}</td><td>{item.CompleteDate.ToShortDateString()}</td><td>{(item.DateDiffDays > 0 ? item.DateDiffDays.ToString() : "半")}</td></tr>");
                                        index++;
                                    }
                                }
                                //邮件正文
                                string bodyStr = @"<html>
<head>
<style>
    table {
        border-collapse: collapse;
        width: 100%;
    }
    th, td {
        border: 1px solid black;
        padding: 8px;
        text-align: left;
    }
</style>
</head>
<body>
<h2>关键事项超期预警提醒</h2>
<a href='https://zhgd.cwcec.com/'>请点击此处，查看详细信息，并及时处置关闭</a>
<table>
<thead>
    <tr>
        <th>序号</th>
        <th>类型</th>
        <th>责任单位</th>
        <th>事项编号</th>
        <th>事项描述</th>
        <th>事项类别</th>
        <th>发起人</th>
        <th>责任人</th>
        <th>约定完成时间</th>
        <th>超期时间（天）</th>
    </tr>
</thead>
<tbody>" + tbodyStr.ToString() + "</tbody></table></body></html>";

                                mail.Body = bodyStr;
                                if (index > 1)
                                {
                                    //allnum++;
                                    bool send = PushEmail(mail);
                                    //Thread.Sleep(1000); //暂停1秒
                                }
                            }
                        }
                    }
                }

                #endregion

            }
            catch (Exception ex)
            {
                ErrLogInfo.WriteLog("关键事项邮件预警", ex);
            }
        }

        /// <summary>
        /// 发送邮件
        /// </summary>
        /// <param name="mail"></param>
        private static bool PushEmail(MailMessage mail)
        {
            //await Task.Delay(1000); //等待1000毫秒
            // 忽略SSL证书验证
            ServicePointManager.ServerCertificateValidationCallback =
                delegate (object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors sslPolicyErrors)
                {
                    return true;
                };
            //获取发送邮箱配置
            Email_Pop pops = BLL.Email_PopService.GetEmail_Pop("7EC5E991-B7A0-495A-90ED-2BE15370C959");
            if (pops != null)
            {
                mail.From = new MailAddress(pops.EmailYx);//发件人邮箱地址
                SmtpClient client = new SmtpClient(pops.EmailFwq);//替换为你的SMTP服务器地址
                client.Port = int.Parse(pops.EmailDk);//587或465如果使用SSL
                client.EnableSsl = true;//如果服务器支持SSL，设置为true
                client.DeliveryMethod = SmtpDeliveryMethod.Network;
                client.UseDefaultCredentials = false;
                client.Credentials = new NetworkCredential(pops.EmailYx, pops.EmailPass);//替换为你的邮箱和服务授权码
                client.Timeout = 6000;//6秒超时
                try
                {
                    client.Send(mail);
                    client.Dispose();//释放资源
                    return true;
                    //Console.WriteLine("Email sent successfully.");
                }
                catch (Exception ex)
                {
                    ErrLogInfo.WriteLog(mail.Subject, ex);
                    return false;
                    //Console.WriteLine("Email sending failed: " + ex.Message);
                }
            }
            return false;
        }

    }
}