RPT最新版本的保存更新

wzp

2022-07-12 93dbdc305bd736f5745d217e33e2ba79cc7782fe

 web/Dao/GwRptCodeDao.cs

@@ -1,4 +1,4 @@
 

using Common;
using Oracle.DataAccess.Client;
using System;
@@ -7,83 +7,123 @@

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"),
                        TimeSpan = oracleReaderWrapper.GetString("TimeSpan","10"),
                        Threshold = oracleReaderWrapper.GetString("Threshold", "10000"),
                        WhitePhone = oracleReaderWrapper.GetString("WhitePhone", ""),
                    });
                }
            }
            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,TimeSpan,Threshold,WhitePhone) VALUES(:SPID,:PROPORTION,SYSDATE,:TimeSpan,:Threshold,:WhitePhone)",
                OracleHelper.Connection, new OracleParameter(":SPID", (object)code.Spid), new OracleParameter(":PROPORTION", (object)code.Proportion),
                new OracleParameter(":TimeSpan", (object)code.TimeSpan), new OracleParameter(":Threshold", (object)code.Threshold),new OracleParameter(":WhitePhone", (object)code.WhitePhone)) > 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;
        }
    }
  }
}