From 1b3db8f5683373dd8e179b006e7314783dd1f9db Mon Sep 17 00:00:00 2001 From: cnf <3200815559@qq.com> Date: 星期三, 10 九月 2025 14:42:12 +0800 Subject: [PATCH] 文件补充 --- WebApi/Gs.Wom/Service/MesProcInfoController.cs | 475 +++++++++++++++++++++++++++++----------------------------- 1 files changed, 238 insertions(+), 237 deletions(-) diff --git a/WebApi/Gs.Wom/Service/MesProcInfoController.cs b/WebApi/Gs.Wom/Service/MesProcInfoController.cs index d798403..d636e1a 100644 --- a/WebApi/Gs.Wom/Service/MesProcInfoController.cs +++ b/WebApi/Gs.Wom/Service/MesProcInfoController.cs @@ -1,44 +1,50 @@ -锘縰sing System.Data; -using System.Data.SqlClient; -using System.Dynamic; +锘縰sing Gs.Toolbox.ApiCore.Common.Mvc; using Gs.Toolbox; -using Gs.Toolbox.ApiCore.Abstract.Mvc; -using Gs.Toolbox.ApiCore.Common.Mvc; using Gs.Toolbox.ApiCore.Group; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Mvc; +using System; +using System.Collections.Generic; +using System.Data; +using System.Data.SqlClient; +using System.Dynamic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; +using Gs.Toolbox.ApiCore.Abstract.Mvc; using static Gs.Toolbox.UtilityHelper; -namespace Gs.Wom.Service; - -[ApiGroup(ApiGroupNames.WOM)] -public class MesProcInfoController : IRomteService +namespace Gs.Wom.Service { - private readonly IHttpContextAccessor _http; - private readonly string _userCode, _userGuid, _orgFids; - - public MesProcInfoController(IHttpContextAccessor httpContextAccessor) + [ApiGroup(ApiGroupNames.WOM)] + public class MesProcInfoController : IRomteService { - _http = httpContextAccessor; - (_userCode, _userGuid, _orgFids) = - GetUserGuidAndOrgGuid(_http); - } + private readonly IHttpContextAccessor _http; + private readonly string _userCode, _userGuid, _orgFids; - /// <summary> - /// 璇诲彇鍒楄〃锛屾敮鎸佸垎椤� - /// </summary> - /// <param name="model"></param> - /// <returns></returns> - [RequestMethod(RequestMethods.POST)] - public ReturnDto<PageList<dynamic>> GetListPage([FromBody] dynamic model) - { - int currentPage = model.currentPage; - int everyPageSize = model.everyPageSize; - string sortName = model.sortName; - string keyWhere = model.keyWhere; - SqlParameter[] parameters = + public MesProcInfoController(IHttpContextAccessor httpContextAccessor) { + _http = httpContextAccessor; + (_userCode, _userGuid, _orgFids) = + GetUserGuidAndOrgGuid(_http); + } + + + /// <summary> + /// 璇诲彇鍒楄〃锛屾敮鎸佸垎椤� + /// </summary> + /// <param name="model"></param> + /// <returns></returns> + [RequestMethod(RequestMethods.POST)] + public ReturnDto<PageList<dynamic>> GetListPage([FromBody] dynamic model) + { + int currentPage = model.currentPage; + int everyPageSize = model.everyPageSize; + string sortName = model.sortName; + string keyWhere = model.keyWhere; + SqlParameter[] parameters = + { new("@inCurrentPage", currentPage), new("@inEveryPageSize", everyPageSize), new("@inSortName", sortName), @@ -50,253 +56,248 @@ new("@inP3", ""), new("@inP4", "") }; - var dset = new DataSet(); - var _pglist = new PageList<dynamic> - { - total = 0, - everyPageSize = 0, - pages = 0, - list = new List<dynamic>() - }; - try - { - dset = DbHelperSQL.RunProcedure("[prc_proc_info_lst]", parameters, - "0"); - - if (dset != null && dset.Tables.Count > 0 && - dset.Tables[0].Rows.Count > 0) //鏈夋暟鎹� + var dset = new DataSet(); + var _pglist = new PageList<dynamic> { - var intTotal = - int.Parse(dset.Tables[1].Rows[0]["intTotal"].ToString()); - var pages = intTotal % everyPageSize != 0 - ? intTotal / everyPageSize + 1 - : intTotal / everyPageSize; - _pglist.total = intTotal; - _pglist.everyPageSize = everyPageSize; - _pglist.pages = pages; - var _dy = dset.Tables[0].TableToDynamicList(); - _pglist.list = _dy; - } - } - catch (Exception ex) - { - LogHelper.Debug(ToString(), ex.Message); - return ReturnDto<PageList<dynamic>>.QuickReturn(_pglist, - ReturnCode.Exception, ex.Message); - } - - return ReturnDto<PageList<dynamic>>.QuickReturn(_pglist, - ReturnCode.Success, "璇诲彇鎴愬姛"); - } - - /// <summary> - /// 澧炲姞鎴栫紪杈戝疄浣� - /// </summary> - /// <param name="model"></param> - /// <returns></returns> - [RequestMethod(RequestMethods.POST)] - public ReturnDto<ExpandoObject> EditModel([FromBody] dynamic model) - { - // 涓婚敭澶勭悊 - Guid? guid = model.guid; //涓婚敭 - // 鍩烘湰瀛楁澶勭悊 - string procOrder = model.procOrder; - string procNo = model.procNo; - string workshopCenterCode = model.workshopCenterCode; - string procName = model.procName; - string memo = model.memo; - string org = model.org; - string salaryType = model.salaryType; - - //var _sb = new StringBuilder(); - //var _split = "|"; - //foreach (var m in model.list) - //{ - // string _guid = m.Guid.ToString(); - // var _line = m.ProcOrder + _split - // + m.ProcNo + _split - // + m.WorkshopCenterCode + _split - // + m.Memo + _split - // + (CheckGuid(_guid) ? _guid : Guid.Empty.ToString()); - // if (_sb.Length > 0) - // _sb.Append("~"); - // _sb.Append(_line); - //} - //string memo = model.memo; - //string extDate = model.extDate; - //// - //string quantity = model.quantity; - //string psnQty_1 = model.psnQty_1; - //string iCount_1 = model.iCount_1; - dynamic mObj = new ExpandoObject(); - mObj.outMsg = ""; - mObj.outSum = -1; - mObj.outGuid = ""; - mObj.outNo = ""; - using (var conn = new SqlConnection(DbHelperSQL.strConn)) - { - using (var cmd = new SqlCommand("[prc_proc_info_edt]", conn)) + total = 0, + everyPageSize = 0, + pages = 0, + list = new List<dynamic>() + }; + try { - try + dset = DbHelperSQL.RunProcedure("[prc_proc_info_lst]", parameters, "0"); + + if (dset != null && dset.Tables.Count > 0 && + dset.Tables[0].Rows.Count > 0) //鏈夋暟鎹� { - conn.Open(); - cmd.CommandType = CommandType.StoredProcedure; - SqlParameter[] parameters = + var intTotal = + int.Parse(dset.Tables[1].Rows[0]["intTotal"].ToString()); + var pages = intTotal % everyPageSize != 0 + ? intTotal / everyPageSize + 1 + : intTotal / everyPageSize; + _pglist.total = intTotal; + _pglist.everyPageSize = everyPageSize; + _pglist.pages = pages; + var _dy = dset.Tables[0].TableToDynamicList(); + _pglist.list = _dy; + } + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), ex.Message); + return ReturnDto<PageList<dynamic>>.QuickReturn(_pglist, + ReturnCode.Exception, ex.Message); + } + return ReturnDto<PageList<dynamic>>.QuickReturn(_pglist, + ReturnCode.Success, "璇诲彇鎴愬姛"); + } + + /// <summary> + /// 澧炲姞鎴栫紪杈戝疄浣� + /// </summary> + /// <param name="model"></param> + /// <returns></returns> + [RequestMethod(RequestMethods.POST)] + public ReturnDto<ExpandoObject> EditModel([FromBody] dynamic model) + { + // 涓婚敭澶勭悊 + Guid? guid = model.guid; //涓婚敭 + // 鍩烘湰瀛楁澶勭悊 + string procOrder = model.procOrder; + string procNo = model.procNo; + string workshopCenterCode = model.workshopCenterCode; + string procName = model.procName; + string memo = model.memo; + string org = model.org; + string salaryType = model.salaryType; + + //var _sb = new StringBuilder(); + //var _split = "|"; + //foreach (var m in model.list) + //{ + // string _guid = m.Guid.ToString(); + // var _line = m.ProcOrder + _split + // + m.ProcNo + _split + // + m.WorkshopCenterCode + _split + // + m.Memo + _split + // + (CheckGuid(_guid) ? _guid : Guid.Empty.ToString()); + // if (_sb.Length > 0) + // _sb.Append("~"); + // _sb.Append(_line); + //} + //string memo = model.memo; + //string extDate = model.extDate; + //// + //string quantity = model.quantity; + //string psnQty_1 = model.psnQty_1; + //string iCount_1 = model.iCount_1; + dynamic mObj = new ExpandoObject(); + mObj.outMsg = ""; + mObj.outSum = -1; + mObj.outGuid = ""; + mObj.outNo = ""; + using (var conn = new SqlConnection(DbHelperSQL.strConn)) + { + using (var cmd = new SqlCommand("[prc_proc_info_edt]", conn)) + { + try { + conn.Open(); + cmd.CommandType = CommandType.StoredProcedure; + SqlParameter[] parameters = + { new("@outMsg", SqlDbType.NVarChar, 300), new("@outSum", SqlDbType.Int), new("@outGuid", SqlDbType.UniqueIdentifier), new("@outNo", SqlDbType.NVarChar, 300), - new("@inOrderGuid", - CheckGuid(guid) ? guid : DBNull.Value), - new("@procOrder", procOrder), - new("@procNo", procNo), - new("@workshopCenterCode", workshopCenterCode), - new("@procName", procName), - new("@memo", memo), - new("@org", org), - new("@salaryType", salaryType), - //new("@memo", memo), - //new("@extDate", extDate), - //new("@quantity", quantity), - //new("@psnQty_1", psnQty_1), - //new("@iCount_1", iCount_1), - new("@inEdtUserGuid", _userGuid) + new("@inOrderGuid", CheckGuid(guid) ? guid : DBNull.Value), + new("@procOrder", procOrder), + new("@procNo", procNo), + new("@workshopCenterCode", workshopCenterCode), + new("@procName", procName), + new("@memo", memo), + new("@org",org), + new("@salaryType", salaryType), + //new("@memo", memo), + //new("@extDate", extDate), + //new("@quantity", quantity), + //new("@psnQty_1", psnQty_1), + //new("@iCount_1", iCount_1), + new("@inEdtUserGuid", _userGuid), }; - parameters[0].Direction = ParameterDirection.Output; - parameters[1].Direction = ParameterDirection.Output; - parameters[2].Direction = ParameterDirection.Output; - parameters[3].Direction = ParameterDirection.Output; - foreach (var parameter in parameters) - cmd.Parameters.Add(parameter); - cmd.ExecuteNonQuery(); - mObj.outMsg = parameters[0].Value.ToString(); - mObj.outSum = int.Parse(parameters[1].Value.ToString()); - mObj.outGuid = parameters[2].Value.ToString(); - mObj.outNo = parameters[3].Value.ToString(); - } - catch (Exception ex) - { - LogHelper.Debug(ToString(), - "box_edt error锛�" + ex.Message); - mObj.outMsg = ex.Message; - mObj.outSum = -1; - } - finally - { - conn.Close(); + parameters[0].Direction = ParameterDirection.Output; + parameters[1].Direction = ParameterDirection.Output; + parameters[2].Direction = ParameterDirection.Output; + parameters[3].Direction = ParameterDirection.Output; + foreach (var parameter in parameters) + cmd.Parameters.Add(parameter); + cmd.ExecuteNonQuery(); + mObj.outMsg = parameters[0].Value.ToString(); + mObj.outSum = int.Parse(parameters[1].Value.ToString()); + mObj.outGuid = parameters[2].Value.ToString(); + mObj.outNo = parameters[3].Value.ToString(); + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), + "box_edt error锛�" + ex.Message); + mObj.outMsg = ex.Message; + mObj.outSum = -1; + } + finally + { + conn.Close(); + } } } + if (mObj.outSum <= 0) + return ReturnDto<dynamic>.QuickReturn(mObj, ReturnCode.Exception, mObj.outMsg); + return ReturnDto<dynamic>.QuickReturn(mObj, ReturnCode.Success, mObj.outMsg); } - if (mObj.outSum <= 0) - return ReturnDto<dynamic>.QuickReturn(mObj, ReturnCode.Exception, - mObj.outMsg); - return ReturnDto<dynamic>.QuickReturn(mObj, ReturnCode.Success, - mObj.outMsg); - } - - [RequestMethod(RequestMethods.POST)] - public ReturnDto<int?> DeleteModel([FromBody] dynamic model) - { - int? rtnInt = (int)ReturnCode.Default; - Guid? guid = model.guid; //鍒拌揣鍗曚富閿� - //string mxGuid = model.mxGuid; - var _outMsg = ""; - var _outSum = -1; - using (var conn = new SqlConnection(DbHelperSQL.strConn)) + [RequestMethod(RequestMethods.POST)] + public ReturnDto<int?> DeleteModel([FromBody] dynamic model) { - using (var cmd = new SqlCommand("[prc_proc_info_del]", conn)) + int? rtnInt = (int)ReturnCode.Default; + Guid? guid = model.guid; //鍒拌揣鍗曚富閿� + //string mxGuid = model.mxGuid; + var _outMsg = ""; + var _outSum = -1; + using (var conn = new SqlConnection(DbHelperSQL.strConn)) { - try + using (var cmd = new SqlCommand("[prc_proc_info_del]", conn)) { - conn.Open(); - cmd.CommandType = CommandType.StoredProcedure; - SqlParameter[] parameters = + try { + conn.Open(); + cmd.CommandType = CommandType.StoredProcedure; + SqlParameter[] parameters = + { new("@outMsg", SqlDbType.NVarChar, 300), new("@outSum", SqlDbType.Int), new("@inOrderGuid", CheckGuid(guid) ? guid : DBNull.Value), - new("@inEdtUserGuid", _userGuid) + new("@inEdtUserGuid", _userGuid), //new("@inMxGuid", mxGuid) }; - parameters[0].Direction = ParameterDirection.Output; - parameters[1].Direction = ParameterDirection.Output; - foreach (var parameter in parameters) - cmd.Parameters.Add(parameter); + parameters[0].Direction = ParameterDirection.Output; + parameters[1].Direction = ParameterDirection.Output; + foreach (var parameter in parameters) + cmd.Parameters.Add(parameter); - cmd.ExecuteNonQuery(); - _outMsg = parameters[0].Value.ToString(); - _outSum = int.Parse(parameters[1].Value.ToString()); - } - catch (Exception ex) - { - LogHelper.Debug(ToString(), - "prc_proc_info_del error锛�" + ex.Message); - _outMsg = ex.Message; - _outSum = -1; - } - finally - { - conn.Close(); + cmd.ExecuteNonQuery(); + _outMsg = parameters[0].Value.ToString(); + _outSum = int.Parse(parameters[1].Value.ToString()); + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), + "prc_proc_info_del error锛�" + ex.Message); + _outMsg = ex.Message; + _outSum = -1; + } + finally + { + conn.Close(); + } } } + + if (_outSum <= 0) + return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Exception, + _outMsg); + return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Success, _outMsg); } - if (_outSum <= 0) - return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Exception, - _outMsg); - return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Success, _outMsg); - } - - /// <summary> - /// 璇诲彇 - /// </summary> - /// <param name="guid"></param> - /// <returns></returns> - [RequestMethod(RequestMethods.POST)] - public ReturnDto<ExpandoObject> GetModel([FromBody] dynamic model) - { - string guid = model.guid.ToString(); - dynamic m = new ExpandoObject(); - m.list = new List<dynamic>(); - m.list2 = new List<dynamic>(); - SqlParameter[] parameters = + /// <summary> + /// 璇诲彇 + /// </summary> + /// <param name="guid"></param> + /// <returns></returns> + [RequestMethod(RequestMethods.POST)] + public ReturnDto<ExpandoObject> GetModel([FromBody] dynamic model) { + string guid = model.guid.ToString(); + dynamic m = new ExpandoObject(); + m.list = new List<dynamic>(); + m.list2 = new List<dynamic>(); + SqlParameter[] parameters = + { new("@inMainGuid", guid), new("@inP1", ""), new("@inP2", ""), new("@inP3", ""), new("@inP4", "") }; - var dset = new DataSet(); - try - { - dset = DbHelperSQL.RunProcedure("[prc_proc_info_mx]", parameters, - "0"); - if (dset != null && dset.Tables.Count > 0 && - dset.Tables[0].Rows.Count > 0) + var dset = new DataSet(); + try { - var dr = dset.Tables[0].Rows[0]; - m = dr.RowToDynamic(); - //var _tb = dset.Tables[1].TableToDynamicList(); - //m.list = _tb; - //var _tb2 = dset.Tables[2].TableToDynamicList(); - //m.list2 = _tb2; + dset = DbHelperSQL.RunProcedure("[prc_proc_info_mx]", parameters, "0"); + if (dset != null && dset.Tables.Count > 0 && + dset.Tables[0].Rows.Count > 0) + { + var dr = dset.Tables[0].Rows[0]; + m = dr.RowToDynamic(); + //var _tb = dset.Tables[1].TableToDynamicList(); + //m.list = _tb; + //var _tb2 = dset.Tables[2].TableToDynamicList(); + //m.list2 = _tb2; + } } - } - catch (Exception ex) - { - LogHelper.Debug(ToString(), ex.Message); + catch (Exception ex) + { + LogHelper.Debug(ToString(), ex.Message); + } + + if (m != null) + return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Success, + "璇诲彇鎴愬姛锛�"); + return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default, "璇诲彇澶辫触锛�"); } - if (m != null) - return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Success, - "璇诲彇鎴愬姛锛�"); - return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default, "璇诲彇澶辫触锛�"); } -} \ No newline at end of file +} -- Gitblit v1.9.3