using System.Globalization;
|
using MES.Service.DB;
|
using MES.Service.Dto.webApi;
|
using MES.Service.Modes;
|
using MES.Service.util;
|
using SqlSugar;
|
|
namespace MES.Service.service.BasicData;
|
|
public class ProductionOrderManager : Repository<ProductionOrder>
|
{
|
//当前类已经继承了 Repository 增、删、查、改的方法
|
|
private readonly ProductionOrderSubManager _productionOrderSubManager =
|
new();
|
|
private string ORDERNO = "";
|
|
|
//ErpWYOrder
|
public bool Save(ErpWYOrder wyOrder)
|
{
|
var erpProductionOrderDto = wyOrder.OrderDto;
|
var mesRohIn = ConvertErpToProductionOrder(erpProductionOrderDto,
|
wyOrder.Items[0].FBILLNO);
|
var mesRohInDatas =
|
ConvertErpToProductionOrderSub(wyOrder.Items);
|
|
return UseTransaction(db =>
|
{
|
switch (erpProductionOrderDto.Type)
|
{
|
// case "2":
|
// return InsertData(db, mesRohIn, mesRohInDatas,
|
// rohInErpRohIn.FBILLTYPE)
|
// ? 1
|
// : 0;
|
case "3":
|
return UpdateData(db, wyOrder.Items[0].FBILLNO) ? 1 : 0;
|
case "2":
|
case "4":
|
return SaveOrUpdateData(db, mesRohIn, mesRohInDatas,
|
erpProductionOrderDto.Type)
|
? 1
|
: 0;
|
default:
|
throw new NotImplementedException(
|
$"type没有{erpProductionOrderDto.Type}这个类型");
|
}
|
}) > 0;
|
}
|
|
private bool UpdateData(SqlSugarScope db, string FBILLNO)
|
{
|
// var decimals = mesRohInDatas.Select(s => s.Guid).ToArray();
|
|
var orderNoList = db.Queryable<ProductionOrder>()
|
.Where(s => s.OrderNo.Contains(FBILLNO))
|
.Select(s => s.OrderNo)
|
.ToList();
|
|
var update = db.Deleteable<ProductionOrder>()
|
.Where(s => orderNoList.Contains(s.OrderNo))
|
.ExecuteCommand() > 0;
|
|
//s.WorkOrderNo
|
var insertOrUpdate = db
|
.Deleteable<ProductionOrderSub>()
|
.Where(s => orderNoList.Contains(s.WorkOrderNo))
|
.ExecuteCommand() > 0;
|
|
if (update && insertOrUpdate) return true;
|
throw new NotImplementedException("更新失败");
|
}
|
|
// 插入或更新数据的方法
|
private bool SaveOrUpdateData(SqlSugarScope db, ProductionOrder mesRohIn,
|
List<ProductionOrderSub> mesRohInDatas, string type)
|
{
|
if (StringUtil.CheckGuid(mesRohIn.Guid))
|
db.Deleteable<ProductionOrder>()
|
.Where(s => s.OrderNo == mesRohIn.OrderNo)
|
.ExecuteCommand();
|
|
if (mesRohInDatas.Count > 0)
|
db.Deleteable<ProductionOrderSub>()
|
.Where(s =>
|
s.WorkOrderNo == mesRohIn.OrderNo)
|
.ExecuteCommand();
|
|
var orUpdate = db.Insertable(mesRohIn)
|
.IgnoreColumns(true).ExecuteCommand() > 0;
|
|
|
var baOrUpdate = db.Insertable(mesRohInDatas).PageSize(1)
|
.IgnoreColumnsNull()
|
.ExecuteCommand() > 0;
|
|
if (orUpdate && baOrUpdate) return true;
|
|
throw new NotImplementedException("插入或更新失败");
|
}
|
|
// 批量保存记录的方法
|
public bool SaveList(List<ErpWYOrder> rohIns)
|
{
|
var result = rohIns.Select(Save).ToList();
|
return result.All(b => b);
|
}
|
|
private ProductionOrder ConvertErpToProductionOrder(
|
ErpProductionOrderDto erpDto, string SUBBOM)
|
{
|
DateTime parsedDate;
|
|
// 时间格式转换函数，ERP时间格式可能为 "yyyy-MM-dd" 或 "yyyy-M-d"
|
DateTime? ParseDateTime(string dateStr)
|
{
|
if (string.IsNullOrEmpty(dateStr)) return null;
|
|
// 尝试解析多种日期格式，支持不补零的月份和日期
|
if (DateTime.TryParse(dateStr, out DateTime result))
|
{
|
return result;
|
}
|
|
return null;
|
}
|
|
var productionOrder = new ProductionOrder
|
{
|
OrderNo = SUBBOM,
|
|
OrderDate = ParseDateTime(erpDto.FDate) ?? null,
|
OrderType = erpDto.FBillType,
|
BusinessStatus = erpDto.FStatus,
|
|
WorkOrderQty = Convert.ToDecimal(erpDto.FQty),
|
PlanningGroup = erpDto.FWorkGroupId,
|
Planner = erpDto.FPlannerID,
|
EstimatedStartTime =
|
ParseDateTime(erpDto.FPlanStartDate) ?? null,
|
EstimatedEndTime =
|
ParseDateTime(erpDto.FPlanFinishDate) ?? null,
|
StorageUpperLimit = Convert.ToDecimal(erpDto.FStockInLimitH),
|
StorageLowerLimit = Convert.ToDecimal(erpDto.FStockInLimitL),
|
TrackingNo = erpDto.FMTONO,
|
BatchNo = erpDto.FLot,
|
BomVersion = erpDto.FBomId,
|
SalesOrderNo = erpDto.F_UNW_XSDDH,
|
GenerationMethod = erpDto.FCreateType,
|
ErpProductionOrderId = erpDto.FSUBID,
|
ErpProductionOrderLineNo = erpDto.FSUBBILLNOSEQ,
|
ErpProductionOrderNo = erpDto.FSUBBILLNO,
|
|
SourceOrderNo = erpDto.FSrcBillNo,
|
SourceOrderEntryNo = erpDto.FSrcBillEntrySeq,
|
DemandOrderNo = erpDto.FSALEORDERNO,
|
DemandOrderLineNo = erpDto.FSaleOrderEntrySeq,
|
ClosingPerson = erpDto.FFORCECLOSERID,
|
ClosingType = erpDto.FCloseType,
|
Remarks = erpDto.FDescription,
|
ErpId = erpDto.FID,
|
// ErpProductionEntryCode = erpDto.FSUBENTRYID,
|
ErpProductionEntryCode = SUBBOM,
|
Purchaseorderno = erpDto.FPurOrderNo,
|
Purchaseorderentryseq = Convert.ToInt32(erpDto.FPurOrderEntrySeq),
|
Stockinqty = Convert.ToDecimal(erpDto.FBaseStockInQty),
|
Nostockinqty = Convert.ToDecimal(erpDto.FBaseNoStockInQty),
|
// Stockowner = erpDto.FInStockOwnerId,
|
Stockowner = "1",
|
PlanConfirmation = !string.IsNullOrEmpty(erpDto.PlanConfirmation)
|
? (DateTime.TryParse(erpDto.PlanConfirmation, out DateTime planDate) ? planDate : (DateTime?)null)
|
: null,
|
ReqSrc = erpDto.FReqSrc,
|
SrcSplitSeq = erpDto.SrcSplitSeq,
|
Typea = erpDto.TypeA,
|
};
|
|
productionOrder.SourceOrderType = erpDto.FSrcBillType switch
|
{
|
//SourceOrderType = erpDto.FSrcBillType,
|
"0" => "无来源",
|
"1" => "销售订单行号",
|
"2" => "预测",
|
"3" => "出口订单行号",
|
"4" => "需求分类代号",
|
"5" => "销售订单号",
|
"6" => "出口订单号",
|
"7" or "8" => "生产订单",
|
_ => "委外订单"
|
};
|
|
//Unit = ,
|
// CAA009 单位 -> MES_UNIT.id
|
if (!string.IsNullOrEmpty(erpDto.FUnitID))
|
{
|
var unit = Db.Queryable<MesUnit>()
|
.Where(u => u.Fnumber == erpDto.FUnitID)
|
.Select(u => u.Id)
|
.First();
|
productionOrder.Unit = unit.ToString();
|
}
|
|
// CAA006 产品编码 -> MES_ITEMS.id
|
if (!string.IsNullOrEmpty(erpDto.FMaterialId))
|
{
|
var item = Db.Queryable<MesItems>()
|
.Where(i => i.ItemNo == erpDto.FMaterialId)
|
.Select(i => i.Id)
|
.First();
|
productionOrder.ProductCode = item.ToString();
|
}
|
|
// Warehouse = erpDto.FStockID,
|
if (!string.IsNullOrEmpty(erpDto.FStockID))
|
{
|
var depot = Db.Queryable<MesDepots>()
|
.Where(d => d.DepotCode == erpDto.FStockID)
|
.Select(d => d.DepotId)
|
.First();
|
productionOrder.Warehouse = depot.ToString();
|
}
|
|
var single = base.GetSingle(it =>
|
it.OrderNo == erpDto.FBillNo);
|
if (single != null) productionOrder.Guid = single.Guid;
|
|
return productionOrder;
|
}
|
|
private List<ProductionOrderSub> ConvertErpToProductionOrderSub(
|
List<ErpProductionOrderSubDto> erpDtoList)
|
{
|
var productionOrderSubList =
|
new List<ProductionOrderSub>();
|
|
foreach (var erpDto in erpDtoList)
|
{
|
var productionOrderSub = new ProductionOrderSub
|
{
|
SequenceNo = Convert.ToInt32(erpDto.FSEQ),
|
WorkOrderNo = erpDto.FBILLNO,
|
RequiredQty = Convert.ToDecimal(erpDto.FMustQty),
|
IssuedQty = Convert.ToDecimal(erpDto.FPickedQty),
|
LocationNo = erpDto.FPositionNO,
|
// StockOwner = erpDto.FOwnerID,
|
StockOwner = "1",
|
TrackingNo = erpDto.FMTONO,
|
BatchNo = erpDto.FLot,
|
|
IssuingMethod = erpDto.FIssueType,
|
Unit = erpDto.FUnitID2,
|
Unit2 = erpDto.FUnitID3,
|
SupplyingType = erpDto.FSupplyType,
|
Numerator = Convert.ToDecimal(erpDto.FNumerator),
|
Denominator = Convert.ToDecimal(erpDto.FDenominator),
|
ErpId = erpDto.FPPOMENTRYID,
|
ErpHeaderId = erpDto.FPPOMID,
|
FixedLoss = Convert.ToDecimal(erpDto.FFixScrapQty),
|
VariableLossRate = Convert.ToDecimal(erpDto.FScrapRate),
|
SubItemType = erpDto.FMaterialType,
|
ItemNo = erpDto.FReplaceGroup,
|
OwnerType = erpDto.FOwnerTypeId,
|
// Owner = erpDto.FOwnerID2,
|
Owner = "1",
|
Fisgetscrap = erpDto.FISGETSCRAP,
|
Fiskeycomponent = erpDto.FISKEYCOMPONENT,
|
// Fsrctransorgid = erpDto.FSRCTRANSORGID,
|
Fsrctransorgid = "1",
|
Fsrctransstockid = erpDto.FSRCTRANSSTOCKID,
|
Fstockstatusid = erpDto.FSTOCKSTATUSID,
|
Fneeddate = erpDto.FNEEDDATE != null
|
? DateTime.Parse(erpDto.FNEEDDATE)
|
: null,
|
Freservetype = erpDto.FRESERVETYPE,
|
Fmemo = erpDto.FMEMO,
|
Typeb = erpDto.TypeB,
|
// ErpProductionEntryCode = erpDto.FSUBENTRYID
|
ErpProductionEntryCode = erpDto.FBILLNO
|
};
|
|
var single = _productionOrderSubManager.GetSingle(it =>
|
it.ErpId == productionOrderSub.ErpId);
|
if (single != null) productionOrderSub.Guid = single.Guid;
|
|
if (!string.IsNullOrEmpty(erpDto.FMaterialID2))
|
{
|
var item = Db.Queryable<MesItems>()
|
.Where(i => i.ItemNo == erpDto.FMaterialID2)
|
.Select(i => i.Id)
|
.First();
|
if (item != null)
|
{
|
productionOrderSub.MaterialCode = item.ToString();
|
}
|
}
|
|
if (!string.IsNullOrEmpty(erpDto.FStockID))
|
{
|
var item = Db.Queryable<MesDepots>()
|
.Where(i => i.DepotCode == erpDto.FStockID)
|
.Select(i => i.DepotId)
|
.First();
|
if (item != null)
|
{
|
productionOrderSub.Warehouse = item.ToString();
|
}
|
}
|
|
productionOrderSubList.Add(productionOrderSub);
|
}
|
|
return productionOrderSubList;
|
}
|
}
|
