require "log"
require "sys"
require "utils"
require "patch"
siganl = require 'posix.signal'
syswait = require 'posix.sys.wait'
unistd = require 'posix.unistd'
mqtt=require "mosquitto"
base64=require("base64")
dyutils=require("dyutils")
require("lua_pack")
require "internal_api"

gw_sn = nil
g_nodes = {}

local function FormatLenght(format)
    local len
    if string.upper(format) == "C" then len = 1
    elseif string.upper(string.sub(format,2,2)) == "S" then len  = 2
    elseif string.upper(string.sub(format,2,2)) == "I"  then len = 4
    elseif string.upper(string.sub(format,1,1)) == "A"  then len = tonumber(string.sub(format,2))
    else
        log.warn("port2pp", "format not support",format)
        return 0
    end
    return len
end

global_point_table =
{
    {
        ----! regs.reginfo  寄存器名称(或名称的数组),寄存器地址,寄存器格式化符号,数值缩放比例
        reginfo = {"Status",6,"C"},
    },
    {
        reginfo = {"TempOfOut",298,"<S",0.1},
    },
    {
        reginfo = {"OutPower",350,"<S"},
    },
    {
        reginfo = {"OutVoltage",366,"<S",0.1},
    },
    {
        reginfo = {"ExpectPower",378,"<S"},
    },
    {
        reginfo = {"TempOfIn",380,"<S",0.1},
    },
    {
        reginfo = {"TotalGenCount",476,"<S"},
    },
    {
        reginfo = {"TotalGenTime",478,"<S"},
    },
}


---- 解包二进制数据流,检查格式
---- param@raw_data:二进制数据
function ex_unpack(raw_data)
    --取出入参--
    local obj={}
    ---- 检查数据长度
    if #raw_data < 500 then
        log.warn("ex_unpack", "raw data length error. length = ",#raw_data)
        return
    end
    local stx = string.byte(raw_data,1)
    local dir = string.byte(raw_data,2)
    local etx = string.byte(raw_data,#raw_data)
    -- ---- 检查头尾
    if stx ~= 2 or etx ~= 3 then
        log.warn("ex_unpack", "STX or EXT error. STX,ETX = ",stx,etx)
        return
    end
    ---- 检查方向
    -- if dir ~= 0 then
    --     log.warn("ex_unpack", "DIR error. STX,ETX = ",dir)
    --     return
    -- end
    return true,raw_data
end

local function port2pp(topic,payload)
    local input = cjson.decode(payload)
    if input and input.data_b64 then
        local sn = input.sn
        local raw_data = base64.decode(input.data_b64)
        if not raw_data then return end
        local identifier = "read_data"
        local gw_port = "TCPDUMP"
        -- print("response_message:",string.toHex(raw_data," "))
        local obj
        local json_str = nil
        local result,data = ex_unpack(raw_data)
        if result then
            obj = {identifier = identifier,sn=sn,mi=0}
            for _,reg in ipairs(global_point_table) do
                local key = reg.reginfo[1]
                local offset = reg.reginfo[2]
                local format = reg.reginfo[3]
                local scale = reg.reginfo[4] and reg.reginfo[4] or 1
                local len = FormatLenght(format)
                ---- 检查数据点位是否存在
                if not string.sub(data,offset + 1) then
                    log.warn("port2pp","sample point error, key:",key,"point:", offset)
                    break
                end
                ---- 将收到数据,按照点位偏移取出数值
                local _,value = bunpack(string.sub(data,offset + 1),format)
                ---- 检查数据格式,如果是数值需要乘倍数
                if type(value) == "number" then
                    obj[key] = value * scale
                else
                    obj[key] = value
                end
                err_code = 0
            end

            -- log.info("port2pp","result:",cjson.encode(obj))
            internal_api.pp2north(gw_sn,sn,gw_port,identifier,obj,0)
            return 
        end
    end
end


local function parser_period_service()
    for _,node in ipairs(nodes) do
        for _,service in ipairs(global_point_table) do
            if service.read_write == "R" and service.sample_interval and service.sample_interval > 0 then
                local period={
                        identifier = service.identifier,
                        sn = node.sn,
                        intv_sample = service.sample_interval,  -- 直接使用上报周期做采样
                        intv_report = service.report_interval,  -- 直接使用上报周期做采样
                        last_sample = 0,
                        last_report = 0
                }
                table.insert(period_list,period)
            end
        end
    end
end

local function handler()
    local pid, status, code = syswait.wait(-1, syswait.WNOHANG)
    log.error('system exit', pid, status, code) --打印不出来
    os.exit(0)
end

function main(nodes_cfg,sn)
    log.info("main_loop", "=============== fuelEnergy RUN 3.0 ============")

    gw_sn = sn
    if not gw_sn then
        -- gw_sn = io.getGatewayID()
        gw_sn = "21012C00FFFF"
    end

    log.info("main_loop",  string.format("Try Run At Shell\nsn='%s'\nnodes='%s'\nmain_loop(nodes,sn)",gw_sn or "NOT SN",nodes_cfg or ""))

    siganl.signal(siganl.SIGKILL,handler)
    siganl.signal(siganl.SIGHUP,handler)

    local devs_sn = {}
    g_nodes = cjson.decode(nodes_cfg or "{}")
    for _,node in ipairs(g_nodes) do
        table.insert(devs_sn,node.sn)  
    end
    log.info(nil,cjson.encode(devs_sn))

    internal_api.local_mqtt_session(devs_sn,"PP",nil,port2pp)

    --启动系统框架
    sys.init(0, 0)
    sys.run()
end

-- python /root/packet_cap.py tcp and ip[2:2] = 446 and src host 192.168.11.2 and src port 5000&
main(arg[1],arg[2])