123

0_RECEIVE_FACTORY/RECEIVE_FACTORY.js

@@ -84,11 +84,6 @@ CMD.init = function(){
 
 CMD.runTask = async function(){
    
-    for (let index = 0; index < recv_data_list.length; index++) {
-        const xml = recv_data_list[index];
-       
-    }
- 
 }
 
 CMD.test_fq_book_sid_tt = async function(book_id,sid_tt){
@@ -179,6 +174,17 @@ CMD.get_fq_rechargeTemplate = function(res){
     });
 }
 
+CMD.get_pull_token = async function(){
+    let token =  await redis_help.getKeyValue("pull_data_token")
+    res.writeHead(200, {'Content-Type': 'application/json'});
+    if(data.code==200){
+        res.end(JSON.stringify({ message:"成功！",data:{token:token},code:10000}));
+    }else{
+        res.end(JSON.stringify({ message:"fail!",code:401}));
+    }
+    console.log('get_pull_token:', token);
+}
+
 
 
 var server = http.createServer(function(req,res){
@@ -230,6 +236,8 @@ var server = http.createServer(function(req,res){
                         CMD.get_hy_passBackTemplate(res) 
                     }else if(jsonData['fun']=="rechargeTemplate"&&jsonData['cmd']=="fq_link"){
                         CMD.get_fq_rechargeTemplate(res) 
+                    }else if(jsonData['fun']=="get_pull_token"&&jsonData['cmd']=="pull_data_config"){
+                        CMD.get_pull_token(res) 
                     } else{
                         res.writeHead(200, {'Content-Type': 'application/json'});
                         res.end(JSON.stringify({ message: 'fun 错误',code:100}));

PULL_DATA_FACTORY/PULL_DATA.js

@@ -268,7 +268,7 @@ async function processTask(timeRange){
         //         element.limit
         //     )
         // }
-        process_novel_material_list()     
+        await process_novel_material_list()     
         console.log("processTask over!")
         // response = await pullDataService.get_detail(materialId_list)
         // if(!response.success){

src/PullDataService.js

@@ -82,7 +82,6 @@ class PullDataService {
                 }
             } catch (error) {
                 if (i === maxRetries - 1) return {data:null,success:false,msg:error};
-                await this.getToken()
                 console.log(`Retry get_novel_material_list ${i + 1} of ${maxRetries}`);
                 await new Promise(resolve => setTimeout(resolve, delay * (i + 1)));
             }
@@ -113,7 +112,6 @@ class PullDataService {
                 }
             } catch (error) {
                 if (i === maxRetries - 1) return {data:null,success:false,msg:error};
-                await this.getToken()
                 console.log(`Retry get_detail ${i + 1} of ${maxRetries}`);
                 await new Promise(resolve => setTimeout(resolve, delay * (i + 1)));
             }