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 MesRohInManager : Repository<MesRohIn>
|
{
|
//当前类已经继承了 Repository 增、删、查、改的方法
|
|
private readonly MesRohInDataManager rohInDataManager = new();
|
|
//这里面写的代码不会给覆盖,如果要重新生成请删除 MesRohInManager.cs
|
|
public bool Save(RohIn rohIn)
|
{
|
var rohInErpRohIn = rohIn.ErpRohIn;
|
var mesRohIn = GetMesRohIn(rohInErpRohIn);
|
var mesRohInDatas =
|
GetMesRohInDatas(rohIn.ErpRohinDatas, rohInErpRohIn.Type);
|
switch (rohInErpRohIn.Type)
|
{
|
case "1":
|
var insert = base.Insert(mesRohIn);
|
var insertRange = rohInDataManager.InsertRange(mesRohInDatas);
|
|
if (insert && insertRange) return true;
|
throw new NotImplementedException("插入失败");
|
case "2":
|
var update = base.Update(mesRohIn);
|
var insertOrUpdate =
|
rohInDataManager.InsertOrUpdate(mesRohInDatas);
|
|
if (update && insertOrUpdate) return true;
|
throw new NotImplementedException("更新失败");
|
case "4":
|
var orUpdate = SaveOrUpdate(mesRohIn);
|
var baOrUpdate =
|
rohInDataManager.InsertOrUpdate(mesRohInDatas);
|
if (orUpdate && baOrUpdate) return true;
|
throw new NotImplementedException("插入失败");
|
default:
|
throw new NotImplementedException("type没有" +
|
rohInErpRohIn.Type + "这个类型");
|
}
|
}
|
|
private bool SaveOrUpdate(MesRohIn mesRohIn)
|
{
|
var mesRohIns = base.GetList(it => it.EbelnK3id == mesRohIn.EbelnK3id);
|
|
if (CollectionUtil.IsNullOrEmpty(mesRohIns))
|
{
|
return base.Insert(mesRohIn);
|
}
|
|
return base.Update(mesRohIn);
|
}
|
|
public bool SaveList(List<RohIn> rohIns)
|
{
|
var result = new List<bool>();
|
rohIns.ForEach(s =>
|
{
|
var save = Save(s);
|
result.Add(save);
|
});
|
return result.All(b => b);
|
}
|
|
public MesRohIn GetMesRohIn(ErpRohIn rohIn)
|
{
|
var eid = Convert.ToDecimal(rohIn.id);
|
var mesRohIn = new MesRohIn();
|
if (!"1".Equals(rohIn.Type))
|
{
|
var single = base.GetSingle(it => it.EbelnK3id == eid);
|
if (single != null) mesRohIn.Id = single.Id;
|
}
|
|
mesRohIn.EbelnK3id = eid;
|
|
mesRohIn.BillNo = rohIn.FBillNo;
|
mesRohIn.DocumentStatus = rohIn.FDocumentStatus;
|
mesRohIn.DocumentType = rohIn.FBillTypeID;
|
mesRohIn.BusinessType = rohIn.FBusinessType;
|
|
if (rohIn.FDate != null)
|
mesRohIn.PurchaseDate = DateTime.ParseExact(
|
rohIn.FDate, "yyyy-MM-dd HH:mm:ss", null);
|
|
mesRohIn.Supplier = rohIn.FSupplierId;
|
mesRohIn.CloseStatus = rohIn.FCloseStatus;
|
mesRohIn.PurchaseOrg = rohIn.FPurchaseOrgId;
|
mesRohIn.PurchaseDept = rohIn.FPurchaseDeptId;
|
mesRohIn.PurchaseGroup = rohIn.FPurchaserGroupId;
|
mesRohIn.QtyAcceptance = rohIn.Facctype;
|
mesRohIn.Purchaser = rohIn.FPurchaserId;
|
mesRohIn.QualityReq = rohIn.F_UNW_Remarks_zlyq;
|
// mesRohIn.SupplierContact = rohIn.F_UNW_GYSLXR;
|
// mesRohIn.ContactPhone = rohIn.F_UNW_LXRDH;
|
// mesRohIn.Position = rohIn.FProviderJob;
|
// mesRohIn.OfficePhone = rohIn.FProviderPhone;
|
// mesRohIn.SupplierAddress = rohIn.FProviderAddress;
|
mesRohIn.SettlementParty = rohIn.FSettleId;
|
mesRohIn.PaymentParty = rohIn.FChargeId;
|
mesRohIn.Email = rohIn.FProviderEMail;
|
mesRohIn.TransportMethod = rohIn.F_UNW_Text_ysfs;
|
mesRohIn.Remarks = rohIn.F_UNW_BZ;
|
mesRohIn.FixtureMoldProcurement = rohIn.F_UNW_Combo_zjmj;
|
mesRohIn.CancellationStatus = rohIn.FCancelStatus;
|
mesRohIn.CancellationPerson = rohIn.FCancellerId;
|
if (rohIn.FCancelDate != null)
|
mesRohIn.CancellationDate = DateTime.ParseExact(
|
rohIn.FCancelDate, "yyyy-MM-dd HH:mm:ss", null);
|
|
mesRohIn.CreateBy = rohIn.FCreatorId;
|
|
if (rohIn.FCreateDate != null)
|
mesRohIn.CreateDate = DateTime.ParseExact(
|
rohIn.FCreateDate, "yyyy-MM-dd HH:mm:ss", null);
|
|
mesRohIn.LastupdateBy = rohIn.FModifierId;
|
|
if (rohIn.FModifyDate != null)
|
mesRohIn.LastupdateDate = DateTime.ParseExact(
|
rohIn.FModifyDate, "yyyy-MM-dd HH:mm:ss", null);
|
|
mesRohIn.ErpCheckBy = rohIn.FApproverId;
|
mesRohIn.ErpCheckDate = rohIn.FApproveDate;
|
|
|
return mesRohIn;
|
}
|
|
public List<MesRohInData> GetMesRohInDatas(List<ErpRohinData> ErpRohinDatas,
|
string type)
|
{
|
var list = new List<MesRohInData>();
|
ErpRohinDatas.ForEach(s =>
|
{
|
var entity = new MesRohInData();
|
|
var eid = Convert.ToDecimal(s.id);
|
|
if (!"1".Equals(type))
|
{
|
var single =
|
rohInDataManager.GetSingle(it => it.EbelnK3id == eid);
|
if (single != null) entity.Id = single.Id;
|
}
|
|
entity.EbelnK3id = Convert.ToDecimal(s.id);
|
entity.ErpId = Convert.ToDecimal(s.Eid);
|
|
entity.BillNo = s.FBillNo;
|
entity.SalesOrderId = s.F_UNW_Text_xsddh;
|
entity.ItemId = s.FMaterialId;
|
entity.PurchaseUnit = s.FUnitId;
|
entity.PurchaseQty = Convert.ToDecimal(s.FQty);
|
entity.InventoryUnit = s.FStockUnitID;
|
entity.PricingUnit = s.FPriceUnitId;
|
entity.PricingQty = Convert.ToDecimal(s.FPriceUnitQty);
|
|
if (s.FDeliveryDate != null)
|
entity.DeliveryDate = DateTime.ParseExact(
|
s.FDeliveryDate, "yyyy-MM-dd HH:mm:ss", null);
|
|
if (s.FDeliveryEarlyDate != null)
|
entity.EarliestDeliveryDate = DateTime.ParseExact(
|
s.FDeliveryEarlyDate, "yyyy-MM-dd HH:mm:ss", null);
|
|
if (s.FDeliveryLastDate != null)
|
entity.LatestDeliveryDate = DateTime.ParseExact(
|
s.FDeliveryLastDate, "yyyy-MM-dd HH:mm:ss", null);
|
|
entity.IsGift = s.FGiveAway;
|
entity.Remarks = s.FEntryNote;
|
entity.SupplierItemCode = s.FSupMatId;
|
entity.SupplierItemName = s.FSupMatName;
|
entity.OutsourcingOrderId = s.FSUBREQBILLNO;
|
entity.BatchNumber = s.FLot;
|
entity.BusinessClose = s.FMRPCloseStatus;
|
entity.BusinessFreeze = s.FMRPFreezeStatus;
|
entity.Freezer = s.FFreezerId;
|
|
if (s.FFreezeDate != null)
|
entity.FreezeTime = DateTime.ParseExact(
|
s.FFreezeDate, "yyyy-MM-dd HH:mm:ss", null);
|
|
entity.BusinessTerminate = s.FMRPTerminateStatus;
|
entity.Terminator = s.FTerminaterId;
|
|
if (s.FTerminateDate != null)
|
entity.TerminateTime = DateTime.ParseExact(
|
s.FTerminateDate, "yyyy-MM-dd HH:mm:ss", null);
|
|
entity.TotalReceivedQty = Convert.ToDecimal(s.FReceiveQty);
|
entity.RemainingReceivedQty =
|
Convert.ToDecimal(s.FRemainReceiveQty);
|
entity.TotalStoredQty = Convert.ToDecimal(s.FStockInQty);
|
entity.RemainingStoredQty = Convert.ToDecimal(s.FRemainStockINQty);
|
entity.TotalReturnedQty = Convert.ToDecimal(s.FMrbQty);
|
entity.ReturnableReceivedQty = Convert.ToDecimal(s.FCHECKRETQTY);
|
entity.ReturnableStoredQty = Convert.ToDecimal(s.FSTOCKRETQTY);
|
entity.SourceDocumentType = s.FSrcBillTypeId;
|
entity.SourceDocumentId = s.FSrcBillNo;
|
entity.DemandTrackingId = s.FReqTraceNo;
|
entity.PlanTrackingId = s.FMtoNo;
|
entity.ChangeFlag = s.FChangeFlag;
|
entity.DemandSource = s.FDEMANDTYPE;
|
entity.DemandDocumentId = s.FDEMANDBILLNO;
|
entity.DemandDocumentLineId = s.FDEMANDBILLENTRYSEQ;
|
entity.PurchaseOrderLineNumber = s.PurchaseOrderLineNumber;
|
entity.Demand = s.Demand;
|
entity.Receiving = s.Receiving;
|
entity.Settlement = s.Settlement;
|
list.Add(entity);
|
});
|
return list;
|
}
|
|
#region 教学方法
|
|
/// <summary>
|
/// 仓储方法满足不了复杂业务需求，业务代码请在这里面定义方法
|
/// </summary>
|
public void Study()
|
{
|
/*********查询*********/
|
|
var data1 = base.GetById(1); //根据ID查询
|
var data2 = base.GetList(); //查询所有
|
var data3 = base.GetList(it => 1 == 1); //根据条件查询
|
//var data4 = base.GetSingle(it => 1 == 1);//根据条件查询一条,如果超过一条会报错
|
|
var p = new PageModel { PageIndex = 1, PageSize = 2 }; // 分页查询
|
var data5 = base.GetPageList(it => 1 == 1, p);
|
Console.Write(p.TotalCount); //返回总数
|
|
var data6 =
|
base.GetPageList(it => 1 == 1, p,
|
it => SqlFunc.GetRandom()); // 分页查询加排序
|
Console.Write(p.TotalCount); //返回总数
|
|
var conModels = new List<IConditionalModel>(); //组装条件查询作为条件实现 分页查询加排序
|
conModels.Add(new ConditionalModel
|
{
|
FieldName = typeof(MesRohIn).GetProperties()[0].Name,
|
ConditionalType = ConditionalType.Equal, FieldValue = "1"
|
}); //id=1
|
var data7 = base.GetPageList(conModels, p, it => SqlFunc.GetRandom());
|
|
AsQueryable().Where(x => 1 == 1)
|
.ToList(); //支持了转换成queryable,我们可以用queryable实现复杂功能
|
|
|
/*********插入*********/
|
var insertData = new MesRohIn(); //测试参数
|
var insertArray = new[] { insertData };
|
base.Insert(insertData); //插入
|
base.InsertRange(insertArray); //批量插入
|
var id = base.InsertReturnIdentity(insertData); //插入返回自增列
|
AsInsertable(insertData).ExecuteCommand(); //我们可以转成 Insertable实现复杂插入
|
|
|
/*********更新*********/
|
var updateData = new MesRohIn(); //测试参数
|
var updateArray = new[] { updateData }; //测试参数
|
base.Update(updateData); //根据实体更新
|
base.UpdateRange(updateArray); //批量更新
|
//base.Update(it => new MesRohIn() { ClassName = "a", CreateTime = DateTime.Now }, it => it.id==1);// 只更新ClassName列和CreateTime列，其它列不更新，条件id=1
|
AsUpdateable(updateData).ExecuteCommand(); //转成Updateable可以实现复杂的插入
|
|
|
/*********删除*********/
|
var deldata = new MesRohIn(); //测试参数
|
base.Delete(deldata); //根据实体删除
|
base.DeleteById(1); //根据主键删除
|
base.DeleteById(new[] { 1, 2 }); //根据主键数组删除
|
base.Delete(it => 1 == 2); //根据条件删除
|
AsDeleteable().Where(it => 1 == 2)
|
.ExecuteCommand(); //转成Deleteable实现复杂的操作
|
}
|
|
#endregion
|
}
|
