2021.11.22

riku

2021-11-22 316bb4380e276a0b9e2745ad126a5c6c0e4b221d

2021.11.22

 src/main/kotlin/com/flightfeather/uav/lightshare/service/RealTimeDataService.kt

@@ -20,6 +20,8 @@

    fun outToExcel(deviceCode: String, startTime: String, endTime: String, response: HttpServletResponse): HttpServletResponse

    fun getOriginData(deviceCode: String?, startTime: String?, endTime: String?, page: Int?, perPage: Int?): BaseResponse<List<DataVo>>

    /**
     * 数据处理
     * 去除原始数据中的异常波动值

 src/main/kotlin/com/flightfeather/uav/lightshare/service/impl/RealTimeDataServiceImpl.kt

@@ -231,7 +231,7 @@
        return contents
    }

    private fun getOriginData(deviceCode: String?, startTime: String?, endTime: String?, page: Int?, perPage: Int?): BaseResponse<List<DataVo>> {
    override fun getOriginData(deviceCode: String?, startTime: String?, endTime: String?, page: Int?, perPage: Int?): BaseResponse<List<DataVo>> {
        val _perPage = perPage ?: 60
        val _page = page ?: 1
        val sTime = startTime?.let { dateFormatter.parse(it) }

 src/main/kotlin/com/flightfeather/uav/repository/impl/AirDataRepositoryImpl.kt

@@ -270,7 +270,7 @@
        }
    }

    private fun dataTransform(vo: DataVo, bean: BaseRealTimeData) {
    fun dataTransform(vo: DataVo, bean: BaseRealTimeData) {
        bean.apply {
            deviceCode = vo.deviceCode
            latitude = vo.lat?.toBigDecimal()

 src/test/kotlin/com/flightfeather/uav/lightshare/service/impl/RealTimeDataServiceImplTest.kt

@@ -4,7 +4,13 @@
import com.flightfeather.uav.common.utils.ExcelUtil
import com.flightfeather.uav.dataprocess.DataProcess
import com.flightfeather.uav.domain.entity.RealTimeData
import com.flightfeather.uav.domain.entity.RealTimeDataVehicle
import com.flightfeather.uav.domain.mapper.RealTimeDataVehicleMapper
import com.flightfeather.uav.lightshare.service.RealTimeDataService
import com.flightfeather.uav.model.epw.EPWDataPrep
import com.flightfeather.uav.repository.AirDataRepository
import com.flightfeather.uav.repository.impl.AirDataRepositoryImpl
import com.flightfeather.uav.socket.eunm.UWDeviceType
import com.github.pagehelper.PageHelper
import org.apache.poi.xssf.streaming.SXSSFWorkbook
import org.junit.Test
@@ -28,6 +34,12 @@

    @Autowired
    lateinit var realTimeDataService: RealTimeDataService

    @Autowired
    lateinit var realTimeDataVehicleMapper: RealTimeDataVehicleMapper

    @Autowired
    lateinit var airDataRepository: AirDataRepositoryImpl

    @Test
    fun outToExcel() {
@@ -137,4 +149,31 @@
        val r = realTimeDataService.dataCalibration()
        println(r.data)
    }

    @Test
    fun dataTransform() {

        var page = 1
        var total = -1
        var count = 0

        while (total == -1 || page <= total) {
            println("------车载数据转换start------")
            val res = realTimeDataService.getOriginData("0a0000000001", "2021-01-01 00:00:00", "2021-10-25 15:37:21", page, 50000)
            res.head?.let {
                total = it.totalPage
            }
            if (page == 1) {
                println("总页数：$total")
            }
            println("当前页数：$page")
            res.data?.forEach {vo ->
                val d = RealTimeDataVehicle()
                airDataRepository.dataTransform(vo, d)
                realTimeDataVehicleMapper.insert(d)
                count++
            }
            page++
        }
    }
}