|
|
|
|
@ -6221,7 +6221,7 @@ async function processIotData(hw_Id, data) {
|
|
|
|
|
// Case 1: First time signal is lost
|
|
|
|
|
if (
|
|
|
|
|
existingTank.slave_status !== "signal_lost1" &&
|
|
|
|
|
existingTank.slave_status !== "not_working"
|
|
|
|
|
existingTank.slave_status !== "not_working1"
|
|
|
|
|
) {
|
|
|
|
|
existingTank.slave_status = "signal_lost1";
|
|
|
|
|
existingTank.slave_disconnected_time = now.format('DD-MMM-YYYY - HH:mm:ss');
|
|
|
|
|
@ -6240,7 +6240,7 @@ async function processIotData(hw_Id, data) {
|
|
|
|
|
const minutesElapsed = now.diff(lostTime, 'minutes');
|
|
|
|
|
|
|
|
|
|
if (minutesElapsed >= 15) {
|
|
|
|
|
existingTank.slave_status = "not_working";
|
|
|
|
|
existingTank.slave_status = "not_working1";
|
|
|
|
|
existingTank.slave_disconnected_time = now.format('DD-MMM-YYYY - HH:mm:ss');
|
|
|
|
|
await existingTank.save();
|
|
|
|
|
|
|
|
|
|
@ -6257,7 +6257,7 @@ async function processIotData(hw_Id, data) {
|
|
|
|
|
if (linkedTank) {
|
|
|
|
|
for (const inputConnection of linkedTank.connections.inputConnections) {
|
|
|
|
|
if (inputConnection.inputConnections === tank_name) {
|
|
|
|
|
inputConnection.slave_status = "not_working";
|
|
|
|
|
inputConnection.slave_status = "not_working1";
|
|
|
|
|
await linkedTank.save();
|
|
|
|
|
console.log(`🔗 Linked tank [${linkedTank.tankName}] inputConnection updated to not_working`);
|
|
|
|
|
}
|
|
|
|
|
|