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 MesItemsManager : Repository<MesItems>
|
{
|
public bool Save(ErpItems item)
|
{
|
var entity = GetMesItems(item);
|
|
return UseTransaction(db =>
|
{
|
switch (item.Type)
|
{
|
case "3":
|
if (DeleteItem(db, entity))
|
return 1;
|
break;
|
case "2":
|
case "4":
|
case "5":
|
if (InsertOrUpdate(db, entity))
|
return 1;
|
break;
|
default:
|
throw new ArgumentNullException(
|
$"type没有{item.Type}这个类型的参数");
|
}
|
|
throw new NotImplementedException("操作失败");
|
}) > 0;
|
}
|
|
public bool SaveList(List<ErpItems> items)
|
{
|
var result = items.Select(Save).ToList();
|
return result.All(b => b);
|
}
|
|
private bool DeleteItem(SqlSugarScope db, List<MesItems> listItem)
|
{
|
// 提取所有需要的 MesId 组合
|
var ids = listItem.Select(customer => customer.Id.ToString())
|
.ToList();
|
|
// 使用这些 MesId 去查询 MesLinkU9 表，找到对应的 U9Id
|
var u9Ids = Db.Queryable<MesLinkU9>()
|
.Where(u =>
|
ids.Contains(u.MesId) && u.TableType == "MES_ITEMS")
|
.Select(u => u.U9Id)
|
.Distinct() // 应用 Distinct 去重
|
.ToList();
|
|
// 根据 U9Id 找到所有对应的 MesId，进行删除
|
// 注意：这里假设您确实想要删除这些记录。如果不确定，请先查询以验证结果。
|
var idsToDelete = Db.Queryable<MesLinkU9>()
|
.Where(u => u9Ids.Contains(u.U9Id) && u.TableType == "MES_ITEMS")
|
.Select(u => u.MesId)
|
.Distinct() // 应用 Distinct 去重
|
.ToList();
|
|
var deleteByIds = Db.Deleteable<MesItems>().In(idsToDelete)
|
.ExecuteCommand();
|
// if (deleteByIds > 0)
|
// return true;
|
return true;
|
//throw new NotImplementedException("删除失败");
|
}
|
|
private List<MesItems> GetMesItems(ErpItems item)
|
{
|
List<MesItems> list = new();
|
|
foreach (var erpDetail in item.FUseOrgId)
|
{
|
var exists = Db.Queryable<MesLinkU9>().Any(u =>
|
u.U9Id == item.Id && u.OrgId == erpDetail.FUseOrgId &&
|
u.TableType == "MES_ITEMS");
|
|
decimal mesId = 0;
|
if (exists)
|
{
|
//获取mesid
|
mesId = Convert.ToDecimal(Db.Queryable<MesLinkU9>()
|
.Where(u =>
|
u.U9Id == item.Id && u.OrgId == erpDetail.FUseOrgId &&
|
u.TableType == "MES_ITEMS")
|
.Select(u => u.MesId) // 选择 MesId 字段
|
.First());
|
}
|
else
|
{
|
mesId = GetSeqUtil.GetSeq("SEQ_ITEMS_ID");
|
var entity = new MesLinkU9
|
{
|
CreateDate = DateTime.Now,
|
MesId = mesId.ToString(),
|
U9Id = item.Id,
|
OrgId = erpDetail.FUseOrgId,
|
TableType = "MES_ITEMS"
|
};
|
Db.Insertable(entity).ExecuteCommand();
|
}
|
|
var items = new MesItems
|
{
|
Id = mesId,
|
ItemId = mesId,
|
|
Fmaterialgroup = item.FMaterialGroup,
|
ItemNo = item.FNumber,
|
OldItemNo = item.FOldNumber,
|
ItemName = item.FName,
|
CatalogNo = item.CatalogNo,
|
ItemModel = item.FSpecification,
|
SafeStock = item.FSafeStock,
|
Lowlimit = item.FMinStock,
|
Highlimit = item.FMaxStock,
|
DepotCode = item.FStockId,
|
Fisbatchmanage = item.FIsBatchManage,
|
MaterialProperti = item.FErpClsID,
|
Storeunit = item.FStoreUnitID,
|
ItemUnit = item.FBaseUnitId,
|
Fpurchaseunitid = item.FPurchaseUnitId,
|
Saleunit = item.FSaleUnitId,
|
ProduceUnit = item.FPRODUCEUNITID,
|
MaterialOutUomid = item.MaterialOutUomid,
|
CreateBy = item.CreateBy,
|
PubDescSeg38 = item.PubDescSeg38,
|
Description = item.Description,
|
PrivateDescSeg4 = item.PrivateDescSeg4,
|
PrivateDescSeg9 = item.PrivateDescSeg9,
|
IsDualQuantity = item.IsDualQuantity,
|
IsDualUom = item.IsDualUom,
|
IsMultyUom = item.IsMultyUom,
|
IsVarRatio = item.IsVarRatio,
|
ConverRatioRule = item.ConverRatioRule,
|
PrivateDescSeg11 = item.PrivateDescSeg11,
|
PrivateDescSeg7 = item.PrivateDescSeg7,
|
PrivateDescSeg2 = item.PrivateDescSeg2,
|
DocumentStatus = item.FDocumentStatus,
|
ForbidStatus = item.FForbidStatus,
|
UseOrg = erpDetail.FUseOrgId,
|
CreateDate = DateTime.Now,
|
Company = "1000",
|
Factory = "1000",
|
WarehouseKeeper = item.WarehouseKeeper,
|
Merchandiser = item.Merchandiser
|
};
|
list.Add(items);
|
}
|
|
return list;
|
}
|
|
private bool InsertOrUpdate(SqlSugarScope db, List<MesItems> listItem)
|
{
|
DeleteItem(db, listItem);
|
|
var insert = db.Insertable(listItem).PageSize(1).IgnoreColumnsNull()
|
.ExecuteCommand();
|
return insert > 0;
|
}
|
}
|
