Browse Source

增加开启自动跑时的校验

Pchen. 3 months ago
parent
commit
54ecac799c
1 changed files with 11 additions and 6 deletions
  1. 11 6
      apis/Lepao/ChangeAutoRun.js

+ 11 - 6
apis/Lepao/ChangeAutoRun.js

@@ -16,8 +16,7 @@ class ChangeAutoRun extends API {
 
 
         if ([uuid, session, id].some(value => value === '' || value === null || value === undefined))
         if ([uuid, session, id].some(value => value === '' || value === null || value === undefined))
             return res.json({
             return res.json({
-                ...BaseStdResponse.MISSING_PARAMETER,
-                endpoint: 1513126
+                ...BaseStdResponse.MISSING_PARAMETER
             });
             });
 
 
         if (!await AccessControl.checkSession(uuid, session))
         if (!await AccessControl.checkSession(uuid, session))
@@ -25,7 +24,7 @@ class ChangeAutoRun extends API {
                 ...BaseStdResponse.ACCESS_DENIED
                 ...BaseStdResponse.ACCESS_DENIED
             })
             })
 
 
-        let selectSql = 'SELECT create_user FROM lepao_account WHERE id = ?'
+        let selectSql = 'SELECT create_user, target_count, total_num, auto_run FROM lepao_account WHERE id = ?'
         let selectRows = await db.query(selectSql, [id])
         let selectRows = await db.query(selectSql, [id])
         if (!selectRows || selectRows.length === 0)
         if (!selectRows || selectRows.length === 0)
             return res.json({
             return res.json({
@@ -42,6 +41,13 @@ class ChangeAutoRun extends API {
                 })
                 })
         }
         }
 
 
+        if (selectRows[0].auto_run === 0 && (selectRows[0].target_count <= selectRows[0].total_num)) {
+            return res.json({
+                ...BaseStdResponse.ERR,
+                msg: '该账号累计跑步次数已达到预设目标次数,请尝试增大目标次数后再试'
+            })
+        }
+
         let sql = 'UPDATE lepao_account SET auto_run = 1 - auto_run WHERE id = ?';
         let sql = 'UPDATE lepao_account SET auto_run = 1 - auto_run WHERE id = ?';
         try {
         try {
             let r = await db.query(sql, [id]);
             let r = await db.query(sql, [id]);
@@ -49,13 +55,12 @@ class ChangeAutoRun extends API {
             if (r && r.affectedRows > 0) {
             if (r && r.affectedRows > 0) {
                 res.json({
                 res.json({
                     ...BaseStdResponse.OK
                     ...BaseStdResponse.OK
-                });
+                })
             } else {
             } else {
                 res.json({
                 res.json({
                     ...BaseStdResponse.ERR,
                     ...BaseStdResponse.ERR,
-                    endpoint: 7894378,
                     msg: '切换自动乐跑状态失败!未找到对应数据或数据库未更新'
                     msg: '切换自动乐跑状态失败!未找到对应数据或数据库未更新'
-                });
+                })
             }
             }
         } catch (err) {
         } catch (err) {
             this.logger.error(`切换自动乐跑状态失败!${err.stack}`);
             this.logger.error(`切换自动乐跑状态失败!${err.stack}`);