| | |
|---|
| | | |
|---|
| | | import cc.mrbird.febs.dapp.service.DappSystemService; |
|---|
| | | import cc.mrbird.febs.rabbit.QueueConstants; |
|---|
| | | import com.rabbitmq.client.Channel; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.amqp.core.Message; |
|---|
| | | import org.springframework.amqp.rabbit.annotation.RabbitListener; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; |
|---|
| | |
|---|
| | | @RabbitListener(queues = QueueConstants.QUEUE_GFA_ZY_HUA_DIAN) |
|---|
| | | public void distrbProfit(Long id) { |
|---|
| | | log.info("收到滑点分配消息:{}", id); |
|---|
| | | // dappSystemService.tradeProfitDistribute(id); |
|---|
| | | dappSystemService.tradeProfitDistribute(id); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @RabbitListener(queues = QueueConstants.USER_BUY_REWARD) |
|---|
