实时数据大屏产品系统

1.为影院端实现票务行业的"实时 + 离线"双模数据大屏
2.实现影院票务数字化，实现实时经营指标监控，如排片效率、上座率、卖品销量数据秒级更新，及时调整经营策略

1.实时采集模块：通过flink-cdc实时采集业务数据库binlog，将数据写入kafka队列
2.票务实时计算模块：flink实时接收kafka数据，按放映日期实时计算影片票房、影院票房、观影人次、排片效率等指标
3.卖品实时计算模块：通过flink实时计算影院卖品实时销量指标
4.会员实时计算模块：通过flink实时计算影院会员开卡、充值、退卡等指标
5.离线指标计算模块：通过自建clickhouse集群，每天离线计算昨日指标

数据大屏包含实时大屏和离线大屏。实时大屏采用Flink CDC、Flink、HBase、Redis实现当天数据秒级更新，计算结果写入Redis，统计指标涵盖实时交易票房、放映票房、预售票房、热销卖品、排片效率等。离线大屏采用ClickHouse 按T+1方式计算昨日数据，DolphinScheduler调度，结果数据写入MySQL。