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

添加每日接口同步考勤数据

parent b768109e
......@@ -68,7 +68,10 @@ public class SyncDoorsEventTaskImpl implements ITaskExcuteService {
doorEventReq.setPageSize(1000);
Rest<DoorEventDataInfo> doorEventsRest = hikDoorService.getDoorEvents(doorEventReq);
log.info("doorEventsRest:{}",doorEventsRest.getCode());
if (doorEventsRest.getCode() == YesNoEnum.YES.getValue()) {
//同步当前考勤数据
List<AttendanceRecordHikEntity> attRecords = doorEventsRest.getData().getList().stream().map(item -> {
AttendanceRecordHikEntity recordHikEntity = new AttendanceRecordHikEntity();
......@@ -94,6 +97,8 @@ public class SyncDoorsEventTaskImpl implements ITaskExcuteService {
return recordHikEntity;
}).collect(Collectors.toList());
log.info("attRecords size:{}",attRecords.size());
List<String> eventIds = attRecords.parallelStream().map(i -> i.getRemark()).collect(Collectors.toList());
//查询当天考勤记录是否有重复的 有的 则不添加
......@@ -108,6 +113,8 @@ public class SyncDoorsEventTaskImpl implements ITaskExcuteService {
recordHikService.save(saveRecordList);
}
log.info("saveRecordList size:{}",saveRecordList.size());
}
}
......
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