|  |  |  | 
|---|
|  |  |  | storageEscalationParam.setBarcode(BoxNo); | 
|---|
|  |  |  | storageEscalationParam.setMatIdList(staProtocol.getMatIdList()); | 
|---|
|  |  |  | storageEscalationParam.setFullPlt(staProtocol.isFullPlt() ? 1 : 0); | 
|---|
|  |  |  | storageEscalationParam.setMpHigh((short) (staProtocol.getSiteId() < 200 ? 1 :staProtocol.isHigh() ? 2 : staProtocol.isLow() ? 1 : 0));    // 高度,侧面码盘的高度 低1,高2 | 
|---|
|  |  |  | log.info("组托入库={}", storageEscalationParam); | 
|---|
|  |  |  | TaskWrk taskWrk = toWmsService.getLocNoFromWms(storageEscalationParam); | 
|---|
|  |  |  | if (taskWrk == null) { | 
|---|
|  |  |  | 
|---|
|  |  |  | boolean offer = false; | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | offer = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol)); | 
|---|
|  |  |  | //                                staProtocol.setMp(taskWrk.getMp()); | 
|---|
|  |  |  | //                                staProtocol.setLx(taskWrk.getLx()); | 
|---|
|  |  |  | //                                staProtocol.setLev(taskWrk.getLev()); | 
|---|
|  |  |  | //                                MessageQueue.offer(SlaveType.Devp, 1, new Task(3, staProtocol)); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | log.error("下发输送线任务失败:异常:" + e); | 
|---|
|  |  |  | log.error("下发输送线任务失败:异常:offer:" + offer); | 
|---|
|  |  |  | 
|---|
|  |  |  | taskWrk.setWrkSts(14); | 
|---|
|  |  |  | taskWrk.setCompleteTime(new Date()); | 
|---|
|  |  |  | taskWrkService.updateById(taskWrk); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 侧面出库完成 上报执行状态 | 
|---|
|  |  |  | toWmsService.executionStatusReport(taskWrk.getTaskNo(), taskWrk.getWrkSts()); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | log.error("下发输送线任务失败:taskWrk:" + JSON.toJSONString(taskWrk)); | 
|---|
|  |  |  | } | 
|---|