硬件
协议规定
上位机同时控制两路继电器协议: "data":"switch":开关指令; "bit":"1&2":第一路和第二路
询问两路继电器状态: {"data":"switch","bit":"1&2","status":"-1"}
控制两路继电器吸合: {"data":"switch","bit":"1&2","status":"1&1"}
控制两路继电器断开: {"data":"switch","bit":"1&2","status":"0&0"}
控制第一路吸合,第二路断开: {"data":"switch","bit":"1&2","status":"1&0"}
控制第一路断开,第二路吸合: {"data":"switch","bit":"1&2","status":"0&1"}
下位机回复两路继电器状态:
第一路断开,第二路吸合: {"data":"switch","bit":"1&2","status":"0&1"}
上位机控制一路继电器协议: "bit":"1":第一路
询问第一路继电器状态: {"data":"switch","bit":"1","status":"-1"}
询问第二路继电器状态: {"data":"switch","bit":"2","status":"-1"}
控制第一路继电器吸合: {"data":"switch","bit":"1","status":"1"}
控制第二路继电器断开: {"data":"switch","bit":"2","status":"0"}
下位机回复两路继电器状态:
第一路断开 {"data":"switch","bit":"1","status":"0"}
第二路吸合 {"data":"switch","bit":"2","status":"1"}
处理MQTT消息
--- 模块功能：MQTT客户端数据接收处理
-- @author openLuat
-- @module mqtt.mqttInMsg
-- @license MIT
-- @copyright openLuat
-- @release 2018.03.28
module(...,package.seeall)
require"pins"
local IntoFlag=false;
local JsonTable = {};--组合JSON使用
--继电器引脚
RelayPin1 = pins.setup(pio.P0_3,0)
RelayPin1In = pio.P0_3
RelayPin2 = pins.setup(pio.P0_2,0)
RelayPin2In = pio.P0_2
--记录继电器的状态,状态改变发送状态
local RelayState1;
local RelayState2;
--处理继电器数据
local function Relay(jsondata)
IntoFlag = false;
if jsondata["bit"] ~= nil then
if jsondata["bit"] =="1&2" then --两路继电器
if jsondata["status"] ~= nil then
if jsondata["status"] =="-1" then--查询
IntoFlag=true;
elseif jsondata["status"] =="0&0" then
IntoFlag=true;
RelayPin1(0);
RelayPin2(0);
elseif jsondata["status"] =="0&1" then
IntoFlag=true;
RelayPin1(0);
RelayPin2(1);
elseif jsondata["status"] =="1&0" then
IntoFlag=true;
RelayPin1(1);
RelayPin2(0);
elseif jsondata["status"] =="1&1" then
IntoFlag=true;
RelayPin1(1);
RelayPin2(1);
end
if IntoFlag==true then
JsonTable["data"] = "switch";
JsonTable["bit"] = "1&2";
JsonTable["status"] = pio.pin.getval(RelayPin1In).."&"..pio.pin.getval(RelayPin2In); --拼接继电器状态
mqttOutMsg.insertMsg(json.encode(JsonTable),1)
JsonTable = {}
end
end
elseif jsondata["bit"] =="1" then --控制第一路继电器
if jsondata["status"] ~= nil then
if jsondata["status"] =="-1" then--查询
IntoFlag=true;
elseif jsondata["status"] =="0" then
IntoFlag=true;
RelayPin1(0);
elseif jsondata["status"] =="1" then
IntoFlag=true;
RelayPin1(1);
end
if IntoFlag==true then
JsonTable["data"] = "switch";
JsonTable["bit"] = "1";
JsonTable["status"] = pio.pin.getval(RelayPin1In); --继电器状态
mqttOutMsg.insertMsg(json.encode(JsonTable),1)
JsonTable = {}
end
end
elseif jsondata["bit"] =="2" then --控制第一路继电器
if jsondata["status"] ~= nil then
if jsondata["status"] =="-1" then--查询
IntoFlag=true;
elseif jsondata["status"] =="0" then
IntoFlag=true;
RelayPin2(0);
elseif jsondata["status"] =="1" then
IntoFlag=true;
RelayPin2(1);
end
if IntoFlag==true then
JsonTable["data"] = "switch";
JsonTable["bit"] = "2";
JsonTable["status"] = pio.pin.getval(RelayPin2In); --继电器状态
mqttOutMsg.insertMsg(json.encode(JsonTable),1)
JsonTable = {}
end
end
end
end
end
local function LoopTimer(param)
if RelayState1 ~= pio.pin.getval(RelayPin1In) then--继电器状态变化,发送继电器状态
RelayState1 = pio.pin.getval(RelayPin1In)
JsonTable["data"] = "switch"
JsonTable["bit"] = "1"
JsonTable["status"] = pio.pin.getval(RelayPin1In) --继电器状态
mqttOutMsg.insertMsg(json.encode(JsonTable),1)
JsonTable = {}
end
if RelayState2 ~= pio.pin.getval(RelayPin2In) then--继电器状态变化,发送继电器状态
RelayState2 = pio.pin.getval(RelayPin2In)
JsonTable["data"] = "switch"
JsonTable["bit"] = "2"
JsonTable["status"] = pio.pin.getval(RelayPin2In) --继电器状态
mqttOutMsg.insertMsg(json.encode(JsonTable),1)
JsonTable = {}
end
end
sys.timerLoopStart(LoopTimer,1)
--- MQTT客户端数据接收处理
-- @param mqttClient，MQTT客户端对象
-- @return 处理成功返回true，处理出错返回false
-- @usage mqttInMsg.proc(mqttClient)
function proc(mqttClient)
local result,data
while true do
result,data = mqttClient:receive(2000)
--接收到数据
if result then
local jsondata,result,errinfo = json.decode(data.payload)--判断是不是json
--dup,topic,id,payload,qos,retain
if result and type(jsondata)=="table" then -- 是json数据
if jsondata["data"] ~= nil and jsondata["data"] =="switch" then
Relay(jsondata) --处理继电器
end
else
--非JSON数据
end
uart.write(1, data.payload) --串口输出接收的数据
--如果mqttOutMsg中有等待发送的数据，则立即退出本循环
if mqttOutMsg.waitForSend() then return true end
else
break
end
end
return result or data=="timeout"
end测试
打开MQTT调试助手
提示:设备的IMEI可看自己模块上的
订阅的主题: device/设备的imei号
发布的主题: user/设备的imei号
控制两路继电器吸合
{"data":"switch","bit":"1&2","status":"1&1"}
控制两路继电器断开
{"data":"switch","bit":"1&2","status":"0&0"}
