proproxy.java

实现统一的人员日志管理系统管理后台

package com.tb.log.model.proxy;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.tb.log.factory.OracleDAOFactory;
import com.tb.log.model.bo.vo.dept.ShowDeptVo;
import com.tb.log.model.bo.vo.pro.EditProVo;
import com.tb.log.model.bo.vo.pro.ProVo;
import com.tb.log.model.bo.vo.pro.ShowProVo;
import com.tb.log.model.dao.DAOFactory;
import com.tb.log.model.dao.idao.IProDAO;
import com.tb.log.model.dao.idao.IUserDAO;
import com.tb.log.model.po.Pro;
import com.tb.log.system.SystemException;
import com.tb.log.util.pages.PageBean;
import com.tb.log.util.tools.GetProSql;
import com.tb.log.util.tools.ToolKit;

public class ProProxy extends Proxy {

	@Override
	public boolean add(Object obj) throws SystemException{
		
		boolean b = false;
		ProVo proVo = (ProVo)obj;
		IProDAO iDao = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getProDAO();
		Connection conn = OracleDAOFactory.getConnection();
		Pro pro = new Pro(proVo.getPro_id(),proVo.getPro_category() ,proVo.getPro_name() ,proVo.getPlan_start_date() ,
				proVo.getPlan_stop_date(),proVo.getPro_desc(),proVo.getPro_state(),
				proVo.getStart_date() ,proVo.getStop_date());
		try {
			try {
				
				conn.setAutoCommit(false);
				iDao.save(pro);
				conn.commit();
				conn.setAutoCommit(true);
				b = true;
			} catch (SQLException e) {
				try {
					conn.rollback();
				} catch (SQLException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
				e.printStackTrace();
			}
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return b;
	}

	@Override
	public Object get(int id) throws SystemException{
		Map map = new HashMap();
		IProDAO ipro = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getProDAO();
		IUserDAO iUser = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getUserDAO();
		Pro pro = null;
		ProVo proVo = null;
		List userList = new ArrayList();
		try {
			pro = (Pro)ipro.findById(Integer.toString(id));
			proVo = new ProVo(pro.getPro_id(),pro.getPro_category() ,pro.getPro_name() ,pro.getPlan_start_date() ,
					pro.getPlan_stop_date(),pro.getPro_desc(),pro.getPro_state(),
					pro.getStart_date() ,pro.getStop_date());
			List usersid = ipro.findById("user_id", "pro_id", proVo.getPro_id());
			System.out.println(usersid);
			userList = iUser.findById(usersid);
		} catch (SystemException e) {
			e.printStackTrace();
		}
		map.put(1, proVo);
		map.put(2, userList);
		return map;
	}

	@Override
	public Object load(int id) throws SystemException{
		// TODO Auto-generated method stub
		return null;
	}

	@Override
	public boolean modify(Object obj) throws SystemException{
		boolean b = false;
		EditProVo proVo = (EditProVo)obj;
		IProDAO iDao = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getProDAO();
		Connection conn = OracleDAOFactory.getConnection();
		Pro pro = new Pro(proVo.getPro_id(),proVo.getPro_category() ,proVo.getPro_name() ,proVo.getPlan_start_date() ,
				proVo.getPlan_stop_date(),proVo.getPro_desc(),proVo.getPro_state(),
				proVo.getStart_date() ,proVo.getStop_date());
		try {
			try {
				
				conn.setAutoCommit(false);
				iDao.update(pro);
				iDao.addUserProByUserList(pro.getPro_id(), ToolKit.StringToArray(proVo.getUsersid()));
				conn.commit();
				conn.setAutoCommit(true);
				b = true;
			} catch (SQLException e) {
				try {
					conn.rollback();
				} catch (SQLException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
				e.printStackTrace();
			}
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return b;

	}
	

	@Override
	public boolean remove(Object obj) throws SystemException{
		boolean b = false;
		ProVo proVo = (ProVo)obj;
		Pro pro = new Pro();
		pro.setPro_id(proVo.getPro_id());
		IProDAO ipro = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getProDAO();
		Connection conn = OracleDAOFactory.getConnection();
		try {
			try {
				conn.setAutoCommit(false);
				ipro.removeAll(pro);
				conn.commit();
				conn.setAutoCommit(true);
				b = true;
				//System.out.println("remove---!!!!-");
			} catch (SQLException e) {
			//	System.out.println("error in proProxy--");
				try {
					conn.rollback();
				} catch (SQLException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
				e.printStackTrace();
			}
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return b;
	}
	
	public Map findByCondition(ShowProVo showPro)throws SystemException{
		Map map = new HashMap();
		String pro_category = showPro.getPro_category();
		String start_date = showPro.getStart_date();
		String end_date = showPro.getEnd_date();
		String pro_state = showPro.getPro_state();
		String pro_name = showPro.getPro_name();
		String countSql = new GetProSql().getSql(pro_category, start_date, end_date, pro_state, pro_name);
		String pageSql = new GetProSql().toSql(pro_category, start_date, end_date, pro_state, pro_name) ;
		IProDAO ipro = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getProDAO();
	//	System.out.println("pageSql:"+pageSql);
		try {
			List proList = ipro.findByCondition(pageSql, showPro.getCurrentPage());
			PageBean pages = ipro.getCurrentPageByCondition(countSql);
			List proCateList = ipro.findProCategory(); 
			map.put(1, proList);
			map.put(2, pages);
			map.put(3, proCateList);
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return map;
	}
	
	public List getAllUser() throws SystemException{
		IUserDAO iuser = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getUserDAO();
		List userList = null;
		try {
			userList = iuser.findAll();
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return userList;
	}
	
	
	public void changeProState(ProVo proVo)throws SystemException{
		String sql = "";
		if(proVo.getPro_state().equals("已完成")){
			sql = "update t_project set stop_date='"+proVo.getStop_date()+"',pro_state='"+proVo.getPro_state()+"' where pro_id="+proVo.getPro_id();
		}else{
			sql = "update t_project set pro_state='"+proVo.getPro_state()+"' where pro_id="+proVo.getPro_id();
		}
		IProDAO ipro = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getProDAO();
		Connection conn = OracleDAOFactory.getConnection();
		System.out.println("sql:"+sql);
		try {
			try {
				conn.setAutoCommit(false);
				ipro.changeProStateBySql(sql);
				conn.commit();
				conn.setAutoCommit(true);
			} catch (SQLException e) {
				try {
					conn.rollback();
				} catch (SQLException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
				e.printStackTrace();
			}
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	
	public static void main(String[] args) {
		//System.out.println(new ProProxy().get(21));
	}
	

}