~kyy/LB_MesService.git

			@@ -10,35 +10,35 @@
			using Microsoft.AspNetCore.Mvc;
			using static Gs.Toolbox.UtilityHelper;

			namespace Gs.QiTaCk;

			[ApiGroup(ApiGroupNames.QTCK)]
			public class MesItemBlManager : IRomteService
			namespace Gs.QiTaCk
			{
			private readonly IHttpContextAccessor _http;
			private readonly string _userCode, _userGuid, _orgFids;

			public MesItemBlManager(IHttpContextAccessor httpContextAccessor)
			[ApiGroup(ApiGroupNames.QTCK)]
			public class MesItemBlManager : 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 MesItemBlManager(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,109 +50,111 @@
			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_BL_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;
			total = 0,
			everyPageSize = 0,
			pages = 0,
			list = new List<dynamic>()
			};
			try
			{
			dset = DbHelperSQL.RunProcedure("prc_BL_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);
			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.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="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_BL_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;
			}
			}
			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;
			dynamic m = new ExpandoObject();
			m.outSum = -1;
			m.outMsg = "";
			using (var conn = new SqlConnection(DbHelperSQL.strConn))
			{
			using (var cmd = new SqlCommand("prc_BL_submit", conn))
			{
			try
			dset = DbHelperSQL.RunProcedure("[prc_BL_mx]", parameters, "0");
			if (dset != null && dset.Tables.Count > 0 &&
			dset.Tables[0].Rows.Count > 0)
			{
			conn.Open();
			cmd.CommandType = CommandType.StoredProcedure;
			SqlParameter[] parameters =
			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)
			{
			string _guid = mode.guid;
			string _inFieldValue = mode.inFieldValue;
			dynamic m = new ExpandoObject();
			m.outSum = -1;
			m.outMsg = "";
			using (var conn = new SqlConnection(DbHelperSQL.strConn))
			{
			using (var cmd = new SqlCommand("prc_BL_submit", conn))
			{
			try
			{
			conn.Open();
			cmd.CommandType = CommandType.StoredProcedure;
			SqlParameter[] parameters =
			{
			new("@outMsg", SqlDbType.NVarChar, 300),
			new("@outSum", SqlDbType.Int),
			new("@inEdtUserGuid", _userGuid),
			@@ -161,178 +163,174 @@
			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_WOMDAAHB_submit error：" + ex.Message);
			return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default,
			ex.Message);
			}
			finally
			{
			conn.Close();
			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_WOMDAAHB_submit error：" + ex.Message);
			return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default,
			ex.Message);
			}
			finally
			{
			conn.Close();
			}
			}
			}
			return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Success, "操作成功！");
			}

			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 inOrgId = model.inOrgId; //
			string inGdId = model.inGdId; //工单号
			string inYy = model.inYy; //原因
			string inType = model.inType; //业务类型
			var _sb = new StringBuilder();
			var _split = "\|";
			foreach (var m in model.list)
			/// <summary>
			/// 增加或编辑实体
			/// </summary>
			/// <param name="model"></param>
			/// <returns></returns>
			[RequestMethod(RequestMethods.POST)]
			public ReturnDto<ExpandoObject> EditModel([FromBody] dynamic model)
			{
			string _guid = m.Guid.ToString();
			var _line =
			m.DabGuid + _split
			+ m.Sqsl + _split
			+ m.Bz + _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_BL_edt]", conn))
			Guid? guid = model.guid; //主键
			string inOrgId = model.inOrgId; //
			string inGdId = model.inGdId; //工单号
			string inYy = model.inYy;//原因
			string inType=model.inType;//业务类型
			var _sb = new StringBuilder();
			var _split = "\|";
			foreach (var m in model.list)
			{
			try
			string _guid = m.Guid.ToString();
			var _line =
			m.DabGuid + _split
			+ m.Sqsl + _split
			+ m.Bz + _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_BL_edt]", 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("@outGuid", SqlDbType.UniqueIdentifier),
			new("@outNo", SqlDbType.NVarChar, 300),
			new("@inOrderGuid",
			CheckGuid(guid) ? guid : DBNull.Value),
			new("@inOrderGuid",UtilityHelper.CheckGuid(guid)? guid : DBNull.Value),
			new("@inOrgId", inOrgId),
			new("@inGdId", inGdId),
			new("@inYy", inYy),
			new("@inType", inType),
			new("@inType",inType),
			new("@inEdtUserGuid", _userGuid),
			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_BL_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(),
			"prc_BL_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);
			}

			/// <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))
			/// <summary>
			/// 删除主表或明细
			/// </summary>
			/// <param name="model"></param>
			/// <returns></returns>
			[RequestMethod(RequestMethods.POST)]
			public ReturnDto<int?> DeleteModelOrMx([FromBody] dynamic model)
			{
			using (var cmd = new SqlCommand("[prc_BL_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_BL_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)
			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);
			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();
			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);
			}

			if (_outSum <= 0)
			return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Exception,
			_outMsg);
			return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Success, _outMsg);
			}
			}