fundjb.java

这是本人以前在学校时

package com.funddeal.model.bean.fund;

import java.util.Calendar;
import java.util.Collection;
import java.util.List;

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

import com.funddeal.base.PublicFunction;
import com.funddeal.base.interfaces.OperLogInterface;
import com.funddeal.model.bean.operare_log.OperareLogJB;
import com.funddeal.model.dao.fund.FundDAO;
import com.funddeal.model.pojo.custom_entity.BringNumParamEntity;
import com.funddeal.model.pojo.custom_entity.OperLogParamEntity;
import com.funddeal.model.pojo.custom_entity.SearchParamEntity;
import com.funddeal.model.pojo.fund.Fund;

public class FundJB {
	
	public static String errorMsg="";
	
	//添加基金产品
	public boolean AddFund(Fund f,OperLogParamEntity olpe)
	{
		errorMsg="";
		boolean flag=false;
		PublicFunction pf=new PublicFunction();
		
		//产生一个自动编号
		BringNumParamEntity bPE=new BringNumParamEntity();
		bPE.setPojoName("Fund");
		bPE.setPropertyId("fundNo");
		bPE.setTableName("FUND");
		String fundNo=pf.bringNumber(bPE);
//		将值设置到实体中，以便添加记录
		f.setFundNo(fundNo);
		f.setStatus("上市");
		f.setCreatedDate(Calendar.getInstance());
		
		FundDAO funddao=new FundDAO();
		try {
			String id=funddao.AddFund(f);//调用数据访问对象中的基金产品添加的方法
			if(id.length()==32){
				flag=true;
				/*
				 * 添加相应的日志
				 */
//////////////////////////////////////////////////////////////			
				olpe.setOperResultId(fundNo);				//
				olpe.setOperTableName("FUND");				//
				olpe.setOperType("添加基金记录");				//
				OperLogInterface pif=new OperareLogJB();	//
				pif.addOperareLog(olpe);					//
//////////////////////////////////////////////////////////////				
			}
		}catch(HibernateException e){
			errorMsg=e.getMessage();
			e.printStackTrace();
		}
		return flag;
	}


	// 查询基金产品
	public Fund SearchFund(String fundNo,String fundName) throws HibernateException
	{
		FundDAO fundDAO=new FundDAO();
		Fund fund=null;
		List list=fundDAO.SearchFund(fundNo,fundName);
		if(list.size()>0){
			fund=new Fund();
			fund=(Fund)list.get(0);
		}
		return fund;
	}
	
	/**
	 * 获得基金例表
	 * @return 集合对象
	 */
	public Collection searchAllFund(){
		errorMsg="";
		Collection col=null;
		PublicFunction pf=new PublicFunction();
		Query query=pf.search("from Fund as fund where fund.status='上市'");
		List list=null;
		try {
			if(query.list().size()<=0){
				if(PublicFunction.errorMsg.equals(""))
					errorMsg="没有记录";
				else
					errorMsg=PublicFunction.errorMsg;
				return col;
			}
			list=query.list();
		} catch (HibernateException e) {
			e.printStackTrace();
		}
		return list;
	}
	
	
	//修改基金产品
	public boolean UpdateFund(Fund fund,OperLogParamEntity olpe) throws HibernateException
	{
		errorMsg="";
		boolean bl=false;
		String id=fund.getFundId();
		SearchParamEntity spe=new SearchParamEntity();
		spe.setPojoName("Fund");
		spe.setPropertyName("fundId");
		spe.setValue(id);
		PublicFunction pf=new PublicFunction();
		Query query = pf.search(spe);
		if( query.list().size()<=0){
			if(PublicFunction.errorMsg.equals(""))
				errorMsg="主键为" + id + "的此记录不存在";
			else
				errorMsg=PublicFunction.errorMsg;
			return false;
		}
		Fund f=(Fund)query.list().get(0);
		String fundNo=f.getFundNo();
		Calendar calendar=f.getCreatedDate();
		fund.setFundNo(fundNo);
		fund.setCreatedDate(calendar);
		FundDAO funddao=new FundDAO();
		bl= funddao.UpdateFund(fund);
		if(!bl){
			errorMsg=FundDAO.errorMsg;
			return false;
		}
		/*
		 * 添加相应的日志
		 */
//////////////////////////////////////////////////////
		olpe.setOperResultId(fund.getFundNo());		//
		olpe.setOperTableName("FUND");				//
		olpe.setOperType("修改基金产品信息");			//
		OperLogInterface pif=new OperareLogJB();	//
		pif.addOperareLog(olpe);					//
//////////////////////////////////////////////////////
		return true;
	}
}