|
@@ -3,7 +3,7 @@ package com.xy.consumer;
|
|
|
import cn.hutool.json.JSONObject;
|
|
import cn.hutool.json.JSONObject;
|
|
|
import cn.hutool.json.JSONUtil;
|
|
import cn.hutool.json.JSONUtil;
|
|
|
import com.xy.dto.DeviceStatusDto;
|
|
import com.xy.dto.DeviceStatusDto;
|
|
|
-import com.xy.service.DeviceStatusService;
|
|
|
|
|
|
|
+import com.xy.service.impl.DeviceStatusServiceImpl;
|
|
|
import lombok.AllArgsConstructor;
|
|
import lombok.AllArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
@@ -21,7 +21,7 @@ import org.springframework.stereotype.Service;
|
|
|
@AllArgsConstructor
|
|
@AllArgsConstructor
|
|
|
public class ConnectedConsumer implements MqttConsumer {
|
|
public class ConnectedConsumer implements MqttConsumer {
|
|
|
|
|
|
|
|
- private DeviceStatusService deviceStatusService;
|
|
|
|
|
|
|
+ private DeviceStatusServiceImpl deviceStatusService;
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public boolean message(String topic, String payload) {
|
|
public boolean message(String topic, String payload) {
|
