| | |
| | | * 统计飞行次数 |
| | | */ |
| | | @PostMapping("/{workspace_id}/patrol_statistics") |
| | | public ResponseResult<WaylineJobCountDTO> patrolStatistics(@PathVariable(name = "workspace_id") String workspaceId){ |
| | | public ResponseResult<WaylineJobCountDTO> patrolStatistics(@PathVariable(name = "workspace_id") String workspaceId,String queryTime){ |
| | | |
| | | WaylineJobCountDTO waylineJobCountDTO = waylineJobService.patrolStatistics(workspaceId); |
| | | WaylineJobCountDTO waylineJobCountDTO = waylineJobService.patrolStatistics(workspaceId,queryTime); |
| | | |
| | | return ResponseResult.success(waylineJobCountDTO); |
| | | } |
| | |
| | | import com.dji.sample.wayline.model.param.WaylineJobQueryParam; |
| | | import org.apache.ibatis.annotations.Param; |
| | | |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @author sean |
| | | * @version 1.1 |
| | |
| | | Page<WaylineJobEntity> getPage(Page<WaylineJobEntity> waylineJobEntityPage, @Param("queryParam") WaylineJobQueryParam param, @Param("workspaceId") String workspaceId); |
| | | |
| | | WaylineJobEntity getLatest(@Param("workspaceId")String workspaceId,@Param("queryParam") WaylineJobQueryParam waylineJobQueryParam); |
| | | |
| | | List<WaylineJobEntity> patrolStatistics(@Param("workspaceId") String workspaceId, @Param("queryTime") String queryTime); |
| | | } |
| | |
| | | |
| | | |
| | | </select> |
| | | <select id="patrolStatistics" resultType="com.dji.sample.wayline.model.entity.WaylineJobEntity"> |
| | | SELECT |
| | | * |
| | | FROM |
| | | wayline_job |
| | | WHERE 1=1 |
| | | and status = 3 |
| | | <if test="queryTime != null and queryTime != ''"> |
| | | and ( FROM_UNIXTIME( execute_time / 1000, '%Y' ) = #{queryTime} OR FROM_UNIXTIME( execute_time / 1000, '%Y-%m' ) = #{queryTime} ) |
| | | </if> |
| | | <if test="workspaceId != null and workspaceId != ''"> |
| | | and workspace_id = #{workspaceId} |
| | | </if> |
| | | </select> |
| | | </mapper> |
| | |
| | | */ |
| | | WaylineJobEntity getLatestJob(String workspaceId, WaylineJobQueryParam waylineJobQueryParam); |
| | | |
| | | WaylineJobCountDTO patrolStatistics(String workspaceId); |
| | | WaylineJobCountDTO patrolStatistics(String workspaceId,String queryTime); |
| | | |
| | | void updateJobCollect(WaylineJobEntity waylineJob); |
| | | |
| | |
| | | |
| | | |
| | | @Override |
| | | public WaylineJobCountDTO patrolStatistics(String workspaceId) { |
| | | public WaylineJobCountDTO patrolStatistics(String workspaceId,String queryTime) { |
| | | WaylineJobCountDTO waylineJobCountDTO = new WaylineJobCountDTO(); |
| | | List<WaylineJobEntity> list = new LambdaQueryChainWrapper<>(mapper).eq(WaylineJobEntity::getStatus, 3).list(); |
| | | List<WaylineJobEntity> list = mapper.patrolStatistics(workspaceId,queryTime); |
| | | if (!CollectionUtils.isEmpty(list)){ |
| | | waylineJobCountDTO.setTotalNumber(list.size()); |
| | | long totalTime = list.stream().mapToLong(s -> s.getEndTime() - s.getBeginTime()).sum() / 1000; |