PLTWEB.git - Gitblit

package com.vci.server.portal.service;
 
import java.math.BigDecimal;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
 
import org.hibernate.SQLQuery;
import org.hibernate.Session;
import org.omg.CORBA.IntHolder;
 
import com.vci.server.base.persistence.dao.BaseService;
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
import com.vci.server.portal.dao.impl.PortalVIEntityDaoImpl;
import com.vci.server.portal.entity.PortalVIEntity;
import com.vci.server.portal.tools.ServerTool;
import com.vci.corba.portal.data.PortalVI;
 
public class PortalVIEntityService extends BaseService{
    private static PortalVIEntityService instance = null;
    
    private PortalVIEntityService(){
        
    }
    
    public static PortalVIEntityService getInstance(){
        if(instance == null){
            instance = new PortalVIEntityService();
        }
        return instance;
    }
    
    /**
     * 新增视图对象
     * @param obj
     * @throws Throwable 
     */
    public boolean savePortalVIEntity(PortalVIEntity obj) throws Throwable {
        try {
            PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
            impl.saveOrUpdate(obj);
            return true;
        } catch (Throwable e) {
            throw e;
        }
    }
    
    public boolean batchSavePortalVIEntity(PortalVIEntity[] objs) throws Throwable {
        try {
            PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
            List<PortalVIEntity> list = new ArrayList<PortalVIEntity>();
            int batchNum = 200;
            for (int i = 0; i < objs.length; i++) {
                list.add(objs[i]);
                if ((i + 1) % batchNum == 0) {
                    impl.saveOrUpdateAll(list);
                    list = new ArrayList<PortalVIEntity>();
                }
            }
            impl.saveOrUpdateAll(list);
            return true;
        } catch (Throwable e) {
            throw e;
        }
    }
    
    /**
     * 更新视图对象
     * @param obj
     * @return
     * @throws Throwable 
     */
    public boolean updatePortalVIEntity(PortalVIEntity obj) throws Throwable{
        try{
            PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
            PortalVIEntity objGet = impl.getById(obj.getId());
            if (objGet == null) {
                impl.saveOrUpdate(obj);
            } else {
                // objGet.setId(obj.getId());
                objGet.setTypeFlag(obj.getTypeFlag());
                objGet.setTypeName(obj.getTypeName());
                objGet.setViName(obj.getViName());
                objGet.setViType(obj.getViType());
                objGet.setPrm(obj.getPrm());
                impl.saveOrUpdate(objGet);
            }
            return true;
        }catch (Throwable e) {
            throw e;
        }
    }
    
    /**
     * 删除视图对象
     * @param obj
     * @return
     * @throws Throwable 
     */
    public boolean deletePortalVIEntity(PortalVIEntity obj) throws Throwable{
        try{
            PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
            impl.delete(obj);
            return true;
        }catch (Throwable e) {
            throw e;
        }
        
    }
 
    /**
     * 根据Id删除指定的对象
     * @param id
     * @return
     * @throws Throwable 
     */
    public boolean deletePortalVIEntityById(String id) throws Throwable{
        try{
            PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
            PortalVIEntity obj = impl.getById(id);
            if (obj != null) {
                impl.delete(obj);
            }
            return true;
        }catch (Throwable e) {
            throw e;
        }
        
    }
    
    /**
     * 获取指定ID的PortalVIEntity
     * @param id
     * @return
     * @throws Throwable 
     */
    public PortalVIEntity getPortalVIEntityById(String id) throws Throwable{
        try{
            PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
            PortalVIEntity obj = impl.getById(id);
            return obj;
        }catch (Throwable e) {
            throw e;
        }
    }
    
    /**
     * 根据标示获取标示对应的定义
     * @param symbol
     * @return
     * @throws Throwable
     */
    public PortalVIEntity getPortalVIBySymbol (String symbol) throws Throwable{
        try{
            try{
                PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
                PortalVIEntity obj = impl.findEntity("from PortalVIEntity where viName = '" + symbol + "'");
                return obj;
            }catch(Throwable e){
                throw e;
            }
        }catch (Throwable e) {
            throw e;
        }
    }
    
    /**
     * 获取指定类型下的所有视图
     * @param typeName
     * @return
     * @throws Throwable 
     */
    public PortalVI[] getPortalVIArrayByTypeName(String typeName) throws Throwable{
        try{
            PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
            List<PortalVIEntity> list = impl.findEntities("select p from PortalVIEntity p where typeName = '" + typeName + "'");
            if(list == null || list.size() < 0){
                return new PortalVI[0];
            }
            List<PortalVI> list_ = new ArrayList<PortalVI>();
            for(int i = 0; i < list.size(); i++){
                PortalVI obj = ServerTool.getPortalVI(list.get(i));
                if(obj != null){
                    list_.add(obj);
                }
            }
            return list_.toArray(new PortalVI[0]);
        }catch (Throwable e) {
            throw e;
        }
    }
    
    public int getPortalVICountByTypeName(String typeName) throws Throwable{
        try{
            String sql = "select count(*) from plportalvi p where typeName = '" + typeName + "'";
            Session session = HibernateSessionFactory.getSession();
            SQLQuery query = session.createSQLQuery(sql);
            List queryList = query.list();
            Object array = (Object)queryList.get(0);
            int count = ((BigDecimal) array).intValue();
            return count;
        }catch (Throwable e) {
            throw e;
        }
    }
    
    public int getPortalVICountByCondition(String typeName, int sheetType,
            String sheetName) throws Throwable{
        try{
            String sql = "select count(*) from plportalvi p where typeName = '" + typeName + "'";
            if (sheetType != -1) {
                sql += " and vitype = " + sheetType;
            }
            if (!sheetName.trim().equals("")) {
                sql += " and viname like '%" + sheetName + "%' "; 
            }
            Session session = HibernateSessionFactory.getSession();
            SQLQuery query = session.createSQLQuery(sql);
            List queryList = query.list();
            Object array = (Object)queryList.get(0);
            int count = ((BigDecimal) array).intValue();
            return count;
        }catch (Throwable e) {
            throw e;
        }
    }
    
    /**
     * 分页查找当前业务类型下的表单和表格
     * @param typeName
     * @param startPage
     * @param endPage
     * @return
     * @throws Throwable
     */
    public PortalVI[] getPagePortalVIArrayByTypeName(String typeName, int startPage, int endPage) throws Throwable{
        try{
            PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
            String sql = "select {c.*} from (select * from (select a.*, rownum rn from (" + 
                    "select * from plportalvi p where typeName = '" + typeName + "') a where rownum < " + endPage + ") b where rn >= " + startPage + ") c";
            List<PortalVIEntity> list = impl.findEntites(sql, new String[0], "c", PortalVIEntity.class);
            
            if(list == null || list.size() < 0){
                return new PortalVI[0];
            }
            List<PortalVI> list_ = new ArrayList<PortalVI>();
            for(int i = 0; i < list.size(); i++){
                PortalVI obj = ServerTool.getPortalVI(list.get(i));
                if(obj != null){
                    list_.add(obj);
                }
            }
            return list_.toArray(new PortalVI[0]);
        }catch (Throwable e) {
            throw e;
        }
    }
    
    /**
     * 分页查找当前业务类型下的表单和表格
     * @param typeName
     * @param startPage
     * @param endPage
     * @return
     * @throws Throwable
     */
    public PortalVI[] getPagePortalVIArrayByCondition(String typeName, int sheetType, String sheetName, int startPage, int endPage) throws Throwable{
        try{
            PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
            String sql = "select {c.*} from (select * from (select a.*, rownum rn from (" + 
                    "select * from plportalvi p where typeName = '" + typeName + "'";
            if (sheetType != -1) {
                sql += " and viType = " + sheetType; 
            }
            if (!sheetName.trim().equals("")) {
                sql += " and viname like '%" + sheetName + "%' "; 
            }
            sql += ") a where rownum < " + endPage + ") b where rn >= " + startPage + ") c";
            List<PortalVIEntity> list = impl.findEntites(sql, new String[0], "c", PortalVIEntity.class);
            
            if(list == null || list.size() < 0){
                return new PortalVI[0];
            }
            List<PortalVI> list_ = new ArrayList<PortalVI>();
            for(int i = 0; i < list.size(); i++){
                PortalVI obj = ServerTool.getPortalVI(list.get(i));
                if(obj != null){
                    list_.add(obj);
                }
            }
            return list_.toArray(new PortalVI[0]);
        }catch (Throwable e) {
            throw e;
        }
    }
 
    public PortalVI[] getPortalVIByQueryInfo(String typeName, int typeFlag,
            String viName, int viType, IntHolder total) {
        //TODO
        return null;
    }
    /**
     * 根据翻页参数返回表单
     * @param typeName 表单所在类型名称
     * @param viName 表单名称 模糊查询
     * @param viType 表单类型 PortalVIType.Table|Form
     * @param viTypeFlag 表单类型标识 PortalVITypeFlag.BtmType|LinkType
     * @param pageIndex 页号
     * @param pageSize 页大小
     * @param total 输出参数总数
     * @return
     * @throws Throwable
     */
    public PortalVI[] getPagePortalVIArrayByPageInfo(String typeName,
            String viName, short viType, short viTypeFlag, long pageIndex,
            long pageSize, IntHolder total) throws Throwable {
        String fromField = "vi.id,vi.typename,vi.viname,vi.vitype,vi.typeflag ";
        String countField = " count(1) count_ ";
        String where = "1=1";
        if(!"".equals(typeName)){
            where += " and vi.typename = '" + typeName + "' ";
        }
        if(!"".equals(viName)){
            where += " and vi.viname like '%" + viName + "%' ";
        }
        if(viType != -1){
            where += " and vi.vitype = " + viType + " ";
        }
        if(viTypeFlag != -1){
            where += " and vi.typeflag = " + viTypeFlag + " ";
        }
        String orderBy = "order by vi.viname";
        long begin = (pageIndex <= 1 ? 1 : ((pageIndex - 1) * pageSize) + 1);
        long end = (pageIndex <= 0 ? pageSize : pageIndex * pageSize);
        String sql = "" +
                "select * from(" +
                "    select row_.*,rownum rownum_ from(" +
                "        select " + fromField + " from plportalvi vi where " + where + " " + orderBy + "" +
                "    ) row_" +
                ") where rownum_ >= " + String.valueOf(begin) + " and rownum_ <= " + String.valueOf(end);
        PortalVI[] res = new PortalVI[0];
        List<PortalVI> vis = new ArrayList<PortalVI>();
        try{
            SQLQuery sqlQuery = HibernateSessionFactory.getSession().createSQLQuery(sql);
            @SuppressWarnings("unchecked")
            List<Object[]> list = sqlQuery.list();
            for(Object[] obj : list){
                vis.add(getPortalVI(obj));
            }
            res = vis.toArray(new PortalVI[0]);
            
            sql = "select " + countField + " from plportalvi vi where " + where + " ";
            
            sqlQuery = HibernateSessionFactory.getSession().createSQLQuery(sql);
            
            List<BigDecimal> temp = sqlQuery.list();
            if (temp.size() > 0 && temp.get(0) != null)
                total.value = temp.get(0).intValue();
            else
                total.value = 0;
            
        }catch(Exception ex){
            ex.printStackTrace();
        }finally{
        }
        return res;
    }
    private PortalVI getPortalVI(Object[] obj) throws SQLException{
        PortalVI vi = new PortalVI();
        vi.id = (String) (obj[0] == null ? "" : obj[0]);
        vi.typeName = (String) (obj[1] == null ? "" : obj[1]);
        vi.viName = (String) (obj[2] == null ? "" : obj[2]);
        vi.viType = Short.valueOf((obj[3] == null ? "0" : obj[3].toString()));
        vi.typeFlag = ((BigDecimal) (obj[4] == null ? "" : obj[4])).shortValue();
        return vi;
    }
 
 
    /**
     * 根据OID级联删除表单
     * @param oids 表单 oids
     * @return
     * @throws Throwable
     */
    public boolean deletePagePortalVIForCascade(String[] oids) throws Throwable {
        //TODO
        return false;
    }
 
    /**
     * 根据类型名和视图名获取视图
     * @param typeName
     * @param viName
     * @return
     * @throws Throwable 
     */
    public PortalVIEntity getPortalVIEntityByTypeNameAndVIName(String typeName,
            String viName) throws Throwable {
        try{
            PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
            
            PortalVIEntity obj = impl.findEntity("from PortalVIEntity where typeName = '" + typeName
                    + "' and viName = '" + viName + "'");
            return obj;
        }catch(Throwable e){
            throw e;
        }
    }
    
    /**
     * 根据业务类型名称和代号模糊查询符合要求的表单定义
     * @param viName
     * @param typeName
     * @return
     * @throws Throwable
     */
    public PortalVI[] getPortalVIBySymbolAndTypeName(String viName,
            String typeName) throws Throwable {
        try{
            PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
            
            List<PortalVIEntity> list = impl.findEntities("from PortalVIEntity where typeName = '" + typeName
                    + "' and viName like '%" + viName + "%'");
            if(list == null || list.size() < 0){
                return new PortalVI[0];
            }
            List<PortalVI> list_ = new ArrayList<PortalVI>();
            for(int i = 0; i < list.size(); i++){
                PortalVI obj = ServerTool.getPortalVI(list.get(i));
                if(obj != null){
                    list_.add(obj);
                }
            }
            return list_.toArray(new PortalVI[0]);
        }catch(Throwable e){
            throw e;
        }
    }
    
    /**
     * @author lmh,20150805
     * 获取所有结果集，缓存使用
     * @return
     */
    public PortalVI[] getAllPortalVI() throws Throwable{
        try{
            PortalVIEntityDaoImpl impl = new PortalVIEntityDaoImpl();
            List<PortalVIEntity> list = impl.findEntities("select p from PortalVIEntity p ");
            if(list == null || list.size() < 0){
                return new PortalVI[0];
            }
            List<PortalVI> list_ = new ArrayList<PortalVI>();
            for(int i = 0; i < list.size(); i++){
                PortalVI obj = ServerTool.getPortalVI(list.get(i));
                if(obj != null){
                    list_.add(obj);
                }
            }
            return list_.toArray(new PortalVI[0]);
        }catch (Throwable e) {
            throw e;
        }
    }
}