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/WorkService/WorkProController.cs | 436 ++++++++++++++++++++++++++---------------------------- 1 files changed, 208 insertions(+), 228 deletions(-) diff --git a/WebApi/Gs.Wom/WorkService/WorkProController.cs b/WebApi/Gs.Wom/WorkService/WorkProController.cs index 8ced017..8c7cb2c 100644 --- a/WebApi/Gs.Wom/WorkService/WorkProController.cs +++ b/WebApi/Gs.Wom/WorkService/WorkProController.cs @@ -13,252 +13,232 @@ using static Gs.Toolbox.UtilityHelper; -namespace Gs.Wom.WorkService; - -[ApiGroup(ApiGroupNames.BaseInfo)] -public class WorkProController : IRomteService +namespace Gs.Wom.WorkService { - private readonly IHttpContextAccessor _http; - private readonly string _userCode, _userGuid, _orgFids; - - - public WorkProController(IHttpContextAccessor httpContextAccessor) + [ApiGroup(ApiGroupNames.BaseInfo)] + public class WorkProController : IRomteService { - _http = httpContextAccessor; - (_userCode, _userGuid, _orgFids) = - GetUserGuidAndOrgGuid(_http); - } + private readonly IHttpContextAccessor _http; + private readonly string _userCode, _userGuid, _orgFids; - #region - /// <summary> - /// 璇诲彇鍒楄〃锛屾敮鎸佸垎椤� - /// </summary> - /// <param name="model"></param> - /// <returns></returns> - [RequestMethod(RequestMethods.POST)] - public ReturnDto<PageList<dynamic>> GetListPage([FromBody] PageQuery model) - { - var currentPage = model.currentPage; - var everyPageSize = model.everyPageSize; - var sortName = string.IsNullOrEmpty(model.sortName) - ? "a.hNo" - : model.sortName; - var keyWhere = model.keyWhere; - var sbSql = new StringBuilder(); - sbSql.Append("select * from "); - sbSql.Append("( "); - sbSql.Append("select top 100000 ROW_NUMBER() over(order by " + - sortName + " " + model.sortOrder + - ") as rowIndex,cast(0 as bit) as chkInt,a.*,(a.processNo+':'+a.processName) as processNoAndName,(case a.isStatus when 1 then '姝e父' when -1 then '绂佺敤' else cast(a.isStatus as nvarchar(4)) end) as isStatusTxt from WORK_PROCESS a where 1=1" + - keyWhere); - sbSql.Append(") as T "); - sbSql.Append(" where T.rowindex>(" + currentPage + "-1)*" + - everyPageSize + " and T.rowindex<=" + currentPage + "*" + - everyPageSize); - sbSql.Append(" order by rowindex asc "); - sbSql.Append( - " select count(1) as intTotal from WORK_PROCESS a where 1=1 " + - keyWhere); - var dset = new DataSet(); - try + public WorkProController(IHttpContextAccessor httpContextAccessor) { - dset = DbHelperSQL.Query(sbSql.ToString()); - } - catch (Exception ex) - { - LogHelper.Debug(ToString(), "GetListPage error锛�" + ex.Message); - return ReturnDto<PageList<dynamic>>.QuickReturn( - default(PageList<dynamic>), ReturnCode.Exception, ex.Message); + _http = httpContextAccessor; + (_userCode, _userGuid, _orgFids) = + GetUserGuidAndOrgGuid(_http); } - var _pglist = new PageList<dynamic> + #region + /// <summary> + /// 璇诲彇鍒楄〃锛屾敮鎸佸垎椤� + /// </summary> + /// <param name="model"></param> + /// <returns></returns> + [RequestMethod(RequestMethods.POST)] + public ReturnDto<PageList<dynamic>> GetListPage([FromBody] PageQuery model) { - 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, "璇诲彇鎴愬姛"); - } + //(case a.isStatus when 1 then '姝e父' when - 1 then '绂佺敤' else cast(a.isStatus as nvarchar(4)) end) as isStatusTxt - - /// <summary> - /// 鍒犻櫎 - /// </summary> - /// <param name="model"></param> - /// <returns></returns> - [RequestMethod(RequestMethods.POST)] - public ReturnDto<int?> DeleteModel([FromBody] JArray guidList) - { - var intArray = guidList.ToObject<string[]>(); - var sbGuid = new StringBuilder(); - foreach (var val in intArray) - { - if (sbGuid.Length > 0) sbGuid.Append(", "); - sbGuid.Append(val); - } - - var rtnInt = (int)ReturnCode.Default; - var cont = 0; - try - { - cont = isChkOrUnChk(sbGuid.ToString(), 1); - if (cont > 0) - return ReturnDto<int>.QuickReturn(default(int?), - ReturnCode.Exception, "鍒犻櫎澶辫触锛岃淇℃伅宸茶瀹℃牳锛�"); + var currentPage = model.currentPage; + var everyPageSize = model.everyPageSize; + var sortName = string.IsNullOrEmpty(model.sortName) + ? "a.hNo" + : model.sortName; + var keyWhere = model.keyWhere; var sbSql = new StringBuilder(); - sbSql.Append("delete from WORK_PROCESS "); - sbSql.Append(" where guid in (select line from dbo.fn_split('" + - sbGuid + "',','))"); - var rows = DbHelperSQL.ExecuteSql(sbSql.ToString()); - rtnInt = rows; - } - catch (Exception ex) - { - LogHelper.Debug(ToString(), "DeleteModel error锛�" + ex.Message); - rtnInt = (int)ReturnCode.Exception; - return ReturnDto<int>.QuickReturn(default(int?), - ReturnCode.Exception, "鍒犻櫎澶辫触锛�" + ex.Message); - } - - if (rtnInt > 0) - return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Success, - "鎿嶄綔鎴愬姛锛屽叡鍒犻櫎" + rtnInt + "鏉℃暟鎹紒"); - return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Exception, - "鍒犻櫎澶辫触锛岃閲嶈瘯锛�"); - } - - /// <summary> - /// 澧炲姞 - /// </summary> - /// <param name="model"></param> - /// <returns></returns> - [RequestMethod(RequestMethods.POST)] - public ReturnDto<string?> EditModel([FromBody] dynamic model) - { - string guid = model.guid; - string processNo = model.processNo; - string processName = model.processName; - string remark = model.remark; - string isBack = model.isBack; - string isStatus = model.isStatus; - string isZsm = model.isZsm; - string isTbm = model.isTbm; - string description = model.description; - int? rtnInt = (int)ReturnCode.Default; - var sbSql = new StringBuilder(); - if (!CheckGuid(guid)) - { - guid = Guid.NewGuid().ToString(); + sbSql.Append("select * from "); + sbSql.Append("( "); + sbSql.Append("select top 100000 ROW_NUMBER() over(order by " + + sortName + " " + model.sortOrder + + ") as rowIndex,cast(0 as bit) as chkInt, a.*,(a.PROC_NO+':'+a.PROC_NAME) as processNoAndName from MES_PROC_INFO a where 1=1" + + keyWhere); + sbSql.Append(") as T "); + sbSql.Append(" where T.rowindex>(" + currentPage + "-1)*" + + everyPageSize + " and T.rowindex<=" + currentPage + "*" + + everyPageSize); + sbSql.Append(" order by rowindex asc "); sbSql.Append( - "INSERT INTO [dbo].[WORK_PROCESS] ([guid] ,[processNo] ,[processName] ,[remark] ,[isBack] ,[isStatus] ,[description] ,[createBy] ,[createDate] ,[lastUpdateBy] ,[lastUpdateDate],isZsm,isTbm)"); - sbSql.Append(" values( '" + guid + - "',@processNo,@processName,@remark,@isBack,@isStatus,@description,'" + - _userCode + "',getdate(),'" + _userCode + - "',getdate(),@isZsm,@isTbm)"); - } - else - { - sbSql.Append( - "UPDATE [dbo].[WORK_PROCESS] SET [processNo] =@processNo,[processName] =@processName,[remark] =@remark,[isBack] =@isBack,[isStatus] =@isStatus,[description] =@description,[lastUpdateBy] ='" + - _userCode + - "',[lastUpdateDate] =getdate(),isZsm=@isZsm,isTbm=@isTbm where guid='" + - guid + "'"); - } - - SqlParameter[] parameters = - { - new("@processNo", processNo), - new("@processName", processName), - new("@remark", remark), - new("@isBack", isBack), - new("@isStatus", isStatus), - new("@description", description), - new("@isZsm", isZsm), - new("@isTbm", isTbm) - }; - try - { - rtnInt = DbHelperSQL.ExecuteSql(sbSql.ToString(), parameters); - } - catch (Exception ex) - { - LogHelper.Debug(ToString(), "EditModel error锛�" + ex.Message); - rtnInt = (int)ReturnCode.Exception; - return ReturnDto<string>.QuickReturn("", ReturnCode.Exception, - ex.Message); - } - - if (rtnInt > 0) - return ReturnDto<string>.QuickReturn(guid, ReturnCode.Success, - "鎿嶄綔鎴愬姛锛�"); - return ReturnDto<string>.QuickReturn("", ReturnCode.Exception, - "澧炲姞澶辫触锛岃閲嶈瘯锛�"); - } - - /// <summary> - /// 璇诲彇 - /// </summary> - /// <param name="guid"></param> - /// <returns></returns> - [RequestMethod(RequestMethods.POST)] - [AllowAnonymous] - public ReturnDto<ExpandoObject> GetModel([FromBody] dynamic model) - { - dynamic m = new ExpandoObject(); - var sbSql = new StringBuilder(); - sbSql.Append("select top 1 * from WORK_PROCESS where 1=1 and guid='" + - model.guid.ToString() + "' "); - try - { + " select count(1) as intTotal from MES_PROC_INFO a where 1=1 " + + keyWhere); var dset = new DataSet(); - dset = DbHelperSQL.Query(sbSql.ToString()); - if (dset != null && dset.Tables.Count > 0 && - dset.Tables[0].Rows.Count > 0) + try { - var dr = dset.Tables[0].Rows[0]; - m = dr.RowToDynamic(); - return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Success, - "璇诲彇鎴愬姛锛�"); + dset = DbHelperSQL.Query(sbSql.ToString()); + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), "GetListPage error锛�" + ex.Message); + return ReturnDto<PageList<dynamic>>.QuickReturn(default(PageList<dynamic>), ReturnCode.Exception, ex.Message); + } + 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="model"></param> + /// <returns></returns> + [RequestMethod(RequestMethods.POST)] + public ReturnDto<int?> DeleteModel([FromBody] JArray guidList) + { + string[] intArray = guidList.ToObject<string[]>(); + System.Text.StringBuilder sbGuid = new StringBuilder(); + foreach (string val in intArray) + { + if (sbGuid.Length > 0) sbGuid.Append(", "); + sbGuid.Append(val); + } + var rtnInt = (int)ReturnCode.Default; + var cont = 0; + try + { + cont = isChkOrUnChk(sbGuid.ToString(), 1); + if (cont > 0) + return ReturnDto<int>.QuickReturn(default(int?), + ReturnCode.Exception, "鍒犻櫎澶辫触锛岃淇℃伅宸茶瀹℃牳锛�"); + System.Text.StringBuilder sbSql = new StringBuilder(); + sbSql.Append("delete from MES_PROC_INFO "); + sbSql.Append(" where guid in (select line from dbo.fn_split('" + sbGuid.ToString() + "',','))"); + var rows = DbHelperSQL.ExecuteSql(sbSql.ToString()); + rtnInt = rows; + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), "DeleteModel error锛�" + ex.Message); + rtnInt = (int)ReturnCode.Exception; + return ReturnDto<int>.QuickReturn(default(int?), + ReturnCode.Exception, "鍒犻櫎澶辫触锛�" + ex.Message); + } + if (rtnInt > 0) + return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Success, + "鎿嶄綔鎴愬姛锛屽叡鍒犻櫎" + rtnInt + "鏉℃暟鎹紒"); + return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Exception, + "鍒犻櫎澶辫触锛岃閲嶈瘯锛�"); + } + + /// <summary> + /// 澧炲姞 + /// </summary> + /// <param name="model"></param> + /// <returns></returns> + [RequestMethod(RequestMethods.POST)] + public ReturnDto<string?> EditModel([FromBody] dynamic model) + { + string guid = model.guid; + string processNo = model.processNo; + string processName = model.processName; + string remark = model.remark; + string isBack = model.isBack; + string isStatus = model.isStatus; + string description = model.description; + int? rtnInt = (int)ReturnCode.Default; + System.Text.StringBuilder sbSql = new StringBuilder(); + if (!CheckGuid(guid)) + { + guid= Guid.NewGuid().ToString(); + sbSql.Append("INSERT INTO [dbo].[WORK_PROCESS] ([guid] ,[processNo] ,[processName] ,[remark] ,[isBack] ,[isStatus] ,[description] ,[createBy] ,[createDate] ,[lastUpdateBy] ,[lastUpdateDate])"); + sbSql.Append(" values( '"+ guid + "',@processNo,@processName,@remark,@isBack,@isStatus,@description,'" + _userCode + "',getdate(),'" + _userCode + "',getdate())"); + } + else + { + sbSql.Append("UPDATE [dbo].[WORK_PROCESS] SET [processNo] =@processNo,[processName] =@processName,[remark] =@remark,[isBack] =@isBack,[isStatus] =@isStatus,[description] =@description,[lastUpdateBy] ='" + _userCode + "',[lastUpdateDate] =getdate() where guid='"+guid.ToString()+"'"); + } + SqlParameter[] parameters = + { + new("@processNo", processNo), + new("@processName", processName), + new("@remark", remark), + new("@isBack", isBack), + new("@isStatus", isStatus), + new("@description", description), + }; + try + { + rtnInt = DbHelperSQL.ExecuteSql(sbSql.ToString(), parameters); + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), "EditModel error锛�" + ex.Message); + rtnInt = (int)ReturnCode.Exception; + return ReturnDto<string>.QuickReturn("", ReturnCode.Exception, ex.Message); } - return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default, - "璇诲彇澶辫触锛�"); + if (rtnInt > 0) + return ReturnDto<string>.QuickReturn(guid, ReturnCode.Success, "鎿嶄綔鎴愬姛锛�"); + return ReturnDto<string>.QuickReturn("", ReturnCode.Exception, "澧炲姞澶辫触锛岃閲嶈瘯锛�"); } - catch (Exception ex) + + /// <summary> + /// 璇诲彇 + /// </summary> + /// <param name="guid"></param> + /// <returns></returns> + [RequestMethod(RequestMethods.POST)] + [AllowAnonymous] + public ReturnDto<ExpandoObject> GetModel([FromBody] dynamic model) { - LogHelper.Debug(ToString(), "GetModel error:" + ex.Message); - return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default, - "璇诲彇澶辫触锛�"); + dynamic m = new ExpandoObject(); + var sbSql = new StringBuilder(); + sbSql.Append("select top 1 * from WORK_PROCESS where 1=1 and guid='" + + model.guid.ToString() + "' "); + try + { + var dset = new DataSet(); + dset = DbHelperSQL.Query(sbSql.ToString()); + if (dset != null && dset.Tables.Count > 0 && + dset.Tables[0].Rows.Count > 0) + { + var dr = dset.Tables[0].Rows[0]; + m = dr.RowToDynamic(); + return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Success, + "璇诲彇鎴愬姛锛�"); + } + return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default, + "璇诲彇澶辫触锛�"); + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), "GetModel error:" + ex.Message); + return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default, + "璇诲彇澶辫触锛�"); + } } - } - private int isChkOrUnChk(string guidList, int status) - { - var cont = 0; - //cont = int.Parse(DbHelperSQL - // .GetSingle("select count(1) from mes_Holiday where guid='" + - // guidList + "' and isnull(check_status,0)=" + status + "") - // .ToString()); - return cont; + private int isChkOrUnChk(string guidList, int status) + { + var cont = 0; + //cont = int.Parse(DbHelperSQL + // .GetSingle("select count(1) from mes_Holiday where guid='" + + // guidList + "' and isnull(check_status,0)=" + status + "") + // .ToString()); + return cont; + } + #endregion } - - #endregion -} \ No newline at end of file +} -- Gitblit v1.9.3