From b77a69357da82a965cd63e76e8ceaf625ec4009b Mon Sep 17 00:00:00 2001
From: riku <risaku@163.com>
Date: 星期四, 15 七月 2021 16:37:47 +0800
Subject: [PATCH] 1. 新增信访信息获取接口 2. 新增用电量信息获取接口 3. 新增风险评估结果接口 4. 新增污染权重实时分析接口
---
src/main/kotlin/com/flightfeather/uav/common/utils/FileExchange.kt | 78 +++++++++++++++++++++++++++++++++++++++
1 files changed, 78 insertions(+), 0 deletions(-)
diff --git a/src/main/kotlin/com/flightfeather/uav/common/utils/FileExchange.kt b/src/main/kotlin/com/flightfeather/uav/common/utils/FileExchange.kt
index b282399..678ec0a 100644
--- a/src/main/kotlin/com/flightfeather/uav/common/utils/FileExchange.kt
+++ b/src/main/kotlin/com/flightfeather/uav/common/utils/FileExchange.kt
@@ -1,14 +1,19 @@
package com.flightfeather.uav.common.utils
import com.alibaba.fastjson.JSONObject
+import com.flightfeather.uav.domain.entity.RealTimeData
import com.flightfeather.uav.socket.bean.AirData
import org.apache.poi.hssf.usermodel.HSSFWorkbook
import java.io.File
import java.io.FileInputStream
import java.io.FileOutputStream
+import java.io.InputStream
import java.text.SimpleDateFormat
import java.util.*
+/**
+ * 鏃犱汉鑸归噰闆嗘暟鎹牸寮忚浆鎹�
+ */
class FileExchange {
companion object {
@@ -21,6 +26,79 @@
private val format = SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
}
+ fun exchangeBoatData(deviceCode: String, file: InputStream): List<RealTimeData> {
+ val workbook = HSSFWorkbook(file)
+ val sheet = workbook.getSheetAt(0)
+
+ val dataList = mutableListOf<RealTimeData>()
+
+ for (i in 1 until sheet.lastRowNum) {
+ val row = sheet.getRow(i)
+ val time = row.getCell(2).numericCellValue.toLong() * 1000
+ val lat = row.getCell(4).numericCellValue
+ val lng = row.getCell(5).numericCellValue
+ val value = row.getCell(6).stringCellValue
+
+ //鏃堕棿
+ val datetime = Date(time)
+ //鐩戞祴鍥犲瓙
+ val jO = JSONObject.parseObject(value)
+ val tmp = jO.getDoubleValue(TMP)
+ val spC = jO.getDoubleValue(SPCOND)
+ val tur = jO.getDoubleValue(TUR)
+ val dO = jO.getDoubleValue(DO)
+ val ph = jO.getDoubleValue(PH)
+
+ val factorsList = mutableListOf<AirData>()
+
+ factorsList.apply {
+ add(AirData().apply {
+ factorId = "1"
+ factorName = "TMP"
+ factorData = tmp
+ physicalQuantity = 0.0
+ })
+ add(AirData().apply {
+ factorId = "2"
+ factorName = "spC"
+ factorData = spC
+ physicalQuantity = 0.0
+ })
+ add(AirData().apply {
+ factorId = "3"
+ factorName = "tur"
+ factorData = tur
+ physicalQuantity = 0.0
+ })
+ add(AirData().apply {
+ factorId = "4"
+ factorName = "DO"
+ factorData = dO
+ physicalQuantity = 0.0
+ })
+ add(AirData().apply {
+ factorId = "5"
+ factorName = "PH"
+ factorData = ph
+ physicalQuantity = 0.0
+ })
+ }
+
+ val factors = JSONObject.toJSON(factorsList).toString()
+
+ dataList.add(RealTimeData().apply {
+ this.deviceCode = deviceCode
+ latitude = lat.toBigDecimal()
+ longitude = lng.toBigDecimal()
+ dataTime = datetime
+ createTime = Date()
+ this.factors = factors
+ })
+ }
+
+ return dataList
+ }
+
fun doTask() {
//source
val path = "E:\\宸ヤ綔\\閲戝北璧拌埅\\MissionData.xls"
--
Gitblit v1.9.3