| | |
| | |
|
| | | /*不报警版本*/
|
| | | public class Listener implements MessageListener {
|
| | |
|
| | | @Resource
|
| | | RabbitTemplate rabbitTemplate;
|
| | |
|
| | | @Resource
|
| | | TaskDao taskDao;
|
| | |
|
| | | private Logger logger = LoggerFactory.getLogger(Listener.class);
|
| | |
|
| | | public void onMessage(Message message) {
|
| | |
|
| | | logger.warn("正在运行的线程名称=" + Thread.currentThread().getName());
|
| | |
| | | removeNotBind(receiveMsgMap,exsensorMap,bindsensor);
|
| | | }
|
| | |
|
| | |
|
| | | //为绑定传感器产生历史和即时数据
|
| | | List<State> states = taskDao.findstateBymac(mac);
|
| | | updateOrinsertstate(receiveMsgMap, mac, exsensorMap);
|
| | |
| | | } else {
|
| | | insertTohistoryDistinct(receiveMsgMap,mac,exsensorMap,states);
|
| | | }
|
| | |
|
| | |
|
| | | //查找临界值表
|
| | | List<Critical> criticals = taskDao.findcritical();
|