Commit 72ab25d9 authored by 赵啸非's avatar 赵啸非

添加统计异常详细信息

parent 01daa54f
...@@ -81,7 +81,6 @@ public class AttendanceRecordHikServiceImpl extends AbstractCRUDServiceImpl<Atte ...@@ -81,7 +81,6 @@ public class AttendanceRecordHikServiceImpl extends AbstractCRUDServiceImpl<Atte
public void addAttendanceOtherRecordList(List<AttendanceRecordHikEntity> hikEntityList, Context context) throws Exception { public void addAttendanceOtherRecordList(List<AttendanceRecordHikEntity> hikEntityList, Context context) throws Exception {
List<AttendanceRecordHikEntity> collect = hikEntityList.stream().sorted(Comparator.comparing(AttendanceRecordHikEntity::getAttendanceDate)).collect(Collectors.toList()); List<AttendanceRecordHikEntity> collect = hikEntityList.stream().sorted(Comparator.comparing(AttendanceRecordHikEntity::getAttendanceDate)).collect(Collectors.toList());
//另一种实现
Map<Long, List<AttendanceRecordHikEntity>> listMap = collect.stream().collect(Collectors.groupingBy(AttendanceRecordHikEntity::getStaffId)); Map<Long, List<AttendanceRecordHikEntity>> listMap = collect.stream().collect(Collectors.groupingBy(AttendanceRecordHikEntity::getStaffId));
List<AttendanceRecordEntity> saveList = new ArrayList<>(); List<AttendanceRecordEntity> saveList = new ArrayList<>();
...@@ -442,8 +441,6 @@ public class AttendanceRecordHikServiceImpl extends AbstractCRUDServiceImpl<Atte ...@@ -442,8 +441,6 @@ public class AttendanceRecordHikServiceImpl extends AbstractCRUDServiceImpl<Atte
} }
if (!ObjectUtils.isEmpty(errorEntityList)) { if (!ObjectUtils.isEmpty(errorEntityList)) {
//添加异常记录,去掉异常列表中 重复的数据;
errorService.save(errorEntityList, context); errorService.save(errorEntityList, context);
} }
} }
......
package com.mortals.xhx.module.attendance.service.work; package com.mortals.xhx.module.attendance.service.work;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSON;
import com.mortals.framework.model.Context; import com.mortals.framework.model.Context;
import com.mortals.framework.model.OrderCol; import com.mortals.framework.model.OrderCol;
import com.mortals.xhx.common.code.*; import com.mortals.xhx.common.code.*;
...@@ -213,7 +214,7 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract { ...@@ -213,7 +214,7 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract {
boolean goOffBetweenTime = DateUtil.isIn(curDateTime, goWorkDateAfter, offWorkDateBefore); boolean goOffBetweenTime = DateUtil.isIn(curDateTime, goWorkDateAfter, offWorkDateBefore);
boolean updateCheck=false; boolean updateCheck = false;
// if(goOffBetweenTime){ // if(goOffBetweenTime){
// //如果考勤时间在上班与下班区间内 则将考勤状态改为迟到 如果已经存在 在改为早退 // //如果考勤时间在上班与下班区间内 则将考勤状态改为迟到 如果已经存在 在改为早退
...@@ -231,7 +232,7 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract { ...@@ -231,7 +232,7 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract {
if (attendanceRecordDetailEntity.getShiftsId() == classDetail.getId()) { if (attendanceRecordDetailEntity.getShiftsId() == classDetail.getId()) {
attendanceRecordDetailEntity.setGoWorkResult(GoWorkResultEnum.正常.getValue()); attendanceRecordDetailEntity.setGoWorkResult(GoWorkResultEnum.正常.getValue());
attendanceRecordDetailEntity.setGoWorkDate(recordHikEntity.getAttendanceDate()); attendanceRecordDetailEntity.setGoWorkDate(recordHikEntity.getAttendanceDate());
updateCheck=true; updateCheck = true;
} }
} }
// boolean inTime = DateUtil.isIn(curDateTime, goWorkDateBefore, goWorkDateAfter); // boolean inTime = DateUtil.isIn(curDateTime, goWorkDateBefore, goWorkDateAfter);
...@@ -250,13 +251,13 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract { ...@@ -250,13 +251,13 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract {
// } // }
// } // }
// } // }
}else{ } else {
if(goOffBetweenTime){ if (goOffBetweenTime) {
for (AttendanceRecordDetailEntity attendanceRecordDetailEntity : commonData.getDetailEntityList()) { for (AttendanceRecordDetailEntity attendanceRecordDetailEntity : commonData.getDetailEntityList()) {
if (attendanceRecordDetailEntity.getShiftsId() == classDetail.getId()&&GoWorkResultEnum.缺卡.getValue()==attendanceRecordDetailEntity.getGoWorkResult()) { if (attendanceRecordDetailEntity.getShiftsId() == classDetail.getId() && GoWorkResultEnum.缺卡.getValue() == attendanceRecordDetailEntity.getGoWorkResult()) {
attendanceRecordDetailEntity.setGoWorkResult(GoWorkResultEnum.迟到.getValue()); attendanceRecordDetailEntity.setGoWorkResult(GoWorkResultEnum.迟到.getValue());
attendanceRecordDetailEntity.setGoWorkDate(recordHikEntity.getAttendanceDate()); attendanceRecordDetailEntity.setGoWorkDate(recordHikEntity.getAttendanceDate());
updateCheck=true; updateCheck = true;
} }
} }
} }
...@@ -285,10 +286,10 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract { ...@@ -285,10 +286,10 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract {
} }
} }
}*/ }*/
}else{ } else {
if(goOffBetweenTime){ if (goOffBetweenTime) {
for (AttendanceRecordDetailEntity attendanceRecordDetailEntity : commonData.getDetailEntityList()) { for (AttendanceRecordDetailEntity attendanceRecordDetailEntity : commonData.getDetailEntityList()) {
if (attendanceRecordDetailEntity.getShiftsId() == classDetail.getId()&&!updateCheck) { if (attendanceRecordDetailEntity.getShiftsId() == classDetail.getId() && !updateCheck) {
attendanceRecordDetailEntity.setOffWorkResult(OffWorkResultEnum.早退.getValue()); attendanceRecordDetailEntity.setOffWorkResult(OffWorkResultEnum.早退.getValue());
attendanceRecordDetailEntity.setOffWorkDate(recordHikEntity.getAttendanceDate()); attendanceRecordDetailEntity.setOffWorkDate(recordHikEntity.getAttendanceDate());
} }
...@@ -314,7 +315,7 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract { ...@@ -314,7 +315,7 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract {
if (next.getOffWorkResult() == OffWorkResultEnum.缺卡.getValue()) { if (next.getOffWorkResult() == OffWorkResultEnum.缺卡.getValue()) {
if (DateUtil.compare(new Date(), next.getOffWorkDate()) < 0) { if (DateUtil.compare(new Date(), next.getOffWorkDate()) < 0) {
next.setOffWorkDate(null); next.setOffWorkDate(null);
// next.setOffWorkResult(OffWorkResultEnum.正常.getValue()); // next.setOffWorkResult(OffWorkResultEnum.正常.getValue());
next.setOffWorkResult(null); next.setOffWorkResult(null);
} }
} }
...@@ -402,11 +403,7 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract { ...@@ -402,11 +403,7 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract {
} }
errorEntityList.add(errorEntity); errorEntityList.add(errorEntity);
} }
} }
if (!ObjectUtils.isEmpty(errorEntityList)) { if (!ObjectUtils.isEmpty(errorEntityList)) {
//删除当前员工当日未处理的异常后,重新添加 //删除当前员工当日未处理的异常后,重新添加
AttendanceRecordErrorQuery errorQuery = new AttendanceRecordErrorQuery(); AttendanceRecordErrorQuery errorQuery = new AttendanceRecordErrorQuery();
...@@ -417,11 +414,15 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract { ...@@ -417,11 +414,15 @@ public class FixWorkOtherAttendance extends AttendanceWorkAbstract {
Long[] errorIds = errorService.find(errorQuery).stream().map(i -> i.getId()).toArray(Long[]::new); Long[] errorIds = errorService.find(errorQuery).stream().map(i -> i.getId()).toArray(Long[]::new);
if(attendanceRecordEntity.getStaffId()==191L){
log.info("删除异常id:{}", JSON.toJSONString(errorIds));
}
if (!ObjectUtils.isEmpty(errorIds)) { if (!ObjectUtils.isEmpty(errorIds)) {
errorService.remove(errorIds, context); errorService.remove(errorIds, context);
} }
for (AttendanceRecordErrorEntity errorEntity : errorEntityList) { for (AttendanceRecordErrorEntity errorEntity : errorEntityList) {
//查看是否存在相同的异常记录,如果存在 则不添加 //查看是否存在相同的异常记录,如果存在 则不添加
errorQuery = new AttendanceRecordErrorQuery(); errorQuery = new AttendanceRecordErrorQuery();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment