| | |
|---|
| | | package cn.flightfeather.supervision.business.autooutput.datasource |
|---|
| | | |
|---|
| | | import cn.flightfeather.supervision.common.exception.ResponseErrorException |
|---|
| | | import cn.flightfeather.supervision.common.utils.Constant |
|---|
| | | import cn.flightfeather.supervision.domain.ds1.entity.* |
|---|
| | | import cn.flightfeather.supervision.domain.ds2.entity.LedgerRecord |
|---|
| | |
|---|
| | | |
|---|
| | | // 从监管系统获取场景 |
|---|
| | | private fun initSceneSource(config: AopDataConfig) { |
|---|
| | | config.topTaskGuid ?: throw IllegalStateException("顶层任务id不能为null") |
|---|
| | | config.topTaskGuid ?: throw ResponseErrorException("顶层任务id不能为null") |
|---|
| | | this.config = config |
|---|
| | | this.mode = 0 |
|---|
| | | sceneSourceList.clear() |
|---|
| | | val taskSceneIdList = |
|---|
| | | aopDbMapper.monitorobjectversionMapper.getSceneByType(config.topTaskGuid, config.sceneType, config.townCode) |
|---|
| | | |
|---|
| | | aopDbMapper.scenseMapper.selectByExample(Example(Scense::class.java).apply { |
|---|
| | | createCriteria() |
|---|
| | | .andIn("guid", taskSceneIdList) |
|---|
| | | })?.let { sceneSourceList.addAll(it) } |
|---|
| | | aopDbMapper.scenseMapper.getSceneByType(config.topTaskGuid, config.sceneType, config.townCode) |
|---|
| | | sceneSourceList.addAll(taskSceneIdList) |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 从台账系统获取场景 |
|---|
