Guwan
/
cqyt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

v10:增加考勤

This commit is contained in:
gaoben 2024-08-14 11:08:22 +08:00
parent 75cc8af2cb
commit e81d002324
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
shapelight-admin/src/main/java/net/shapelight/modules/httpapi/service/RecordSaveSyncService.java
View File

@ -4,7 +4,10 @@ package net.shapelight.modules.httpapi.service;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import net.shapelight.modules.ten.entity.TenPersonEntity;
import net.shapelight.modules.ten.entity.TenRecordEntity; import net.shapelight.modules.ten.entity.TenRecordEntity;
import net.shapelight.modules.ten.service.TenCheckService;
import net.shapelight.modules.ten.service.TenPersonService;
import net.shapelight.modules.ten.service.TenRecordService; import net.shapelight.modules.ten.service.TenRecordService;
import org.apache.commons.io.FileUtils; import org.apache.commons.io.FileUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -22,6 +25,10 @@ import java.util.concurrent.ConcurrentLinkedQueue;
public class RecordSaveSyncService implements ApplicationRunner { public class RecordSaveSyncService implements ApplicationRunner {
@Autowired @Autowired
private TenRecordService tenRecordService; private TenRecordService tenRecordService;
@Autowired
private TenPersonService tenPersonService;
@Autowired
private TenCheckService tenCheckService;
private final ConcurrentLinkedQueue<TenRecordEntity> queue = new ConcurrentLinkedQueue<>(); private final ConcurrentLinkedQueue<TenRecordEntity> queue = new ConcurrentLinkedQueue<>();
@ -37,6 +44,14 @@ public class RecordSaveSyncService implements ApplicationRunner {
if (record != null) { if (record != null) {
log.debug("异步保存识别记录................................"); log.debug("异步保存识别记录................................");
tenRecordService.saveServer(record); tenRecordService.saveServer(record);
// 考勤记录，没有删除的人记录考勤
TenPersonEntity memberEntity = tenPersonService.getById(record.getPersonId(),record.getCellId());
if(memberEntity!=null){
if(memberEntity.getDeleteFlag().intValue() == 0){
tenCheckService.saveCheck(memberEntity,record);
}
}
} }
Thread.sleep(100); Thread.sleep(100);
} }