diff --git a/AF-Demo/src/af/interfaces/AFState.java b/AF-Demo/src/af/interfaces/AFState.java index 63f5cca..3b9ae61 100644 --- a/AF-Demo/src/af/interfaces/AFState.java +++ b/AF-Demo/src/af/interfaces/AFState.java @@ -4,4 +4,5 @@ public interface AFState { public String IDLE = "IDLE"; public String W_E01Res = "W_DBRes"; public String W_ARes = "W_ARes"; + public String END = "END"; } diff --git a/AF-Demo/src/af/state/StateIdle.java b/AF-Demo/src/af/state/StateIdle.java index cc0ac4e..c4d7f67 100644 --- a/AF-Demo/src/af/state/StateIdle.java +++ b/AF-Demo/src/af/state/StateIdle.java @@ -4,6 +4,7 @@ import java.util.ArrayList; import af.instatnce.E01Instance; import af.instatnce.EC02Instance; +import af.instatnce.EQXRawInstance; import af.interfaces.AFEvent; import af.interfaces.AFState; import af.interfaces.EQXMsg; @@ -16,41 +17,56 @@ import ec02.af.utils.AlarmCategory; import ec02.af.utils.AlarmSeverity; import ec02.af.utils.AlarmType; -public class StateIdle implements IAFState { +public class StateIdle implements IAFState { private String eqxState = null; private EC02Builder ec02Builder = new EC02Builder(); private ArrayList eqxRawDataList = new ArrayList(); - + @Override public String doAction(AbstractAF abstractAF, Object instance, ArrayList eqxRawDataList) { EC02Instance ec02Ins = (EC02Instance) instance; - - for(EquinoxRawData eqxRawData : eqxRawDataList){ + + for (EquinoxRawData eqxRawData : eqxRawDataList) { this.ec02Builder.setEquinoxRawData(eqxRawData, abstractAF, ec02Ins); ec02Ins.getAFInstance().setInvoke(eqxRawData.getInvoke()); ec02Ins.getAFInstance().setOrig(eqxRawData.getRawDataAttribute(EQXMsg.ORIG)); + + /* + * if(eqxRawData.getRawEventType().equals(AFEvent. + * Incoming_HTTP_Request)){ E01Instance e01Ins = new E01Instance(); + * ArrayList keys = new ArrayList(); + * keys.add(eqxRawData.getRawDataMessage()); keys.add("def"); + * keys.add("def"); keys.add("def"); keys.add("def"); + * e01Ins.setCmd("search"); e01Ins.setObjType("TESTDATA"); + * e01Ins.setKey(keys); // e01Ins.setId("01"); + * ec02Ins.setE01Ins(e01Ins); this.ec02Builder.getE01Request(); + * String [] parameter = {""}; + * abstractAF.getUtils().writeLog("mylog1", "hello word!!!"); + * abstractAF.getUtils().incrementStats("my_stat"); + * abstractAF.getUtils().incrementStats("raise_by_stat"); + * abstractAF.getUtils().raiseAlarm("my_alarm", parameter, + * AlarmSeverity.WARNING, AlarmCategory.APPLICATION, + * AlarmType.Normal); this.eqxState = AFState.W_E01Res; } + */ + ArrayList eqxRawList = new ArrayList(); + EQXRawInstance eqxRaw = new EQXRawInstance(); + eqxRaw.setMessage("B1 Req."); + eqxRaw.setTo(abstractAF.getUtils().getHmWarmConfig().get("Resource-Name-B").get(0)); + eqxRaw.setCtype(EQXMsg.TEXTXML); + eqxRawList.add(eqxRaw); + + EQXRawInstance eqxRaw2 = new EQXRawInstance(); + eqxRaw2.setMessage("B2 Req."); + eqxRaw2.setTo(abstractAF.getUtils().getHmWarmConfig().get("Resource-Name-B").get(0)); + eqxRaw2.setCtype(EQXMsg.TEXTXML); + eqxRawList.add(eqxRaw2); + + ArrayList rawList = this.ec02Builder.getHTTPRequest(eqxRawList); + for (int i = 0; i < rawList.size(); i++) { + this.eqxRawDataList.add(rawList.get(i)); + } + this.eqxState = AFState.W_ARes; - if(eqxRawData.getRawEventType().equals(AFEvent.Incoming_HTTP_Request)){ - E01Instance e01Ins = new E01Instance(); - ArrayList keys = new ArrayList(); - keys.add(eqxRawData.getRawDataMessage()); - keys.add("def"); - keys.add("def"); - keys.add("def"); - keys.add("def"); - e01Ins.setCmd("search"); - e01Ins.setObjType("TESTDATA"); - e01Ins.setKey(keys); -// e01Ins.setId("01"); - ec02Ins.setE01Ins(e01Ins); - this.ec02Builder.getE01Request(); - String [] parameter = {""}; - abstractAF.getUtils().writeLog("mylog1", "hello word!!!"); - abstractAF.getUtils().incrementStats("my_stat"); - abstractAF.getUtils().incrementStats("raise_by_stat"); - abstractAF.getUtils().raiseAlarm("my_alarm", parameter, AlarmSeverity.WARNING, AlarmCategory.APPLICATION, AlarmType.Normal); - this.eqxState = AFState.W_E01Res; - } } ec02Ins.setEqxRawDataList(this.eqxRawDataList); return this.eqxState; diff --git a/AF-Demo/src/af/state/StateWaitA.java b/AF-Demo/src/af/state/StateWaitA.java index 2a069e8..6984ee4 100644 --- a/AF-Demo/src/af/state/StateWaitA.java +++ b/AF-Demo/src/af/state/StateWaitA.java @@ -24,8 +24,9 @@ public class StateWaitA implements IAFState { EC02Instance ec02Ins = (EC02Instance)instance; for(EquinoxRawData eqxRawData : eqxRawDataList) { - this.ec02Builder.setEquinoxRawData(eqxRawData, abstractAF, ec02Ins); - if(eqxRawData.getRawEventType().equals(AFEvent.Incoming_A_Response)){ + this.ec02Builder.setEquinoxRawData(eqxRawData, abstractAF, ec02Ins); + + /*if(eqxRawData.getRawEventType().equals(AFEvent.Incoming_A_Response)){ StringExtract str = new StringExtract(); HashMap map = str.getAll(str.setMessage(eqxRawData.getRawDataMessage().trim())); String message = map.get("MSG[0].value"); @@ -35,12 +36,18 @@ public class StateWaitA implements IAFState { eqxRaw.setTo(ec02Ins.getAFInstance().getOrig()); eqxRaw.setCtype(EQXMsg.TEXTPLAIN); this.eqxRawDataList.add(this.ec02Builder.getHTTPResponse(eqxRaw)); - this.eqxState = AFState.IDLE; - } + this.eqxState = AFState.END; + /*} else { - } - } + }*/ + EQXRawInstance eqxRaw = new EQXRawInstance(); + eqxRaw.setMessage("A Res."); + eqxRaw.setTo(ec02Ins.getAFInstance().getOrig()); + eqxRaw.setCtype(EQXMsg.TEXTPLAIN); + this.eqxRawDataList.add(this.ec02Builder.getHTTPResponse(eqxRaw)); + this.eqxState = AFState.END; + } ec02Ins.setEqxRawDataList(this.eqxRawDataList); return this.eqxState; -- libgit2 0.21.2