123

common/dbproxy/tg_zhanghu.lua

@@ -144,7 +144,7 @@ function M.mainFilter(msg_body)
 end
 
 function M.search(msg_body)
-    local isok ,key =  tools.checkData({"advertiser_id_list","avatar_status","property_status","main_id","content","page_size","page_number","status"},msg_body)
+    local isok ,key =  tools.checkData({"advertiser_grant_balance_valid","stat_cost","advertiser_id_list","avatar_status","property_status","main_id","content","page_size","page_number","status"},msg_body)
     if not isok then
         return false,string.format("缺少字段： %s.", key)
     end
@@ -152,6 +152,25 @@ function M.search(msg_body)
     local page_number = msg_body.page_number
     local offset = (page_number - 1) * page_size
     
+
+    local advertiser_grant_balance_valid_param = ""
+    if msg_body.advertiser_grant_balance_valid~="" then
+        if msg_body.advertiser_grant_balance_valid>0 then
+            advertiser_grant_balance_valid_param = string.format(" advertiser_grant_balance_valid DESC ")
+        else
+            advertiser_grant_balance_valid_param = string.format(" advertiser_grant_balance_valid ASC ")
+        end
+    end
+
+    local stat_cost_param = ""
+    if msg_body.stat_cost~="" then
+        if msg_body.stat_cost>0 then
+            stat_cost_param = string.format(" stat_cost DESC ")
+        else
+            stat_cost_param = string.format(" stat_cost ASC ")
+        end
+    end
+
     local advertiser_id_list_param = ""
     if msg_body.advertiser_id_list~="" then
         local idString = table.concat(msg_body.advertiser_id_list, ",")
@@ -184,12 +203,17 @@ function M.search(msg_body)
         content_param = string.format(" AND  (advertiser_name LIKE CONCAT( '%%%s%%')) OR (advertiser_id LIKE CONCAT('%%%s%%'))",msg_body.content,msg_body.content)
     end
 
+    local order_param = advertiser_grant_balance_valid_param..stat_cost_param
+    if order_param == "" then
+        order_param = " id DESC "
+    end
     local param = advertiser_id_list_param..avatar_status_param..property_status_param..statuss_param..main_id_param..content_param
     local sql = "SELECT COUNT(*) AS total FROM advertiser  WHERE 1=1 "..param
     local total = mysqldbx.query(sql)
 
-    sql = "SELECT * FROM advertiser  WHERE 1=1 "..param..string.format(" ORDER BY id LIMIT %d OFFSET %d ",page_size, offset)
+    sql = "SELECT * FROM advertiser  WHERE 1=1 "..param..string.format(" ORDER BY %s LIMIT %d OFFSET %d ",order_param,page_size, offset)
     local res;
+    skynet.error(sql)
     res = mysqldbx.query(sql)
     return true,res,total[1].total
 end

service/backmgr/init.lua

@@ -53,6 +53,7 @@ local product_task = require "product_task"
 local tf_age_tpl = require "tf_age_tpl"
 local tf_region_tpl = require "tf_region_tpl"
 local no_filter_origin2 = require "no_filter_origin2"
+local tf_product_selling_points_tpl = require "tf_product_selling_points_tpl"
 local status_200 = 200
 local CMD = {
     
@@ -105,6 +106,7 @@ CMD["product_task"] = product_task;
 CMD["tf_age_tpl"] = tf_age_tpl;
 CMD["tf_region_tpl"] = tf_region_tpl;
 CMD["no_filter_origin2"] = no_filter_origin2;
+CMD["tf_product_selling_points_tpl"] = tf_product_selling_points_tpl;
 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/tf_product_selling_points_tpl.lua

@@ -0,0 +1,47 @@
+--投放产品卖点模版
+
+local M = {}
+local mysqldbx = require "mysqldbx"
+local tools = require "tools"
+local skynet = require "skynet"
+
+
+function M.add(msg_body)
+    local isok ,key =  tools.checkData({"name","selling_points","call_to_action_buttons","status"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+    local sql = string.format("INSERT INTO `tf_product_selling_points_tpl` (name,selling_points,call_to_action_buttons,status)  VALUES ('%s','%s','%s',%d)",msg_body.name,msg_body.selling_points,msg_body.call_to_action_buttons,msg_body.status)
+    skynet.error(sql)
+    mysqldbx.query(sql)
+    return true, {}
+end
+
+
+function M.modify(msg_body)
+    local isok ,key =  tools.checkData({"name","selling_points","call_to_action_buttons","status","id"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+    local sql = string.format("UPDATE  tf_product_selling_points_tpl SET name = '%s' , selling_points = '%s' , call_to_action_buttons = '%s' , status = %d WHERE id = %d ",msg_body.name,msg_body.selling_points,msg_body.call_to_action_buttons,msg_body.status,msg_body.id)
+    mysqldbx.query(sql)
+    return true, {}
+end
+
+function M.search(msg_body)
+    local isok ,key =  tools.checkData({"page_size","page_number"},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 sql = "SELECT * FROM tf_product_selling_points_tpl "..string.format(" LIMIT %d OFFSET %d ",page_size, offset)
+    local list = mysqldbx.query(sql)
+    sql = "SELECT   COUNT(*) AS total  FROM tf_product_selling_points_tpl "
+    local total = mysqldbx.query(sql)
+    return true,list,total[1].total
+end
+
+return M

service/backmgr/video_material.lua

@@ -57,6 +57,8 @@ end
 --sync_status 状态
 function M.search(msg_body)
     local isok ,key =  tools.checkData({
+    "id_list",
+    "material_id_list",
     "qc_upload_status",
     "qc_is_upload",
     "material_platform",
@@ -170,12 +172,23 @@ function M.search(msg_body)
         genre_param =  string.format(" AND genre = %d ",tonumber(msg_body.genre)) 
     end
 
+    local id_list_param = ""
+    if msg_body.id_list~="" then
+        local idString = table.concat(msg_body.id_list, ",")
+        id_list_param =string.format(" AND id IN (%s) ",idString)
+    end
 
     local material_id_param = ""
     if msg_body.material_id~="" then
         material_id_param =  string.format(" AND id = %d ",tonumber(msg_body.material_id)) 
     end
 
+    local material_id_list_param = ""
+    if msg_body.material_id_list~="" then
+        local idString = table.concat(msg_body.material_id_list, ",")
+        material_id_list_param =string.format(" AND material_id IN (%s) ",idString)
+    end
+
     local oce_material_id_list_param = ""
     if msg_body.oce_material_id_list~="" then
         local idString = table.concat(msg_body.oce_material_id_list, ",")
@@ -330,7 +343,7 @@ function M.search(msg_body)
 
     local new_param = stat_cost_param..show_cnt_param..click_cnt_param..convert_cnt_param..cvr_param..ctr_param
     -----
-    local param = qc_is_upload_param..qc_upload_status_param..material_platform_param..bl_status_param..publish_time_param..yun_fabu_time_param..opt_time_param..exe_review_person_id_param..word_param..genre_param..date_param..product_param..oce_material_id_list_param..status_param..tg_platform_param..sync_status_param..product_name_param..is_auto_param..material_id_param..signature_param..dy_id_1_param..artificial_status_param..machine_review_status_param..is_sexual_inducement_content_param..is_bad_value_view_param..user_id_param
+    local param = qc_is_upload_param..qc_upload_status_param..material_platform_param..bl_status_param..publish_time_param..yun_fabu_time_param..opt_time_param..exe_review_person_id_param..word_param..genre_param..date_param..product_param..material_id_list_param..oce_material_id_list_param..status_param..tg_platform_param..sync_status_param..product_name_param..is_auto_param..id_list_param..material_id_param..signature_param..dy_id_1_param..artificial_status_param..machine_review_status_param..is_sexual_inducement_content_param..is_bad_value_view_param..user_id_param
 
     local up_down_param = d_z_param..comment_param..forward_param..collect_param..new_param