package com.flightfeather.uav.biz.sourcetrace
|
|
import com.flightfeather.uav.common.utils.DateUtil
|
import com.flightfeather.uav.domain.entity.Mission
|
import com.flightfeather.uav.domain.entity.RealTimeDataVehicle
|
import com.flightfeather.uav.domain.mapper.MissionMapper
|
import com.flightfeather.uav.domain.repository.MissionRep
|
import com.flightfeather.uav.domain.repository.SceneInfoRep
|
import com.flightfeather.uav.domain.repository.SourceTraceRep
|
import com.flightfeather.uav.lightshare.service.RealTimeDataService
|
import org.junit.Test
|
import org.junit.runner.RunWith
|
import org.springframework.beans.factory.annotation.Autowired
|
import org.springframework.boot.test.context.SpringBootTest
|
import org.springframework.test.context.junit4.SpringRunner
|
import tk.mybatis.mapper.entity.Example
|
|
@RunWith(SpringRunner::class)
|
@SpringBootTest
|
class SourceTraceControllerTest {
|
|
@Autowired
|
lateinit var sceneInfoRep: SceneInfoRep
|
|
@Autowired
|
lateinit var sourceTraceRep: SourceTraceRep
|
|
@Autowired
|
lateinit var missionMapper: MissionMapper
|
|
@Autowired
|
lateinit var realTimeDataService: RealTimeDataService
|
|
@Test
|
fun autoSourceTrace() {
|
val sourceTraceController = SourceTraceController(sceneInfoRep, sourceTraceRep)
|
val missions = missionMapper.selectByExample(Example(Mission::class.java).apply {
|
createCriteria().andEqualTo("deviceType", "0a")
|
.andLessThanOrEqualTo("startTime", "2024-11-07 15:00:00")
|
orderBy("startTime").desc()
|
})
|
missions.forEach { m ->
|
val rtData = realTimeDataService.getSecondData(
|
m?.deviceType,
|
m?.deviceCode,
|
DateUtil.instance.dateToString(m?.startTime, DateUtil.DateStyle.YYYY_MM_DD_HH_MM_SS),
|
DateUtil.instance.dateToString(m?.endTime, DateUtil.DateStyle.YYYY_MM_DD_HH_MM_SS),
|
null,
|
1,
|
10000
|
)
|
rtData.data?.forEach { d ->
|
val rtdVehicle = d.toBaseRealTimeData(RealTimeDataVehicle::class.java)
|
// Thread.sleep(500)
|
sourceTraceController.addOneData(rtdVehicle)
|
}
|
sourceTraceController.initTask()
|
}
|
// val rtData = realTimeDataService.getSecondData(
|
// "0a",
|
// "0a0000000001",
|
// "2025-01-06 13:32:00",
|
// "2025-01-06 15:52:36",
|
// null,
|
// 1,
|
// 10000
|
// )
|
// rtData.data?.forEach { d ->
|
// val rtdVehicle = d.toBaseRealTimeData(RealTimeDataVehicle::class.java)
|
//// Thread.sleep(500)
|
// sourceTraceController.addOneData(rtdVehicle)
|
// }
|
|
}
|
|
}
|
