using APT.Infrastructure.Core;
using APT.BaseData.Domain.ApiModel;
using APT.BaseData.Domain.Entities.FM;
using APT.BaseData.Domain.IServices.FM;
using APT.Utility;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Collections.Immutable;
using APT.BaseData.Domain.Entities;
using APT.BaseData.Domain.Enums;
using APT.Infrastructure.Api;
using APT.MS.Domain.Entities.PF;
using APT.BaseData.Domain.Dtos;
using Castle.Core.Internal;
using APT.MS.Domain.Entities.SC;

namespace APT.BaseData.Services.Services.FM
{
    public partial class FMNoticeService : CommonService, IFMNoticeService
    {

        public FMNoticeService(IRepository repository) : base(repository)
        {
        }

        /// <summary>
        /// 发送短信
        /// </summary>
        /// <param name="noticeType">现在只支持会议</param>
        /// <param name="DATA_ID"></param>
        public void SendMsg(NOTICETYPE? noticeType, Guid? DATA_ID, Guid? KEY = null, T_FM_SYNC_TASK task = null)
        {
            var mtConfig = GetEntity<T_SC_MT_CONFIG>(e => e.IS_SENDMSG);
            if (mtConfig == null)
            {
                return;
            }

            Expression<Func<T_FM_NOTICE, bool>> expression = e => e.NOTICE_STATUS == FMNoticeStatus.等待发送;
            if (noticeType != null && noticeType.HasValue)
            {
                expression = expression.And(e => e.NOTICETYPE == noticeType.Value);
            }
            if (DATA_ID != null && DATA_ID.HasValue)
            {
                expression = expression.And(e => e.DATA_ID == DATA_ID.Value);
            }
            if (KEY != null && KEY.HasValue)
            {
                expression = expression.And(e => e.KEY == KEY.Value);
            }

            var listNoticeSend = GetEntities(expression);//&&e.NOTICETYPE==NOTICETYPE.Meeting 以后放开此限制
            if (listNoticeSend == null || !listNoticeSend.Any())
                return;
            //数据完善
            //    如果没有手机号码 修改为发送失败  
            //短信发送
            //    发送次数 ++
            //    发送成功修改状态
            //    如果发送失败 判断次数  如果第三次（最后一次） 修改为 发送失败 记录失败原因

            #region      判断 手机号码 补齐  公用

            var noTEL = listNoticeSend.Where(e => e.TEL == null || e.TEL.Length < 1);
            T_FM_USER FMCheck = null;
            if (noTEL != null && noTEL.Any())
            {
                var listUserID = noTEL.Where(e => e.USER_ID.HasValue).Select(e => e.USER_ID);
                if (listUserID != null && listUserID.Any())
                {
                    var users = GetEntities<T_FM_USER>(e => listUserID.Contains(e.ID));
                    foreach (var item in listNoticeSend)
                    {
                        if (string.IsNullOrEmpty(item.TEL))
                        {
                            FMCheck = users.FirstOrDefault(e => e.ID == item.USER_ID);
                            if (FMCheck == null)
                            {
                                item.ERRORMSG = "获取人员信息失败";
                                item.NOTICE_STATUS = FMNoticeStatus.发送失败;
                            }
                            else if (string.IsNullOrEmpty(FMCheck.PHONE))
                            {
                                item.ERRORMSG = "缺少手机号码";
                                item.NOTICE_STATUS = FMNoticeStatus.发送失败;
                            }
                            else if (FMCheck.ENABLE_STATUS == 1)
                            {
                                item.ERRORMSG = "该用户已停用";
                                item.NOTICE_STATUS = FMNoticeStatus.发送失败;
                            }
                            else
                            {
                                item.TEL = FMCheck.PHONE;
                            }
                        }
                    }
                }
            }

            #endregion

            #region 结束时间小于当前时间, 就不发送了 
            DateTime dtNow = DateTime.Now;
            foreach (var item in listNoticeSend)
            {
                if (item.ENDDT.HasValue && item.ENDDT < dtNow)
                {
                    item.ERRORMSG = "结束时间小于当前时间不发送";
                    item.NOTICE_STATUS = FMNoticeStatus.发送失败;
                }
            }
            #endregion


            #region 验证手机号码
            foreach (var item in listNoticeSend)
            {
                if (item.NOTICE_STATUS == FMNoticeStatus.等待发送 && item.TEL.Length < 11)
                {
                    item.ERRORMSG = "手机号码错误";
                    item.NOTICE_STATUS = FMNoticeStatus.发送失败;
                }
            }
            #endregion


            #region     短信发送
            List<string> listPhone = new List<string>();
            List<string> listTemplateParams = new List<string>();

            //var listDataID = listNoticeSend.Select(e => e.DATA_ID).Distinct();
            var lisKEY = listNoticeSend.Select(e => e.KEY).Distinct();

            TencentSendSMS tencentSendSMS = new TencentSendSMS();
            string[] phoneNumbers = null;
            List<string> templates = null;
            string TEMPLATE_ID = string.Empty;//短信模板

            bool isSend = false;//是否发送成功
            foreach (var item in lisKEY)
            {
                var listTemp = listNoticeSend.Where(e => e.KEY == item && e.NOTICE_STATUS == FMNoticeStatus.等待发送);
                phoneNumbers = listTemp.Select(e => e.TEL).ToArray();
                //2个参数
                foreach (var itemS in listTemp)
                {
                    if (templates == null)
                    {
                        templates = new List<string>();
                        templates.Add(itemS.TITLE);
                        templates.Add(itemS.ENDDT.Value.ToString("yyyy-MM-dd HH:mm"));
                        TEMPLATE_ID = itemS.TEMPLATE_ID;
                        break;
                    }
                }
                if (string.IsNullOrEmpty(TEMPLATE_ID) || phoneNumbers.Length < 1 || !templates.Any())
                {
                    continue;
                }

                try
                {
                    var result = tencentSendSMS.sendSMS(TEMPLATE_ID, phoneNumbers, templates.ToArray());
                    foreach (var itemResult in result.SendStatusSet)
                    {
                        foreach (var itemRN in listNoticeSend)
                        {
                            if (itemRN.KEY == item && itemRN.NOTICE_STATUS == FMNoticeStatus.等待发送 && itemResult.PhoneNumber.EndsWith(itemRN.TEL))
                            {
                                itemRN.TRYCOUNT++;
                                if (itemResult.Code == "Ok")
                                {
                                    isSend = true;
                                    itemRN.NOTICE_STATUS = FMNoticeStatus.发送成功;
                                }
                                else if (itemRN.TRYCOUNT == 3)
                                {
                                    //3次发送失败 记录信息
                                    itemRN.NOTICE_STATUS = FMNoticeStatus.发送失败;
                                    itemRN.ERRORMSG = itemResult.Message;
                                    if (itemRN.ERRORMSG != null && itemRN.ERRORMSG.Length > 100)
                                    {
                                        itemRN.ERRORMSG = itemRN.ERRORMSG.Substring(0, 95);
                                    }
                                }
                                break;
                            }
                        }
                    }
                }
                catch
                {
                    //发送信息报错 例：腾讯云 服务器挂了
                }
            }

            #endregion

            #region    信息保存
            if (isSend)
            {
                UnifiedCommit(() =>
                {
                    BantchUpdateEntityNoCommit(listNoticeSend);
                    if (task != null)
                    {
                        UpdateEntityNoCommit(task);
                    }
                });
            }
            else
            {
                var listChange = listNoticeSend.Where(e => e.NOTICE_STATUS == FMNoticeStatus.发送失败);
                if (listChange != null && listChange.Any())
                {
                    foreach (var item in listChange)
                    {
                        item.TRYCOUNT++;
                    }
                    BantchUpdateEntityNoCommit(listChange);
                    if (task != null)
                    {
                        UpdateEntityNoCommit(task);
                    }
                }
            }

            #endregion
        }
    }
}