in code/src/main/java/DataProviderWE02.java [35:99]
public void getData() throws JCoException
{
if(config.we02)
{
//METRICS
Integer Inbound = 0;
Integer Outbound = 0;
SimpleDateFormat de_formatter = new SimpleDateFormat("yyyyMMdd");
String today = de_formatter.format(new java.util.Date());
//PART1 (INBOUND)
//IMPORT
HashMap<String, Object> importParameters = new HashMap<String, Object>();
String myjson = "{ \"SELOPT_PARA\":[ { \"CALL_ID\":0, \"SELECTION_PARAMETER\":[ { \"PARAM\":\"DIRECTION\", \"T_RANGES\":[{ \"SIGN\":\"\", \"OPTION\":\"EQ\", \"LOW\":\"INBOUND\", \"HIGH\":\"\" }] }, { \"PARAM\":\"STATUS\", \"T_RANGES\":[{ \"SIGN\":\"\", \"OPTION\":\"EQ\", \"LOW\":\"RED\", \"HIGH\":\"\" }] }, { \"PARAM\":\"CLIENT\", \"T_RANGES\":[{ \"SIGN\":\"\", \"OPTION\":\"EQ\", \"LOW\":\"TOTAL\", \"HIGH\":\"\" }] }, { \"PARAM\":\"IGNORE_BEFORE_DATE\", \"T_RANGES\":[{ \"SIGN\":\"\", \"OPTION\":\"EQ\", \"LOW\":\""+today+"\", \"HIGH\":\"\" }] } ] } ] }";
importParameters.put("json", myjson);
//EXECUTE
JCoParameterList exportParameters = utils.execute("PARAMS", importParameters, rfc, prefix+"_Inbound", frequency);
//EXPORT
if(exportParameters != null)
{
final JCoTable result = exportParameters.getTable("RESULT");
for (int i = 0; i < result.getNumRows(); i++) {
result.setRow(i);
Inbound += result.getStructure("RESULT").getInt("AVERAGE");
}
}
//PART2 (OUTBOUND)
//IMPORT
HashMap<String, Object> importParametersT = new HashMap<String, Object>();
String myjsonT = "{ \"SELOPT_PARA\":[ { \"CALL_ID\":0, \"SELECTION_PARAMETER\":[ { \"PARAM\":\"DIRECTION\", \"T_RANGES\":[{ \"SIGN\":\"\", \"OPTION\":\"EQ\", \"LOW\":\"OUTBOUND\", \"HIGH\":\"\" }] }, { \"PARAM\":\"STATUS\", \"T_RANGES\":[{ \"SIGN\":\"\", \"OPTION\":\"EQ\", \"LOW\":\"RED\", \"HIGH\":\"\" }] }, { \"PARAM\":\"CLIENT\", \"T_RANGES\":[{ \"SIGN\":\"\", \"OPTION\":\"EQ\", \"LOW\":\"TOTAL\", \"HIGH\":\"\" }] }, { \"PARAM\":\"IGNORE_BEFORE_DATE\", \"T_RANGES\":[{ \"SIGN\":\"\", \"OPTION\":\"EQ\", \"LOW\":\""+today+"\", \"HIGH\":\"\" }] } ] } ] }";
importParametersT.put("json", myjsonT);
//EXECUTE
JCoParameterList exportParametersT = utils.execute("PARAMS", importParametersT, rfc, prefix+"_Outbound", frequency);
//EXPORT
if(exportParametersT != null)
{
final JCoTable resultT = exportParametersT.getTable("RESULT");
for (int i = 0; i < resultT.getNumRows(); i++) {
resultT.setRow(i);
Outbound += resultT.getStructure("RESULT").getInt("AVERAGE");
}
System.out.println("Inbound: "+Inbound);
System.out.println("Outbound: "+Outbound);
//COLLECT & SUBMIT
utils.collectResultEmbedded(config.destination_name, prefix+"_INBOUND", (double) Inbound);
utils.collectResultEmbedded(config.destination_name, prefix+"_OUTBOUND", (double) Outbound);
utils.submitResultsEmbedded(prefix);
}
}
else
{
System.out.println("we02 collector disabled! Enable by passing we02 = 1 through Secrets Manager!");
}
}