From 6b57612f6e9f7575d206e82955ffd989faaaf8b3 Mon Sep 17 00:00:00 2001 From: 啊鑫 <t2856754968@163.com> Date: 星期五, 12 九月 2025 13:24:15 +0800 Subject: [PATCH] 同步祈禧代码 --- WebApi/Gs.QiTaCk/MesCgthSqManager.cs | 851 ++++++++++++++++++++++++++++---------------------------- 1 files changed, 420 insertions(+), 431 deletions(-) diff --git a/WebApi/Gs.QiTaCk/MesCgthSqManager.cs b/WebApi/Gs.QiTaCk/MesCgthSqManager.cs index 0d6e98a..1c5904e 100644 --- a/WebApi/Gs.QiTaCk/MesCgthSqManager.cs +++ b/WebApi/Gs.QiTaCk/MesCgthSqManager.cs @@ -11,35 +11,34 @@ using Newtonsoft.Json.Linq; using static Gs.Toolbox.UtilityHelper; -namespace Gs.QiTaCk; - -[ApiGroup(ApiGroupNames.QTCK)] -public class MesCgthSqManager : IRomteService +namespace Gs.QiTaCk { - private readonly IHttpContextAccessor _http; - private readonly string _userCode, _userGuid, _orgFids; - - public MesCgthSqManager(IHttpContextAccessor httpContextAccessor) + [ApiGroup(ApiGroupNames.QTCK)] + public class MesCgthSqManager : IRomteService { - _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 = + private readonly IHttpContextAccessor _http; + private readonly string _userCode, _userGuid, _orgFids; + public MesCgthSqManager(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), @@ -51,17 +50,360 @@ new("@inP3", ""), new("@inP4", "") }; - var dset = new DataSet(); - var _pglist = new PageList<dynamic> + var dset = new DataSet(); + var _pglist = new PageList<dynamic> + { + total = 0, + everyPageSize = 0, + pages = 0, + list = new List<dynamic>() + }; + try + { + dset = DbHelperSQL.RunProcedure("prc_cgthsq_lst", parameters, "0"); + if (dset != null && dset.Tables.Count > 0 && + dset.Tables[0].Rows.Count > 0) //鏈夋暟鎹� + { + 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="guid"></param> + /// <returns></returns> + [RequestMethod(RequestMethods.POST)] + public ReturnDto<ExpandoObject> GetModel([FromBody] dynamic model) { - total = 0, - everyPageSize = 0, - pages = 0, - list = new List<dynamic>() + 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", "") }; - try + var dset = new DataSet(); + try + { + dset = DbHelperSQL.RunProcedure("[prc_cgthsq_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; + + } + } + 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, "璇诲彇澶辫触锛�"); + } + + /// <summary> + /// + /// </summary> + /// <param name="mode"></param> + /// <returns></returns> + [RequestMethod(RequestMethods.POST)] + public ReturnDto<ExpandoObject> EditModelSubmit([FromBody] dynamic mode) { - dset = DbHelperSQL.RunProcedure("prc_cgthsq_lst", parameters, "0"); + string _guid = mode.guid; + string _inFieldValue = mode.inFieldValue; + string _proName = "prc_cgthsq_submit"; + dynamic m = new ExpandoObject(); + m.outSum = -1; + m.outMsg = ""; + using (var conn = new SqlConnection(DbHelperSQL.strConn)) + { + using (var cmd = new SqlCommand(_proName, conn)) + { + try + { + conn.Open(); + cmd.CommandType = CommandType.StoredProcedure; + SqlParameter[] parameters = + { + new("@outMsg", SqlDbType.NVarChar, 300), + new("@outSum", SqlDbType.Int), + new("@inEdtUserGuid", _userGuid), + new("@inOrderGuid", _guid), + new("@inFieldValue", _inFieldValue), + new("@in1", ""), + new("@in2", "") + }; + parameters[0].Direction = ParameterDirection.Output; + parameters[1].Direction = ParameterDirection.Output; + foreach (var parameter in parameters) + cmd.Parameters.Add(parameter); + cmd.ExecuteNonQuery(); + m.outMsg = parameters[0].Value.ToString(); + m.outSum = int.Parse(parameters[1].Value.ToString()); + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), "prc_cgthsq_submit error锛�" + ex.Message); + m.outMsg = ex.Message; + return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default, ex.Message); + } + finally + { + conn.Close(); + } + } + } + return ReturnDto<dynamic>.QuickReturn(m, 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 bz = model.Remark; //澶囨敞 + string thOrgId = model.thOrgId;//閫�璐х粍缁� + string gysId = model.SuppId; //渚涘簲鍟� + string Fmrmode = model.Fmrmode;//鏂瑰紡 + string Reason = model.Reason;//鍘熷洜 + string fHasLink = model.fHasLink; + string fRequireOrgId = model.fRequireOrgId; + string fPurchaseDeptId = model.fPurchaseDeptId; + string fPurchaserId = model.fPurchaserId; + string fOwnerIdHead = model.fOwnerIdHead; + StringBuilder _sb = new StringBuilder(); + string _split = "|"; + foreach (var m in model.list) + { + string _guid = m.Guid.ToString(); + var _line = m.AboutGuid + _split + + m.Quantity + _split + + m.Bz + _split + + m.DepotId + _split + + m.ItemId + _split + + (UtilityHelper.CheckGuid(_guid) ? _guid : Guid.Empty.ToString()); + if (_sb.Length > 0) + _sb.Append("~"); + _sb.Append(_line); + } + 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_cgthsq_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",UtilityHelper.CheckGuid(guid) ? guid: DBNull.Value), + new("@inBz", bz), + new("@inGysId", gysId), + new("@Fmrmode", Fmrmode), + new("@Reason", Reason), + new("@inEdtUserGuid", _userGuid), + new("@thOrgId", thOrgId), + new("@fHasLink", fHasLink), + new("@fRequireOrgId", fRequireOrgId), + new("@fPurchaseDeptId", fPurchaseDeptId), + new("@fPurchaserId", fPurchaserId), + new("@fOwnerIdHead", fOwnerIdHead), + new("@inLineList", _sb.ToString()) + }; + 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(), + "prc_cgthsq_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); + } + + /// <summary> + /// 鍒犻櫎涓昏〃鎴栨槑缁� + /// </summary> + /// <param name="model"></param> + /// <returns></returns> + [RequestMethod(RequestMethods.POST)] + public ReturnDto<int?> DeleteModelOrMx([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)) + { + using (var cmd = new SqlCommand("[prc_cgthsq_del]", conn)) + { + try + { + conn.Open(); + cmd.CommandType = CommandType.StoredProcedure; + SqlParameter[] parameters = + { + new("@outMsg", SqlDbType.NVarChar, 300), + new("@outSum", SqlDbType.Int), + new("@inOrderGuid", + UtilityHelper.CheckGuid(guid) + ? guid + : DBNull.Value), + 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); + + cmd.ExecuteNonQuery(); + _outMsg = parameters[0].Value.ToString(); + _outSum = int.Parse(parameters[1].Value.ToString()); + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), + "prc_cgdhd_Edt 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); + } + + + /// <summary> + /// 寮圭獥閫夋嫨 + /// </summary> + /// <param name="model"></param> + /// <returns></returns> + [RequestMethod(RequestMethods.POST)] + public ReturnDto<PageList<dynamic>> SelectForm([FromBody] dynamic model) + { + int currentPage = model.currentPage; + int everyPageSize = model.everyPageSize; + string sortName = model.sortName; + string keyWhere = model.keyWhere; + string inSupId = model.inSupId; + string isWw = model.inIsWw;//0=閲囪喘锛�1=濮斿 + string inReceiveOrgId = model.inReceiveOrgId; + var dset = new DataSet(); + try + { + using (var conn = new SqlConnection(DbHelperSQL.strConn)) + { + using (var cmd = new SqlCommand("[prc_cgthsq_select]", conn)) + { + conn.Open(); + cmd.CommandType = CommandType.StoredProcedure; + SqlParameter[] parameters = + { + new("@inCurrentPage", currentPage), + new("@inEveryPageSize", everyPageSize), + new("@inSortName", sortName), + new("@inSortOrder", ""), + new("@inQueryWhere", keyWhere), + new("@inSupId", inSupId), + new("@inP1", isWw), + new("@inP2", inReceiveOrgId) + }; + foreach (var parameter in parameters) + cmd.Parameters.Add(parameter); + using (var dt = new SqlDataAdapter(cmd)) + { + dt.Fill(dset, "0"); + } + } + + conn.Close(); + } + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), "prc_cgthsq_select error锛�" + ex.Message); + return ReturnDto<PageList<dynamic>>.QuickReturn(default(PageList<dynamic>), ReturnCode.Exception, "璇诲彇澶辫触"); + } + var _pglist = new PageList<dynamic> + { + total = 0, + everyPageSize = 0, + pages = 0, + list = new List<dynamic>() + }; if (dset != null && dset.Tables.Count > 0 && dset.Tables[0].Rows.Count > 0) //鏈夋暟鎹� { @@ -76,421 +418,68 @@ 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); + ReturnCode.Success, "璇诲彇鎴愬姛"); } - return ReturnDto<PageList<dynamic>>.QuickReturn(_pglist, - ReturnCode.Success, "璇诲彇鎴愬姛"); - } - /// <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="query"></param> + /// <returns></returns> + [RequestMethod(RequestMethods.POST)] + public ReturnDto<List<dynamic>> SelectFormTo( + JArray guidList) { - new("@inMainGuid", guid), - new("@inP1", ""), - new("@inP2", ""), - new("@inP3", ""), - new("@inP4", "") - }; - var dset = new DataSet(); - try - { - dset = DbHelperSQL.RunProcedure("[prc_cgthsq_mx]", parameters, "0"); - if (dset != null && dset.Tables.Count > 0 && - dset.Tables[0].Rows.Count > 0) + var intArray = guidList.ToObject<string[]>(); + var sbLine = new StringBuilder(); + foreach (var str in intArray) { - var dr = dset.Tables[0].Rows[0]; - m = dr.RowToDynamic(); - var _tb = dset.Tables[1].TableToDynamicList(); - m.list = _tb; + if (sbLine.Length > 0) + sbLine.Append(","); + sbLine.Append(str); } - } - 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, "璇诲彇澶辫触锛�"); - } - - /// <summary> - /// </summary> - /// <param name="mode"></param> - /// <returns></returns> - [RequestMethod(RequestMethods.POST)] - public ReturnDto<ExpandoObject> EditModelSubmit([FromBody] dynamic mode) - { - string _guid = mode.guid; - string _inFieldValue = mode.inFieldValue; - var _proName = "prc_cgthsq_submit"; - dynamic m = new ExpandoObject(); - m.outSum = -1; - m.outMsg = ""; - using (var conn = new SqlConnection(DbHelperSQL.strConn)) - { - using (var cmd = new SqlCommand(_proName, conn)) - { - try - { - conn.Open(); - cmd.CommandType = CommandType.StoredProcedure; - SqlParameter[] parameters = - { - new("@outMsg", SqlDbType.NVarChar, 300), - new("@outSum", SqlDbType.Int), - new("@inEdtUserGuid", _userGuid), - new("@inOrderGuid", _guid), - new("@inFieldValue", _inFieldValue), - new("@in1", ""), - new("@in2", "") - }; - parameters[0].Direction = ParameterDirection.Output; - parameters[1].Direction = ParameterDirection.Output; - foreach (var parameter in parameters) - cmd.Parameters.Add(parameter); - cmd.ExecuteNonQuery(); - m.outMsg = parameters[0].Value.ToString(); - m.outSum = int.Parse(parameters[1].Value.ToString()); - } - catch (Exception ex) - { - LogHelper.Debug(ToString(), - "prc_cgthsq_submit error锛�" + ex.Message); - m.outMsg = ex.Message; - return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default, - ex.Message); - } - finally - { - conn.Close(); - } - } - } - - return ReturnDto<dynamic>.QuickReturn(m, 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 bz = model.Remark; //澶囨敞 - string thOrgId = model.thOrgId; //閫�璐х粍缁� - string gysId = model.SuppId; //渚涘簲鍟� - string Fmrmode = model.Fmrmode; //鏂瑰紡 - string Reason = model.Reason; //鍘熷洜 - string fHasLink = model.fHasLink; - string fRequireOrgId = model.fRequireOrgId; - string fPurchaseDeptId = model.fPurchaseDeptId; - string fPurchaserId = model.fPurchaserId; - string fOwnerIdHead = model.fOwnerIdHead; - var _sb = new StringBuilder(); - var _split = "|"; - foreach (var m in model.list) - { - string _guid = m.Guid.ToString(); - var _line = m.AboutGuid + _split - + m.Quantity + _split - + m.Bz + _split - + m.DepotId + _split - + m.ItemId + _split - + (CheckGuid(_guid) - ? _guid - : Guid.Empty.ToString()); - if (_sb.Length > 0) - _sb.Append("~"); - _sb.Append(_line); - } - - 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_cgthsq_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("@inBz", bz), - new("@inGysId", gysId), - new("@Fmrmode", Fmrmode), - new("@Reason", Reason), - new("@inEdtUserGuid", _userGuid), - new("@thOrgId", thOrgId), - new("@fHasLink", fHasLink), - new("@fRequireOrgId", fRequireOrgId), - new("@fPurchaseDeptId", fPurchaseDeptId), - new("@fPurchaserId", fPurchaserId), - new("@fOwnerIdHead", fOwnerIdHead), - new("@inLineList", _sb.ToString()) - }; - 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(), - "prc_cgthsq_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); - } - - /// <summary> - /// 鍒犻櫎涓昏〃鎴栨槑缁� - /// </summary> - /// <param name="model"></param> - /// <returns></returns> - [RequestMethod(RequestMethods.POST)] - public ReturnDto<int?> DeleteModelOrMx([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)) - { - using (var cmd = new SqlCommand("[prc_cgthsq_del]", conn)) - { - 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("@inMxGuid", mxGuid) - }; - 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_cgdhd_Edt 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); - } - - - /// <summary> - /// 寮圭獥閫夋嫨 - /// </summary> - /// <param name="model"></param> - /// <returns></returns> - [RequestMethod(RequestMethods.POST)] - public ReturnDto<PageList<dynamic>> SelectForm([FromBody] dynamic model) - { - int currentPage = model.currentPage; - int everyPageSize = model.everyPageSize; - string sortName = model.sortName; - string keyWhere = model.keyWhere; - string inSupId = model.inSupId; - string isWw = model.inIsWw; //0=閲囪喘锛�1=濮斿 - string inReceiveOrgId = model.inReceiveOrgId; - var dset = new DataSet(); - try - { + var lst = new List<dynamic>(); + var dset = new DataSet(); using (var conn = new SqlConnection(DbHelperSQL.strConn)) { - using (var cmd = new SqlCommand("[prc_cgthsq_select]", conn)) + using (var cmd = + new SqlCommand("[prc_cgthsq_select_to_grid]", conn)) { - conn.Open(); - cmd.CommandType = CommandType.StoredProcedure; - SqlParameter[] parameters = + try { - new("@inCurrentPage", currentPage), - new("@inEveryPageSize", everyPageSize), - new("@inSortName", sortName), - new("@inSortOrder", ""), - new("@inQueryWhere", keyWhere), - new("@inSupId", inSupId), - new("@inP1", isWw), - new("@inP2", inReceiveOrgId) - }; - foreach (var parameter in parameters) - cmd.Parameters.Add(parameter); - using (var dt = new SqlDataAdapter(cmd)) - { - dt.Fill(dset, "0"); - } - } - - conn.Close(); - } - } - catch (Exception ex) - { - LogHelper.Debug(ToString(), - "prc_cgthsq_select error锛�" + ex.Message); - return ReturnDto<PageList<dynamic>>.QuickReturn( - default(PageList<dynamic>), ReturnCode.Exception, "璇诲彇澶辫触"); - } - - var _pglist = new PageList<dynamic> - { - total = 0, - everyPageSize = 0, - pages = 0, - list = new List<dynamic>() - }; - if (dset != null && dset.Tables.Count > 0 && - dset.Tables[0].Rows.Count > 0) //鏈夋暟鎹� - { - 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; - } - - return ReturnDto<PageList<dynamic>>.QuickReturn(_pglist, - ReturnCode.Success, "璇诲彇鎴愬姛"); - } - - - /// <summary> - /// </summary> - /// <param name="query"></param> - /// <returns></returns> - [RequestMethod(RequestMethods.POST)] - public ReturnDto<List<dynamic>> SelectFormTo( - JArray guidList) - { - var intArray = guidList.ToObject<string[]>(); - var sbLine = new StringBuilder(); - foreach (var str in intArray) - { - if (sbLine.Length > 0) - sbLine.Append(","); - sbLine.Append(str); - } - - var lst = new List<dynamic>(); - var dset = new DataSet(); - using (var conn = new SqlConnection(DbHelperSQL.strConn)) - { - using (var cmd = - new SqlCommand("[prc_cgthsq_select_to_grid]", conn)) - { - try - { - conn.Open(); - cmd.CommandType = CommandType.StoredProcedure; - SqlParameter[] parameters = - { + conn.Open(); + cmd.CommandType = CommandType.StoredProcedure; + SqlParameter[] parameters = + { new("@inP1", sbLine.ToString()) }; - foreach (var parameter in parameters) - cmd.Parameters.Add(parameter); - using (var dt = new SqlDataAdapter(cmd)) + foreach (var parameter in parameters) + cmd.Parameters.Add(parameter); + using (var dt = new SqlDataAdapter(cmd)) + { + dt.Fill(dset, "0"); + } + } + catch (Exception ex) { - dt.Fill(dset, "0"); + LogHelper.Debug(ToString(), + "prc_cgthsq_select_to_grid error锛�" + ex.Message); + } + finally + { + conn.Close(); } } - catch (Exception ex) - { - LogHelper.Debug(ToString(), - "prc_cgthsq_select_to_grid error锛�" + ex.Message); - } - finally - { - conn.Close(); - } } + + if (dset != null && dset.Tables.Count > 0 && + dset.Tables[0].Rows.Count > 0) //鏈夋暟鎹� + lst = dset.Tables[0].TableToDynamicList(); + return ReturnDto<List<dynamic>>.QuickReturn(lst, ReturnCode.Success, + "璇诲彇鎴愬姛锛�"); } - if (dset != null && dset.Tables.Count > 0 && - dset.Tables[0].Rows.Count > 0) //鏈夋暟鎹� - lst = dset.Tables[0].TableToDynamicList(); - return ReturnDto<List<dynamic>>.QuickReturn(lst, ReturnCode.Success, - "璇诲彇鎴愬姛锛�"); } } \ No newline at end of file -- Gitblit v1.9.3