PLTWEB.git - Gitblit

package com.vci.server.bof;
 
import java.util.HashMap;
import java.util.Map;
 
import javax.xml.rpc.holders.LongHolder;
 
import com.vci.corba.bofactory.BOFactoryService;
import com.vci.corba.omd.data.AttributeValue;
import com.vci.corba.omd.data.BusinessObject;
import com.vci.corba.omd.data.LinkObject;
import com.vci.corba.omd.data.RevisionDataInfo;
import com.vci.corba.omd.data.VersionDataInfo;
import com.vci.corba.omd.lcm.TransitionVO;
import com.vci.server.BaseService;
import com.vci.server.bof.delegate.BOFactoryServerBODelegate;
import com.vci.server.bof.delegate.BOFactoryServerDelegate;
import com.vci.server.bof.delegate.BatchSqlServerDelegate;
import com.vci.server.bof.delegate.CustomSqlServerDelegate;
import com.vci.server.bof.delegate.LOFacotryServerLODelegate;
import com.vci.server.bof.delegate.LOFactoryServerDelegate;
import com.vci.server.bof.service.BatchTransferService;
import com.zeroc.Ice.Current;
import com.vci.corba.common.VCIError;
import com.vci.common.ServiceNames;
import com.vci.common.log.ServerWithLog4j;
import com.vci.corba.framework.data.UserInfo;
 
public class BOFactoryServiceImpl extends BaseService implements BOFactoryService {
 
    @Override
    public String getServiceName() {
        return ServiceNames.BOFSERVICE;
    }
 
    /*
     * 初始化BOF服务
     */
    public BOFactoryServiceImpl() {
        //HibernateSessionFactory.getSessionFactory();
    }
 
    @Override
    public void test(Current current) {
    }
 
    @Override
    public BusinessObject initBusinessObject(String btmName, Current current) throws VCIError {
        BOFactoryServerBODelegate bofDelegate = BOFactoryServerBODelegate.getInstance();
        return bofDelegate.initBusinessObject(btmName);
    }
 
    @Override
    public BusinessObject revisionBusinessObject(BusinessObject bo, LinkObject[] los, boolean isRev, boolean isSave,
            boolean isFromLinkCopy, boolean isToLinkCopy, Current current) throws VCIError {
        BOFactoryServerBODelegate bofDelegate = BOFactoryServerBODelegate.getInstance();
        return bofDelegate.revisionBusinessObject(bo, los, isRev, isSave, isFromLinkCopy, isToLinkCopy);
    }
 
    @Override
    public BusinessObject revisionBusinessObjectWithLink(BusinessObject bo, String[] linkTypes, boolean isRev,
            boolean isSave, boolean isFromLinkCopy, boolean isToLinkCopy, Current current) throws VCIError {
        BOFactoryServerBODelegate bofDelegate = BOFactoryServerBODelegate.getInstance();
        return bofDelegate.revisionBusinessObject(bo, linkTypes, isRev, isSave, isFromLinkCopy, isToLinkCopy);
    }
 
    public BusinessObject createBusinessObject(BusinessObject bo, boolean isRevision, boolean isNewVersion,
            Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.createBusinessObject(bo, isRevision, isNewVersion);
    }
 
    @Override
    public boolean createBusinessObjectWithLink(BusinessObject[] bos, LinkObject lo, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.createBusinessObject(bos, lo);
    }
 
    public UpdateBusinessObjectResult updateBusinessObject(BusinessObject bo, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        boolean success = bofDelegate.updateBuinessObject(bo);
 
        return new UpdateBusinessObjectResult(success, bo.ts);
    }
 
    public boolean updateBusinessObjectOut(BusinessObject bo, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.updateBuinessObject(bo);
    }
 
    public boolean deleteBusinessObject(BusinessObject bo, long type, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.deleteBusinessObject(bo, (int) type);
    }
 
    @Override
    public BusinessObject readBusinessObject(String oid, String btwName, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        BusinessObject bo = bofDelegate.getInfoBusinessObject(oid, btwName);
        if (bo == null) {
            bo = new BusinessObject();
            bo.newAttrValList = new AttributeValue[0];
            bo.hisAttrValList = new AttributeValue[0];
        }
        return bo;
    }
 
    @Override
    public BusinessObject[] getLastRevisionBusinessObject(String oid, String btwName, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        BusinessObject[] bos = bofDelegate.getLastRevisionBusinessObject(oid, btwName);
        if (bos == null) {
            bos = new BusinessObject[0];
        }
        return bos;
    }
 
    public BusinessObject[] getBatchBusinessObject(String[] oids, String btmName, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        BusinessObject[] bos = bofDelegate.getBatchBusinessObject(oids, btmName);
        return bos;
    }
    
 
    @Override
    public BusinessObject[] batchGetBusinessObjects(String btName, int page, int pageSize, Current current)
            throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        BusinessObject[] bos = bofDelegate.getBatchBusinessObjects(btName, page, pageSize);
        return bos;
    }    
 
    @Override
    public boolean checkInBusinessObject(BusinessObject bo, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.checkInBusinessObject(bo);
    }
 
    @Override
    public boolean checkoutBusinessObject(BusinessObject bo, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.checkoutBusinessObject(bo);
    }
 
    @Override
    public boolean unCheckOutBusinessObject(BusinessObject bo, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.undoCheckoutBusinessObject(bo);
    }
 
    @Override
    public boolean changeBusinessObjectOwner(BusinessObject bo, UserInfo userInfo, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.changeBusinessObjectOwner(bo, userInfo);
    }
 
    @Override
    public boolean transferBusinessObject(BusinessObject bo, TransitionVO vo, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.transferBusinessObject(bo, vo, "");
    }
 
    @Override
    public boolean transferBusinessObjectAndRelease(BusinessObject bo, TransitionVO vo, String releaseStatus,
            Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.transferBusinessObject(bo, vo, releaseStatus);
    }
 
    @Override
    public LinkObject initLinkObject(String ltName, Current current) throws VCIError {
        LOFacotryServerLODelegate bofDelegate = LOFacotryServerLODelegate.getInstance();
        return bofDelegate.initLinkObject(ltName);
    }
 
    @Override
    public LinkObject[] readLinkObjectByFromBO(BusinessObject bo, String linkTypeName, Current current)
            throws VCIError {
        LOFactoryServerDelegate lofDelegate = LOFactoryServerDelegate.getInstance();
        LinkObject[] los = lofDelegate.getLinkObjectByBO(bo, linkTypeName, true);
        if (los == null) {
            return new LinkObject[0];
        }
        int len = los.length;
        for (int i = 0; i < len; i++) {
            if (los[i].newAttrValList == null) {
                los[i].newAttrValList = new AttributeValue[0];
            }
            if (los[i].hisAttrValList == null) {
                los[i].hisAttrValList = new AttributeValue[0];
            }
        }
        return los;
    }
 
    @Override
    public LinkObject[] readLinkObjectByToBO(BusinessObject bo, String linkTypeName, Current current)
            throws VCIError {
        LOFactoryServerDelegate lofDelegate = LOFactoryServerDelegate.getInstance();
        LinkObject[] los = lofDelegate.getLinkObjectByBO(bo, linkTypeName, false);
        if (los == null) {
            return new LinkObject[0];
        }
        int len = los.length;
        for (int i = 0; i < len; i++) {
            if (los[i].newAttrValList == null) {
                los[i].newAttrValList = new AttributeValue[0];
            }
            if (los[i].hisAttrValList == null) {
                los[i].hisAttrValList = new AttributeValue[0];
            }
        }
        return los;
    }
 
    @Override
    public LinkObject createLinkObject(LinkObject lo, Current current) throws VCIError {
        LOFactoryServerDelegate lofDelegate = LOFactoryServerDelegate.getInstance();
        return lofDelegate.createLinkObject(lo);
    }
 
    @Override
    public boolean updateLinkObject(LinkObject lo, Current current) throws VCIError {
        LOFactoryServerDelegate lofDelegate = LOFactoryServerDelegate.getInstance();
        return lofDelegate.updateBuinessObject(lo);
    }
 
    @Override
    public boolean deleteLinkObject(LinkObject lo, Current current) throws VCIError {
        LOFactoryServerDelegate lofDelegate = LOFactoryServerDelegate.getInstance();
        return lofDelegate.deleteLinkObject(lo);
    }
 
    @Override
    public RevisionDataInfo getNextRevisionValueObject(String btName, String nameOid, String revisionRule,
            boolean revInput, String revisionVal, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.getNextRevisionValueObject(btName, nameOid, revisionRule, revInput, revisionVal);
    }
 
    @Override
    public RevisionDataInfo getNextRevisionValue(String revisonValue, short revisionSeq, String revisionRule,
            Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.getNextRevisionValueObject(revisonValue, revisionSeq, revisionRule);
    }
 
    @Override
    public VersionDataInfo getNextVersionValue(String btName, String revisionOid, String nameOid, long versionType,
            Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.getNextVersionValue(btName, revisionOid, nameOid, (int) versionType);
    }
 
    @Override
    public BusinessObject[] batchCreateBusinessObject(BusinessObject[] bos, boolean isRevision, boolean isNewVersion,
            Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        ServerWithLog4j.logger.debug("=== BOFactoryServiceImpl.batchCreateBusinessObject ===========");
        return bofDelegate.batchCreateBusinessObject(bos, isRevision, isNewVersion);
    }
 
    @Override
    public boolean batchCreateBusinessObjectWithLink(BusinessObject[] bos, LinkObject[] los, Current current)
            throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.batchCreateBusinessObjectWithLink(bos, los);
    }
 
    @Override
    public boolean batchUpdateBusinessObject(BusinessObject[] bos, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.batchUpdateBusinessObject(bos);
    }
 
    @Override
    public boolean batchDeleteBusinessObject(BusinessObject[] bos, long type, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.batchDeleteBusinessObject(bos, (int) type);
    }
 
    @Override
    public boolean batchCheckInBusinessObject(BusinessObject[] bos, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.batchCheckInBusinessObject(bos);
    }
 
    @Override
    public boolean batchCheckoutBusinessObject(BusinessObject[] bos, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.batchCheckoutBusinessObject(bos);
    }
 
    @Override
    public boolean batchUnCheckOutBusinessObject(BusinessObject[] bos, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.batchUnCheckOutBusinessObject(bos);
    }
 
    @Override
    public boolean batchChangeBusinessObjectOwner(BusinessObject[] bos, UserInfo[] userList, Current current)
            throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.batchChangeBusinessObjectOwner(bos, userList);
    }
 
    @Override
    public LinkObject[] batchCreateLinkObject(LinkObject[] los, Current current) throws VCIError {
        LOFactoryServerDelegate lofDelegate = LOFactoryServerDelegate.getInstance();
        return lofDelegate.batchCreateLinkObject(los);
    }
 
    @Override
    public boolean batchUpdateLinkObject(LinkObject[] los, Current current) throws VCIError {
        LOFactoryServerDelegate lofDelegate = LOFactoryServerDelegate.getInstance();
        return lofDelegate.batchUpdateLinkObject(los);
    }
 
    @Override
    public boolean batchDeleteLinkObject(LinkObject[] los, Current current) throws VCIError {
        LOFactoryServerDelegate lofDelegate = LOFactoryServerDelegate.getInstance();
        return lofDelegate.batchDeleteLinkObject(los);
    }
 
    @Override
    public String[] getClssficationValue(String sql, AttributeValue[] attrVals, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.getClssficationValue(sql, attrVals);
    }
 
    @Override
    public String[][] getSqlQueryResult(String sql, AttributeValue[] attrVals, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.getSqlQueryResult(sql, attrVals);
    }
 
    @Override
    public String[][] getCustomSqlValue(String[] sqls, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.getCustomSqlValue(sqls);
    }
 
    /**
     * 创建带有链接的对象，并返回ts
     */
    @Override
    public CreateBusinessObjectWithLinkTSResult createBusinessObjectWithLinkTS(BusinessObject[] bos, LinkObject lo,
            Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
 
        LongHolder ts = new LongHolder();//new StringBuilder();
        boolean success = bofDelegate.CreateBusinessObjectWithLinkTS(bos, lo, ts);
 
        return new CreateBusinessObjectWithLinkTSResult(success, ts.value);
    }
 
    /**
     * 批量创建业务对象和链接对象，并返回业务对象的ts
     */
    @Override
    public BatchCreateBusinessObjectWithLinkTSResult batchCreateBusinessObjectWithLinkTS(BusinessObject[] bos,
            LinkObject[] los, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        LongHolder ts = new LongHolder();
        boolean success = bofDelegate.batchCreateBusinessObjectWithLinkTS(bos, los, ts);
        return new BatchCreateBusinessObjectWithLinkTSResult(success, ts.value);
    }
 
    /**
     * 批量升版本
     */
    @Override
    public boolean batchRevisonBusinessObject(String[] oids, String btmName, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.batchRevisonBusinessObject(oids, btmName);
    }
 
    @Override
    public LinkObject readLinkObjectById(String oid, String linkTypeName, Current current) throws VCIError {
        LOFactoryServerDelegate lofDelegate = LOFactoryServerDelegate.getInstance();
        return lofDelegate.readLinkObjectById(oid, linkTypeName);
    }
 
    @Override
    public boolean batchCreateDeleteBOLO(BusinessObject[] createBOs, LinkObject[] createLOs, BusinessObject[] deleteBOs,
            LinkObject[] deleteLOs, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.batchCreateDeleteBOLO(createBOs, createLOs, deleteBOs, deleteLOs);
    }
 
    @Override
    public boolean batchCUDBOLO(BusinessObject[] createBOs, LinkObject[] createLOs, BusinessObject[] updateBOs,
            LinkObject[] updateLOs, BusinessObject[] deleteBOs, LinkObject[] deleteLOs, Current current)
            throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.batchCUDBOLO(createBOs, createLOs, updateBOs, updateLOs, deleteBOs, deleteLOs);
    }
 
    @Override
    public boolean batchTransferBusinessObjectAndRelease(BusinessObject[] bos, TransitionVO[] vos,
            String[] releaseStatus, Current current) throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.batchTransferBusinessObject(bos, vos, releaseStatus);
    }
 
    @Override
    public boolean executeUpdateSql(String sql, Current current) throws VCIError {
        return CustomSqlServerDelegate.getInstance().executeUpdateSql(sql);
    }
 
    @Override
    public boolean batchCreateBOWithLinkNoCheckNoLog(BusinessObject[] bos, LinkObject[] los, Current current)
            throws VCIError {
        BOFactoryServerDelegate bofDelegate = BOFactoryServerDelegate.getInstance();
        return bofDelegate.batchCreateBOWithLinkNoCheckNoLog(bos, los);
    }
 
    @Override
    public boolean executeUpdateSqls(String[] sqls, Current current) throws VCIError {
        return BatchSqlServerDelegate.getInstance().executeUpdateSqls(sqls);
    }
 
    @Override
    public boolean executeUpdateSqlByParams(String sql, AttributeValue[] attrVals, Current current) throws VCIError {
        Map<String, String> params = new HashMap<String, String>();
        if (attrVals != null && attrVals.length > 0) {
            for (int i = 0; i < attrVals.length; i++) {
                AttributeValue attr = attrVals[i];
                params.put(attr.attrName, attr.attrVal);
            }
        }
        return CustomSqlServerDelegate.getInstance().executeUpdateSql(sql, params);
    }
 
    /**
     * 开始长事务
     */
    @Override
    public String beginTransaction(Current current) {
        return BatchTransferService.getInstance().beginTransaction();
    }
 
    /**
     * 传递长事务数据
     */
    @Override
    public boolean batchCUDBOLOByTransaction(String sessionKey, BusinessObject[] createBOs, LinkObject[] createLOs,
            BusinessObject[] updateBOs, LinkObject[] updateLOs, BusinessObject[] deleteBOs, LinkObject[] deleteLOs,
            Current current) throws VCIError {
        return BatchTransferService.getInstance().batchCUDBOLO(sessionKey, createBOs, createLOs, updateBOs, updateLOs,
                deleteBOs, deleteLOs);
    }
 
    /**
     * 提交长事务
     */
    @Override
    public CommitTransactionResult commitTransaction(String sessionKey, Current current) throws VCIError {
        boolean success = BatchTransferService.getInstance().commitTransaction(sessionKey);
 
        return new CommitTransactionResult(success, 0);
    }
 
 
}