From 9eaf758e97367dbc2eca2bdbdc92ab39e08be9d0 Mon Sep 17 00:00:00 2001 From: zs <zhousong@weben-smart.com> Date: 周四, 15 5月 2025 13:12:17 +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 | 146 ++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 127 insertions(+), 19 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 7211e3f..9e1d4b1 100644 --- a/PipeLineLems/server/src/CMS.Plugin.PipeLineLems.Application/Implements/SharedService.cs +++ b/PipeLineLems/server/src/CMS.Plugin.PipeLineLems.Application/Implements/SharedService.cs @@ -19,6 +19,12 @@ using CmsQueryExtensions.Entitys; using CMS.Unit.RuntimeValue.Abstractions; using CMS.Extensions.Variable; +using CMS.Plugin.TraceManagement.Abstractions.Models.Traces; +using CMS.Plugin.ProcessManagement.Abstractions; +using KissUtil.Extensions; +using CMS.Plugin.TraceManagement.Abstractions; +using CMS.Plugin.ProductManagement.Abstractions.Models; +using CMS.Plugin.MaterialManagement.Abstractions; namespace CMS.Plugin.PipeLineLems.Application.Implements; @@ -28,29 +34,135 @@ 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>(); + var _workStationManager = _serviceProvider.GetRequiredService<IWorkStationManager>(); + var traceProvider = _serviceProvider.GetRequiredService<ITraceProvider>(); + 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("鍒嗘嫞宸ュ簭"); + var workStation = await _workStationManager.GetByNameAsync("鍒嗘嫞宸ヤ綅"); + //鍐欏叆杩芥函鎶ヨ〃 + 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() + }); + } + //鐗╂枡鍙傛暟鍒楄〃 + 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("鍒嗘嫞鍘熸枡绠″瀷鍙�"); + 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, + + }); + } + }; + + //閰嶇疆杩囩▼鍙傛暟(閲囬泦鍙傛暟銆侀厤鏂瑰弬鏁�) + traceModel.Params = new List<TraceParamModel>(); + foreach (var item in workSection.ProcessParameters) + { + 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); + var response = new MesOrderResponse { - Code = "000000", + Code = "200", Data = "", - Fail = false, - Mesg = "澶勭悊鎴愬姛", - Success = true, + Message = "澶勭悊鎴愬姛", Time = DateTime.UtcNow }; return response; @@ -262,9 +374,7 @@ { Code = "000000", Data = orderModels, - Fail = false, - Mesg = "澶勭悊鎴愬姛", - Success = true, + Message = "澶勭悊鎴愬姛", Time = DateTime.UtcNow }; return response; @@ -387,10 +497,8 @@ // 杩斿洖缁撴灉 var response = new MesOrderResponse { - Code = "000000", - Fail = false, - Mesg = "鍙枡鎴愬姛", - Success = true, + Code = "200", + Message = "鍙枡鎴愬姛", Time = DateTime.UtcNow }; return response; -- Gitblit v1.9.3