| | |
| | | package com.flightfeather.uav.lightshare.service.impl |
| | | |
| | | import com.flightfeather.uav.biz.report.MissionReport |
| | | import com.flightfeather.uav.common.exception.BizException |
| | | import com.flightfeather.uav.domain.entity.Mission |
| | | import com.flightfeather.uav.domain.entity.RealTimeDataVehicle |
| | | import com.flightfeather.uav.domain.mapper.MissionMapper |
| | | import com.flightfeather.uav.domain.mapper.RealTimeDataVehicleMapper |
| | | import com.flightfeather.uav.lightshare.bean.BaseResponse |
| | | import com.flightfeather.uav.lightshare.bean.DataHead |
| | | import com.flightfeather.uav.lightshare.service.MissionService |
| | | import com.github.pagehelper.PageHelper |
| | | import org.springframework.stereotype.Service |
| | | import tk.mybatis.mapper.entity.Example |
| | | import javax.servlet.http.HttpServletResponse |
| | | |
| | | @Service |
| | | class MissionServiceImpl(private val missionMapper: MissionMapper) : MissionService { |
| | | class MissionServiceImpl( |
| | | private val missionMapper: MissionMapper, |
| | | private val realTimeDataVehicleMapper: RealTimeDataVehicleMapper, |
| | | private val missionReport: MissionReport, |
| | | ) : MissionService { |
| | | override fun getMission(type: String?, page: Int?, perPage: Int?): BaseResponse<List<Mission>> { |
| | | val _perPage = perPage ?: 60 |
| | | val _page = page ?: 1 |
| | |
| | | return BaseResponse(it == 1) |
| | | } |
| | | } |
| | | |
| | | override fun deleteMissionAndData(missionCode: String): Boolean { |
| | | val mission = missionMapper.selectByPrimaryKey(missionCode) ?: throw BizException("任务不存在") |
| | | missionMapper.deleteByPrimaryKey(missionCode) |
| | | realTimeDataVehicleMapper.deleteByExample(Example(RealTimeDataVehicle::class.java).apply { |
| | | createCriteria().andEqualTo("deviceCode", mission.deviceCode) |
| | | .andBetween("dataTime", mission.startTime, mission.endTime) |
| | | }) |
| | | return true |
| | | } |
| | | |
| | | override fun getReport(missionCode: String, response: HttpServletResponse) { |
| | | missionReport.execute(missionCode) |
| | | } |
| | | } |