package com.ruoyi.inspectiontask.controller;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.ruoyi.common.utils.poi.ExcelUtil;
|
import com.ruoyi.framework.web.controller.BaseController;
|
import com.ruoyi.framework.web.domain.R;
|
import com.ruoyi.inspectiontask.dto.InspectionTaskDto;
|
import com.ruoyi.inspectiontask.dto.TimingTaskDto;
|
import com.ruoyi.inspectiontask.pojo.InspectionTask;
|
import com.ruoyi.inspectiontask.service.InspectionTaskService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.AllArgsConstructor;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletResponse;
|
import java.time.LocalDateTime;
|
|
/**
|
* @author :yys
|
* @date : 2025/9/19 10:52
|
*/
|
@RestController
|
@Api(tags = "巡检任务管理")
|
@RequestMapping("/inspectionTask")
|
public class InspectionTaskController extends BaseController {
|
|
@Autowired
|
private InspectionTaskService inspectionTaskService;
|
|
/**
|
* 巡检任务表表查询
|
*/
|
@GetMapping("/list")
|
@ApiOperation("巡检任务表表查询")
|
public R<IPage<InspectionTaskDto>> list(Page<InspectionTask> page, InspectionTaskDto inspectionTaskDto) {
|
IPage<InspectionTaskDto> list = inspectionTaskService.selectInspectionTaskList(page,inspectionTaskDto);
|
return R.ok(list);
|
}
|
|
|
/**
|
* 导出
|
*/
|
@PostMapping("/export")
|
@ApiOperation(value = "导出定时任务记录")
|
public void export(HttpServletResponse response) {
|
Page page = new Page<>(-1,-1);
|
InspectionTaskDto timingTask = new InspectionTaskDto();
|
IPage<InspectionTaskDto> list = inspectionTaskService.selectInspectionTaskList(page,timingTask);
|
ExcelUtil<InspectionTaskDto> util = new ExcelUtil<>(InspectionTaskDto.class);
|
util.exportExcel(response, list.getRecords(), "导出定时任务记录");
|
}
|
|
/**
|
* 巡检任务表新增修改
|
*/
|
@PostMapping("/addOrEditInspectionTask")
|
@ApiOperation("巡检任务表新增修改")
|
@Transactional(rollbackFor = Exception.class)
|
public R addOrEditInspectionTask(@RequestBody InspectionTaskDto inspectionTaskDto) {
|
return R.ok(inspectionTaskService.addOrEditInspectionTask(inspectionTaskDto));
|
}
|
|
/**
|
* 巡检任务表删除
|
*/
|
@DeleteMapping("/delInspectionTask")
|
@ApiOperation("巡检任务表删除")
|
@Transactional(rollbackFor = Exception.class)
|
public R remove(@RequestBody Long[] ids) {
|
return R.ok(inspectionTaskService.delByIds(ids));
|
}
|
|
@PostMapping("/start/{id}")
|
@ApiOperation("启动巡检并联动采集设备")
|
public R start(@PathVariable Long id) {
|
InspectionTask task = inspectionTaskService.getById(id);
|
if (task == null) return R.fail("巡检任务不存在");
|
if ("finished".equals(task.getTaskStatus())) return R.fail("任务已完成，无需重复启动");
|
if ("running".equals(task.getTaskStatus())) return R.fail("任务已在执行中");
|
task.setTaskStatus("running");
|
task.setActualStartTime(LocalDateTime.now());
|
task.setReportContent(null);
|
task.setReportTime(null);
|
inspectionTaskService.updateById(task);
|
return R.ok(task);
|
}
|
|
@PostMapping("/finish/{id}")
|
@ApiOperation("完成巡检并自动生成报告")
|
public R finish(@PathVariable Long id) {
|
InspectionTask task = inspectionTaskService.getById(id);
|
if (task == null) return R.fail("巡检任务不存在");
|
if (!"running".equals(task.getTaskStatus())) return R.fail("请先开始巡检再完成");
|
LocalDateTime now = LocalDateTime.now();
|
task.setTaskStatus("finished");
|
task.setActualEndTime(now);
|
task.setReportTime(now);
|
|
String sourceLabel = sourceLabel(task.getDeviceSource());
|
String duration = "未记录";
|
if (task.getActualStartTime() != null) {
|
long minutes = java.time.Duration.between(task.getActualStartTime(), now).toMinutes();
|
duration = minutes + " 分钟";
|
}
|
StringBuilder report = new StringBuilder();
|
report.append("巡检报告\n")
|
.append("任务名称：").append(nvl(task.getTaskName())).append("\n")
|
.append("巡检区域：").append(nvl(task.getInspectionLocation())).append("\n")
|
.append("规划路径：").append(nvl(task.getInspectionRoute())).append("\n")
|
.append("采集终端：").append(sourceLabel).append("\n")
|
.append("巡检人员：").append(nvl(task.getInspector())).append("\n")
|
.append("开始时间：").append(nvl(task.getActualStartTime())).append("\n")
|
.append("结束时间：").append(now).append("\n")
|
.append("执行时长：").append(duration).append("\n\n")
|
.append("巡检结论：按规划路径完成全部点位巡检，未发现需立即处置的重大异常；")
|
.append("现场影像、设备回传与点位记录已归档。\n")
|
.append("生成时间：").append(now);
|
task.setReportContent(report.toString());
|
inspectionTaskService.updateById(task);
|
return R.ok(task);
|
}
|
|
private static String sourceLabel(String source) {
|
if (source == null) return "人工终端";
|
switch (source) {
|
case "video": return "视频分析";
|
case "drone": return "无人机";
|
case "robot": return "巡检机器人";
|
case "manual": return "人工终端";
|
default: return source;
|
}
|
}
|
|
private static String nvl(Object v) {
|
return v == null ? "—" : v.toString();
|
}
|
|
}
|
