using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using MES.Service.DB;
|
using MES.Service.Dto.webApi;
|
using MES.Service.Modes;
|
using static Microsoft.EntityFrameworkCore.DbLoggerCategory;
|
|
namespace MES.Service.service
|
{
|
public class DbckaManager : Repository<MesInvItemDbsq>
|
{
|
public bool SaveList(List<ERPDBCK> list)
|
{
|
var result = list.Select(Save).ToList();
|
return result.All(b => b);
|
}
|
|
public bool Save(ERPDBCK data)
|
{
|
var head = MapErpToMesHead(data.erpDbcka);
|
var details = MapErpDbckbToDbckb(data.erpDbckB);
|
|
return UseTransaction(db =>
|
{
|
switch (data.erpDbcka.type)
|
{
|
case "3":
|
return UpdateData(db, head, details) ? 1 : 0;
|
case "2":
|
case "4":
|
case "5":
|
return SaveOrUpdateData(db, head, details) ? 1 : 0;
|
default:
|
throw new NotImplementedException($"type没有 {data.erpDbcka.type} 这个类型");
|
}
|
}) > 0;
|
}
|
|
private MesInvItemDbsq MapErpToMesHead(ErpDBCKA dto)
|
{
|
var entity = new MesInvItemDbsq
|
{
|
BillNo = dto.billno,
|
Djlx = dto.dj_lx,
|
DbLx1 = dto.db_lx1,
|
DbFx = dto.db_fx,
|
DbLx = dto.db_lx,
|
YwLx = dto.yw_lx,
|
DjZt = dto.dj_zt,
|
SqBm = dto.sq_bm,
|
SqZz = dto.sq_zz,
|
SqTime = dto.sq_time,
|
DcHz = dto.dc_hz,
|
Remark = dto.bz,
|
Erpid = dto.erpid,
|
CreateDate = DateTime.Now,
|
CreateBy = "System"
|
};
|
|
// var single = base.GetSingle(it => it.Erpid == entity.Erpid);
|
/* if (single != null && single.Id.HasValue)
|
entity.Id = single.Id.Value;*/
|
var single = Db.Queryable<MesInvItemDbsq>()
|
.Where(it => it.Erpid == entity.Erpid)
|
.First();
|
if (single != null)
|
entity.Id = single.Id;
|
|
return entity;
|
}
|
|
|
private List<MesInvItemDbsqItems> MapErpDbckbToDbckb(List<ErpDBCKB> list)
|
{
|
var result = new List<MesInvItemDbsqItems>();
|
|
foreach (var dto in list)
|
{
|
var item = new MesInvItemDbsqItems
|
{
|
ItemId = Convert.ToDecimal(dto.itemid),
|
ItemUnit = Convert.ToDecimal(dto.unit),
|
SqNum = decimal.TryParse(dto.quantity, out var qty) ? qty : 0,
|
DcOrg = dto.dc_org,
|
DcDepot = dto.dc_depot,
|
DrOrg = dto.dr_org,
|
DrDepot = dto.dr_depot,
|
DcHz = dto.dc_hz,
|
DrHz = dto.dr_hz,
|
Remark = dto.bz,
|
Erpid = dto.erpid,
|
Eid = dto.eid,
|
|
};
|
|
var existing = Db.Queryable<MesInvItemDbsqItems>().Where(s => s.Erpid == item.Erpid).Single();
|
if (existing != null) item.Id = existing.Id;
|
|
result.Add(item);
|
}
|
|
return result;
|
}
|
|
private bool SaveOrUpdateData(SqlSugarScope db, MesInvItemDbsq head, List<MesInvItemDbsqItems> details)
|
{
|
if (head.Id != null)
|
base.DeleteById(head.Id);
|
|
db.Deleteable<MesInvItemDbsqItems>()
|
.Where(d => d.Eid == head.Erpid)
|
.ExecuteCommand();
|
|
var insertedHead = db.Insertable(head)
|
.IgnoreColumns(true)
|
.ExecuteReturnIdentity();
|
if (insertedHead <= 0)
|
throw new Exception("主表插入失败，未返回ID");
|
|
|
|
var success = db.Insertable(details)
|
.PageSize(10)
|
.IgnoreColumnsNull()
|
.ExecuteCommand() > 0;
|
|
|
if (insertedHead >= 0 && success) return true;
|
throw new NotImplementedException("插入或更新失败");
|
}
|
|
private bool UpdateData(SqlSugarScope db, MesInvItemDbsq head, List<MesInvItemDbsqItems> details)
|
{
|
var ids = details.Select(d => d.Id).ToArray();
|
var deletedHead = base.DeleteById(head.Id);
|
var deletedDetails = db.Deleteable<MesInvItemDbsqItems>().In(ids).ExecuteCommand() > 0;
|
|
|
if (deletedHead && deletedDetails) return true;
|
throw new NotImplementedException("更新失败");
|
}
|
}
|
}
|
