From 5a871e40ec70a3e01a895dfc7f694adee5367a7d Mon Sep 17 00:00:00 2001
From: schangxiang@126.com <schangxiang@126.com>
Date: 周日, 18 5月 2025 15:05:18 +0800
Subject: [PATCH] 222

---
 PipeLineLems/server/src/CMS.Plugin.PipeLineLems.Application/Implements/SharedService.cs |  504 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 498 insertions(+), 6 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 3a1e6b2..297b6c4 100644
--- a/PipeLineLems/server/src/CMS.Plugin.PipeLineLems.Application/Implements/SharedService.cs
+++ b/PipeLineLems/server/src/CMS.Plugin.PipeLineLems.Application/Implements/SharedService.cs
@@ -25,6 +25,12 @@
 using CMS.Plugin.TraceManagement.Abstractions;
 using CMS.Plugin.ProductManagement.Abstractions.Models;
 using CMS.Plugin.MaterialManagement.Abstractions;
+using CMS.Plugin.HIAWms.Application.Contracts.Services;
+using CMS.Plugin.HIAWms.Application.Contracts.Dtos.CommonDto;
+using System.Collections.Generic;
+using CMS.Plugin.HIAWms.Abstractions;
+using Newtonsoft.Json;
+using CmsQueryExtensions;
 
 namespace CMS.Plugin.PipeLineLems.Application.Implements;
 
@@ -55,6 +61,7 @@
         var traceProvider = _serviceProvider.GetRequiredService<ITraceProvider>();
         var materialProvider = _serviceProvider.GetRequiredService<IMaterialProvider>();
         var workPlanAppService = _serviceProvider.GetRequiredService<IWorkPlanAppService>();
+        var callMaterialOrderAppService = _serviceProvider.GetRequiredService<ICallMaterialOrderAppService>();
 
         //Dictionary<string, object?> keyValuePairs = new Dictionary<string, object?>
         //            {
@@ -97,6 +104,9 @@
         var firstWorkPlans = await workPlanAppService.GetListByFilterAsync(x => x.PipeSpecCode == input.PipeSpecCode);
 
         var firstWorkPlan = await workPlanAppService.GetSingleByFilterAsync(x => x.PipeSpecCode == input.PipeSpecCode);
+
+        var callMaterialOrder = await callMaterialOrderAppService.GetSingleByFilterAsync(x => x.DataIdentifier == firstWorkPlan.DataIdentifier);
+
         var rawPipe_DataIdentifier = await materialProvider.FindByNameAsync("鍘熸枡绠℃爣璇�");
         var rawPipe_MaterialMode = await materialProvider.FindByNameAsync("鍘熸枡绠″瀷鍙�");
         var rawPipe_Batch = await materialProvider.FindByNameAsync("鍘熸枡绠℃壒娆�");
@@ -135,7 +145,7 @@
                     Quantity = 1,
                     MaterialId = rawPipe_Batch.MaterialId,
                     MaterialDetailId = rawPipe_Batch.MaterialDetails.First().Id,
-                    Value = "111",//鎵规鏆傛椂鍐欐
+                    Value = callMaterialOrder.MaterialBatch,//鎵规鏆傛椂鍐欐
 
                 });
             }
@@ -148,7 +158,30 @@
             string _value = "";
             if (item.Name == "鍒嗘嫞鏂瑰悜")
             {
-                _value = "鐭瑁呴厤";
+                _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);
+        };
+        foreach (var item in workSection.FormulaParameters)
+        {
+            string _value = "";
+            if (item.Name == "鍒嗘嫞鏂瑰悜")
+            {
+                _value = "鐭鍒嗘嫞";
             }
             if (item.Name == "鍒嗘嫞鎵樼洏鍙�")
             {
@@ -203,6 +236,13 @@
         if (input.Count == 0)
         {
             throw new UserFriendlyException("杈撳叆鍙傛暟Data涓嶈兘涓虹┖");
+        }
+
+        //鍐欐 鎵撶爜鍐呭
+        foreach (var item in input)
+        {
+            //鏍煎紡 绠℃缂栫爜,绠℃鍚嶇О,鑸瑰彿,椤圭洰鍙�
+            item.MarkingContent = item.PipeSpecCode + "," + item.PipeSectionName + "," + item.ShipNumber + "," + item.ProjectNumber;
         }
 
         //鏍¢獙鏁版嵁
@@ -460,15 +500,46 @@
         // 楠岃瘉鐘舵��
         if (callMaterialOrder.CallMaterialStatus != Domain.Shared.Enums.CallMaterialStatusEnum.鏈墽琛�)
         {
-            throw new UserFriendlyException($"鍘熸枡鏍囪瘑涓� '{callMaterialOrder.DataIdentifier}' 鐨勫彨鏂欒褰曠姸鎬佷负 '{callMaterialOrder.CallMaterialStatus}'锛屼笉鍏佽鍙枡");
+            //throw new UserFriendlyException($"鍘熸枡鏍囪瘑涓� '{callMaterialOrder.DataIdentifier}' 鐨勫彨鏂欒褰曠姸鎬佷负 '{callMaterialOrder.CallMaterialStatus}'锛屼笉鍏佽鍙枡");
         }
 
         //TODO:杩欓噷璋冪敤wms鐨勫彨鏂欐帴鍙�
+        try
+        {
+            List<LMesCallMaterialInput> param = new List<LMesCallMaterialInput>() {
+             new LMesCallMaterialInput(){
+                     DataIdentifier=callMaterialOrder.DataIdentifier,
+                      MaterialMode=callMaterialOrder.MaterialMode,
+             }
+        };
+            string baseUrl = @"http://127.0.0.1:18000/api/v1/HIAWms/";
+            string url = baseUrl + "lMesOperate/LMesCallMaterial";
+            string json = JsonConvert.SerializeObject(param);
+            var result = HttpApiRequest.HttpPost(url, json);
+            var res = JsonConvert.DeserializeObject<CmsApiResponse<List<MyCallMaterialOutput>>>(result);
+            if (res.Code == 200)
+            {
+                var retData = res.Data;
+                callMaterialOrder.MaterialBatch = retData[0].MaterialBatch;
+                callMaterialOrder.WmsTaskNo = retData[0].TaskNo;
+                callMaterialOrder.WmsRetResult = res.Message;
+            }
+            else
+            {
+                throw new UserFriendlyException(res.Message);
+            }
+        }
+        catch (Exception)
+        {
+
+            throw;
+        }
+
 
         // 鏇存柊鏁版嵁
-        callMaterialOrder.MaterialBatch = GenerateRandomBatch();//wms杩斿洖鐨勫師鏂欐壒娆�
-        callMaterialOrder.WmsRetResult = "鎴愬姛";
-        callMaterialOrder.WmsTaskNo = GenerateRandomTaskNo();
+        //callMaterialOrder.MaterialBatch = GenerateRandomBatch();//wms杩斿洖鐨勫師鏂欐壒娆�
+        //callMaterialOrder.WmsRetResult = "鎴愬姛";
+        //callMaterialOrder.WmsTaskNo = GenerateRandomTaskNo();
         callMaterialOrder.CallMaterialStatus = Domain.Shared.Enums.CallMaterialStatusEnum.鍙枡瀹屾垚;
         callMaterialOrder.LastModifierName = "SuperAdmin";
 
@@ -522,6 +593,427 @@
     }
 
     /// <summary>
+    ///瑁呴厤/鐒婃帴寮�宸�
+    /// </summary>
+    /// <param name="input"></param>
+    /// <param name="_serviceProvider"></param>
+    /// <param name="myCurrentUser"></param>
+    /// <returns></returns>
+    /// <exception cref="UserFriendlyException"></exception>
+    public async Task<MesOrderResponse> StartProduction(StartProductionInput input, IServiceProvider _serviceProvider, MyCurrentUser myCurrentUser)
+    {
+        if (string.IsNullOrEmpty(input.TaskCode.ToString()))
+        {
+            throw new UserFriendlyException("浠诲姟缂栫爜涓嶈兘涓虹┖");
+        }
+
+        string processName = "";
+
+        VariableService _variableService = _serviceProvider.GetRequiredService<VariableService>();
+        var callMaterialOrderRepository = _serviceProvider.GetRequiredService<ICallMaterialOrderRepository>();
+        var workPlanRepository = _serviceProvider.GetRequiredService<IWorkPlanRepository>();
+        var callMaterialOrderRecordRepository = _serviceProvider.GetRequiredService<ICallMaterialOrderRecordRepository>();
+        var orderManager = _serviceProvider.GetRequiredService<IOrderManager>();
+        var callMaterialOrderAppService = _serviceProvider.GetRequiredService<ICallMaterialOrderAppService>();
+
+        // 鏌ユ壘鏁版嵁
+
+        var workPlan = await workPlanRepository.GetSingleByFilterAsync(x => x.TaskCode == input.TaskCode);
+        if (workPlan == null)
+        {
+            throw new UserFriendlyException($"鎵句笉鍒颁綔涓氳鍒�");
+        }
+        if (workPlan.ProcessName == "瑁呴厤宸ュ簭")
+        {
+            processName = "瑁呴厤";
+        }
+        else if (workPlan.ProcessName == "鐒婃帴宸ュ簭")
+        {
+            processName = "鐒婃帴";
+        }
+
+        // 楠岃瘉鐘舵��
+        if (workPlan.WorkPlanStatus != Domain.Shared.Enums.WorkPlanStatusEnum.鏆傚仠涓� && workPlan.WorkPlanStatus != Domain.Shared.Enums.WorkPlanStatusEnum.鏈敓浜�)
+        {
+            //鏆傛椂娉ㄩ噴
+            //throw new UserFriendlyException($"浠诲姟缂栫爜 '{input.TaskCode}' 鐨勫綍鐘舵�佷负 '{workPlan.WorkPlanStatus}'锛屼笉鍏佽寮�宸�");
+        }
+
+        var callMaterialOrder = await callMaterialOrderAppService.GetSingleByFilterAsync(x => x.DataIdentifier == workPlan.DataIdentifier);
+        #region 浜嬪姟
+
+        using var scope = _serviceProvider.CreateScope();
+        var unitOfWorkManager = scope.ServiceProvider.GetRequiredService<IUnitOfWorkManager>();
+        using var uow = unitOfWorkManager.Begin(requiresNew: true);
+
+        try
+        {
+            #region 鏁版嵁澶勭悊
+
+            //1銆佹洿鏂颁綔涓氳鍒掕〃涓� 鐢熶骇涓�
+            //2銆佺粰PLC鍙戝伐鑹哄弬鏁版寚浠�,骞跺啓鍏� plc涓� 浜у搧id
+            //if (workPlan.ProcessName == "瑁呴厤宸ュ簭")
+            //{
+            //    workPlan.WorkPlanStatus = Domain.Shared.Enums.WorkPlanStatusEnum.鐢熶骇涓�;
+            //}
+            //else if (workPlan.ProcessName == "鐒婃帴宸ュ簭")
+            //{
+            //    workPlan.WorkPlanStatus = Domain.Shared.Enums.WorkPlanStatusEnum.宸插畬鎴�;
+            //}
+            workPlan.WorkPlanStatus = Domain.Shared.Enums.WorkPlanStatusEnum.鐢熶骇涓�;
+
+            await workPlanRepository.UpdateAsync(workPlan);
+
+            Dictionary<string, object?> keyValuePairs = new Dictionary<string, object?>
+                        {
+                            { $"{processName}_ProductID", workPlan.PipeSpecCode },
+                            { $"{processName}绠℃缂栫爜", workPlan.PipeSpecCode },
+                            { $"{processName}绠℃鍚嶇О", workPlan.PipeSectionName },
+                            { $"{processName}鍘熸枡绠℃壒娆�", callMaterialOrder.MaterialBatch },
+                            { $"{processName}鍘熸枡绠″瀷鍙�", callMaterialOrder.MaterialMode },
+                            { $"{processName}鍘熸枡绠℃爣璇�", callMaterialOrder.DataIdentifier },
+                            { $"{processName}椤圭洰鍙�", workPlan.ProjectNumber },
+                            { $"{processName}鑸瑰彿", workPlan.ShipNumber },
+
+                            //閲囬泦鏁版嵁妯℃嫙鍐欏叆
+                            { $"{processName}鍘嬪姏", "10.0 MPa" },
+                            { $"{processName}閫熷害", "18mm/s"},
+
+                            { $"{processName}浜�", myCurrentUser.UserAccount},
+                            { $"{processName}闂撮殭","15mm"},
+                            { $"{processName}浣嶇疆", "10,23,24"},
+                        };
+            _variableService.WriteValueAsync(keyValuePairs);
+
+
+            #endregion
+
+            await uow.CompleteAsync();
+
+            // 杩斿洖缁撴灉
+            var response = new MesOrderResponse
+            {
+                Code = "200",
+                Message = "澶勭悊鎴愬姛",
+                Time = DateTime.UtcNow
+            };
+            return response;
+        }
+        catch (Exception)
+        {
+            await uow.RollbackAsync();
+            throw;
+        }
+        finally
+        {
+
+        }
+
+
+
+        #endregion
+    }
+
+
+
+    /// <summary>
+    /// 瑁呴厤宸ュ簭瀹屽伐
+    /// </summary>
+    /// <param name="_serviceProvider"></param>
+    /// <param name="input"></param>
+    /// <param name="myCurrentUser"></param>
+    /// <returns></returns>
+    public async Task<MesOrderResponse> CompleteAssemblyProcess(IServiceProvider _serviceProvider, CompleteAssemblyProcessInput input, MyCurrentUser myCurrentUser)
+    {
+        //1銆佽褰曞垎鎷h褰曡〃
+        //2銆佹洿鏂颁綔涓氳鍒掕〃鐨勭姸鎬� =宸插垎鎷�
+        //3銆佸啓鍏� 鍒嗘嫞鍙橀噺
+        //4銆佸啓鍏ヨ拷婧姤琛�
+        //5銆佺墿鏂欑粍鐩�
+
+        if (string.IsNullOrEmpty(input.PipeSpecCode))
+        {
+            throw new UserFriendlyException($"绠℃缂栫爜涓嶈兘涓虹┖");
+        }
+
+
+        VariableService _variableService = _serviceProvider.GetRequiredService<VariableService>();
+        var _workSectionManager = _serviceProvider.GetRequiredService<IWorkSectionManager>();
+        var _workStationManager = _serviceProvider.GetRequiredService<IWorkStationManager>();
+        var traceProvider = _serviceProvider.GetRequiredService<ITraceProvider>();
+        var materialProvider = _serviceProvider.GetRequiredService<IMaterialProvider>();
+        var workPlanAppService = _serviceProvider.GetRequiredService<IWorkPlanAppService>();
+        var workPlanRepository = _serviceProvider.GetRequiredService<IWorkPlanRepository>();
+        var callMaterialOrderAppService = _serviceProvider.GetRequiredService<ICallMaterialOrderAppService>();
+
+        string processName = "";
+        //鐗╂枡鍙傛暟鍒楄〃
+        var firstWorkPlan = await workPlanAppService.GetSingleByFilterAsync(x => x.PipeSpecCode == input.PipeSpecCode && x.ProcessName == input.ProcessName);
+        if (firstWorkPlan == null)
+        {
+            throw new UserFriendlyException($"鎵句笉鍒颁綔涓氳鍒�");
+        }
+        if (firstWorkPlan.ProcessName == "瑁呴厤宸ュ簭")
+        {
+            processName = "瑁呴厤";
+        }
+        else if (firstWorkPlan.ProcessName == "鐒婃帴宸ュ簭")
+        {
+            processName = "鐒婃帴";
+        }
+
+        await CompleteHandleOutStoreFinish(_serviceProvider, processName, true);
+
+        //鏍规嵁宸ュ簭鍚嶈幏鍙栧伐搴忓璞�
+        var workSection = await _workSectionManager.GetByNameAsync($"{processName}宸ュ簭");
+        var workStation = await _workStationManager.GetByNameAsync($"{processName}宸ヤ綅");
+        //鍐欏叆杩芥函鎶ヨ〃
+        var finishTime = DateTime.Now;
+        TraceModel traceModel = new TraceModel()
+        {
+            SerialNumber = input.PipeSpecCode,
+            WorkSectionId = workSection.Id,
+            WorkSectionName = workSection.Name,
+            WorkStationName = workStation.Name,
+
+            FinishTime = finishTime,
+            IsQualified = true,
+            UnqualifiedReason = "",
+            ProductModel = "",
+            ProductName = "",
+
+        };
+        traceModel.Params = new List<TraceParamModel>();
+        foreach (var item in workSection.ProcessParameters)
+        {
+            var value = "ssss";
+            traceModel.Params.Add(new TraceParamModel()
+            {
+                Key = item.Key,
+                Value = value.SafeString()
+            });
+        }
+
+        #region 浜嬪姟
+
+        using var scope = _serviceProvider.CreateScope();
+        var unitOfWorkManager = scope.ServiceProvider.GetRequiredService<IUnitOfWorkManager>();
+        using var uow = unitOfWorkManager.Begin(requiresNew: true);
+
+        try
+        {
+            #region 鏁版嵁澶勭悊
+
+
+
+            firstWorkPlan.WorkPlanStatus = Domain.Shared.Enums.WorkPlanStatusEnum.宸插畬鎴�;
+            await workPlanRepository.UpdateAsync(firstWorkPlan);
+
+            var callMaterialOrder = await callMaterialOrderAppService.GetSingleByFilterAsync(x => x.DataIdentifier == firstWorkPlan.DataIdentifier);
+
+            var rawPipe_DataIdentifier = await materialProvider.FindByNameAsync("鍘熸枡绠℃爣璇�");
+            var rawPipe_MaterialMode = await materialProvider.FindByNameAsync("鍘熸枡绠″瀷鍙�");
+            var rawPipe_Batch = await materialProvider.FindByNameAsync("鍘熸枡绠℃壒娆�");
+            var rawPipe_ProjectNumber = await materialProvider.FindByNameAsync("椤圭洰鍙�");
+            var rawPipe_ShipNumber = await materialProvider.FindByNameAsync("鑸瑰彿");
+            List<TraceMaterialModel> _MaterialParams = new List<TraceMaterialModel>();
+            foreach (var item in workSection.MaterialParameters)
+            {
+                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
+
+                    });
+                }
+                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 = callMaterialOrder.MaterialBatch,//鎵规鏆傛椂鍐欐
+
+                    });
+                }
+                if (item.Name == "椤圭洰鍙�")
+                {
+                    _MaterialParams.Add(new TraceMaterialModel()
+                    {
+                        Key = item.Key,
+                        Quantity = 1,
+                        MaterialId = rawPipe_ProjectNumber.MaterialId,
+                        MaterialDetailId = rawPipe_ProjectNumber.MaterialDetails.First().Id,
+                        Value = firstWorkPlan.ProjectNumber,
+
+                    });
+                }
+                if (item.Name == "鑸瑰彿")
+                {
+                    _MaterialParams.Add(new TraceMaterialModel()
+                    {
+                        Key = item.Key,
+                        Quantity = 1,
+                        MaterialId = rawPipe_ShipNumber.MaterialId,
+                        MaterialDetailId = rawPipe_ShipNumber.MaterialDetails.First().Id,
+                        Value = firstWorkPlan.ShipNumber,
+
+                    });
+                }
+            };
+
+            //閰嶇疆杩囩▼鍙傛暟(閲囬泦鍙傛暟銆侀厤鏂瑰弬鏁�)
+            traceModel.Params = new List<TraceParamModel>();
+            foreach (var item in workSection.ProcessParameters)
+            {
+                string _value = "";
+
+                //閲囬泦鍙傛暟
+                if (item.Name == $"{processName}鍘嬪姏")
+                {
+                    var _getValue = await _variableService.ReadValueAsync($"{processName}鍘嬪姏");
+                    _value = _getValue.Content.Value.SafeString().ToString();
+                }
+                if (item.Name == $"{processName}浣嶇疆")
+                {
+                    var _getValue = await _variableService.ReadValueAsync($"{processName}浣嶇疆");
+                    _value = _getValue.Content.Value.SafeString().ToString();
+                }
+                if (item.Name == $"{processName}閫熷害")
+                {
+                    var _getValue = await _variableService.ReadValueAsync($"{processName}閫熷害");
+                    _value = _getValue.Content.Value.SafeString().ToString();
+                }
+
+                if (item.Name == $"{processName}闂撮殭")
+                {
+                    _value = "15mm";
+                }
+                if (item.Name == $"{processName}浜�")
+                {
+                    _value = myCurrentUser.UserAccount;
+                }
+                //item.Key
+                TraceParamModel traceParamModel = new TraceParamModel()
+                {
+                    Key = item.Key,
+                    Value = _value
+                };
+                traceModel.Params.Add(traceParamModel);
+            };
+            foreach (var item in workSection.FormulaParameters)
+            {
+                string _value = "";
+
+                //閲囬泦鍙傛暟
+                if (item.Name == $"{processName}鍘嬪姏")
+                {
+                    var _getValue = await _variableService.ReadValueAsync($"{processName}鍘嬪姏");
+                    _value = _getValue.Content.Value.SafeString().ToString();
+                }
+                if (item.Name == $"{processName}浣嶇疆")
+                {
+                    var _getValue = await _variableService.ReadValueAsync($"{processName}浣嶇疆");
+                    _value = _getValue.Content.Value.SafeString().ToString();
+                }
+                if (item.Name == $"{processName}閫熷害")
+                {
+                    var _getValue = await _variableService.ReadValueAsync($"{processName}閫熷害");
+                    _value = _getValue.Content.Value.SafeString().ToString();
+                }
+
+                if (item.Name == $"{processName}闂撮殭")
+                {
+                    _value = "15mm";
+                }
+                if (item.Name == $"{processName}浜�")
+                {
+                    _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);
+
+            var response = new MesOrderResponse
+            {
+                Code = "200",
+                Data = "",
+                Message = "澶勭悊鎴愬姛",
+                Time = DateTime.UtcNow
+            };
+            return response;
+
+            #endregion
+
+            await uow.CompleteAsync();
+        }
+        catch (Exception)
+        {
+            await uow.RollbackAsync();
+            throw;
+        }
+        finally
+        {
+
+        }
+
+
+
+        #endregion
+
+    }
+
+
+    /// <summary>
+    /// 鍏叡澶勭悊 鍝嶅簲鍑虹珯瀹屾垚淇″彿
+    /// </summary>
+    /// <param name="_serviceProvider"></param>
+    /// <param name="input"></param>
+    /// <param name="myCurrentUser"></param>
+    /// <returns></returns>
+    public async Task CompleteHandleOutStoreFinish(IServiceProvider _serviceProvider, string processName, bool isOutResult)
+    {
+
+        VariableService _variableService = _serviceProvider.GetRequiredService<VariableService>();
+
+        Dictionary<string, object?> keyValuePairs = new Dictionary<string, object?>
+                    {
+                        { $"{processName}鍑虹珯瀹屾垚",isOutResult},
+                        { $"{processName}鍑虹珯缁撴灉",isOutResult? "鎴愬姛":""},
+                    };
+        await _variableService.WriteValueAsync(keyValuePairs);
+
+    }
+
+    /// <summary>
     /// 鐢熸垚闅忔満鐨刉msTaskNo
     /// </summary>
     /// <returns>闅忔満鐢熸垚鐨勪换鍔$紪鍙�</returns>

--
Gitblit v1.9.3