mh_sms/APT.BaseData.Services/Services/FM/FMNoticeService.cs

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;
using TencentCloud.Sms.V20210111.Models;

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);
            //}
            expression = expression.And(e => e.NOTICETYPE == noticeType);
            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();
                switch (noticeType)
                {
                    case NOTICETYPE.Meeting:
                        //2个参数
                        foreach (var itemS in listTemp)
                        {
                            if (templates == null)
                            {
                                templates = new List<string>();
                                TEMPLATE_ID = itemS.TEMPLATE_ID;
                                templates.Add(itemS.TITLE);
                                templates.Add(itemS.ENDDT.Value.ToString("yyyy-MM-dd HH:mm"));
                                break;
                            }
                        }
                        break;
                    case NOTICETYPE.MeetingJD:
                        //2个参数
                        foreach (var itemS in listTemp)
                        {
                            if (templates == null)
                            {
                                templates = new List<string>();

                                TEMPLATE_ID = itemS.TEMPLATE_ID;
                                templates.AddRange(GetSplit(itemS.TITLE.Split('[')[0]));
                                templates.Add(itemS.ENDDT.Value.Year.ToString());
                                templates.Add(itemS.ENDDT.Value.Month.ToString("00"));
                                templates.Add(itemS.ENDDT.Value.Day.ToString("00"));
                                templates.Add(itemS.ENDDT.Value.Hour.ToString("00"));
                                templates.Add(itemS.ENDDT.Value.Minute.ToString("00"));
                                templates.Add(itemS.ENDDT.Value.Second.ToString("00"));
                                break;
                            }
                        }
                        break;
                    default:
                        break;
                }

                if (string.IsNullOrEmpty(TEMPLATE_ID) || phoneNumbers.Length < 1 || !templates.Any())
                {
                    continue;
                }

                try
                {
                    SendSmsResponse result = null;
                    if (noticeType == NOTICETYPE.Meeting)
                    {
                        result = tencentSendSMS.sendSMS(TEMPLATE_ID, phoneNumbers, templates.ToArray());
                    }
                    else if (noticeType == NOTICETYPE.MeetingJD)
                    {
                        //result = tencentSendSMS.sendSMSDCJD(TEMPLATE_ID, phoneNumbers, templates.ToArray());
                    }
                    if (result != null)
                    {
                        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(() =>
                {
                    BantchSaveEntityNoCommit(listNoticeSend);//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++;
                    }
                    BantchSaveEntityNoCommit(listChange); //BantchUpdateEntityNoCommit(listChange);
                    if (task != null)
                    {
                        UpdateEntityNoCommit(task);
                    }
                }
            }

            #endregion
        }

        /// <summary>
        /// 获取会议模板ID
        /// </summary>
        /// <param name="ORG_ID"></param>
        /// <returns></returns>
        public string GetTEMPLATE_ID(Guid ORG_ID)
        {
            if (ORG_ID == new Guid("B043B28B-BBC3-C452-6052-4FBA1457ABFA"))
            {
                return NOTICETYPE.Meeting.GetDescription();
            }
            else if (ORG_ID == new Guid("8B3C41AA-51B1-7CE9-1879-248A038C1B5C"))
            {
                return NOTICETYPE.MeetingJD.GetDescription();
            }

            return "";
        }

        /// <summary>
        /// 文本分块(发送信息时用)
        /// </summary>
        /// <param name="title"></param>
        /// <param name="piece"></param>
        /// <param name="splitMax"></param>
        /// <returns></returns>
        private List<string> GetSplit(string title, int piece = 3, int splitMax = 6)
        {
            int titleLength = title.Length;
            List<string> listResult = new List<string>();
            if (titleLength == piece)
            {
                //每个字一份
                for (int i = 0; i < piece; i++)
                {
                    listResult.Add(title.Substring(i, 1));
                }

            }
            else if (titleLength >= splitMax * piece)
            {
                //按最长给 多的也不给
                for (int i = 0; i < piece; i++)
                {
                    listResult.Add(title.Substring(i * splitMax, splitMax));
                }
            }
            else
            {
                int remain = titleLength % piece;
                int Per = titleLength / piece;

                //分割长度
                List<int> listLength = new List<int>();
                if (remain == 0)
                {
                    for (int i = 0; i < piece; i++)
                        listLength.Add(Per);
                }
                else
                {
                    for (int i = 0; i < piece; i++)
                    {
                        remain--;
                        if (remain < 0)
                            listLength.Add(Per);
                        else
                            listLength.Add(Per + 1);
                    }
                }

                for (int i = 0; i < piece; i++)
                {
                    listResult.Add(title.Substring(0, listLength[i]));
                    title = title.Substring(listLength[i]);
                }
            }
            return listResult;

        }
    }
}