0

src/api/yjbdc/routes.js

@@ -17,6 +17,9 @@ router.get('/api/DeleteYJBDCArticleList',yjbdcController.DeleteYJBDCArticleList)
 router.get('/api/UpdateYJBDCArticleReadCount',yjbdcController.UpdateYJBDCArticleReadCount);
 router.get('/api/GetMiaoguoTodayAllWords',yjbdcController.GetMiaoguoTodayAllWords);
 router.get('/api/GetWordChinese',yjbdcController.GetWordChinese);
+router.get('/api/AddOrDeleteYJBDCUserCollect',yjbdcController.AddOrDeleteYJBDCUserCollect);
+router.get('/api/DeleteYJBDCUserCollect',yjbdcController.DeleteYJBDCUserCollect);
+router.get('/api/GetYJBDCUserCollect',yjbdcController.GetYJBDCUserCollect);
 
 router.get('/yjbdc_article_admin',yjbdcController.YJBDC_Articles_Admin);
 

src/api/yjbdc/yjbdcController.js

@@ -633,6 +633,51 @@ export async function UpdateYJBDCArticleReadCount(ctx) {
     ctx.body = {"errcode": 10000};
 }
 
+export async function AddOrDeleteYJBDCUserCollect(ctx) {
+    const param = {
+        UserID: ctx.query.UserID || 0,
+        Word: ctx.query.Word || '',
+        CreateTime:moment().format("YYYY-MM-DD HH:mm:ss"),
+    };
+    
+    let list=await yjbdc.GetYJBDCUserCollect(param);
+    if (list && list.length>0)
+        await yjbdc.DeleteYJBDCUserCollect(param);
+    else
+        await yjbdc.AddYJBDCUserCollect(param);
+    
+    let param2={}
+    param2.UserID=param.UserID;
+    let result=await yjbdc.GetYJBDCUserCollect(param2);
+    ctx.body = {"errcode": 10000,result:result};
+}
+
+export async function DeleteYJBDCUserCollect(ctx) {
+    const param = {
+        UserID: ctx.query.UserID || 0,
+        WordArr:ctx.query.WordArr || "",
+    };
+    
+    let arr=param.WordArr.split(",");
+    for(let i=0;i<arr.length;i++){
+        let obj={};
+        obj.UserID=param.UserID;
+        obj.Word=arr[i];
+        await yjbdc.DeleteYJBDCUserCollect(obj);
+    }
+    ctx.body = {"errcode": 10000};
+}
+
+export async function GetYJBDCUserCollect(ctx) {
+    const param = {
+        UserID: ctx.query.UserID || 0,
+    };
+    
+    let list=await yjbdc.GetYJBDCUserCollect(param);
+    
+    ctx.body = {"errcode": 10000,result:list};
+}
+
 //生成PDF
 export async function GeneratePDF(ctx) {
     const params = ctx.request.body;

src/model/yjbdc.js

@@ -79,6 +79,42 @@ class YJBDC {
         }
     }
 
+    static async AddYJBDCUserCollect(obj) {
+        try {
+            const sql = "INSERT INTO YJBDC_Collects SET ?";
+            return await query(sql, [obj]);
+        } catch (error) {
+            console.error('添加用户收藏失败:', error);
+            throw error;
+        }
+    }
+
+    static async DeleteYJBDCUserCollect(obj) {
+        try {
+            const sql = "Delete from YJBDC_Collects WHERE UserID=? and Word=?";
+            return await query(sql, [obj.UserID,obj.Word]);
+        } catch (error) {
+            console.error('删除用户收藏失败:', error);
+            throw error;
+        }
+    }
+
+    static async GetYJBDCUserCollect(obj) {
+        try {
+            let sql = "Select ID,Word from YJBDC_Collects WHERE UserID=? order by ID desc;";
+            if (obj.Word){
+                sql = "Select * from YJBDC_Collects WHERE UserID=? and Word=?";
+                return await query(sql, [obj.UserID,obj.Word]);
+            }
+            else
+                return await query(sql, [obj.UserID]);
+        } catch (error) {
+            console.error('更新用户收藏失败:', error);
+            throw error;
+        }
+    }
+
+
     static async AddOCRInfo(obj) {
         try {
             const sql = "INSERT INTO YJBDC_OCRs SET ?";

src/test/build.test.js

@@ -80,6 +80,7 @@ async function runScript(){
         console.log("完成");
     } catch (error) {
         console.error('Error executing script:', error);
+        debugger;
     }
 }
 

src/test/build.test2.js

@@ -11,10 +11,10 @@ async function runScript(){
         let list = await commonModel.RunSql(null,sql);
         let count=list.length;
 
-        const start=8490;
+        const start=8995;
         //count=10;
         // 添加延时函数，确保每分钟只发送9次请求（约每6.67秒一次请求）
-        // const delay = (ms) => new Promise(resolve => setTimeout(resolve, ms));
+        // const delay = (ms ) => new Promise(resolve => setTimeout(resolve, ms));
         // const requestDelay = 300; // 7秒，确保每分钟最多9次请求
         
         for(let i=start;i<count;i++){