| | |
| | | import com.moral.common.bean.Constants;
|
| | | import com.moral.common.bean.PageBean;
|
| | | import com.moral.common.bean.PageResult;
|
| | | import com.moral.common.exception.BusinessException;
|
| | | import com.moral.common.util.ExampleUtil;
|
| | | import com.moral.common.util.RedisUtils;
|
| | | import com.moral.mapper.MonitorPointMapper;
|
| | | import org.apache.commons.collections.MapUtils;
|
| | | import org.apache.commons.lang3.BooleanUtils;
|
| | | import org.apache.commons.lang3.StringUtils;
|
| | | import org.apache.log4j.Logger;
|
| | | import org.springframework.stereotype.Service;
|
| | | import org.springframework.transaction.annotation.Transactional;
|
| | | import org.springframework.util.ObjectUtils;
|
| | |
| | |
|
| | | @Service
|
| | | public class DeviceServiceImpl implements DeviceService {
|
| | |
|
| | | Logger log = Logger.getLogger(DeviceServiceImpl.class);
|
| | | //-----------------------redis key前缀-开始---------------------------------
|
| | | private static String AlARM = "alarm";//警报阀值储存key前缀
|
| | | private static String ADJUST="adjust";//校准值存储key前缀
|
| | | private static String DEVICE = "device";//设备信息数据key前缀
|
| | | private static String STATE = "state";//设备实时状态key前缀
|
| | | private static String DATA = "data";//设备实时数据key前缀
|
| | | //-----------------------redis key前缀-结束---------------------------------
|
| | | private String keysConnect(String... keys) {
|
| | | StringBuilder key = new StringBuilder(keys[0]);
|
| | | for(int i=1;i<keys.length;i++) {
|
| | | key.append("_");
|
| | | key.append(keys[i]);
|
| | | }
|
| | | return key.toString().toLowerCase();
|
| | | }
|
| | | @Resource
|
| | | private DeviceMapper deviceMapper;
|
| | | @Resource
|
| | |
| | |
|
| | | @Override
|
| | | public Device getDeviceByMac(String mac) {
|
| | | ValidateUtil.notEmpty(mac, "param.is.null");
|
| | | Device device = new Device();
|
| | | device.setMac(mac);
|
| | | device = deviceMapper.selectOne(device);
|
| | | Device device = getDeviceFromRedis(mac);
|
| | | if(device==null) {
|
| | | device = deviceMapper.selectWithOrgIdsByMac(mac);
|
| | | if(device!=null){
|
| | | setDeviceToRedis(mac,device);
|
| | | }
|
| | | }
|
| | | return device;
|
| | | }
|
| | | /*
|
| | | * 获取报警阀值在redis里的key
|
| | | */
|
| | | private String getDeviceKey(String mac) {
|
| | | return keysConnect(DEVICE,mac);
|
| | | }
|
| | | /*
|
| | | * 将校正值存入redis方法组 开始
|
| | | */
|
| | | private void setDeviceToRedis(String mac,Device device){
|
| | | String key = getDeviceKey(mac);
|
| | | Device simpleDevice = new Device();
|
| | | simpleDevice.setId(device.getId());// id
|
| | | simpleDevice.setName(device.getName());// name
|
| | | simpleDevice.setAddress(device.getAddress());// address
|
| | | simpleDevice.setDeviceVersionId(device.getDeviceVersionId());// version
|
| | | simpleDevice.setMac(device.getMac()); // mac
|
| | | simpleDevice.setMonitorPointId(device.getMonitorPointId());// 监控地id
|
| | | simpleDevice.setOrganizationIds(device.getOrganizationIds());// 组织数组
|
| | | redisUtils.set(key,simpleDevice);
|
| | | }
|
| | | private Device getDeviceFromRedis(String mac) {
|
| | | String key = getDeviceKey(mac);
|
| | | return redisUtils.get(key,Device.class);
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | }
|
| | | }
|
| | | @Override
|
| | | public PageBean queryByPageBean(PageBean pageBean) {
|
| | | public int countByExample(PageBean pageBean){
|
| | | Example example = ExampleUtil.generateExample(ENTITY_CLASS,pageBean);
|
| | | addDeletesToExample(example);
|
| | | return deviceMapper.selectCountByExample(example);
|
| | | }
|
| | |
|
| | | /**
|
| | | * 增加删除条件过滤
|
| | | * @param example
|
| | | */
|
| | | private void addDeletesToExample(Example example){
|
| | | List<Example.Criteria> criteriaList = example.getOredCriteria();
|
| | | if(criteriaList!=null&&criteriaList.size()>0){
|
| | | for(Example.Criteria cri : criteriaList){
|
| | |
| | | }else {
|
| | | example.or().andNotEqualTo("isDelete",Constants.IS_DELETE_TRUE);
|
| | | }
|
| | | }
|
| | | @Override
|
| | | public PageBean queryByPageBean(PageBean pageBean) {
|
| | | Example example = ExampleUtil.generateExample(ENTITY_CLASS,pageBean);
|
| | | addDeletesToExample(example);
|
| | | if(pageBean.getPageSize()>0){
|
| | | PageHelper.startPage(pageBean.getPageIndex(),pageBean.getPageSize());
|
| | | }
|
| | |
| | | throw ex;
|
| | | }
|
| | | }
|
| | |
|
| | | @Override
|
| | | public List<Map> countByTimes(Date start,Date end,String format){
|
| | | if(start==null||end==null||StringUtils.isBlank(format)){
|
| | | log.error("some params is null");
|
| | | throw new BusinessException("some params is null");
|
| | | }
|
| | | return deviceMapper.countByTimes(start, end, format);
|
| | | }
|
| | | @Override
|
| | | public List<Device> getDevicesByMonitorPointId(Integer monitorPointId) {
|
| | | Device device = new Device();
|