|
@@ -93,6 +93,7 @@ async function processNewCreateTask(){
|
|
fq_book.tg_platform_id = result.data.tg_platform_id
|
|
fq_book.tg_platform_id = result.data.tg_platform_id
|
|
fq_book_data.tg_platform_id = result.data.tg_platform_id
|
|
fq_book_data.tg_platform_id = result.data.tg_platform_id
|
|
await CMD.insert_product(fq_book_data)
|
|
await CMD.insert_product(fq_book_data)
|
|
|
|
+ await CMD.update_filter_data(FilterConfig,result.data)
|
|
}
|
|
}
|
|
result.data.words = words
|
|
result.data.words = words
|
|
result.data.genre = fq_book_data.genre
|
|
result.data.genre = fq_book_data.genre
|
|
@@ -100,9 +101,10 @@ async function processNewCreateTask(){
|
|
result.data.book_name = fq_book_data.book_name
|
|
result.data.book_name = fq_book_data.book_name
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
+ console.log("处理完一条数据:")
|
|
}
|
|
}
|
|
|
|
|
|
- await CMD.update_filter_data(FilterConfig,result.data)
|
|
|
|
|
|
+
|
|
}catch(e){
|
|
}catch(e){
|
|
if(e==0){
|
|
if(e==0){
|
|
console.log("processCreateTask:没有需要处理的任务")
|
|
console.log("processCreateTask:没有需要处理的任务")
|