YiWuProject.git

			@@ -13,6 +13,7 @@
			import com.mes.bigstoragecagetask.service.BigStorageCageTaskService;
			import com.mes.common.config.Const;
			import com.mes.glassinfo.service.GlassInfoService;
			import com.mes.largenscreen.entity.PieChartVO;
			import com.mes.temperingglass.entity.TemperingGlassInfo;
			import com.mes.temperingglass.service.TemperingGlassInfoService;
			import com.mes.tools.WebSocketServer;
			@@ -72,7 +73,7 @@
			BigStorageTaskVO task = new BigStorageTaskVO();
			task.setGlassId(requestWord.getValue() + "");
			int isExistCount = bigStorageCageDetailsService.count(new LambdaQueryWrapper<BigStorageCageDetails>().in(BigStorageCageDetails::getGlassId, task.getGlassId())
			.in(BigStorageCageDetails::getState, Const.GLASS_STATE_IN_ALL_ZERO));
			.in(BigStorageCageDetails::getState, Const.GLASS_STATE_IN_ALL));
			if (isExistCount > 0) {
			task.setIsSame(1);
			} else {
			@@ -203,4 +204,29 @@
			e.printStackTrace();
			}
			}

			@Scheduled(fixedDelay = 1000)
			public void largenScreen() {
			JSONObject jsonObject = new JSONObject();
			//理片笼使用情况
			List<Map<String, Object>> bigStorageCageUsage = bigStorageCageService.selectBigStorageCageUsage();
			jsonObject.append("bigStorageCageUsage", bigStorageCageUsage);
			List<PieChartVO> pieChartVOS = bigStorageCageService.queryPieChart();
			jsonObject.append("pieChartVOS", pieChartVOS);
			ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("largenScreen");
			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("largenScreen is closed");
			}
			}
			}
			}
			}