From 3dbb348682f4b7e114d41c22f40e0c0e2bc177b2 Mon Sep 17 00:00:00 2001
From: 快乐的昕的电脑 <快乐的昕的电脑@DESKTOP-C2BQPQU>
Date: 星期三, 26 十一月 2025 16:44:51 +0800
Subject: [PATCH] 物料信息

---
 MES.Service/service/BasicData/MesItemsManager.cs |  107 +++++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 95 insertions(+), 12 deletions(-)

diff --git a/MES.Service/service/BasicData/MesItemsManager.cs b/MES.Service/service/BasicData/MesItemsManager.cs
index e405e58..ea21df2 100644
--- a/MES.Service/service/BasicData/MesItemsManager.cs
+++ b/MES.Service/service/BasicData/MesItemsManager.cs
@@ -1,6 +1,8 @@
-锘縰sing MES.Service.DB;
+锘縰sing AngleSharp.Dom;
+using MES.Service.DB;
 using MES.Service.Dto.webApi;
 using MES.Service.Modes;
+using SharpCompress.Common;
 using SqlSugar;
 
 namespace MES.Service.service.BasicData;
@@ -113,11 +115,18 @@
 
     private MesItems GetMesItems(ErpItems item)
     {
-        return new MesItems
+        // 鏌ユ壘鏄惁宸插瓨鍦ㄧ浉鍚屽鎴风紪鐮佺殑璁板綍銆侷D銆乧reate_date
+        var existingCustomer = Db.Queryable<MesItems>()
+            .Where(s => s.ItemNo == item.FNumber)
+            .First();
+
+        var entity = new MesItems
         {
-            Id = Convert.ToDecimal(item.Id),
-            EItemId = long.Parse(item.Id),
-            ItemId = long.Parse(item.Id),
+            // 濡傛灉瀛樺湪锛屼娇鐢ㄧ幇鏈夌殑ID锛屽悗缁皢鍒犻櫎鍚庨噸鏂版彃鍏�
+            // 濡傛灉涓嶅瓨鍦紝璁句负0锛孖nsertOrUpdate鏂规硶灏嗙敓鎴愭柊ID
+            Id = existingCustomer?.Id ?? 0,
+            EItemId = existingCustomer?.Id ?? 0,
+            ItemId = existingCustomer?.Id ?? 0,
             Type = item.Type,
             ItemNo = item.FNumber,
             ItemName = item.FName,
@@ -134,10 +143,10 @@
             Fissuetype = item.FIssueType,
             Fisbatchmanage = Convert.ToInt32(item.FIsBatchManage),
             Fpurchaserid = item.FPurchaserId,
-            Fpurchaseunitid = Convert.ToDecimal(item.FPurchaseUnitId),
+            Fpurchaseunitid = item.FPurchaseUnitId,
             Storeunit = item.FStoreUnitID,
             Saleunit = item.FSaleUnitId,
-            Fforbidstatus = item.FForbidStatus,
+            //Fforbidstatus = item.FForbidStatus,
             MaterialProperti = item.FErpClsID,
             ProductionWorkshop = item.FWorkShopId,
             ProduceUnit = item.FPRODUCEUNITID,
@@ -145,11 +154,46 @@
             FSubsidiary = item.FUseOrgId,
             Fumbrella = item.FCreateOrgId,
             LastupdateDate = DateTime.Now,
-            CreateDate = DateTime.Now,
+            // 濡傛灉瀛樺湪锛屼娇鐢ㄧ幇鏈夌殑CreateDate锛屽悗缁皢鍒犻櫎鍚庨噸鏂版彃鍏�
+            // 濡傛灉涓嶅瓨鍦紝璁句负褰撳墠鏃堕棿
+            CreateDate = existingCustomer?.CreateDate ?? DateTime.Now,
             MnemonicCode = item.FMnemonicCode,
             Company = "1000",
             Factory = "1000"
         };
+
+        // ERP: 0=鏈鐢�, 1=绂佺敤
+        // MES: A=鏈鐢�, B=绂佺敤
+        if (string.IsNullOrEmpty(item.FForbidStatus))
+        {
+            entity.Fforbidstatus = "A";
+        }
+        else
+        {
+            //鎴戞湡鏈涚殑鍊兼槸A=鍚�,B=鏄�
+            //瀹為檯缁欐垜鐨勫�兼槸0鎴�1锛屾垜甯屾湜涓烘垜杞崲浠嶢鍜孊鐨勬柟寮�
+            entity.Fforbidstatus = item.FForbidStatus == "1" ? "B" : "A";
+        }
+
+        return entity;
+    }
+
+    /// <summary>
+    /// 鐢熸垚鏂扮殑ID锛岀‘淇濅笉閲嶅
+    /// </summary>
+    private decimal GenerateNewId()
+    {
+        // 澶勭悊绌鸿〃鐨勬儏鍐碉紝浠�1寮�濮�
+        var maxId = Db.Queryable<MesItems>().Max(x => (decimal?)x.Id) ?? 0;
+        var newId = maxId + 1;
+
+        // 鍙岄噸妫�鏌ワ紝纭繚鐢熸垚鐨処D涓嶅瓨鍦�
+        while (Db.Queryable<MesItems>().Where(x => x.Id == newId).Any())
+        {
+            newId++;
+        }
+
+        return newId;
     }
 
     private bool UpdateItemStatusBatch(SqlSugarScope db,
@@ -186,15 +230,54 @@
         throw new NotImplementedException("鍒犻櫎澶辫触");
     }
 
+    /// <summary>
+    /// 鍚屾鐗╂枡淇℃伅new_0/4
+    /// </summary>
+    /// <param name="db"></param>
+    /// <param name="entity"></param>
+    /// <returns></returns>
     private bool InsertOrUpdate(SqlSugarScope db, MesItems entity)
     {
-        db.Deleteable<MesItems>().Where(s => s.Id == entity.Id)
-            .ExecuteCommand();
+        if (entity.Id == 0)
+        {
+            // 鏂板鎯呭喌锛氱敓鎴愭柊ID骞舵彃鍏�
+            var newId = GenerateNewId();
+            entity.Id = newId;
+            entity.EItemId = newId;
+            entity.ItemId = newId;
+            return db.Insertable(entity).ExecuteCommand() > 0;
+        }
+        else
+        {
+            // 鏇存柊鎯呭喌锛氬垹闄ゅ悗閲嶆柊鎻掑叆锛屼繚鎸佸師鏈塈D
+            var originalId = entity.Id;
 
-        var insert = db.Insertable(entity).ExecuteCommand();
-        return insert > 0;
+            // 鍏堝垹闄ゅ師璁板綍锛堝鏋滃瓨鍦級
+            db.Deleteable<MesItems>().Where(s => s.Id == originalId).ExecuteCommand();
+
+            // 閲嶆柊鎻掑叆锛屼繚鎸佸師鏈塈D
+            entity.Id = originalId;
+            entity.EItemId = originalId;
+            entity.ItemId = originalId;
+            return db.Insertable(entity).ExecuteCommand() > 0;
+        }
     }
 
+    /// <summary>
+    /// 鍚屾鐗╂枡淇℃伅old_0/4
+    /// </summary>
+    /// <param name="db"></param>
+    /// <param name="entity"></param>
+    /// <returns></returns>
+    //private bool InsertOrUpdate(SqlSugarScope db, MesItems entity)
+    //{
+    //    db.Deleteable<MesItems>().Where(s => s.Id == entity.Id)
+    //        .ExecuteCommand();
+
+    //    var insert = db.Insertable(entity).ExecuteCommand();
+    //    return insert > 0;
+    //}
+
     private bool InsertOrUpdateBatch(SqlSugarScope db, List<MesItems> itemList)
     {
         return itemList.All(entity => InsertOrUpdate(db, entity));

--
Gitblit v1.9.3