From 97a9f6feb1778f61268033790ebad2ba2e35f061 Mon Sep 17 00:00:00 2001
From: zainali5120 <512061637@qq.com>
Date: Thu, 16 Jul 2020 17:15:44 +0800
Subject: [PATCH] EOS同步提交

---
 src/main/java/com/xcong/excoin/modules/coin/service/impl/BlockCoinServiceImpl.java |   15 +++++++++++++--
 1 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/coin/service/impl/BlockCoinServiceImpl.java b/src/main/java/com/xcong/excoin/modules/coin/service/impl/BlockCoinServiceImpl.java
index 1eae8af..1bb919e 100644
--- a/src/main/java/com/xcong/excoin/modules/coin/service/impl/BlockCoinServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/coin/service/impl/BlockCoinServiceImpl.java
@@ -295,6 +295,7 @@
                 if(StringUtils.isNotBlank(quantity)){
                     // 转账额
                     String amountStr = quantity.split("")[0];
+                    BigDecimal amount = new BigDecimal(amountStr);
                     List<MemberCoinAddressEntity> memberCoinAddress = memberCoinAddressDao.selectAllBlockAddressBySymbolAndTag(CoinTypeEnum.EOS.name(), memo);
                     if(CollectionUtils.isNotEmpty(memberCoinAddress)){
                         MemberCoinAddressEntity memberCoinAddressEntity = memberCoinAddress.get(0);
@@ -302,9 +303,19 @@
                         Long memberId = memberCoinAddressEntity.getMemberId();
                         MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, CoinTypeEnum.EOS.name());
                         if(memberCoinAddressEntity!=null){
-                            memberWalletCoinDao.updateBlockBalance(memberWalletCoinEntity.getId(),new BigDecimal(amountStr),BigDecimal.ZERO,0);
+                            memberWalletCoinDao.updateBlockBalance(memberWalletCoinEntity.getId(),amount,BigDecimal.ZERO,0);
                             // 添加冲币记录
-                            insertCoinCharge(EosService.ACCOUNT,memberId,new BigDecimal(amountStr),CoinTypeEnum.EOS.name(),memo,BigDecimal.ZERO);
+                            String orderNo = insertCoinCharge(EosService.ACCOUNT,memberId,amount,CoinTypeEnum.EOS.name(),memo,BigDecimal.ZERO);
+                            LogRecordUtils.insertMemberAccountMoneyChange(memberId, "转入", amount, CoinTypeEnum.EOS.name(), 1, 1);
+
+                            ThreadPoolUtils.sendDingTalk(5);
+                            MemberEntity member = memberDao.selectById(memberId);
+                            if (StrUtil.isNotBlank(member.getPhone())) {
+                                //String amountEos = amountStr + "EOS";
+                                Sms106Send.sendRechargeMsg(member.getPhone(), DateUtil.format(new Date(), DatePattern.NORM_DATETIME_MINUTE_PATTERN), orderNo);
+                            } else {
+                                SubMailSend.sendRechargeMail(member.getEmail(), DateUtil.format(new Date(), DatePattern.NORM_DATETIME_MINUTE_PATTERN), orderNo);
+                            }
                         }
                     }
                 }

--
Gitblit v1.9.1