using MES.Service.DB; using MES.Service.Dto.webApi; using MES.Service.Modes; using MES.Service.util; using SqlSugar; using System.Collections.Generic; namespace MES.Service.service.BasicData; public class MesCustomerManager : Repository { public bool Save(ErpCustomer customer) { var entity = GetSysDepartment(customer); return UseTransaction(db => { switch (customer.Type) { case "0": if (UpdateCustomerStatusBatch(db, entity, "A")) return 1; break; case "1": if (UpdateCustomerStatusBatch(db, entity, "B")) return 1; break; case "3": if (DeleteCustomerBatch(db, entity)) return 1; break; case "2": case "4": if (InsertOrUpdateBatch(db, entity)) return 1; break; default: throw new ArgumentNullException( $"type没有{customer.Type}这个类型的参数"); } throw new NotImplementedException("操作失败"); }) > 0; } public bool SaveList(List customers) { //var list = customers.Select(GetSysDepartment).ToList(); //因为U9的模式,会导致多组织的基础数据被处理成List<>,所以需要修改方法,SaveLits中应该是把单条处理出来的List数据加起来,而不是之前的方法处理。 List mes_customers = new List(); foreach (ErpCustomer customer in customers) { var mesCustomerList = GetSysDepartment(customer); if (mesCustomerList != null) { mes_customers.AddRange(mesCustomerList); } } var groupBy = mes_customers.GroupBy(s => s.Type) .ToDictionary(g => g.Key, g => g.ToList()); return UseTransaction(db => { foreach (var customerGroup in groupBy) switch (customerGroup.Key) { case "0": if (!UpdateCustomerStatusBatch(db, customerGroup.Value,"A")) throw new NotImplementedException("启用失败"); break; case "1": if (!UpdateCustomerStatusBatch(db, customerGroup.Value,"B")) throw new NotImplementedException("禁用失败"); break; case "3": if (!DeleteCustomerBatch(db, customerGroup.Value)) throw new NotImplementedException("删除失败"); break; case "2": case "4": if (!InsertOrUpdateBatch(db, customerGroup.Value)) throw new NotImplementedException("同步失败"); break; default: throw new ArgumentNullException( $"type没有{customerGroup.Key}这个类型的参数"); } return 1; }) > 0; } private bool UpdateCustomerStatus(SqlSugarScope db, decimal customerId, string status) { var result = db.Updateable() .SetColumns(s => s.Fforbidstatus == status) .Where(s => s.Id == customerId).ExecuteCommand(); if (result > 0) return true; throw new NotImplementedException(status == "A" ? "启用失败" : "禁用失败"); } private bool InsertCustomer(SqlSugarScope db, MesCustomer entity) { var insert = db.Insertable(entity).ExecuteCommand(); if (insert > 0) return true; throw new NotImplementedException("插入失败"); } private bool DeleteCustomer(SqlSugarScope db, decimal customerId) { var deleteById = db.Deleteable().In(customerId) .ExecuteCommand(); if (deleteById > 0) return true; throw new NotImplementedException("删除失败"); } private List GetSysDepartment(ErpCustomer customer) { //var db = SqlSugarHelper.GetInstance(); //var id = db.Insertable(insertObj).ExecuteReturnIdentity(); List customers = new List(); customers = customer.ErpDetails.Select(ErpDetails => new MesCustomer { Id = GetSeqUtil.GetSeq("U9_MES_ID"), CustNo = customer.FNumber, CustSname = customer.FShortName, CustName = customer.FName, Anred = customer.FContact, Telf1 = customer.FMobilephone, Fseller = customer.FSeller, CUSTOMER_STATE = customer.State, Fforbidstatus = customer.FForbidStatus, UseOrg = Convert.ToDecimal(ErpDetails.FUseOrgId), }).ToList(); return customers; } private bool UpdateCustomerStatusBatch(SqlSugarScope db, List customerList, string status) { var ids = customerList.Select(it => it.Id).ToArray(); var result = db.Updateable() .SetColumns(s => s.Fforbidstatus == status) .Where(s => ids.Contains(s.Id)).ExecuteCommand(); if (result > 0) return true; throw new NotImplementedException(status == "A" ? "启用失败" : "禁用失败"); } private bool InsertCustomerBatch(SqlSugarScope db, List customerList) { var insertRange = db.Insertable(customerList).ExecuteCommand(); if (insertRange > 0) return true; throw new NotImplementedException("插入失败"); } private bool DeleteCustomerBatch(SqlSugarScope db, List customerList) { var ids = customerList.Select(it => it.Id).ToArray(); var deleteByIds = db.Deleteable().In(ids).ExecuteCommand(); if (deleteByIds > 0) return true; throw new NotImplementedException("删除失败"); } /// /// "插入或更新的方法"调整:修改为先删除再插入。 /// /// /// 修改人:池南骏 /// 修改日期:2024-12-30 /// 修改说明:` /// //// - 原代码: //private bool InsertOrUpdate(SqlSugarScope db, MesCustomer entity) //{ // var exists = db.Queryable().Any(e => e.Id == entity.Id); // if (exists) // { // var update = db.Updateable(entity).ExecuteCommand(); // if (update > 0) // return true; // } // else // { // var insert = db.Insertable(entity).ExecuteCommand(); // if (insert > 0) // return true; // } // return false; //} /// 新代码 private bool InsertOrUpdate(SqlSugarScope db, MesCustomer entity) { db.Deleteable() .Where(s => s.Id == entity.Id) .ExecuteCommand(); var insert = db.Insertable(entity).ExecuteCommand(); return insert > 0; } private bool InsertOrUpdateBatch(SqlSugarScope db, List customerList) { foreach (var entity in customerList) if (!InsertOrUpdate(db, entity)) return false; return true; } }