From 5d1fc41db9c48ca7e4beffdfeb789fd6f69f4d2f Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 21 Nov 2022 11:20:03 +0800
Subject: [PATCH] 20221117
---
src/main/java/cc/mrbird/febs/rabbit/consumer/UsdtUpdateConsumer.java | 29 +++++++++++++++++++++++++----
1 files changed, 25 insertions(+), 4 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/rabbit/consumer/UsdtUpdateConsumer.java b/src/main/java/cc/mrbird/febs/rabbit/consumer/UsdtUpdateConsumer.java
index aef580f..eff7ad4 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/consumer/UsdtUpdateConsumer.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/UsdtUpdateConsumer.java
@@ -1,10 +1,9 @@
package cc.mrbird.febs.rabbit.consumer;
-import cc.mrbird.febs.dapp.chain.BlockCoinService;
-import cc.mrbird.febs.dapp.chain.Trc20Service;
-import cc.mrbird.febs.dapp.chain.TrxUsdtUpdateService;
-import cc.mrbird.febs.dapp.chain.UsdtErc20UpdateService;
+import cc.mrbird.febs.common.utils.RedisUtils;
+import cc.mrbird.febs.dapp.chain.*;
import cc.mrbird.febs.dapp.chain.entity.EthUsdtChargeDto;
+import cc.mrbird.febs.dapp.service.ApiIgtOnHookPlanService;
import cc.mrbird.febs.job.BlockCoinUpdateJob;
import cc.mrbird.febs.rabbit.RabbitMqConfig;
import cn.hutool.core.util.StrUtil;
@@ -34,7 +33,27 @@
private BlockCoinService blockCoinService;
@Resource
+ private ApiIgtOnHookPlanService apiIgtOnHookPlanService;
+
+ @Resource
TrxUsdtUpdateService trxUsdtUpdateService;
+
+ @Resource
+ private RedisUtils redisUtils;
+
+ @RabbitListener(queues = RabbitMqConfig.MEMBER_COIN_INSIDE_QUEUE)
+ public void memberCoinInside(Long withdrawId) {
+ log.info("处理用户内部转账的消息:{}#", withdrawId);
+
+ apiIgtOnHookPlanService.memberCoinInsideMessage(withdrawId);
+ }
+
+ @RabbitListener(queues = RabbitMqConfig.END_ON_HOOK_QUEUE)
+ public void endOnHook(Long orderId) {
+ log.info("处理用户结束挂机的消息:{}#", orderId);
+
+ apiIgtOnHookPlanService.endOnHookMessage(orderId);
+ }
@RabbitListener(queues = RabbitMqConfig.QUEUE_USDT_UPDATE)
public void doSomething(String content) {
@@ -62,7 +81,9 @@
String address = split[0];
String tag = split[1];
if("TRC20".equals(tag)){
+ log.info("添加地址成功:{}", address);
TrxUsdtUpdateService.addressList.add(address);
+ redisUtils.lSet(ChainConstants.REDIS_KEY_ADDRESS_LIST, TrxUsdtUpdateService.addressList);
// 此时还需要给这个地址转账用于激活及后续手续费
Trc20Service.sendTrx(Trc20Service.TRX_PRIVATE_KEY,address,new BigDecimal(10));
}
--
Gitblit v1.9.1