|
@@ -1,5 +1,5 @@
|
|
|
const CMD = {}
|
|
|
-const time_count = 2000;
|
|
|
+const time_count = 1000;
|
|
|
const redis_help = require('../src/use_redis');
|
|
|
const video_applet_product_controllers = require('../src/data_manager/Controllers/video_applet_product_controllers');
|
|
|
var qm_create_link_task_list = []
|
|
@@ -102,11 +102,23 @@ async function processTask(){
|
|
|
}
|
|
|
let main_info = CMD.getMainInfoById(MainConfig,result.data.main_id)
|
|
|
|
|
|
+ if(main_info==null&&result.data.is_close_execution==1){
|
|
|
+ let CloseMainConfig = await redis_help.getKeyValue("CloseMainConfig")
|
|
|
+ CloseMainConfig = JSON.parse(CloseMainConfig)
|
|
|
+ main_info = CMD.getMainInfoById(CloseMainConfig,result.data.main_id)
|
|
|
+ }
|
|
|
+
|
|
|
if(main_info==null){
|
|
|
- console.error("主体没有开启创建链接任务:",main_info)
|
|
|
- throw "主体没有开启创建链接任务"
|
|
|
+ await video_applet_product_controllers.updateData({id:result.data.id},{
|
|
|
+ status:2,
|
|
|
+ wait_status:2,
|
|
|
+ error_info:JSON.stringify({msg:"主体配置错误:"})
|
|
|
+ })
|
|
|
+ console.error("主体配置错误:",result)
|
|
|
+ throw "主体配置错误:"
|
|
|
}
|
|
|
|
|
|
+
|
|
|
let PlatformInfo = null
|
|
|
|
|
|
PlatformInfo = CMD.getPlatformInfoById(PlatformConfig,main_info.tg_platform_id)
|
|
@@ -122,23 +134,6 @@ async function processTask(){
|
|
|
}
|
|
|
|
|
|
|
|
|
- if(main_info==null&&result.data.is_close_execution==1){
|
|
|
- let CloseMainConfig = await redis_help.getKeyValue("CloseMainConfig")
|
|
|
- CloseMainConfig = JSON.parse(CloseMainConfig)
|
|
|
- main_info = CMD.getMainInfoById(CloseMainConfig,result.data.main_id)
|
|
|
- }
|
|
|
-
|
|
|
- if(main_info==null){
|
|
|
- await video_applet_product_controllers.updateData({id:result.data.id},{
|
|
|
- status:2,
|
|
|
- wait_status:2,
|
|
|
- error_info:JSON.stringify({msg:"主体配置错误:"})
|
|
|
- })
|
|
|
- console.error("主体配置错误:",result)
|
|
|
- throw "主体配置错误:"
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
qm_create_link_task_list.push({
|
|
|
n_data:result.data,
|
|
|
main_info:main_info,
|