Commit 6d404617 authored by renjie's avatar renjie

bug修改

parent 840e792f
...@@ -142,19 +142,21 @@ public class AdministratorServiceImpl implements AdministratorService { ...@@ -142,19 +142,21 @@ public class AdministratorServiceImpl implements AdministratorService {
double childbalanceused = 0; double childbalanceused = 0;
if (account.getParent() == null) { if (account.getParent() == null) {
List<Account> children = accountRepository.findByParent(account.getName()); List<Account> children = accountRepository.findByParent(account.getName());
for (Account child : children) { if (children != null && children.size() > 0) {
List<UserPrePaidBilling> userPrePaidBillings_child = userPrePaidBillingRepository.findByUsernameAndPayMethodIn(child.getName(), Arrays.asList(1,2)); for (Account child : children) {
if (userPrePaidBillings_child != null) List<UserPrePaidBilling> userPrePaidBillings_child = userPrePaidBillingRepository.findByUsernameAndPayMethodIn(child.getName(), Arrays.asList(1,2));
childexpense += userPrePaidBillings_child.stream().mapToDouble(UserPrePaidBilling::getTotal).sum(); if (userPrePaidBillings_child != null)
childwithdrawn += child.getPromotion().getWithdrawn(); childexpense += userPrePaidBillings_child.stream().mapToDouble(UserPrePaidBilling::getTotal).sum();
UserBalance userBalance_child = userBalanceRepository.findById(child.getName()).orElse(null); childwithdrawn += child.getPromotion().getWithdrawn();
if (userBalance_child != null) { UserBalance userBalance_child = userBalanceRepository.findById(child.getName()).orElse(null);
childbalanced += userBalance_child.getBalanced(); if (userBalance_child != null) {
childbalanceused += userBalance_child.getUsed(); childbalanced += userBalance_child.getBalanced();
childbalanceused += userBalance_child.getUsed();
}
List<UserPrePaidBilling> userPrePaidBillings1_child = userPrePaidBillingRepository.findByUsernameAndPayMethod(child.getName(), 3);
if (userPrePaidBillings1_child != null)
childbanktransfer += userPrePaidBillings1_child.stream().mapToDouble(UserPrePaidBilling::getTotal).sum();
} }
List<UserPrePaidBilling> userPrePaidBillings1_child = userPrePaidBillingRepository.findByUsernameAndPayMethod(child.getName(), 3);
if (userPrePaidBillings1_child != null)
childbanktransfer += userPrePaidBillings1_child.stream().mapToDouble(UserPrePaidBilling::getTotal).sum();
} }
} }
......
...@@ -404,7 +404,6 @@ public class PaymentServiceImpl implements PaymentService { ...@@ -404,7 +404,6 @@ public class PaymentServiceImpl implements PaymentService {
internalOrder.setTransId(response.getTradeNo()); internalOrder.setTransId(response.getTradeNo());
userPaymentRepository.save(internalOrder); userPaymentRepository.save(internalOrder);
log.error(response.getBody());
String form = response.getBody(); String form = response.getBody();
return form; return form;
......
...@@ -181,7 +181,7 @@ public class BrowserTask { ...@@ -181,7 +181,7 @@ public class BrowserTask {
HttpMethod.GET, entity, IpInfoResultDto.class, "browser", ipResource.getAddr()); HttpMethod.GET, entity, IpInfoResultDto.class, "browser", ipResource.getAddr());
IpInfoResultDto ipInfoResultDto = result.getBody(); IpInfoResultDto ipInfoResultDto = result.getBody();
if (ipInfoResultDto != null && StringUtils.isBlank(ipInfoResultDto.getErrorCode())) { if (ipInfoResultDto != null && StringUtils.isBlank(ipInfoResultDto.getErrorCode())) {
if (ipInfoResultDto.getStatus().equals("Running")) { if (ipInfoResultDto.getStatus() != null && ipInfoResultDto.getStatus().equals("Running")) {
ipResource.setStatus(0); ipResource.setStatus(0);
ipResourceRepository.save(ipResource); ipResourceRepository.save(ipResource);
} }
......
...@@ -11,11 +11,6 @@ public abstract class ThreadPoolUtils { ...@@ -11,11 +11,6 @@ public abstract class ThreadPoolUtils {
private static final Logger log = LoggerFactory.getLogger(ThreadPoolUtils.class); private static final Logger log = LoggerFactory.getLogger(ThreadPoolUtils.class);
private static final int SCHEDULER_POOL_COUNT = 50;
public static final int MAX_WAITING_TASKS = 10;
public static final BlockingQueue<Runnable> schedulerQueue = new UniquePriorityBlockingQueue<>(50); public static final BlockingQueue<Runnable> schedulerQueue = new UniquePriorityBlockingQueue<>(50);
...@@ -33,7 +28,7 @@ public abstract class ThreadPoolUtils { ...@@ -33,7 +28,7 @@ public abstract class ThreadPoolUtils {
private static final int TIME_SCHEDULER_POOL_COUNT = 20; private static final int TIME_SCHEDULER_POOL_COUNT = 20;
public static final ScheduledExecutorService queryIpTasksPool = Executors.newScheduledThreadPool(TIME_SCHEDULER_POOL_COUNT, new ThreadFactory() { public static final ExecutorService queryIpTasksPool = Executors.newFixedThreadPool(TIME_SCHEDULER_POOL_COUNT, new ThreadFactory() {
int count = 1; int count = 1;
@Override @Override
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment