1. 新增用电量数据查询接口 2. 调整污染权重算法

riku

2021-07-12 d978297ae85b2d7453054e616bbbe87bfabe9cbe

 src/main/kotlin/com/flightfeather/uav/model/epw/EPWModel.kt

@@ -1,7 +1,9 @@
package com.flightfeather.uav.model.epw

import com.flightfeather.uav.domain.entity.Company
import com.flightfeather.uav.lightshare.bean.CompanySOP
import com.flightfeather.uav.lightshare.bean.DataVo
import com.flightfeather.uav.model.*
import com.flightfeather.uav.socket.eunm.FactorType
import java.math.BigDecimal

/**
@@ -9,41 +11,25 @@
 * 根据走航监测数据，结合风速、风向、监测点与企业的相对位置等因素，计算企业对监测区域的影响程度
 * @author riku
 */
class EPWModel {
class EPWModel : BaseModel<DataVo, CompanySOP>() {

    private val windDirWeight = WindDirWeight()
    private val windDisWeight = WindDisWeight()

    private lateinit var datas: List<DataVo>
    private lateinit var sources: List<Company>

    fun execute() {
        datas.forEach d@{d ->
            if (d.lng == null || d.lng == 0.0 || d.lat == null || d.lat == 0.0) {
                return@d
            }

            var con = 0
            var ws = 0.0
            var wd = 0
            var hr = 0
            val lng = d.lng
            val lat = d.lat

            sources.forEach s@ { s ->
                // 经纬度有效性判断
                if (s.ciLongitude == null || s.ciLongitude == BigDecimal(0) || s.ciLatitude == null || s.ciLatitude == BigDecimal(0)) {
                    return@s
                }

                val p1 = Pair(lng!!, lat!!)
                val p2 = Pair(s.ciLongitude.toDouble(), s.ciLatitude.toDouble())
                windDirWeight.getWeight(p1, p2, wd)

                windDisWeight.getWeight(p1, p2, ws)


            }
    // 默认监测点经纬度
    var defaultLocation: Pair<Double, Double>? = null
        set(value) {
            weights = listOf(WindDirWeight(value), WindDisWeight(value))
        }
    }

    override var dataPrep: BaseDataPrep<DataVo, CompanySOP> = EPWDataPrep()

    override var factorTypes: List<FactorType> = WeightType.weightType

    override var weights: List<BaseWeight<DataVo, CompanySOP>> = listOf(WindDirWeight(defaultLocation), WindDisWeight(defaultLocation))

    override var sections: List<BaseSection<DataVo, CompanySOP>> = listOf(TimeSection())

    override fun mDataCheck(m: DataVo): Boolean = !(m.lng == null || m.lng == 0.0 || m.lat == null || m.lat == 0.0)

    override fun sopCheck(s: CompanySOP): Boolean =
        !(s.ciLongitude == null || s.ciLongitude == BigDecimal(0) || s.ciLatitude == null || s.ciLatitude == BigDecimal(0))

}