| | |
|---|
| | | // 自购到账事务消息
|
|---|
| | | OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_ZIGOU,
|
|---|
| | | mainUser.getId(), hongBaoOrder.getCommonOrder().getSourceType(),
|
|---|
| | | hongBaoOrder.getCommonOrder().getOrderNo(), null, new Date());
|
|---|
| | | hongBaoOrder.getCommonOrder().getOrderNo(), null, new Date(),0);
|
|---|
| | | mqMsg.setOrderFirst(first);
|
|---|
| | | Message msg = new Message(MQTopicName.TOPIC_ORDER.name(), OrderTopicTagEnum.orderFanLiActual.name(),
|
|---|
| | | new Gson().toJson(mqMsg).getBytes());
|
|---|
| | |
|---|
| | | }
|
|---|
| | | if (resultCode == 1) {// 只发送新增消息
|
|---|
| | | OrderMQMsg mqMsg = new OrderMQMsg(orderId, sourceType, uid, OrderMQMsg.HANDLE_TYPE_ADD,
|
|---|
| | | isCommonOrderValid(coList));
|
|---|
| | | isCommonOrderValid(coList),0,new Date());
|
|---|
| | | Message msg = new Message(MQTopicName.TOPIC_ORDER.name(), OrderTopicTagEnum.orderStatistic.name(),
|
|---|
| | | new Gson().toJson(mqMsg).getBytes());
|
|---|
| | | producer.send(msg);
|
|---|
