RPT的处理

wzp

2021-11-30 f0a773e75016d08684a5c1fdd70d81f68141845d

 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;
        }
    }
  }
}