基于java的OA员工请假系统源码+sql数据库.zip

package com.imooc.oa.service; import com.imooc.oa.entity.Employee; import com.imooc.oa.entity.LeaveForm; import com.imooc.oa.entity.Notice; import com.imooc.oa.entity.ProcessFlow; import com.imooc.oa.mapper.EmployeeMapper; import com.imooc.oa.mapper.LeaveFormMapper; import com.imooc.oa.mapper.NoticeMapper; import com.imooc.oa.mapper.ProcessFlowMapper; import com.imooc.oa.service.exception.LeaveFormException; import com.imooc.oa.utils.MybatisUtils; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; import java.util.Map; import java.util.stream.Collectors; public class LeaveFormService { private EmployeeService employeeService = new EmployeeService(); /** * 创建请假单 * @param form 前端输入的请假单数据 * @return 持久化后的请假单对象 */ public LeaveForm createLeaveForm(LeaveForm form){ LeaveForm f = (LeaveForm) MybatisUtils.executeUpdate(sqlSession -> { //1.持久化form表单数据,8级以下员工表单状态为processing,8级(总经理)状态为approved EmployeeMapper employeeMapper = sqlSession.getMapper(EmployeeMapper.class); Employee employee = employeeMapper.selectById(form.getEmployeeId()); if(employee.getLevel() == 8){ form.setState("approved"); }else{ form.setState("processing"); } LeaveFormMapper leaveFormMapper = sqlSession.getMapper(LeaveFormMapper.class); leaveFormMapper.insert(form); NoticeMapper noticeMapper = sqlSession.getMapper(NoticeMapper.class); //2.增加第一条流程数据,说明表单已提交,状态为complete ProcessFlowMapper processFlowMapper = sqlSession.getMapper(ProcessFlowMapper.class); ProcessFlow flow1 = new ProcessFlow(); flow1.setFormId(form.getFormId()); flow1.setOperatorId(employee.getEmployeeId()); flow1.setAction("apply"); flow1.setCreateTime(new Date()); flow1.setOrderNo(1); flow1.setState("complete"); flow1.setIsLast(0); processFlowMapper.insert(flow1); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd-HH时"); //3.分情况创建其余流程数据 //3.1 7级以下员工,生成部门经理审批任务,请假时间大于等于72小时,还需生成总经理审批任务 if(employee.getLevel() < 7){ Employee dmanager = employeeService.selectLeader(employee.getEmployeeId()); ProcessFlow flow2 = new ProcessFlow(); flow2.setFormId(form.getFormId()); flow2.setOperatorId(dmanager.getEmployeeId()); flow2.setAction("audit"); flow2.setCreateTime(new Date()); flow2.setOrderNo(2); flow2.setState("process"); long diff = form.getEndTime().getTime() - form.getStartTime().getTime(); float hours = diff/(1000*60*60) * 1f; if(hours >= 72){ flow2.setIsLast(0); processFlowMapper.insert(flow2); Employee manager = employeeService.selectLeader(dmanager.getEmployeeId()); ProcessFlow flow3 = new ProcessFlow(); flow3.setFormId(form.getFormId()); flow3.setOperatorId(manager.getEmployeeId()); flow3.setAction("audit"); flow3.setCreateTime(new Date()); flow3.setState("ready"); flow3.setOrderNo(3); flow3.setIsLast(1); processFlowMapper.insert(flow3); }else { flow2.setIsLast(1); processFlowMapper.insert(flow2); } String notice1 = String.format("您的请假申请[%s-%s]已提交,请等待上级审批.", sdf.format(form.getStartTime()), sdf.format(form.getEndTime())); noticeMapper.insert(new Notice(employee.getEmployeeId(),notice1)); String notice2 = String.format("%s-%s提起请假申请[%s-%s],请尽快审批", employee.getTitle(), employee.getName(), sdf.format(form.getStartTime()), sdf.format(form.getEndTime())); noticeMapper.insert(new Notice(dmanager.getEmployeeId(),notice2)); }else if(employee.getLevel() == 7){ //3.2 7级员工,仅生成总经理审批任务 Employee manager = employeeService.selectLeader(employee.getEmployeeId()); ProcessFlow flow2 = new ProcessFlow(); flow2.setFormId(form.getFormId()); flow2.setOperatorId(manager.getEmployeeId()); flow2.setAction("audit"); flow2.setCreateTime(new Date()); flow2.setState("process"); flow2.setOrderNo(2); flow2.setIsLast(1); processFlowMapper.insert(flow2); //请假单已提交消息 String notice1 = String.format("您的请假申请[%s-%s]已提交,请等待上级审批." , sdf.format(form.getStartTime()), sdf.format(form.getEndTime())); noticeMapper.insert(new Notice(employee.getEmployeeId(),notice1)); //通知总经理审批消息 String notice2 = String.format("%s-%s提起请假申请[%s-%s],请尽快审批", employee.getTitle() , employee.getName() ,sdf.format(form.getStartTime()),sdf.format(form.getEndTime())); noticeMapper.insert(new Notice(manager.getEmployeeId(),notice2)); }else if(employee.getLevel() == 8){ //3.3 8级员工,生成总经理审批任务,系统自动通过 ProcessFlow flow2 = new ProcessFlow(); flow2.setFormId(form.getFormId()); flow2.setOperatorId(employee.getEmployeeId()); flow2.setAction("audit"); flow2.setResult("approved"); flow2.setReason("自动通过"); flow2.setCreateTime(new Date()); flow2.setAuditTime(new Date()); flow2.setState("complete"); flow2.setOrderNo(2); flow2.setIsLast(1); processFlowMapper.insert(flow2); String noticeContent = String.format("您的请假申请[%s-%s]系统已自动批准通过." , sdf.format(form.getStartTime()) , sdf.format(form.getEndTime())); noticeMapper.insert(new Notice(employee.getEmployeeId(),noticeContent)); } return form; }); return f; } /** * 获取指定任务状态及指定经办人对应的请假单列表 * @param pfState ProcessFlow任务状态 * @param operatorId 经办人编号 * @return 请假单及相关数据列表 */ public List<Map> getLeaveFormList(String pfState, Long operatorId){ return (List<Map>) MybatisUtils.executeQuery(sqlSession -> { LeaveFormMapper mapper = sqlSession.getMapper(LeaveFormMapper.class); List<Map> maps = mapper.selectByParams(pfState, operatorId); return maps; }); } /** * 审核请假单 * @param formId 表单编号 * @param operatorId 经办人(当前登录员工) * @param result 审批结果 * @param reason 审批意见 */ public void audit(Long formId , Long operatorId , String result , String reason){ MybatisUtils.executeUpdate(sqlSession -> { //无论同意/驳回,当前任务状态变更为complete ProcessFlowMapper processFlowMapper = sqlSession.getMapper(ProcessFlowMapper.class); List<ProcessFlow> flowList = processFlowMapper.selectByFormId(formId); if(flowList.size() == 0){ thro