事关破产, 求助如何写用户扣费逻辑

我在写个功能:

1.调用第三方企业收费 API 转卖给个人,用户充值获得积分之后才能使用 API,自己先垫付钱.

2.第三方 API 调用失败不扣费.

3.我搞了多个队列来限流用户的请求,大概 20 多个.

4.数据库用的 MongoDB

这是精简版数据模型

数据表

id
userId // 用户 id
status // pending progress success fail
requestData // 用户的数据
resultData // 调用第三方 api 的结果

积分表

point 

先保存用户的 requestData 请求数据, status 默认为 pending, 然后把这条数据给到 queue 队列, 队列里来处理逻辑.

下面是我的逻辑:

// 在开始事务
startTransaction();

try{

// 1.拿着 userId 查积分表 不足就 throw
if(point < 0) throw error NotEnoughPointError

// 2.如果处理成功过, 又因为某些原因又加入到 queue 里了
if(status == success) throw error AlreadyInQueueError

// 3.状态改为 progress
await setProgress()

// 4.转换一下用户格式 不修改表里的数据
await transformRequestData()

// 5.调用第三方 API 失败会抛出 ThirdAPIRrror
const result = await thirdAPI()

// 6.扣用户的积分
await minusUserPoint()

// 7.状态改为 success
await setSuccess()

// 8.提交事务
commitTransaction()

// 9.从队列里返回数据
return result

}catch(error){

// 1.终止事务
abortTransaction()

// 2.设置成错误状态
await setFail()

} finally {

// 1.结束事务
endSession();

}

问题来了...

1.我 20 多个队列同时大量这种请求, 队列是 Redis, 我加上这个事务是不是能解决并发扣费问题, 会不会多个操作同时扣费.

2.如果从 try 里面的调用第三方 API 之后的 6.扣用户的积分 7.状态改为 success 8.提交事务 这三个操作内部 throw 出错了,我钱就白花了.

3.我这逻辑有没有其他问题啊,实在没写过扣费,谢谢大家了.