初始化

dubin

3 天以前 e2aa3f9c79ae688a56ea3bb5bc96ba1600f215de

 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java

@@ -389,8 +389,6 @@
                            storageEscalationParam.setLocType(1);
                        }else if(staProtocol.isLow()){
                            storageEscalationParam.setLocType(0);
                        }else if (staProtocol.isCentre()){
                            storageEscalationParam.setLocType(2);
                        }

                        storageEscalationParam.setTerminalNo(staProtocol.getSiteId());
@@ -465,6 +463,7 @@
                                        staProtocol.setStaNo(inSta.getBackSta().shortValue());
                                        devpThread.setPakMk(staProtocol.getSiteId(), false);
                                        MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                        log.error("已有入库任务,wms--->任务号:{}",result.getTaskNo());
                                    }

                                } else {
@@ -479,6 +478,7 @@
                                    staProtocol.setStaNo(inSta.getBackSta().shortValue());
                                    devpThread.setPakMk(staProtocol.getSiteId(), false);
                                    MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                    log.error("入库异常,wms返回值不符合条件,wms--->{}",response);
                                }
                            }
                        } catch (Exception e) {
@@ -634,6 +634,7 @@
                                    staProtocol.setStaNo(inSta.getBackSta().shortValue());
                                    devpThread.setPakMk(staProtocol.getSiteId(), false);
                                    MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                    log.error("任务已存在,wms--->任务号:{}",result.getTaskNo());
                                }

                            } else {
@@ -646,6 +647,7 @@
                                staProtocol.setStaNo(inSta.getBackSta().shortValue());
                                devpThread.setPakMk(staProtocol.getSiteId(), false);
                                MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                log.error("请求接口异常,wms--->{}",response);
                            }

                        } catch (Exception e) {
@@ -1131,7 +1133,7 @@
                crnCommand.setDestinationPosX(Utils.getRowShort(taskWrk.getTargetPoint()));     // 目标库位列
                crnCommand.setDestinationPosY(Utils.getBayShort(taskWrk.getTargetPoint()));     // 目标库位层
                crnCommand.setDestinationPosZ(Utils.getLevShort(taskWrk.getTargetPoint()));     // 目标库位排
                crnCommand.setCommand((short) 1);
                crnCommand.setCommand((short) 0);
                log.info("堆垛机入库任务下发={}", crnCommand);
                if (!CommandUtils.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand), false)) {
                    log.error("堆垛机命令生成失败，堆垛机号={}，任务数据={}", taskWrk.getCrnNo(), JSON.toJSON(crnCommand));
@@ -1220,11 +1222,13 @@
                        if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) {
                            break;
                        }
//                        int storeCount = basDevpService.getStoreCount();
//                        if (storeCount >= maxCount) {
//                            log.error("输送线暂存数达到上限{}", storeCount);
//                            break;
//                        }

                        //输送线只允许存在一个托盘
                        int storeCount = basDevpService.getStoreCount();
                        if (storeCount >= maxCount) {
                            log.error("输送线暂存数达到上限,当前输送线托盘数量:{},最大暂存数量:{}", storeCount,maxCount);
                            break;
                        }


                        // 已经存在吊车执行任务时，则过滤
@@ -1242,7 +1246,7 @@
                        command.setDestinationPosX(crnStn.getRow().shortValue());     // 目标库位排
                        command.setDestinationPosY(crnStn.getBay().shortValue());     // 目标库位列
                        command.setDestinationPosZ(crnStn.getLev().shortValue());     // 目标库位层
                        command.setCommand((short) 1);
                        command.setCommand((short) 0);

                        if (!CommandUtils.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, command), false)) {
                            log.error("堆垛机命令生成失败，堆垛机号={}，任务数据={}", taskWrk.getCrnNo(), JSON.toJSON(command));