using Microsoft.Extensions.Logging; using SqlSugar; using WIDESEA_Common.AllocateEnum; using WIDESEA_Common.OrderEnum; using WIDESEA_Core; using WIDESEA_Core.BaseRepository; using WIDESEA_Core.BaseServices; using WIDESEA_Core.CodeConfigEnum; using WIDESEA_Core.DB; using WIDESEA_Core.Helper; using WIDESEA_Core.Seed; using WIDESEA_IAllocateService; using WIDESEA_IBasicService; using WIDESEA_IInboundService; using WIDESEA_IOutboundService; using WIDESEA_Model.Models; namespace WIDESEA_AllocateService { public partial class AllocateService : ServiceBase>, IAllocateService { public readonly IUnitOfWorkManage _unitOfWorkManage; public readonly IInboundService _inboundService; public readonly IOutboundService _outboundService; public readonly IRepository _allocateOrderRepository; public readonly IRepository _allocateOrderDetailRepository; private readonly IMaterielInfoService _materielInfoService; public readonly IRepository _inboundOrderDetailRepository; private readonly ILogger _logger; public AllocateService(IRepository BaseDal, IUnitOfWorkManage unitOfWorkManage, IInboundService inboundService, IOutboundService outboundService, IRepository allocateOrderRepository, IRepository allocateOrderDetailRepository, IRepository inboundOrderDetailRepository, ILogger logger, IMaterielInfoService materielInfoService) : base(BaseDal) { _unitOfWorkManage = unitOfWorkManage; _inboundService = inboundService; _outboundService = outboundService; _allocateOrderRepository = allocateOrderRepository; _allocateOrderDetailRepository = allocateOrderDetailRepository; _logger = logger; _inboundOrderDetailRepository = inboundOrderDetailRepository; _materielInfoService = materielInfoService; } public IRepository Repository => BaseDal; public async Task ReceiveAllocateOrder(Dt_AllocateOrder allocateOrder, int operateType) { try { return operateType switch { 1 => await AddAllocateOrder(allocateOrder), 2 => await UpdateAllocateOrder(allocateOrder), 3 => await DeleteAllocateOrder(allocateOrder), _ => WebResponseContent.Instance.OK(), }; } catch (Exception ex) { return WebResponseContent.Instance.Error(ex.Message); } } public async Task AddAllocateOrder(Dt_AllocateOrder allocateOrder) { try { if (BaseDal.QueryFirst(x => x.UpperOrderNo == allocateOrder.UpperOrderNo) != null) { return WebResponseContent.Instance.Error($"{allocateOrder.UpperOrderNo}调拨单号重复"); } allocateOrder.OrderNo = CreateCodeByRule(nameof(RuleCodeEnum.AllocateOrderCodeRule)); var materielCodes = allocateOrder.Details.Select(x => x.MaterielCode).Distinct().ToList(); var materielInfos = _materielInfoService.Db.Queryable().Where(x => materielCodes.Contains(x.MaterielCode)).ToList(); foreach (var item in allocateOrder.Details) { if (materielInfos.Any()) { item.MaterielName = materielInfos.FirstOrDefault(x => x.MaterielCode == item.MaterielCode)?.MaterielName ?? ""; } } Db.InsertNav(allocateOrder).Include(x => x.Details).ExecuteCommand(); await AddInOutData(allocateOrder); return WebResponseContent.Instance.OK(); } catch (Exception ex) { _logger.LogInformation("AllocateService AddAllocateOrder err: " + ex.Message); return WebResponseContent.Instance.Error(ex.Message); } } private async Task AddInOutData(Dt_AllocateOrder allocateOrder) { if (Enum.TryParse(allocateOrder.BusinessType, out var businessType)) { if (businessType == BusinessTypeEnum.外部仓库调智仓) { allocateOrder.OrderType = (int)InOrderTypeEnum.AllocatInbound; var inboundOrders = ConvertToInboundOrders(allocateOrder); await _inboundService.InbounOrderService.ReceiveInboundOrder(inboundOrders, 1); } else if (businessType == BusinessTypeEnum.智仓调外部仓库 || businessType == BusinessTypeEnum.智仓调智仓) { if (businessType == BusinessTypeEnum.智仓调外部仓库) { allocateOrder.OrderType = (int)InOrderTypeEnum.AllocatOutbound; } else if (businessType == BusinessTypeEnum.智仓调智仓) { allocateOrder.OrderType = (int)InOrderTypeEnum.InternalAllocat; } var outboundOrders = ConvertToOutboundOrders(allocateOrder); await _outboundService.OutboundOrderService.ReceiveOutboundOrder(outboundOrders, 1); } else { // 处理未定义的枚举值(如未来新增但未实现的类型) throw new NotSupportedException($"不支持的业务类型枚举值: {businessType}"); } } } public async Task UpdateAllocateOrder(Dt_AllocateOrder model) { try { var allocateOrder = Db.Queryable().Where(x => x.UpperOrderNo == model.UpperOrderNo).Includes(x => x.Details).First(); if (allocateOrder == null) { return WebResponseContent.Instance.Error($"未找到调拨单信息"); } if (allocateOrder.Details == null || allocateOrder.Details.Count == 0) { return WebResponseContent.Instance.Error($"未找到调拨单明细信息"); } List allocateOrderDetails = new List(); List updateAllocateOrderDetails = new List(); List detailIds = new List(); var materielCodes = allocateOrder.Details.Select(x => x.MaterielCode).Distinct().ToList(); var materielInfos = _materielInfoService.Db.Queryable().Where(x => materielCodes.Contains(x.MaterielCode)).ToList(); foreach (var item in model.Details) { if (!string.IsNullOrEmpty(item.Barcode)) { Dt_AllocateOrderDetail? allocateOrderDetail = allocateOrder.Details.FirstOrDefault(x => x.Barcode == item.Barcode); if (allocateOrderDetail == null) { allocateOrderDetail = new Dt_AllocateOrderDetail() { OrderId = allocateOrder.Id, MaterielCode = item.MaterielCode, LineNo = item.LineNo, BatchNo = item.BatchNo, Unit = item.Unit, WarehouseCode = item.WarehouseCode, Barcode = item.Barcode, BarcodeUnit = item.BarcodeUnit, BarcodeQty = (decimal)item.BarcodeQty, OrderQuantity = item.OrderQuantity }; if (materielInfos.Any()) { allocateOrderDetail.MaterielName = materielInfos.FirstOrDefault(x => x.MaterielCode == item.MaterielCode)?.MaterielName ?? ""; } allocateOrderDetails.Add(allocateOrderDetail); } else { allocateOrderDetail.LineNo = item.LineNo; allocateOrderDetail.MaterielCode = item.MaterielCode; allocateOrderDetail.BatchNo = item.BatchNo; allocateOrderDetail.Unit = item.Unit; allocateOrderDetail.WarehouseCode = item.WarehouseCode; allocateOrderDetail.Barcode = item.Barcode; allocateOrderDetail.BarcodeUnit = item.BarcodeUnit; allocateOrderDetail.BarcodeQty = item.BarcodeQty; allocateOrderDetail.OrderQuantity = item.OrderQuantity; if (materielInfos.Any()) { allocateOrderDetail.MaterielName = materielInfos.FirstOrDefault(x => x.MaterielCode == item.MaterielCode)?.MaterielName ?? ""; } updateAllocateOrderDetails.Add(allocateOrderDetail); detailIds.Add(allocateOrderDetail.Id); } } } allocateOrder.UpperOrderNo = model.UpperOrderNo; allocateOrder.BusinessType = model.BusinessType; allocateOrder.IsBatch = model.IsBatch; allocateOrder.FactoryArea = model.FactoryArea; List deletePurchaseOrderDetails = allocateOrder.Details.Where(x => !detailIds.Contains(x.Id)).ToList(); _unitOfWorkManage.BeginTran(); foreach (var item in deletePurchaseOrderDetails) { // _allocateOrderDetailRepository.DeleteAndMoveIntoHty(item, OperateTypeEnum.自动删除); _allocateOrderDetailRepository.DeleteData(item); } _allocateOrderDetailRepository.UpdateData(updateAllocateOrderDetails); _allocateOrderDetailRepository.AddData(allocateOrderDetails); BaseDal.UpdateData(allocateOrder); DeleteInOutData(model.UpperOrderNo, allocateOrder); await AddInOutData(allocateOrder); _unitOfWorkManage.CommitTran(); return WebResponseContent.Instance.OK(); } catch (Exception ex) { _unitOfWorkManage.RollbackTran(); _logger.LogInformation("AllocateService UpdateAllocateOrder err: " + ex.Message); return WebResponseContent.Instance.Error(ex.Message); } } public async Task DeleteAllocateOrder(Dt_AllocateOrder model) { try { var allocateOrder = Db.Queryable().Where(x => x.UpperOrderNo == model.UpperOrderNo).Includes(x => x.Details).First(); if (allocateOrder == null) { return WebResponseContent.Instance.Error($"未找到调拨单信息"); } if (allocateOrder.Details == null || allocateOrder.Details.Count == 0) { return WebResponseContent.Instance.Error($"未找到调拨单明细信息"); } //Db.DeleteNav(Allocate).Include(x => x.Details).ExecuteCommand(); _unitOfWorkManage.BeginTran(); // BaseDal.DeleteAndMoveIntoHty(allocateOrder, OperateTypeEnum.自动删除); foreach (var item in allocateOrder.Details) { // _allocateOrderDetailRepository.DeleteAndMoveIntoHty(item, OperateTypeEnum.自动删除); _allocateOrderDetailRepository.DeleteData(item); } BaseDal.DeleteData(allocateOrder); DeleteInOutData(model.UpperOrderNo, allocateOrder); _unitOfWorkManage.CommitTran(); return WebResponseContent.Instance.OK(); } catch (Exception ex) { _unitOfWorkManage.RollbackTran(); _logger.LogInformation("AllocateService DeleteAllocateOrder err: " + ex.Message); return WebResponseContent.Instance.Error(ex.Message); } } private void DeleteInOutData(string upperOrderNo, Dt_AllocateOrder allocateOrder) { if (Enum.TryParse(allocateOrder.BusinessType, out var businessType)) { if (businessType == BusinessTypeEnum.外部仓库调智仓) { _inboundService.InbounOrderService.Db.Deleteable().Where(x => x.UpperOrderNo == upperOrderNo).ExecuteCommand(); _inboundService.InboundOrderDetailService.Db.Deleteable() .Where(p => SqlFunc.Subqueryable().Where(s => s.Id == p.OrderId && s.UpperOrderNo == upperOrderNo).Any()).ExecuteCommand(); } else if (businessType == BusinessTypeEnum.智仓调外部仓库 || businessType == BusinessTypeEnum.智仓调智仓) { _outboundService.OutboundOrderService.Db.Deleteable().Where(x => x.UpperOrderNo == upperOrderNo).ExecuteCommand(); _outboundService.OutboundOrderDetailService.Db.Deleteable() .Where(p => SqlFunc.Subqueryable().Where(s => s.Id == p.OrderId && s.UpperOrderNo == upperOrderNo).Any()).ExecuteCommand(); } } } public List ConvertToInboundOrders(Dt_AllocateOrder allocateOrder) { var distinctDetails = allocateOrder.Details .GroupBy(d => d.Barcode) .Select(g => g.First()) .ToList(); return new List() { new Dt_InboundOrder(){ WarehouseId= allocateOrder.WarehouseId, InboundOrderNo=allocateOrder.OrderNo, UpperOrderNo=allocateOrder.UpperOrderNo, SupplierId=allocateOrder.SupplierId, OrderType= allocateOrder.OrderType , OrderStatus=allocateOrder.OrderStatus, CreateType=allocateOrder.CreateType, BusinessType=allocateOrder.BusinessType, IsBatch=allocateOrder.IsBatch, FactoryArea=allocateOrder.FactoryArea, Remark=allocateOrder.Remark, Details=distinctDetails.Select(detail=>new Dt_InboundOrderDetail { OrderId= 0, MaterielCode=detail.MaterielCode, MaterielName="", BatchNo=detail.BatchNo, OrderQuantity=detail.OrderQuantity, ReceiptQuantity=detail.ReceiptQuantity, OverInQuantity=detail.OverInQuantity, OrderDetailStatus=detail.OrderDetailStatus, Unit=detail.Unit, RowNo=0, lineNo=detail.LineNo, SupplyCode=detail.SupplyCode, WarehouseCode=detail.WarehouseCode, Barcode=detail.Barcode, OutBoxbarcodes="", BarcodeQty=(decimal)detail.BarcodeQty, BarcodeUnit=detail.BarcodeUnit }).ToList() } }; } public Dt_OutboundOrder ConvertToOutboundOrders(Dt_AllocateOrder allocateOrder) { var distinctDetails = allocateOrder.Details .GroupBy(d => string.IsNullOrEmpty(d.Barcode) ? $"{d.MaterielCode}_{d.BatchNo}_{d.SupplyCode}_{d.WarehouseCode}" : d.Barcode) .Select(g => new { Detail = g.First(), //汇总分组内的数量 Qty = g.Sum(x => x.BarcodeQty ?? x.OrderQuantity) }).ToList(); return new Dt_OutboundOrder() { WarehouseId = allocateOrder.WarehouseId, OrderNo = allocateOrder.OrderNo, UpperOrderNo = allocateOrder.UpperOrderNo, OrderType = allocateOrder.OrderType, OrderStatus = allocateOrder.OrderStatus, CreateType = allocateOrder.CreateType, BusinessType = allocateOrder.BusinessType, IsBatch = allocateOrder.IsBatch, FactoryArea = allocateOrder.FactoryArea, Remark = allocateOrder.Remark, DepartmentCode = "", DepartmentName = "", Details = distinctDetails.Select(item => new Dt_OutboundOrderDetail { OrderId = 0, MaterielCode = item.Detail.MaterielCode, MaterielName = "", BatchNo = item.Detail.BatchNo, OrderQuantity = item.Detail.OrderQuantity, BarcodeQty = item.Detail.BarcodeQty??0, BarcodeUnit = item.Detail.BarcodeUnit??"", LockQuantity = 0, lineNo = item.Detail.LineNo, OverOutQuantity = 0, OrderDetailStatus = item.Detail.OrderDetailStatus, Unit = item.Detail.Unit, RowNo = 0, SupplyCode = item.Detail.SupplyCode, WarehouseCode = item.Detail.WarehouseCode, }).ToList() }; } static object lock_code = new object(); public string CreateCodeByRule(string ruleCode) { lock (lock_code) { string code = string.Empty; DateTime dateTime = DateTime.Now; DateTime now = DateTime.Now; try { if (string.IsNullOrEmpty(ruleCode)) throw new ArgumentNullException(nameof(ruleCode)); SqlSugarClient sugarClient = new SqlSugarClient(new ConnectionConfig { IsAutoCloseConnection = true, DbType = DbType.SqlServer, ConnectionString = DBContext.ConnectionString }); Dt_CodeRuleConfig codeRuleConfig = sugarClient.Queryable().Where(x => x.RuleCode == ruleCode).First(); if (codeRuleConfig == null) throw new ArgumentNullException(nameof(codeRuleConfig)); if (codeRuleConfig.ModifyDate != null) { dateTime = Convert.ToDateTime(codeRuleConfig.ModifyDate); } else { dateTime = Convert.ToDateTime(codeRuleConfig.CreateDate); } if (now.Year == dateTime.Year && now.Month == dateTime.Month && now.Day == dateTime.Day) { now = dateTime; codeRuleConfig.CurrentVal = Convert.ToInt32(codeRuleConfig.CurrentVal) + 1; } else { codeRuleConfig.CurrentVal = 1; } codeRuleConfig.ModifyDate = DateTime.Now; code = codeRuleConfig.StartStr + codeRuleConfig.Format; code = code.Replace($"[{CodeFormatTypeEnum.YYYY}]", now.Year.ToString().PadLeft(4, '0')); code = code.Replace($"[{CodeFormatTypeEnum.MM}]", now.Month.ToString().PadLeft(2, '0')); code = code.Replace($"[{CodeFormatTypeEnum.DD}]", now.Day.ToString().PadLeft(2, '0')); code = code.Replace($"[{CodeFormatTypeEnum.ST}]", codeRuleConfig.StartStr?.ToString() ?? ""); code = code.Replace($"[{CodeFormatTypeEnum.NUM}]", codeRuleConfig.CurrentVal.ToString().PadLeft(codeRuleConfig.Length, '0')); Dictionary keyValuePairs = new Dictionary() { { nameof(codeRuleConfig.CurrentVal), codeRuleConfig.CurrentVal }, { nameof(codeRuleConfig.Id), codeRuleConfig.Id }, { nameof(codeRuleConfig.ModifyDate), DateTime.Now } }; sugarClient.Updateable(keyValuePairs).AS(MainDb.CodeRuleConfig).WhereColumns(nameof(codeRuleConfig.Id)).ExecuteCommand(); sugarClient.Updateable(codeRuleConfig); } catch (Exception ex) { } return code; } } public override PageGridData GetPageData(PageDataOptions options) { string wheres = ValidatePageOptions(options); //获取排序字段 Dictionary orderbyDic = GetPageDataSort(options, TProperties); List orderByModels = new List(); foreach (var item in orderbyDic) { OrderByModel orderByModel = new() { FieldName = item.Key, OrderByType = item.Value }; orderByModels.Add(orderByModel); } int totalCount = 0; List searchParametersList = new List(); if (!string.IsNullOrEmpty(options.Wheres)) { try { searchParametersList = options.Wheres.DeserializeObject>(); options.Filter = searchParametersList; } catch { } } var data = BaseDal.Db.Queryable() .WhereIF(!wheres.IsNullOrEmpty(), wheres) .OrderBy(orderByModels) .ToPageList(options.Page, options.Rows, ref totalCount); foreach (var item in data) { Dt_InboundOrder _InboundOrder = SqlSugarHelper.DbWMS.Queryable().Where(x => x.UpperOrderNo == item.UpperOrderNo).First(); Dt_OutboundOrder OutboundOrder = SqlSugarHelper.DbWMS.Queryable().Where(x => x.UpperOrderNo == item.UpperOrderNo).First(); if (_InboundOrder != null) { item.OrderStatus = _InboundOrder.OrderStatus; item.OrderType = _InboundOrder.OrderType; }else if (OutboundOrder!=null) { item.OrderStatus = OutboundOrder.OrderStatus; item.OrderType = OutboundOrder.OrderType; } } return new PageGridData(totalCount, data); } public override PageGridData GetDetailPage(PageDataOptions options) { string wheres = ValidatePageOptions(options); //获取排序字段 Dictionary orderbyDic = GetPageDataSort(options, TProperties); List orderByModels = new List(); foreach (var item in orderbyDic) { OrderByModel orderByModel = new() { FieldName = item.Key, OrderByType = item.Value }; orderByModels.Add(orderByModel); } int totalCount = 0; List searchParametersList = new List(); if (!string.IsNullOrEmpty(options.Wheres)) { try { searchParametersList = options.Wheres.DeserializeObject>(); options.Filter = searchParametersList; } catch { } } //var data = BaseDal.Db.Queryable() // .WhereIF(!wheres.IsNullOrEmpty(), wheres) // .OrderBy(orderByModels) // .ToPageList(options.Page, options.Rows, ref totalCount); //Dt_AllocateOrder allocateOrder = _allocateOrderRepository.QueryFirst(x => x.Id == (int)options.Value); //Dt_InboundOrder _InboundOrder = SqlSugarHelper.DbWMS.Queryable().Where(x => x.UpperOrderNo == allocateOrder.UpperOrderNo).First(); //var details = _inboundOrderDetailRepository.QueryData(x => x.OrderId == _InboundOrder.Id ); //foreach (var item in data) //{ // var detail = details.Where(x => x.MaterielCode == item.MaterielCode).FirstOrDefault(); // if (detail != null) // { // item.OrderQuantity = detail.OrderQuantity; // item.ReceiptQuantity = detail.ReceiptQuantity; // item.OverInQuantity = detail.OverInQuantity; // item.OrderDetailStatus = detail.OrderDetailStatus; // } //} //return new PageGridData(totalCount, data); Dt_AllocateOrder allocateOrder = _allocateOrderRepository.QueryFirst(x => x.Id == (int)options.Value); Dt_InboundOrder _InboundOrder = SqlSugarHelper.DbWMS.Queryable().Where(x => x.UpperOrderNo == allocateOrder.UpperOrderNo).First(); var Id = _InboundOrder == null ? 0 : _InboundOrder.Id; var data = BaseDal.Db.Queryable() .WhereIF(!wheres.IsNullOrEmpty(), wheres) .Where( x => x.OrderId == Id) .OrderBy(orderByModels) .ToPageList(options.Page, options.Rows, ref totalCount); return new PageGridData(totalCount, data); } } }