| | |
|---|
| | | |
|---|
| | | // 命令下发区 -------------------------------------------------------------------------- |
|---|
| | | |
|---|
| | | // 更新站点信息 且 下发plc命令 |
|---|
| | | staProtocol.setWorkNo(wrkMast.getWrkNo().shortValue()); |
|---|
| | | staProtocol.setStaNo(wrkMast.getStaNo().shortValue()); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
|---|
| | | if (result) { |
|---|
| | | // 更新工作主档 |
|---|
| | | wrkMast.setWrkSts(2L); // 工作状态：2.设备上走 |
|---|
| | | wrkMast.setModiTime(new Date()); |
|---|
| | | if (wrkMastMapper.updateById(wrkMast) == 0) { |
|---|
| | | log.error("更新工作档失败！！！ [工作号：{}]", wrkMast.getWrkNo()); |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | log.error("发布命令至输送线队列失败！！！ [plc编号：{}]", devp.getId()); |
|---|
| | | } |
|---|
| | | // // 更新站点信息 且 下发plc命令 |
|---|
| | | // staProtocol.setWorkNo(wrkMast.getWrkNo().shortValue()); |
|---|
| | | // staProtocol.setStaNo(wrkMast.getStaNo().shortValue()); |
|---|
| | | // devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | // boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
|---|
| | | // if (result) { |
|---|
| | | // // 更新工作主档 |
|---|
| | | // wrkMast.setWrkSts(2L); // 工作状态：2.设备上走 |
|---|
| | | // wrkMast.setModiTime(new Date()); |
|---|
| | | // if (wrkMastMapper.updateById(wrkMast) == 0) { |
|---|
| | | // log.error("更新工作档失败！！！ [工作号：{}]", wrkMast.getWrkNo()); |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // //更新WMS任务状态 |
|---|
| | | // WmsWrk wmsWrk = wmsWrkService.selectByWmsWrkNo(wrkMast.getWmsWrkNo()); |
|---|
| | | // wmsWrk.setWmsStatus(WmsStatusType.WORKING.id);//执行中 |
|---|
| | | // wmsWrk.setModiTime(new Date()); |
|---|
| | | // wmsWrkService.updateById(wmsWrk); |
|---|
| | | // |
|---|
| | | // } else { |
|---|
| | | // log.error("发布命令至输送线队列失败！！！ [plc编号：{}]", devp.getId()); |
|---|
| | | // } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
