| | |
|---|
| | | private TemperingGlassInfoService temperingGlassInfoService; |
|---|
| | | |
|---|
| | | private JSONObject jsonObject = new JSONObject(); |
|---|
| | | private JSONObject jsonObject1 = new JSONObject(); |
|---|
| | | public void queryDataSource1() throws InterruptedException { |
|---|
| | | List<Double> carPostion=new ArrayList<>(); |
|---|
| | | carPostion.add(0.25); |
|---|
| | | carPostion.add(0.5); |
|---|
| | | jsonObject.append("carPostion",carPostion); |
|---|
| | | //界面展示笼子信息 |
|---|
| | | // jsonObject.append("bigStorageCageInfos", bigStorageCageService.querybigStorageCageDetail()); |
|---|
| | | jsonObject1.append("bigStorageCageInfos", bigStorageCageService.querybigStorageCageDetail()); |
|---|
| | | |
|---|
| | | //进片任务数据 |
|---|
| | | List<BigStorageCageDetails> bigStorageCageDetailsFeedTask=bigStorageCageDetailsService.selectTask(1); |
|---|
| | |
|---|
| | | @Scheduled(fixedDelay = 1000) |
|---|
| | | public void plcStorageCageTask() throws InterruptedException { |
|---|
| | | jsonObject = new JSONObject(); |
|---|
| | | jsonObject1 = new JSONObject(); |
|---|
| | | try { |
|---|
| | | //查询使用数据源1查询数据 |
|---|
| | | queryDataSource1(); |
|---|
| | | //查询使用数据源2查询数据 |
|---|
| | | queryDataSource2(); |
|---|
| | | |
|---|
| | | ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("slicecage"); |
|---|
| | | if (sendwServer != null) { |
|---|
| | | for (WebSocketServer webserver : sendwServer) { |
|---|
| | | if (webserver != null) { |
|---|
| | | |
|---|
| | | webserver.sendMessage(jsonObject.toString()); |
|---|
| | | webserver.sendMessage(jsonObject1.toString()); |
|---|
| | | List<String> messages = webserver.getMessages(); |
|---|
| | | if (!messages.isEmpty()) { |
|---|
| | | // // 将最后一个消息转换为整数类型的列表 |
|---|
