2025.7.31 1. 新增基础数据产品相关接口

feiyu02

2025-07-31 6688232eaa889eeb6c58d0d804b587699db55ec2

 src/main/kotlin/cn/flightfeather/supervision/lightshare/service/impl/DataProductServiceImpl.kt

@@ -7,6 +7,7 @@
import cn.flightfeather.supervision.business.report.file.ReportThree
import cn.flightfeather.supervision.business.report.file.ReportTwo
import cn.flightfeather.supervision.common.exception.BizException
import cn.flightfeather.supervision.domain.ds1.mapper.DataProductMapper
import cn.flightfeather.supervision.domain.ds1.repository.TaskRep
import cn.flightfeather.supervision.lightshare.service.DataProductService
import cn.flightfeather.supervision.lightshare.vo.AreaVo
@@ -14,6 +15,7 @@
import cn.flightfeather.supervision.model.dataproduct.DataProdOption
import cn.flightfeather.supervision.model.dataproduct.PPListProbRecurrence
import cn.flightfeather.supervision.model.dataproduct.PPListProblemChange
import org.springframework.beans.BeanUtils
import org.springframework.beans.factory.annotation.Value
import org.springframework.http.HttpHeaders
import org.springframework.http.MediaType
@@ -33,6 +35,7 @@
    private val dbMapper: DbMapper,
    @Value("\${filePath}") private val filePath: String,
    private val reportTaskCtrl: ReportTaskCtrl,
    private val dataProductMapper: DataProductMapper,
) : DataProductService {

    override fun downloadProduct(
@@ -83,10 +86,30 @@
    }

    override fun problemChangeList(option: DataProdOption): List<PPListProblemChange> {
        TODO("Not yet implemented")
        return dataProductMapper.problemChangeList(option)
    }

    override fun problemRecurrence(option: DataProdOption): List<PPListProbRecurrence> {
        TODO("Not yet implemented")
        val res = mutableListOf<PPListProbRecurrence>()
        problemChangeList(option).forEach {pcl ->
            val r = res.find {
                it.sceneName == pcl.sceneName && it.problemName == pcl.problemName
            }
            if (r == null) {
                val probRec = PPListProbRecurrence()
                BeanUtils.copyProperties(pcl, probRec)
                probRec.apply {
                    proNum = 1
                    changeNum += pcl.changeSum
                }
                res.add(probRec)
            } else {
                r.apply {
                    proNum++
                    changeNum += pcl.changeSum
                }
            }
        }
        return res
    }
}