using System.Globalization;
|
using MES.Service.DB;
|
using MES.Service.Dto.webApi;
|
using MES.Service.Modes;
|
using SqlSugar;
|
|
namespace MES.Service.service;
|
|
/// <summary>
|
/// 出货计划出货服务管理类
|
/// </summary>
|
public class ShipmentPlanDeliveryManager : Repository<ShipmentPlanDelivery>
|
{
|
private readonly ShipmentPlanDeliveryDetailManager _detailManager = new();
|
|
/// <summary>
|
/// 保存出货计划出货数据
|
/// </summary>
|
public bool Save(ErpShipmentPlanDelivery data)
|
{
|
var headerDto = data.OrderDto;
|
var header = ConvertDtoToHeader(data.OrderDto);
|
var details = ConvertDtoToDetails(data.Items);
|
|
return UseTransaction(db =>
|
{
|
switch (headerDto.Type)
|
{
|
case "3":
|
return UpdateData(db, header, details) ? 1 : 0;
|
case "2":
|
case "4":
|
return SaveOrUpdateData(db, header, details) ? 1 : 0;
|
default:
|
throw new NotImplementedException($"不支持的接口类型: {headerDto.Type}");
|
}
|
}) > 0;
|
}
|
|
/// <summary>
|
/// 更新数据
|
/// </summary>
|
private bool UpdateData(SqlSugarScope db, ShipmentPlanDelivery header, List<ShipmentPlanDeliveryDetail> details)
|
{
|
// 检查是否已生成出库单
|
var outCount = Db.Ado.SqlQuery<decimal>(
|
"SELECT COUNT(*) FROM MES_INV_ITEM_OUTS A WHERE A.WORK_NO = :billNo AND A.BILL_TYPE_ID = 200 AND A.TRANSACTION_NO = 250",
|
new { billNo = header.BillNo }).First();
|
|
if (outCount > 0)
|
{
|
throw new NotImplementedException("该出货单已生成出库单，不能修改！");
|
}
|
|
// 删除原有数据
|
var deleteHeader = base.DeleteById(header.Id);
|
var detailIds = details.Select(d => d.Id).ToArray();
|
var deleteDetails = db.Deleteable<ShipmentPlanDeliveryDetail>().In(detailIds).ExecuteCommand() > 0;
|
|
if (deleteHeader && deleteDetails)
|
{
|
return true;
|
}
|
|
throw new NotImplementedException("更新失败");
|
}
|
|
/// <summary>
|
/// 插入或更新数据
|
/// </summary>
|
private bool SaveOrUpdateData(SqlSugarScope db, ShipmentPlanDelivery header, List<ShipmentPlanDeliveryDetail> details)
|
{
|
// 检查是否已生成出库单
|
var outCount = Db.Ado.SqlQuery<decimal>(
|
"SELECT COUNT(*) FROM MES_INV_ITEM_OUTS A WHERE A.WORK_NO = :billNo AND A.BILL_TYPE_ID = 200 AND A.TRANSACTION_NO = 250",
|
new { billNo = header.BillNo }).First();
|
|
if (outCount > 0)
|
{
|
throw new NotImplementedException("该出货单已生成出库单，不能修改！");
|
}
|
|
// 如果存在则删除旧数据
|
if (header.Id != null)
|
{
|
base.DeleteById(header.Id);
|
}
|
|
if (details.Count > 0)
|
{
|
db.Deleteable<ShipmentPlanDeliveryDetail>()
|
.Where(s => s.ErpHeadId == header.ErpHeadId)
|
.ExecuteCommand();
|
}
|
|
// 插入新数据并获取主表ID
|
var headerId = base.InsertReturnIdentity(header);
|
|
// 插入明细数据，关联主表ID
|
if (headerId > 0)
|
{
|
foreach (var detail in details)
|
{
|
detail.HeadId = headerId;
|
_detailManager.Insert(detail);
|
}
|
}
|
|
return headerId > 0;
|
}
|
|
/// <summary>
|
/// 批量保存
|
/// </summary>
|
public bool SaveList(List<ErpShipmentPlanDelivery> dataList)
|
{
|
var result = dataList.Select(Save).ToList();
|
return result.All(b => b);
|
}
|
|
/// <summary>
|
/// 转换DTO为主表实体
|
/// </summary>
|
private ShipmentPlanDelivery ConvertDtoToHeader(ErpShipmentPlanDeliveryDto dto)
|
{
|
DateTime? ParseDateTime(string? dateStr)
|
{
|
if (string.IsNullOrEmpty(dateStr)) return null;
|
|
if (DateTime.TryParseExact(dateStr, "yyyy-MM-dd HH:mm:ss",
|
CultureInfo.InvariantCulture,
|
DateTimeStyles.None,
|
out var parsedDate))
|
{
|
return parsedDate;
|
}
|
|
return null;
|
}
|
|
var entity = new ShipmentPlanDelivery
|
{
|
BillType = dto.BillType,
|
BillNo = dto.BillNo,
|
Customer = dto.Customer,
|
FDate = ParseDateTime(dto.FDate),
|
InterfaceStatus = dto.InterfaceStatus,
|
Salesperson = dto.Salesperson,
|
Department = dto.Department,
|
SourceDocCategory = dto.SourceDocCategory,
|
SourceDocument = dto.SourceDocument,
|
Status = dto.Status,
|
CreatedBy = dto.CreatedBy,
|
CreatedDate = ParseDateTime(dto.CreatedDate),
|
ApprovedBy = dto.ApprovedBy,
|
ApprovedDate = ParseDateTime(dto.ApprovedDate),
|
HeaderNote = dto.HeaderNote,
|
Remark = dto.Remark,
|
AsnNo = dto.AsnNo,
|
Project = dto.Project,
|
CustomerPo = dto.CustomerPo,
|
ShippingPolicy = dto.ShippingPolicy,
|
ShippingMethod = dto.ShippingMethod,
|
DemandCategory = dto.DemandCategory,
|
ShippingPort = dto.ShippingPort,
|
DestinationPort = dto.DestinationPort,
|
ErpHeadId = dto.ErpHeadId
|
};
|
|
// 根据ErpHeadId查找是否已存在
|
var existing = base.GetSingle(it => it.ErpHeadId == dto.ErpHeadId);
|
if (existing != null)
|
{
|
entity.Id = existing.Id;
|
}
|
|
// 验证必填项
|
if (string.IsNullOrEmpty(entity.ErpHeadId))
|
{
|
throw new NotImplementedException("表头ErpHeadId不能为空");
|
}
|
|
return entity;
|
}
|
|
/// <summary>
|
/// 转换DTO为明细表实体列表
|
/// </summary>
|
private List<ShipmentPlanDeliveryDetail> ConvertDtoToDetails(List<ErpShipmentPlanDeliveryDetailDto> dtoList)
|
{
|
var detailList = new List<ShipmentPlanDeliveryDetail>();
|
|
foreach (var dto in dtoList)
|
{
|
var detail = new ShipmentPlanDeliveryDetail
|
{
|
LineNo = dto.LineNo,
|
Project = dto.Project,
|
CustomerItemNo = dto.CustomerItemNo,
|
CustomerItemName = dto.CustomerItemName,
|
MaterialId = dto.MaterialId,
|
MaterialName = dto.MaterialName,
|
Specification = dto.Specification,
|
StorageLocation = dto.StorageLocation,
|
Unit = dto.Unit,
|
Quantity = string.IsNullOrEmpty(dto.Quantity) ? null : Convert.ToDecimal(dto.Quantity),
|
FreeItemType = dto.FreeItemType,
|
DeliveryDate = dto.DeliveryDate,
|
BodyNote = dto.BodyNote,
|
AsnLineNo = dto.AsnLineNo,
|
AvailableStock = dto.AvailableStock,
|
InventoryQueryTime = dto.InventoryQueryTime,
|
LineStatus = dto.LineStatus,
|
ReceiverLocation = dto.ReceiverLocation,
|
ReceiverAddress = dto.ReceiverAddress,
|
ReceiverAddressFull = dto.ReceiverAddressFull,
|
ReceiverContact = dto.ReceiverContact,
|
Returnable = dto.Returnable,
|
AvailableDate = dto.AvailableDate,
|
CommitmentDate = dto.CommitmentDate,
|
PlanShipDate = dto.PlanShipDate,
|
CustomerConfirmDate = dto.CustomerConfirmDate,
|
PlanOrg = dto.PlanOrg,
|
VendorDirectShip = dto.VendorDirectShip,
|
SupplySource = dto.SupplySource,
|
SupplyType = dto.SupplyType,
|
SupplyOrg = dto.SupplyOrg,
|
Supplier = dto.Supplier,
|
DetailShippingMethod = dto.DetailShippingMethod,
|
OwnerOrg = dto.OwnerOrg,
|
DetailDemandCategory = dto.DetailDemandCategory,
|
InventoryPlanning = dto.InventoryPlanning,
|
LineRemark = dto.LineRemark,
|
SourceDocCategory = dto.SourceDocCategory,
|
SourceDocNo = dto.SourceDocNo,
|
SourceLineNo = dto.SourceLineNo,
|
ErpLineId = dto.ErpLineId,
|
ErpHeadId = dto.ErpHeadId
|
};
|
|
// 验证必填项
|
if (string.IsNullOrEmpty(detail.ErpLineId))
|
{
|
throw new NotImplementedException("明细行ErpLineId不能为空");
|
}
|
|
if (string.IsNullOrEmpty(detail.ErpHeadId))
|
{
|
throw new NotImplementedException("明细行ErpHeadId不能为空");
|
}
|
|
// 根据ErpLineId查找是否已存在
|
var existing = _detailManager.GetSingle(it => it.ErpLineId == detail.ErpLineId);
|
if (existing != null)
|
{
|
detail.Id = existing.Id;
|
}
|
|
// 物料ID映射转换（如果需要）
|
if (!string.IsNullOrEmpty(dto.MaterialId) && !string.IsNullOrEmpty(dto.SupplyOrg))
|
{
|
var materialLink = Db.Queryable<MesLinkU9>()
|
.Where(x => x.U9Id == dto.MaterialId
|
&& x.OrgId == dto.SupplyOrg
|
&& x.TableType == "MES_ITEMS")
|
.First();
|
|
if (materialLink != null)
|
{
|
detail.MaterialId = materialLink.MesId;
|
}
|
}
|
|
// 项目映射转换（如果需要）
|
if (!string.IsNullOrEmpty(dto.Project) && !string.IsNullOrEmpty(dto.SupplyOrg))
|
{
|
var projectLink = Db.Queryable<MesLinkU9>()
|
.Where(x => x.U9Id == dto.Project
|
&& x.OrgId == dto.SupplyOrg
|
&& x.TableType == "MES_PROJECT")
|
.First();
|
|
if (projectLink != null)
|
{
|
detail.Project = projectLink.MesId;
|
}
|
}
|
|
detailList.Add(detail);
|
}
|
|
return detailList;
|
}
|
}
|
|
/// <summary>
|
/// 出货计划出货明细管理类
|
/// </summary>
|
public class ShipmentPlanDeliveryDetailManager : Repository<ShipmentPlanDeliveryDetail>
|
{
|
// 继承Repository基础增删改查方法
|
}
|
