|
@@ -196,6 +196,9 @@ class Lepao {
|
|
|
throw new Error('系统繁忙,请联系客服或稍后再试')
|
|
throw new Error('系统繁忙,请联系客服或稍后再试')
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ // 临时修复3.12~3.18期间未入库记录,后续可删除
|
|
|
|
|
+ await this.fixRecords(uuid, ossData)
|
|
|
|
|
+
|
|
|
// 扣除乐跑次数
|
|
// 扣除乐跑次数
|
|
|
this.logger.info(`${account}开始扣减乐跑次数`)
|
|
this.logger.info(`${account}开始扣减乐跑次数`)
|
|
|
const useLepaoCountSql = 'UPDATE users SET lepao_count = lepao_count - 1 WHERE uuid = ?'
|
|
const useLepaoCountSql = 'UPDATE users SET lepao_count = lepao_count - 1 WHERE uuid = ?'
|
|
@@ -369,6 +372,28 @@ class Lepao {
|
|
|
this.logger.error(`设置用户 ${account} state时出错: ${error.stack || error.message}`)
|
|
this.logger.error(`设置用户 ${account} state时出错: ${error.stack || error.message}`)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+ // 修复3.12~3.18期间未入库记录
|
|
|
|
|
+ async fixRecords(uuid, reqData) {
|
|
|
|
|
+ try {
|
|
|
|
|
+ const countUrl = this.runpy + '/get_term_record'
|
|
|
|
|
+
|
|
|
|
|
+ const recordRes = await axios.post(countUrl, reqData)
|
|
|
|
|
+ const { data } = recordRes
|
|
|
|
|
+ if(!data || !data.data) {
|
|
|
|
|
+ this.logger.warn(`修复乐跑记录失败,接口返回异常`)
|
|
|
|
|
+ return
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ const count = data.data.count || 0
|
|
|
|
|
+ let fixSql = 'UPDATE users SET lepao_count = lepao_count - ? WHERE uuid = ?'
|
|
|
|
|
+ await db.query(fixSql, [count, uuid])
|
|
|
|
|
+ this.logger.info(`修复乐跑记录成功,扣除用户 ${uuid} 乐跑次数 ${count} 次`)
|
|
|
|
|
+
|
|
|
|
|
+ } catch (error) {
|
|
|
|
|
+ this.logger.error(`修复乐跑记录失败: ${error.stack || error.message}`)
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
const lepao = new Lepao()
|
|
const lepao = new Lepao()
|