salesbean.java

这是本人以前在学校时

package com.funddeal.model.bean.sales;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Calendar;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;

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.dao.sales.SalesDAO; 
import com.funddeal.model.pojo.custom_entity.LoginUserInfoEntity;
import com.funddeal.model.pojo.custom_entity.OperLogParamEntity;
import com.funddeal.model.pojo.custom_entity.SearchParamEntity;
import com.funddeal.model.pojo.sales.Sales;

public class SalesBean {
	public static String errorMsg="";
	SalesDAO salesDAO;
	
	/**
	 * 添加用户
	 * @param sales
	 * @param olpe
	 * @return
	 * @throws HibernateException
	 */
	public boolean Add(Sales sales,OperLogParamEntity olpe) throws HibernateException{
		
		PublicFunction pf=new PublicFunction();
		String salesno=pf.bringNumber("SALES");
		sales.setCreatedDate(Calendar.getInstance());
		sales.setSalesNo(salesno);
		sales.setUserType("柜台操作员");
		
		salesDAO=new SalesDAO();
		String str=salesDAO.getSessionAdd(sales);
		if(str.length()==32){
			/*
			 * 添加相应的日志
			 */
//////////////////////////////////////////////////////////////
			olpe.setOperResultId(sales.getSalesNo());		//
			olpe.setOperTableName("SALES");					//				
			olpe.setOperType("添加操作人员");					//
			OperLogInterface pif=new OperareLogJB();		//
			pif.addOperareLog(olpe);						//
//////////////////////////////////////////////////////////////			
			return true;
		}else{
			errorMsg="添加失败!";
			return false;
		}
	}

	/**
	 * 用户登录
	 * @param sales
	 * @param request
	 * @return
	 * @throws HibernateException
	 */
	public boolean Select(Sales sales,HttpServletRequest request) throws HibernateException
	{
		Collection col=null;
		salesDAO=new SalesDAO();
		String name=sales.getUserName();
		String pwd=sales.getPassWord();
		String userType="柜台操作员";
		int cut= name.indexOf("@");
		if(cut!=-1){
			String str=name.substring(cut+1);
			name=name.substring(0,cut);
			if(str.equals("administrator")){
				userType="系统管理员";
			}
			System.out.println(str);
		}
		String str="from Sales sales where sales.userName='";
		str+=name +"' and sales.passWord='";
		str+=pwd +"' and sales.userType='"+ userType +"'";
		col=salesDAO.selectSales(str);
		if(col==null){
			return false;
		}
		ArrayList al=(ArrayList)col;
		if(al.size()<=0){
			return false;
		}
		sales=(Sales)al.get(0);
		
		LoginUserInfoEntity luife=new LoginUserInfoEntity();
		luife.setOperMachineAddress(request.getRemoteAddr());
		luife.setSalesNo(sales.getSalesNo());
		luife.setLoginDateTime(Calendar.getInstance());
		luife.setUserName(sales.getUserName());
		luife.setUserType(userType);
		HttpSession session=request.getSession(true);
		session.setAttribute("LoginUserInfoEntity",luife);
		
		return true;
	}
	
	/**
	 * 修改
	 * @param sales
	 * @return
	 * @throws HibernateException
	 */
	public boolean Update(Sales sales,OperLogParamEntity olpe) throws HibernateException{
		errorMsg="";
		if(sales==null){
			errorMsg="参数无效";
			return false;
		}
		if(sales.getSalesNo().equals("")|| sales.getUserName().equals("") || sales.getRealName().equals("") || sales.getPassWord().equals("")){
			errorMsg="参数无效";
			return false;
		}
		if(sales.getSex().equals("")){
			sales.setSex("男");
		}
		Sales salesOld=this.exit(sales.getSalesNo());
		if(salesOld==null){
			errorMsg="需更新的记录不存在";
			return false;
		}
		salesOld.setUserName(sales.getUserName());
		salesOld.setRealName(sales.getRealName());
		salesOld.setPassWord(sales.getPassWord());
		salesOld.setSex(sales.getSex());
		salesDAO=new SalesDAO();
		if(salesDAO.getSessionUpdate(salesOld)){
			/*
			 * 添加相应的日志
			 */
//////////////////////////////////////////////////////////////
			olpe.setOperResultId(sales.getSalesNo());		//
			olpe.setOperTableName("SALES");					//				
			olpe.setOperType("修改操作人员");					//
			OperLogInterface pif=new OperareLogJB();		//
			pif.addOperareLog(olpe);						//
//////////////////////////////////////////////////////////////				
			return true;
		}else{
			return false;
		}
	}
	
	public Sales exit(String str){
		try {
			salesDAO=new SalesDAO();
			String ss="from Sales sales where sales.salesNo='"+ str +"'";
			Sales sales=salesDAO.select(ss);
			return sales;
		} catch (HibernateException e) {
			e.printStackTrace();
			return null;
		}
	}
	
	/**
	 * 得到配置记录数据集(带分页)
	 * @param pageIndex：当前页
	 * @param pageSize：每页的记录条数
	 * @return PageParaPOJO：分页对象实体
	 */
	public PageParaPOJO salesManagerJB(int pageIndex,int pageSize){
		errorMsg="";
		PageParaPOJO pp=new PageParaPOJO();
		PaginationInterface pIf=new PaginationCs();
		pp=pIf.searchConfigBringNumJB(pageIndex,pageSize,"Sales");
		errorMsg=PaginationCs.errorMsg;
		return pp;
	}
	
	/**
	 * 加载某一条记录到页面上
	 * @return
	 */
	public Sales londSales(String salesId){
		errorMsg="";
		Sales sales=null;
		SearchParamEntity spe=new SearchParamEntity();
		spe.setPojoName("Sales");
		spe.setPropertyName("salesId");
		spe.setValue(salesId);
		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 sales;
			}
			sales=new Sales();
			sales=(Sales)query.list().get(0);
		} catch (HibernateException e) {
			errorMsg=e.getMessage();
		}
		return sales;
	}
	
	
	/**
	 * 删除配置
	 * @param cbn：实体对象
	 * @return True|False(成功与否)
	 */
	public boolean delSalesJB(String salesId,OperLogParamEntity olpe){
		errorMsg="";
		if(salesId==null || salesId.equals("")){
			errorMsg="非法的条件参数!";
			return false;
		}
		Sales sales;
		SearchParamEntity spe=new SearchParamEntity();
		spe.setPojoName("Sales");
		spe.setPropertyName("salesId");
		spe.setValue(salesId);
		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;
			}
			sales=new Sales();
			sales=(Sales)query.list().get(0);
		} catch (HibernateException e){
			errorMsg=e.getMessage();
			return false;
		}
		SalesDAO sDAO;
		try {
			sDAO = new SalesDAO();
			if(sDAO.delSales(sales)){
				/*
				 * 添加相应的日志
				 */
//////////////////////////////////////////////////////////////////
				olpe.setOperResultId(sales.getSalesNo());		//
				olpe.setOperTableName("SALES");	//							
				olpe.setOperType("删除操作员");					//
				OperLogInterface pif=new OperareLogJB();		//
				pif.addOperareLog(olpe);						//
//////////////////////////////////////////////////////////////////			
				return true;
			}else{
				errorMsg=ConfigBringNumberDAO.errorMsg;
				return false;
			}
		} catch (HibernateException e) {
			e.printStackTrace();
			errorMsg=e.getMessage();
			return false;
		}
	}
}