大彩串口屏4G应用--MQTT连接阿里云

发布人：大彩科技发布日期：2021-03-25

--[[*********************************************************************
** Function name:  on_aliyun_get_iot_token_cb
** Descriptions :  Aliyun认证回调函数
**                 成功时发送命令 AT+MCONFIG 和 AT+SSLMIPSTART
*********************************************************************--]]
function on_aliyun_get_iot_token_cb(key, value)
    ......
    mqtt_config(clientId,iotId,iotToken)
    mqtt_tcp_start(productKey ..
                 '.iot-as-mqtt.cn-shanghai.aliyuncs.com', 1883, true)
    ......
end

--[[*********************************************************************
** Function name:  on_air_resp_callback
** Descriptions :  4G模块-数据回调接口
** @key          :  屏幕->4G模块的发送请求
** @value        :  4G模块->返回的数据
*********************************************************************--]]
function on_air_resp_callback(key, value)  

    my_print('on_air_resp_callback()')
    ......
    --****************************************************************
    --条件：    连接Aliyun，AT+SSLMIPSTART 成功
    --功能：    发送AT+MCONNECT=...
    --********************************************************************
    if string.find(key, '+SSLMIPSTART') ~= nil and 
       string.find(value, 'CONNECT OK') ~= nil
    then
        my_print('mqtt_connect(1,600)')
        mqtt_connect(1,600)
    end
end

--[[*********************************************************************
** Function name:  on_air_resp_callback
** Descriptions :  4G模块-数据回调接口
** @key           :  屏幕->4G模块的发送请求
** @value        :  4G模块->返回的数据
*********************************************************************--]]
function on_air_resp_callback(key, value)  
    ......
    --********************************************************************
    --条件：     接收 Aliyun 发布消息
    --功能：     在 cloud_on_property_set(payload) 中对消息进行处理。
    --调用函数：cloud_on_property_set(payload)
    --*******************************************************************
    if string.find(key, '+MCONNECT') ~= nil 
        and string.find(value,'CONNACK OK')~=nil
   then
        mqtt_sub(
            '/sys/'..productKey..'/'..deviceName..'/thing/service/property/set',
            0 ) 
        mqtt_sub_bit = 'sub_OK'
    end
end

local params = {}
local property = {}
local post_id = 1               --屏发布的消息次数ID
--[[*********************************************************************
** Function name:  aliyun_pub
** Descriptions :  屏发布消息时，此函数处理消息内容，并发送
** @screen      : aliyun 画面ID
** @control     : 控件ID
** @value       : 控件值
** @return      : nil,无返回值
*********************************************************************--]]
function aliyun_pub(screen, control, value) 
    params   = nil
    property = nil
    params   = {} 
    property = {}
    property['method'] = 'thing.event.property.post'
    property['id'] = ''..post_id
    property['version'] = '1.0'
    post_id = post_id + 1

    if screen == screen_ac_control
    then
        --按下开关按钮
        if control == 1
        then
            local PowerSwitchName = 'powerstate'
            params[PowerSwitchName] = value --在表写入按钮数值
            property['params'] = params
            local jsonStr = cjson.encode(property)
            --发布消息
            mqtt_pub(
'/sys/'..productKey..'/'..deviceName..'/thing/event/property/post',
            0,
            0,
            jsonStr
            )
        end 
    end 
    if screen == screen_ac_control
    then
        --按下滑块
        if control == 3
        then
            local PowerSwitchName = 'filter_time'
            params[PowerSwitchName] = value --在表写入滑块数值
            property['params'] = params
            local jsonStr = cjson.encode(property)
            --发布消息
            mqtt_pub(
'/sys/'..productKey..'/'..deviceName..'/thing/event/property/post',
            0,
            0,
            jsonStr
            )
        end 
    end 

    if screen == screen_ac_control
    then
        --按下温度设置按钮，温度减
        if control == 6 and value == 1
        then
            temp_value = tonumber(get_text(screen_ac_control,4))
            temp_value = temp_value-1
            if temp_value<16 then
                temp_value = 16
            end
            set_text(screen_ac_control,4,temp_value)

        --按下温度设置按钮，温度加
        elseif control == 7 and value == 1
        then
            temp_value = tonumber(get_text(screen_ac_control,4))
            temp_value = temp_value+1
            if temp_value>32 then
                temp_value = 32
            end
            set_text(screen_ac_control,4,temp_value)
        end
        local PowerSwitchName = 'targetTemperature'
        params[PowerSwitchName] = temp_value --在表写入温度数值
        property['params'] = params     
        local jsonStr = cjson.encode(property)
        --发布消息
        mqtt_pub(
'/sys/'..productKey..'/'..deviceName..'/thing/event/property/post',
        0,
        0,
        jsonStr
        )

    end 

    if screen == screen_ac_control
    then
        if control == 10
        then
            local PowerSwitchName = 'mode'
            params[PowerSwitchName] = value
            property['params'] = params     
            local jsonStr = cjson.encode(property)    
            mqtt_pub(
'/sys/'..productKey..'/'..deviceName..'/thing/event/property/post',
            0,
            0,
            jsonStr
            )
        end 
    end 
end


--[[**********************************************************************
** Function name : on_control_notify
** Descriptions  : 系统回调函数，用户通过触摸修改控件后，执行此回调函数。
**                 点击按钮控件，修改文本控件、修改滑动条都会触发此事件。
** @return       : nil,无返回值
**********************************************************************--]]
function on_control_notify(screen,control,value)

    --********************************************************************
    --位置：    空调控制器
    --********************************************************************
    if screen == screen_ac_control 
    then
        if control == 1 or 
           control == 3 or
           control == 6 or
           control == 7 or 
           control == 10
        then
            --屏发布消息
            aliyun_pub(screen,control,value)
        end
    end
end