package jnpf.bizcommon.onlyoffice.service.impl;
|
|
import cn.hutool.crypto.digest.DigestUtil;
|
import jnpf.exception.DataException;
|
import lombok.RequiredArgsConstructor;
|
import org.redisson.api.RBucket;
|
import org.redisson.api.RedissonClient;
|
import org.springframework.stereotype.Component;
|
|
import java.util.concurrent.TimeUnit;
|
|
/** 跨实例保存响应丢失后的冻结取消意图，阻止迟到请求重新取得 fence。 */
|
@Component
|
@RequiredArgsConstructor
|
class OnlyOfficeFreezeCancellationStore {
|
private static final String KEY_PREFIX = "jnpf:onlyoffice:record-freeze-cancel:";
|
private static final long RETENTION_DAYS = 7L;
|
|
private final RedissonClient redissonClient;
|
|
void cancel(String tenantId, String recordId, String fileId, String fileType, String token) {
|
try {
|
bucket(tenantId, recordId, fileId, fileType, token)
|
.set("1", RETENTION_DAYS, TimeUnit.DAYS);
|
} catch (RuntimeException e) {
|
throw new DataException("记录冻结取消状态写入失败，已拒绝继续处理");
|
}
|
}
|
|
boolean isCancelled(String tenantId, String recordId, String fileId, String fileType, String token) {
|
try {
|
return bucket(tenantId, recordId, fileId, fileType, token).get() != null;
|
} catch (RuntimeException e) {
|
throw new DataException("记录冻结取消状态读取失败，已拒绝继续处理");
|
}
|
}
|
|
private RBucket<String> bucket(String tenantId, String recordId, String fileId,
|
String fileType, String token) {
|
String identity = tenantId + '\u001f' + recordId + '\u001f' + fileId
|
+ '\u001f' + fileType + '\u001f' + token;
|
return redissonClient.getBucket(KEY_PREFIX + DigestUtil.sha256Hex(identity));
|
}
|
}
|
