123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102 |
- var option = {
-
- clientId: 'mqttjs_' + (Math.random() * 1000000).toString(),
- timeout: 5000,
- useSSL: false
- }
- var href = window.location.href;
- var path = window.location.pathname;
- let alarmBasicUrl = href.slice(0, href.indexOf(path));
- let alarmMqttUrl = "ws:" + alarmBasicUrl.slice(alarmBasicUrl.indexOf("//")) + "/mqtt";
- var alarmMqttClient = mqtt.connect(alarmMqttUrl, option);
- alarmMqttClient.on('connect', function () {
- console.log("alarm bar connected to mqtt server successfully");
-
- alarmMqttClient.subscribe('/+/+/thing/event/OnAlarm/+', function(err) {
- if (err) {
- console.log("subscribe OnAlarm event failed, error info:"+err);
- }
- });
- alarmMqttClient.subscribe('/+/+/thing/event/OnGenericAlarm/+', function (err) {
- if (err) {
- console.log("failed to subsecribe OnGenericAlarm event");
- }
- });
- });
- alarmMqttClient.on('message', function (topic, message) {
- var reg = RegExp(/OnAlarm/);
- if (topic.toString().match(reg)) {
- ProcessAlarmInformations(JSON.parse(message.toString()));
- } else if (topic.toString().match(RegExp(/OnGenericAlarm/))) {
-
- ProcessGenericAlarm(JSON.parse(message.toString()));
- }
- });
- function ProcessGenericAlarm(message){
- if (message === null) {
- console.log("Invalid generic alarm message received");
- return;
- }
- if (Array.isArray(message)) {
- message.forEach(function (alarm) {
- var temp = {
- "Key": alarm.Title + alarm.Category + alarm.Severity, "Description": alarm.Title, "OccurTime": null, "Module": alarm.Category, "Severity": alarm.Severity, "Action": alarm.Action,
- "Acked": false
- };
- AddAlarmInfomation(JSON.stringify(temp));
- });
- } else {
- var temp = {
- "Key": message.Title + message.Category + message.Severity, "Description": message.Title, "OccurTime": null, "Module": message.Category, "Severity": message.Severity, "Action": message.Action,
- "Acked": false
- };
- AddAlarmInfomation(JSON.stringify(temp));
- }
- }
- function ProcessAlarmInformations(message) {
- if (message == null || message.Alarms == null || !Array.isArray(message.Alarms)) {
- console.log("Invalid alarm message received");
- return;
- }
- message.Alarms.forEach(function(alarm) {
- var temp = {
- "Key": alarm.TankNumber + alarm.Type, "Description": alarm.Description, "OccurTime": alarm.CreatedTimeStamp, "Module": "ATG", "Severity": alarm.Priority, "Action": null,
- "Acked":false
- };
- AddAlarmInfomation(JSON.stringify(temp));
- });
- }
- function AddAlarmInfomation(message) {
- $.ajax({
- url: "/AlarmBar/AddInformation",
- contentType: 'application/json',
- data: message,
- type: 'post',
- success: function (res) {
-
- },
- error: function (msg) {
- console.log(msg);
- }
- });
- }
- function RemoveAlarmInfomationByKey(key) {
- $.ajax({
- url: "/AlarmBar/RemoveInformation?key="+key,
- contentType: 'application/json',
-
- type: 'post',
- success: function (res) {
-
- },
- error: function (msg) {
- console.log(msg);
- }
- });
- }
|