| | |
|---|
| | | int writeCount = 0; |
|---|
| | | //任务下发成功标识 |
|---|
| | | boolean writeFlag = false; |
|---|
| | | while(writeCount < 5){ |
|---|
| | | writeResult = siemensS7Net.Write("DB100." + index*4, array); // 工作号、目标站 |
|---|
| | | |
|---|
| | | if(writeResult.IsSuccess){ |
|---|
| | | Thread.sleep(200); |
|---|
| | | OperateResultExOne<byte[]> readResult = siemensS7Net.Read("DB100." + index*4, (short)4); |
|---|
| | | if(readResult.IsSuccess){ |
|---|
| | | short workNo = siemensS7Net.getByteTransform().TransInt16(readResult.Content, 0); |
|---|
| | | short staNo = siemensS7Net.getByteTransform().TransInt16(readResult.Content, 2); |
|---|
| | | if(staProtocol.getWorkNo().equals(workNo) && staProtocol.getStaNo().equals(staNo)){ |
|---|
| | | //任务命令写入成功 |
|---|
| | | writeFlag = true; |
|---|
| | | log.info("写入输送线命令后返回成功，并且回读成功。输送线plc编号={}，{}，写入次数={}", slave.getId(), JSON.toJSON(staProtocol), writeCount); |
|---|
| | | |
|---|
| | | Date now = new Date(); |
|---|
| | | |
|---|
| | | //更新指令状态 |
|---|
| | | commandInfo.setCommandStatus(CommandStatusType.COMPLETE.id);//输送线直接完成状态 |
|---|
| | | commandInfo.setExecuteTime(now); |
|---|
| | | commandInfo.setCompleteTime(now); |
|---|
| | | commandInfoService.updateById(commandInfo); |
|---|
| | | |
|---|
| | | //更新指令日志 |
|---|
| | | commandInfoLog.setDeviceLog("指令下发成功"); |
|---|
| | | commandInfoLog.setCommandStatus(CommandStatusType.COMPLETE.id);//输送线直接完成状态 |
|---|
| | | commandInfoLog.setExecuteTime(now); |
|---|
| | | commandInfoLog.setCompleteTime(now); |
|---|
| | | commandInfoLogService.insert(commandInfoLog); |
|---|
| | | |
|---|
| | | OperateResult writeResult1 = siemensS7Net.Write("DB100." + index*6, (int) staProtocol.getWorkNo()); // 工作号 |
|---|
| | | OperateResult writeResult2 = siemensS7Net.Write("DB100." + (index*6+4), staProtocol.getStaNo()); // 目标站 |
|---|
| | | if(writeResult1.IsSuccess&&writeResult2.IsSuccess){ |
|---|
| | | //更新任务步序 |
|---|
| | | TaskWrkService taskWrkService = SpringUtils.getBean(TaskWrkService.class); |
|---|
| | | TaskWrk taskWrk = taskWrkService.selectByWrkNo(staProtocol.getWorkNo().intValue()); |
|---|
| | | TaskWrk taskWrk = taskWrkService.selectByWrkNo((int) staProtocol.getWorkNo()); |
|---|
| | | if (taskWrk != null) { |
|---|
| | | taskWrk.setCommandStep(taskWrk.getCommandStep() + 1);//更新指令步序 |
|---|
| | | taskWrkService.updateById(taskWrk); |
|---|
| | | } |
|---|
| | | |
|---|
| | | break; |
|---|
| | | } else {//返回结果是成功了，但是真实值不相同 |
|---|
| | | writeCount++; |
|---|
| | | OutputQueue.DEVP.offer(MessageFormat.format("【{0}】写入输送线命令后返回成功，但是读取任务值不一致。输送线plc编号={1}，站点数据={2},写入次数={3}", |
|---|
| | | slave.getId(), JSON.toJSON(staProtocol),writeCount)); |
|---|
| | | log.error("写入输送线命令后返回成功，但是读取任务值不一致。输送线plc编号={}，{}，写入次数={}", slave.getId(), JSON.toJSON(staProtocol), writeCount); |
|---|
| | | //更新指令日志 |
|---|
| | | commandInfoLog.setDeviceLog("指令下发失败"); |
|---|
| | | commandInfoLogService.insert(commandInfoLog); |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | writeCount++; |
|---|
| | | OutputQueue.DEVP.offer(MessageFormat.format("【{0}】写入输送线命令后读取失败。输送线plc编号={1}，站点数据={2},写入次数={3}", |
|---|
| | | slave.getId(), JSON.toJSON(staProtocol), writeCount)); |
|---|
| | | log.error("写入输送线命令后读取失败。输送线plc编号={}，站点数据={},写入次数={}", slave.getId(), JSON.toJSON(staProtocol), writeCount); |
|---|
| | | |
|---|
| | | //更新指令日志 |
|---|
| | | commandInfoLog.setDeviceLog("指令下发失败"); |
|---|
| | | commandInfoLogService.insert(commandInfoLog); |
|---|
| | | log.error("输送线写入失败"+staProtocol+"++++++++++++++++++++++++++++++++++++++"); |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | writeCount++; |
|---|
| | | OutputQueue.DEVP.offer(MessageFormat.format("【{0}】写入输送线命令失败。输送线plc编号={1}，站点数据={2},写入次数={3}", |
|---|
| | | slave.getId(), JSON.toJSON(staProtocol),writeCount)); |
|---|
| | | log.error("写入输送线命令失败。输送线plc编号={}，站点数据={},写入次数={}", slave.getId(), JSON.toJSON(staProtocol), writeCount); |
|---|
| | | |
|---|
| | | //更新指令日志 |
|---|
| | | commandInfoLog.setDeviceLog("指令下发失败"); |
|---|
| | | commandInfoLogService.insert(commandInfoLog); |
|---|
| | | } |
|---|
| | | Thread.sleep(200); |
|---|
| | | } |
|---|
| | | |
|---|
| | | //写命令尝试了5次还是失败了 |
|---|
| | | if(!writeFlag){ |
|---|
| | | staProtocol = station.get(staProtocol.getSiteId()); |
|---|
| | | if (staProtocol.getWorkNo() == 0 && staProtocol.getStaNo() ==0) { |
|---|
| | | staProtocol.setPakMk(true); |
|---|
| | | } |
|---|
| | | OutputQueue.DEVP.offer(MessageFormat.format("【{0}】写入输送线命令尝试5次失败。输送线plc编号={1}，站点数据={2}", slave.getId(), JSON.toJSON(staProtocol))); |
|---|
| | | log.error("写入输送线命令尝试5次失败。输送线plc编号={}，站点数据={}", slave.getId(), JSON.toJSON(staProtocol)); |
|---|
| | | |
|---|
| | | //重新添加数据到任务队列 |
|---|
| | | boolean result = MessageQueue.offer(SlaveType.Devp, slave.getId(), new Task(2, staProtocol)); |
|---|
| | | read();//读取1次设备状态 |
|---|
| | | return; |
|---|
| | | } else { |
|---|
| | | OutputQueue.DEVP.offer(MessageFormat.format("【{0}】 输送线命令下发成功 [id:{1}] >>>>> {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(staProtocol))); |
|---|
| | | //log.info("输送线命令下发 [id:{}] >>>>> 命令下发成功： {}", slave.getId(), JSON.toJSON(staProtocol)); |
|---|
| | | |
|---|
| | | Integer siteId = staProtocol.getSiteId(); |
|---|
| | | staProtocol = station.get(siteId); |
|---|
| | | if ((siteId == 101 || siteId == 201)&&(staProtocol.getWorkNo() == 0 && staProtocol.getStaNo() ==0)) { |
|---|
| | | staProtocol.setPakMk(true); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | private void write2(StaProtocol staProtocol) throws InterruptedException { |
|---|
