| | |
|---|
| | | write((StaProtocol)task.getData()); |
|---|
| | | // log.error("输送线下发命令："+((StaProtocol) task.getData()).getWorkNo()+","+((StaProtocol) task.getData()).getStaNo()); |
|---|
| | | break; |
|---|
| | | case 3: |
|---|
| | | write1((StaProtocol)task.getData()); |
|---|
| | | break; |
|---|
| | | default: |
|---|
| | | break; |
|---|
| | | } |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 扫码器触发 |
|---|
| | | */ |
|---|
| | | private void write1(StaProtocol staProtocol) { |
|---|
| | | if (null == staProtocol) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | OperateResult writeResult1 = siemensS7Net.Write("DB100.500", true); // 扫码器触发 |
|---|
| | | if (!writeResult1.IsSuccess) { |
|---|
| | | |
|---|
| | | OutputQueue.DEVP.offer(MessageFormat.format("【{0}】写入输送线站点数据失败。输送线plc编号={1}，站点数据={2}", slave.getId(), JSON.toJSON(staProtocol))); |
|---|
| | | log.error("写入扫码器触发数据失败。输送线plc编号={}，站点数据={}", slave.getId(), JSON.toJSON(staProtocol)); |
|---|
| | | } 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)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 心跳 |
|---|
| | | */ |
|---|
| | | private void heartbeat(){ |
|---|
