| | |
|---|
| | | import com.xcong.excoin.rabbit.pricequeue.whole.WholePriceDataModel; |
|---|
| | | import com.xcong.excoin.rabbit.producer.OrderProducer; |
|---|
| | | import com.xcong.excoin.utils.dingtalk.DingTalkUtils; |
|---|
| | | import lombok.SneakyThrows; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | |
|---|
| | | import javax.validation.constraints.NotNull; |
|---|
| | |
|---|
| | | */ |
|---|
| | | public static void sendWholePrice(@NotNull Long memberId) { |
|---|
| | | EXECUTOR.execute(new Runnable() { |
|---|
| | | @SneakyThrows |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | | Thread.sleep(500); |
|---|
| | | log.info("全仓操作价格"); |
|---|
| | | |
|---|
| | | OrderProducer orderProducer = SpringContextHolder.getBean(OrderProducer.class); |
|---|
| | | orderProducer.sendWholePrice(memberId.toString()); |
|---|
| | | } |
|---|
