~admin/HangZhouMes.git

			@@ -27,6 +27,7 @@

			import java.io.BufferedReader;
			import java.io.InputStreamReader;
			import java.net.InetSocketAddress;
			import java.net.Socket;
			import java.util.ArrayList;
			import java.util.List;
			@@ -172,6 +173,7 @@
			);
			jsonObject4.append("takeGlass", takeGlass);


			ArrayList<WebSocketServer> sendwServer4 = WebSocketServer.sessionMap.get("unloadglass");
			if (sendwServer4 != null) {
			for (WebSocketServer webserver : sendwServer4) {
			@@ -204,29 +206,61 @@

			@Scheduled(fixedDelay = Long.MAX_VALUE)
			public void scanCodeTask() {
			JSONObject jsonObject = new JSONObject();
			log.info("扫描任务已启动");
			while (true) {
			try (Socket socket = new Socket(scanIp, scanPort);
			BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {
			// 接收服务器响应
			socket.setSoTimeout(1000);
			String response;
			while ((response = in.readLine()) != null) {
			List<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("unloadglass");
			if (CollectionUtils.isNotEmpty(sendwServer)) {
			//按照玻璃id获取玻璃信息返回给前端界面，具体需要哪些数据待确认
			GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>()
			.eq(GlassInfo::getGlassId, response));
			if (null == glassInfo) {
			log.info("按照玻璃id：{}，无法找到玻璃信息", response);
			} else {
			jsonObject.append("scanGlass",glassInfo);
			sendwServer.get(0).sendMessage(jsonObject.toString());
			new Thread(() -> {
			try (Socket socket = new Socket(scanIp, scanPort);
			BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {
			// 接收服务器响应
			String response;
			log.info("等待扫码中......");
			while ((response = in.readLine()) != null) {
			log.info("扫描到的玻璃id：{}", response);
			List<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("scanCode");
			if (CollectionUtils.isNotEmpty(sendwServer)) {
			//按照玻璃id获取玻璃信息返回给前端界面，具体需要哪些数据待确认
			GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>()
			.eq(GlassInfo::getGlassId, response).last("limit 1"));
			if (null == glassInfo) {
			log.info("按照玻璃id：{}，无法找到玻璃信息", response);
			} else {
			sendwServer.get(0).sendMessage(glassInfo.toString());
			}
			}
			}
			} catch (Exception exception) {
			log.info("读取异常，原因为{}", exception.getMessage());
			}
			} catch (Exception exception) {
			log.info("读取异常，原因为{}", exception.getMessage());
			}).start();
			}
			}

			@Scheduled(fixedDelay = Long.MAX_VALUE)
			public void scanCodeTaskCopy()
			{
			log.info("扫描任务已启动");
			try {
			BarcodeReadThread brt=new BarcodeReadThread(scanIp,scanPort,this);
			brt.start();

			}catch (Exception exception) {
			log.info("扫描任务启动异常，原因为{}", exception.getMessage());
			}

			}
			//socket读取到消息后会调用这个函数
			public void barcodeCheckin(String response)
			{
			log.info("扫描到的玻璃id：{}", response);
			List<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("scanCode");
			if (CollectionUtils.isNotEmpty(sendwServer)) {
			//按照玻璃id获取玻璃信息返回给前端界面，具体需要哪些数据待确认
			GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>()
			.eq(GlassInfo::getGlassId, response).last("limit 1"));
			if (null == glassInfo) {
			log.info("按照玻璃id：{}，无法找到玻璃信息", response);
			} else {
			sendwServer.get(0).sendMessage(glassInfo.toString());
			}
			}
			}