|
@@ -200,10 +200,9 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
|
|
msgLog.setBusinessId(order.getId());
|
|
msgLog.setBusinessId(order.getId());
|
|
msgLog.setExchange(ChargeConsumeConfig.NAME);
|
|
msgLog.setExchange(ChargeConsumeConfig.NAME);
|
|
msgLog.setRoutingKey(ChargeConsumeConfig.NAME);
|
|
msgLog.setRoutingKey(ChargeConsumeConfig.NAME);
|
|
|
|
+ msgLog.setMsg(JSON.toJSONString(chargeVo));
|
|
msgLogService.save(msgLog);
|
|
msgLogService.save(msgLog);
|
|
chargeVo.setSeq(msgLog.getId());
|
|
chargeVo.setSeq(msgLog.getId());
|
|
- msgLog.setMsg(JSON.toJSONString(chargeVo));
|
|
|
|
- msgLogService.updateById(msgLog);
|
|
|
|
CorrelationData correlationData = new CorrelationData(msgLog.getId().toString());
|
|
CorrelationData correlationData = new CorrelationData(msgLog.getId().toString());
|
|
rabbitTemplate.convertAndSend(msgLog.getExchange(), msgLog.getRoutingKey(), chargeVo,correlationData);
|
|
rabbitTemplate.convertAndSend(msgLog.getExchange(), msgLog.getRoutingKey(), chargeVo,correlationData);
|
|
}catch (Exception e){
|
|
}catch (Exception e){
|