123

common/dbproxy/tg_platform.lua

@@ -34,11 +34,12 @@ end
 
 --修改平台
 function M.modifyPlatform(msg_body)
-    local isok ,key =  tools.checkData({"tg_platform_name","id"},msg_body)
+    local isok ,key =  tools.checkData({"tg_platform_name","id","filter_guajian_logic"},msg_body)
     if not isok then
         return false,string.format("缺少字段： %s.", key)
     end
-    local sql = string.format("UPDATE `tg_platform` SET  tg_platform_name = '%s'  WHERE id = %d ",
+    local sql = string.format("UPDATE `tg_platform` SET filter_guajian_logic = '%s' , tg_platform_name = '%s'  WHERE id = %d ",
+    msg_body.filter_guajian_logic,
     msg_body.tg_platform_name,msg_body.id)
     mysqldbx.query(sql)
     skynet.send("backmgr","lua","on_recv",nil,"ws_push_msg",cjson.encode({cmd="updatePlatformConfig"}))
@@ -277,6 +278,16 @@ function M.modifyMiniProgramPlatform(msg_body)
     return true,obj
 end
 
+function M.set_filter_guajian_logic(msg_body)
+    local isok ,key =  tools.checkData({"id","filter_guajian_logic"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+    local  sql = string.format("UPDATE `tg_platform` SET  filter_guajian_logic = '%s'  WHERE id = %d ",msg_body.filter_guajian_logic,msg_body.id)
+    mysqldbx.query(sql)
+    return true,{}
+end
+
 function M.getTotal()
     local sql = "SELECT COUNT(*) AS total FROM tg_platform"
     local res = mysqldbx.query(sql)

service/backmgr/filter_data.lua

@@ -104,4 +104,18 @@ function M.search_filter_data(msg_body)
 end
 
 
+function M.set_material_sync_status(msg_body)
+    local isok ,key =  tools.checkData({"id_list","material_sync_status"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+    for i = 1, #msg_body.id_list, 1 do
+        local res,sql,id;
+        id = msg_body.id_list[i]
+        sql = string.format("UPDATE  filter_data SET material_sync_status = %d WHERE id = %d ",msg_body.material_sync_status,id)
+        res = mysqldbx.query(sql)
+    end
+    return true,{}
+end
+
 return M

service/backmgr/origin_data.lua

@@ -13,6 +13,19 @@ function M.delete_origin_data_by_time(msg_body)
     local delete_time_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
 
+function M.reset_status(msg_body)
+    local isok ,key =  tools.checkData({"id_list"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+    for i = 1, #msg_body.id_list, 1 do
+        local res,sql,id;
+        id = msg_body.id_list[i]
+        sql = string.format("UPDATE  origin_data SET status = 0 WHERE id = %d ",id)
+        res = mysqldbx.query(sql)
+    end
+    return true,{}
+end
 
 function M.search_origin_data(msg_body)
     local isok ,key =  tools.checkData({"page_size","page_number","start_create_time","end_create_time","guajian_info","start_publish_time","end_publish_time","materialId"},msg_body)