using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using MES.Service.DB;
|
using MES.Service.Dto.webApi;
|
using MES.Service.Modes;
|
|
namespace MES.Service.service
|
{
|
public class ZzcxdManager : Repository<Zzcxa>
|
{
|
public bool SaveList(List<ERPZZCXD> list)
|
{
|
var result = list.Select(Save).ToList();
|
return result.All(b => b);
|
}
|
|
public bool Save(ERPZZCXD data)
|
{
|
var head = MapErpToMesHead(data.ERPZZCXA);
|
var details = MapErpDbckbToDbckb(data.ERPZZCXB);
|
|
return UseTransaction(db =>
|
{
|
switch (data.ERPZZCXA.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.ERPZZCXA.type} 这个类型");
|
}
|
}) > 0;
|
}
|
|
private Zzcxa MapErpToMesHead(ERPZZCXA dto)
|
{
|
var entity = new Zzcxa
|
{
|
BillNo = dto.bill_no, // 单据编码
|
DjLx = dto.dj_lx, // 单据类型
|
KcZz = dto.kc_zz, // 库存组织
|
SwLx = dto.sw_lx, // 事务类型
|
Time = dto.time , // 日期
|
Bm = dto.bm, // 部门
|
Cgy = dto.cgy, // 仓管员
|
Kcz = dto.kcz, // 库存组
|
DjZt = dto.dj_zt, // 单据状态
|
Memo = dto.memo, // 备注
|
Cphzlx = dto.cphzlx, // 成品货主类型
|
Cphz = dto.cphz, // 成品货主
|
Zjhzlx = dto.zjhzlx, // 子件货主类型
|
Zjhz = dto.zjhz, // 子件货主
|
ItemId = string.IsNullOrEmpty(dto.item_id) ? null : Convert.ToDecimal(dto.item_id), // 物料编码id
|
Qty = string.IsNullOrEmpty(dto.qty) ? null : Convert.ToDecimal(dto.qty), // 数量
|
Unit = dto.unit, // 单位
|
DepotId = dto.depot_id, // 仓库
|
Erpid = dto.erpid // ERP 主表id
|
};
|
|
var single = Db.Queryable<Zzcxa>()
|
.Where(it => it.Erpid == entity.Erpid)
|
.First();
|
if (single != null)
|
entity.Id = single.Id;
|
|
return entity;
|
}
|
|
private List<Zzcxb> MapErpDbckbToDbckb(List<ERPZZCXB> list)
|
{
|
var result = new List<Zzcxb>();
|
|
foreach (var dto in list)
|
{
|
var item = new Zzcxb
|
{
|
Erpid = dto.erpid, // ERP 主表id
|
Eid = dto.eid, // ERP 单据头id
|
ItemId = string.IsNullOrEmpty(dto.item_id) ? null : Convert.ToDecimal(dto.item_id), // 物料编码id
|
Qty = string.IsNullOrEmpty(dto.qty) ? null : Convert.ToDecimal(dto.qty), // 数量
|
Unit = dto.unit, // 单位
|
DepotId = dto.depot_id, // 仓库
|
LotNo = dto.lot_no, // 批号
|
Memo = dto.memo // 备注
|
};
|
|
var existing = Db.Queryable<Zzcxb>().Where(s => s.Erpid == item.Erpid).Single();
|
if (existing != null) item.Id = existing.Id;
|
|
result.Add(item);
|
}
|
|
return result;
|
}
|
|
private bool SaveOrUpdateData(SqlSugarScope db, Zzcxa head, List<Zzcxb> details)
|
{
|
if (head.Id != null)
|
base.DeleteById(head.Id);
|
|
db.Deleteable<Zzcxb>()
|
.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, Zzcxa head, List<Zzcxb> details)
|
{
|
var ids = details.Select(d => d.Id).ToArray();
|
var deletedHead = base.DeleteById(head.Id);
|
var deletedDetails = db.Deleteable<Zzcxb>().In(ids).ExecuteCommand() > 0;
|
|
if (deletedHead && deletedDetails) return true;
|
throw new NotImplementedException("更新失败");
|
}
|
}
|
}
|
