using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using MES.Service.DB;
|
using MES.Service.Modes;
|
using MES.Service.Dto.webApi;
|
|
namespace MES.Service.service
|
{
|
public class ShtzdManager : Repository<Shtzd>
|
{
|
public bool Save(Sh sh)
|
{
|
var SH = sh.ErpShtzd;
|
var mesShtzd = GetMesShtzd(SH);
|
var shtzdDetails = GetMesShtzdDetail(sh.ErpShzdDetail);
|
|
return UseTransaction(db =>
|
{
|
return SH.Type switch
|
{
|
"2" or "4" or "5" => SaveOrUpdateData(db, mesShtzd, shtzdDetails) ? 1 : 0,
|
"3" => UpdateData(db, mesShtzd, shtzdDetails) ? 1 : 0,
|
_ => throw new NotImplementedException($"类型 Type = {SH.Type} 不存在")
|
};
|
}) > 0;
|
}
|
public bool SaveList(List<Sh> shList)
|
{
|
return UseTransaction(db =>
|
{
|
foreach (var sh in shList)
|
{
|
var SH = sh.ErpShtzd;
|
var mesShtzd = GetMesShtzd(SH);
|
var shtzdDetails = GetMesShtzdDetail(sh.ErpShzdDetail);
|
|
switch (SH.Type)
|
{
|
case "2":
|
case "4":
|
case "5":
|
SaveOrUpdateData(db, mesShtzd, shtzdDetails);
|
break;
|
case "3":
|
UpdateData(db, mesShtzd, shtzdDetails);
|
break;
|
default:
|
throw new NotImplementedException($"类型 Type = {SH.Type} 暂不支持处理");
|
}
|
}
|
return shList.Count;
|
}) > 0;
|
}
|
|
public Shtzd GetMesShtzd(ErpShzd sh)
|
{
|
return new Shtzd
|
{
|
ID = Convert.ToInt32(sh.ERPID),
|
Deliveryno = sh.FBillNo,
|
Depotno = sh.FStockID,
|
Supplierid = sh.FSupplierId,
|
Fdate = sh.FDate,
|
Remark = sh.FNote,
|
FZjxfSfgx = sh.F_ZJXF_sfgx
|
};
|
}
|
|
public List<ShtzdDetail> GetMesShtzdDetail(List<ErpShzdDetail> erpShzdDetails)
|
{
|
return erpShzdDetails.Select(s => new ShtzdDetail
|
{
|
Erpid = Convert.ToInt32(s.ERPID),
|
Eid = Convert.ToInt32(s.EID),
|
Lineno = s.LineNo,
|
Fbillno = s.FORDERBILLNO,
|
Productcode = s.FMATERIALID,
|
Purchaseqty = s.FPOQTY,
|
Deliveryqty = s.FACTRECEIVEQTY,
|
Includeqty = s.FACTREQTY,
|
Purchaseunit = s.FUNITID,
|
Inventoryunit = s.FSTOCKUNITID,
|
Remark = s.FDESCRIPTION,
|
Salesorderid = s.FSRCBILLNO,
|
Orderlineid = s.FSRCENTRYID,
|
Fxshth = s.FXSHTH,
|
Fmtono = s.FMtoNo,
|
Flot = s.FLot
|
}).ToList();
|
}
|
|
protected int UseTransaction(Func<SqlSugarScope, int> action)
|
{
|
try
|
{
|
Db.Ado.BeginTran();
|
var affectedRows = action.Invoke(Db);
|
Db.Ado.CommitTran();
|
return affectedRows;
|
}
|
catch (Exception)
|
{
|
Db.Ado.RollbackTran();
|
throw;
|
}
|
}
|
|
private bool SaveOrUpdateData(SqlSugarScope db, Shtzd header, List<ShtzdDetail> details)
|
{
|
var exists = db.Queryable<Shtzd>().Any(x => x.ID == header.ID);
|
if (exists)
|
{
|
db.Updateable(header).ExecuteCommand();
|
db.Deleteable<ShtzdDetail>().Where(x => x.Eid == header.ID).ExecuteCommand();
|
}
|
else
|
{
|
db.Insertable(header).ExecuteCommand();
|
}
|
|
foreach (var item in details)
|
{
|
item.Eid = header.ID;
|
}
|
db.Insertable(details).ExecuteCommand();
|
return true;
|
}
|
|
private bool UpdateData(SqlSugarScope db, Shtzd header, List<ShtzdDetail> details)
|
{
|
db.Updateable(header).ExecuteCommand();
|
db.Deleteable<ShtzdDetail>().Where(x => x.Eid == header.ID).ExecuteCommand();
|
|
foreach (var item in details)
|
{
|
item.Eid = header.ID;
|
}
|
db.Insertable(details).ExecuteCommand();
|
return true;
|
}
|
}
|
}
|
