| | |
| | | import com.iailab.framework.common.util.object.BeanUtils; |
| | | import com.iailab.module.model.api.mcs.McsApi; |
| | | import com.iailab.module.model.api.mcs.dto.*; |
| | | import com.iailab.module.model.api.mdk.dto.StScheduleRecordVO; |
| | | import com.iailab.module.model.common.utils.ApiSecurityUtils; |
| | | import com.iailab.module.model.common.utils.ExcelUtil; |
| | | import com.iailab.module.model.influxdb.vo.InfluxModelResultVO; |
| | | import io.swagger.v3.oas.annotations.Operation; |
| | | import io.swagger.v3.oas.annotations.tags.Tag; |
| | | import lombok.extern.slf4j.Slf4j; |
| | |
| | | } |
| | | @GetMapping("/schedule-data/last") |
| | | @Operation(summary = "调度模型最新结果查询") |
| | | public CommonResult<String> getLastScheduleData(@RequestParam String scheduleCode) { |
| | | return CommonResult.success(mcsApi.getLastScheduleData(scheduleCode)); |
| | | public CommonResult<List<StScheduleRecordVO>> getLastScheduleData(@RequestParam String scheduleCode, @RequestParam Integer limit) { |
| | | if (null == limit) { |
| | | limit = 1; |
| | | } |
| | | return CommonResult.success(mcsApi.getLastScheduleData(scheduleCode,limit)); |
| | | } |
| | | |
| | | @PostMapping("/machineRealTimeStatus") |
| | |
| | | CommonResult<List<Map<String, Object>>> getRealTimeStatus(@RequestBody List<Map<String, Object>> machines) { |
| | | return CommonResult.success(mcsApi.getRealTimeStatus(machines)); |
| | | } |
| | | |
| | | @PostMapping("/predict-data/itemNo") |
| | | @Operation(summary = "查询时间范围内预测结果") |
| | | CommonResult<Map<String,List<Object[]>>> getPredictDataItemNo(@RequestBody PreDataItemNoReqVO reqVO) { |
| | | return CommonResult.success(mcsApi.getPredictDataItemNo(reqVO)); |
| | | } |
| | | } |