From 5a149d626ae8bc3fa4bddbb53f8caf40f51f6da6 Mon Sep 17 00:00:00 2001 From: zs <zhousong@weben-smart.com> Date: 周三, 04 6月 2025 17:42:13 +0800 Subject: [PATCH] Merge branch 'master' of http://222.71.245.114:9086/r/HIA24016N_PipeLineDemo --- PipeLineLems/server/src/CMS.Plugin.PipeLineLems/Controller/WorkPlanPublicController.cs | 202 +++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 190 insertions(+), 12 deletions(-) diff --git a/PipeLineLems/server/src/CMS.Plugin.PipeLineLems/Controller/WorkPlanPublicController.cs b/PipeLineLems/server/src/CMS.Plugin.PipeLineLems/Controller/WorkPlanPublicController.cs index 0ad0a16..33a15cf 100644 --- a/PipeLineLems/server/src/CMS.Plugin.PipeLineLems/Controller/WorkPlanPublicController.cs +++ b/PipeLineLems/server/src/CMS.Plugin.PipeLineLems/Controller/WorkPlanPublicController.cs @@ -2,6 +2,8 @@ using CMS.Framework.AspNetCore.Users; using CMS.Plugin.PipeLineLems.Application.Contracts.Dtos.WorkPlan; using CMS.Plugin.PipeLineLems.Application.Contracts.Services; +using CMS.Plugin.PipeLineLems.Application.Implements; +using CmsQueryExtensions; using CmsQueryExtensions.Entitys; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Mvc; @@ -20,7 +22,7 @@ [Route("api/v{version:apiVersion}/PipeLineLems/[controller]")] public class WorkPlanPublicController : ControllerBase { - + private readonly IWorkPlanAppService _workPlanAppService; private readonly IMesAppService _mesAppService; private readonly ICurrentUser _currentUser; private readonly Application.Implements.SharedService sharedService; @@ -31,12 +33,13 @@ /// </summary> /// <param name="testentitynameAppService">The testentityname application service.</param> public WorkPlanPublicController(IMesAppService mesAppService, ICurrentUser currentUser, Application.Implements.SharedService _sharedService, - IServiceProvider serviceProvider) + IServiceProvider serviceProvider, IWorkPlanAppService workPlanAppService) { _mesAppService = mesAppService; _currentUser = currentUser; sharedService = _sharedService; _serviceProvider = serviceProvider; + _workPlanAppService = workPlanAppService; } /// <summary> @@ -60,12 +63,23 @@ [Route("Pick")] public virtual async Task<MesOrderResponse> Pick([FromBody] PickInput input) { - MyCurrentUser myCurrentUser = new MyCurrentUser() + try { - UserAccount = _currentUser.UserAccount, - UserId = _currentUser.UserId - }; - return await sharedService.CommonPick(_serviceProvider, input, myCurrentUser); + MyCurrentUser myCurrentUser = new MyCurrentUser() + { + UserAccount = _currentUser.UserAccount, + UserId = _currentUser.UserId + }; + return await sharedService.CommonPick(_serviceProvider, input, myCurrentUser); + } + catch (Exception ex) + { + return new MesOrderResponse() + { + Code = "400", + Message = ex.Message + }; + } } @@ -79,14 +93,178 @@ [Route("CallMaterial")] public virtual async Task<MesOrderResponse> CallMaterial([FromBody] CallMaterialByDataIdentifierInput input) { - MyCurrentUser myCurrentUser = new MyCurrentUser() + try { - UserAccount = _currentUser.UserAccount, - UserId = _currentUser.UserId - }; - return await sharedService.CallMaterial(input, _serviceProvider, myCurrentUser); + MyCurrentUser myCurrentUser = new MyCurrentUser() + { + UserAccount = _currentUser.UserAccount, + UserId = _currentUser.UserId + }; + return await sharedService.CallMaterial(input, _serviceProvider, myCurrentUser); + } + catch (Exception ex) + { + return new MesOrderResponse() + { + Code = "400", + Message = ex.Message + }; + } + } + + /// <summary> + /// 涓嬪彂娉曞叞鍐茬爜 + /// </summary> + /// <param name="input">鏍囪瘑绗�.</param> + /// <returns></returns> + [Authorize] + [HttpPost] + [Route("SendFlangeCode")] + public virtual async Task<MesOrderResponse> SendFlangeCode([FromBody] SendFlangeCodeInput input) + { + try + { + MyCurrentUser myCurrentUser = new MyCurrentUser() + { + UserAccount = _currentUser.UserAccount, + UserId = _currentUser.UserId + }; + return await sharedService.SendFlangeCode_StartProduction(input, _serviceProvider, myCurrentUser); + } + catch (Exception ex) + { + return new MesOrderResponse() + { + Code = "400", + Message = ex.Message + }; + } + } + + /// <summary> + /// 娉曞叞鍐茬爜瀹屽伐 + /// </summary> + /// <param name="input"></param> + /// <returns></returns> + [Authorize] + [HttpPost] + [Route("SendFlangeCode_FinishProduction")] + public virtual async Task<MesOrderResponse> SendFlangeCode_FinishProduction([FromBody] CompleteAssemblyProcessInput input) + { + try + { + MyCurrentUser myCurrentUser = new MyCurrentUser() + { + UserAccount = _currentUser.UserAccount, + UserId = _currentUser.UserId + }; + return await sharedService.SendFlangeCode_CompleteAssemblyProcess(_serviceProvider, input, myCurrentUser); + } + catch (Exception ex) + { + return new MesOrderResponse() + { + Code = "400", + Message = ex.Message + }; + } + } + + /// <summary> + /// 寮�宸� + /// </summary> + /// <param name="input"></param> + /// <returns></returns> + [Authorize] + [HttpPost] + [Route("StartProduction")] + public virtual async Task<MesOrderResponse> StartProduction([FromBody] StartProductionInput input) + { + try + { + MyCurrentUser myCurrentUser = new MyCurrentUser() + { + UserAccount = _currentUser.UserAccount, + UserId = _currentUser.UserId + }; + return await sharedService.StartProduction(input, _serviceProvider, myCurrentUser); + } + catch (Exception ex) + { + return new MesOrderResponse() + { + Code = "400", + Message = ex.Message + }; + } + } + + /// <summary> + /// 瀹屽伐 + /// </summary> + /// <param name="input"></param> + /// <returns></returns> + [Authorize] + [HttpPost] + [Route("FinishProduction")] + public virtual async Task<MesOrderResponse> FinishProduction([FromBody] CompleteAssemblyProcessInput input) + { + try + { + MyCurrentUser myCurrentUser = new MyCurrentUser() + { + UserAccount = _currentUser.UserAccount, + UserId = _currentUser.UserId + }; + return await sharedService.CompleteAssemblyProcess(_serviceProvider, input, myCurrentUser); + } + catch (Exception ex) + { + return new MesOrderResponse() + { + Code = "400", + Message = ex.Message + }; + } } + /// <summary> + /// 鍒嗘嫞鏃惰幏鍙栫敓浜ц鍒掑拰鍒嗛厤鍖哄煙 + /// </summary> + /// <param name="input"></param> + /// <returns></returns> + [HttpPost] + [Route("GetPickRet")] + public virtual async Task<CmsApiResponse<PickOutput>> GetPickRetAsync([FromBody] GetWorkPlanInput input) + { + + //WorkPlanDto workPlanDto = await _workPlanAppService.FindSingleByFilterAsync(input); + ////杩欓噷瑕佽幏鍙杦ms鐨勫簱瀛橈紝鏉ュ垎鏋� 瑕佹斁鍒板摢涓墭鐩橀噷 + //return new PickOutput() + //{ + // WorkPlan = workPlanDto, + // PlaceNo = "", + // ContinerNo = "" + //}; + try + { + MyCurrentUser myCurrentUser = new MyCurrentUser() + { + UserAccount = _currentUser.UserAccount, + UserId = _currentUser.UserId + }; + return await sharedService.GetPickRetAsync(input, _serviceProvider, myCurrentUser); + } + catch (Exception ex) + { + return new CmsApiResponse<PickOutput>() + { + Code = 400, + Message = ex.Message + }; + } + + } } } -- Gitblit v1.9.3