zl-opd-gather/src/main/java/com/hb/proj/gather/business/DataTransConfig.java

package com.hb.proj.gather.business;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.hb.proj.gather.model.AlarmDefineVO;
import com.hb.proj.gather.model.WellParamVO;
import com.hb.proj.gather.rep.WellConfigService;
import com.hb.xframework.util.ApplicationContextUtils;

/**
 * 采集数据转换配置数据
 * @author cwen
 *
 */
public class DataTransConfig {
	
	private final static  Logger logger = LoggerFactory.getLogger(DataTransConfig.class);

	private static Map<String,WellParamVO> configerParam=null;
	
	private static Map<String,AlarmDefineVO> configerAlarm=null;
	
	private static WellConfigService configService=null;
	
	public static void init() {
		logger.info("开始加载参数配置、报警设置...");
		configService=ApplicationContextUtils.getBean("wellConfigService", WellConfigService.class);
		configerParam=configService.loadWellParams();
		configerAlarm=configService.loadAlarmDefines();
		logger.info("完成加载参数配置、报警设置");
	}
	
	public static void reloadAll() {
		configerParam=configService.loadWellParams();
		configerAlarm=configService.loadAlarmDefines();
	}
	
	
	public static void reloadParams(String wellId) {
		Map<String,WellParamVO> reloadParams=configService.loadWellParams(wellId);
		if(reloadParams!=null) {
			configerParam.putAll(reloadParams);
		}
	}
	
	public static void reloadAlarms(String wellId) {
		Map<String,AlarmDefineVO> reloadAlarm=configService.loadAlarmDefines(wellId);
		if(reloadAlarm!=null) {
			configerAlarm.putAll(reloadAlarm);
		}
	}
	
	
	public static WellParamVO get(String serialParamCode) {
		if(configerParam==null) {
			configerParam=configService.loadWellParams();
		}
		return configerParam.get(serialParamCode);
	}
	
	public static List<AlarmDefineVO> getAlarmDefines(String wellId) {
		if(configerAlarm==null) {
			configerAlarm=configService.loadAlarmDefines();
		}
		List<AlarmDefineVO>  rtnAlarms=new ArrayList<>();
		for(String almkey : configerAlarm.keySet()) {
			if(almkey.startsWith(wellId)) {
				rtnAlarms.add(configerAlarm.get(almkey));
			}
		}
		return rtnAlarms;
	}
}