切换验收数据库

sjz

2025-09-12 0c1a03e880bbf795b771a9c8ee4b7b271c262b58

 MES.Service/service/BasicData/MesCustomerManager.cs

@@ -44,8 +44,7 @@
    public bool SaveList(List<ErpCustomer> customers)
    {
        var list = customers.Select(GetSysDepartment).ToList();
        var groupBy = list.GroupBy(s => s.Type)
            .ToDictionary(g => g.Key, g => g.ToList());
        var groupBy = list.GroupBy(s => s.Type).ToDictionary(g => g.Key, g => g.ToList());

        return UseTransaction(db =>
        {
@@ -53,13 +52,11 @@
                switch (customerGroup.Key)
                {
                    case "0":
                        if (!UpdateCustomerStatusBatch(db, customerGroup.Value,
                                "A"))
                        if (!UpdateCustomerStatusBatch(db, customerGroup.Value,"A"))
                            throw new NotImplementedException("启用失败");
                        break;
                    case "1":
                        if (!UpdateCustomerStatusBatch(db, customerGroup.Value,
                                "B"))
                        if (!UpdateCustomerStatusBatch(db, customerGroup.Value,"B"))
                            throw new NotImplementedException("禁用失败");
                        break;
                    case "3":
@@ -72,23 +69,20 @@
                            throw new NotImplementedException("同步失败");
                        break;
                    default:
                        throw new ArgumentNullException(
                            $"type没有{customerGroup.Key}这个类型的参数");
                        throw new ArgumentNullException($"type没有{customerGroup.Key}这个类型的参数");
                }

            return 1;
        }) > 0;
    }

    private bool UpdateCustomerStatus(SqlSugarScope db, decimal customerId,
        string status)
    private bool UpdateCustomerStatus(SqlSugarScope db, decimal customerId,string status)
    {
        var result = db.Updateable<MesCustomer>()
            .SetColumns(s => s.Fforbidstatus == status)
            .Where(s => s.Id == customerId).ExecuteCommand();
        var result = db.Updateable<MesCustomer>().SetColumns(s => s.Fforbidstatus == status).Where(s => s.Id == customerId).ExecuteCommand();

        if (result > 0)
        {
            return true;
        }

        throw new NotImplementedException(status == "A" ? "启用失败" : "禁用失败");
    }
@@ -104,11 +98,11 @@

    private bool DeleteCustomer(SqlSugarScope db, decimal customerId)
    {
        var deleteById = db.Deleteable<MesCustomer>()
            .Where(s => s.Id == customerId).ExecuteCommand();
        var deleteById = db.Deleteable<MesCustomer>().Where(s => s.Id == customerId).ExecuteCommand();
        if (deleteById > 0)
        {
            return true;

        }
        throw new NotImplementedException("删除失败");
    }

@@ -135,59 +129,50 @@
            Factory = "1000",
            DataType = customer.FDocumentStatus,
            Type = customer.Type,
            //FPRIMARYGROUP = customer.FPRIMARYGROUP
            
        };
    }

    private bool UpdateCustomerStatusBatch(SqlSugarScope db,
        List<MesCustomer> customerList, string status)
    private bool UpdateCustomerStatusBatch(SqlSugarScope db,List<MesCustomer> customerList, string status)
    {
        var ids = customerList.Select(it => it.Id).ToArray();
        var result = db.Updateable<MesCustomer>()
            .SetColumns(s => s.Fforbidstatus == status)
            .Where(s => ids.Contains(s.Id)).ExecuteCommand();

        var result = db.Updateable<MesCustomer>().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<MesCustomer> customerList)
    private bool InsertCustomerBatch(SqlSugarScope db,List<MesCustomer> customerList)
    {
        var insertRange = db.Insertable(customerList).ExecuteCommand();
        if (insertRange > 0)
        {
            return true;

        }
        throw new NotImplementedException("插入失败");
    }

    private bool DeleteCustomerBatch(SqlSugarScope db,
        List<MesCustomer> customerList)
    private bool DeleteCustomerBatch(SqlSugarScope db,List<MesCustomer> customerList)
    {
        var ids = customerList.Select(it => it.Id).ToArray();
        var deleteByIds = db.Deleteable<MesCustomer>()
            .Where(s => ids.Contains(s.Id)).ExecuteCommand();
        var deleteByIds = db.Deleteable<MesCustomer>().Where(s => ids.Contains(s.Id)).ExecuteCommand();
        if (deleteByIds > 0)
        {
            return true;
        }

        throw new NotImplementedException("删除失败");
    }

    private bool InsertOrUpdate(SqlSugarScope db, MesCustomer entity)
    {
        db.Deleteable<MesCustomer>().Where(s => s.Id == entity.Id)
            .ExecuteCommand();

        db.Deleteable<MesCustomer>().Where(s => s.Id == entity.Id).ExecuteCommand();
        var insert = db.Insertable(entity).ExecuteCommand();

        return insert > 0;
    }

    private bool InsertOrUpdateBatch(SqlSugarScope db,
        List<MesCustomer> customerList)
    private bool InsertOrUpdateBatch(SqlSugarScope db,List<MesCustomer> customerList)
    {
        return customerList.All(entity => InsertOrUpdate(db, entity));
    }