configbringnumberjb.java

这是本人以前在学校时

package com.funddeal.model.bean.config_bring_number;

import java.util.TreeSet;

import net.sf.hibernate.HibernateException;
import net.sf.hibernate.Query;

import com.funddeal.base.PublicFunction;
import com.funddeal.base.interfaces.OperLogInterface;
import com.funddeal.base.interfaces.PaginationInterface;
import com.funddeal.base.pagination.PageParaPOJO;
import com.funddeal.base.pagination.PaginationCs;
import com.funddeal.model.bean.operare_log.OperareLogJB;
import com.funddeal.model.dao.config_bring_number.ConfigBringNumberDAO;
import com.funddeal.model.pojo.config_bring_number.ConfigBringNumber;
import com.funddeal.model.pojo.custom_entity.BringNumParamEntity;
import com.funddeal.model.pojo.custom_entity.OperLogParamEntity;
import com.funddeal.model.pojo.custom_entity.SearchParamEntity;

public class ConfigBringNumberJB {
	public static String errorMsg;
	public static TreeSet<String> tsTableName;
	public ConfigBringNumberJB()
	{
		tsTableName=new TreeSet<String>();
		tsTableName.add("FUND");
		tsTableName.add("SALES");
		tsTableName.add("CLIENT");
		tsTableName.add("FINANCIAL_ACCOUNT");
		tsTableName.add("FUND_ACCOUNT");
		tsTableName.add("OPERARE_LOG");
		tsTableName.add("CONFIG_BRING_NUMBER");
	}
	/**
	 * 添加配置
	 * @param cbn：实体对象
	 * @return True|False(成功与否)
	 */
	public boolean addConfigBringNumJB(ConfigBringNumber cbn,OperLogParamEntity olpe){
		errorMsg="";
		String id="";
		String tableName=cbn.getTableName();
		if(!tsTableName.contains(tableName)){
			errorMsg="此数据库表名不存在！";
			return false;
		}
		SearchParamEntity spe=new SearchParamEntity();
		spe.setPojoName("ConfigBringNumber");
		spe.setPropertyName("tableName");
		spe.setValue(tableName);
		PublicFunction pf=new PublicFunction();
		if(pf.exist(spe)){
			if(PublicFunction.errorMsg.equals(""))
				errorMsg="该表的自动编号生成配置已经存在!";
			else
				errorMsg=PublicFunction.errorMsg;
			return false;
		}
		
//		产生一个自动编号
		BringNumParamEntity bPE=new BringNumParamEntity();
		bPE.setPojoName("ConfigBringNumber");
		bPE.setPropertyId("numberNo");
		bPE.setTableName("CONFIG_BRING_NUMBER");
		String numberNo=pf.bringNumber(bPE);
		
		cbn.setNumberNo(numberNo);
		
		ConfigBringNumberDAO cbnDAO=new ConfigBringNumberDAO();
		try {
			id=cbnDAO.addConfigBringNum(cbn);
		} catch (HibernateException e) {
			errorMsg="调用会话工厂对象保存数据时出现异常："+ e.getMessage();
		}
		if(id.length()==32){
			/*
			 * 添加相应的日志
			 */
//////////////////////////////////////////////////////////////
			olpe.setOperResultId(numberNo);				 	//
			olpe.setOperTableName("CONFIG_BRING_NUMBER");	//				
			olpe.setOperType("添加编号配置");					//
			OperLogInterface pif=new OperareLogJB();		//
			pif.addOperareLog(olpe);						//
//////////////////////////////////////////////////////////////
			return true;
		}else{
			return false;
		}
	}
	
	/**
	 * 删除配置
	 * @param cbn：实体对象
	 * @return True|False(成功与否)
	 */
	public boolean delConfigBringNumJB(String numberId,OperLogParamEntity olpe){
		errorMsg="";
		if(numberId==null || numberId.equals("")){
			errorMsg="非法的条件参数!";
			return false;
		}
		ConfigBringNumber cbn;
		SearchParamEntity spe=new SearchParamEntity();
		spe.setPojoName("ConfigBringNumber");
		spe.setPropertyName("numberId");
		spe.setValue(numberId);
		PublicFunction pf=new PublicFunction();
		Query query= pf.search(spe);
		try {
			if(query.list().size()<=0){
				if(PublicFunction.errorMsg.equals(""))
					errorMsg="该记录不存在";
				else
					errorMsg=PublicFunction.errorMsg;
				return false;
			}
			cbn=new ConfigBringNumber();
			cbn=(ConfigBringNumber)query.list().get(0);
		} catch (HibernateException e){
			errorMsg=e.getMessage();
			return false;
		}
		ConfigBringNumberDAO cbnDAO=new ConfigBringNumberDAO();
		if(cbnDAO.delConfigBringNum(cbn)){
			/*
			 * 添加相应的日志
			 */
//////////////////////////////////////////////////////////////
			olpe.setOperResultId(cbn.getNumberNo());		//
			olpe.setOperTableName("CONFIG_BRING_NUMBER");	//							
			olpe.setOperType("删除编号配置");			//
			OperLogInterface pif=new OperareLogJB();		//
			pif.addOperareLog(olpe);						//
//////////////////////////////////////////////////////////////			
			return true;
		}else{
			errorMsg=ConfigBringNumberDAO.errorMsg;
			return false;
		}
	}
	
	
	/**
	 * 修改配置
	 * @param cbn：实体对象
	 * @return True|False(成功与否)
	 */
	public boolean updateConfigBringNumJB(ConfigBringNumber cbn,OperLogParamEntity olpe){
		errorMsg="";
		String tableName=cbn.getTableName();
		if(tableName==null){
			errorMsg="传值失败！";
			return false;
		}
		if(!tsTableName.contains(tableName)){
			errorMsg="此数据库表名不存在！";
			return false;
		}
		SearchParamEntity spe=new SearchParamEntity();
		spe.setPojoName("ConfigBringNumber");
		spe.setPropertyName("tableName");
		spe.setValue(tableName);
		PublicFunction pf=new PublicFunction();
		if(!pf.exist(spe)){
			if(PublicFunction.errorMsg.equals(""))
				errorMsg="该表的自动生成编号配置不存在!";
			else
				errorMsg=PublicFunction.errorMsg;
			return false;
		}
		ConfigBringNumberDAO cbnDAO=new ConfigBringNumberDAO();
		boolean bl=false;
		bl = cbnDAO.updateConfigBringNum(cbn);
		if(bl){
			/*
			 * 添加相应的日志
			 */
//////////////////////////////////////////////////////////////
			olpe.setOperResultId(cbn.getNumberNo());		//
			olpe.setOperTableName("CONFIG_BRING_NUMBER");	//							
			olpe.setOperType("修改编号配置");			//
			OperLogInterface pif=new OperareLogJB();		//
			pif.addOperareLog(olpe);						//
//////////////////////////////////////////////////////////////
			return true;
		}else{
			errorMsg=ConfigBringNumberDAO.errorMsg;
			return false;
		}
	}
	
	/**
	 * 得到配置记录数据集(带分页)
	 * @param pageIndex：当前页
	 * @param pageSize：每页的记录条数
	 * @return PageParaPOJO：分页对象实体
	 */
	public PageParaPOJO searchConfigBringNumJB(int pageIndex,int pageSize){
		errorMsg="";
		PageParaPOJO pp=new PageParaPOJO();
		PaginationInterface pIf=new PaginationCs();
		pp=pIf.searchConfigBringNumJB(pageIndex,pageSize,"ConfigBringNumber");
		errorMsg=PaginationCs.errorMsg;
		return pp;
	}
	
	/**
	 * 转发页
	 * @param numberId
	 * @return
	 */
	public ConfigBringNumber forwardUpdate(String numberId){
		errorMsg="";
		ConfigBringNumber cbn=null;
		SearchParamEntity spe=new SearchParamEntity();
		spe.setPojoName("ConfigBringNumber");
		spe.setPropertyName("numberId");
		spe.setValue(numberId);
		PublicFunction pf=new PublicFunction();
		Query query = pf.search(spe);
		try {
			int cut= query.list().size();
			if(cut<=0){
				if(PublicFunction.errorMsg.equals(""))
					errorMsg=PublicFunction.errorMsg;
				else
					errorMsg="出现错误：没有找到编号所对应的记录！";
				return cbn;
			}
			cbn=new ConfigBringNumber();
			cbn=(ConfigBringNumber)query.list().get(0);
		} catch (HibernateException e) {
			errorMsg=e.getMessage();
		}
		return cbn;
	}
}