|
|
|
@ -2973,11 +2973,11 @@ exports.motorAction = async (req, reply) => {
|
|
|
|
|
console.log(thresholdTime,"thresholdTime")
|
|
|
|
|
console.log("motor stopping because it entered this condition")
|
|
|
|
|
// Emit the threshold time notification
|
|
|
|
|
eventEmitter.emit(
|
|
|
|
|
"sendThresholdTimeNotification",
|
|
|
|
|
fcmToken,
|
|
|
|
|
`Motor has reached its time threshold of ${req.body.manual_threshold_time} minutes and will stop.`
|
|
|
|
|
);
|
|
|
|
|
// eventEmitter.emit(
|
|
|
|
|
// "sendThresholdTimeNotification",
|
|
|
|
|
// fcmToken,
|
|
|
|
|
// `Motor has reached its time threshold of ${req.body.manual_threshold_time} minutes and will stop.`
|
|
|
|
|
// );
|
|
|
|
|
|
|
|
|
|
await Tank.updateOne(
|
|
|
|
|
{ customerId, "connections.inputConnections.motor_id": motorId },
|
|
|
|
|