OA2023/OASystem/OASystem.Api/OAMethodLib/QiYeWeChatAPI/AppNotice/Library.cs

using OASystem.Domain.Dtos.Groups;
using OASystem.Domain.Entities.Financial;
using OASystem.Domain.Entities.Groups;
using OASystem.Domain.Entities.PersonnelModule;
using OASystem.Domain.ViewModels.CRM;
using OASystem.Domain.ViewModels.Groups;
using OASystem.Domain.ViewModels.QiYeWeChat;
using OASystem.Infrastructure.Repositories.Groups;
using OASystem.Domain.Entities.WorkOrder;
using OASystem.Infrastructure.Logging;

namespace OASystem.API.OAMethodLib.QiYeWeChatAPI.AppNotice
{
    public static class AppNoticeLibrary
    {
        private static readonly IQiYeWeChatApiService _qiYeWeChatApiService = AutofacIocManager.Instance.GetService<IQiYeWeChatApiService>();

        private static readonly DelegationInfoRepository _grpDeleRep = AutofacIocManager.Instance.GetService<DelegationInfoRepository>();
        private static readonly IGroupTextFileLogger _groupLog = AutofacIocManager.Instance.GetService<IGroupTextFileLogger>();

        #region 获取企微Id

        public static List<string> GetQiyeChatUserIdList(List<string> userId)
        {
            List<string> result = new List<string>();

            try
            {
                foreach (string item in userId)
                {
                    int uid = int.Parse(item);
                    Sys_Users users = _grpDeleRep._sqlSugar.Queryable<Sys_Users>().First(s => s.Id == uid);
                    if (!string.IsNullOrEmpty(users.QiyeChatUserId))
                    {
                        result.Add(users.QiyeChatUserId);
                    }
                }
            }
            catch (Exception ex)
            {
            }
            return result;
        }

        #endregion

        #region 确认出团

        /// <summary>
        /// 向指定群聊发送- 确认出团 -通知
        /// </summary>
        /// <param name="diId"></param>
        /// <param name="qwEnum"></param>
        /// <returns></returns>
        public static async Task<bool> SendChatMsg_GroupStatus_Create(int diId, QiyeWeChatEnum qwEnum)
        {
            Grp_DelegationInfo entity = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();

            string dateRange = string.Format(@"{0}至{1}", entity.VisitStartDate.ToString("yyyy-MM-dd"), entity.VisitEndDate.ToString("yyyy-MM-dd"));

            string grpTypeStr = (_grpDeleRep.Query<Sys_SetData>(s => s.Id == entity.TeamDid).First()).Name;

            GroupStatus_CreateModel info = new GroupStatus_CreateModel()
            {
                ClientName = entity.ClientName,
                ClientUnit = entity.ClientUnit,
                TeamName = entity.TeamName,
                VisitDays = entity.VisitDays,
                VisitPNumber = entity.VisitPNumber,
                VisitDateRange = dateRange,
                TeamDid_Text = grpTypeStr
            };
            string chatId = qwEnum.GetEnumDescription();
            //发送信息
            ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.GroupStatus_Create(info));
            if (result.errcode != 0)
            {
                //抄送日志 
                return false;
            }

            return true;
        }

        /// <summary>
        /// 向指定用户发送- 确认出团 -通知
        /// </summary>
        /// <param name="diId"></param>
        /// <param name="userId"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_GroupStatus_Create(int diId, List<string> userId)
        {
            Grp_DelegationInfo entity = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();

            string dateRange = string.Format(@"{0}至{1}", entity.VisitStartDate.ToString("yyyy-MM-dd"), entity.VisitEndDate.ToString("yyyy-MM-dd"));

            string grpTypeStr = (_grpDeleRep.Query<Sys_SetData>(s => s.Id == entity.TeamDid).First()).Name;

            GroupStatus_CreateModel info = new GroupStatus_CreateModel()
            {
                ClientName = entity.ClientName,
                ClientUnit = entity.ClientUnit,
                TeamName = entity.TeamName,
                VisitDays = entity.VisitDays,
                VisitPNumber = entity.VisitPNumber,
                VisitDateRange = dateRange,
                TeamDid_Text = grpTypeStr
            };

            //发送信息
            List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.GroupStatus_Create(info));

                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }
            return true;
        }

        #endregion

        #region 团组费用审核

        /// <summary>
        /// 向指定群聊发送- 费用申请 -通知
        /// </summary>
        /// <param name="creditCardId"></param>
        /// <param name="sign"></param>
        /// <param name="qwEnum"></param>
        /// <returns></returns>
        public static async Task<bool> SendChatMsg_GroupStatus_ApplyFee(int creditCardId, int sign, QiyeWeChatEnum qwEnum)
        {
            string chatId = qwEnum.GetEnumDescription();

            Grp_CreditCardPayment ccp = _grpDeleRep.Query<Grp_CreditCardPayment>(s => s.Id == creditCardId).First();
            Grp_DelegationInfo group = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == ccp.DIId).First();

            Sys_SetData payMoneyCurrencySetData = _grpDeleRep.Query<Sys_SetData>(s => s.Id == ccp.PaymentCurrency).First();
            string priceStr = string.Format(@"{0} {1}", ccp.PayMoney, payMoneyCurrencySetData.Name);

            List<Grp_CreditCardPayment> entityList = _grpDeleRep
                   .Query<Grp_CreditCardPayment>(s => s.DIId == ccp.DIId && s.IsDel == 0 && s.CreateUserId > 0 && s.IsAuditGM == 0)
                   .ToList();

            GroupStatus_ApplyFeeModel info = new GroupStatus_ApplyFeeModel()
            {
                QueueCount = entityList.Count,
                TeamName = group.TeamName,
                Price = priceStr
            };

            if (sign == 2)
            {
                info.TitleStr = "[更新]一项费用待审核";
            }

            // CTable
            #region CTable

            if (ccp.CTable == 76)//76,酒店预订
            {
                Grp_HotelReservations _HotelReservations = _grpDeleRep.Query<Grp_HotelReservations>(s => s.Id == ccp.CId).First();
                info.CreateDt = _HotelReservations.CreateTime.ToString("yyyy-MM-dd HH:mm");

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _HotelReservations.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "酒店预订";
                info.PriceName = _HotelReservations.HotelName;
            }
            else if (ccp.CTable == 79) //79://车/导游地接
            {
                Grp_CarTouristGuideGroundReservations _CarTouristGuideGroundReservations = _grpDeleRep.Query<Grp_CarTouristGuideGroundReservations>(s => s.Id == ccp.CId).First();
                info.CreateDt = _CarTouristGuideGroundReservations.CreateTime.ToString("yyyy-MM-dd HH:mm");

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _CarTouristGuideGroundReservations.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "车/导游地接";
                info.PriceName = _CarTouristGuideGroundReservations.PriceName;
            }
            else if (ccp.CTable == 80) //签证
            {
                List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
                Grp_VisaInfo _VisaInfos = _grpDeleRep.Query<Grp_VisaInfo>(s => s.Id == ccp.CId).First();
                info.CreateDt = _VisaInfos.CreateTime.ToString("yyyy-MM-dd HH:mm");

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _VisaInfos.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "签证";
                info.PriceName = getClientNameStr(clientNameList, _VisaInfos.VisaClient);
            }
            else if (ccp.CTable == 81)//邀请/公务活动
            {
                Grp_InvitationOfficialActivities _InvitationOfficialActivities = _grpDeleRep.Query<Grp_InvitationOfficialActivities>(s => s.Id == ccp.CId).First();
                info.CreateDt = _InvitationOfficialActivities.CreateTime.ToString("yyyy-MM-dd HH:mm");

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _InvitationOfficialActivities.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "邀请/公务活动";
                info.PriceName = _InvitationOfficialActivities.InviterArea;
            }
            else if (ccp.CTable == 82)//团组客户保险
            {
                List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
                Grp_Customers _Customers = _grpDeleRep.Query<Grp_Customers>(s => s.Id == ccp.CId).First();
                info.CreateDt = _Customers.CreateTime.ToString("yyyy-MM-dd HH:mm");

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _Customers.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "团组客户保险";
                info.PriceName = getClientNameStr(clientNameList, _Customers.ClientName);
            }
            else if (ccp.CTable == 85) //机票预订
            {
                var _AirTicketReservations = _grpDeleRep.Query<Grp_AirTicketReservations>(s => s.Id == ccp.CId).First();
                if (_AirTicketReservations == null)
                {
                    return false;
                }
            
                info.CreateDt = _AirTicketReservations.CreateTime.ToString("yyyy-MM-dd HH:mm");

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _AirTicketReservations.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "机票预订";
                info.PriceName = "(" + _AirTicketReservations.FlightsCode + ")";
            }
            else if (ccp.CTable == 98) //其他款项
            {
                Grp_DecreasePayments _DecreasePayments = _grpDeleRep.Query<Grp_DecreasePayments>(s => s.Id == ccp.CId).First();
                info.CreateDt = _DecreasePayments.CreateTime.ToString("yyyy-MM-dd HH:mm");

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _DecreasePayments.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "其他款项";
                info.PriceName = _DecreasePayments.PriceName;
            }
            #endregion

            //发送信息
            ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.GroupStatus_ApplyFee(info));
            if (result.errcode != 0)
            {
                //抄送日志 
                return false;
            }

            return true;
        }

        /// <summary>
        /// 向财务群发送费用审核结果通知(审核通过条件下发送)
        /// </summary>
        /// <param name="Grp_CreditCardPaymentId"></param>
        /// <param name="qwEnum"></param>
        /// <returns></returns>
        public static async Task<bool> SendChatMsg_GroupStatus_AuditFee(int Grp_CreditCardPaymentId, QiyeWeChatEnum qwEnum)
        {

            string chatId = qwEnum.GetEnumDescription();

            Grp_CreditCardPayment ccp = _grpDeleRep.Query<Grp_CreditCardPayment>(s => s.Id == Grp_CreditCardPaymentId).First();
            Grp_DelegationInfo group = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == ccp.DIId).First();

            Sys_SetData payMoneyCurrencySetData = _grpDeleRep.Query<Sys_SetData>(s => s.Id == ccp.PaymentCurrency).First();
            string priceStr = string.Format(@"{0} {1}", ccp.PayMoney, payMoneyCurrencySetData.Name);

            AuditResult_ApplyFee_GroupModel info = new AuditResult_ApplyFee_GroupModel()
            {
                TeamName = group.TeamName,
                Price = priceStr,
                GMAuditDate = "-"
            };

            DateTime gmAuditDt;
            bool bGMAuditDt = DateTime.TryParse(ccp.AuditGMDate, out gmAuditDt);
            info.GMAuditDate = gmAuditDt.ToString("yyyy-MM-dd HH:mm");

            //CTable
            #region CTable

            if (ccp.CTable == 76)//76,酒店预订
            {
                Grp_HotelReservations _HotelReservations = _grpDeleRep.Query<Grp_HotelReservations>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _HotelReservations.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "酒店预订";
                info.PriceName = _HotelReservations.HotelName;
            }
            else if (ccp.CTable == 79) //79://车/导游地接
            {
                Grp_CarTouristGuideGroundReservations _CarTouristGuideGroundReservations = _grpDeleRep.Query<Grp_CarTouristGuideGroundReservations>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _CarTouristGuideGroundReservations.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "车/导游地接";
                info.PriceName = _CarTouristGuideGroundReservations.PriceName;
            }
            else if (ccp.CTable == 80) //签证
            {
                List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
                Grp_VisaInfo _VisaInfos = _grpDeleRep.Query<Grp_VisaInfo>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _VisaInfos.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "签证";
                info.PriceName = getClientNameStr(clientNameList, _VisaInfos.VisaClient);
            }
            else if (ccp.CTable == 81)//邀请/公务活动
            {
                Grp_InvitationOfficialActivities _InvitationOfficialActivities = _grpDeleRep.Query<Grp_InvitationOfficialActivities>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _InvitationOfficialActivities.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "邀请/公务活动";
                info.PriceName = _InvitationOfficialActivities.InviterArea;
            }
            else if (ccp.CTable == 82)//团组客户保险
            {
                List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
                Grp_Customers _Customers = _grpDeleRep.Query<Grp_Customers>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _Customers.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "团组客户保险";
                info.PriceName = getClientNameStr(clientNameList, _Customers.ClientName);
            }
            else if (ccp.CTable == 85) //机票预订
            {
                Grp_AirTicketReservations _AirTicketReservations = _grpDeleRep.Query<Grp_AirTicketReservations>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _AirTicketReservations.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "机票预订";
                info.PriceName = "(" + _AirTicketReservations.FlightsCode + ")";
            }
            else if (ccp.CTable == 98) //其他款项
            {
                Grp_DecreasePayments _DecreasePayments = _grpDeleRep.Query<Grp_DecreasePayments>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _DecreasePayments.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "其他款项";
                info.PriceName = _DecreasePayments.PriceName;
            }
            #endregion

            //发送信息
            ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.AuditResult_ApplyFee_Chat(info));
            if (result.errcode != 0)
            {
                //抄送日志 
                return false;
            }

            return true;
        }


        /// <summary>
        /// 向指定用户发送-团组费用审核结果
        /// </summary>
        /// <param name="Grp_CreditCardPaymentId"></param>
        /// <param name="userId"></param>
        /// <param name="qwEnum"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_GroupStatus_AuditFee(int Grp_CreditCardPaymentId, List<string> userId, QiyeWeChatEnum qwEnum)
        {
            Grp_CreditCardPayment ccp = _grpDeleRep.Query<Grp_CreditCardPayment>(s => s.Id == Grp_CreditCardPaymentId).First();
            Grp_DelegationInfo group = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == ccp.DIId).First();

            Sys_SetData payMoneyCurrencySetData = _grpDeleRep.Query<Sys_SetData>(s => s.Id == ccp.PaymentCurrency).First();
            string priceStr = string.Format(@"{0} {1}", ccp.PayMoney, payMoneyCurrencySetData.Name);

            AuditResult_ApplyFee_GroupModel info = new AuditResult_ApplyFee_GroupModel()
            {
                TeamName = group.TeamName,
                Price = priceStr,
                GMAuditDate = "-"
            };

            DateTime gmAuditDt;
            bool bGMAuditDt = DateTime.TryParse(ccp.AuditGMDate, out gmAuditDt);
            info.GMAuditDate = gmAuditDt.ToString("yyyy-MM-dd HH:mm");

            if (ccp.IsAuditGM == 2)
            {
                info.Result = "总经理审核未通过";
                info.ResultColor = "warning";
            }

            //CTable
            #region CTable

            if (ccp.CTable == 76)//76,酒店预订
            {
                Grp_HotelReservations _HotelReservations = _grpDeleRep.Query<Grp_HotelReservations>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _HotelReservations.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "酒店预订";
                info.PriceName = _HotelReservations.HotelName;
            }
            else if (ccp.CTable == 79) //79://车/导游地接
            {
                Grp_CarTouristGuideGroundReservations _CarTouristGuideGroundReservations = _grpDeleRep.Query<Grp_CarTouristGuideGroundReservations>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _CarTouristGuideGroundReservations.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "车/导游地接";
                info.PriceName = _CarTouristGuideGroundReservations.PriceName;
            }
            else if (ccp.CTable == 80) //签证
            {
                List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
                Grp_VisaInfo _VisaInfos = _grpDeleRep.Query<Grp_VisaInfo>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _VisaInfos.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "签证";
                info.PriceName = getClientNameStr(clientNameList, _VisaInfos.VisaClient);
            }
            else if (ccp.CTable == 81)//邀请/公务活动
            {
                //默认增加王鸽ID
                userId.Add("149");//王鸽
                //userId.Add("208");//雷怡
                //userId.Add("5");//杨俊霄

                Grp_InvitationOfficialActivities _InvitationOfficialActivities = _grpDeleRep.Query<Grp_InvitationOfficialActivities>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep._sqlSugar.Queryable<Sys_Users>().First(s => s.Id == _InvitationOfficialActivities.CreateUserId);
                if (user != null)
                {
                    Sys_JobPost job = _grpDeleRep._sqlSugar.Queryable<Sys_JobPost>().First(s => s.Id == user.JobPostId);
                    info.CreateUser = string.Format(@"{0} - {1}", job?.JobName ?? "-", user.CnName);
                }


                info.PriceModule = "邀请/公务活动";
                info.PriceName = _InvitationOfficialActivities.InviterArea;
            }
            else if (ccp.CTable == 82)//团组客户保险
            {
                List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
                Grp_Customers _Customers = _grpDeleRep.Query<Grp_Customers>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _Customers.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "团组客户保险";
                info.PriceName = getClientNameStr(clientNameList, _Customers.ClientName);
            }
            else if (ccp.CTable == 85) //机票预订
            {
                Grp_AirTicketReservations _AirTicketReservations = _grpDeleRep.Query<Grp_AirTicketReservations>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _AirTicketReservations.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "机票预订";
                info.PriceName = "(" + _AirTicketReservations.FlightsCode + ")";
            }
            else if (ccp.CTable == 98) //其他款项
            {
                Grp_DecreasePayments _DecreasePayments = _grpDeleRep.Query<Grp_DecreasePayments>(s => s.Id == ccp.CId).First();

                Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _DecreasePayments.CreateUserId).First();
                Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
                info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);

                info.PriceModule = "其他款项";
                info.PriceName = _DecreasePayments.PriceName;
            }
            #endregion

            //发送信息
            List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.AuditResult_ApplyFee_User(info));

                if (ccp.IsAuditGM == 1)
                {
                    await SendChatMsg_GroupStatus_AuditFee(Grp_CreditCardPaymentId, qwEnum);
                }
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }
            return true;
        }

        /// <summary>
        /// 向指定用户发送-团组费用支付结果
        /// </summary>
        /// <param name="Grp_CreditCardPaymentId"></param>
        /// <param name="userId"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_GroupStatus_PayResult(int Grp_CreditCardPaymentId, List<string> userId)
        {
            //, QiyeWeChatEnum qiyeWeChat
            Grp_CreditCardPayment ccp = _grpDeleRep.Query<Grp_CreditCardPayment>(s => s.Id == Grp_CreditCardPaymentId).First();
            Grp_DelegationInfo group = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == ccp.DIId).First();

            Sys_SetData payMoneyCurrencySetData = _grpDeleRep.Query<Sys_SetData>(s => s.Id == ccp.PaymentCurrency).First();
            string priceStr = string.Format(@"{0} {1}", ccp.PayMoney, payMoneyCurrencySetData.Name);

            PayResult_Group_ToUserModel info = new PayResult_Group_ToUserModel()
            {
                PayDt = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
                Price = priceStr,
                TeamName = group.TeamName
            };

            #region CTable

            if (ccp.CTable == 76)//76,酒店预订
            {
                Grp_HotelReservations _HotelReservations = _grpDeleRep.Query<Grp_HotelReservations>(s => s.Id == ccp.CId).First();

                info.PriceModule = "酒店预订";
                info.PriceName = _HotelReservations.HotelName;
            }
            else if (ccp.CTable == 79) //79://车/导游地接
            {
                Grp_CarTouristGuideGroundReservations _CarTouristGuideGroundReservations = _grpDeleRep.Query<Grp_CarTouristGuideGroundReservations>(s => s.Id == ccp.CId).First();

                info.PriceModule = "车/导游地接";
                info.PriceName = _CarTouristGuideGroundReservations.PriceName;
            }
            else if (ccp.CTable == 80) //签证
            {
                List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
                Grp_VisaInfo _VisaInfos = _grpDeleRep.Query<Grp_VisaInfo>(s => s.Id == ccp.CId).First();

                info.PriceModule = "签证";
                info.PriceName = getClientNameStr(clientNameList, _VisaInfos.VisaClient);
            }
            else if (ccp.CTable == 81)//邀请/公务活动
            {
                Grp_InvitationOfficialActivities _InvitationOfficialActivities = _grpDeleRep.Query<Grp_InvitationOfficialActivities>(s => s.Id == ccp.CId).First();

                info.PriceModule = "邀请/公务活动";
                info.PriceName = _InvitationOfficialActivities.InviterArea;
            }
            else if (ccp.CTable == 82)//团组客户保险
            {
                List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
                Grp_Customers _Customers = _grpDeleRep.Query<Grp_Customers>(s => s.Id == ccp.CId).First();

                info.PriceModule = "团组客户保险";
                info.PriceName = getClientNameStr(clientNameList, _Customers.ClientName);
            }
            else if (ccp.CTable == 85) //机票预订
            {
                Grp_AirTicketReservations _AirTicketReservations = _grpDeleRep.Query<Grp_AirTicketReservations>(s => s.Id == ccp.CId).First();

                info.PriceModule = "机票预订";
                info.PriceName = "(" + _AirTicketReservations.FlightsCode + ")";
            }
            else if (ccp.CTable == 98) //其他款项
            {
                Grp_DecreasePayments _DecreasePayments = _grpDeleRep.Query<Grp_DecreasePayments>(s => s.Id == ccp.CId).First();

                info.PriceModule = "其他款项";
                info.PriceName = _DecreasePayments.PriceName;
            }
            #endregion

            //发送信息
            List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.PayResult_Group_ToUser(info));

                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }
            return true;
        }

        #endregion

        #region 团组出发、结束提醒（财务群）

        public static async Task<bool> SendChatMsg_GroupRemindersToCaiwu(List<Grp_DelegationInfo> list_7day, List<Grp_DelegationInfo> list_3day, List<Grp_DelegationInfo> list_minus1day, QiyeWeChatEnum qwEnum)
        {
            string chatId = qwEnum.GetEnumDescription();

            ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.GroupRemindersToCaiwuChat(list_7day, list_3day, list_minus1day));
            if (result.errcode != 0)
            {
                //抄送日志 
                return false;
            }

            return true;
        }

        #endregion

        #region 团组结束提醒（国交群）

        public static async Task<bool> SendChatMsg_GroupRemindersToGuojiao(List<Grp_DelegationInfo> list_3day, QiyeWeChatEnum qwEnum)
        {
            string chatId = qwEnum.GetEnumDescription();

            ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.GroupRemindersToGuojiao(list_3day));
            if (result.errcode != 0)
            {
                //抄送日志 
                return false;
            }

            return true;
        }

        #endregion

        #region 团组出发提醒(HR)

        public static async Task<bool> SendUserMsg_DelegationVisit_ToHR(List<Grp_DelegationInfo> list_3day, List<string> userId)
        {
            //发送信息
            List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.GroupRemindersToHR(list_3day));

                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }
            return true;
        }

        #endregion

        #region 市场部新增客户资源统计

        /// <summary>
        /// 周统计
        /// </summary>
        /// <param name="sourceList"></param>
        /// <param name="userId"></param>
        /// <param name="begin"></param>
        /// <param name="end"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_CRMStatistics_ToHR(List<CRMWeekStatisticsView> sourceList, List<string> userId, string begin, string end)
        {
            //发送信息
            List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.CRMStatistics_ToUser(sourceList, begin, end));

                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }
            return true;
        }

        /// <summary>
        /// 月统计
        /// </summary>
        /// <param name="sourceList"></param>
        /// <param name="userId"></param>
        /// <param name="begin"></param>
        /// <param name="end"></param>
        /// <param name="totalInsert"></param>
        /// <param name="totalDelete"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_CRMStatistics_Month_ToHR(List<CRMWeekStatisticsView> sourceList, List<string> userId, string begin, string end, int totalInsert, int totalDelete)
        {
            //发送信息
            List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.CRMStatistics_Month_ToUser(sourceList, begin, end, totalInsert, totalDelete));

                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }
            return true;
        }

        #endregion

        #region 日付申请审核

        /// <summary>
        ///  日付申请提交时推送财务群
        /// </summary>
        /// <param name="dailyPayId"></param>
        /// <param name="sign"></param>
        /// <param name="qwEnum"></param>
        /// <returns></returns>
        public static async Task<bool> DailyPayReminders_Create_ToCaiwuChat(int dailyPayId, int sign, QiyeWeChatEnum qwEnum)
        {
            string chatId = qwEnum.GetEnumDescription();
            Fin_DailyFeePayment fin_DailyFeePayment = _grpDeleRep.Query<Fin_DailyFeePayment>(s => s.Id == dailyPayId).First();

            Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == fin_DailyFeePayment.CreateUserId).First();
            Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
            string users = string.Format(@"{0}-{1}", job.JobName, user.CnName);

            string[] companyArr = new string[] { "未知", "成都泛美商务有限公司", "四川泛美交流有限公司", "成都纽茵教育科技有限公司", "成都鸿企中元科技有限公司", "测试公司1" };
            string companyStr = "未知";
            if (fin_DailyFeePayment.CompanyId < companyArr.Length)
            {
                companyStr = companyArr[fin_DailyFeePayment.CompanyId];
            }

            Sys_SetData sd_tansferType = _grpDeleRep.Query<Sys_SetData>(s => s.Id == fin_DailyFeePayment.TransferTypeId).First();
            Sys_SetData sd_priceType = _grpDeleRep.Query<Sys_SetData>(s => s.Id == fin_DailyFeePayment.PriceTypeId).First();
            string feeSignStr = string.Format(@"{0}-{1}", sd_tansferType.Name, sd_priceType?.Name ?? "");

            string priceStr = fin_DailyFeePayment.SumPrice.ToString("#0.00");

            DailyPayReminders_Create_ToCaiwuChatModel info = new DailyPayReminders_Create_ToCaiwuChatModel()
            {
                CreateDt = fin_DailyFeePayment.CreateTime.ToString("yyyy-MM-dd HH:mm"),
                CreateUser = users,
                Price = priceStr,
                Company = companyStr,
                FeeSign = feeSignStr,
                PriceName = fin_DailyFeePayment.Instructions

            };

            if (sign == 2) info.TitleStr = "[更新]一项费用待审核";

            ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.DailyPayReminders_Create_ToCaiwuChat(info));
            if (result.errcode != 0)
            {
                //抄送日志 
                return false;
            }

            return true;
        }

        /// <summary>
        /// 日付申请审核结果推送给申请人
        /// </summary>
        /// <param name="dailyPayId"></param>
        /// <param name="userId"></param>
        /// <param name="qwEnum"></param>
        /// <returns></returns>
        public static async Task<bool> DailyPayReminder_Audit_ToUser(int dailyPayId, List<string> userId, QiyeWeChatEnum qwEnum)
        {
            Fin_DailyFeePayment fin_DailyFeePayment = _grpDeleRep.Query<Fin_DailyFeePayment>(s => s.Id == dailyPayId).First();

            Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == fin_DailyFeePayment.CreateUserId).First();
            Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
            string users = string.Format(@"{0}-{1}", job.JobName, user.CnName);

            string priceStr = fin_DailyFeePayment.SumPrice.ToString("#0.00");

            DailyPayReminder_Audit_ToUserModel info = new DailyPayReminder_Audit_ToUserModel()
            {
                Price = priceStr,
                PriceName = fin_DailyFeePayment.Instructions
            };

            if (fin_DailyFeePayment.FAudit == 1)
            {
                info.AuditDate = fin_DailyFeePayment.MAuditDate.ToString("yyyy-MM-dd HH:mm");
                if (fin_DailyFeePayment.MAudit == 1)
                {
                    info.Result = "你有一笔日付申请已通过审核";
                    info.ResultColor = "info";

                    //发送至财务群

                    DailyPayReminder_Audit_ToCaiwuChatModel chatInfo = new DailyPayReminder_Audit_ToCaiwuChatModel()
                    {
                        AuditDate = info.AuditDate,
                        CreateUser = users,
                        Price = priceStr,
                        PriceName = fin_DailyFeePayment.Instructions
                    };

                    string chatId = qwEnum.GetEnumDescription();
                    await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.DailyPayReminder_Audit_ToCaiwuChat(chatInfo));
                }
                else if (fin_DailyFeePayment.MAudit == 2)
                {
                    info.Result = "你有一笔日付申请未通过总经理审核";
                    info.ResultColor = "warning";
                }
            }
            else if (fin_DailyFeePayment.FAudit == 2)
            {
                info.AuditDate = fin_DailyFeePayment.FAuditDate.ToString("yyyy-MM-dd HH:mm");
                info.Result = "你有一笔日付申请未通过财务审核";
                info.ResultColor = "warning";
            }
            List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.DailyPayReminder_Audit_ToUser(info));
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }

            return true;
        }

        /// <summary>
        /// 日付申请已付款推送给申请人
        /// </summary>
        /// <returns></returns>
        public static async Task<bool> DailyPayReminder_Pay_ToUser(int dailyPayId, List<string> userId)
        {
            Fin_DailyFeePayment fin_DailyFeePayment = _grpDeleRep.Query<Fin_DailyFeePayment>(s => s.Id == dailyPayId).First();
            string priceStr = fin_DailyFeePayment.SumPrice.ToString("#0.00");

            DailyPayReminder_Pay_ToUserModel info = new DailyPayReminder_Pay_ToUserModel()
            {
                PayDt = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
                PriceName = fin_DailyFeePayment.Instructions,
                Price = priceStr
            };
            List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.DailyPayReminder_Pay_ToUser(info));
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }
            return true;
        }

        #endregion

        #region 费用保存发送消息

        #region 三公费用更改通知

        /// <summary>
        /// 三公费用汇率大于实时汇率 通知发送(22、208、5)
        /// </summary>
        /// <param name="diId"></param>
        /// <param name="operationId"></param>
        /// <param name="msgContent"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_GroupShare_ToFin(int diId, int operationId, string msgContent)
        {
            var groupInfo = _grpDeleRep._sqlSugar.Queryable<Grp_DelegationInfo>().First(x => x.Id == diId);

            var operationName = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.Id == operationId).First()?.CnName ?? "Unknown";

            var defaultUserIds = new List<string>() { "208", "22", "5" };

            if (defaultUserIds.Count > 0)
            {
                List<string> qwUserIdList = GetQiyeChatUserIdList(defaultUserIds);

                string resMsg = string.Format(@" `三公费用异常通知 - 汇率预警`  

>团组：<font color='info'>{0}</font> 

>**汇率明细**   
{1}

>操作人员：<font color='comment'>{2}</font> 
>操作时间：<font color='comment'>{3}</font> 

[详细信息请前往OA系统查看](http://oa.pan-american-intl.com:4399/)   ", groupInfo?.TeamName ?? "-", msgContent, operationName, DateTime.Now.ToString("yyyy-MM-dd HH:mm"));


                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, resMsg);
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }

            return true;
        }

        #endregion

        #region 三公费用更改通知

        /// <summary>
        /// 三公费用更改通知发送总经理(21)
        /// </summary>
        /// <param name="diId"></param>
        /// <param name="receivedUserIds"></param>
        /// <param name="updateUserId"></param>
        /// <param name="url"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_GroupShare_ToGM(int diId, List<string> receivedUserIds, int updateUserId, string url)
        {

            Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();

            GroupShare_ToGMModel info = new GroupShare_ToGMModel()
            {
                RefreshDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
                TeamName = groupInfo?.TeamName ?? "-",
                CreateUser = _grpDeleRep.Query<Sys_Users>(s => s.Id == updateUserId).First()?.CnName ?? "-",
                Url = url
            };

            if (receivedUserIds.Count > 0)
            {
                List<string> qwUserIdList = GetQiyeChatUserIdList(receivedUserIds);
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.GroupShare_ToGM(info));
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }

            return true;
        }

        /// <summary>
        /// 三公费用确认通知发送财务部人员
        /// </summary>
        /// <param name="diId"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_GroupShare_ToFinance(int diId)
        {
            Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();

            GroupShare_ToUserModel info = new GroupShare_ToUserModel()
            {
                RefreshDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
                TeamName = groupInfo.TeamName
            };

            List<string> receivedUserIds = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.DepId == 3).Select(x => x.Id.ToString()).ToList();
            var defaultUserIds = new List<string>() { "208", "233" };
            receivedUserIds.AddRange(defaultUserIds);
            if (receivedUserIds.Contains("150")) receivedUserIds.Remove("150");

            if (receivedUserIds.Count > 0)
            {
                List<string> qwUserIdList = GetQiyeChatUserIdList(receivedUserIds);
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.GroupShare_ToFinance(info));
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }

            return true;
        }

        #endregion

        /// <summary>
        /// 机票行程代码录入变更通知发送国交经理、主管、王鸽
        /// </summary>
        /// <param name="diId"></param>
        /// <param name="operationId"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_GroupShare_ToDP(int diId, int operationId)
        {
            Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();

            var operationName = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.Id == operationId).First()?.CnName ?? "Unknown";
            var defaultJobPostIds = new List<int>() { 22, 32 };
            List<string> receivedUserIds = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.DepId == 7 && defaultJobPostIds.Contains(s.JobPostId)).Select(x => x.Id.ToString()).ToList();
            var defaultUserIds = new List<string>() { "208", "233" };
            receivedUserIds.AddRange(defaultUserIds);

            if (receivedUserIds.Count > 0)
            {
                List<string> qwUserIdList = GetQiyeChatUserIdList(receivedUserIds);

                string resMsg = string.Format(@" `机票行程代码已调整更新通知`  

>团组：<font color='info'>{0}</font> 

>操作人员：<font color='comment'>{1}</font> 
>操作时间：<font color='comment'>{2}</font> 

[详细信息请前往OA系统查看](http://oa.pan-american-intl.com:4399/)   ", groupInfo.TeamName, operationName, DateTime.Now.ToString("yyyy-MM-dd HH:mm"));


                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, resMsg);
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }

            return true;
        }


        #region 公务出访数据变更发送通知
        /// <summary>
        /// 机票行程代码录入变更通知发送国交经理、主管、王鸽、OP操作人员
        /// </summary>
        /// <param name="diId"></param>
        /// <param name="operationId"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_GroupShare_ToOP(int diId, int operationId)
        {
            Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();

            var operationName = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.Id == operationId).First()?.CnName ?? "Unknown";
            var defaultJobPostIds = new List<int>();
            List<string> receivedUserIds = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.DepId == 7 && s.JobPostId == 28).Select(x => x.Id.ToString()).ToList();
            var defaultUserIds = new List<string>() { "208", "233", "235" };
            receivedUserIds.AddRange(defaultUserIds);

            #region 添加对应的OP操作人员
            var groupModuleOperators = GeneralMethod.GetGroupModuleOperators(diId);
            var opUserIds = groupModuleOperators
            .Where(x => x.CTableId == 79)
            .FirstOrDefault()?
            .OperationUsers.Select(x => x.UserId.ToString())
            .ToList();
            receivedUserIds.AddRange(opUserIds ?? new List<string>());
            receivedUserIds = receivedUserIds.Distinct().ToList();
            #endregion

            if (receivedUserIds.Count > 0)
            {
                List<string> qwUserIdList = GetQiyeChatUserIdList(receivedUserIds);

                string resMsg = string.Format(@" `公务出访有数据更新通知`  

>团组：<font color='info'>{0}</font> 

>操作人员：<font color='comment'>{1}</font> 
>操作时间：<font color='comment'>{2}</font> 

[详细信息请前往OA系统查看](http://oa.pan-american-intl.com:4399/)   ", groupInfo.TeamName, operationName, DateTime.Now.ToString("yyyy-MM-dd HH:mm"));


                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, resMsg);
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }

            return true;
        }

        #endregion

        #endregion

        #region 成本通知

        /// <summary>
        /// 成本通知发送给对应岗位用户
        /// </summary>
        /// <param name="diId"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_GroupShare_ToJob(int diId)
        {
            Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();
            List<Sys_Users> list_user = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && (s.JobPostId == 24 || s.JobPostId == 25 || s.JobPostId == 28 || s.JobPostId == 23)).ToList();
            //List<Sys_Users> list_user = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && (s.JobPostId == 40 || s.JobPostId == 41)).ToList();
            List<string> userIds = new List<string>();
            list_user.ForEach(s => userIds.Add(s.Id.ToString()));

            userIds.Add("235");
            List<string> qwUserIdList = GetQiyeChatUserIdList(userIds);

            GroupShare_ToUserModel info = new GroupShare_ToUserModel()
            {
                RefreshDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
                TeamName = groupInfo.TeamName
            };

            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.GroupShare_ToUser(info));
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }

            return true;
        }

        public static async Task<bool> SendUserMsg_blackAirInfo_ToVisaUser(int diId, List<CountryDataTime> arr)
        {
            Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();

            var visaUser = _grpDeleRep.Query<Sys_Users>(x => x.IsDel == 0 && x.JobPostId == 26)
                .Select(x => x.Id)
                .ToList();

            List<string> userIds = new List<string>() { "235" };
            userIds.AddRange(visaUser.Select(x => x.ToString()));
            List<string> qwUserIdList = GetQiyeChatUserIdList(userIds);

            BlackCodeInfo_ToVisaUser info = new BlackCodeInfo_ToVisaUser()
            {
                RefreshDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
                TeamName = groupInfo.TeamName,
                info = arr
            };

            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.BlackCodeInfo_ToVisaUser(info));
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }

            return true;
        }

        public static async Task<bool> SendUserMsg_GroupTimeInfo_ToVisaUser(int diId, string startTime, string endTime)
        {
            Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();

            var visaUser = _grpDeleRep.Query<Sys_Users>(x => x.IsDel == 0 && x.JobPostId == 26)
                .Select(x => x.Id)
                .ToList();

            List<string> userIds = new List<string>() { "235" };
            userIds.AddRange(visaUser.Select(x => x.ToString()));
            List<string> qwUserIdList = GetQiyeChatUserIdList(userIds);

            GroupDateTime_ToVisaUser info = new GroupDateTime_ToVisaUser()
            {
                RefreshDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
                TeamName = groupInfo.TeamName,
                EndTime = endTime,
                StartTime = startTime,
            };

            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.GroupDateTime_ToVisaUser(info));
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }

            return true;
        }


        #region 机票群预算通知

        /// <summary>
        /// 机票群预算通知
        /// </summary>
        /// <param name="diId"></param>
        /// <param name="qwEnum"></param>
        /// <returns></returns>
        public static async Task<bool> SendChatMsg_AirCostChat(int diId, QiyeWeChatEnum qwEnum)
        {

            string chatId = qwEnum.GetEnumDescription();
            Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId && s.IsDel == 0).First();
            var groupcost = _grpDeleRep.Query<Grp_GroupCostParameter>(s => s.DiId == diId && s.IsDel == 0 && s.CostType == "A").First();

            var info = new GroupShare_ToAirUserModel()
            {
                TeamName = groupInfo.TeamName,
                RefreshDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
                AirCost = @$"
经济舱：{groupcost.JJCCB}元/人   {groupcost.JJCRS}人   共:{groupcost.JJCCB * groupcost.JJCRS}元
公务舱：{groupcost.GWCCB}元/人   {groupcost.GWCRS}人   共:{groupcost.GWCCB * groupcost.GWCRS}元"
            };

            ResponseBase result = await _qiYeWeChatApiService.
            GroupStatus_SendChatMsg_Markdown(chatId,
            MarkdownLib.GroupShare_ToAirUser(info));

            if (result.errcode != 0)
            {
                //抄送日志 
                return false;
            }

            return true;
        }


        #endregion

        #endregion

        #region 任务通知

        /// <summary>
        /// 任务通知
        /// </summary>
        /// <param name="userIds"></param>
        /// <param name="groupId"></param>
        /// <param name="title"></param>
        /// <param name="currUserId"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_Task_ToUser(List<string> userIds, int groupId, string title, int currUserId)
        {
            List<string> qwUserIdList = GetQiyeChatUserIdList(userIds);

            if (qwUserIdList.Any())
            {
                var groupName = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.IsDel == 0 && s.Id == groupId).First()?.TeamName ?? "未选择";
                var userName = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.Id == currUserId).First()?.CnName ?? "Unknown";
                var model = new TaskAssignment_Create_ToUserModel()
                {
                    GroupName = groupName,
                    Title = title,
                    CreateUser = userName,
                    RefreshDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm")
                };

                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.TaskAssignment_Create_ToUser(model));
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }

            return true;
        }
        #endregion

        #region 物资通知

        /// <summary>
        /// 物资领用通知
        /// 接收者：审核节点相关审核人
        /// </summary>
        /// <param name="dataId"></param>
        /// <param name="diId"></param>
        /// <param name="operationId"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_CompanyShare_ToHR(int dataId, int diId, int operationId)
        {
            //企微通知
            var userIds = new List<string>()
            {
                "208", //雷怡
                "374", //罗颖
            };

            var isCheckValuable = false;
            var valuableUserNames = new List<string>();

            //根据审核节点的审核人，发送通知
            var flow = _grpDeleRep._sqlSugar.Queryable<Sys_AuditFlow>().First(x => x.IsDel == 0 && x.BusinessType == 1 && x.BusinessId == dataId);
            if (flow != null)
            {
                var auditNode = _grpDeleRep._sqlSugar
                    .Queryable<Sys_AuditTemplateNode>()
                    .First(x => x.IsDel == 0 && x.TemplateId == flow.TemplateId && x.Id == flow.CurrentNodeId);
                if (auditNode != null)
                {
                    var auditUserList = _grpDeleRep._sqlSugar.Queryable<Sys_AuditTemplateNodeUser>()
                        .Where(x => x.IsDel == 0 && x.NodeId == auditNode.Id)
                        .Select(x => new
                        {
                            x.UserId,
                            x.UserName
                        })
                        .ToList();
                    if (auditUserList.Any())
                    {
                        if (auditUserList.Count > 1) isCheckValuable = true;

                        userIds.AddRange(auditUserList.Select(x => x.UserId.ToString()).ToList());
                        userIds = userIds.Distinct().ToList();
                        valuableUserNames.AddRange(auditUserList.Select(x => x.UserName).ToList());
                    }
                }
            }

            Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();
            var operationName = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.Id == operationId).First()?.CnName ?? "Unknown";

            var groupName = diId switch
            {
                0 => "其他物资(公司内部物资)",
                -1 => "拜访客户所使用的物资",
                -2 => "库存调整",
                _ => groupInfo?.TeamName ?? "-"
            };


            var receiveInfo = _grpDeleRep._sqlSugar.Queryable<Pm_GoodsReceive>().First(x => x.IsDel == 0 && x.Id == dataId);
            if (receiveInfo == null) return false;
            var receiveDetails = _grpDeleRep._sqlSugar
                .Queryable<Pm_GoodsReceiveDetails>()
                .LeftJoin<Pm_GoodsInfo>((x, y) => x.GoodsId == y.Id)
                .Where(x => x.IsDel == 0 && x.GoodsReceiveId == dataId)
                .Select((x, y) => new
                {
                    y.Name,
                    x.Quantity,
                    y.Unit
                })
                .ToList();

            if (!receiveDetails.Any()) return false;

            var goodsMsg = new StringBuilder();
            foreach (var info in receiveDetails)
            {
                goodsMsg.AppendLine($">- {info.Name}：{info.Quantity:#0.00} {info.Unit}");
            }

            var groupLabel = string.Empty;
            if (string.IsNullOrEmpty(groupName) || !groupName.Equals("-"))
            {
                groupLabel = $">团组归属：<font color='info'>{groupName}</font>";
            }

            //普通物品审批消息通知
            string resMsg = string.Format(@" ` 物资领用申请通知 `  

> ` {0} `提交物资领用申请： 

{1}

>**物资明细**   
{2}
>用途：<font color='comment'>{3}</font> 
>申请时间：<font color='comment'>{4}</font> 

[详细信息请前往OA系统查看](http://oa.pan-american-intl.com:4399/)   ",
operationName,
groupLabel,
goodsMsg,
receiveInfo.Reason,
DateTime.Now.ToString("yyyy-MM-dd HH:mm"));

            //贵重物品审批消息通知
            if (isCheckValuable)
            {
                var auditUserLabel = string.Empty;
                foreach (var userName in valuableUserNames)
                {
                    auditUserLabel += $"@{userName} ";
                }

                resMsg = string.Format(@" ` 【或签审批】物资领用（任一人审批即可）通知 `  

>{0}
> ` {1} `提交物资领用申请，您被列为或签审批人： 

**或签规则**  
• 您与其他{2}人并行审批  
• 任意一人通过即视为本环节通过  
• 任意一人拒绝即视为终止流程  

{3}

>**物资明细**   
{4}
>用途：<font color='comment'>{5}</font> 
>申请时间：<font color='comment'>{6}</font> 

[详细信息请前往OA系统查看](http://oa.pan-american-intl.com:4399/)   ",
auditUserLabel,
operationName,
valuableUserNames.Count - 1,
groupLabel,
goodsMsg,
receiveInfo.Reason,
DateTime.Now.ToString("yyyy-MM-dd HH:mm"));
            }

            List<string> qwUserIdList = GetQiyeChatUserIdList(userIds);
            ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, resMsg);
            if (result.errcode != 0)
            {
                //抄送日志 
                return false;
            }

            return true;
        }
        #endregion

        #region 日服申请 
        /// <summary>
        /// 日服申请、编辑通知
        /// 接收者：指定接收者
        /// </summary>
        /// <param name="dataId"></param>
        /// <param name="operationId">操作人Id</param>
        /// <param name="recipients">接收者Id集合</param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_CompanyShare_ToDailtPay(int dataId, int operationId, List<string> recipients)
        {
            //企微通知
            var userIds = recipients;

            string operationName = _grpDeleRep._sqlSugar.Queryable<Sys_Users>().First(x => x.IsDel
             == 0 && x.Id == operationId).CnName ?? "Unknown";

            var dailyPaymentInfo = await _grpDeleRep._sqlSugar.Queryable<Fin_DailyFeePayment>()
                .FirstAsync(x => x.IsDel == 0 && x.Id == dataId);

            var details = await _grpDeleRep._sqlSugar.Queryable<Fin_DailyFeePaymentContent>()
                .Where(x => x.IsDel == 0 && x.DFPId == dataId)
                .Select(x => new { x.PriceName, x.Quantity, x.Price })
                .ToListAsync();
            var detailsMsg = new StringBuilder();
            foreach (var info in details)
            {
                detailsMsg.AppendLine($">- {info.PriceName}：{info.Quantity:#0.00} * {info.Price:#0.00} = {info.Quantity * info.Price:#0.00} 元");
            }
            if (detailsMsg.Length == 0 || detailsMsg == null)
            {
                detailsMsg.Append("无费用明细");
            }


            //普通物品审批消息通知
            string resMsg = string.Format(@" ` 日付申请通知 `  

> ` {0} `提交费用申请： 

>**费用明细**   
{1}

>总金额：<font color='comment'>{2} 元</font> 
>申请说明：<font color='comment'>{3}</font> 
>申请时间：<font color='comment'>{4}</font> 

[详细信息请前往OA系统查看](http://oa.pan-american-intl.com:4399/)   ",
operationName,
detailsMsg.ToString(),
dailyPaymentInfo?.SumPrice.ToString("#0.00") ?? "0.00",
dailyPaymentInfo?.Instructions ?? "无申请说明",
DateTime.Now.ToString("yyyy-MM-dd HH:mm"));

            List<string> qwUserIdList = GetQiyeChatUserIdList(recipients);
            ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, resMsg);
            if (result.errcode != 0)
            {
                //抄送日志 
                return false;
            }

            return true;
        }
        #endregion

        #region OA任务通知
        public static async Task<bool> SendUserMsg_Task_ToUser(int taskOrderId, List<string> msgUserList, bool isNew)
        {
            msgUserList.Add("235");
            msgUserList = msgUserList.Distinct().ToList();
            List<string> qwUserIdList = GetQiyeChatUserIdList(msgUserList);
            var workOrder = _grpDeleRep._sqlSugar.Queryable<Task_WorkOrder>().First(x => x.IsDel == 0 && x.Id == taskOrderId);
            var task = _grpDeleRep._sqlSugar.Queryable<Task_WorkTask>().Where(x => x.IsDel == 0 && x.WorkOrderId == taskOrderId).ToList();

            TaskInfo_ToUser info = new TaskInfo_ToUser
            {
                isNew = isNew,
                TaskName = workOrder.Name,
                StartTime = workOrder.StartTime.ToString("yyyy-MM-dd HH:mm"),
                TaskCount = task.Count,
                UrgentCount = task.Count(x => x.IsUrgent)
            };

            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.TaskInfo_ToUser(info));
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }

            return true;
        }

        public static async Task<bool> SendUserMsg_TaskSubMit_ToUser(int taskId, List<string> msgUserList)
        {
            msgUserList.Add("235");
            msgUserList = msgUserList.Distinct().ToList();
            List<string> qwUserIdList = GetQiyeChatUserIdList(msgUserList);
            var task = _grpDeleRep._sqlSugar.
            Queryable<Task_WorkTask>().
            Includes(x => x.WorkOrder).
            First(x => x.IsDel == 0 && x.Id == taskId);

            TaskInfo_SubMit_ToUser info = new TaskInfo_SubMit_ToUser
            {
                TaskName = task.WorkOrder.Name + " - " + task.Name,
                StartTime = task.StartTime.ToString("yyyy-MM-dd HH:mm"),
                EndTime = task.EndTime?.ToString("yyyy-MM-dd HH:mm") ?? ""
            };

            if (qwUserIdList.Count > 0)
            {
                ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.TaskInfo_SubMit_ToUser(info));
                if (result.errcode != 0)
                {
                    //抄送日志 
                    return false;
                }
            }

            return true;
        }

        public static async Task<bool> SendUserMsg_TaskAudit_ToUser(int taskId, bool auditResult, string message, List<string> msgUserList)
        {
            msgUserList.Add("235");
            msgUserList = msgUserList.Distinct().ToList();
            List<string> qwUserIdList = GetQiyeChatUserIdList(msgUserList);

            var task = _grpDeleRep._sqlSugar.
            Queryable<Task_WorkTask>().
            Includes(x => x.WorkOrder).
            First(x => x.IsDel == 0 && x.Id == taskId);

            TaskInfo_Audit_ToUser info = new TaskInfo_Audit_ToUser
            {
                TaskName = task.WorkOrder.Name + " - " + task.Name,
                auditResult = auditResult,
                Message = message
            };

            ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.TaskInfo_Audit_ToUser(info));
            if (result.errcode != 0)
            {
                //抄送日志 
                return false;
            }

            return true;
        }

        #endregion

        #region 报批通知
        public static async Task<bool> SendUserMsg_BaoPi_ToUser(List<string> msgUserList, int diid)
        {
            var di = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.IsDel == 0 && s.Id == diid).First();
            if (di == null) return false;

            msgUserList.Add("235");
            msgUserList = msgUserList.Distinct().ToList();
            List<string> qwUserIdList = GetQiyeChatUserIdList(msgUserList);
            var resMsg = string.Format(@" ` 团组确认通知 `  
> {0}已确认，请进行下一步业务操作
- 客户单位：{1}
- 出访日期：{2}
- 天数：{3}
- 人数：{4}
",
di.TeamName,
di.ClientName,
di.VisitDate.ToString("yyyy-MM-dd"),
di.VisitDays,
di.VisitPNumber);

            ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, resMsg);
            if (result.errcode != 0)
            {
                throw new Exception(result.errmsg);
            }
            return true;

        }
        #endregion

        #region 团组超支费用通知
        public static async Task<bool> SendChatMsg_ExpenseOverrunsChat(int diId, int userid, int cTable, QiyeWeChatEnum qwEnum)
        {
            string chatId = qwEnum.GetEnumDescription();
            Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId && s.IsDel == 0).First();
            var operationName = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.Id == userid).First()?.CnName ?? "Unknown";
            var table = _grpDeleRep.Query<Sys_SetData>(s => s.IsDel == 0 && s.Id == cTable && s.STid == 16).First()?.Name ?? "Unknown";

            string markDown = @$"`团组超支费用通知`
>团组名称：<font color='info'> {groupInfo.TeamName} </font>
><font color='warning'>此团组{table}版块有超支费用产生（目前因票据未出，无法上传相应票据）</font>
>更新时间：{DateTime.Now.ToString("yyyy-MM-dd HH:mm")}
>更新人：{operationName}";

            ResponseBase result = await _qiYeWeChatApiService.
           GroupStatus_SendChatMsg_Markdown(chatId,
           markDown);

            if (result.errcode != 0)
            {
                //抄送日志 
                return false;
            }

            return true;
        }

        #endregion

        #region 团组流程节点任务通知、预警
        /// <summary>
        /// 团组流程节点任务通知
        /// 接收者：审核节点相关人 
        /// </summary>
        /// <param name="title"></param>
        /// <param name="groupName"></param>
        /// <param name="msgs"></param>
        /// <param name="qwUserIds"></param>
        /// <returns></returns>
        public static async Task<bool> SendUserMsg_GroupProcNode_Notif(string title, string groupName,List<string> msgs, List<string> qwUserIds)
        {
            //消息体 或者 接收人 集合为空，则不发送
            if (!msgs.Any() || !qwUserIds.Any())
            {
                return false;
            }

            var msgLabel = string.Join("\n", msgs);

            string resMsg = string.Format(@" ` {0} `  

> ` {1} `： 

> {2}

>通知时间：<font color='comment'>{3}</font> 

[详细信息请前往OA系统查看](http://oa.pan-american-intl.com:4399/)   ",
title,
groupName,
msgLabel,
DateTime.Now.ToString("yyyy-MM-dd HH:mm"));

            ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIds, resMsg);
            if (result.errcode != 0)
            {
                //抄送日志 
                return false;
            }

            return true;
        }
        

        #endregion

        #region Helper

        private static string getClientNameStr(List<SimplClientInfo> list, string origin)
        {
            string result = origin;

            if (Regex.Match(origin, @"\d +,?").Value.Length > 0)
            {
                string[] temparr = origin.Split(',');
                string fistrStr = temparr[0];
                int count = temparr.Length;

                int tempId;
                bool success = int.TryParse(fistrStr, out tempId);
                if (success)
                {
                    SimplClientInfo tempInfo = list.FirstOrDefault(s => s.Id == tempId);
                    if (tempInfo != null)
                    {
                        if (count > 1)
                        {
                            result = string.Format(@"{0}{1}等{2}人", tempInfo.LastName, tempInfo.FirstName, count);
                        }
                        else
                        {
                            result = string.Format(@"{0}{1}", tempInfo.LastName, tempInfo.FirstName);
                        }
                    }
                }
            }

            return result;
        }

        private static List<SimplClientInfo> getSimplClientList(int diId)
        {
            string sql = string.Format("select b.Id,b.Pinyin,b.lastName,b.firstName,b.phone from  Grp_TourClientList a, Crm_DeleClient b where a.clientid = b.id and a.isdel = 0 and a.diid = {0}", diId);
            List<SimplClientInfo> arr = _grpDeleRep._sqlSugar.SqlQueryable<SimplClientInfo>(sql).ToList();
            return arr;
        }

        #endregion

    }
}