| | |
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void processVipShopOrder(VipShopOrder order) {
|
|---|
| | | |
|---|
| | | if (order == null || order.getDetailList() == null || order.getDetailList().size() == 0)
|
|---|
| | | return;
|
|---|
| | | |
|---|
| | |
|
|---|
| | | // 根据ext1与subUnionId跟单
|
|---|
| | | String channelTag = order.getChannelTag();
|
|---|
| | |
|---|
| | | if (!Constant.IS_TEST)
|
|---|
| | | if (result.getResultCode() == HongBaoAddResult.CODE_ADD) {// 只发送新增消息
|
|---|
| | | OrderMQMsg mqMsg = new OrderMQMsg(orderId, sourceType, uid, OrderMQMsg.HANDLE_TYPE_ADD,
|
|---|
| | | isCommonOrderValid(coList), 0, new Date(), result.isMiandan());
|
|---|
| | | isCommonOrderValid(coList), 0, new Date(), result.isMiandan(),coList.get(0).getThirdCreateTime());
|
|---|
| | | Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderStatistic, mqMsg);
|
|---|
| | | producer.send(msg);
|
|---|
| | | }
|
|---|
