通过组织id获取政府站点列表

lizijie

2021-09-23 5912cb4e4705b60875a2b1aa4beb1f7c94fc72e1

 screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java

@@ -39,7 +39,6 @@
    public void listen(ConsumerRecord<String, String> record, Consumer consumer) throws Exception {
        String messageStr = record.value();
        Map<String, Object> message = (Map<String, Object>) JSON.parse(messageStr);
        log.info(message.toString());
        //long serverStartTime = System.currentTimeMillis();
        CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets;
        for (SingleDeviceServer socket : sockets) {