| | |
| | | return if (res.isEmpty()) null else res[0] |
| | | } |
| | | |
| | | fun fetchList(deviceCode: String, startTime: Date, endTime: Date): List<BaseExceptionResult?> { |
| | | return sourceTraceMsgBlobMapper.selectWithBlob(deviceCode, startTime, endTime) |
| | | .map { stm -> |
| | | fun fetchList( |
| | | deviceCode: String, |
| | | startTime: Date, |
| | | endTime: Date, |
| | | msgType: MsgType? = null, |
| | | ): List<BaseExceptionResult?> { |
| | | var res = sourceTraceMsgBlobMapper.selectWithBlob(deviceCode, startTime, endTime) |
| | | if (msgType !== null) { |
| | | res = res.filter { it?.msgType == msgType.value } |
| | | } |
| | | |
| | | return res.map { stm -> |
| | | when (stm?.msgType) { |
| | | MsgType.PolClue.value, |
| | | MsgType.DataChange.value, |
| | |
| | | .andGreaterThanOrEqualTo("startTime", mission.startTime) |
| | | .andLessThanOrEqualTo("endTime", mission.endTime) |
| | | }).map { it?.id } |
| | | if (idList.isEmpty()) return 0 |
| | | sourceTraceMsgMapper.deleteByExample(Example(SourceTraceMsg::class.java).apply { |
| | | createCriteria().andIn("id", idList) |
| | | }) |