Commit b4be6fdc authored by 赵啸非's avatar 赵啸非

修改考勤汇总查询

parent d6e050c9
...@@ -109,7 +109,7 @@ public class SyncDoorsEventWeekTaskImpl implements ITaskExcuteService { ...@@ -109,7 +109,7 @@ public class SyncDoorsEventWeekTaskImpl implements ITaskExcuteService {
} }
log.info("开始计算及统计最近7天考勤!"); log.info("开始计算及统计最近7天考勤!");
String expire = cacheService.get(KEY_ATTENDANCE_STAT_LOCK_CACHE); String expire = cacheService.get(KEY_ATTENDANCE_STAT_LOCK_CACHE);
if(ObjectUtils.isEmpty(expire)) { if (ObjectUtils.isEmpty(expire)) {
AddAttendThread addAttendThread = new AddAttendThread(recordHikService, hikEntity, null); AddAttendThread addAttendThread = new AddAttendThread(recordHikService, hikEntity, null);
ThreadPool.getInstance().execute(addAttendThread); ThreadPool.getInstance().execute(addAttendThread);
} }
...@@ -126,13 +126,14 @@ public class SyncDoorsEventWeekTaskImpl implements ITaskExcuteService { ...@@ -126,13 +126,14 @@ public class SyncDoorsEventWeekTaskImpl implements ITaskExcuteService {
query.setStartTimeStart(hikEntity.getAttendanceDateStart()); query.setStartTimeStart(hikEntity.getAttendanceDateStart());
query.setEndTimeEnd(hikEntity.getAttendanceDateEnd()); query.setEndTimeEnd(hikEntity.getAttendanceDateEnd());
if (between > 120) return; if (between > 120) return;
Thread thread = new Thread(new Runnable() { Runnable runnable = new Runnable() {
@Override @Override
public void run() { public void run() {
attendanceLeaveRecordService.syncLeaveRecord(query, null); attendanceLeaveRecordService.syncLeaveRecord(query, null);
} }
}); };
ThreadPool.getInstance().execute(thread);
ThreadPool.getInstance().execute(runnable);
} }
......
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