详解使用SSM实现简单工作流系统之实现篇

详解使用SSM实现简单工作流系统之实现篇

项目说明

本项目是依据《轻量级 java EE 企业应用实战 第4版》的最后一章中的项目实现的，原本项目使用的框架是Struts2 + Spring 4 + Hibernate，因为本人在学习Spring MVC + Spring + Mybatis，所以将它重写了一次，使用了Spring MVC + Spring + Mybatis项目。在正文中介绍项目的时候，也将主要依据原书的叙述。

因为项目是根据原始项目实现的，实现过程中可能出现有Bug，如果发现问题可以与我联系，或在评论区中留言评论。

零，准备工作

首先根据参考链接建立SSM基本项目；也可以直接从github上直接下载, 下载之后, 在目录initProject下面有一个HRSystem项目，这个项目就是初始项目了。这个项目是根据前面提供的链接实现的，整合了基本的SSM框架，直接部署Tomcat就可以运行了，部署方式可以直接参考前面的链接。该项目下还有一个目录就是originalProject，该目录存放的是原书中的项目代码，也是本文代码的参考实现。

Github地址

HRSystem: https://github.com/sysuKinthon/HRSystem （包含项目初始项目和原始SSH项目）

HRSystem_Dev: https://github.com/sysuKinthon/HRSystem_Dev (包含完整的SSM项目代码)

上面的项目都是idea项目，下载到相应的项目后，运行步骤如下：

在IDEA中打开

建立下数据库，数据库使用mysql，sql文件在src/main/resource目录下，叫做schema.sql。

修改下项目中的spring-mybatis.xml里面关于数据库的配置，主要修改用户名和密码。

上述都配置好后，再配置一下tomcat就可以了。

一，项目背景及系统结构

1）应用背景

项目实现的是一个简单的工作流系统，该系统包含公司日常的事务：日常考勤，工资结算及签核申请等。该签核系统完成了考勤改变申请的送签，以及对申请的签核，这是一种简单的工作流，，可以提高企业的生产效率，另外，本应用额外的打卡系统，自动工资结算等，也可以在一定程度上提高企业的生产效率。

2）系统功能介绍

系统的用户主要分为两种：普通员工和经理。

普通员工的功能包括

员工通过打卡完成每天上下班的考勤记录，考勤记录包括迟到，早退，旷工等；

员工也可以查看本人最近3天的考勤情况；

如果发现考勤情况与实际不符，可提出申请，申请将由系统自动转发给员工经理，如果经理通过核准，则此申请自动生效，系统将考勤必为实际的情况；

员工也可以查看自己的工资记录

经理的功能包括

包含上述普通员工的功能，但是经理的考勤不能提出申请；

签核员工申请

新增员工

查看管理的全部员工

查看员工的上月工资

3）系统结构

表现层：由jsP页面组成

MVC层：使用MVC框架技术（Spring MVC）

业务逻辑层：主要由Spring IoC容器管理的业务逻辑组件组成（门面模式）

DAO层：由6个DAO组件组成

领域对象层：由7个持久化对象组成（使用贫血模式设计）

数据库服务层：使用MySQL数据库存储持久化数据

4）系统功能模块

本系统可以大致分为两个模块：经理模块和员工模块，其主要业务逻辑通过EmpManagerService和MgrManagerService两个业务逻辑组件来实现，因此可以使用这两个业务组件来封装DAO组件。

系统以业务逻辑组件作为DAO组件的门面，封装这些DAO组件，业务逻辑组件底层依赖于这些DAO组件，向上实现系统的业务逻辑功能

本系统主要有如下6个DAO对象

ApplicationDao:提供对application_inf表的基本操作

AttendDao:提供对attend_inf表的基本操作

AttendTypeDao：提供对attend_type_inf表的基本操作

CheckbackDao：提供对checkback_inf表的基本操作

EmployeeDao：提供对employee_inf表的基本操作

PaymentDao：提供对payment_inf表的基本操作

系统提供了两个业务逻辑组件：

EmpManagerSerivce：提供Employee角色所需业务逻辑功能的实现

MgrManagerService：提供Manager角色所需业务逻辑功能的实现

二，持久层设计

1）设计持久化实体

面向对象分析，是指根据系统需求提取应用中的对象，将这些对象抽象成类，再抽取出需需要持久化保存的类，这些需要持久化保持的类就是持久化对象（PO）。

本项目一共设计了7个持久化类

Application: 对应普通员工的考勤提出申请，包含申请理由，是否被批复及申请改变的类型等属性

Attend: 对应每天的考勤，包含考勤时间，考勤员工，是否上班及考勤类别等信息

AttendType: 对应考勤的类别，包含考勤的名称，如迟到，早退等

Checkback: 对应批复，包含该批复对应的申请，是否通过申请，由哪个经理完成批复等属性

Employee: 对应系统的员工信息，包含员工的用户名，密码，工资以及对应的经理等属性

Manager: 对应系统的经理信息，公包含经理管理的部门名。实际上，Manager继承了Employee类，因此该类同样包含Employee的所有属性

Payment: 对应每月所发的薪水信息，包含发薪月份，领薪员工和薪资数等信息

本应用采用贫血模式来设计它们，所以持久化类中不提供业务逻辑方法，而是将所有的业务逻辑方法放到业务逻辑组件中实现。

当采用贫血模式的架构模型时，系统中的领域对象十分简洁，它们都是单纯的数据类，不需要考虑到底应该包含哪些业务逻辑方法，因此开发起来非常便捷；而系统的所有的业务逻辑都由业务逻辑组件负责实现，可以将业务逻辑的变化限制在业务逻辑层内，从而避免扩散到两个层，因此降低了系统的开发难度。

7个PO的关系如下：

Employee是Manager的父类，同时Manager和Employee之间存在 1-N的关系，即一个Manager对应多个Employee，但每个Employee只能对应一个Manager

Employee和Payment之间是1-N的关系，即每个员工可以多次领取薪水

Employee和Attend之间存在1-N的关系，即每个员工可以参与多次考勤，但每次考勤只对应一个员工

Manager继承了Employee类，因此具有Employee的全部属性，另外Manager还不慌不忙 Checkback之间存在1-N的关系

Application与Attend之间存在N-1的关系，即每个Attend可以被对应多次申请。

Application与AttendType之间存在N-1的关系，即每次申请都有明确的考勤类型，而一个考勤类型可以对应多个申请

Attend与AttendType之间存在N-1的关系，即每个Attend只属于一个AttendType。

根据上面书写如下的schema.sql，也就是数据库文件

CREATE DATABASE IF NOT EXISTS hrSystem COLLATE = 'utf8_general_ci' CHARACTER SET = 'utf8';

use hrSystem;

create table attend_type_inf

(

type_id int auto_increment,

amerce_amount double not null,

type_name varchar(50) not null,

primary key(type_id)

);

create table employee_inf

(

emp_id int auto_increment,

emp_type int,

emp_name varchar(50) not null,

emp_pass varchar(50) not null,

emp_salary double not null,

mgr_id int,

dept_name varchar(50),

primary key(emp_id),

unique key(emp_name),

foreign key(mgr_id) references employee_inf(emp_id)

);

create table attend_inf

(

attend_id int auto_increment,

duty_day varchar(50) not null,

punch_time datetime,

is_come boolean not null,

type_id int not null,

emp_id int not null,

primary key(attend_id),

foreign key(type_id) references attend_type_inf(type_id),

foreign key(emp_id) references employee_inf(emp_id)

);

create table application_iZbsIfQnf

(

app_id int auto_increment,

attend_id int not null,

app_reason varchar(255),

app_result boolean,

type_id int not null,

primary key(app_id),

foreign key(type_id) references attend_type_inf(type_id),

foreign key(attend_id) references attend_inf(attend_id)

);

create table payment_inf

(

pay_id int auto_increment,

pay_month varchar(50) not null,

pay_amount double not null,

emp_id int not null,

primary key(pay_id),

foreign key(emp_id) references employee_inf(emp_id)

);

create table checkback_inf

(

check_id int auto_increment,

app_id int not null,

check_result boolean not null,

check_reason varchar(255),

mgr_id int not null,

primary key(check_id),

foreign key(app_id) references application_inf(app_id),

foreign key(mgr_id) references employee_inf(emp_id)

);

INSERT INTO `test_user` VALUES ('1', '123455@qq.com','12345', 'test');

insert into attend_type_inf ( type_name , amerce_amount)

values ( '正常', 0);

insert into attend_type_inf ( type_name , amerce_amount)

values ( '事假', -20);

insert into attend_type_inf ( type_name , amerce_amount)

values ( '病假', -10);

insert into attend_type_inf ( type_name , amerce_amount)

values ( '迟到', -10);

insert into attend_type_inf ( type_name , amerce_amount)

values ( '早退', -10);

insert into attend_type_inf ( type_name , amerce_amount)

values ( '旷工', -30);

insert into attend_type_inf ( type_name , amerce_amount)

values ( '出差', 10);

# 插入经理

insert into employee_inf (emp_type , emp_name , emp_pass , emp_salary , mgr_id , dept_name)

values (2, 'oracle', 'oracle' , 5000 , null , 'DB部');

insert into employee_inf (emp_type , emp_name , emp_pass , emp_salary , mgr_id , dept_name)

values (2, 'weblogic', 'weblogic' , 6000 , null , 'Server部');

# 员工

insert into employee_inf (emp_type , emp_name , emp_pass , emp_salary , mgr_id)

values (1 , 'mysql', 'mysql' , 3000 , 1);

insert into employee_inf (emp_type , emp_name , emp_pass , emp_salary , mgr_id)

values (1 , 'hsql', 'hsql' , 3200 , 1);

insert into employee_inf (emp_type , emp_name , emp_pass , emp_salary , mgr_id)

values (1 , 'tomcat', 'tomcat' , 2800 , 2);

insert into employee_inf (emp_type , emp_name , emp_pass , emp_salary , mgr_id)

values (1 , 'jetty', 'jetty' , 2560 , 2);

上面已经陈述了全部的设计，剩下的一些细节将在下面的代码实现中说明。

三，Model层

为了节约篇幅，下面的所有实现都只针对Employee类来说明，如有必要会针对其他进行说明

持久化实体类的存放目录是com.kevin.HRSystem.model，下面是Employee持久化类的源码：

package com.kevin.HRSystem.model;

public class Employee {

private long id;

private int type;

private String name;

private String password;

private double salary;

private Manager manager;

public long getId() {

return id;

}

public void setId(long id) {

this.id = id;

}

public int getType() {

return type;

}

public void setType(int type) {

this.type = type;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

public String getPassword() {

return password;

}

public void setPassword(String password) {

this.password = password;

}

public double getSalary() {

return salary;

}

public void setSalary(double salary) {

this.salary = salary;

}

public Manager getManager() {

return manager;

}

public void setManager(Manager manager) {

this.manager = manager;

}

@Override

public String toString() {

String rsl = "Employee [id=" + this.id + ", name=" + this.name + ", password=" + this.password + ", type=" + this.type + ", salary=" + this.salary;

if(this.manager != null) {

rsl += ", managerId=" + this.manager.getId() + ", managerName=" + this.manager.getName() + "]";

}

return rsl;

}

}

在这里针对Employee.java和Manager.java进行一点说明，这两个的数据库表都是employee_inf，但是Employee没有dept_name（部门名称），而Manager没有mgr_id（所属部门经理id）

其他的model对象这里就不多说，直接参考源码即可。

四，DAO（Data Access Object）层

1）DAO组件的定义

在持久层之上，可以使用DAO组件再次封装数据库操作，这也是Java EE应用里常用的DAO模式。当使用DAO模式时，既体现了业务逻辑组件封装DAO组件的门面模式，也可分离业务逻辑组件和DAO组件的功能：业务逻辑组件负责业务逻辑的变化，而DAO组件负责持久化技术的变化，这也正是桥接模式的使用。

引入DAO模式后，每个DAO组件包含了数据库的访问逻辑；每个DAO组件可对一个数据库表完成基本的CURD等操作。

DAO模式是一种更符合软件工程的开发方式，使用DAO模式有如下理由：

DAO模式抽象出数据访问方式，业务逻辑组件无须理会底层的数据库访问细节，而只专注于业务逻辑的实现，业务逻辑组件只负责业务功能的变化

DAO将数据访问集中在独立的一层，所有的数据访问都由DAO对象完成，这层独立的DAO分离了数据访问的实现与其他业务逻辑，使得系统更具可维护性

DAO还有助于提升系统的可移植性，独立的DAO层使得系统能在不同的数据库之间轻易切换，底层的数据库实现对于业务逻辑组件是透明的。数据库移植时仅仅影响DAO层，不同数据库的切换也不会影响业务逻辑组件，因此提供了系统的可复用性

DAO组件提供了各持久化对象的基本的CRUD操作，而在DAO接口里则对DAO组件包含的各种CRUD方法提供了声明。使用DAO接口的原因是：避免业务逻辑组件与特定的DAO组件耦合

尽管很多的DAO组件方法需要根据业务逻辑需求的变化而变化，但是还是有一些通用的方法，在代码实现中，BaseDao接口包含了几个通用的方法，其定义如下：

package com.kevin.HRSystem.dao;

import java.util.List;

public interface BaseDao {

void save(T entity); //保持持久化实例

void delete(long id); //根据主键删除持久化实例

void update(T entity); //更新持久化实例

T findById(long id); //根据主键加载持久化实例

List findAll(); //获取数据表中全部的持久化实例

}

DAO接口无须给出任何实现，仅仅是DAO组件包含的CRUD方法的定义，这些方法定义的实现取决于底层的持久化技术，DAO组件的实现既可以使用传统的JDBC，也可以采用Hibernate，MyBatis等技术。

如下是我们的EmployeeDao组件接口的源码

package com.kevin.HRSystem.dao;

import com.kevin.HRSystem.model.Employee;

import com.kevin.HRSystem.model.Manager;

import org.apache.ibatis.annotations.Param;

import java.util.List;

public interface EmployeeDao extends BaseDao{

/**

* 根据用户名和密码查询员工

* @param name 用户名

* password 密码

* @return 返回员工

*/

public Employee findByNameAndPass(@Param("name")String name, @Param("password") String password);

public Employee findByName(@Param("name")String name);

public List findEmployeesByMgrId(@Param("id") long id);

public void saveAsEmployee(Employee employee);

public void saveAsManager(Manager manager);

}

其他的DAO组件接口的源码请直接查看代码；这里有一个要明确的，就是持久化对象里面有Employee和Manager，但是DAO组件里面只有EmployeeDAO，因为这两个持久化对象对应的其实是同一个数据库表，在实现的过程中，我将两个持化对象的CRUD整合到同一个DAO组件里面了。

DAO接口只定义了DAO组件应该实现的方法，但如何实现这些DAO方法则没有任何限制，程序可以使用任何持久化技术来实现它们，这样就可以让DAO组件来负责持久化技术这个维度的变化，当系统需要在不同的持久化技术之间迁移时，应用只需要提供不同的DAO实现类即可，程序的其他部分无须进行任何改变，这就很好地提高了系统的可扩展性。

2）DAO组件的实现

在本项目中，DAO层的实现是使用了MyBatis技术，在基础项目中， 我们已经在Spring中引入了MyBatis，其配置文件（spring-mybatis.xml）如下：

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xmlns:context="http://springframework.org/schema/context" xmlns:tx="http://springframework.org/schema/tx"

xsi:schemaLocation="http://springframework.org/schema/beans http://springframework.org/schema/beans/spring-beans.xsd http://springframework.org/schema/context http://springframework.org/schema/context/spring-context.xsd http://springframework.org/schema/tx http://springframework.org/schema/tx/spring-tx.xsd">

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xmlns:context="http://springframework.org/schema/context" xmlns:tx="http://springframework.org/schema/tx"

xsi:schemaLocation="http://springframework.org/schema/beans http://springframework.org/schema/beans/spring-beans.xsd http://springframework.org/schema/context http://springframework.org/schema/context/spring-context.xsd http://springframework.org/schema/tx http://springframework.org/schema/tx/spring-tx.xsd">

根据上面的配置文件可以看出，我们的DAO层实现类是放在了classpath:mapper路径下面的，这里我们一样只给出EmployeeDao组件的实现，

INSERT INTO employee_inf(emp_type, emp_name, emp_pass, emp_salary, mgr_id, dept_name) VALUES (#{type}, #{name}, #{password}, #{salary}, #{manager.id}, #{departmentName})

INSERT INTO employee_inf(emp_type, emp_name, emp_pass, emp_salary, mgr_id) VALUES (#{type}, #{name}, #{password}, #{salary}, #{manager.id})

INSERT INTO employee_inf(emp_type, emp_name, emp_pass, emp_salary, dept_name) VALUES (#{type}, #{name}, #{password}, #{salary}, #{departmentName})

DELETE FROM employee_inf WHERE emp_id=#{id}

UPDATE employee_inf SET emp_name=#{name}, emp_pass=#{password}, emp_salary=#{saraly}, emp_type=#{type}, mgr_id=#{manager.id} WHERE emp_id=#{id}

SELECT * FROM employee_inf

SELECT * FROM employee_inf WHERE emp_id=#{id}

SELECT * FROM employee_inf WHERE emp_name=#{name} and emp_pass=#{password}

SELECT * FROM employee_inf WHERE emp_name=#{name}

SELECT * FROM employee_inf WHERE mgr_id=#{id}

SELECT e.emp_id, e.emp_name, e.emp_pass, e.emp_type, e.emp_salary, m.emp_id mgr_id, m.emp_name mgr_name, m.dept_name FROM employee_inf e, employee_inf m WHERE e.mgr_id = m.emp_id and e.emp_id = #{id}

这个xml文件就是我们EmployeeDao组件的实现类了。关于这个类的鉴别器使用可以参考 SSM项目问题与解决(还没有出)

四，Service层

1）业务逻辑组件的设计

业务逻辑组件是DAO组件的门面，所以可以理解为业务逻辑组件需要依赖于DAO组件。EmpManagerService接口（业务逻辑组件之一）里定义了大量的业务方法，这些方法的实现依赖于DAO组件，由于每个业务都要涉及多个DAO操作，其DAO操作是单条数据记录的操作，而业务逻辑方法的访问，则需要设计多个DAO操作，因此每个业务逻辑方法可能需要涉及多条记录的访问

业务逻辑组件面向DAO接口编程，可以让业务逻辑组件从DAO组件的实现中分离，因此业务逻辑组件只关系业务逻辑的实现，无须关心数据访问逻辑的实现

EmpManagerService接口的代码实现如下：

package com.kevin.HRSystem.service;

import com.kevin.HRSystem.model.AttendType;

import com.kevin.HRSystem.model.Employee;

import com.kevin.HRSystem.model.Manager;

import com.kevin.HRSystem.vo.AttendVo;

import com.kevin.HRSystem.vo.PaymentVo;

import java.util.List;

public interface EmpManagerService {

/**

* 验证登录

* @param employee 登录的身份

* @return

* 登录后的身份确认：0为登录失败，1为登录emp，2为登录mgr

*/

int validLogin(Employee employee);

/**

* 自动打卡，周一到周五，早上7点为每个员工插入旷工记录

*/

void autoPunch();

/**

* 自动结算工资，每月1号，结算上个月工资

*/

void autoPay();

/**

* 验证某个员工是否可以打卡，以及打卡的类型，上班打卡，还是下班打卡

* @param user 员工名

* @param dutyDay 日期

* @return 可打卡的类别

*/

int validPunch(String user, String dutyDay);

/**

* 实现普通员工的打卡

* @param user 员工名

* @param dutyDay 打卡日期

* @param isCome 是否是上班打卡

* @return 打卡结果

*/

int punch(String user, String dutyDay, boolean isCome);

/**

* 根据员工浏览自己的工资

* @param employeeName 员工名

* @return 该员工的工资列表

*/

List employeeSalary(String employeeName);

/**

* 员工查看自己的最近三天的非正常打卡

* @param employeeName 员工名

* @return 该员工最近三天的非正常打卡

*/

List getUnAttend(String employeeName);

/**

* 返回全部的出勤类别

* @return 全部的出勤类别

*/

List getAllType();

/**

* 添加申请

* @param attId 申请的出勤ID

* @param typeId 申请的类型ID

* @param reason 申请的理由

* @return 添加的结果

*/

boolean addApplication(int attId, int typeId, String reason);

}

2）实现业务逻辑组件

业务逻辑组件负责实现系统所需的业务方法，系统有多少个业务需求，业务逻辑组件就提供多少个对应方法，本应用采用的贫血模式的架构模型，因此业务逻辑方法完全由业务逻辑组件负责实现。

业务逻辑组件只负责业务逻辑上的变化，而持久层的变化则交给DAO层负责，因此业务逻辑组件必须依赖于DAO组件。

下面是EmpManagerServiceImpl的代码实现：

package com.kevin.HRSystem.service.impl;

import com.kevin.HRSystem.dao.*;

import com.kevin.HRSystem.model.*;

import com.kevin.HRSystem.service.EmpManagerService;

import com.kevin.HRSystem.vo.AttendVo;

import com.kevin.HRSystem.vo.PaymentVo;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import javax.annotation.Resource;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Calendar;

import java.util.Date;

import java.util.List;

import static com.kevin.HRSystem.constant.ConstantManager.*;

@Service("EmpManagerService")

public class EmpManagerServiceImpl implements EmpManagerService {

@Resource

private ApplicationDao applicationDao;

@Resource

private AttendDao attendDao;

@Resource

private AttendTypeDao attendTypeDao;

@Resource

private CheckbackDao checkbackDao;

@Resource

private EmployeeDao employeeDao;

@Resource

private PaymentDao paymentDao;

public int validLogin(Employee employee) {

Employee employee1 = employeeDao.findByNameAndPass(employee.getName(), employee.getPassword());

if(null != employee1) {

if(employee1 instanceof Manager) {

System.out.println("EmpManagerService: manager");

System.out.println(employee);

return LOGIN_MGR;

} else {

System.out.println("EmpManagerService:employee");

System.out.println(employee);

return LOGIN_EMP;

}

}

return LOGIN_FALT;

}

public void autoPunch() {

List employees = employeeDao.findAll();

System.out.println(employees.size());

//获取当前时间

String dutyDay = new java.sql.Date(System.currentTimeMillis()).toString();

for(Employee employee : employees) {

System.out.println(employee);

//先设置出ZbsIfQ勤类型为旷工，然后真正出勤的时候由员工去修改出勤的状态

//6表示旷工；已经插入数据库了; 这里最好弄一个常量管理类；但为了方便先这样吧

AttendType attendType = attendTypeDao.findById(6);

Attend a = new Attend();

a.setAttendType(attendType);

a.setDutyDay(dutyDay);

//如果是早上，则对应上班打卡

if(Calendar.getInstance().get(Calendar.HOUR_OF_DAY) < AM_LIMIT) {

a.setCome(true);

} else {

//下班打卡

a.setCome(false);

}

a.setEmployee(employee);

attendDao.save(a);

}

}

public void autoPay() {

List employees = employeeDao.findAll();

//获取上个月时间

Calendar c = Calendar.getInstance();

c.add(Calendar.DAY_OF_MONTH, -15);

http:// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM");

String payMonth = sdf.format(c.getTime());

for(Employee employee : employees) {

Payment pay = new Payment();

double amount = employee.getSalary();

//获取出勤记录

List attends = attendDao.findByEmpAndMonth(employee, payMonth);

//计算工资

for(Attend attend : attends) {

amount += attend.getAttendType().getAmerceAmount();

}

pay.setPayMonth(payMonth);

pay.setEmployee(employee);

pay.setPayAmount(amount);

paymentDao.save(pay);

}

}

@Override

public int validPunch(String user, String dutyDay) {

//不能查找到对应的用户，返回无法打卡

Employee employee = employeeDao.findByName(user);

if(null == employee) {

return NO_PUNCH;

}

//打到员工指定日期的出勤记录

List attends = attendDao.findByEmpAndDutyDay(employee, dutyDay);

//系统没有为用户在当前插入空打卡记录，无法打卡

if(null == attends || attends.size() == 0) {

return NO_PUNCH;

}

//开始上班打卡

if(attends.size() == 1 && attends.get(0).isCome() && null == attends.get(0).getPunchTime()) {

return COME_PUNCH;

}

if(attends.size() == 1 && null == attends.get(0).getPunhttp://chTime()) {

return LEAVE_PUNCH;

}

if(attends.size() == 2) {

if(null == attends.get(0).getPunchTime() && null == attends.get(0).getPunchTime()) {

return BOTH_PUNCH;

} else if(null == attends.get(1).getPunchTime()) {

return LEAVE_PUNCH;

} else {

return NO_PUNCH;

}

}

return NO_PUNCH;

}

public int punch(String user, String dutyDay, boolean isCome) {

Employee employee = employeeDao.findByName(user);

if(null == employee) {

return PUNCH_FALT;

}

//找到员工本次打卡对应的出勤记录

Attend attend = attendDao.findByEmpAndDutyDayAndCome(employee, dutyDay, isCome);

if(null == attend) {

return PUNCH_FALT;

}

//如果已经打卡

if(null != attend.getPunchTime()) {

return PUNCHED;

}

int punchHour = Calendar.getInstance().get(Calendar.HOUR_OF_DAY);

attend.setPunchTime(new Date());

//上班打卡

if(isCome) {

//9点之前算正常

if(punchHour < COME_LIMIT) {

//1表示正常

attend.setAttendType(attendTypeDao.findById(1));

} else if (punchHour < LATE_LIMIT) {

//9点到11点之间算迟到

attend.setAttendType(attendTypeDao.findById(4));

}

//11点之后算旷工，不用管，本来初始就是旷工

} else {

//下班打卡

//18点之后算正常

if(punchHour >= LEAVE_LIMIT) {

attend.setAttendType(attendTypeDao.findById(1));

} else if(punchHour >= LEAVE_LIMIT) {

//16到18点算正常

attend.setAttendType(attendTypeDao.findById(5));

}

}

attendDao.update(attend);

return PUNCH_SUCC;

}

public List employeeSalary(String employeeName) {

Employee employee = employeeDao.findByName(employeeName);

List payments = paymentDao.findByEmp(employee);

System.out.println(payments);

List result = new ArrayList();

for(Payment payment : payments) {

result.add(new PaymentVo(payment.getPayMonth(), payment.getPayAmount()));

}

return result;

}

/**

* 查看自己最近三天的非正常打卡

* @param employeeName 员工名

* @return 该员工的最近三天的非正常打卡

*/

public List getUnAttend(String employeeName) {

AttendType type = attendTypeDao.findById(1);

Employee employee = employeeDao.findByName(employeeName);

//获取最近三天非正常的出勤记录

List attends = attendDao.findByEmpUnAttend(employee, type);

List result = new ArrayList();

for(Attend attend : attends) {

result.add(new AttendVo(attend.getId(), attend.getDutyDay(), attend.getAttendType().getTypeName(), attend.getPunchTime()));

}

return result;

}

public List getAllType() {

return attendTypeDao.findAll();

}

@Override

public boolean addApplication(int attId, int typeId, String reason) {

Application application = new Application();

//获取申请需要改变的出勤记录

Attend attend = attendDao.findById(attId);

AttendType type = attendTypeDao.findById(typeId);

application.setAttend(attend);

application.setAttendType(type);

if(reason != null) {

application.setApplicationReason(reason);

}

applicationDao.save(application);

return true;

}

}

这里需要介绍一下上面业务逻辑组件的一些方法，首先是autoPunch和autoPay，这两个方法并不由客户端直接调用，而是由任务调度来执行.

系统会在每个工作日的早上7点和下午12点时自动调用autoPunch，这个方法负责为每个员工插入一条旷工考勤记录，所以一天就会插入两条旷工记录了。这样做的原因在于，先插入记录为旷工，然后在员工上班打卡时，就将早上7点插入的记录的出勤类型根据出勤时间进行修改为正常或是迟到等，如果没有打卡就是旷工了。在员工下班打卡的时候，根据下班打卡的时间将12点插入的记录进行修改其出勤类型。

系统同样会在每月3日为所有员工完成工资结算，这个是通过autoPay来实现的。

六，实现任务的自动调度

系统中常常有些需要自动执行的任务，这些任务可能每隔一段时间就要执行一次，也可能需要在指定时间点自动执行，这些任务的自动执行必须使用任务的自动调度。通过使用开源框架Quartz，借助于它的支持，既可以实现简单的任务调度，也可以实现复杂的任务调度。

1）引入Quartz

为了在Spring项目中引入Quartz， 我们需要在pom.xml中加入如下的包依赖，

org.springframework

spring-context-support

${spring.version}

org.quartz-scheduler

quartz

2.2.1

2）实现任务调度

Quartz允许提供一个名为quartz.properties的配置文件，通过该配置文件，可以修改框架运行时的环境，其配置如下：

# 配置主调度器属性

org.quartz.scheduler.instanceName = QuartzScheduler

org.quartz.scheduler.instanceId = AUTO

# 配置线程池

# Quartz线程池的实现类

org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool

# 线程池的线程数量

org.quartz.threadPool.threadCount = 1

# 线程池里线程的优先级

org.quartz.threadPool.threadPriority = 10

# 配置作业存储

org.quartz.jobStore.misfireThreshold = 60000

org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

接下来就实现我们的两个作业类了，这两个作业类都需要去继承QuartzJobBean，PunchJob的实现如下：

package com.kevin.HRSystem.schedule;

import com.kevin.HRSystem.service.EmpManagerService;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

import org.springframework.scheduling.quartz.QuartzJobBean;

import javax.annotation.Resource;

public class PunchJob extends QuartzJobBean {

//判断作业是否执行的标志

private boolean isRunning = false;

@Resource

private EmpManagerService empManagerService;

public void setEmpManagerService(EmpManagerService empManagerService) {

this.empManagerService = empManagerService;

}

public void executeInternal(JobExecutionContext ctx) throws JobExecutionException {

if(!isRunning) {

System.out.println("开始调度自动打卡");

isRunning = true;

empManagerService.autoPunch();

System.out.println("打卡结束");

isRunning = false;

}

}

}

定义完上面的工作类后，就可以在配置文件中进行定义Bean了，新建一个spring-quartz.xml文件，其配置如下：

xmlns:xsi="http://w3.org/2001/XMLSchema-instance" xmlns:p="http://springframework.org/schema/p"

xsi:schemaLocation="http://springframework.org/schema/beans http://springframework.org/schema/beans/spring-beans.xsd">

class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"

p:cronExpression="0 0 2 3 * ? *">

xmlns:xsi="http://w3.org/2001/XMLSchema-instance" xmlns:p="http://springframework.org/schema/p"

xsi:schemaLocation="http://springframework.org/schema/beans http://springframework.org/schema/beans/spring-beans.xsd">

class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"

p:cronExpression="0 0 2 3 * ? *">

class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"

p:cronExpression="0 0 2 3 * ? *">

关于Cron表达式的使用请自行Google，其配置还是比较直观的。

七， 实现系统Web层

在这一层，我们使用的是SpringMVC，在初始项目中，已经配置好了相关的文件，主要是配置下spring-mvc.xml和web.xml，两个文件的配置如下：

spring-mvc.xml

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xmlns:context="http://springframework.org/schema/context"

xmlns:mvc="http://springframework.org/schema/mvc"

xsi:schemaLocation="http://springframework.org/schema/beans

http://springframework.org/schema/beans/spring-beans.xsd

http://springframework.org/schema/context

http://springframework.org/schema/context/spring-context.xsd

http://springframework.org/schema/mvc

http://springframework.org/schema/mvc/spring-mvc-3.0.xsd">

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xmlns:context="http://springframework.org/schema/context"

xmlns:mvc="http://springframework.org/schema/mvc"

xsi:schemaLocation="http://springframework.org/schema/beans

http://springframework.org/schema/beans/spring-beans.xsd

http://springframework.org/schema/context

http://springframework.org/schema/context/spring-context.xsd

http://springframework.org/schema/mvc

http://springframework.org/schema/mvc/spring-mvc-3.0.xsd">

web.xml

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee

http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd" version="3.1">

Archetype Created Web Application

encodingFilter

org.springframework.web.filter.CharacterEncodingFilter

encoding

UTF-8

encodingFilter

/*

SpringMVC

org.springframework.web.servlet.DispatcherServlet

contextConfigLocation

classpath:spring-*.xml

1

SpringMVC

/

index.jsp

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee

http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd" version="3.1">

Archetype Created Web Application

encodingFilter

org.springframework.web.filter.CharacterEncodingFilter

encoding

UTF-8

encodingFilter

/*

SpringMVC

org.springframework.web.servlet.DispatcherServlet

contextConfigLocation

classpath:spring-*.xml

1

SpringMVC

/

index.jsp

配置好上面的文件之后，我们的所有请求就会被SpringMVC所拦截进行分发了。为了节约篇幅，我们这里只陈述实现登录业务的整体过程，其他的业务大致类似。

因为到Service层我们都已经实现了，只要定义好前端和Controller层的数据就可以了，我们先开发jsp页面。在这里有一个要注意的，在tomcat项目中，放在应用程序目录下的任何资源，用户都可以通过输入该资源的URL而直接进行访问，如果你希望某个资源可以被Servlet访问，但是不能被用户访问，那么应用把它放在WEB-INF目录下面; 所以我们的jsp页面是放在webapp/WEB-INF下面的，而图片等静态资源是放在了webapp/resources下。

为了在我们的jsp中使用jstl，我们还需要引入如下的依赖

javax.servlet

jstl

1.2

taglibs

standard

1.1.2

首先们来看下main.jsp的源码，当index.jsp被访问时（欢迎页面），请求就会被转发到这个页面

所以当我们点击了登录系统按钮之后，就会发起/loginPage的请求，我们需要定义这个方法，其定义如下（在CommonController.java中）：

@RequestMapping(value = "/loginPage", method = RequestMethod.GET)

public ModelAndView showLoginPage() {

return new ModelAndView("login", "employee", new Employee());

}

关于SpringMVC的基本使用可以参考：链接

通过上面的逻辑我们知道，我们的SpringMVC经过处理请求后，会发送login.jsp给前端，login.jsp的定义如下：

<%--

Created by IntelliJ IDEA.

User: kevin

Date: 18-3-3

Time: 下午5:55

To change this template use File | Settings | File Templates.

--%>

<%@ page contentType="text/html;charset=UTF-8" language="java" %>

<%@taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>

<%@taglib uri="http://springframework.org/tags/form" prefix="form"%>

<%@include file="header.jsp"%>

background="${pageContext.request.contextPath}/resources/images/bodybg.jpg">

请输入用户名和密码来登录

<%@include file="footer.jsp"%>

当我们输入用户名和密码，并点击登录之后，会发起/processLogin的请求，其定义如下：

@RequestMapping(value = "/processLogin", method = RequestMethod.POST)

public ModelAndView processLogin(@ModelAttribute("employee") Employee employee, HttpServletRequest request) {

System.out.println(employee);

System.out.println(request.getProtocol());

ModelAndView modelAndView;

int result = empManagerService.validLogin(employee);

String message;

//登录结果为普通员工

System.out.println(result);

if(result == ConstantManager.LOGIN_EMP) {

//设置Session

request.getSession().setAttribute(WebConstant.USER, employee.getName());

request.getSession().setAttribute(WebConstant.LEVEL, WebConstant.EMP_LEVEL);

message = "您已成功登录系统,您的身份是普通员工";

System.out.println(message);

// modelAndView = new ModelAndView("success");

modelAndView = new ModelAndView("employee/index");

modelAndView.addObject("message", message);

return modelAndView;

} else if(result == ConstantManager.LOGIN_MGR){

request.getSession().setAttribute(WebConstant.USER, employee.getName());

request.getSession().setAttribute(WebConstant.LEVEL, WebConstant.MGR_LEVEL);

message = "您已成功登录系统,您的身份是经理";

System.out.println(message);

// modelAndView = new ModelAndView("success");

modelAndView = new ModelAndView("manager/index");

modelAndView.addObject("message", message);

return modelAndView;

} else {

message = "用户名与密码不匹配，登录失败";

System.out.println(message);

modelAndView = new ModelAndView("error");

modelAndView.addObject("message", message);

return modelAndView;

}

}

根据校验结果的不同，而有不同的返回页面，假设校验成功是一个普通员工的话，我们就返回了employee/index.jsp，并设置了message变量供jsp页面获取，employee/index.jsp如下：

<%--

Created by IntelliJ IDEA.

User: kevin

Date: 18-3-6

Time: 下午4:36

To change this template use File | Settings | File Templates.

--%>

<%@ page contentType="text/html;charset=UTF-8" language="java" %>

<%@taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>

<%@include file="../header.jsp"%>

<%@include file="empheader.jsp"%>

，欢迎您使用JavaEE简单工作流系统，您是普通员工

<%@include file="../footer.jsp"%>

其他页面的开发逻辑也类似如上。

八，结语

项目是依据《轻量级Java EE企业应用实战 第4版》的SSH项目来实现的，所以可能在实现过程中会有些问题，如果有问题，欢迎留言讨论。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。