| | |
| | | _traceConnectionString = traceConnection;
|
| | | }
|
| | |
|
| | | public int LeachCase(Object.EventRecord mNewRec)
|
| | | public int LeachCase(Object.EOSEventRecord mNewRec)
|
| | | {
|
| | | switch (SameCase(mNewRec))
|
| | | {
|
| | |
| | | return _mergeCase.GetOldEquipment();
|
| | | }
|
| | |
|
| | | private int SameCase(Object.EventRecord mNewRec)
|
| | | private int SameCase(Object.EOSEventRecord mNewRec)
|
| | | {
|
| | | string sqlStmt = "SELECT R.ACCEPTNUM,R.CASEID as CASEID,R.IMPORTCASE as IMPORTCASE,E.CASETYPE as CASETYPE FROM EOS.EVENTRECORD R,"
|
| | | + "EOS.EVENTS E WHERE ";
|
| | |
| | | }
|
| | | catch (Exception e)
|
| | | {
|
| | | Logger.Error(e.Message);
|
| | | Logger.Error(e, e.Message);
|
| | | return GlobalVariable.FailureByDb;
|
| | | }
|
| | | finally
|
| | |
| | | return status;
|
| | | }
|
| | |
|
| | | private int Judge(Object.EventRecord mNewRec, bool changeCaseType)
|
| | | private int Judge(Object.EOSEventRecord mNewRec, bool changeCaseType)
|
| | | {
|
| | | int mResult = GlobalVariable.FailureByDb;
|
| | |
|
| | |
| | | {
|
| | | if (mNewRec.Fsc!= 0)
|
| | | {
|
| | | mNewRec.LocateEquipment.SetFsc(GlobalVariable.Breaker);
|
| | | mNewRec.LocateEquipment.SetUfid(mNewRec.Ufid);
|
| | | mNewRec.LocateEquipment.Fsc = (GlobalVariable.Breaker);
|
| | | mNewRec.LocateEquipment.Ufid = (mNewRec.Ufid);
|
| | | Logger.Info("饋線全停:" + mNewRec.Fsc+ ", " + mNewRec.Ufid);
|
| | | _mergeCase.Merge(mNewRec, _connectionTpc, _transaction, _traceConnectionString);
|
| | | return GlobalVariable.Success;
|
| | |
| | | return mResult;
|
| | | }
|
| | |
|
| | | private int GetEquipment(Object.EventRecord mNewRec)
|
| | | private int GetEquipment(Object.EOSEventRecord mNewRec)
|
| | | {
|
| | | string temp;
|
| | | string mOwnerTpclid;
|
| | |
| | | }
|
| | | catch (Exception e)
|
| | | {
|
| | | Logger.Error(e.Message);
|
| | | Console.WriteLine(e.StackTrace);
|
| | | Logger.Error(e, e.Message);
|
| | | return GlobalVariable.FailureByDb;
|
| | | }
|
| | | finally
|
| | |
| | | }
|
| | | }
|
| | |
|
| | | private int GetSxfmr(string mTpclid, string mGroup, Object.EventRecord mNewRec)
|
| | | private int GetSxfmr(string mTpclid, string mGroup, Object.EOSEventRecord mNewRec)
|
| | | {
|
| | | string sqlStmt;
|
| | | int mStatus = GlobalVariable.FailureByDb;
|
| | |
| | | return mStatus;
|
| | | }
|
| | |
|
| | | private int GetHicustomer(string mTpclid, string mGroup, Object.EventRecord mNewRec)
|
| | | private int GetHicustomer(string mTpclid, string mGroup, Object.EOSEventRecord mNewRec)
|
| | | {
|
| | | string sqlStmt;
|
| | |
|
| | |
| | | }
|
| | | }
|
| | |
|
| | | private void GetLocateEquipment(Object.EventRecord mNewRec)
|
| | | private void GetLocateEquipment(Object.EOSEventRecord mNewRec)
|
| | | {
|
| | | var sqlStmt = "SELECT OWNERFSC as FSC,OWNERUFID as UFID,OWNERTPCLID as TPCLID FROM ";
|
| | | switch (mNewRec.Fsc)
|
| | |
| | | {
|
| | | if (reader.Read())
|
| | | {
|
| | | mNewRec.LocateEquipment.SetFsc(Convert.ToInt32(reader["FSC"].ToString()));
|
| | | mNewRec.LocateEquipment.SetUfid(Convert.ToInt32(reader["UFID"].ToString()));
|
| | | mNewRec.LocateEquipment.SetTpclid(reader["TPCLID"].ToString());
|
| | | mNewRec.LocateEquipment.Fsc = (Convert.ToInt32(reader["FSC"].ToString()));
|
| | | mNewRec.LocateEquipment.Ufid = (Convert.ToInt32(reader["UFID"].ToString()));
|
| | | mNewRec.LocateEquipment.Tpclid = (reader["TPCLID"].ToString());
|
| | | }
|
| | | }
|
| | | catch (Exception e)
|