Browse Source

#数据关联

zhongwei
yang_shj 1 year ago
parent
commit
f09b74cc2c
  1. 4
      hzims-service/operational/src/main/java/com/hnac/hzims/operational/census/service/impl/TargetServiceImpl.java

4
hzims-service/operational/src/main/java/com/hnac/hzims/operational/census/service/impl/TargetServiceImpl.java

@ -405,7 +405,7 @@ public class TargetServiceImpl implements TargetService {
CountDownLatch countDownLatch = new CountDownLatch(areas.size()); CountDownLatch countDownLatch = new CountDownLatch(areas.size());
List<CompleteTicketVo> completes = new ArrayList<>(); List<CompleteTicketVo> completes = new ArrayList<>();
exe.execute(()-> { exe.execute(()-> {
if(StringUtil.isEmpty(areaName)){ if(!StringUtil.isEmpty(areaName)){
for (Dept dept: areas.stream().filter(area->area.getDeptName().equals(areaName)).collect(Collectors.toList())) { for (Dept dept: areas.stream().filter(area->area.getDeptName().equals(areaName)).collect(Collectors.toList())) {
// 双票 // 双票
DoublePassRateVO doublePass = ticketInfoAllClient.getDoublePassRate(Collections.singletonList(dept.getId()), firstDateTime, LocalDateTime.now()); DoublePassRateVO doublePass = ticketInfoAllClient.getDoublePassRate(Collections.singletonList(dept.getId()), firstDateTime, LocalDateTime.now());
@ -441,8 +441,8 @@ public class TargetServiceImpl implements TargetService {
} }
completes.add(completeTicketVo); completes.add(completeTicketVo);
} }
countDownLatch.countDown();
} }
countDownLatch.countDown();
}); });
// 等待所有线程执行完成 // 等待所有线程执行完成
try { try {

Loading…
Cancel
Save