empmanagerimpl.java

用Struts+Hibernate+Spring做的J2EE工作流系统.性能良好.

package org.yeeku.service;

import org.yeeku.dao.*;
import org.yeeku.model.*;
import org.yeeku.business.*;
import org.yeeku.exception.*;

import java.text.*;
import java.util.*;



/**
 * @author  yeeku.H.lee [e-mail]
 * @version  1.0
 * <br>Copyright (C), 2005-2008, yeeku.H.Lee
 * <br>This program is protected by copyright laws.
 * <br>Program Name:
 * <br>Date: 
 */
public class EmpManagerImpl implements EmpManager
{
    private ApplicationDao appDao;
    private AttendDao attendDao;
    private AttendTypeDao typeDao;
    private CheckBackDao checkDao;
    private EmployeeDao empDao;
    private ManagerDao mgrDao;
    private PaymentDao payDao;
    private SimpleDateFormat sdf = new  SimpleDateFormat("yyyy-MM");


    public void setAppDao(ApplicationDao appDao)
    {
        this.appDao = appDao;
    }

    public void setAttendDao(AttendDao attendDao)
    {
        this.attendDao = attendDao;
    }

    public void setTypeDao(AttendTypeDao typeDao)
    {
        this.typeDao = typeDao;
    }

    public void setCheckDao(CheckBackDao checkDao)
    {
        this.checkDao = checkDao;
    }
    
    public void setEmpDao(EmployeeDao empDao)
    {
        this.empDao = empDao;
    }

    public void setMgrDao(ManagerDao mgrDao)
    {
        this.mgrDao = mgrDao;
    }

    public void setPayDao(PaymentDao payDao)
    {
        this.payDao = payDao;
    }

    /**
      * 验证登陆
      * @param user 登陆用的用户名
      * @param pass 登陆用的密码
      * @return 登陆后的身份确认:0为登陆失败，1为登陆emp 2为登陆mgr
      */
    public int validLogin(String user , String pass)
    {
        if (mgrDao.findByNameAndPass(user,pass).size() >= 1)
        {
            return LOGIN_MGR;
        }
        else if (empDao.findByNameAndPass(user,pass).size() >= 1)
        {
            return LOGIN_EMP;
        }
        else
        {
            return LOGIN_FAIL;
        }
    }

    /**
      * 自动打卡，周一到周五，早上7：00为每个员工插入旷工记录
      */
    public void autoPunch()
    {
        System.out.println("自动插入旷工记录");
        List<Employee> emps = empDao.findAll();
        String dutyDay = new java.sql.Date(System.currentTimeMillis()).toString();

        for (Employee e : emps)
        {
            AttendType atype = typeDao.get(6);
            Attend a = new Attend();
            a.setDutyDay(dutyDay);
            a.setType(atype);
            if (Calendar.getInstance().HOUR_OF_DAY < 11)
            {
                a.setIsCome(true);
            }
            a.setIsCome(false);
            a.setEmployee(e);
            attendDao.save(a);
        }
    }

    /**
      * 自动打卡，周一到周五，早上7：00为每个员工插入旷工记录
      */
    public void autoPay()
    {
        System.out.println("自动插入工资结算");
        List<Employee> emps = empDao.findAll();
        //获取上个月时间
        Calendar c = Calendar.getInstance();
        c.add(Calendar.DAY_OF_MONTH, -15);
        String payMonth = sdf.format(c.getTime());

        for (Employee e : emps)
        {
            Payment pay = new Payment();
            
            List<Attend> attends = attendDao.findByEmp(e);
            double amount = e.getSalary();
            for ( Attend a : attends )
            {
                amount += a.getType().getAmerce();
            }
            pay.setPayMonth(payMonth);
            pay.setEmployee(e);
            pay.setAmount(amount);
            payDao.save(pay);
        }
    }

    /**
      * 验证某个员工是否可打卡
      * @param user 员工名
      * @param dutyDay 日期
      * @return 可打卡的类别
      */
    public int validPunch(String user , String dutyDay)
    {
        //不能查找到对应用户，返回无法打卡
        Employee emp = empDao.findByName(user);
        if (emp == null)
        {
            return NO_PUNCH;
        }
        List<Attend> attends = attendDao.findByEmpAndDutyDay(emp , dutyDay);

        //系统没有为用户在当天插入空打卡记录，无法打卡
        if (attends == null)
        {
            return NO_PUNCH;
        }
        //可以上班、下班打卡
        if (attends.size() <= 0)
        {
            return NO_PUNCH;
        }
        else if (attends.size() == 1 && attends.get(0).getIsCome() 
            && attends.get(0).getPunchTime() == null)
        {
            return COME_PUNCH;
        }
        else if (attends.size() == 1 && attends.get(0).getPunchTime() == null)
        {
            return LEAVE_PUNCH;
        }
        else if (attends.size() == 2)
        {
            if (attends.get(0).getPunchTime() == null && attends.get(1).getPunchTime() == null)
            {
                return BOTH_PUNCH;
            }
            else if (attends.get(1).getPunchTime() == null)
            {
                return LEAVE_PUNCH;
            }
            else
            {
                return NO_PUNCH;
            }
        }
        return NO_PUNCH;
    }

    /**
      * 打卡
      * @param user 员工名
      * @param dutyDay 打卡日期
      * @param isCome 是否是上班打卡
      * @return 打卡结果
      */
    public int punch(String user , String dutyDay , boolean isCome)
    {
        Employee emp = empDao.findByName(user);
        if (emp == null)
        {
            return PUNCH_FAIL;
        }
        Attend attend = attendDao.findByEmpAndDutyDayAndCome(emp , dutyDay , isCome);
        if (attend == null)
        {
            return PUNCH_FAIL;
        }
        if (attend.getPunchTime() != null)
        {
            return PUNCHED;
        }
        int punchHour = Calendar.getInstance().HOUR_OF_DAY;
        attend.setPunchTime(new Date());
        //上班打卡
        if (isCome)
        {
            // 9 点之前算正常
            if (punchHour < 9)
            {
                attend.setType(typeDao.get(1));
            }
            // 9～11 点之间算迟到
            else if (punchHour < 11)
            {
                attend.setType(typeDao.get(4));
            }
            //11点之后算旷工
        }
        //下班打卡
        else
        {
            // 6 点之后算正常
            if (punchHour > 6)
            {
                attend.setType(typeDao.get(1));
            }
            // 4～6 点之间算早退
            else if (punchHour < 4)
            {
                attend.setType(typeDao.get(5));
            }
        }
        attendDao.update(attend);
        return PUNCH_SUCC;
    }

    /**
      * 根据员工浏览自己的工资
      * @param empName 员工名
      * @return 该员工的工资列表
      */

    public List<PaymentBean> empSalary(String empName)
    {
        Employee emp = empDao.findByName(empName);
        List<Payment> pays = payDao.findByEmp(emp);
        List<PaymentBean> result = new ArrayList<PaymentBean>();
        for (Payment p : pays )
        {
            result.add(new PaymentBean(p.getPayMonth(),p.getAmount()));
        }
        return result;
    }

    /**
      * 员工查看自己的最近三天非正常打卡
      * @param empName 员工名
      * @return 该员工的最近三天的非正常打卡
      */
    public List<AttendBean> unAttend(String empName)
    {
        AttendType type = typeDao.get(1);
        Employee emp = empDao.findByName(empName);
        List<Attend> attends = attendDao.findByEmpUnAttend(emp, type);
        List<AttendBean> result = new ArrayList<AttendBean>();
        for (Attend att : attends )
        {
            result.add(new AttendBean(att.getId() , att.getDutyDay() , att.getType().getName() , att.getPunchTime()));
        }
        return result;
    }

    /**
      * 返回全部的出勤类别
      * @return 全部的出勤类别
      */
    public List<AttendType> getAllType()
    {
        return typeDao.findAll();
    }

    /**
      * 添加申请
      * @param attId 申请的出勤ID
      * @param typeId 申请的类型ID
      * @param reason 申请的理由
      * @return 添加的结果
      */
    public boolean addApplication(int attId , int typeId , String reason)
    {
        try
        {
            Application app = new Application();
            Attend attend = attendDao.get(attId);
            AttendType type = typeDao.get(typeId);
            app.setAttend(attend);
            app.setType(type);
            if (reason != null)
            {
                app.setReason(reason);
            }
            appDao.save(app);
            return true;
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
        return false;
    }
}