|  |  |  | 
|---|
|  |  |  | 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()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|