| | |
|---|
| | | import com.aliyun.openservices.ons.api.Message;
|
|---|
| | | import com.aliyun.openservices.ons.api.MessageListener;
|
|---|
| | | import com.aliyun.openservices.ons.api.Producer;
|
|---|
| | | import com.google.gson.Gson;
|
|---|
| | | import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum;
|
|---|
| | | import com.yeshi.fanli.dto.mq.order.body.OrderMoneyRecievedMQMsg;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.HongBaoV2;
|
|---|
| | |
|---|
| | | mainHongBaoId = v2.getParent().getId();
|
|---|
| | | HongBaoOrder hongBaoOrder = hongBaoOrderService.selectDetailByHongBaoId(mainHongBaoId);
|
|---|
| | | if (hongBaoOrder != null && hongBaoOrder.getCommonOrder() != null) {
|
|---|
| | | // 按订单号与用户统计资金
|
|---|
| | | String mapKey = String.format("%s#%s#%s#%s", hongBaoOrder.getCommonOrder().getOrderNo(),
|
|---|
| | | hongBaoOrder.getCommonOrder().getSourceType(), v2.getUserInfo().getId(),
|
|---|
| | | getHongBaoType(v2.getType()));
|
|---|
| | |
|---|
| | | OrderMoneyRecievedMQMsg msg = new OrderMoneyRecievedMQMsg(Integer.parseInt(type),
|
|---|
| | | Long.parseLong(uid), Integer.parseInt(sourceType), orderNo, moneyMap.get(mapKey),
|
|---|
| | | new Date(), 0);
|
|---|
| | | LogHelper.test(String.format("批量返利到账订单分发:\n key值:%s \n 内容:%s", key, new Gson().toJson(msg)));
|
|---|
| | | producer.send(MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER,
|
|---|
| | | OrderTopicTagEnum.orderFanLiSeparateByOrderNo, msg));
|
|---|
| | | }
|
|---|
