| | |
|---|
| | | import com.yeshi.fanli.service.inter.push.PushService;
|
|---|
| | | import com.yeshi.fanli.service.inter.shop.BanLiShopOrderService;
|
|---|
| | | import com.yeshi.fanli.util.StringUtil;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|---|
| | | import com.yeshi.fanli.util.shop.BanLiShopOrderUtil;
|
|---|
| | | import com.yeshi.fanli.util.wx.BanLiShopWXPayUtil;
|
|---|
| | |
|---|
| | | if (order != null) {// 支付成功消息推送
|
|---|
| | | BanLiShopOrderMQMsg msg = new BanLiShopOrderMQMsg(order.getId(), order.getUid(),
|
|---|
| | | new BigDecimal(map.get("total_fee")).multiply(new BigDecimal("0.01")));
|
|---|
| | | Message message = new Message(MQTopicName.TOPIC_ORDER.name(),
|
|---|
| | | OrderTopicTagEnum.banLiShopOrderPaid.name(), new Gson().toJson(msg).getBytes());
|
|---|
| | | Message message =MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER,
|
|---|
| | | OrderTopicTagEnum.banLiShopOrderPaid, msg);
|
|---|
| | | producer.send(message);
|
|---|
| | | Map<String, String> returnMap = new HashMap<>();
|
|---|
| | | returnMap.put("return_code", "SUCCESS");
|
|---|
