using Admin.NET.Core.Service; using Admin.NET.Application.Entity; using Microsoft.AspNetCore.Http; using System.Data; using System.Web; using System.Text; namespace Admin.NET.Application; /// /// 批次数据服务 /// [ApiDescriptionSettings(ApplicationConst.WmsOrderGroupName, Order = 100)] public class Mes_BatchOrderUPI_NewService : IDynamicApiController, ITransient { private readonly SqlSugarRepository _rep; public Mes_BatchOrderUPI_NewService(SqlSugarRepository rep) { _rep = rep; } /// /// 分页查询批次数据 /// /// /// [HttpPost] [ApiDescriptionSettings(Name = "Page")] [Description("Mes_BatchOrderUPI_New/Page")] public async Task> Page(Mes_BatchOrderUPI_NewInput input) { var query = CommonPageFilter(input); return await query.OrderBuilder(input, "", "Id").ToPagedListAsync(input.Page, input.PageSize); } /// /// 不分页查询批次数据 /// /// /// [HttpGet] [ApiDescriptionSettings(Name = "List")] [Description("Mes_BatchOrderUPI_New/List")] public async Task> List([FromQuery] Mes_BatchOrderUPI_NewInput input) { var query = CommonPageFilter(input); return await query.OrderBuilder(input, "", "Id").Select().ToListAsync(); } /// /// 增加批次数据 /// /// /// [HttpPost] [ApiDescriptionSettings(Name = "Add")] [Description("Mes_BatchOrderUPI_New/Add")] public async Task Add(AddMes_BatchOrderUPI_NewInput input) { var entity = input.Adapt(); //重复性验证 await CheckExist(entity); await _rep.InsertAsync(entity); return entity.Id; } /// /// 删除批次数据 /// /// /// [HttpPost] [ApiDescriptionSettings(Name = "Delete")] [Description("Mes_BatchOrderUPI_New/Delete")] public async Task Delete(DeleteMes_BatchOrderUPI_NewInput input) { var entity = await _rep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002); //await _rep.FakeDeleteAsync(entity); //假删除 await _rep.DeleteAsync(entity); //真删除 } /// /// 更新批次数据 /// /// /// [HttpPost] [ApiDescriptionSettings(Name = "Update")] [Description("Mes_BatchOrderUPI_New/Update")] public async Task Update(UpdateMes_BatchOrderUPI_NewInput input) { var entity = input.Adapt(); //重复性验证 await CheckExist(entity,true); await _rep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync(); } /// /// 获取批次数据 /// /// /// [HttpGet] [ApiDescriptionSettings(Name = "Detail")] [Description("Mes_BatchOrderUPI_New/Detail")] public async Task Detail([FromQuery] QueryByIdMes_BatchOrderUPI_NewInput input) { return await _rep.GetFirstAsync(u => u.Id == input.Id); } #region 导入 /// /// Excel模板导入批次数据功能 /// /// Excel模板文件 /// 导入的记录数 [HttpPost] [ApiDescriptionSettings(Name = "ImportExcel")] [Description("Mes_BatchOrderUPI_New/ImportExcel")] public async Task ImportExcelAsync(IFormFile file) { int _HeadStartLine = 2;//第1行是说明,第2行是列名 int _DataStartLine = 3;//第3行开始是数据 DataTable importDataTable = ExcelUtil.ImportExcelToDataTable(file, _HeadStartLine, _DataStartLine); var addList =await CommonImport(importDataTable, _DataStartLine); await _rep.InsertRangeAsync(addList); return addList.Count; } /// /// DataTable转换实体对象列表 /// /// /// 模版列名开始行 /// private async Task> CommonImport(DataTable dataTable, int dataStartLine) { var details = new List(); int index = dataStartLine;//模版列名开始行 foreach (System.Data.DataRow row in dataTable.Rows) { index++; //导入模版定制化代码(替换模版使用) var addItem = new Mes_BatchOrderUPI_New(); #region 定义变量 var _UPI = "";//部件条码 var _PlanNo = "";//批次号 var _OrderId = "";//订单号 var _Info5 = "";//生产单号 var _AreaCode = "";//所在区域 var _UpiStatus = "";//板料状态 var _DetailName = "";//部件名称 var _Length = "";//长 var _Width = "";//宽 var _Thk = "";//厚 var _IsPA = "";//是否优化包装 var _PackageCode = "";//包装号 var _MachineXCenter = "";//包装X坐标 var _MachineYCenter = "";//包装Y坐标 var _MachineZCenter = "";//包装Z坐标 var _Sequence = "";//层数 var _Shelf = "";//次序 var _Info1 = "";//纸箱长 var _Info2 = "";//纸箱宽 var _Info3 = "";//纸箱高 var _Info4 = "";//销售合同单号 var _Info6 = "";//第几包 var _Info7 = "";//经销店名称 var _Info8 = "";//产品名称 var _Info10 = "";//客户名称 var _Info9 = "";//包装编码 var _Info11 = "";//自提or发货 var _Info12 = "";//包装部件总数量 var _Info13 = "";//包装面积 var _Info14 = "";//部件名称 var _Info15 = "";//部件数量 var _Info16 = "";//部件尺寸 var _Info17 = "";//机械臂是否旋转 var _UpiFlag = "";//标记 #endregion #region 取值 _UPI = row["部件条码"]?.ToString() ; _PlanNo = row["批次号"]?.ToString() ; _OrderId = row["订单号"]?.ToString() ; _Info5 = row["生产单号"]?.ToString() ; _AreaCode = row["所在区域"]?.ToString() ; _UpiStatus = row["板料状态"]?.ToString() ; _DetailName = row["部件名称"]?.ToString() ; _Length = row["长"]?.ToString() ; _Width = row["宽"]?.ToString() ; _Thk = row["厚"]?.ToString() ; _IsPA = row["是否优化包装"]?.ToString() ; _PackageCode = row["包装号"]?.ToString() ; _MachineXCenter = row["包装X坐标"]?.ToString() ; _MachineYCenter = row["包装Y坐标"]?.ToString() ; _MachineZCenter = row["包装Z坐标"]?.ToString() ; _Sequence = row["层数"]?.ToString() ; _Shelf = row["次序"]?.ToString() ; _Info1 = row["纸箱长"]?.ToString() ; _Info2 = row["纸箱宽"]?.ToString() ; _Info3 = row["纸箱高"]?.ToString() ; _Info4 = row["销售合同单号"]?.ToString() ; _Info6 = row["第几包"]?.ToString() ; _Info7 = row["经销店名称"]?.ToString() ; _Info8 = row["产品名称"]?.ToString() ; _Info10 = row["客户名称"]?.ToString() ; _Info9 = row["包装编码"]?.ToString() ; _Info11 = row["自提or发货"]?.ToString() ; _Info12 = row["包装部件总数量"]?.ToString() ; _Info13 = row["包装面积"]?.ToString() ; _Info14 = row["部件名称"]?.ToString() ; _Info15 = row["部件数量"]?.ToString() ; _Info16 = row["部件尺寸"]?.ToString() ; _Info17 = row["机械臂是否旋转"]?.ToString() ; _UpiFlag = row["标记"]?.ToString() ; #endregion #region 验证 if (string.IsNullOrEmpty(_UPI)) { throw Oops.Oh($"第{index}行[部件条码]{_UPI}不能为空!"); } if(!string.IsNullOrEmpty(_UPI)) { addItem.UPI = (string)(_UPI.Trim()); } if (string.IsNullOrEmpty(_PlanNo)) { throw Oops.Oh($"第{index}行[批次号]{_PlanNo}不能为空!"); } if(!string.IsNullOrEmpty(_PlanNo)) { addItem.PlanNo = (string)(_PlanNo.Trim()); } if (string.IsNullOrEmpty(_OrderId)) { throw Oops.Oh($"第{index}行[订单号]{_OrderId}不能为空!"); } if(!string.IsNullOrEmpty(_OrderId)) { addItem.OrderId = (string)(_OrderId.Trim()); } if(!string.IsNullOrEmpty(_Info5)) { addItem.Info5 = (string)(_Info5.Trim()); } if(!string.IsNullOrEmpty(_AreaCode)) { Admin.NET.Application.AreaCodeEnum enumAreaCode = default(Admin.NET.Application.AreaCodeEnum); if(!Enum.TryParse(_AreaCode, out enumAreaCode)&&!string.IsNullOrEmpty(_AreaCode)) { throw Oops.Oh($"第{index}行[所在区域]{_AreaCode}值不正确!"); } else { addItem.AreaCode = enumAreaCode; } } if (string.IsNullOrEmpty(_UpiStatus)) { throw Oops.Oh($"第{index}行[板料状态]{_UpiStatus}不能为空!"); } if(!string.IsNullOrEmpty(_UpiStatus)) { Admin.NET.Application.UpiStatusEnum enumUpiStatus = default(Admin.NET.Application.UpiStatusEnum); if(!Enum.TryParse(_UpiStatus, out enumUpiStatus)&&!string.IsNullOrEmpty(_UpiStatus)) { throw Oops.Oh($"第{index}行[板料状态]{_UpiStatus}值不正确!"); } else { addItem.UpiStatus = enumUpiStatus; } } if (string.IsNullOrEmpty(_DetailName)) { throw Oops.Oh($"第{index}行[部件名称]{_DetailName}不能为空!"); } if(!string.IsNullOrEmpty(_DetailName)) { addItem.DetailName = (string)(_DetailName.Trim()); } if (string.IsNullOrEmpty(_Length)) { throw Oops.Oh($"第{index}行[长]{_Length}不能为空!"); } if(!string.IsNullOrEmpty(_IsPA)) { if (!int.TryParse(_IsPA, out int outIsPA)&&!string.IsNullOrEmpty(_IsPA)) { throw Oops.Oh($"第{index}行[是否优化包装]{_IsPA}值不正确!"); } if (outIsPA <= 0&&!string.IsNullOrEmpty(_IsPA)) { throw Oops.Oh($"第{index}行[是否优化包装]{_IsPA}值不能小于等于0!"); } else { addItem.IsPA = outIsPA; } } if (string.IsNullOrEmpty(_PackageCode)) { throw Oops.Oh($"第{index}行[包装号]{_PackageCode}不能为空!"); } if(!string.IsNullOrEmpty(_PackageCode)) { addItem.PackageCode = (string)(_PackageCode.Trim()); } if(!string.IsNullOrEmpty(_Sequence)) { if (!int.TryParse(_Sequence, out int outSequence)&&!string.IsNullOrEmpty(_Sequence)) { throw Oops.Oh($"第{index}行[层数]{_Sequence}值不正确!"); } if (outSequence <= 0&&!string.IsNullOrEmpty(_Sequence)) { throw Oops.Oh($"第{index}行[层数]{_Sequence}值不能小于等于0!"); } else { addItem.Sequence = outSequence; } } if(!string.IsNullOrEmpty(_Shelf)) { if (!int.TryParse(_Shelf, out int outShelf)&&!string.IsNullOrEmpty(_Shelf)) { throw Oops.Oh($"第{index}行[次序]{_Shelf}值不正确!"); } if (outShelf <= 0&&!string.IsNullOrEmpty(_Shelf)) { throw Oops.Oh($"第{index}行[次序]{_Shelf}值不能小于等于0!"); } else { addItem.Shelf = outShelf; } } if(!string.IsNullOrEmpty(_Info4)) { addItem.Info4 = (string)(_Info4.Trim()); } if(!string.IsNullOrEmpty(_Info6)) { addItem.Info6 = (string)(_Info6.Trim()); } if(!string.IsNullOrEmpty(_Info7)) { addItem.Info7 = (string)(_Info7.Trim()); } if(!string.IsNullOrEmpty(_Info8)) { addItem.Info8 = (string)(_Info8.Trim()); } if(!string.IsNullOrEmpty(_Info10)) { addItem.Info10 = (string)(_Info10.Trim()); } if(!string.IsNullOrEmpty(_Info9)) { addItem.Info9 = (string)(_Info9.Trim()); } if(!string.IsNullOrEmpty(_Info11)) { addItem.Info11 = (string)(_Info11.Trim()); } if(!string.IsNullOrEmpty(_Info12)) { addItem.Info12 = (string)(_Info12.Trim()); } if(!string.IsNullOrEmpty(_Info13)) { addItem.Info13 = (string)(_Info13.Trim()); } if(!string.IsNullOrEmpty(_Info14)) { addItem.Info14 = (string)(_Info14.Trim()); } if(!string.IsNullOrEmpty(_Info15)) { if (!int.TryParse(_Info15, out int outInfo15)&&!string.IsNullOrEmpty(_Info15)) { throw Oops.Oh($"第{index}行[部件数量]{_Info15}值不正确!"); } if (outInfo15 <= 0&&!string.IsNullOrEmpty(_Info15)) { throw Oops.Oh($"第{index}行[部件数量]{_Info15}值不能小于等于0!"); } else { addItem.Info15 = outInfo15; } } if(!string.IsNullOrEmpty(_Info16)) { addItem.Info16 = (string)(_Info16.Trim()); } if(!string.IsNullOrEmpty(_Info17)) { addItem.Info17 = (string)(_Info17.Trim()); } if(!string.IsNullOrEmpty(_UpiFlag)) { Admin.NET.Application.UpiFlagEnum enumUpiFlag = default(Admin.NET.Application.UpiFlagEnum); if(!Enum.TryParse(_UpiFlag, out enumUpiFlag)&&!string.IsNullOrEmpty(_UpiFlag)) { throw Oops.Oh($"第{index}行[标记]{_UpiFlag}值不正确!"); } else { addItem.UpiFlag = enumUpiFlag; } } #endregion details.Add(addItem); } //验重 await CheckExisitForImport(details); return details; } /// /// 根据版本下载批次数据的Excel导入模板 /// /// 下载的模板文件 [HttpGet] [ApiDescriptionSettings(Name = "DownloadExcelTemplate")] [Description("Mes_BatchOrderUPI_New/DownloadExcelTemplate")] public IActionResult DownloadExcelTemplate() { string _path = TemplateConst.EXCEL_TEMPLATEFILE_导入模版路径 + $"\\批次数据{TemplateConst.EXCEL_TEMPLATEFILE_导入模版名称后缀}.xlsx"; var fileName = HttpUtility.UrlEncode($"导入模板(批次数据).xlsx", Encoding.GetEncoding("UTF-8")); return new FileStreamResult(new FileStream(_path, FileMode.Open), "application/octet-stream") { FileDownloadName = fileName }; } #endregion #region 私有方法 /// /// 公共查询批次数据条件 /// /// /// private ISugarQueryable CommonPageFilter(Mes_BatchOrderUPI_NewInput input) { var query = _rep.AsQueryable() .WhereIF(!string.IsNullOrWhiteSpace(input.SearchKey), u => u.UPI.Contains(input.SearchKey.Trim()) || u.PlanNo.Contains(input.SearchKey.Trim()) || u.OrderId.Contains(input.SearchKey.Trim()) || u.Info5.Contains(input.SearchKey.Trim()) || u.DetailName.Contains(input.SearchKey.Trim()) || u.PackageCode.Contains(input.SearchKey.Trim()) || u.Info4.Contains(input.SearchKey.Trim()) || u.Info6.Contains(input.SearchKey.Trim()) || u.Info7.Contains(input.SearchKey.Trim()) || u.Info8.Contains(input.SearchKey.Trim()) || u.Info10.Contains(input.SearchKey.Trim()) || u.Info9.Contains(input.SearchKey.Trim()) || u.Info11.Contains(input.SearchKey.Trim()) || u.Info12.Contains(input.SearchKey.Trim()) || u.Info13.Contains(input.SearchKey.Trim()) || u.Info14.Contains(input.SearchKey.Trim()) || u.Info16.Contains(input.SearchKey.Trim()) || u.Info17.Contains(input.SearchKey.Trim()) || u.CreateUserName.Contains(input.SearchKey.Trim()) || u.UpdateUserName.Contains(input.SearchKey.Trim()) ) .WhereIF(!string.IsNullOrWhiteSpace(input.UPI), u => u.UPI.Contains(input.UPI.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.PlanNo), u => u.PlanNo.Contains(input.PlanNo.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.OrderId), u => u.OrderId.Contains(input.OrderId.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Info5), u => u.Info5.Contains(input.Info5.Trim())) .WhereIF(input.AreaCode.HasValue, u => u.AreaCode == input.AreaCode) .WhereIF(input.UpiStatus.HasValue, u => u.UpiStatus == input.UpiStatus) .WhereIF(!string.IsNullOrWhiteSpace(input.DetailName), u => u.DetailName.Contains(input.DetailName.Trim())) .WhereIF(input.IsPA>0, u => u.IsPA == input.IsPA) .WhereIF(!string.IsNullOrWhiteSpace(input.PackageCode), u => u.PackageCode.Contains(input.PackageCode.Trim())) .WhereIF(input.Sequence>0, u => u.Sequence == input.Sequence) .WhereIF(input.Shelf>0, u => u.Shelf == input.Shelf) .WhereIF(!string.IsNullOrWhiteSpace(input.Info4), u => u.Info4.Contains(input.Info4.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Info6), u => u.Info6.Contains(input.Info6.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Info7), u => u.Info7.Contains(input.Info7.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Info8), u => u.Info8.Contains(input.Info8.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Info10), u => u.Info10.Contains(input.Info10.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Info9), u => u.Info9.Contains(input.Info9.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Info11), u => u.Info11.Contains(input.Info11.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Info12), u => u.Info12.Contains(input.Info12.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Info13), u => u.Info13.Contains(input.Info13.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Info14), u => u.Info14.Contains(input.Info14.Trim())) .WhereIF(input.Info15>0, u => u.Info15 == input.Info15) .WhereIF(!string.IsNullOrWhiteSpace(input.Info16), u => u.Info16.Contains(input.Info16.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Info17), u => u.Info17.Contains(input.Info17.Trim())) .WhereIF(input.UpiFlag.HasValue, u => u.UpiFlag == input.UpiFlag) .Select(); return query; } /// /// 重复性验证 /// /// 验证对象 /// 是否是编辑 /// private async Task CheckExist( Mes_BatchOrderUPI_New input,bool isEdit=false) { //没有配置组合校验,不需要验重 //没有配置单独校验,不需要验重 } /// /// 根据组合校验和单独校验验证数据是否已存在-导入时验证 /// /// /// private async Task CheckExisitForImport(List inputs) { if (inputs?.Count <= 0) { throw Oops.Oh($"导入数据不能为空"); } //根据组合校验验证表格中中是否已存在相同数据 //根据单独校验验证表格中中是否已存在相同数据 } #endregion }