#

zhou zhou

3 天以前 964a867a0e8a0814ecd7152a8ef1266f664a014b

 src/main/java/com/zy/asrs/timer/LedWebsocket.java

@@ -118,7 +118,7 @@
        }
        //仓库数据
        EntityWrapper<LocDetl> locDetlEntityWrapper = new EntityWrapper<>();
        locDetlEntityWrapper.setSqlSelect("matnr,COUNT(*) as matnrCount").groupBy("matnr");
        locDetlEntityWrapper.setSqlSelect("TOP 5 matnr,SUM(anfme) as matnrCount").groupBy("matnr").orderBy("matnrCount",false);
        List<Map<String, Object>>  selectMap = locDetlService.selectMaps(locDetlEntityWrapper);

        Date now = new Date();
@@ -151,9 +151,17 @@
        for (LedSlave slave : slaveProperties.getLed()) {
                LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, slave.getId());
                if (null != ledThread) {
                    map.put("to",slave.getStaArr().get(0).toString());
                    map.put("message",Cools.add("type", "error").add("errMsg",ledThread.getErrorMsg().toString()));
                    webSocketServer.onMessage(JSONObject.toJSONString(map),null,slave.getStaArr().get(0).toString());
                    if (!slave.getStaArr().isEmpty()){
                        map.put("to",slave.getStaArr().get(0).toString());
                        map.put("message",Cools.add("type", "error").add("errMsg",ledThread.getErrorMsg().toString()));
                        webSocketServer.onMessage(JSONObject.toJSONString(map),null,slave.getStaArr().get(0).toString());
                    }else {
                        map.put("to",slave.getAgvStaArr().get(0));
                        map.put("message",Cools.add("type", "error").add("errMsg",ledThread.getErrorMsg().toString()));
                        webSocketServer.onMessage(JSONObject.toJSONString(map),null,slave.getAgvStaArr().get(0));
                    }


                }

        }
@@ -166,9 +174,16 @@
        for (LedSlave slave : slaveProperties.getLed()) {
                LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, slave.getId());
                if (null != ledThread) {
                    map.put("to",slave.getStaArr().get(0).toString());
                    map.put("message",Cools.add("type", "task").add("taskList",ledThread.getCommandList()));
                    webSocketServer.onMessage(JSONObject.toJSONString(map),null,slave.getStaArr().get(0).toString());
                    if (!slave.getStaArr().isEmpty()){
                        map.put("to",slave.getStaArr().get(0).toString());
                        map.put("message",Cools.add("type", "task").add("taskList",ledThread.getCommandList()));
                        webSocketServer.onMessage(JSONObject.toJSONString(map),null,slave.getStaArr().get(0).toString());
                    }else {
                        map.put("to",slave.getAgvStaArr().get(0));
                        map.put("message",Cools.add("type", "task").add("taskList",ledThread.getCommandList()));
                        webSocketServer.onMessage(JSONObject.toJSONString(map),null,slave.getAgvStaArr().get(0));
                    }

                }

        }