|
|
@@ -75,12 +75,9 @@ public class WeComUserDetailJob {
|
|
|
@XxlJob("syncUserDetail")
|
|
|
public ReturnT<String> syncUserDetail(String param) {
|
|
|
List<ThirdPartWeComStaff> activeStaffList = thirdPartyService.getActiveStaffList();
|
|
|
- activeStaffList = activeStaffList.stream()
|
|
|
- .filter(staff -> staff.getId() == 7)
|
|
|
- .collect(Collectors.toList());
|
|
|
CountDownLatch cdl = new CountDownLatch(activeStaffList.size());
|
|
|
for (ThirdPartWeComStaff staff : activeStaffList) {
|
|
|
- //pool.execute(() -> {
|
|
|
+ pool.execute(() -> {
|
|
|
try {
|
|
|
syncStaffUserDetail(staff);
|
|
|
} catch (Exception e) {
|
|
|
@@ -88,7 +85,7 @@ public class WeComUserDetailJob {
|
|
|
} finally {
|
|
|
cdl.countDown();
|
|
|
}
|
|
|
- //});
|
|
|
+ });
|
|
|
}
|
|
|
try {
|
|
|
cdl.await();
|