904118851 4 долоо хоног өмнө
parent
commit
1c9cf2294e

+ 19 - 7
common/dbproxy/tg_main.lua

@@ -64,7 +64,7 @@ end
 
 function M.search(msg_body)
 
-    local isok ,key =  tools.checkData({"tg_app_index_list","aigc_status","title_pay_type","is_boost","is_reservation","title_type_id","is_group_record","tf_time_interval","mini_program_platform_id","is_comment","material_rule_id","parent_main_id","id","ads_operation_status","statistics_platform_id","converted_time_duration","cbo_status","project_type","oce_product_id","oce_product_platform_id","delivery_mode","material_platform_id","wx_miniapp_create_status","genre","template_bid","cpa_bid","page_size","page_number","main_name","running_status","custom_budget","pay_type","tg_platform_id","butler_id","tg_app_index","is_open_create_link","is_delete"},msg_body)
+    local isok ,key =  tools.checkData({"tf_support_status","internal_advertiser_classify","tg_app_index_list","aigc_status","title_pay_type","is_boost","is_reservation","title_type_id","is_group_record","tf_time_interval","mini_program_platform_id","is_comment","material_rule_id","parent_main_id","id","ads_operation_status","statistics_platform_id","converted_time_duration","cbo_status","project_type","oce_product_id","oce_product_platform_id","delivery_mode","material_platform_id","wx_miniapp_create_status","genre","template_bid","cpa_bid","page_size","page_number","main_name","running_status","custom_budget","pay_type","tg_platform_id","butler_id","tg_app_index","is_open_create_link","is_delete"},msg_body)
    
     if not isok then
         return false,string.format("缺少字段: %s.", key)
@@ -76,6 +76,16 @@ function M.search(msg_body)
 
     local offset = (page_number - 1) * page_size
 
+    local tf_support_status_param = ""
+    if msg_body.tf_support_status~="" then
+        tf_support_status_param =  " AND tf_support_status = "..msg_body.tf_support_status
+    end
+
+    local internal_advertiser_classify_param = ""
+    if msg_body.internal_advertiser_classify~="" then
+        internal_advertiser_classify_param =  string.format(" AND internal_advertiser_classify = '%s' ",msg_body.internal_advertiser_classify)
+    end
+
     local tg_app_index_list_param = ""
     if msg_body.tg_app_index_list~="" then
         local idString = table.concat(msg_body.tg_app_index_list, ",")
@@ -264,7 +274,7 @@ function M.search(msg_body)
         genre_param =  string.format(" AND genre = %d ",msg_body.genre) 
     end
 
-    local param =  tg_app_index_list_param..aigc_status_param..title_pay_type_param..is_boost_param..is_reservation_param..title_type_id_param..is_group_record_param..tf_time_interval_param..mini_program_platform_id_param..is_comment_param..material_rule_id_param..parent_main_id_param..id_param..ads_operation_status_param..statistics_platform_id_param..converted_time_duration_param..infra_status_param..cbo_script_status_param..cbo_status_param..project_type_param..oce_product_platform_id_param..oce_product_id_param..delivery_mode_param..main_name_param..tg_platform_param..running_status_param..pay_type_param..butler_id_param..tg_app_index_param..is_open_create_link_param..is_delete_param..custom_budget_param..cpa_bid_param..template_bid_param..genre_param..wx_miniapp_create_status_param..material_platform_id_param;
+    local param =  internal_advertiser_classify_param..tf_support_status_param..tg_app_index_list_param..aigc_status_param..title_pay_type_param..is_boost_param..is_reservation_param..title_type_id_param..is_group_record_param..tf_time_interval_param..mini_program_platform_id_param..is_comment_param..material_rule_id_param..parent_main_id_param..id_param..ads_operation_status_param..statistics_platform_id_param..converted_time_duration_param..infra_status_param..cbo_script_status_param..cbo_status_param..project_type_param..oce_product_platform_id_param..oce_product_id_param..delivery_mode_param..main_name_param..tg_platform_param..running_status_param..pay_type_param..butler_id_param..tg_app_index_param..is_open_create_link_param..is_delete_param..custom_budget_param..cpa_bid_param..template_bid_param..genre_param..wx_miniapp_create_status_param..material_platform_id_param;
 
     local sql = "SELECT * FROM tg_main where 1=1 "..param..string.format(" LIMIT %d OFFSET %d ",page_size, offset)
     local res = mysqldbx.query(sql)
@@ -288,13 +298,15 @@ end
 -- `daily_new_limit` int DEFAULT '0' COMMENT '今天新上数量上限',
 
 function M.addMain(msg_body)
-    local isok ,key =  tools.checkData({"aigc_status","title_pay_type","is_boost","is_reservation","title_type_id","is_group_record","tf_time_interval","mat_roi","reduce_roi","boost_high_price_end_time","boost_high_price_number","reduce_consume_amount","reduce_bid_amount","is_comment","member_token","zy_conifg","convert_cnt","material_rule_id","material_rule_number","parent_main_id","tg_day","valid_timer_like_num" ,"ads_operation_status","statistics_platform_id","hide_if_converted","converted_time_duration","cbo_script_time","cbo_script_status","cbo_status","project_type","tf_status","tf_start_time","min_book_word","max_book_word","stat_cost","hy_accountId","oce_product_id","oce_product_platform_id","material_platform_id","delivery_mode","advertiser_id","wx_miniapp_create_status","genre","ad_act","template_bid","zh_id","roi_goal","ql_bid","infra_status","pay_type","qm_id","ldy_template_site_id","yw_id","parent_platform_id","platform_shared_id","distributor_id","is_delete","ad_convert_type","aweme_id","tg_app_index","butler_id","mini_program_platform_id","landing_page","valid_timer_time","valid_timer_number","channelId","no_bid_budget","max_ad_quantity","tg_link_config","tg_platform_id","app_id","main_name","running_status","ad_quantity","cpa_bid","bid_type","bid_ratio","custom_budget","daily_new_limit","valid_time","group_id"},msg_body)
+    local isok ,key =  tools.checkData({"tf_support_status","internal_advertiser_classify","aigc_status","title_pay_type","is_boost","is_reservation","title_type_id","is_group_record","tf_time_interval","mat_roi","reduce_roi","boost_high_price_end_time","boost_high_price_number","reduce_consume_amount","reduce_bid_amount","is_comment","member_token","zy_conifg","convert_cnt","material_rule_id","material_rule_number","parent_main_id","tg_day","valid_timer_like_num" ,"ads_operation_status","statistics_platform_id","hide_if_converted","converted_time_duration","cbo_script_time","cbo_script_status","cbo_status","project_type","tf_status","tf_start_time","min_book_word","max_book_word","stat_cost","hy_accountId","oce_product_id","oce_product_platform_id","material_platform_id","delivery_mode","advertiser_id","wx_miniapp_create_status","genre","ad_act","template_bid","zh_id","roi_goal","ql_bid","infra_status","pay_type","qm_id","ldy_template_site_id","yw_id","parent_platform_id","platform_shared_id","distributor_id","is_delete","ad_convert_type","aweme_id","tg_app_index","butler_id","mini_program_platform_id","landing_page","valid_timer_time","valid_timer_number","channelId","no_bid_budget","max_ad_quantity","tg_link_config","tg_platform_id","app_id","main_name","running_status","ad_quantity","cpa_bid","bid_type","bid_ratio","custom_budget","daily_new_limit","valid_time","group_id"},msg_body)
     if not isok then
         return false,string.format("缺少字段: %s.", key)
     end
     local current_time = os.date("%Y-%m-%d %H:%M:%S")
     msg_body.create_time = current_time
-    local sql = string.format("INSERT INTO `tg_main` (aigc_status,title_pay_type,is_boost,is_reservation,title_type_id,is_group_record,tf_time_interval,mat_roi,reduce_roi,boost_high_price_end_time,boost_high_price_number,reduce_consume_amount,reduce_bid_amount,is_comment,member_token,zy_conifg,convert_cnt,material_rule_id,material_rule_number,parent_main_id,tg_day,valid_timer_like_num,ads_operation_status,statistics_platform_id,hide_if_converted,converted_time_duration,cbo_script_time,cbo_script_status,cbo_status,project_type,tf_status,tf_start_time,min_book_word,max_book_word,stat_cost,hy_accountId,oce_product_id,oce_product_platform_id,material_platform_id,delivery_mode,advertiser_id,wx_miniapp_create_status,genre,ad_act,template_bid,zh_id,roi_goal,ql_bid,infra_status,pay_type,qm_id,ldy_template_site_id,yw_id,parent_platform_id,platform_shared_id,distributor_id,is_delete,ad_convert_type,aweme_id,tg_app_index,butler_id,mini_program_platform_id,landing_page,valid_timer_time,valid_timer_number,channelId,no_bid_budget,max_ad_quantity,tg_link_config,tg_platform_id,app_id,main_name,running_status,ad_quantity,cpa_bid,bid_type,bid_ratio,custom_budget,daily_new_limit,valid_time,group_id)  VALUES (%d,%d, %d, %d,%d,  %d,%d,%f,%f,%d,%d,%f,%f,%d,'%s','%s',%d,%d,%d, %d,%d,%d,'%s',%d,'%s','%s','%s',%d,%d,%d,%d,'%s',%d,%d,%d,'%s','%s','%s',%d,'%s','%s',%d,%d,%d,%d,'%s',%d,%d,%d,%d,'%s','%s','%s',%d,%d,'%s',%d,'%s','%s', %d, %d, %d,'%s', %d, '%s', '%s',%d, %d, '%s', %d, '%s', '%s', %d, %d, %d,%d, '%s', %d, %d, '%s', '%s')",
+    local sql = string.format("INSERT INTO `tg_main` (tf_support_status,internal_advertiser_classify,aigc_status,title_pay_type,is_boost,is_reservation,title_type_id,is_group_record,tf_time_interval,mat_roi,reduce_roi,boost_high_price_end_time,boost_high_price_number,reduce_consume_amount,reduce_bid_amount,is_comment,member_token,zy_conifg,convert_cnt,material_rule_id,material_rule_number,parent_main_id,tg_day,valid_timer_like_num,ads_operation_status,statistics_platform_id,hide_if_converted,converted_time_duration,cbo_script_time,cbo_script_status,cbo_status,project_type,tf_status,tf_start_time,min_book_word,max_book_word,stat_cost,hy_accountId,oce_product_id,oce_product_platform_id,material_platform_id,delivery_mode,advertiser_id,wx_miniapp_create_status,genre,ad_act,template_bid,zh_id,roi_goal,ql_bid,infra_status,pay_type,qm_id,ldy_template_site_id,yw_id,parent_platform_id,platform_shared_id,distributor_id,is_delete,ad_convert_type,aweme_id,tg_app_index,butler_id,mini_program_platform_id,landing_page,valid_timer_time,valid_timer_number,channelId,no_bid_budget,max_ad_quantity,tg_link_config,tg_platform_id,app_id,main_name,running_status,ad_quantity,cpa_bid,bid_type,bid_ratio,custom_budget,daily_new_limit,valid_time,group_id)  VALUES (%d,'%s',%d,%d, %d, %d,%d,  %d,%d,%f,%f,%d,%d,%f,%f,%d,'%s','%s',%d,%d,%d, %d,%d,%d,'%s',%d,'%s','%s','%s',%d,%d,%d,%d,'%s',%d,%d,%d,'%s','%s','%s',%d,'%s','%s',%d,%d,%d,%d,'%s',%d,%d,%d,%d,'%s','%s','%s',%d,%d,'%s',%d,'%s','%s', %d, %d, %d,'%s', %d, '%s', '%s',%d, %d, '%s', %d, '%s', '%s', %d, %d, %d,%d, '%s', %d, %d, '%s', '%s')",
+    msg_body.tf_support_status,
+    msg_body.internal_advertiser_classify,
     msg_body.aigc_status,
     msg_body.title_pay_type,
     msg_body.is_boost,
@@ -498,14 +510,14 @@ function pushAddMainMsg(msg_body)
    
 end
 function M.modifyMain(msg_body)
-    local isok ,key =  tools.checkData({"aigc_status","title_pay_type","is_boost","is_reservation","title_type_id","is_group_record","tf_time_interval","mat_roi","reduce_roi","boost_high_price_end_time","boost_high_price_number","reduce_consume_amount","reduce_bid_amount","is_comment","member_token","zy_conifg","convert_cnt","material_rule_id","material_rule_number","tg_day","valid_timer_like_num","ads_operation_status","statistics_platform_id","hide_if_converted","converted_time_duration","cbo_script_time","cbo_script_status","cbo_status","project_type","tf_status","tf_start_time","min_book_word","max_book_word","stat_cost","hy_accountId","oce_product_id","oce_product_platform_id","material_platform_id","delivery_mode","advertiser_id","wx_miniapp_create_status","genre","ad_act","template_bid","zh_id","roi_goal","ql_bid","infra_status","pay_type","pay_type","qm_id","ldy_template_site_id","yw_id","parent_platform_id","platform_shared_id","distributor_id","is_delete","ad_convert_type","aweme_id","tg_app_index","butler_id","mini_program_platform_id","landing_page","valid_timer_time","valid_timer_number","channelId","no_bid_budget","max_ad_quantity","tg_link_config","id","tg_platform_id","app_id","main_name","running_status","ad_quantity","cpa_bid","bid_type","bid_ratio","custom_budget","daily_new_limit","valid_time","group_id"},msg_body)
+    local isok ,key =  tools.checkData({"tf_support_status","internal_advertiser_classify","aigc_status","title_pay_type","is_boost","is_reservation","title_type_id","is_group_record","tf_time_interval","mat_roi","reduce_roi","boost_high_price_end_time","boost_high_price_number","reduce_consume_amount","reduce_bid_amount","is_comment","member_token","zy_conifg","convert_cnt","material_rule_id","material_rule_number","tg_day","valid_timer_like_num","ads_operation_status","statistics_platform_id","hide_if_converted","converted_time_duration","cbo_script_time","cbo_script_status","cbo_status","project_type","tf_status","tf_start_time","min_book_word","max_book_word","stat_cost","hy_accountId","oce_product_id","oce_product_platform_id","material_platform_id","delivery_mode","advertiser_id","wx_miniapp_create_status","genre","ad_act","template_bid","zh_id","roi_goal","ql_bid","infra_status","pay_type","pay_type","qm_id","ldy_template_site_id","yw_id","parent_platform_id","platform_shared_id","distributor_id","is_delete","ad_convert_type","aweme_id","tg_app_index","butler_id","mini_program_platform_id","landing_page","valid_timer_time","valid_timer_number","channelId","no_bid_budget","max_ad_quantity","tg_link_config","id","tg_platform_id","app_id","main_name","running_status","ad_quantity","cpa_bid","bid_type","bid_ratio","custom_budget","daily_new_limit","valid_time","group_id"},msg_body)
     if not isok then
         return false,string.format("缺少字段: %s.", key)
     end
     local current_time = os.date("%Y-%m-%d %H:%M:%S")
     msg_body.update_time = current_time
-    local sql = string.format("UPDATE  `tg_main` SET aigc_status = %d , title_pay_type = %d , is_boost = %d , is_reservation = %d , title_type_id = %d , is_group_record = %d , tf_time_interval = %d , mat_roi = %f , reduce_roi = %f , boost_high_price_end_time = %d , boost_high_price_number = %d , reduce_consume_amount = %f , reduce_bid_amount = %f , is_comment = %d , member_token = '%s' , zy_conifg = '%s' , convert_cnt = %d , material_rule_id = %d , material_rule_number = %d , tg_day = %d ,  valid_timer_like_num = %d , ads_operation_status = '%s' , statistics_platform_id = %d , hide_if_converted = '%s' ,converted_time_duration = '%s' ,cbo_script_time = '%s' , cbo_script_status = %d , cbo_status = %d ,  project_type = %d ,tf_status = %d , tf_start_time = '%s' , min_book_word = %d ,  max_book_word = %d , stat_cost = %d , hy_accountId = '%s' , oce_product_id = '%s' , oce_product_platform_id = '%s' , material_platform_id = %d , delivery_mode = '%s' , advertiser_id = '%s' ,wx_miniapp_create_status = %d , genre = %d , ad_act = %d ,template_bid = %d , zh_id = '%s', roi_goal = %d , ql_bid = %d, infra_status = %d , pay_type = %d ,qm_id = '%s' , ldy_template_site_id = '%s' , yw_id = '%s' , parent_platform_id = %d , platform_shared_id = %d ,distributor_id = '%s' , is_delete = %d , ad_convert_type = '%s', aweme_id = '%s' ,tg_app_index = %d , butler_id = %d , mini_program_platform_id = %d , landing_page = '%s' , valid_timer_time = %d , valid_timer_number = %d ,channelId = '%s' , no_bid_budget = %d , max_ad_quantity = %d ,tg_platform_id = %d , app_id = '%s' ,main_name = '%s' , update_time = '%s' , running_status = %d ,ad_quantity = %d ,cpa_bid = %d ,bid_type = %d ,bid_ratio = '%s' ,custom_budget = %d ,daily_new_limit = %d ,valid_time = %d ,tg_link_config = '%s' ,group_id = '%s' WHERE id = %d ",
-    msg_body.aigc_status,msg_body.title_pay_type,msg_body.is_boost,msg_body.is_reservation,msg_body.title_type_id,msg_body.is_group_record,msg_body.tf_time_interval,msg_body.mat_roi,msg_body.reduce_roi,msg_body.boost_high_price_end_time,msg_body.boost_high_price_number,msg_body.reduce_consume_amount,msg_body.reduce_bid_amount,msg_body.is_comment,msg_body.member_token,cjson.encode(msg_body.zy_conifg),msg_body.convert_cnt,msg_body.material_rule_id,msg_body.material_rule_number,msg_body.tg_day,msg_body.valid_timer_like_num,msg_body.ads_operation_status,msg_body.statistics_platform_id,msg_body.hide_if_converted,msg_body.converted_time_duration,msg_body.cbo_script_time,msg_body.cbo_script_status,msg_body.cbo_status,msg_body.project_type,msg_body.tf_status,msg_body.tf_start_time,msg_body.min_book_word,msg_body.max_book_word,msg_body.stat_cost,msg_body.hy_accountId,msg_body.oce_product_id,msg_body.oce_product_platform_id,msg_body.material_platform_id,msg_body.delivery_mode,msg_body.advertiser_id,msg_body.wx_miniapp_create_status,msg_body.genre,msg_body.ad_act,msg_body.template_bid,msg_body.zh_id,msg_body.roi_goal,msg_body.ql_bid,msg_body.infra_status,msg_body.pay_type,msg_body.qm_id,msg_body.ldy_template_site_id,msg_body.yw_id,msg_body.parent_platform_id,msg_body.platform_shared_id,msg_body.distributor_id,msg_body.is_delete,msg_body.ad_convert_type,msg_body.aweme_id,msg_body.tg_app_index,msg_body.butler_id,msg_body.mini_program_platform_id,msg_body.landing_page,tonumber(msg_body.valid_timer_time),tonumber(msg_body.valid_timer_number),msg_body.channelId,msg_body.no_bid_budget,msg_body.max_ad_quantity,msg_body.tg_platform_id,msg_body.app_id,msg_body.main_name,msg_body.update_time,msg_body.running_status,msg_body.ad_quantity,msg_body.cpa_bid,msg_body.bid_type,msg_body.bid_ratio,msg_body.custom_budget,
+    local sql = string.format("UPDATE  `tg_main` SET  tf_support_status = %d , internal_advertiser_classify = '%s' ,aigc_status = %d , title_pay_type = %d , is_boost = %d , is_reservation = %d , title_type_id = %d , is_group_record = %d , tf_time_interval = %d , mat_roi = %f , reduce_roi = %f , boost_high_price_end_time = %d , boost_high_price_number = %d , reduce_consume_amount = %f , reduce_bid_amount = %f , is_comment = %d , member_token = '%s' , zy_conifg = '%s' , convert_cnt = %d , material_rule_id = %d , material_rule_number = %d , tg_day = %d ,  valid_timer_like_num = %d , ads_operation_status = '%s' , statistics_platform_id = %d , hide_if_converted = '%s' ,converted_time_duration = '%s' ,cbo_script_time = '%s' , cbo_script_status = %d , cbo_status = %d ,  project_type = %d ,tf_status = %d , tf_start_time = '%s' , min_book_word = %d ,  max_book_word = %d , stat_cost = %d , hy_accountId = '%s' , oce_product_id = '%s' , oce_product_platform_id = '%s' , material_platform_id = %d , delivery_mode = '%s' , advertiser_id = '%s' ,wx_miniapp_create_status = %d , genre = %d , ad_act = %d ,template_bid = %d , zh_id = '%s', roi_goal = %d , ql_bid = %d, infra_status = %d , pay_type = %d ,qm_id = '%s' , ldy_template_site_id = '%s' , yw_id = '%s' , parent_platform_id = %d , platform_shared_id = %d ,distributor_id = '%s' , is_delete = %d , ad_convert_type = '%s', aweme_id = '%s' ,tg_app_index = %d , butler_id = %d , mini_program_platform_id = %d , landing_page = '%s' , valid_timer_time = %d , valid_timer_number = %d ,channelId = '%s' , no_bid_budget = %d , max_ad_quantity = %d ,tg_platform_id = %d , app_id = '%s' ,main_name = '%s' , update_time = '%s' , running_status = %d ,ad_quantity = %d ,cpa_bid = %d ,bid_type = %d ,bid_ratio = '%s' ,custom_budget = %d ,daily_new_limit = %d ,valid_time = %d ,tg_link_config = '%s' ,group_id = '%s' WHERE id = %d ",
+    msg_body.tf_support_status,msg_body.internal_advertiser_classify,msg_body.aigc_status,msg_body.title_pay_type,msg_body.is_boost,msg_body.is_reservation,msg_body.title_type_id,msg_body.is_group_record,msg_body.tf_time_interval,msg_body.mat_roi,msg_body.reduce_roi,msg_body.boost_high_price_end_time,msg_body.boost_high_price_number,msg_body.reduce_consume_amount,msg_body.reduce_bid_amount,msg_body.is_comment,msg_body.member_token,cjson.encode(msg_body.zy_conifg),msg_body.convert_cnt,msg_body.material_rule_id,msg_body.material_rule_number,msg_body.tg_day,msg_body.valid_timer_like_num,msg_body.ads_operation_status,msg_body.statistics_platform_id,msg_body.hide_if_converted,msg_body.converted_time_duration,msg_body.cbo_script_time,msg_body.cbo_script_status,msg_body.cbo_status,msg_body.project_type,msg_body.tf_status,msg_body.tf_start_time,msg_body.min_book_word,msg_body.max_book_word,msg_body.stat_cost,msg_body.hy_accountId,msg_body.oce_product_id,msg_body.oce_product_platform_id,msg_body.material_platform_id,msg_body.delivery_mode,msg_body.advertiser_id,msg_body.wx_miniapp_create_status,msg_body.genre,msg_body.ad_act,msg_body.template_bid,msg_body.zh_id,msg_body.roi_goal,msg_body.ql_bid,msg_body.infra_status,msg_body.pay_type,msg_body.qm_id,msg_body.ldy_template_site_id,msg_body.yw_id,msg_body.parent_platform_id,msg_body.platform_shared_id,msg_body.distributor_id,msg_body.is_delete,msg_body.ad_convert_type,msg_body.aweme_id,msg_body.tg_app_index,msg_body.butler_id,msg_body.mini_program_platform_id,msg_body.landing_page,tonumber(msg_body.valid_timer_time),tonumber(msg_body.valid_timer_number),msg_body.channelId,msg_body.no_bid_budget,msg_body.max_ad_quantity,msg_body.tg_platform_id,msg_body.app_id,msg_body.main_name,msg_body.update_time,msg_body.running_status,msg_body.ad_quantity,msg_body.cpa_bid,msg_body.bid_type,msg_body.bid_ratio,msg_body.custom_budget,
     tonumber(msg_body.daily_new_limit),tonumber(msg_body.valid_time),cjson.encode(msg_body.tg_link_config),msg_body.group_id,msg_body.id)
     skynet.error(sql)
     tools.dump(mysqldbx.query(sql))

+ 0 - 32
service/backmgr/filter_task.lua

@@ -294,38 +294,6 @@ function M.search_bao_liang_data(msg_body)
 end
 
 
---添加书籍数据
-function M.add_book_data(msg_body)
-    local isok ,key =  tools.checkData({"fee_unit","default_price","default_pay_section","publish_time","status","product_parent_id","tg_platform_id","product_id","product_name"
-    ,"genre","is_store"},msg_body)
-    if not isok then
-        return false,string.format("缺少字段: %s.", key)
-    end
-    local sql ;
-    local isok,res;
-    local sql = string.format("SELECT * FROM video_product where product_id = '%s'  LIMIT 1 ",msg_body.product_id)
-    res = mysqldtaskbx.Singleton().query(sql)
-
-    if #res>0 then
-        return false,"书籍已存在!"
-    end
-
-    sql = string.format("INSERT INTO `video_product` (fee_unit,default_price,default_pay_section,publish_time,status,product_parent_id,book_platform,product_id, product_name, genre,is_store,is_auto)  VALUES (%d,%f,%d,'%s',%d,'%s',%d,'%s','%s',%d,%d,0)",
-    msg_body.fee_unit,
-    msg_body.default_price,
-    msg_body.default_pay_section,
-    msg_body.publish_time,
-    msg_body.status,
-    msg_body.product_parent_id,
-    msg_body.tg_platform_id,
-    msg_body.product_id,
-    msg_body.product_name,
-    msg_body.genre,msg_body.is_store)
-
-    res = mysqldtaskbx.Singleton().query(sql)
-    return true,{}
-end
-
 --发送书籍数据到主体
 function M.send_book_data(msg_body)
     local isok ,key =  tools.checkData({"tg_platform_id","app_id","id_list","main_id_list"},msg_body)

+ 47 - 0
service/backmgr/video_product.lua

@@ -342,6 +342,53 @@ function M.set_fee_unit(msg_body)
     return true, {}
 end
 
+--设置 专辑链接 album_link
+function M.set_album_link(msg_body)
+    local isok ,key =  tools.checkData({"album_link","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 album_link = '%s' WHERE id IN (%s) ",msg_body.album_link,idString)
+    mysqldtaskbx.Singleton().query(sql)
+    return true, {}
+end
+
+
+--添加书籍数据
+function M.add_book_data(msg_body)
+    local isok ,key =  tools.checkData({"album_link","fee_unit","default_price","default_pay_section","publish_time","status","product_parent_id","tg_platform_id","product_id","product_name"
+    ,"genre","is_store"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段: %s.", key)
+    end
+    local sql ;
+    local isok,res;
+    local sql = string.format("SELECT * FROM video_product where product_id = '%s'  LIMIT 1 ",msg_body.product_id)
+    res = mysqldtaskbx.Singleton().query(sql)
+
+    if #res>0 then
+        return false,"书籍已存在!"
+    end
+
+    sql = string.format("INSERT INTO `video_product` (album_link,fee_unit,default_price,default_pay_section,publish_time,status,product_parent_id,book_platform,product_id, product_name, genre,is_store,is_auto)  VALUES ('%s',%d,%f,%d,'%s',%d,'%s',%d,'%s','%s',%d,%d,0)",
+    msg_body.album_link,
+    msg_body.fee_unit,
+    msg_body.default_price,
+    msg_body.default_pay_section,
+    msg_body.publish_time,
+    msg_body.status,
+    msg_body.product_parent_id,
+    msg_body.tg_platform_id,
+    msg_body.product_id,
+    msg_body.product_name,
+    msg_body.genre,msg_body.is_store)
+
+    res = mysqldtaskbx.Singleton().query(sql)
+    return true,{}
+end
+
+
 function mysqldtaskbx.start()
     local function on_connect(db)
         db:query("set charset utf8mb4");