|
@@ -6,12 +6,12 @@ const taskdbConfig = config.isDebug?config.debug_task_mysql:config.release_task_
|
|
|
const redis_help = require('../src/use_redis');
|
|
|
const filter_data_controllers = require('../src/data_manager/Controllers/filter_data_controllers');
|
|
|
const helper = require("../src/helper");
|
|
|
-const get_fq_book_tab_controllers = require('../src/data_manager/Controllers/get_fq_book_tab_controllers');
|
|
|
+const get_fq_mf_book_tab_controllers = require('../src/data_manager/Controllers/get_fq_mf_book_tab_controllers');
|
|
|
const CMD = {}
|
|
|
async function processTask(){
|
|
|
let right_status = true
|
|
|
let connection = null
|
|
|
- let tg_platform_id = config.platform_fanqie
|
|
|
+ let tg_platform_id = config.platform_fanqiemf
|
|
|
try{
|
|
|
connection = await mysql.createConnection({
|
|
|
...dbConfig,
|
|
@@ -28,11 +28,11 @@ async function processTask(){
|
|
|
let filter_info = row[0]
|
|
|
|
|
|
if(filter_info.book_id.length<18){
|
|
|
- let fq_book_result = await get_fq_book_tab_controllers.getData({ book_id: filter_info.book_id });
|
|
|
+ let fq_book_result = await get_fq_mf_book_tab_controllers.getData({ book_id: filter_info.book_id });
|
|
|
if(fq_book_result.success){
|
|
|
|
|
|
|
|
|
- const [info_list] = await connection.execute(
|
|
|
+ const [info_list] = await connection.execute(
|
|
|
`SELECT id FROM filter_data
|
|
|
WHERE tg_platform_id = ? AND book_id = ?
|
|
|
LIMIT 100`,
|
|
@@ -58,7 +58,7 @@ async function processTask(){
|
|
|
1,
|
|
|
fq_book_result.data.info.book_name,
|
|
|
fq_book_result.data.info.genre,
|
|
|
- fq_book_result.data.info.words,
|
|
|
+ fq_book_result.data.info.words==undefined?0:fq_book_result.data.info.words,
|
|
|
fq_book_result.data.book_id
|
|
|
]
|
|
|
);
|