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 8d4750e..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
@@ -312,7 +316,7 @@
return new SuccessResponseData(deviceService.selectDeviceTotalData(devCode, beginTime, endTime));
}
-// @ApiOperation("统计设备在一定时间段内报警数")
+ // @ApiOperation("统计设备在一定时间段内报警数")
// @RequestMapping(value = "/alarmCountByDay")
// @ResponseBody
// public Object alarmCountByDay(String beginTime, String endTime) {
@@ -321,4 +325,12 @@
// }
// 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 8d4750e..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
@@ -312,7 +316,7 @@
return new SuccessResponseData(deviceService.selectDeviceTotalData(devCode, beginTime, endTime));
}
-// @ApiOperation("统计设备在一定时间段内报警数")
+ // @ApiOperation("统计设备在一定时间段内报警数")
// @RequestMapping(value = "/alarmCountByDay")
// @ResponseBody
// public Object alarmCountByDay(String beginTime, String endTime) {
@@ -321,4 +325,12 @@
// }
// 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 107a876..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
@@ -9,6 +9,7 @@
import com.casic.missiles.modular.system.dto.DeviceDto;
import com.casic.missiles.modular.system.service.IDeviceService;
import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@@ -42,7 +43,7 @@
Page page = new PageFactory().defaultPage();
//查询数据权限 使用默认DEPTID 字段
DataScope dataScope = permissionService.getCurrUserDataScope();
- areaId += "%";
+// areaId += "%";
List list = deviceService.selectDataScopePage(dataScope, page, "13", "", "", "", keywords, "", areaId);
DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
@@ -52,17 +53,34 @@
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()));
});
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 8d4750e..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
@@ -312,7 +316,7 @@
return new SuccessResponseData(deviceService.selectDeviceTotalData(devCode, beginTime, endTime));
}
-// @ApiOperation("统计设备在一定时间段内报警数")
+ // @ApiOperation("统计设备在一定时间段内报警数")
// @RequestMapping(value = "/alarmCountByDay")
// @ResponseBody
// public Object alarmCountByDay(String beginTime, String endTime) {
@@ -321,4 +325,12 @@
// }
// 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 107a876..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
@@ -9,6 +9,7 @@
import com.casic.missiles.modular.system.dto.DeviceDto;
import com.casic.missiles.modular.system.service.IDeviceService;
import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@@ -42,7 +43,7 @@
Page page = new PageFactory().defaultPage();
//查询数据权限 使用默认DEPTID 字段
DataScope dataScope = permissionService.getCurrUserDataScope();
- areaId += "%";
+// areaId += "%";
List list = deviceService.selectDataScopePage(dataScope, page, "13", "", "", "", keywords, "", areaId);
DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
@@ -52,17 +53,34 @@
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()));
});
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 6528cc1..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
@@ -108,4 +108,6 @@
String getNoiseData();
// List