1

zj

2026-01-14 afb9b1cefb1c2d2f57fe8f0f3c19efa354669c66

1

 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();
}

 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();
}

 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();
}

 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();
    }
}

 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();
    }

}


 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();
    }
}


 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;
    }