From bf13ce8d93e4e3125ec08b32949ca7ba5f375f6c Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 04 Feb 2021 17:09:55 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java | 5 +++-- src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java | 19 +++++++++---------- 2 files changed, 12 insertions(+), 12 deletions(-) diff --git a/src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java b/src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java index 5ee1e1a..d6c5c3c 100644 --- a/src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java +++ b/src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java @@ -772,6 +772,7 @@ * * @param */ + @Transactional(rollbackFor = Exception.class) public void dealCoinOut(List<ContractHoldOrderEntity> orderList, List<OrderModel> orderModels) { if (CollectionUtils.isNotEmpty(orderList)) { Map<Long, Integer> modelMap = new HashMap<Long, Integer>(); @@ -802,7 +803,7 @@ bombOrder(holdOrderEntity); } - MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(coinsOrder.getMemberId(), CoinTypeConvert.convertContractTypeToCoin(coinsOrder.getSymbol())); + MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(coinsOrder.getMemberId(), CoinTypeEnum.USDT.name()); // 流水记录 TODO MemberAccountFlowEntity record = new MemberAccountFlowEntity(); @@ -863,7 +864,7 @@ contractOrderService.save(contractOrderEntity); //更新用户钱包数据 - MemberWalletContractEntity usdt = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memId, CoinTypeConvert.convertContractTypeToCoin(coinsOrder.getSymbol())); + MemberWalletContractEntity usdt = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memId, CoinTypeEnum.USDT.name()); // 减去的时候用负数 BigDecimal totalPrice = coinsOrder.getBondAmount().negate(); diff --git a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java index 07dea96..658e0b7 100644 --- a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java +++ b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java @@ -201,18 +201,17 @@ walletContractSimulate.setWalletCode(CoinTypeEnum.USDT.name()); memberWalletContractSimulateDao.insert(walletContractSimulate); + //初始化合约钱包 + MemberWalletContractEntity walletContract = new MemberWalletContractEntity(); + walletContract.setMemberId(member.getId()); + walletContract.setAvailableBalance(AppContants.INIT_MONEY); + walletContract.setFrozenBalance(AppContants.INIT_MONEY); + walletContract.setTotalBalance(AppContants.INIT_MONEY); + walletContract.setBorrowedFund(AppContants.INIT_MONEY); + walletContract.setWalletCode(CoinTypeEnum.USDT.name()); + memberWalletContractDao.insert(walletContract); for (CoinTypeEnum coinTypeEnum : CoinTypeEnum.values()) { - //初始化合约钱包 - MemberWalletContractEntity walletContract = new MemberWalletContractEntity(); - walletContract.setMemberId(member.getId()); - walletContract.setAvailableBalance(AppContants.INIT_MONEY); - walletContract.setFrozenBalance(AppContants.INIT_MONEY); - walletContract.setTotalBalance(AppContants.INIT_MONEY); - walletContract.setBorrowedFund(AppContants.INIT_MONEY); - walletContract.setWalletCode(coinTypeEnum.name()); - memberWalletContractDao.insert(walletContract); - // 初始化币币钱包 MemberWalletCoinEntity walletCoin = new MemberWalletCoinEntity(); walletCoin.setWalletCode(coinTypeEnum.name()); -- Gitblit v1.9.1