package com.vci.server.bof.service;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.List;
import java.util.ArrayList;

import org.hibernate.Session;

import com.vci.corba.omd.atm.AttribItem;
import com.vci.corba.omd.data.AttributeValue;
import com.vci.corba.omd.data.BusinessObject;
import com.vci.corba.omd.data.RevisionDataInfo;
import com.vci.omd.constants.BusinessConstants;
import com.vci.omd.utils.ObjectTool;
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
import com.vci.server.base.utility.OmdHelper;
import com.vci.server.bof.utils.ServerObjectUtil;
import com.vci.server.bof.utils.TempTableUtil;
import com.vci.common.utility.ObjectUtility;

public class BOFactoryBatchServices extends BOFactoryBaseService{
 
	private static BOFactoryBatchServices instance = null;
	
	public static synchronized BOFactoryBatchServices getInstance() {
		if (instance == null) {
			instance = new BOFactoryBatchServices();
		}

		return instance;
	}
	
	/**
	 * 批量对业务对象进行升版本
	 * @param ids
	 * @param type
	 * @param currentUser
	 * @return
	 * @throws Exception
	 * @throws Throwable
	 */
    public BusinessObject[] batchRevisionBusinessObject(String[] ids, String btmName, String currentUser) throws Exception, Throwable {
		BusinessObject[] bos = getBatchBusinessObject(ids, btmName);
		AttribItem[] attrItems = getBOAttributeItem(btmName);
		
		String tableName = OmdHelper.getBTTableName(btmName);
		
		for (int i = 0; i < bos.length; i ++) {
			RevisionDataInfo info = BOFactoryServices.getInstance().getNextRevisionValue(tableName, bos[i].nameoid, 
					ObjectTool.getBOAttributeValue(bos[i], BusinessConstants.SELECT_REVISIONRULE), false, "");
			bos[i].revisionSeq = info.revisionSeq;
			bos[i].revisionValue = info.revisionVal;
			bos[i].fromVersion = bos[i].oid;
			bos[i].oid = ObjectUtility.getNewObjectID36();
			bos[i].revisionid = ObjectUtility.getNewObjectID36();
			bos[i].modifier = currentUser;
			bos[i].creator = currentUser;
			bos[i].isFirstR = false;
			bos[i].isLastR = true;
			bos[i].isFirstV = true;
			bos[i].isLastV = true;
			bos[i].versionSeq = 1;
			bos[i].lcStatus = getLcFirstStatus(ObjectTool.getBOAttributeValue(bos[i], BusinessConstants.SELECT_LCTID));
			int len = bos[i].hisAttrValList.length;
			int alen = attrItems.length;
			bos[i].newAttrValList = new AttributeValue[alen];
			for (int j = 0; j < alen; j++) {
				bos[i].newAttrValList[j] = bos[i].hisAttrValList[j + len - alen];
			}
			bos[i] = BOFactoryServices.getInstance().createBusinessObject(bos[i], true, false);
		}
		
		return bos;
	}
    
    /**
     * 通过批量的oid和btmname获取对应的对象信息
     * @param oids
     * @param btmName
     * @return
     * @throws Exception
     * @throws Throwable
     */
    public BusinessObject[] getBatchBusinessObject(String[] oids, String btmName)
			throws Exception, Throwable {
		AttribItem[] attrItems = getBOAttributeItem(btmName);

		String tableName = OmdHelper.getBTTableName(btmName);

		//Session session = HibernateSessionFactory.getSession();
		Connection connection = HibernateSessionFactory.getSessionConnection();
		
		String sql = getBatchSelectBOSql(oids, tableName, attrItems);
		Statement stmt = connection.createStatement();
		ResultSet rs = stmt.executeQuery(sql);
		
		List<BusinessObject> lstBO = new ArrayList<BusinessObject>();
		BusinessObject bo = new BusinessObject();
		while (rs.next()) {
			bo = ServerObjectUtil.createBOByRS(attrItems, rs);
			lstBO.add(bo);
		}
		
		return lstBO.toArray(new BusinessObject[0]);
		
//		SQLQuery query = session.createSQLQuery(sql);
//		query.executeUpdate();
//		List<?> queryList = query.list();
//		if (queryList == null || queryList.size() < 1) {
//			return new BusinessObject[0];
//		}
//		ServerBusinessObject sbo = new ServerBusinessObject();
//		String[] queryColumns = sbo.getQueryColumnAccordingToSQL(sql, "SELECT",
//				"FROM " + tableName);
//
//		BusinessObject[] bos = new BusinessObject[queryList.size()];
//		
//		for (int k = 0; k < queryList.size(); k++) {
//			ServerBusinessObject csbo = new ServerBusinessObject();
//			Object[] array = (Object[]) queryList.get(k);
//			String attrType = "";
//			int j = 0;
//			for (int i = 0; i < array.length; i++) {
//				if (i < array.length - attrItems.length) {
//					attrType = "";
//				} else {
//					attrType = attrItems[j++].vtDataType;
//				}
//				csbo.setAttributeValue(queryColumns[i], attrType, array[i]);
//			}
//
//			BusinessObject bo = csbo.getBusinessObject();
//			bos[k] = bo;
//		}

//		return bos;
	}
    
    public BusinessObject[] getBatchBusinessObjectByTempOIDs(String[] oids, String btmName)
			throws Exception, Throwable {
		AttribItem[] attrItems = getBOAttributeItem(btmName);

		String tableName = OmdHelper.getBTTableName(btmName);

		//Session session = HibernateSessionFactory.getSession();
		Connection connection = HibernateSessionFactory.getSessionConnection();
		TempTableUtil.insertTempOIDs(connection, oids);

		String sql = getBatchSelectBOSqlByTempOIDs(tableName, attrItems);
		Statement stmt = connection.createStatement();
		ResultSet rs = stmt.executeQuery(sql);
		
		List<BusinessObject> lstBO = new ArrayList<BusinessObject>();
		BusinessObject bo = new BusinessObject();
		while (rs.next()) {
			bo = ServerObjectUtil.createBOByRS(attrItems, rs);
			lstBO.add(bo);
		}
		
		return lstBO.toArray(new BusinessObject[0]);
    }

    /**
     * 通过批量的oid和btmname获取对应的对象信息
     * @param oids
     * @param btmName
     * @return
     * @throws Exception
     * @throws Throwable
     */
    public BusinessObject[] getBatchBusinessObjects(String btmName, int page, int pageSize)
			throws Exception, Throwable {
		AttribItem[] attrItems = getBOAttributeItem(btmName);

		String tableName = OmdHelper.getBTTableName(btmName);

		Session session = HibernateSessionFactory.getSession();
		String sql = getPageSelectBOSql(tableName, attrItems, page, pageSize);
		Statement stmt = HibernateSessionFactory.getSessionConnection().createStatement();
		ResultSet rs = stmt.executeQuery(sql);
		
		List<BusinessObject> lstBO = new ArrayList<BusinessObject>();
		BusinessObject bo = new BusinessObject();
		while (rs.next()) {
			bo = ServerObjectUtil.createBOByRS(attrItems, rs);
			lstBO.add(bo);
		}
		
		return lstBO.toArray(new BusinessObject[0]);
	}    
    /**
	 * 构建查询SQL语句
	 * 
	 * @param oid
	 * @param btmName
	 * @param queryColumns
	 * @return
	 */
	private String getBatchSelectBOSql(String[] oids, String btmName,
			AttribItem[] attrItems) {
		String sql = "";
		StringBuffer sbFields = new StringBuffer(
				"SELECT OID,REVISIONOID,NAMEOID,BtmName,isLastR,isFirstR,isLastV,isFirstV,Creator,CreateTime,LastModifier,"
						+ "LastModifyTime,RevisionRule,VersionRule,RevisionSeq,RevisionValue,"
						+ "VersionSeq,VersionValue,LCTID,LCStatus,TS,ID,NAME,DESCRIPTION,OWNER,COPYFROMVERSION");//
//						+ "CHECKINBY,CHECKINTIME,CHECKOUTBY,CHECKOUTTIME,");
		for (int i = 0; i < attrItems.length; i++) {
			sbFields.append(",");
			sbFields.append(attrItems[i].name);
		}
		
		sbFields.append(" FROM ").append(btmName).append(" p where p.OID in (");
		for (int i = 0; i < oids.length; i++) {
			if ((i != 0) && (i % 500 != 0)) {
				sbFields.append(",");
			}
			sbFields.append("'").append(oids[i]).append("'");
			if (i + 1 == oids.length) {
				break;
			}
			if((i + 1) % 500 == 0){
				sbFields.append(") or p.OID in (");
			}
		}
		sbFields.append(")");
		sql = sbFields.toString();
		return sql;
	}
	
	private String getBatchSelectBOSqlByTempOIDs(String btmName, AttribItem[] attrItems) {
		String sql = "";
		StringBuffer sbFields = new StringBuffer(
				"SELECT OID,REVISIONOID,NAMEOID,BtmName,isLastR,isFirstR,isLastV,isFirstV,Creator,CreateTime,LastModifier,"
						+ "LastModifyTime,RevisionRule,VersionRule,RevisionSeq,RevisionValue,"
						+ "VersionSeq,VersionValue,LCTID,LCStatus,TS,ID,NAME,DESCRIPTION,OWNER,COPYFROMVERSION");
						//+ "CHECKINBY,CHECKINTIME,CHECKOUTBY,CHECKOUTTIME");
		for (int i = 0; i < attrItems.length; i++) {
			sbFields.append(",");
			sbFields.append(attrItems[i].name);
		}
		sbFields.append(" FROM ").append(btmName).append(" p where p.OID in (select oid from pl_tempoid)");

		sql = sbFields.toString();
		return sql;
	}
	
	/**
	 * 分页查询指定类型的对象
	 * @param btmName
	 * @param attrItems
	 * @param page
	 * @param pageSize
	 * @return
	 */
	private String getPageSelectBOSql(String btmName, AttribItem[] attrItems, int page, int pageSize) {
		String sql = "";
		StringBuffer sbFields = new StringBuffer(
				"SELECT OID,REVISIONOID,NAMEOID,BtmName,isLastR,isFirstR,isLastV,isFirstV,Creator,CreateTime,LastModifier,"
						+ "LastModifyTime,RevisionRule,VersionRule,RevisionSeq,RevisionValue,"
						+ "VersionSeq,VersionValue,LCTID,LCStatus,TS,ID,NAME,DESCRIPTION,OWNER,COPYFROMVERSION");
//						+ "CHECKINBY,CHECKINTIME,CHECKOUTBY,CHECKOUTTIME,");
		for (int i = 0; i < attrItems.length; i++) {
			sbFields.append(",");
			sbFields.append(attrItems[i].name);
		}
		
		sbFields.append(" FROM ").append(btmName).append(" p ");
		
		if (page > 0 && pageSize > 0) {
			int start = (page - 1) * pageSize;
			int end = page * pageSize;
			sbFields.append("where rownum between ").append(start).append(" and ").append(end);
		}
		
		sql = sbFields.toString();
		return sql;
	}
	
//	public static void main(String[] args) {
//		BOFactoryBatchServices s = new BOFactoryBatchServices();
//		StringBuffer sbFields = new StringBuffer();
//		sbFields.append(" FROM ").append("abc").append(" p where p.OID in (");
//		String[] oids = new String[5];
//		for (int i = 0; i < 5; i++) {
//			oids[i] = "oid" + i;
//		}
//		for (int i = 0; i < oids.length; i++) {
//			if (i != 0 && i%3 != 0) {
//				sbFields.append(",");
//			}
//			sbFields.append("'").append(oids[i]).append("'");
//			if (i + 1 == oids.length) {
//				break;
//			}
//			if((i + 1) % 3 == 0){
//				sbFields.append(") or p.OID in (");
//			}
//		}
//		sbFields.append(")");
//		
//		System.out.println(sbFields.toString());
//	}
}