数据分析设计

PipelineNightWaterWaveAnalyse<EPipelineNightWaterWave>

+ EAnalyseType.PipelineNightWaterWave analyseType()+ AverageValueAnalyse dataAnalyseDependency()+ analyse(dataAnalyseContext)

数据支撑层

管网溢流

管网高水位分析

历史数据接入

EPipelineNightWaterWave

True               有波动False              无波动

分析上下文

方法标签- 私有+ 公有# 保护/子类可用! 强制子类覆盖@O 覆盖父类@S 定时器@R 引用

DataAnalyseContext

- st- tt- Sl651 sl651- List<SiteMonitor> siteMonitorList- ERtuSiteType rtuSiteType- ERainFlag rainFlag- ERainLevel rainLevel- EDayNightFlag dayNightFlag- ESunDayFlow sunDayFlow- ENightPipelineWaterWave

SunDayFlowAnalyse<ESunDayFlow>

+ EAnalyseType.SunDayFlow analyseType()+ RainAnalyse  dataAnalyseDependency()+ analyse(dataAnalyseContext)

管网夜间水位波动

数据接入层

ERainFlag

Rain              有雨NoRain         无雨

EAverageValueType

Hour               小时均值Day                 日均值SevenDay        7日均值

EDayNightFlag

Day               白天Night            夜间

newfiber-business-pipeline

                                                                                                                    EAnalyseTypeKey                                          Value                          Sort   Service                                                IDataAnalyseTag                         DataAnalyseDependency

RainAnalyse                            降雨分析                        1       RainAnalyse                                         ERainFlag、ERainLevel                  SunDayFlow                            晴天出流                        2       SunDayFlowAnalyse                            ESunDayFlow                                RainAnalyseAverageValueAnalyse             均值分析                        3       AverageValueAnalysePipelineNightWaterWave       管网夜间水位波动           4       PipelineNightWaterWaveAnalyse       EPipelineNightWaterWave            AverageValueAnalysePipelineHighWaterLevel         管网高水位分析              5       PipelineHighWaterLevelAnalyse          EPipelineHighWaterLevelPipelineOverflow                    管网溢流                        6       PipelineOverflowAnalyse                     EPipelineOverflow

实时数据接入

DataCenter

MonitorDataAccessor

# notifyAnalyser(List<DataAnalyseContext>)! monitorDataAccess()

PipelineOverflowAnalyse<EPipelineOverflow>

+ EAnalyseType.PipelineOverflow analyseType()+ analyse(dataAnalyseContext)

PipelineHighWaterLevelAnalyse<EPipelineHighWaterLevel>

+ EAnalyseType.PipelineHighWaterLevel analyseType()+ analyse(dataAnalyseContext)

管网数据中心

ListableDataAnalyse

#@R DataCenter dataCenter

# process(dataAnalyseContext)# mongoSync()

数据层

EPipelineHighWaterLevel

True               高水位False              正常水位

HistoryMonitorDataAccessor

@O monitorDataAccess()

MySQL

RainAnalyse<ERainLevel>

- ERainFlag rainFlag- ERainLevel rainLevel

+ EAnalyseType.RainAnalyse analyseType()+ analyse(dataAnalyseContext)

RealtimeMonitorDataAccessor

@O/S monitorDataAccess()

晴天出流

降雨分析

数据分析层

IDataAnalyse<IDataAnalyseTag>

EAnalyseType analyseType()void analyse(DataAnalyseContext)default List<EAnalyseType> dataAnalyseDependency

EPipelineOverflow

True               出现溢流False              未出现溢流

IDataAnalyseTag

getKey()getValye()

newfiber-data-analyse

ERtuSiteType

Rain                         雨量站Flow                        流量站WaterLevel              水位站Pipeline                   管网WaterLogging         内涝

均值分析

RainStatusAsync

- rainContinueMinute

- rainStatusAsync()

ERainLevel

0_NAN                          无降雨1_SMALL                       小雨2_MIDDLE                     中雨3_LARGE                       大雨4_STORM                      暴雨5_LARGE_STORM         大暴雨6_EX_LARGE_STORM    特大暴雨

MongoDB

newfiber-business-base

ESunDayFlow

True               有出流False              无出流

AverageValueAnalyse<>

+ EAnalyseType.AverageValueAnalyse analyseType()+ analyse(dataAnalyseContext)- @S averageValueCalcSchedule()

监测数据中心