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 configerParam=null; private static Map 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 reloadParams=configService.loadWellParams(wellId); if(reloadParams!=null) { configerParam.putAll(reloadParams); } } public static void reloadAlarms(String wellId) { Map 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 getAlarmDefines(String wellId) { if(configerAlarm==null) { configerAlarm=configService.loadAlarmDefines(); } List rtnAlarms=new ArrayList<>(); for(String almkey : configerAlarm.keySet()) { if(almkey.startsWith(wellId)) { rtnAlarms.add(configerAlarm.get(almkey)); } } return rtnAlarms; } }