123

service/backmgr/filter_task.lua

@@ -298,7 +298,7 @@ end
 --添加书籍数据
 function M.add_book_data(msg_body)
     local isok ,key =  tools.checkData({"tg_platform_id","product_id","product_name"
-    ,"genre","is_store"},msg_body)
+    ,"genre","is_store","start_chapter"},msg_body)
     if not isok then
         return false,string.format("缺少字段： %s.", key)
     end
@@ -311,11 +311,11 @@ function M.add_book_data(msg_body)
         return false,"书籍已存在！"
     end
 
-    sql = string.format("INSERT INTO `video_product` (book_platform,product_id, product_name, genre,is_store,is_auto)  VALUES (%d,'%s','%s',%d,%d,0)",
+    sql = string.format("INSERT INTO `video_product` (book_platform,product_id, product_name, genre,is_store,is_auto,start_chapter)  VALUES (%d,'%s','%s',%d,%d,0,%d)",
     msg_body.tg_platform_id,
     msg_body.product_id,
     msg_body.product_name,
-    msg_body.genre,msg_body.is_store)
+    msg_body.genre,msg_body.is_store,msg_body.start_chapter)
 
     res = mysqldtaskbx.Singleton().query(sql)
     return true,{}

service/backmgr/material_review.lua

@@ -1,17 +1,72 @@
---素材审核表
+--推广
 local M = {}
 local mysqldbx = require "mysqldbx"
 local tools = require "tools"
 local skynet = require "skynet"
-local mysql = require "skynet.db.mysql"
-local config = require "run_config"
 local cjson = require "cjson"
+local config = require "run_config"
 local db
-local mysqldtaskbx = {}
+--设置推广状态
+function M.set_tui_guang_status(msg_body)
+    local isok ,key =  tools.checkData({"id_list","status"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+
+    local idString = table.concat(msg_body.id_list, ",")
+    local sql = string.format("SELECT * FROM video_material WHERE id IN (%s)",idString)
+    local isok,res;
+    res = mysqldbx.query(sql)
+
+    for i = 1, #res, 1 do
+        local id =   res[i].id
+        local material_id = res[i].material_id
+        sql = string.format("UPDATE  video_material SET status = %d WHERE id =%d ",msg_body.status,id)
+        mysqldbx.query(sql)
+    end
+    
+    return true,{}
+end
+
+--设置审核状态
+function M.set_artificial_status(msg_body)
+    local isok ,key =  tools.checkData({"id_list","artificial_status","user_id"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+
+    local idString = table.concat(msg_body.id_list, ",")
+    local sql = string.format("SELECT * FROM video_material WHERE id IN (%s)",idString)
+    local isok,res;
+    res = mysqldbx.query(sql)
+
+    for i = 1, #res, 1 do
+        local id =   res[i].id
+        sql = string.format("UPDATE  video_material SET artificial_status = %d , exe_review_person_id = %d WHERE id =%d ",msg_body.artificial_status,msg_body.user_id,id)
+        mysqldbx.query(sql)
+    end
+    
+    return true,{}
+end
 
+--搜索推广数据
+--oce_material_id 推广素材id
+--book_platform 平台id
+--product_id 书id
+--sync_status 状态
 function M.search(msg_body)
-    local isok ,key =  tools.checkData({"page_size","page_number","material_id","oce_material_id",
-    "is_sexual_inducement_content","is_bad_value_view","start_time_date","end_time_date"},msg_body)
+    local isok ,key =  tools.checkData({"min_book_word","max_book_word","genre","end_time_date",
+    "start_time_date",
+    "sync_status",
+    "product_id",
+    "tg_platform_id",
+    "oce_material_id",
+    "product_name",
+    "material_id",
+    "page_size",
+    "page_number",
+    "dy_id",
+"d_z","comment","collect","forward","status","signature","dy_id_1","artificial_status","machine_review_status","is_sexual_inducement_content","is_bad_value_view","user_id"},msg_body)
     if not isok then
         return false,string.format("缺少字段： %s.", key)
     end
@@ -19,70 +74,222 @@ function M.search(msg_body)
     local page_number = msg_body.page_number
     local offset = (page_number - 1) * page_size
 
+    local user_id_param = ""
+    if msg_body.user_id~="" then
+        user_id_param = string.format(" AND user_id = %d ",tonumber(msg_body.user_id)) 
+    end
+
+    local word_param = ""
+    if msg_body.min_book_word~="" and msg_body.max_book_word~="" then
+        word_param =  string.format(" AND CAST(words AS UNSIGNED) >= %f  AND CAST(words AS UNSIGNED) <= %f ",msg_body.min_book_word,msg_body.max_book_word)
+    end
+
+    local product_param = ""
+    if msg_body.product_id~="" then
+        product_param =  string.format(" AND product_id = %d ",tonumber(msg_body.product_id))
+    end
+
+
+    local product_name_param = ""
+    if msg_body.product_name~="" then
+        product_name_param = string.format("AND product_name = '%s' ",msg_body.product_name) 
+    end
+
+    local is_auto_param = ""
+    if msg_body.dy_id~="" then
+        if msg_body.dy_id~=0 then
+            is_auto_param = " AND dy_id != 0"
+        else
+            is_auto_param = " AND dy_id = 0"
+        end
+    end
+
+
+    local genre_param = ""
+    if msg_body.genre~="" then
+        genre_param =  string.format(" AND genre = %d ",tonumber(msg_body.genre)) 
+    end
+
 
     local material_id_param = ""
     if msg_body.material_id~="" then
-        material_id_param =  string.format(" AND material_id = %d ",tonumber(msg_body.material_id)) 
+        material_id_param =  string.format(" AND id = %d ",tonumber(msg_body.material_id)) 
     end
 
     local oce_material_param = ""
     if msg_body.oce_material_id~="" then
         oce_material_param =string.format("AND oce_material_id =  %d ",tonumber(msg_body.oce_material_id))
     end
+    local tg_platform_param = ""
+    if msg_body.tg_platform_id~="" then
+        tg_platform_param = " AND book_platform = "..msg_body.tg_platform_id.." "
+    end
+
+    local date_param = ""
+    if msg_body.start_time_date~="" and msg_body.end_time_date~="" then
+        date_param = " AND DATE(create_at) >= DATE(FROM_UNIXTIME(" .. (msg_body.start_time_date / 1000) .. ")) AND DATE(create_at) <= DATE(FROM_UNIXTIME(" .. (msg_body.end_time_date / 1000) .. "))"
+    end
+
+    local sync_status_param = ""
+
+    if msg_body.sync_status~="" then
+        sync_status_param = " AND sync_status = "..msg_body.sync_status.." "
+    end
+
+
+    local status_param = ""
+
+    if msg_body.status~="" then
+        status_param = " AND status = "..msg_body.status.." "
+    end
+
+    local artificial_status_param = ""
+    if msg_body.artificial_status~="" then
+        artificial_status_param = " AND artificial_status = "..msg_body.artificial_status.." "
+    end
+
+    local machine_review_status_param = ""
+    if msg_body.machine_review_status~="" then
+        machine_review_status_param = " AND machine_review_status = "..msg_body.machine_review_status.." "
+    end
 
     local is_sexual_inducement_content_param = ""
     if msg_body.is_sexual_inducement_content~="" then
-        is_sexual_inducement_content_param = "AND is_sexual_inducement_content = "..msg_body.is_sexual_inducement_content.." "
+        is_sexual_inducement_content_param = " AND is_sexual_inducement_content = "..msg_body.is_sexual_inducement_content.." "
     end
 
     local is_bad_value_view_param = ""
     if msg_body.is_bad_value_view~="" then
-        is_bad_value_view_param = "AND is_bad_value_view = "..msg_body.is_bad_value_view.." "
+        is_bad_value_view_param = " AND is_bad_value_view = "..msg_body.is_bad_value_view.." "
     end
 
-    local date_param = ""
-    if msg_body.start_time_date~="" and msg_body.end_time_date~="" then
-        date_param = " AND DATE(create_at) >= DATE(FROM_UNIXTIME(" .. (msg_body.start_time_date / 1000) .. ")) AND DATE(create_at) <= DATE(FROM_UNIXTIME(" .. (msg_body.end_time_date / 1000) .. "))"
+    local signature_param = ""
+    if msg_body.signature~="" then
+        signature_param = string.format("AND signature = '%s' ",msg_body.signature)
     end
 
-    local param = material_id_param..oce_material_param..is_sexual_inducement_content_param..is_bad_value_view_param..date_param
+    local dy_id_1_param = ""
+    if msg_body.dy_id_1~="" then
+        dy_id_1_param = " AND dy_id =  "..tonumber(msg_body.dy_id_1)
+    end
 
-    local sql = "SELECT * FROM video_material_review where 1=1 "..param..string.format(" LIMIT %d OFFSET %d ",page_size, offset)
-    skynet.error("sql:",sql)
-    local list = mysqldtaskbx.Singleton().query(sql)
-    sql = "SELECT   COUNT(*) AS total  FROM video_material_review where 1=1 "..param
-    local total = mysqldtaskbx.Singleton().query(sql)
-    return true,list,total[1].total
-end
+    local d_z_param = ""
+    if msg_body.d_z~="" then
+        if(msg_body.d_z == 0) then
+            d_z_param = " d_z_number ASC"
+        else
+            d_z_param = " d_z_number DESC"
+        end
+    end
+   
+    local comment_param = ""
+    if msg_body.comment~="" then
+        if(msg_body.comment == 0) then
+            comment_param = " comment_number ASC"
+        else
+            comment_param = " comment_number DESC"
+        end
+    end
 
-function mysqldtaskbx.start()
-    local function on_connect(db)
-        db:query("set charset utf8mb4");
-    end
-    local conf = config.db_cnf.book_server.mysqldb_material_review_cnf
-    db = mysql.connect{
-        host=conf.ip,
-        port=conf.port,
-        database=conf.db,
-        user=conf.user,
-        password=conf.password,
-        charset="utf8mb4",
-        max_packet_size = 1024 * 1024,
-        on_connect = on_connect
-    }
-    if not db then
-       skynet.error("mysql connect fail")
+    local forward_param = ""
+    if msg_body.forward~="" then
+        if(msg_body.forward == 0) then
+            forward_param = " forward_number ASC"
+        else
+            forward_param = " forward_number DESC"
+        end
     end
-end
+    
+    local collect_param = ""
+    if msg_body.collect~="" then
+        if(msg_body.collect == 0) then
+            collect_param = " collect_number ASC"
+        else
+            collect_param = " collect_number DESC"
+        end
+    end
+    
 
-function mysqldtaskbx.Singleton()
-    if db == nil then
-        mysqldtaskbx.start()
+
+    -----
+    local stat_cost_param = ""
+    if msg_body.stat_cost~="" then
+        if(msg_body.stat_cost == 0) then
+            stat_cost_param = " stat_cost ASC"
+        else
+            stat_cost_param = " stat_cost DESC"
+        end
     end
-    return mysqldtaskbx
-end
-function mysqldtaskbx.query(sql)
-    return db:query(sql)
+   
+    local show_cnt_param = ""
+    if msg_body.show_cnt~="" then
+        if(msg_body.show_cnt == 0) then
+            show_cnt_param = " comment_number ASC"
+        else
+            show_cnt_param = " comment_number DESC"
+        end
+    end
+
+    local click_cnt_param = ""
+    if msg_body.click_cnt~="" then
+        if(msg_body.click_cnt == 0) then
+            click_cnt_param = " click_cnt ASC"
+        else
+            click_cnt_param = " click_cnt DESC"
+        end
+    end
+    
+    local convert_cnt_param = ""
+    if msg_body.convert_cnt~="" then
+        if(msg_body.convert_cnt == 0) then
+            convert_cnt_param = " convert_cnt ASC"
+        else
+            convert_cnt_param = " convert_cnt DESC"
+        end
+    end
+
+
+    local cvr_param = ""
+    if msg_body.cvr~="" then
+        if(msg_body.cvr == 0) then
+            cvr_param = " cvr ASC"
+        else
+            cvr_param = " cvr DESC"
+        end
+    end
+    
+    local ctr_param = ""
+    if msg_body.ctr~="" then
+        if(msg_body.ctr == 0) then
+            ctr_param = " ctr ASC"
+        else
+            ctr_param = " ctr DESC"
+        end
+    end
+
+    local new_param = stat_cost_param..show_cnt_param..click_cnt_param..convert_cnt_param..cvr_param..ctr_param
+    -----
+    local param = word_param..genre_param..date_param..product_param..oce_material_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 up_down_param = d_z_param..comment_param..forward_param..collect_param..new_param
+
+    if up_down_param ~= "" then
+        up_down_param = " ORDER BY " ..up_down_param
+    else
+        up_down_param = " ORDER BY id DESC "
+    end
+
+    local sql = "SELECT * FROM video_material  WHERE  1=1 "..param..up_down_param..string.format(" LIMIT %d OFFSET %d ",page_size, offset)
+   
+    local res = mysqldbx.query(sql)
+
+    skynet.error("sql:",sql)
+
+    sql =  "SELECT COUNT(*) AS total FROM video_material  WHERE  1=1 "..param.." ORDER BY id DESC "
+    
+    local total = mysqldbx.query(sql)
+
+    return true,res,total[1].total
 end
 
 return M

service/backmgr/video_product.lua

@@ -211,6 +211,18 @@ function M.set_video_product_genre(msg_body)
     return true, {}
 end
 
+--设置推荐章节
+function M.set_video_product_start_chapter(msg_body)
+    local isok ,key =  tools.checkData({"start_chapter","id_list"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+    local idString = table.concat(msg_body.id_list, ",")
+    local sql = string.format("UPDATE  video_product SET start_chapter = %d WHERE id IN (%s) ",msg_body.start_chapter,idString)
+    mysqldtaskbx.Singleton().query(sql)
+    return true, {}
+end
+
 function mysqldtaskbx.start()
     local function on_connect(db)
         db:query("set charset utf8mb4");