解决冲突

huang

2025-11-17 e76f0739e647fe8a7e0e2618914e2faff554b1b7

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
package com.mes.device.controller;
 
import com.mes.device.request.DevicePlcBatchRequest;
import com.mes.device.service.DevicePlcOperationService;
import com.mes.device.vo.DevicePlcVO;
import com.mes.vo.Result;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
 
import javax.validation.Valid;
import java.util.List;
 
/**
 * 设备 PLC 操作控制器
 *
 * @author mes
 * @since 2025-11-17
 */
@Slf4j
@Validated
@RestController
@RequiredArgsConstructor
@RequestMapping("device/plc")
@Tag(name = "设备PLC操作", description = "多设备PLC写入与状态查询接口")
public class DevicePlcController {
 
    private final DevicePlcOperationService devicePlcOperationService;
 
    @PostMapping("/requests")
    @Operation(summary = "批量触发PLC请求", description = "对指定设备发送PLC请求字")
    public Result<List<DevicePlcVO.OperationResult>> triggerRequests(
            @Valid @RequestBody DevicePlcBatchRequest request) {
        return Result.success(devicePlcOperationService.triggerRequest(request.getDeviceIds()));
    }
 
    @PostMapping("/reports")
    @Operation(summary = "批量模拟PLC汇报", description = "对指定设备模拟PLC任务完成汇报")
    public Result<List<DevicePlcVO.OperationResult>> triggerReports(
            @Valid @RequestBody DevicePlcBatchRequest request) {
        return Result.success(devicePlcOperationService.triggerReport(request.getDeviceIds()));
    }
 
    @PostMapping("/resets")
    @Operation(summary = "批量重置PLC状态", description = "重置指定设备关联PLC的关键字段")
    public Result<List<DevicePlcVO.OperationResult>> resetPlc(
            @Valid @RequestBody DevicePlcBatchRequest request) {
        return Result.success(devicePlcOperationService.resetDevices(request.getDeviceIds()));
    }
 
    @PostMapping("/groups/{groupId}/request")
    @Operation(summary = "设备组触发PLC请求", description = "对设备组内所有设备发送PLC请求字")
    public Result<List<DevicePlcVO.OperationResult>> triggerGroupRequest(
            @PathVariable Long groupId) {
        return Result.success(devicePlcOperationService.triggerRequestByGroup(groupId));
    }
 
    @PostMapping("/groups/{groupId}/report")
    @Operation(summary = "设备组模拟PLC汇报", description = "对设备组内所有设备模拟任务完成汇报")
    public Result<List<DevicePlcVO.OperationResult>> triggerGroupReport(
            @PathVariable Long groupId) {
        return Result.success(devicePlcOperationService.triggerReportByGroup(groupId));
    }
 
    @GetMapping("/status/{deviceId}")
    @Operation(summary = "查询设备PLC状态", description = "读取单台设备的PLC数据")
    public Result<DevicePlcVO.StatusInfo> readStatus(@PathVariable Long deviceId) {
        return Result.success(devicePlcOperationService.readStatus(deviceId));
    }
 
    @GetMapping("/groups/{groupId}/status")
    @Operation(summary = "查询设备组PLC状态", description = "读取设备组内所有设备的PLC数据")
    public Result<List<DevicePlcVO.StatusInfo>> readGroupStatus(@PathVariable Long groupId) {
        return Result.success(devicePlcOperationService.readStatusByGroup(groupId));
    }
}