|
|
@ -210,6 +210,17 @@ public class ScreenExtractServiceImpl implements ScreenExtractService { |
|
|
|
threadPool.submit(() -> { |
|
|
|
//公众参与排行(注册人数、参与人数、话题数、议题数、项目数)screen_public_party_total_data
|
|
|
|
try { |
|
|
|
|
|
|
|
ScreenCentralZoneDataFormDTO screenCentralZone = new ScreenCentralZoneDataFormDTO(); |
|
|
|
screenCentralZone.setCustomerId(customerId); |
|
|
|
screenCentralZone.setDateId(dateId); |
|
|
|
//中央区 screen_user_total_data
|
|
|
|
try { |
|
|
|
screenCentralZoneDataAbsorptionService.centralZoneDataHub(screenCentralZone); |
|
|
|
} catch (Exception e) { |
|
|
|
log.error("中央区抽取到大屏失败,customerId为:" + customerId + "dateId为:" + dateId, e); |
|
|
|
} |
|
|
|
|
|
|
|
try { |
|
|
|
publicPartiTotalDataExtractService.extractPublicPartiTotalData(customerId, dateId); |
|
|
|
} catch (Exception e) { |
|
|
@ -246,15 +257,6 @@ public class ScreenExtractServiceImpl implements ScreenExtractService { |
|
|
|
}); |
|
|
|
threadPool.submit(() -> { |
|
|
|
try { |
|
|
|
ScreenCentralZoneDataFormDTO param = new ScreenCentralZoneDataFormDTO(); |
|
|
|
param.setCustomerId(customerId); |
|
|
|
param.setDateId(dateId); |
|
|
|
//中央区 screen_user_total_data
|
|
|
|
try { |
|
|
|
screenCentralZoneDataAbsorptionService.centralZoneDataHub(param); |
|
|
|
} catch (Exception e) { |
|
|
|
log.error("中央区抽取到大屏失败,customerId为:" + customerId + "dateId为:" + dateId, e); |
|
|
|
} |
|
|
|
|
|
|
|
try { |
|
|
|
// 项目(事件)分析按网格_按天统计
|
|
|
|