123

service/backmgr/init.lua

@@ -36,6 +36,7 @@ local video_product_material = require "video_product_material"
 local aweme_auth_list = require "aweme_auth_list"
 local checks = require "checks"
 local fq_mf_book = require "fq_mf_book"
+local tg_main_price_template = require "tg_main_price_template"
 local status_200 = 200
 local CMD = {
     
@@ -70,6 +71,7 @@ CMD["video_product_material"] = video_product_material;
 CMD["aweme_auth_list"] = aweme_auth_list;
 CMD["checks"] = checks;
 CMD["fq_mf_book"] = fq_mf_book;
+CMD["tg_main_price_template"] = tg_main_price_template;
 function run(target,fun,msg_body,fd)
     if target~=nil and fun~=nil and target[fun]~=nil then
         local isok,data,total = target[fun](msg_body)

service/backmgr/task_material_queue_queue.lua

@@ -26,7 +26,7 @@ function M.set_sweight(msg_body)
 end
 
 function M.search_task_material_queue_queue(msg_body)
-    local isok ,key =  tools.checkData({"page_size","page_number","start_create_time","end_create_time",
+    local isok ,key =  tools.checkData({"butler_id","tg_main_id","page_size","page_number","start_create_time","end_create_time",
     "tg_platform_id","advertiser_id","advertiser_name","product_id","product_name","material_id","status"},msg_body)
     if not isok then
         return false,string.format("缺少字段： %s.", key)
@@ -35,6 +35,16 @@ function M.search_task_material_queue_queue(msg_body)
     local page_number = msg_body.page_number
     local offset = (page_number - 1) * page_size
 
+    local butler_id_param = ""
+    if msg_body.butler_id~="" then
+        butler_id_param =  " AND butler_id = "..msg_body.butler_id
+    end
+
+    local tg_main_id_param = ""
+    if msg_body.tg_main_id~="" then
+        tg_main_id_param =  " AND tg_main_id = "..msg_body.tg_main_id
+    end
+
     local tg_platform_id_param = ""
     if msg_body.tg_platform_id~="" then
         tg_platform_id_param =  " AND tg_platform_id = "..msg_body.tg_platform_id
@@ -77,7 +87,7 @@ function M.search_task_material_queue_queue(msg_body)
         create_date_param = " AND DATE(created_at) >= DATE(FROM_UNIXTIME(" .. (msg_body.start_create_time / 1000) .. ")) AND DATE(created_at) <= DATE(FROM_UNIXTIME(" .. (msg_body.end_create_time / 1000) .. "))"
     end
 
-    local param = tg_platform_id_param..advertiser_id_param..advertiser_name_param..product_id_param..product_name_param..material_id_param..status_param..create_date_param
+    local param = tg_main_id_param..butler_id_param..tg_platform_id_param..advertiser_id_param..advertiser_name_param..product_id_param..product_name_param..material_id_param..status_param..create_date_param
 
     local sql = "SELECT * FROM task_material_queue_queue WHERE 1=1 "..param.." ORDER BY id DESC "..string.format(" LIMIT %d OFFSET %d ",page_size, offset)
    

service/backmgr/tg_main_price_template.lua

@@ -0,0 +1,75 @@
+--主体出价模版
+local M = {}
+local mysqldbx = require "mysqldbx"
+local tools = require "tools"
+local skynet = require "skynet"
+local cjson = require "cjson"
+local config = require "run_config"
+
+function M.add_tg_main_price_template(msg_body)
+    local isok ,key =  tools.checkData({"name","tg_main_id","cpa_bid","custom_budget","no_bid_budget","tg_main_name","status"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+    local sql_param = "INSERT INTO `tg_main_price_template` (name,tg_main_id,cpa_bid,custom_budget,no_bid_budget,tg_main_name,status) "
+    local  sql = sql_param..string.format("  VALUES ('%s',%d,%d,%d,%d,'%s',%d) ",
+    msg_body.name,msg_body.tg_main_id,msg_body.cpa_bid,msg_body.custom_budget,msg_body.no_bid_budget,msg_body.tg_main_name,msg_body.status)
+    mysqldbx.query(sql)
+    return true
+end
+
+function M.modify_tg_main_price_template(msg_body)
+    local isok ,key =  tools.checkData({"id","name","tg_main_id","cpa_bid","custom_budget","no_bid_budget","tg_main_name","status"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+    local sql = string.format("UPDATE  `tg_main_price_template` SET name = '%s' ,tg_main_id = %d , cpa_bid = %d , custom_budget = %d , no_bid_budget = %d , tg_main_name = '%s' ,  status = %d  WHERE id = %d ",
+    msg_body.name,msg_body.tg_main_id,msg_body.cpa_bid,msg_body.custom_budget,msg_body.no_bid_budget
+    ,msg_body.tg_main_name,msg_body.status,msg_body.id)
+    mysqldbx.query(sql)
+    return true
+end
+
+function M.search_tg_main_price_template(msg_body)
+    local isok ,key =  tools.checkData({"page_size","page_number","name","status","tg_main_name","cpa_bid"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+    local page_size = msg_body.page_size
+    local page_number = msg_body.page_number
+    local offset = (page_number - 1) * page_size
+
+    local name_param = ""
+    if msg_body.name~="" then
+        name_param = string.format(" AND (tg_main_name LIKE '%%%s%%' ) ",msg_body.name)
+    end
+
+    local tg_main_name_param = ""
+    if msg_body.tg_main_name~="" then
+        tg_main_name_param = string.format(" AND (tg_main_name LIKE '%%%s%%' ) ",msg_body.tg_main_name)
+    end
+
+    local status_param = ""
+    if msg_body.status~="" then
+        status_param =  string.format(" AND status = %d ",msg_body.status)
+    end
+
+    local cpa_bid_param = ""
+    if msg_body.cpa_bid~="" then
+        cpa_bid_param =  string.format(" AND cpa_bid = %d ",msg_body.cpa_bid)
+    end
+
+    local param = name_param..tg_main_name_param..status_param..cpa_bid_param
+
+    local sql = "SELECT * FROM tg_main_price_template WHERE 1=1 "..param..string.format(" LIMIT %d OFFSET %d ",page_size, offset)
+   
+    local list = mysqldbx.query(sql)
+
+    sql = "SELECT   COUNT(*) AS total  FROM tg_main_price_template WHERE 1=1  "..param
+
+    local total = mysqldbx.query(sql)
+
+    return true,list,total[1].total
+end
+
+return M

service/doc/cmd_sql.sql

@@ -198,3 +198,9 @@ create table tg_mini_program_platform (
 primary key (id));
 
 
+create table ad_convert_type (  
+	id int not null auto_increment COMMENT '唯一id',
+	name  varchar(64),	
+	ad_convert_type  int,	
+	create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+primary key (id));