using AutoMapper; using Magicodes.ExporterAndImporter.Core; using Magicodes.ExporterAndImporter.Core.Models; using Magicodes.ExporterAndImporter.Excel; using MailKit.Search; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Mvc.RazorPages; using Org.BouncyCastle.Asn1.X509; using SqlSugar; using System; using System.Collections.Generic; using System.Globalization; using System.Linq; using System.Reflection; using System.Reflection.Metadata; using System.Text; using System.Threading.Tasks; using WIDESEA_Core; using WIDESEA_Core.Attributes; using WIDESEA_Core.BaseRepository; using WIDESEA_Core.BaseServices; using WIDESEA_Core.CodeConfigEnum; using WIDESEA_Core.Enums; using WIDESEA_Core.Helper; using WIDESEA_Core.Utilities; using WIDESEA_DTO; using WIDESEA_DTO.Basic; using WIDESEA_DTO.Inbound; using WIDESEA_IBasicService; using WIDESEA_IInboundRepository; using WIDESEA_IInboundService; using WIDESEA_IStockService; using WIDESEA_ITaskInfoRepository; using WIDESEA_Model.Models; using OrderByType = SqlSugar.OrderByType; namespace WIDESEA_InboundService { public partial class InboundOrderService : ServiceBase, IInboundOrderService { /// /// 根据入库单号获取入库单(含明细) /// /// /// public Dt_InboundOrder GetInboundOrder(string inboundOrderNo) { return BaseDal.Db.Queryable().Includes(x => x.Details).First(x => x.OrderNo == inboundOrderNo); ; } /// /// 组盘数据更新 /// /// 入库单 /// 入库单明细 /// 组盘数据 /// public WebResponseContent MaterielGroupUpdateData(Dt_InboundOrder inboundOrder, List inboundOrderDetails, Dt_StockInfo stockInfo) { try { _unitOfWorkManage.BeginTran(); UpdateData(inboundOrder); _inboundOrderDetailService.UpdateData(inboundOrderDetails); _stockService.StockInfoService.AddMaterielGroup(stockInfo); _unitOfWorkManage.CommitTran(); return WebResponseContent.Instance.OK(); } catch (Exception ex) { _unitOfWorkManage.RollbackTran(); return WebResponseContent.Instance.Error(ex.Message); } } /// /// PDA分页查询数据 /// /// 页码 /// 订单号 /// public WebResponseContent QueryOrderInfo(int pageNo, string orderNo) { if (string.IsNullOrEmpty(orderNo)) { object obj = Repository.QueryPage(x => true, pageNo, 10, new Dictionary { { nameof(Dt_InboundOrder.CreateDate), OrderByType.Desc } }).Rows.Select(x => new { x.OrderNo, x.UpperOrderNo, x.CreateDate, x.Creater }); return WebResponseContent.Instance.OK(data: obj); } else { object obj = Repository.QueryPage(x => x.OrderNo == orderNo, pageNo, 10, new Dictionary { { nameof(Dt_InboundOrder.CreateDate), OrderByType.Desc } }).Rows.Select(x => new { x.OrderNo, x.UpperOrderNo, x.CreateDate, x.Creater }); return WebResponseContent.Instance.OK(data: obj); } } //下载模版 public virtual WebResponseContent DownLoadTemplate() { WebResponseContent content = new WebResponseContent(); IExporter exporter = new ExcelExporter(); Inbounddaoc inbounddaoc = new Inbounddaoc(); byte[] data = exporter.ExportHeaderAsByteArray(inbounddaoc).Result; string fileName = ""; fileName ="模板.xlsx"; string savePath = AppDomain.CurrentDomain.BaseDirectory + $"ExcelImprotTemplate"; FileHelper.WriteFile(savePath, fileName, data); content = WebResponseContent.Instance.OK(data: savePath + "\\" + fileName); return content; } //导入 public virtual WebResponseContent Import(List files) { try { if (files == null || files.Count == 0) return new WebResponseContent { Status = true, Message = "请选择上传的文件" }; Microsoft.AspNetCore.Http.IFormFile formFile = files[0]; // 使用Path.Combine,避免硬编码路径分隔符 string dicPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "ExcelImport", DateTime.Now.ToString("yyyyMMdd")); if (!Directory.Exists(dicPath)) Directory.CreateDirectory(dicPath); string fileName = $"{Guid.NewGuid()}_{formFile.FileName}"; string fullPath = Path.Combine(dicPath, fileName); // 使用FileStream保存文件 using (FileStream stream = new FileStream(fullPath, FileMode.Create)) { formFile.CopyTo(stream); } // 初始化Excel导入工具 ExcelImporter importer = new ExcelImporter(); // 导入Excel数据 ImportResult importResult = importer.Import(fullPath, "").Result; if (importResult.HasError) { return WebResponseContent.Instance.Error(importResult.TemplateErrors.Serialize()); } // 假设BaseDal是数据访问层,进行数据存储 List dt_Inbounds = new List(); foreach (var item in importResult.Data) { int Startingcolumn = 0; int Terminationcolumn = 0; if (item.OrderType == "成品") { if (item.UpperOrderNo.Contains("回料")) { Startingcolumn = 14; Terminationcolumn = 37; } } //Dt_InboundOrder dt_2 = new Dt_InboundOrder() //{ // OrderName = item.OrderName, // UpperOrderNo = item.UpperOrderNo, // OrderType = item.OrderType == "原材料" ? (int)InventoryMaterialType.原材料 : (int)InventoryMaterialType.成品, // OrderNo = item.OrderNo, // CreateType = (int)CreateType.daoru, // Creater = "导入", // CreateDate = DateTime.Now, // Startingcolumn= Startingcolumn, // Terminationcolumn= Terminationcolumn //}; //dt_Inbounds.Add(dt_2); } BaseDal.AddData(dt_Inbounds); return WebResponseContent.Instance.OK(); } catch (Exception ex) { // 捕获异常并返回错误消息 return WebResponseContent.Instance.Error(ex.Message); } } public class Inbounddaoc { [ImporterHeader(Name = "物料号")] [ExporterHeader(DisplayName = "物料号")] [SugarColumn(IsNullable = true, ColumnDescription = "物料号", ColumnName = "物料号")] public string OrderName { get; set; } [ImporterHeader(Name = "物料名称")] [ExporterHeader(DisplayName = "物料名称")] [SugarColumn(IsNullable = true, Length = 50, ColumnDescription = "物料名称", ColumnName = "物料名称")] public string UpperOrderNo { get; set; } [ImporterHeader(Name = "类型")] [ExporterHeader(DisplayName = "类型")] [SugarColumn(IsNullable = true, ColumnDescription = "类型", ColumnName = "类型")] public string OrderType { get; set; } [ImporterHeader(Name = "物料详情")] [ExporterHeader(DisplayName = "物料详情")] [SugarColumn(IsNullable = true, Length = 50, ColumnDescription = "物料详情", ColumnName = "物料详情")] public string OrderNo { get; set; } } } }