| | |
| | | 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;
|
| | |
|
| | |
| | |
|
| | | @Resource
|
| | | RedisTemplate<String, String> redisTemplate;
|
| | |
|
| | | @Resource
|
| | | protected MongoTemplate mongoTemplate;
|
| | |
|
| | | private Logger logger = LoggerFactory.getLogger(TaskListener.class);
|
| | |
|
| | |
| | |
|
| | | // //保存原始数据
|
| | | // taskDao.insertTologger(mac, message, getDate());
|
| | | mongoTemplate.insert(message, "logger");
|
| | |
|
| | | //保存历史记录
|
| | | List<History> histories = new ArrayList<History>();
|
| | |
| | | /*
|
| | | * 设置三级警报阀值,把map数据结构转换成数组结构
|
| | | */
|
| | | @Value(value="alarmLevles.json")
|
| | | @Value(value="alarmLevels.json")
|
| | | public void setAlarmLevles(String path) throws IOException {
|
| | | org.springframework.core.io.Resource resource = new ClassPathResource(path);
|
| | | InputStreamReader reader=new InputStreamReader(resource.getInputStream());
|