Commit 82324ce7 authored by zhaochengming's avatar zhaochengming

省测--查询

parent f6ec7efc
...@@ -15,7 +15,10 @@ import org.springframework.beans.factory.annotation.Autowired; ...@@ -15,7 +15,10 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Comparator;
import java.util.List; import java.util.List;
import java.util.TreeSet;
import java.util.stream.Collectors;
import java.util.stream.Stream; import java.util.stream.Stream;
/** /**
...@@ -74,10 +77,17 @@ public class OcpTenantIocnServiceImpl extends ServiceImpl<OcpTenantIocnMapper, O ...@@ -74,10 +77,17 @@ public class OcpTenantIocnServiceImpl extends ServiceImpl<OcpTenantIocnMapper, O
} }
}*/ }*/
List<OcpTenantGroupIocnDto> lists = new ArrayList<>();
List<OcpTenantGroupIocnDto> groupIocnDtos = ocpTenantBaseMapper.selectAlls(); List<OcpTenantGroupIocnDto> groupIocnDtos = ocpTenantBaseMapper.selectAlls();
for (OcpTenantGroupIocnDto groupIocnDto : groupIocnDtos) {
Short isDelete = groupIocnDto.getIsDelete();
if (isDelete == 0){
lists.add(groupIocnDto);
}
}
return groupIocnDtos; return lists;
} }
...@@ -96,6 +106,11 @@ public class OcpTenantIocnServiceImpl extends ServiceImpl<OcpTenantIocnMapper, O ...@@ -96,6 +106,11 @@ public class OcpTenantIocnServiceImpl extends ServiceImpl<OcpTenantIocnMapper, O
list.add(iocn); list.add(iocn);
} }
//去重
// msgs = msgs.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(Msg :: getMsgId))), ArrayList::new));
for (byte[] bytes : list) { for (byte[] bytes : list) {
if (!(list.contains(bytes))){ if (!(list.contains(bytes))){
list.add(bytes); list.add(bytes);
......
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