| | |
| | | import com.xcong.excoin.modules.otc.vo.SaleOrderDetailVo; |
| | | import com.xcong.excoin.rabbit.producer.OtcProducter; |
| | | import com.xcong.excoin.utils.RedisUtils; |
| | | import com.xcong.excoin.utils.ThreadPoolUtils; |
| | | import lombok.RequiredArgsConstructor; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.context.annotation.Bean; |
| | |
| | | this.baseMapper.insert(otcOrder); |
| | | this.baseMapper.insert(sale); |
| | | |
| | | ThreadPoolUtils.sendOrderMsg(); |
| | | return Result.ok("购买成功", otcOrder.getId()); |
| | | } |
| | | |
| | |
| | | this.baseMapper.insert(buy); |
| | | |
| | | memberWalletCoinDao.updateFrozenBalance(member.getId(), wallet.getId(), orderAddDto.getUsdtAmount()); |
| | | |
| | | ThreadPoolUtils.sendOrderMsg(); |
| | | return Result.ok("出售成功", otcOrder.getId()); |
| | | } |
| | | |