From 3f98ccf49e7ffc098689c37237bd1dceed651ca1 Mon Sep 17 00:00:00 2001 From: ZengTao <2773468879@qq.com> Date: 星期一, 27 十一月 2023 09:14:39 +0800 Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/CanadaMes --- springboot-vue3/src/main/java/com/example/springboot/component/Plchome.java | 74 ++++++++++++++++++++++++++++-------- 1 files changed, 57 insertions(+), 17 deletions(-) diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/Plchome.java b/springboot-vue3/src/main/java/com/example/springboot/component/Plchome.java index 953fd91..60f5831 100644 --- a/springboot-vue3/src/main/java/com/example/springboot/component/Plchome.java +++ b/springboot-vue3/src/main/java/com/example/springboot/component/Plchome.java @@ -1,23 +1,25 @@ package com.example.springboot.component; import cn.hutool.json.JSONObject; - -import java.util.ArrayList; import java.util.List; - 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 { private HomeMapper homeMapper; + private SpianMapper spianMapper; + private JdbcConnections dbserve; @Override public void run() { while (this != null) { try { - Thread.sleep(10000); + Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } @@ -25,6 +27,7 @@ // 娉ㄥ叆mapper homeMapper = WebSocketServer.applicationContext.getBean(HomeMapper.class); + spianMapper = WebSocketServer.applicationContext.getBean(SpianMapper.class); // 绗煎瓙浣跨敤鎯呭喌 List<StorageCage> tableData = homeMapper.selectAll(); jsonObject.append("tableData", tableData); @@ -38,30 +41,67 @@ jsonObject.append("cagelist3", cagelist3); jsonObject.append("cagelist4", cagelist4); // 杩涘嚭鐗囦换鍔� - List<StorageCage> tasklist1 = homeMapper.selectinout(2); - List<StorageCage> tasklist2 = homeMapper.selectinout(3); + 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杩涚墖杞︿笌鍑虹墖杞︿綅缃甒 - List<String> addressList = new ArrayList<String>(); - addressList.add("DB106.0"); - addressList.add("DB106.12"); - List<Short> paramlist = S7control.getinstance().ReadWord(addressList); - + // // 璇诲幓Plc杩涚墖杞︿笌鍑虹墖杞︿綅缃甒 + // List<String> addressList = new ArrayList<String>(); + // addressList.add("DB106.12"); + // addressList.add("DB106.0"); + // List<Short> paramlist = S7control.getinstance().ReadWord(addressList); + // if (paramlist != null) { + // jsonObject.append("params", paramlist); + // } + // // 鑾峰彇杩涚墖杞︾姸鎬� + // List<Short> datas1ListState = S7control.getinstance().ReadWord("DB106.8", + // 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) + // jsonObject.append("loadglassheight", inglassInfo.get(0) * 70); + // } + // 浼� 鑾峰彇杩涙槸鍚︽湁寰呯‘璁ょ殑鐜荤拑id + String queid = spianMapper.Selectqueueid(); + String 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 = 1; - // short para2 = 2; + // short para1 = 11111; + // short para2 = 32000; // paramlists.add(para1); // paramlists.add(para2); // System.out.println(paramlists); - if(paramlist!=null){ - // Short[] paramlists = paramlist.toArray(new Short[0]); - jsonObject.append("params", paramlist); + dbserve = WebSocketServer.applicationContext.getBean(JdbcConnections.class); + boolean dbconnected = false; + try { + dbserve.getConn(); + dbconnected = true; + } catch (Exception e) { + // TODO: handle exception + dbconnected = false; } + jsonObject.append("dbconnected", dbconnected); // jsonObject.append("params", new short[] { 30, 40, }); WebSocketServer sendwServer = WebSocketServer.sessionMap.get("Home"); if (sendwServer != null) { -- Gitblit v1.8.0