大彩串口屏4G应用- TCP单连接

发布人：大彩科技发布日期：2021-10-21

--[[*********************************************************************
** Function name:  on_init
** Descriptions :  系统初始化时，执行此回调函数。
*********************************************************************--]]
function on_init() 
    dofile('air724at.lua') --加载 http.lua 文件
    uart_set_baudrate3(115200) --设置与4G模块通讯的串口3的波特率为115200

    --设置4G库函数的命令发送函数，命令回调函数、调试信息打印函数
    air_set_callback(on_air_send_cb,on_air_resp_callback,on_air_log_cb)
    air_hw_int() --4G模块初始化设置
    --开启自动获取型号强度、时间、天气功能
    start_timer(timerId_Sig_Weather, 1000 , 0, 0)
end

--[[*********************************************************************
** Function name:  on_timer
** Descriptions :  定时器超时回到调函数。
** @ timer_id    :  定时器ID
*********************************************************************--]]
function on_timer(timer_id)
    on_air_timer(timer_id) --4G库函数的定时处理

    --定时获取信号强度
    if timer_id == timerId_Sig_Weather
    then
        --定时器计数，timer0_notify_cnt 每秒+1。
        timer0_notify_cnt = timer0_notify_cnt + 1 
        if timer0_notify_cnt%15 == 0
        then
            --每15s调用一次，更新信号值
            at_cops_csq()
            timer0_notify_cnt = 0 --标志位清空
        end
    end
end

--[[*********************************************************************
** Function name : at_cops_csq
** Descriptions  : 获取运营商信息、信号强度
** @return       : nil,无返回值
*********************************************************************--]]
function at_cops_csq()
    air_cmd_add('AT+COPS?','OK',1000) –获取运营商
    air_cmd_add('AT+CSQ'  ,'OK',1000) –获取信号
end

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

--***********************************************************************
    --功能：    判断 key
    --          如果 key 为空，则退出函数。
    --          因为 key 为空时，下方 string.find( key , ) 是不正确的使用。
    --          以下key的处理必须不为空，
    --********************************************************************
    if key == nil 
    then
        return
    end

    ...... 
    --******************************************************************
    --条件：    4G初始化完成
    --功能：    使用使用AT指令获取信号强度和运营商。
    --调用函数：at_cops_csq()
    --函数功能：获取信号强度和运营商
    --调用函数：at_tcp_client_cofig()
    --函数功能：TCP配置
     *********************************************************************
    if string.find(key,'+SAPBR=1,1') ~= nil and string.find(value,'OK') ~= nil 
    then
        at_cops_csq()
        at_tcp_client_cofig()
    end

    --********************************************************************
    --条件：    4G模块返回运营商信息
    --功能：   
    --********************************************************************
    if string.find(key,'+COPS') ~= nil and string.find(value,'+COPS') ~= nil
    then
        --****************************************************************
        --value    ： +COPS: 0,2,"46000",7
        --要提取的值：46000
        --正则表达式： '+COPS:.*,.*,"(%d*)"'
        --****************************************************************
        local regular_e = '+COPS:.*,.*,"(%d*)"'--正则表达式
        --获取的值赋给 my_mobile_MCCMNC 
        local my_mobile_MCCMNC = string.match( value, regular_e )
        set_text( screen_main, 2, mobile_MCCMNC[my_mobile_MCCMNC])
    end

    --********************************************************************
    --条件：4G模块返回信号强度信息
    --功能： 
    --********************************************************************
    if string.find(key,'+CSQ')~=nil and string.find(value,'+CSQ')~=nil
    then
        --***************************************************************
        --value    ： +CSQ: 15,99
        --要提取的值：15
        --正则表达式： '+CSQ: (.*),.*' 
        --****************************************************************
        local regular_e = '+CSQ: (.*),.*' --正则表达式
        local my_csq = tonumber(string.match(value,regular_e))
        if my_csq<=11 
        then
            set_value( screen_main, 1, 1) --设置信号图标显示第1帧 
        elseif my_csq>=12 and my_csq<=13 
        then
            set_value(screen_main, 1, 2) --设置信号图标显示第2帧 
        elseif my_csq>=14 and my_csq<=15 
        then
            set_value( screen_main, 1, 3) --设置信号图标显示第3帧 
        elseif my_csq>=16 
        then
            set_value( screen_main, 1, 4) --设置信号图标显示第4帧 
        end
    end
end

--[[**********************************************************************
** Function name: on_uart_recv_data3
** Descriptions : 接收串口3数据回调函数，连接4G模块。
**********************************************************************--]]
function on_uart_recv_data3(packet)
    --4G AT指令库API
    on_air_recv_data(packet)
end

--[[*********************************************************************
** Function name:  on_air_resp_callback
** Descriptions :  4G模块-数据回调接口
** @key           :  屏幕向4G模块的发送请求
** @value        :  4G模块返回的数据
*********************************************************************--]]
function on_air_resp_callback(key, value)
    ......
    --******************************************************************
    --条件：    4G初始化完成
    --功能：    使用使用AT指令获取信号强度和运营商。
    --调用函数：at_cops_csq()
    --函数功能：获取信号强度和运营商
    --调用函数：at_tcp_client_cofig()
    --函数功能：TCP配置
    --*****************************************************************
    if string.find(key,'+SAPBR=1,1') ~= nil and string.find(value,'OK') ~= nil 
    then
        .......
        at_tcp_client_cofig()
    end
end

--[[*********************************************************************
** Function name : at_tcp_client_cofig
** Descriptions  : TCP配置
** @return       : nil,无返回值
******************************************************************** --]]
function at_tcp_client_cofig(connect) 
    local function my_get_ip_cb(key, value)

        if string.find(key,'+CIFSR') ~= nil and value ~= nil 
        then
        Tcp_ip = value
        set_text(sc_Tcp, 1, Tcp_ip)
        end
    end

    local function my_ip_state(key, value)
        air_log('my debugMsg key   -> '..key)
        air_log('my debugMsg value -> '..value)

        if string.find(key,'+CIPSTATUS') ~= nil 
            and string.find(value,'IP STATUS') ~= nil 
        then
            Tcp_state = 1
            air_log('at_tcp_client_cofig success !!!!!!')
        end
    end

    if connect == nil
    then
        connect = 0
    end
    air_cmd_add('AT+CREG=1', 'OK', 1000, 3) --设置当前GPRS注册状态
    air_cmd_add('AT+CGREG=1', 'OK', 1000, 3) --设置当前GPRS注册状态
    air_cmd_add('AT+CGATT=1', 'OK', 1000, 3) --设置当前GPRS附着状态
    air_cmd_add('AT+CIPMUX='.. connect, 'OK', 1000, 3) --设置为单、多链接模式

    --设置为快发模式（推荐使用这种模式）
    air_cmd_add('AT+CIPQSEND=1', 'OK', 1000, 3)
    air_cmd_add('AT+CSTT?', 'OK', 1000, 3) --启动任务，查看APN
    air_cmd_add('AT+CSTT="CMIOT"', 'OK', 1000, 3) --启动任务，设置APN

    air_cmd_add('AT+CIICR', 'OK', 1000, 3) --激活移动场景
    air_cmd_add('AT+CIFSR' , 'OK', 1000, 3, my_get_ip_cb) --查询分配的IP地址

    air_cmd_add('AT+CIPSTATUS' , 'STATE: IP STATUS', 1000, 3, my_ip_state) --查询下链接状态

end

--[[*********************************************************************
** Function name : at_tcp_client_connect
** Descriptions  : 设置接收模式
** @head         : 是否显示头部
** @showtp       : 是否显示协议
** @srip         : 是否显示IP、端口
** @return       : nil,无返回值
*********************************************************************--]]
function at_set_tcp_recv_mode(head, showtp,srip)
    air_cmd_add('AT+CIPHEAD='..head,      'OK', 1000, 3) --显示头部
    air_cmd_add('AT+CIPSHOWTP='..showtp,  'OK', 1000, 3) --显示协议
    air_cmd_add('AT+CIPSRIP='..srip,      'OK', 1000, 3) --显示IP、端口
end

--[[*********************************************************************
** Function name : at_tcp_client_connect
** Descriptions  : 连接服务器
** @mode         : 连接模式，TCPUPD
** @server_ip    : 服务器地址
** @port         : 服务器端口
** @return       : nil,无返回值
********************************************************************--]]
function at_tcp_client_connect(mode, server_ip, port)
    --连接服务器
    air_cmd_add(
        'AT+CIPSTART="'..mode..'",'..'"'..server_ip..'",'..port, 
        'OK', 
        1000,
        3)
    --查询当前GPRS注册状态
    air_cmd_add('AT+CIPSTATUS', 'STATE: CONNECT OK', 1000, 3) 

end
--[[*********************************************************************
** Function name : on_control_notify
** Descriptions  : 系统回调函数，用户通过触摸修改控件后，执行此回调函数。
**                 点击按钮控件，修改文本控件、修改滑动条都会触发此事件。
** @return       : nil,无返回值
********************************************************************--]]
function on_control_notify(screen,control,value)
    if screen == sc_Tcp 
    then
        if control == 4 and value == 0 and Tcp_state == 1
        then
            Tcp_server_ip = get_text(sc_Tcp, 3)
            Tcp_server_port = get_text(sc_Tcp, 3)
            at_tcp_client_connect('TCP', Tcp_server_ip, Tcp_server_port) --连接服务器
            at_set_tcp_recv_mode(1, 1, 1)              --设置接收模式
        ......
        end

    end
end

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

--[[*********************************************************************
** Function name : at_tcp_send
** Descriptions  : TCP、发送数据到服务端
** @str          : 发送数据
** @return       : nil,无返回值
********************************************************************--]]
function at_tcp_send(str)
    air_cmd_add('AT+CIPSEND='..string.len(str) , '>', 1000, 3)
    air_cmd_add(str, 'DATA ACCEPT', 1000, 3)
end

--[[*********************************************************************
** Function name: split
** Descriptions : 切割字符串
** @ str          : 源字符串
** @ pat          : 分割符号
*********************************************************************--]]
function split(str, pat)
    local t = {}
    local last_end = 0
    local s, e = string.find(str, pat, 1) --第一个分割号
    local i = 1
    while s do
        table.insert(t, string.sub(str, last_end + 1, last_end + s - last_end - 1))
        last_end = e
        s, e = string.find(str, pat, last_end + 1)
        i = i + 1
    end
    if last_end <= #str then
        cap = string.sub(str, last_end + 1)
        table.insert(t, cap)
    end
    return t  
end

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

    ...... 
    if value ~= nil
    then
        if string.find(value,'FROM') ~= nil 
        then
            --+RECV FROM: 60.166.12.210:7500
            --分割成3份，分别为+RECV FROM、60.166.12.210、7500
            local serverInfo = split(value,':')
            set_text(sc_Tcp, 7, serverInfo[2]) –- ip
            set_text(sc_Tcp, 8, serverInfo[3]) –-端口

        elseif  string.find(value,'IPD') ~= nil 
        then
            --+IPD,TCP,10:123456789
            --分割成2份，分别为+IPD,TCP,10、123456789
            local serverData = split(value,':')
            set_text(sc_Tcp, 9, serverData[2]) -- 数据内容
        end
    end
    ......
end