| | |
|---|
| | | import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;
|
|---|
| | | import com.yeshi.fanli.util.jd.JDApiUtil;
|
|---|
| | | import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTagConstant;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|---|
| | |
|
|---|
| | |
|---|
| | | mainUser.getId(), hongBaoOrder.getCommonOrder().getSourceType(),
|
|---|
| | | 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());
|
|---|
| | | Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderFanLiActual,
|
|---|
| | | mqMsg);
|
|---|
| | | String key = mainUser.getId() + "-" + UUID.randomUUID().toString();
|
|---|
| | | msg.setKey(key);
|
|---|
| | | try {
|
|---|
| | |
|---|
| | | if (resultCode == 1) {// 只发送新增消息
|
|---|
| | | OrderMQMsg mqMsg = new OrderMQMsg(orderId, sourceType, uid, OrderMQMsg.HANDLE_TYPE_ADD,
|
|---|
| | | isCommonOrderValid(coList),0,new Date());
|
|---|
| | | Message msg = new Message(MQTopicName.TOPIC_ORDER.name(), OrderTopicTagEnum.orderStatistic.name(),
|
|---|
| | | new Gson().toJson(mqMsg).getBytes());
|
|---|
| | | Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderStatistic,
|
|---|
| | | mqMsg);
|
|---|
| | | producer.send(msg);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
