package com.casic.service.scanner; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.casic.mapper.DeviceDataMapper; import com.casic.service.DeviceDataScanner; import com.casic.service.DeviceDataSupport; import org.springframework.stereotype.Service; import java.util.List; import java.util.Map; @Service public class PressDataScanner extends DeviceDataSupport implements DeviceDataScanner { @Override public void scanDeviceData() { String thresholdValue = alarmLevelConfig.getPressure(); List<Map<String, Object>> pressDataMapList = this.deviceDataMapper.getPressureData(); pressDataMapList.forEach( pressDataMap -> { String devcode = pressDataMap.get("DEVCODE").toString(); String pressdata = pressDataMap.get("PRESSDATA").toString(); Integer isAlarm=isAlarm(pressdata,thresholdValue); sendAlarmMsg(devcode,isAlarm); } ); } }