myCard新增mq补单逻辑2

This commit is contained in:
liaozetao
2024-01-24 11:49:15 +08:00
parent c9bba26f22
commit c27345526a

View File

@@ -49,6 +49,11 @@ public class MyCardChargeMessageConsumer extends AbstractMessageListener<ChargeM
if (!Constant.ChargeChannel.my_card.equals(channel)) {
return;
}
Byte chargeStatus = chargeRecord.getChargeStatus();
if (Constant.ChargeRecordStatus.finish.equals(chargeStatus)) {
log.info("订单 {} 已完成", chargeRecordId);
return;
}
log.info("开始执行MyCard mq监控流程 chargeRecordId : {}", chargeRecordId);
boolean isSuccess = myCardBizService.updateOrder(chargeRecordId);
String countStr = jedisService.hget(RedisKey.charge_record_mq_count.getKey(), chargeRecordId);