|
|
@@ -1,8 +1,10 @@
|
|
|
package com.zhongshu.card.server.core.controller.iotCenter;
|
|
|
|
|
|
+import com.github.microservice.models.device.DeviceSyncListParam;
|
|
|
import com.zhongshu.card.client.model.mqtt.SendMessageModel;
|
|
|
import com.zhongshu.card.client.ret.ResultContent;
|
|
|
import com.zhongshu.card.server.core.service.mqtt.MqttServiceImpl;
|
|
|
+import com.zhongshu.card.server.core.service.sync.DeviceSyncFromIotService;
|
|
|
import io.swagger.v3.oas.annotations.Hidden;
|
|
|
import io.swagger.v3.oas.annotations.Operation;
|
|
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
|
|
@@ -25,12 +27,12 @@ import org.springframework.web.bind.annotation.RestController;
|
|
|
public class DeviceSyncController {
|
|
|
|
|
|
@Autowired
|
|
|
- MqttServiceImpl mqttService;
|
|
|
+ DeviceSyncFromIotService deviceSyncFromIotService;
|
|
|
|
|
|
- @Operation(summary = "发送指令", hidden = true)
|
|
|
- @RequestMapping(value = "sendMessage", method = {RequestMethod.POST})
|
|
|
- public ResultContent sendMessage(@RequestBody SendMessageModel param) {
|
|
|
- return mqttService.sendMessage(param);
|
|
|
+ @Operation(summary = "物联网同步设备接口", hidden = true)
|
|
|
+ @RequestMapping(value = "syncDevices", method = {RequestMethod.POST})
|
|
|
+ public ResultContent syncDevices(@RequestBody DeviceSyncListParam param) {
|
|
|
+ return deviceSyncFromIotService.syncFromIotDevices(param);
|
|
|
}
|
|
|
|
|
|
}
|