| | |
|---|
| | | package com.zy.core.thread; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.core.common.Cools; |
|---|
| | | import com.core.common.DateUtils; |
|---|
| | | import com.zy.core.Slave; |
|---|
| | |
|---|
| | | import java.net.Socket; |
|---|
| | | import java.net.SocketAddress; |
|---|
| | | import java.net.SocketTimeoutException; |
|---|
| | | import java.text.MessageFormat; |
|---|
| | | import java.util.Date; |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | if (!Cools.isEmpty(s)) { |
|---|
| | | barcode = new String(read); |
|---|
| | | log.info("{}号条码器，检索数据：{}", slave.getId(), this.barcode); |
|---|
| | | OutputQueue.CRN.offer(MessageFormat.format("【{0}】堆垛机plc连接失败！！！ ===>> [id:{1}] [ip:{2}] [port:{3}] ", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort())); |
|---|
| | | JSONObject jsonObject = new JSONObject(); |
|---|
| | | jsonObject.put("time", DateUtils.convert(new Date(), DateUtils.yyyyMMddHHmmss_F)); |
|---|
| | | jsonObject.put("barcode", barcode); |
|---|
| | | if (OutputQueue.BARCODE.size() >= 32) { |
|---|
| | | OutputQueue.BARCODE.poll(); |
|---|
| | | } |
|---|
| | | OutputQueue.BARCODE.offer(jsonObject); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | Thread.sleep(100); |
|---|
