管理系统系列--悟空HRM人力资源管理系统-提供入职管理、招聘管理、绩效考核管理等一站式人力管理流程.zip

package com.kakarote.hrm.service.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.ListUtil; import cn.hutool.core.convert.Convert; import cn.hutool.core.date.*; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.kakarote.common.entity.UserInfo; import com.kakarote.common.utils.UserUtil; import com.kakarote.core.common.Const; import com.kakarote.core.common.enums.FieldEnum; import com.kakarote.core.entity.BasePage; import com.kakarote.core.entity.PageEntity; import com.kakarote.core.exception.CrmException; import com.kakarote.core.servlet.BaseServiceImpl; import com.kakarote.core.utils.BaseUtil; import com.kakarote.core.utils.ExcelParseUtil; import com.kakarote.hrm.common.EmployeeHolder; import com.kakarote.hrm.common.HrmCodeEnum; import com.kakarote.hrm.constant.*; import com.kakarote.hrm.entity.BO.*; import com.kakarote.hrm.entity.PO.*; import com.kakarote.hrm.entity.VO.*; import com.kakarote.hrm.mapper.HrmAttendanceClockMapper; import com.kakarote.hrm.service.*; import com.kakarote.hrm.utils.AttendUtil; import com.kakarote.hrm.utils.EmployeeUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.servlet.http.HttpServletResponse; import java.math.BigDecimal; import java.sql.Timestamp; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.time.temporal.ChronoUnit; import java.time.temporal.TemporalAdjusters; import java.util.*; import java.util.stream.Collectors; import java.util.stream.Stream; /** * <p> * 打卡记录表 服务实现类 * </p> * * @author zhangzhiwei * @since 2020-12-07 */ @Service public class HrmAttendanceClockServiceImpl extends BaseServiceImpl<HrmAttendanceClockMapper, HrmAttendanceClock> implements IHrmAttendanceClockService { @Autowired private EmployeeUtil employeeUtil; @Autowired private IHrmAttendanceGroupService attendanceGroupService; @Autowired private IHrmAttendanceShiftService attendanceShiftService; @Autowired private IHrmAttendanceLegalHolidaysService attendanceLegalHolidaysService; @Autowired private IHrmEmployeeLeaveRecordService leaveRecordService; @Autowired private IHrmEmployeeService employeeService; @Autowired private IHrmEmployeeOverTimeRecordService employeeOverTimeRecordService; @Autowired private IHrmAttendancePointService attendancePointService; @Autowired private IHrmAttendanceWifiService attendanceWifiService; @Autowired private IHrmAttendanceHistoryShiftService attendanceHistoryShiftService; @Autowired private IHrmAttendanceDateShiftService attendanceDateShiftService; private static final int FOUR = 4; private static final int TWO = 2; private static final int THREE = 3; private static final int ZERO = 0; private static final int ONE = 1; private static final int SEVEN = 7; private static final String START_STATUS = "startStatus"; private static final String END_STATUS = "endStatus"; private static final String START_IS_OUT_CARD = "startIsOutCard"; private static final String END_IS_OUT_CARD = "endIsOutCard"; private static final String NULL = " "; @Override public void addOrUpdate(HrmAttendanceClock attendanceClock) { attendanceClock.setAttendanceTime(LocalDateTime.now()); attendanceClock.setClockEmployeeId(EmployeeHolder.getEmployeeId()); saveOrUpdate(attendanceClock); } @Override public BasePage<QueryAttendancePageVO> queryPageList(QueryAttendancePageBO attendancePageBO) { Collection<Long> employeeIds = employeeUtil.queryDataAuthEmpIdByMenuId(MenuIdConstant.ATTENDANCE_MENU_ID); return getBaseMapper().queryPageList(attendancePageBO.parse(), attendancePageBO, employeeIds); } @Override public List<HrmAttendanceClock> queryClockListByTime(LocalDate time, Collection<Long> employeeIds) { return getBaseMapper().queryClockListByTime(time, employeeIds); } @Override public Set<String> queryClockStatusList(QueryNotesStatusBO queryNotesStatusBO, Collection<Long> employeeIds) { return getBaseMapper().queryClockStatusList(queryNotesStatusBO, employeeIds); } @Override public BasePage<QueryAttendancePageVO> queryMyPageList(PageEntity pageEntity) { return getBaseMapper().queryMyPageList(pageEntity.parse(), EmployeeHolder.getEmployeeId()); } @Override @Transactional(rollbackFor = Exception.class) public void setHrmAttendanceClock(SetHrmAttendanceClockB0 attendanceClock) { if (attendanceClock.getClockStatus() == null) { attendanceClock.setClockStatus(ClockStatusEnum.NORMAL.getValue()); if (attendanceClock.getClockType().intValue() == ClockType.GO_TO.getValue()) { if (LocalDateTimeUtil.toEpochMilli(attendanceClock.getClockTime()) > LocalDateTimeUtil.toEpochMilli(attendanceClock.getAttendanceTime())) { attendanceClock.setClockStatus(ClockStatusEnum.LATE.getValue()); } } else { if (LocalDateTimeUtil.toEpochMilli(attendanceClock.getClockTime()) < LocalDateTimeUtil.toEpochMilli(attendanceClock.getAttendanceTime())) { attendanceClock.setClockStatus(ClockStatusEnum.EARLY.getValue()); } } } HrmAttendanceClock hrmAttendanceClock = BeanUtil.copyProperties(attendanceClock, HrmAttendanceClock.class); saveOrUpdate(hrmAttendanceClock); if (attendanceClock.getClockStatus() == SEVEN) {//加班 //查询对应的班次 QueryAttendanceDailyDetailBO queryAttendanceDailyDetailBO = new QueryAttendanceDailyDetailBO(); queryAttendanceDailyDetailBO.setCurrentDate(attendanceClock.getAttendanceTime().toLocalDate()); queryAttendanceDailyDetailBO.setEmployeeId(attendanceClock.getClockEmployeeId()); //查询出今日班次 HrmAttendanceShift hrmAttendanceShift = getHrmAttendanceShift(queryAttendanceDailyDetailBO); HrmEmployeeOverTimeRecord hrmEmployeeOverTimeRecord = new HrmEmployeeOverTimeRecord(); if (ObjectUtil.equal(hrmAttendanceShift.getShiftType(), ShiftTypeEnum.REST.getValue())) { hrmEmployeeOverTimeRecord = employeeOverTimeRecordService.lambdaQuery().eq(HrmEmployeeOverTimeRecord::getEmployeeId, attendanceClock.getClockEmployeeId()) .apply("date_format(attendance_time,'%Y-%m-%d') = {0}", LocalDateTimeUtil.format(queryAttendanceDailyDetailBO.getCurrentDate(), DatePattern.NORM_DATE_PATTERN)).orderByDesc(HrmEmployeeOverTimeRecord::getCreateTime).one(); if (ObjectUtil.isNull(hrmEmployeeOverTimeRecord)) { hrmEmployeeOverTimeRecord = new HrmEmployeeOverTimeRecord(); } if (attendanceClock.getClockType() == ClockType.GO_TO.getValue()) { HrmAttendanceClock hrmStartAttendanceClock = lambdaQuery().eq(HrmAttendanceClock::getClockType, ClockType.GO_TO.getValue()).eq(HrmAttendanceClock::getClockEmployeeId, queryAttendanceDailyDetailBO.getEmployeeId()) .apply("date_format(attendance_time,'%Y-%m-%d') = {0}", LocalDateTimeUtil.format(queryAttendanceDailyDetailBO.getCurrentDate(), DatePattern.NORM_DATE_PATTERN)).orderByDesc(HrmAttendanceClock::getCreateTime).one(); hrmEmployeeOverTimeRecord.setEmployeeId(attendanceClock.getClockEmployeeId()); //休息日加班 hrmEmployeeOverTimeRecord.setOverTimeType(TWO); hrmEmployeeOverTimeRecord.setAttendan