| | |
| | | import com.flightfeather.uav.lightshare.bean.DataHead |
| | | import com.flightfeather.uav.lightshare.bean.DataVo |
| | | import com.flightfeather.uav.lightshare.bean.ElectricVo |
| | | import com.flightfeather.uav.lightshare.eunm.ElectricityType |
| | | import com.flightfeather.uav.lightshare.service.ElectricityService |
| | | import com.flightfeather.uav.socket.bean.AirData |
| | | import com.github.pagehelper.PageHelper |
| | |
| | | import java.time.LocalDateTime |
| | | import java.time.ZoneId |
| | | import java.time.format.DateTimeFormatter |
| | | import kotlin.math.round |
| | | |
| | | @Service |
| | | class ElectricityServiceImpl( |
| | |
| | | createCriteria().andEqualTo("cdCompanyId", cId) |
| | | }) |
| | | //产线风机 |
| | | var d1: String? = null |
| | | var d1: CompanyDevice? = null |
| | | //废气净化装置 |
| | | var d2: String? = null |
| | | var d2: CompanyDevice? = null |
| | | |
| | | deviceCodeList.forEach { |
| | | // FIXME: 2021/11/5 此处暂时写死,后续修改 |
| | | if (it?.cdDeviceCode == "31011020210602" || it?.cdDeviceCode == "31011020210603") { |
| | | d1 = it.cdDeviceCode |
| | | }else if (it?.cdDeviceCode == "31011020210601" || it?.cdDeviceCode == "31011020210604") { |
| | | d2 = it.cdDeviceCode |
| | | if (it?.cdType == ElectricityType.ProductionLine.value) { |
| | | d1 = it |
| | | }else if (it?.cdType == ElectricityType.Purify.value) { |
| | | d2 = it |
| | | } |
| | | } |
| | | |
| | | var pageInfo = PageHelper.startPage<ElectricMinuteValue>(p, perP) |
| | | val dataList1 = electricMinuteValueMapper.selectByExample(Example(ElectricMinuteValue::class.java).apply { |
| | | createCriteria().andEqualTo("mvStatCode", d1) |
| | | createCriteria().andEqualTo("mvStatCode", d1?.cdDeviceCode) |
| | | .apply { |
| | | sTime?.let { andGreaterThanOrEqualTo("mvDataTime", it) } |
| | | eTime?.let { andLessThanOrEqualTo("mvDataTime", it) } |
| | |
| | | } |
| | | pageInfo = PageHelper.startPage<ElectricMinuteValue>(p, perP) |
| | | val dataList2 = electricMinuteValueMapper.selectByExample(Example(ElectricMinuteValue::class.java).apply { |
| | | createCriteria().andEqualTo("mvStatCode", d2) |
| | | createCriteria().andEqualTo("mvStatCode", d2?.cdDeviceCode) |
| | | .apply { |
| | | sTime?.let { andGreaterThanOrEqualTo("mvDataTime", it) } |
| | | eTime?.let { andLessThanOrEqualTo("mvDataTime", it) } |
| | |
| | | null |
| | | } |
| | | |
| | | var lsT = LocalDateTime.ofInstant(sT?.toInstant(), ZoneId.systemDefault()).withSecond(0) |
| | | val leT = LocalDateTime.ofInstant(eT?.toInstant(), ZoneId.systemDefault()).withSecond(0) |
| | | if (sT == null || eT == null) { |
| | | return BaseResponse(true, data = result) |
| | | } |
| | | |
| | | if (sT != null && eT != null) { |
| | | while (!lsT.isAfter(leT)) { |
| | | val vo = ElectricVo(lsT.format(dateFormatter2)) |
| | | if (dataList1.isNotEmpty()) { |
| | | val d = dataList1[0] |
| | | val t = LocalDateTime.ofInstant(d?.mvDataTime?.toInstant(), ZoneId.systemDefault()).withSecond(0) |
| | | if (lsT.isEqual(t)) { |
| | | var lsT = LocalDateTime.ofInstant(sT.toInstant(), ZoneId.systemDefault()).withSecond(0) |
| | | val leT = LocalDateTime.ofInstant(eT.toInstant(), ZoneId.systemDefault()).withSecond(0) |
| | | |
| | | // 根据两台设备的最长起始时间,计算其中每一分钟的对应均值 |
| | | while (!lsT.isAfter(leT)) { |
| | | // 两台设备的数据根据时间合并为一个结构体 |
| | | val vo = ElectricVo(lsT.format(dateFormatter2)) |
| | | |
| | | // FIXME: 2021/11/22 此处由于前端设备的采样时间不标准 ,采样周期并不是严格的1分钟,导致采样时间有时会缺少1分钟的数据 |
| | | // FIXME: 2021/11/22 因此,当某一分钟该设备数据轮空时,采用前一个数据作为填充 |
| | | if (dataList1.isNotEmpty()) { |
| | | val d = dataList1[0] |
| | | val t = LocalDateTime.ofInstant(d?.mvDataTime?.toInstant(), ZoneId.systemDefault()).withSecond(0) |
| | | if (lsT.isEqual(t)) { |
| | | vo.apply { |
| | | d1eA = d?.mvElectricityA ?: .0 |
| | | d1eB = d?.mvElectricityB ?: .0 |
| | | d1eC = d?.mvElectricityC ?: .0 |
| | | val s = getStatus(d, d1) |
| | | d1Status = s.first |
| | | d1StatusName = s.second |
| | | d1Avg = s.third |
| | | } |
| | | dataList1.removeAt(0) |
| | | } else { |
| | | result.lastOrNull()?.let { |
| | | vo.apply { |
| | | d1eA = d?.mvElectricityA ?: .0 |
| | | d1eB = d?.mvElectricityB ?: .0 |
| | | d1eC = d?.mvElectricityC ?: .0 |
| | | d1Status = getStatus(d) |
| | | d1eA = it.d1eA |
| | | d1eB = it.d1eB |
| | | d1eC = it.d1eC |
| | | d1Status = it.d1Status |
| | | d1StatusName = it.d1StatusName |
| | | d1Avg = it.d1Avg |
| | | } |
| | | dataList1.removeAt(0) |
| | | } |
| | | } |
| | | if (dataList2.isNotEmpty()) { |
| | | val d = dataList2[0] |
| | | val t = LocalDateTime.ofInstant(d?.mvDataTime?.toInstant(), ZoneId.systemDefault()).withSecond(0) |
| | | if (lsT.isEqual(t)) { |
| | | vo.apply { |
| | | d2eA = d?.mvElectricityA ?: .0 |
| | | d2eB = d?.mvElectricityB ?: .0 |
| | | d2eC = d?.mvElectricityC ?: .0 |
| | | d2Status = getStatus(d) |
| | | } |
| | | dataList2.removeAt(0) |
| | | } else { |
| | | result.lastOrNull()?.let { |
| | | vo.apply { |
| | | d1eA = it.d1eA |
| | | d1eB = it.d1eB |
| | | d1eC = it.d1eC |
| | | d1Status = it.d1Status |
| | | d1StatusName = it.d1StatusName |
| | | d1Avg = it.d1Avg |
| | | } |
| | | } |
| | | result.add(vo) |
| | | |
| | | lsT = lsT.plusMinutes(1) |
| | | } |
| | | if (dataList2.isNotEmpty()) { |
| | | val d = dataList2[0] |
| | | val t = LocalDateTime.ofInstant(d?.mvDataTime?.toInstant(), ZoneId.systemDefault()).withSecond(0) |
| | | if (lsT.isEqual(t)) { |
| | | vo.apply { |
| | | d2eA = d?.mvElectricityA ?: .0 |
| | | d2eB = d?.mvElectricityB ?: .0 |
| | | d2eC = d?.mvElectricityC ?: .0 |
| | | val s = getStatus(d, d2) |
| | | d2Status = s.first |
| | | d2StatusName = s.second |
| | | d2Avg = s.third |
| | | } |
| | | dataList2.removeAt(0) |
| | | } else { |
| | | result.lastOrNull()?.let { |
| | | vo.apply { |
| | | d2eA = it.d2eA |
| | | d2eB = it.d2eB |
| | | d2eC = it.d2eC |
| | | d2Status = it.d2Status |
| | | d2StatusName = it.d2StatusName |
| | | d2Avg = it.d2Avg |
| | | } |
| | | } |
| | | } |
| | | } else { |
| | | result.lastOrNull()?.let { |
| | | vo.apply { |
| | | d2eA = it.d2eA |
| | | d2eB = it.d2eB |
| | | d2eC = it.d2eC |
| | | d2Status = it.d2Status |
| | | d2StatusName = it.d2StatusName |
| | | d2Avg = it.d2Avg |
| | | } |
| | | } |
| | | } |
| | | result.add(vo) |
| | | |
| | | lsT = lsT.plusMinutes(1) |
| | | } |
| | | |
| | | return BaseResponse(true, head = DataHead(pageInfo.pageNum, pageInfo.pages), data = result) |
| | | } |
| | | |
| | | // FIXME: 2021/11/5 此处暂时写死,后续修改 |
| | | private fun getStatus(e: ElectricMinuteValue?): String { |
| | | var values = listOf(1, 100) |
| | | var status = listOf("0", "2", "3") |
| | | private fun getStatus(e: ElectricMinuteValue?, d: CompanyDevice?): Triple<String, String, Double> { |
| | | var values = mutableListOf<Int>().apply { |
| | | d?.cdLimits?.split(";")?.forEach { |
| | | it.toIntOrNull()?.let { i -> add(i) } |
| | | } |
| | | } |
| | | var status = d?.cdStatus?.split(";") ?: emptyList() |
| | | var statusNames = d?.cdStatusName?.split(";") ?: emptyList() |
| | | if (values.isEmpty()) values = mutableListOf(1, 100) |
| | | if (status.isEmpty()) status = listOf("0", "2", "3") |
| | | if (statusNames.isEmpty()) statusNames = listOf("待机", "运行", "超负荷") |
| | | if (e == null) { |
| | | return status.first() |
| | | return Triple(status.first(), statusNames.first(), .0) |
| | | } |
| | | when (e.mvStatCode) { |
| | | "31011020210601" -> { |
| | | values = listOf(1, 100) |
| | | status = listOf("0", "2", "3") |
| | | } |
| | | "31011020210602" -> { |
| | | values = listOf(13, 30) |
| | | status = listOf("0", "2", "3") |
| | | } |
| | | "31011020210603" -> { |
| | | values = listOf(1, 50, 80) |
| | | status = listOf("0", "1", "2", "3") |
| | | } |
| | | "31011020210604" -> { |
| | | values = listOf(15, 90, 125) |
| | | status = listOf("0", "1", "2", "3") |
| | | } |
| | | } |
| | | |
| | | val electricityList = mutableListOf<Double>() |
| | | electricityList.add(e.mvElectricityA) |
| | | electricityList.add(e.mvElectricityB) |
| | | electricityList.add(e.mvElectricityC) |
| | | |
| | | val avg = electricityList.average() |
| | | val avg = round(electricityList.average() * 100) / 100 |
| | | for (i in values.indices) { |
| | | if (avg < values[i]) { |
| | | return status[i] |
| | | return Triple(status[i], statusNames[i], avg) |
| | | } |
| | | } |
| | | return status.last() |
| | | return Triple(status.last(), statusNames.last(), avg) |
| | | } |
| | | } |