diff --git a/fastbee-open-api/src/main/java/com/fastbee/data/controller/devicedetail/DeviceDetailController.java b/fastbee-open-api/src/main/java/com/fastbee/data/controller/devicedetail/DeviceDetailController.java index 1eb289d..319c1e0 100644 --- a/fastbee-open-api/src/main/java/com/fastbee/data/controller/devicedetail/DeviceDetailController.java +++ b/fastbee-open-api/src/main/java/com/fastbee/data/controller/devicedetail/DeviceDetailController.java @@ -1,13 +1,13 @@ package com.fastbee.data.controller.devicedetail; -import com.alibaba.fastjson2.JSONObject; import com.fastbee.common.core.controller.BaseController; import com.fastbee.common.core.domain.AjaxResult; +import com.fastbee.common.core.domain.CommonResult; import com.fastbee.common.model.vo.iot.QueryLogVo; -import com.fastbee.common.utils.StringUtils; import com.fastbee.data.service.devicedetail.IDeviceDetailService; import com.fastbee.iot.domain.Device; -import com.fastbee.iot.model.DeviceHistoryParam; +import com.fastbee.iot.model.haiwei.CmdHaiWeiVo; +import com.fastbee.iot.model.haiwei.dto.CmdHaiWeiDto; import com.fastbee.waterele.domain.MaWatereleRecord; import com.fastbee.waterele.domain.dto.MaGuangaiRecordDto; import com.fastbee.waterele.domain.dto.MaWatereleRecordDto; @@ -15,10 +15,8 @@ import com.fastbee.xunjian.domain.XjInspectionRecords; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.web.bind.annotation.*; -import java.util.HashMap; import java.util.List; @Api(tags = "设备详情数据") @@ -126,6 +124,16 @@ public class DeviceDetailController extends BaseController { } return AjaxResult.success(deviceDetailService.anfangInfo(deviceId)); } + @ApiOperation("箱门打开控制") + @PostMapping("/hwcmd") + public CommonResult cmdDevices(@RequestBody CmdHaiWeiDto cmdHwDto) { + return deviceDetailService.cmdDevices(cmdHwDto); + } + + + + + } diff --git a/fastbee-open-api/src/main/java/com/fastbee/data/controller/waterele/MaWatereleRecordController.java b/fastbee-open-api/src/main/java/com/fastbee/data/controller/waterele/MaWatereleRecordController.java index 1ad333b..bb7f3fd 100644 --- a/fastbee-open-api/src/main/java/com/fastbee/data/controller/waterele/MaWatereleRecordController.java +++ b/fastbee-open-api/src/main/java/com/fastbee/data/controller/waterele/MaWatereleRecordController.java @@ -1,5 +1,6 @@ package com.fastbee.data.controller.waterele; +import java.util.ArrayList; import java.util.List; import java.util.Map; import javax.servlet.http.HttpServletResponse; @@ -57,8 +58,8 @@ public class MaWatereleRecordController extends BaseController { @GetMapping("/echart") @ApiOperation("查询水电双计数据记录echart") public Map echart(MaWatereleRecord maWatereleRecord) { - Map map = maWatereleRecordService.chartData(maWatereleRecord); - return success(map); + ArrayList list = maWatereleRecordService.chartData(maWatereleRecord); + return success(list); } diff --git a/fastbee-open-api/src/main/java/com/fastbee/data/service/devicedetail/IDeviceDetailService.java b/fastbee-open-api/src/main/java/com/fastbee/data/service/devicedetail/IDeviceDetailService.java index e77564a..a7e2b92 100644 --- a/fastbee-open-api/src/main/java/com/fastbee/data/service/devicedetail/IDeviceDetailService.java +++ b/fastbee-open-api/src/main/java/com/fastbee/data/service/devicedetail/IDeviceDetailService.java @@ -1,15 +1,17 @@ package com.fastbee.data.service.devicedetail; +import com.fastbee.common.core.domain.CommonResult; import com.fastbee.common.model.vo.iot.QueryLogVo; import com.fastbee.data.domain.vo.AnfangInfoVo; import com.fastbee.iot.domain.Device; +import com.fastbee.iot.model.haiwei.CmdHaiWeiVo; +import com.fastbee.iot.model.haiwei.dto.CmdHaiWeiDto; import com.fastbee.waterele.domain.MaWatereleRecord; import com.fastbee.waterele.domain.dto.MaGuangaiRecordDto; import com.fastbee.waterele.domain.dto.MaWatereleRecordDto; import com.fastbee.xunjian.domain.XjInspectionRecords; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; public interface IDeviceDetailService { @@ -29,5 +31,7 @@ public interface IDeviceDetailService { List xunjianRecord(QueryLogVo queryLogVo); + CommonResult cmdDevices(CmdHaiWeiDto cmdHaiWeiDto); + AnfangInfoVo anfangInfo(Long deviceId); } diff --git a/fastbee-open-api/src/main/java/com/fastbee/data/service/devicedetail/impl/DeviceDetailServiceImpl.java b/fastbee-open-api/src/main/java/com/fastbee/data/service/devicedetail/impl/DeviceDetailServiceImpl.java index 2fd3b40..d5827ad 100644 --- a/fastbee-open-api/src/main/java/com/fastbee/data/service/devicedetail/impl/DeviceDetailServiceImpl.java +++ b/fastbee-open-api/src/main/java/com/fastbee/data/service/devicedetail/impl/DeviceDetailServiceImpl.java @@ -1,13 +1,17 @@ package com.fastbee.data.service.devicedetail.impl; +import com.fastbee.common.core.domain.CommonResult; import com.fastbee.common.model.vo.iot.QueryLogVo; import com.fastbee.common.utils.DevParamsUtils; import com.fastbee.common.utils.StringUtils; +import com.fastbee.common.utils.StringUtils; import com.fastbee.data.domain.vo.AnfangInfoVo; import com.fastbee.data.service.devicedetail.IDeviceDetailService; import com.fastbee.iot.domain.Device; -import com.fastbee.iot.domain.ThingsModel; +import com.fastbee.iot.haiwei.service.HaiWeiService; import com.fastbee.iot.mapper.DeviceMapper; +import com.fastbee.iot.model.haiwei.CmdHaiWeiVo; +import com.fastbee.iot.model.haiwei.dto.CmdHaiWeiDto; import com.fastbee.iot.service.IDeviceService; import com.fastbee.iot.service.IThingsModelService; import com.fastbee.waterele.domain.MaWatereleRecord; @@ -35,6 +39,8 @@ public class DeviceDetailServiceImpl implements IDeviceDetailService { private XjInspectionRoutesMapper xjInspectionRoutesMapper; @Autowired private XjInspectionRecordsMapper xjInspectionRecordsMapper; + @Autowired + private HaiWeiService haiWeiService; public DeviceDetailServiceImpl(DeviceMapper deviceMapper) { this.deviceMapper = deviceMapper; } @@ -138,6 +144,18 @@ public class DeviceDetailServiceImpl implements IDeviceDetailService { //获取安防历史记录 return null; } + @Override + public CommonResult cmdDevices(CmdHaiWeiDto cmdHaiWeiDto) { + String url = "https://cloud.haiwell.com/api/project/machine/datagroup/setTagsValue"; + Device deviceEntity = deviceMapper.selectDeviceByDeviceId(cmdHaiWeiDto.getDeviceId()); + Map devParams1 = DevParamsUtils.getDevParams(deviceEntity.getDevParams()); + String guimenIds = devParams1.get("guimenIds").toString(); + if (StringUtils.isEmpty(guimenIds)) { + return null; + } + cmdHaiWeiDto.setDeviceId(Long.valueOf(guimenIds)); + return haiWeiService.cmdDevices(cmdHaiWeiDto); + } } diff --git a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/IMaWatereleRecordService.java b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/IMaWatereleRecordService.java index 3c0d403..15f5ac0 100644 --- a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/IMaWatereleRecordService.java +++ b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/IMaWatereleRecordService.java @@ -1,5 +1,6 @@ package com.fastbee.waterele.service; +import java.util.ArrayList; import java.util.List; import java.util.Map; @@ -61,7 +62,7 @@ public interface IMaWatereleRecordService */ public int deleteMaWatereleRecordById(Long id); - Map chartData(MaWatereleRecord maWatereleRecord); + ArrayList chartData(MaWatereleRecord maWatereleRecord); } diff --git a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaWatereleRecordServiceImpl.java b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaWatereleRecordServiceImpl.java index 6c4310d..4a18793 100644 --- a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaWatereleRecordServiceImpl.java +++ b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaWatereleRecordServiceImpl.java @@ -96,20 +96,33 @@ public class MaWatereleRecordServiceImpl implements IMaWatereleRecordService } @Override - public Map chartData(MaWatereleRecord maWatereleRecord) { + public ArrayList chartData(MaWatereleRecord maWatereleRecord) { Map map = new HashMap(); + ArrayList list = new ArrayList<>(); List maWatereleRecords = maWatereleRecordMapper.selectMaWatereleRecordList(maWatereleRecord); List time = new ArrayList<>(); List sumFlow = new ArrayList<>(); List sumEle = new ArrayList<>(); + HashMap sumFlowtMap = new HashMap<>(); + sumFlowtMap.put("name", "累计水量"); + sumFlowtMap.put("unit", "m³"); + HashMap sumEletMap = new HashMap<>(); + sumEletMap.put("name", "累计电量"); + sumEletMap.put("unit", "度"); for (MaWatereleRecord record : maWatereleRecords) { time.add(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, record.getCreateTime())); sumFlow.add(record.getSumflow()); sumEle.add(record.getSumele()); } - map.put("time", time); - map.put("sumFlow", sumFlow); - map.put("sumEle", sumEle); - return map; + sumFlowtMap.put("time", time); + sumFlowtMap.put("data", sumFlow); + sumEletMap.put("time", time); + sumEletMap.put("data", sumEle); + list.add(sumFlowtMap); + list.add(sumEletMap); +// map.put("time", time); +// map.put("sumFlow", sumFlow); +// map.put("sumEle", sumEle); + return list; } }