package com.sandu.ximon.admin.service;
|
|
|
import cn.hutool.core.collection.CollUtil;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.github.pagehelper.PageHelper;
|
import com.sandu.common.domain.CommonPage;
|
import com.sandu.common.execption.BusinessException;
|
import com.sandu.common.object.BaseConditionVO;
|
import com.sandu.common.service.impl.BaseServiceImpl;
|
import com.sandu.common.util.ResUtils;
|
import com.sandu.common.util.SpringContextHolder;
|
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5AtmosphereHeartbeatReportInnerFrame;
|
import com.sandu.ximon.admin.manager.iot.rrpc.enums.AtmoFunctionCode;
|
import com.sandu.ximon.admin.security.SecurityUtils;
|
import com.sandu.ximon.admin.utils.RedisUtils;
|
import com.sandu.ximon.admin.utils.StringUtil;
|
import com.sandu.ximon.dao.bo.AirDataBo;
|
import com.sandu.ximon.dao.domain.AirData;
|
import com.sandu.ximon.dao.domain.AirEquipment;
|
import com.sandu.ximon.dao.domain.PoleBinding;
|
import com.sandu.ximon.dao.mapper.AirDataMapper;
|
import lombok.AllArgsConstructor;
|
import org.apache.commons.lang.StringUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
@Service
|
@AllArgsConstructor
|
public class AirDataService extends BaseServiceImpl<AirDataMapper, AirData> {
|
private final AirDataMapper airDataMapper;
|
private final AirEquipmentService airEquipmentService;
|
|
/**
|
* 保存上报大气心跳数据
|
*
|
* @return 是否成功
|
*/
|
public boolean saveReportData(String deviceName, A5AtmosphereHeartbeatReportInnerFrame.HeartBeatDataPackage heartBeatDataPackage) {
|
if (heartBeatDataPackage == null) {
|
System.out.println("保存大气设备心跳包数据异常，心跳包为空！");
|
return false;
|
}
|
|
AirData airData = new AirData();
|
BeanUtils.copyProperties(heartBeatDataPackage, airData);
|
airData.setDeviceMac(deviceName);
|
|
//将设备信息添加到大气设备表
|
AirEquipment airEquipment = new AirEquipment();
|
airEquipment.setId(airData.getId());
|
airEquipment.setMac(airData.getDeviceMac());
|
airEquipment.setDeviceType(heartBeatDataPackage.getDeviceType());
|
airEquipment.setModuleWarmUpStatusFlag(heartBeatDataPackage.getModuleWarmUpStatusFlag());
|
//温度传感器
|
airEquipment.setTemperature(heartBeatDataPackage.getTemperature() != null ? 1 : 0);
|
//湿度传感器
|
airEquipment.setHumidity(heartBeatDataPackage.getHumidity() != null ? 1 : 0);
|
//风速传感器
|
airEquipment.setWindSpeed(heartBeatDataPackage.getWindSpeed() != null ? 1 : 0);
|
//风向传感器
|
if (heartBeatDataPackage.getWindDirection() == null) {
|
airEquipment.setWindDirection(0);
|
} else if (heartBeatDataPackage.getWindDirection().contains("度")) {
|
//360度传感器
|
airEquipment.setWindDirection(2);
|
} else {
|
//八向仪传感器
|
airEquipment.setWindDirection(1);
|
}
|
//风力传感器
|
airEquipment.setWindPower(heartBeatDataPackage.getWindPower() != null ? 1 : 0);
|
//气压传感器
|
airEquipment.setPressure(heartBeatDataPackage.getPressure() != null ? 1 : 0);
|
//光强传感器
|
airEquipment.setLightIntensity(heartBeatDataPackage.getLightIntensity() != null ? 1 : 0);
|
//噪音传感器
|
airEquipment.setNoise(heartBeatDataPackage.getNoise() != null ? 1 : 0);
|
//PM25传感器
|
airEquipment.setPm25(heartBeatDataPackage.getPm25() != null ? 1 : 0);
|
//PM10传感器
|
airEquipment.setPm10(heartBeatDataPackage.getPm10() != null ? 1 : 0);
|
//TSP传感器
|
airEquipment.setTsp(heartBeatDataPackage.getTsp() != null ? 1 : 0);
|
//雨量传感器
|
airEquipment.setRain(heartBeatDataPackage.getRain() != null ? 1 : 0);
|
//SO2传感器
|
airEquipment.setSo2(heartBeatDataPackage.getSo2() != null ? 1 : 0);
|
//甲醛传感器
|
airEquipment.setEch2o(heartBeatDataPackage.getEch2o() != null ? 1 : 0);
|
//NO2传感器
|
airEquipment.setNo2(heartBeatDataPackage.getNo2() != null ? 1 : 0);
|
//TVOC传感器
|
airEquipment.setTvoc(heartBeatDataPackage.getTvoc() != null ? 1 : 0);
|
//CO传感器
|
airEquipment.setCo(heartBeatDataPackage.getCo() != null ? 1 : 0);
|
//CO2传感器
|
airEquipment.setCo2(heartBeatDataPackage.getCo2() != null ? 1 : 0);
|
//03传感器
|
airEquipment.setO3(heartBeatDataPackage.getO3() != null ? 1 : 0);
|
//氟化物传感器
|
airEquipment.setFluoride(heartBeatDataPackage.getFluoride() != null ? 1 : 0);
|
|
airEquipmentService.addAirEquipment(airEquipment);
|
|
//存缓存心跳包
|
RedisUtils.getBean().set(AtmoFunctionCode.AIR_HEARTBEAT.getCode() + deviceName, heartBeatDataPackage);
|
//存缓存状态
|
RedisUtils.getBean().set(AtmoFunctionCode.AIR_HEARTBEAT_STATE.getCode() + deviceName, heartBeatDataPackage, 300L);
|
|
return save(airData);
|
}
|
|
/**
|
* 查询大气数据(模糊查询)
|
*/
|
public CommonPage listAirDataByKeyword(BaseConditionVO baseConditionVO, String keyword) {
|
PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
|
List<Long> listAirId;
|
if (SecurityUtils.getClientId() == null) {
|
listAirId = baseMapper.listAirId(keyword, null);
|
} else {
|
listAirId = baseMapper.listAirId(keyword, SecurityUtils.getUserId());
|
}
|
CommonPage commonPage = CommonPage.restPage(listAirId);
|
if (CollUtil.isEmpty(listAirId)) {
|
return commonPage;
|
}
|
List<AirDataBo> airDataBos = baseMapper.listAirDataByIds(listAirId);
|
commonPage.setList(airDataBos);
|
return commonPage;
|
|
}
|
|
/**
|
* 查询大气设备历史数据
|
*/
|
public List<AirDataBo> listAirDataOfDeviceCode(BaseConditionVO baseConditionVO, String deviceMac) {
|
if (StringUtils.isEmpty(deviceMac)) {
|
throw new BusinessException("设备号不能为空！");
|
}
|
PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
|
List<AirDataBo> list = baseMapper.listAirDataHistory(deviceMac);
|
|
return list;
|
|
}
|
|
|
/**
|
* +
|
* 根据灯杆id查询大气数据
|
*/
|
public A5AtmosphereHeartbeatReportInnerFrame.HeartBeatDataPackage getDataByPoleid(Long poleId) {
|
String code;
|
if (SecurityUtils.getClientId() != null) {
|
code = baseMapper.getCodeByPoleId(poleId, SecurityUtils.getUserId());
|
} else {
|
code = baseMapper.getCodeByPoleId(poleId, null);
|
}
|
A5AtmosphereHeartbeatReportInnerFrame.HeartBeatDataPackage heartBeatDataPackage
|
= RedisUtils.getBean().get(AtmoFunctionCode.AIR_HEARTBEAT.getCode() + code, A5AtmosphereHeartbeatReportInnerFrame.HeartBeatDataPackage.class);
|
if (heartBeatDataPackage == null) {
|
return null;
|
}
|
|
return heartBeatDataPackage;
|
}
|
|
}
|
