video-tools-server/service/config_mgr/init.lua

local skynet = require "skynet"
local s = require "service"
local mysql = require "skynet.db.mysql"
local runconfig = require("run_config")
local cjson = require "cjson"
local tools = require "tools"
local db = nil
local config = {
    config_info = {
        ["1"] = {  --片头
            [2]={
                name = "横屏 16:9",
                is_ban = 0,
                classification_id = 2,
                describe = "",
            },
            [1]={
                name = "竖屏 9:16",
                is_ban = 0,
                classification_id = 1,
                describe = "",
            }
        },
        ["2"] = { --正片
            [2]={
                name = "横屏 16:9",
                is_ban = 0,
                classification_id = 2,
                describe = "",
            },
            [1]={
                name = "竖屏 9:16",
                is_ban = 0,
                classification_id = 1,
                describe = "",
            }
        },
        ["3"] = { --片尾
            [2]={
                name = "横屏 16:9",
                is_ban = 0,
                classification_id = 2,
                describe = "",
            },
            [1]={
                name = "竖屏 9:16",
                is_ban = 0,
                classification_id = 1,
                describe = "",
            }
        },
        ["4"] = { --bgm音频
            [1]={
                name = "全部",
                is_ban = 0,
                classification_id = 1,
                describe = "",
            }
        },
        ["5"] = { --片尾音频
            [1]={
                name = "全部",
                is_ban = 0,
                classification_id = 1,
                describe = "",
            }
        },
        ["6"] = { --图片
            [1]={
                name = "全部",
                is_ban = 0,
                classification_id = 1,
                describe = "",
            }
        },
        ["7"] = { --角标
            [1]={
                name = "全部",
                is_ban = 0,
                classification_id = 1,
                describe = "",
            }
        },
        ["8"] = { --底纹
            [1]={
                name = "全部",
                is_ban = 0,
                classification_id = 1,
                describe = "",
            }
        },
    },
    permissions_info = {

    },
    other_info = {

    },
    group_info = {

    }
}



s.resp.update_permissions_info = function(msg_body,fd)
    local permissions_info = {}
    skynet.error("update_permissions_info")
    function action(isOk,list)
        local error_json = '{"code": 10000,   "msg": "更新权限失败成功"}'
        if isOk then
            if #list>0 then
                for i = 1, #list, 1 do
                    local permissions_id  = list[i].id
                    permissions_info[permissions_id] = list[i]
                end
                config.permissions_info = permissions_info;
            end
        end
        if fd~=nil then
            s.resp.updateConfigDb()
            return tools.response(fd,200,error_json)
        end

    end
    local sql = string.format("select * from permissions_list_tab")
    local res = db:query(sql)
    if res and #res > 0 then
        local tab =  {}
        if #res == 1 then
            tab[1] = tools.getDbResData(res)
        else
            tab = tools.getDbResData(res)
        end
        action(true,tab)
        skynet.error("Found data:")
    else
        action(false,nil)
        skynet.error("No data found.")
    end
end

s.resp.update_group_info = function(msg_body,fd)
    local group_info = {}
    function action(isOk,list)
        local error_json = '{"code": 10000,   "msg": "更新权限失败成功"}'
        if isOk then
            if #list>0 then
                for i = 1, #list, 1 do
                    local group_id  = list[i].id
                    group_info[group_id] = list[i]
                end
                config.group_info = group_info;
            end
        end
        if fd~=nil then
            s.resp.updateConfigDb()
            return tools.response(fd,200,error_json)
        end
    end
    local sql = string.format("select * from group_list_tab")
    local res = db:query(sql)
    if res and #res > 0 then
        local tab =  {}
        if #res == 1 then
            tab[1] = tools.getDbResData(res)
        else
            tab = tools.getDbResData(res)
        end
        action(true,tab)
        skynet.error("Found data:")
    else
        action(false,nil)
        skynet.error("No data found.")
    end
end

s.resp.update_other_info = function()
    
end

s.resp.update_config_info = function(msg_body,fd)
    local config_info = {}
    skynet.error("update_config_info")
    function action(isOk,info)
        local error_json = '{"code": 10000,   "msg": "更新权限失败"}'
        if isOk then
            config.config_info = info.info
        else
            config_info =  cjson.encode(config.config_info)
            config.config_info = config_info
            local sql = string.format("INSERT INTO classification_list_tab (info,self_id) VALUES ('%s',%d)",config_info,1)
            local res = db:query(sql)
            skynet.error(sql)
        end
        if fd~=nil then
            s.resp.updateConfigDb()
            return tools.response(fd,200,error_json)
        end

    end
    local sql = string.format("select info from classification_list_tab where self_id = 1")
    local res = db:query(sql)
    if res and #res > 0 then
        local tab =  {}
        tab = tools.getDbResData(res)
        action(true,tab)
        skynet.error("Found data:")
    else
        action(false,nil)
        skynet.error("No data found.")
    end
end

s.resp.get_config_info = function(msg_body,fd)
    -- skynet.error("config.config_info",config.config_info)
    return tools.response(fd,200,cjson.encode({code=10000,msg = "成功！",data=cjson.decode(config.config_info)}))
end

s.resp.get_permissions_info = function(msg_body,fd)
    -- local isOk,key = tools.checkData({"permissions_id"},msg_body)
    -- if not isOk then
    --     return tools.response(fd,200,cjson.encode({code=9001,msg = string.format("缺少字段： '%s'.", key)}))
    -- end

    local permissions_info = {} 
    if config.permissions_info~=nil and #config.permissions_info>0 then
        permissions_info = config.permissions_info
    end
    -- tools.dump(permissions_info)
   return tools.response(fd,200,cjson.encode({code=10000,msg = "成功！",data=permissions_info}))
end

s.resp.get_group_info = function(msg_body,fd)
    return tools.response(fd,200,cjson.encode({code=10000,msg = "成功！",data=config.group_info}))
end

s.resp.get_other_info = function(fd)
    return tools.response(fd,200,cjson.encode({code=10000,msg = "成功！",data=config.other_info}))
end

s.resp.on_recv = function (source, fd, msg_id, msg_body,user_data)
    skynet.error("接收一条客户端配置的接口 ",msg_id)
    local func = string.gsub(msg_id, '/config/', '')
    skynet.error("func",func)
    if s.resp[func] ~=nil then
        return s.resp[func](msg_body,fd)
    end
    return tools.response(fd,200,string.format("接口 %s 不存在",func))
end
s.init = function()
    if runconfig.is_debug then
        db=mysql.connect({
            host=runconfig.db_debug_config.db_tost,
            port=runconfig.db_debug_config.db_port,
            database=runconfig.db_debug_config.db_name,
            user=runconfig.db_debug_config.db_user,
            password=runconfig.db_debug_config.db_pw,
            max_packet_size = 1024 * 1024,
            on_connect = nil
        })
    else
        db=mysql.connect({
            host=runconfig.db_release_config.db_tost,
            port=runconfig.db_release_config.db_port,
            database=runconfig.db_release_config.db_name,
            user=runconfig.db_release_config.db_user,
            password=runconfig.db_release_config.db_pw,
            max_packet_size = 1024 * 1024,
            on_connect = nil
        })
    end
    if not db then
        skynet.error("failed to connect")
        skynet.exit()
    else
        skynet.error(" config success to connect to mysql server")    
        s.resp.initConfig()
    end
end
s.resp.updateConfigDb = function()
    -- skynet.fork(function()
    --     local config_info ="{}"
    --     if config.config_info~=nil and #config.config_info>0 then
    --         config_info =  cjson.encode(config.config_info)
    --     end

    --     local permissions_info ="{}"
    --     if config.permissions_info~=nil and #config.permissions_info>0 then
    --         permissions_info =  cjson.encode(config.permissions_info)
    --     end
    --     local other_info ="{}"
    --     if config.other_info~=nil and #config.other_info>0 then
    --         other_info =  cjson.encode(config.other_info)
    --     end

    --     local group_info ="{}"
    --     if config.group_info~=nil and #config.group_info>0 then
    --         group_info =  cjson.encode(config.group_info)
    --     end
    --     local sql = string.format("UPDATE video_tools_config_tab SET config_info = '%s' , permissions_info = '%s' , other_info = '%s' , group_info = '%s' WHERE id =%d",config_info,permissions_info,other_info,group_info,1)
    --     db:query(sql)
    -- end)
 
end
s.resp.initConfig = function()
    -- local sql = string.format("select * from video_tools_config_tab where id = %d ",1)
    -- local res = db:query(sql)
    -- skynet.error('folder_res_list',sql)
    -- 判断是否找到数据
    -- if res and #res > 0 then
    --     local tab =  {}
    --     tab = tools.getDbResData(res)
    --     config.config_info = cjson.decode( tab.config_info)
    --     config.group_info = cjson.decode( tab.group_info)
    --     config.permissions_info = cjson.decode( tab.permissions_info)
    --     config.other_info = cjson.decode( tab.other_info)
    -- else
        s.resp.update_config_info()
        s.resp.update_permissions_info()
        s.resp.update_group_info()
        s.resp.update_other_info()
        s.resp.updateConfigDb()
    -- end

    skynet.error("静态配置完成！")
end
s.start(...)