CanadaMes.git - Gitblit

			@@ -1,20 +1,32 @@
			package com.example.springboot.component;

			import cn.hutool.json.JSONObject;

			import java.util.List;

			import org.springframework.beans.factory.annotation.Autowired;

			import com.example.springboot.entity.Out_slice;
			import com.example.springboot.entity.Queue;
			import com.example.springboot.entity.StorageCage;
			import com.example.springboot.entity.alarmmg;
			import com.example.springboot.entity.north_glass_buffer1;
			import com.example.springboot.mapper.HomeMapper;
			import com.example.springboot.mapper.SpianMapper;
			import com.example.springboot.service.JdbcConnections;


			public class Plchome extends Thread {

			@Autowired
			private HomeMapper homeMapper;
			private SpianMapper spianMapper;
			private JdbcConnections dbserve;
			private JdbcConnections jdbcConnections;


			public static Boolean isAllowQueue=true;
			// public static Map b=new HashMap<>();
			// b.put()
			@Override
			public void run() {
			while (this != null) {
			@@ -28,6 +40,7 @@
			// 注入mapper
			homeMapper = WebSocketServer.applicationContext.getBean(HomeMapper.class);
			spianMapper = WebSocketServer.applicationContext.getBean(SpianMapper.class);
			jdbcConnections = WebSocketServer.applicationContext.getBean(JdbcConnections.class);
			// 笼子使用情况
			List<StorageCage> tableData = homeMapper.selectAll();
			jsonObject.append("tableData", tableData);
			@@ -43,18 +56,12 @@
			// 进出片任务
			List<StorageCage> tasklist1 = homeMapper.selectinout(3);
			List<StorageCage> tasklist2 = homeMapper.selectinout(2);
			for (StorageCage storageCage : tasklist1) {
			storageCage.setnorth_glass_buffer1s(homeMapper.SelectBoxNo(storageCage.getGlassId()));
			}
			for (StorageCage storageCage : tasklist2) {
			storageCage.setnorth_glass_buffer1s(homeMapper.SelectBoxNo(storageCage.getGlassId()));
			}
			jsonObject.append("tasklist1", tasklist1);
			jsonObject.append("tasklist2", tasklist2);
			// 查询报警信息
			List<alarmmg> alarmmg = homeMapper.SelectAlarmmgInfo();
			jsonObject.append("alarmmg", alarmmg);
			// // 读去Plc进片车与出片车位置W
			// 读去Plc进片车与出片车位置W
			// List<String> addressList = new ArrayList<String>();
			// addressList.add("DB106.12");
			// addressList.add("DB106.0");
			@@ -67,7 +74,7 @@
			// 1);// 获取进片车状态
			// boolean exist1 = datas1ListState.contains((short) 0);
			// jsonObject.append("zhuangtai", exist1);
			// 获取进片玻璃信息
			// //获取进片玻璃信息
			// List<Short> inglassInfo = S7control.getinstance().ReadWord("DB106.24", 1);
			// if (inglassInfo != null) {
			// if (inglassInfo.size() > 0)
			@@ -75,22 +82,27 @@
			// }
			// 伍获取进是否有待确认的玻璃id
			String queid = spianMapper.Selectqueueid();
			String state = spianMapper.Selectqueuestate();
			int state = spianMapper.Selectqueuestate();
			jsonObject.append("queid", queid);
			jsonObject.append("state", state);
			// 获取扫码位与上片位玻璃信息
			String queueglassid2 = homeMapper.GetQueueInfo(2);
			String queueglassid1 = homeMapper.GetQueueInfo(1);
			north_glass_buffer1 form2 = homeMapper.SelectGlassByGlassID(queueglassid2);
			north_glass_buffer1 form3 = homeMapper.SelectGlassByGlassID(queueglassid1);
			jsonObject.append("form2", form2);
			jsonObject.append("form3", form3);
			// List<Short> paramlists = new ArrayList<Short>();
			// short para1 = 11111;
			// short para2 = 32000;
			// paramlists.add(para1);
			// paramlists.add(para2);
			// System.out.println(paramlists);
			Queue form2 = homeMapper.GetQueueInfo(2);
			Queue form3 = homeMapper.GetQueueInfo(1);
			if(form2.getglassId()!=null&&form2.getglassId()!=""){
			jsonObject.append("form2", form2);
			}
			if(form3.getglassId()!=null&&form3.getglassId()!=""){
			jsonObject.append("form3", form3);
			}
			// 获取出片队列信息
			List<Out_slice> listoutslice = homeMapper.SelectProductionqueue();
			for (Out_slice out_slice : listoutslice) {
			out_slice.setstorageCage(homeMapper.SelectStorageGlassById(out_slice.getGlassId()));
			}
			jsonObject.append("listoutslice", listoutslice);
			//获取当前出片队列状态
			jsonObject.append("isAllowQueue", isAllowQueue);


			dbserve = WebSocketServer.applicationContext.getBean(JdbcConnections.class);
			boolean dbconnected = false;