大屏后台管理代码update

ZhuDongming

2019-10-09 578e49d67183d8d12a6af7e8244a9d152cb366d4

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

@@ -20,6 +20,8 @@
import com.moral.mapper.OrganizationMapper;

import com.moral.service.AccountService;

import com.moral.service.DeviceService;

import com.moral.util.TkMybatisUtils;



import org.apache.commons.collections.MapUtils;

import org.apache.commons.lang3.BooleanUtils;

import org.apache.commons.lang3.StringUtils;

@@ -27,10 +29,12 @@
import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.util.ObjectUtils;



import tk.mybatis.mapper.entity.Example;



import javax.annotation.Resource;

import javax.validation.constraints.NotNull;



import java.util.ArrayList;

import java.util.Arrays;

import java.util.Date;

@@ -48,6 +52,7 @@
   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]);

@@ -57,6 +62,7 @@
      }

      return key.toString().toLowerCase();

   }



   @Resource

   private DeviceMapper deviceMapper;

    @Resource

@@ -74,6 +80,7 @@
   OrganizationMapper organizationMapper;

   @Resource

   DictionaryDataMapper dictionaryDataMapper;



   @Override

   public Map<String, Object> getDeviceStatesByAccount(Map<String, Object> parameters) {

      ValidateUtil.notNull(parameters.get("accountId"), "param.is.null");

@@ -136,7 +143,6 @@
   }



   /**

    *

    * @param mac

    * @param fromCache

    * @return 包含组织数组

@@ -157,6 +163,7 @@


    /**

     * 默认会从缓存取

     *

     * @param mac

     * @return

     */

@@ -165,12 +172,14 @@


      return getDeviceByMac(mac,true);

   }



   /*

    * 获取报警阀值在redis里的key

    */

   private String getDeviceKey(String mac) {

      return keysConnect(DEVICE,mac);

   }



//   /*

//    * 将校正值存入redis方法组 开始

//    */

@@ -193,9 +202,7 @@
   }



   /**

    *

    * @param params

    * map里 包括 组织id和4个坐标点

     * @param params map里 包括 组织id和4个坐标点

    * @return 返回未删除结果集

    */

   @Override

@@ -211,8 +218,10 @@
      }

      return deviceList;

   }



   /**

    *  根据组织id和设备名称 分页查询设备

     *

    * @param orgId

    * @param deviceName

    * @param pageSize

@@ -229,19 +238,24 @@
      switch (deviceName){

         case "正常":

            state = "0";

            deviceName = null;break;

                deviceName = null;

                break;

            case "轻度":

            state = "1";

            deviceName = null;break;

                deviceName = null;

                break;

         case "中度":

            state = "2";

            deviceName = null;break;

                deviceName = null;

                break;

         case "重度":

            state = "3";

            deviceName = null;break;

                deviceName = null;

                break;

         case "维保":

            state = "4";

            deviceName = null;break;

                deviceName = null;

                break;

      }

      List<Device> list = deviceMapper.selectByOrgIdAndDevName(orgId,orgIds,state,deviceName);

      //从redis里取状态

@@ -254,6 +268,7 @@


   /**

    * 根据组织id和监控点id 分页查询设备

     *

    * @param orgId

    * @param mpId

    * @param pageSize

@@ -274,6 +289,7 @@
      }

      return new PageResult(null,list);

   }



   private void loadDeviceState(List<Device> list){

      //从redis里取状态

      list.stream().map( device -> {

@@ -287,6 +303,7 @@
         return device;

      }).count();

   }



   private String getSateFromRedis(Integer mpId,String mac){



      Map<String,String> stateMap  = getStateMapFromRedis(mpId,mac);

@@ -297,12 +314,15 @@
      state = state == null ?Constants.DEVICE_STATE_OFFLINE:state;

      return  state;

   }



   public Map<String,String> getStateMapFromRedis(Integer mpId,String mac){

      StringBuilder key = new StringBuilder();

      //拼凑key

      key.append("state_").append(mpId).append("_").append(mac);

      return   redisUtils.get(key.toString(),new TypeReference<Map<String,String>>(){});

        return redisUtils.get(key.toString(), new TypeReference<Map<String, String>>() {

        });

   }



   private Device getDeviceWithOrgIdsByMac(String mac) {

      String key = "device_"+mac;

      Device device = redisUtils.get(key,Device.class);

@@ -318,38 +338,25 @@
   /**

    * 要在数据库更改后刷新

    * 刷新 redis 设备的信息,注意此处指删除不做更新。更新由task完成

     *

    * @param mac

    */

   private void refreshDeviceInRedis(String mac){

        if(!StringUtils.isBlank(mac)){

            String key = getDeviceKey(mac);

            redisUtils.remove(key);

         }else

       {

        } else {

          log.warn("param mac is null in method [refreshDeviceInRedis]");

       }

   }



   @Override

   public int countByExample(PageBean pageBean){

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

      addDeletesToExample(example);

        TkMybatisUtils.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){

            cri.andNotEqualTo("isDelete", Constants.IS_DELETE_TRUE);

         }

      }else {

         example.or().andNotEqualTo("isDelete",Constants.IS_DELETE_TRUE);

      }

   }

   @Override

   public PageBean    queryByPageBean(PageBean pageBean) {

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

@@ -416,11 +423,11 @@
         }

         //刷新redis里设备信息

         refreshDeviceInRedis(device.getMac());

      }

      catch (Exception ex){

        } catch (Exception ex) {

         throw  ex;

      }

   }



   @Override

   public List<Map> countByTimes(Date start,Date end,String format){

      if(start==null||end==null||StringUtils.isBlank(format)){

@@ -445,6 +452,7 @@


   /**

    *  返回map{mac：，state：}

     *

    * @param macList

    * @return

    */

@@ -465,7 +473,8 @@
            //添加data

            if(BooleanUtils.isTrue(withData)){

               String dataKey = "data_"+mac;

               Map<String,String> dataMap = redisUtils.get(dataKey,new TypeReference<Map<String,String>>(){});

                    Map<String, String> dataMap = redisUtils.get(dataKey, new TypeReference<Map<String, String>>() {

                    });

               if(!MapUtils.isEmpty(dataMap)){

                  resultMap.putAll(dataMap);

               }

@@ -492,6 +501,7 @@
      ValidateUtil.notNull(parameters.get("organizationId"), "param.is.null");

      return deviceMapper.getDevicesByOrganizationId(parameters);

   }



   @Override

    public Map<String,Long> queryDeviceStateSummary(@NotNull Integer orgId){

       Map<String,Object> params = new HashMap<>();