ApiController.java
5.32 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
package com.huaheng.control.management.controller;
import java.util.List;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import com.huaheng.control.management.dto.EquipmentStatus;
import com.huaheng.control.management.dto.Task;
import com.huaheng.control.management.dto.TaskExecutionOrder;
import com.huaheng.control.management.service.ApiService;
import com.huaheng.control.management.vo.Result;
import io.swagger.v3.oas.annotations.Operation;
@RestController
@RequestMapping("/api")
public class ApiController {
@Resource
private ApiService apiService;
@ResponseBody
@PostMapping("/reportTask")
@Operation(summary = "任务信息上报")
public Result<?> reportTask(@RequestBody @Validated Task task, HttpServletRequest request) {
task.setReporter(request.getAttribute("audience").toString());
if (!apiService.saveTask(task)) {
return Result.error("任务信息上报异常");
}
return Result.OK("任务信息上报成功");
}
@ResponseBody
@PostMapping("/reportTasks")
@Operation(summary = "任务信息上报（批量）")
public Result<?> reportTasks(@RequestBody @Validated List<Task> taskList, HttpServletRequest request) {
for (Task task : taskList) {
task.setReporter(request.getAttribute("audience").toString());
if (!apiService.saveTask(task)) {
return Result.error("任务信息上报异常");
}
}
return Result.OK("任务信息上报成功");
}
@ResponseBody
@PostMapping("/reportEquipmentStatus")
@Operation(summary = "设备状态上报")
public Result<?> reportEquipmentStatus(@RequestBody @Validated EquipmentStatus equipmentStatus, HttpServletRequest request) {
if (!apiService.saveEquipmentStatus(equipmentStatus)) {
return Result.error("设备状态上报异常");
}
return Result.OK("设备状态上报成功");
}
@ResponseBody
@PostMapping("/reportTaskExecutionOrder")
@Operation(summary = "任务执行顺序上报")
public Result<?> reportTaskExecutionOrder(@RequestBody @Validated List<TaskExecutionOrder> taskExecutionOrders, HttpServletRequest request) {
return Result.OK("任务执行顺序上报成功", apiService.saveTaskExecutionOrders(taskExecutionOrders));
}
@ResponseBody
@GetMapping("/getAllTaskStatusInfos")
@Operation(summary = "获取全部任务状态信息")
public Result<?> getAllTaskStatusInfos(HttpServletRequest request) {
return Result.OK("获取全部任务状态信息成功", apiService.getAllTaskStatusInfos());
}
@ResponseBody
@PostMapping("/queryNextTaskPackage")
@Operation(summary = "获取下一个任务信息")
public Result<?> queryNextTaskPackage(HttpServletRequest request) {
return Result.OK("获取下一个任务信息成功", apiService.getNextTaskPackage());
}
@ResponseBody
@PostMapping("/queryTaskDetails")
@Operation(summary = "任务信息查询")
public Result<?> queryTaskDetails(HttpServletRequest request) {
return Result.OK("任务信息查询成功", apiService.queryTaskDetails());
}
@ResponseBody
@PostMapping("/queryPackageTasks")
@Operation(summary = "任务信息查询（已封装）")
public Result<?> queryPackageTasks(HttpServletRequest request) {
return Result.OK("任务信息查询成功", apiService.queryTaskPackages());
}
@ResponseBody
@PostMapping("/queryHistoryTaskPackages")
@Operation(summary = "历史任务信息查询（已封装）")
public Result<?> queryHistoryTaskPackages(@RequestParam(required = false, defaultValue = "10") Long count, HttpServletRequest request) {
return Result.OK("历史任务信息查询成功", apiService.queryHistoryTaskPackages(count));
}
@ResponseBody
@PostMapping("/queryEquipmentStatus")
@Operation(summary = "设备状态查询")
public Result<?> queryEquipmentStatus(@RequestParam(required = false) String equipmentId, HttpServletRequest request) {
return Result.OK("设备状态查询成功", apiService.queryEquipmentStatus(equipmentId));
}
@ResponseBody
@PostMapping("/queryAllEquipmentStatus")
@Operation(summary = "所有设备状态查询")
public Result<?> queryAllEquipmentStatus(HttpServletRequest request) {
return Result.OK("所有设备状态查询成功", apiService.queryAllEquipmentStatus());
}
@ResponseBody
@PostMapping("/queryTodayTaskSummary")
@Operation(summary = "今日任务摘要")
public Result<?> queryTodayTaskSummary(HttpServletRequest request) {
return Result.OK("今日任务摘要获取成功", apiService.queryTodayTaskSummary());
}
}