managerdao.java~45~

销售管理系统 随着我国国民经济的持续发展

package com.dao;

import com.tool.JDBConnection;
import java.sql.ResultSet;
import java.sql.*;
import com.domain.EmployeeVO;
import com.domain.RightVO;
import com.domain.ManagerVO;
import java.util.*;

//对员工信息的操作
public class ManagerDao {
  private JDBConnection connection = null;
  public ManagerDao() {
    connection = new JDBConnection();
    this.connection.creatConnection(); //利用构造方法调用类中的对象对数据库创建连接
  }

//对员工信息的添加操作
  public void insertManager(EmployeeVO vo) {
    String sql =
        "insert into tb_employee values('" + vo.getEm_number() + "','" +
        vo.getEm_accouts() + "','" +
        vo.getEm_password() + "','" + vo.getEm_name() + "','" + vo.getEm_sex() +
        "'," + vo.getEm_age() + ",'" + vo.getEm_birthday() + "','" +
        vo.getEm_business() + "','" + vo.getEm_school() + "')";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

//得到数据库流水号
  public Integer employeeSelectId(String number) {
    Integer em_id = Integer.valueOf("-1");
    String sql = "select * from tb_employee where em_number='" + number +
        "'";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        em_id = Integer.valueOf(rs.getString("id")); //取得数据库流水号信息
        connection.closeConnection();
      }
    }
    catch (SQLException ex) {
    }
    return em_id;
  }

//对超级员工的查询
  public ManagerVO managerSelect(String number) {
    ManagerVO manager = new ManagerVO();
    String sql = "select * from tb_manager where ma_number='" + number + "'";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        manager.setMa_id(Integer.valueOf(rs.getString(1)));
        manager.setMa_number(rs.getString(2));
        manager.setMa_manager(Integer.valueOf(rs.getString(3)));
      }
    }
    catch (SQLException ex) {
    }
    connection.closeConnection();
    return manager;
  }

//利用List集合进行条件查询
  public List employeeSelect(Integer ma_number) {
    List list = new ArrayList();
    EmployeeVO em = null;
    String sql = null;
    if (ma_number.intValue() == 0) {
      sql = "select * from tb_employee where em_number not in (select ma_number from tb_manager) order by id";
    }
    else {
      sql = "select  * from tb_employee where em_number not in (select ma_number from tb_manager where ma_manager='" +
          ma_number + "') order by id";
    }
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        em = new EmployeeVO();
        em.setEm_id(Integer.valueOf(rs.getString(1))); //取得数据库流水号信息
        em.setEm_number(rs.getString(2)); //取得员工的编号信息
        em.setEm_accouts(rs.getString(3)); //取得员工的账号信息
        em.setEm_password(rs.getString(4)); //取得员工的密码信息
        em.setEm_name(rs.getString(5)); //取得员工的姓名信息
        em.setEm_sex(rs.getString(6)); //取得员工性别信息
        em.setEm_age(Integer.valueOf(rs.getString(7))); //取得员工的年龄信息
        em.setEm_birthday(rs.getString(8)); //取得员工出生日期
        em.setEm_business(rs.getString(9)); //取得员工职务信息
        em.setEm_school(rs.getString(10)); //取得员工的毕业学校信息
        list.add(em);
      }
    }
    catch (SQLException ex) {
    }
    connection.closeConnection();
    return list;
  }

//对员工信息的条件查询
  public EmployeeVO employeeCheck(String em_account) {
    EmployeeVO em = new EmployeeVO();
    String sql = "select * from tb_employee where em_accouts='" + em_account +
        "'";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        em.setEm_id(Integer.valueOf(rs.getString(1))); //取得数据库流水号信息
        em.setEm_number(rs.getString(2)); //取得员工的编号信息
        em.setEm_accouts(rs.getString(3)); //取得员工的账号信息
        em.setEm_password(rs.getString(4)); //取得员工的密码信息
        em.setEm_name(rs.getString(5)); //取得员工的姓名信息
        em.setEm_sex(rs.getString(6)); //取得员工性别信息
        em.setEm_age(Integer.valueOf(rs.getString(7))); //取得员工的年龄信息
        em.setEm_birthday(rs.getString(8)); //取得员工出生日期
        em.setEm_business(rs.getString(9)); //取得员工职务信息
        em.setEm_school(rs.getString(10)); //取得员工的毕业学校信息
        connection.closeConnection();
      }
    }
    catch (SQLException ex) {
    }
    return em;
  }

  //修改员工编号的操作
  public void emNumberUpdate(Integer id) {
    String sql = "update tb_employee set em_number='EM-" + id + "' where id='" +
        id + "'";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

  //对员工权限表的更新操作
  public void insertRight(Integer id) {
    String sql = "insert into tb_right values('EM-" + id +
        "',0,0,0,0,0,0,0)";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

//利用List集合得到所有员工权利的信息
  public List getRightList() {
    List list = new ArrayList();
    RightVO right = null;
    String sql = "select * from tb_right where rt_number not in (select ma_number from tb_manager)";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        right = new RightVO();
        right.setRt_id(Integer.valueOf(rs.getString(1))); //取得数据库流水号
        right.setRt_number(rs.getString(2)); //取得员工表的外键信息
        right.setRt_code(Byte.valueOf(rs.getString(3))); //取得基础信息设置
        right.setRt_date(Byte.valueOf(rs.getString(4))); //取得基础资料设置
        right.setRt_operation(Byte.valueOf(rs.getString(5))); //取得业务管理设置
        right.setRt_forms(Byte.valueOf(rs.getString(6))); //取得报表中心设置
        right.setRt_sell(Byte.valueOf(rs.getString(7))); //取得销售分析设置
        right.setRt_tool(Byte.valueOf(rs.getString(8))); //取得辅助工具设置
        right.setRt_right(Byte.valueOf(rs.getString(9))); //取得系统设置
        list.add(right);
      }
    }
    catch (SQLException ex) {
    }
    connection.closeConnection();
    return list;

  }

  //得到员工的权利信息
  public RightVO getRight(String number) {
    RightVO right = new RightVO();
    String sql = "select * from tb_right where rt_number='" + number + "'";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        right.setRt_id(Integer.valueOf(rs.getString(1))); //取得数据库流水号
        right.setRt_number(rs.getString(2)); //取得员工表的外键信息
        right.setRt_code(Byte.valueOf(rs.getString(3))); //取得基础信息设置
        right.setRt_date(Byte.valueOf(rs.getString(4))); //取得基础资料设置
        right.setRt_operation(Byte.valueOf(rs.getString(5))); //取得业务管理设置
        right.setRt_forms(Byte.valueOf(rs.getString(6))); //取得报表中心设置
        right.setRt_sell(Byte.valueOf(rs.getString(7))); //取得销售分析设置
        right.setRt_tool(Byte.valueOf(rs.getString(8))); //取得辅助工具设置
        right.setRt_right(Byte.valueOf(rs.getString(9))); //取得系统设置
        connection.closeConnection();
      }
    }
    catch (SQLException ex) {
    }
    return right;
  }

  //删除员工表的信息
  public void deleteEmployee(String number) {
    String sql = "delete from tb_employee where em_number='" + number + "'";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

  //删除权限表
  public void deleteRight(String number) {
    String sql = "delete from tb_right where rt_number='" + number + "'";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

  //删除管理员表
  public void deleteManager(String number) {
    String sql = "delete from tb_manager where ma_number='" + number + "'";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

  //修改员工权限
  public void updateRight(RightVO right) {

    String sql = "update tb_right set rt_code='" + right.getRt_code() +
        "',rt_data='" + right.getRt_date() + "',rt_operation='" +
        right.getRt_operation() + "',rt_forms='" + right.getRt_forms() +
        "',rt_sell='" + right.getRt_sell() + "',rt_tool='" + right.getRt_tool() +
        "',rt_right='" + right.getRt_right() + "' where rt_number='" +
        right.getRt_number() + "'";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

//添加超级员工
  public void insertManager(ManagerVO manager) {
    String sql = "insert into tb_manager values ('" + manager.getMa_number() +
        "','" + manager.getMa_manager() + "')";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

  //以员工的编号查询员工信息
  public EmployeeVO getEmployee(String number) {
    EmployeeVO em = null;
    String sql = "select * from tb_employee where em_number='" + number +
        "'";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        em = new EmployeeVO();
        em.setEm_id(Integer.valueOf(rs.getString(1))); //取得数据库流水号信息
        em.setEm_number(rs.getString(2)); //取得员工的编号信息
        em.setEm_accouts(rs.getString(3)); //取得员工的账号信息
        em.setEm_password(rs.getString(4)); //取得员工的密码信息
        em.setEm_name(rs.getString(5)); //取得员工的姓名信息
        em.setEm_sex(rs.getString(6)); //取得员工性别信息
        em.setEm_age(Integer.valueOf(rs.getString(7))); //取得员工的年龄信息
        em.setEm_birthday(rs.getString(8)); //取得员工出生日期
        em.setEm_business(rs.getString(9)); //取得员工职务信息
        em.setEm_school(rs.getString(10)); //取得员工的毕业学校信息
        connection.closeConnection();
      }
    }
    catch (SQLException ex) {
    }
    return em;
  }

//修改员工密码
  public void updatePassword(EmployeeVO em) {
    String sql = "update tb_employee set em_password='" + em.getEm_password() +
        "' where em_number='" + em.getEm_number() + "'";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

//修改员工的信息
  public void updateEmployee(EmployeeVO em) {
    String sql = "update tb_employee set em_name='" + em.getEm_name() +
        "',em_sex='" + em.getEm_sex() + "',em_age='" + em.getEm_age() +
        "',em_birthday='" + em.getEm_birthday() + "',em_school='" +
        em.getEm_school() + "' where em_number='" + em.getEm_number() + "'";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

}