• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

GPRS(Air202) Lua开发: 物联网MQTT ,继电器远程控制 - 杨奉武

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

GPRS(Air202) Lua开发: 物联网MQTT ,继电器远程控制

 

 

 

 

硬件

 

 

 

 

协议规定

上位机同时控制两路继电器协议:  "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客户端数据接收处理
-- @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_4,0)
RelayPin1In = pio.P0_4

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"}

 

 

 

 


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Lua面向对象设计发布时间:2022-07-22
下一篇:
GPRS(Air202) Lua开发: GPIO输入检测 - 杨奉武发布时间:2022-07-22
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap