From afb9b1cefb1c2d2f57fe8f0f3c19efa354669c66 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 14 Jan 2026 14:42:08 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/service/impl/UserRechargeServiceImpl.java | 7 +++++++
src/main/java/com/nq/ws/WebSocketClientBeanConfig.java | 18 +++++++++---------
src/main/java/com/nq/service/impl/UserWithdrawServiceImpl.java | 7 +++++++
src/main/java/com/nq/service/IUserWithdrawService.java | 2 ++
src/main/java/com/nq/service/IUserRechargeService.java | 2 ++
src/main/java/com/nq/service/IUserService.java | 2 ++
src/main/java/com/nq/service/impl/UserServiceImpl.java | 7 +++++++
7 files changed, 36 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/nq/service/IUserRechargeService.java b/src/main/java/com/nq/service/IUserRechargeService.java
index f4bf91e..31a7069 100644
--- a/src/main/java/com/nq/service/IUserRechargeService.java
+++ b/src/main/java/com/nq/service/IUserRechargeService.java
@@ -41,4 +41,6 @@
BigDecimal CountTotalRechargeAmountByTime(Integer paramInteger);
List<UserRecharge> exportByAdmin( Integer agentId, Integer userId, String realName, Integer state, String beginTime, String endTime, HttpServletRequest request);
+
+ int countPendingRecharge();
}
diff --git a/src/main/java/com/nq/service/IUserService.java b/src/main/java/com/nq/service/IUserService.java
index 9bb91b9..d2a14aa 100644
--- a/src/main/java/com/nq/service/IUserService.java
+++ b/src/main/java/com/nq/service/IUserService.java
@@ -92,4 +92,6 @@
ServerResponse queryMyOption(String code, HttpServletRequest request);
ServerResponse getMoenyLog(String type,HttpServletRequest request);
+
+ int countPendingAuth();
}
diff --git a/src/main/java/com/nq/service/IUserWithdrawService.java b/src/main/java/com/nq/service/IUserWithdrawService.java
index 95cdc16..e6ea808 100644
--- a/src/main/java/com/nq/service/IUserWithdrawService.java
+++ b/src/main/java/com/nq/service/IUserWithdrawService.java
@@ -35,4 +35,6 @@
ServerResponse deleteWithdraw(Integer withdrawId);
List<UserWithdraw> exportByAdmin( Integer agentId, Integer userId, String realName, Integer state, String beginTime, String endTime, HttpServletRequest request);
+
+ int countPendingWithdraw();
}
diff --git a/src/main/java/com/nq/service/impl/UserRechargeServiceImpl.java b/src/main/java/com/nq/service/impl/UserRechargeServiceImpl.java
index cd8100a..e371ed3 100644
--- a/src/main/java/com/nq/service/impl/UserRechargeServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/UserRechargeServiceImpl.java
@@ -404,4 +404,11 @@
return userRecharges;
}
+
+ @Override
+ public int countPendingRecharge() {
+ com.baomidou.mybatisplus.core.conditions.query.QueryWrapper<UserRecharge> queryWrapper = new com.baomidou.mybatisplus.core.conditions.query.QueryWrapper<>();
+ queryWrapper.eq("order_status", 0);
+ return this.userRechargeMapper.selectCount(queryWrapper).intValue();
+ }
}
diff --git a/src/main/java/com/nq/service/impl/UserServiceImpl.java b/src/main/java/com/nq/service/impl/UserServiceImpl.java
index 699ce23..4972401 100644
--- a/src/main/java/com/nq/service/impl/UserServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/UserServiceImpl.java
@@ -1203,5 +1203,12 @@
return ServerResponse.createBySuccess(mapper.selectList(queryWrapper));
}
+ @Override
+ public int countPendingAuth() {
+ QueryWrapper<User> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("is_active", 1);
+ return this.userMapper.selectCount(queryWrapper).intValue();
+ }
+
}
diff --git a/src/main/java/com/nq/service/impl/UserWithdrawServiceImpl.java b/src/main/java/com/nq/service/impl/UserWithdrawServiceImpl.java
index e0ac187..aae1bfa 100644
--- a/src/main/java/com/nq/service/impl/UserWithdrawServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/UserWithdrawServiceImpl.java
@@ -413,5 +413,12 @@
}
+
+ @Override
+ public int countPendingWithdraw() {
+ com.baomidou.mybatisplus.core.conditions.query.QueryWrapper<UserWithdraw> queryWrapper = new com.baomidou.mybatisplus.core.conditions.query.QueryWrapper<>();
+ queryWrapper.eq("with_status", 0);
+ return this.userWithdrawMapper.selectCount(queryWrapper).intValue();
+ }
}
diff --git a/src/main/java/com/nq/ws/WebSocketClientBeanConfig.java b/src/main/java/com/nq/ws/WebSocketClientBeanConfig.java
index 53ac141..97f80ff 100644
--- a/src/main/java/com/nq/ws/WebSocketClientBeanConfig.java
+++ b/src/main/java/com/nq/ws/WebSocketClientBeanConfig.java
@@ -29,15 +29,15 @@
// } catch (Exception e) {
// log.error("jpWebsocketRunClient 异常: {}", e.getMessage());
// }
-// try {
-// USWebsocketRunClient usWebsocketRunClient = new USWebsocketRunClient(new URI(PropertiesUtil.getProperty("US_WS_URL")), EStockType.US);
-// usWebsocketRunClient.connect();
-// usWebsocketRunClient.setConnectionLostTimeout(0);
-// startHeartbeatThread(usWebsocketRunClient);
-// retMap.put(EStockType.US.getStockKey(), usWebsocketRunClient);
-// } catch (Exception e) {
-// log.error("usWebsocketRunClient 异常: {}", e.getMessage());
-// }
+ try {
+ USWebsocketRunClient usWebsocketRunClient = new USWebsocketRunClient(new URI(PropertiesUtil.getProperty("US_WS_URL")), EStockType.US);
+ usWebsocketRunClient.connect();
+ usWebsocketRunClient.setConnectionLostTimeout(0);
+ startHeartbeatThread(usWebsocketRunClient);
+ retMap.put(EStockType.US.getStockKey(), usWebsocketRunClient);
+ } catch (Exception e) {
+ log.error("usWebsocketRunClient 异常: {}", e.getMessage());
+ }
return retMap;
}
--
Gitblit v1.9.3