feat():监听

master
WeiRan 2024-08-09 14:40:13 +08:00
parent 7d21534df2
commit 98479e94e9
1 changed files with 0 additions and 3 deletions

View File

@ -74,16 +74,13 @@ public class OrderPayCustomerServiceImpl extends ServiceImpl<OrderPayCustomerMap
@Override @Override
public List<String> getCustomerAllList() { public List<String> getCustomerAllList() {
List<String> nacosServerAllList = nacosServerService.nacosServerAllList(); List<String> nacosServerAllList = nacosServerService.nacosServerAllList();
log.info("数据库查询数据 nacosServerAllList ---> {}" ,JSONObject.toJSONString(nacosServerAllList));
LambdaQueryWrapper<OrderPayCustomer> queryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<OrderPayCustomer> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.select(OrderPayCustomer::getAppCode); queryWrapper.select(OrderPayCustomer::getAppCode);
List<OrderPayCustomer> orderPayCustomerList = this.list(queryWrapper); List<OrderPayCustomer> orderPayCustomerList = this.list(queryWrapper);
log.info("数据库查询数据 orderPayCustomerList ---> {}" , JSONObject.toJSONString(orderPayCustomerList));
Set<String> customerSet = orderPayCustomerList.stream().map(OrderPayCustomer::getAppCode).collect(Collectors.toSet()); Set<String> customerSet = orderPayCustomerList.stream().map(OrderPayCustomer::getAppCode).collect(Collectors.toSet());
List<String> list = nacosServerAllList.stream() List<String> list = nacosServerAllList.stream()
.filter(nacosServer -> !customerSet.contains(nacosServer)) .filter(nacosServer -> !customerSet.contains(nacosServer))
.toList(); .toList();
log.info("数据库查询数据 List<String> ---> {}",JSONObject.toJSONString(list));
return list; return list;
} }