Notes

//var start=new Date();
/******************************************************************************
Author: Venkatesh Koneri
Description: Service to return data for alarm insights for the second column
Input: activityType
Output: JSON
Created On: 25-Oct-2018
Modified By: Andrew Gondek
Modified Date: 13-Dec-2018
Modification Desc:added filtering to improve speed performance
*******************************************************************************/
var obj = {
};
var result = {
};
result.activities = [];
var shiftStartTime;
var shiftEndTime;
getShiftTimes(shiftType);

var aquery =
{
"filters": {
"type": "And",
"filters": [
{
"type": "GE",
"fieldName": "StartTime",
"value": shiftStartTime
}
,
{
"type": "LT",
"fieldName": "StartTime",
"value": shiftEndTime
}
]
}
};
var params = {
query: aquery /* QUERY */
};
// result: INFOTABLE dataShape: ActiveAlarms_DataShape
var alarmsActive = Things["AlarmWidgetHelperThing"].cloneAndFilterActiveAlarms(params);

var mquery =
{
"filters": {
"type": "And",
"filters": [
{
"type": "GE",
"fieldName": "EndTime",
"value": shiftStartTime
}
,
{
"type": "LT",
"fieldName": "EndTime",
"value": shiftEndTime
}
]
}
};

var params = {
query: mquery /* QUERY */
};

var alarmsHistorical = Things["AlarmWidgetHelperThing"].cloneAndFilterMasterActivity(params);


if ( alarmsActive.getRowCount() == 0 && alarmsHistorical.getRowCount() == 0 ) {
// do nothing
}
else {
var params = {
sortColumn: 'StartTime' /* STRING */,
t: alarmsActive /* INFOTABLE */,
ascending: false /* BOOLEAN */
};
alarmsActive = Resources["InfoTableFunctions"].Sort(params);


var params = {
sortColumn: 'StartTime' /* STRING */,
t: alarmsHistorical /* INFOTABLE */,
ascending: false /* BOOLEAN */
};
alarmsHistorical = Resources["InfoTableFunctions"].Sort(params);

alarmsActive.RemoveField('AlarmId');
var params = {
t1: alarmsActive /* INFOTABLE */,
t2: alarmsHistorical /* INFOTABLE */
};

var alarms = Resources["InfoTableFunctions"].Union(params);

result = getByFrequency(alarms);
}

function getByFrequency(alarms) {

var result = {
};
result.activities = [];
start = Date.now();
var params = {
t: alarms /* INFOTABLE */,
columns: 'AlarmName' /* STRING */,
aggregates: 'COUNT' /* STRING */,
groupByColumns: 'Asset,AlarmName' /* STRING */
};

var aggAlarms = Resources["InfoTableFunctions"].Aggregate(params);
var params = {
sortColumn: 'COUNT_AlarmName' /* STRING */,
t: aggAlarms /* INFOTABLE */,
ascending: false /* BOOLEAN */
};

// result: INFOTABLE
var sortAggAlarms = Resources["InfoTableFunctions"].Sort(params);
end = Date.now();
logger.info("Control Tower Alarm Insights - Aggregate and Sort - Start Time : " + ( start - end) / 1000 );

for each ( s_row in sortAggAlarms.rows ) {

var obj = {
};
var first_idx = 0;
obj.alarmHistoryData = [];
var query =
{
"filters": {
"type": "And",
"filters": [
{
"type": "EQ",
"fieldName": "AlarmName",
"value": s_row.AlarmName
}
,
{
"type": "EQ",
"fieldName": "Asset",
"value": s_row.Asset
}
]
}
};

var params = {
t: alarms /* INFOTABLE */,
query: query /* QUERY */
};

// result: INFOTABLE
var filtered = Resources["InfoTableFunctions"].Query(params);
for each ( a_row in filtered.rows ) {

if ( s_row.Asset == a_row.Asset && s_row.AlarmName == a_row.AlarmName ) {
if ( first_idx == 0 ) {
first_idx = first_idx + 1;
obj.lineNumber = a_row.Line;
obj.assetName = a_row.Asset;
obj.alarmName = a_row.AlarmName;
if ( a_row.Severity == 1 ) {
obj.alarmType = 'warning';
}

if ( a_row.Severity == 2 ) {
obj.alarmType = 'alarm';
}
obj.isCBM = a_row.isCBM;

obj.currentStatus = a_row.AlarmStatus;

if ( obj.currentStatus == 'Active' ) {
if ( (new Date().getTime() - a_row.StartTime) > ( 6 * 60 * 60 * 1000 ) ) {
obj.onMoreThan6 = true;

}
}
}



var alarmHistoryObj = {
};
var startHours = (a_row.StartTime.getHours() > 9) ? a_row.StartTime.getHours() : '0' + a_row.StartTime.getHours();
var startMins = (a_row.StartTime.getMinutes() > 9) ? a_row.StartTime.getMinutes() : '0' + a_row.StartTime.getMinutes();
alarmHistoryObj.start = startHours + ':' + startMins;

if ( a_row.Acknowledgement == true ) {

if ( a_row.AcknowledgementTime != undefined ) {
var ackHour = a_row.AcknowledgementTime.getHours() > 9 ? a_row.AcknowledgementTime.getHours() : '0' + a_row.AcknowledgementTime.getHours();
var ackMins = a_row.AcknowledgementTime.getMinutes() > 9 ? a_row.AcknowledgementTime.getMinutes() : '0' + a_row.AcknowledgementTime.getMinutes();
alarmHistoryObj.Ackn = ackHour + ':' + ackMins;
alarmHistoryObj.AckowlBy = a_row.AcknowledgementBy;
}
else {
alarmHistoryObj.Ackn = '--';
alarmHistoryObj.AckowlBy = '--';
}
}

alarmHistoryObj.Status = a_row.AlarmStatus;
if ( a_row.AlarmStatus == 'Resolved' ) {
var resHor = a_row.EndTime.getHours() > 9 ? a_row.EndTime.getHours() : '0' + a_row.EndTime.getHours();
var resMin = a_row.EndTime.getMinutes() > 9 ? a_row.EndTime.getMinutes() : '0' + a_row.EndTime.getMinutes();
alarmHistoryObj.Reso = resHor + ':' + resMin;
}
else {
alarmHistoryObj.Reso = '--';
}

obj.alarmHistoryData.push(alarmHistoryObj);
}

}
obj.totalCount = s_row.COUNT_AlarmName;

var params = {
totalAlarms: filtered /* INFOTABLE */,
asset: s_row.Asset /* STRING */,
alarmName : s_row.AlarmName
};

// result: LONG
var longAvgActToAck = me.getAvgActiveToAcknowledgedTime(params);
obj.avgActToAckTime = getHoursAndMinutes(longAvgActToAck);

var longAckToResolved = me.getAvgAckToResolvedTime(params);
obj.avgAckToResolveTime = getHoursAndMinutes(longAckToResolved);

var longActToResolved = me.getAvgActiveToResolvedTime(params);
obj.avgActiveToResolveTime = getHoursAndMinutes(longActToResolved);

if ( obj.currentStatus == 'Acknowledged' ) {
obj.currentStatus = 'Active';
}

result.activities.push(obj);
}
return result;
}

function getShiftTimes(shiftType) {
var currentTime = new Date();
var firstShiftStartTime = new Date().setHours(6,30,0,0);

if ( currentTime > firstShiftStartTime && currentTime < (firstShiftStartTime + (12*60*60*1000)) ) {
shiftStartTime = new Date(new Date().setHours(6,30,0,0));
}
else if ( currentTime < firstShiftStartTime ) {
shiftStartTime = new Date(new Date(new Date().setHours(0,0,0,0) - 1 ).setHours(18,30,0,0));
}
else {
shiftStartTime = new Date(new Date().setHours(18,30,0,0));
}

shiftEndTime = dateAddHours(shiftStartTime, 12);

if ( shiftType == '0' ) {
shiftStartTime = dateAddHours(shiftStartTime, -12);
shiftEndTime = dateAddHours(shiftEndTime, -12);
}

}

function getHoursAndMinutes(calculatedDiff) {

var diffInHrNMin = calculatedDiff / ( 60 * 60 * 1000);
var wholeNum = Math.floor(diffInHrNMin);
var diffInMin = Math.floor((diffInHrNMin - wholeNum ) * 60);

if ( wholeNum < 10 ) {
wholeNum = '0' + wholeNum;
}
if ( diffInMin < 10 ) {
diffInMin = '0' + diffInMin;
}


return (wholeNum + ":" + diffInMin);

}
//var end=new Date();
//var diff=end.getTime()-start.getTime();
//logger.info("Atest diff: "+diff);