diff --git a/casic-device/pom.xml b/casic-device/pom.xml
index 2f74cd0..8f02469 100644
--- a/casic-device/pom.xml
+++ b/casic-device/pom.xml
@@ -133,6 +133,11 @@
org.springframework.boot
spring-boot-starter-activemq
+
+ com.casic
+ casic-admin-area
+ 1.0.1.alpha
+
diff --git a/casic-device/pom.xml b/casic-device/pom.xml
index 2f74cd0..8f02469 100644
--- a/casic-device/pom.xml
+++ b/casic-device/pom.xml
@@ -133,6 +133,11 @@
org.springframework.boot
spring-boot-starter-activemq
+
+ com.casic
+ casic-admin-area
+ 1.0.1.alpha
+
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java
index 21ffcec..8316f46 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java
@@ -27,6 +27,7 @@
import com.casic.missiles.modular.system.model.Device;
import com.casic.missiles.modular.system.model.DeviceModels;
import com.casic.missiles.modular.system.model.DeviceType;
+import com.casic.missiles.modular.system.service.IAreaService;
import com.casic.missiles.modular.system.service.IDeviceModelsService;
import com.casic.missiles.modular.system.service.IDeviceService;
import com.casic.missiles.modular.system.service.IDeviceTypeService;
@@ -77,6 +78,9 @@
@Autowired
private IDeviceModelsService deviceModelsService;
+ @Autowired
+ private IAreaService iAreaService;
+
@ApiOperation("获取设备列表")
@RequestMapping(value = "/list")
@ResponseBody
@@ -98,9 +102,8 @@
@RequestMapping(value = "/listByConfig")
@ResponseBody
public ResponseData listByConfig(String deviceType, String configStatus) {
-
DataScope dataScope = permissionService.getCurrUserDataScope();
- List list = deviceService.selectDevicesByConfig(dataScope, deviceType, configStatus);
+ List list = deviceService.selectDevicesByConfig(dataScope, deviceType, configStatus);
if (ToolUtil.isNotEmpty(list)) {
list.forEach(deviceCodeSelectDto -> {
deviceCodeSelectDto.setDeptName(permissionService.getDeptName(deviceCodeSelectDto.getDeptId()));
@@ -109,7 +112,6 @@
return new SuccessResponseData(list);
}
-
@ApiOperation("获取设备类型列表")
@GetMapping(value = "/type")
@ResponseBody
@@ -131,8 +133,9 @@
public Object model(String deviceType) {
//设备类型列表查询
EntityWrapper query = new EntityWrapper<>();
- if (ToolUtil.isNotEmpty(deviceType))
+ if (ToolUtil.isNotEmpty(deviceType)) {
query.eq(DEVICE_QUERY_DEVICE_TYPE, deviceType);
+ }
List list = deviceModelsService.selectList(query);
List selectDtos = new ArrayList<>();
@@ -293,5 +296,41 @@
return ResponseData.success();
}
+ @ApiOperation("设备历史数据")
+ @RequestMapping(value = "/sevenDayData")
+ @ResponseBody
+ public Object sevenDayData(String devCode, String beginTime, String endTime) {
+ if (ToolUtil.isEmpty(devCode)) {
+ throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+ }
+ return new SuccessResponseData(deviceService.selectDeviceData(devCode, beginTime, endTime));
+ }
+ @ApiOperation("设备总用水数据")
+ @RequestMapping(value = "/totalData")
+ @ResponseBody
+ public Object totalData(String devCode, String beginTime, String endTime) {
+ if (ToolUtil.isEmpty(devCode)) {
+ throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+ }
+ return new SuccessResponseData(deviceService.selectDeviceTotalData(devCode, beginTime, endTime));
+ }
+
+ // @ApiOperation("统计设备在一定时间段内报警数")
+// @RequestMapping(value = "/alarmCountByDay")
+// @ResponseBody
+// public Object alarmCountByDay(String beginTime, String endTime) {
+// if (ToolUtil.isEmpty(beginTime) || ToolUtil.isEmpty(endTime)) {
+// throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+// }
+// return new SuccessResponseData(deviceService.selectAlarmCountByDay(beginTime, endTime));
+// }
+
+
+ @RequestMapping(value = "/getAreas")
+ @ResponseBody
+ public Object getAreas() {
+ //设备类型列表查询
+ return ResponseData.success(iAreaService.selectList(null));
+ }
}
diff --git a/casic-device/pom.xml b/casic-device/pom.xml
index 2f74cd0..8f02469 100644
--- a/casic-device/pom.xml
+++ b/casic-device/pom.xml
@@ -133,6 +133,11 @@
org.springframework.boot
spring-boot-starter-activemq
+
+ com.casic
+ casic-admin-area
+ 1.0.1.alpha
+
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java
index 21ffcec..8316f46 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java
@@ -27,6 +27,7 @@
import com.casic.missiles.modular.system.model.Device;
import com.casic.missiles.modular.system.model.DeviceModels;
import com.casic.missiles.modular.system.model.DeviceType;
+import com.casic.missiles.modular.system.service.IAreaService;
import com.casic.missiles.modular.system.service.IDeviceModelsService;
import com.casic.missiles.modular.system.service.IDeviceService;
import com.casic.missiles.modular.system.service.IDeviceTypeService;
@@ -77,6 +78,9 @@
@Autowired
private IDeviceModelsService deviceModelsService;
+ @Autowired
+ private IAreaService iAreaService;
+
@ApiOperation("获取设备列表")
@RequestMapping(value = "/list")
@ResponseBody
@@ -98,9 +102,8 @@
@RequestMapping(value = "/listByConfig")
@ResponseBody
public ResponseData listByConfig(String deviceType, String configStatus) {
-
DataScope dataScope = permissionService.getCurrUserDataScope();
- List list = deviceService.selectDevicesByConfig(dataScope, deviceType, configStatus);
+ List list = deviceService.selectDevicesByConfig(dataScope, deviceType, configStatus);
if (ToolUtil.isNotEmpty(list)) {
list.forEach(deviceCodeSelectDto -> {
deviceCodeSelectDto.setDeptName(permissionService.getDeptName(deviceCodeSelectDto.getDeptId()));
@@ -109,7 +112,6 @@
return new SuccessResponseData(list);
}
-
@ApiOperation("获取设备类型列表")
@GetMapping(value = "/type")
@ResponseBody
@@ -131,8 +133,9 @@
public Object model(String deviceType) {
//设备类型列表查询
EntityWrapper query = new EntityWrapper<>();
- if (ToolUtil.isNotEmpty(deviceType))
+ if (ToolUtil.isNotEmpty(deviceType)) {
query.eq(DEVICE_QUERY_DEVICE_TYPE, deviceType);
+ }
List list = deviceModelsService.selectList(query);
List selectDtos = new ArrayList<>();
@@ -293,5 +296,41 @@
return ResponseData.success();
}
+ @ApiOperation("设备历史数据")
+ @RequestMapping(value = "/sevenDayData")
+ @ResponseBody
+ public Object sevenDayData(String devCode, String beginTime, String endTime) {
+ if (ToolUtil.isEmpty(devCode)) {
+ throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+ }
+ return new SuccessResponseData(deviceService.selectDeviceData(devCode, beginTime, endTime));
+ }
+ @ApiOperation("设备总用水数据")
+ @RequestMapping(value = "/totalData")
+ @ResponseBody
+ public Object totalData(String devCode, String beginTime, String endTime) {
+ if (ToolUtil.isEmpty(devCode)) {
+ throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+ }
+ return new SuccessResponseData(deviceService.selectDeviceTotalData(devCode, beginTime, endTime));
+ }
+
+ // @ApiOperation("统计设备在一定时间段内报警数")
+// @RequestMapping(value = "/alarmCountByDay")
+// @ResponseBody
+// public Object alarmCountByDay(String beginTime, String endTime) {
+// if (ToolUtil.isEmpty(beginTime) || ToolUtil.isEmpty(endTime)) {
+// throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+// }
+// return new SuccessResponseData(deviceService.selectAlarmCountByDay(beginTime, endTime));
+// }
+
+
+ @RequestMapping(value = "/getAreas")
+ @ResponseBody
+ public Object getAreas() {
+ //设备类型列表查询
+ return ResponseData.success(iAreaService.selectList(null));
+ }
}
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterMeterDataController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterMeterDataController.java
index 6773e07..17556c7 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterMeterDataController.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterMeterDataController.java
@@ -6,15 +6,10 @@
import com.casic.missiles.core.common.constant.factory.PageFactory;
import com.casic.missiles.core.common.service.ICommonPermissionService;
import com.casic.missiles.core.datascope.DataScope;
-import com.casic.missiles.modular.system.constant.ModularDictConst;
import com.casic.missiles.modular.system.dto.DeviceDto;
-import com.casic.missiles.modular.system.dto.DeviceTypeEnum;
import com.casic.missiles.modular.system.service.IDeviceService;
-import com.sun.javafx.binding.StringFormatter;
import io.swagger.annotations.ApiOperation;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@@ -25,25 +20,31 @@
import java.util.List;
import java.util.Map;
+/**
+ * @author a203
+ */
@Controller
@RequestMapping("/waterMeterData")
public class WaterMeterDataController extends ExportController {
- private static final Logger logger = LoggerFactory.getLogger(DeviceController.class);
- @Autowired
- private ICommonPermissionService permissionService;
- @Autowired
- private IDeviceService deviceService;
+ private final ICommonPermissionService permissionService;
+ private final IDeviceService deviceService;
+
+ public WaterMeterDataController(ICommonPermissionService permissionService,
+ IDeviceService deviceService) {
+ this.permissionService = permissionService;
+ this.deviceService = deviceService;
+ }
@ApiOperation("获取水表设备列表")
@RequestMapping(value = "/listPage")
@ResponseBody
- public Object listPage(String keywords, String deptid, String areaId) {
+ public Object listPage(String keywords, String areaId) {
Page page = new PageFactory().defaultPage();
//查询数据权限 使用默认DEPTID 字段
DataScope dataScope = permissionService.getCurrUserDataScope();
- areaId += "%";
- List list = deviceService.selectDataScopePage(dataScope, page, "13", deptid, "", "", keywords, "", areaId);
+// areaId += "%";
+ List list = deviceService.selectDataScopePage(dataScope, page, "13", "", "", "", keywords, "", areaId);
DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
DateFormat sdf4 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -52,21 +53,45 @@
list.forEach(deviceDto -> {
// 获取日月年用水量和最近的读数
Map dayMeter = deviceService.selectWaterMeterDay(deviceDto.getDevcode(), date);
- deviceDto.setDayCount(dayMeter.get("FLOW_ACC_DATE").toString());
+ if (dayMeter == null) {
+ deviceDto.setDayCount("0");
+ } else {
+ deviceDto.setDayCount(dayMeter.get("FLOW_ACC_DATE").toString());
+ }
Map monthMeter = deviceService.selectWaterMeterMonth(deviceDto.getDevcode(), date.substring(0, 7));
- deviceDto.setMonthCount(monthMeter.get("FLOW_ACC_MONTH").toString());
+ if (monthMeter == null) {
+ deviceDto.setMonthCount("0");
+ } else {
+ deviceDto.setMonthCount(monthMeter.get("FLOW_ACC_MONTH").toString());
+ }
Map totalMeter = deviceService.selectWaterMeterTotal(deviceDto.getDevcode(), date.substring(0, 4));
- deviceDto.setTotalCount(totalMeter.get("FLOW_ACC_TOTAL").toString());
+ if (totalMeter == null) {
+ deviceDto.setTotalCount("0");
+ } else {
+ deviceDto.setTotalCount(totalMeter.get("FLOW_ACC_TOTAL").toString());
+ }
Map meterRec = deviceService.selectLatestWaterMeter(deviceDto.getDevcode());
- deviceDto.setWatchNum(meterRec.get("FLOW_ACC").toString());
- deviceDto.setUptime(sdf4.format((Date) meterRec.get("UPTIME")));
+ if (meterRec == null) {
+ deviceDto.setWatchNum("0");
+ deviceDto.setUptime(sdf4.format(new Date()));
+ } else {
+ deviceDto.setWatchNum(meterRec.get("FLOW_ACC").toString());
+ deviceDto.setUptime(sdf4.format((Date) meterRec.get("UPTIME")));
+ }
deviceDto.setAreaFullName(deviceService.getAreaFullNameById(deviceDto.getArea()));
});
page.setRecords(list);
return new SuccessResponseData(super.packForBT(page));
}
+
+ @ApiOperation("统计水表数量")
+ @RequestMapping(value = "/count")
+ @ResponseBody
+ public Object waterMeterCount() {
+ return new SuccessResponseData(deviceService.getWaterMeterCount());
+ }
}
diff --git a/casic-device/pom.xml b/casic-device/pom.xml
index 2f74cd0..8f02469 100644
--- a/casic-device/pom.xml
+++ b/casic-device/pom.xml
@@ -133,6 +133,11 @@
org.springframework.boot
spring-boot-starter-activemq
+
+ com.casic
+ casic-admin-area
+ 1.0.1.alpha
+
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java
index 21ffcec..8316f46 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java
@@ -27,6 +27,7 @@
import com.casic.missiles.modular.system.model.Device;
import com.casic.missiles.modular.system.model.DeviceModels;
import com.casic.missiles.modular.system.model.DeviceType;
+import com.casic.missiles.modular.system.service.IAreaService;
import com.casic.missiles.modular.system.service.IDeviceModelsService;
import com.casic.missiles.modular.system.service.IDeviceService;
import com.casic.missiles.modular.system.service.IDeviceTypeService;
@@ -77,6 +78,9 @@
@Autowired
private IDeviceModelsService deviceModelsService;
+ @Autowired
+ private IAreaService iAreaService;
+
@ApiOperation("获取设备列表")
@RequestMapping(value = "/list")
@ResponseBody
@@ -98,9 +102,8 @@
@RequestMapping(value = "/listByConfig")
@ResponseBody
public ResponseData listByConfig(String deviceType, String configStatus) {
-
DataScope dataScope = permissionService.getCurrUserDataScope();
- List list = deviceService.selectDevicesByConfig(dataScope, deviceType, configStatus);
+ List list = deviceService.selectDevicesByConfig(dataScope, deviceType, configStatus);
if (ToolUtil.isNotEmpty(list)) {
list.forEach(deviceCodeSelectDto -> {
deviceCodeSelectDto.setDeptName(permissionService.getDeptName(deviceCodeSelectDto.getDeptId()));
@@ -109,7 +112,6 @@
return new SuccessResponseData(list);
}
-
@ApiOperation("获取设备类型列表")
@GetMapping(value = "/type")
@ResponseBody
@@ -131,8 +133,9 @@
public Object model(String deviceType) {
//设备类型列表查询
EntityWrapper query = new EntityWrapper<>();
- if (ToolUtil.isNotEmpty(deviceType))
+ if (ToolUtil.isNotEmpty(deviceType)) {
query.eq(DEVICE_QUERY_DEVICE_TYPE, deviceType);
+ }
List list = deviceModelsService.selectList(query);
List selectDtos = new ArrayList<>();
@@ -293,5 +296,41 @@
return ResponseData.success();
}
+ @ApiOperation("设备历史数据")
+ @RequestMapping(value = "/sevenDayData")
+ @ResponseBody
+ public Object sevenDayData(String devCode, String beginTime, String endTime) {
+ if (ToolUtil.isEmpty(devCode)) {
+ throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+ }
+ return new SuccessResponseData(deviceService.selectDeviceData(devCode, beginTime, endTime));
+ }
+ @ApiOperation("设备总用水数据")
+ @RequestMapping(value = "/totalData")
+ @ResponseBody
+ public Object totalData(String devCode, String beginTime, String endTime) {
+ if (ToolUtil.isEmpty(devCode)) {
+ throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+ }
+ return new SuccessResponseData(deviceService.selectDeviceTotalData(devCode, beginTime, endTime));
+ }
+
+ // @ApiOperation("统计设备在一定时间段内报警数")
+// @RequestMapping(value = "/alarmCountByDay")
+// @ResponseBody
+// public Object alarmCountByDay(String beginTime, String endTime) {
+// if (ToolUtil.isEmpty(beginTime) || ToolUtil.isEmpty(endTime)) {
+// throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+// }
+// return new SuccessResponseData(deviceService.selectAlarmCountByDay(beginTime, endTime));
+// }
+
+
+ @RequestMapping(value = "/getAreas")
+ @ResponseBody
+ public Object getAreas() {
+ //设备类型列表查询
+ return ResponseData.success(iAreaService.selectList(null));
+ }
}
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterMeterDataController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterMeterDataController.java
index 6773e07..17556c7 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterMeterDataController.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterMeterDataController.java
@@ -6,15 +6,10 @@
import com.casic.missiles.core.common.constant.factory.PageFactory;
import com.casic.missiles.core.common.service.ICommonPermissionService;
import com.casic.missiles.core.datascope.DataScope;
-import com.casic.missiles.modular.system.constant.ModularDictConst;
import com.casic.missiles.modular.system.dto.DeviceDto;
-import com.casic.missiles.modular.system.dto.DeviceTypeEnum;
import com.casic.missiles.modular.system.service.IDeviceService;
-import com.sun.javafx.binding.StringFormatter;
import io.swagger.annotations.ApiOperation;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@@ -25,25 +20,31 @@
import java.util.List;
import java.util.Map;
+/**
+ * @author a203
+ */
@Controller
@RequestMapping("/waterMeterData")
public class WaterMeterDataController extends ExportController {
- private static final Logger logger = LoggerFactory.getLogger(DeviceController.class);
- @Autowired
- private ICommonPermissionService permissionService;
- @Autowired
- private IDeviceService deviceService;
+ private final ICommonPermissionService permissionService;
+ private final IDeviceService deviceService;
+
+ public WaterMeterDataController(ICommonPermissionService permissionService,
+ IDeviceService deviceService) {
+ this.permissionService = permissionService;
+ this.deviceService = deviceService;
+ }
@ApiOperation("获取水表设备列表")
@RequestMapping(value = "/listPage")
@ResponseBody
- public Object listPage(String keywords, String deptid, String areaId) {
+ public Object listPage(String keywords, String areaId) {
Page page = new PageFactory().defaultPage();
//查询数据权限 使用默认DEPTID 字段
DataScope dataScope = permissionService.getCurrUserDataScope();
- areaId += "%";
- List list = deviceService.selectDataScopePage(dataScope, page, "13", deptid, "", "", keywords, "", areaId);
+// areaId += "%";
+ List list = deviceService.selectDataScopePage(dataScope, page, "13", "", "", "", keywords, "", areaId);
DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
DateFormat sdf4 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -52,21 +53,45 @@
list.forEach(deviceDto -> {
// 获取日月年用水量和最近的读数
Map dayMeter = deviceService.selectWaterMeterDay(deviceDto.getDevcode(), date);
- deviceDto.setDayCount(dayMeter.get("FLOW_ACC_DATE").toString());
+ if (dayMeter == null) {
+ deviceDto.setDayCount("0");
+ } else {
+ deviceDto.setDayCount(dayMeter.get("FLOW_ACC_DATE").toString());
+ }
Map monthMeter = deviceService.selectWaterMeterMonth(deviceDto.getDevcode(), date.substring(0, 7));
- deviceDto.setMonthCount(monthMeter.get("FLOW_ACC_MONTH").toString());
+ if (monthMeter == null) {
+ deviceDto.setMonthCount("0");
+ } else {
+ deviceDto.setMonthCount(monthMeter.get("FLOW_ACC_MONTH").toString());
+ }
Map totalMeter = deviceService.selectWaterMeterTotal(deviceDto.getDevcode(), date.substring(0, 4));
- deviceDto.setTotalCount(totalMeter.get("FLOW_ACC_TOTAL").toString());
+ if (totalMeter == null) {
+ deviceDto.setTotalCount("0");
+ } else {
+ deviceDto.setTotalCount(totalMeter.get("FLOW_ACC_TOTAL").toString());
+ }
Map meterRec = deviceService.selectLatestWaterMeter(deviceDto.getDevcode());
- deviceDto.setWatchNum(meterRec.get("FLOW_ACC").toString());
- deviceDto.setUptime(sdf4.format((Date) meterRec.get("UPTIME")));
+ if (meterRec == null) {
+ deviceDto.setWatchNum("0");
+ deviceDto.setUptime(sdf4.format(new Date()));
+ } else {
+ deviceDto.setWatchNum(meterRec.get("FLOW_ACC").toString());
+ deviceDto.setUptime(sdf4.format((Date) meterRec.get("UPTIME")));
+ }
deviceDto.setAreaFullName(deviceService.getAreaFullNameById(deviceDto.getArea()));
});
page.setRecords(list);
return new SuccessResponseData(super.packForBT(page));
}
+
+ @ApiOperation("统计水表数量")
+ @RequestMapping(value = "/count")
+ @ResponseBody
+ public Object waterMeterCount() {
+ return new SuccessResponseData(deviceService.getWaterMeterCount());
+ }
}
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterStatisticController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterStatisticController.java
new file mode 100644
index 0000000..eaa2073
--- /dev/null
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterStatisticController.java
@@ -0,0 +1,40 @@
+package com.casic.missiles.modular.system.controller;
+
+import com.casic.missiles.core.base.controller.BaseController;
+import com.casic.missiles.core.base.response.SuccessResponseData;
+import com.casic.missiles.modular.system.service.IDeviceService;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+/**
+ * @author a203
+ */
+@Controller
+@RequestMapping("/waterStatistic")
+public class WaterStatisticController extends BaseController {
+
+ private final IDeviceService deviceService;
+
+ public WaterStatisticController(IDeviceService deviceService) {
+ this.deviceService = deviceService;
+ }
+
+ @ApiOperation("总览查询用水量")
+ @RequestMapping(value = "/overview")
+ @ResponseBody
+ public Object overview() {
+ return new SuccessResponseData(deviceService.getOverview());
+ }
+
+// @ApiOperation("一级分区各区用水量")
+// @RequestMapping(value = "/countByFirstArea")
+// @ResponseBody
+// public Object countByFirstArea(String devType, String startTime, String endTime) {
+// if (ToolUtil.isEmpty(startTime) || ToolUtil.isEmpty(endTime)) {
+// throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+// }
+// return new SuccessResponseData(deviceService.countByFirstArea(devType, startTime, endTime));
+// }
+}
diff --git a/casic-device/pom.xml b/casic-device/pom.xml
index 2f74cd0..8f02469 100644
--- a/casic-device/pom.xml
+++ b/casic-device/pom.xml
@@ -133,6 +133,11 @@
org.springframework.boot
spring-boot-starter-activemq
+
+ com.casic
+ casic-admin-area
+ 1.0.1.alpha
+
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java
index 21ffcec..8316f46 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceController.java
@@ -27,6 +27,7 @@
import com.casic.missiles.modular.system.model.Device;
import com.casic.missiles.modular.system.model.DeviceModels;
import com.casic.missiles.modular.system.model.DeviceType;
+import com.casic.missiles.modular.system.service.IAreaService;
import com.casic.missiles.modular.system.service.IDeviceModelsService;
import com.casic.missiles.modular.system.service.IDeviceService;
import com.casic.missiles.modular.system.service.IDeviceTypeService;
@@ -77,6 +78,9 @@
@Autowired
private IDeviceModelsService deviceModelsService;
+ @Autowired
+ private IAreaService iAreaService;
+
@ApiOperation("获取设备列表")
@RequestMapping(value = "/list")
@ResponseBody
@@ -98,9 +102,8 @@
@RequestMapping(value = "/listByConfig")
@ResponseBody
public ResponseData listByConfig(String deviceType, String configStatus) {
-
DataScope dataScope = permissionService.getCurrUserDataScope();
- List list = deviceService.selectDevicesByConfig(dataScope, deviceType, configStatus);
+ List list = deviceService.selectDevicesByConfig(dataScope, deviceType, configStatus);
if (ToolUtil.isNotEmpty(list)) {
list.forEach(deviceCodeSelectDto -> {
deviceCodeSelectDto.setDeptName(permissionService.getDeptName(deviceCodeSelectDto.getDeptId()));
@@ -109,7 +112,6 @@
return new SuccessResponseData(list);
}
-
@ApiOperation("获取设备类型列表")
@GetMapping(value = "/type")
@ResponseBody
@@ -131,8 +133,9 @@
public Object model(String deviceType) {
//设备类型列表查询
EntityWrapper query = new EntityWrapper<>();
- if (ToolUtil.isNotEmpty(deviceType))
+ if (ToolUtil.isNotEmpty(deviceType)) {
query.eq(DEVICE_QUERY_DEVICE_TYPE, deviceType);
+ }
List list = deviceModelsService.selectList(query);
List selectDtos = new ArrayList<>();
@@ -293,5 +296,41 @@
return ResponseData.success();
}
+ @ApiOperation("设备历史数据")
+ @RequestMapping(value = "/sevenDayData")
+ @ResponseBody
+ public Object sevenDayData(String devCode, String beginTime, String endTime) {
+ if (ToolUtil.isEmpty(devCode)) {
+ throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+ }
+ return new SuccessResponseData(deviceService.selectDeviceData(devCode, beginTime, endTime));
+ }
+ @ApiOperation("设备总用水数据")
+ @RequestMapping(value = "/totalData")
+ @ResponseBody
+ public Object totalData(String devCode, String beginTime, String endTime) {
+ if (ToolUtil.isEmpty(devCode)) {
+ throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+ }
+ return new SuccessResponseData(deviceService.selectDeviceTotalData(devCode, beginTime, endTime));
+ }
+
+ // @ApiOperation("统计设备在一定时间段内报警数")
+// @RequestMapping(value = "/alarmCountByDay")
+// @ResponseBody
+// public Object alarmCountByDay(String beginTime, String endTime) {
+// if (ToolUtil.isEmpty(beginTime) || ToolUtil.isEmpty(endTime)) {
+// throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+// }
+// return new SuccessResponseData(deviceService.selectAlarmCountByDay(beginTime, endTime));
+// }
+
+
+ @RequestMapping(value = "/getAreas")
+ @ResponseBody
+ public Object getAreas() {
+ //设备类型列表查询
+ return ResponseData.success(iAreaService.selectList(null));
+ }
}
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterMeterDataController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterMeterDataController.java
index 6773e07..17556c7 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterMeterDataController.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterMeterDataController.java
@@ -6,15 +6,10 @@
import com.casic.missiles.core.common.constant.factory.PageFactory;
import com.casic.missiles.core.common.service.ICommonPermissionService;
import com.casic.missiles.core.datascope.DataScope;
-import com.casic.missiles.modular.system.constant.ModularDictConst;
import com.casic.missiles.modular.system.dto.DeviceDto;
-import com.casic.missiles.modular.system.dto.DeviceTypeEnum;
import com.casic.missiles.modular.system.service.IDeviceService;
-import com.sun.javafx.binding.StringFormatter;
import io.swagger.annotations.ApiOperation;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@@ -25,25 +20,31 @@
import java.util.List;
import java.util.Map;
+/**
+ * @author a203
+ */
@Controller
@RequestMapping("/waterMeterData")
public class WaterMeterDataController extends ExportController {
- private static final Logger logger = LoggerFactory.getLogger(DeviceController.class);
- @Autowired
- private ICommonPermissionService permissionService;
- @Autowired
- private IDeviceService deviceService;
+ private final ICommonPermissionService permissionService;
+ private final IDeviceService deviceService;
+
+ public WaterMeterDataController(ICommonPermissionService permissionService,
+ IDeviceService deviceService) {
+ this.permissionService = permissionService;
+ this.deviceService = deviceService;
+ }
@ApiOperation("获取水表设备列表")
@RequestMapping(value = "/listPage")
@ResponseBody
- public Object listPage(String keywords, String deptid, String areaId) {
+ public Object listPage(String keywords, String areaId) {
Page page = new PageFactory().defaultPage();
//查询数据权限 使用默认DEPTID 字段
DataScope dataScope = permissionService.getCurrUserDataScope();
- areaId += "%";
- List list = deviceService.selectDataScopePage(dataScope, page, "13", deptid, "", "", keywords, "", areaId);
+// areaId += "%";
+ List list = deviceService.selectDataScopePage(dataScope, page, "13", "", "", "", keywords, "", areaId);
DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
DateFormat sdf4 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -52,21 +53,45 @@
list.forEach(deviceDto -> {
// 获取日月年用水量和最近的读数
Map dayMeter = deviceService.selectWaterMeterDay(deviceDto.getDevcode(), date);
- deviceDto.setDayCount(dayMeter.get("FLOW_ACC_DATE").toString());
+ if (dayMeter == null) {
+ deviceDto.setDayCount("0");
+ } else {
+ deviceDto.setDayCount(dayMeter.get("FLOW_ACC_DATE").toString());
+ }
Map monthMeter = deviceService.selectWaterMeterMonth(deviceDto.getDevcode(), date.substring(0, 7));
- deviceDto.setMonthCount(monthMeter.get("FLOW_ACC_MONTH").toString());
+ if (monthMeter == null) {
+ deviceDto.setMonthCount("0");
+ } else {
+ deviceDto.setMonthCount(monthMeter.get("FLOW_ACC_MONTH").toString());
+ }
Map totalMeter = deviceService.selectWaterMeterTotal(deviceDto.getDevcode(), date.substring(0, 4));
- deviceDto.setTotalCount(totalMeter.get("FLOW_ACC_TOTAL").toString());
+ if (totalMeter == null) {
+ deviceDto.setTotalCount("0");
+ } else {
+ deviceDto.setTotalCount(totalMeter.get("FLOW_ACC_TOTAL").toString());
+ }
Map meterRec = deviceService.selectLatestWaterMeter(deviceDto.getDevcode());
- deviceDto.setWatchNum(meterRec.get("FLOW_ACC").toString());
- deviceDto.setUptime(sdf4.format((Date) meterRec.get("UPTIME")));
+ if (meterRec == null) {
+ deviceDto.setWatchNum("0");
+ deviceDto.setUptime(sdf4.format(new Date()));
+ } else {
+ deviceDto.setWatchNum(meterRec.get("FLOW_ACC").toString());
+ deviceDto.setUptime(sdf4.format((Date) meterRec.get("UPTIME")));
+ }
deviceDto.setAreaFullName(deviceService.getAreaFullNameById(deviceDto.getArea()));
});
page.setRecords(list);
return new SuccessResponseData(super.packForBT(page));
}
+
+ @ApiOperation("统计水表数量")
+ @RequestMapping(value = "/count")
+ @ResponseBody
+ public Object waterMeterCount() {
+ return new SuccessResponseData(deviceService.getWaterMeterCount());
+ }
}
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterStatisticController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterStatisticController.java
new file mode 100644
index 0000000..eaa2073
--- /dev/null
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/WaterStatisticController.java
@@ -0,0 +1,40 @@
+package com.casic.missiles.modular.system.controller;
+
+import com.casic.missiles.core.base.controller.BaseController;
+import com.casic.missiles.core.base.response.SuccessResponseData;
+import com.casic.missiles.modular.system.service.IDeviceService;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+/**
+ * @author a203
+ */
+@Controller
+@RequestMapping("/waterStatistic")
+public class WaterStatisticController extends BaseController {
+
+ private final IDeviceService deviceService;
+
+ public WaterStatisticController(IDeviceService deviceService) {
+ this.deviceService = deviceService;
+ }
+
+ @ApiOperation("总览查询用水量")
+ @RequestMapping(value = "/overview")
+ @ResponseBody
+ public Object overview() {
+ return new SuccessResponseData(deviceService.getOverview());
+ }
+
+// @ApiOperation("一级分区各区用水量")
+// @RequestMapping(value = "/countByFirstArea")
+// @ResponseBody
+// public Object countByFirstArea(String devType, String startTime, String endTime) {
+// if (ToolUtil.isEmpty(startTime) || ToolUtil.isEmpty(endTime)) {
+// throw new GunsException(GunsExceptionEnum.REQUEST_NULL);
+// }
+// return new SuccessResponseData(deviceService.countByFirstArea(devType, startTime, endTime));
+// }
+}
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceMapper.java
index e0818ff..a376ba8 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceMapper.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceMapper.java
@@ -20,11 +20,12 @@
*/
public interface DeviceMapper extends BaseMapper {
- List selectDataScopePage(@Param("scope") DataScope dataScope, @Param("page") Page page, @Param("deviceType") String deviceType, @Param("deptid") String deptid, @Param("beginTime") String beginTime, @Param("endTime") String endTime, @Param("keywords") String keywords,@Param("isOnline") String isOnline, @Param("areaId") String areaId);
+ List selectDataScopePage(@Param("scope") DataScope dataScope, @Param("page") Page page, @Param("deviceType") String deviceType, @Param("deptid") String deptid, @Param("beginTime") String beginTime, @Param("endTime") String endTime, @Param("keywords") String keywords, @Param("isOnline") String isOnline, @Param("areaId") String areaId);
DeviceWellDto selectWellIdByCode(@Param("wellCode") String wellCode);
String getArea(@Param("id") String id);
+
String getAreaPId(@Param("id") String id);
DeviceConcentratorDto selectDeviceConcentorByCode(@Param("concenCode") String concenCode);
@@ -33,40 +34,80 @@
List selectLiquidDataScopePage(@Param("dataScope") DataScope dataScope, @Param("page") Page page, @Param("deptid") String deptid, @Param("beginTime") String beginTime, @Param("endTime") String endTime, @Param("keywords") String keywords);
- List