basemanager.java

本文论述了一个前台笔记本销售系统的开发过程

package com.set.appframe.business;

import java.math.BigDecimal;
import java.sql.Date;
import java.util.Iterator;
import java.util.List;

import com.set.appframe.data.GenericValueObject;
import com.set.appframe.data.SearchResult;
import com.set.appframe.exception.SystemException;
import com.set.appframe.persistence.hibernate.BaseDAOHibernate; //import com.set.crm.utils.TrendCRMLogger;
import com.set.db.DBAccessException;
import com.set.db.DBAccessHelper; //import com.set.system.business.DataChgLogMgr;
//import com.set.system.model.DataChgLogVO;
import com.set.utils.Converter;

/**
 * Base class for Business Services - use this class for utility methods.
 * 
 */
public class BaseManager {
	protected BaseDAOHibernate entityDAO;

	// TrendCRMLogger filelog = new TrendCRMLogger("BaseManager");

	public void setEntityDAO(BaseDAOHibernate entityDAO) {
		this.entityDAO = entityDAO;
	}

	protected Object getVOByID(String id, Class voClass, Class poClass)
			throws SystemException {
		Object o = null;
		try {
			Object po = entityDAO.getObject(id, poClass);
			if (null != po) {
				o = voClass.newInstance();
				Converter.converPO2VO(po, o);
			} else {
				throw new SystemException("error.recordnotexists");
			}
		} catch (Exception ex) {
			throw new SystemException("error.recordnotexists");
		}

		return o;
	}

	protected SearchResult baseSearch(int intPageNo, int intPageSize,
			String sqlFile, List param) throws DBAccessException {
		SearchResult result = null;

		try {
			result = DBAccessHelper.pagedQuery(sqlFile, param, intPageSize,
					intPageNo);
		} catch (Exception dbe) {
			  System.out.println("==== "+dbe.toString());
		}

		return result;
	}

	protected SearchResult baseSearch(int intPageNo, int intPageSize,
			String sqlFile, List param, List sqlStrParam)
			throws DBAccessException {
		SearchResult result = null;

		try {
			result = DBAccessHelper.pagedQuery(sqlFile, param, intPageSize,
					intPageNo, sqlStrParam);
		} catch (Exception dbe) {
			throw new DBAccessException("error.dberror", dbe);
		}

		return result;
	}

	protected SearchResult baseSearch(int intPageNo, int intPageSize,
			String sqlFile, List param, List sqlStrParam, String sOrderParam)
			throws DBAccessException {
		SearchResult result = null;

		try {
			result = DBAccessHelper.pagedQuery(sqlFile, param, intPageSize,
					intPageNo, sqlStrParam, sOrderParam);
		} catch (Exception dbe) {
            System.out.println("==== "+dbe.toString());
		}

		return result;
	}

	// LZQ 添加排序参数sOrderParam，重载baseSearch方法
	protected SearchResult baseSearch(int intPageNo, int intPageSize,
			String sqlFile, List param, String sOrderParam)
			throws DBAccessException {
		SearchResult result = new SearchResult();

		try {
			result = DBAccessHelper.pagedQuery(sqlFile, param, intPageSize,
					intPageNo, sOrderParam);
		} catch (Exception dbe) {
			dbe.printStackTrace();
			throw new DBAccessException("error.dberror", dbe);
		}

		return result;
	}

	/**
	 * get a bean specificed in a xml file from spring bean factory
	 * 
	 * @param name
	 *            String
	 * @return Object
	 * @author zhengbh history : modified by zhifeng, change the implementation
	 *         of getBean() 2004-11-11
	 */
	public Object getBean(String name) throws SystemException {
		return SpringBeanFactory.getInstance().getBean(name);
	}

	// public void delete(GenericValueObject vo)throws SystemException {return
	// ;}
	public void unDelete(GenericValueObject vo) throws SystemException {
		return;
	}

	public void remove(GenericValueObject vo) throws SystemException {
		return;
	}

	// protected void createLog(List v, String chgType, String tableName,
	// String pkFieldName, String pkFieldValue, String createdBy) {
	// Iterator it = v.iterator();
	// while (it.hasNext()) {
	// GenericValueObject gvo = (GenericValueObject) it.next();
	// DataChgLogVO dvo = new DataChgLogVO();
	// dvo.setChgtype(chgType);
	// dvo.setTablename(tableName);
	// dvo.setColumnname(gvo.getItemString("COLUMNNAME"));
	// dvo.setFromvalue(gvo.getItemString("FROMVALUE"));
	// dvo.setTovalue(gvo.getItemString("TOVALUE"));
	// dvo.setPkfieldname(pkFieldName);
	// dvo.setPkfieldvalue(pkFieldValue);
	// dvo.setCreatedby(createdBy);
	// try {
	// DataChgLogMgr dmgr = (DataChgLogMgr) SpringBeanFactory
	// .getInstance().getBean("DataChgLogMgr");
	// dmgr.create(dvo);
	// } catch (Exception e) {
	// e.printStackTrace();
	// }
	// }
	// }

	/** check function for data change log* */
	/** return null means the Two Value equals* */
	/**
	 * return String value means the Two Value not equals,return the String of
	 * entityValue*
	 */
	protected GenericValueObject checkInt(int entityValue, String voValue,
			String columnName) throws Exception {
		GenericValueObject returnGvo = null;
		try {
			int intValue = 0;
			if (null != voValue && !"".equals(voValue)) {
				intValue = Integer.parseInt(voValue);
			}
			if (entityValue != intValue) {
				returnGvo = new GenericValueObject();
				returnGvo.add("COLUMNNAME", columnName);
				returnGvo.add("FROMVALUE", String.valueOf(entityValue));
				returnGvo.add("TOVALUE", voValue);
			}
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}
		return returnGvo;
	}

	protected GenericValueObject checkDouble(double entityValue,
			String voValue, String columnName) throws Exception {
		GenericValueObject returnGvo = null;
		try {
			double doubleValue = 0;
			if (null != voValue && !"".equals(voValue)) {
				doubleValue = Double.parseDouble(voValue);
			}
			if (entityValue != doubleValue) {
				returnGvo = new GenericValueObject();
				returnGvo.add("COLUMNNAME", columnName);
				returnGvo.add("FROMVALUE", String.valueOf(entityValue));
				returnGvo.add("TOVALUE", voValue);
			}
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}
		return returnGvo;
	}

	protected GenericValueObject checkBigDecimal(BigDecimal entityValue,
			String voValue, String columnName) throws Exception {
		GenericValueObject returnGvo = null;
		BigDecimal decimalValue = new BigDecimal(0);
		try {
			if (null != voValue && !"".equals(voValue)) {
				decimalValue = new BigDecimal(voValue);
			}
			if (null == entityValue) {
				if (null != voValue && !"".equals(voValue)) {
					returnGvo = new GenericValueObject();
					returnGvo.add("COLUMNNAME", columnName);
					returnGvo.add("FROMVALUE", "");
					returnGvo.add("TOVALUE", voValue);
				}
			} else {
				if (!entityValue.equals(decimalValue)) {
					returnGvo = new GenericValueObject();
					returnGvo.add("COLUMNNAME", columnName);
					returnGvo.add("FROMVALUE", String.valueOf(entityValue));
					returnGvo.add("TOVALUE", voValue);
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}
		return returnGvo;
	}

	protected GenericValueObject checkFloat(float entityValue, String voValue,
			String columnName) throws Exception {
		GenericValueObject returnGvo = null;
		try {
			float doubleValue = 0;
			if (null != voValue && !"".equals(voValue)) {
				doubleValue = Float.parseFloat(voValue);
			}
			if (entityValue != doubleValue) {
				returnGvo = new GenericValueObject();
				returnGvo.add("COLUMNNAME", columnName);
				returnGvo.add("FROMVALUE", String.valueOf(entityValue));
				returnGvo.add("TOVALUE", voValue);
			}
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}
		return returnGvo;
	}

	protected GenericValueObject checkLong(long entityValue, String voValue,
			String columnName) throws Exception {
		GenericValueObject returnGvo = null;
		try {
			long longValue = 0;
			if (null != voValue && !"".equals(voValue)) {
				longValue = Long.parseLong(voValue);
			}
			if (entityValue != longValue) {
				returnGvo = new GenericValueObject();
				returnGvo.add("COLUMNNAME", columnName);
				returnGvo.add("FROMVALUE", String.valueOf(entityValue));
				returnGvo.add("TOVALUE", voValue);
			}
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}
		return returnGvo;
	}

	protected GenericValueObject checkString(String entityValue,
			String voValue, String columnName) throws Exception {
		GenericValueObject returnGvo = null;
		try {
			if (entityValue == null) {
				if (null == voValue || "".equals(voValue)) {
					return null;
				} else {
					returnGvo = new GenericValueObject();
					returnGvo.add("COLUMNNAME", columnName);
					returnGvo.add("FROMVALUE", "");
					returnGvo.add("TOVALUE", voValue);
				}
			} else {
				if (!entityValue.equals(voValue)) {
					returnGvo = new GenericValueObject();
					returnGvo.add("COLUMNNAME", columnName);
					returnGvo.add("FROMVALUE", entityValue);
					returnGvo.add("TOVALUE", voValue);
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}
		return returnGvo;
	}

	protected GenericValueObject checkDate(Date entityValue, String voValue,
			String columnName) throws Exception {
		GenericValueObject returnGvo = null;
		try {
			if (null == entityValue) {
				if (null == voValue || "".equals(voValue)) {
					return null;
				} else {
					returnGvo = new GenericValueObject();
					returnGvo.add("COLUMNNAME", columnName);
					returnGvo.add("FROMVALUE", "");
					returnGvo.add("TOVALUE", voValue);
				}
			} else {
				if (entityValue.toString().equals(voValue)) {
					return null;
				} else {
					returnGvo = new GenericValueObject();
					returnGvo.add("COLUMNNAME", columnName);
					returnGvo.add("FROMVALUE", entityValue);
					returnGvo.add("TOVALUE", voValue);
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}
		return returnGvo;
	}

	protected GenericValueObject checkTimestamp(java.sql.Timestamp entityValue,
			String voValue, String columnName) throws Exception {
		GenericValueObject returnGvo = null;
		try {
			returnGvo = new GenericValueObject();
			returnGvo.add("COLUMNNAME", columnName);
			returnGvo.add("FROMVALUE", (null == entityValue) ? "" : String
					.valueOf(entityValue));
			returnGvo.add("TOVALUE", voValue);
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}
		return returnGvo;
	}

	protected GenericValueObject check(Object entityValue, String voValue,
			String columnName) throws Exception {
		if (entityValue instanceof Integer) {
			checkInt(((Integer) entityValue).intValue(), voValue, columnName);
		} else if (entityValue instanceof Long) {
			return checkLong(((Long) entityValue).longValue(), voValue,
					columnName);
		} else if (entityValue instanceof Float) {
			return checkFloat(((Float) entityValue).floatValue(), voValue,
					columnName);
		} else if (entityValue instanceof Double) {
			return checkDouble(((Double) entityValue).doubleValue(), voValue,
					columnName);
		} else if (entityValue instanceof String) {
			return checkString((String) entityValue, voValue, columnName);
		} else if (entityValue instanceof java.sql.Date) {
			return checkDate((java.sql.Date) entityValue, voValue, columnName);
		} else if (entityValue instanceof java.sql.Timestamp) {
			return checkTimestamp((java.sql.Timestamp) entityValue, voValue,
					columnName);
		}
		return new GenericValueObject();
	}

	// protected void createLog(List v, String chgType, String tableName,
	// String pkFieldName, String pkFieldValue, String createdBy,
	// String createdDate) {
	// Iterator it = v.iterator();
	// while (it.hasNext()) {
	// GenericValueObject gvo = (GenericValueObject) it.next();
	// DataChgLogVO dvo = new DataChgLogVO();
	// dvo.setChgtype(chgType);
	// dvo.setTablename(tableName);
	// dvo.setColumnname(gvo.getItemString("COLUMNNAME"));
	// dvo.setFromvalue(gvo.getItemString("FROMVALUE"));
	// dvo.setTovalue(gvo.getItemString("TOVALUE"));
	// dvo.setPkfieldname(pkFieldName);
	// dvo.setPkfieldvalue(pkFieldValue);
	// dvo.setCreatedby(createdBy);
	// dvo.setCreateddate(createdDate);
	// try {
	// DataChgLogMgr dmgr = (DataChgLogMgr) SpringBeanFactory
	// .getInstance().getBean("DataChgLogMgr");
	// dmgr.create(dvo);
	// } catch (Exception e) {
	// e.printStackTrace();
	// }
	// }
	// }
}