保存历史数据至mongodb

沈斌

2017-11-02 b0db21cae6416355aef7ebf53c2696283a8bc23e

 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;



@@ -45,6 +46,9 @@


    @Resource

    RedisTemplate<String, String> redisTemplate;



    @Resource

    protected MongoTemplate mongoTemplate;



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



@@ -101,6 +105,7 @@


//        //保存原始数据

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

        mongoTemplate.insert(message, "logger");



        //保存历史记录

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