待审核增加通道筛选

wangsheng

2022-03-07 89b8562ad1fb3943db3ffb922544afb3ce57e457

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
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Common;
using Model;
using Oracle.DataAccess.Client;
using System.Data;
using System.Data.Common;
 
namespace Dao
{
    /// <summary>
    /// 携号转网
    /// </summary>
    public class GwTransferDao:IDisposable
    {
        #region IDisposable 成员
 
        public void Dispose()
        {
        }
 
        #endregion
 
        /// <summary>
        /// 加载
        /// </summary>
        /// <param name="phone"></param>
        /// <param name="recordcount"></param>
        /// <param name="PageIndex"></param>
        /// <param name="pageSize"></param>
        /// <returns></returns>
        public List<GwTransfer> LoadInfoList(string phone, out int recordcount, int PageIndex, int pageSize)
        {
            List<GwTransfer> list = new List<GwTransfer>();
            recordcount = 0;
            try
            {
                StringBuilder stringBuilder = new StringBuilder();
                stringBuilder.Append("from Gw_Transfer b where 1=1");
                OracleParameter[] oracleParameterArray = new OracleParameter[1];
                if (phone != null && phone != "")
                {
                    oracleParameterArray[0] = new OracleParameter(":PHONE", (OracleDbType)126);
                    ((DbParameter)oracleParameterArray[0]).Value = (object)phone;
                    stringBuilder.Append(" and mobile like '%'||:PHONE||'%'");
                }
                stringBuilder.Append(" order by Id DESC");
                using (OracleDataReader reader = OracleHelper.ExecuteReader("select count(*) as count " + stringBuilder.ToString(), OracleHelper.Connection, oracleParameterArray))
                {
                    while (((DbDataReader)reader).Read())
                    {
                        OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
                        recordcount = oracleReaderWrapper.GetInt("count", 0);
                    }
                }
                using (OracleDataReader reader = OracleHelper.ExecuteReader(PubConstant.doOracleSql(PageIndex, pageSize, recordcount, "select * " + stringBuilder.ToString()).ToString(), OracleHelper.Connection, oracleParameterArray))
                {
                    while (((DbDataReader)reader).Read())
                    {
                        GwTransfer o = new GwTransfer();
                        if (this.ReadInfo(reader, o))
                            list.Add(o);
                    }
                }
 
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return list;
            }
            return list;
        }
 
 
        public bool Delete(int pid)
        {
            if (pid == 0)
                return false;
 
            DateTime dateTime = Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
            StringBuilder stringBuilder = new StringBuilder();
            stringBuilder.Append("begin ");
            stringBuilder.Append("delete from Gw_Transfer where Id=:ID; ");
            stringBuilder.Append("INSERT INTO GW_EVENT_LOG(EVENT_ID,ASSIGNED_TO,EVENT_TYPE,CONTENT,EVENT_TIME,HANDLE_FLAG)VALUES(GW_EVENT_LOG_SEQ.NEXTVAL,'SMEXC','TRANSFER','',:DateTime,0); ");
            stringBuilder.Append("end; ");
            OracleParameter[] oracleParameterArray = new OracleParameter[2]
            {
        new OracleParameter(":ID", (object) pid),
        new OracleParameter(":DateTime",(object)dateTime)
            };
            return OracleHelper.ExecuteSql(stringBuilder.ToString(), OracleHelper.Connection, oracleParameterArray) > 0;
 
            //return OracleHelper.ExecuteSql("delete from Gw_Transfer where Id=:ID", OracleHelper.Connection, new OracleParameter(":ID", (object)pid)) > 0;
        }
 
        public bool Add(GwTransfer o)
        {
            DateTime dateTime = Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
            StringBuilder stringBuilder = new StringBuilder();
            stringBuilder.Append("begin ");
            stringBuilder.Append("insert into Gw_Transfer(ID,MOBILE,Operator) values(GW_TRANSFER_ID_SEQ.NEXTVAL,:MOBILE,:Operator); ");
            stringBuilder.Append("INSERT INTO GW_EVENT_LOG(EVENT_ID,ASSIGNED_TO,EVENT_TYPE,CONTENT,EVENT_TIME,HANDLE_FLAG)VALUES(GW_EVENT_LOG_SEQ.NEXTVAL,'SMEXC','TRANSFER','',:DateTime,0); ");
            stringBuilder.Append("end; ");
            OracleParameter[] oracleParameterArray = new OracleParameter[3]
            {
        new OracleParameter(":MOBILE", (object) o.Mobile),
        new OracleParameter(":Operator", (object) o.Operator),
        new OracleParameter(":DateTime",(object)dateTime)
            };
            return OracleHelper.ExecuteSql(stringBuilder.ToString(), OracleHelper.Connection, oracleParameterArray) > 0;
 
            //return OracleHelper.ExecuteSql("insert into Gw_Transfer(ID,MOBILE,Operator) values(GW_TRANSFER_ID_SEQ.NEXTVAL,:MOBILE,:Operator)", OracleHelper.Connection, new OracleParameter(":MOBILE", (object)o.Mobile), new OracleParameter(":Operator", (object)o.Operator)) > 0;
        }
 
 
        private bool ReadInfo(OracleDataReader reader, GwTransfer o)
        {
            OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
            o.Id = oracleReaderWrapper.GetInt("ID", 0);
            o.Mobile = oracleReaderWrapper.GetString("MOBILE", "");
            o.Operator = oracleReaderWrapper.GetString("OPERATOR", "");
            return true;
        }
 
        
        /// <summary>
        /// 判断号码是否存在
        /// </summary>
        /// <param name="pMobile"></param>
        /// <returns></returns>
        public bool IsExitsMobile(string pMobile)
        {
            using (OracleDataReader oracleDataReader = OracleHelper.ExecuteReader(string.Format("select * from Gw_Transfer where mobile=:MOBILE"), OracleHelper.Connection, new OracleParameter(":MOBILE", (object)pMobile)))
            {
                if (((DbDataReader)oracleDataReader).Read())
                    return true;
            }
            return false;
        }
 
    }
}