Skip to content

O
order-group
Commit 3456bf5e by 徐康
Options

发消息

parent dbefa935
Showing with 2 additions and 2 deletions
order-application-service/src/main/java/cn/freemud/service/impl/MCCafeOrderServiceImpl.java
...@@ -1064,7 +1064,7 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService { ...@@ -1064,7 +1064,7 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService {
} }
} }
Header header = new Header(MQAction.UPDATE.getAction(), "order-application-service-api", Header header = new Header(MQAction.INSERT.getAction(), "order-application-service-api",
"send_score_key", "send_score_queue"); "send_score_key", "send_score_queue");
OrderInfoRequest body = new OrderInfoRequest(); OrderInfoRequest body = new OrderInfoRequest();
body.setBizType(orderBean.getBizType()); body.setBizType(orderBean.getBizType());
...@@ -1083,7 +1083,7 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService { ...@@ -1083,7 +1083,7 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService {
body.setSettlementAmount(settlementAmount); body.setSettlementAmount(settlementAmount);
MQMessage<OrderInfoRequest> mqMessage = new MQMessage<>(header, body); MQMessage<OrderInfoRequest> mqMessage = new MQMessage<>(header, body);
ApiLog.info("邀请有礼发消息："+JSON.toJSONString(mqMessage)); ApiLog.info("邀请有礼发消息："+JSON.toJSONString(mqMessage));
mqService.convertAndSend("topic-Exchange", "send_score_queue", mqMessage); mqService.convertAndSend("topic-Exchange", "send_score_key", mqMessage);
//支付回掉成功标记 //支付回掉成功标记
redisCache.save(RedisKeyConstant.KGD_PAYMENT_CALLBACK_FMID + message.getOut_trade_no(), message.getOut_trade_no(), 10L, TimeUnit.MINUTES); redisCache.save(RedisKeyConstant.KGD_PAYMENT_CALLBACK_FMID + message.getOut_trade_no(), message.getOut_trade_no(), 10L, TimeUnit.MINUTES);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment