~zhoushihao/YiWuProject.git

New file
			@@ -0,0 +1,96 @@
			package com.mes.job;

			import cn.hutool.json.JSONObject;
			import com.mes.bigstorage.entity.BigStorageCageDetails;
			import com.mes.bigstorage.service.BigStorageCageDetailsService;
			import com.mes.bigstorage.service.BigStorageCageService;
			import com.mes.common.S7object;
			import com.mes.device.PlcParameterObject;
			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.scheduling.annotation.Scheduled;
			import org.springframework.stereotype.Component;

			import javax.annotation.Resource;
			import java.util.ArrayList;
			import java.util.List;
			import java.util.Map;

			/**
			* @author SNG-015
			*/
			@Component
			@Slf4j
			public class PlcSlicecage {

			@Resource
			private BigStorageCageService bigStorageCageService;
			@Resource
			private BigStorageCageDetailsService bigStorageCageDetailsService;
			@Resource
			private TemperingGlassInfoService temperingGlassInfoService;

			/**
			* fixedRate : 上一个调用开始后再次调用的延时（不用等待上一次调用完成）
			* fixedDelay : 上一个调用结束后再次调用的延时
			*/
			@Scheduled(fixedDelay = 5000)
			public void plcStorageCageTask() throws InterruptedException {
			JSONObject jsonObject = new JSONObject();
			try {
			//界面展示笼子信息
			jsonObject.append("bigStorageCageInfo1", bigStorageCageService.querybigStorageCageDetail(1));
			jsonObject.append("bigStorageCageInfo2", bigStorageCageService.querybigStorageCageDetail(2));
			jsonObject.append("bigStorageCageInfo3", bigStorageCageService.querybigStorageCageDetail(3));
			jsonObject.append("bigStorageCageInfo4", bigStorageCageService.querybigStorageCageDetail(4));
			jsonObject.append("bigStorageCageInfo5", bigStorageCageService.querybigStorageCageDetail(5));
			jsonObject.append("bigStorageCageInfo6", bigStorageCageService.querybigStorageCageDetail(6));
			jsonObject.append("bigStorageCageInfo7", bigStorageCageService.querybigStorageCageDetail(7));
			jsonObject.append("bigStorageCageInfo8", bigStorageCageService.querybigStorageCageDetail(8));

			//进片任务数据
			List<BigStorageCageDetails> bigStorageCageDetailsFeedTask=bigStorageCageDetailsService.selectTask(1);
			jsonObject.append("bigStorageCageDetailsFeedTask", bigStorageCageDetailsFeedTask);

			//出片任务数据
			List<BigStorageCageDetails> bigStorageCageDetailsOutTask=bigStorageCageDetailsService.selectTask(2);
			jsonObject.append("bigStorageCageDetailsOutTask", bigStorageCageDetailsOutTask);

			//理片笼使用情况
			List<Map<String, Object>> bigStorageCageUsage=bigStorageCageService.selectBigStorageCageUsage();
			jsonObject.append("bigStorageCageUsage", bigStorageCageUsage);

			//出片队列
			List<TemperingGlassInfo> temperingGlassInfoList= temperingGlassInfoService.list();
			jsonObject.append("temperingGlassInfoList", temperingGlassInfoList);

			//报警信息
			jsonObject.append("bigStorageCageFullAlarm", PlcStorageCageTask.bigStorageCageFullAlarm);

			//理片笼表格信息
			jsonObject.append("bigStorageCageInfo", bigStorageCageService.querybigStorageCageDetail(0));


			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");
			}
			}
			}
			} catch (Exception e) {
			e.printStackTrace();
			}
			}

			}