require "log"
require "sys"
require "bit"
siganl = require 'posix.signal'
syswait = require 'posix.sys.wait'
unistd = require 'posix.unistd'
lua_pack = require("lua_pack")
dyutils = require("dyutils")


--[[ 

 55 aa 00 00 00 01 00 da 00 00 00 00 00 00 a2 01 00 00 a2 01 

 75 75 75 75 75 75 75 75 75 75 75 75 75 75 75 75 
 80 00 20 00 03 01 01 02 00 00 00 00 00 00 00 00 A2 01 00 00 00 00 00 00 00 00 00 00 
 节目
 00 76 01 00 00 02 02 00 00 01 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 

 01 BA 00 00 00 E5 01 01 00 00 00 00 00 00 00 00 7F 00 0F 00 00 00 00 00 00 00 00 00 00 00 00 00 02 9A 00 00 00 0E 04 00 

 字体颜色
 10 10 00 03 00 00 00 00 43 00 3A 00 5C 00 55 00 

 特效
 61 FF 0C FF 03 00 00 00 00 00 7F 00 0F 00 01 00 10 00 00 FF 
 61 FF 0C FF 03 00 00 00 00 00 7F 00 0F 00 01 00 10 00 00 FF 
 61 FF 0C FF 03 00 00 00 00 00 7F 00 0F 00 01 00 10 00 00 FF 
 61 FF 0C FF 03 00 00 00 00 00 7F 00 0F 00 01 00 02 00 00 FF 
 数据
 BC F2 BD DD A3 AC BC F2 BD DD A3 AC BC F2 BD DD 
 A3 AC BC F2 BD DD A3 AC BC F2 BD DD A3 AC BC F2 
 BD DD BC F2 BD DD A3 AC BC F2 BD DD A3 AC BC F2 
 BD DD 
 
 02 A2 00 00 00 E5 01 01 00 00 00 00 00 00 10 00 7F 00 1F 00 00 00 00 00 00 00 00 00 00 00 00 00 02 82 00 00 00 0E 03 00 10 10 00 03 00 00 00 00 43 00 3A 00 5C 00 55 00 
 61 FF 0C FF 03 00 00 00 00 00 7F 00 0F 00 01 00 10 00 00 FF 
 61 FF 0C FF 03 00 00 00 00 00 7F 00 0F 00 01 00 10 00 00 FF 
 61 FF 0C FF 03 00 00 00 00 00 7F 00 0F 00 01 00 0E 00 00 FF 
 32 32 32 32 32 32 33 33 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 32 
 
 00 00 0d 0a


 {"identifier":"push","up":"BCF2BDDDBCD3D3CD","sn":"test","mi":38880829,"down":"363636363636","timestamp":1632487428,"ip_addr":"192.168.20.112","port":10000,"term_addr":""}
 ]]

local areas_table = 
{
    
    {x = 0, y = 0, xx = 0x7F, xy = 0x0F},
    {x = 0, y = 0x10, xx = 0x7F, xy = 0x1F}
}

HIGH = 0x80
WIDTH = 0x20
CLR = 3
GRAY = 1
STORE = 2

local function gen_show(item, cnt)
    local result = bpack("I4<S2C4I2<II2A", 0, 0, 0, 0, HIGH, WIDTH, CLR, GRAY, cnt, STORE, 0, 0, #item + 44, 0, 0, item)
    return result
end

local function gen_item(no, area_data, area_cnt)
    local result = bpack("C<IC2<SCI4A", no, #area_data + 26, 0x02, area_cnt, 0, 1, 0, 0, 0, 0, area_data)
    return result
end

local function gen_area(no, data)
    local len = #data
    local page_cnt = math.ceil(len/16)
    local mod = math.fmod(len, 16)
    local total_len = 20 * page_cnt + len + 56

    local t = bpack("C4<S<S4CC<SC2", 0x61, 0, 0x0c, 0x0, 0x3, 0, 0, 0x7F, 0x0F, 1, 0, 16, 0, 0)
    local t_mod = bpack("C4<S<S4CC<SC2", 0x61, 0, 0x0c, 0x0, 0x3, 0, 0, 0x7F, 0x0F, 1, 0, mod, 0, 0)

    local result = ""
    for i=1, page_cnt - 1 do
        result = bpack("AA", result, t)
    end
    result = bpack("AAA", result, t_mod, data)
    result = bpack("C4I3A", 0x10, 0x10, 0, 0x03, 0, 0, 0, result)

    local t = bpack("C<IC3I<S4", no, total_len, 0xe5, 0x01, 0x01, 0, areas_table[no].x, areas_table[no].y, areas_table[no].xx, areas_table[no].xy)
    
    result = bpack("AI3CIC<SA", t, 0, 0, 0, 0x02, total_len - 32, 0x0e, page_cnt, result)

    print("area:", no, string.toHex(result))

    return result
end

function protocol_encode(json_str, len)
    print("json_str", json_str)
    local err_code = 0
    -- 取出入参--
    local obj = cjson.decode(json_str)
    local id = obj.identifier

    -- 编码--
    local up = obj.up
    local down = obj.down
    local up_raw_data = string.fromHex(up)
    local up_data = gen_area(1, up_raw_data)
    local down_raw_data = string.fromHex(down)
    local down_data = gen_area(2, down_raw_data)
    local area = bpack("AA",up_data, down_data)
    local item = gen_item(0, area, 2)
    local show = gen_show(item, 1)

    -- 出参格式化--
    bin_str = string.toHex(show)
    print(err_code, bin_str, #bin_str)
    return err_code, bin_str, #bin_str
end

function protocol_decode(input_str, len)
    local err_code = 0
    -- 取出入参--
    local obj = {}
    local input_obj = cjson.decode(input_str)
    local bin_str = input_obj.raw_data
    local id = input_obj.identifier
    -- 入参中的raw_data的二进制转换--
    bin_str = string.fromHex(bin_str)
    -- 分割位域--
    local err_data = string.sub(bin_str, 21)

    local _, err_code = bunpack(err_data, "<I")
    print("error code ", err_code)
    obj['code'] = err_code
    if err_code == 1 then
        obj['msg'] = "通讯完成并成功。"
    elseif err_code == 132 then
        obj['msg'] = "操作码错误"
    elseif err_code == 130 then
        obj['msg'] = "帧序号错误 1.在通讯传输过程中发生帧序号不连续的情况"
    elseif err_code == 169 then
        obj['msg'] = "帧长度超过要求的最大尺寸"
    elseif err_code == 166 then
        obj['msg'] = "帧头错误，不符合通讯协议规定的帧头格式值"
    else
        obj['msg'] = "请参考手册"
    end

    local json_str = cjson.encode(obj)
    print(err_code, json_str, #json_str)
    return err_code, json_str, #json_str
end

-- protocol_encode('{"identifier":"push","up":"BCF2BDDDBCD3D3CD","sn":"test","mi":38880829,"down":"363636363636","timestamp":1632487428,"ip_addr":"192.168.20.112","port":10000,"term_addr":""}', 0)
-- protocol_decode('{"raw_data":"55AA0000000000DA0000000000000400000004000100000000000D0A","identifier":""}',74)