调整KFKA数据推送测试2

jiazx0107@163.com

2024-01-04 50da1f165cc96d49d72694606920b77c74e1747c

 src/main/java/com/fzzy/gateway/service/GatewayDeviceService.java

@@ -92,6 +92,15 @@
        flushCache();
    }

    public void updateData(GatewayDevice device) {
        device.setStatus(Constant.YN_Y);

        gatewayDeviceRep.save(device);

        flushCacheOne(device);
    }


    /**
     * gatewayDeviceService#delData
     *
@@ -115,6 +124,10 @@
        for (GatewayDevice device : list) {
            GatewayUtils.add2Cache(device);
        }
    }

    private void flushCacheOne(GatewayDevice device) {
        GatewayUtils.add2Cache(device);
    }


@@ -154,4 +167,6 @@
            GatewayUtils.add2Cache(device);
        }
    }


}