hangzhoumesParent/common/servicebase/src/main/java/com/mes/temperingglass/service/impl/TemperingGlassInfoServiceImpl.java
@@ -32,10 +32,14 @@ QueryWrapper<TemperingGlassInfo> wrapper = new QueryWrapper<>(); wrapper.select("Top 1 *").eq("state",1); TemperingGlassInfo glass=temperingMapper.selectOne(wrapper); QueryWrapper<TemperingGlassInfo> glassinfo = new QueryWrapper<>(); glassinfo.eq("engineer_id",glass.getEngineerId()) .eq("tempering_layout_id", glass.getTemperingLayoutId()); return temperingMapper.selectList(glassinfo); if(glass!=null) { QueryWrapper<TemperingGlassInfo> glassinfo = new QueryWrapper<>(); glassinfo.eq("engineer_id", glass.getEngineerId()) .eq("tempering_layout_id", glass.getTemperingLayoutId()); return temperingMapper.selectList(glassinfo); }else { return null; } } @Override hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/WebSocketServer.java
@@ -122,7 +122,7 @@ if(this.session.isOpen()){ int maxChunkSize = 50000; // 定义最大的分块大小 int length = message.length(); // if(length>50000){ if(length>50000){ int chunks = (int) Math.ceil((double) length / maxChunkSize); //分块发送消息 for (int i = 0; i < chunks; i++) { @@ -138,9 +138,9 @@ // 发送分块消息，并传递是否是最后一块消息的标识 this.session.getBasicRemote().sendText(chunk); } // }else{ // this.session.getBasicRemote().sendText(message); // } }else{ this.session.getBasicRemote().sendText(message); } } } catch (Exception e) {
