904118851 8 ヶ月 前
コミット
98658410a3
2 ファイル変更24 行追加1 行削除
  1. 1 1
      common/dbproxy/tg_zhanghu.lua
  2. 23 0
      service/backmgr/filter_task.lua

+ 1 - 1
common/dbproxy/tg_zhanghu.lua

@@ -143,7 +143,7 @@ function M.search_info_by_id(msg_body)
         local sql = string.format("SELECT * FROM advertiser WHERE advertiser_id = '%s' LIMIT 1",zhang_hu_id)
         local res = mysqldbx.query(sql)
         if #res >0 then
-            temp[key] = res[1]
+            table.insert(temp,#temp,res[1])
         end
     end
     return true,temp

+ 23 - 0
service/backmgr/filter_task.lua

@@ -183,6 +183,29 @@ function M.tui_guang_zeng_liang(msg_body)
     return true,res
 end
 
+--搜索推广数据
+--oce_material_id 推广素材id
+--book_platform 平台id
+--product_id 书id
+--sync_status 状态
+function M.search_tg_data(msg_body)
+    local isok ,key =  tools.checkData({"end_time_date",
+    "start_time_date",
+    "sync_status",
+    "product_id",
+    "book_platform",
+    "oce_material_id",
+    "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 id FROM generate_video_list_tab WHERE DATE(create_time) >= DATE(FROM_UNIXTIME(" .. (msg_body.start_time_date / 1000) .. ")) AND DATE(create_time) <= DATE(FROM_UNIXTIME(" .. (msg_body.end_time_date / 1000) .. "))".." AND video_state=1"..param
+end
+
 
 --获取爆量数据总数
 function M.get_bao_liang_total()