123

ZY

2025-05-10 0c695808a612e96a1f62d5873c390a5785650322

 src/main/java/com/zy/asrs/controller/DevopsController.java

@@ -6,7 +6,6 @@
import com.core.common.R;
import com.zy.asrs.domain.devops.DevopsMessage;
import com.zy.asrs.domain.devops.ErrorType;
import com.zy.asrs.domain.vo.SiteTableVo;
import com.zy.asrs.entity.BasDevp;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.mapper.WrkMastMapper;
@@ -20,7 +19,6 @@
import com.zy.core.enums.CrnStatusType;
import com.zy.core.enums.SlaveType;
import com.zy.core.model.CrnSlave;
import com.zy.core.model.DevpSlave;
import com.zy.core.model.protocol.CrnProtocol;
import com.zy.core.model.protocol.StaProtocol;
import com.zy.core.properties.SlaveProperties;
@@ -30,9 +28,7 @@
import org.springframework.web.bind.annotation.RestController;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("/devops")
@@ -55,22 +51,35 @@
        List<DevopsMessage> devopsMessages = new ArrayList<>();
        DevopsMessage devopsMessage;
        for (CrnSlave crnSlave : slaveProperties.getCrn()) {
            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("crn_no", crnSlave.getId()).in("io_type", 101, 103, 107).orderBy("wrk_sts", false));
            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("crn_no", crnSlave.getId()).orderBy("wrk_sts", false));
            //先查询堆垛机是否在工作
            WrkMast working = wrkMastMapper.selectWorking(crnSlave.getId());
            for (WrkMast wrkMast : wrkMasts) {
                CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, wrkMast.getCrnNo());
                CrnProtocol crnProtocol = crnThread.getCrnProtocol();
                if (crnProtocol == null) {
                    crnProtocol = new CrnProtocol();
                }
                devopsMessage = new DevopsMessage();
                devopsMessage.setWrkNo(wrkMast.getWrkNo());
                if (working != null) {
                    //在工作，则判断是否未当前这条
                    if (working.getWrkNo().equals(wrkMast.getWrkNo())) {
                        devopsMessage.setError("该工作档正在出库，请稍后");
                        if (crnProtocol.getTaskNo().intValue() == working.getWrkNo()) {
                            devopsMessage.setError("该工作档正在执行，请稍后");
                        } else {
                            devopsMessage.setError("该工作档状态不对，与堆垛机的工作号不匹配");
                            devopsMessage.setMethod("结合任务情况进行操作;如果实际已完成，就将工作档完成;如果未完成，则调整工作档状态");
                        }
                    } else {
                        devopsMessage.setError(working.getWrkNo() + "号工作档正在出库，请稍后");
                        devopsMessage.setError(working.getWrkNo() + "号工作档正在执行，请稍后");
                    }
                    devopsMessages.add(devopsMessage);
                    continue;
                }
                List<ErrorType> staError = isStaError(wrkMast);
                DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
                StaProtocol staProtocol = devpThread.getStation().get(wrkMast.getStaNo());
                List<ErrorType> staError = isStaError(staProtocol, wrkMast);
                for (ErrorType type : staError) {
                    if (!Cools.isEmpty(devopsMessage.getError())) {
                        devopsMessage.setError(devopsMessage.getError() + ";" + type.getDesc());
@@ -80,7 +89,7 @@
                        devopsMessage.setMethod(type.getMethod());
                    }
                }
                List<ErrorType> crnError = isCrnError(wrkMast);
                List<ErrorType> crnError = isCrnError(crnProtocol, wrkMast);
                for (ErrorType type : crnError) {
                    if (!Cools.isEmpty(devopsMessage.getError())) {
                        devopsMessage.setError(devopsMessage.getError() + ";" + type.getDesc());
@@ -96,94 +105,172 @@
        return R.ok(devopsMessages);
    }

    private List<ErrorType> isStaError(WrkMast staNo) {
    private List<ErrorType> isStaError(StaProtocol staProtocol, WrkMast wrkMast) {
        List<ErrorType> types = new ArrayList<>();
        DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
        StaProtocol staProtocol = devpThread.getStation().get(staNo);
        if (staProtocol == null) {
            types.add(ErrorType.ERROR);
            return types;
        } else {
            staProtocol = staProtocol.clone();
        }
        // 自动
        if (staProtocol.isAutoing()) {
            types.add(ErrorType.FEIZIDONG);
        }
        if (staProtocol.isLoading()) {
            types.add(ErrorType.YOUWU);
        }
        if (staProtocol.getWorkNo() == 0) {
            types.add(ErrorType.GONGZUOHAO);
        }
        if (staProtocol.getStaNo() == null) {
            types.add(ErrorType.STANO);
        if (wrkMast.getIoType() > 100) {
            // 出库校验
            // 有物
            if (staProtocol.isLoading()) {
                types.add(ErrorType.YOUWU);
            } // 工作号是否为0
            if (staProtocol.getWorkNo() == 0) {
                types.add(ErrorType.GONGZUOHAO);
            }
            // 目标站点
            if (staProtocol.getStaNo() == null) {
                types.add(ErrorType.STANO);
            }
        } else {
            // 入库校验

        }
        return types;
    }


    private List<ErrorType> isCrnError(WrkMast wrkMast) {
    private List<ErrorType> isCrnError(CrnProtocol crnProtocol, WrkMast wrkMast) {
        List<ErrorType> types = new ArrayList<>();
        CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, wrkMast.getCrnNo());
        CrnProtocol crnProtocol = crnThread.getCrnProtocol();

        // 堆垛机是否空闲
        if (crnProtocol.getStatusType() == CrnStatusType.IDLE) {
            types.add(ErrorType.CRN_NO_IDLE);
        }
        //任务号是否为0
        if (crnProtocol.getTaskNo() == 0) {
            types.add(ErrorType.WORKING);
        }
        // 堆垛机是否自动
        if (crnProtocol.getModeType() == CrnModeType.AUTO) {
            types.add(ErrorType.CRN_FEIZIDONG);
        }
        // 载货台有物
        if (crnProtocol.getLoaded() == 0) {
            types.add(ErrorType.LOAD);
        }
        // 堆垛机取货中
        if (crnProtocol.statusType == CrnStatusType.FETCHING) {
            types.add(ErrorType.WORKING);
        }
        // 放货中
        if (crnProtocol.statusType == CrnStatusType.PUTTING) {
            types.add(ErrorType.WORKING);
        }
        // 堆垛机等待确认状态
        if (crnProtocol.statusType == CrnStatusType.WAITING) {
            types.add(ErrorType.WORKING);
        }
        // 货叉是否会回中
        if (crnProtocol.forkPosType == CrnForkPosType.HOME) {
            types.add(ErrorType.HOME);
        }
        if (crnProtocol.modeType == CrnModeType.AUTO) {
            types.add(ErrorType.FEIZIDONG);
        }

        return types;
    }



    @PostMapping("/site/list")
    @ManagerAuth(memo = "站点信息表")
    public R siteTable(){
        List<SiteTableVo> list = new ArrayList<>();
        // 内存数据
        Map<Integer, StaProtocol> station = new HashMap<>();
        for (DevpSlave devp : slaveProperties.getDevp()) {
            DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
            station.putAll(devpThread.getStation());
        }
    public R siteTable() {
        List<DevopsMessage> devopsMessages = new ArrayList<>();
        DevopsMessage devopsMessage;
        List<Integer> outSta = slaveProperties.getOutSta();
        List<Integer> inSta = slaveProperties.getInSta();
        // 持久数据
        List<BasDevp> basDevps = basDevpService.selectList(new EntityWrapper<BasDevp>().orderBy("dev_no"));
        for (BasDevp devp : basDevps) {
            StaProtocol staProtocol = station.get(devp.getDevNo());
            if (null == staProtocol) { continue; }
            SiteTableVo vo = new SiteTableVo();
            vo.setDevNo(devp.getDevNo());    // 站点编号
            vo.setWorkNo(staProtocol.getWorkNo());   //  工作号
            vo.setAutoing(staProtocol.isAutoing()?"Y":"N");     //  自动
            vo.setLoading(staProtocol.isLoading()?"Y":"N");     // 有物
            vo.setInEnable(staProtocol.isInEnable()?"Y":"N");   // 可入
            vo.setOutEnable(staProtocol.isOutEnable()?"Y":"N"); // 可出
            list.add(vo);
        for (Integer out : outSta) {
            for (BasDevp devp : basDevps) {
                if (devp.getDevNo().equals(out)) {
                    devopsMessage = new DevopsMessage();
                    devopsMessage.setStaNo(out);
                    devopsMessage.setType("出库站点");
                    if (devp.getLoading().equalsIgnoreCase("Y")) {
                        devopsMessage.setError(ErrorType.YOUWU.getDesc());
                        devopsMessage.setMethod("请将物料挪走，才能出库");
                    } else {
                        List<ErrorType> crnError = isOutStaError(devp);
                        for (ErrorType type : crnError) {
                            if (!Cools.isEmpty(devopsMessage.getError())) {
                                devopsMessage.setError(devopsMessage.getError() + ";" + type.getDesc());
                                devopsMessage.setMethod(devopsMessage.getMethod() + ";" + type.getMethod());
                            } else {
                                devopsMessage.setError(type.getDesc());
                                devopsMessage.setMethod(type.getMethod());
                            }
                        }
                    }
                    devopsMessages.add(devopsMessage);
                }
            }
        }
        return R.ok().add(list);
        for (Integer in : inSta) {
            for (BasDevp devp : basDevps) {
                if (devp.getDevNo().equals(in)) {
                    devopsMessage = new DevopsMessage();
                    devopsMessage.setStaNo(in);
                    devopsMessage.setType("入库站点");
                    if (devp.getLoading().equalsIgnoreCase("Y")) {
                        List<ErrorType> crnError = isInStaError(devp);
                        for (ErrorType type : crnError) {
                            if (!Cools.isEmpty(devopsMessage.getError())) {
                                devopsMessage.setError(devopsMessage.getError() + ";" + type.getDesc());
                                devopsMessage.setMethod(devopsMessage.getMethod() + ";" + type.getMethod());
                            } else {
                                devopsMessage.setError(type.getDesc());
                                devopsMessage.setMethod(type.getMethod());
                            }
                        }
                    } else {
                        devopsMessage.setError(ErrorType.WUWU.getDesc());
                        devopsMessage.setMethod(ErrorType.WUWU.getMethod());
                    }
                    devopsMessages.add(devopsMessage);
                }
            }
        }
        return R.ok().add(devopsMessages);
    }

    private List<ErrorType> isOutStaError(BasDevp devp) {
        List<ErrorType> types = new ArrayList<>();
        // 自动
        if (!devp.getAutoing().equalsIgnoreCase("Y")) {
            types.add(ErrorType.FEIZIDONG);
        }
        // 工作号是否为0
        if (devp.getWrkNo() != null && devp.getWrkNo() > 0) {
            types.add(ErrorType.GONGZUOHAO);
        }
        // 目标站点
        //TODO
//        if (devp.getStaNo() == null) {
//            types.add(ErrorType.STANO);
//        }

        return types;
    }

    private List<ErrorType> isInStaError(BasDevp devp) {
        List<ErrorType> types = new ArrayList<>();
        // 自动
        if (!devp.getAutoing().equalsIgnoreCase("Y")) {
            types.add(ErrorType.FEIZIDONG);
        }
        // 工作号是否为0
        if (devp.getWrkNo() != null && devp.getWrkNo() > 0) {
            types.add(ErrorType.GONGZUOHAO);
        }
        // 目标站点
//        if (staProtocol.getStaNo() == null) {
//            types.add(ErrorType.STANO);
//        }
        return types;
    }
}