YiWuProject.git

			@@ -2,11 +2,12 @@

			import cn.hutool.json.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
			import com.mes.common.config.Const;
			import com.mes.damage.entity.Damage;
			import com.mes.damage.service.DamageService;
			import com.mes.temperingglass.service.TemperingGlassInfoService;
			import com.mes.largenscreen.entity.PieChartVO;
			import com.mes.temperingglass.entity.TemperingGlassInfo;
			import com.mes.temperingglass.service.TemperingGlassInfoService;
			import com.mes.tools.WebSocketServer;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.beans.factory.annotation.Autowired;
			@@ -15,7 +16,6 @@

			import java.util.ArrayList;
			import java.util.List;
			import java.util.stream.Collectors;

			/**
			* @author SNG-010
			@@ -38,7 +38,7 @@
			public void temperingGlassHome() {
			JSONObject jsonObject = new JSONObject();
			//正在等待进片的玻璃
			List<TemperingGlassInfo> waitingGlass = temperingAgoService.selectWaitingGlass();
			List<TemperingGlassInfo> waitingGlass = temperingAgoService.selectWaitingGlassByOpc();
			if (waitingGlass != null) {
			jsonObject.append("waitingGlass", waitingGlass);
			}
			@@ -86,6 +86,8 @@
			//正在进行的任务
			List<TemperingGlassInfo> temperingTaskType = temperingAgoService.selectTaskType();
			jsonObject.append("temperingTaskType", temperingTaskType);


			ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("temperingIsRun");
			if (sendwServer != null) {
			for (WebSocketServer webserver : sendwServer) {
			@@ -99,5 +101,49 @@

			}

			@Scheduled(fixedDelay = 1000)
			public void largenScreen() {
			JSONObject jsonObject = new JSONObject();
			//大屏钢化信息
			Integer putGlass = temperingAgoService.count(
			new LambdaUpdateWrapper<TemperingGlassInfo>()
			.eq(TemperingGlassInfo::getState, Const.TEMPERING_NEW)
			);
			jsonObject.append("temperingTaskType", putGlass);
			//大屏钢化信息
			List<TemperingGlassInfo> temperingGlassInfoList = temperingAgoService.list(
			new LambdaQueryWrapper<TemperingGlassInfo>()
			.select(TemperingGlassInfo::getEngineerId, TemperingGlassInfo::getTemperingLayoutId) // 选择要去重的字段
			.eq(TemperingGlassInfo::getState, Const.TEMPERING_START)
			.groupBy(TemperingGlassInfo::getEngineerId, TemperingGlassInfo::getTemperingLayoutId) // 按 engineerId 和 temperingLayoutId 分组
			);
			jsonObject.append("temperingGlassInfoList", temperingGlassInfoList.size());
			//大屏钢化信息
			List<TemperingGlassInfo> temperingGlassInfoInList = temperingAgoService.list(
			new LambdaQueryWrapper<TemperingGlassInfo>()
			.select(TemperingGlassInfo::getEngineerId, TemperingGlassInfo::getTemperingLayoutId) // 选择要去重的字段
			.eq(TemperingGlassInfo::getState, Const.TEMPERING_DROP)
			.groupBy(TemperingGlassInfo::getEngineerId, TemperingGlassInfo::getTemperingLayoutId) // 按 engineerId 和 temperingLayoutId 分组
			);
			jsonObject.append("temperingGlassInfoInList", temperingGlassInfoInList.size());
			//钢化饼图数据
			List<PieChartVO> pieChartVOS = temperingAgoService.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");
			}
			}
			}
			}

			}