using Furion; 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.Core; using Myshipping.Core.Entity; using Myshipping.Core.Service; using Newtonsoft.Json.Linq; 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 { /// /// 派车任务 /// [ApiDescriptionSettings("Application", Name = "TaskManageTruck", Order = 10)] public class TaskManageTruckService : ITaskManageTruckService, IDynamicApiController { private readonly ISysCacheService _cache; private readonly ILogger _logger; private readonly SqlSugarRepository _taskTruckRepository; private readonly SqlSugarRepository _taskTruckContaRepository; private readonly SqlSugarRepository _taskBaseRepository; private readonly SqlSugarRepository _bookingPrintTemplateTemplate; private readonly SqlSugarRepository _djyUserConfigConfig; private readonly SqlSugarRepository _bookingExcelTemplateRepository; private readonly SqlSugarRepository _bookingOrderRepository; private readonly SqlSugarRepository _sysUserRepository; const string PRINT_LIST_TYPE_KEY = "booking_truck_print_list"; const string PRINT_DATASOURCE_KEY = "booking_order"; public TaskManageTruckService(SqlSugarRepository taskTruckRepository, SqlSugarRepository taskTruckContaRepository, SqlSugarRepository taskBaseRepository, SqlSugarRepository bookingPrintTemplateTemplate, SqlSugarRepository djyUserConfigConfig, SqlSugarRepository bookingExcelTemplateRepository, SqlSugarRepository bookingOrderRepository, SqlSugarRepository sysUserRepository, ISysCacheService cache, ILogger logger) { _cache = cache; _logger = logger; _taskTruckRepository = taskTruckRepository; _taskTruckContaRepository = taskTruckContaRepository; _taskBaseRepository = taskBaseRepository; _bookingPrintTemplateTemplate = bookingPrintTemplateTemplate; _djyUserConfigConfig = djyUserConfigConfig; _bookingExcelTemplateRepository = bookingExcelTemplateRepository; _bookingOrderRepository = bookingOrderRepository; _sysUserRepository = sysUserRepository; } /// /// 保存派车 /// /// 派车信息 /// 返回回执 [HttpPost("/TaskManageTruck/Save")] public async Task 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; } /// /// 保存内部方法 /// /// 派车信息 /// 返回派车Id [SqlSugarUnitOfWork] private async Task InnerSave(TaskTruckDto info) { TaskTruckInfo entity = info.Adapt(); if (entity == null) throw Oops.Oh($"派车信息不能为空"); List entityCtnList = info.ContaList.Adapt>(); 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.CreatedTime, it.CreatedUserId, it.CreatedUserName, it.IsDeleted, it.BookingId, it.TruckId, it.TruckName, it.TruckCode, it.Status, }).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); }); } } return entity.PK_ID; } /// /// 获取派车详情 /// /// 派车主键 /// 返回回执 [HttpGet("/TaskManageTruck/GetInfo")] public async Task 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(); if (truckCtnList.Count > 0) model.ContaList = truckCtnList.Adapt>(); result.succ = true; result.ext = model; } catch (Exception ex) { result.succ = false; result.msg = $"获取派车详情异常,原因:{ex.Message}"; } return result; } /// /// 通过任务主键获取派车详情 /// /// 派车主键 /// 返回回执 [HttpGet("/TaskManageTruck/GetInfoByTaskId")] public async Task 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(); if (truckCtnList.Count > 0) model.ContaList = truckCtnList.Adapt>(); result.succ = true; result.ext = model; } catch (Exception ex) { result.succ = false; result.msg = $"获取派车详情异常,原因:{ex.Message}"; } return result; } /// /// 打印派车 /// /// 派车主键 /// 打印模板ID /// 分类代码(使用字典【booking_template_category】中的代码) /// 类型,1:pdf、2:xlsx、3:docx /// 打印类型,10:FastReport、20:Excel模板 /// 返回回执 [HttpGet("/TaskManageTruck/Print")] public async Task 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 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().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(); 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().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")); } /// /// 生成打印报表文件 /// /// 派车ID /// 打印模板 /// 文档类型,1:pdf、2:xlsx、3:docx /// 返回文件流 [NonAction] private async Task 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(); 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>(); _logger.LogInformation($"taskTruckId={taskTruckId} 请求打印 JSON={JSON.Serialize(model)}"); return await PrintHelper.GeneratePrintFile(JSON.Serialize(model), reportUrl, PRINT_DATASOURCE_KEY, printFileType, printTemplate); } /// /// 批量派车 /// /// 派车主键组 /// 返回回执 [HttpPost("/TaskManageTruck/SendDispatchBatch")] public async Task SendDispatchBatch([FromBody] string[] pkIds) { TaskManageOrderResultDto result = new TaskManageOrderResultDto(); try { } catch (Exception ex) { } return result; } /// /// 取消派车 /// /// 派车主键 /// 返回回执 [HttpGet("/TaskManageTruck/CancelDispatch")] public async Task CancelDispatch(string pkId) { TaskManageOrderResultDto result = new TaskManageOrderResultDto(); try { } catch (Exception ex) { } return result; } /// /// 批量取消派车 /// /// 派车主键组 /// 返回回执 [HttpPost("/TaskManageTruck/CancelDispatchBatch")] public async Task CancelDispatchBatch([FromBody] string[] pkIds) { TaskManageOrderResultDto result = new TaskManageOrderResultDto(); try { } catch (Exception ex) { } return result; } #region 校验派车 /// /// 校验派车 /// /// 操作类型 /// 派车信息列表 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())) { 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($"派车状态只有暂存、已撤销才能作废"); } } } #endregion /// /// 获取订舱打印模板列表(带有当前用户打印历史排序) /// /// 分类代码(使用字典【booking_template_category】中的代码) /// 打印分类,10:FastReport、20:Excel模板 /// [HttpGet("/TaskManageTruck/PrintTemplateWithHistoryList")] public async Task PrintTemplateWithHistoryList(string cateCode, BookingPrintTemplateType printType) { var typeCode = printType.ToString(); //当前公司所有已配置的模板 var allList = await _bookingPrintTemplateTemplate.AsQueryable() .Filter(null, true).InnerJoin((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(); //当前用户打印历史数据 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; } } } }