From 0c2965362c5f7ec353ec8819557b772a4f39a82e Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 17 Nov 2022 09:56:37 +0800
Subject: [PATCH] 20221116,IGT充值未到账,比对本地地址 同步充值USDT-TRC20

---
 src/main/java/cc/mrbird/febs/dapp/dto/UpdateAddressDto.java                     |   15 +++++++++++++++
 src/main/java/cc/mrbird/febs/dapp/controller/ApiCommonController.java           |   13 +++++++++++++
 src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java |    2 +-
 3 files changed, 29 insertions(+), 1 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/controller/ApiCommonController.java b/src/main/java/cc/mrbird/febs/dapp/controller/ApiCommonController.java
index edc578f..29e476a 100644
--- a/src/main/java/cc/mrbird/febs/dapp/controller/ApiCommonController.java
+++ b/src/main/java/cc/mrbird/febs/dapp/controller/ApiCommonController.java
@@ -2,6 +2,7 @@
 
 import cc.mrbird.febs.common.annotation.EncryptEnable;
 import cc.mrbird.febs.common.entity.FebsResponse;
+import cc.mrbird.febs.dapp.chain.TrxUsdtUpdateService;
 import cc.mrbird.febs.dapp.dto.*;
 import cc.mrbird.febs.dapp.service.DappMemberService;
 import cc.mrbird.febs.dapp.service.DappSimulateDataService;
@@ -93,4 +94,16 @@
     public FebsResponse appVersion() {
         return new FebsResponse().success().data(dappMemberService.findAppVersion());
     }
+
+    private final TrxUsdtUpdateService trxUsdtUpdateService;
+
+    @ApiOperation(value = "IGT充值未到账,比对本地地址 同步充值USDT-TRC20")
+    @GetMapping(value = "/updateAddress")
+    public FebsResponse updateAddress(@RequestBody UpdateAddressDto updateAddressDto) {
+        if("xy".equals(updateAddressDto.getSymbol())){
+            long blockHeight = Long.parseLong(updateAddressDto.getBlockHeight());
+            trxUsdtUpdateService.monitorCoinListener(blockHeight);
+        }
+        return new FebsResponse().success();
+    }
 }
diff --git a/src/main/java/cc/mrbird/febs/dapp/dto/UpdateAddressDto.java b/src/main/java/cc/mrbird/febs/dapp/dto/UpdateAddressDto.java
new file mode 100644
index 0000000..58ff3c4
--- /dev/null
+++ b/src/main/java/cc/mrbird/febs/dapp/dto/UpdateAddressDto.java
@@ -0,0 +1,15 @@
+package cc.mrbird.febs.dapp.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+@ApiModel(value = "UpdateAddressDto")
+public class UpdateAddressDto {
+
+    @ApiModelProperty(value = "标识",example = "xy")
+    private Integer symbol;
+    @ApiModelProperty(value = "区块高度",example = "49546512")
+    private String blockHeight;
+}
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java
index ca7f2a7..3b9c368 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java
@@ -154,7 +154,7 @@
 //        BigDecimal totalProfit = igtOnHookPlanOrder.getProfit();
         BigDecimal planAmount = igtOnHookPlanOrder.getPlanAmount();
 //        BigDecimal avaAmount = igtOnHookPlanOrder.getAvaAmount();
-        //更新用户表是否正在挂机状态字段为否
+        //更新用户表是否正在挂机状态字段为结算中
         DappMemberEntity dappMember = dappMemberDao.selectById(memberId);
         dappMember.setIsOnHook(3);
         dappMemberDao.updateById(dappMember);

--
Gitblit v1.9.1