|
@@ -46,12 +46,12 @@ async function processCreateTask(){
|
|
if(task_queue.length>0){
|
|
if(task_queue.length>0){
|
|
let task_queue_item = task_queue.pop()
|
|
let task_queue_item = task_queue.pop()
|
|
result = task_queue_item.result
|
|
result = task_queue_item.result
|
|
- let other_book = await other_book_controllers.getData({product_id:task_queue_item.result.data.book_id})
|
|
|
|
|
|
+ let other_book = await other_book_controllers.getData({product_id:result.data.book_id})
|
|
if(other_book.success){
|
|
if(other_book.success){
|
|
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})
|
|
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 "处理了一条长篇或者筛选不要的书"
|
|
throw "处理了一条长篇或者筛选不要的书"
|
|
}
|
|
}
|
|
- let product = await video_product_controllers.getProductData({ book_id: task_queue_item.result.data.book_id });
|
|
|
|
|
|
+ let product = await video_product_controllers.getProductData({ book_id: result.data.book_id });
|
|
let FilterConfig = await redis_help.getKeyValue("FilterConfig")
|
|
let FilterConfig = await redis_help.getKeyValue("FilterConfig")
|
|
FilterConfig = JSON.parse(FilterConfig)
|
|
FilterConfig = JSON.parse(FilterConfig)
|
|
if(!product.success){
|
|
if(!product.success){
|
|
@@ -312,7 +312,7 @@ CMD.insert_product = async function(data){
|
|
default_price:data.default_price,
|
|
default_price:data.default_price,
|
|
fee_unit:data.fee_unit,
|
|
fee_unit:data.fee_unit,
|
|
product_parent_id:product_parent_id,
|
|
product_parent_id:product_parent_id,
|
|
- match_book:match_book,
|
|
|
|
|
|
+ match_book:match_book
|
|
})
|
|
})
|
|
}
|
|
}
|
|
|
|
|