From f476ec010c22cd4e3c6a119eea035cbf4594bfbb Mon Sep 17 00:00:00 2001
From: kyy <3283105747@qq.com>
Date: 星期五, 12 九月 2025 19:32:00 +0800
Subject: [PATCH] 1\修正收料通知单

---
 MES.Service/service/BasicData/MesUnitManager.cs |  105 ++++++++++++++++++++++++++++++++--------------------
 1 files changed, 64 insertions(+), 41 deletions(-)

diff --git a/MES.Service/service/BasicData/MesUnitManager.cs b/MES.Service/service/BasicData/MesUnitManager.cs
index 74f8467..ba637e9 100644
--- a/MES.Service/service/BasicData/MesUnitManager.cs
+++ b/MES.Service/service/BasicData/MesUnitManager.cs
@@ -43,39 +43,15 @@
 
     public bool SaveList(List<ErpUnit> units)
     {
-        var list = units.Select(GetMesUnit).ToList();
-        var groupBy = list.GroupBy(s => s.Type)
-            .ToDictionary(g => g.Key, g => g.ToList());
-
-        return UseTransaction(db =>
+        if (units == null || !units.Any())
         {
-            foreach (var unitGroup in groupBy)
-                switch (unitGroup.Key)
-                {
-                    case "0":
-                        if (!UpdateUnitStatusBatch(db, unitGroup.Value, "A"))
-                            throw new NotImplementedException("鍚敤澶辫触");
-                        break;
-                    case "1":
-                        if (!UpdateUnitStatusBatch(db, unitGroup.Value, "B"))
-                            throw new NotImplementedException("绂佺敤澶辫触");
-                        break;
-                    case "3":
-                        if (!DeleteUnitBatch(db, unitGroup.Value))
-                            throw new NotImplementedException("鍒犻櫎澶辫触");
-                        break;
-                    case "2":
-                    case "4":
-                        if (!InsertOrUpdateBatch(db, unitGroup.Value))
-                            throw new NotImplementedException("鍚屾澶辫触");
-                        break;
-                    default:
-                        throw new ArgumentNullException(
-                            $"type娌℃湁{unitGroup.Key}杩欎釜绫诲瀷鐨勫弬鏁�");
-                }
+            Console.WriteLine("璀﹀憡: 浼犲叆鐨勫垪琛ㄤ负绌�");
+            return false;
+        }
 
-            return 1;
-        }) > 0;
+        // 閫愭潯澶勭悊锛屽叏閮ㄦ垚鍔熸墠杩斿洖true锛堜簨鍔″唴鎵归噺澶勭悊鏇翠紭锛屾澶勪繚鎸佸師鏈夐�昏緫锛�
+        var result = units.Select(Save).ToList();
+        return result.All(b => b);
     }
 
     private bool UpdateUnitStatus(SqlSugarScope db, decimal unitId,
@@ -112,7 +88,6 @@
 
     private MesUnit GetMesUnit(ErpUnit unit)
     {
-        
         var fForbidStatus = unit.FForbidStatus;
         if (unit.FForbidStatus == "0")
         {
@@ -122,12 +97,9 @@
         {
             fForbidStatus = "B";
         }
-        
-        return new MesUnit
+
+        var entity = new MesUnit
         {
-            Id = string.IsNullOrEmpty(unit.Id)
-                ? DateTimeOffset.UtcNow.ToUnixTimeSeconds()
-                : Convert.ToDecimal(unit.Id),
             Fnumber = unit.FNumber,
             Fname = unit.FName,
             Funitgroupid = unit.FUnitGroupId,
@@ -145,6 +117,24 @@
             Factory = "1000",
             Type = unit.Type
         };
+
+        // 鏌ユ壘鏄惁宸插瓨鍦ㄧ浉鍚屽崟浣嶇紪鐮佺殑璁板綍
+        var existingUnit = Db.Queryable<MesUnit>()
+            .Where(s => s.Fnumber == entity.Fnumber)
+            .First();
+
+        if (existingUnit != null)
+        {
+            // 濡傛灉瀛樺湪锛屼娇鐢ㄧ幇鏈夌殑ID锛屽悗缁皢鍒犻櫎鍚庨噸鏂版彃鍏�
+            entity.Id = existingUnit.Id;
+        }
+        else
+        {
+            // 濡傛灉涓嶅瓨鍦紝璁句负0锛孖nsertOrUpdate鏂规硶灏嗙敓鎴愭柊ID
+            entity.Id = 0;
+        }
+
+        return entity;
     }
 
     private bool UpdateUnitStatusBatch(SqlSugarScope db, List<MesUnit> unitList,
@@ -178,12 +168,45 @@
         return deleteByIds > 0;
     }
 
+    /// <summary>
+    /// 鐢熸垚鏂扮殑ID锛岀‘淇濅笉閲嶅
+    /// </summary>
+    private decimal GenerateNewId()
+    {
+        // 澶勭悊绌鸿〃鐨勬儏鍐碉紝浠�1寮�濮�
+        var maxId = Db.Queryable<MesUnit>().Max(x => (decimal?)x.Id) ?? 0;
+        var newId = maxId + 1;
+        
+        // 鍙岄噸妫�鏌ワ紝纭繚鐢熸垚鐨処D涓嶅瓨鍦�
+        while (Db.Queryable<MesUnit>().Where(x => x.Id == newId).Any())
+        {
+            newId++;
+        }
+        
+        return newId;
+    }
+
     private bool InsertOrUpdate(SqlSugarScope db, MesUnit entity)
     {
-        db.Deleteable<MesUnit>()
-            .Where(s => s.Id == entity.Id).ExecuteCommand();
-        var insert = db.Insertable(entity).ExecuteCommand();
-        return insert > 0;
+        if (entity.Id == 0)
+        {
+            // 鏂板鎯呭喌锛氱敓鎴愭柊ID骞舵彃鍏�
+            var newId = GenerateNewId();
+            entity.Id = newId;
+            return db.Insertable(entity).IgnoreColumns(ignoreNullColumn:true).ExecuteCommand() > 0;
+        }
+        else
+        {
+            // 鏇存柊鎯呭喌锛氬垹闄ゅ悗閲嶆柊鎻掑叆锛屼繚鎸佸師鏈塈D
+            var originalId = entity.Id;
+            
+            // 鍏堝垹闄ゅ師璁板綍锛堝鏋滃瓨鍦級
+            db.Deleteable<MesUnit>().Where(s => s.Id == originalId).ExecuteCommand();
+            
+            // 閲嶆柊鎻掑叆锛屼繚鎸佸師鏈塈D
+            entity.Id = originalId;
+            return db.Insertable(entity).IgnoreColumns(ignoreNullColumn:true).ExecuteCommand() > 0;
+        }
     }
 
     private bool InsertOrUpdateBatch(SqlSugarScope db, List<MesUnit> unitList)

--
Gitblit v1.9.3