Merge remote-tracking branch 'origin/master'

沈斌

2017-11-11 45be44fb95325305373647231ef74e72d1501f8c

 src/main/java/com/moral/monitor/listener/TaskListener.java

@@ -20,6 +20,7 @@
import org.springframework.amqp.rabbit.core.RabbitTemplate;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.core.io.ClassPathResource;

import org.springframework.data.mongodb.core.MongoTemplate;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.util.StringUtils;



@@ -30,6 +31,7 @@
import com.moral.monitor.dao.TaskDao;

import com.moral.monitor.entity.History;

import com.moral.monitor.entity.Sensor;

import com.moral.monitor.service.RedisService;

import com.moral.monitor.util.RedisUtil;



public class TaskListener implements MessageListener {

@@ -46,8 +48,12 @@
    @Resource

    RedisTemplate<String, String> redisTemplate;



    private Logger logger = LoggerFactory.getLogger(TaskListener.class);

    @Resource

    protected MongoTemplate mongoTemplate;



    private Logger logger = LoggerFactory.getLogger(TaskListener.class);

    @Resource

    RedisService redisService;

    @Override

    public void onMessage(Message msg) {



@@ -65,17 +71,9 @@
        if(StringUtils.isEmpty(ver) || StringUtils.isEmpty(mac)) {

            return;

        }



        Map<String, Float> adjustMap;

        String adjust_key = "adjust_" + mac;

        if(RedisUtil.hasKey(redisTemplate, adjust_key)) {

            adjustMap = JSON.parseObject(RedisUtil.get(redisTemplate, adjust_key), new TypeReference<Map<String, Float>>() {});

        } else {

            adjustMap = getAdjustData(mac);

            RedisUtil.set(redisTemplate, adjust_key, JSON.toJSONString(adjustMap));

        }



        if(!adjustMap.isEmpty()) {

        //获取缓存中的校准值map

        Map<String, Float> adjustMap = redisService.getAdjustsByMac(mac);

        if(adjustMap!=null&&!adjustMap.isEmpty()) {

            for (Map.Entry<String, Float> entry : adjustMap.entrySet()) {

                String key = entry.getKey();

                if(msgData.containsKey(key)) {

@@ -85,12 +83,12 @@
                }

            }

        }



//        System.out.println(message);

//        System.out.println(JSON.toJSONString(msgData));



        rabbitTemplate.convertAndSend("monitors_data2", "", JSON.toJSONString(msgData).getBytes());

//        rabbitTemplate.send("monitors_data_3", "", new Message(JSON.toJSONString(msgData).getBytes(), new MessageProperties()));

        String new_message = JSON.toJSONString(msgData);

        rabbitTemplate.convertAndSend("monitors_data2", "", new_message.getBytes());

//        rabbitTemplate.send("monitors_data2", "", new Message(JSON.toJSONString(msgData).getBytes(), new MessageProperties()));



//        int state = (new Random()).nextInt(4) % 5; //TODO

          int state = detEquState(msgData);

@@ -99,8 +97,9 @@
        //更新设备状态

        jobDao.updateStateByMac(mac, state);



        //保存原始数据

        taskDao.insertTologger(mac, message, getDate());

//        //保存原始数据

//        taskDao.insertTologger(mac, message, getDate());

        mongoTemplate.insert(message, "logger");



        //保存历史记录

        List<History> histories = new ArrayList<History>();

@@ -119,29 +118,16 @@
            }

        }

        jobDao.batchInsertHistory(histories);

    }



    private Map<String, Float> getAdjustData(String mac) {

        List<Map<String, String>> adjusts = jobDao.findAdjustByMac(mac);

        Map<String, Float> dataMap = new HashMap<String, Float>();

        for (int i = 0; i < adjusts.size(); i++) {

            Map adjust = adjusts.get(i);

            if(adjust.get("value") != null) {

                String key = String.valueOf(adjust.get("key"));

                String data = String.valueOf(adjust.get("value"));

                BigDecimal value = new BigDecimal(data);

                value.setScale(3, BigDecimal.ROUND_HALF_UP);

                dataMap.put(key, value.floatValue());

            }

        }

        return dataMap;

        //mongoTemplate.insert(JSON.toJSONString(histories), "data");

        mongoTemplate.insert(new_message, "data");

    }

    //三级警报值阀值

    private static Map<String,Double[]> alarmLevles =new HashMap<String, Double[]>();

    /*

     * 设置三级警报阀值,把map数据结构转换成数组结构

     */

   @Value(value="alarmLevles.json")

   @Value(value= "system/alarmLevels.json")

    public void setAlarmLevles(String path) throws IOException {

       org.springframework.core.io.Resource resource  = new ClassPathResource(path);

       InputStreamReader reader=new InputStreamReader(resource.getInputStream());

@@ -154,14 +140,18 @@
         double level1 = levels.get("level1");

         double level2 = levels.get("level2");

         double level3 = levels.get("level3");

         //三级警报数组

         Double arr[] = {0.0,level1,level2,level3};

         alarmLevles.put(key, arr);

         //当三个值都为零时，不加入阀值

         if(levels.get("enable")!=null&&levels.get("enable")==1) {

            //三级警报数组

            Double arr[] = {0.0,level1,level2,level3};

            alarmLevles.put(key, arr);

         }

      }

    }

   //根据三级警报阀值，确定设备状态

    private int detEquState(Map<String,String> data) {

       int state = 0;

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

       if(data!=null) {

             for(String key:alarmLevles.keySet()) {

                  String value = data.get(key);

@@ -173,21 +163,25 @@
                          if(val>=arr[index]) {

                             //如果当前状态级别更高就取当前状态。否则保持之前状态

                             state = (index>state)?index:state;

                             break;

                             String e_key = "level"+Integer.toString(index);

                              Object e_States = equMap.get(e_key);

                              if(e_States!=null&&e_States instanceof List) {

                                 ((List)e_States).add(key);

                              }else {

                                 e_States = new ArrayList<String>();

                                 equMap.put(e_key, e_States);

                                 ((List)e_States).add(key);

    						        	
                              }

                              equMap.put(e_key, e_States);

                              break;

                          }

                     }

                     //当前状态到达最大级别不再遍历，跳出循环

                     if(state == (arr.length-1)) {

                        break;

                     }

                  }

             }

       }

       equMap.put("state", state);//设备状态  
       redisService.setEquState(data.get("mac"),equMap);

       return state;

    }

    private String getDate() {

        Date d = new Date();

        SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        return formatter.format(d);

    }

}