工业级运维app手机api
沈斌
2017-10-27 052c104cbc2ccc13d83cd912e3b2bbf12c0d56bc
src/main/java/com/moral/monitor/listener/TaskListener.java
@@ -4,6 +4,7 @@
import com.alibaba.fastjson.TypeReference;
import com.moral.monitor.dao.JobDao;
import com.moral.monitor.dao.TaskDao;
import com.moral.monitor.entity.History;
import com.moral.monitor.entity.Sensor;
import com.moral.monitor.util.RedisUtil;
import org.slf4j.Logger;
@@ -87,13 +88,21 @@
        taskDao.insertTologger(mac, message, getDate());
        //保存历史记录
        List<History> histories = new ArrayList<History>();
        List<Sensor> sensorList = taskDao.selectFromsensorByver(ver);
        for (Sensor sensor : sensorList) {
            String key = sensor.getMac_key();
            if(msgData.containsKey(key)) {
                taskDao.insertTohistory(mac, sensor.getSensor(), key, msgData.get(key));
                //taskDao.insertTohistory(mac, sensor.getSensor(), key, msgData.get(key));
                History history = new History();
                history.setMac(mac);
                history.setMac_key(key);
                history.setSensor(sensor.getSensor());
                history.setMac_value(Double.valueOf(msgData.get(key)));
                histories.add(history);
            }
        }
        jobDao.batchInsertHistory(histories);
    }
    private Map<String, Float> getAdjustData(String mac) {