package jnpf.elnService.template.impl;
|
|
import cn.hutool.core.util.IdUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import jnpf.audit.model.AuditEventDTO;
|
import jnpf.audit.sdk.AuditClient;
|
import jnpf.base.ActionResult;
|
import jnpf.base.ActionResultCode;
|
import jnpf.base.UserInfo;
|
import jnpf.database.util.TenantDataSourceUtil;
|
import jnpf.elnEntity.ElnDocumentFileVo;
|
import jnpf.elnEntity.template.ElnTemplateBindingEntity;
|
import jnpf.elnEntity.template.ElnTemplateCurrentVersionEntity;
|
import jnpf.elnEntity.template.ElnTemplateEnums;
|
import jnpf.elnEntity.template.ElnTemplateForms;
|
import jnpf.elnEntity.template.ElnTemplateVersionEntity;
|
import jnpf.elnEntity.template.ElnTemplateVos;
|
import jnpf.elnMapper.ElnTemplateMapper;
|
import jnpf.elnMapper.ElnTemplateBindingMapper;
|
import jnpf.elnMapper.ElnTemplateCurrentVersionMapper;
|
import jnpf.elnService.template.ElnTemplateCatalogService;
|
import jnpf.elnService.template.ElnTemplateFileService;
|
import jnpf.elnService.template.ElnTemplateHealthService;
|
import jnpf.elnService.template.ElnTemplatePublishValidator;
|
import jnpf.elnService.template.ElnTemplateRepeatGroupService;
|
import jnpf.elnService.template.ElnTemplateStepService;
|
import jnpf.exception.DataException;
|
import jnpf.model.tenant.TenantVO;
|
import jnpf.onlyoffice.TemplatePublishFenceApi;
|
import jnpf.permission.UserApi;
|
import jnpf.permission.entity.UserEntity;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.UserProvider;
|
import org.springframework.beans.factory.ObjectProvider;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.dao.DuplicateKeyException;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.PlatformTransactionManager;
|
import org.springframework.transaction.TransactionDefinition;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.support.TransactionTemplate;
|
import org.springframework.util.StringUtils;
|
|
import java.nio.charset.StandardCharsets;
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.Comparator;
|
import java.util.Date;
|
import java.util.LinkedHashMap;
|
import java.util.LinkedHashSet;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.Set;
|
import java.util.UUID;
|
import java.util.function.Consumer;
|
import java.util.function.Supplier;
|
import java.util.stream.Collectors;
|
|
@Service
|
public class ElnTemplateCatalogServiceImpl implements ElnTemplateCatalogService {
|
|
private static final String ENABLED = "enabled";
|
private static final int MAX_SOURCE_CHAIN_DEPTH = 32;
|
|
private final TemplateCatalogStore store;
|
private final Supplier<UserContext> userContextSupplier;
|
private final TargetIdFactory targetIdFactory;
|
private final Supplier<String> bindingIdSupplier;
|
private final TemplateFileCopier fileCopier;
|
private final Consumer<AuditEventDTO> auditRecorder;
|
private final TransactionRunner transactionRunner;
|
private final List<ElnTemplatePublishValidator> publishValidators;
|
private final TemplatePublishFence publishFence;
|
private final UserNameResolver userNameResolver;
|
private final VersionGroupCopier versionGroupCopier;
|
|
@Autowired
|
public ElnTemplateCatalogServiceImpl(ElnTemplateMapper templateMapper,
|
ElnTemplateBindingMapper bindingMapper,
|
ElnTemplateCurrentVersionMapper currentMapper,
|
ElnTemplateFileService fileService,
|
ElnTemplateHealthService healthService,
|
ElnTemplateRepeatGroupService repeatGroupService,
|
ElnTemplateStepService stepService,
|
List<ElnTemplatePublishValidator> publishValidators,
|
ObjectProvider<AuditClient> auditClientProvider,
|
PlatformTransactionManager transactionManager,
|
TemplatePublishFenceApi publishFenceApi,
|
UserApi userApi) {
|
this(new MyBatisTemplateCatalogStore(templateMapper, bindingMapper, currentMapper),
|
ElnTemplateCatalogServiceImpl::currentUserContext,
|
ElnTemplateCatalogServiceImpl::deterministicTargetId,
|
IdUtil::getSnowflakeNextIdStr,
|
fileService::copyDocx,
|
event -> {
|
AuditClient client = auditClientProvider.getIfAvailable();
|
if (client != null) {
|
client.record(event);
|
}
|
}, new SpringTransactionRunner(transactionManager),
|
withHealthValidator(healthService, publishValidators),
|
remotePublishFence(publishFenceApi), remoteUserNameResolver(userApi),
|
(tenantId, sourceTemplateId, targetTemplateId) -> {
|
repeatGroupService.copyForVersion(
|
tenantId, sourceTemplateId, targetTemplateId);
|
stepService.copyForVersion(tenantId, sourceTemplateId, targetTemplateId);
|
});
|
}
|
|
ElnTemplateCatalogServiceImpl(TemplateCatalogStore store,
|
Supplier<UserContext> userContextSupplier,
|
TargetIdFactory targetIdFactory,
|
Supplier<String> bindingIdSupplier,
|
TemplateFileCopier fileCopier,
|
Consumer<AuditEventDTO> auditRecorder) {
|
this(store, userContextSupplier, targetIdFactory, bindingIdSupplier,
|
fileCopier, auditRecorder, callback -> callback.get(), Collections.emptyList(),
|
TemplatePublishFence.noop(), userId -> userId);
|
}
|
|
ElnTemplateCatalogServiceImpl(TemplateCatalogStore store,
|
Supplier<UserContext> userContextSupplier,
|
TargetIdFactory targetIdFactory,
|
Supplier<String> bindingIdSupplier,
|
TemplateFileCopier fileCopier,
|
Consumer<AuditEventDTO> auditRecorder,
|
TransactionRunner transactionRunner) {
|
this(store, userContextSupplier, targetIdFactory, bindingIdSupplier, fileCopier,
|
auditRecorder, transactionRunner, Collections.emptyList(),
|
TemplatePublishFence.noop(), userId -> userId);
|
}
|
|
ElnTemplateCatalogServiceImpl(TemplateCatalogStore store,
|
Supplier<UserContext> userContextSupplier,
|
TargetIdFactory targetIdFactory,
|
Supplier<String> bindingIdSupplier,
|
TemplateFileCopier fileCopier,
|
Consumer<AuditEventDTO> auditRecorder,
|
TransactionRunner transactionRunner,
|
List<ElnTemplatePublishValidator> publishValidators) {
|
this(store, userContextSupplier, targetIdFactory, bindingIdSupplier, fileCopier,
|
auditRecorder, transactionRunner, publishValidators,
|
TemplatePublishFence.noop(), userId -> userId);
|
}
|
|
ElnTemplateCatalogServiceImpl(TemplateCatalogStore store,
|
Supplier<UserContext> userContextSupplier,
|
TargetIdFactory targetIdFactory,
|
Supplier<String> bindingIdSupplier,
|
TemplateFileCopier fileCopier,
|
Consumer<AuditEventDTO> auditRecorder,
|
TransactionRunner transactionRunner,
|
List<ElnTemplatePublishValidator> publishValidators,
|
TemplatePublishFence publishFence) {
|
this(store, userContextSupplier, targetIdFactory, bindingIdSupplier, fileCopier,
|
auditRecorder, transactionRunner, publishValidators, publishFence,
|
userId -> userId);
|
}
|
|
ElnTemplateCatalogServiceImpl(TemplateCatalogStore store,
|
Supplier<UserContext> userContextSupplier,
|
TargetIdFactory targetIdFactory,
|
Supplier<String> bindingIdSupplier,
|
TemplateFileCopier fileCopier,
|
Consumer<AuditEventDTO> auditRecorder,
|
TransactionRunner transactionRunner,
|
List<ElnTemplatePublishValidator> publishValidators,
|
TemplatePublishFence publishFence,
|
UserNameResolver userNameResolver) {
|
this(store, userContextSupplier, targetIdFactory, bindingIdSupplier, fileCopier,
|
auditRecorder, transactionRunner, publishValidators, publishFence,
|
userNameResolver, (tenantId, sourceTemplateId, targetTemplateId) -> { });
|
}
|
|
ElnTemplateCatalogServiceImpl(TemplateCatalogStore store,
|
Supplier<UserContext> userContextSupplier,
|
TargetIdFactory targetIdFactory,
|
Supplier<String> bindingIdSupplier,
|
TemplateFileCopier fileCopier,
|
Consumer<AuditEventDTO> auditRecorder,
|
TransactionRunner transactionRunner,
|
List<ElnTemplatePublishValidator> publishValidators,
|
TemplatePublishFence publishFence,
|
UserNameResolver userNameResolver,
|
VersionGroupCopier versionGroupCopier) {
|
this.store = store;
|
this.userContextSupplier = userContextSupplier;
|
this.targetIdFactory = targetIdFactory;
|
this.bindingIdSupplier = bindingIdSupplier;
|
this.fileCopier = fileCopier;
|
this.auditRecorder = auditRecorder;
|
this.transactionRunner = transactionRunner;
|
this.publishValidators = publishValidators == null
|
? Collections.emptyList() : new ArrayList<>(publishValidators);
|
this.publishFence = publishFence;
|
this.userNameResolver = userNameResolver;
|
this.versionGroupCopier = versionGroupCopier;
|
}
|
|
@Override
|
@Transactional(readOnly = true)
|
public IPage<ElnTemplateVos.ListItem> page(ElnTemplateForms.Query query) {
|
UserContext context = requireContext();
|
ElnTemplateForms.Query actual = query == null ? new ElnTemplateForms.Query() : query;
|
if (actual.getCurrentPage() < 1 || actual.getPageSize() < 1) {
|
throw new DataException("分页参数无效");
|
}
|
IPage<ElnTemplateVersionEntity> entities = store.page(context.getTenantId(), actual);
|
Page<ElnTemplateVos.ListItem> result = new Page<>(entities.getCurrent(), entities.getSize());
|
result.setTotal(entities.getTotal());
|
List<String> templateCodes = entities.getRecords().stream()
|
.map(ElnTemplateVersionEntity::getMubanBianhao)
|
.filter(StringUtils::hasText).distinct().collect(Collectors.toList());
|
Map<String, String> currentTemplateIds = store.listCurrentVersions(
|
context.getTenantId(), templateCodes).stream()
|
.collect(Collectors.toMap(ElnTemplateCurrentVersionEntity::getMubanBianhao,
|
ElnTemplateCurrentVersionEntity::getDangqianMubanId,
|
(first, second) -> first, LinkedHashMap::new));
|
List<String> templateIds = entities.getRecords().stream()
|
.map(ElnTemplateVersionEntity::getId).collect(Collectors.toList());
|
Map<String, Set<String>> fieldsByTemplate = new LinkedHashMap<>();
|
for (ElnTemplateBindingEntity binding : store.listActiveBindingsByTemplateIds(
|
context.getTenantId(), templateIds)) {
|
if (StringUtils.hasText(binding.getZiduanDingyiId())) {
|
fieldsByTemplate.computeIfAbsent(
|
binding.getMubanId(), key -> new LinkedHashSet<>())
|
.add(binding.getZiduanDingyiId());
|
}
|
}
|
List<ElnTemplateVos.ListItem> records = new ArrayList<>();
|
for (ElnTemplateVersionEntity entity : entities.getRecords()) {
|
ElnTemplateVos.ListItem item = toListItem(entity);
|
item.setShifouDangqian(Objects.equals(entity.getId(),
|
currentTemplateIds.get(entity.getMubanBianhao())));
|
item.setZiduanShu((long) fieldsByTemplate
|
.getOrDefault(entity.getId(), Collections.emptySet()).size());
|
records.add(item);
|
}
|
result.setRecords(records);
|
return result;
|
}
|
|
@Override
|
@Transactional(readOnly = true)
|
public IPage<ElnTemplateVos.CatalogItem> directory(ElnTemplateForms.Query query) {
|
UserContext context = requireContext();
|
ElnTemplateForms.Query actual = query == null ? new ElnTemplateForms.Query() : query;
|
if (actual.getCurrentPage() < 1 || actual.getPageSize() < 1) {
|
throw new DataException("分页参数无效");
|
}
|
IPage<ElnTemplateVos.CatalogItem> result = store.pageDirectory(
|
context.getTenantId(), actual);
|
List<String> effectiveTemplateIds = result.getRecords().stream()
|
.map(ElnTemplateVos.CatalogItem::getShengxiaoMubanId)
|
.filter(StringUtils::hasText).collect(Collectors.toList());
|
Map<String, Set<String>> fieldsByTemplate = new LinkedHashMap<>();
|
for (ElnTemplateBindingEntity binding : store.listActiveBindingsByTemplateIds(
|
context.getTenantId(), effectiveTemplateIds)) {
|
if (StringUtils.hasText(binding.getZiduanDingyiId())) {
|
fieldsByTemplate.computeIfAbsent(
|
binding.getMubanId(), key -> new LinkedHashSet<>())
|
.add(binding.getZiduanDingyiId());
|
}
|
}
|
for (ElnTemplateVos.CatalogItem item : result.getRecords()) {
|
if (StringUtils.hasText(item.getShengxiaoMubanId())) {
|
item.setZiduanShu((long) fieldsByTemplate.getOrDefault(
|
item.getShengxiaoMubanId(), Collections.emptySet()).size());
|
}
|
}
|
return result;
|
}
|
|
@Override
|
@Transactional(readOnly = true)
|
public ElnTemplateVos.Detail detail(String templateId) {
|
UserContext context = requireContext();
|
ElnTemplateVersionEntity current = requireTemplate(context.getTenantId(), templateId);
|
ElnTemplateVos.Detail result = toDetail(current);
|
mergeSourceChain(context.getTenantId(), current, result);
|
enrichDetailNames(result);
|
return result;
|
}
|
|
@Override
|
public ElnTemplateVos.Detail createVersion(String sourceTemplateId,
|
ElnTemplateForms.CreateVersion form) {
|
UserContext context = requireContext();
|
validateCreateVersion(sourceTemplateId, form);
|
String sourceId = sourceTemplateId.trim();
|
String operation = form.getShengbanCaozuoBianma().trim();
|
String businessVersion = form.getMubanBanben().trim();
|
Date effectiveDate = form.getShengxiaoRiqi();
|
try {
|
return transactionRunner.execute(() -> createVersionInTransaction(
|
context, sourceId, businessVersion, operation, effectiveDate));
|
} catch (DuplicateKeyException e) {
|
return transactionRunner.execute(() -> resolveConcurrentConflict(
|
context, sourceId, businessVersion, operation, effectiveDate));
|
}
|
}
|
|
private ElnTemplateVos.Detail createVersionInTransaction(
|
UserContext context, String sourceId, String businessVersion,
|
String operation, Date effectiveDate) {
|
String tenantId = context.getTenantId();
|
ElnTemplateVersionEntity existing = store.findByOperation(tenantId, operation);
|
if (existing != null) {
|
return completeIdempotentRetry(
|
context, sourceId, businessVersion, operation, effectiveDate, existing);
|
}
|
|
ElnTemplateVersionEntity source = requireTemplateForUpdate(tenantId, sourceId);
|
if (store.findByCodeAndVersion(tenantId, source.getMubanBianhao(), businessVersion) != null) {
|
throw new DataException("同名模板业务版本已存在");
|
}
|
|
String targetId = targetIdFactory.create(tenantId, sourceId, operation);
|
ElnTemplateVersionEntity target = new ElnTemplateVersionEntity();
|
target.setId(targetId);
|
target.setFTenantId(tenantId);
|
target.setMubanBianhao(source.getMubanBianhao());
|
target.setMubanBanben(businessVersion);
|
target.setMubanMingcheng(source.getMubanMingcheng());
|
target.setShiyanBuzhou(source.getShiyanBuzhou());
|
target.setJianyanXiangmu(source.getJianyanXiangmu());
|
target.setJianyanXiangmuBianma(source.getJianyanXiangmuBianma());
|
target.setJianyanXiangmuMingcheng(source.getJianyanXiangmuMingcheng());
|
target.setMubanFenlei(source.getMubanFenlei());
|
target.setMubanFenleiMingcheng(source.getMubanFenleiMingcheng());
|
target.setShengxiaoRiqi(effectiveDate);
|
target.setBizStatus(ElnTemplateEnums.TemplateStatus.DRAFT.name());
|
target.setBizEnabled(ENABLED);
|
target.setLaiyuanMubanId(sourceId);
|
target.setShengbanCaozuoBianma(operation);
|
Date createdAt = new Date();
|
target.setChuangjianRenyuan(context.getUserId());
|
target.setChuangjianShijian(createdAt);
|
target.setFCreatorUserId(context.getUserId());
|
target.setFCreatorTime(createdAt);
|
target.setFVersion(0);
|
target.setFDeleteMark(0);
|
store.insertTemplate(target);
|
|
String attachmentJson = fileCopier.copy(source.getMubanFile(), targetId);
|
target.setMubanFile(attachmentJson);
|
store.updateTemplateFile(target);
|
|
List<ElnTemplateBindingEntity> sourceBindings =
|
store.listActiveBindings(tenantId, sourceId);
|
Map<String, ElnTemplateBindingEntity> sourceBindingsById = new LinkedHashMap<>();
|
Map<String, String> targetBindingIds = new LinkedHashMap<>();
|
for (ElnTemplateBindingEntity sourceBinding : sourceBindings) {
|
if (!StringUtils.hasText(sourceBinding.getId())
|
|| sourceBindingsById.put(sourceBinding.getId(), sourceBinding) != null) {
|
throw new DataException("源模板绑定集合无效");
|
}
|
String targetBindingId = bindingIdSupplier.get();
|
if (!StringUtils.hasText(targetBindingId)
|
|| targetBindingIds.containsValue(targetBindingId)) {
|
throw new DataException("目标模板绑定 ID 生成失败");
|
}
|
targetBindingIds.put(sourceBinding.getId(), targetBindingId);
|
}
|
for (ElnTemplateBindingEntity sourceBinding : sourceBindings) {
|
store.insertBinding(copyBinding(sourceBinding, target, operation,
|
sourceBindingsById, targetBindingIds));
|
}
|
versionGroupCopier.copy(tenantId, sourceId, targetId);
|
auditVersionCreate(context, operation, sourceId, targetId, "SUCCESS");
|
return toDetail(target);
|
}
|
|
private ElnTemplateVos.Detail resolveConcurrentConflict(
|
UserContext context, String sourceId, String businessVersion,
|
String operation, Date effectiveDate) {
|
String tenantId = context.getTenantId();
|
ElnTemplateVersionEntity existing = store.findByOperation(tenantId, operation);
|
if (existing != null) {
|
return completeIdempotentRetry(
|
context, sourceId, businessVersion, operation, effectiveDate, existing);
|
}
|
ElnTemplateVersionEntity source = requireTemplate(tenantId, sourceId);
|
if (store.findByCodeAndVersion(tenantId, source.getMubanBianhao(), businessVersion) != null) {
|
throw new DataException("同名模板业务版本已存在");
|
}
|
throw new DataException("模板升版并发冲突，请重试");
|
}
|
|
private ElnTemplateVos.Detail completeIdempotentRetry(
|
UserContext context, String sourceId, String businessVersion,
|
String operation, Date effectiveDate, ElnTemplateVersionEntity existing) {
|
if (!sourceId.equals(existing.getLaiyuanMubanId())
|
|| !businessVersion.equals(existing.getMubanBanben())
|
|| !sameInstant(effectiveDate, existing.getShengxiaoRiqi())) {
|
throw new DataException("升版操作码已用于其他模板版本");
|
}
|
ElnTemplateVersionEntity source = requireTemplate(context.getTenantId(), sourceId);
|
String attachmentJson = fileCopier.copy(source.getMubanFile(), existing.getId());
|
existing.setMubanFile(attachmentJson);
|
store.updateTemplateFile(existing);
|
versionGroupCopier.copy(context.getTenantId(), sourceId, existing.getId());
|
auditVersionCreate(context, operation, sourceId, existing.getId(), "IDEMPOTENT");
|
return toDetail(existing);
|
}
|
|
private static boolean sameInstant(Date left, Date right) {
|
return left == null ? right == null
|
: right != null && left.getTime() == right.getTime();
|
}
|
|
@Override
|
public void publish(String templateId, String reason) {
|
UserContext context = requireContext();
|
ElnTemplateVersionEntity snapshot = requireTemplate(context.getTenantId(), templateId);
|
if (!ElnTemplateEnums.TemplateStatus.DRAFT.name().equals(snapshot.getBizStatus())) {
|
throw new DataException("只有草稿模板可以发布");
|
}
|
String fileId = uniqueDocxFileId(snapshot.getMubanFile());
|
String fileType = "annex";
|
String token = publishFence.acquire(
|
context.getTenantId(), snapshot.getId(), fileId, fileType);
|
try {
|
transactionRunner.execute(() -> {
|
publishInTransaction(context, snapshot.getId(), fileId, reason);
|
return null;
|
});
|
} catch (RuntimeException publishError) {
|
try {
|
publishFence.release(context.getTenantId(), snapshot.getId(),
|
fileId, fileType, token);
|
} catch (RuntimeException releaseError) {
|
publishError.addSuppressed(releaseError);
|
}
|
throw publishError;
|
}
|
try {
|
publishFence.release(context.getTenantId(), snapshot.getId(), fileId, fileType, token);
|
} catch (RuntimeException releaseError) {
|
DataException result = new DataException(
|
"模板已发布成功，但 OnlyOffice 发布锁释放失败，需人工恢复并刷新页面");
|
result.addSuppressed(releaseError);
|
throw result;
|
}
|
}
|
|
private void publishInTransaction(UserContext context, String templateId,
|
String fencedFileId, String reason) {
|
ElnTemplateVersionEntity template = requireTemplateForUpdate(
|
context.getTenantId(), templateId);
|
if (!ElnTemplateEnums.TemplateStatus.DRAFT.name().equals(template.getBizStatus())) {
|
throw new DataException("只有草稿模板可以发布");
|
}
|
if (!fencedFileId.equals(uniqueDocxFileId(template.getMubanFile()))) {
|
throw new DataException("模板附件已变化，请刷新后重试");
|
}
|
ElnTemplateVersionEntity changed = copyTemplate(template);
|
changed.setMubanFile(fileCopier.copy(template.getMubanFile(),
|
template.getId() + "-published"));
|
validateForPublish(changed);
|
changed.setBizStatus(ElnTemplateEnums.TemplateStatus.PUBLISHED.name());
|
touch(changed, context);
|
store.updateTemplateLifecycle(changed);
|
makeFirstRunnableVersionCurrent(context, changed);
|
auditLifecycle("ELN_TEMPLATE_PUBLISH", "发布 ELN 模板版本", changed.getId(),
|
context, template, changed, trimToNull(reason));
|
}
|
|
private void makeFirstRunnableVersionCurrent(UserContext context,
|
ElnTemplateVersionEntity published) {
|
ElnTemplateCurrentVersionEntity current = store.findCurrent(
|
context.getTenantId(), published.getMubanBianhao());
|
if (current != null
|
|| !ENABLED.equals(published.getBizEnabled())
|
|| published.getShengxiaoRiqi() == null
|
|| published.getShengxiaoRiqi().after(new Date())) {
|
return;
|
}
|
insertCurrent(context, published);
|
}
|
|
private static String uniqueDocxFileId(String attachments) {
|
try {
|
List<ElnDocumentFileVo> files = JsonUtil.getJsonToList(attachments, ElnDocumentFileVo.class);
|
List<String> docxFileIds = files == null ? Collections.emptyList() : files.stream()
|
.filter(Objects::nonNull)
|
.filter(file -> "docx".equalsIgnoreCase(file.getFileExtension())
|
|| StringUtils.hasText(file.getFileId())
|
&& file.getFileId().toLowerCase().endsWith(".docx"))
|
.map(ElnDocumentFileVo::getFileId)
|
.filter(StringUtils::hasText)
|
.collect(Collectors.toList());
|
if (docxFileIds.size() != 1) {
|
throw new DataException("模板必须且只能包含一个 DOCX 附件");
|
}
|
return docxFileIds.get(0);
|
} catch (DataException e) {
|
throw e;
|
} catch (RuntimeException e) {
|
throw new DataException("模板附件无效");
|
}
|
}
|
|
@Override
|
@Transactional
|
public void enable(String templateId, String reason) {
|
changeEnabled(templateId, ENABLED, requireReason(reason),
|
"ELN_TEMPLATE_ENABLE", "启用 ELN 模板版本");
|
}
|
|
@Override
|
@Transactional
|
public void disable(String templateId, String reason) {
|
changeEnabled(templateId, "disabled", requireReason(reason),
|
"ELN_TEMPLATE_DISABLE", "停用 ELN 模板版本");
|
}
|
|
@Override
|
@Transactional
|
public void switchCurrent(String templateCode, String templateId, String reason) {
|
UserContext context = requireContext();
|
String actualReason = requireReason(reason);
|
if (!StringUtils.hasText(templateCode)) {
|
throw new DataException("模板编号不能为空");
|
}
|
String actualCode = templateCode.trim();
|
ElnTemplateVersionEntity target = requireTemplateForUpdate(
|
context.getTenantId(), templateId);
|
if (!actualCode.equals(target.getMubanBianhao())) {
|
throw new DataException("模板编号与目标版本不一致");
|
}
|
if (!ElnTemplateEnums.TemplateStatus.PUBLISHED.name().equals(target.getBizStatus())
|
|| !ENABLED.equals(target.getBizEnabled())
|
|| target.getShengxiaoRiqi() == null
|
|| target.getShengxiaoRiqi().after(new Date())) {
|
throw new DataException("目标模板不具备设为当前版本的资格");
|
}
|
validateForPublish(target);
|
|
ElnTemplateCurrentVersionEntity current =
|
store.findCurrent(context.getTenantId(), actualCode);
|
String beforeTemplateId = current == null ? null : current.getDangqianMubanId();
|
if (current == null) {
|
insertCurrent(context, target);
|
} else {
|
ElnTemplateCurrentVersionEntity changed = copyCurrent(current);
|
changed.setDangqianMubanId(target.getId());
|
changed.setJianyanXiangmuBianma(target.getJianyanXiangmuBianma());
|
touch(changed, context);
|
store.updateCurrent(changed);
|
}
|
auditSwitch(context, actualReason, beforeTemplateId, target.getId());
|
}
|
|
private void insertCurrent(UserContext context, ElnTemplateVersionEntity target) {
|
ElnTemplateCurrentVersionEntity current = new ElnTemplateCurrentVersionEntity();
|
current.setId(IdUtil.getSnowflakeNextIdStr());
|
current.setFTenantId(context.getTenantId());
|
current.setMubanBianhao(target.getMubanBianhao());
|
current.setDangqianMubanId(target.getId());
|
current.setJianyanXiangmuBianma(target.getJianyanXiangmuBianma());
|
current.setFVersion(0);
|
current.setFDeleteMark(0);
|
current.setFCreatorUserId(context.getUserId());
|
touch(current, context);
|
try {
|
if (!store.insertCurrent(current)) {
|
throw new DataException("当前模板设置失败，请重试");
|
}
|
} catch (DuplicateKeyException e) {
|
throw new DataException("当前模板已被其他操作设置，请刷新后重试");
|
}
|
}
|
|
private void changeEnabled(String templateId, String targetEnabled, String reason,
|
String actionCode, String actionLabel) {
|
UserContext context = requireContext();
|
ElnTemplateVersionEntity template = requireTemplateForUpdate(
|
context.getTenantId(), templateId);
|
if (targetEnabled.equals(template.getBizEnabled())) {
|
throw new DataException(ENABLED.equals(targetEnabled) ? "模板已启用" : "模板已停用");
|
}
|
ElnTemplateVersionEntity changed = copyTemplate(template);
|
changed.setBizEnabled(targetEnabled);
|
touch(changed, context);
|
store.updateTemplateLifecycle(changed);
|
auditLifecycle(actionCode, actionLabel, changed.getId(), context,
|
template, changed, reason);
|
}
|
|
private void validateForPublish(ElnTemplateVersionEntity template) {
|
List<ElnTemplateVos.Diagnostic> diagnostics = new ArrayList<>();
|
ElnTemplateVos.Diagnostic attachment = attachmentDiagnostic(template.getMubanFile());
|
if (attachment != null) {
|
diagnostics.add(attachment);
|
}
|
for (ElnTemplatePublishValidator validator : publishValidators) {
|
if (validator == null) {
|
continue;
|
}
|
try {
|
List<ElnTemplateVos.Diagnostic> items = validator.validate(
|
template.getFTenantId(), template.getId(), template.getMubanFile());
|
if (items != null) {
|
diagnostics.addAll(items);
|
}
|
} catch (DataException e) {
|
diagnostics.add(diagnostic("ERROR", "TEMPLATE_VALIDATION_FAILED", e.getMessage()));
|
}
|
}
|
List<ElnTemplateVos.Diagnostic> errors = diagnostics.stream()
|
.filter(item -> item != null && "ERROR".equalsIgnoreCase(item.getSeverity()))
|
.collect(Collectors.toList());
|
if (!errors.isEmpty()) {
|
String message = errors.stream()
|
.map(item -> StringUtils.hasText(item.getMessage())
|
? item.getMessage() : "模板存在未说明的校验错误")
|
.collect(Collectors.joining("；"));
|
throw new DataException("模板发布校验失败：" + message);
|
}
|
}
|
|
private static ElnTemplateVos.Diagnostic attachmentDiagnostic(String attachments) {
|
try {
|
List<ElnDocumentFileVo> files = JsonUtil.getJsonToList(attachments, ElnDocumentFileVo.class);
|
long docxCount = files == null ? 0 : files.stream()
|
.filter(item -> item != null && StringUtils.hasText(item.getFileId()))
|
.filter(item -> "docx".equalsIgnoreCase(item.getFileExtension())
|
|| item.getFileId().toLowerCase().endsWith(".docx"))
|
.count();
|
return docxCount == 1 ? null : diagnostic("ERROR", "INVALID_DOCX_ATTACHMENT",
|
"模板必须且只能包含一个 DOCX 附件");
|
} catch (RuntimeException e) {
|
return diagnostic("ERROR", "INVALID_DOCX_ATTACHMENT", "模板附件无效");
|
}
|
}
|
|
static ElnTemplatePublishValidator healthValidator(ElnTemplateHealthService healthService) {
|
return new ElnTemplatePublishValidator() {
|
@Override
|
public List<ElnTemplateVos.Diagnostic> validate(String tenantId, String templateId) {
|
return validate(tenantId, templateId, null);
|
}
|
|
@Override
|
public List<ElnTemplateVos.Diagnostic> validate(
|
String tenantId, String templateId, String attachments) {
|
ElnTemplateHealthService.HealthReport report = healthService.inspect(templateId, attachments);
|
List<ElnTemplateVos.Diagnostic> result = new ArrayList<>();
|
if (report == null || report.getDiagnostics() == null) {
|
return result;
|
}
|
for (ElnTemplateHealthService.HealthDiagnostic source : report.getDiagnostics()) {
|
if (source == null) {
|
continue;
|
}
|
String severity = source.getSeverity();
|
if ("PENDING_BINDING".equals(source.getCode())
|
|| "PENDING_CONFIRMATION_REQUIRED".equals(source.getCode())
|
|| "FIELD_VERSION_NOT_PUBLISHED".equals(source.getCode())
|
|| "CHECKBOX_GROUP_SINGLE_MEMBER".equals(source.getCode())) {
|
severity = "ERROR";
|
}
|
ElnTemplateVos.Diagnostic target = diagnostic(
|
severity, source.getCode(), source.getMessage());
|
target.setBindingId(source.getBindingId());
|
target.setControlTag(source.getControlTag());
|
result.add(target);
|
}
|
return result;
|
}
|
};
|
}
|
|
private static List<ElnTemplatePublishValidator> withHealthValidator(
|
ElnTemplateHealthService healthService,
|
List<ElnTemplatePublishValidator> injectedValidators) {
|
List<ElnTemplatePublishValidator> result = new ArrayList<>();
|
result.add(healthValidator(healthService));
|
if (injectedValidators != null) {
|
result.addAll(injectedValidators);
|
}
|
return result;
|
}
|
|
private static ElnTemplateVos.Diagnostic diagnostic(
|
String severity, String code, String message) {
|
ElnTemplateVos.Diagnostic result = new ElnTemplateVos.Diagnostic();
|
result.setSeverity(severity);
|
result.setCode(code);
|
result.setMessage(message);
|
return result;
|
}
|
|
private ElnTemplateBindingEntity copyBinding(ElnTemplateBindingEntity source,
|
ElnTemplateVersionEntity target,
|
String operation,
|
Map<String, ElnTemplateBindingEntity> sourceBindings,
|
Map<String, String> targetBindingIds) {
|
ElnTemplateBindingEntity copy = new ElnTemplateBindingEntity();
|
copy.setId(targetBindingIds.get(source.getId()));
|
copy.setMubanId(target.getId());
|
copy.setMubanBianhao(target.getMubanBianhao());
|
copy.setZiduanDingyiId(source.getZiduanDingyiId());
|
copy.setZiduanBianma(source.getZiduanBianma());
|
copy.setZiduanBanbenId(source.getZiduanBanbenId());
|
copy.setKongjianBiaoqian(source.getKongjianBiaoqian());
|
copy.setKongjianBieming(source.getKongjianBieming());
|
copy.setKongjianLeixing(source.getKongjianLeixing());
|
copy.setKongjianJuese(source.getKongjianJuese());
|
copy.setYinyongShiliId(remapPrimaryBindingId(
|
source, sourceBindings, targetBindingIds));
|
copy.setRepeatGroupCode(source.getRepeatGroupCode());
|
copy.setRepeatPrototypeRowId(source.getRepeatPrototypeRowId());
|
copy.setCheckboxGroupCode(source.getCheckboxGroupCode());
|
copy.setBangdingZhuangtai(ElnTemplateEnums.BindingStatus.PENDING.name());
|
copy.setCaozuoBianma(operation + ":" + source.getId());
|
copy.setLaiyuanBangdingId(source.getId());
|
copy.setDaoqiShijian(null);
|
copy.setZhuangtaiYuanyin(null);
|
copy.setFTenantId(target.getFTenantId());
|
copy.setFVersion(0);
|
copy.setFDeleteMark(0);
|
return copy;
|
}
|
|
private static String remapPrimaryBindingId(ElnTemplateBindingEntity source,
|
Map<String, ElnTemplateBindingEntity> sourceBindings,
|
Map<String, String> targetBindingIds) {
|
if (ElnTemplateEnums.ControlRole.PRIMARY.name().equals(source.getKongjianJuese())) {
|
if (StringUtils.hasText(source.getYinyongShiliId())) {
|
throw new DataException("源模板主控件引用关系无效");
|
}
|
return null;
|
}
|
if (ElnTemplateEnums.ControlRole.REPEAT.name().equals(source.getKongjianJuese())) {
|
if (StringUtils.hasText(source.getYinyongShiliId())
|
|| !StringUtils.hasText(source.getRepeatGroupCode())
|
|| !StringUtils.hasText(source.getRepeatPrototypeRowId())) {
|
throw new DataException("源模板重复绑定关系无效");
|
}
|
return null;
|
}
|
if (!ElnTemplateEnums.ControlRole.REFERENCE.name().equals(source.getKongjianJuese())
|
|| !StringUtils.hasText(source.getYinyongShiliId())) {
|
throw new DataException("源模板绑定角色无效");
|
}
|
ElnTemplateBindingEntity primary = sourceBindings.get(source.getYinyongShiliId());
|
if (primary == null
|
|| !ElnTemplateEnums.ControlRole.PRIMARY.name().equals(primary.getKongjianJuese())
|
|| !source.getZiduanDingyiId().equals(primary.getZiduanDingyiId())
|
|| !source.getZiduanBanbenId().equals(primary.getZiduanBanbenId())) {
|
throw new DataException("源模板引用控件未指向本次复制的有效主控件");
|
}
|
String targetPrimaryId = targetBindingIds.get(primary.getId());
|
if (!StringUtils.hasText(targetPrimaryId)) {
|
throw new DataException("目标模板主控件 ID 映射缺失");
|
}
|
return targetPrimaryId;
|
}
|
|
private void validateCreateVersion(String sourceTemplateId, ElnTemplateForms.CreateVersion form) {
|
if (!StringUtils.hasText(sourceTemplateId) || form == null
|
|| !StringUtils.hasText(form.getMubanBanben())
|
|| !StringUtils.hasText(form.getShengbanCaozuoBianma())) {
|
throw new DataException("源模板、业务版本和升版操作码不能为空");
|
}
|
}
|
|
private ElnTemplateVersionEntity requireTemplate(String tenantId, String templateId) {
|
if (!StringUtils.hasText(templateId)) {
|
throw new DataException("模板不存在");
|
}
|
ElnTemplateVersionEntity template = store.findTemplate(tenantId, templateId.trim());
|
if (template == null || !tenantId.equals(template.getFTenantId())) {
|
throw new DataException("模板不存在或不属于当前租户");
|
}
|
return template;
|
}
|
|
private ElnTemplateVersionEntity requireTemplateForUpdate(
|
String tenantId, String templateId) {
|
if (!StringUtils.hasText(templateId)) {
|
throw new DataException("模板不存在");
|
}
|
ElnTemplateVersionEntity template = store.findTemplateForUpdate(
|
tenantId, templateId.trim());
|
if (template == null || !tenantId.equals(template.getFTenantId())) {
|
throw new DataException("模板不存在或不属于当前租户");
|
}
|
return template;
|
}
|
|
private UserContext requireContext() {
|
UserContext context = userContextSupplier.get();
|
if (context == null || !StringUtils.hasText(context.getTenantId())) {
|
throw new DataException("当前租户无效");
|
}
|
return context;
|
}
|
|
private static String requireReason(String reason) {
|
if (!StringUtils.hasText(reason)) {
|
throw new DataException("操作原因不能为空");
|
}
|
return reason.trim();
|
}
|
|
private static String trimToNull(String value) {
|
return StringUtils.hasText(value) ? value.trim() : null;
|
}
|
|
private static String value(String source) {
|
return source == null ? "" : source;
|
}
|
|
private static ElnTemplateVersionEntity copyTemplate(ElnTemplateVersionEntity source) {
|
return JsonUtil.getJsonToBean(source, ElnTemplateVersionEntity.class);
|
}
|
|
private static ElnTemplateCurrentVersionEntity copyCurrent(
|
ElnTemplateCurrentVersionEntity source) {
|
return JsonUtil.getJsonToBean(source, ElnTemplateCurrentVersionEntity.class);
|
}
|
|
private static void touch(ElnTemplateVersionEntity target, UserContext context) {
|
target.setFLastModifyUserId(context.getUserId());
|
target.setFLastModifyTime(new Date());
|
}
|
|
private static void touch(ElnTemplateCurrentVersionEntity target, UserContext context) {
|
target.setFLastModifyUserId(context.getUserId());
|
target.setFLastModifyTime(new Date());
|
}
|
|
private void auditVersionCreate(UserContext context, String operation, String sourceId,
|
String targetId, String result) {
|
Map<String, Object> snapshot = new LinkedHashMap<>();
|
snapshot.put("operation", operation);
|
snapshot.put("sourceTemplateId", sourceId);
|
snapshot.put("targetTemplateId", targetId);
|
snapshot.put("result", result);
|
auditRecorder.accept(AuditEventDTO.builder()
|
.operationId(operation)
|
.tenantId(context.getTenantId())
|
.operatorId(context.getUserId())
|
.eventTime(new Date())
|
.eventType("DATA_CHANGE")
|
.actionCode("ELN_TEMPLATE_VERSION_CREATE")
|
.actionLabel("ELN_TEMPLATE_VERSION_CREATE")
|
.bizModule("eln")
|
.bizType("eln_template_version")
|
.targetTable("eln_template")
|
.targetId(targetId)
|
.dataSnapshot(JsonUtil.getObjectToString(snapshot))
|
.build());
|
}
|
|
private void auditLifecycle(String actionCode, String actionLabel, String targetId,
|
UserContext context, Object before, Object after, String reason) {
|
Map<String, Object> snapshot = new LinkedHashMap<>();
|
snapshot.put("before", before);
|
snapshot.put("after", after);
|
auditRecorder.accept(AuditEventDTO.builder()
|
.tenantId(context.getTenantId())
|
.operatorId(context.getUserId())
|
.eventTime(new Date())
|
.eventType("BIZ_ACTION")
|
.actionCode(actionCode)
|
.actionLabel(actionLabel)
|
.bizModule("eln")
|
.bizType("eln_template")
|
.targetTable("eln_template")
|
.targetId(targetId)
|
.reason(reason)
|
.dataSnapshot(JsonUtil.getObjectToString(snapshot))
|
.build());
|
}
|
|
private void auditSwitch(UserContext context, String reason,
|
String beforeTemplateId, String afterTemplateId) {
|
Map<String, Object> snapshot = new LinkedHashMap<>();
|
snapshot.put("beforeTemplateId", beforeTemplateId);
|
snapshot.put("afterTemplateId", afterTemplateId);
|
auditRecorder.accept(AuditEventDTO.builder()
|
.tenantId(context.getTenantId())
|
.operatorId(context.getUserId())
|
.eventTime(new Date())
|
.eventType("BIZ_ACTION")
|
.actionCode("ELN_TEMPLATE_SWITCH_CURRENT")
|
.actionLabel("切换 ELN 当前模板版本")
|
.bizModule("eln")
|
.bizType("eln_template")
|
.targetTable("eln_template_current_version")
|
.targetId(afterTemplateId)
|
.reason(reason)
|
.dataSnapshot(JsonUtil.getObjectToString(snapshot))
|
.build());
|
}
|
|
private static ElnTemplateVos.ListItem toListItem(ElnTemplateVersionEntity source) {
|
ElnTemplateVos.ListItem result = new ElnTemplateVos.ListItem();
|
result.setId(source.getId());
|
result.setMubanBianhao(source.getMubanBianhao());
|
result.setMubanBanben(source.getMubanBanben());
|
result.setJianyanXiangmu(source.getJianyanXiangmu());
|
result.setJianyanXiangmuBianma(source.getJianyanXiangmuBianma());
|
result.setJianyanXiangmuMingcheng(source.getJianyanXiangmuMingcheng());
|
result.setMubanFenlei(source.getMubanFenlei());
|
result.setMubanFenleiMingcheng(source.getMubanFenleiMingcheng());
|
result.setBizStatus(source.getBizStatus());
|
result.setBizEnabled(source.getBizEnabled());
|
result.setShengxiaoRiqi(source.getShengxiaoRiqi());
|
result.setGengxinShijian(source.getFLastModifyTime() == null
|
? source.getFCreatorTime() : source.getFLastModifyTime());
|
result.setChuangjianShijian(source.getChuangjianShijian() == null
|
? source.getFCreatorTime() : source.getChuangjianShijian());
|
return result;
|
}
|
|
private static ElnTemplateVos.Detail toDetail(ElnTemplateVersionEntity source) {
|
ElnTemplateVos.Detail result = new ElnTemplateVos.Detail();
|
ElnTemplateVos.ListItem base = toListItem(source);
|
result.setId(base.getId());
|
result.setMubanBianhao(base.getMubanBianhao());
|
result.setMubanBanben(base.getMubanBanben());
|
result.setJianyanXiangmu(base.getJianyanXiangmu());
|
result.setJianyanXiangmuBianma(base.getJianyanXiangmuBianma());
|
result.setJianyanXiangmuMingcheng(base.getJianyanXiangmuMingcheng());
|
result.setMubanFenlei(base.getMubanFenlei());
|
result.setMubanFenleiMingcheng(base.getMubanFenleiMingcheng());
|
result.setBizStatus(base.getBizStatus());
|
result.setBizEnabled(base.getBizEnabled());
|
result.setShengxiaoRiqi(base.getShengxiaoRiqi());
|
result.setGengxinShijian(base.getGengxinShijian());
|
result.setChuangjianShijian(base.getChuangjianShijian());
|
result.setMubanMingcheng(source.getMubanMingcheng());
|
result.setShiyanBuzhou(source.getShiyanBuzhou());
|
result.setChuangjianRenyuan(firstText(
|
source.getChuangjianRenyuan(), source.getFCreatorUserId()));
|
result.setMubanFile(source.getMubanFile());
|
result.setLaiyuanMubanId(source.getLaiyuanMubanId());
|
result.setShengbanCaozuoBianma(source.getShengbanCaozuoBianma());
|
return result;
|
}
|
|
private void mergeSourceChain(String tenantId, ElnTemplateVersionEntity current,
|
ElnTemplateVos.Detail result) {
|
Set<String> visited = new LinkedHashSet<>();
|
visited.add(current.getId());
|
String sourceId = current.getLaiyuanMubanId();
|
int depth = 0;
|
while (StringUtils.hasText(sourceId)
|
&& depth++ < MAX_SOURCE_CHAIN_DEPTH
|
&& visited.add(sourceId)) {
|
ElnTemplateVersionEntity source = store.findTemplate(tenantId, sourceId);
|
if (source == null) {
|
break;
|
}
|
fillMissingDetailFields(result, source);
|
sourceId = source.getLaiyuanMubanId();
|
}
|
}
|
|
private static void fillMissingDetailFields(ElnTemplateVos.Detail target,
|
ElnTemplateVersionEntity source) {
|
if (!StringUtils.hasText(target.getMubanMingcheng())) {
|
target.setMubanMingcheng(source.getMubanMingcheng());
|
}
|
if (!StringUtils.hasText(target.getShiyanBuzhou())) {
|
target.setShiyanBuzhou(source.getShiyanBuzhou());
|
}
|
if (!StringUtils.hasText(target.getJianyanXiangmu())) {
|
target.setJianyanXiangmu(source.getJianyanXiangmu());
|
}
|
if (!StringUtils.hasText(target.getJianyanXiangmuBianma())) {
|
target.setJianyanXiangmuBianma(source.getJianyanXiangmuBianma());
|
}
|
if (!StringUtils.hasText(target.getJianyanXiangmuMingcheng())) {
|
target.setJianyanXiangmuMingcheng(source.getJianyanXiangmuMingcheng());
|
}
|
if (!StringUtils.hasText(target.getMubanFenlei())) {
|
target.setMubanFenlei(source.getMubanFenlei());
|
}
|
if (!StringUtils.hasText(target.getMubanFenleiMingcheng())) {
|
target.setMubanFenleiMingcheng(source.getMubanFenleiMingcheng());
|
}
|
if (!StringUtils.hasText(target.getChuangjianRenyuan())) {
|
target.setChuangjianRenyuan(firstText(
|
source.getChuangjianRenyuan(), source.getFCreatorUserId()));
|
}
|
if (target.getChuangjianShijian() == null) {
|
target.setChuangjianShijian(source.getChuangjianShijian() == null
|
? source.getFCreatorTime() : source.getChuangjianShijian());
|
}
|
}
|
|
private void enrichDetailNames(ElnTemplateVos.Detail result) {
|
result.setChuangjianRenyuanMingcheng(resolveUserName(
|
result.getChuangjianRenyuan()));
|
}
|
|
private String resolveUserName(String userId) {
|
if (!StringUtils.hasText(userId)) {
|
return userId;
|
}
|
try {
|
String name = userNameResolver.resolve(userId);
|
return StringUtils.hasText(name) ? name : userId;
|
} catch (RuntimeException ignored) {
|
return userId;
|
}
|
}
|
|
private static String firstText(String first, String second) {
|
return StringUtils.hasText(first) ? first : second;
|
}
|
|
private static UserNameResolver remoteUserNameResolver(UserApi userApi) {
|
return userId -> {
|
List<UserEntity> users = userApi.getUserName(Collections.singletonList(userId));
|
if (users == null) {
|
return null;
|
}
|
return users.stream()
|
.filter(user -> userId.equals(user.getId()))
|
.map(user -> firstText(user.getRealName(), user.getAccount()))
|
.filter(StringUtils::hasText)
|
.findFirst().orElse(null);
|
};
|
}
|
|
static String deterministicTargetId(String tenantId, String sourceTemplateId,
|
String operationCode) {
|
String seed = tenantId + "\u0000" + sourceTemplateId + "\u0000" + operationCode;
|
return UUID.nameUUIDFromBytes(seed.getBytes(StandardCharsets.UTF_8))
|
.toString().replace("-", "");
|
}
|
|
private static UserContext currentUserContext() {
|
UserInfo user = UserProvider.getUser();
|
TenantVO routed = TenantDataSourceUtil.getTenantInfo();
|
String tenantId = routed != null && StringUtils.hasText(routed.getEnCode())
|
? routed.getEnCode().trim()
|
: user != null && StringUtils.hasText(user.getTenantId())
|
? user.getTenantId().trim() : "0";
|
String userId = user == null || !StringUtils.hasText(user.getUserId())
|
? null : user.getUserId().trim();
|
return new UserContext(tenantId, userId);
|
}
|
|
static final class UserContext {
|
private final String tenantId;
|
private final String userId;
|
|
UserContext(String tenantId, String userId) {
|
this.tenantId = tenantId;
|
this.userId = userId;
|
}
|
|
String getTenantId() {
|
return tenantId;
|
}
|
|
String getUserId() {
|
return userId;
|
}
|
}
|
|
interface TargetIdFactory {
|
String create(String tenantId, String sourceTemplateId, String operationCode);
|
}
|
|
interface TemplateFileCopier {
|
String copy(String sourceAttachments, String targetTemplateId);
|
}
|
|
interface TemplatePublishFence {
|
String acquire(String tenantId, String templateId, String fileId, String fileType);
|
|
void release(String tenantId, String templateId, String fileId, String fileType, String token);
|
|
static TemplatePublishFence noop() {
|
return new TemplatePublishFence() {
|
@Override
|
public String acquire(String tenantId, String templateId,
|
String fileId, String fileType) {
|
return "noop";
|
}
|
|
@Override
|
public void release(String tenantId, String templateId,
|
String fileId, String fileType, String token) {
|
}
|
};
|
}
|
}
|
|
private static TemplatePublishFence remotePublishFence(TemplatePublishFenceApi api) {
|
return new TemplatePublishFence() {
|
@Override
|
public String acquire(String tenantId, String templateId,
|
String fileId, String fileType) {
|
ActionResult<String> result = api.acquire(
|
tenantId, templateId, fileId, fileType);
|
if (result == null
|
|| !ActionResultCode.SUCCESS.getCode().equals(result.getCode())
|
|| !StringUtils.hasText(result.getData())) {
|
throw new DataException(result == null || !StringUtils.hasText(result.getMsg())
|
? "无法锁定 OnlyOffice 模板文件，请稍后重试" : result.getMsg());
|
}
|
return result.getData();
|
}
|
|
@Override
|
public void release(String tenantId, String templateId,
|
String fileId, String fileType, String token) {
|
ActionResult<Boolean> result = api.release(
|
tenantId, templateId, fileId, fileType, token);
|
if (result == null
|
|| !ActionResultCode.SUCCESS.getCode().equals(result.getCode())
|
|| !Boolean.TRUE.equals(result.getData())) {
|
throw new DataException(result == null || !StringUtils.hasText(result.getMsg())
|
? "OnlyOffice 发布锁释放失败，需人工恢复" : result.getMsg());
|
}
|
}
|
};
|
}
|
|
interface TransactionRunner {
|
ElnTemplateVos.Detail execute(Supplier<ElnTemplateVos.Detail> callback);
|
}
|
|
private static final class SpringTransactionRunner implements TransactionRunner {
|
private final TransactionTemplate transactionTemplate;
|
|
private SpringTransactionRunner(PlatformTransactionManager transactionManager) {
|
this.transactionTemplate = new TransactionTemplate(transactionManager);
|
this.transactionTemplate.setPropagationBehavior(
|
TransactionDefinition.PROPAGATION_REQUIRES_NEW);
|
}
|
|
@Override
|
public ElnTemplateVos.Detail execute(Supplier<ElnTemplateVos.Detail> callback) {
|
return transactionTemplate.execute(status -> callback.get());
|
}
|
}
|
|
interface TemplateCatalogStore {
|
ElnTemplateVersionEntity findTemplate(String tenantId, String templateId);
|
|
ElnTemplateVersionEntity findTemplateForUpdate(String tenantId, String templateId);
|
|
ElnTemplateVersionEntity findByOperation(String tenantId, String operationCode);
|
|
ElnTemplateVersionEntity findByCodeAndVersion(
|
String tenantId, String templateCode, String businessVersion);
|
|
void insertTemplate(ElnTemplateVersionEntity template);
|
|
void updateTemplateFile(ElnTemplateVersionEntity template);
|
|
void updateTemplateLifecycle(ElnTemplateVersionEntity template);
|
|
ElnTemplateCurrentVersionEntity findCurrent(String tenantId, String templateCode);
|
|
List<ElnTemplateCurrentVersionEntity> listCurrentVersions(
|
String tenantId, List<String> templateCodes);
|
|
boolean insertCurrent(ElnTemplateCurrentVersionEntity current);
|
|
void updateCurrent(ElnTemplateCurrentVersionEntity current);
|
|
List<ElnTemplateBindingEntity> listActiveBindings(String tenantId, String templateId);
|
|
List<ElnTemplateBindingEntity> listActiveBindingsByTemplateIds(
|
String tenantId, List<String> templateIds);
|
|
default List<ElnTemplateVos.TemplateCategory> listTemplateCategories(
|
String tenantId, List<String> templateCategoryIds) {
|
return Collections.emptyList();
|
}
|
|
void insertBinding(ElnTemplateBindingEntity binding);
|
|
IPage<ElnTemplateVersionEntity> page(String tenantId, ElnTemplateForms.Query query);
|
|
IPage<ElnTemplateVos.CatalogItem> pageDirectory(
|
String tenantId, ElnTemplateForms.Query query);
|
}
|
|
interface UserNameResolver {
|
String resolve(String userId);
|
}
|
|
interface VersionGroupCopier {
|
void copy(String tenantId, String sourceTemplateId, String targetTemplateId);
|
}
|
|
private static final class MyBatisTemplateCatalogStore implements TemplateCatalogStore {
|
private final ElnTemplateMapper templateMapper;
|
private final ElnTemplateBindingMapper bindingMapper;
|
private final ElnTemplateCurrentVersionMapper currentMapper;
|
|
private MyBatisTemplateCatalogStore(ElnTemplateMapper templateMapper,
|
ElnTemplateBindingMapper bindingMapper,
|
ElnTemplateCurrentVersionMapper currentMapper) {
|
this.templateMapper = templateMapper;
|
this.bindingMapper = bindingMapper;
|
this.currentMapper = currentMapper;
|
}
|
|
@Override
|
public ElnTemplateVersionEntity findTemplate(String tenantId, String templateId) {
|
return templateMapper.selectOne(templateQuery(tenantId)
|
.eq(ElnTemplateVersionEntity::getId, templateId));
|
}
|
|
@Override
|
public ElnTemplateVersionEntity findTemplateForUpdate(
|
String tenantId, String templateId) {
|
return templateMapper.selectOne(templateQuery(tenantId)
|
.eq(ElnTemplateVersionEntity::getId, templateId)
|
.last("FOR UPDATE"));
|
}
|
|
@Override
|
public ElnTemplateVersionEntity findByOperation(String tenantId, String operationCode) {
|
return templateMapper.selectOne(templateQuery(tenantId)
|
.eq(ElnTemplateVersionEntity::getShengbanCaozuoBianma, operationCode));
|
}
|
|
@Override
|
public ElnTemplateVersionEntity findByCodeAndVersion(
|
String tenantId, String templateCode, String businessVersion) {
|
return templateMapper.selectOne(templateQuery(tenantId)
|
.eq(ElnTemplateVersionEntity::getMubanBianhao, templateCode)
|
.eq(ElnTemplateVersionEntity::getMubanBanben, businessVersion));
|
}
|
|
@Override
|
public void insertTemplate(ElnTemplateVersionEntity template) {
|
templateMapper.insert(template);
|
}
|
|
@Override
|
public void updateTemplateFile(ElnTemplateVersionEntity template) {
|
Integer expectedVersion = template.getFVersion();
|
int nextVersion = expectedVersion == null ? 1 : expectedVersion + 1;
|
LambdaUpdateWrapper<ElnTemplateVersionEntity> update =
|
Wrappers.<ElnTemplateVersionEntity>lambdaUpdate()
|
.eq(ElnTemplateVersionEntity::getFTenantId, template.getFTenantId())
|
.eq(ElnTemplateVersionEntity::getId, template.getId())
|
.and(item -> item.isNull(ElnTemplateVersionEntity::getFDeleteMark)
|
.or().eq(ElnTemplateVersionEntity::getFDeleteMark, 0))
|
.set(ElnTemplateVersionEntity::getMubanFile, template.getMubanFile())
|
.set(ElnTemplateVersionEntity::getFLastModifyUserId,
|
template.getFLastModifyUserId())
|
.set(ElnTemplateVersionEntity::getFLastModifyTime,
|
template.getFLastModifyTime())
|
.set(ElnTemplateVersionEntity::getFVersion, nextVersion);
|
if (expectedVersion == null) {
|
update.isNull(ElnTemplateVersionEntity::getFVersion);
|
} else {
|
update.eq(ElnTemplateVersionEntity::getFVersion, expectedVersion);
|
}
|
if (templateMapper.update(null, update) != 1) {
|
throw new DataException("模板状态已变化，请刷新后重试");
|
}
|
template.setFVersion(nextVersion);
|
}
|
|
@Override
|
public void updateTemplateLifecycle(ElnTemplateVersionEntity template) {
|
Integer expectedVersion = template.getFVersion();
|
int nextVersion = expectedVersion == null ? 1 : expectedVersion + 1;
|
LambdaUpdateWrapper<ElnTemplateVersionEntity> update =
|
Wrappers.<ElnTemplateVersionEntity>lambdaUpdate()
|
.eq(ElnTemplateVersionEntity::getFTenantId, template.getFTenantId())
|
.eq(ElnTemplateVersionEntity::getId, template.getId())
|
.and(item -> item.isNull(ElnTemplateVersionEntity::getFDeleteMark)
|
.or().eq(ElnTemplateVersionEntity::getFDeleteMark, 0))
|
.set(ElnTemplateVersionEntity::getMubanFile, template.getMubanFile())
|
.set(ElnTemplateVersionEntity::getBizStatus, template.getBizStatus())
|
.set(ElnTemplateVersionEntity::getBizEnabled, template.getBizEnabled())
|
.set(ElnTemplateVersionEntity::getFLastModifyUserId,
|
template.getFLastModifyUserId())
|
.set(ElnTemplateVersionEntity::getFLastModifyTime,
|
template.getFLastModifyTime())
|
.set(ElnTemplateVersionEntity::getFVersion, nextVersion);
|
if (expectedVersion == null) {
|
update.isNull(ElnTemplateVersionEntity::getFVersion);
|
} else {
|
update.eq(ElnTemplateVersionEntity::getFVersion, expectedVersion);
|
}
|
if (templateMapper.update(null, update) != 1) {
|
throw new DataException("模板状态已变化，请刷新后重试");
|
}
|
template.setFVersion(nextVersion);
|
}
|
|
@Override
|
public ElnTemplateCurrentVersionEntity findCurrent(String tenantId, String templateCode) {
|
return currentMapper.selectOne(Wrappers.<ElnTemplateCurrentVersionEntity>lambdaQuery()
|
.eq(ElnTemplateCurrentVersionEntity::getFTenantId, tenantId)
|
.eq(ElnTemplateCurrentVersionEntity::getMubanBianhao, templateCode)
|
.and(item -> item.isNull(ElnTemplateCurrentVersionEntity::getFDeleteMark)
|
.or().eq(ElnTemplateCurrentVersionEntity::getFDeleteMark, 0)));
|
}
|
|
@Override
|
public List<ElnTemplateCurrentVersionEntity> listCurrentVersions(
|
String tenantId, List<String> templateCodes) {
|
if (templateCodes.isEmpty()) {
|
return Collections.emptyList();
|
}
|
return currentMapper.selectList(
|
Wrappers.<ElnTemplateCurrentVersionEntity>lambdaQuery()
|
.eq(ElnTemplateCurrentVersionEntity::getFTenantId, tenantId)
|
.in(ElnTemplateCurrentVersionEntity::getMubanBianhao, templateCodes)
|
.and(item -> item.isNull(ElnTemplateCurrentVersionEntity::getFDeleteMark)
|
.or().eq(ElnTemplateCurrentVersionEntity::getFDeleteMark, 0)));
|
}
|
|
@Override
|
public boolean insertCurrent(ElnTemplateCurrentVersionEntity current) {
|
return currentMapper.insert(current) == 1;
|
}
|
|
@Override
|
public void updateCurrent(ElnTemplateCurrentVersionEntity current) {
|
Integer expectedVersion = current.getFVersion();
|
int nextVersion = expectedVersion == null ? 1 : expectedVersion + 1;
|
LambdaUpdateWrapper<ElnTemplateCurrentVersionEntity> update =
|
Wrappers.<ElnTemplateCurrentVersionEntity>lambdaUpdate()
|
.eq(ElnTemplateCurrentVersionEntity::getFTenantId,
|
current.getFTenantId())
|
.eq(ElnTemplateCurrentVersionEntity::getMubanBianhao,
|
current.getMubanBianhao())
|
.eq(ElnTemplateCurrentVersionEntity::getId, current.getId())
|
.and(item -> item.isNull(ElnTemplateCurrentVersionEntity::getFDeleteMark)
|
.or().eq(ElnTemplateCurrentVersionEntity::getFDeleteMark, 0))
|
.set(ElnTemplateCurrentVersionEntity::getDangqianMubanId,
|
current.getDangqianMubanId())
|
.set(ElnTemplateCurrentVersionEntity::getFLastModifyUserId,
|
current.getFLastModifyUserId())
|
.set(ElnTemplateCurrentVersionEntity::getFLastModifyTime,
|
current.getFLastModifyTime())
|
.set(ElnTemplateCurrentVersionEntity::getFVersion, nextVersion);
|
if (expectedVersion == null) {
|
update.isNull(ElnTemplateCurrentVersionEntity::getFVersion);
|
} else {
|
update.eq(ElnTemplateCurrentVersionEntity::getFVersion, expectedVersion);
|
}
|
if (currentMapper.update(null, update) != 1) {
|
throw new DataException("当前模板已变化，请刷新后重试");
|
}
|
current.setFVersion(nextVersion);
|
}
|
|
@Override
|
public List<ElnTemplateBindingEntity> listActiveBindings(String tenantId, String templateId) {
|
return bindingMapper.selectList(Wrappers.<ElnTemplateBindingEntity>lambdaQuery()
|
.eq(ElnTemplateBindingEntity::getFTenantId, tenantId)
|
.eq(ElnTemplateBindingEntity::getMubanId, templateId)
|
.eq(ElnTemplateBindingEntity::getBangdingZhuangtai,
|
ElnTemplateEnums.BindingStatus.ACTIVE.name())
|
.and(item -> item.isNull(ElnTemplateBindingEntity::getFDeleteMark)
|
.or().eq(ElnTemplateBindingEntity::getFDeleteMark, 0)));
|
}
|
|
@Override
|
public List<ElnTemplateBindingEntity> listActiveBindingsByTemplateIds(
|
String tenantId, List<String> templateIds) {
|
if (templateIds.isEmpty()) {
|
return Collections.emptyList();
|
}
|
return bindingMapper.selectList(Wrappers.<ElnTemplateBindingEntity>lambdaQuery()
|
.eq(ElnTemplateBindingEntity::getFTenantId, tenantId)
|
.in(ElnTemplateBindingEntity::getMubanId, templateIds)
|
.eq(ElnTemplateBindingEntity::getBangdingZhuangtai,
|
ElnTemplateEnums.BindingStatus.ACTIVE.name())
|
.and(item -> item.isNull(ElnTemplateBindingEntity::getFDeleteMark)
|
.or().eq(ElnTemplateBindingEntity::getFDeleteMark, 0)));
|
}
|
|
@Override
|
public List<ElnTemplateVos.TemplateCategory> listTemplateCategories(
|
String tenantId, List<String> templateCategoryIds) {
|
if (templateCategoryIds.isEmpty()) {
|
return Collections.emptyList();
|
}
|
return templateMapper.selectTemplateCategories(tenantId, templateCategoryIds);
|
}
|
|
@Override
|
public void insertBinding(ElnTemplateBindingEntity binding) {
|
bindingMapper.insert(binding);
|
}
|
|
@Override
|
public IPage<ElnTemplateVersionEntity> page(String tenantId, ElnTemplateForms.Query form) {
|
if (ElnTemplateForms.VersionScope.LATEST.equals(form.getVersionScope())) {
|
return pageLatestVersions(tenantId, form);
|
}
|
LambdaQueryWrapper<ElnTemplateVersionEntity> query = templateQuery(tenantId);
|
applyPageFilters(query, form);
|
query.orderByDesc(ElnTemplateVersionEntity::getFLastModifyTime)
|
.orderByDesc(ElnTemplateVersionEntity::getFCreatorTime)
|
.orderByDesc(ElnTemplateVersionEntity::getId);
|
return templateMapper.selectPage(new Page<>(form.getCurrentPage(), form.getPageSize()), query);
|
}
|
|
@Override
|
public IPage<ElnTemplateVos.CatalogItem> pageDirectory(
|
String tenantId, ElnTemplateForms.Query form) {
|
String keyword = trimToNull(form.getKeyword());
|
return templateMapper.selectTemplateDirectory(
|
new Page<>(form.getCurrentPage(), form.getPageSize()),
|
tenantId,
|
trimToNull(form.getMubanFenlei()),
|
trimToNull(form.getMubanBianhao()),
|
trimToNull(form.getBizStatus()),
|
trimToNull(form.getBizEnabled()),
|
keyword == null ? null : "%" + keyword + "%");
|
}
|
|
private IPage<ElnTemplateVersionEntity> pageLatestVersions(
|
String tenantId, ElnTemplateForms.Query form) {
|
String keyword = trimToNull(form.getKeyword());
|
IPage<String> codePage = templateMapper.selectLatestTemplateCodes(
|
new Page<>(form.getCurrentPage(), form.getPageSize()),
|
tenantId,
|
trimToNull(form.getMubanFenlei()),
|
trimToNull(form.getMubanBianhao()),
|
trimToNull(form.getBizStatus()),
|
trimToNull(form.getBizEnabled()),
|
keyword == null ? null : "%" + keyword + "%");
|
Page<ElnTemplateVersionEntity> result =
|
new Page<>(codePage.getCurrent(), codePage.getSize());
|
result.setTotal(codePage.getTotal());
|
if (codePage.getRecords().isEmpty()) {
|
return result;
|
}
|
|
LambdaQueryWrapper<ElnTemplateVersionEntity> query = templateQuery(tenantId)
|
.in(ElnTemplateVersionEntity::getMubanBianhao, codePage.getRecords());
|
applyPageFilters(query, form);
|
List<ElnTemplateVersionEntity> candidates = templateMapper.selectList(query);
|
candidates.sort(MyBatisTemplateCatalogStore::compareLatestFirst);
|
Map<String, ElnTemplateVersionEntity> latestByCode = new LinkedHashMap<>();
|
for (ElnTemplateVersionEntity candidate : candidates) {
|
latestByCode.putIfAbsent(candidate.getMubanBianhao(), candidate);
|
}
|
List<ElnTemplateVersionEntity> records = codePage.getRecords().stream()
|
.map(latestByCode::get)
|
.filter(Objects::nonNull)
|
.collect(Collectors.toList());
|
result.setRecords(records);
|
return result;
|
}
|
|
private static void applyPageFilters(
|
LambdaQueryWrapper<ElnTemplateVersionEntity> query,
|
ElnTemplateForms.Query form) {
|
if (StringUtils.hasText(form.getMubanBianhao())) {
|
query.eq(ElnTemplateVersionEntity::getMubanBianhao, form.getMubanBianhao().trim());
|
}
|
if (StringUtils.hasText(form.getMubanFenlei())) {
|
query.eq(ElnTemplateVersionEntity::getMubanFenlei, form.getMubanFenlei().trim());
|
}
|
if (StringUtils.hasText(form.getBizStatus())) {
|
query.eq(ElnTemplateVersionEntity::getBizStatus, form.getBizStatus().trim());
|
}
|
if (StringUtils.hasText(form.getBizEnabled())) {
|
query.eq(ElnTemplateVersionEntity::getBizEnabled, form.getBizEnabled().trim());
|
}
|
if (StringUtils.hasText(form.getKeyword())) {
|
String keyword = form.getKeyword().trim();
|
query.and(item -> item.like(ElnTemplateVersionEntity::getMubanBianhao, keyword)
|
.or().like(ElnTemplateVersionEntity::getMubanBanben, keyword)
|
.or().like(ElnTemplateVersionEntity::getJianyanXiangmu, keyword)
|
.or().like(ElnTemplateVersionEntity::getJianyanXiangmuMingcheng,
|
keyword));
|
}
|
}
|
|
private static int compareLatestFirst(ElnTemplateVersionEntity left,
|
ElnTemplateVersionEntity right) {
|
int byTime = Comparator.nullsLast(Comparator.<Date>reverseOrder())
|
.compare(versionTimestamp(left), versionTimestamp(right));
|
if (byTime != 0) {
|
return byTime;
|
}
|
return Comparator.nullsLast(Comparator.<String>reverseOrder())
|
.compare(left.getId(), right.getId());
|
}
|
|
private static Date versionTimestamp(ElnTemplateVersionEntity version) {
|
if (version.getFLastModifyTime() != null) {
|
return version.getFLastModifyTime();
|
}
|
if (version.getFCreatorTime() != null) {
|
return version.getFCreatorTime();
|
}
|
return version.getChuangjianShijian();
|
}
|
|
private static String trimToNull(String value) {
|
return StringUtils.hasText(value) ? value.trim() : null;
|
}
|
|
private static LambdaQueryWrapper<ElnTemplateVersionEntity> templateQuery(String tenantId) {
|
return Wrappers.<ElnTemplateVersionEntity>lambdaQuery()
|
.eq(ElnTemplateVersionEntity::getFTenantId, tenantId)
|
.and(item -> item.isNull(ElnTemplateVersionEntity::getFDeleteMark)
|
.or().eq(ElnTemplateVersionEntity::getFDeleteMark, 0));
|
}
|
}
|
}
|
