RPT的调整

wzp

2022-03-01 eb62f992f048d3721485d6d3c1e02a4a9a0b0ce6

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
 
using Common;
using Oracle.DataAccess.Client;
using System;
using System.Collections.Generic;
using System.Data.Common;
 
namespace Dao
{
    public class GwRptCodeDao : IDisposable
    {
        public List<RptCode> LoadRptCodeList()
        {
            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;
        }
 
 
        /// <summary>
        /// 获取账号比例
        /// </summary>
        /// <returns></returns>
        public List<RptAccount> LoadRptAccountList()
        {
            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;
        }
 
        public bool AddAccountCode(RptAccount code)
        {
            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;
        }
 
        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;
        }
    }
}