| | |
| | | import org.springframework.boot.test.context.SpringBootTest |
| | | import org.springframework.test.context.junit4.SpringRunner |
| | | import tk.mybatis.mapper.entity.Example |
| | | import java.time.LocalDateTime |
| | | import java.time.ZoneId |
| | | |
| | | @RunWith(SpringRunner::class) |
| | | @SpringBootTest |
| | |
| | | |
| | | @Test |
| | | fun autoSourceTrace() { |
| | | val sourceTraceController = SourceTraceController(sceneInfoRep, sourceTraceRep, false) |
| | | val mCode = listOf("SH-CN-20241227", "SH-CN-20241127", "SH-CN-20240906", "SH-CN-20240830(05)", |
| | | "SH-CN-20240830(04)", "SH-CN-20240823", "SH-CN-20240723(02)", "SH-CN-20250723(01)") |
| | | mCode.forEach { c-> |
| | | missionRep.findOne(c)?.let {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) |
| | | val sourceTraceController = SourceTraceController(sceneInfoRep, sourceTraceRep, true) |
| | | // val mCode = listOf( |
| | | // "SH-CN-20241227", "SH-CN-20241127", "SH-CN-20240906", "SH-CN-20240830(05)", |
| | | // "SH-CN-20240830(04)", "SH-CN-20240823", |
| | | // "SH-CN-20240723(02)", |
| | | //// "SH-CN-20250723(01)" |
| | | // ) |
| | | // val startTime = LocalDateTime.of(2024, 12, 31, 0, 0, 0).atZone(ZoneId.systemDefault()).toInstant() |
| | | val startTime = LocalDateTime.of(2024, 12, 4, 0, 0, 0).atZone(ZoneId.systemDefault()).toInstant() |
| | | val endTime = LocalDateTime.of(2025, 4, 11, 23, 59, 59).atZone(ZoneId.systemDefault()).toInstant() |
| | | val missions = missionMapper.selectByExample(Example(Mission::class.java).apply { |
| | | createCriteria().andBetween("startTime", startTime, endTime) |
| | | }) |
| | | 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() |
| | | sourceTraceController.addOneData(rtdVehicle) |
| | | } |
| | | sourceTraceController.initTask() |
| | | } |
| | | // val missions = missionMapper.selectByExample(Example(Mission::class.java).apply { |
| | | // createCriteria().andEqualTo("deviceType", "0a") |
| | |
| | | |
| | | @Test |
| | | fun deleteSourceTrace() { |
| | | val mCode = listOf("SH-CN-20241227", "SH-CN-20241127", "SH-CN-20240906", "SH-CN-20240830(05)", |
| | | "SH-CN-20240830(04)", "SH-CN-20240823", "SH-CN-20240723(02)", "SH-CN-20250723(01)") |
| | | mCode.forEach {c -> |
| | | missionRep.findOne(c)?.let { |
| | | sourceTraceRep.delete(it) |
| | | } |
| | | // val mCode = listOf( |
| | | // "SH-CN-20241227", "SH-CN-20241127", "SH-CN-20240906", "SH-CN-20240830(05)", |
| | | // "SH-CN-20240830(04)", "SH-CN-20240823", |
| | | // "SH-CN-20240723(02)", |
| | | //// "SH-CN-20250723(01)" |
| | | // ) |
| | | val startTime = LocalDateTime.of(2024, 12, 4, 0, 0, 0).atZone(ZoneId.systemDefault()).toInstant() |
| | | val endTime = LocalDateTime.of(2025, 4, 11, 23, 59, 59).atZone(ZoneId.systemDefault()).toInstant() |
| | | val missions = missionMapper.selectByExample(Example(Mission::class.java).apply { |
| | | createCriteria().andBetween("startTime", startTime, endTime) |
| | | }) |
| | | missions.forEach { m -> |
| | | m ?: return@forEach |
| | | sourceTraceRep.delete(m) |
| | | } |
| | | } |
| | | |