Sfoglia il codice sorgente

修改过滤条件

xueyiming 3 mesi fa
parent
commit
d3ca2ad0bf

+ 1 - 1
offline-module/src/main/java/com/tzld/piaoquan/offline/job/WeComMessageDataJob.java

@@ -260,7 +260,7 @@ public class WeComMessageDataJob {
                 }
                 //过滤用户
                 List<WeComUser> filtered = weComUserList.stream()
-                        .filter(e -> filterUserId.contains(e.getId())).collect(Collectors.toList());
+                        .filter(e -> !filterUserId.contains(e.getId())).collect(Collectors.toList());
                 //落库逻辑
                 List<SendMessage> allSeneMessageList = new ArrayList<>();
                 for (WeComUser weComUser : filtered) {