--小程序 local M = {} local skynet = require "skynet" local mysqldbx = require "mysqldbx" local tools = require "tools" --获取所有小程序 function M.getAppList() local sql = string.format("select * from `tools_micro_app` ") local isok,res; res = mysqldbx.query(sql) if #res <= 0 then return true ,{} end return true, res end --添加小程序 function M.addApp(msg_body) local isok ,key = tools.checkData({"tg_platform_id","app_id","instance_id","name","advertiser_id","reason","audit_status","landing_page","titles","source","cpa_bid","budget"},msg_body) if not isok then return false,string.format("缺少字段: %s.", key) end local current_time = os.date("%Y-%m-%d %H:%M:%S") msg_body.create_time = current_time local sql = string.format("INSERT INTO `tools_micro_app` (tg_platform_id,app_id, instance_id, name,advertiser_id,reason,create_time,audit_status,landing_page,titles,source,cpa_bid,budget,update_time) VALUES (%d,'%s','%s','%s' ,'%s','%s','%s', '%s','%s','%s', '%s',%d, %d, '%s')", msg_body.tg_platform_id, msg_body.app_id, msg_body.instance_id,msg_body.name,msg_body.advertiser_id,msg_body.reason,msg_body.create_time,msg_body.audit_status,msg_body.landing_page,msg_body.titles,msg_body.source,msg_body.cpa_bid,msg_body.budget,msg_body.create_time) skynet.error(sql) mysqldbx.query(sql) return true end --修改小程序 function M.modifyApp(msg_body) local isok ,key = tools.checkData({"tg_platform_id","id","app_id","instance_id","name","name","advertiser_id","reason","audit_status","landing_page","titles","source","cpa_bid","budget"},msg_body) if not isok then return false,string.format("缺少字段: %s.", key) end local current_time = os.date("%Y-%m-%d %H:%M:%S") msg_body.update_time = current_time local sql = string.format("UPDATE `tools_micro_app` SET tg_platform_id =%d ,app_id ='%s' , instance_id ='%s' , name ='%s' , advertiser_id ='%s' , reason ='%s' , audit_status ='%s' , landing_page ='%s' , titles ='%s' , source ='%s' , cpa_bid =%d , budget =%d , update_time ='%s' WHERE id = %d ", msg_body.tg_platform_id,msg_body.app_id,msg_body.instance_id,msg_body.name,msg_body.advertiser_id,msg_body.reason,msg_body.audit_status,msg_body.landing_page,msg_body.titles,msg_body.source,msg_body.cpa_bid,msg_body.budget,msg_body.update_time,msg_body.id) skynet.error(sql) mysqldbx.query(sql) return true end return M