| | |
|---|
| | | import com.yeshi.fanli.util.StringUtil;
|
|---|
| | | import com.yeshi.fanli.util.TaoBaoConstant;
|
|---|
| | | import com.yeshi.fanli.util.TimeUtil;
|
|---|
| | | import com.yeshi.fanli.util.cmq.order.PlaceOrderCMQManager;
|
|---|
| | | import com.yeshi.fanli.util.cmq.order.TeamOrderCMQManager;
|
|---|
| | | import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;
|
|---|
| | | import com.yeshi.fanli.util.jd.JDApiUtil;
|
|---|
| | | import com.yeshi.fanli.util.mq.cmq.order.PlaceOrderCMQManager;
|
|---|
| | | import com.yeshi.fanli.util.mq.cmq.order.TeamOrderCMQManager;
|
|---|
| | | import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|---|
| | |
|---|
| | | 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);
|
|---|
| | | }
|
|---|
