logproxy.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.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;

import com.sun.java_cup.internal.internal_error;
import com.tb.log.factory.OracleDAOFactory;
import com.tb.log.model.bo.vo.log.CheckLogVo;
import com.tb.log.model.bo.vo.log.FindLogVo;
import com.tb.log.model.bo.vo.log.LogVo;
import com.tb.log.model.bo.vo.log.ShowLogVo;
import com.tb.log.model.bo.vo.user.LoginVo;
import com.tb.log.model.dao.DAOFactory;
import com.tb.log.model.dao.idao.IDeptDAO;
import com.tb.log.model.dao.idao.ILogDAO;
import com.tb.log.model.dao.idao.IProDAO;
import com.tb.log.model.dao.idao.IRoleDAO;
import com.tb.log.model.dao.idao.IUserDAO;
import com.tb.log.model.po.Dept;
import com.tb.log.model.po.Log;
import com.tb.log.model.po.Pro;
import com.tb.log.model.po.User;
import com.tb.log.system.SystemException;
import com.tb.log.util.pages.PageBean;
import com.tb.log.util.tools.CheckLogSql;
import com.tb.log.util.tools.LogSql;
import com.tb.log.util.tools.ToolKit;

public class LogProxy extends Proxy{

	@Override
	public boolean add(Object obj) throws SystemException{
		LogVo logVo = (LogVo)obj;
		Log log = new Log(logVo.getLog_id() ,logVo.getUser_id() ,logVo.getPro_id() ,logVo.getLog_date(),logVo.getWrite_date(),
				logVo.getLog_desc() ,logVo.getLog_plan(),logVo.getSum_question() ,logVo.getLog_state());
		ILogDAO ilog = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getLogDAO();
		Connection conn = OracleDAOFactory.getConnection();
		try {
			try {
				conn.setAutoCommit(false);
				ilog.save(log);
				conn.commit();
				conn.setAutoCommit(true);
			} catch (SQLException e) {
				try {
					conn.rollback();
				} catch (SQLException e1) {
					e1.printStackTrace();
				}
				e.printStackTrace();
			}
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return true;
	}

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

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

	@Override
	public boolean modify(Object obj) throws SystemException{
		LogVo logVo = (LogVo)obj;
		Log log = new Log(logVo.getLog_id() ,logVo.getUser_id() ,logVo.getPro_id() ,logVo.getLog_date(),logVo.getWrite_date(),
				logVo.getLog_desc() ,logVo.getLog_plan(),logVo.getSum_question() ,logVo.getLog_state());
		ILogDAO ilog = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getLogDAO();
		Connection conn = OracleDAOFactory.getConnection();
		try {
			try {
				conn.setAutoCommit(false);
				ilog.update(log);
				conn.commit();
				conn.setAutoCommit(true);
			} catch (SQLException e) {
				try {
					conn.rollback();
				} catch (SQLException e1) {
					e1.printStackTrace();
				}
				e.printStackTrace();
			}
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return true;
	}

	@Override
	public boolean remove(Object obj) throws SystemException{
		LogVo logVo = (LogVo)obj;
		Log log = new Log();
		log.setLog_id(logVo.getLog_id());
		ILogDAO ilog = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getLogDAO();
		Connection conn = OracleDAOFactory.getConnection();
		try {
			try {
				conn.setAutoCommit(false);
				ilog.remove(log);
				conn.commit();
				conn.setAutoCommit(true);
			} catch (SQLException e) {
				try {
					conn.rollback();
				} catch (SQLException e1) {
					e1.printStackTrace();
				}
				e.printStackTrace();
			}
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return true;
	}
	
	public List getProList(int user_id)throws SystemException{
		List proList = null;
		ILogDAO ilog = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getLogDAO();
		IProDAO ipro = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getProDAO();
		try {
		//s	Set set = ipro.findProidByUserid(Integer.toString(user_id));
			List list = ipro.findById("pro_id", "user_id", user_id);
			proList = ipro.findById(list);
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return proList;
	}
	
	
	public Map showLog(FindLogVo log)throws SystemException{
		Map map = new HashMap();
		String pageSql = new LogSql().getPageSql(log.getStart_date(), log.getEnd_date(), log.getPro_id(),log.getUser_id());
		String countSql = new LogSql().getCountSql(log.getStart_date(), log.getEnd_date(), log.getPro_id(),log.getUser_id());
		ILogDAO ilog = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getLogDAO();
		IProDAO ipro = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getProDAO();
		//System.out.println("pageSql:"+pageSql);
		//System.out.println("countSql:"+countSql);
		List list = new ArrayList();
		ShowLogVo showLog = null;
		try {
			
			
			//条件查询日志列表，遍历列表取proid查询项目信息，放入showLogVo，放入list列表
			List logList = ilog.findByCondition(pageSql, log.getCurrentPage());
			for (Iterator iterator = logList.iterator(); iterator.hasNext();) {
				Log lg = (Log) iterator.next();
				Pro pro =(Pro) ipro.findById(Integer.toString(lg.getPro_id()));
				showLog = new ShowLogVo(lg.getLog_id(), lg.getUser_id(), lg.getLog_date(), lg.getLog_desc(),
						lg.getLog_plan(), lg.getLog_state(), pro.getPro_name());
				//System.out.println("showLog:"+showLog);
				list.add(showLog);
			}
			PageBean page = ilog.getCurrentPageByCondition(countSql);
			List proNameList = ipro.findProName(); 
			map.put(1, list);
			map.put(2,page);
			map.put(3, proNameList);
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return map;
	}
	
	public Map getEdit(String id)throws SystemException{
		Map map = new HashMap();
		ILogDAO ilog = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getLogDAO();
		IProDAO ipro = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getProDAO();
		try {
			Log log = (Log)ilog.findById(id);
			List proList = ipro.findProName();
			map.put(1, log);
			map.put(2, proList);
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return map;
	}
	
	
	public Map getCheck(CheckLogVo log)throws SystemException{
		Map map = new HashMap();
		
		ILogDAO ilog = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getLogDAO();
		IDeptDAO idept = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getDeptDAO();
		IProDAO ipro = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getProDAO();
		IUserDAO iuser = DAOFactory.getDAOFactory(DAOFactory.ORACLE).getUserDAO();
		
	//	System.out.println("pageSql:"+pageSql);
	//	System.out.println("countSql:"+countSql);
		List loglist = null;
		ShowLogVo showLog = null;
		try {
			//System.out.println("id:"+log.getUser_id());
			//获得用户权限列表
			User user = iuser.findById(Integer.toString(log.getUser_id()));
			String deptid = user.getDeptid();
			String supper_id ="11";
			if(user.getGrade().equals("班长")){
				supper_id = idept.findById(deptid).getSupper_id();				
			}else if(user.getGrade().equals("组长")){
				supper_id = deptid;
			}
			List deptlist = null;
			if(user.getGrade().equals("管理员")){
				deptlist = idept.findIdByGrade("3");
			}else{
				deptlist = idept.findSubidById(Integer.parseInt(supper_id));
			}
			//权限集合组串
			String str = ToolKit.ListToString(deptlist);
		//	System.out.println("deptList:"+deptList);
		//	System.out.println("Str:"+str);
			String pageSql = new CheckLogSql().getPageSql(log.getStart_date(), log.getEnd_date(), log.getPro_id(),log.getLog_state(),log.getUser_name(),str);
			String countSql = new CheckLogSql().getCountSql(log.getStart_date(), log.getEnd_date(), log.getPro_id(),log.getLog_state(),log.getUser_name(),str);
		//	System.out.println(pageSql);
			//条件查询日志列表，遍历列表取proid查询项目信息，放入showLogVo，放入list列表
			loglist = ilog.findCheckByCondition(pageSql, log.getCurrentPage());
		//	System.out.println("logList:"+logList);
			PageBean page = ilog.getCurrentPageByCondition(countSql);
			List proNameList = ipro.findProName(); 
			map.put(1, loglist);
			map.put(2,page);
			map.put(3, proNameList);
		} catch (SystemException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return map;
	}

}