@8355 老哥,我改了改,这样是不是好些了...
1.先扣费,扣费的时候
1.1 开启事务
1.2 积分表加行级锁
1.3 扣费记录加一条
1.4 改余额成 扣了之后的
1.5 此条数据状态: 已扣费

1 如果错误就抛给用户

2.入队列, if 状态 = 已扣费 and 不在队列里 and 没有 jobId, 入队列后 此条数据 加上 jobId,

2 如果错误就抛给用户

4.队列里面

4.1 开启事务
try
4.2 查询这条数据 where status = 已扣费
4.3 状态改为成功
4.4 此条数据状态 改成成功
4.4 调用第三方 API
4.5 提交事务
4.6 记录日志
catch
4.7 终止事务
4.8 把此条数据的状态改为失败(在事务外) 记录第三方 API 抛出的错误


5.队列里面设置重试次数重试 重试次数到了 job 的状态是 job 错误

6 在外面轮询这个 jobId 判断这个 job 的状态成功还是错误

6.1 如果错误
6.2 开启事务
6.3 如果错误了 积分表加行级锁 返积分 where 扣费记录 是否返了积分 = 否
6.4 扣费记录 是否返了积分 设为 是
6.5 提交事务