PLTWEB.git - Gitblit

package com.vci.server.cache;
 
import java.util.List;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.Map;
 
import org.apache.commons.lang3.StringUtils;
 
import com.alibaba.fastjson.JSONObject;
import com.vci.corba.omd.atm.AttribItem;
import com.vci.corba.omd.btm.BtmItem;
import com.vci.corba.omd.etm.EnumItem;
import com.vci.corba.omd.lcm.LifeCycle;
import com.vci.corba.omd.ltm.LinkType;
import com.vci.corba.omd.stm.StatePool;
import com.vci.corba.omd.vrm.VersionRule;
import com.vci.server.cache.redis.RedisUtil;
 
public final class OMCacheProvider {
    
    public static AttribItem getAttribute(String name) {
        String attrObj = RedisUtil.getInstance().hget(CacheNames.ATTRITEMS, name);
        if (StringUtils.isBlank(attrObj))
            return null;
        
        return JSONObject.parseObject(attrObj, AttribItem.class);
    }
    
    public static AttribItem[] getAttributes(String[] names) {
        List<AttribItem> lstAI = new ArrayList<AttribItem>();
        for (int i = 0; i < names.length; i++) {
            String jsonObj = RedisUtil.getInstance().hget(CacheNames.ATTRITEMS, names[i]);
            if (StringUtils.isBlank(jsonObj))
                continue;
            
            lstAI.add(JSONObject.parseObject(jsonObj, AttribItem.class));
        }
        
        lstAI.sort(new Comparator<AttribItem>() {//使用List接口的方法排序
            @Override
            public int compare(AttribItem o1, AttribItem o2) {
                return o1.name.toLowerCase().compareTo(o2.name.toLowerCase());
            }
        });        
        
        return lstAI.toArray(new AttribItem[0]);
    }
    
    public static AttribItem[] getAttributes() {
        List<AttribItem> lstAI = new ArrayList<AttribItem>();
        
        Map<String, String> map = RedisUtil.getInstance().hgetAll(CacheNames.ATTRITEMS);
        String[] jsons = map.values().toArray(new String[0]);
        for (int i = 0; i < jsons.length; i++) {
            if (StringUtils.isBlank(jsons[i]))
                continue;
            
            lstAI.add(JSONObject.parseObject(jsons[i], AttribItem.class));
        }
        
        lstAI.sort(new Comparator<AttribItem>() {//使用List接口的方法排序
            @Override
            public int compare(AttribItem o1, AttribItem o2) {
                return o1.name.toLowerCase().compareTo(o2.name.toLowerCase());
            }
        });        
        
        return lstAI.toArray(new AttribItem[0]);
    }
    
    public static boolean existAttribute(String name) {
        if (StringUtils.isBlank(name))
            return false;
        
        String jsonObj = RedisUtil.getInstance().hget(CacheNames.ATTRITEMS, name.toLowerCase());
        if (StringUtils.isBlank(jsonObj))
            return false;
        
        return true;
    }
    
    public static EnumItem getEnumType(String name) {
        String jsonObj = RedisUtil.getInstance().hget(CacheNames.ENUMTYPES, name.toLowerCase());
        if (StringUtils.isBlank(jsonObj))
            return null;
        
        return JSONObject.parseObject(jsonObj, EnumItem.class);
    }
    
    public static boolean existEnumType(String name) {
        if (StringUtils.isBlank(name))
            return false;
        
        String jsonObj = RedisUtil.getInstance().hget(CacheNames.ENUMTYPES, name.toLowerCase());
        if (StringUtils.isBlank(jsonObj))
            return false;
        
        return true;
    }
    
    public static EnumItem[] getEnumTypeByFilter(String filter) {
        
        Map<String, String> map = RedisUtil.getInstance().hgetAll(CacheNames.ENUMTYPES);
        
        boolean isFilter = !StringUtils.isBlank(filter);
        
        List<EnumItem> lstET = new ArrayList<EnumItem>();
        String[] jsons = map.values().toArray(new String[0]);
        for (String json : jsons) {
            if (StringUtils.isBlank(json))
                continue;
            
            EnumItem item = JSONObject.parseObject(json, EnumItem.class);
            if (isFilter) {
                if (item.name.contains(filter))
                    lstET.add(item);
            } else {
                lstET.add(item);
            }
        }
        
        lstET.sort(new Comparator<EnumItem>() {//使用List接口的方法排序
            @Override
            public int compare(EnumItem o1, EnumItem o2) {
                return o1.name.toLowerCase().compareTo(o2.name.toLowerCase());
            }
        });
 
        return lstET.toArray(new EnumItem[0]);
    }
    
    public static StatePool getLifeState(String name) {
        String jsonObj = RedisUtil.getInstance().hget(CacheNames.LIFESTATES, name.toLowerCase());
        if (StringUtils.isBlank(jsonObj))
            return null;
        
        return JSONObject.parseObject(jsonObj, StatePool.class);
    }
    
    public static StatePool[] getLifeStates() {
        List<StatePool> lstState = new ArrayList<StatePool>();
        
        Map<String, String> map = RedisUtil.getInstance().hgetAll(CacheNames.LIFESTATES);
        String[] jsons = map.values().toArray(new String[0]);
        for (int i = 0; i < jsons.length; i++) {
            if (StringUtils.isBlank(jsons[i]))
                continue;
            
            lstState.add(JSONObject.parseObject(jsons[i], StatePool.class));
        }
        
        lstState.sort(new Comparator<StatePool>() {//使用List接口的方法排序
            @Override
            public int compare(StatePool o1, StatePool o2) {
                return o1.name.toLowerCase().compareTo(o2.name.toLowerCase());
            }
        });        
        
        return lstState.toArray(new StatePool[0]);
    }
    
    
    public static LifeCycle getLifeCycle(String name) {
        String jsonObj = RedisUtil.getInstance().hget(CacheNames.LIFECYCLES, name.toLowerCase());
        if (StringUtils.isBlank(jsonObj))
            return null;
        
        return JSONObject.parseObject(jsonObj, LifeCycle.class);
    }
    
    public static LifeCycle[] getLifeCycles() {
        List<LifeCycle> lstLC = new ArrayList<LifeCycle>();
        
        Map<String, String> map = RedisUtil.getInstance().hgetAll(CacheNames.LIFECYCLES);
        String[] jsons = map.values().toArray(new String[0]);
        for (int i = 0; i < jsons.length; i++) {
            if (StringUtils.isBlank(jsons[i]))
                continue;
            
            lstLC.add(JSONObject.parseObject(jsons[i], LifeCycle.class));
        }
        
        lstLC.sort(new Comparator<LifeCycle>() {//使用List接口的方法排序
            @Override
            public int compare(LifeCycle o1, LifeCycle o2) {
                return o1.name.toLowerCase().compareTo(o2.name.toLowerCase());
            }
        });                
        
        return lstLC.toArray(new LifeCycle[0]);
    }
    
    /**
     * 获取事件key
     * 
     * @throws Throwable
     */
    public static String[] getLCEventKeys() {
        Map<String, String> map = RedisUtil.getInstance().hgetAll(CacheNames.LCEVENTS);
        
        return map.keySet().toArray(new String[0]);
    }
 
    /**
     * 获取事件value
     * 
     * @throws Throwable
     */
 
    public static String getLCEventValue(String key) throws Throwable {
        return RedisUtil.getInstance().hget(CacheNames.LCEVENTS, key);
    }
    
    public static VersionRule getVersionRule(String name) {
        String jsonObj = RedisUtil.getInstance().hget(CacheNames.VERRULES, name.toLowerCase());
        if (StringUtils.isBlank(jsonObj))
            return null;
        
        return JSONObject.parseObject(jsonObj, VersionRule.class);
    }
    
    public static VersionRule[] getVersionRules() {
        List<VersionRule> lstVR = new ArrayList<VersionRule>();
        
        Map<String, String> map = RedisUtil.getInstance().hgetAll(CacheNames.VERRULES);
        String[] jsons = map.values().toArray(new String[0]);
        for (int i = 0; i < jsons.length; i++) {
            if (StringUtils.isBlank(jsons[i]))
                continue;
            
            lstVR.add(JSONObject.parseObject(jsons[i], VersionRule.class));
        }
        
        lstVR.sort(new Comparator<VersionRule>() {//使用List接口的方法排序
            @Override
            public int compare(VersionRule o1, VersionRule o2) {
                return o1.name.toLowerCase().compareTo(o2.name.toLowerCase());
            }
        });                
        
        return lstVR.toArray(new VersionRule[0]);
    }
    
 
    public static BtmItem getBizType(String name) {
        String btObj = RedisUtil.getInstance().hget(CacheNames.BIZTYPES, name.toLowerCase());
        if (StringUtils.isBlank(btObj))
            return null;
        
        return JSONObject.parseObject(btObj, BtmItem.class);
    }
    
    public static BtmItem[] getBizTypes() {
        Map<String, String> allBTs = RedisUtil.getInstance().hgetAll(CacheNames.BIZTYPES);
        
        List<BtmItem> lstObj = new ArrayList<BtmItem>();
        String[] items = allBTs.values().toArray(new String[0]);
        for (int i = 0; i < items.length; i++) {
            lstObj.add(JSONObject.parseObject(items[i], BtmItem.class));
        }
        
        lstObj.sort(new Comparator<BtmItem>() {//使用List接口的方法排序
            @Override
            public int compare(BtmItem o1, BtmItem o2) {
                return o1.name.toLowerCase().compareTo(o2.name.toLowerCase());
            }
        });                
        
        return lstObj.toArray(new BtmItem[0]);
    }
    
    public static BtmItem[] getChildrenBizTypes(String btName) {
        Map<String, String> allBTs = RedisUtil.getInstance().hgetAll(CacheNames.BIZTYPES);
        
        List<BtmItem> lstBT = new ArrayList<BtmItem>();
        String[] items = allBTs.values().toArray(new String[0]);
        for (int i = 0; i < items.length; i++) {
            BtmItem bt = JSONObject.parseObject(items[i], BtmItem.class);
            if (bt.fName.equals(btName))
                lstBT.add(bt);
        }
        
        lstBT.sort(new Comparator<BtmItem>() {//使用List接口的方法排序
            @Override
            public int compare(BtmItem o1, BtmItem o2) {
                return o1.name.toLowerCase().compareTo(o2.name.toLowerCase());
            }
        });        
        
        return lstBT.toArray(new BtmItem[0]);
    }    
    
    public static String[] getBTAttributes(String name) {
        String btObj = RedisUtil.getInstance().hget(CacheNames.BIZTYPES, name.toLowerCase());
        if (StringUtils.isBlank(btObj))
            return new String[0];
        
        BtmItem bt = JSONObject.parseObject(btObj, BtmItem.class);
        if (bt != null)
            return bt.apNameArray;
        
        return new String[0];
    }
 
    
    public static AttribItem[] getAttribItemsByBizType(String name) {
        String btObj = RedisUtil.getInstance().hget(CacheNames.BIZTYPES, name.toLowerCase());
        if (StringUtils.isBlank(btObj))
            return new AttribItem[0];
        
        BtmItem bt = JSONObject.parseObject(btObj, BtmItem.class);
        if (bt == null)
            return new AttribItem[0];
        
        List<AttribItem> lstAI = new ArrayList<AttribItem>();
        for (int i = 0; i < bt.apNameArray.length; i++) {
            String attrObj = RedisUtil.getInstance().hget(CacheNames.ATTRITEMS, bt.apNameArray[i]);
            if (StringUtils.isBlank(attrObj))
                continue;
            
            lstAI.add(JSONObject.parseObject(attrObj, AttribItem.class));
        }
        
        return lstAI.toArray(new AttribItem[0]);
    }
    
 
    public static LinkType getLinkType(String name) {
        String attrObj = RedisUtil.getInstance().hget(CacheNames.LINKTYPES, name.toLowerCase());
        if (StringUtils.isBlank(attrObj))
            return null;
        
        return JSONObject.parseObject(attrObj, LinkType.class);
    }
    
    public static LinkType[] getLinkTypes() {
        Map<String, String> allLTs = RedisUtil.getInstance().hgetAll(CacheNames.LINKTYPES);
        
        List<LinkType> lstObj = new ArrayList<LinkType>();
        String[] items = allLTs.values().toArray(new String[0]);
        for (int i = 0; i < items.length; i++) {
            lstObj.add(JSONObject.parseObject(items[i], LinkType.class));
        }
        
        lstObj.sort(new Comparator<LinkType>() {//使用List接口的方法排序
            @Override
            public int compare(LinkType o1, LinkType o2) {
                return o1.name.toLowerCase().compareTo(o2.name.toLowerCase());
            }
        });            
        
        return lstObj.toArray(new LinkType[0]);
    }
    
    
    public static String[] getLTAttributes(String name) {
        String jsonObj = RedisUtil.getInstance().hget(CacheNames.LINKTYPES, name.toLowerCase());
        if (StringUtils.isBlank(jsonObj))
            return new String[0];
        
        LinkType lt = JSONObject.parseObject(jsonObj, LinkType.class);
        if (lt != null)
            return lt.attributes;
        
        return new String[0];
    }
 
    
    public static AttribItem[] getAttribItemsByLinkType(String name) {
        String btObj = RedisUtil.getInstance().hget(CacheNames.LINKTYPES, name.toLowerCase());
        if (StringUtils.isBlank(btObj))
            return new AttribItem[0];
        
        BtmItem bt = JSONObject.parseObject(btObj, BtmItem.class);
        if (bt == null)
            return new AttribItem[0];
        
        List<AttribItem> lstAI = new ArrayList<AttribItem>();
        for (int i = 0; i < bt.apNameArray.length; i++) {
            String attrObj = RedisUtil.getInstance().hget(CacheNames.ATTRITEMS, bt.apNameArray[i]);
            if (StringUtils.isBlank(attrObj))
                continue;
            
            lstAI.add(JSONObject.parseObject(attrObj, AttribItem.class));
        }
        
        return lstAI.toArray(new AttribItem[0]);
    }
    
}