package com.casic.service.scanner;

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 FlowDataScanner extends DeviceDataSupport implements DeviceDataScanner {

    @Override
    public void scanDeviceData() {
        String thresholdValue = alarmLevelConfig.getFlow();
        List<Map<String, Object>> flowDataMapList = this.deviceDataMapper.getFlowData();
        flowDataMapList.forEach(
                flowDataMap -> {
                    String devcode = flowDataMap.get("devcode").toString();
                    String insdata = flowDataMap.get("insdata").toString();
                    Integer isAlarm = isAlarm(insdata, thresholdValue);
                    sendAlarmMsg(devcode, isAlarm);
                }
        );
    }


}