|
|
@ -2349,6 +2349,7 @@ cron.schedule("* * * * *", async () => {
|
|
|
|
exports.publishMotorStopStatus = async (motor_id, motor_stop_status) => {
|
|
|
|
exports.publishMotorStopStatus = async (motor_id, motor_stop_status) => {
|
|
|
|
console.log("entered publish",motor_id,motor_stop_status)
|
|
|
|
console.log("entered publish",motor_id,motor_stop_status)
|
|
|
|
const deviceTopic = `water/operation/${motor_id}`; // Target specific IoT
|
|
|
|
const deviceTopic = `water/operation/${motor_id}`; // Target specific IoT
|
|
|
|
|
|
|
|
console.log(deviceTopic,"deviceTopic")
|
|
|
|
const payload = {
|
|
|
|
const payload = {
|
|
|
|
topic: 'operation',
|
|
|
|
topic: 'operation',
|
|
|
|
object: {
|
|
|
|
object: {
|
|
|
|