From a31721c6deee97f54ecb1dcf6d7324433c1f9dbc Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 04 Jun 2021 11:31:07 +0800
Subject: [PATCH] 20210604

---
 src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcServiceImpl.java |   14 ++++++++++++++
 1 files changed, 14 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcServiceImpl.java b/src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcServiceImpl.java
index bf070e3..2259c8d 100644
--- a/src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcServiceImpl.java
@@ -298,4 +298,18 @@
         return new FebsResponse().success();
     }
 
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public int reduceCoin(Long id) {
+        OtcOrderEntity order = otcOrderMapper.selectById(id);
+
+        MemberWalletCoinEntity saleWallet = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(order.getMemberId(), "USDT");
+        MemberWalletCoinEntity buyWallet = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(order.getOppositeMemberId(), "USDT");
+
+        memberWalletCoinMapper.updateBlockBalance(order.getCoinAmount(), buyWallet.getId());
+        memberWalletCoinMapper.reduceFrozenBalance(order.getCoinAmount(), saleWallet.getId());
+
+        otcOrderMapper.updateOrderStatusByOrderNo(OtcOrderEntity.STATUS_THREE, order.getOrderNo());
+        return 1;
+    }
 }

--
Gitblit v1.9.1