by2025/SmartParks
9
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

refactor(sis): 1

Browse Source
This commit is contained in:
zcxlsm 2025-07-27 22:00:41 +08:00
parent 56dcc609d1
commit b857a2121b
1 changed files with 37 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
ruoyi-modules/Sis/src/main/java/org/dromara/sis/config/timer/AuthTimer.java
View File

@ -63,52 +63,56 @@ public class AuthTimer {
@Scheduled(cron = "0 */2 * * * ?") @Scheduled(cron = "0 */2 * * * ?")
public void autoAuth() { public void autoAuth() {
AtomicReference<List<RemoteResidentPersonVo>> unAuthPersonRef = new AtomicReference<>(new ArrayList<>()); AtomicReference<List<RemoteResidentPersonVo>> unAuthPersonRef = new AtomicReference<>(new ArrayList<>());
AtomicReference<byte[]> imgByteRef = new AtomicReference<>(new byte[0]);
// 需要先设置模拟上下文 // 需要先设置模拟上下文
SaTokenContextMockUtil.setMockContext(() -> { SaTokenContextMockUtil.setMockContext(() -> {
// 模拟登录 // 模拟登录
StpUtil.login(-8); // 模拟登录 StpUtil.login(1); // 模拟登录
unAuthPersonRef.set(remoteResidentPersonService.queryUnAuthPerson()); unAuthPersonRef.set(remoteResidentPersonService.queryUnAuthPerson());
}); List<RemoteResidentPersonVo> unAuthPerson = unAuthPersonRef.get();
List<RemoteResidentPersonVo> unAuthPerson = unAuthPersonRef.get();
if (CollUtil.isNotEmpty(unAuthPerson)) {
try { try {
for (RemoteResidentPersonVo person : unAuthPerson) { if (CollUtil.isNotEmpty(unAuthPerson)) {
log.info("开始定时授权：{}", person.getId()); for (RemoteResidentPersonVo person : unAuthPerson) {
log.info("开始定时授权：{}", person.getId());
// 判断是否已存在授权
SisAuthRecordVo authRecord = sisAuthRecordService.queryByGroupIdAndPersonId(person.getAuthGroupId(), person.getId());
if (ObjectUtil.isEmpty(authRecord)) {
// 无授权记录时，补录
this.syncAuthRecord(person);
}
imgByteRef.set(remoteFileService.downloadToByteArray(Long.parseLong(person.getOssId())));
// 读取人像
byte[] imgByte = imgByteRef.get();
if (imgByte == null) continue;
// 写入华为盒子
Long huaweiId = syncHuaweiBox(person, imgByte);
if (huaweiId == null) continue;
// 更新人像信息huaweiBoxId
Boolean update = sisPersonLibImgService.updateByPersonId(person.getId(), huaweiId);
if (!update) continue;
// 同步E8平台
Long e8Id = syncE8Plat(person, imgByte);
if (e8Id == null) continue;
// 更新入驻员工E8平台id
remoteResidentPersonService.updateE8Id(person.getId(), e8Id);
// 判断是否已存在授权
SisAuthRecordVo authRecord = sisAuthRecordService.queryByGroupIdAndPersonId(person.getAuthGroupId(), person.getId());
if (ObjectUtil.isEmpty(authRecord)) {
// 无授权记录时，补录
this.syncAuthRecord(person);
} }
// 读取人像 } else {
byte[] imgByte = remoteFileService.downloadToByteArray(Long.parseLong(person.getOssId())); log.info("无待授权人员");
if (imgByte == null) continue;
// 写入华为盒子
Long huaweiId = syncHuaweiBox(person, imgByte);
if (huaweiId == null) continue;
// 更新人像信息huaweiBoxId
Boolean update = sisPersonLibImgService.updateByPersonId(person.getId(), huaweiId);
if (!update) continue;
// 同步E8平台
Long e8Id = syncE8Plat(person, imgByte);
if (e8Id == null) continue;
// 更新入驻员工E8平台id
remoteResidentPersonService.updateE8Id(person.getId(), e8Id);
} }
} catch (Exception e) { } catch (Exception e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
} else { });
log.info("无待授权人员");
}
} }
private void syncAuthRecord(RemoteResidentPersonVo person) { private void syncAuthRecord(RemoteResidentPersonVo person) {