From f0a773e75016d08684a5c1fdd70d81f68141845d Mon Sep 17 00:00:00 2001 From: wzp <2880584989@qq.com> Date: 星期二, 30 十一月 2021 16:38:22 +0800 Subject: [PATCH] RPT的处理 --- web/Dao/GwRptCodeDao.cs | 173 ++++++++++++++++++++++++++++++++++----------------------- 1 files changed, 104 insertions(+), 69 deletions(-) diff --git a/web/Dao/GwRptCodeDao.cs b/web/Dao/GwRptCodeDao.cs index 43e834e..d89323c 100644 --- a/web/Dao/GwRptCodeDao.cs +++ b/web/Dao/GwRptCodeDao.cs @@ -1,4 +1,4 @@ -锘� +锘� using Common; using Oracle.DataAccess.Client; using System; @@ -7,83 +7,118 @@ namespace Dao { - public class GwRptCodeDao : IDisposable - { - public List<RptCode> LoadRptCodeList() + public class GwRptCodeDao : IDisposable { - List<RptCode> list = new List<RptCode>(); - using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_RPT_CODE ORDER BY CREATE_TIME ASC", OracleHelper.Connection)) - { - while (reader != null && ((DbDataReader) reader).Read()) + public List<RptCode> LoadRptCodeList() { - OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader); - list.Add(new RptCode() - { - NewCode = oracleReaderWrapper.GetString("NEW_CODE", ""), - OldCode = oracleReaderWrapper.GetString("OLD_CODE", ""), - CreateTime = oracleReaderWrapper.GetDateTime("CREATE_TIME"), - Remark = oracleReaderWrapper.GetString("REMARK", "") - }); + List<RptCode> list = new List<RptCode>(); + using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_RPT_CODE ORDER BY CREATE_TIME ASC", OracleHelper.Connection)) + { + while (reader != null && ((DbDataReader)reader).Read()) + { + OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader); + list.Add(new RptCode() + { + NewCode = oracleReaderWrapper.GetString("NEW_CODE", ""), + OldCode = oracleReaderWrapper.GetString("OLD_CODE", ""), + CreateTime = oracleReaderWrapper.GetDateTime("CREATE_TIME"), + Remark = oracleReaderWrapper.GetString("REMARK", "") + }); + } + } + return list; } - } - return list; - } - public void Dispose() - { - } - public RptCode GetRptCode(string oldCode) - { - using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_RPT_CODE WHERE OLD_CODE=:OLD_CODE", OracleHelper.Connection, new OracleParameter(":OLD_CODE", (object) oldCode))) - { - if (reader != null && ((DbDataReader) reader).Read()) + /// <summary> + /// 鑾峰彇璐﹀彿姣斾緥 + /// </summary> + /// <returns></returns> + public List<RptAccount> LoadRptAccountList() { - OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader); - return new RptCode() - { - NewCode = oracleReaderWrapper.GetString("NEW_CODE", ""), - OldCode = oracleReaderWrapper.GetString("OLD_CODE", ""), - CreateTime = oracleReaderWrapper.GetDateTime("CREATE_TIME"), - Remark = oracleReaderWrapper.GetString("REMARK", "") - }; + List<RptAccount> list = new List<RptAccount>(); + using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_RPT_ACCOUNT ORDER BY CREATETIME ASC", OracleHelper.Connection)) + { + while (reader != null && ((DbDataReader)reader).Read()) + { + OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader); + list.Add(new RptAccount() + { + Spid = oracleReaderWrapper.GetString("SPID", ""), + Proportion = oracleReaderWrapper.GetString("Proportion", ""), + CreateTime = oracleReaderWrapper.GetDateTime("CREATETIME") + }); + } + } + return list; } - } - return (RptCode) null; - } - public bool UpdateCode(RptCode code) - { - return OracleHelper.ExecuteSql("UPDATE GW_RPT_CODE SET NEW_CODE =:NEW_CODE,REMARK=:REMARK WHERE OLD_CODE=:OLD_CODE", OracleHelper.Connection, new OracleParameter(":NEW_CODE", (object) code.NewCode), new OracleParameter(":OLD_CODE", (object) code.OldCode), new OracleParameter(":REMARK", (object) code.Remark)) > 0; - } - - public bool DeleteCode(string oldCode) - { - return OracleHelper.ExecuteSql("DELETE FROM GW_RPT_CODE WHERE OLD_CODE = :OLD_CODE", OracleHelper.Connection, new OracleParameter(":OLD_CODE", (object) oldCode)) > 0; - } - - public bool AddCode(RptCode code) - { - return OracleHelper.ExecuteSql("INSERT INTO GW_RPT_CODE(OLD_CODE,NEW_CODE,CREATE_TIME,REMARK) VALUES(:OLD_CODE,:NEW_CODE,SYSDATE,:REMARK)", OracleHelper.Connection, new OracleParameter(":OLD_CODE", (object) code.OldCode), new OracleParameter(":NEW_CODE", (object) code.NewCode), new OracleParameter(":REMARK", (object) code.Remark)) > 0; - } - - public List<ErrCode> LoadErrCodeList() - { - List<ErrCode> list = new List<ErrCode>(); - using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_ERR_CODE ORDER BY TYPE,CODE ASC", OracleHelper.Connection)) - { - while (reader != null && ((DbDataReader) reader).Read()) + public bool AddAccountCode(RptAccount code) { - OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader); - list.Add(new ErrCode() - { - Code = oracleReaderWrapper.GetString("CODE", ""), - Remark = oracleReaderWrapper.GetString("REMARK", ""), - Type = oracleReaderWrapper.GetInt("TYPE", 0) - }); + return OracleHelper.ExecuteSql("INSERT INTO GW_RPT_ACCOUNT(SPID,PROPORTION,CREATETIME) VALUES(:SPID,:PROPORTION,SYSDATE)", OracleHelper.Connection, new OracleParameter(":SPID", (object)code.Spid), new OracleParameter(":PROPORTION", (object)code.Proportion)) > 0; } - } - return list; + + public bool DeleteAccount(string spid) + { + return OracleHelper.ExecuteSql("DELETE FROM GW_RPT_ACCOUNT WHERE SPID = :SPID", OracleHelper.Connection, new OracleParameter(":SPID", (object)spid)) > 0; + } + + + public void Dispose() + { + } + + public RptCode GetRptCode(string oldCode) + { + using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_RPT_CODE WHERE OLD_CODE=:OLD_CODE", OracleHelper.Connection, new OracleParameter(":OLD_CODE", (object)oldCode))) + { + if (reader != null && ((DbDataReader)reader).Read()) + { + OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader); + return new RptCode() + { + NewCode = oracleReaderWrapper.GetString("NEW_CODE", ""), + OldCode = oracleReaderWrapper.GetString("OLD_CODE", ""), + CreateTime = oracleReaderWrapper.GetDateTime("CREATE_TIME"), + Remark = oracleReaderWrapper.GetString("REMARK", "") + }; + } + } + return (RptCode)null; + } + + public bool UpdateCode(RptCode code) + { + return OracleHelper.ExecuteSql("UPDATE GW_RPT_CODE SET NEW_CODE =:NEW_CODE,REMARK=:REMARK WHERE OLD_CODE=:OLD_CODE", OracleHelper.Connection, new OracleParameter(":NEW_CODE", (object)code.NewCode), new OracleParameter(":OLD_CODE", (object)code.OldCode), new OracleParameter(":REMARK", (object)code.Remark)) > 0; + } + + public bool DeleteCode(string oldCode) + { + return OracleHelper.ExecuteSql("DELETE FROM GW_RPT_CODE WHERE OLD_CODE = :OLD_CODE", OracleHelper.Connection, new OracleParameter(":OLD_CODE", (object)oldCode)) > 0; + } + + public bool AddCode(RptCode code) + { + return OracleHelper.ExecuteSql("INSERT INTO GW_RPT_CODE(OLD_CODE,NEW_CODE,CREATE_TIME,REMARK) VALUES(:OLD_CODE,:NEW_CODE,SYSDATE,:REMARK)", OracleHelper.Connection, new OracleParameter(":OLD_CODE", (object)code.OldCode), new OracleParameter(":NEW_CODE", (object)code.NewCode), new OracleParameter(":REMARK", (object)code.Remark)) > 0; + } + + public List<ErrCode> LoadErrCodeList() + { + List<ErrCode> list = new List<ErrCode>(); + using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_ERR_CODE ORDER BY TYPE,CODE ASC", OracleHelper.Connection)) + { + while (reader != null && ((DbDataReader)reader).Read()) + { + OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader); + list.Add(new ErrCode() + { + Code = oracleReaderWrapper.GetString("CODE", ""), + Remark = oracleReaderWrapper.GetString("REMARK", ""), + Type = oracleReaderWrapper.GetInt("TYPE", 0) + }); + } + } + return list; + } } - } } -- Gitblit v1.9.1