package jnpf.elnService.impl;
|
|
import cn.hutool.core.util.IdUtil;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import jnpf.base.ActionResult;
|
import jnpf.base.ActionResultCode;
|
import jnpf.base.UserInfo;
|
import jnpf.database.util.TenantDataSourceUtil;
|
import jnpf.elnEntity.ElnDocumentFileVo;
|
import jnpf.elnEntity.field.ElnFieldForms;
|
import jnpf.elnEntity.field.ElnFieldVersionEntity;
|
import jnpf.elnEntity.runtime.ElnRecordEntity;
|
import jnpf.elnEntity.runtime.ElnRecordFieldValueEntity;
|
import jnpf.elnEntity.runtime.ElnRecordFormulaCalculationResult;
|
import jnpf.elnEntity.runtime.ElnRecordForms;
|
import jnpf.elnEntity.runtime.ElnRecordRepeatRowEntity;
|
import jnpf.elnEntity.runtime.ElnRecordRepeatValueEntity;
|
import jnpf.elnEntity.runtime.ElnRecordRevisionEntity;
|
import jnpf.elnEntity.runtime.ElnRecordVos;
|
import jnpf.elnMapper.ElnFieldVersionMapper;
|
import jnpf.elnMapper.ElnRecordFieldValueMapper;
|
import jnpf.elnMapper.ElnRecordMapper;
|
import jnpf.elnMapper.ElnRecordRepeatRowMapper;
|
import jnpf.elnMapper.ElnRecordRepeatValueMapper;
|
import jnpf.elnMapper.ElnRecordRevisionMapper;
|
import jnpf.elnService.ElnTestWorkItemSnapshotProvider;
|
import jnpf.elnService.ElnRecordFormulaCalculationService;
|
import jnpf.elnService.ElnRecordRevisionService;
|
import jnpf.elnService.template.ElnTemplateFileService;
|
import jnpf.exception.DataException;
|
import jnpf.lims.api.model.TestWorkItemSnapshotBatch;
|
import jnpf.lims.api.model.TestWorkItemSnapshot;
|
import jnpf.lims.api.model.TestWorkItemSnapshotProperty;
|
import jnpf.model.tenant.TenantVO;
|
import jnpf.onlyoffice.RecordRevisionFenceApi;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.UserProvider;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.support.TransactionSynchronization;
|
import org.springframework.transaction.support.TransactionSynchronizationManager;
|
import org.springframework.util.StringUtils;
|
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Collections;
|
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;
|
|
@Service
|
public class ElnRecordRevisionServiceImpl implements ElnRecordRevisionService {
|
|
private static final Logger log = LoggerFactory.getLogger(ElnRecordRevisionServiceImpl.class);
|
|
private static final String ACTIVE = "ACTIVE";
|
private static final String PRIMARY = "PRIMARY";
|
private static final String DRAFT = "DRAFT";
|
private static final String HISTORICAL = "HISTORICAL";
|
private static final String PENDING_TEST = "pending_test";
|
private static final String AUDIT_REJECTED = "audit_rejected";
|
private static final String CANCELLED = "cancelled";
|
private static final String CROSS_TEMPLATE = "CROSS_TEMPLATE";
|
private static final String LIMS_TASK = "LIMS_TASK";
|
private static final String SYSTEM = "SYSTEM";
|
|
private final ElnTestWorkItemSnapshotProvider taskProvider;
|
private final ElnRecordMapper recordMapper;
|
private final ElnRecordRevisionMapper revisionMapper;
|
private final ElnRecordFieldValueMapper valueMapper;
|
private final ElnFieldVersionMapper fieldVersionMapper;
|
private final ElnRecordRepeatRowMapper repeatRowMapper;
|
private final ElnRecordRepeatValueMapper repeatValueMapper;
|
private final ElnTemplateFileService fileService;
|
private final ElnRecordFormulaCalculationService calculationService;
|
private final RecordRevisionFence revisionFence;
|
private final CurrentUserProvider currentUserProvider;
|
|
@Autowired
|
public ElnRecordRevisionServiceImpl(
|
ElnTestWorkItemSnapshotProvider taskProvider,
|
ElnRecordMapper recordMapper,
|
ElnRecordRevisionMapper revisionMapper,
|
ElnRecordFieldValueMapper valueMapper,
|
ElnFieldVersionMapper fieldVersionMapper,
|
ElnRecordRepeatRowMapper repeatRowMapper,
|
ElnRecordRepeatValueMapper repeatValueMapper,
|
ElnTemplateFileService fileService,
|
ElnRecordFormulaCalculationService calculationService,
|
RecordRevisionFenceApi revisionFenceApi) {
|
this(taskProvider, recordMapper, revisionMapper, valueMapper, fieldVersionMapper,
|
repeatRowMapper, repeatValueMapper,
|
fileService, calculationService, remoteFence(revisionFenceApi),
|
ElnRecordRevisionServiceImpl::currentUser);
|
}
|
|
ElnRecordRevisionServiceImpl(
|
ElnTestWorkItemSnapshotProvider taskProvider,
|
ElnRecordMapper recordMapper,
|
ElnRecordRevisionMapper revisionMapper,
|
ElnRecordFieldValueMapper valueMapper,
|
ElnFieldVersionMapper fieldVersionMapper,
|
ElnRecordRepeatRowMapper repeatRowMapper,
|
ElnRecordRepeatValueMapper repeatValueMapper,
|
ElnTemplateFileService fileService,
|
ElnRecordFormulaCalculationService calculationService,
|
RecordRevisionFence revisionFence,
|
CurrentUserProvider currentUserProvider) {
|
this.taskProvider = taskProvider;
|
this.recordMapper = recordMapper;
|
this.revisionMapper = revisionMapper;
|
this.valueMapper = valueMapper;
|
this.fieldVersionMapper = fieldVersionMapper;
|
this.repeatRowMapper = repeatRowMapper;
|
this.repeatValueMapper = repeatValueMapper;
|
this.fileService = fileService;
|
this.calculationService = calculationService;
|
this.revisionFence = revisionFence;
|
this.currentUserProvider = currentUserProvider;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public ElnRecordVos.Created open(ElnRecordForms.Create command) {
|
String testWorkItemId = required(
|
command == null ? null : command.getTestWorkItemId(), "检验项不能为空");
|
String operationCode = required(
|
command == null ? null : command.getOperationCode(), "操作码不能为空");
|
UserContext user = currentUserProvider.get();
|
TestWorkItemSnapshot snapshot = snapshot(user, testWorkItemId);
|
ElnRecordEntity observed = recordMapper.selectLiveByTestWorkItem(
|
user.tenantId, testWorkItemId);
|
if (observed == null) {
|
throw new DataException("电子记录不存在");
|
}
|
ElnRecordEntity record = recordMapper.selectLiveForUpdate(user.tenantId, observed.getId());
|
if (record == null || !testWorkItemId.equals(record.getJianyanXiangId())
|
|| !StringUtils.hasText(record.getDangqianXiudingId())) {
|
throw new DataException("电子记录不存在或当前修订无效");
|
}
|
ElnRecordRevisionEntity current = currentRevision(user.tenantId, record);
|
ElnRecordRevisionEntity idempotent = revisionByOperation(
|
user.tenantId, record.getId(), operationCode);
|
if (idempotent != null) {
|
if (!Objects.equals(current.getId(), idempotent.getId())) {
|
throw new DataException("操作码已用于其他电子记录修订");
|
}
|
return created(record, idempotent, true);
|
}
|
if (PENDING_TEST.equals(snapshot.getTaskStatus())) {
|
if (!DRAFT.equals(current.getBizStatus())) {
|
throw new DataException("电子记录当前修订不是可编辑草稿");
|
}
|
return created(record, current, true);
|
}
|
if (!AUDIT_REJECTED.equals(snapshot.getTaskStatus())
|
&& !CANCELLED.equals(snapshot.getTaskStatus())) {
|
throw new DataException("检验项当前状态不允许创建电子记录修订");
|
}
|
if (DRAFT.equals(current.getBizStatus())
|
&& StringUtils.hasText(current.getLaiyuanXiudingId())) {
|
return created(record, current, true);
|
}
|
return createRevision(record, current, snapshot, operationCode, user);
|
}
|
|
private ElnRecordVos.Created createRevision(
|
ElnRecordEntity record, ElnRecordRevisionEntity source,
|
TestWorkItemSnapshot snapshot, String operationCode, UserContext user) {
|
if (!DRAFT.equals(source.getBizStatus()) && !HISTORICAL.equals(source.getBizStatus())) {
|
throw new DataException("电子记录来源修订状态无效");
|
}
|
if (source.getXiudingHao() == null || source.getXiudingHao() < 1) {
|
throw new DataException("电子记录来源修订号无效");
|
}
|
String sourceFileId = required(source.getJiluWendang(),
|
"电子记录来源修订缺少文档");
|
FenceLease lease = acquireFence(user.tenantId, record.getId(), sourceFileId);
|
boolean completionRegistered = registerFenceCompletion(lease);
|
try {
|
List<ElnRecordFieldValueEntity> sourceValues = sourceValues(
|
user.tenantId, record, source);
|
RepeatSnapshot repeatSnapshot = sourceRepeatSnapshot(
|
user.tenantId, record, source);
|
if (DRAFT.equals(source.getBizStatus())
|
&& revisionMapper.markHistorical(user.tenantId, record.getId(), source.getId(),
|
source.getFVersion(), user.userId) != 1) {
|
throw new DataException("电子记录来源修订状态冲突");
|
}
|
|
String revisionId = IdUtil.getSnowflakeNextIdStr();
|
Date now = new Date();
|
ElnDocumentFileVo document = copiedDocument(fileService.copyDocx(
|
sourceDocument(sourceFileId), revisionId));
|
ElnRecordRevisionEntity revision = revision(
|
revisionId, record.getId(), source, operationCode,
|
document.getFileId(), user, now);
|
if (revisionMapper.insert(revision) != 1) {
|
throw new DataException("电子记录新修订创建冲突");
|
}
|
List<ElnRecordFieldValueEntity> values = new ArrayList<>(sourceValues.size());
|
for (ElnRecordFieldValueEntity sourceValue : sourceValues) {
|
ElnRecordFieldValueEntity value = copyValue(
|
sourceValue, revisionId, snapshot, user, now);
|
if (valueMapper.insert(value) != 1) {
|
throw new DataException("电子记录新修订字段值复制失败");
|
}
|
values.add(value);
|
}
|
copyRepeatSnapshot(repeatSnapshot, revisionId, user, now);
|
if (recordMapper.switchCurrentRevision(
|
user.tenantId, record.getId(), source.getId(), revisionId,
|
record.getFVersion(), user.userId) != 1) {
|
throw new DataException("电子记录当前修订切换冲突");
|
}
|
record.setDangqianXiudingId(revisionId);
|
record.setFVersion(record.getFVersion() + 1);
|
ElnRecordFormulaCalculationResult calculated =
|
calculationService.recalculateAllWithRepeats(
|
user.tenantId, record, revision, values, operationCode, user.userId);
|
for (ElnRecordFieldValueEntity value : calculated.getFieldValues()) {
|
if (valueMapper.updateById(value) != 1) {
|
throw new DataException("电子记录新修订公式结果保存失败");
|
}
|
}
|
for (ElnRecordRepeatValueEntity value : calculated.getRepeatValues()) {
|
if (repeatValueMapper.updateById(value) != 1) {
|
throw new DataException("电子记录新修订重复公式结果保存失败");
|
}
|
}
|
if (!completionRegistered) {
|
revisionFence.complete(lease);
|
}
|
return created(record, revision, false);
|
} catch (RuntimeException e) {
|
if (!completionRegistered) {
|
releaseFence(lease, e);
|
}
|
throw e;
|
}
|
}
|
|
private FenceLease acquireFence(String tenantId, String recordId, String fileId) {
|
String fileType = "annex";
|
String token = revisionFence.acquire(tenantId, recordId, fileId, fileType);
|
if (!StringUtils.hasText(token)) {
|
throw new DataException("无法锁定 OnlyOffice 历史文档，请稍后重试");
|
}
|
return new FenceLease(tenantId, recordId, fileId, fileType, token);
|
}
|
|
private boolean registerFenceCompletion(FenceLease lease) {
|
if (!TransactionSynchronizationManager.isSynchronizationActive()) {
|
return false;
|
}
|
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
|
@Override
|
public void afterCompletion(int status) {
|
try {
|
if (status == TransactionSynchronization.STATUS_COMMITTED) {
|
revisionFence.complete(lease);
|
} else {
|
revisionFence.release(lease);
|
}
|
} catch (RuntimeException e) {
|
log.error("OnlyOffice 记录修订 fence 收尾失败，record={} file={} committed={}",
|
lease.recordId, lease.fileId,
|
status == TransactionSynchronization.STATUS_COMMITTED, e);
|
}
|
}
|
});
|
return true;
|
}
|
|
private void releaseFence(FenceLease lease, RuntimeException original) {
|
try {
|
revisionFence.release(lease);
|
} catch (RuntimeException releaseError) {
|
original.addSuppressed(releaseError);
|
}
|
}
|
|
private List<ElnRecordFieldValueEntity> sourceValues(
|
String tenantId, ElnRecordEntity record, ElnRecordRevisionEntity revision) {
|
List<ElnRecordFieldValueEntity> values = valueMapper.selectList(
|
Wrappers.<ElnRecordFieldValueEntity>lambdaQuery()
|
.eq(ElnRecordFieldValueEntity::getFTenantId, tenantId)
|
.eq(ElnRecordFieldValueEntity::getDianziJiluId, record.getId())
|
.eq(ElnRecordFieldValueEntity::getXiudingId, revision.getId())
|
.and(q -> q.isNull(ElnRecordFieldValueEntity::getFDeleteMark)
|
.or().eq(ElnRecordFieldValueEntity::getFDeleteMark, 0))
|
.orderByAsc(ElnRecordFieldValueEntity::getId));
|
if (values == null || values.isEmpty()) {
|
throw new DataException("电子记录来源修订没有字段值");
|
}
|
Set<String> bindingIds = new LinkedHashSet<>();
|
for (ElnRecordFieldValueEntity value : values) {
|
if (!Objects.equals(record.getMubanId(), value.getMubanId())
|
|| !Objects.equals(revision.getId(), value.getXiudingId())
|
|| !PRIMARY.equals(value.getBangdingJuese())
|
|| !ACTIVE.equals(value.getBangdingZhuangtai())
|
|| !bindingIds.add(value.getMubanBangdingId())) {
|
throw new DataException("电子记录来源修订字段值与固定模板不一致");
|
}
|
}
|
return values;
|
}
|
|
private RepeatSnapshot sourceRepeatSnapshot(
|
String tenantId, ElnRecordEntity record, ElnRecordRevisionEntity revision) {
|
List<ElnRecordRepeatRowEntity> rows = repeatRowMapper.selectList(
|
Wrappers.<ElnRecordRepeatRowEntity>lambdaQuery()
|
.eq(ElnRecordRepeatRowEntity::getFTenantId, tenantId)
|
.eq(ElnRecordRepeatRowEntity::getDianziJiluId, record.getId())
|
.eq(ElnRecordRepeatRowEntity::getXiudingId, revision.getId())
|
.orderByAsc(ElnRecordRepeatRowEntity::getRepeatGroupCode)
|
.orderByAsc(ElnRecordRepeatRowEntity::getRowOrder)
|
.orderByAsc(ElnRecordRepeatRowEntity::getId));
|
List<ElnRecordRepeatValueEntity> values = repeatValueMapper.selectList(
|
Wrappers.<ElnRecordRepeatValueEntity>lambdaQuery()
|
.eq(ElnRecordRepeatValueEntity::getFTenantId, tenantId)
|
.eq(ElnRecordRepeatValueEntity::getDianziJiluId, record.getId())
|
.eq(ElnRecordRepeatValueEntity::getXiudingId, revision.getId())
|
.orderByAsc(ElnRecordRepeatValueEntity::getRepeatGroupCode)
|
.orderByAsc(ElnRecordRepeatValueEntity::getRepeatRowId)
|
.orderByAsc(ElnRecordRepeatValueEntity::getId));
|
rows = rows == null ? Collections.emptyList() : rows;
|
values = values == null ? Collections.emptyList() : values;
|
|
Map<String, ElnRecordRepeatRowEntity> rowsByIdentity = new LinkedHashMap<>();
|
Set<String> operationCodes = new LinkedHashSet<>();
|
for (ElnRecordRepeatRowEntity row : rows) {
|
String key = repeatRowKey(row == null ? null : row.getRepeatGroupCode(),
|
row == null ? null : row.getRowId());
|
if (row == null
|
|| !Objects.equals(record.getId(), row.getDianziJiluId())
|
|| !Objects.equals(revision.getId(), row.getXiudingId())
|
|| !Objects.equals(record.getMubanId(), row.getMubanId())
|
|| !StringUtils.hasText(row.getRepeatGroupCode())
|
|| !StringUtils.hasText(row.getRowId())
|
|| row.getRowOrder() == null || row.getRowOrder() < 1
|
|| !StringUtils.hasText(row.getOperationCode())
|
|| !validRepeatRowLifecycle(row)
|
|| rowsByIdentity.put(key, row) != null
|
|| !operationCodes.add(row.getOperationCode())) {
|
throw new DataException("电子记录来源修订重复行快照无效");
|
}
|
}
|
|
Set<String> cells = new LinkedHashSet<>();
|
for (ElnRecordRepeatValueEntity value : values) {
|
String rowKey = repeatRowKey(value == null ? null : value.getRepeatGroupCode(),
|
value == null ? null : value.getRepeatRowId());
|
ElnRecordRepeatRowEntity row = rowsByIdentity.get(rowKey);
|
String cellKey = rowKey + "\n" + (value == null ? null : value.getMubanBangdingId());
|
if (value == null || row == null
|
|| !Objects.equals(record.getId(), value.getDianziJiluId())
|
|| !Objects.equals(revision.getId(), value.getXiudingId())
|
|| !Objects.equals(record.getMubanId(), value.getMubanId())
|
|| !Objects.equals("REPEAT", value.getBangdingJuese())
|
|| !Objects.equals(ACTIVE, value.getBangdingZhuangtai())
|
|| !StringUtils.hasText(value.getMubanBangdingId())
|
|| !Objects.equals(deleted(row), deleted(value))
|
|| !cells.add(cellKey)) {
|
throw new DataException("电子记录来源修订重复字段值快照无效");
|
}
|
}
|
return new RepeatSnapshot(rows, values);
|
}
|
|
private void copyRepeatSnapshot(
|
RepeatSnapshot snapshot, String revisionId, UserContext user, Date now) {
|
for (ElnRecordRepeatRowEntity source : snapshot.rows) {
|
ElnRecordRepeatRowEntity row = copyRepeatRow(source, revisionId, user, now);
|
if (repeatRowMapper.insert(row) != 1) {
|
throw new DataException("电子记录新修订重复行复制失败");
|
}
|
}
|
for (ElnRecordRepeatValueEntity source : snapshot.values) {
|
ElnRecordRepeatValueEntity value = copyRepeatValue(source, revisionId, user, now);
|
if (repeatValueMapper.insert(value) != 1) {
|
throw new DataException("电子记录新修订重复字段值复制失败");
|
}
|
}
|
}
|
|
private static ElnRecordRepeatRowEntity copyRepeatRow(
|
ElnRecordRepeatRowEntity source, String revisionId, UserContext user, Date now) {
|
ElnRecordRepeatRowEntity row = new ElnRecordRepeatRowEntity();
|
row.setId(IdUtil.getSnowflakeNextIdStr());
|
row.setDianziJiluId(source.getDianziJiluId());
|
row.setXiudingId(revisionId);
|
row.setMubanId(source.getMubanId());
|
row.setRepeatGroupCode(source.getRepeatGroupCode());
|
row.setRowId(source.getRowId());
|
row.setRowOrder(source.getRowOrder());
|
row.setOperationCode(source.getOperationCode());
|
row.setOperationStatus(source.getOperationStatus());
|
row.setDeleteOperationCode(source.getDeleteOperationCode());
|
row.setDeleteReason(source.getDeleteReason());
|
row.setDeleteRequestedUserId(source.getDeleteRequestedUserId());
|
row.setDeleteRequestedTime(source.getDeleteRequestedTime());
|
row.setFTenantId(user.tenantId);
|
row.setFVersion(0);
|
row.setFCreatorUserId(user.userId);
|
row.setFCreatorTime(now);
|
row.setFLastModifyUserId(user.userId);
|
row.setFLastModifyTime(now);
|
row.setFDeleteUserId(source.getFDeleteUserId());
|
row.setFDeleteTime(source.getFDeleteTime());
|
row.setFDeleteMark(source.getFDeleteMark());
|
return row;
|
}
|
|
private static ElnRecordRepeatValueEntity copyRepeatValue(
|
ElnRecordRepeatValueEntity source, String revisionId, UserContext user, Date now) {
|
ElnRecordRepeatValueEntity value = new ElnRecordRepeatValueEntity();
|
value.setId(IdUtil.getSnowflakeNextIdStr());
|
value.setDianziJiluId(source.getDianziJiluId());
|
value.setXiudingId(revisionId);
|
value.setMubanId(source.getMubanId());
|
value.setRepeatRowId(source.getRepeatRowId());
|
value.setRepeatGroupCode(source.getRepeatGroupCode());
|
value.setMubanBangdingId(source.getMubanBangdingId());
|
value.setZiduanDingyiId(source.getZiduanDingyiId());
|
value.setZiduanBianma(source.getZiduanBianma());
|
value.setZiduanBanbenId(source.getZiduanBanbenId());
|
value.setBangdingJuese(source.getBangdingJuese());
|
value.setBangdingZhuangtai(source.getBangdingZhuangtai());
|
value.setZhiWenben(source.getZhiWenben());
|
value.setZhiShuzhi(source.getZhiShuzhi());
|
value.setZhiRiqi(source.getZhiRiqi());
|
value.setZhiLaiyuan(source.getZhiLaiyuan());
|
value.setJisuanZhuangtai(source.getJisuanZhuangtai());
|
value.setJisuanXiaoxi(source.getJisuanXiaoxi());
|
value.setJisuanShijian(source.getJisuanShijian());
|
value.setFTenantId(user.tenantId);
|
value.setFVersion(0);
|
value.setFCreatorUserId(user.userId);
|
value.setFCreatorTime(now);
|
value.setFLastModifyUserId(user.userId);
|
value.setFLastModifyTime(now);
|
value.setFDeleteUserId(source.getFDeleteUserId());
|
value.setFDeleteTime(source.getFDeleteTime());
|
value.setFDeleteMark(source.getFDeleteMark());
|
return value;
|
}
|
|
private static boolean validRepeatRowLifecycle(ElnRecordRepeatRowEntity row) {
|
String status = row.getOperationStatus();
|
boolean deleted = deleted(row);
|
if ("DELETED".equals(status)) {
|
return deleted && hasDeleteIntent(row)
|
&& StringUtils.hasText(row.getFDeleteUserId())
|
&& row.getFDeleteTime() != null;
|
}
|
if ("DELETE_PREPARED".equals(status)) {
|
return !deleted && hasDeleteIntent(row);
|
}
|
if (ACTIVE.equals(status) || "PREPARED".equals(status)
|
|| "CANCELLED".equals(status)) {
|
return !deleted && !hasAnyDeleteIntent(row);
|
}
|
return false;
|
}
|
|
private static boolean hasDeleteIntent(ElnRecordRepeatRowEntity row) {
|
return StringUtils.hasText(row.getDeleteOperationCode())
|
&& StringUtils.hasText(row.getDeleteReason())
|
&& StringUtils.hasText(row.getDeleteRequestedUserId())
|
&& row.getDeleteRequestedTime() != null;
|
}
|
|
private static boolean hasAnyDeleteIntent(ElnRecordRepeatRowEntity row) {
|
return row.getDeleteOperationCode() != null || row.getDeleteReason() != null
|
|| row.getDeleteRequestedUserId() != null || row.getDeleteRequestedTime() != null;
|
}
|
|
private static boolean deleted(ElnRecordRepeatRowEntity row) {
|
return Objects.equals(row.getFDeleteMark(), 1);
|
}
|
|
private static boolean deleted(ElnRecordRepeatValueEntity value) {
|
return Objects.equals(value.getFDeleteMark(), 1);
|
}
|
|
private static String repeatRowKey(String groupCode, String rowId) {
|
return groupCode + "\n" + rowId;
|
}
|
|
private ElnRecordFieldValueEntity copyValue(
|
ElnRecordFieldValueEntity source, String revisionId,
|
TestWorkItemSnapshot snapshot, UserContext user, Date now) {
|
ElnRecordFieldValueEntity value = new ElnRecordFieldValueEntity();
|
value.setId(IdUtil.getSnowflakeNextIdStr());
|
value.setDianziJiluId(source.getDianziJiluId());
|
value.setXiudingId(revisionId);
|
value.setMubanId(source.getMubanId());
|
value.setMubanBangdingId(source.getMubanBangdingId());
|
value.setZiduanDingyiId(source.getZiduanDingyiId());
|
value.setZiduanBianma(source.getZiduanBianma());
|
value.setZiduanBanbenId(source.getZiduanBanbenId());
|
value.setBangdingJuese(source.getBangdingJuese());
|
value.setBangdingZhuangtai(source.getBangdingZhuangtai());
|
value.setZhiWenben(source.getZhiWenben());
|
value.setZhiShuzhi(source.getZhiShuzhi());
|
value.setZhiRiqi(source.getZhiRiqi());
|
value.setZhiLaiyuan(source.getZhiLaiyuan());
|
value.setYuanShuxing(source.getYuanShuxing());
|
value.setYuanShuxingBanben(source.getYuanShuxingBanben());
|
value.setYuanYinyongLeixing(source.getYuanYinyongLeixing());
|
value.setYuanYinyongId(source.getYuanYinyongId());
|
value.setYuanHuoquShijian(source.getYuanHuoquShijian());
|
value.setYuanQuzhiZhuangtai(source.getYuanQuzhiZhuangtai());
|
value.setYuanQuzhiYuanyin(source.getYuanQuzhiYuanyin());
|
value.setYuanXueyuan(source.getYuanXueyuan());
|
value.setKuamoLaiyuanJiluId(source.getKuamoLaiyuanJiluId());
|
value.setKuamoLaiyuanXiudingId(source.getKuamoLaiyuanXiudingId());
|
value.setKuamoLaiyuanZhiId(source.getKuamoLaiyuanZhiId());
|
value.setKuamoLaiyuanZiduanBanbenId(source.getKuamoLaiyuanZiduanBanbenId());
|
value.setKuamoHuoquShijian(source.getKuamoHuoquShijian());
|
value.setJisuanZhuangtai(source.getJisuanZhuangtai());
|
value.setJisuanXiaoxi(source.getJisuanXiaoxi());
|
value.setJisuanShijian(source.getJisuanShijian());
|
value.setFTenantId(user.tenantId);
|
value.setFVersion(0);
|
value.setFDeleteMark(0);
|
value.setFCreatorUserId(user.userId);
|
value.setFLastModifyUserId(user.userId);
|
value.setFCreatorTime(now);
|
value.setFLastModifyTime(now);
|
|
if (CROSS_TEMPLATE.equals(source.getZhiLaiyuan())) {
|
return value;
|
}
|
if (source.getYuanShuxingBanben() != null) {
|
return value;
|
}
|
ElnFieldVersionEntity version = fixedVersion(user.tenantId, source);
|
ElnFieldForms.Binding binding = parseBinding(version.getBangdingPeizhi());
|
String provider = binding == null || binding.getRead() == null
|
? null : binding.getRead().getSource();
|
String property = binding == null || binding.getRead() == null
|
? null : binding.getRead().getProperty();
|
if (LIMS_TASK.equals(provider)) {
|
TestWorkItemSnapshotProperty taskValue = taskProperty(snapshot, property);
|
if (!Objects.equals(version.getShujuLeixing(), taskValue.getDataType())) {
|
throw new DataException("LIMS 任务快照字段类型与固定字段版本不一致");
|
}
|
value.setZhiWenben(taskValue.getValue());
|
value.setZhiShuzhi(null);
|
value.setZhiRiqi(null);
|
value.setZhiLaiyuan(LIMS_TASK);
|
value.setYuanShuxing(property);
|
value.setYuanYinyongLeixing(taskValue.getSource());
|
value.setYuanYinyongId(taskValue.getSourceRef());
|
value.setYuanHuoquShijian(now);
|
} else if (SYSTEM.equals(provider)) {
|
applySystemValue(value, property, user, now);
|
}
|
return value;
|
}
|
|
private ElnFieldVersionEntity fixedVersion(
|
String tenantId, ElnRecordFieldValueEntity value) {
|
ElnFieldVersionEntity version = fieldVersionMapper.selectOne(
|
Wrappers.<ElnFieldVersionEntity>lambdaQuery()
|
.eq(ElnFieldVersionEntity::getFTenantId, tenantId)
|
.eq(ElnFieldVersionEntity::getId, value.getZiduanBanbenId())
|
.and(q -> q.isNull(ElnFieldVersionEntity::getFDeleteMark)
|
.or().eq(ElnFieldVersionEntity::getFDeleteMark, 0))
|
.last("limit 1"));
|
if (version == null || !Objects.equals(
|
value.getZiduanDingyiId(), version.getZiduanDingyiId())) {
|
throw new DataException("电子记录固定字段版本无效");
|
}
|
return version;
|
}
|
|
private TestWorkItemSnapshot snapshot(UserContext user, String testWorkItemId) {
|
TestWorkItemSnapshotBatch batch = taskProvider.resolveAsActor(
|
user.tenantId, user.userId,
|
Collections.singletonList(testWorkItemId),
|
Collections.singletonList("test.basis"));
|
if (batch == null || batch.getItems() == null || batch.getItems().size() != 1) {
|
throw new DataException("LIMS 检验任务快照返回无效");
|
}
|
TestWorkItemSnapshot item = batch.getItems().get(0);
|
if (item == null || !testWorkItemId.equals(item.getTestWorkItemId())
|
|| !"SUCCESS".equals(item.getOutcomeCode())) {
|
throw new DataException(item != null && StringUtils.hasText(item.getReason())
|
? item.getReason() : "当前用户或检验项状态不允许打开电子记录");
|
}
|
return item;
|
}
|
|
private ElnRecordRevisionEntity currentRevision(String tenantId, ElnRecordEntity record) {
|
ElnRecordRevisionEntity revision = revisionMapper.selectOne(
|
Wrappers.<ElnRecordRevisionEntity>lambdaQuery()
|
.eq(ElnRecordRevisionEntity::getFTenantId, tenantId)
|
.eq(ElnRecordRevisionEntity::getId, record.getDangqianXiudingId())
|
.eq(ElnRecordRevisionEntity::getDianziJiluId, record.getId())
|
.and(q -> q.isNull(ElnRecordRevisionEntity::getFDeleteMark)
|
.or().eq(ElnRecordRevisionEntity::getFDeleteMark, 0))
|
.last("limit 1"));
|
if (revision == null) {
|
throw new DataException("电子记录当前修订不存在");
|
}
|
return revision;
|
}
|
|
private ElnRecordRevisionEntity revisionByOperation(
|
String tenantId, String recordId, String operationCode) {
|
return revisionMapper.selectOne(Wrappers.<ElnRecordRevisionEntity>lambdaQuery()
|
.eq(ElnRecordRevisionEntity::getFTenantId, tenantId)
|
.eq(ElnRecordRevisionEntity::getDianziJiluId, recordId)
|
.eq(ElnRecordRevisionEntity::getXiudingCaozuoBianma, operationCode)
|
.and(q -> q.isNull(ElnRecordRevisionEntity::getFDeleteMark)
|
.or().eq(ElnRecordRevisionEntity::getFDeleteMark, 0))
|
.last("limit 1"));
|
}
|
|
private static ElnRecordRevisionEntity revision(
|
String revisionId, String recordId, ElnRecordRevisionEntity source,
|
String operationCode, String document, UserContext user, Date now) {
|
ElnRecordRevisionEntity revision = new ElnRecordRevisionEntity();
|
revision.setId(revisionId);
|
revision.setDianziJiluId(recordId);
|
revision.setXiudingHao(source.getXiudingHao() + 1);
|
revision.setLaiyuanXiudingId(source.getId());
|
revision.setXiudingCaozuoBianma(operationCode);
|
revision.setJiluWendang(document);
|
revision.setBizStatus(DRAFT);
|
revision.setFTenantId(user.tenantId);
|
revision.setFVersion(0);
|
revision.setFDeleteMark(0);
|
revision.setFCreatorUserId(user.userId);
|
revision.setFLastModifyUserId(user.userId);
|
revision.setFCreatorTime(now);
|
revision.setFLastModifyTime(now);
|
return revision;
|
}
|
|
private static void applySystemValue(
|
ElnRecordFieldValueEntity value, String property, UserContext user, Date now) {
|
value.setZhiWenben(null);
|
value.setZhiShuzhi(null);
|
value.setZhiRiqi(null);
|
value.setZhiLaiyuan(SYSTEM);
|
value.setYuanShuxing(property);
|
value.setYuanYinyongLeixing(SYSTEM);
|
value.setYuanYinyongId(user.userId);
|
value.setYuanHuoquShijian(now);
|
if ("current_user.id".equals(property)) {
|
value.setZhiWenben(user.userId);
|
} else if ("current_user.real_name".equals(property)) {
|
value.setZhiWenben(user.userName);
|
} else if ("current_date".equals(property)) {
|
value.setZhiWenben(new SimpleDateFormat("yyyy-MM-dd").format(now));
|
value.setZhiRiqi(now);
|
} else if ("current_datetime".equals(property)) {
|
value.setZhiWenben(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(now));
|
value.setZhiRiqi(now);
|
} else {
|
throw new DataException("未支持的 SYSTEM property：" + property);
|
}
|
}
|
|
private static TestWorkItemSnapshotProperty taskProperty(
|
TestWorkItemSnapshot item, String property) {
|
if (item.getProperties() != null) {
|
for (TestWorkItemSnapshotProperty candidate : item.getProperties()) {
|
if (candidate != null && Objects.equals(property, candidate.getProperty())) {
|
if (!"SUCCESS".equals(candidate.getOutcomeCode())) {
|
throw new DataException(StringUtils.hasText(candidate.getReason())
|
? candidate.getReason() : "LIMS 任务快照字段不可用");
|
}
|
return candidate;
|
}
|
}
|
}
|
throw new DataException("LIMS 任务快照缺少字段：" + property);
|
}
|
|
private static ElnFieldForms.Binding parseBinding(String json) {
|
try {
|
return StringUtils.hasText(json)
|
? JsonUtil.getJsonToBean(json, ElnFieldForms.Binding.class) : null;
|
} catch (RuntimeException e) {
|
throw new DataException("字段绑定配置无效");
|
}
|
}
|
|
private static String sourceDocument(String fileId) {
|
if (!StringUtils.hasText(fileId)) {
|
throw new DataException("电子记录来源修订缺少文档");
|
}
|
ElnDocumentFileVo file = new ElnDocumentFileVo();
|
file.setFileId(fileId);
|
file.setName(fileId);
|
file.setFileExtension("docx");
|
return JsonUtil.getObjectToString(Collections.singletonList(file));
|
}
|
|
private static ElnDocumentFileVo copiedDocument(String attachments) {
|
try {
|
List<ElnDocumentFileVo> files = JsonUtil.getJsonToList(attachments, ElnDocumentFileVo.class);
|
if (files == null || files.size() != 1 || files.get(0) == null
|
|| !StringUtils.hasText(files.get(0).getFileId())) {
|
throw new DataException("独占电子记录文档复制结果无效");
|
}
|
return files.get(0);
|
} catch (DataException e) {
|
throw e;
|
} catch (RuntimeException e) {
|
throw new DataException("独占电子记录文档复制结果无效");
|
}
|
}
|
|
private static ElnRecordVos.Created created(
|
ElnRecordEntity record, ElnRecordRevisionEntity revision, boolean existing) {
|
ElnRecordVos.Created result = new ElnRecordVos.Created();
|
result.setRecordId(record.getId());
|
result.setRevisionId(revision.getId());
|
result.setDocument(document(revision.getJiluWendang()));
|
result.setExisting(existing);
|
return result;
|
}
|
|
private static ElnDocumentFileVo document(String fileId) {
|
if (!StringUtils.hasText(fileId)) {
|
throw new DataException("电子记录当前修订缺少文档");
|
}
|
ElnDocumentFileVo document = new ElnDocumentFileVo();
|
document.setFileId(fileId);
|
document.setName(fileId);
|
document.setFileExtension("docx");
|
return document;
|
}
|
|
private static String required(String value, String message) {
|
if (!StringUtils.hasText(value)) {
|
throw new DataException(message);
|
}
|
return value.trim();
|
}
|
|
private static UserContext currentUser() {
|
UserInfo user = UserProvider.getUser();
|
if (user == null || !StringUtils.hasText(user.getUserId())) {
|
throw new DataException("当前登录用户无效");
|
}
|
TenantVO routed = TenantDataSourceUtil.getTenantInfo();
|
String tenantId = routed != null && StringUtils.hasText(routed.getEnCode())
|
? routed.getEnCode().trim() : user.getTenantId();
|
return new UserContext(
|
StringUtils.hasText(tenantId) ? tenantId.trim() : "0",
|
user.getUserId().trim(), user.getUserName());
|
}
|
|
private static RecordRevisionFence remoteFence(RecordRevisionFenceApi api) {
|
return new RecordRevisionFence() {
|
@Override
|
public String acquire(String tenantId, String recordId,
|
String fileId, String fileType) {
|
ActionResult<String> result = api.acquire(tenantId, recordId, 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 complete(FenceLease lease) {
|
requireFenceResult(api.complete(lease.tenantId, lease.recordId,
|
lease.fileId, lease.fileType, lease.token),
|
"OnlyOffice 历史文档标记失败，需人工恢复");
|
}
|
|
@Override
|
public void release(FenceLease lease) {
|
requireFenceResult(api.release(lease.tenantId, lease.recordId,
|
lease.fileId, lease.fileType, lease.token),
|
"OnlyOffice 记录修订锁释放失败，需人工恢复");
|
}
|
};
|
}
|
|
private static void requireFenceResult(ActionResult<Boolean> result, String fallback) {
|
if (result == null
|
|| !ActionResultCode.SUCCESS.getCode().equals(result.getCode())
|
|| !Boolean.TRUE.equals(result.getData())) {
|
throw new DataException(result == null || !StringUtils.hasText(result.getMsg())
|
? fallback : result.getMsg());
|
}
|
}
|
|
private static final class RepeatSnapshot {
|
private final List<ElnRecordRepeatRowEntity> rows;
|
private final List<ElnRecordRepeatValueEntity> values;
|
|
private RepeatSnapshot(List<ElnRecordRepeatRowEntity> rows,
|
List<ElnRecordRepeatValueEntity> values) {
|
this.rows = rows;
|
this.values = values;
|
}
|
}
|
|
@FunctionalInterface
|
interface CurrentUserProvider {
|
UserContext get();
|
}
|
|
interface RecordRevisionFence {
|
String acquire(String tenantId, String recordId, String fileId, String fileType);
|
|
void complete(FenceLease lease);
|
|
void release(FenceLease lease);
|
|
}
|
|
static final class FenceLease {
|
private final String tenantId;
|
private final String recordId;
|
private final String fileId;
|
private final String fileType;
|
private final String token;
|
|
FenceLease(String tenantId, String recordId, String fileId,
|
String fileType, String token) {
|
this.tenantId = tenantId;
|
this.recordId = recordId;
|
this.fileId = fileId;
|
this.fileType = fileType;
|
this.token = token;
|
}
|
}
|
|
static final class UserContext {
|
private final String tenantId;
|
private final String userId;
|
private final String userName;
|
|
UserContext(String tenantId, String userId, String userName) {
|
this.tenantId = tenantId;
|
this.userId = userId;
|
this.userName = userName;
|
}
|
}
|
}
|
