From a2448a582f2baeabf32c4f8dd8ab447feb2538e6 Mon Sep 17 00:00:00 2001
From: zs <zhousong@weben-smart.com>
Date: 周五, 16 5月 2025 10:25:21 +0800
Subject: [PATCH] Merge branch 'master' of http://222.71.245.114:9086/r/HIA24016N_PipeLineDemo

---
 PipeLineLems/server/src/CMS.Plugin.PipeLineLems.Application/Implements/SharedService.cs |  121 ++++++++++++++++++++++++++++++++--------
 1 files changed, 96 insertions(+), 25 deletions(-)

diff --git a/PipeLineLems/server/src/CMS.Plugin.PipeLineLems.Application/Implements/SharedService.cs b/PipeLineLems/server/src/CMS.Plugin.PipeLineLems.Application/Implements/SharedService.cs
index acd549a..ee97a01 100644
--- a/PipeLineLems/server/src/CMS.Plugin.PipeLineLems.Application/Implements/SharedService.cs
+++ b/PipeLineLems/server/src/CMS.Plugin.PipeLineLems.Application/Implements/SharedService.cs
@@ -34,12 +34,20 @@
 public class SharedService : CMSPluginAppService
 {
 
-
+    /// <summary>
+    /// 鍒嗘嫞鍔熻兘
+    /// </summary>
+    /// <param name="_serviceProvider"></param>
+    /// <param name="input"></param>
+    /// <param name="myCurrentUser"></param>
+    /// <returns></returns>
     public async Task<MesOrderResponse> CommonPick(IServiceProvider _serviceProvider, PickInput input, MyCurrentUser myCurrentUser)
     {
         //1銆佽褰曞垎鎷h褰曡〃
         //2銆佹洿鏂颁綔涓氳鍒掕〃鐨勭姸鎬� =宸插垎鎷�
         //3銆佸啓鍏� 鍒嗘嫞鍙橀噺
+        //4銆佸啓鍏ヨ拷婧姤琛�
+        //5銆佺墿鏂欑粍鐩�
 
         VariableService _variableService = _serviceProvider.GetRequiredService<VariableService>();
         var _workSectionManager = _serviceProvider.GetRequiredService<IWorkSectionManager>();
@@ -48,13 +56,13 @@
         var materialProvider = _serviceProvider.GetRequiredService<IMaterialProvider>();
         var workPlanAppService = _serviceProvider.GetRequiredService<IWorkPlanAppService>();
 
-        Dictionary<string, object?> keyValuePairs = new Dictionary<string, object?>
-                    {
-                        { "鍒嗘嫞鎵樼洏鍙�","鎵樼洏1"},
-                        { "鍒嗘嫞鏂瑰悜", "鐭瑁呴厤"},
-                        { "鍒嗘嫞浜�", myCurrentUser.UserAccount }
-                    };
-        _variableService.WriteValueAsync(keyValuePairs);
+        //Dictionary<string, object?> keyValuePairs = new Dictionary<string, object?>
+        //            {
+        //                { "鍒嗘嫞鎵樼洏鍙�","鎵樼洏1"},
+        //                { "鍒嗘嫞鏂瑰悜", "鐭瑁呴厤"},
+        //                { "鍒嗘嫞浜�", myCurrentUser.UserAccount }
+        //            };
+        //_variableService.WriteValueAsync(keyValuePairs);
 
         //鏍规嵁宸ュ簭鍚嶈幏鍙栧伐搴忓璞�
         var workSection = await _workSectionManager.GetByNameAsync("鍒嗘嫞宸ュ簭");
@@ -89,26 +97,76 @@
         var firstWorkPlans = await workPlanAppService.GetListByFilterAsync(x => x.PipeSpecCode == input.PipeSpecCode);
 
         var firstWorkPlan = await workPlanAppService.GetSingleByFilterAsync(x => x.PipeSpecCode == input.PipeSpecCode);
-        var rawPipe_DataIdentifier = await materialProvider.FindByNameAsync("鍒嗘嫞鍘熸枡绠℃爣璇�");
-        var rawPipe_MaterialMode = await materialProvider.FindByNameAsync("鍒嗘嫞鍘熸枡绠″瀷鍙�");
+        var rawPipe_DataIdentifier = await materialProvider.FindByNameAsync("鍘熸枡绠℃爣璇�");
+        var rawPipe_MaterialMode = await materialProvider.FindByNameAsync("鍘熸枡绠″瀷鍙�");
+        var rawPipe_Batch = await materialProvider.FindByNameAsync("鍘熸枡绠℃壒娆�");
         List<TraceMaterialModel> _MaterialParams = new List<TraceMaterialModel>();
-        _MaterialParams.Add(new TraceMaterialModel()
+        foreach (var item in workSection.MaterialParameters)
         {
-            Key = "鍒嗘嫞鍘熸枡绠℃爣璇�",
-            Quantity = 1,
-            MaterialId = rawPipe_DataIdentifier.MaterialId,
-            MaterialDetailId = rawPipe_DataIdentifier.MaterialDetails.First().Id,
-            Value = firstWorkPlan.DataIdentifier,
+            if (item.Name == "鍘熸枡绠″瀷鍙�")
+            {
+                _MaterialParams.Add(new TraceMaterialModel()
+                {
+                    Key = item.Key,
+                    Quantity = 1,
+                    MaterialId = rawPipe_MaterialMode.MaterialId,
+                    MaterialDetailId = rawPipe_MaterialMode.MaterialDetails.First().Id,
+                    Value = firstWorkPlan.MaterialMode
 
-        });
-        _MaterialParams.Add(new TraceMaterialModel()
+                });
+            }
+            if (item.Name == "鍘熸枡绠℃爣璇�")
+            {
+                _MaterialParams.Add(new TraceMaterialModel()
+                {
+                    Key = item.Key,
+                    Quantity = 1,
+                    MaterialId = rawPipe_DataIdentifier.MaterialId,
+                    MaterialDetailId = rawPipe_DataIdentifier.MaterialDetails.First().Id,
+                    Value = firstWorkPlan.DataIdentifier,
+
+                });
+            }
+            if (item.Name == "鍘熸枡绠℃壒娆�")
+            {
+                _MaterialParams.Add(new TraceMaterialModel()
+                {
+                    Key = item.Key,
+                    Quantity = 1,
+                    MaterialId = rawPipe_Batch.MaterialId,
+                    MaterialDetailId = rawPipe_Batch.MaterialDetails.First().Id,
+                    Value = "111",//鎵规鏆傛椂鍐欐
+
+                });
+            }
+        };
+
+        //閰嶇疆杩囩▼鍙傛暟(閲囬泦鍙傛暟銆侀厤鏂瑰弬鏁�)
+        traceModel.Params = new List<TraceParamModel>();
+        foreach (var item in workSection.ProcessParameters)
         {
-            Key = "鍒嗘嫞鍘熸枡绠″瀷鍙�",
-            Quantity = 1,
-            MaterialId = rawPipe_MaterialMode.MaterialId,
-            MaterialDetailId = rawPipe_MaterialMode.MaterialDetails.First().Id,
-            Value = firstWorkPlan.MaterialMode
-        });
+            string _value = "";
+            if (item.Name == "鍒嗘嫞鏂瑰悜")
+            {
+                _value = "鐭瑁呴厤";
+            }
+            if (item.Name == "鍒嗘嫞鎵樼洏鍙�")
+            {
+                _value = input.ContinerNo;
+            }
+            if (item.Name == "鍒嗘嫞浜�")
+            {
+                _value = myCurrentUser.UserAccount;
+            }
+            //item.Key
+            TraceParamModel traceParamModel = new TraceParamModel()
+            {
+                Key = item.Key,
+                Value = _value
+            };
+            traceModel.Params.Add(traceParamModel);
+        };
+
         traceModel.MaterialParams = _MaterialParams;
 
         await traceProvider.CreateTraceAsync(traceModel);
@@ -405,7 +463,10 @@
             throw new UserFriendlyException($"鍘熸枡鏍囪瘑涓� '{callMaterialOrder.DataIdentifier}' 鐨勫彨鏂欒褰曠姸鎬佷负 '{callMaterialOrder.CallMaterialStatus}'锛屼笉鍏佽鍙枡");
         }
 
+        //TODO:杩欓噷璋冪敤wms鐨勫彨鏂欐帴鍙�
+
         // 鏇存柊鏁版嵁
+        callMaterialOrder.MaterialBatch = GenerateRandomBatch();//wms杩斿洖鐨勫師鏂欐壒娆�
         callMaterialOrder.WmsRetResult = "鎴愬姛";
         callMaterialOrder.WmsTaskNo = GenerateRandomTaskNo();
         callMaterialOrder.CallMaterialStatus = Domain.Shared.Enums.CallMaterialStatusEnum.鍙枡瀹屾垚;
@@ -414,7 +475,7 @@
         await callMaterialOrderRepository.UpdateAsync(callMaterialOrder);
 
         //鏇存柊浣滀笟璁″垝琛�
-        var workPlanList = await workPlanRepository.FindByDataIdentifierAsync(callMaterialOrder.DataIdentifier);
+        var workPlanList = await workPlanRepository.GetListByFilterAsync(x => x.DataIdentifier == callMaterialOrder.DataIdentifier);
         foreach (var item in workPlanList)
         {
             item.CallMaterialStatus = Domain.Shared.Enums.CallMaterialStatusEnum.鍙枡瀹屾垚;
@@ -426,6 +487,7 @@
         var callMaterialOrderRecord = new CallMaterialOrderRecord()
         {
             CallMaterialStatus = Domain.Shared.Enums.CallMaterialStatusEnum.鍙枡瀹屾垚,
+            MaterialBatch = callMaterialOrder.MaterialBatch,
             MaterialMode = callMaterialOrder.MaterialMode,
             DataIdentifier = callMaterialOrder.DataIdentifier,
             Quantity = 1,
@@ -471,4 +533,13 @@
         // 鐢熸垚鍓嶇紑
         return $"WMS{timestamp}";
     }
+
+    private string GenerateRandomBatch()
+    {
+        // 鑾峰彇褰撳墠鏃堕棿鎴筹紙浠�1970-01-01 00:00:00 UTC鍒扮幇鍦ㄧ殑绉掓暟锛�
+        long timestamp = new DateTimeOffset(DateTime.UtcNow).ToUnixTimeSeconds();
+
+        // 鐢熸垚鍓嶇紑
+        return $"Batch{timestamp}";
+    }
 }

--
Gitblit v1.9.3