lsh#

1

2 天以前 fb265bc00a43a463a95fc380ded0221e4535f997

 rsf-open-api/src/main/java/com/vincent/rsf/openApi/controller/phyz/MESController.java

@@ -2,26 +2,35 @@

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
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")
@@ -30,7 +39,17 @@
            throw new CoolException("参数不能为空！！");
        }
        // 返回模拟数据
        if (SIMULATED_DATA_ENABLE.equals("0")) {
        if (SIMULATED_DATA_ENABLE.equals("1")) {
            JSONArray params = paramsFormat(objParams);
            List<MatPreparationOrder> orders = JSON.parseArray(params.toJSONString(), MatPreparationOrder.class);
            JSONArray array = ERPController.map;
            for (int i = 0; i < ERPController.map.size(); i++) {
                JSONObject obj = array.getJSONObject(i);
                obj.put("orderNo", orders.get(0).getOrderNo());
                obj.put("matNr", orders.get(0).getOrderItems().get(0).getMatNr());
            }
            ERPController.map = array;

            return CommonResponse.ok();
        }

@@ -47,7 +66,7 @@
            throw new CoolException("参数不能为空！！");
        }
        // 返回模拟数据
        if (SIMULATED_DATA_ENABLE.equals("0")) {
        if (SIMULATED_DATA_ENABLE.equals("1")) {
            return CommonResponse.ok();
        }

@@ -91,4 +110,39 @@
        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

}