|
|
@@ -85,33 +85,41 @@ async function processCreateTask(){
|
|
|
FilterConfig = JSON.parse(FilterConfig)
|
|
|
if(!product.success){
|
|
|
let tg_platform_id = result.data.tg_platform_id
|
|
|
- if(tg_platform_id==2){
|
|
|
+ if(tg_platform_id==config.platform_fanqie){
|
|
|
let client = new HttpClient()
|
|
|
let sid_tt = await tools.getFqSidtt()
|
|
|
let response = await client.proxyRequest( helper.getFqRequestOpt(result.data.book_id,sid_tt))
|
|
|
let obj = response['data']
|
|
|
- let book_name = obj['novel_data'].book_name
|
|
|
- let book_id = obj['novel_data'].book_id
|
|
|
- let genre = CMD.getFqGenre(obj['novel_data'].genre)
|
|
|
- let words = obj['novel_data'].word_number
|
|
|
- let fq_book_data = {book_name:book_name,book_id:book_id,genre:genre,words:words,info:JSON.stringify(obj['novel_data'])}
|
|
|
- let fq_book = {}
|
|
|
- fq_book.key = result.data.book_id
|
|
|
- // console.log("response:",obj,sid_tt)
|
|
|
- await CMD.add_fq_book(fq_book,fq_book_data)
|
|
|
- let product_result = await video_product_controllers.getProductData({ book_id: fq_book_data.book_id });
|
|
|
- if(!product_result.success){ //如果书库也没有
|
|
|
- fq_book.tg_platform_id = result.data.tg_platform_id
|
|
|
-
|
|
|
- if(CMD.isGenre(FilterConfig,fq_book_data.genre)){
|
|
|
- fq_book_data.tg_platform_id = result.data.tg_platform_id
|
|
|
- await CMD.insert_product(fq_book_data)
|
|
|
+ if (Object.keys(obj['novel_data']).length === 0) {
|
|
|
+ result.data.words = 0
|
|
|
+ result.data.genre = 999
|
|
|
+ result.data.book_id = result.data.book_id
|
|
|
+ result.data.book_name = "没有找到这本书"
|
|
|
+ }else{
|
|
|
+ let book_name = obj['novel_data'].book_name
|
|
|
+ let book_id = obj['novel_data'].book_id
|
|
|
+ let genre = CMD.getFqGenre(obj['novel_data'].genre)
|
|
|
+ let words = obj['novel_data'].word_number
|
|
|
+ let fq_book_data = {book_name:book_name,book_id:book_id,genre:genre,words:words,info:JSON.stringify(obj['novel_data'])}
|
|
|
+ let fq_book = {}
|
|
|
+ fq_book.key = result.data.book_id
|
|
|
+ // console.log("response:",obj,sid_tt)
|
|
|
+ await CMD.add_fq_book(fq_book,fq_book_data)
|
|
|
+ let product_result = await video_product_controllers.getProductData({ book_id: fq_book_data.book_id });
|
|
|
+ if(!product_result.success){ //如果书库也没有
|
|
|
+ fq_book.tg_platform_id = result.data.tg_platform_id
|
|
|
+
|
|
|
+ if(CMD.isGenre(FilterConfig,fq_book_data.genre)){
|
|
|
+ fq_book_data.tg_platform_id = result.data.tg_platform_id
|
|
|
+ await CMD.insert_product(fq_book_data)
|
|
|
+ }
|
|
|
}
|
|
|
+ result.data.words = words
|
|
|
+ result.data.genre = fq_book_data.genre
|
|
|
+ result.data.book_id = fq_book_data.book_id
|
|
|
+ result.data.book_name = fq_book_data.book_name
|
|
|
}
|
|
|
- result.data.words = words
|
|
|
- result.data.genre = fq_book_data.genre
|
|
|
- result.data.book_id = fq_book_data.book_id
|
|
|
- result.data.book_name = fq_book_data.book_name
|
|
|
+
|
|
|
}
|
|
|
}
|
|
|
await CMD.update_filter_data(FilterConfig,result.data)
|
