using Furion;
using Furion.DependencyInjection;
using Furion.DistributedIDGenerator;
using Furion.DynamicApiController;
using Furion.FriendlyException;
using Furion.JsonSerialization;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
using Myshipping.Application.Entity;
using Myshipping.Application.Enum;
using Myshipping.Application.Helper;
using Myshipping.Core;
using Myshipping.Core.Entity;
using Myshipping.Core.Service;
using Newtonsoft.Json.Linq;
using Org.BouncyCastle.Crypto;
using StackExchange.Profiling.Internal;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Web;

namespace Myshipping.Application
{
    /// <summary>
    /// 派车任务
    /// </summary>
    [ApiDescriptionSettings("Application", Name = "TaskManageTruck", Order = 10)]
    public class TaskManageTruckService : ITaskManageTruckService, IDynamicApiController
    {
        private readonly ISysCacheService _cache;
        private readonly ILogger<BookingTruckService> _logger;

        private readonly SqlSugarRepository<TaskTruckInfo> _taskTruckRepository;
        private readonly SqlSugarRepository<TaskTruckCtn> _taskTruckContaRepository;
        private readonly SqlSugarRepository<TaskBaseInfo> _taskBaseRepository;
        private readonly SqlSugarRepository<BookingPrintTemplate> _bookingPrintTemplateTemplate;
        private readonly SqlSugarRepository<DjyUserConfig> _djyUserConfigConfig;
        private readonly SqlSugarRepository<BookingExcelTemplate> _bookingExcelTemplateRepository;
        private readonly SqlSugarRepository<BookingOrder> _bookingOrderRepository;
        private readonly SqlSugarRepository<SysUser> _sysUserRepository;
        private readonly INamedServiceProvider<IBookingTruckService> _namedServiceProvider;

        const string PRINT_LIST_TYPE_KEY = "booking_truck_print_list";
        const string PRINT_DATASOURCE_KEY = "booking_order";
        public TaskManageTruckService(SqlSugarRepository<TaskTruckInfo> taskTruckRepository,
            SqlSugarRepository<TaskTruckCtn> taskTruckContaRepository,
            SqlSugarRepository<TaskBaseInfo> taskBaseRepository,
            SqlSugarRepository<BookingPrintTemplate> bookingPrintTemplateTemplate,
            SqlSugarRepository<DjyUserConfig> djyUserConfigConfig,
            SqlSugarRepository<BookingExcelTemplate> bookingExcelTemplateRepository,
            SqlSugarRepository<BookingOrder> bookingOrderRepository,
            SqlSugarRepository<SysUser> sysUserRepository,
            INamedServiceProvider<IBookingTruckService> namedServiceProvider,
            ISysCacheService cache, ILogger<BookingTruckService> logger)
        {
            _cache = cache;
            _logger = logger;

            _taskTruckRepository = taskTruckRepository;
            _taskTruckContaRepository = taskTruckContaRepository;
            _taskBaseRepository = taskBaseRepository;

            _bookingPrintTemplateTemplate = bookingPrintTemplateTemplate;
            _djyUserConfigConfig = djyUserConfigConfig;
            _bookingExcelTemplateRepository = bookingExcelTemplateRepository;
            _bookingOrderRepository = bookingOrderRepository;
            _sysUserRepository = sysUserRepository;

            _namedServiceProvider = namedServiceProvider;
        }

        /// <summary>
        /// 保存派车
        /// </summary>
        /// <param name="info">派车信息</param>
        /// <returns>返回回执</returns>
        [HttpPost("/TaskManageTruck/Save")]
        public async Task<TaskManageOrderResultDto> Save(TaskTruckDto info)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            try
            {
                var id = await InnerSave(info);

                result.succ = true;
                result.msg = "保存成功";
                result.ext = id;
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = $"保存派车异常，原因：{ex.Message}";
            }

            return result;
        }

        /// <summary>
        /// 保存内部方法
        /// </summary>
        /// <param name="info">派车信息</param>
        /// <returns>返回派车Id</returns>
        [SqlSugarUnitOfWork]
        private async Task<string> InnerSave(TaskTruckDto info)
        {
            TaskTruckInfo entity = info.Adapt<TaskTruckInfo>();

            if (entity == null)
                throw Oops.Oh($"派车信息不能为空");

            List<TaskTruckCtn> entityCtnList = info.ContaList.Adapt<List<TaskTruckCtn>>();

            if (entityCtnList != null && entityCtnList.Count > 0)
            {
                //保存时默认统计箱型箱量
                entity.CntrTotal = string.Join(";", entityCtnList.GroupBy(a => a.CTNALL)
                    .Select(a =>
                    {
                        return $"{a.Key}*{a.ToList().Sum(b => b.CTNNUM.HasValue ? b.CTNNUM.Value : 1)}";
                    }).ToArray());
            }

            if (entity.DispatcherId.HasValue && entity.DispatcherId.Value > 0)
            {
                var dispatchUser = _sysUserRepository.AsQueryable().First(a => a.Id == entity.DispatcherId.Value);

                if (dispatchUser != null)
                    entity.DispatcherName = dispatchUser.Name;
            }

            if (string.IsNullOrWhiteSpace(entity.PK_ID))
            {
                entity.Status = BookingTruckStatus.TEMP.ToString();
                entity.PK_ID = IDGen.NextID().ToString();

                _taskTruckRepository.Insert(entity);

                if (entityCtnList != null && entityCtnList.Count > 0)
                {
                    entityCtnList.ForEach(async ctn =>
                    {
                        ctn.P_ID = entity.PK_ID;
                        ctn.PK_ID = IDGen.NextID().ToString();

                        await _taskTruckContaRepository.InsertAsync(ctn);
                    });
                }
            }
            else
            {
                var model = _taskTruckRepository.AsQueryable().First(a => a.PK_ID == entity.PK_ID);

                if (model == null)
                    throw Oops.Oh($"派车信息获取失败，派车信息不存在或已作废");

                //校验
                ValidateTruck(OperateTypeEnum.Save, new TaskTruckInfo[] { model });

                entity.UpdatedTime = DateTime.Now;
                entity.UpdatedUserId = UserManager.UserId;
                entity.UpdatedUserName = UserManager.Name;

                await _taskTruckRepository.AsUpdateable(entity).IgnoreColumns(it => new
                {
                    it.TenantId,
                    it.TenantName,
                    it.CreatedTime,
                    it.CreatedUserId,
                    it.CreatedUserName,
                    it.IsDeleted,
                    it.BookingId,
                    it.Status,
                    it.TruckFlowNo,
                    it.TaskNo,
                    it.TASK_ID,
                    it.BookingTruckId,
                    it.DispatcherId,
                    it.DispatcherName
                }).ExecuteCommandAsync();

                await _taskTruckContaRepository.DeleteAsync(x => x.P_ID == model.PK_ID);

                if (entityCtnList != null && entityCtnList.Count > 0)
                {
                    entityCtnList.ForEach(async ctn =>
                    {
                        ctn.P_ID = entity.PK_ID;
                        ctn.PK_ID = IDGen.NextID().ToString();

                        //await _bookingTruckContaRepository.AsUpdateable(ctn).IgnoreColumns(it => new
                        //{
                        //    it.TenantId,
                        //    it.CreatedTime,
                        //    it.CreatedUserId,
                        //    it.CreatedUserName,
                        //    it.IsDeleted,
                        //}).ExecuteCommandAsync();

                        await _taskTruckContaRepository.InsertAsync(ctn);
                    });
                }

               var taskInfo = _taskBaseRepository.AsQueryable().First(a => a.PK_ID == model.TASK_ID);

                if(taskInfo != null)
                {
                    taskInfo.TRUCK_NAME = entity.TruckName;
                    taskInfo.UpdatedTime = entity.UpdatedTime;
                    taskInfo.UpdatedUserId = UserManager.UserId;
                    taskInfo.UpdatedUserName = UserManager.Name;

                    await _taskBaseRepository.AsUpdateable(taskInfo).UpdateColumns(it => new
                    {
                        it.TRUCK_NAME,
                        it.UpdatedTime,
                        it.UpdatedUserId,
                        it.UpdatedUserName
                    }).ExecuteCommandAsync();
                }
            }

            return entity.PK_ID;
        }

        /// <summary>
        /// 获取派车详情
        /// </summary>
        /// <param name="pkId">派车主键</param>
        /// <returns>返回回执</returns>
        [HttpGet("/TaskManageTruck/GetInfo")]
        public async Task<TaskManageOrderResultDto> GetInfo(string pkId)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            try
            {
                var truckOrder = _taskTruckRepository.AsQueryable().First(a => a.PK_ID == pkId);

                if (truckOrder == null)
                    throw Oops.Oh($"派车主键{pkId}无法获取业务信息");

                var truckCtnList = _taskTruckContaRepository.AsQueryable().Where(a => a.P_ID == pkId).ToList();

                TaskTruckShowDto model = truckOrder.Adapt<TaskTruckShowDto>();

                if (truckCtnList.Count > 0)
                    model.ContaList = truckCtnList.Adapt<List<TaskTruckCtnDto>>();


                result.succ = true;
                result.ext = model;

            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = $"获取派车详情异常，原因：{ex.Message}";
            }

            return result;
        }

        /// <summary>
        /// 通过任务主键获取派车详情
        /// </summary>
        /// <param name="taskPkId">派车主键</param>
        /// <returns>返回回执</returns>
        [HttpGet("/TaskManageTruck/GetInfoByTaskId")]
        public async Task<TaskManageOrderResultDto> GetInfoByTaskId(string taskPkId)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            try
            {
                var taskBase = _taskBaseRepository.AsQueryable().First(a => a.PK_ID == taskPkId);

                if (taskBase == null)
                    throw Oops.Oh($"任务主键{taskPkId}无法获取业务信息");

                var truckOrder = _taskTruckRepository.AsQueryable().First(a => a.TASK_ID == taskBase.PK_ID);

                if (truckOrder == null)
                    throw Oops.Oh($"任务主键{taskPkId}无法获取派车业务信息");

                var truckCtnList = _taskTruckContaRepository.AsQueryable().Where(a => a.P_ID == truckOrder.PK_ID).ToList();

                TaskTruckShowDto model = truckOrder.Adapt<TaskTruckShowDto>();

                if (truckCtnList.Count > 0)
                    model.ContaList = truckCtnList.Adapt<List<TaskTruckCtnDto>>();

                result.succ = true;
                result.ext = model;

            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = $"获取派车详情异常，原因：{ex.Message}";
            }

            return result;
        }

        /// <summary>
        /// 打印派车
        /// </summary>
        /// <param name="taskPKId">派车主键</param>
        /// <param name="templateId">打印模板ID</param>
        /// <param name="cateCode">分类代码（使用字典【booking_template_category】中的代码）</param>
        /// <param name="printFileType">类型，1：pdf、2：xlsx、3：docx</param>
        /// <param name="printType">打印类型，10：FastReport、20：Excel模板</param>
        /// <returns>返回回执</returns>
        [HttpGet("/TaskManageTruck/Print")]
        public async Task<string> Print([FromQuery] string taskPKId, [FromQuery] long templateId, [FromQuery] string cateCode, [FromQuery] PrintFileTypeEnum printFileType = PrintFileTypeEnum.PDF,
            [FromQuery] BookingPrintTemplateType printType = BookingPrintTemplateType.FastReport)
        {
            var printTemplate = await _bookingPrintTemplateTemplate.AsQueryable().Filter(null, true)
                .FirstAsync(x => x.Id == templateId);

            if (printTemplate == null)
            {
                throw Oops.Bah(BookingErrorCode.BOOK115);
            }

            var truckOrder = _taskTruckRepository.AsQueryable().First(x => x.PK_ID == taskPKId);
            if (!truckOrder.NeedArriveTime.HasValue)
            {
                throw Oops.Oh("要求送达日期不能为空");
            }
            //var order = await _bookingTruckRepository.FirstOrDefaultAsync(x => x.Id == bookingId);
            //var edi = await _bookingEDIExt.FirstOrDefaultAsync(x => x.BookingId == bookingId);
            //if (order == null)
            //{
            //    throw Oops.Bah(BookingErrorCode.BOOK001);
            //}

            var fileName = string.Empty;
            //var dicCate = (await _cache.GetAllDictData()).FirstOrDefault(x => x.Code == cateCode && x.TypeCode == "booking_template_category");
            //if (dicCate == null)
            //{
            //    throw Oops.Bah("分类代码参数不正确");
            //}

            if (printType == BookingPrintTemplateType.FastReport)
            {
                #region FastReport打印
                var bs = await GenPrintFile(taskPKId, printTemplate, printFileType);
                var fileType = "";
                if (printFileType == PrintFileTypeEnum.PDF)
                {
                    fileType = ".pdf";
                }
                else if (printFileType == PrintFileTypeEnum.XLSX)
                {
                    fileType = ".xlsx";
                }
                else if (printFileType == PrintFileTypeEnum.DOCX)
                {
                    fileType = ".docx";
                }
                else
                {
                    throw Oops.Bah("类型参数不正确");
                }

                fileName = $"{DateTime.Now.Ticks}{fileType}";//名称

                ////2023-4-3，根据河川操作要求，文件名只带提单号
                //if (!string.IsNullOrEmpty(order.MBLNO))
                //{
                //    fileName = $"{order.MBLNO}{fileType}";//名称
                //}
                //else
                //{
                //    fileName = $"{order.Id}_{DateTime.Now.Ticks}{fileType}";//名称
                //}
                var opt = App.GetOptions<TempFileOptions>().Path;
                var serverpath = Path.Combine(App.WebHostEnvironment.WebRootPath, opt);//服务器路径
                if (!Directory.Exists(serverpath))
                {
                    Directory.CreateDirectory(serverpath);
                }

                var fullPath = Path.Combine(serverpath, fileName);
                await File.WriteAllBytesAsync(fullPath, bs);

                #endregion
            }

            /*
            else if (printType == BookingPrintTemplateType.ExcelTemplate)
            {
                #region Excel模板打印
                var opt = App.GetOptions<PrintTemplateOptions>();
                var dirAbs = opt.basePath;
                if (string.IsNullOrEmpty(dirAbs))
                {
                    dirAbs = App.WebHostEnvironment.WebRootPath;
                }
                var fileAbsPath = Path.Combine(dirAbs, printTemplate.FilePath);
                _logger.LogInformation($"准备调用EXCEL生成：id：{id}，文件：{printTemplate.FileName}");
                var result = new FileStream(fileAbsPath, FileMode.Open);
                var excelwork = new HSSFWorkbook(result);
                var sheet = excelwork.GetSheetAt(0);
                var entity = await _bookingExcelTemplateRepository.AsQueryable()
                    .Where(x => x.PId == templateId).OrderBy(x => x.Row).ToListAsync();
                if (entity == null)
                {

                    throw Oops.Bah("当前模板未设置");

                }
                for (int _row = 1; _row <= entity.Max(x => x.Row); _row++)
                {

                    if (entity.Where(x => x.Row == _row).Count() > 0)
                    {
                        ////获取行
                        var row = sheet.GetRow(_row - 1);
                        if (row != null)
                        {
                            for (int _cellNum = 1; _cellNum <= entity.Max(x => x.Column); _cellNum++)
                            {
                                if (entity.Where(x => x.Row == _row && x.Column == _cellNum).Count() > 0)
                                {
                                    var name = entity.Where(x => x.Row == _row && x.Column == _cellNum).Select(x => x.Field).FirstOrDefault();

                                    if (name.Split('.')[0].ToLower() == "order")
                                    {

                                        foreach (PropertyDescriptor descriptor in TypeDescriptor.GetProperties(order))
                                        {
                                            var _name = descriptor.Name.ToLower();
                                            if (name.Split('.')[0].ToLower() == "order" && name.Split('.')[1].ToLower() == _name)
                                            {
                                                var value = descriptor.GetValue(order) != null ? descriptor.GetValue(order).ToString() : "";
                                                ICell cell = row.GetCell(_cellNum - 1);
                                                if (descriptor.PropertyType.FullName.Contains("DateTime"))
                                                {
                                                    value = value != "" ? Convert.ToDateTime(value).ToString("yyyy-MM-dd") : "";
                                                }
                                                if (cell != null)
                                                {
                                                    row.Cells[_cellNum - 1].SetCellValue(value);
                                                }
                                                else
                                                {
                                                    row.CreateCell(_cellNum - 1).SetCellValue(value);
                                                }
                                            }
                                        }


                                    }

                                    if (name.Split('.')[0].ToLower() == "edi")
                                    {

                                        foreach (PropertyDescriptor descriptor in TypeDescriptor.GetProperties(edi))
                                        {
                                            var _name = descriptor.Name.ToLower();
                                            if (name.Split('.')[0].ToLower() == "edi" && name.Split('.')[1].ToLower() == _name)
                                            {
                                                var value = descriptor.GetValue(edi) != null ? descriptor.GetValue(edi).ToString() : "";
                                                ICell cell = row.GetCell(_cellNum - 1);
                                                if (descriptor.PropertyType.FullName.Contains("DateTime"))
                                                {
                                                    value = value != "" ? Convert.ToDateTime(value).ToString("yyyy-MM-dd") : "";
                                                }
                                                if (cell != null)
                                                {
                                                    row.Cells[_cellNum - 1].SetCellValue(value);
                                                }
                                                else
                                                {
                                                    row.CreateCell(_cellNum - 1).SetCellValue(value);
                                                }
                                            }
                                        }


                                    }

                                    if (name.Split('.')[0].ToLower() == "userinfo")
                                    {
                                        ICell cell = row.GetCell(_cellNum - 1);
                                        var value = string.Empty;
                                        if (name.Split('.')[1].ToLower() == "username")
                                        {
                                            value = UserManager.Name;
                                        }
                                        if (name.Split('.')[1].ToLower() == "usertel")
                                        {
                                            value = UserManager.TEl;
                                        }
                                        if (name.Split('.')[1].ToLower() == "usermobile")
                                        {
                                            value = UserManager.Phone;
                                        }
                                        if (name.Split('.')[1].ToLower() == "useremail")
                                        {
                                            value = UserManager.Email;
                                        }
                                        if (name.Split('.')[1].ToLower() == "usertenant")
                                        {
                                            value = UserManager.TENANT_NAME;
                                        }
                                        if (cell != null)
                                        {
                                            row.Cells[_cellNum - 1].SetCellValue(value);
                                        }
                                        else
                                        {
                                            row.CreateCell(_cellNum - 1).SetCellValue(value);
                                        }
                                    }
                                }
                            }
                        }
                        else
                        {
                            ////创建行
                            var srow = NpoiExcelExportHelper._.CreateRow(sheet, _row - 1);

                            for (int _cellNum = 1; _cellNum <= entity.Max(x => x.Column); _cellNum++)
                            {
                                if (entity.Where(x => x.Row == _row && x.Column == _cellNum).Count() > 0)
                                {
                                    var name = entity.Where(x => x.Row == _row && x.Column == _cellNum).Select(x => x.Field).FirstOrDefault();

                                    if (name.Split('.')[0].ToLower() == "order")
                                    {
                                        foreach (PropertyDescriptor descriptor in TypeDescriptor.GetProperties(order))
                                        {
                                            var _name = descriptor.Name.ToLower();
                                            if (name.Split('.')[1].ToLower() == _name && name.Split('.')[0].ToLower() == "order")
                                            {
                                                var value = descriptor.GetValue(order) != null ? descriptor.GetValue(order).ToString() : "";
                                                if (descriptor.PropertyType.FullName.Contains("DateTime"))
                                                {
                                                    value = value != "" ? Convert.ToDateTime(value).ToString("yyyy-MM-dd") : "";
                                                }
                                                srow.CreateCell(_cellNum - 1).SetCellValue(value);
                                            }
                                        }
                                    }
                                    if (name.Split('.')[0].ToLower() == "edi")
                                    {
                                        foreach (PropertyDescriptor descriptor in TypeDescriptor.GetProperties(edi))
                                        {
                                            var _name = descriptor.Name.ToLower();
                                            if (name.Split('.')[1].ToLower() == _name && name.Split('.')[0].ToLower() == "edi")
                                            {
                                                var value = descriptor.GetValue(edi) != null ? descriptor.GetValue(edi).ToString() : "";
                                                if (descriptor.PropertyType.FullName.Contains("DateTime"))
                                                {
                                                    value = value != "" ? Convert.ToDateTime(value).ToString("yyyy-MM-dd") : "";
                                                }
                                                srow.CreateCell(_cellNum - 1).SetCellValue(value);
                                            }
                                        }
                                    }

                                    if (name.Split('.')[0].ToLower() == "userinfo")
                                    {

                                        var value = string.Empty;
                                        if (name.Split('.')[1].ToLower() == "username")
                                        {
                                            value = UserManager.Name;
                                        }
                                        if (name.Split('.')[1].ToLower() == "usertel")
                                        {
                                            value = UserManager.TEl;
                                        }
                                        if (name.Split('.')[1].ToLower() == "usermobile")
                                        {
                                            value = UserManager.Phone;
                                        }
                                        if (name.Split('.')[1].ToLower() == "useremail")
                                        {
                                            value = UserManager.Email;
                                        }
                                        if (name.Split('.')[1].ToLower() == "usertenant")
                                        {
                                            value = UserManager.TENANT_NAME;
                                        }

                                        srow.CreateCell(_cellNum - 1).SetCellValue(value);

                                    }
                                }
                            }
                        }

                    }
                }
                var fileFullPath = Path.Combine(App.WebHostEnvironment.WebRootPath, App.GetOptions<TempFileOptions>().Path);//服务器路径
                if (!Directory.Exists(fileFullPath))
                {
                    Directory.CreateDirectory(fileFullPath);
                }

                fileName = $"{DateTime.Now.Ticks}.xls";//名称
                ////2023-4-3，根据河川操作要求，文件名只带提单号
                //if (!string.IsNullOrEmpty(order.MBLNO))
                //{
                //    fileName = $"{order.MBLNO}.xls";//名称
                //}
                //else
                //{
                //    fileName = $"{order.Id}_{DateTime.Now.Ticks}.xls";//名称
                //}
                _logger.LogInformation("导出excel:" + Path.Combine(fileFullPath, fileName));
                var filestream = new FileStream(Path.Combine(fileFullPath, fileName), FileMode.OpenOrCreate, FileAccess.ReadWrite);
                excelwork.Write(filestream);

                #endregion
            }
            */

            //记录打印次数和时间，用于前端动态展示常用的打印类型
            var printRecentListKey = $"{PRINT_LIST_TYPE_KEY}_{cateCode}_{printType}";
            var usrCfg = _djyUserConfigConfig.AsQueryable().First(x => x.CreatedUserId == UserManager.UserId && x.Type == printRecentListKey);
            if (usrCfg == null)
            {
                usrCfg = new DjyUserConfig();
                usrCfg.Type = printRecentListKey;
                usrCfg.ConfigJson = (new long[] { templateId }).ToJson();
                await _djyUserConfigConfig.InsertAsync(usrCfg);
            }
            else
            {
                var arr = JArray.Parse(usrCfg.ConfigJson).Select(x => Convert.ToInt64(x)).Where(x => x != templateId).ToList();
                arr.Insert(0, templateId);
                usrCfg.ConfigJson = arr.ToArray().ToJson();
                await _djyUserConfigConfig.UpdateAsync(usrCfg);
            }

            return HttpUtility.UrlEncode(fileName, Encoding.GetEncoding("UTF-8"));
        }

        /// <summary>
        /// 生成打印报表文件
        /// </summary>
        /// <param name="bookingTruckId">派车ID</param>
        /// <param name="printTemplate">打印模板</param>
        /// <param name="printType">文档类型，1：pdf、2：xlsx、3：docx</param>
        /// <returns>返回文件流</returns>
        [NonAction]
        private async Task<byte[]> GenPrintFile(string taskTruckId, BookingPrintTemplate printTemplate,
            PrintFileTypeEnum printFileType = PrintFileTypeEnum.PDF)
        {
            //打印报表服务地址
            var reportUrl = _cache.GetAllDictData().Result.FirstOrDefault(x => x.TypeCode == "url_set"
                && x.Code == "url_report_generate").Value;

            if (!reportUrl.EndsWith("/"))
            {
                reportUrl += "/";
            }

            var truckOrder = _taskTruckRepository.AsQueryable().First(a => a.PK_ID == taskTruckId);

            if (truckOrder == null)
                throw Oops.Oh($"派车主键{taskTruckId}无法获取业务信息");

            var truckCtnList = _taskTruckContaRepository.AsQueryable().Where(a => a.P_ID == taskTruckId).ToList();

            BookingOrder bookingOrder = null;

            if (truckOrder.BookingId.HasValue && truckOrder.BookingId.Value > 0)
            {
                bookingOrder = _bookingOrderRepository.AsQueryable().First(a => a.Id == truckOrder.BookingId.Value);
            }

            TaskTruckPrintDto model = truckOrder.Adapt<TaskTruckPrintDto>();

            model.IsGuaJi = truckOrder.IsGuaJi ? "是" : "无";
            if (bookingOrder != null)
            {
                model.Vessel = bookingOrder.VESSEL;

                if (!string.IsNullOrWhiteSpace(bookingOrder.VOYNO))
                {
                    model.VoyNo = bookingOrder.VOYNO;
                }
                else
                {
                    model.VoyNo = bookingOrder.VOYNOINNER;
                }

                model.MBLNo = bookingOrder.MBLNO;
                model.CarrierID = bookingOrder.CARRIERID;
                model.Carrier = bookingOrder.CARRIER;
                model.DestinationID = bookingOrder.DESTINATIONID;
                model.Destination = bookingOrder.DESTINATION;
                model.ETD = bookingOrder.ETD;
            }

            if (truckCtnList.Count > 0)
                model.ContaList = truckCtnList.Adapt<List<TaskTruckCtnPrintDto>>();

            _logger.LogInformation($"taskTruckId={taskTruckId} 请求打印 JSON={JSON.Serialize(model)}");

            return await PrintHelper.GeneratePrintFile(JSON.Serialize(model), reportUrl, PRINT_DATASOURCE_KEY,
                printFileType, printTemplate);
        }

        /// <summary>
        /// 派车
        /// </summary>
        /// <param name="pkId">派车主键</param>
        /// <returns>返回回执</returns>
        [HttpGet("/TaskManageTruck/SendDispatch")]
        public async Task<TaskManageOrderResultDto> SendDispatch(string pkId)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            try
            {
                var model = _taskTruckRepository.AsQueryable().First(a => a.PK_ID == pkId);

                if (model == null)
                    throw Oops.Oh($"派车主键{pkId}无法获取业务信息");

                result = await InnerSendDispatch(model);
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = ex.GetMessage();
            }

            return result;
        }

        /// <summary>
        /// 批量派车
        /// </summary>
        /// <param name="pkIds">派车主键组</param>
        /// <returns>返回回执</returns>
        [HttpPost("/TaskManageTruck/SendDispatchBatch")]
        public async Task<TaskManageOrderResultDto> SendDispatchBatch([FromBody] string[] pkIds)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            string batchNo = IDGen.NextID().ToString();

            _logger.LogInformation("批次={no}获取派车请求 {ids}", batchNo, pkIds);

            try
            {
                var list = _taskTruckRepository.AsQueryable()
                    .Where(a => pkIds.Contains(a.PK_ID)).ToList();

                if (list.Count != pkIds.Length)
                    throw Oops.Oh($"部分派车信息获取失败，不能提交，派车信息不存在或已作废");

                //校验
                ValidateTruck(OperateTypeEnum.SendDispatch, list.ToArray());

                List<Task<TaskManageOrderResultDto>> taskList = new List<Task<TaskManageOrderResultDto>>();

                list.ForEach(async tk =>
                {
                    taskList.Add(InnerSendDispatch(tk));
                });

                //等待所有结果
                Task.WaitAll(taskList.ToArray(), 20000);

                result.succ = true;
                result.msg = "派车成功";

                List<string> msgList = new List<string>();

                taskList.ForEach(async a =>
                {
                    var rlt = a.Result;

                    if (!rlt.succ)
                    {
                        result.succ = false;

                        var curInfo = list.FirstOrDefault(a => a.BookingTruckId.Value == (long)rlt.ext2);

                        msgList.Add($"{curInfo.TaskNo} 派车失败 {rlt.msg}");


                    }
                });

                if (msgList.Count > 0)
                {
                    result.succ = false;
                    result.msg = String.Join(";", msgList.ToArray());
                }

                result.ext = msgList;
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = ex.GetMessage("批量派车");
            }

            return result;
        }

        /// <summary>
        /// 批量派车通过任务ID
        /// </summary>
        /// <param name="taskPkIds">Task任务主键组</param>
        /// <returns>返回回执</returns>
        [HttpPost("/TaskManageTruck/SendDispatchBatchByTask")]
        public async Task<TaskManageOrderResultDto> SendDispatchBatchByTask([FromBody] string[] taskPkIds)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            string batchNo = IDGen.NextID().ToString();

            _logger.LogInformation("批次={no}获取派车请求 {ids}", batchNo, taskPkIds);

            try
            {
                var list = _taskTruckRepository.AsQueryable()
                    .Where(a => taskPkIds.Contains(a.TASK_ID)).ToList();

                if (list.Count != taskPkIds.Length)
                    throw Oops.Oh($"部分派车信息获取失败，不能提交，派车信息不存在或已作废");

                //校验
                ValidateTruck(OperateTypeEnum.SendDispatch, list.ToArray());

                List<Task<TaskManageOrderResultDto>> taskList = new List<Task<TaskManageOrderResultDto>>();

                list.ForEach(async tk =>
                {
                    taskList.Add(InnerSendDispatch(tk));
                });

                //等待所有结果
                Task.WaitAll(taskList.ToArray(), 20000);

                result.succ = true;
                result.msg = "派车成功";

                List<string> msgList = new List<string>();

                taskList.ForEach(a =>
                {
                    var rlt = a.Result;

                    if (!rlt.succ)
                    {
                        result.succ = false;

                        var curInfo = list.FirstOrDefault(a => a.BookingTruckId.Value == (long)rlt.ext2);

                        msgList.Add($"{curInfo.TaskNo} 派车失败 {rlt.msg}");


                    }
                });

                if (msgList.Count > 0)
                {
                    result.succ = false;
                    result.msg = String.Join(";", msgList.ToArray());
                }

                result.ext = msgList;
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = ex.GetMessage("批量派车");
            }

            return result;
        }

        /// <summary>
        /// 派车（内部方法）
        /// </summary>
        /// <param name="info">派车详情</param>
        /// <returns>返回回执</returns>
        private async Task<TaskManageOrderResultDto> InnerSendDispatch(TaskTruckInfo info)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            try
            {
                ValidateTruck(OperateTypeEnum.SendDispatch, new TaskTruckInfo[] { info });

                info.UpdatedTime = DateTime.Now;
                info.UpdatedUserId = UserManager.UserId;
                info.UpdatedUserName = UserManager.Name;

                info.Status = BookingTruckStatus.SEND_DISPATCH.ToString();

                await _taskTruckRepository.AsUpdateable(info).IgnoreColumns(it => new
                {
                    it.TenantId,
                    it.TenantName,
                    it.CreatedTime,
                    it.CreatedUserId,
                    it.CreatedUserName,
                    it.IsDeleted,
                    it.BookingId,
                    it.TruckId,
                    it.TruckName,
                    it.TruckCode,
                    it.TruckFlowNo,
                    it.TaskNo,
                    it.TASK_ID,
                    it.BookingTruckId,
                    it.DispatcherId,
                    it.DispatcherName
                }).ExecuteCommandAsync();


                var truckCtnList = _taskTruckContaRepository.AsQueryable().Where(a => a.P_ID == info.PK_ID).ToList();
                BookingTruckDto model = info.Adapt<BookingTruckDto>();

                model.CallBackStatus = info.Status;

                if (truckCtnList.Count > 0)
                    model.ContaList = truckCtnList.Adapt<List<BookingTruckCtnDto>>();

                if (info.BookingTruckId.HasValue)
                    model.Id = info.BookingTruckId.Value;

                //更新完回写订舱的派车信息
                var service = _namedServiceProvider.GetService(nameof(BookingTruckService));
                var rlt = await service.TruckDispatchCompleteCallBack(model);

                result.succ = true;
                result.msg = "派车成功";
                result.ext = rlt;
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = ex.GetMessage("发送派车失败");
            }

            return result;
        }

        /// <summary>
        /// 取消派车
        /// </summary>
        /// <param name="pkId">派车主键</param>
        /// <returns>返回回执</returns>
        [HttpGet("/TaskManageTruck/CancelDispatch")]
        public async Task<TaskManageOrderResultDto> CancelDispatch(string pkId)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            try
            {
                var model = _taskTruckRepository.AsQueryable().First(a => a.PK_ID == pkId);

                if (model == null)
                    throw Oops.Oh($"派车主键{pkId}无法获取业务信息");

                result = await InnerCancelDispatch(model);
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = ex.GetMessage();
            }

            return result;
        }

        /// <summary>
        /// 取消派车（内部方法）
        /// </summary>
        /// <param name="info">派车详情</param>
        /// <returns>返回回执</returns>
        private async Task<TaskManageOrderResultDto> InnerCancelDispatch(TaskTruckInfo info)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            try
            {
                ValidateTruck(OperateTypeEnum.CancelDispatch, new TaskTruckInfo[] { info });

                info.UpdatedTime = DateTime.Now;
                info.UpdatedUserId = UserManager.UserId;
                info.UpdatedUserName = UserManager.Name;

                info.Status = BookingTruckStatus.CANCEL_DISPATCH.ToString();

                await _taskTruckRepository.AsUpdateable(info).IgnoreColumns(it => new
                {
                    it.TenantId,
                    it.CreatedTime,
                    it.CreatedUserId,
                    it.CreatedUserName,
                    it.IsDeleted,
                    it.BookingId,
                    it.TruckId,
                    it.TruckName,
                    it.TruckCode,
                }).ExecuteCommandAsync();

                var truckCtnList = _taskTruckContaRepository.AsQueryable().Where(a => a.P_ID == info.PK_ID).ToList();
                BookingTruckDto model = info.Adapt<BookingTruckDto>();

                model.CallBackStatus = info.Status;

                if (truckCtnList.Count > 0)
                    model.ContaList = truckCtnList.Adapt<List<BookingTruckCtnDto>>();

                if (info.BookingTruckId.HasValue)
                    model.Id = info.BookingTruckId.Value;

                //更新完回写订舱的派车信息
                var service = _namedServiceProvider.GetService(nameof(BookingTruckService));
                var rlt = await service.TruckDispatchCompleteCallBack(model);

                result.succ = true;
                result.msg = "取消成功";
                result.ext = rlt;
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = ex.GetMessage("取消派车失败");
            }

            return result;
        }

        /// <summary>
        /// 批量取消派车
        /// </summary>
        /// <param name="pkIds">派车主键组</param>
        /// <returns>返回回执</returns>
        [HttpPost("/TaskManageTruck/CancelDispatchBatch")]
        public async Task<TaskManageOrderResultDto> CancelDispatchBatch([FromBody] string[] pkIds)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            string batchNo = IDGen.NextID().ToString();

            _logger.LogInformation("批次={no}获取派车请求 {ids}", batchNo, pkIds);

            try
            {
                var list = _taskTruckRepository.AsQueryable()
                    .Where(a => pkIds.Contains(a.PK_ID)).ToList();

                if (list.Count != pkIds.Length)
                    throw Oops.Oh($"部分派车信息获取失败，不能提交，派车信息不存在或已作废");

                //校验
                ValidateTruck(OperateTypeEnum.CancelDispatch, list.ToArray());

                List<Task<TaskManageOrderResultDto>> taskList = new List<Task<TaskManageOrderResultDto>>();

                list.ForEach(async tk =>
                {
                    taskList.Add(InnerCancelDispatch(tk));
                });

                //等待所有结果
                Task.WaitAll(taskList.ToArray(), 20000);

                result.succ = true;
                result.msg = "取消派车成功";

                List<string> msgList = new List<string>();

                taskList.ForEach(async a =>
                {
                    var rlt = a.Result;

                    if (!rlt.succ)
                    {
                        result.succ = false;

                        var curInfo = list.FirstOrDefault(a => a.BookingTruckId.Value == (long)rlt.ext2);

                        msgList.Add($"{curInfo.TaskNo} 取消派车失败 {rlt.msg}");


                    }
                });

                if (msgList.Count > 0)
                {
                    result.succ = false;
                    result.msg = String.Join(";", msgList.ToArray());
                }

                result.ext = msgList;
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = ex.GetMessage("批量取消派车失败");
            }

            return result;
        }

        /// <summary>
        /// 批量取消派车通过任务ID
        /// </summary>
        /// <param name="taskPkIds">Task任务主键组</param>
        /// <returns>返回回执</returns>
        [HttpPost("/TaskManageTruck/CancelDispatchBatchByTask")]
        public async Task<TaskManageOrderResultDto> CancelDispatchBatchByTask([FromBody] string[] taskPkIds)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            string batchNo = IDGen.NextID().ToString();

            _logger.LogInformation("批次={no}获取派车请求 {ids}", batchNo, taskPkIds);

            try
            {
                var list = _taskTruckRepository.AsQueryable()
                    .Where(a => taskPkIds.Contains(a.TASK_ID)).ToList();

                if (list.Count != taskPkIds.Length)
                    throw Oops.Oh($"部分派车信息获取失败，不能提交，派车信息不存在或已作废");

                //校验
                ValidateTruck(OperateTypeEnum.CancelDispatch, list.ToArray());

                List<Task<TaskManageOrderResultDto>> taskList = new List<Task<TaskManageOrderResultDto>>();

                list.ForEach(async tk =>
                {
                    taskList.Add(InnerCancelDispatch(tk));
                });

                //等待所有结果
                Task.WaitAll(taskList.ToArray(), 20000);

                result.succ = true;
                result.msg = "取消派车成功";

                List<string> msgList = new List<string>();

                taskList.ForEach(a =>
                {
                    var rlt = a.Result;

                    if (!rlt.succ)
                    {
                        result.succ = false;

                        var curInfo = list.FirstOrDefault(a => a.BookingTruckId.Value == (long)rlt.ext2);

                        msgList.Add($"{curInfo.TaskNo} 取消派车失败 {rlt.msg}");


                    }
                });

                if (msgList.Count > 0)
                {
                    result.succ = false;
                    result.msg = String.Join(";", msgList.ToArray());
                }

                result.ext = msgList;
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = ex.GetMessage("批量取消派车失败");
            }

            return result;
        }

        #region 校验派车
        /// <summary>
        /// 校验派车
        /// </summary>
        /// <param name="operateType">操作类型</param>
        /// <param name="entityArg">派车信息列表</param>
        private void ValidateTruck(OperateTypeEnum operateType, TaskTruckInfo[] entityArg)
        {
            if (operateType == OperateTypeEnum.Save)
            {
                if (entityArg.Any(a => a.Status != BookingTruckStatus.TEMP.ToString()
                    && a.Status != BookingTruckStatus.CANCELED.ToString() && a.Status != BookingTruckStatus.CANCEL_DISPATCH.ToString()))
                {
                    throw Oops.Oh($"派车状态只有暂存、已撤销才能保存");
                }
            }
            else if (operateType == OperateTypeEnum.Submit)
            {
                if (entityArg.Any(a => a.Status != BookingTruckStatus.TEMP.ToString()
                    && a.Status != BookingTruckStatus.CANCELED.ToString()))
                {
                    throw Oops.Oh($"派车状态只有暂存、已撤销才能提交");
                }
            }
            else if (operateType == OperateTypeEnum.Cancel)
            {
                if (entityArg.Any(a => a.Status != BookingTruckStatus.SUBMITED.ToString()))
                {
                    throw Oops.Oh($"派车状态只有已提交才能撤销派车");
                }
            }
            else if (operateType == OperateTypeEnum.Delete)
            {
                if (entityArg.Any(a => a.Status != BookingTruckStatus.TEMP.ToString()
                    && a.Status != BookingTruckStatus.CANCELED.ToString()))
                {
                    throw Oops.Oh($"派车状态只有暂存、已撤销才能作废");
                }
            }
            else if (operateType == OperateTypeEnum.SendDispatch)
            {
                if (entityArg.Any(a => a.Status != BookingTruckStatus.TEMP.ToString()
                    && a.Status != BookingTruckStatus.SUBMITED.ToString()
                    && a.Status != BookingTruckStatus.CANCEL_DISPATCH.ToString()))
                {
                    throw Oops.Oh($"派车状态只有暂存、已撤销、已提交、已撤销派车才能发送派车");
                }
            }
            else if (operateType == OperateTypeEnum.CancelDispatch)
            {
                if (entityArg.Any(a => a.Status != BookingTruckStatus.SEND_DISPATCH.ToString()))
                {
                    throw Oops.Oh($"派车状态只有已派车才能取消派车");
                }
            }
        }
        #endregion

        /// <summary>
        /// 获取订舱打印模板列表（带有当前用户打印历史排序）
        /// </summary>
        /// <param name="cateCode">分类代码（使用字典【booking_template_category】中的代码）</param>
        /// <param name="printType">打印分类，10：FastReport、20：Excel模板</param>
        /// <returns></returns>
        [HttpGet("/TaskManageTruck/PrintTemplateWithHistoryList")]
        public async Task<dynamic> PrintTemplateWithHistoryList(string cateCode, BookingPrintTemplateType printType)
        {
            var typeCode = printType.ToString();
            //当前公司所有已配置的模板
            var allList = await _bookingPrintTemplateTemplate.AsQueryable()
                .Filter(null, true).InnerJoin<BookingPrinttemplateRight>((d, t) => d.Id == t.PrintTemplateId && t.SysUserId == UserManager.UserId)
                .Where(d => d.TenantId == UserManager.TENANT_ID && d.CateCode.Contains(cateCode) && d.Type == typeCode)
                .Select(d => new
                {
                    d.Id,
                    d.CateCode,
                    d.CateName,
                    d.DisplayName

                })
                .ToListAsync();

            var listReult = new List<dynamic>();
            //当前用户打印历史数据
            var printRecentListKey = $"{PRINT_LIST_TYPE_KEY}_{cateCode}_{printType}";
            var usrCfg = await _djyUserConfigConfig.AsQueryable().FirstAsync(x => x.CreatedUserId == UserManager.UserId && x.Type == printRecentListKey);
            if (usrCfg != null)
            {
                var arr = JArray.Parse(usrCfg.ConfigJson).Select(x => Convert.ToInt64(x)).ToList();

                //按顺序加入到结果
                arr.ForEach(x =>
                {
                    var find = allList.FirstOrDefault(y => y.Id == x);
                    if (find != null)
                    {
                        listReult.Add(find);
                    }
                });

                var listOut = allList.Where(x => !arr.Contains(x.Id)).ToList();
                listReult.AddRange(listOut);

                return listReult;
            }
            else
            {
                return allList;
            }
        }


        /// <summary>
        /// 获取场站数据
        /// </summary>
        /// <param name="pkId">派车任务主键</param>
        /// <param name="isWeb"></param>
        /// <returns>返回场站详情</returns>
        [HttpGet("/TaskManageTruck/GetYardData")]
        public async Task<string> GetYardData(string pkId, bool isWeb = false)
        {
            //订舱派车数据
            var entity = _taskTruckRepository.AsQueryable().First(x => x.PK_ID == pkId);

            if (entity == null)
                throw Oops.Oh($"派车信息不能为空", typeof(InvalidOperationException));

            BookingOrder bookingOrder = null;

            if (entity.BookingId.HasValue)
            {
                bookingOrder = _bookingOrderRepository.AsQueryable().First(x => x.Id == entity.BookingId);
            }

            string yardId = string.Empty;
            string mblNo = string.Empty;

            if (bookingOrder != null)
            {
                yardId = bookingOrder.YARDID;
                mblNo = bookingOrder.MBLNO;
            }

            if (string.IsNullOrWhiteSpace(yardId))
                yardId = entity.YARDID;

            if (string.IsNullOrWhiteSpace(mblNo))
                mblNo = entity.MBLNo;

            if (string.IsNullOrEmpty(yardId))
            {
                throw Oops.Bah("场站信息不能为空");
            }

            if (string.IsNullOrEmpty(mblNo))
            {
                throw Oops.Bah("提单号不能为空");
            }

            var rtn = await YardDataHelper.GetYardDataWithTranslateAsync(UserManager.UserId, bookingOrder.TenantId.Value, bookingOrder.TenantName,
                mblNo, yardId, isWeb);

            return rtn;
        }

    }
}