|
|
|
@ -2880,8 +2880,35 @@ exports.motoractiontest = async (req, reply) => {
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
exports.motoractiontestbeforeqc = async (req, reply) => {
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (action === "start") {
|
|
|
|
|
await this.publishMotorStopStatus(motor_id, "2");
|
|
|
|
|
} else if (action === "stop") {
|
|
|
|
|
await this.publishMotorStopStatus(motor_id, "1");
|
|
|
|
|
} else {
|
|
|
|
|
return reply.status(400).send({ success: false, message: "Invalid action" });
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return reply.send({ success: true, message: `Motor ${action} command sent.` });
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} catch (error) {
|
|
|
|
|
console.error("Error fetching data:", error);
|
|
|
|
|
return reply.status(500).send({ success: false, message: "Internal Server Error" });
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const motorIntervals = {};
|
|
|
|
|
async function calculateTotalPumpedWater(customerId, motorId, start_instance_id) {
|
|
|
|
|