| | |
|---|
| | | 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;
|
|---|
| | | import com.yeshi.fanli.entity.order.HongBaoOrder;
|
|---|
| | | import com.yeshi.fanli.entity.order.HongBaoV2SettleTemp;
|
|---|
| | | import com.yeshi.fanli.log.LogHelper;
|
|---|
| | | import com.yeshi.fanli.service.inter.hongbao.HongBaoV2SettleTempService;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.HongBaoOrderService;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.HongBaoV2Service;
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public Action consume(Message message, ConsumeContext context) {
|
|---|
| | | LogHelper.mqInfo("consumer:OrderMoneyRecievedMessageListener", message.getMsgID(), message.getTopic(),
|
|---|
| | | message.getTag(), new String(message.getBody()));
|
|---|
| | | // 根据红包做订单分发
|
|---|
| | | if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {
|
|---|
| | | if (OrderTopicTagEnum.orderFanLiActual.name().equalsIgnoreCase(message.getTag())) {
|
|---|
| | |
|---|
| | | 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));
|
|---|
| | | }
|
|---|
