✨ feat: 删除30天前的变更记录

apis/Corn/StartPowerCheck.js

@@ -60,7 +60,7 @@ class StartPowerCheck extends API {
                     }
 
                     // 记录变更并更新任务表余额
-                    const insertSql = 'INSERT INTO power_chang_record (time, balance, old_balance, change_time, task_id) VALUES (?, ?, ?, ?, ?)'
+                    const insertSql = 'INSERT INTO power_change_record (time, balance, old_balance, change_time, task_id) VALUES (?, ?, ?, ?, ?)'
                     const insertRows = await db.query(insertSql, [time, nowBalanceNum, balanceNum, now_change_time, id])
 
                     const updateSql = 'UPDATE power_task SET update_time = ?, balance = ?, koufei_date = ? WHERE id = ?'
@@ -97,6 +97,15 @@ class StartPowerCheck extends API {
                     continue
                 }
             }
+
+            // 删除30天前的记录
+            const delete_time = new Date().getTime() - 2592000000
+            let deleteSql = 'DELETE FROM power_change_record WHERE time < ?'
+            let deleteRows = await db.query(deleteSql, [delete_time])
+            if(!deleteRows) {
+                this.logger.error(`删除电费变更记录失败`)
+                return
+            }
         } catch (error) {
             this.logger.error(error)
         }