服务范围增删改查接口

lizijie

2022-01-14 9147ac833536f581c4ce8ff7504d7daf4a20cd9c

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

@@ -38,9 +38,6 @@
    private RedisTemplate redisTemplate;

    @Autowired
    private HistorySecondSpecialService historySecondSpecialService;

    @Autowired
    private HistorySecondCruiserService historySecondCruiserService;

    @Autowired
@@ -157,7 +154,6 @@
    @KafkaListener(topics = KafkaConstants.UAV_TOPIC_SECOND, groupId = KafkaConstants.GROUP_INSERT, containerFactory = "insertListenerContainerFactory")
    public void listenSecondSpecial(ConsumerRecord<String, String> record, Acknowledgment ack) {
        String msg = record.value();
        System.out.println(msg);
        try {
            Map<String, Object> data = JSON.parseObject(msg, Map.class);
            Object mac = data.get("mac");