jianjun 4 years ago
parent
commit
42a6ee7663
  1. 14
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/toscreen/impl/ScreenExtractServiceImpl.java

14
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/toscreen/impl/ScreenExtractServiceImpl.java

@ -163,7 +163,7 @@ public class ScreenExtractServiceImpl implements ScreenExtractService {
public void extractDaily(String customerId, String dateId, boolean isLast) { public void extractDaily(String customerId, String dateId, boolean isLast) {
//等待3个线程执行完毕后再 继续执行下一个客户的 避免死锁 //等待3个线程执行完毕后再 继续执行下一个客户的 避免死锁
final CountDownLatch latch = new CountDownLatch(NumConstant.FOUR); final CountDownLatch latch = new CountDownLatch(NumConstant.FOUR);
threadPool.submit(() -> { /* threadPool.submit(() -> {
//党员基本情况screen_cpc_base_data //党员基本情况screen_cpc_base_data
try { try {
partyBaseInfoService.statsPartyMemberBaseInfoToScreen(customerId, dateId); partyBaseInfoService.statsPartyMemberBaseInfoToScreen(customerId, dateId);
@ -256,7 +256,7 @@ public class ScreenExtractServiceImpl implements ScreenExtractService {
} }
latch.countDown(); latch.countDown();
log.info("extractDaily 3 thread run end ========= dateId:{},customerId:{}", dateId, customerId); log.info("extractDaily 3 thread run end ========= dateId:{},customerId:{}", dateId, customerId);
}); });*/
threadPool.submit(() -> { threadPool.submit(() -> {
//治理能力排行screen_govern_rank_data //治理能力排行screen_govern_rank_data
try { try {
@ -300,15 +300,15 @@ public class ScreenExtractServiceImpl implements ScreenExtractService {
} catch (Exception e) { } catch (Exception e) {
log.error("网格员数据统计fact_grid_member_statistics_daily抽取失败,customerId为:" + customerId + "dateId为:" + dateId, e); log.error("网格员数据统计fact_grid_member_statistics_daily抽取失败,customerId为:" + customerId + "dateId为:" + dateId, e);
} }
extractPartData(customerId, dateId); //extractPartData(customerId, dateId);
latch.countDown(); //latch.countDown();
log.info("extractDaily 4 thread run end ========= dateId:{},customerId:{}", dateId, customerId); log.info("extractDaily 4 thread run end ========= dateId:{},customerId:{}", dateId, customerId);
}); });
try { /* try {
latch.await(); //latch.await();
} catch (InterruptedException e) { } catch (InterruptedException e) {
log.error("extractDaily run exception", e); log.error("extractDaily run exception", e);
} }*/
log.info("===== extractDaily method end customerId:{}======",customerId); log.info("===== extractDaily method end customerId:{}======",customerId);
} }

Loading…
Cancel
Save