|
@@ -37,6 +37,7 @@ public class EnergyDeviceServiceImpl implements EnergyDeviceService {
|
|
|
|
|
|
final static String ENERGTY_DEVICE_URL="/api/energy/ENERGY/device/list?pageNum=1&pageSize=1000";
|
|
|
|
|
|
+ final static String WATER_HEATER_URL="/api/energy/ENERGY/device/controlWaterHeater";
|
|
|
@Override
|
|
|
public ReturnMsg getDeviceList() {
|
|
|
// 创建RestTemplate
|
|
@@ -80,4 +81,26 @@ public class EnergyDeviceServiceImpl implements EnergyDeviceService {
|
|
|
return ReturnMsg.fail(message);
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public ReturnMsg OpenWaterHeater(Integer deviceId, Integer open) {
|
|
|
+ // 创建RestTemplate
|
|
|
+ RestTemplate restTemplate = restTemplateConfig.build();
|
|
|
+ // 发送GET请求
|
|
|
+ String url = restTemplateConfig.addBaseUrl(WATER_HEATER_URL+"?deviceId="+deviceId+"&open="+open);
|
|
|
+ ResponseEntity<Map> responseEntity = restTemplate.getForEntity(url, Map.class);
|
|
|
+ // 获取响应对象里的 body 对象
|
|
|
+ Map<String, Object> body = responseEntity.getBody();
|
|
|
+ // 获取状态码
|
|
|
+ Integer code = (Integer)body.get("code");
|
|
|
+ // 获取响应信息
|
|
|
+ String message = (String)body.get("msg");
|
|
|
+ if(code==200){
|
|
|
+
|
|
|
+ return ReturnMsg.ok();
|
|
|
+ }else{
|
|
|
+ log.info("获取能源设备数据:"+message);
|
|
|
+ return ReturnMsg.fail(message);
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|