| | |
|---|
| | | import com.yeshi.fanli.util.StringUtil;
|
|---|
| | | import com.yeshi.fanli.util.charge.FuLuChargeApiUtil;
|
|---|
| | | import com.yeshi.fanli.util.factory.RedPackDetailFactory;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|---|
| | | import com.yeshi.fanli.util.wx.BanLiShopWXPayUtil;
|
|---|
| | |
|
|---|
| | |
|---|
| | | order.setMoneyPaymentState(BanLiShopOrder.PAY_STATE_REFUNDING);
|
|---|
| | | // 发送退款消息
|
|---|
| | | BanLiShopOrderMQMsg msg = new BanLiShopOrderMQMsg(order.getId(), order.getUid());
|
|---|
| | | Message message = new Message(MQTopicName.TOPIC_ORDER.name(),
|
|---|
| | | OrderTopicTagEnum.banLiShopOrderRefund.name(), new Gson().toJson(msg).getBytes());
|
|---|
| | | Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER,
|
|---|
| | | OrderTopicTagEnum.banLiShopOrderRefund, msg);
|
|---|
| | | message.setStartDeliverTime(System.currentTimeMillis() + 1000 * 60 * 5L);// 延时24小时通知检测微信退款状态
|
|---|
| | | SendResult result = producer.send(message);
|
|---|
| | | if (result == null) {
|
|---|
