weiran
/
2112-cloud-pay
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat():监听

master
WeiRan 2024-08-09 14:33:25 +08:00
parent 412a87c441
commit 26f5900865
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
cloud-pay-server/src/main/java/com/muyu/cloud/pay/service/impl/OrderPayCustomerServiceImpl.java
View File

@ -1,5 +1,6 @@
package com.muyu.cloud.pay.service.impl; package com.muyu.cloud.pay.service.impl;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.dtflys.forest.Forest; import com.dtflys.forest.Forest;
@ -73,13 +74,17 @@ 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());
return 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;
} }
} }