lbq
2 天以前 1f2ab3faafd2c0e06d4aceb4bf5a815235a32608
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
129
130
131
132
133
134
135
136
137
package com.vincent.rsf.openApi.controller.phyz;
 
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.vincent.rsf.framework.exception.CoolException;
import com.vincent.rsf.openApi.entity.dto.CommonResponse;
import com.vincent.rsf.openApi.entity.phyz.*;
import com.vincent.rsf.openApi.service.phyz.MesReportService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
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.RestController;
 
import javax.annotation.Resource;
import java.util.List;
import java.util.Objects;
 
import static com.vincent.rsf.openApi.controller.AuthController.SIMULATED_DATA_ENABLE;
import static com.vincent.rsf.openApi.controller.phyz.ERPController.paramsFormat;
 
@Slf4j
@RestController
@RequestMapping("/mes")
@Api("银座新工厂(五期)MES接口")
public class MESController {
 
    @Resource
    private MesReportService mesReportService;
 
 
    @ApiOperation("备料通知")
    @PostMapping("/callMaterial")
    public CommonResponse callMaterial(@RequestBody Object objParams) {
        if (Objects.isNull(objParams)) {
            throw new CoolException("参数不能为空!!");
        }
        // 返回模拟数据
        if (SIMULATED_DATA_ENABLE.equals("0")) {
            return CommonResponse.ok();
        }
 
        JSONArray params = paramsFormat(objParams);
        List<MatPreparationOrder> orders = JSON.parseArray(params.toJSONString(), MatPreparationOrder.class);
        // 数据处理,转发server
        return CommonResponse.ok();
    }
 
    @ApiOperation("简单生产领料、退料AGV任务")
    @PostMapping("/transTask/simpleProduction")
    public CommonResponse simpleProductionTask(@RequestBody Object objParams) {
        if (Objects.isNull(objParams)) {
            throw new CoolException("参数不能为空!!");
        }
        // 返回模拟数据
        if (SIMULATED_DATA_ENABLE.equals("0")) {
            return CommonResponse.ok();
        }
 
        JSONArray params = paramsFormat(objParams);
        List<SimpleProductionTask> tasks = JSON.parseArray(params.toJSONString(), SimpleProductionTask.class);
        // 数据处理,转发server
        return CommonResponse.ok();
    }
 
    @ApiOperation("空托出库")
    @PostMapping("/emptyTray/callOut")
    public CommonResponse callOutEmptyTray(@RequestBody Object objParams) {
        if (Objects.isNull(objParams)) {
            throw new CoolException("参数不能为空!!");
        }
        // 返回模拟数据
        if (SIMULATED_DATA_ENABLE.equals("1")) {
            return CommonResponse.ok();
        }
 
        JSONArray params = paramsFormat(objParams);
        List<Task> tasks = JSON.parseArray(params.toJSONString(), Task.class);
        // 数据处理,转发server
        return CommonResponse.ok();
    }
 
    @ApiOperation("空托入库")
    @PostMapping("/emptyTray/backIn")
    public CommonResponse emptyTrayBackIn(@RequestBody Object objParams) {
        if (Objects.isNull(objParams)) {
            throw new CoolException("参数不能为空!!");
        }
        // 返回模拟数据
        if (SIMULATED_DATA_ENABLE.equals("1")) {
            return CommonResponse.ok();
        }
 
        JSONArray params = paramsFormat(objParams);
        List<Task> tasks = JSON.parseArray(params.toJSONString(), Task.class);
        // 数据处理,转发server
        return CommonResponse.ok();
    }
 
    // region 测试推送功能
    @ApiOperation("托盘信息同步")
    @PostMapping("/syncPalletInfo")
    public CommonResponse syncPalletInfo(@RequestBody Object objParams) {
        try {
            return mesReportService.syncPalletInfo(objParams);
        } catch (Exception e) {
            log.error("mes, syncPalletInfo", e);
        }
        return CommonResponse.ok();
    }
 
    @ApiOperation("站点信息同步")
    @PostMapping("/syncStationInfo")
    public CommonResponse syncStationInfo(@RequestBody Object objParams) {
        try {
            return mesReportService.syncStationInfo(objParams);
        } catch (Exception e) {
            log.error("mes, syncStationInfo", e);
        }
        return CommonResponse.ok();
    }
 
    @ApiOperation("AGV任务回调")
    @PostMapping("/reportTaskExecute")
    public CommonResponse reportTaskExecute(@RequestBody Object objParams) {
        try {
            return mesReportService.reportTaskExecute(objParams);
        } catch (Exception e) {
            log.error("mes, reportTaskExecute", e);
        }
        return CommonResponse.ok();
    }
    // endregion
 
}