diff --git a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/controller/tuya/TuyaDeviceController.java b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/controller/tuya/TuyaDeviceController.java index 8bead82..80f1189 100644 --- a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/controller/tuya/TuyaDeviceController.java +++ b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/controller/tuya/TuyaDeviceController.java @@ -1,7 +1,15 @@ package com.qiuguo.iot.user.api.controller.tuya; +import com.alibaba.fastjson.JSONObject; +import com.qiuguo.iot.third.query.TuyaQuery; +import com.qiuguo.iot.third.service.TuyaDeviceConnector; +import com.qiuguo.iot.third.service.TuyaDeviceService; +import java.util.Arrays; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import reactor.core.publisher.Mono; /** * XXX @@ -13,8 +21,15 @@ import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping("/tuya") public class TuyaDeviceController { - - + + @Autowired + private TuyaDeviceService tuyaDeviceService; + + @GetMapping("/set") + public Mono set(TuyaQuery query) { + + return tuyaDeviceService.controlDevice(query); + } }