~zhoushihao/YiWuProject.git

			@@ -6,12 +6,12 @@
			import com.mes.bigstorage.entity.BigStorageCageDetails;
			import com.mes.bigstorage.service.BigStorageCageDetailsService;
			import com.mes.bigstorage.service.BigStorageCageService;
			import com.mes.common.utils.RedisUtil;
			import com.mes.glassinfo.entity.GlassInfo;
			import com.mes.glassinfo.service.GlassInfoService;
			import com.mes.temperingglass.entity.TemperingGlassInfo;
			import com.mes.temperingglass.service.TemperingGlassInfoService;
			import com.mes.tools.WebSocketServer;
			import com.mes.utils.RedisUtil;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.beans.factory.annotation.Value;
			@@ -126,22 +126,31 @@
			queryDataSource1();
			//查询使用数据源2查询数据
			queryDataSource2();

			ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("slicecage");
			if (sendwServer != null) {
			for (WebSocketServer webserver : sendwServer) {
			if (webserver != null) {
			webserver.sendMessage(jsonObject.toString());
			List<String> messages = webserver.getMessages();
			if (!messages.isEmpty()) {
			// // 将最后一个消息转换为整数类型的列表
			webserver.clearMessages();
			try {
			ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("slicecage");
			if (sendwServer != null) {
			for (WebSocketServer webserver : sendwServer) {
			if (webserver != null) {
			webserver.sendMessage(jsonObject.toString());
			List<String> messages = webserver.getMessages();
			if (!messages.isEmpty()) {
			// // 将最后一个消息转换为整数类型的列表
			webserver.clearMessages();
			}
			} else {
			log.info("Home is closed");
			}
			} else {
			log.info("Home is closed");
			}
			}
			}catch (Exception e){
			e.printStackTrace(); // 打印堆栈信息，方便定位问题
			System.out.println("webserver出现异常: " + e.getMessage());
			// TODO: handle exception
			}




			} catch (Exception e) {
			e.printStackTrace();
			}