refator code

ulysseskao

2016-05-03 410dc2d04dbecf019129cd8cd65a3be2c62b4d0c

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
using System; 
 
using System.Data.OracleClient; 
using NLog; 
 
namespace CCSTrace.CCS.Object 
{ 
    public class LocateEquipment 
    { 
        private static readonly Logger Logger = LogManager.GetCurrentClassLogger(); 
 
        private int _caseId = 0; 
        private int _dsUfid = -1; 
        private int _fsc = 0; 
        private int _ufid = 0; 
        private string _fdr = ""; 
        private string _tpclid = ""; 
 
        public LocateEquipment(int mCaseId, bool hasData, OracleConnection conn, OracleTransaction transaction) 
        { 
            OracleCommand command = null; 
            OracleDataReader reader = null; 
 
            CaseId = mCaseId; 
 
            try 
            { 
                string sqlStmt; 
                if (hasData) 
                { 
                    sqlStmt = "SELECT DSUFID,FSC,UFID,FDR,TPCLID FROM EOS.EVENTRECORD_EX WHERE CASEID = " + mCaseId; 
 
                    command = new OracleCommand(sqlStmt, conn, transaction); 
                    reader = command.ExecuteReader(); 
 
                    if (reader.Read()) 
                    { 
                        DsUfid =Convert.ToInt32(reader["DSUFID"].ToString()); 
                        Fsc = Convert.ToInt32(reader["FSC"].ToString()); 
                        Ufid = Convert.ToInt32(reader["UFID"].ToString()); 
                        Fdr = reader["FDR"].ToString(); 
                        Tpclid = reader["TPCLID"].ToString(); 
                    } 
                } 
                else 
                { 
                    sqlStmt = "SELECT UFID FROM EOS.DISASTER_EX WHERE ISDISASTER = " + GlobalVariable.IsDisaster; 
 
                    command = new OracleCommand(sqlStmt, conn, transaction); 
                    reader = command.ExecuteReader(); 
 
                    if (reader.Read()) 
                        DsUfid = Convert.ToInt32(reader["UFID"].ToString()); 
                } 
            } 
            catch (Exception e) 
            { 
                Logger.Warn(e, e.Message); 
            } 
            finally 
            { 
                reader?.Close(); 
                command?.Dispose(); 
            } 
        } 
 
        public int CaseId 
        { 
            get { return _caseId; } 
            set { _caseId = value; } 
        } 
 
        public int DsUfid 
        { 
            get { return _dsUfid; } 
            set { _dsUfid = value; } 
        } 
 
        public int Fsc 
        { 
            get { return _fsc; } 
            set { _fsc = value; } 
        } 
 
        public int Ufid 
        { 
            get { return _ufid; } 
            set { _ufid = value; } 
        } 
 
        public string Fdr 
        { 
            get { return _fdr; } 
            set { _fdr = value; } 
        } 
 
        public string Tpclid 
        { 
            get { return _tpclid; } 
            set { _tpclid = value; } 
        } 
 
        public string GetInsertSqlStmt() 
        { 
            var sqlStmt = "INSERT INTO EOS.EVENTRECORD_EX (CASEID,DSUFID,FSC,UFID,TPCLID,FDR) VALUES(" + CaseId + "," + DsUfid + "," + Fsc 
                             + "," + Ufid + ",'" + Tpclid + "','" + Fdr + "')"; 
            return sqlStmt; 
        } 
 
        //public String getUpdateSqlStmt() 
        //{ 
        //    String SqlStmt; 
 
        //    SqlStmt = "UPDATE EOS.EVENTRECORD_EX SET DSUFID = " + getDSUFID() + ",FSC = " + getFSC() + ",UFID = " + getUFID() + ",TPCLID = '" 
        //            + getTPCLID() + "',FDR = '" + getFDR() + "' WHERE CASEID = " + getCaseID(); 
 
        //    return SqlStmt; 
        //} 
    } 
}