Administrator
2024-10-23 86198183670e47c8b44c7ccdd0b83e9f7fb52b36
src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -12,6 +12,7 @@
import com.zy.asrs.utils.RouteUtils;
import com.zy.asrs.utils.Utils;
import com.zy.asrs.utils.VersionUtils;
import com.zy.common.constant.GhjtApiConstant;
import com.zy.common.model.LocTypeDto;
import com.zy.common.model.MatDto;
import com.zy.common.model.SearchLocParam;
@@ -892,7 +893,7 @@
                    continue;
                }
                // 判断工作档条件
                if (wrkMast.getIoType() < 100 || wrkMast.getStaNo() == null || wrkMast.getSourceStaNo() == null) {
                if ((wrkMast.getIoType() < 100 && wrkMast.getIoType() != 12) || wrkMast.getStaNo() == null || wrkMast.getSourceStaNo() == null) {
                    continue;
                }
                // 判断吊车是否实际已完成,且电脑状态在move中,以备电脑进行更新工作档
@@ -1591,8 +1592,10 @@
                continue;
            }
            log.info("{}号堆垛机选定的出库口是{}",crnProtocol.getCrnNo(),crnStn.getPlatNo());
            // 工作档状态判断
            if (wrkMast.getIoType() < 100 || wrkMast.getSourceStaNo() == null) {
            if ((wrkMast.getIoType() < 100 && wrkMast.getIoType()!=12) || wrkMast.getSourceStaNo() == null) {
                log.error("查询工作档数据不符合条件--入出类型/站点, 工作号={},源库位={},入出类型={}", wrkMast.getWrkNo(), wrkMast.getSourceLocNo(), wrkMast.getIoType());
                continue;
            }
@@ -1725,9 +1728,6 @@
     */
    private boolean crnEnabled(WrkMast wrkMast) {
        String url = "http://192.168.14.249:8008";
        String path = "/api/Task/DockStatus";
        // 获取请求头
        Map<String,Object> headers = new HashMap<>();
        headers.put("digi-type","sync ");
@@ -1744,8 +1744,8 @@
        String response;
        try {
            response = new HttpHandler.Builder()
                    .setUri(url)
                    .setPath(path)
                    .setUri(GhjtApiConstant.GWCS_IP_PORT)
                    .setPath(GhjtApiConstant.GWCS_CKMT_URL)
                    .setHeaders(headers)
                    .setJson(body)
                    .build()
@@ -1758,8 +1758,8 @@
                    success = false;
                }
            } else {
                log.error("请求接口失败!!!url:{};request:{};response:{}", url + path, body, response);
                throw new CoolException("下发出库任务给GWCS(从出库码头到出库口)失败");
                log.error("确认出库码头是否可用失败!!!url:{};request:{};response:{}", GhjtApiConstant.GWCS_IP_PORT + GhjtApiConstant.GWCS_CKMT_URL, body, response);
                throw new CoolException("确认出库码头是否可用失败");
            }
        } catch (Exception e) {
            success = false;
@@ -4636,13 +4636,20 @@
                        && crnProtocol.getForkPos() == 0) {
                    CrnSlave.CrnStn crnStn = null;
                    CrnSlave.CrnStn crnStn2 = null;
                    for (CrnSlave.CrnStn crnStn1 : crn.getCrnOutStn()){
                        if(crnStn1.getStaNo().equals(wrkMast.getStaNo())){
                            crnStn = crnStn1;
                            break;
                        }
                    }
                    if(Cools.isEmpty(crnStn)){
                    for (CrnSlave.CrnStn crnStn1 : crn.getCrnInStn()){
                        if(crnStn1.getStaNo().equals(wrkMast.getSourceStaNo())){
                            crnStn2 = crnStn1;
                            break;
                        }
                    }
                    if(Cools.isEmpty(crnStn) || Cools.isEmpty(crnStn2)){
                        continue;
                    }
@@ -4652,13 +4659,13 @@
                    crnCommand.setTaskNo(wrkMast.getWrkNo().shortValue()); // 工作号
                    crnCommand.setAckFinish((short) 0);  // 任务完成确认位
                    crnCommand.setTaskMode(CrnTaskModeType.LOC_MOVE); // 任务模式:  库位移转
                    //crnCommand.setSourcePosX(crnStn.getRow().shortValue());     // 源库位排
                    //crnCommand.setSourcePosY(crnStn.getBay().shortValue());     // 源库位列
                    //crnCommand.setSourcePosZ(crnStn.getLev().shortValue());     // 源库位层
                    crnCommand.setSourcePosX(crnStn2.getRow().shortValue());     // 源库位排
                    crnCommand.setSourcePosY(crnStn2.getBay().shortValue());     // 源库位列
                    crnCommand.setSourcePosZ(crnStn2.getLev().shortValue());     // 源库位层
                    crnCommand.setDestinationPosX(crnStn.getRow().shortValue());     // 目标库位排
                    crnCommand.setDestinationPosY(crnStn.getBay().shortValue());     // 目标库位列
                    crnCommand.setDestinationPosZ(crnStn.getLev().shortValue());     // 目标库位层
                    crnCommand.setSourceStaNo(crnStn.getPlatNo().shortValue());     // 源库位排
//                    crnCommand.setSourceStaNo(crnStn.getPlatNo().shortValue());     // 源库位排
                    if (!MessageQueue.offer(SlaveType.Crn, wrkMast.getCrnNo(), new Task(2, crnCommand))) {
                        log.error("堆垛机命令下发失败,堆垛机号={},任务数据={}", wrkMast.getCrnNo(), JSON.toJSON(crnCommand));
                    } else {
@@ -4677,4 +4684,11 @@
            }
        }
    }
    /**
     * 12.跨巷道移库
     */
    public synchronized void autoMoveLoc() {
    }
}