添加同步计算每日考勤

attendance-performance-manager/src/main/java/com/mortals/xhx/daemon/task/SyncDoorsEventTaskImpl.java

@@ -6,8 +6,11 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.mortals.framework.common.Rest;
 import com.mortals.framework.exception.AppException;
+import com.mortals.framework.model.Context;
 import com.mortals.framework.service.ITask;
 import com.mortals.framework.service.ITaskExcuteService;
+import com.mortals.framework.util.DateUtils;
+import com.mortals.xhx.base.system.user.model.UserEntity;
 import com.mortals.xhx.common.code.YesNoEnum;
 import com.mortals.xhx.module.attendance.model.AttendanceRecordHikEntity;
 import com.mortals.xhx.module.attendance.model.AttendanceRecordHikQuery;
@@ -49,6 +52,29 @@ public class SyncDoorsEventTaskImpl implements ITaskExcuteService {
 
     @Override
     public void excuteTask(ITask task) throws AppException {
+        syncDoorEvents();
+
+        calculateAttendByDay();
+    }
+
+    private void calculateAttendByDay() {
+        Context context = new Context();
+        UserEntity userEntity = new UserEntity();
+        userEntity.setCreateUserId(1L);
+        userEntity.setCreateUserName("system");
+        userEntity.setCreateTime(new Date());
+        context.setUser(userEntity);
+        AttendanceRecordHikQuery recordHikEntity = new AttendanceRecordHikQuery();
+        recordHikEntity.setAttendanceDateStart(DateUtils.getCurrStrDate());
+        recordHikEntity.setAttendanceDateEnd(DateUtils.getCurrStrDate());
+        try {
+            recordHikService.addAttendanceRecord(recordHikEntity, context);
+        } catch (Exception e) {
+            log.error("计算考勤异常", e);
+        }
+    }
+
+    private void syncDoorEvents() {
         DoorEventReq doorEventReq = new DoorEventReq();
         List<Integer> eventTypes = new ArrayList<>();
         eventTypes.add(196885);
@@ -77,15 +103,14 @@ public class SyncDoorsEventTaskImpl implements ITaskExcuteService {
             for (int i = 1; i <= pageCount; i++) {
                 doorEventReq.setPageNo(i);
                 doorEventReq.setPageSize(1000);
-                 doorEventsRest = hikDoorService.getDoorEvents(doorEventReq);
-                log.info("doorEventsRest:{} msg:{},page:{}", doorEventsRest.getCode(), doorEventsRest.getMsg(),doorEventReq.getPageNo());
-                getDoorEvents( doorEventsRest);
+                doorEventsRest = hikDoorService.getDoorEvents(doorEventReq);
+                log.info("doorEventsRest:{} msg:{},page:{}", doorEventsRest.getCode(), doorEventsRest.getMsg(), doorEventReq.getPageNo());
+                getDoorEvents(doorEventsRest);
             }
         }
-
     }
 
-    private void getDoorEvents( Rest<DoorEventDataInfo> doorEventsRest) {
+    private void getDoorEvents(Rest<DoorEventDataInfo> doorEventsRest) {
         //同步当前考勤数据
         List<AttendanceRecordHikEntity> attRecords = doorEventsRest.getData().getList().stream().map(item -> {
             AttendanceRecordHikEntity recordHikEntity = new AttendanceRecordHikEntity();

attendance-performance-manager/src/main/java/com/mortals/xhx/module/attendance/service/impl/AttendanceRecordServiceImpl.java

@@ -32,7 +32,6 @@ public class AttendanceRecordServiceImpl extends AbstractCRUDServiceImpl<Attenda
 
     @Override
     protected void findAfter(AttendanceRecordEntity params, PageInfo pageInfo, Context context, List<AttendanceRecordEntity> list) throws AppException {
-
         list.stream().map(item->{
             //chax
             List<AttendanceRecordDetailEntity> attendanceRecordDetailEntities = attendanceRecordDetailService.find(new AttendanceRecordDetailQuery().recordId(item.getId()));