|  |  |  | 
|---|
|  |  |  | 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)); | 
|---|
|  |  |  | //                                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)); | 
|---|
|  |  |  | } | 
|---|