|
@@ -46,6 +46,9 @@ import vip.xiaonuo.coldchain.modular.monitordevice.service.MonitorDeviceService;
|
|
import vip.xiaonuo.coldchain.modular.monitordevicetype.entity.CountEntity;
|
|
import vip.xiaonuo.coldchain.modular.monitordevicetype.entity.CountEntity;
|
|
import vip.xiaonuo.coldchain.modular.monitordevicetype.entity.MonitorDeviceType;
|
|
import vip.xiaonuo.coldchain.modular.monitordevicetype.entity.MonitorDeviceType;
|
|
import vip.xiaonuo.coldchain.modular.monitordevicetype.service.MonitorDeviceTypeService;
|
|
import vip.xiaonuo.coldchain.modular.monitordevicetype.service.MonitorDeviceTypeService;
|
|
|
|
+import vip.xiaonuo.coldchain.modular.monitortarget.entity.MonitorTarget;
|
|
|
|
+import vip.xiaonuo.coldchain.modular.monitortarget.param.TargetStatus;
|
|
|
|
+import vip.xiaonuo.coldchain.modular.monitortarget.service.MonitorTargetService;
|
|
import vip.xiaonuo.coldchain.modular.monitortargetregion.service.MonitorTargetRegionService;
|
|
import vip.xiaonuo.coldchain.modular.monitortargetregion.service.MonitorTargetRegionService;
|
|
import vip.xiaonuo.common.enums.CommonDeleteFlagEnum;
|
|
import vip.xiaonuo.common.enums.CommonDeleteFlagEnum;
|
|
import vip.xiaonuo.common.enums.CommonSortOrderEnum;
|
|
import vip.xiaonuo.common.enums.CommonSortOrderEnum;
|
|
@@ -74,6 +77,8 @@ public class MonitorDeviceServiceImpl extends ServiceImpl<MonitorDeviceMapper, M
|
|
private MonitorDeviceTypeService monitorDeviceTypeService;
|
|
private MonitorDeviceTypeService monitorDeviceTypeService;
|
|
@Resource
|
|
@Resource
|
|
private MonitorTargetRegionService monitorTargetRegionService;
|
|
private MonitorTargetRegionService monitorTargetRegionService;
|
|
|
|
+ @Resource
|
|
|
|
+ private MonitorTargetService monitorTargetService;
|
|
|
|
|
|
private String bucketName;
|
|
private String bucketName;
|
|
|
|
|
|
@@ -323,15 +328,20 @@ public class MonitorDeviceServiceImpl extends ServiceImpl<MonitorDeviceMapper, M
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public CountEntity getIndexCount() {
|
|
public CountEntity getIndexCount() {
|
|
|
|
+ TargetStatus targetCount = monitorTargetService.getTargetCount(null);
|
|
CountEntity countEntity = new CountEntity();
|
|
CountEntity countEntity = new CountEntity();
|
|
- countEntity.setDeviceCount((int) count());
|
|
|
|
- LambdaQueryWrapper<MonitorDevice> onlineDeviceQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
|
- onlineDeviceQueryWrapper.eq(MonitorDevice::getStatus, MonitorDeviceStatusEnum.NORMAL.getValue()).eq(MonitorDevice::getDeleteFlag, CommonDeleteFlagEnum.NOT_DELETE);
|
|
|
|
- LambdaQueryWrapper<MonitorDevice> offlineDeviceIdQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
|
- offlineDeviceIdQueryWrapper.eq(MonitorDevice::getStatus, MonitorDeviceStatusEnum.UNUSED.getValue()).eq(MonitorDevice::getDeleteFlag, CommonDeleteFlagEnum.NOT_DELETE);
|
|
|
|
- countEntity.setOnlineDeviceCount((int) count(onlineDeviceQueryWrapper));
|
|
|
|
|
|
+ countEntity.setDeviceCount((int) targetCount.getTotal());
|
|
|
|
+// LambdaQueryWrapper<MonitorDevice> onlineDeviceQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
|
+// onlineDeviceQueryWrapper.eq(MonitorDevice::getStatus, MonitorDeviceStatusEnum.NORMAL.getValue()).eq(MonitorDevice::getDeleteFlag, CommonDeleteFlagEnum.NOT_DELETE);
|
|
|
|
+// LambdaQueryWrapper<MonitorDevice> offlineDeviceIdQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
|
+// offlineDeviceIdQueryWrapper.eq(MonitorDevice::getStatus, MonitorDeviceStatusEnum.UNUSED.getValue()).eq(MonitorDevice::getDeleteFlag, CommonDeleteFlagEnum.NOT_DELETE);
|
|
|
|
+ countEntity.setOnlineDeviceCount((int) targetCount.getOnline());
|
|
|
|
+ countEntity.setOfflineDeviceCount((int) targetCount.getOffline());
|
|
Integer sensorCount = 0;
|
|
Integer sensorCount = 0;
|
|
- List<MonitorDevice> monitorDeviceList = list();
|
|
|
|
|
|
+ SaBaseLoginUser loginUser = StpLoginUserUtil.getLoginUser();
|
|
|
|
+ LambdaQueryWrapper<MonitorDevice> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
|
+ queryWrapper.eq(MonitorDevice::getDeleteFlag, CommonDeleteFlagEnum.NOT_DELETE).eq(MonitorDevice::getCreateOrg,loginUser.getOrgId());
|
|
|
|
+ List<MonitorDevice> monitorDeviceList = list(queryWrapper);
|
|
for (MonitorDevice monitorDevice : monitorDeviceList) {
|
|
for (MonitorDevice monitorDevice : monitorDeviceList) {
|
|
sensorCount += monitorDevice.getSensorCount();
|
|
sensorCount += monitorDevice.getSensorCount();
|
|
}
|
|
}
|