数据库更新数据

沈斌

2017-10-27 3b400676fd00ae2f5834c712fe66f431850c9587

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

@@ -20,14 +20,12 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;

public class TaskListener implements MessageListener {

    @Resource
    RabbitTemplate rabbitTemplate;

    @Resource
    CachingConnectionFactory rabbitConnectionFactory;

    @Resource
    JobDao jobDao;
@@ -74,6 +72,11 @@

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

        int state = (new Random()).nextInt(4) % 5;
        rabbitTemplate.convertAndSend("monitors_alarm", "", "{\"mac\": \"" + mac + "\", \"state\": " + state + "}");

        jobDao.updateStateByMac(mac, state);
    }

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