OA2023/OASystem/OASystem.Api/Controllers/PersonnelModuleController.cs

using Aspose.Cells;
using Aspose.Words;
using FluentValidation;
using Microsoft.AspNetCore.SignalR;
using OASystem.API.OAMethodLib;
using OASystem.API.OAMethodLib.DeepSeekAPI;
using OASystem.API.OAMethodLib.Hub.HubClients;
using OASystem.API.OAMethodLib.Hub.Hubs;
using OASystem.API.OAMethodLib.QiYeWeChatAPI;
using OASystem.API.OAMethodLib.QiYeWeChatAPI.AppNotice;
using OASystem.Domain.Dtos.Groups;
using OASystem.Domain.Dtos.PersonnelModule;
using OASystem.Domain.Dtos.Statistics;
using OASystem.Domain.Entities.Groups;
using OASystem.Domain.Entities.PersonnelModule;
using OASystem.Domain.ViewModels.PersonnelModule;
using OASystem.Domain.ViewModels.QiYeWeChat;
using OASystem.Domain.ViewModels.Statistics;
using OASystem.Infrastructure.Repositories.Groups;
using OASystem.Infrastructure.Repositories.PersonnelModule;
using System.Data;
using System.Diagnostics;
using System.Globalization;
using static OASystem.API.OAMethodLib.JWTHelper;
using Markdig;
using Dm.util;

namespace OASystem.API.Controllers
{
    /// <summary>
    /// 人事模块
    /// </summary>
    [Route("api/[controller]/[action]")]
    public class PersonnelModuleController : ControllerBase
    {
        private Result _result;
        private readonly IMapper _mapper;
        //private readonly decimal _chengDuMinimumWage = 2100.00M;
        private readonly IQiYeWeChatApiService _qiYeWeChatApiService;
        private readonly WageSheetRepository _wageSheetRep;
        private readonly UsersRepository _usersRep;
        private readonly TaskAllocationRepository _taskAllocationRep;
        private readonly SqlSugarClient _sqlSugar;

        private readonly IHubContext<ChatHub, IChatClient> _hubContext;
        private readonly GoodsRepository _goodsRep;
        private readonly DecreasePaymentsRepository _otherPaymentRep;
        private readonly FeeAuditRepository _feeAuditRep;
        private readonly IDeepSeekService _deepSeekService;

        private readonly string url;
        private readonly string path;

        /// <summary>
        /// 初始化
        /// </summary>
        /// <param name="qiYeWeChatApiService"></param>
        /// <param name="wageSheetRep"></param>
        /// <param name="usersRep"></param>
        /// <param name="mapper"></param>
        /// <param name="taskAllocationRep"></param>
        /// <param name="hubContext"></param>
        /// <param name="goodsRep"></param>
        /// <param name="sqlSugar"></param>
        /// <param name="otherPaymentRep"></param>
        /// <param name="feeAuditRep"></param>
        /// <param name="deepSeekService"></param>
        public PersonnelModuleController(
            IHubContext<ChatHub, IChatClient> hubContext,
            IMapper mapper,
            IQiYeWeChatApiService qiYeWeChatApiService,
            WageSheetRepository wageSheetRep,
            UsersRepository usersRep,
            TaskAllocationRepository taskAllocationRep,
            GoodsRepository goodsRep,
            SqlSugarClient sqlSugar,
            DecreasePaymentsRepository otherPaymentRep,
            FeeAuditRepository feeAuditRep,
            IDeepSeekService deepSeekService
            )
        {
            _mapper = mapper;
            _usersRep = usersRep;
            _qiYeWeChatApiService = qiYeWeChatApiService;
            _wageSheetRep = wageSheetRep;
            _result = new Result();

            _sqlSugar = sqlSugar;

            url = AppSettingsHelper.Get("ExcelBaseUrl");
            path = AppSettingsHelper.Get("ExcelBasePath");
            if (!System.IO.Directory.Exists(path))
            {
                System.IO.Directory.CreateDirectory(path);//不存在就创建文件夹
            }

            this._taskAllocationRep = taskAllocationRep;
            _hubContext = hubContext;
            _goodsRep = goodsRep;
            _otherPaymentRep = otherPaymentRep;
            _feeAuditRep = feeAuditRep;
            _deepSeekService = deepSeekService;
        }

        #region 工资表单

        /// <summary>
        /// 工资 月列表
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GetWageSheetMonth()
        {
            string sql = string.Format("Select * From  Pm_WageIssueWorkingDay Where IsDel = 0 Order By YearMonth Desc");
            var data = await _wageSheetRep._sqlSugar.SqlQueryable<WageSheetMonthView>(sql).ToListAsync();

            return Ok(JsonView(true, "查询成功!", data));
        }

        /// <summary>
        /// 工资 工作日信息
        /// 查询
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GetWageSheetMonthWorkdays(string startDt, string endDt)
        {
            //参数处理
            var dtFormat = "yyyy-MM-dd";
            var startDtIsValid = DateTime.TryParseExact(startDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out _);
            var endDtIsValid = DateTime.TryParseExact(endDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out _);

            if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式：yyyy-MM-dd  "));
            if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式：yyyy-MM-dd  "));

            string sql = string.Format(@"Select  * From Sys_Calendar Where Isdel = 0 And Dt between  '{0}' And  '{1}'", startDt, endDt);
            var data = await _sqlSugar.SqlQueryable<CalendarInfoView>(sql).ToListAsync();

            return Ok(JsonView(true, "查询成功!", data));

        }

        /// <summary>
        /// 工资 工作日信息
        /// 编辑
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GetWageSheetMonthWorkdaysAddOrEdit(WageSheetMonthWorkdaysAddOrEditDto dto)
        {
            //参数处理
            string yearFormat = "yyyy-MM";
            string dtFormat = "yyyy-MM-dd";
            bool yearDtIsValid = DateTime.TryParseExact(dto.YearMonth, yearFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime yearDt);
            bool startDtIsValid = DateTime.TryParseExact(dto.StartDate, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime startDt1);
            bool endDtIsValid = DateTime.TryParseExact(dto.EndDate, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime endDt1);


            if (!yearDtIsValid) return Ok(JsonView(false, "年月日期格式错误!正确时间格式：yyyy-MM  "));
            if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式：yyyy-MM-dd  "));
            if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式：yyyy-MM-dd  "));

            #region 处理数据
            Pm_WageIssueWorkingDay pm_WageIssueWorkingDay1 = new();
            pm_WageIssueWorkingDay1 = _mapper.Map<Pm_WageIssueWorkingDay>(dto);
            List<Sys_Calendar> sys_Calendars = new();
            sys_Calendars = _mapper.Map<List<Sys_Calendar>>(dto.CalendarInfos);
            if (sys_Calendars.Count > 0)
            {
                sys_Calendars = sys_Calendars.OrderBy(it => it.Dt).ToList();
            }

            pm_WageIssueWorkingDay1.Workdays = sys_Calendars.Where(it => it.IsWorkDay == true).ToList().Count;
            foreach (var item in sys_Calendars)
            {
                item.Remark = pm_WageIssueWorkingDay1.Remark;
                item.CreateUserId = pm_WageIssueWorkingDay1.CreateUserId;
                item.CreateTime = pm_WageIssueWorkingDay1.CreateTime;
            }

            #endregion

            var _sqlSugar = _wageSheetRep._sqlSugar;
            _sqlSugar.BeginTran();

            try
            {
                List<Sys_Calendar> sys_Calendars_add = new();
                List<Sys_Calendar> sys_Calendars_update = new();
                sys_Calendars_add = sys_Calendars.Where(it => it.Id == 0).OrderBy(it => it.Dt).ToList();
                sys_Calendars_update = sys_Calendars.Where(it => it.Id != 0).OrderBy(it => it.Dt).ToList();

                //int add1 = 0;
                //int upd = 0;
                if (sys_Calendars_add.Count > 0)
                {
                    var calendarsAdd = await _sqlSugar.Insertable(sys_Calendars_add).ExecuteReturnIdentityAsync();

                    if (calendarsAdd < 0)
                    {
                        _sqlSugar.RollbackTran();
                        return Ok(JsonView(false, "工作日/节假日/休息日添加失败!"));
                    }
                }
                if (sys_Calendars_update.Count > 0)
                {
                    var calendarsUpdate = await _sqlSugar.Updateable<Sys_Calendar>(sys_Calendars)
                    .UpdateColumns(it => new { it.Dt, it.IsWorkDay, it.IsHoliDay, it.HoliName })
                    .WhereColumns(it => it.Id)
                    .ExecuteCommandAsync();
                    if (calendarsUpdate < 0)
                    {
                        _sqlSugar.RollbackTran();
                        return Ok(JsonView(false, "工作日/节假日/休息日编辑失败!"));
                    }
                }

                var calendarsDatas = await _sqlSugar.Queryable<Sys_Calendar>()
                    .Where(it => Convert.ToDateTime(it.Dt) >= Convert.ToDateTime(dto.StartDate) && Convert.ToDateTime(it.Dt) <= Convert.ToDateTime(dto.EndDate)).ToListAsync();
                if (calendarsDatas.Count < 0)
                {
                    _sqlSugar.RollbackTran();
                    return Ok(JsonView(false, "日期包暂无工作日/节假日/休息日的信息!"));
                }
                //月份表是否存在
                Pm_WageIssueWorkingDay pm_WageIssueWorkingDay = new()
                {
                    YearMonth = dto.YearMonth,
                    StartDate = dto.StartDate,
                    EndDate = dto.EndDate,
                    Workdays = calendarsDatas.Where(it => it.IsWorkDay == true).ToList().Count
                };

                string sql = string.Format("Select * From Pm_WageIssueWorkingDay Where Isdel = 0 And YearMonth='{0}'", dto.YearMonth);
                var workdsys = await _sqlSugar.SqlQueryable<Pm_WageIssueWorkingDay>(sql).FirstAsync();

                pm_WageIssueWorkingDay.CreateUserId = dto.UserId;
                pm_WageIssueWorkingDay.IsDel = 0;

                if (workdsys == null) //添加
                {
                    int addId = await _sqlSugar.Insertable(pm_WageIssueWorkingDay).ExecuteReturnIdentityAsync();
                    if (addId < 0)
                    {
                        _sqlSugar.RollbackTran();
                        return Ok(JsonView(false, "工作日设置添加失败!"));
                    }
                }
                else //更新
                {
                    int updCount = await _sqlSugar.Updateable(pm_WageIssueWorkingDay)
                        .IgnoreColumns(z => new { z.CreateUserId, z.CreateTime, z.DeleteUserId, z.DeleteTime, z.IsDel })
                        .WhereColumns(it => it.YearMonth)
                        .ExecuteCommandAsync();
                    if (updCount < 0)
                    {
                        _sqlSugar.RollbackTran();
                        return Ok(JsonView(false, "工作日设置编辑失败!"));
                    }
                }

                _sqlSugar.CommitTran();


                return Ok(JsonView(true, "操作成功!"));
            }
            catch (Exception ex)
            {
                _sqlSugar.RollbackTran();
                return Ok(JsonView(false, ex.Message));
            }


        }

        /// <summary>
        /// 工资表单 基础数据源
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GetWageSheetBasicsDataSource()
        {
            string companySql = string.Format("Select * From Sys_Company Where IsDel = 0");
            var compnayData = await _wageSheetRep._sqlSugar.SqlQueryable<CompanyNameView>(companySql).ToListAsync();

            string depSql = string.Format("Select * From Sys_Department Where IsDel = 0");
            var depData = await _wageSheetRep._sqlSugar.SqlQueryable<Domain.ViewModels.System.DepartmentView>(depSql).ToListAsync();

            //获取OA系统内所有用户
            var nameData = await _usersRep.GetUserNameList(1);

            if (nameData.Code != 0)
            {
                return Ok(JsonView(false, nameData.Msg));
            }

            var data = new
            {
                compnayData,
                depData,
                userNames = nameData.Data
            };


            return Ok(JsonView(true, "查询成功!", data));
        }

        /// <summary>
        /// 获取工资发放月份
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GetWageYaerMonths(WageYearDto dto)
        {
            string sql = string.Format(@"Select * From  Pm_WageIssueWorkingDay 
                                         Where Isdel = 0 And YearMonth Like '%{0}%'
                                         Order By YearMonth Asc", dto.Year);

            var data = await _wageSheetRep._sqlSugar.SqlQueryable<WageYearMonthView>(sql).ToListAsync();


            return Ok(JsonView(true, "操作成功!", data));
        }

        /// <summary>
        /// 获取工资表单
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GetWageSheetList(WageSheetListDto dto)
        {
            if (string.IsNullOrEmpty(dto.YearMonth)) return Ok(JsonView(false, "请选择日期格式"));

            //验证日期格式
            if (!DateTime.TryParse(dto.YearMonth, out DateTime yearMonthDt))
            {
                return Ok(JsonView(false, "无效的日期格式"));
            }

            //参数处理
            //string ymFormat = "yyyy-MM";
            //bool yearMonthDttIsValid = DateTime.TryParseExact(dto.YearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime yearMonthDt);
            //if (!yearMonthDttIsValid)
            //{
            //    _result.Msg = "年月格式错误!正确时间格式：yyyy-MM  ";
            //    return Ok(JsonView(false, _result.Msg));
            //}

            //获取月工资数据
            string yearMonth = yearMonthDt.ToString("yyyy-MM");

            if (dto.PortType == 1)
            {
                _result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(yearMonth);
                if (_result.Code != 0)
                {
                    return Ok(JsonView(false, _result.Msg));
                }
            }
            else if (dto.PortType == 2)
            { }
            else if (dto.PortType == 3)
            { }
            else
            {
                return Ok(JsonView(false, "请选择正确的端口参数"));
            }

            return Ok(JsonView(true, _result.Msg, _result.Data));
        }

        /// <summary>
        /// 获取工资 详情
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GetWageSheetById(WageSheetInfoDto dto)
        {
            if (dto.PortType == 1)
            {
                _result = await _wageSheetRep.Get_WageSheet_InfoByIdAsync(dto.Id);
                if (_result.Code != 0)
                {
                    return Ok(JsonView(false, _result.Msg));
                }
            }
            else if (dto.PortType == 2)
            { }
            else if (dto.PortType == 3)
            { }
            else
            {
                return Ok(JsonView(false, "请选择正确的端口参数"));
            }

            return Ok(JsonView(true, _result.Msg, _result.Data));
        }

        /// <summary>
        /// 人事模块 工资表单 删除
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostWageSheetDel(WageDelDto dto)
        {
            try
            {
                _result = await _wageSheetRep.Post_WageSheet_DelAsync(dto);
                if (_result.Code != 0)
                {
                    return Ok(JsonView(false, _result.Msg));

                }
            }
            catch (Exception ex)
            {

                return Ok(JsonView(false, ex.Message));
            }

            return Ok(JsonView(true, _result.Msg, _result.Data));
        }

        /// <summary>
        /// 人事模块 工资表单 添加 Or 修改
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostWageSheetAddOrEdit(WageAddOrEditDto dto)
        {
            try
            {
                Pm_WageSheet pm_WageSheet = new();
                pm_WageSheet = _mapper.Map<Pm_WageSheet>(dto);
                pm_WageSheet.LastUpdateUserId = dto.CreateUserId;

                #region 计算工资

                //月工资
                decimal salary = pm_WageSheet.Basic + pm_WageSheet.Floats + pm_WageSheet.PostAllowance + pm_WageSheet.InformationSecurityFee + pm_WageSheet.OtherSubsidies;
                //扣款合计
                decimal totalDeduction = pm_WageSheet.SickLeave + pm_WageSheet.SomethingFalse + pm_WageSheet.LateTo + pm_WageSheet.LeaveEarly + pm_WageSheet.Absenteeism + pm_WageSheet.NotPunch +
                                         pm_WageSheet.ReservedFunds + pm_WageSheet.WithholdingInsurance + pm_WageSheet.OtherDeductions + pm_WageSheet.OtherDeductions;

                //实发合计 不含个税
                if (pm_WageSheet.RegularDays >= pm_WageSheet.WorkDays)
                {
                    pm_WageSheet.RegularDays = pm_WageSheet.WorkDays;
                    salary = salary + pm_WageSheet.Mealsupplement + pm_WageSheet.OtherHandle;
                }
                else
                {
                    if (dto.UserId == 21) //21==张海麟
                    {
                        salary = salary + pm_WageSheet.Mealsupplement + pm_WageSheet.OtherHandle;
                    }
                    else
                    {
                        salary = PayrollComputation.ConvertToDecimal(salary / pm_WageSheet.WorkDays * pm_WageSheet.RegularDays + pm_WageSheet.Mealsupplement + pm_WageSheet.OtherHandle);
                    }
                }

                decimal actualTotal = salary - totalDeduction;
                pm_WageSheet.Should = salary;
                pm_WageSheet.TotalDeductions = totalDeduction;
                pm_WageSheet.TotalRealHair = actualTotal - pm_WageSheet.WithholdingTax;
                pm_WageSheet.AfterTax = actualTotal - pm_WageSheet.WithholdingTax;

                #endregion


                _result = await _wageSheetRep.Post_WageSheet_AddOrEditAsync(dto, pm_WageSheet);
                if (_result.Code != 0)
                {
                    return Ok(JsonView(false, _result.Msg));
                }
            }
            catch (Exception ex)
            {

                return Ok(JsonView(false, ex.Message));
            }

            return Ok(JsonView(true, _result.Msg, _result.Data));
        }

        /// <summary>
        /// 计算工资
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> SalaryCalculatorAsync(SalaryCalculatorDto dto)
        {
            Result result = new();
            Stopwatch sw = new();
            sw.Start();
            //参数处理
            string ymFormat = "yyyy-MM";
            string dtFormat = "yyyy-MM-dd";
            bool yearMonthDtIsValid = DateTime.TryParseExact(dto.yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime yearMonthDt);
            bool startDtIsValid = DateTime.TryParseExact(dto.startDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime startDt);
            bool endDtIsValid = DateTime.TryParseExact(dto.endDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime endDt);

            if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式：yyyy-MM  "));
            if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式：yyyy-MM-dd  "));
            if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式：yyyy-MM-dd  "));

            string thisYearMonth = dto.yearMonth;
            string preYearMonth = yearMonthDt.AddMonths(-1).ToString("yyyy-MM");

            //计算本月工资起止时间 比如是2月的1号-28号，那就是2月1号的零点到3月1号的零点 
            DateTime thisStartDt = startDt;
            DateTime thisEndDt = endDt; //

            //本月工资是否有数据 有数据则不计算
            result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(thisYearMonth);
            if (result.Code == 0)
            {
                return Ok(JsonView(false, thisYearMonth + " 工资数据已存在,若无人员工资请手动添加!"));
            }

            //获取上个月工资信息
            List<Pm_WageSheet> preWageSheetItems = await _wageSheetRep._sqlSugar.Queryable<Pm_WageSheet>().Where(it => it.IsDel == 0 && it.YearMonth == preYearMonth).ToListAsync();
            preWageSheetItems = preWageSheetItems.OrderBy(it => it.UserId).ToList();
            if (preWageSheetItems.Count <= 0)
            {
                return Ok(JsonView(false, thisYearMonth + " 上月工资数据不存在,请手动添加!"));
            }
            //处理上个月同月同人 多条数据
            List<Pm_WageSheet> preWageSheetItems1 = new();
            //preWageSheetItems1 = preWageSheetItems.GroupBy(it => new { it.YearMonth, it.UserId })
            //                                      .Select(it => it.FirstOrDefault(item => item.Basic != 0))
            //                                      .ToList();
            preWageSheetItems1 = preWageSheetItems
                .GroupBy(it => new { it.YearMonth, it.UserId })
                .Select(it => it.FirstOrDefault(item => item.Basic != 0))
                .Where(it => it != null)
                .ToList()!;

            //获取OA系统内所有用户
            List<UserNameView> userNames = _usersRep._sqlSugar.SqlQueryable<UserNameView>("Select Id,CnName From Sys_Users").ToList();

            List<Pm_WageSheet> wageSheets = new();

            _result = await PayrollComputation.SalaryCalculatorAsync(preWageSheetItems1, userNames, dto.UserId, thisYearMonth, thisStartDt, thisEndDt);

            #region 批量添加

            if (_result.Code != 0)
            {
                return Ok(JsonView(false, _result.Msg));
            }

            wageSheets = _result.Data;

            var add = await _wageSheetRep._sqlSugar.Insertable(wageSheets).ExecuteCommandAsync();
            if (add <= 0)
            {
                return Ok(JsonView(false, "操作失败!"));
            }

            #endregion

            #region 处理返回数据
            //List <WageSheetItemInfoView> wageSheetItems = new List<WageSheetItemInfoView>();
            //wageSheetItems = _mapper.Map<List<WageSheetItemInfoView>>(wageSheets);
            //wageSheetItems = wageSheetItems.Select(it => 
            //        {
            //            UserNameView? uName1 = new UserNameView();
            //            UserNameView? uName2 = new UserNameView();
            //            uName1 = userNames.Where(it1 => it.UserId == it1.Id).FirstOrDefault();
            //            if (uName1 != null)  it.Name = uName1.CnName;

            //            uName2 = userNames.Where(it1 => it.LastUpdateUserId == it1.Id).FirstOrDefault();
            //            if (uName2 != null) it.LastUpdateUserName = uName2.CnName;

            //            return it; }
            //        ).ToList();
            #endregion

            sw.Stop();
            return Ok(JsonView(true, "操作成功! 耗时：" + (sw.ElapsedMilliseconds / 1000) + "s"));
        }

        /// <summary>
        /// 计算工资 By YearMonth And UserId
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> SalaryCalculatorSingleAsync(SalaryCalculatorSingleDto dto)
        {
            Result result = new();
            Stopwatch sw = new();
            sw.Start();

            //参数处理
            string ymFormat = "yyyy-MM";
            string ymdFormat = "yyyy-MM-dd";
            bool yearMonthDtIsValid = DateTime.TryParseExact(dto.YearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime yearMonthDt);
            bool startDtIsValid = DateTime.TryParseExact(dto.StartDate, ymdFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime startDt);
            bool endDtIsValid = DateTime.TryParseExact(dto.EndDate, ymdFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime endDt);

            if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式：yyyy-MM  "));

            if (!startDtIsValid) return Ok(JsonView(false, "开始时间格式错误!正确时间格式：yyyy-MM-dd  "));

            if (!yearMonthDtIsValid) return Ok(JsonView(false, "结束时间格式错误!正确时间格式：yyyy-MM-dd  "));

            List<Pm_WageSheet> wageSheets = new();
            Pm_WageSheet wageSheet = _mapper.Map<Pm_WageSheet>(dto);
            Pm_WageSheet wageSheet1 = await _wageSheetRep._sqlSugar.Queryable<Pm_WageSheet>().Where(it => it.UserId == dto.UserId && it.YearMonth == dto.YearMonth && it.StartDate == dto.StartDate && it.EndDate == dto.EndDate).FirstAsync();
            if (wageSheet1 != null)
            {
                wageSheet.Id = wageSheet1.Id;
            }

            wageSheets.Add(wageSheet);
            //获取OA系统内所有用户
            List<UserNameView> userNames = _usersRep._sqlSugar.SqlQueryable<UserNameView>("Select Id,CnName From Sys_Users").ToList();

            _result = await PayrollComputation.SalaryCalculatorAsync(wageSheets, userNames, dto.UserId, dto.YearMonth, startDt, endDt);

            if (_result.Code != 0)
            {
                return Ok(JsonView(false, _result.Msg));
            }

            List<Pm_WageSheet> wageSheets1 = new();
            wageSheets1 = _result.Data;

            #region 处理返回数据

            List<WageSheetInfoView> wageSheetItems = new();
            wageSheetItems = _mapper.Map<List<WageSheetInfoView>>(wageSheets1);
            wageSheetItems = wageSheetItems.Select(it =>
                {
                    UserNameView? uName1 = new();
                    UserNameView? uName2 = new();
                    uName1 = userNames.Where(it1 => it.UserId == it1.Id).FirstOrDefault();
                    if (uName1 != null) it.Name = uName1.CnName;

                    uName2 = userNames.Where(it1 => it.LastUpdateUserId == it1.Id).FirstOrDefault();
                    if (uName2 != null) it.LastUpdateUserName = uName2.CnName;

                    return it;
                }
            ).ToList();
            #endregion

            sw.Stop();
            return Ok(JsonView(true, "操作成功!耗时：" + (sw.ElapsedMilliseconds / 1000) + "s", wageSheetItems[0]));


        }

        /// <summary>
        /// 导出工资单
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> ExportWageCard(string yearMonth)
        {
            Stopwatch sw = new();
            sw.Start();

            //参数处理
            string ymFormat = "yyyy-MM";
            bool yearMonthDtIsValid = DateTime.TryParseExact(yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out _);

            if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式：yyyy-MM  "));
            //公司部门
            string sql = string.Format(@"Select row_number() over(order by pm_ws.Id) as Row_Number,
                                            sc.Id as CompanyId,sc.CompanyName,sd.Id as DepId,sd.DepName, 
                                            sys_u1.CnName Name,sys_u2.CnName LastUpdateUserName,pm_ws.* 
                                         From Pm_WageSheet pm_ws
                                         Left Join Sys_Users sys_u1 On pm_ws.UserId = sys_u1.Id
                                         Left Join Sys_Users sys_u2 On pm_ws.LastUpdateUserId = sys_u2.Id
                                         Left Join Sys_Company sc On  sys_u1.companyId = sc.Id
                                         Left Join Sys_Department sd On sys_u1.DepId = sd.Id
                                         Where pm_ws.IsDel = 0 And pm_ws.YearMonth = '{0}'", yearMonth);
            var wageSheetList = await _wageSheetRep._sqlSugar.SqlQueryable<ExportWageSheetItemView>(sql).ToListAsync();

            if (wageSheetList.Count <= 0)
            {
                return Ok(JsonView(false, yearMonth + "暂无工资数据!"));
            }

            decimal SumPrice = 0.00M;
            foreach (var item in wageSheetList)
            {
                SumPrice += item.AfterTax;
            }

            WorkbookDesigner designer = new()
            {
                Workbook = new Workbook(AppSettingsHelper.Get("ExcelBasePath") + "Template/工资详细清单.xlsx")
            };
            designer.Workbook.Worksheets[0].Name = yearMonth + " 工资单";
            designer.SetDataSource("WageSheet", wageSheetList);
            designer.SetDataSource("YearMonth", yearMonth);
            designer.SetDataSource("StartEndDt", wageSheetList[0].StartDate + " - " + wageSheetList[0].EndDate);
            designer.SetDataSource("WorkDays", wageSheetList[0].WorkDays);
            designer.SetDataSource("SumPrice", SumPrice);
            designer.SetDataSource("WageSheetTitle", "工资单");//
            designer.Process();

            string fileName = "WageCard/" + yearMonth + "_工资单_" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".xlsx";
            string path = AppSettingsHelper.Get("ExcelBasePath");
            designer.Workbook.Save(path + fileName);
            string excelPath = AppSettingsHelper.Get("ExcelFtpPath") + fileName;
            string url = AppSettingsHelper.Get("ExcelBaseUrl");
            string fileUrl = url + excelPath;

            sw.Stop();
            return Ok(JsonView(true, "操作成功!耗时：" + (sw.ElapsedMilliseconds / 1000) + "s", new { FileUrl = fileUrl }));
        }

        /// <summary>
        /// 下载个税模板
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> WageSheetTaxTemplate()
        {
            //string serverUrl = AppSettingsHelper.Get("WageSheetExcelBaseUrl");
            var userData = await _usersRep.GetUserNameList(1);

            if (userData.Code == 0)
            {
                var userNames = userData.Data;

                List<string> names = new()
                {
                    "管理员",
                    "国交共享号",
                    "人事审核号",
                    "国交主管号"
                };

                List<TaxTemlateViuw> taxs = new();
                List<UserNameView> users = JsonConvert.DeserializeObject<List<UserNameView>>(JsonConvert.SerializeObject(userNames));

                foreach (UserNameView item in users)
                {
                    string uName = item.CnName;
                    if (!names.Contains(uName))
                    {
                        taxs.Add(new TaxTemlateViuw { UserName = item.CnName });
                    }
                }

                if (taxs.Count > 0)
                {
                    WorkbookDesigner designer = new()
                    {
                        Workbook = new Workbook(AppSettingsHelper.Get("ExcelBasePath") + "Template/个税导入模板.xlsx")
                    };
                    designer.Workbook.Worksheets[0].Name = "个税模板";
                    designer.SetDataSource("TaxTemp", taxs);
                    designer.Process();

                    string fileName = "WageSheetTaxFile/个税模板" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".xlsx";
                    string path = AppSettingsHelper.Get("ExcelBasePath");
                    designer.Workbook.Save(path + fileName);
                    string excelPath = AppSettingsHelper.Get("ExcelFtpPath") + fileName;
                    string url = AppSettingsHelper.Get("ExcelBaseUrl");
                    string fileUrl = url + excelPath;
                    return Ok(JsonView(true, "操作成功!", new { FileUrl = fileUrl }));
                }
            }
            return Ok(JsonView(false, "操作失败!"));
        }

        /// <summary>
        /// 上传个税
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> UploadTax(IFormFile file)
        {
            try
            {
                var yearMonth = Request.Headers["YearMonth"].ToString();
                //string yearMonth = "2023-10";
                string ymFormat = "yyyy-MM";
                bool yearMonthDtIsValid = DateTime.TryParseExact(yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime yearMonthDt);
                if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式：yyyy-MM  "));
                if (file != null)
                {
                    var fileDir = AppSettingsHelper.Get("WageSheetExcelFptPath");
                    //文件名称
                    string projectFileName = file.FileName;

                    //上传的文件的路径
                    string filePath = "";


                    if (!Directory.Exists(fileDir))
                    {
                        Directory.CreateDirectory(fileDir);
                    }

                    //上传的文件的路径
                    filePath = fileDir + $@"\{projectFileName}";

                    if (System.IO.File.Exists(filePath))
                    {
                        //删除文件
                        System.IO.File.Delete(filePath);
                    }

                    using (FileStream fs = System.IO.File.Create(filePath))
                    {
                        file.CopyTo(fs);
                        fs.Flush();
                    }

                    if (System.IO.File.Exists(filePath))
                    {
                        Workbook book = new(filePath);
                        DataSet dataSet = new();
                        if (book.Worksheets.Count > 0)
                        {
                            var sheet = book.Worksheets[0];

                            if (sheet != null)
                            {
                                // sheets 中的数据必须存在
                                if (sheet.Cells.MaxDataRow != -1 && sheet.Cells.MaxDataColumn != -1)
                                {
                                    // 方法 ExportDataTable 的参数说明
                                    //  要导出的第一个单元格的行号。
                                    //  要导出的第一个单元格的列号。
                                    //  要导入的行数。
                                    //  要导入的列数。
                                    //  指示第一行的数据是否导出到DataTable的列名。
                                    DataTable dataTable = sheet.Cells.ExportDataTable(0, 0, sheet.Cells.MaxDataRow + 1, sheet.Cells.MaxDataColumn + 1, true);
                                    dataSet.Tables.Add(dataTable);

                                    DataTable taxData = dataSet.Tables[0];

                                    //公司部门
                                    string sql = string.Format(@"Select row_number() over(order by pm_ws.Id) as Row_Number,
                                            sc.Id as CompanyId,sc.CompanyName,sd.Id as DepId,sd.DepName, 
                                            sys_u1.CnName Name,sys_u2.CnName LastUpdateUserName,pm_ws.* 
                                         From Pm_WageSheet pm_ws
                                         Left Join Sys_Users sys_u1 On pm_ws.UserId = sys_u1.Id
                                         Left Join Sys_Users sys_u2 On pm_ws.LastUpdateUserId = sys_u2.Id
                                         Left Join Sys_Company sc On  sys_u1.companyId = sc.Id
                                         Left Join Sys_Department sd On sys_u1.DepId = sd.Id
                                         Where pm_ws.IsDel = 0 And pm_ws.YearMonth = '{0}'
                                         Order By UserId Asc ", yearMonth);
                                    var wageSheetList = await _wageSheetRep._sqlSugar.SqlQueryable<WageSheetInfoView>(sql).ToListAsync();

                                    if (wageSheetList.Count <= 0)
                                    {
                                        return Ok(JsonView(false, yearMonth + "工资数据不存在,请先添加工资数据!"));
                                    }

                                    for (int i = 0; i < taxData.Rows.Count; i++)
                                    {
                                        string name = taxData.Rows[i][0].ToString().Trim();

                                        List<WageSheetInfoView> wageSheets = new();
                                        wageSheets = wageSheetList.Where(it => it.Name.Equals(name)).ToList();
                                        if (wageSheets.Count > 0)
                                        {
                                            wageSheetList.Where(it => it.Name.Equals(name))
                                            .Select(it =>
                                             {
                                                 //修改 绩效不等于0.00M的数据
                                                 //decimal oldTax = it.WithholdingTax;
                                                 var newTax = Convert.ToDecimal(taxData.Rows[i][1].ToString());
                                                 it.WithholdingTax = newTax;
                                                 it.TotalRealHair = it.Should - it.TotalDeductions - newTax;
                                                 return it;
                                             })
                                            .ToList();
                                        }
                                    }
                                    List<Pm_WageSheet> wageSheets1 = new();
                                    wageSheets1 = _mapper.Map<List<Pm_WageSheet>>(wageSheetList);
                                    var updateStatus = _wageSheetRep._sqlSugar
                                        .Updateable(wageSheets1)
                                        .UpdateColumns(it => new { it.WithholdingTax, it.TotalRealHair })
                                        .ExecuteCommand();

                                    if (updateStatus < 0)
                                    {
                                        return Ok(JsonView(false, "操作失败！"));
                                    }

                                    if (System.IO.File.Exists(filePath))
                                    {
                                        //删除文件
                                        System.IO.File.Delete(filePath);
                                    }
                                    return Ok(JsonView(true, "操作成功!"));

                                }
                            }
                            else
                            {
                                return Ok(JsonView(false, "工作薄没有数据！"));
                            }


                        }
                    }

                    return Ok(JsonView(true, "上传成功！", projectFileName));
                }
                else
                {
                    return Ok(JsonView(false, "上传失败！"));
                }
            }
            catch (Exception ex)
            {
                return Ok(JsonView(false, "程序错误！"));
                throw;
            }
            //return Ok(JsonView(true, "操作成功!"));
        }

        /// <summary>
        /// 打卡记录测试
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> Test(string startDt, string endDt, int code)
        {
            UserIdListView userIdListView = await _qiYeWeChatApiService.GetUserIdListAsync();
            if (userIdListView.errcode != 0)
            {
                _result.Msg = "【企业微信】【打卡】【获取员工ID】【Msg】" + userIdListView.errmsg;
                return Ok(JsonView(false, _result.Msg));
            }

            List<string> qyWhchatIdList = new();
            //qyWhchatIdList = userIdListView.dept_user.Select(it => it.userid).ToList();
            qyWhchatIdList = userIdListView.dept_user.Select(it => it.userid!).ToList();

            var data = await _qiYeWeChatApiService.GetCheckinDataAsync(qyWhchatIdList, code, Convert.ToDateTime(startDt), Convert.ToDateTime(endDt));
            return Ok(JsonView(true, "操作成功!", data.checkindata));
        }

        /// <summary>
        /// 审批详情
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostApprovalDetailAsync(string spNo)
        {
            if (string.IsNullOrEmpty(spNo))
            {
                return Ok(JsonView(false, "审批单号不能为空!!"));
            }
            var data = await _qiYeWeChatApiService.GetApprovalDetailAsync(spNo);
            return Ok(JsonView(true, "操作成功!", data));
        }
        #endregion

        #region 任务单

        /// <summary>
        /// 任务分配 
        /// 基础数据源
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationInit(TaskAllocationInitDto dto)
        {
            #region  参数验证
            if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
            if (dto.PageId < 1) dto.PageId = 172; //任务指派Id

            #region 页面操作权限验证
            PageFunAuthViewBase pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);

            if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
            #endregion

            #endregion

            var _view = await _taskAllocationRep._Init(dto.PortType, dto.UserId);
            if (_view.Code == 0)
            {
                return Ok(JsonView(true, "查询成功!", _view.Data));
            }

            return Ok(JsonView(false, _view.Msg));
        }

        /// <summary>
        /// 任务分配 
        /// page
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationPage(TaskAllocationPageDto dto)
        {
            #region  参数验证
            if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
            if (dto.PageId < 1) dto.PageId = 172; //任务指派Id

            PageFunAuthViewBase pageFunAuthView = new();

            #region 页面操作权限验证
            pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);

            if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
            #endregion

            #endregion
            var groupNames = dto.GroupNames;
            var groupArr = Array.Empty<string>();
            if (!string.IsNullOrEmpty(groupNames))
            {
                groupArr = groupNames.Split(',').Select(part => part.Trim()).ToArray();
            }


            string whereSql = "", currUserName = "";
            #region 分页参数处理

            //类型处理
            if (dto.Type == 0) whereSql = "";
            else if (dto.Type == 1) //1 由我指派
            {
                //whereSql = string.Format(@" And ta.CreateUserId = {0} Or (Select COUNT(1) As PeopleNumber From Pm_TaskRelevanceUser Where IsDel = 0 And ta.Id = TAId And UserId = {0}) > 0", dto.UserId);
            }
            else if (dto.Type == 2)// 2 指派给我
            {
                //whereSql = string.Format(@" And (Select COUNT(1) As PeopleNumber From Pm_TaskRelevanceUser Where IsDel = 0 And ta.Id = TAId And UserId = {0}) > 0", dto.UserId);
            }
            //状态 -1 全部 0 未开始 1 进行中 2 待审核 3 未完成 4 已完成
            if (dto.Status == -1) //全部
            {
                whereSql += "";
            }
            else
            {
                whereSql += string.Format(@" And ta.Status = {0} ", dto.Status);
            }

            //任务名称
            if (!string.IsNullOrEmpty(dto.TaskName))
            {
                whereSql += string.Format(@" And ta.TaskName Like '%{0}%' ", dto.TaskName);
            }

            #endregion

            var currUserInfo = await _sqlSugar.Queryable<Sys_Users>().FirstAsync(x => x.Id == dto.UserId);
            if (currUserInfo != null) currUserName = currUserInfo.CnName;

            string pageSql = string.Format(@"Select
 ROW_NUMBER() OVER(
        ORDER BY
          CreateTime Desc
      ) AS RowNumber,
  *
From
(
    Select
      ta.Id,
      ta.TaskName,
      ta.TaskContent,
      ta.TaskPriority,
      d.DepName,
      di.TeamName,
      ta.Status,
      ta.PredictBeginTime,
      ta.PredictEndTime,
      u.CnName As CreateUserName,
      ta.CreateTime,
      (
        SELECT
          STUFF(
            (
              Select
                ',' + u.CnName
              From
                Pm_TaskRelevanceUser tra
                Left Join Sys_Users u On tra.UserId = u.Id
              Where
                tra.Isdel = 0
                And tra.TAId = ta.Id FOR XML PATH('')
            ),
            1,
            1,
            ''
          )
      ) As Participant,
      (
        SELECT
          STUFF(
            (
              Select
                ',' + u.CnName
              From
                Pm_TaskRelevanceUser tra
                Left Join Sys_Users u On tra.UserId = u.Id
              Where
                tra.Isdel = 0
                And tra.TAId = ta.Id
                And tra.TaskStatus = 4 FOR XML PATH('')
            ),
            1,
            1,
            ''
          )
      ) As Consummator
    From
      Pm_TaskAllocation ta
      Left Join Sys_Department d On ta.DepId = d.Id
      Left Join Grp_DelegationInfo di On ta.DiId = di.Id
      Left Join Sys_Users u On ta.CreateUserId = u.Id
    Where
      ta.IsDel = 0 {0}
  ) As temp
WHERE
  [CreateUserName] like '%{1}%'
  OR [Participant] like '%{2}%' ", whereSql, currUserName, currUserName);

            RefAsync<int> total = 0;
            var _view = await _sqlSugar.SqlQueryable<TaskListView>(pageSql)
                .WhereIF(groupArr.Any(), x => groupArr.Contains(x.TeamName))
                .ToPageListAsync(dto.PageIndex, dto.PageSize, total);//ToPageAsync

            List<int> taskIds = taskIds = _view.Select(it => it.Id).ToList();

            string taskerSql = string.Format(@"Select tau.TAId,tau.Id,tau.UserId,u.CnName As UserName,tau.BeginTime,tau.OverTime,tau.TaskStatus,
                                                  tau.Cause,tau.Score,tau.Remark As ScoreRemark,tau.CreateUserId As TaskCreateUserId
                                                  From Pm_TaskRelevanceUser tau 
                                                  Left Join Sys_Users u On tau.UserId = u.Id
                                                  Where tau.IsDel = 0");

            var taskerData = _sqlSugar.SqlQueryable<TaskerDetailsView>(taskerSql).Where(it => taskIds.Contains(it.TAId)).ToList();
            foreach (var item in _view)
            {
                //任务接收者显示自己任务状态
                if (!item.CreateUserName.Equals(currUserName))
                {
                    var subTaskInfo = taskerData.FirstOrDefault(x => item.Id == x.TAId && x.UserId == dto.UserId);
                    if (subTaskInfo != null) item.Status = subTaskInfo.TaskStatus;
                }
                else
                {
                    item.TaskerDetails = taskerData.Where(it => it.TAId == item.Id).ToArray();
                }

                ////处理任务总状态 And 任务人状态
                //var taskerStatusData = taskerData.Where(it => it.TAId == item.Id && it.TaskCreateUserId != dto.UserId && it.UserId == dto.UserId).FirstOrDefault();
                //if (taskerStatusData != null)
                //{
                //    item.Status = taskerStatusData.TaskStatus;
                //}
            }


            return Ok(JsonView(true, "查询成功!", _view, total));
        }

        /// <summary>
        /// 任务分配
        /// 详情
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationDetails(TaskAllocationDetailsDto dto)
        {
            #region  参数验证
            if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
            if (dto.PageId < 1) dto.PageId = 172; //任务指派Id

            #region 页面操作权限验证
            PageFunAuthViewBase pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);

            if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
            #endregion

            #endregion

            var _view = await _taskAllocationRep._Details(dto.PortType, dto.Id);
            if (_view.Code == 0)
            {
                return Ok(JsonView(true, "查询成功!", _view.Data));
            }

            return Ok(JsonView(false, _view.Msg));
        }

        /// <summary>
        /// 任务分配
        /// Add Or Edit
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationAddOrEdit(TaskAllocationAddOrEditDto dto)
        {
            #region  参数验证
            if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
            if (dto.PageId < 1) dto.PageId = 172; //任务指派Id

            PageFunAuthViewBase pageFunAuthView = new();

            #region 页面操作权限验证
            pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);

            if (dto.Id == 0)
            {
                if (pageFunAuthView.AddAuth == 0) return Ok(JsonView(false, "您没有添加权限!"));
            }
            else if (dto.Id > 0)
            {

                if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
            }


            #endregion

            #endregion

            var _view = await _taskAllocationRep._AddOrEdit(dto);
            if (_view.Code == 0)
            {

                if (dto.Id == 0) //添加提示任务单创建
                {
                    string title = $"[{dto.TaskName}] 任务新建成功!";
                    string content = $"[{dto.TaskName}] 任务新建成功,请前往任务页面查看详情!";

                    await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, dto.UserIds);

                    var userIds = dto.UserIds.Select(x => x.ToString()).ToList();

                    await AppNoticeLibrary.SendUserMsg_Task_ToUser(userIds, dto.DiId, title, dto.UserId);
                }

                return Ok(JsonView(true, "操作成功!"));
            }

            return Ok(JsonView(false, _view.Msg));
        }

        /// <summary>
        /// 任务分配
        /// 状态任务归属人详情
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationTaskerDetails(TaskerDetailsDto dto)
        {
            var _view = await _taskAllocationRep._TaskerDetails(dto.Id);
            if (_view.Code == 0)
            {
                return Ok(JsonView(true, "操作成功!", _view.Data));
            }

            return Ok(JsonView(false, _view.Msg));
        }

        /// <summary>
        /// 任务分配
        /// 状态任务归属人设置开始状态
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationSetStartStatus(TaskerStatusDto dto)
        {
            var _view = await _taskAllocationRep._TaskerSetStartStatus(dto.UserId, dto.Id);
            if (_view.Code == 0)
            {
                //发送消息
                var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == dto.Id).First();
                if (taskData != null)
                {
                    var taskUserIds = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.TAId == dto.Id).Select(it => it.UserId).ToList();
                    if (taskUserIds.Count > 0)
                    {
                        taskUserIds.Remove(dto.UserId);
                    }

                    var UserName = _taskAllocationRep._sqlSugar.Queryable<Sys_Users>().Where(it => it.Id == dto.UserId).Select(it => it.CnName).First();

                    string title_createUser = $"[{taskData.TaskName}] 进度更新!";
                    string conten_createUser = $"[{UserName}] 已开始任务,请注意该工作人员任务进度!";

                    //创建人发送消息
                    List<int> createUserIds = new() { taskData.CreateUserId };
                    await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title_createUser, conten_createUser, createUserIds);

                    await AppNoticeLibrary.SendUserMsg_Task_ToUser(createUserIds.Select(x => x.ToString()).ToList(), taskData.DiId, conten_createUser, taskData.CreateUserId);

                    //其他人发送消息
                    string title = $"[{taskData.TaskName}] 进度更新!";
                    string content = $"[{UserName}] 已开始任务.若需查看,请前往任务页面查看详情!";

                    await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, taskUserIds);

                    await AppNoticeLibrary.SendUserMsg_Task_ToUser(taskUserIds.Select(x => x.ToString()).ToList(), taskData.DiId, content, dto.UserId);

                }

                return Ok(JsonView(true, "操作成功!"));
            }

            return Ok(JsonView(false, _view.Msg));
        }

        /// <summary>
        /// 任务分配
        /// 状态 任务归属人 设置完成状态
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationSetOverStatus(TaskerStatusDto dto)
        {
            var _view = await _taskAllocationRep._TaskerSetOverStatus(dto.UserId, dto.Id);
            if (_view.Code == 0)
            {
                //发送消息
                var taskData = _sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == dto.Id).First();
                if (taskData != null)
                {
                    var taskUserIds = _sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.TAId == dto.Id).Select(it => it.UserId).Distinct().ToList();
                    var UserName = _sqlSugar.Queryable<Sys_Users>().Where(it => it.Id == dto.UserId).Select(it => it.CnName).First();

                    string title_createUser = $"[{taskData.TaskName}] 进度更新!";
                    string conten_createUser = $"[{UserName}] 已完成任务,请前往任务页面进行审核操作!";

                    await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title_createUser, conten_createUser, new List<int>() { taskData.CreateUserId }); //创建人发送消息

                    await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { taskData.CreateUserId.ToString() }, taskData.DiId, conten_createUser, dto.UserId);

                    string title = $"[{taskData.TaskName}] 进度更新!";
                    string content = $"[{UserName}] 已完成任务,请注意在规定时间内完成任务.若需查看,请前往任务页面查看详情!";
                    string yw_content = $"[{UserName}] 已完成任务,请注意在规定时间内完成任务!";

                    await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, taskUserIds); //其他人发送消息

                    await AppNoticeLibrary.SendUserMsg_Task_ToUser(taskUserIds.Select(x => x.ToString()).ToList(), taskData.DiId, yw_content, dto.UserId);

                    string content1 = $"任务已完成,等待任务发布人审核！若需查看,请前往任务页面查看详情!";
                    string yw_content1 = $"任务已完成,等待任务发布人审核!";
                    await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content1, new List<int>() { dto.UserId }); //设置任务人 发送消息

                    await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { dto.UserId.ToString() }, taskData.DiId, yw_content1, dto.UserId);

                }

                return Ok(JsonView(true, "操作成功!"));
            }

            return Ok(JsonView(false, _view.Msg));
        }

        /// <summary>
        /// 任务分配
        /// 状态 任务归属人 设置知晓状态
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationSetHaveStatus(TaskAllocationStatusDto dto)
        {
            var _view = await _taskAllocationRep._TaskSetHaveStatus(dto.SubId);
            if (_view.Code == 0)
            {
                //发送消息
                var taskUserData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.SubId).First();
                if (taskUserData != null)
                {
                    var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == taskUserData.TAId).First();

                    if (taskData != null)
                    {

                        var UserName = _taskAllocationRep._sqlSugar.Queryable<Sys_Users>().Where(it => it.Id == taskData.CreateUserId).Select(it => it.CnName).First();

                        string title = $"[{taskData.TaskName}] 进度更新!";
                        string conten_createUser = $"[{UserName}] 已知晓任务.若需查看,请前往任务页面查看详情!";
                        string qw_conten_createUser = $"[{UserName}] 已知晓任务!";

                        await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, conten_createUser, new List<int>() { taskData.CreateUserId }); //创建人发送消息

                        await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { taskData.CreateUserId.ToString() }, taskData.DiId, qw_conten_createUser, taskData.CreateUserId);


                        string content = $"请注意任务完成时间！若需查看,请前往任务页面查看详情!";
                        string yw_content = $"请注意任务完成时间!";
                        await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, new List<int>() { taskUserData.UserId }); //设置任务人 发送消息
                        await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { taskUserData.UserId.ToString() }, taskData.DiId, yw_content, taskUserData.UserId);

                    }
                }

                return Ok(JsonView(true, "操作成功!"));
            }

            return Ok(JsonView(false, _view.Msg));
        }

        /// <summary>
        /// 任务分配
        /// 任务发布者 单人设置审批状态
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationSetAuditStatus(TaskAllocationStatusDto dto)
        {
            var _view = await _taskAllocationRep._TaskSetAuditStatus(dto.SubId);
            if (_view.Code == 0)
            {
                //发送消息
                var taskUserData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.SubId).First();
                if (taskUserData != null)
                {
                    var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == taskUserData.TAId).First();

                    if (taskData != null)
                    {
                        string title = $"[{taskData.TaskName}] 进度更新!";
                        string content = $"任务已完成！若需查看,请前往任务页面查看详情!";
                        string yw_content = $"任务已完成!";
                        await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, new List<int>() { taskUserData.UserId }); //设置任务人 发送消息

                        await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { taskUserData.UserId.ToString() }, taskData.DiId, yw_content, taskUserData.UserId);

                    }
                }

                return Ok(JsonView(true, "操作成功!"));
            }

            return Ok(JsonView(false, _view.Msg));
        }

        /// <summary>
        /// 任务分配
        /// 任务发布者 单人设置未完成状态
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationSetUnFinishedStatus(TaskAllocationSetUnFinishedStatusDto dto)
        {
            var _view = await _taskAllocationRep._TaskSetUnFinishedStatus(dto.SubId, dto.Cause);
            if (_view.Code == 0)
            {
                //发送消息
                var taskUserData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.SubId).First();
                if (taskUserData != null)
                {
                    var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == taskUserData.TAId).First();

                    if (taskData != null)
                    {
                        string title = $"[{taskData.TaskName}] 进度更新!";
                        string content = $"任务未完成！若需查看,请前往任务页面查看详情!";
                        string yw_content = $"任务未完成!";
                        await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, new List<int>() { taskUserData.UserId }); //设置任务人 发送消息
                        await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { taskUserData.UserId.ToString() }, taskData.DiId, yw_content, taskUserData.UserId);

                    }
                }

                return Ok(JsonView(true, "操作成功!"));
            }

            return Ok(JsonView(false, _view.Msg));
        }

        ///// <summary>
        ///// 任务分配
        ///// 确认任务是否可操作完成
        ///// </summary>
        ///// <returns></returns>
        //[HttpPost]
        //[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        //public async Task<IActionResult> PostTaskAllocationIsConfirmCompletion(TaskAllocationScoreDto dto)
        //{
        //    try
        //    {
        //        #region  参数验证
        //        if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
        //        if (dto.PageId < 1) dto.PageId = 172; //任务指派Id

        //        PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();

        //        #region 页面操作权限验证
        //        pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);

        //        if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));

        //        #endregion

        //        #endregion

        //        var _view = await _taskAllocationRep._TaskConfirmCompletion(dto.PortType, dto.Id);
        //        if (_view.Code == 0)
        //        {
        //            return Ok(JsonView(true, "操作成功!"));
        //        }

        //        return Ok(JsonView(false, _view.Msg));
        //    }
        //    catch (Exception ex)
        //    {
        //        return Ok(JsonView(false, ex.Message));
        //    }
        //}

        ///// <summary>
        ///// 任务分配
        ///// 任务确认完成
        ///// </summary>
        ///// <returns></returns>
        //[HttpPost]
        //[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        //public async Task<IActionResult> PostTaskAllocationConfirmCompletion(TaskAllocationConfirmCompletionDto dto)
        //{
        //    try
        //    {
        //        #region  参数验证
        //        if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
        //        if (dto.PageId < 1) dto.PageId = 172; //任务指派Id

        //        PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();

        //        #region 页面操作权限验证
        //        pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);

        //        if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));

        //        #endregion

        //        #endregion

        //        var _view = await _taskAllocationRep._TaskConfirmCompletion(dto.PortType,dto.Id);
        //        if (_view.Code == 0)
        //        {
        //            return Ok(JsonView(true, "操作成功!"));
        //        }

        //        return Ok(JsonView(false, _view.Msg));
        //    }
        //    catch (Exception ex)
        //    {
        //        return Ok(JsonView(false, ex.Message));
        //    }
        //}

        /// <summary>
        /// 任务分配
        /// 任务发布者 任务评分
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationScore(TaskAllocationScoreDto dto)
        {
            #region  参数验证
            if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
            if (dto.PageId < 1) dto.PageId = 172; //任务指派Id


            #region 页面操作权限验证
            PageFunAuthViewBase pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
            if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));

            #endregion

            #endregion

            var _view = await _taskAllocationRep._TaskScore(dto);
            if (_view.Code == 0)
            {
                //发送消息
                var taskUserData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.SubId).First();
                if (taskUserData != null)
                {
                    var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == taskUserData.TAId).First();

                    if (taskData != null)
                    {
                        string title = $"[{taskData.TaskName}] 进度更新!";
                        string content = $"任务评分已完成！若需查看,请前往任务页面查看详情!";
                        string yw_content = $"任务评分已完成!";
                        await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, new List<int>() { taskUserData.UserId }); //设置任务人 发送消息


                        await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { taskUserData.UserId.ToString() }, taskData.DiId, yw_content, taskUserData.UserId);

                    }
                }

                return Ok(JsonView(true, "操作成功!"));
            }

            return Ok(JsonView(false, _view.Msg));
        }

        /// <summary>
        /// 任务分配
        /// 任务发布者 任务终止
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationTermination(TaskAllocationConfirmCompletionDto dto)
        {
            #region  参数验证
            if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
            if (dto.PageId < 1) dto.PageId = 172; //任务指派Id

            #region 页面操作权限验证

            PageFunAuthViewBase pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
            if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));

            #endregion

            #endregion

            var _view = await _taskAllocationRep._TaskTermination(dto.Id);
            if (_view.Code == 0)
            {
                //发送消息
                var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == dto.Id).First();
                if (taskData != null)
                {
                    var taskUserIds = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.Id).Select(it => it.UserId).ToList();
                    taskUserIds.Add(taskData.CreateUserId);

                    string title = $"[{taskData.TaskName}] 进度更新!";
                    string content = $"任务已终止！若需查看,请前往任务页面查看详情!";
                    string yw_content = $"[{taskData.TaskName}]任务已终止!";
                    await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, taskUserIds); //设置任务人 发送消息

                    await AppNoticeLibrary.SendUserMsg_Task_ToUser(taskUserIds.Select(x => x.ToString()).ToList(), taskData.DiId, yw_content, taskData.CreateUserId);

                }

                return Ok(JsonView(true, "操作成功!"));
            }

            return Ok(JsonView(false, _view.Msg));
        }

        /// <summary>
        /// 任务分配
        /// 任务发布者 任务删除
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTaskAllocationDel(TaskAllocationConfirmCompletionDto dto)
        {
            #region  参数验证
            if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
            if (dto.PageId < 1) dto.PageId = 172; //任务指派Id

            #region 页面操作权限验证
            PageFunAuthViewBase pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);

            if (pageFunAuthView.DeleteAuth == 0) return Ok(JsonView(false, "您没有删除权限!"));

            #endregion

            #endregion

            var _view = await _taskAllocationRep._TaskDel(dto.Id);
            if (_view.Code == 0)
            {
                return Ok(JsonView(true, "操作成功!"));
            }

            return Ok(JsonView(false, _view.Msg));
        }
        #endregion

        #region 团组状态通知

        // ///// <summary>
        // ///// 测试
        // ///// </summary>
        // ///// <param name="dto"></param>
        // ///// <returns></returns>
        // [HttpPost]
        // [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        // public async Task<IActionResult> Test_QIYEWX(PostTourClientListDownloadFile dto)
        // {
        //     //    //List<string> templist = new List<string>() { 234.ToString() };
        //     //    //await AppNoticeLibrary.SendUserMsg_GroupStatus_AuditFee(14090, templist, QiyeWeChatEnum.TestChat);

        //     //    //await AppNoticeLibrary.SendUserMsg_GroupShare_ToJob(dto.DiId); ;


        //     //    //DeleReminderMessage.PostMessageByWebhook();
        //     //    //GroupStatus_UserSimplelistView list = await _qiYeWeChatApiService.GroupStatus_GetUserList();

        //     //    //创建群聊

        //     //    //List<string> userList1 = new List<string>() { "Feint", "amy.zhu@pan-american-intl.com", "judy.zeng@pan-american-intl.com", "FuHongJin" };
        //     //    //List<string> userList2 = new List<string>() {  "Feint", "ZhaoYaQi", "LiaoWenYa" };
        //     List<string> userList3 = new List<string>() { "rongfeng.yuan", "zhaiyang" };

        //     //    //GroupStatus_CreateChatView rst1 = await _qiYeWeChatApiService.GroupStatus_CreateChat("团组通知", "Feint", userList1, "CaiWuChat01");
        //     //    //GroupStatus_CreateChatView rst2 = await _qiYeWeChatApiService.GroupStatus_CreateChat("OA通知-国交部", "Feint", userList2, "GuoJiaoLeader01");
        //     GroupStatus_CreateChatView rst3 = await _qiYeWeChatApiService.GroupStatus_CreateChat("OA通知-机票预算", "rongfeng.yuan", userList3, "AirCostChat01");

        //     //    //推送消息(模板)

        //     //    //List<string> userList = new List<string>() { "Feint", "huaju.liu", "johnny.yang@pan-american-intl.com" };
        //     //    //List<string> userList = new List<string>() { "Feint", "johnny.yang@pan-american-intl.com" };
        //     //    GroupStatus_CreateChatView rst1 = await _qiYeWeChatApiService.GroupStatus_CreateChat("团组费用提示", "Feint", userList, "GuoJiaoChat01");

        //     //    //团组出发
        //     //    //AppNoticeLibrary.SendUserMsg_GroupStatus_Create(2358, userList);

        //     //    //费用审核
        //     //    //AppNoticeLibrary.SendChatMsg_GroupStatus_ApplyFee(dto.DiId, QiyeWeChatEnum.TestChat);

        //     //    //费用审核结果通知（通过情况下发送财务群）
        //     //    //List<string> userList = new List<string>() { "234" };
        //     //    //AppNoticeLibrary.SendUserMsg_GroupStatus_AuditFee(dto.DiId, userList, QiyeWeChatEnum.CaiWuChat02);

        //     //    //4、财务付款时:(1)对应版块人员【单独发,状态为已付款才发】
        //     //    //AppNoticeLibrary.SendUserMsg_GroupStatus_PayResult(dto.DiId, userList);

        //     //    //团组提醒财务群
        //     //    //DateTime dtNow = DateTime.Now;
        //     //    //List<Grp_DelegationInfo> listSource = _usersRep.Query<Grp_DelegationInfo>(s => s.IsDel == 0 && s.VisitStartDate >= dtNow).Take(3).ToList();
        //     //    //List<Grp_DelegationInfo> listAdd7day = _usersRep.Query<Grp_DelegationInfo>(s => s.IsDel == 0 && s.VisitStartDate >= dtNow).Take(3).ToList();
        //     //    //List<Grp_DelegationInfo> listAdd3day = new List<Grp_DelegationInfo>() { };

        //     //机票预算群通知
        //     await AppNoticeLibrary.SendChatMsg_AirCostChat(dto.DiId, QiyeWeChatEnum.AirCostChat01);

        //     //    //日付申请提醒财务群
        //     //    //AppNoticeLibrary.DailyPayReminders_Create_ToCaiwuChat(dto.DiId, QiyeWeChatEnum.CaiWuChat02);
        //     //    //日付申请结果推送用户、成功通知财务群
        //     //    //AppNoticeLibrary.DailyPayReminder_Audit_ToUser(dto.DiId, userList, QiyeWeChatEnum.TestChat);
        //     //    //AppNoticeLibrary.DailyPayReminder_Pay_ToUser(dto.DiId, userList);

        //     //    //string q = "";

        //     //    DeleReminderMessage.PostMessageByWebhook_CRMStatistics();


        //     return Ok(JsonView(true, "操作成功！"));
        // }

        #endregion

        #region 物资进销存

        /// <summary>
        /// 物资进销存
        /// 基础数据类型
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsInitDataSource()
        {
            return Ok(await _goodsRep.InitDataSource());
        }

        /// <summary>
        /// 物资进销存
        /// 基础数据类型 --> 团组名称列表 分页
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsGroupNameInit(QueryGroupListOffsetDto dto)
        {
            var watch = new Stopwatch();
            watch.Start();
            var countyDatas = await _sqlSugar
                .Queryable<Grp_DelegationInfo>()
                .Where((di) => di.IsDel == 0 && !string.IsNullOrWhiteSpace(di.TeamName))
                .OrderBy((di) => new { id = SqlFunc.Desc(di.Id) })
                .Select((di) => new { id = di.Id, name = di.TeamName })
                .ToListAsync();

            countyDatas.Insert(0, new { id = 0, name = "其他物资(公司内部物资)" });
            countyDatas.Insert(0, new { id = -1, name = "拜访客户所使用的物资" });
            countyDatas.Insert(0, new { id = -2, name = "库存调整" });
            countyDatas.Insert(0, new { id = -3, name = "全部团组" });
            var total = countyDatas.Count;
            countyDatas = countyDatas.WhereIF(!string.IsNullOrEmpty(dto.Search), x => x.name.Contains(dto.Search)).ToList();
            countyDatas = countyDatas
                .Skip((dto.PageIndex - 1) * dto.PageSize)
                .Take(dto.PageSize)
                .ToList();

            watch.Stop();

            return Ok(JsonView(true, $"{MsgTips.Succeed}，耗时 {watch.ElapsedMilliseconds} ms", countyDatas, total));

        }

        /// <summary>
        /// 物资进销存
        /// 物品 列表
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsList(GoodsListDto dto)
        {
            if (dto.PortType < 1 || dto.PortType > 3) return Ok(JsonView(false, MsgTips.Port));
            if (dto.PageIndex < 1 || dto.PageSize < 1) return Ok(JsonView(false, MsgTips.PageIndex));

            return Ok(await _goodsRep.GoodsList(dto));
        }

        /// <summary>
        /// 物资进销存
        /// 物品 详情
        /// </summary>
        /// <returns></returns>
        [HttpGet()]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsInfo(int portType, int id)
        {
            if (portType < 1 || portType > 3) return Ok(JsonView(false, MsgTips.Port));
            if (id < 1) return Ok(JsonView(false, MsgTips.Id));

            return Ok(await _goodsRep.GoodsInfo(portType, id));
        }

        /// <summary>
        /// 物资进销存
        /// 物品 OP(Add OR Edit)
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsOP(GoodsOpDto dto)
        {
            var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            var validator = new GoodsOPDTOValidator();
            var validatorRes = await validator.ValidateAsync(dto);
            if (!validatorRes.IsValid)
            {
                var sb = new StringBuilder();
                foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
                return Ok(JsonView(false, sb.ToString()));
            }

            return Ok(await _goodsRep.GoodsOp(dto, currUserInfo.UserId));
        }

        /// <summary>
        /// 物资进销存
        /// 物品 Del
        /// </summary>
        /// <returns></returns>
        [HttpDelete("{id}")]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsDel(int id)
        {
            if (id < 1) return Ok(JsonView(false, MsgTips.Id));

            var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            return Ok(await _goodsRep.GoodsDel(id, currUserInfo.UserId));
        }

        /// <summary>
        /// 物资进销存(审核，需传token)
        /// 入库 列表
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsStorageList(GoodsStorageListDto dto)
        {
            //var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            //if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            if (dto.PortType < 1 || dto.PortType > 3) return Ok(JsonView(false, MsgTips.Port));
            if (dto.PageIndex < 1 || dto.PageSize < 1) return Ok(JsonView(false, MsgTips.PageIndex));

            return Ok(await _goodsRep.GoodsStorageList(dto));
            //return Ok(await _goodsRep.GoodsStorageList(dto, 0));

        }

        /// <summary>
        /// 物资进销存
        /// 入库 详情
        /// </summary>
        /// <returns></returns>
        [HttpGet("{id}")]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsStorageInfo([FromQuery] int portType, int id)
        {
            if (portType < 1 || portType > 3) return Ok(JsonView(false, MsgTips.Port));
            if (id < 1) return Ok(JsonView(false, MsgTips.Id));

            return Ok(await _goodsRep.GoodsStorageInfo(portType, id));
        }

        /// <summary>
        /// 物资进销存
        /// 入库 OP(Add OR Edit)
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsStorageOp(GoodsStorageOpDto dto)
        {
            var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            var validator = new GoodsStorageOpDtoValidator();
            var validatorRes = await validator.ValidateAsync(dto);
            if (!validatorRes.IsValid)
            {
                var sb = new StringBuilder();
                foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
                return Ok(JsonView(false, sb.ToString()));
            }

            return Ok(await _goodsRep.GoodsStorageOp(dto, currUserInfo.UserId));
        }

        /// <summary>
        /// 物资进销存
        /// 入库确认状态变更
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsStorageConfirmStatusChange(GoodsStorageConfirmDto dto)
        {
            if (dto.Id < 1) return Ok(JsonView(false, MsgTips.Id));

            if (!Enum.IsDefined(typeof(GoodsAuditDepEnum), (int)dto.AuditDep))
            {
                return Ok(JsonView(false, $"审核部门类型超出可用范围!"));
            }

            if (!Enum.IsDefined(typeof(GoodsConfirmEnum), (int)dto.ConfirmStatus))
            {
                return Ok(JsonView(false, $"入库审核状态超出可用范围!"));
            }

            if (dto.ConfirmStatus == GoodsConfirmEnum.WaitConfirm || dto.ConfirmStatus == GoodsConfirmEnum.PartConfirmed)
            {
                return Ok(JsonView(false, $"入库审核状态(待确认、部分确认)不可用!"));
            }

            var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            return Ok(await _goodsRep.GoodsStorageConfirmStatusChange(dto, currUserInfo.UserId));
        }

        /// <summary>
        /// 物资进销存
        /// 入库 Del
        /// </summary>
        /// <returns></returns>
        [HttpDelete("{id}")]
        //[Authorize]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsStorageDel(int id)
        {
            var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            if (id < 1) return Ok(JsonView(false, MsgTips.Id));

            return Ok(await _goodsRep.GoodsStorageDel(id, currUserInfo.UserId));
        }

        /// <summary>
        /// 物资进销存
        /// 入库 excelDownload
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsStorageExcelDownload()
        {
            //token验证
            var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            //文件下载权限验证
            int userId = currUserInfo.UserId,
                pageId = 191;

            #region 页面操作权限验证
            PageFunAuthViewBase pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(userId, pageId);

            if (pageFunAuthView.FilesDownloadAuth == 0) return Ok(JsonView(false, "您未分配文件下载权限!"));
            #endregion

            return Ok(await _goodsRep.GoodsStorageExcelDownload());
        }

        /// <summary>
        /// 物资进销存
        /// 领用记录 List
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsReceiveList(GoodsReceiveListDTO dto)
        {
            //token验证
            var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            if (dto.PortType < 1 || dto.PortType > 3) return Ok(JsonView(false, MsgTips.Port));
            if (dto.PageIndex < 1 || dto.PageSize < 1) return Ok(JsonView(false, MsgTips.PageIndex));

            //文件下载权限验证
            int userId = currUserInfo.UserId,
                pageId = 191;

            if (dto.IsExcelDownload)
            {
                if (userId < 1) return Ok(JsonView(false, "excel导出时,需传入正确的当前操作人UserId!"));
                ;
                #region 页面操作权限验证
                PageFunAuthViewBase pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(userId, pageId);
                if (pageFunAuthView.FilesDownloadAuth == 0) return Ok(JsonView(false, "您未分配文件下载权限!"));
                #endregion
            }
            dto.CurrUserId = currUserInfo.UserId;
            return Ok(await _goodsRep.GoodsReceiveList(dto));
        }

        /// <summary>
        /// 物资进销存
        /// 领用 审核 List
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsReceiveAuditList(GoodsReceiveAuditListDTO dto)
        {
            //token验证
            var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            if (dto.PortType < 1 || dto.PortType > 3) return Ok(JsonView(false, MsgTips.Port));
            if (dto.PageIndex < 1 || dto.PageSize < 1) return Ok(JsonView(false, MsgTips.PageIndex));

            dto.CurrUserId = currUserInfo.UserId;
            return Ok(await _goodsRep.GoodsReceiveAuditList(dto));
        }

        /// <summary>
        /// 物资进销存
        /// 领用详情
        /// </summary>
        /// <returns></returns>
        [HttpGet("{id}")]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsReceiveInfo([FromQuery] int portType, int id)
        {
            if (portType < 1 || portType > 3) return Ok(JsonView(false, MsgTips.Port));
            if (id < 1) return Ok(JsonView(false, MsgTips.Id));

            return Ok(await _goodsRep.GoodsReceiveInfo(portType, id));
        }

        /// <summary>
        /// 物资进销存
        /// 领用 OP
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsReceiveOP(GoodsReceiveOpDto dto)
        {
            var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            var validator = new GoodsReceiveOpDtoValidator();
            var validatorRes = await validator.ValidateAsync(dto);
            if (!validatorRes.IsValid)
            {
                var sb = new StringBuilder();
                foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
                return Ok(JsonView(false, sb.ToString()));
            }

            //Return Ok(await _goodsRep.GoodsReceiveOp(dto, currUserInfo.UserId));

            //TODO：调试完成后 单个领用使用批量领用方法
            var receiveDetails = new GoodsReceiveDetailsView[] {
                new () {
                    Id = 0,
                    GoodsId = dto.GoodsId,
                    Quantity = dto.Quantity,
                    Remark = dto.Remark
                }
            };

            var newDto = new GoodsReceiveBatchOpDto()
            {
                Id = dto.Id,
                GroupId = dto.GroupId,
                ReceiveDetails = receiveDetails,
                Reason = dto.Reason,
                Remark = dto.Remark,
                IsReplace = dto.IsReplace,
                CurrUserId = currUserInfo.UserId,
            };

            var res = await _goodsRep.GoodsReceiveBatchOpAsync(newDto);
            //企业微信消息通知
            if (res.Code == StatusCodes.Status200OK && dto.Id < 1)
            {
                var signProperty = res.Data?.GetType().GetProperty("sign");
                int sign = signProperty != null && signProperty.GetValue(res.Data, null) is int value ? value : 0;
                //物资领用通知
                await AppNoticeLibrary.SendUserMsg_CompanyShare_ToHR(sign, dto.GroupId, currUserInfo.UserId);
            }

            return Ok(res);

        }

        /// <summary>
        /// 物资进销存
        /// 领用 审核
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [ApiExplorerSettings(IgnoreApi = true)]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsReceiveAudit(GoodsReceiveAuditDTO dto)
        {
            var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            var validator = new GoodsReceiveAuditDTOValidator();
            var validatorRes = await validator.ValidateAsync(dto);
            if (!validatorRes.IsValid)
            {
                var sb = new StringBuilder();
                foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
                return Ok(JsonView(false, sb.ToString()));
            }
            int[] idArray = dto.Label
                .Split(',')
                .Select(x =>
                {
                    if (int.TryParse(x, out var id)) return id;
                    return id;
                })
                .ToArray();

            var view = await _goodsRep.GoodsReceiveAudit(idArray, currUserInfo.UserId, dto.AuditEnum);
            //var view = new JsonView() { Code = StatusCodes.Status200OK};
            //TODO：出库成功 并且是团组相关物资 向团组其他款项添加信息
            #region 出库成功 && 不需要归还的物资（IsReplace == false） && 团组相关物资 向团组其他款项添加信息

            if (view.Code != StatusCodes.Status200OK) return Ok(view);

            if (idArray.Length < 1) return Ok(view);

            int receiveId = idArray[0];

            var receiveInfo = await _sqlSugar.Queryable<Pm_GoodsReceive>().FirstAsync(x => x.IsDel == 0 && x.Id == receiveId);
            if (receiveInfo == null) return Ok(view);

            if (receiveInfo.IsReplace)
            {
                view.Msg += $"\r\n 需要归还的物资不向团组其他款项添加信息！";
                return Ok(view);
            }

            var auditEnums = new List<GoodsAuditEnum>() { GoodsAuditEnum.OutConfirmed, GoodsAuditEnum.OutRejected };
            if (!auditEnums.Contains(receiveInfo.AuditStatus)) return Ok(view);

            var groupInfo = await _sqlSugar.Queryable<Grp_DelegationInfo>().FirstAsync(x => x.IsDel == 0 && x.Id == receiveInfo.GroupId);
            if (groupInfo == null) return Ok(view);

            var basicData = await _sqlSugar.Queryable<Sys_SetData>().Where(x => x.IsDel == 0 && x.STid == 91).ToListAsync();
            var goodsInfo = await _sqlSugar.Queryable<Pm_GoodsInfo>().FirstAsync(x => x.IsDel == 0 && x.Id == receiveInfo.GoodsId);
            if (goodsInfo == null) return Ok(view);

            var basicInfo = basicData.FirstOrDefault(x => x.Name.Equals(goodsInfo.Name));
            if (basicInfo == null) return Ok(view);

            string priceName = basicInfo.Name;

            _ = decimal.TryParse(basicInfo.Remark, out decimal price);
            decimal total = price * receiveInfo.Quantity;

            var requestData = new DecreasePaymentsOpDto()
            {
                Status = 1,
                DiId = groupInfo.Id,
                PriceName = priceName,
                Price = price,
                Quantity = receiveInfo.Quantity,
                FeeTotal = total,
                Currency = 836,
                FilePath = "",
                OrbitalPrivateTransfer = 0,
                OTAOrderNo = "-",
                OtherBankName = "-",
                OtherSideName = "-",
                OtherSideNo = "-",
                PayDId = 105,
                SupplierAddress = "-",
                SupplierArea = 1,
                SupplierContact = "-",
                SupplierContactNumber = "-",
                SupplierEmail = "-",
                SupplierName = "-",
                SupplierSocialAccount = "-",
                SupplierTypeId = 0,
                CreateUserId = receiveInfo.CreateUserId,
                Remark = $"物资领用模块添加！！"
            };

            //其他费用

            #region 调用方法
            JsonView groupData = await _otherPaymentRep.OpDecreasePayments(requestData);
            if (groupData.Code != 200)
            {
                view.Msg += groupData.Msg;
                return Ok(view);
            }

            #region 应用推送

            int diId = requestData.DiId, status = requestData.Status;

            int otherId = Convert.ToInt32(groupData.Data.GetType().GetProperty("dataId").GetValue(groupData.Data, null) ?? 0);
            int ccpId = Convert.ToInt32(groupData.Data.GetType().GetProperty("ccpId").GetValue(groupData.Data, null) ?? 0);
            int sign = Convert.ToInt32(groupData.Data.GetType().GetProperty("sign").GetValue(groupData.Data, null) ?? 0);

            //自动审核
            var autoAdit = await _feeAuditRep.FeeAutomaticAudit(3, diId, otherId);

            await AppNoticeLibrary.SendChatMsg_GroupStatus_ApplyFee(ccpId, sign, QiyeWeChatEnum.GuoJiaoLeaderChat);

            //2024-10-21 新增LZ UID
            var userIds = new List<int>() { 208 };
            //var userIds = new List<int>() { 21 };
            string title = $"系统通知";
            string content = "";

            var ccpInfo = await _sqlSugar.Queryable<Grp_CreditCardPayment>().Where(x => x.Id == ccpId).FirstAsync();
            if (status == 1) content = $"[新增-其他款项({groupInfo?.TeamName ?? "-"})]一项费用：{ccpInfo.PayMoney * ccpInfo.DayRate:#0.00} CNY;";
            else if (status == 2) content = $"[更新-其他款项({groupInfo?.TeamName ?? "-"})]一项费用：{ccpInfo.PayMoney * ccpInfo.DayRate:#0.00} CNY;";

            await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.GroupBusinessOperations, title, content, userIds, diId);

            //await APNsTools.iOS_PushNotifications1("051", $"其他款项费用审核", "", content);

            #endregion
            #endregion

            #endregion

            return Ok(view);
        }

        /// <summary>
        /// 物资进销存
        /// 领用 List(含批量)
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsReceiveBatchList(GoodsReceiveBatchListDto dto)
        {
            var currUserId = dto.CurrUserId;
            var userInfo = await _sqlSugar.Queryable<Sys_Users>().FirstAsync(x => x.IsDel == 0 && x.Id == currUserId);
            if (userInfo == null)
            {
                var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
                if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
                dto.CurrUserId = currUserInfo.UserId;
            }

            return Ok(await _goodsRep.GoodsReceiveBatchListAsync(dto));
        }

        /// <summary>
        /// 物资进销存
        /// 领用 OP 批量领用
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsReceiveBatchOp(GoodsReceiveBatchOpDto dto)
        {
            var currUserId = dto.CurrUserId;
            var userInfo = await _sqlSugar.Queryable<Sys_Users>().FirstAsync(x => x.IsDel == 0 && x.Id == currUserId);
            if (userInfo == null)
            {
                var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
                if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
                dto.CurrUserId = currUserInfo.UserId;
            }

            //参数验证
            if (!dto.ReceiveDetails.Any()) Ok(JsonView(false, "请传入领用明细!"));

            int index = 1;
            foreach (var item in dto.ReceiveDetails)
            {
                //物品验证
                if (item.GoodsId < 1) return Ok(JsonView(false, $"第{index}项物品无效！"));

                //数量验证
                if (item.Quantity <= 0.00M) return Ok(JsonView(false, $"第{index}项物品的数量无效！"));
                index++;
            }

            var res = await _goodsRep.GoodsReceiveBatchOpAsync(dto);

            //企业微信消息通知
            if (res.Code == StatusCodes.Status200OK && dto.Id < 1)
            {
                var signProperty = res.Data?.GetType().GetProperty("sign");
                int sign = signProperty != null && signProperty.GetValue(res.Data, null) is int value ? value : 0;

                //物资领用通知
                await AppNoticeLibrary.SendUserMsg_CompanyShare_ToHR(sign, dto.GroupId, dto.CurrUserId);
            }

            return Ok(res);
        }

        /// <summary>
        /// 物资进销存
        /// 领用 详情(含批量)
        /// </summary>
        /// <param name="id">id</param>
        /// <returns></returns>
        [HttpGet("{id}")]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsReceiveBatchInfo(int id)
        {
            return Ok(await _goodsRep.GoodsReceiveBatchInfoAsync(id));
        }

        /// <summary>
        /// 物资进销存
        /// 领用 审核 (含批量)
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsReceiveAuditNew(GoodsReceiveAuditDTO dto)
        {
            var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            var validator = new GoodsReceiveAuditDTOValidator();
            var validatorRes = await validator.ValidateAsync(dto);
            if (!validatorRes.IsValid)
            {
                var sb = new StringBuilder();
                foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
                return Ok(JsonView(false, sb.ToString()));
            }
            int[] idArray = dto.Label
                .Split(',')
                .Select(x =>
                {
                    if (int.TryParse(x, out var id)) return id;
                    return id;
                })
                .ToArray();

            if (idArray.Length < 1) return Ok(JsonView(false, "请传入有效的领用ID"));
            int receiveId = idArray[0];
            var receiveInfo = await _sqlSugar.Queryable<Pm_GoodsReceive>().FirstAsync(x => x.IsDel == 0 && x.Id == receiveId);
            if (receiveInfo == null) return Ok(JsonView(false, "请传入有效的领用ID"));

            var view = new JsonView();

            if (dto.AuditEnum == GoodsAuditEnum.Approved) //审核通过
            {
                view = await _goodsRep.GoodsReceiveApproveAsync(receiveId, currUserInfo.UserId);

            }
            else if (dto.AuditEnum == GoodsAuditEnum.UnApproved) //审核拒绝
            {
                view = await _goodsRep.GoodsReceiveRejectAsync(receiveId, currUserInfo.UserId);
            }

            if (view.Code != StatusCodes.Status200OK) return Ok(view);

            receiveInfo = await _sqlSugar.Queryable<Pm_GoodsReceive>().FirstAsync(x => x.IsDel == 0 && x.Id == receiveId);
            var auditEnums = new List<GoodsAuditEnum>() { GoodsAuditEnum.OutConfirmed, GoodsAuditEnum.OutRejected };

            if (receiveInfo.AuditStatus == GoodsAuditEnum.OutConfirming)
            {
                //物资领用通知
                await AppNoticeLibrary.SendUserMsg_CompanyShare_ToHR(receiveId, receiveInfo.GroupId, receiveInfo.CreateUserId);
            }

            #region 出库成功 && 不需要归还的物资（IsReplace == false） && 团组相关物资 向团组其他款项添加信息

            //if (!auditEnums.Contains(receiveInfo.AuditStatus)) return Ok(view);

            if (receiveInfo.IsReplace)
            {
                view.Msg += $"\r\n 需要归还的物资不向团组其他款项添加信息！";
                return Ok(view);
            }

            var groupInfo = await _sqlSugar.Queryable<Grp_DelegationInfo>().FirstAsync(x => x.IsDel == 0 && x.Id == receiveInfo.GroupId);
            if (groupInfo == null) return Ok(view);

            var basicData = await _sqlSugar.Queryable<Sys_SetData>().Where(x => x.IsDel == 0 && x.STid == 91).ToListAsync();

            var receiveDetails = await _sqlSugar.Queryable<Pm_GoodsReceiveDetails>()
                .Where(x => x.IsDel == 0 && x.GoodsReceiveId == receiveInfo.Id)
                .ToListAsync();
            if (!receiveDetails.Any()) return Ok(view);

            var goodsIds = receiveDetails.Select(y => y.GoodsId).ToList();
            var goodsInfos = await _sqlSugar.Queryable<Pm_GoodsInfo>()
                .Where(x => x.IsDel == 0 && goodsIds.Contains(x.Id))
                .ToListAsync();
            if (!goodsInfos.Any()) return Ok(view);

            string priceName = string.Join("、", goodsInfos.Select(x => x.Name).ToList());
            //物品价格 按照物品批次单价计算
            var goodsPriceDetails = new StringBuilder();
            decimal price = 0.00M; //物品累计价格

            var goodsStorages = await _sqlSugar.Queryable<Pm_GoodsStorage>().Where(x => x.IsDel == 0 && goodsIds.Contains(x.GoodsId)).ToListAsync();
            foreach (var item in receiveDetails)
            {
                List<GoodsReceiveLinkStorageView> storageFlows = new();
                if (!string.IsNullOrEmpty(item.GoodsStorageInfo))
                {
                    storageFlows = JsonConvert.DeserializeObject<List<GoodsReceiveLinkStorageView>>(item.GoodsStorageInfo);
                }

                if (storageFlows.Any())
                {
                    storageFlows.ForEach(storage =>
                    {
                        price += goodsStorages.FirstOrDefault(x => x.Id == storage.StorageId)?.UnitPrice ?? 0m * storage.Quantity;
                    });
                }
            }

            decimal quantity = 1m;
            var total = price * quantity;

            string remark = $"物资领用模块添加!需核对领用物品价格！！！";

            if (!string.IsNullOrEmpty(receiveInfo.Remark)) remark = $"{receiveInfo.Remark}\n物资领用模块添加!需核对领用物品价格！！！";

            var requestData = new DecreasePaymentsOpDto()
            {
                Status = 1,
                DiId = groupInfo.Id,
                PriceName = priceName,
                Price = price,
                Quantity = quantity,
                FeeTotal = total,
                Currency = 836,
                FilePath = "",
                OrbitalPrivateTransfer = 0,
                OTAOrderNo = "-",
                OtherBankName = "-",
                OtherSideName = "-",
                OtherSideNo = "-",
                PayDId = 105,
                SupplierAddress = "-",
                SupplierArea = 1,
                SupplierContact = "-",
                SupplierContactNumber = "-",
                SupplierEmail = "-",
                SupplierName = "-",
                SupplierSocialAccount = "-",
                SupplierTypeId = 0,
                CreateUserId = receiveInfo.CreateUserId,
                Remark = remark
            };


            //1   2590 √
            //2   2737 √ √
            //3   2760 √ √
            //4   2761 √ √
            //5   2788 √ √
            //6   2796 √ √
            //7   2809 √ √
            //8   2833 √ √
            //9   2834 √ √
            //10  2839 √ √
            //11  2846 √ √


            //其他费用
            #region 调用方法
            JsonView groupData = await _otherPaymentRep.OpDecreasePayments(requestData);
            if (groupData.Code != 200)
            {
                view.Msg += groupData.Msg;
                return Ok(view);
            }

            #region 应用推送

            int diId = requestData.DiId, status = requestData.Status;

            int otherId = Convert.ToInt32(groupData.Data.GetType().GetProperty("dataId").GetValue(groupData.Data, null) ?? 0);
            int ccpId = Convert.ToInt32(groupData.Data.GetType().GetProperty("ccpId").GetValue(groupData.Data, null) ?? 0);
            int sign = Convert.ToInt32(groupData.Data.GetType().GetProperty("sign").GetValue(groupData.Data, null) ?? 0);

            //自动审核
            //var autoAdit = await _feeAuditRep.FeeAutomaticAudit(3, diId, otherId);

            await AppNoticeLibrary.SendChatMsg_GroupStatus_ApplyFee(ccpId, sign, QiyeWeChatEnum.GuoJiaoLeaderChat);

            //2024-10-21 新增LZ UID
            var userIds = new List<int>() { 208 };
            //var userIds = new List<int>() { 21 };
            string title = $"系统通知";
            string content = "";

            var ccpInfo = await _sqlSugar.Queryable<Grp_CreditCardPayment>().Where(x => x.Id == ccpId).FirstAsync();
            if (status == 1) content = $"[新增-其他款项({groupInfo?.TeamName ?? "-"})]一项费用：{(ccpInfo.PayMoney * ccpInfo.DayRate).ToString("#0.00")} CNY;";
            else if (status == 2) content = $"[更新-其他款项({groupInfo?.TeamName ?? "-"})]一项费用：{(ccpInfo.PayMoney * ccpInfo.DayRate).ToString("#0.00")} CNY;";

            await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.GroupBusinessOperations, title, content, userIds, diId);

            //await APNsTools.iOS_PushNotifications1("051", $"其他款项费用审核", "", content);

            #endregion
            #endregion
            #endregion

            return Ok(view);
        }

        /// <summary>
        /// 物资进销存
        /// 领用 Del
        /// </summary>
        /// <returns></returns>
        [HttpDelete("{id}")]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GoodsReceiveDel(int id)
        {
            var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
            if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));

            if (id < 1) return Ok(JsonView(false, MsgTips.Id));

            return Ok(await _goodsRep.GoodsReceiveDel(id, currUserInfo.UserId));
        }
        #endregion

        #region 员工绩效

        /// <summary>
        /// 员工绩效组成结构获取
        /// </summary>
        /// <param name="userid"></param>
        /// <param name="date"></param>
        /// <param name="loginUser"></param>
        /// <returns></returns>
        [HttpGet]
        public IActionResult GetPerformanceList(int userid, string date, int loginUser)
        {
            var jw = JsonView(false);

            if (!DateTime.TryParse(date, out DateTime date_Dt))
            {
                jw.Msg = "日期格式有误!";
                return Ok(jw);
            }

            string sql_CTE = $@"-- 定义递归查询的CTE
WITH PerAssessmentSettingsCTE AS (
    -- 选择指定ID的记录作为起点
    SELECT
        pac.Id,
        pac.Name,
        pac.AssessmentProportion,
        pac.AssessmentStandard,
        pac.ParentId,
        1 AS Depth

        
    FROM
        Per_AssessmentSetting pac 
    INNER JOIN
    	Per_AssessmentContentSetting pacs 
    ON 
    	pac.id = pacs.assessmentSettingid AND  pacs.isdel = 0
    	
    WHERE
        pacs.userid = {userid}
	AND  
		pac.isdel = 0
        
    UNION ALL

    -- 递归部分，选择所有子级记录
    SELECT
        ps.Id,
        ps.Name,
        ps.AssessmentProportion,
        ps.AssessmentStandard,
        ps.ParentId,
        CAST(caste.Depth as int) + 1
    FROM
        Per_AssessmentSetting ps 
    	
    INNER JOIN PerAssessmentSettingsCTE caste ON ps.Id  = caste.ParentId)
                                             
                                             
-- 从CTE中选择最终结果
SELECT * FROM PerAssessmentSettingsCTE
OPTION (MAXRECURSION 0); -- 允许无限递归      ";

            var result_CTE = _sqlSugar.Ado.SqlQuery<Per_AssessmentSetting>(sql_CTE);

            var ids = result_CTE.Select(x => x.Id);

            var List = _sqlSugar.Queryable<Per_AssessmentSetting>()
                        .LeftJoin<Per_AssessmentContentSetting>((a, b) => a.Id == b.AssessmentSettingId && b.IsDel == 0 && b.UserId == userid)
                        .LeftJoin<Per_AssessmentScore>((a, b, c) => b.Id == c.AssessmentContentSettingId && c.IsDel == 0 && c.YearMonth.Year == date_Dt.Year && c.YearMonth.Month == date_Dt.Month)
                        .Where((a, b) => a.IsDel == 0 && ids.Contains(a.Id))
                        .Select((a, b, c) => new TreeNode
                        {
                            Id = a.Id,
                            ContentId = b.Id,
                            Name = a.Name,
                            ParentId = a.ParentId,
                            AssessmentProportion = a.AssessmentProportion, //占比
                            AssessmentStandard = a.AssessmentStandard, //描述
                            AssessmentProportionChi = b.AssessmentProportionChi, //占比
                            UserId = b.UserId,
                            JobId = b.JobId,
                            AssessmentSettingId = b.AssessmentSettingId,
                            Fixed = b.Fixed,
                            TargetValue = b.TargetValue,
                            AssessmentProportion_Percentage = a.AssessmentProportion * 100,
                            HigherUpAssessment = c.HigherUpAssessment,
                            HigherUpConfig = c.HigherUpConfig,
                            HigherUpUserId = c.HigherUpUserId,
                            Score = c.Score,
                            ScoreTotal = c.ScoreTotal,
                            SelfAssessment = c.SelfAssessment,
                            Status = c.Status,
                            YearMonth = c.YearMonth,
                        })
                        .ToList();


            var rootNodeList = List.Where(x => x.ParentId == 0);
            var rootResult = rootNodeList.Select(x => BuildSubTree(x, List));

            jw.Data = new
            {
                Root = rootResult,
                IsLeader = IsLeader(userid, loginUser)
            };
            jw.Code = 200;
            jw.Msg = "成功";

            return Ok(jw);
        }

        private static TreeNode BuildSubTree(TreeNode parent, List<TreeNode> nodes)
        {
            var children = nodes
                .Where(n => n.ParentId == parent.Id)
                .Select(n => BuildSubTree(n, nodes))
                .ToList();

            parent.Children = children;
            return parent;
        }

        /// <summary>
        /// 绩效项增改
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<IActionResult> AssessmentSettingOperationAsync(PerAssessmentSettingOperationDto dto)
        {
            var jw = JsonView(false);

            if (!ModelState.IsValid)
            {
                jw.Msg = "参数错误";
                jw.Data = ModelState;
                return Ok(jw);
            }

            try
            {
                if (dto.ParentId != 0)
                {
                    var parent = await _sqlSugar.Queryable<Per_AssessmentSetting>().FirstAsync(x => x.IsDel == 0 && x.Id == dto.ParentId);
                    if (parent == null)
                    {
                        jw.Msg = "父级节点不存在";
                        return Ok(jw);
                    }
                }

                var entity = new Per_AssessmentSetting
                {
                    Name = dto.Name,
                    AssessmentProportion = dto.AssessmentProportion,
                    AssessmentStandard = dto.AssessmentStandard,
                    ParentId = dto.ParentId,
                    Id = dto.Id,
                    Remark = dto.Remark,
                };

                jw.Code = 200;
                if (dto.Id == 0)
                {
                    entity.CreateUserId = dto.CreateId;
                    entity.CreateTime = DateTime.Now;
                    await _sqlSugar.Insertable(entity).ExecuteCommandAsync();
                    jw.Msg = "添加成功!";
                }
                else
                {
                    await _sqlSugar.Updateable(entity).ExecuteCommandAsync();
                    jw.Msg = "修改成功!";
                }
            }
            catch (Exception ex)
            {
                jw.Msg = "Api error " + ex.Message;
                jw.Code = 400;
            }

            return Ok(jw);
        }

        /// <summary>
        /// 绩效内容增改
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult AssessmentSettingOperationContentAsync(AssessmentSettingOperationContenDto dto)
        {
            var jw = JsonView(false, "", "");
            var entity = new Per_AssessmentContentSetting
            {
                AssessmentProportionChi = dto.AssessmentProportionChi,
                AssessmentSettingId = dto.AssessmentSettingId,
                CreateTime = DateTime.Now,
                CreateUserId = dto.CreateUserId,
                Fixed = dto.Fixed,
                Id = dto.Id,
                JobId = dto.JobId,
                TargetValue = dto.TargetValue,
                UserId = dto.UserId,
                Remark = dto.Remark,
            };
            var entity_Fk = _sqlSugar.Queryable<Per_AssessmentSetting>().First(x => x.Id == dto.AssessmentSettingId && x.IsDel == 0);

            if (entity_Fk == null)
            {
                jw.Msg = "考核设置不存在";
                return Ok(jw);
            }

            try
            {
                if (dto.Id == 0)
                {
                    //add
                    var insertCount = _sqlSugar.Insertable(entity).ExecuteCommand();
                    jw.Msg = "添加成功!";
                }
                else
                {
                    //update
                    var updateCount = _sqlSugar.Updateable(entity).ExecuteCommand();
                    jw.Msg = "修改成功!";
                }

                jw.Code = 200;
            }
            catch (Exception ex)
            {
                jw.Msg = "Api error " + ex.Message;
                jw.Code = 400;
            }
            return Ok(jw);
        }

        /// <summary>
        /// 绩效项查询
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<IActionResult> QueryAssessmentSettingListOffsetAsync(QueryAssessmentSettingListOffsetAsyncDto dto)
        {
            var jw = JsonView(false);

            RefAsync<int> total = 0;//REF和OUT不支持异步,想要真的异步这是最优解
            var entities = await _sqlSugar.Queryable<Per_AssessmentSetting>()
                                 .Where(x => x.IsDel == 0)
                                 .WhereIF(!string.IsNullOrEmpty(dto.SearchValue), e => e.Name.Contains(dto.SearchValue))
                                 .ToPageListAsync(dto.pageIndex, dto.pageSize, total);

            var DtoResult = entities.Select(e => new
            {
                e.Id,
                e.Name,
                e.AssessmentProportion,
                e.AssessmentStandard,
                e.ParentId,
                e.Remark
            }).ToList();

            jw.Data = new
            {
                total = total.Value,
                dto.pageIndex,
                dto.pageSize,
                List = DtoResult
            };

            jw.Code = 200;
            jw.Msg = "查询成功!";

            return Ok(jw);
        }

        /// <summary>
        /// 绩效分数保存
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult SaveUserAssessmen(SaveUserAssessmenDto dto)
        {
            var jw = JsonView(false, "请传入正确的数据！");
            if (dto.Data.Any())
            {

                if (!DateTime.TryParse(dto.AssessmenData, out DateTime yearMonth_Dt))
                {
                    jw.Data = "月份参数有误！";
                    return Ok(jw);
                }

                try
                {
                    var ids = dto.Data.Select(x => x.AssessmentContentSettingId).ToList();
                    var QueryContent_DB = _sqlSugar.Queryable<Per_AssessmentContentSetting>()
                                                   .InnerJoin<Per_AssessmentSetting>((a, b) => b.IsDel == 0 && a.AssessmentSettingId == b.Id)
                                                   .Where((a, b) => a.IsDel == 0 && ids.Contains(a.Id))
                                                   .Select((a, b) => new
                                                   {
                                                       ContentSettingId = a.Id,
                                                       SettingId = b.Id,
                                                       a.TargetValue,
                                                       b.AssessmentStandard,
                                                       MergeStr = $"【项名称:{b.Name}/目标值:{a.TargetValue}/评估标准:{b.AssessmentStandard}】",
                                                       a.AssessmentProportionChi,
                                                       b.Name
                                                   })
                                                   .ToList()
                                                   .ToDictionary(x => x.ContentSettingId);

                    //删除上级未确认数据
                    var expressionWhere = Expressionable
                            .Create<Per_AssessmentScore>()
                            .And(x => x.YearMonth.Year == yearMonth_Dt.Year && x.YearMonth.Month == yearMonth_Dt.Month)
                            .And(x => ids.Contains(x.AssessmentContentSettingId))
                            .And(x => x.HigherUpConfig == 0)
                            .ToExpression();

                    if (IsLeader(dto.AssessmenUserId, dto.CreateUserId))
                    {
                        expressionWhere = Expressionable
                            .Create<Per_AssessmentScore>()
                            .And(x => x.YearMonth.Year == yearMonth_Dt.Year && x.YearMonth.Month == yearMonth_Dt.Month)
                            .And(x => ids.Contains(x.AssessmentContentSettingId))
                            .ToExpression();
                    }

                    _sqlSugar.BeginTran();
                    _sqlSugar.Updateable<Per_AssessmentScore>()
                             .Where(expressionWhere)
                             .SetColumns(x => new Per_AssessmentScore { IsDel = 1, DeleteUserId = dto.CreateUserId, DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") })
                             .ExecuteCommand();

                    var entityList = new List<Per_AssessmentScore>();
                    foreach (var x in dto.Data)
                    {
                        if (x.HigherUpAssessment > 100 || x.SelfAssessment > 100)
                        {
                            jw.Msg = QueryContent_DB[x.AssessmentContentSettingId].Name + "项分数不能超过100。";
                            return Ok(jw);
                        }

                        Per_AssessmentScore item = new Per_AssessmentScore
                        {
                            AssessmentContentSettingId = x.AssessmentContentSettingId,
                            CreateTime = DateTime.Now,
                            CreateUserId = dto.CreateUserId,
                            Details = QueryContent_DB[x.AssessmentContentSettingId].MergeStr,
                            HigherUpAssessment = x.HigherUpAssessment,
                            HigherUpUserId = x.LeadersId,
                            HigherUpConfig = x.HigherUpAssessment > 0 ? 1 : 0,
                            SelfAssessment = x.SelfAssessment,
                            IsDel = 0,
                            Status = x.Status,
                            YearMonth = yearMonth_Dt,
                            Score = x.SelfAssessment * 0.3M + x.HigherUpAssessment * 0.7M,
                            ScoreTotal = (x.SelfAssessment * 0.3M + x.HigherUpAssessment * 0.7M) * QueryContent_DB[x.AssessmentContentSettingId].AssessmentProportionChi,
                        };
                        entityList.Add(item);
                    }

                    var influenceRow = _sqlSugar.Insertable(entityList).ExecuteCommand();
                    _sqlSugar.CommitTran();
                    jw.Code = 200;
                    jw.Msg = "保存成功！";
                    jw.Data = $"{influenceRow}条数据操作成功！";

                }
                catch (Exception ex)
                {
                    _sqlSugar.RollbackTran();
                    jw.Code = 500;
                    jw.Data = $"API ERROR ({ex.Message})";
                }
            }
            return Ok(jw);
        }

        /// <summary>
        /// 绩效项删除
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult DeleteAssessmentSetting(DeleteAssessmentSettingDto dto)
        {
            var jw = JsonView(false, "删除失败！");
            if (!dto.IdArr.Any())
            {
                jw.Msg = "id不能为空!";
                return Ok(jw);
            }

            var rowCount = _sqlSugar.Updateable<Per_AssessmentSetting>()
                .Where(x => dto.IdArr.Contains(x.Id) && x.IsDel == 0)
                .SetColumns(x => new Per_AssessmentSetting
                {
                    IsDel = 1,
                    DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
                    DeleteUserId = dto.UserId,
                })
                .ExecuteCommand();

            jw.Code = 200;
            jw.Msg = $"修改成功！,修改数量{rowCount}";
            return Ok(jw);
        }

        /// <summary>
        /// 绩效内容删除
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult DeleteAssessmentContentSetting(DeleteAssessmentSettingDto dto)
        {
            var jw = JsonView(false, "删除失败！");
            if (!dto.IdArr.Any())
            {
                jw.Msg = "id不能为空!";
                return Ok(jw);
            }

            var rowCount = _sqlSugar.Updateable<Per_AssessmentContentSetting>()
                .Where(x => dto.IdArr.Contains(x.Id) && x.IsDel == 0)
                .SetColumns(x => new Per_AssessmentContentSetting
                {
                    IsDel = 1,
                    DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
                    DeleteUserId = dto.UserId,
                })
                .ExecuteCommand();

            jw.Code = 200;
            jw.Msg = $"修改成功！,修改数量{rowCount}";
            return Ok(jw);
        }

        private bool IsLeader(int userId, int higherUserId)
        {
            Dictionary<int, List<int>> keyValues = new Dictionary<int, List<int>>()
            {
                { 5 , new List<int>{ 258 , 235, 234, 233, 208 } }
            };

            if (keyValues.ContainsKey(higherUserId))
            {
                return keyValues[higherUserId].Contains(userId);
            }

            return false;
        }

        #endregion

        #region 企微Api测试
        [HttpPost]
        public async Task<IActionResult> GetCheckin_MonthDataAsync(DateTime start, DateTime end)
        {
            var jw = JsonView(false);
            jw.Data = await _qiYeWeChatApiService.GetCheckin_MonthDataAsync1(start, end);
            return Ok(jw);
        }


        [HttpPost]
        public async Task<IActionResult> QueryAssessmentByUser(QueryAssessmentByUser Dto)
        {
            var jw = JsonView(false);
            var user_entity = _sqlSugar.Queryable<Sys_Users>()
                              .First(e => e.Id == Dto.UserId && e.IsDel == 0);

            var start_Bool = DateTime.TryParse(Dto.Start, out DateTime start);
            var end_Bool = DateTime.TryParse(Dto.End, out DateTime end);

            if (!start_Bool || !end_Bool)
            {
                jw.Msg = "时间格式不正确！";
                return Ok(jw);
            }

            jw.Msg = "用户企业微信Id未绑定！";
            if (user_entity != null && !string.IsNullOrEmpty(user_entity.QiyeChatUserId))
            {
                var data = await _qiYeWeChatApiService.QueryAssessmentByUser(start, end, new List<string> { user_entity.QiyeChatUserId });
                jw.Data = data;
                jw.Msg = "查询成功！";
                jw.Code = 200;
            }

            return Ok(jw);
        }

        //[HttpPost]
        //public IActionResult TempTest(QueryAssessmentSettingListOffsetAsyncDto Dto)
        //{
        //    var jw = JsonView(false);


        //    return Ok(jw);
        //}

        #endregion

        #region Ai绩效分析

        [HttpGet]
        public async Task<IActionResult> AiPerformanceAnalysis_JobMarketingAsync
        (int userId, DateTime start, DateTime end, int createUserId)
        {
            var jw = JsonView(false);

            var user_entity = _sqlSugar.Queryable<Sys_Users>()
                              .First(e => e.Id == userId && e.IsDel == 0);

            if (user_entity == null)
            {
                jw.Msg = "用户不存在！";
                return Ok(jw);
            }

            List<string> useridlist = new List<string> { user_entity.QiyeChatUserId };

            //获取企微外出打卡信息
            var checkin_data = await _qiYeWeChatApiService.GetCheckinDataAsync(useridlist, 2, start, end);
            if (checkin_data.errcode != 0)
            {
                jw.Msg = "获取企微外出打卡信息失败！" + checkin_data.errmsg;
                return Ok(jw);
            }

            //获取企微外出申请信息
            var approval_data = await _qiYeWeChatApiService.GetApprovalInfoUpdateAsync(start, end, newCursor: "", size: 100, filters: new List<IQiYeWeChatApiService.FilterCondition>(){
                 new
                  IQiYeWeChatApiService.FilterCondition{
                     key = "creator",
                     value = user_entity.QiyeChatUserId
                  },
                  new IQiYeWeChatApiService.FilterCondition{
                    key="record_type",
                    value="4"
                  }
            });
            if (approval_data.errcode != 0)
            {
                jw.Msg = "获取企微外出申请信息失败！" + approval_data.errmsg;
                return Ok(jw);
            }

            List<ApprovalDetailView> detailViews = new List<ApprovalDetailView>();
            foreach (var item in approval_data.sp_no_list)
            {
                var approval_detail = await _qiYeWeChatApiService.GetApprovalDetailAsync(item);
                if (approval_detail.errcode != 0)
                {
                    jw.Msg = "获取企微外出申请详情失败！" + approval_detail.errmsg;
                    return Ok(jw);
                }
                detailViews.Add(approval_detail);
            }

            string question = $"请根据以下数据分析用户绩效：";
            question += $"外出打卡信息：{JsonConvert.SerializeObject(checkin_data.checkindata)}";
            if (approval_data.sp_no_list.Count > 0)
            {
                question += $"外出申请信息：{JsonConvert.SerializeObject(detailViews)}";
            }
            question += $"请根据我提供的{user_entity.CnName}数据信息（提供的数据已经是一个月的数据），按照一个月拜访20个客户的标准判断是否合格，并给出分析报告。";
            question += @"输出内容格式参考这个我下面提供的模板 “根据您提供的陈小龙2025年9月外出打卡数据，现进行绩效分析如下：\n\n### 一、基础数据统计\n**总打卡次数**：16次  \n**覆盖日期**：9月2日-9月29日（共28天）  \n**有效工作日**：22天（扣除周末）\n\n### 二、客户拜访量分析\n1. **实际拜访客户数**：9个\n   - 重庆商务职业学院（2次）\n   - 重庆市南岸区商务委员会（2次）\n   - 重庆市城投金卡信息产业(集团)股份有限公司（2次）\n   - 玉马路\n   - 重庆市南岸区人民政府外事办公室\n   - 重庆经济技术开发区\n   - 中共南岸区委党校\n   - 重庆市南岸区社会主义学院教学楼\n   - 重庆建筑工程职业学院(东站校区)\n   - 中德职业教育西部中职示范基地\n   - 重庆市璧山区人民政府\n\n2. **与标准对比**：\n   - 目标拜访量：20个客户/月\n   - 完成率：45%（9/20）\n   - **结论：未达到合格标准**\n\n### 三、工作模式分析\n**优势**：\n1. 区域集中度较高：主要活跃在南岸区茶园片区（11次打卡）\n2. 重要客户重复拜访：3个重点客户有2次以上跟进记录\n3. 单日效率突出：9月26日完成4个点位拜访\n\n**待改进点**：\n1. 出勤稳定性不足：28天中仅16天有外出记录\n2. 单日拜访密度低：日均拜访0.57个客户\n3. 时间利用不均衡：多个工作日上午无外出记录\n\n### 四、改进建议\n1. **提升拜访频率**：\n   - 建议将日均拜访量提升至1-1.5个客户\n   - 合理安排行程，减少单点停留时间\n\n2. **优化区域规划**：\n   - 继续保持南岸区的集中开发\n   - 沙坪坝区（大学城）客户可集中安排单日拜访\n\n3. **加强过程管理**：\n   - 建立每日拜访计划\n   - 重要客户保持每月2-3次跟进频率\n\n### 五、综合评级：不合格\n按现行标准（20个客户/月），完成率仅45%。建议结合以下因素综合评估：\n- 客户质量（政府机构/职业院校占比高）\n- 单次拜访实效（需结合业务成果）\n- 区域开发难度\n\n是否需要调整考核标准或提供专项支持，建议直属领导进行面谈沟通。\n\n---\n**数据说明**：本分析仅基于打卡位置去重计算，实际客户数量可能需要结合业务系统数据进一步确认。”";


            var settingTemp = await _sqlSugar.Queryable<Sys_SetData>().FirstAsync(x => x.Id == 1461 && x.IsDel == 0);
            if (settingTemp != null && !string.IsNullOrEmpty(settingTemp.Remark))
            {
                var stringFormatResp = await GeneralMethod.StringFormatAsync(new StringFormatDto
                {
                    FormatTemplate = settingTemp.Remark,
                    Parameters = new List<string> {
                         JsonConvert.SerializeObject(checkin_data.checkindata),
                         JsonConvert.SerializeObject(detailViews),
                         user_entity.CnName
                     }
                });

                if (stringFormatResp.Success)
                {
                    question = stringFormatResp.FormattedResult;
                }
            }

            try
            {
                var resp = await _deepSeekService.ChatAsync(question);
                if (!resp.Success)
                {
                    jw.Msg = "Ai分析用户绩效失败！" + resp.Message;
                    return Ok(jw);
                }

                //获取企微上下班考勤打卡信息
                checkin_data = await _qiYeWeChatApiService.GetCheckinDataAsync(useridlist, 1, start, end);
                if (checkin_data.errcode != 0)
                {
                    jw.Msg = "获取企微上下班考勤打卡信息失败！" + checkin_data.errmsg;
                    return Ok(jw);
                }

                question = $"{JsonConvert.SerializeObject(checkin_data.checkindata)}，请根据我提供的{user_entity.CnName}数据信息（提供的数据已经是一个月的数据）,分析该员工日常考勤情况 ,工作日每天需要打卡俩次分别是早上9点和下午18点，"
                + "输出内容标题不要带有表情或者符号。";

                settingTemp = await _sqlSugar.Queryable<Sys_SetData>().FirstAsync(x => x.Id == 1462 && x.IsDel == 0);
                if (settingTemp != null && !string.IsNullOrEmpty(settingTemp.Remark))
                {
                    var stringFormatResp = await GeneralMethod.StringFormatAsync(new StringFormatDto
                    {
                        FormatTemplate = settingTemp.Remark,
                        Parameters = new List<string> {
                         JsonConvert.SerializeObject(checkin_data.checkindata),
                         user_entity.CnName
                        }
                    });

                    if (stringFormatResp.Success)
                    {
                        question = stringFormatResp.FormattedResult;
                    }
                }

                var kaoqinResp = await _deepSeekService.ChatAsync(question);
                if (!resp.Success)
                {
                    jw.Msg = "Ai分析用户考勤失败！" + resp.Message;
                    return Ok(jw);
                }

                jw.Data = new
                {
                    // checkin_data = checkin_data.checkindata,
                    // approval_data = approval_data.sp_no_list,
                    // detailViews = detailViews,
                    Answer = resp.Answer,
                    kaoqinAnswer = kaoqinResp.Answer
                };

                //保存至数据库中
                Pm_PerformanceAnalysis insertData = new Pm_PerformanceAnalysis
                {
                    CreateTime = DateTime.Now,
                    CreateUserId = createUserId,
                    IsDel = 0,
                    Year = start.Year,
                    Month = start.Month,
                    JsonResult = JsonConvert.SerializeObject(jw.Data),
                    UserId = userId,
                };

                await _sqlSugar.Insertable(insertData).ExecuteCommandAsync();

            }
            catch (Exception ex)
            {
                jw.Msg = "Ai分析用户绩效失败！" + ex.Message;
                return Ok(jw);
            }

            jw.Code = 200;
            jw.Msg = "查询成功！";

            return Ok(jw);
        }

        class wordTable
        {
            public int 序号 { get; set; }
            public string 团组名 { get; set; }
            public decimal 营业颔 { get; set; }

            public string 出访日期 { get; set; }

            public int 人数 { get; set; }

            // public string 收款日期 { get; set; }
        };

        [HttpPost]
        public async Task<IActionResult> AiPerformanceAnalysis_JobMarketingFileDownAsync(int year, int month, int userId)
        {
            var jw = JsonView(false);

            var user_entity = _sqlSugar.Queryable<Sys_Users>()
                            .First(e => e.Id == userId && e.IsDel == 0);

            if (user_entity == null)
            {
                jw.Msg = "用户不存在！";
                return Ok(jw);
            }

            var data = new Pm_PerformanceAnalysis();

            if (year < 1 && month < 1)
            {
                data = await _sqlSugar.Queryable<Pm_PerformanceAnalysis>()
                .Where(x => x.UserId == userId && x.IsDel == 0)
                .OrderByDescending(x => x.CreateTime)
                .FirstAsync();
            }
            else
            {
                data = await _sqlSugar.Queryable<Pm_PerformanceAnalysis>()
                .Where(x => x.UserId == userId && x.Year == year && x.Month == month && x.IsDel == 0)
                .FirstAsync();
            }

            if (data == null)
            {
                jw.Msg = "数据不存在！";
                return Ok(jw);
            }

            var jsonResult = JObject.Parse(data.JsonResult);

            var answer = jsonResult["Answer"]?.toString();
            var kaoqinAnswer = jsonResult["kaoqinAnswer"]?.toString();
            var tableapi = await this.AiPerformanceAnalysis_GroupStatisticsAsync(
              userId,
                new DateTime(data.Year, data.Month, 1),
                new DateTime(data.Year, data.Month, 1).AddMonths(1)
                );

            var jwValue = (((tableapi as OkObjectResult).Value) as OASystem.Domain.ViewModels.JsonView);
            if (jwValue.Code != 200)
            {
                jw.Msg = "获取团组统计数据失败！" + jwValue.Msg;
                return Ok(jw);
            }

            var tableList = jwValue.Data as List<AiPerformanceAnalysis_GroupStatisticsView>;
            if (tableList == null)
            {
                jw.Msg = "获取团组统计数据失败！";
                return Ok(jw);
            }

            var tableListValue = tableList.Select(x => new wordTable
            {
                序号 = x.RowNumber,
                团组名 = x.TeamName,
                营业颔 = x.GroupSales,
                出访日期 = x.VisitDate.ToString("yyyy-MM-dd"),
                人数 = x.VisitPNumber,
                // 收款日期 = x.CollectionDays.ToString("yyyy-MM-dd")
            })
            .OrderBy(x => x.序号)
            .ToList();

            var url = this.MarkdownToWord(new
             List<WordContentItem>{
                 new
                  WordContentItem{
                     Type = WordContentType.Markdown,
                    MarkdownContent = answer
                  },
                    WordContentItem.FromObjectList(tableListValue, "团组统计")
                  ,
                  new
                  WordContentItem{
                     Type = WordContentType.Markdown,
                    MarkdownContent = kaoqinAnswer
                  }
             }, $"{user_entity.CnName}_{data.Year}年{data.Month.ToString("00")}月绩效分析");

            jw.Data = new { url };
            jw.Code = 200;
            jw.Msg = "操作成功！";
            return Ok(jw);
        }

        /// <summary>
        /// Word文档内容项类型
        /// </summary>
        public enum WordContentType
        {
            Markdown,  // Markdown内容
            Table      // 表格内容
        }

        /// <summary>
        /// Word文档内容项
        /// </summary>
        public class WordContentItem
        {
            /// <summary>
            /// 内容类型
            /// </summary>
            public WordContentType Type { get; set; }

            /// <summary>
            /// Markdown内容（当Type为Markdown时使用）
            /// </summary>
            public string MarkdownContent { get; set; }

            /// <summary>
            /// 表格数据（当Type为Table时使用）- 第一行为表头
            /// </summary>
            public List<List<string>> TableData { get; set; }

            /// <summary>
            /// 表格标题（可选）
            /// </summary>
            public string TableTitle { get; set; }

            /// <summary>
            /// 从DataTable创建表格数据（便捷方法）
            /// </summary>
            /// <param name="dataTable">数据表</param>
            /// <param name="tableTitle">表格标题（可选）</param>
            /// <param name="includeHeader">是否包含表头（默认true）</param>
            /// <returns>WordContentItem实例</returns>
            public static WordContentItem FromDataTable(DataTable dataTable, string? tableTitle = null, bool includeHeader = true)
            {
                if (dataTable == null || dataTable.Rows.Count == 0)
                {
                    return new WordContentItem
                    {
                        Type = WordContentType.Table,
                        TableTitle = tableTitle,
                        TableData = new List<List<string>>()
                    };
                }

                var tableData = new List<List<string>>();

                // 添加表头
                if (includeHeader)
                {
                    var headerRow = new List<string>();
                    foreach (DataColumn column in dataTable.Columns)
                    {
                        headerRow.Add(column.ColumnName);
                    }
                    tableData.Add(headerRow);
                }

                // 添加数据行
                foreach (DataRow row in dataTable.Rows)
                {
                    var dataRow = new List<string>();
                    foreach (DataColumn column in dataTable.Columns)
                    {
                        dataRow.Add(row[column]?.ToString() ?? "");
                    }
                    tableData.Add(dataRow);
                }

                return new WordContentItem
                {
                    Type = WordContentType.Table,
                    TableTitle = tableTitle,
                    TableData = tableData
                };
            }

            /// <summary>
            /// 从对象列表创建表格数据（便捷方法）
            /// </summary>
            /// <typeparam name="T">对象类型</typeparam>
            /// <param name="items">对象列表</param>
            /// <param name="tableTitle">表格标题（可选）</param>
            /// <param name="columnMappings">列映射（属性名 -> 显示名称），如果为null则使用属性名</param>
            /// <returns>WordContentItem实例</returns>
            public static WordContentItem FromObjectList<T>(List<T> items, string? tableTitle = null, Dictionary<string, string>? columnMappings = null)
            {
                if (items == null || items.Count == 0)
                {
                    return new WordContentItem
                    {
                        Type = WordContentType.Table,
                        TableTitle = tableTitle,
                        TableData = new List<List<string>>()
                    };
                }

                var tableData = new List<List<string>>();
                var properties = typeof(T).GetProperties(System.Reflection.BindingFlags.Public | System.Reflection.BindingFlags.Instance);

                // 添加表头
                var headerRow = new List<string>();
                foreach (var prop in properties)
                {
                    string headerName = columnMappings != null && columnMappings.ContainsKey(prop.Name)
                        ? columnMappings[prop.Name]
                        : prop.Name;
                    headerRow.Add(headerName);
                }
                tableData.Add(headerRow);

                // 添加数据行
                foreach (var item in items)
                {
                    var dataRow = new List<string>();
                    foreach (var prop in properties)
                    {
                        var value = prop.GetValue(item);
                        dataRow.Add(value?.ToString() ?? "");
                    }
                    tableData.Add(dataRow);
                }

                return new WordContentItem
                {
                    Type = WordContentType.Table,
                    TableTitle = tableTitle,
                    TableData = tableData
                };
            }
        }

        /// <summary>
        /// 将多个Markdown内容和表格合并转换为Word文档
        /// </summary>
        /// <param name="contentItems">内容项列表（可以是Markdown或表格）</param>
        /// <param name="fileName">文件名（不含扩展名）</param>
        /// <returns>返回文件访问URL</returns>
        private string MarkdownToWord(List<WordContentItem> contentItems, string fileName)
        {
            if (contentItems == null || contentItems.Count == 0)
            {
                throw new ArgumentException("内容项不能为空", nameof(contentItems));
            }

            // 创建新的Word文档
            Aspose.Words.Document doc = new Aspose.Words.Document();
            Aspose.Words.DocumentBuilder builder = new Aspose.Words.DocumentBuilder(doc);

            // 设置默认字体
            builder.Font.Name = "微软雅黑";
            builder.Font.Size = 10.5;

            // Markdown转换管道
            var pipeline = new Markdig.MarkdownPipelineBuilder().UseAdvancedExtensions().Build();

            // 用于记录每次插入内容后的目标段落位置
            Aspose.Words.Paragraph targetParagraph = null;

            // 处理每个内容项
            for (int i = 0; i < contentItems.Count; i++)
            {
                var item = contentItems[i];

                // 如果是第一个内容项，先清理文档开头的空段落
                if (i == 0)
                {
                    // 清理文档开头的所有空段落
                    var firstBody = doc.FirstSection.Body;
                    while (firstBody.Paragraphs.Count > 0)
                    {
                        var firstPara = firstBody.Paragraphs[0];
                        if (string.IsNullOrWhiteSpace(firstPara.GetText().Trim()))
                        {
                            firstPara.Remove();
                        }
                        else
                        {
                            break;
                        }
                    }
                }
                else
                {
                    // 如果不是第一个内容项，移动到目标段落位置
                    if (targetParagraph != null)
                    {
                        builder.MoveTo(targetParagraph);
                    }
                    else
                    {
                        builder.MoveToDocumentEnd();
                    }
                }

                if (item.Type == WordContentType.Markdown)
                {
                    // 处理Markdown内容
                    if (!string.IsNullOrWhiteSpace(item.MarkdownContent))
                    {
                        // 将Markdown转换为HTML
                        string htmlBody = Markdig.Markdown.ToHtml(item.MarkdownContent, pipeline);

                        // 包装成完整的HTML片段，减少body的margin和padding
                        string htmlContent = $@"<!DOCTYPE html>
<html>
<head>
    <meta charset=""UTF-8"">
    <meta http-equiv=""Content-Type"" content=""text/html; charset=UTF-8"">
    <style>
        body {{ font-family: '微软雅黑', 'Microsoft YaHei', SimSun, sans-serif; font-size: 10.5pt; line-height: 1.5; margin: 0; padding: 0; }}
        h1, h2, h3, h4, h5, h6 {{ font-family: '微软雅黑', 'Microsoft YaHei', SimHei, sans-serif; margin-top: 12pt; margin-bottom: 6pt; }}
        h1 {{ margin-top: 0; }}
        p {{ margin: 0; padding: 0; }}
        table {{ border-collapse: collapse; width: 100%; margin: 10px 0; }}
        table th, table td {{ border: 1px solid #ddd; padding: 8px; text-align: left; }}
        table th {{ background-color: #f2f2f2; font-weight: bold; }}
        code {{ font-family: 'Consolas', 'Courier New', monospace; }}
        pre {{ background-color: #f5f5f5; padding: 10px; border-radius: 4px; margin: 6pt 0; }}
        ul, ol {{ margin: 6pt 0; padding-left: 20pt; }}
        li {{ margin: 3pt 0; }}
    </style>
</head>
<body>
{htmlBody}
</body>
</html>";

                        // 使用LoadOptions指定UTF-8编码
                        var loadOptions = new Aspose.Words.LoadOptions
                        {
                            LoadFormat = Aspose.Words.LoadFormat.Html,
                            Encoding = System.Text.Encoding.UTF8
                        };

                        // 从HTML创建临时文档
                        byte[] htmlBytes = System.Text.Encoding.UTF8.GetBytes(htmlContent);
                        using (MemoryStream htmlStream = new MemoryStream(htmlBytes))
                        {
                            Aspose.Words.Document tempDoc = new Aspose.Words.Document(htmlStream, loadOptions);

                            if (i == 0)
                            {
                                // 第一个内容项：先清理所有空段落
                                var firstBody = doc.FirstSection.Body;

                                // 删除所有空段落
                                while (firstBody.Paragraphs.Count > 0)
                                {
                                    var firstPara = firstBody.Paragraphs[0];
                                    if (string.IsNullOrWhiteSpace(firstPara.GetText().Trim()))
                                    {
                                        firstPara.Remove();
                                    }
                                    else
                                    {
                                        break;
                                    }
                                }

                                // 如果文档完全为空，直接替换整个文档内容
                                if (firstBody.Paragraphs.Count == 0)
                                {
                                    // 清空原文档的所有内容
                                    doc.FirstSection.Body.RemoveAllChildren();

                                    // 将临时文档的所有内容节点复制到主文档
                                    foreach (Aspose.Words.Node node in tempDoc.FirstSection.Body.ChildNodes.ToArray())
                                    {
                                        var importedNode = doc.ImportNode(node, true);
                                        doc.FirstSection.Body.AppendChild(importedNode);
                                    }
                                }
                                else
                                {
                                    // 文档有内容，在第一个段落之前插入
                                    var firstPara = firstBody.Paragraphs[0];
                                    builder.MoveTo(firstPara);
                                    builder.InsertDocument(tempDoc, Aspose.Words.ImportFormatMode.KeepSourceFormatting);
                                }

                                // 插入后再次清理开头的空段落，并统一格式
                                firstBody = doc.FirstSection.Body;
                                while (firstBody.Paragraphs.Count > 0)
                                {
                                    var firstPara = firstBody.Paragraphs[0];
                                    if (string.IsNullOrWhiteSpace(firstPara.GetText().Trim()))
                                    {
                                        firstPara.Remove();
                                    }
                                    else
                                    {
                                        // 找到第一个有内容的段落，确保它没有前间距
                                        firstPara.ParagraphFormat.SpaceBefore = 0;
                                        if (firstPara.ParagraphFormat.SpaceAfter > 6)
                                        {
                                            firstPara.ParagraphFormat.SpaceAfter = 6;
                                        }

                                        // 统一字体格式
                                        foreach (Aspose.Words.Run run in firstPara.Runs)
                                        {
                                            if (string.IsNullOrEmpty(run.Font.Name) ||
                                                (!run.Font.Name.Contains("微软") && !run.Font.Name.Contains("Microsoft") &&
                                                 !run.Font.Name.Contains("Sim") && !run.Font.Name.Contains("宋体")))
                                            {
                                                run.Font.Name = "微软雅黑";
                                            }
                                            if (firstPara.ParagraphFormat.StyleIdentifier != Aspose.Words.StyleIdentifier.Heading1 &&
                                                firstPara.ParagraphFormat.StyleIdentifier != Aspose.Words.StyleIdentifier.Heading2 &&
                                                firstPara.ParagraphFormat.StyleIdentifier != Aspose.Words.StyleIdentifier.Heading3 &&
                                                firstPara.ParagraphFormat.StyleIdentifier != Aspose.Words.StyleIdentifier.Heading4 &&
                                                (run.Font.Size == 0 || (run.Font.Size != 12 && run.Font.Size != 14 && run.Font.Size != 16 && run.Font.Size != 18 && run.Font.Size != 20 && run.Font.Size != 24)))
                                            {
                                                run.Font.Size = 10.5;
                                            }
                                        }
                                        break;
                                    }
                                }

                                // 统一处理第一个内容项的所有段落格式
                                foreach (Aspose.Words.Paragraph para in firstBody.Paragraphs)
                                {
                                    if (string.IsNullOrWhiteSpace(para.GetText().Trim()))
                                    {
                                        continue;
                                    }

                                    // 统一段落格式
                                    para.ParagraphFormat.SpaceBefore = 0;
                                    if (para.ParagraphFormat.SpaceAfter > 6)
                                    {
                                        para.ParagraphFormat.SpaceAfter = 6;
                                    }

                                    // 统一字体格式 - 与非第一个内容项的处理逻辑完全一致
                                    foreach (Aspose.Words.Run run in para.Runs)
                                    {
                                        // 统一字体名称 - 强制设置为微软雅黑
                                        if (string.IsNullOrEmpty(run.Font.Name) ||
                                            (!run.Font.Name.Contains("微软") && !run.Font.Name.Contains("Microsoft") &&
                                             !run.Font.Name.Contains("Sim") && !run.Font.Name.Contains("宋体")))
                                        {
                                            run.Font.Name = "微软雅黑";
                                        }

                                        // 统一字体大小 - 与非第一个内容项的逻辑完全一致
                                        bool isHeading = para.ParagraphFormat.StyleIdentifier == Aspose.Words.StyleIdentifier.Heading1 ||
                                                         para.ParagraphFormat.StyleIdentifier == Aspose.Words.StyleIdentifier.Heading2 ||
                                                         para.ParagraphFormat.StyleIdentifier == Aspose.Words.StyleIdentifier.Heading3 ||
                                                         para.ParagraphFormat.StyleIdentifier == Aspose.Words.StyleIdentifier.Heading4;

                                        if (!isHeading)
                                        {
                                            // 非标题：强制统一设置为10.5pt，确保与非第一个内容项一致
                                            run.Font.Size = 10.5;
                                        }
                                        // 标题保持原有大小，但字体名称已在上面的逻辑中统一
                                    }
                                }
                            }
                            else
                            {
                                // 非第一个内容项：插入到目标段落位置
                                builder.InsertDocument(tempDoc, Aspose.Words.ImportFormatMode.KeepSourceFormatting);

                                // 统一字体格式
                                var appendedBody = doc.FirstSection.Body;
                                var allParagraphs = appendedBody.Paragraphs;

                                foreach (Aspose.Words.Paragraph para in allParagraphs)
                                {
                                    // 跳过空段落（不删除）
                                    if (string.IsNullOrWhiteSpace(para.GetText().Trim()))
                                    {
                                        continue;
                                    }

                                    // 统一段落格式
                                    para.ParagraphFormat.SpaceBefore = 0;
                                    if (para.ParagraphFormat.SpaceAfter > 6)
                                    {
                                        para.ParagraphFormat.SpaceAfter = 6;
                                    }

                                    // 统一字体格式
                                    foreach (Aspose.Words.Run run in para.Runs)
                                    {
                                        // 统一字体名称
                                        if (string.IsNullOrEmpty(run.Font.Name) ||
                                            (!run.Font.Name.Contains("微软") && !run.Font.Name.Contains("Microsoft") &&
                                             !run.Font.Name.Contains("Sim") && !run.Font.Name.Contains("宋体")))
                                        {
                                            run.Font.Name = "微软雅黑";
                                        }

                                        // 统一字体大小
                                        bool isHeading = para.ParagraphFormat.StyleIdentifier == Aspose.Words.StyleIdentifier.Heading1 ||
                                                         para.ParagraphFormat.StyleIdentifier == Aspose.Words.StyleIdentifier.Heading2 ||
                                                         para.ParagraphFormat.StyleIdentifier == Aspose.Words.StyleIdentifier.Heading3 ||
                                                         para.ParagraphFormat.StyleIdentifier == Aspose.Words.StyleIdentifier.Heading4;

                                        if (!isHeading)
                                        {
                                            run.Font.Size = 10.5;
                                        }
                                    }
                                }
                            }
                        }

                        // 移动builder到文档末尾
                        builder.MoveToDocumentEnd();
                    }

                    // 如果不是最后一个内容项，添加三个段落作为间隔
                    if (i < contentItems.Count - 1)
                    {
                        for (int p = 0; p < 3; p++)
                        {
                            builder.InsertBreak(Aspose.Words.BreakType.ParagraphBreak);
                            targetParagraph = builder.CurrentParagraph;
                        }
                    }
                }
                else if (item.Type == WordContentType.Table)
                {
                    // 处理表格内容
                    if (item.TableData != null && item.TableData.Count > 0)
                    {
                        // 确保builder在正确位置
                        if (i == 0)
                        {
                            // 第一个内容项，确保在文档开头
                            builder.MoveToDocumentStart();
                            // 清理开头的空段落
                            var tableBody = doc.FirstSection.Body;
                            while (tableBody.Paragraphs.Count > 0)
                            {
                                var firstPara = tableBody.Paragraphs[0];
                                if (string.IsNullOrWhiteSpace(firstPara.GetText().Trim()))
                                {
                                    firstPara.Remove();
                                }
                                else
                                {
                                    break;
                                }
                            }
                            builder.MoveToDocumentStart();
                        }
                        else
                        {
                            builder.MoveToDocumentEnd();
                        }

                        // 添加表格标题（如果有）
                        if (!string.IsNullOrWhiteSpace(item.TableTitle))
                        {
                            builder.InsertBreak(Aspose.Words.BreakType.ParagraphBreak);
                            builder.InsertBreak(Aspose.Words.BreakType.ParagraphBreak);
                            builder.InsertBreak(Aspose.Words.BreakType.ParagraphBreak);

                            // 强制设置为标题3样式
                            builder.ParagraphFormat.StyleIdentifier = Aspose.Words.StyleIdentifier.Heading3;
                            builder.ParagraphFormat.SpaceAfter = 6;
                            builder.ParagraphFormat.SpaceBefore = 0; // 表格标题前不添加间距
                            builder.Font.Size = 12;
                            builder.Font.Bold = true;
                            builder.Font.Name = "微软雅黑";
                            builder.Writeln(item.TableTitle);

                            // 恢复为正常段落样式
                            builder.ParagraphFormat.StyleIdentifier = Aspose.Words.StyleIdentifier.Normal;
                            builder.Font.Bold = false;
                            builder.Font.Size = 10.5;
                            builder.ParagraphFormat.SpaceAfter = 3; // 标题和表格之间的小间距
                        }

                        // 计算列数（取第一行的列数）
                        int columnCount = item.TableData[0]?.Count ?? 0;
                        if (columnCount == 0)
                        {
                            continue; // 跳过空表格
                        }

                        // 创建表格
                        Aspose.Words.Tables.Table table = builder.StartTable();

                        // 设置列宽（平均分配）- 在添加行之前设置
                        for (int colIndex = 0; colIndex < columnCount; colIndex++)
                        {
                            builder.CellFormat.PreferredWidth = Aspose.Words.Tables.PreferredWidth.FromPercent(100.0 / columnCount);
                        }

                        // 先添加表头（第一行），这样表格就不是空的了
                        if (item.TableData.Count > 0)
                        {
                            var headerRow = item.TableData[0];
                            foreach (var headerCell in headerRow)
                            {
                                builder.InsertCell();
                                builder.CellFormat.VerticalAlignment = Aspose.Words.Tables.CellVerticalAlignment.Center;
                                builder.CellFormat.Shading.BackgroundPatternColor = System.Drawing.Color.FromArgb(240, 240, 240);
                                builder.ParagraphFormat.Alignment = Aspose.Words.ParagraphAlignment.Center;
                                builder.Font.Bold = true;
                                builder.Font.Size = 10.5;
                                builder.Font.Name = "微软雅黑";
                                builder.Font.Color = System.Drawing.Color.Black;
                                builder.Write(headerCell ?? "");
                                builder.Font.Bold = false;
                            }
                            builder.EndRow();
                        }

                        // 现在表格有行了，可以设置表格样式
                        table.StyleIdentifier = Aspose.Words.StyleIdentifier.LightGridAccent1;
                        table.AllowAutoFit = true;
                        table.PreferredWidth = Aspose.Words.Tables.PreferredWidth.FromPercent(100);
                        table.Alignment = Aspose.Words.Tables.TableAlignment.Center;

                        // 添加数据行
                        for (int rowIndex = 1; rowIndex < item.TableData.Count; rowIndex++)
                        {
                            var row = item.TableData[rowIndex];
                            // 确保列数一致
                            while (row.Count < columnCount)
                            {
                                row.Add("");
                            }

                            foreach (var cell in row.Take(columnCount))
                            {
                                builder.InsertCell();
                                builder.CellFormat.VerticalAlignment = Aspose.Words.Tables.CellVerticalAlignment.Center;
                                builder.CellFormat.Shading.BackgroundPatternColor = System.Drawing.Color.White;
                                builder.ParagraphFormat.Alignment = Aspose.Words.ParagraphAlignment.Left;
                                builder.Font.Size = 10.5;
                                builder.Font.Name = "微软雅黑";
                                builder.Write(cell ?? "");
                            }
                            builder.EndRow();
                        }

                        builder.EndTable();

                        // 设置较小的段落间距
                        builder.ParagraphFormat.SpaceAfter = 6;

                        // 移动builder到文档末尾
                        builder.MoveToDocumentEnd();
                    }

                    // 如果不是最后一个内容项，添加三个段落作为间隔
                    if (i < contentItems.Count - 1)
                    {
                        for (int p = 0; p < 3; p++)
                        {
                            builder.InsertBreak(Aspose.Words.BreakType.ParagraphBreak);
                            targetParagraph = builder.CurrentParagraph;
                        }
                    }
                }
            }

            // 只清理文档开头的空段落（第一个有内容的段落之前的空段落）
            var body = doc.FirstSection.Body;
            var paragraphs = body.Paragraphs;
            while (paragraphs.Count > 0)
            {
                var firstPara = paragraphs[0];
                var paraText = firstPara.GetText().Trim();
                // 如果第一个段落是空的或只包含空白字符，删除它
                if (string.IsNullOrWhiteSpace(paraText))
                {
                    firstPara.Remove();
                }
                else
                {
                    // 找到第一个有内容的段落，确保它没有前间距
                    firstPara.ParagraphFormat.SpaceBefore = 0;
                    break;
                }
            }

            // 注意：不删除内容项之间用于间隔的空段落

            // 遍历所有段落，确保字体设置正确，并统一段落间距（不删除空段落）
            foreach (Aspose.Words.Paragraph paragraph in doc.GetChildNodes(Aspose.Words.NodeType.Paragraph, true))
            {
                // 跳过空段落（不删除，用于内容项之间的间隔）
                if (string.IsNullOrWhiteSpace(paragraph.GetText().Trim()))
                {
                    continue;
                }

                // 统一段落间距
                if (paragraph.ParagraphFormat.StyleIdentifier != Aspose.Words.StyleIdentifier.Heading1 &&
                    paragraph.ParagraphFormat.StyleIdentifier != Aspose.Words.StyleIdentifier.Heading2 &&
                    paragraph.ParagraphFormat.StyleIdentifier != Aspose.Words.StyleIdentifier.Heading3 &&
                    paragraph.ParagraphFormat.StyleIdentifier != Aspose.Words.StyleIdentifier.Heading4)
                {
                    // 普通段落保持较小的间距
                    if (paragraph.ParagraphFormat.SpaceAfter > 6)
                    {
                        paragraph.ParagraphFormat.SpaceAfter = 6;
                    }
                    // 移除段落前的间距
                    if (paragraph.ParagraphFormat.SpaceBefore > 0)
                    {
                        paragraph.ParagraphFormat.SpaceBefore = 0;
                    }
                }

                foreach (Aspose.Words.Run run in paragraph.Runs)
                {
                    // 如果字体不是中文字体，设置为微软雅黑
                    if (string.IsNullOrEmpty(run.Font.Name) ||
                        (!run.Font.Name.Contains("微软") && !run.Font.Name.Contains("Microsoft") &&
                         !run.Font.Name.Contains("Sim") && !run.Font.Name.Contains("宋体")))
                    {
                        run.Font.Name = "微软雅黑";
                    }
                }
            }

            // 保存文件
            string saveFolder = $"{AppSettingsHelper.Get("WordBasePath")}PerformanceAnalysis";
            if (!Directory.Exists(saveFolder))
            {
                Directory.CreateDirectory(saveFolder);
            }

            string outputFile = $"{fileName}_{DateTime.Now:yyyyMMddHHmmss}.docx";
            string filePath = Path.Combine(saveFolder, outputFile);

            doc.Save(filePath, Aspose.Words.SaveFormat.Docx);

            // 返回访问URL
            return $"{AppSettingsHelper.Get("WordBaseUrl")}Office/Word/PerformanceAnalysis/{outputFile}";
        }

        [HttpGet]
        public async Task<IActionResult> AiPerformanceAnalysis_QueryAsync(int year, int month, int userId)
        {
            if (userId < 1)
            {
                return Ok(JsonView(false, "请传入有效的userId参数！"));
            }

            var data = new Pm_PerformanceAnalysis();

            if (year < 1 && month < 1)
            {
                data = await _sqlSugar.Queryable<Pm_PerformanceAnalysis>()
                .Where(x => x.UserId == userId && x.IsDel == 0)
                .OrderByDescending(x => x.CreateTime)
                .FirstAsync();
            }
            else
            {
                data = await _sqlSugar.Queryable<Pm_PerformanceAnalysis>()
                .Where(x => x.UserId == userId && x.Year == year && x.Month == month && x.IsDel == 0)
                .OrderByDescending(x => x.CreateTime)
                .FirstAsync();
            }

            var result = JObject.Parse(data.JsonResult);

            return Ok(JsonView(true, "操作成功！", new
            {
                data.JsonResult,
                data.Year,
                data.Month,
                data.Id,
                data.CreateTime,
                data = result
            }));
        }

        /// <summary>
        /// Ai绩效分析
        /// 列表查询基础数据
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> AiPerformanceAnalysis_InitAsync()
        {
            var companyDatas = await _sqlSugar.Queryable<Sys_Company>().Where(x => x.IsDel == 0).Select(x => new { x.Id, x.CompanyName }).ToListAsync();
            var jobPostDatas = await _sqlSugar.Queryable<Sys_JobPost>().Where(x => x.IsDel == 0).Select(x => new { x.Id, x.CompanyId, x.JobName }).ToListAsync();
            var userDatas = await _sqlSugar.Queryable<Sys_Users>().Where(x => x.IsDel == 0).Select(x => new { x.Id, x.CompanyId, x.JobPostId, x.CnName }).ToListAsync();

            companyDatas.Insert(0, new { Id = 0, CompanyName = "全部" });
            jobPostDatas.Insert(0, new { Id = 0, CompanyId = 0, JobName = "全部" });
            userDatas.Insert(0, new { Id = 0, CompanyId = 0, JobPostId = 0, CnName = "全部" });
            return Ok(JsonView(true, "操作成功！", new
            {
                companyDatas,
                jobPostDatas,
                userDatas
            }));
        }

        /// <summary>
        /// Ai绩效分析
        /// 用户列表
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> AiPerformanceAnalysis_UserListAsync(AiPerformanceAnalysis_UserListDto dto)
        {
            if (dto.PageIndex < 1)
            {
                dto.PageIndex = 1;
            }

            if (dto.PageSize < 1 || dto.PageSize > 100)
            {
                dto.PageSize = 10;
            }

            RefAsync<int> total = 0;

            var notidsJson = _sqlSugar.Queryable<Sys_SetData>().First(x => x.Id == 1463 && x.IsDel == 0)?.Remark;
            var notids = new List<int>();
            if (!string.IsNullOrWhiteSpace(notidsJson))
            {
                try
                {
                    notids = JsonConvert.DeserializeObject<List<int>>(notidsJson) ?? new List<int>();
                }
                catch
                { }
            }

            var query = _sqlSugar.Queryable<Sys_Users>()
                .LeftJoin<Sys_Company>((u, c) => u.CompanyId == c.Id)
                .LeftJoin<Sys_Department>((u, c, d) => u.DepId == d.Id)
                .LeftJoin<Sys_JobPost>((u, c, d, jp) => u.JobPostId == jp.Id)
                .Where((u, c, d, jp) => u.IsDel == 0 && !notids.Contains(u.Id))
                .WhereIF(!string.IsNullOrEmpty(dto.ScreeningCriteria?.Trim()), (u, c, d, jp) =>
                    u.CnName.Contains(dto.ScreeningCriteria.Trim()) ||
                    c.CompanyName.Contains(dto.ScreeningCriteria.Trim()) ||
                    d.DepName.Contains(dto.ScreeningCriteria.Trim()) ||
                    jp.JobName.Contains(dto.ScreeningCriteria.Trim()) ||
                    SqlFunc.ToString(u.Id).Contains(dto.ScreeningCriteria.Trim()))

                .OrderBy(u => u.CompanyId)
                .OrderBy(u => u.DepId)
                .OrderBy(u => u.JobPostId)
                .OrderBy(u => u.Id);

            var view = await query.Select((u, c, d, jp) => new AiPerformanceAnalysis_UserView()
            {
                RowNumber = SqlFunc.RowNumber("u.CompanyId ASC, u.JobPostId ASC, u.Id ASC"),
                Id = u.Id,
                UserName = u.CnName,
                Sex = u.Sex == 0 ? "男" : u.Sex == 1 ? "女" : "未设置",
                EDate = u.Edate.ToString("yyyy-MM-dd"),
                CompanyId = u.CompanyId,
                CompanyName = c.CompanyName,
                DepId = u.DepId,
                DepName = d.DepName,
                JobPostId = u.JobPostId,
                JobName = jp.JobName,
                WorkYears = SqlFunc.DateDiff(DateType.Year, u.Edate, DateTime.Now)
            })
            .ToPageListAsync(dto.PageIndex, dto.PageSize, total);

            return Ok(JsonView(true, "操作成功!", view, total));
        }


        /// <summary>
        /// Ai绩效分析
        /// 团组统计
        /// </summary>
        /// <param name="userId">用户ID</param>
        /// <param name="start">开始日期(eg:2025-01-01)</param>
        /// <param name="end">结束日期(eg:2025-12-31)</param>
        /// <returns></returns>
        [HttpGet]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> AiPerformanceAnalysis_GroupStatisticsAsync(int userId, DateTime start, DateTime end)
        {
            #region  参数验证

            if (userId < 1)
            {
                return Ok(JsonView(false, "请传入有效UserId。"));
            }

            if (start > end)
            {
                return Ok(JsonView(false, "开始日期不能晚于结束日期。"));
            }
            #endregion

            var parameters = new
            {
                UserId = userId,
                StartDate = start.Date,
                EndDate = end.Date.AddDays(1).AddSeconds(-1) // 包含结束日期的最后一秒
            };

            string sql = @"
SELECT
    ROW_NUMBER() OVER (ORDER BY MonthNumber, CollectionDays) AS RowNumber,
    Id,
    TeamName,
    ClientUnit,
    ClientName,
    VisitDate,
    VisitPNumber,
    JietuanOperator,
    VisitEndDate,
    MonthNumber,
    GroupSales,
    GroupPickupUser,
    CollectionDays
FROM
(
    SELECT
        di.Id,
        di.TeamName,
        di.ClientUnit,
        di.ClientName,
        di.VisitDate,
        di.VisitPNumber,
        di.JietuanOperator,
        di.VisitEndDate,
        DATEPART(MONTH, di.VisitEndDate) AS MonthNumber,
        (
            SELECT CAST(COALESCE(SUM(ItemSumPrice * Rate), 0) AS DECIMAL(12, 2))
            FROM Fin_ForeignReceivables
            WHERE IsDel = 0
                AND di.Id = Diid
                AND AddingWay IN (0, 1, 2)
        ) AS GroupSales,
        u.CnName AS GroupPickupUser,
        DATEADD(DAY, 7, di.VisitEndDate) AS CollectionDays
    FROM Grp_DelegationInfo di WITH (NOLOCK)
    LEFT JOIN Sys_Users u ON di.JietuanOperator = u.Id
    WHERE di.Isdel = 0
        AND di.IsBid = 0 
        AND di.JietuanOperator = @UserId
        AND di.TeamName NOT LIKE '%投标%'
        AND di.VisitDate BETWEEN @StartDate AND @EndDate
        AND EXISTS (
            SELECT 1
            FROM Fin_ForeignReceivables fr
            WHERE fr.IsDel = 0
                AND fr.Diid = di.Id
                AND fr.AddingWay IN (0, 1, 2)
        )
) Temp
ORDER BY MonthNumber, CollectionDays";

            var groupData = await _sqlSugar.SqlQueryable<AiPerformanceAnalysis_GroupStatisticsView>(sql)
           .AddParameters(parameters)
           .ToListAsync();

            return Ok(JsonView(true, "操作成功！", groupData, groupData?.Count ?? 0));

        }

        private class AiPerformanceAnalysis_GroupStatisticsView : MarketingSalesGroupList
        {
            /// <summary>
            ///月份
            /// </summary>
            public int MonthNumber { get; set; }
        }

        /// <summary>
        /// AI绩效分析用户列表视图模型
        /// </summary>
        private class AiPerformanceAnalysis_UserView
        {
            public int RowNumber { get; set; }
            public int Id { get; set; }
            public string UserName { get; set; }
            public string Sex { get; set; }
            public string EDate { get; set; }
            public int CompanyId { get; set; }
            public string CompanyName { get; set; }
            public int DepId { get; set; }
            public string DepName { get; set; }
            public int JobPostId { get; set; }
            public string JobName { get; set; }
            public int WorkYears { get; set; }
        }

        #endregion

    }
}