Commit b6f00967c384bd04bf1da3a5425a3b4454d710cc

Authored by Suraputt Suntimitr
1 parent a4b4a73e
Exists in AFDemo_Ex2

Ex02 Add END STATE

AF-Demo/src/af/interfaces/AFState.java
@@ -4,4 +4,5 @@ public interface AFState { @@ -4,4 +4,5 @@ public interface AFState {
4 public String IDLE = "IDLE"; 4 public String IDLE = "IDLE";
5 public String W_E01Res = "W_DBRes"; 5 public String W_E01Res = "W_DBRes";
6 public String W_ARes = "W_ARes"; 6 public String W_ARes = "W_ARes";
  7 + public String END = "END";
7 } 8 }
AF-Demo/src/af/state/StateIdle.java
@@ -16,7 +16,7 @@ import ec02.af.utils.AlarmCategory; @@ -16,7 +16,7 @@ import ec02.af.utils.AlarmCategory;
16 import ec02.af.utils.AlarmSeverity; 16 import ec02.af.utils.AlarmSeverity;
17 import ec02.af.utils.AlarmType; 17 import ec02.af.utils.AlarmType;
18 18
19 -public class StateIdle implements IAFState { 19 +public class StateIdle implements IAFState {
20 private String eqxState = null; 20 private String eqxState = null;
21 private EC02Builder ec02Builder = new EC02Builder(); 21 private EC02Builder ec02Builder = new EC02Builder();
22 private ArrayList<EquinoxRawData> eqxRawDataList = new ArrayList<EquinoxRawData>(); 22 private ArrayList<EquinoxRawData> eqxRawDataList = new ArrayList<EquinoxRawData>();
@@ -24,33 +24,28 @@ public class StateIdle implements IAFState { @@ -24,33 +24,28 @@ public class StateIdle implements IAFState {
24 @Override 24 @Override
25 public String doAction(AbstractAF abstractAF, Object instance, ArrayList<EquinoxRawData> eqxRawDataList) { 25 public String doAction(AbstractAF abstractAF, Object instance, ArrayList<EquinoxRawData> eqxRawDataList) {
26 EC02Instance ec02Ins = (EC02Instance) instance; 26 EC02Instance ec02Ins = (EC02Instance) instance;
27 -  
28 - for(EquinoxRawData eqxRawData : eqxRawDataList){ 27 +
  28 + for (EquinoxRawData eqxRawData : eqxRawDataList) {
29 this.ec02Builder.setEquinoxRawData(eqxRawData, abstractAF, ec02Ins); 29 this.ec02Builder.setEquinoxRawData(eqxRawData, abstractAF, ec02Ins);
30 ec02Ins.getAFInstance().setInvoke(eqxRawData.getInvoke()); 30 ec02Ins.getAFInstance().setInvoke(eqxRawData.getInvoke());
31 ec02Ins.getAFInstance().setOrig(eqxRawData.getRawDataAttribute(EQXMsg.ORIG)); 31 ec02Ins.getAFInstance().setOrig(eqxRawData.getRawDataAttribute(EQXMsg.ORIG));
32 -  
33 - if(eqxRawData.getRawEventType().equals(AFEvent.Incoming_HTTP_Request)){  
34 - E01Instance e01Ins = new E01Instance();  
35 - ArrayList<String> keys = new ArrayList<String>();  
36 - keys.add(eqxRawData.getRawDataMessage());  
37 - keys.add("def");  
38 - keys.add("def");  
39 - keys.add("def");  
40 - keys.add("def");  
41 - e01Ins.setCmd("search");  
42 - e01Ins.setObjType("TESTDATA");  
43 - e01Ins.setKey(keys);  
44 -// e01Ins.setId("01");  
45 - ec02Ins.setE01Ins(e01Ins);  
46 - this.ec02Builder.getE01Request();  
47 - String [] parameter = {""};  
48 - abstractAF.getUtils().writeLog("mylog1", "hello word!!!");  
49 - abstractAF.getUtils().incrementStats("my_stat");  
50 - abstractAF.getUtils().incrementStats("raise_by_stat");  
51 - abstractAF.getUtils().raiseAlarm("my_alarm", parameter, AlarmSeverity.WARNING, AlarmCategory.APPLICATION, AlarmType.Normal);  
52 - this.eqxState = AFState.W_E01Res;  
53 - } 32 +
  33 + /*
  34 + * if(eqxRawData.getRawEventType().equals(AFEvent.
  35 + * Incoming_HTTP_Request)){ E01Instance e01Ins = new E01Instance();
  36 + * ArrayList<String> keys = new ArrayList<String>();
  37 + * keys.add(eqxRawData.getRawDataMessage()); keys.add("def");
  38 + * e01Ins.setCmd("search"); e01Ins.setObjType("TESTDATA");
  39 + * e01Ins.setKey(keys); // e01Ins.setId("01");
  40 + * ec02Ins.setE01Ins(e01Ins); this.ec02Builder.getE01Request();
  41 + * String [] parameter = {""};
  42 + * abstractAF.getUtils().writeLog("mylog1", "hello word!!!");
  43 + * abstractAF.getUtils().incrementStats("my_stat");
  44 + * abstractAF.getUtils().incrementStats("raise_by_stat");
  45 + * abstractAF.getUtils().raiseAlarm("my_alarm", parameter,
  46 + * AlarmSeverity.WARNING, AlarmCategory.APPLICATION,
  47 + * AlarmType.Normal); this.eqxState = AFState.W_E01Res; }
  48 + */
54 } 49 }
55 ec02Ins.setEqxRawDataList(this.eqxRawDataList); 50 ec02Ins.setEqxRawDataList(this.eqxRawDataList);
56 return this.eqxState; 51 return this.eqxState;
AF-Demo/src/af/state/StateWaitA.java
1 package af.state; 1 package af.state;
2 2
3 import java.util.ArrayList; 3 import java.util.ArrayList;
4 -import java.util.HashMap;  
5 4
6 -import th.co.ais.equinox.utils.StringExtract;  
7 import af.instatnce.EC02Instance; 5 import af.instatnce.EC02Instance;
8 -import af.instatnce.EQXRawInstance;  
9 -import af.interfaces.AFEvent;  
10 import af.interfaces.AFState; 6 import af.interfaces.AFState;
11 -import af.interfaces.EQXMsg;  
12 import af.message.EC02Builder; 7 import af.message.EC02Builder;
13 import ec02.af.abstracts.AbstractAF; 8 import ec02.af.abstracts.AbstractAF;
14 import ec02.af.data.EquinoxRawData; 9 import ec02.af.data.EquinoxRawData;
@@ -18,30 +13,32 @@ public class StateWaitA implements IAFState { @@ -18,30 +13,32 @@ public class StateWaitA implements IAFState {
18 private String eqxState = null; 13 private String eqxState = null;
19 private EC02Builder ec02Builder = new EC02Builder(); 14 private EC02Builder ec02Builder = new EC02Builder();
20 private ArrayList<EquinoxRawData> eqxRawDataList = new ArrayList<EquinoxRawData>(); 15 private ArrayList<EquinoxRawData> eqxRawDataList = new ArrayList<EquinoxRawData>();
21 - 16 +
22 @Override 17 @Override
23 public String doAction(AbstractAF abstractAF, Object instance, ArrayList<EquinoxRawData> eqxRawDataList) { 18 public String doAction(AbstractAF abstractAF, Object instance, ArrayList<EquinoxRawData> eqxRawDataList) {
24 - EC02Instance ec02Ins = (EC02Instance)instance;  
25 -  
26 - for(EquinoxRawData eqxRawData : eqxRawDataList) {  
27 - this.ec02Builder.setEquinoxRawData(eqxRawData, abstractAF, ec02Ins);  
28 - if(eqxRawData.getRawEventType().equals(AFEvent.Incoming_A_Response)){  
29 - StringExtract str = new StringExtract();  
30 - HashMap<String, String> map = str.getAll(str.setMessage(eqxRawData.getRawDataMessage().trim()));  
31 - String message = map.get("MSG[0].value");  
32 - if (message.trim().equals("SUCCESS")) {  
33 - EQXRawInstance eqxRaw = new EQXRawInstance();  
34 - eqxRaw.setMessage(message.trim());  
35 - eqxRaw.setTo(ec02Ins.getAFInstance().getOrig());  
36 - eqxRaw.setCtype(EQXMsg.TEXTPLAIN);  
37 - this.eqxRawDataList.add(this.ec02Builder.getHTTPResponse(eqxRaw));  
38 - this.eqxState = AFState.IDLE;  
39 -  
40 - }  
41 - else {  
42 -  
43 - }  
44 - } 19 + EC02Instance ec02Ins = (EC02Instance) instance;
  20 +
  21 + for (EquinoxRawData eqxRawData : eqxRawDataList) {
  22 + this.ec02Builder.setEquinoxRawData(eqxRawData, abstractAF, ec02Ins);
  23 + /*
  24 + * if(eqxRawData.getRawEventType().equals(AFEvent.
  25 + * Incoming_A_Response)){ StringExtract str = new StringExtract();
  26 + * HashMap<String, String> map =
  27 + * str.getAll(str.setMessage(eqxRawData.getRawDataMessage().trim()))
  28 + * ; String message = map.get("MSG[0].value"); if
  29 + * (message.trim().equals("SUCCESS")) { EQXRawInstance eqxRaw = new
  30 + * EQXRawInstance(); eqxRaw.setMessage(message.trim());
  31 + * eqxRaw.setTo(ec02Ins.getAFInstance().getOrig());
  32 + * eqxRaw.setCtype(EQXMsg.TEXTPLAIN);
  33 + * this.eqxRawDataList.add(this.ec02Builder.getHTTPResponse(eqxRaw))
  34 + * ; this.eqxState = AFState.IDLE;
  35 + *
  36 + * } else {
  37 + *
  38 + * }
  39 + */
  40 + // }
  41 + this.eqxState = AFState.END;
45 } 42 }
46 ec02Ins.setEqxRawDataList(this.eqxRawDataList); 43 ec02Ins.setEqxRawDataList(this.eqxRawDataList);
47 return this.eqxState; 44 return this.eqxState;