From b6f00967c384bd04bf1da3a5425a3b4454d710cc Mon Sep 17 00:00:00 2001 From: Suraputt Suntimitr Date: Mon, 11 Apr 2016 13:34:20 +0700 Subject: [PATCH] Ex02 Add END STATE --- AF-Demo/src/af/interfaces/AFState.java | 1 + AF-Demo/src/af/state/StateIdle.java | 45 ++++++++++++++++++++------------------------- AF-Demo/src/af/state/StateWaitA.java | 51 ++++++++++++++++++++++++--------------------------- 3 files changed, 45 insertions(+), 52 deletions(-) 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..0bd34cd 100644 --- a/AF-Demo/src/af/state/StateIdle.java +++ b/AF-Demo/src/af/state/StateIdle.java @@ -16,7 +16,7 @@ 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(); @@ -24,33 +24,28 @@ public class StateIdle implements IAFState { @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; - } + + /* + * if(eqxRawData.getRawEventType().equals(AFEvent. + * Incoming_HTTP_Request)){ E01Instance e01Ins = new E01Instance(); + * ArrayList keys = new ArrayList(); + * keys.add(eqxRawData.getRawDataMessage()); 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 ed95e9f..ada6e03 100644 --- a/AF-Demo/src/af/state/StateWaitA.java +++ b/AF-Demo/src/af/state/StateWaitA.java @@ -1,14 +1,9 @@ package af.state; import java.util.ArrayList; -import java.util.HashMap; -import th.co.ais.equinox.utils.StringExtract; import af.instatnce.EC02Instance; -import af.instatnce.EQXRawInstance; -import af.interfaces.AFEvent; import af.interfaces.AFState; -import af.interfaces.EQXMsg; import af.message.EC02Builder; import ec02.af.abstracts.AbstractAF; import ec02.af.data.EquinoxRawData; @@ -18,30 +13,32 @@ public class StateWaitA 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) { - 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"); - if (message.trim().equals("SUCCESS")) { - EQXRawInstance eqxRaw = new EQXRawInstance(); - eqxRaw.setMessage(message.trim()); - eqxRaw.setTo(ec02Ins.getAFInstance().getOrig()); - eqxRaw.setCtype(EQXMsg.TEXTPLAIN); - this.eqxRawDataList.add(this.ec02Builder.getHTTPResponse(eqxRaw)); - this.eqxState = AFState.IDLE; - - } - else { - - } - } + EC02Instance ec02Ins = (EC02Instance) instance; + + for (EquinoxRawData eqxRawData : eqxRawDataList) { + 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"); if + * (message.trim().equals("SUCCESS")) { EQXRawInstance eqxRaw = new + * EQXRawInstance(); eqxRaw.setMessage(message.trim()); + * eqxRaw.setTo(ec02Ins.getAFInstance().getOrig()); + * eqxRaw.setCtype(EQXMsg.TEXTPLAIN); + * this.eqxRawDataList.add(this.ec02Builder.getHTTPResponse(eqxRaw)) + * ; this.eqxState = AFState.IDLE; + * + * } else { + * + * } + */ + // } + this.eqxState = AFState.END; } ec02Ins.setEqxRawDataList(this.eqxRawDataList); return this.eqxState; -- libgit2 0.21.2