From c95807a552fb8814285488b1945a26cfde7ee3fd Mon Sep 17 00:00:00 2001 From: kyy <3283105747@qq.com> Date: 星期五, 26 九月 2025 13:36:02 +0800 Subject: [PATCH] 台账设备报表挪移 --- WebApi/Gs.Report/YS_sbtzb.cs | 352 +++++++++++++++++++++++++++++++++++++++------------------ 1 files changed, 239 insertions(+), 113 deletions(-) diff --git a/WebApi/Gs.Report/YS_sbtzb.cs b/WebApi/Gs.Report/YS_sbtzb.cs index 982710e..9bfc20b 100644 --- a/WebApi/Gs.Report/YS_sbtzb.cs +++ b/WebApi/Gs.Report/YS_sbtzb.cs @@ -1,126 +1,252 @@ -锘縰sing Gs.Toolbox; +锘縰sing System.Data; +using System.Data.SqlClient; +using System.Dynamic; +using System.Text; +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.Data; -using System.Data.SqlClient; -using System.Dynamic; using static Gs.Toolbox.UtilityHelper; +namespace Gs.Report; -namespace Gs.Report +[ApiGroup(ApiGroupNames.Report)] +public class YS_sbtzb : IRomteService { + private readonly IHttpContextAccessor _http; - [ApiGroup(ApiGroupNames.Report)] - public class YS_sbtzb : IRomteService + private readonly string _userCode, _userGuid, _orgFids; + public YS_sbtzb(IHttpContextAccessor httpContextAccessor) { - private readonly IHttpContextAccessor _http; - private readonly string _userCode, _userGuid, _orgFids; - - public YS_sbtzb(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), - new("@inSortOrder", ""), - new("@inQueryWhere", keyWhere), - new("@inFid", ""), - new("@inP1", ""), - new("@inP2", ""), - 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_pc_ysSbtzb_cx", 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.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(); - SqlParameter[] parameters = - { - new("@inMainGuid", guid), - }; - var dset = new DataSet(); - try - { - dset = DbHelperSQL.RunProcedure("[YS_sbtzb_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(); - } - } - 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, "璇诲彇澶辫触锛�"); - } + _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), + new("@inSortOrder", ""), + new("@inQueryWhere", keyWhere), + new("@inFid", ""), + new("@inP1", ""), + new("@inP2", ""), + 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_pc_ysSbtzb_cx", 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.Success, "璇诲彇鎴愬姛"); + } + + /// <summary> + /// 璇诲彇瀛愯〃 + /// </summary> + /// <param name="model"></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>(); + // 鍋囪涓昏〃涓篗ES_JJGZ_JS_SALARY锛屾槑缁嗚〃涓篗ES_JJGZ_JS_SALARY_DETAIL + string mainTable = "YS_sbtzb"; + try + { + string sqlMain = $"SELECT * FROM {mainTable} WHERE guid='{guid}'"; + var dsMain = DbHelperSQL.Query(sqlMain); + if (dsMain != null && dsMain.Tables.Count > 0 && dsMain.Tables[0].Rows.Count > 0) + { + var dr = dsMain.Tables[0].Rows[0]; + m = dr.RowToDynamic(); + } + } + 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 = ""; + try + { + // 鍋囪鎻愪氦灏辨槸鏇存柊鏌愪釜瀛楁 + string sql = $"UPDATE YS_sbtzb SET check_status='{_inFieldValue}',check_date = getdate(), check_user='{_userGuid}' WHERE guid='{_guid}'"; + int rows = DbHelperSQL.ExecuteSql(sql); + m.outSum = rows; + m.outMsg = rows > 0 ? "鎿嶄綔鎴愬姛锛�" : "鏈洿鏂颁换浣曟暟鎹�"; + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), "EditModelSubmit error锛�" + ex.Message); + m.outMsg = ex.Message; + m.outSum = -1; + return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default, ex.Message); + } + 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 sbbm = model.sbbm;//璁惧缂栫爜 + string sbmc = model.sbmc;//璁惧鍚嶇О + string bz = model.bz;//澶囨敞 + string createUser = model.createUser;//鍒涘缓浜� + string createDate = model.createDate;//鍒涘缓鏃堕棿 + string sbgg = model.sbgg;//璁惧瑙勬牸 + string dw = model.dw;//鍗曚綅锛堝彴/鏉★級 + string sl = model.sl;//鏁伴噺 + string zt = model.zt;//鐘舵�� + string sccj = model.sccj;//鐢熶骇鍘傚 + string UpDataTime = model.UpDataTime;//鏇存柊鏃堕棿 + string UpDataUser = model.UpDataUser;//鏇存柊浜� + + dynamic mObj = new ExpandoObject(); + mObj.outMsg = ""; + mObj.outSum = -1; + mObj.outGuid = ""; + mObj.outNo = ""; + try + { + string sql; + if (CheckGuid(guid)) + { + sql = $"declare @userBy nvarchar(20); select top 1 @userBy=[ACCOUNT] from [dbo].[SYS_USER] where guid='{_userGuid}'" + + $"UPDATE YS_sbtzb SET sbbm='{sbbm}', sbmc='{sbmc}', bz='{bz}', sbgg='{sbgg}', dw='{dw}', sl='{sl}'," + + $" zt='{zt}', sccj='{sccj}', UpDataTime=GETDATE(), UpDataUser=@userBy WHERE guid='{guid}'"; + } + else + { + guid = Guid.NewGuid(); + sql = $" declare @userBy nvarchar(20); select top 1 @userBy=[ACCOUNT] from [dbo].[SYS_USER] where guid='{_userGuid}' " + + $"INSERT INTO YS_sbtzb (guid, createUser, createDate, sbbm, sbmc, bz, sbgg, dw, sl ,zt,sccj) " + + $"VALUES ('{guid}',@userBy,GETDATE(), '{sbbm}', '{sbmc}', '{bz}', '{sbgg}', '{dw}', '{sl}', '{zt}', '{sccj}' )"; + } + int rows = DbHelperSQL.ExecuteSql(sql); + mObj.outSum = rows; + mObj.outGuid = guid.ToString(); + mObj.outMsg = rows > 0 ? "鎿嶄綔鎴愬姛锛�" : "鏈洿鏂颁换浣曟暟鎹�"; + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), "EditModel error锛�" + ex.Message); + mObj.outMsg = ex.Message; + mObj.outSum = -1; + } + 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?> DeleteModel([FromBody] dynamic model) + { + int? rtnInt = (int)ReturnCode.Default; + Guid? guid = model.guid; //鍒拌揣鍗曚富閿� + string mxGuid = model.mxGuid; + var _outMsg = ""; + var _outSum = -1; + try + { + if (CheckGuid(guid)) + { + string sql = $"DELETE FROM YS_sbtzb WHERE guid='{guid}'"; + _outSum = DbHelperSQL.ExecuteSql(sql); + _outMsg = _outSum > 0 ? "鍒犻櫎鎴愬姛锛�" : "鏈垹闄や换浣曟暟鎹�"; + } + else + { + _outMsg = "涓婚敭涓嶈兘涓虹┖锛�"; + _outSum = -1; + } + } + catch (Exception ex) + { + LogHelper.Debug(ToString(), "DeleteModel error锛�" + ex.Message); + _outMsg = ex.Message; + _outSum = -1; + } + if (_outSum <= 0) + return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Exception, _outMsg); + return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Success, _outMsg); + } +} \ No newline at end of file -- Gitblit v1.9.3