| | |
|---|
| | | import com.yeshi.fanli.util.TokenUtil;
|
|---|
| | | import com.yeshi.fanli.util.annotation.RequestSerializableByKeyService;
|
|---|
| | | import com.yeshi.fanli.util.factory.RedPackDetailFactory;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|---|
| | |
|
|---|
| | | @Service
|
|---|
| | |
|---|
| | | UserRedPackGiftMQMsg msg = new UserRedPackGiftMQMsg();
|
|---|
| | | msg.setId(giveRecord.getId());
|
|---|
| | | msg.setUid(uid);
|
|---|
| | | Message message = new Message(MQTopicName.TOPIC_USER.name(), UserTopicTagEnum.redPackGiftDrawback.name(),
|
|---|
| | | new Gson().toJson(msg).getBytes());
|
|---|
| | | Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.redPackGiftDrawback,
|
|---|
| | | msg);
|
|---|
| | | try {
|
|---|
| | | producer.send(message);
|
|---|
| | | } catch (Exception e) {
|
|---|
