YiWuProject.git

			@@ -48,7 +48,7 @@
			ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("unloadglass");
			if (sendwServer != null) {
			for (WebSocketServer webserver : sendwServer) {
			if (webserver != null&&webserver.session.isOpen()) {
			if (webserver != null && webserver.session.isOpen()) {
			log.info("已发送");
			webserver.sendMessage(jsonObject.toString());
			}
			@@ -60,13 +60,13 @@
			public void sendGlassInfoData() {
			log.info("发送工位显示图信息1");
			JSONObject jsonObject2 = new JSONObject();
			List<Map<String, Object>> glassinfodata = downWorkstationService.getTotalGlassDimensionsByWorkstation(1,3);
			jsonObject2.append("glassinfo",glassinfodata);
			List<Map<String, Object>> glassinfodata = downWorkstationService.getTotalGlassDimensionsByWorkstation(1, 3);
			jsonObject2.append("glassinfo", glassinfodata);
			log.info(jsonObject2.toString());
			ArrayList<WebSocketServer> sendwServer2 = WebSocketServer.sessionMap.get("unloadglass2");
			if (sendwServer2 != null) {
			for (WebSocketServer webserver : sendwServer2) {
			if (webserver != null&&webserver.session.isOpen()) {
			if (webserver != null && webserver.session.isOpen()) {
			webserver.sendMessage(jsonObject2.toString());
			}
			}
			@@ -77,35 +77,35 @@
			public void sendGlassInfoData2() {
			log.info("发送工位显示图信息2");
			JSONObject jsonObject3 = new JSONObject();
			List<Map<String, Object>> glassinfodata2 = downWorkstationService.getTotalGlassDimensionsByWorkstation(4,6);
			jsonObject3.append("glassinfo2",glassinfodata2);
			List<Map<String, Object>> glassinfodata2 = downWorkstationService.getTotalGlassDimensionsByWorkstation(4, 6);
			jsonObject3.append("glassinfo2", glassinfodata2);
			log.info(jsonObject3.toString());
			ArrayList<WebSocketServer> sendwServer3 = WebSocketServer.sessionMap.get("unloadglass3");
			if (sendwServer3 != null) {
			for (WebSocketServer webserver : sendwServer3) {
			if (webserver != null&&webserver.session.isOpen()) {
			if (webserver != null && webserver.session.isOpen()) {
			webserver.sendMessage(jsonObject3.toString());
			}
			}
			}
			}

			@Scheduled(fixedDelay = 2000)
			@Scheduled(fixedDelay = 2000)
			public void sendDownStorageCages() {
			log.info("发送缓存玻璃信息");
			JSONObject jsonObject4 = new JSONObject();
			List<Map<String, Object>> list=downStorageCageService.selectDownStorageCages();
			jsonObject4.append("params2",list);
			log.info(jsonObject4.toString());
			ArrayList<WebSocketServer> sendwServer4 = WebSocketServer.sessionMap.get("downcache");
			if (sendwServer4 != null) {
			for (WebSocketServer webserver : sendwServer4) {
			if (webserver != null && webserver.session.isOpen()) {
			webserver.sendMessage(jsonObject4.toString());
			}
			}
			}
			}
			List<Map<String, Object>> list = downStorageCageService.selectDownStorageCages();
			jsonObject4.append("params2", list);
			log.info(jsonObject4.toString());
			ArrayList<WebSocketServer> sendwServer4 = WebSocketServer.sessionMap.get("downcache");
			if (sendwServer4 != null) {
			for (WebSocketServer webserver : sendwServer4) {
			if (webserver != null && webserver.session.isOpen()) {
			webserver.sendMessage(jsonObject4.toString());
			}
			}
			}
			}

			@Scheduled(fixedDelay = 2000)
			public void sendDownGlassInfo() {
			@@ -138,4 +138,22 @@
			}
			}
			}

			@Scheduled(fixedDelay = 1000)
			public void isRun() {
			JSONObject jsonObject = new JSONObject();
			//正在进行的任务
			List<DownWorkstation> downWorkstation = downWorkstationService.getoneDownWorkstations(1, 6);
			jsonObject.append("downWorkstation", downWorkstation);
			ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("unLoadGlassIsRun");
			if (sendwServer != null) {
			for (WebSocketServer webserver : sendwServer) {
			if (webserver != null) {
			webserver.sendMessage(jsonObject.toString());
			} else {
			log.info("unLoadGlassIsRun is closed");
			}
			}
			}
			}
			}