| | |
| | | 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; |
| | |
| | | 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) { |