设备 相关更新

xufenglei

2019-02-13 1bd6a5e7678477f5b1fab449c6d618aae9041611

 src/main/java/com/moral/service/impl/DeviceServiceImpl.java

@@ -1,21 +1,16 @@
package com.moral.service.impl;



import java.util.*;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.stream.Collectors;



import javax.annotation.Resource;

import javax.validation.constraints.NotNull;



import com.alibaba.fastjson.TypeReference;

import com.github.pagehelper.Page;

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.entity.DeviceVersion;

import com.moral.mapper.*;

import org.apache.commons.collections.MapUtils;

import org.apache.commons.lang3.BooleanUtils;

import org.apache.commons.lang3.StringUtils;

@@ -24,11 +19,27 @@
import org.springframework.transaction.annotation.Transactional;

import org.springframework.util.ObjectUtils;



import com.alibaba.fastjson.TypeReference;

import com.github.pagehelper.Page;

import com.github.pagehelper.PageHelper;

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.common.util.ValidateUtil;

import com.moral.entity.Device;

import com.moral.entity.DeviceProperty;

import com.moral.mapper.DeviceMapper;

import com.moral.mapper.DevicePropertyMapper;

import com.moral.mapper.DeviceVersionMapper;

import com.moral.mapper.DictionaryDataMapper;

import com.moral.mapper.MonitorPointMapper;

import com.moral.mapper.OrganizationMapper;

import com.moral.service.AccountService;

import com.moral.service.DeviceService;



import tk.mybatis.mapper.entity.Example;



@Service

@@ -508,4 +519,35 @@
      result.put("stop", stop);

      return result;

   }



   @Resource

   private DevicePropertyMapper devicePropertyMapper;

	
   @Override

   @Transactional

   public void saveOrUpdate(Device device, DeviceProperty deviceProperty) {

      if (ObjectUtils.isEmpty(device.getId())) {

         device.setState(Constants.DEVICE_STATE_OFFLINE);

         device.setIsDelete(Constants.IS_DELETE_FALSE);

         deviceMapper.insertSelective(device);

         deviceProperty.setId(device.getId());

      } else {

         deviceMapper.updateByPrimaryKeySelective(device);

         devicePropertyMapper.deleteByPrimaryKey(deviceProperty);

      }

      devicePropertyMapper.insertSelective(deviceProperty);

      refreshDeviceInRedis(device.getMac());



   }

	
   @Override

   public PageBean getDeviceList(PageBean pageBean) {

      Example example = ExampleUtil.generateExample(ENTITY_CLASS,pageBean);

      if(pageBean.getPageSize()>0){

         PageHelper.startPage(pageBean.getPageIndex(),pageBean.getPageSize());

      }

      List<Device> deviceList = deviceMapper.getDeviceList(example);

      return new PageBean(deviceList);

   }



}