| | |
|---|
| | | add(RTExcWindLevel4(config) { exceptionCallback(it) }.also { it.init() }) |
|---|
| | | add(RTExcWindLevel6(config) { exceptionCallback(it) }.also { it.init() }) |
|---|
| | | add(RTExcChangeRate(config) { exceptionCallback(it) }.also { it.init() }) |
|---|
| | | add(RTWarnChangeRate(config) { dataChangeCallback(it) }.also { it.init() }) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | pollutedSummary.addClue(ex) |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 数据变化提醒回调 |
|---|
| | | private fun dataChangeCallback(ex: PollutedClue) { |
|---|
| | | // 溯源污染源信息 |
|---|
| | | ex.searchScenes(sceneInfoRep) |
|---|
| | | |
|---|
| | | // 广播数据变化提醒 |
|---|
| | | UnderwayWebSocketSender.broadcast(MsgType.DataChange.value, ex) |
|---|
| | | } |
|---|
| | | |
|---|
| | | private fun summaryCallback(ex: PollutedSummary.AnalysisResult) { |
|---|
| | | // 广播污染溯源异常结果 |
|---|
| | | UnderwayWebSocketSender.broadcast(MsgType.AnaResult.value, ex) |
|---|
