//package com.zy.acs.wcs.core.thread;
|
//
|
//import com.alibaba.fastjson.JSONObject;
|
//import com.core.common.Cools;
|
//import com.core.common.DateUtils;
|
//import com.core.common.SpringUtils;
|
//import com.zy.asrs.entity.BasDevp;
|
//import com.zy.asrs.service.BasDevpService;
|
//import com.zy.asrs.service.DeviceErrorService;
|
//import com.zy.acs.wcs.core.Slave;
|
//import com.zy.acs.wcs.core.ThreadHandler;
|
//import com.zy.acs.wcs.core.cache.OutputQueue;
|
//import lombok.Data;
|
//import lombok.extern.slf4j.Slf4j;
|
//
|
//import java.io.DataInputStream;
|
//import java.io.DataOutputStream;
|
//import java.io.IOException;
|
//import java.net.InetSocketAddress;
|
//import java.net.Socket;
|
//import java.net.SocketAddress;
|
//import java.net.SocketTimeoutException;
|
//import java.util.Date;
|
//
|
///**
|
// * 磅秤线程
|
// * Created by vincent on 2020/8/4
|
// */
|
//@Data
|
//@Slf4j
|
//public class ScaleThread implements Runnable, ThreadHandler {
|
//
|
// private Slave slave;
|
// private Double scale = 0.0D;
|
// private Socket socket;
|
// private DataOutputStream dataOutputStream;
|
// private DataInputStream dataInputStream;
|
//
|
// public ScaleThread(Slave slave) {
|
// this.slave = slave;
|
// }
|
//
|
// @Override
|
// @SuppressWarnings("InfiniteLoopStatement")
|
// public void run() {
|
// connect();
|
// while (true) {
|
// try {
|
// byte[] read = read(8, 100);
|
// if (null != read) {
|
// String s = new String(read);
|
// if (!Cools.isEmpty(s) && s.startsWith("=")) {
|
// scale = Double.parseDouble(s.substring(1));
|
//
|
// //将称重重量写入设备基础数据中的gross_wt字段
|
// if (scale > 20) {
|
// BasDevpService basDevpService = SpringUtils.getBean(BasDevpService.class);
|
// Integer staNo = slave.getId() == 1 ? 101 : 201;
|
// BasDevp basDevp = basDevpService.selectById(staNo);
|
// if (!Cools.isEmpty(basDevp)) {
|
// basDevp.setGrossWt(scale);
|
// if (null != basDevpService && !basDevpService.updateById(basDevp)) {
|
// throw new Exception("更新数据库数据失败");
|
// }
|
// JSONObject jsonObject = new JSONObject();
|
// jsonObject.put("time", DateUtils.convert(new Date(), DateUtils.yyyyMMddHHmmss_F));
|
// jsonObject.put("id", staNo);
|
// jsonObject.put("scale", scale);
|
// if (OutputQueue.SCALE.size() >= 32) {
|
// OutputQueue.SCALE.poll();
|
// }
|
// OutputQueue.SCALE.offer(jsonObject);
|
// }
|
// }
|
// }
|
// }
|
// Thread.sleep(100);
|
// } catch (SocketTimeoutException ignore) {
|
// } catch (Exception e) {
|
//// e.printStackTrace();
|
// }
|
// }
|
// }
|
//
|
// @Override
|
// public boolean connect() {
|
//
|
// try {
|
// close(); //1.主动释放连接 //2.某些服务器对指定ip有链路数限制
|
// socket = new Socket();
|
// //socket.setKeepAlive(true);
|
// SocketAddress socketAddress = new InetSocketAddress(slave.getIp(), slave.getPort());
|
// socket.connect(socketAddress, 1000); //某些服务器ping延迟高时要增加,否则会报错connect timeout
|
// dataOutputStream = new DataOutputStream(socket.getOutputStream());
|
// dataInputStream = new DataInputStream(socket.getInputStream());
|
//// log.info("条码扫描仪连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
|
// DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
|
// deviceErrorService.deleteDeviceError("scale", slave.getId());
|
// } catch (Exception e) {
|
// socket = null;
|
// log.error("磅秤连接失败！！！ ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
|
// DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
|
// deviceErrorService.addDeviceError("scale", slave.getId(), "磅秤连接失败");
|
// return false;
|
// }
|
// return true;
|
// }
|
//
|
// @Override
|
// public void close() {
|
// try {
|
// if (null != dataOutputStream) {
|
// dataOutputStream.close();
|
// }
|
// if (null != dataInputStream) {
|
// dataInputStream.close();
|
// }
|
//// if (null != socket && !socket.isClosed()) {
|
//// socket.close();
|
//// }
|
// if (null != socket) {
|
// socket.close();
|
// }
|
// socket = null;
|
// } catch (IOException e) {
|
// log.error("SocketClient close Exception:" + e.getMessage());
|
// }
|
// }
|
//
|
// public void write(byte[] msg, int len) throws IOException {
|
// if (null != dataInputStream) {
|
// dataOutputStream.write(msg, 0, len);
|
// dataOutputStream.flush();
|
// }
|
// }
|
//
|
// public byte[] read(int bufferSize, int timeOut) throws IOException {
|
//// if (socket == null) {
|
//// connect();
|
//// }
|
// connect();
|
// socket.setSoTimeout(timeOut);
|
// byte[] bytes = new byte[bufferSize];
|
// int len = dataInputStream.read(bytes);
|
// byte[] tempBytes = null;
|
// if (len > 0) {
|
// tempBytes = new byte[len];
|
// System.arraycopy(bytes, 0, tempBytes, 0, len);
|
// }
|
// return tempBytes;
|
// }
|
//
|
// public boolean valid() throws Exception {
|
// if (null == socket || socket.isClosed() || socket.isInputShutdown() || socket.isOutputShutdown()) {
|
// if (dataInputStream != null) {
|
// dataInputStream.close();
|
// }
|
// if (dataOutputStream != null) {
|
// dataOutputStream.close();
|
// }
|
// if (socket != null) {
|
// socket.close();
|
// }
|
// return false;
|
// }
|
// return true;
|
// }
|
//
|
//}
|
