| | |
|---|
| | | import com.yeshi.fanli.service.inter.order.OrderMoneySettleService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService;
|
|---|
| | | import com.yeshi.fanli.util.Constant;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | |
|---|
| | | */
|
|---|
| | | private boolean sendOrderSubsidyUpdateLater(OrderMoneyRecievedMQMsg dto, int day) {
|
|---|
| | |
|
|---|
| | | Message msg = new Message(MQTopicName.TOPIC_ORDER.name(), OrderTopicTagEnum.orderFanLiDelay.name(),
|
|---|
| | | new Gson().toJson(dto).getBytes());
|
|---|
| | | Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderFanLiDelay,
|
|---|
| | | dto);
|
|---|
| | | msg.setKey(dto.getSourceType() + "_" + dto.getOrderId());
|
|---|
| | | long delayTime = System.currentTimeMillis() + (Constant.IS_TEST ? 1000 * 30L : 1000 * 60 * 60 * 24L * day);
|
|---|
| | | msg.setStartDeliverTime(delayTime);
|
|---|
