|
@@ -20,7 +20,12 @@ async function processTask(){
|
|
|
console.error("没数据了!")
|
|
|
}else{
|
|
|
let product_item = result.data
|
|
|
- task_queue.push({result:{data:product_item}})
|
|
|
+ let product_info = await video_product_controllers.getProductData({book_id:product_item.book_id});
|
|
|
+ if(!product_info.success){
|
|
|
+ task_queue.push({result:{data:product_item}})
|
|
|
+ }else{
|
|
|
+ await filter_data_controllers.updateFilterData({id:product_item.id},{status:3,material_sync_status:2})
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
}catch(e){
|
|
@@ -42,7 +47,7 @@ async function processCreateTask(){
|
|
|
result = task_queue_item.result
|
|
|
let other_book = await other_book_controllers.getData({product_id:task_queue_item.result.data.book_id})
|
|
|
if(other_book.success){
|
|
|
- await filter_data_controllers.updateFilterData({id:result.data.id},{status:2,book_id:other_book.data.product_id,book_name:other_book.data.product_name,material_sync_status:2})
|
|
|
+ await filter_data_controllers.updateFilterData({id:result.data.id},{status:3,book_id:other_book.data.product_id,book_name:other_book.data.product_name,material_sync_status:2})
|
|
|
throw "处理了一条长篇或者筛选不要的书"
|
|
|
}
|
|
|
let product = await video_product_controllers.getProductData({ book_id: task_queue_item.result.data.book_id });
|