|
|
|
@ -1,7 +1,7 @@
|
|
|
|
const websocketUrl = 'ws://119.45.202.115:7181/ws';
|
|
|
|
const websocketUrl = 'ws://119.45.202.115:7181/ws';
|
|
|
|
const deviceDataTime = {};
|
|
|
|
const deviceDataTime = {};
|
|
|
|
const overtime = 1000 * 60 * 10;
|
|
|
|
const overtime = 1000 * 60 * 10;
|
|
|
|
// const overtime = 1000;
|
|
|
|
const intervalTime = 1000 * 30;
|
|
|
|
let alarmReminderSocket = null;
|
|
|
|
let alarmReminderSocket = null;
|
|
|
|
let overtimeTimer = null;
|
|
|
|
let overtimeTimer = null;
|
|
|
|
let overtimeCallback = null;
|
|
|
|
let overtimeCallback = null;
|
|
|
|
@ -34,7 +34,7 @@ const updateDeviceDataTime = (payload) => {
|
|
|
|
|
|
|
|
|
|
|
|
deviceDataTime[monitorId] = {
|
|
|
|
deviceDataTime[monitorId] = {
|
|
|
|
objid: String(objid),
|
|
|
|
objid: String(objid),
|
|
|
|
time: Date.now()
|
|
|
|
time: Date.now() + overtime
|
|
|
|
};
|
|
|
|
};
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
@ -53,7 +53,7 @@ const startOvertimeTimer = () => {
|
|
|
|
Object.keys(deviceDataTime).forEach((monitorId) => {
|
|
|
|
Object.keys(deviceDataTime).forEach((monitorId) => {
|
|
|
|
const item = deviceDataTime[monitorId];
|
|
|
|
const item = deviceDataTime[monitorId];
|
|
|
|
|
|
|
|
|
|
|
|
if (!item || now - item.time <= overtime) {
|
|
|
|
if (!item || now <= item.time) {
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@ -61,7 +61,7 @@ const startOvertimeTimer = () => {
|
|
|
|
monitorId,
|
|
|
|
monitorId,
|
|
|
|
...item
|
|
|
|
...item
|
|
|
|
});
|
|
|
|
});
|
|
|
|
delete deviceDataTime[monitorId];
|
|
|
|
item.time = now + intervalTime;
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}, 1000);
|
|
|
|
}, 1000);
|
|
|
|
};
|
|
|
|
};
|
|
|
|
@ -116,4 +116,4 @@ export const closeAlarmReminder = () => {
|
|
|
|
overtimeCallback = null;
|
|
|
|
overtimeCallback = null;
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
export { websocketUrl, deviceDataTime, overtime };
|
|
|
|
export { websocketUrl, deviceDataTime, overtime, intervalTime };
|
|
|
|
|