Skip to content

A
attendance-performance-platform
Commit 8729d10b authored by 廖旭伟's avatar 廖旭伟
Browse files
Options

绩效核查后取消立即汇总绩效分数改为每天晚上统一汇总一次

parent 9a0b5709
master dazhou pengxi20240725 qionglai reg reg-first
No related merge requests found
Hide whitespace changes
Inline Side-by-side
Showing with 81 additions and 69 deletions
attendance-performance-manager/src/main/java/com/mortals/xhx/daemon/task/AttendanceSummaryTaskImpl.java
View file @ 8729d10b
......@@ -7,10 +7,12 @@ import com.mortals.framework.service.ITask;
import com.mortals.framework.service.ITaskExcuteService;
import com.mortals.framework.util.DateUtils;
import com.mortals.framework.util.StringUtils;
import com.mortals.xhx.common.code.CheckTypeEnum;
import com.mortals.xhx.module.attendance.model.AttendanceRecordErrorQuery;
import com.mortals.xhx.module.attendance.model.vo.AttendanceSummaryQuery;
import com.mortals.xhx.module.attendance.service.AttendanceRecordErrorService;
import com.mortals.xhx.module.attendance.service.AttendanceStatService;
import com.mortals.xhx.module.check.model.vo.StaffCheckSummaryQuery;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
......@@ -19,6 +21,7 @@ import java.util.Calendar;
import java.util.Date;
import static com.mortals.xhx.common.key.RedisKey.KEY_ATTENDANCE_STAT_CACHE;
import static com.mortals.xhx.common.key.RedisKey.KEY_CHECK_SUMMARY_CACHE;
/**
* 考勤汇总
......@@ -58,7 +61,16 @@ public class AttendanceSummaryTaskImpl implements ITaskExcuteService {
attendanceRecordErrorService.doReprocess(errorQuery, null);
log.info("统计添加前一天考勤中绩效异常记录结束");
try {
log.info("汇总当天绩效分数开始");
StaffCheckSummaryQuery summaryQuery = new StaffCheckSummaryQuery();
summaryQuery.setCheckTimeStart(DateUtils.getCurrStrDate());
summaryQuery.setCheckTimeEnd(summaryQuery.getCheckTimeStart());
cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
log.info("汇总当天绩效分数结束");
} catch (Exception e) {
log.error("汇总当天绩效分数出错", e);
}
}
@Override
......
attendance-performance-manager/src/main/java/com/mortals/xhx/module/check/service/impl/CheckAttendRecordServiceImpl.java
View file @ 8729d10b
......@@ -144,19 +144,19 @@ public class CheckAttendRecordServiceImpl extends AbstractCRUDServiceImpl<CheckA
log.error("新增绩效异常信息核查状态出错", e);
}
try {
if(!entity.getErrorTime().after(new Date())) {
StaffCheckSummaryQuery query = new StaffCheckSummaryQuery();
query.setStaffId(entity.getStaffId());
query.setCheckTimeStart(DateUtils.getStrDate(entity.getCheckTime()));
query.setCheckTimeEnd(query.getCheckTimeStart());
query.setCheckType(CheckTypeEnum.考勤绩效.getValue());
cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
}
//summaryCheck(query);
} catch (Exception e) {
log.error("汇总已审核的核查记录出错", e);
}
// try {
// if(!entity.getErrorTime().after(new Date())) {
// StaffCheckSummaryQuery query = new StaffCheckSummaryQuery();
// query.setStaffId(entity.getStaffId());
// query.setCheckTimeStart(DateUtils.getStrDate(entity.getCheckTime()));
// query.setCheckTimeEnd(query.getCheckTimeStart());
// query.setCheckType(CheckTypeEnum.考勤绩效.getValue());
// cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
// }
// //summaryCheck(query);
// } catch (Exception e) {
// log.error("汇总已审核的核查记录出错", e);
// }
}
@Override
......
attendance-performance-manager/src/main/java/com/mortals/xhx/module/check/service/impl/CheckComplainRecordServiceImpl.java
View file @ 8729d10b
......@@ -137,17 +137,17 @@ public class CheckComplainRecordServiceImpl extends AbstractCRUDServiceImpl<Chec
log.error("新增绩效异常信息核查状态出错", e);
}
try {
StaffCheckSummaryQuery query = new StaffCheckSummaryQuery();
query.setStaffId(entity.getStaffId());
query.setCheckTimeStart(DateUtils.getStrDate(entity.getCheckTime()));
query.setCheckTimeEnd(query.getCheckTimeStart());
query.setCheckType(CheckTypeEnum.评价绩效.getValue());
cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
//summaryCheck(query);
} catch (Exception e) {
log.error("汇总已审核的核查记录出错", e);
}
// try {
// StaffCheckSummaryQuery query = new StaffCheckSummaryQuery();
// query.setStaffId(entity.getStaffId());
// query.setCheckTimeStart(DateUtils.getStrDate(entity.getCheckTime()));
// query.setCheckTimeEnd(query.getCheckTimeStart());
// query.setCheckType(CheckTypeEnum.评价绩效.getValue());
// cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
// //summaryCheck(query);
// } catch (Exception e) {
// log.error("汇总已审核的核查记录出错", e);
// }
}
@Override
......
attendance-performance-manager/src/main/java/com/mortals/xhx/module/check/service/impl/CheckEffectRecordServiceImpl.java
View file @ 8729d10b
......@@ -132,17 +132,17 @@ public class CheckEffectRecordServiceImpl extends AbstractCRUDServiceImpl<CheckE
// log.error("新增绩效异常信息核查状态出错", e);
// }
try{
StaffCheckSummaryQuery query = new StaffCheckSummaryQuery();
query.setStaffId(entity.getStaffId());
query.setCheckTimeStart(DateUtils.getStrDate(entity.getCheckTime()));
query.setCheckTimeEnd(query.getCheckTimeStart());
query.setCheckType(CheckTypeEnum.效能绩效.getValue());
cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
//summaryCheck(query);
}catch (Exception e){
log.error("汇总已审核的核查记录出错",e);
}
// try{
// StaffCheckSummaryQuery query = new StaffCheckSummaryQuery();
// query.setStaffId(entity.getStaffId());
// query.setCheckTimeStart(DateUtils.getStrDate(entity.getCheckTime()));
// query.setCheckTimeEnd(query.getCheckTimeStart());
// query.setCheckType(CheckTypeEnum.效能绩效.getValue());
// cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
// //summaryCheck(query);
// }catch (Exception e){
// log.error("汇总已审核的核查记录出错",e);
// }
}
@Override
......
attendance-performance-manager/src/main/java/com/mortals/xhx/module/check/service/impl/CheckGoworkRecordServiceImpl.java
View file @ 8729d10b
......@@ -133,17 +133,17 @@ public class CheckGoworkRecordServiceImpl extends AbstractCRUDServiceImpl<CheckG
}catch (Exception e) {
log.error("新增绩效异常信息核查状态出错", e);
}
try{
StaffCheckSummaryQuery query = new StaffCheckSummaryQuery();
query.setStaffId(entity.getStaffId());
query.setCheckTimeStart(DateUtils.getStrDate(entity.getCheckTime()));
query.setCheckTimeEnd(query.getCheckTimeStart());
query.setCheckType(CheckTypeEnum.办件绩效.getValue());
cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
//summaryCheck(query);
}catch (Exception e){
log.error("汇总已审核的核查记录出错",e);
}
// try{
// StaffCheckSummaryQuery query = new StaffCheckSummaryQuery();
// query.setStaffId(entity.getStaffId());
// query.setCheckTimeStart(DateUtils.getStrDate(entity.getCheckTime()));
// query.setCheckTimeEnd(query.getCheckTimeStart());
// query.setCheckType(CheckTypeEnum.办件绩效.getValue());
// cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
// //summaryCheck(query);
// }catch (Exception e){
// log.error("汇总已审核的核查记录出错",e);
// }
}
@Override
......
attendance-performance-manager/src/main/java/com/mortals/xhx/module/check/service/impl/CheckOtherRecordServiceImpl.java
View file @ 8729d10b
......@@ -134,17 +134,17 @@ public class CheckOtherRecordServiceImpl extends AbstractCRUDServiceImpl<CheckOt
}catch (Exception e) {
log.error("新增绩效异常信息核查状态出错", e);
}
try {
StaffCheckSummaryQuery query = new StaffCheckSummaryQuery();
query.setStaffId(entity.getStaffId());
query.setCheckTimeStart(DateUtils.getStrDate(entity.getCheckTime()));
query.setCheckTimeEnd(query.getCheckTimeStart());
query.setCheckType(CheckTypeEnum.其它绩效.getValue());
cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
//summaryCheck(query);
} catch (Exception e) {
log.error("汇总已审核的核查记录出错", e);
}
// try {
// StaffCheckSummaryQuery query = new StaffCheckSummaryQuery();
// query.setStaffId(entity.getStaffId());
// query.setCheckTimeStart(DateUtils.getStrDate(entity.getCheckTime()));
// query.setCheckTimeEnd(query.getCheckTimeStart());
// query.setCheckType(CheckTypeEnum.其它绩效.getValue());
// cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
// //summaryCheck(query);
// } catch (Exception e) {
// log.error("汇总已审核的核查记录出错", e);
// }
}
@Override
......
attendance-performance-manager/src/main/java/com/mortals/xhx/module/check/service/impl/CheckReviewRecordServiceImpl.java
View file @ 8729d10b
......@@ -136,17 +136,17 @@ public class CheckReviewRecordServiceImpl extends AbstractCRUDServiceImpl<CheckR
}catch (Exception e) {
log.error("新增绩效异常信息核查状态出错", e);
}
try {
StaffCheckSummaryQuery query = new StaffCheckSummaryQuery();
query.setStaffId(entity.getStaffId());
query.setCheckTimeStart(DateUtils.getStrDate(entity.getCheckTime()));
query.setCheckTimeEnd(query.getCheckTimeStart());
query.setCheckType(CheckTypeEnum.评价绩效.getValue());
cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
//summaryCheck(query);
} catch (Exception e) {
log.error("汇总已审核的核查记录出错", e);
}
// try {
// StaffCheckSummaryQuery query = new StaffCheckSummaryQuery();
// query.setStaffId(entity.getStaffId());
// query.setCheckTimeStart(DateUtils.getStrDate(entity.getCheckTime()));
// query.setCheckTimeEnd(query.getCheckTimeStart());
// query.setCheckType(CheckTypeEnum.评价绩效.getValue());
// cacheService.lpush(KEY_CHECK_SUMMARY_CACHE, query);
// //summaryCheck(query);
// } catch (Exception e) {
// log.error("汇总已审核的核查记录出错", e);
// }
}
@Override
......
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