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_sb_djjl.cs | 352 +++++++++++++++++++++++++++++++++++++++------------------- 1 files changed, 238 insertions(+), 114 deletions(-) diff --git a/WebApi/Gs.Report/YS_sb_djjl.cs b/WebApi/Gs.Report/YS_sb_djjl.cs index ecbc144..f5fcef5 100644 --- a/WebApi/Gs.Report/YS_sb_djjl.cs +++ b/WebApi/Gs.Report/YS_sb_djjl.cs @@ -1,126 +1,250 @@ -锘縰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; +/// <summary> +/// 璁惧鐐规璁板綍琛� +/// </summary> +[ApiGroup(ApiGroupNames.Report)] +public class YS_sb_djjl : IRomteService { + private readonly IHttpContextAccessor _http; - [ApiGroup(ApiGroupNames.Report)] - public class YS_sb_djjl : IRomteService + private readonly string _userCode, _userGuid, _orgFids; + public YS_sb_djjl(IHttpContextAccessor httpContextAccessor) { - private readonly IHttpContextAccessor _http; - private readonly string _userCode, _userGuid, _orgFids; - - public YS_sb_djjl(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_ysSbDjjl_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_sb_djjl_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_ysSbDjjl_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_sb_djjl"; + 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_sb_djjl 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 sbmc = model.sbmc;//璁惧鍚嶇О + string djr = model.djr;//鐐规浜� + string djsj = model.djsj;//鐐规鏃堕棿 + string bz = model.bz;//澶囨敞 + string sbbm = model.sbbm;//璁惧缂栫爜 + string djrq = model.djrq;//鐐规鏃ユ湡(澶氫綑) + 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_sb_djjl SET sbmc='{sbmc}', djr='{djr}', djsj='{djsj}',sbbm='{sbbm}',bz='{bz}',djrq='{djrq}'," + + $" 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_sb_djjl (guid, djr, djsj, sbmc, sbbm,bz,djrq) " + + $"VALUES ('{guid}','{djr}','{djsj}', '{sbmc}', '{sbbm}', '{bz}','{djrq}')"; + } + 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_sb_djjl 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