package com.by4cloud.platformx.device.controller; import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.ArrayUtil; import cn.hutool.core.collection.CollUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.by4cloud.platformx.common.core.util.R; import com.by4cloud.platformx.common.log.annotation.SysLog; import com.by4cloud.platformx.device.dto.InspectionTaskQueryDTO; import com.by4cloud.platformx.device.entity.InspectionTask; import com.by4cloud.platformx.device.service.InspectionTaskService; import org.springframework.security.access.prepost.PreAuthorize; import com.by4cloud.platformx.common.excel.annotation.ResponseExcel; import io.swagger.v3.oas.annotations.security.SecurityRequirement; import org.springdoc.api.annotations.ParameterObject; import org.springframework.http.HttpHeaders; import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.Operation; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; import java.util.List; import java.util.Objects; /** * 巡检任务 * * @author syt * @date 2025-04-22 09:15:32 */ @RestController @RequiredArgsConstructor @RequestMapping("/inspectionTask" ) @Tag(description = "inspectionTask" , name = "巡检任务管理" ) @SecurityRequirement(name = HttpHeaders.AUTHORIZATION) public class InspectionTaskController { private final InspectionTaskService inspectionTaskService; /** * 分页查询 * @param page 分页对象 * @param queryDTO 巡检任务 * @return */ @Operation(summary = "分页查询" , description = "分页查询" ) @GetMapping("/page" ) @PreAuthorize("@pms.hasPermission('device_inspectionTask_view')" ) public R getInspectionTaskPage(@ParameterObject Page page, @ParameterObject InspectionTaskQueryDTO queryDTO) { return R.ok(inspectionTaskService.pageNew(page, queryDTO)); } /** * 通过id查询巡检任务 * @param id id * @return R */ @Operation(summary = "通过id查询" , description = "通过id查询" ) @GetMapping("/{id}" ) @PreAuthorize("@pms.hasPermission('device_inspectionTask_view')" ) public R getById(@PathVariable("id" ) Long id) { return R.ok(inspectionTaskService.getByIdNew(id)); } /** * 新增巡检任务 * @param inspectionTask 巡检任务 * @return R */ @Operation(summary = "新增巡检任务" , description = "新增巡检任务" ) @SysLog("新增巡检任务" ) @PostMapping @PreAuthorize("@pms.hasPermission('device_inspectionTask_add')" ) public R save(@RequestBody InspectionTask inspectionTask) { return R.ok(inspectionTaskService.save(inspectionTask)); } /** * 修改巡检任务 * @param inspectionTask 巡检任务 * @return R */ @Operation(summary = "修改巡检任务" , description = "修改巡检任务" ) @SysLog("修改巡检任务" ) @PutMapping @PreAuthorize("@pms.hasPermission('device_inspectionTask_edit')" ) public R updateById(@RequestBody InspectionTask inspectionTask) { return R.ok(inspectionTaskService.updateByIdNew(inspectionTask)); } /** * 通过id删除巡检任务 * @param ids id列表 * @return R */ @Operation(summary = "通过id删除巡检任务" , description = "通过id删除巡检任务" ) @SysLog("通过id删除巡检任务" ) @DeleteMapping @PreAuthorize("@pms.hasPermission('device_inspectionTask_del')" ) public R removeById(@RequestBody Long[] ids) { return R.ok(inspectionTaskService.removeBatchByIds(CollUtil.toList(ids))); } /** * 导出excel 表格 * @param inspectionTask 查询条件 * @param ids 导出指定ID * @return excel 文件流 */ @ResponseExcel @GetMapping("/export") @PreAuthorize("@pms.hasPermission('device_inspectionTask_export')" ) public List export(InspectionTask inspectionTask,Long[] ids) { return inspectionTaskService.list(Wrappers.lambdaQuery(inspectionTask).in(ArrayUtil.isNotEmpty(ids), InspectionTask::getId, ids)); } /** * 通过id开始巡检任务 * @param id id * @return R */ @Operation(summary = "通过id开始巡检任务" , description = "通过id开始巡检任务" ) @GetMapping("/taskStartById/{id}" ) public R taskStartById(@PathVariable("id" ) Long id) { return R.ok(inspectionTaskService.taskStartById(id)); } }