using System;
|
using System.Data;
|
using System.Configuration;
|
using System.Web;
|
using System.Web.Security;
|
using System.Web.UI;
|
using System.Web.UI.HtmlControls;
|
using System.Web.UI.WebControls;
|
using System.Web.UI.WebControls.WebParts;
|
using System.Collections;
|
using TRACEROBJECTLib;
|
using System.Data.OracleClient;
|
|
namespace CCSTrace.CCS.EventAI
|
{
|
public class TraceSubject
|
{
|
static String DEFAULTDBSTR;
|
static bool IsNewCase;
|
static ArrayList m_LinkList; // store the switch of the new case path
|
static TraceEngine m_tEngine;
|
static Hashtable m_TreeMap; // store the switch of the old case path
|
static int s_Fsc;
|
static int s_Ufid;
|
private RecordLog _Plogger;
|
private ArrayList m_Tmp = new ArrayList();
|
private NetworkContext m_pContext;
|
|
private OracleConnection _ConnectionTPC = null;
|
private OracleTransaction _Transaction;
|
|
public TraceSubject(OracleConnection _Conn, OracleTransaction _Trx, RecordLog _Log)
|
{
|
_ConnectionTPC = _Conn;
|
_Transaction = _Trx;
|
_Plogger = _Log;
|
|
try
|
{
|
if (m_tEngine == null) {
|
m_tEngine = new TraceEngine();
|
}
|
}
|
catch (Exception ex) {
|
_Plogger.Error(ex.Message);
|
throw ex;
|
}
|
}
|
|
public void discardEngine() {
|
if (m_tEngine != null) {
|
m_tEngine = null;
|
}
|
}
|
|
public ArrayList getNewResult() {
|
return m_LinkList;
|
}
|
|
public Hashtable getOldResult() {
|
return m_TreeMap;
|
}
|
|
// for EOS(only get the reverse tree)
|
public void startTrace(int Start_Fsc, int Start_Ufid, bool m_IsNew) {
|
s_Fsc = Start_Fsc;
|
s_Ufid = Start_Ufid;
|
IsNewCase = m_IsNew;
|
m_TreeMap = new Hashtable();
|
m_LinkList = new ArrayList();
|
|
try
|
{
|
this.setReverseTree(Trace(true));
|
}
|
catch (Exception e) {
|
_Plogger.Error(e.Message);
|
Console.WriteLine(e.StackTrace);
|
throw e;
|
}
|
}
|
|
private bool getSwitchOn(int UFID) {
|
String SqlStmt;
|
|
SqlStmt = "SELECT M.OSTATUS as OSTATUS FROM (SELECT UFID,OSTATUS FROM BASEDB.CONNECTIVITY WHERE FSC = 114) M,"
|
+ "BASEDB.SWITCH S WHERE M.UFID = S.UFID AND S.NSTATUS <> 0 AND M.UFID = " + UFID;
|
|
OracleCommand Command = null;
|
OracleDataReader reader = null;
|
|
try
|
{
|
Command = new OracleCommand(SqlStmt, _ConnectionTPC, _Transaction);
|
reader = Command.ExecuteReader();
|
|
if (reader.Read())
|
{
|
if (Convert.ToInt32(reader["OSTATUS"]) == 1)
|
return true;
|
}
|
reader.Close();
|
}
|
catch (Exception e)
|
{
|
_Plogger.Error(e.Message);
|
Console.WriteLine(e.StackTrace);
|
}
|
finally
|
{
|
if (Command != null)
|
Command.Dispose();
|
|
if (reader != null)
|
reader.Close();
|
}
|
return false;
|
}
|
|
private bool getJumperOn(int UFID) {
|
String SqlStmt;
|
|
SqlStmt = "SELECT OSTATUS FROM BASEDB.CONNECTIVITY WHERE FSC = 109 AND UFID = " + UFID;
|
|
OracleCommand Command = null;
|
OracleDataReader reader = null;
|
|
try
|
{
|
Command = new OracleCommand(SqlStmt, _ConnectionTPC, _Transaction);
|
reader = Command.ExecuteReader();
|
|
if (reader.Read())
|
{
|
if (Convert.ToInt32(reader["OSTATUS"]) == 1)
|
return true;
|
}
|
reader.Close();
|
}
|
catch (Exception e)
|
{
|
_Plogger.Error(e.Message);
|
Console.WriteLine(e.StackTrace);
|
}
|
finally
|
{
|
if (Command != null)
|
Command.Dispose();
|
|
if (reader != null)
|
reader.Close();
|
}
|
return false;
|
}
|
|
private Hashtable TraceCounts = new Hashtable();
|
|
private void setReverseTree(ResultTree tree) {
|
int i = 0;
|
TreeIterator iti = null;
|
bool ostatus = true;
|
|
if (tree != null) {
|
i = 0;
|
iti = tree.CreateTreeIterator();
|
bool isNotEnd = true;
|
|
while (isNotEnd) {
|
|
if (getTraceCount(iti.Value.ClassID, iti.Value.ObjectID) > 5)
|
throw new TraceLoopException("追蹤產生迴圈狀況。(Fsc,Ufid) = (" + iti.Value.ClassID + "," + iti.Value.ObjectID + ")");
|
else
|
AddTraceCount(iti.Value.ClassID, iti.Value.ObjectID);
|
|
while (iti.IsLeaf == 0)
|
{
|
TRACEROBJECTLib.TreeNode node = iti.Value;
|
|
if ((node.ClassID == 114) || (node.ClassID == 108) || (node.ClassID == 109))
|
{
|
Equipment Equip = new Equipment(node.ClassID, node.ObjectID);
|
|
if (IsNewCase)
|
m_LinkList.Add(Equip);
|
else {
|
m_TreeMap.Add(node.ObjectID, Equip);
|
m_Tmp.Add(Equip);
|
}
|
i++;
|
|
/* if (getTraceCount(node.ClassID, node.ObjectID) > 2)
|
throw new Exception("追蹤產生迴圈狀況。(Fsc,Ufid) = (" + node.ClassID + "," + node.ObjectID + ")");
|
else
|
AddTraceCount(node.ClassID, node.ObjectID);
|
*/ }
|
|
Console.WriteLine(node.ClassID + "----->" + node.ObjectID);
|
_Plogger.Info(node.ClassID + "----->" + node.ObjectID);
|
|
iti.MoveDescent((short) 0);
|
}
|
|
// 當從breaker出來的導線不只一條時,breaker可能會不被add(因為breaker是leaf但其parent的DescentCount > 1,所以被忽略)
|
/*
|
* if ( ((com.origo.TraceModel.ITreeNode)iti.get_Value()).get_ClassID() == EOS.LocalVariable.Breaker ) {
|
* com.origo.TraceModel.ITreeNode node = iti.get_Value(); Equipment Equip = new Equipment(node.get_ClassID(),node.get_ObjectID()); if (
|
* IsNewCase ) m_LinkList.add(i,Equip); else { m_TreeMap.put(new Integer(node.get_ObjectID()),Equip); m_Tmp.add(Equip); }
|
* System.out.println(node.get_ClassID() + "----->" + node.get_ObjectID()); System.out.println("Trace Finish...."); i++; break; }
|
*/
|
|
if ((iti.Value).ClassID == CCS.LocalVariable.Breaker) {
|
TRACEROBJECTLib.TreeNode node = iti.Value;
|
Equipment Equip = new Equipment(node.ClassID, node.ObjectID);
|
|
if (IsNewCase)
|
m_LinkList.Add(Equip);
|
else
|
{
|
m_TreeMap.Add(node.ObjectID, Equip);
|
m_Tmp.Add(Equip);
|
}
|
i++; //後面直接就FINISH，所以就不用判斷tracecount
|
|
Console.WriteLine(node.ClassID + "----->" + node.ObjectID);
|
_Plogger.Info(node.ClassID + "----->" + node.ObjectID);
|
Console.WriteLine("Trace Finish....");
|
_Plogger.Info("Trace Finish....");
|
break;
|
}
|
// 當追蹤到被切開的開關且該上一層設備只有該開關一個child)
|
else if (iti.Value.ClassID == CCS.LocalVariable.Switch || iti.Value.ClassID == CCS.LocalVariable.Jumper ) {
|
TRACEROBJECTLib.TreeNode node = iti.Value;
|
iti.MoveAscent();
|
|
Equipment Equip = new Equipment(node.ClassID, node.ObjectID);
|
|
if (isEndEquip(Equip))
|
{
|
if (IsNewCase)
|
m_LinkList.Add(Equip);
|
else
|
{
|
m_TreeMap.Add(node.ObjectID, Equip);
|
m_Tmp.Add(Equip);
|
}
|
i++; //後面直接就FINISH，所以就不用判斷tracecount
|
|
Console.WriteLine(node.ClassID + "----->" + node.ObjectID);
|
_Plogger.Info(node.ClassID + "----->" + node.ObjectID);
|
Console.WriteLine("Trace Finish....");
|
_Plogger.Info("Trace Finish....");
|
break;
|
}
|
|
//switch (node.ClassID)
|
//{
|
// case 114:
|
// ostatus = getSwitchOn(node.ObjectID);
|
// break;
|
// case 109:
|
// ostatus = getJumperOn(node.ObjectID);
|
// break;
|
//}
|
|
//if (!ostatus && (iti.DescentCount == 1)) {
|
// Equipment Equip = new Equipment(node.ClassID, node.ObjectID);
|
|
// if (IsNewCase)
|
// m_LinkList.Add(Equip);
|
// else {
|
// m_TreeMap.Add(node.ObjectID, Equip);
|
// m_Tmp.Add(Equip);
|
// }
|
// i++;
|
|
// Console.WriteLine(node.ClassID + "----->" + node.ObjectID);
|
// _Plogger.Info(node.ClassID + "----->" + node.ObjectID);
|
// Console.WriteLine("Trace Finish....");
|
// _Plogger.Info("Trace Finish....");
|
// break;
|
//}
|
}
|
else
|
{
|
TRACEROBJECTLib.TreeNode node = iti.Value;
|
iti.MoveAscent();
|
|
if (iti.DescentCount == 1)
|
throw new Exception("追蹤到非開關類斷開之設備(Fsc = " + node.ClassID + ",Ufid = " + node.ObjectID);
|
}
|
|
for (int j = 1; j < iti.DescentCount; j++) {
|
iti.MoveDescent((short) j);
|
|
if (iti.IsLeaf == 1) {
|
TRACEROBJECTLib.TreeNode node = iti.Value;
|
Equipment Equip = new Equipment(node.ClassID, node.ObjectID);
|
|
switch (node.ClassID) {
|
case 108:
|
if (IsNewCase)
|
m_LinkList.Add(Equip);
|
else
|
{
|
m_TreeMap.Add(node.ObjectID, Equip);
|
m_Tmp.Add(Equip);
|
}
|
|
Console.WriteLine(node.ClassID + "----->" + node.ObjectID);
|
_Plogger.Info(node.ClassID + "----->" + node.ObjectID);
|
i++;
|
|
/* if (getTraceCount(node.ClassID, node.ObjectID) > 2)
|
throw new Exception("追蹤產生迴圈狀況。(Fsc,Ufid) = (" + node.ClassID + "," + node.ObjectID + ")");
|
else
|
AddTraceCount(node.ClassID, node.ObjectID);
|
*/
|
break;
|
case 109:
|
case 114:
|
switch (node.ClassID)
|
{
|
case 114:
|
ostatus = getSwitchOn(node.ObjectID);
|
break;
|
case 109:
|
ostatus = getJumperOn(node.ObjectID);
|
break;
|
}
|
|
// Only for switch because the breaker only has one node to descent
|
if (!ostatus) {
|
if (IsNewCase)
|
m_LinkList.Add(Equip);
|
else {
|
m_TreeMap.Add(node.ObjectID, Equip);
|
m_Tmp.Add(Equip);
|
}
|
|
Console.WriteLine(node.ClassID + "----->" + node.ObjectID);
|
_Plogger.Info(node.ClassID + "----->" + node.ObjectID);
|
i++;
|
|
/* if (getTraceCount(node.ClassID, node.ObjectID) > 2)
|
throw new Exception("追蹤產生迴圈狀況。(Fsc,Ufid) = (" + node.ClassID + "," + node.ObjectID + ")");
|
else
|
AddTraceCount(node.ClassID, node.ObjectID);
|
*/
|
}
|
break;
|
default:
|
break;
|
} // switch
|
|
iti.MoveAscent();
|
isNotEnd = false;
|
} else {
|
isNotEnd = true;
|
break;
|
}
|
} // for
|
} // while
|
Console.WriteLine("Tree Node Count = " + i);
|
_Plogger.Info("Tree Node Count = " + i);
|
} else
|
{
|
Console.WriteLine("Tree is null");
|
_Plogger.Info("Tree is null");
|
throw new Exception("無法追蹤到任何設備，可能是該用戶所在變壓器設備連結性有問題。");
|
}
|
|
}
|
|
private ResultTree Trace(bool Reverse) {
|
ResultTree tree = null;
|
|
try {
|
configTrace();
|
_Plogger.Info("configTrace OK.");
|
}
|
catch (Exception e)
|
{
|
_Plogger.Error(e.Message);
|
Console.WriteLine(e.StackTrace);
|
return tree;
|
}
|
|
try {
|
tree = ModeTrace(Reverse);
|
}
|
catch (Exception e) {
|
_Plogger.Error(e.Message);
|
Console.WriteLine(e.StackTrace);
|
}
|
|
return tree;
|
}
|
|
void configTrace() {
|
if (DEFAULTDBSTR == null) {
|
DEFAULTDBSTR = "basedb/basedb000@nntpc";
|
}
|
try {
|
if (m_pContext == null) m_pContext = m_tEngine.teoCreateContext();
|
|
if (m_pContext.IsConnected == 0) {
|
m_pContext.Connect("", DEFAULTDBSTR);
|
}
|
}
|
catch (Exception ex) {
|
_Plogger.Error(ex.Message);
|
}
|
}
|
|
private ResultTree ModeTrace(bool Reverse) {
|
TravelContext tContext = new TravelContext();
|
TravelStartCriterion sCriterion = new TravelStartCriterion();
|
TravelTerminateCriterion eCriterion = new TravelTerminateCriterion();
|
|
sCriterion.ClsID = (short) s_Fsc;
|
sCriterion.ObjID = s_Ufid;
|
|
if (Reverse) // 反向上追
|
{
|
sCriterion.StartMode = (TRAVELSTARTCRITERIONTYPE)(Convert.ToInt32(TRAVELSTARTCRITERIONTYPE.TRAVELBYNEGDIR) + Convert.ToInt32(TRAVELSTARTCRITERIONTYPE.TRAVELWITHFOLLOW));
|
|
eCriterion.ClsID = (short)CCS.LocalVariable.Breaker;
|
eCriterion.EndMode = TRAVELTERMCRITERIONTYPE.TRAVELTOTHISCLASS;
|
} else // 順向追蹤
|
{
|
sCriterion.StartMode = TRAVELSTARTCRITERIONTYPE.TRAVELBYCURDIR;
|
|
eCriterion.EndMode = TRAVELTERMCRITERIONTYPE.TRAVELTOTHISCLASS;
|
}
|
|
tContext.addCriterion(sCriterion);
|
tContext.addCriterion(eCriterion);
|
|
m_pContext.ResetContext();
|
|
_Plogger.Info("Set ModeTrace OK.");
|
ResultTreeBuilder trBuilder = m_pContext.CreateTreeBuilder();
|
if (!trBuilder.constructResultTree(tContext, TRAVELTHREADMODE.CONMODE_SYNCHRONOUS)) { return null; }
|
_Plogger.Info("ConstructResultTree OK.");
|
ResultTree result = trBuilder.ResultTree;
|
|
_Plogger.Info("getResultTree OK.");
|
return result;
|
}
|
|
//判斷是否為最終設備(逆向追到已經無child的設備時，檢查該設備是否為最終設備(查驗該設備的同層設備，是否仍有可繼續逆向追蹤的設備，若無，則該設備為最終設備
|
private bool isEndEquip(Equipment SelfEquip)
|
{
|
String SqlStmt;
|
OracleCommand Command = null;
|
OracleDataReader reader = null;
|
long N_Value = 0;
|
|
SqlStmt = "SELECT DIR,OSTATUS,N1,N2 FROM BASEDB.CONNECTIVITY WHERE FSC = " + SelfEquip.getFSC() + " AND UFID = " + SelfEquip.getUFID();
|
|
try
|
{
|
Command = new OracleCommand(SqlStmt, _ConnectionTPC, _Transaction);
|
reader = Command.ExecuteReader();
|
|
if (reader.Read())
|
{
|
if (Convert.ToInt32(reader["OSTATUS"]) == 1) //如果設備本身為非切開的設備，那應該繼續往逆向追
|
return false;
|
else
|
{
|
if (Convert.ToInt32(reader["DIR"]) == 3) //順向無電 N1-->N2，所以逆向的上游N值抓N2
|
N_Value = Convert.ToInt32(reader["N2"]);
|
else
|
N_Value = Convert.ToInt32(reader["N1"]);
|
}
|
}
|
reader.Close();
|
|
SqlStmt = "SELECT FSC,UFID,DIR,OSTATUS,N1,N2 FROM BASEDB.CONNECTIVITY WHERE N1 <> N2 AND ( N1 = " + N_Value + " OR N2 = " + N_Value + ")";
|
Command.CommandText = SqlStmt;
|
|
reader = Command.ExecuteReader();
|
|
while (reader.Read())
|
{
|
if (Convert.ToInt32(reader["FSC"]) == SelfEquip.getFSC() && Convert.ToInt32(reader["UFID"]) == SelfEquip.getUFID())
|
continue;
|
|
if (Convert.ToInt32(reader["OSTATUS"]) == 0) //切開的設備不可能為逆向的上游
|
continue;
|
|
if (Convert.ToInt32(reader["N1"]) == N_Value)
|
{
|
switch (Convert.ToInt32(reader["DIR"]))
|
{
|
case 1:
|
case 3:
|
break;
|
case 2:
|
case 4:
|
return false; //如果逆向的上游連接點為N1，一定要N2-->N1才可能還有需要逆向追蹤設備
|
case 99:
|
break; //未供電設備不可能是逆向上游
|
}
|
}
|
else if (Convert.ToInt32(reader["N2"]) == N_Value)
|
{
|
switch (Convert.ToInt32(reader["DIR"]))
|
{
|
case 1:
|
case 3:
|
return false; //如果逆向的上游連接點為N2，一定要N1-->N2才可能還有需要逆向追蹤設備
|
case 2:
|
case 4:
|
break;
|
case 99:
|
return false; //未供電設備不可能是逆向上游
|
}
|
}
|
}
|
reader.Close();
|
}
|
catch (Exception e)
|
{
|
_Plogger.Error(e.Message);
|
Console.WriteLine(e.StackTrace);
|
return false;
|
}
|
finally
|
{
|
if (Command != null)
|
Command.Dispose();
|
|
if (reader != null)
|
reader.Close();
|
}
|
|
|
return true;
|
}
|
|
private int getTraceCount(int Fsc, int Ufid)
|
{
|
if (TraceCounts.ContainsKey(Fsc + "|" + Ufid))
|
return Int32.Parse(TraceCounts[Fsc + "|" + Ufid].ToString());
|
else
|
return 0;
|
}
|
|
private void AddTraceCount(int Fsc, int Ufid)
|
{
|
int Count = 1;
|
|
if (TraceCounts.ContainsKey(Fsc + "|" + Ufid))
|
{
|
Count = Int32.Parse(TraceCounts[Fsc + "|" + Ufid].ToString());
|
Count++;
|
TraceCounts.Remove(Fsc + "|" + Ufid);
|
}
|
|
TraceCounts.Add(Fsc + "|" + Ufid, Count.ToString());
|
}
|
|
}
|
|
public class TraceLoopException : Exception
|
{
|
public String Message = "";
|
|
public TraceLoopException(String _Message)
|
{
|
Message = _Message;
|
}
|
}
|
}
|
