123

task_script/clear_fq_filter_data.js

@@ -30,11 +30,42 @@ async function processTask(){
         if(filter_info.book_id.length<18){
             let fq_book_result = await get_fq_book_tab_controllers.getData({ book_id: filter_info.book_id });
             if(fq_book_result.success){
-                console.log("fq_book_result:",fq_book_result,filter_info.id)
-                sql = `UPDATE filter_data SET status = 1 , book_name = "${fq_book_result.data.info.book_name}" , genre = ${fq_book_result.data.info.genre} ,words = "${fq_book_result.data.info.words}" , book_id = ${fq_book_result.data.book_id} WHERE id = "${filter_info.id}" `
-                await connection.execute(
-                    sql
+
+
+            const [info_list] = await connection.execute(
+                `SELECT id FROM filter_data 
+                    WHERE tg_platform_id = ? AND book_id = ? 
+                    LIMIT 100`,
+                [tg_platform_id, filter_info.book_id]
                 );
+                
+                // 2. 提取 id 数组
+                const ids = info_list.map(row => row.id);
+                // 3. 批量更新（如果 ids 不为空）
+                if (ids.length > 0) {
+                    await connection.execute(
+                        `UPDATE filter_data 
+                        SET status = ? ,
+                        book_name = ? ,
+                        genre = ? ,
+                        words = ? ,
+                        book_id = ? ,
+                        WHERE id IN (?)`,  // MySQL 支持 IN (?) 语法
+                        [
+                            1,
+                            fq_book_result.data.info.book_name,
+                            fq_book_result.data.info.genre,
+                            fq_book_result.data.info.words,
+                            fq_book_result.data.book_id,
+                            ids
+                        ]
+                    );
+                }
+                // console.log("fq_book_result:",fq_book_result,filter_info.id)
+                // sql = `UPDATE filter_data SET status = 1 , book_name = "${fq_book_result.data.info.book_name}" , genre = ${fq_book_result.data.info.genre} ,words = "${fq_book_result.data.info.words}" , book_id = ${fq_book_result.data.book_id} WHERE id = "${filter_info.id}" `
+                // await connection.execute(
+                //     sql
+                // );
             }else{
                 sql = `UPDATE filter_data SET weight = 1  WHERE id = "${filter_info.id}" `
                 await connection.execute(