package com.vci.server.omd.linktype.delegate;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import org.apache.commons.lang3.ArrayUtils;
|
import org.hibernate.Session;
|
|
import com.vci.corba.omd.atm.AttribItem;
|
import com.vci.corba.omd.ltm.LinkType;
|
import com.vci.omd.constants.LinkTypeConstants;
|
import com.vci.server.base.exception.ExceptionLocalHandler;
|
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
|
import com.vci.server.base.utility.OmdHelper;
|
import com.vci.server.cache.OMCacheProvider;
|
import com.vci.server.omd.ddlTool.DDLHelper;
|
import com.vci.server.omd.linktype.cache.LinkTypeCacheUtil;
|
import com.vci.server.omd.linktype.service.LTService;
|
import com.vci.common.exception.VciExceptionTool;
|
import com.vci.common.log.ServerWithLog4j;
|
import com.vci.corba.common.VCIError;
|
|
public class LinkTypeServerDelegate {
|
|
// private final String otherFieldLt = "\n\tOID VARCHAR2(36) not null," +
|
// "\n\tCreator VARCHAR2(36),\n\tCreateTime TIMESTAMP,\n\tLastModifier VARCHAR2(36)," +
|
// "\n\tLastModifyTime TIMESTAMP,\n\tF_OID VARCHAR2(36) not null,\n\tF_REVISIONOID VARCHAR2(36)," +
|
// "\n\tF_NAMEOID VARCHAR2(36),\n\tF_BtwName VARCHAR2(36),\n\tT_OID VARCHAR2(36) not null,\n\tT_REVISIONOID VARCHAR2(36)," +
|
// "\n\tT_NAMEOID VARCHAR2(36),\n\tT_BtwName VARCHAR2(36),\n\tTS TIMESTAMP,\n\t";
|
|
|
private static LinkTypeServerDelegate instance;
|
|
private LinkTypeServerDelegate() {
|
|
}
|
|
public static LinkTypeServerDelegate getInstance() {
|
if (instance == null) {
|
instance = new LinkTypeServerDelegate();
|
}
|
|
return instance;
|
}
|
|
protected VCIError getLocalVciError(String key, Throwable e) {
|
VCIError error = new VCIError(key, new String[]{VciExceptionTool.getExceptionStr(e), VciExceptionTool.getExceptionDetail(e)});
|
VCIError rsError = ExceptionLocalHandler.getInstance().getLocalString(error, "PLMLINK");
|
return rsError;
|
}
|
|
public LinkType getLinkType(String name) throws VCIError {
|
return OMCacheProvider.getLinkType(name);
|
}
|
|
public LinkType[] getLinkTypes() throws VCIError {
|
return OMCacheProvider.getLinkTypes();
|
}
|
|
public String getLTData() throws VCIError {
|
return "";//LTServerCacheUtil.getInstance().getLTData();
|
}
|
|
public String[] getLTNamesByAPName(String apName) throws VCIError {
|
LinkType[] lts = OMCacheProvider.getLinkTypes();
|
|
List<String> lstLTName = new ArrayList<String>();
|
for (LinkType lt : lts) {
|
for (int i = 0; i < lt.attributes.length; i++) {
|
if (lt.attributes[i].equalsIgnoreCase(apName)) {
|
lstLTName.add(lt.name);
|
break;
|
}
|
}
|
}
|
|
return lstLTName.toArray(new String[0]);
|
}
|
|
|
public LinkType[] getLinkTypeByBtmName(String btmName, String direction) throws VCIError {
|
LinkType[] lts = OMCacheProvider.getLinkTypes();
|
|
List<LinkType> lstLT = new ArrayList<LinkType>();
|
for (LinkType lt : lts) {
|
if (LinkTypeConstants.Direction_From.equals(direction)) {
|
if (ArrayUtils.contains(lt.btmItemsFrom, btmName))
|
lstLT.add(lt);
|
} else {
|
if (ArrayUtils.contains(lt.btmItemsTo, btmName))
|
lstLT.add(lt);
|
}
|
}
|
|
return lstLT.toArray(new LinkType[0]);
|
}
|
|
public boolean addLinkType(LinkType lt) throws VCIError {
|
try{
|
boolean success = LTService.getInstance().addLinkType(lt);
|
|
if (success) {
|
createTable(lt.name);
|
}
|
|
if (success) {
|
LinkTypeCacheUtil.setLinkType(lt);
|
}
|
return success;
|
}catch(Throwable e){
|
ServerWithLog4j.logger.error("addLinkType", e);
|
throw getLocalVciError("P0010LINK-00001", e);
|
}
|
}
|
|
public boolean modifyLinkType(LinkType lt) throws VCIError {
|
try{
|
boolean success = LTService.getInstance().modifyLinkTypeTable(lt);
|
|
if (success) {
|
success = LTService.getInstance().modifyLinkType(lt);
|
}
|
if (success) {
|
LinkTypeCacheUtil.setLinkType(lt);
|
}
|
return success;
|
}catch(Throwable e){
|
ServerWithLog4j.logger.error("modifyLinkType", e);
|
throw getLocalVciError("P0010LINK-00002", e);
|
}
|
}
|
|
public boolean deleteLinkType(LinkType lt) throws VCIError {
|
try{
|
boolean success = LTService.getInstance().deleteLinkType(lt);
|
|
if (success) {
|
LinkTypeCacheUtil.delLinkType(lt.name);
|
}
|
return success;
|
}catch(Throwable e){
|
ServerWithLog4j.logger.error("deleteLinkType", e);
|
throw getLocalVciError("P0010LINK-00003", e);
|
}
|
}
|
|
/**
|
* 清空链接类型
|
*/
|
public boolean deleteLinkTypes(LinkType[] lts) throws VCIError {
|
try{
|
boolean success = LTService.getInstance().deleteLinkTypes(lts);
|
if (success) {
|
for (LinkType lt : lts)
|
LinkTypeCacheUtil.delLinkType(lt.name);
|
}
|
return success;
|
}catch(Throwable e){
|
ServerWithLog4j.logger.error("deleteLinkTypes", e);
|
throw getLocalVciError("P0010LINK-00003", e);
|
}
|
}
|
|
public String[] executeRepair(String[] sqlArray) throws VCIError {
|
try{
|
return LTService.getInstance().executeRepair(sqlArray);
|
}catch(Throwable e){
|
e.printStackTrace();
|
throw getLocalVciError("P0010LINK-00010", e);
|
}
|
}
|
|
public boolean createTable(String ltName) throws VCIError {
|
try {
|
return LTService.getInstance().createTable(ltName);
|
} catch (Throwable e) {
|
e.printStackTrace();
|
throw getLocalVciError("P0010LINK-00011", e);
|
}
|
}
|
|
public boolean createView() throws VCIError {
|
return LTService.getInstance().createView();
|
}
|
|
|
public boolean truncateTable(String ltName) throws VCIError {
|
try {
|
String tableName = OmdHelper.getLTTableName(ltName);
|
return DDLHelper.truncateTable(tableName);
|
} catch (Throwable e) {
|
e.printStackTrace();
|
throw getLocalVciError("P0010BTM-00018", e);
|
}
|
}
|
|
/**
|
* 清空链接表， 链接类型
|
*/
|
public boolean deleteLtsAndTables(LinkType[] lts) throws VCIError {
|
try{
|
boolean success = LTService.getInstance().deleteLtsAndTables(lts);
|
if (success) {
|
for (LinkType lt : lts)
|
LinkTypeCacheUtil.setLinkType(lt);
|
}
|
return success;
|
}catch(Throwable e){
|
ServerWithLog4j.logger.error("deleteLtsAndTables", e);
|
throw getLocalVciError("P0010LINK-00011", e);
|
}
|
}
|
|
|
public boolean xml2DB(String userName) throws VCIError {
|
return LTService.getInstance().xml2DB(userName);
|
}
|
|
// public boolean addLinkTypeNoCache(LinkType lt) throws VCIError {
|
// try{
|
// return LTService.getInstance().addLinkTypeNoCache(lt);
|
// }catch(Throwable e){
|
// e.printStackTrace();
|
// throw getLocalVciError("P0010LINK-00001", e);
|
// }
|
// }
|
|
// @Override
|
// public boolean deleteLinkTypeNoCache(LinkType lt) throws VCIError {
|
// try{
|
// return LTService.getInstance().deleteLinkTypeNoCache(lt);
|
// }catch(Throwable e){
|
// e.printStackTrace();
|
// throw getLocalVciError("P0010LINK-00003", e);
|
// }
|
// }
|
|
public String[] linkTypeConsistencyCheck() throws VCIError {
|
try{
|
return LTService.getInstance().linkTypeConsistencyCheck();
|
}catch(Throwable e){
|
ServerWithLog4j.logger.error("linkTypeConsistencyCheck", e);
|
throw getLocalVciError("P0010LINK-00009", e);
|
}
|
}
|
|
public boolean hasData(String ltName) throws VCIError {
|
boolean flag = false;
|
Session session = HibernateSessionFactory.getSession();
|
|
String table = OmdHelper.getLTTableName(ltName);
|
//判断表是否存在, 表不存在则该表无数据
|
String sql_ = "select count(1) from user_tables where TABLE_NAME = '" + table +"'";
|
List<?> list_ = session.createSQLQuery(sql_).list();
|
// 当list.get(i)中Object数量为1时, list.get(i)为Object
|
// 当list.get(i)中Object数量 > 1时, list.get(i)为Object
|
Object obj_ = list_.get(0);
|
int count_ = ((BigDecimal) obj_).intValue();
|
if (count_ < 1) {
|
return false;
|
}
|
String sql = "select count(*) from " + table;
|
List<?> list = session.createSQLQuery(sql).list();
|
//当list.get(i)中Object数量为1时, list.get(i)为Object
|
//当list.get(i)中Object数量 > 1时, list.get(i)为Object
|
Object obj = list.get(0);
|
int count = ((BigDecimal)obj).intValue();
|
if(count > 0){
|
flag = true;
|
}
|
return flag;
|
}
|
|
|
public boolean addIndex(String ltName, String[] indexAttrs) throws VCIError {
|
if (indexAttrs.length == 0)
|
return false;
|
|
String sql = "create unique INDEX "+ indexAttrs[0]+" on " + OmdHelper.getLTTableName(ltName) + "(" + indexAttrs[1] + ")\n";
|
|
try {
|
return DDLHelper.executeSql(sql);
|
} catch (Throwable e) {
|
throw getLocalVciError("dropIndex", e);
|
}
|
}
|
|
|
public boolean dropIndex(String btName, String[] indexAttrs) throws VCIError {
|
if (indexAttrs.length == 0)
|
return false;
|
|
String sql = "drop INDEX "+indexAttrs[0]+" \n";
|
|
try {
|
return DDLHelper.executeSql(sql);
|
} catch (Throwable e) {
|
throw getLocalVciError("dropIndex", e);
|
}
|
}
|
|
|
public boolean modifyLTAttribute(String ltName, String attrName) throws VCIError {
|
AttribItem ai = OMCacheProvider.getAttribute(attrName);
|
if (ai == null)
|
return false;
|
|
String abSql = DDLHelper.getAbSql(ai);
|
abSql = abSql.substring(0, abSql.lastIndexOf(","));
|
|
String sql = "alter table " + OmdHelper.getLTTableName(ltName) + " modify( " + abSql + " )";
|
|
try {
|
return DDLHelper.executeSql(sql);
|
} catch (Throwable e) {
|
throw getLocalVciError("modifyBTAttribute", e);
|
}
|
}
|
|
}
|
