package jnpf.elnService.impl;
|
|
import jnpf.base.UserInfo;
|
import jnpf.database.util.TenantDataSourceUtil;
|
import jnpf.elnEntity.ElnDocumentFileVo;
|
import jnpf.elnEntity.runtime.ElnRecordEntity;
|
import jnpf.elnEntity.runtime.ElnRecordRevisionEntity;
|
import jnpf.elnEntity.runtime.ElnRecordVos;
|
import jnpf.elnMapper.ElnRecordMapper;
|
import jnpf.elnMapper.ElnRecordRevisionMapper;
|
import jnpf.elnService.ElnRecordQueryService;
|
import jnpf.exception.DataException;
|
import jnpf.model.tenant.TenantVO;
|
import jnpf.util.UserProvider;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.StringUtils;
|
|
import java.util.Objects;
|
|
@Service
|
public class ElnRecordQueryServiceImpl implements ElnRecordQueryService {
|
|
private final ElnRecordMapper recordMapper;
|
private final ElnRecordRevisionMapper revisionMapper;
|
private final TenantProvider tenantProvider;
|
|
@Autowired
|
public ElnRecordQueryServiceImpl(ElnRecordMapper recordMapper,
|
ElnRecordRevisionMapper revisionMapper) {
|
this(recordMapper, revisionMapper, ElnRecordQueryServiceImpl::currentTenant);
|
}
|
|
ElnRecordQueryServiceImpl(ElnRecordMapper recordMapper,
|
ElnRecordRevisionMapper revisionMapper,
|
TenantProvider tenantProvider) {
|
this.recordMapper = recordMapper;
|
this.revisionMapper = revisionMapper;
|
this.tenantProvider = tenantProvider;
|
}
|
|
@Override
|
@Transactional(readOnly = true)
|
public ElnRecordVos.Created getByTestWorkItem(String testWorkItemId) {
|
String itemId = required(testWorkItemId, "检验项不能为空");
|
String tenantId = tenantProvider.get();
|
ElnRecordEntity record = recordMapper.selectLiveByTestWorkItem(tenantId, itemId);
|
if (record == null || !tenantId.equals(record.getFTenantId())
|
|| !itemId.equals(record.getJianyanXiangId())
|
|| !StringUtils.hasText(record.getDangqianXiudingId())) {
|
throw new DataException("检验项电子记录不存在");
|
}
|
|
ElnRecordRevisionEntity revision = revisionMapper.selectById(record.getDangqianXiudingId());
|
if (revision == null || !tenantId.equals(revision.getFTenantId())
|
|| !record.getId().equals(revision.getDianziJiluId())
|
|| !record.getDangqianXiudingId().equals(revision.getId())
|
|| Objects.equals(1, revision.getFDeleteMark())
|
|| !StringUtils.hasText(revision.getJiluWendang())) {
|
throw new DataException("电子记录当前修订不存在或无效");
|
}
|
|
ElnRecordVos.Created result = new ElnRecordVos.Created();
|
result.setRecordId(record.getId());
|
result.setRevisionId(revision.getId());
|
result.setDocument(document(record, revision));
|
result.setExisting(true);
|
return result;
|
}
|
|
private static ElnDocumentFileVo document(
|
ElnRecordEntity record, ElnRecordRevisionEntity revision) {
|
ElnDocumentFileVo document = new ElnDocumentFileVo();
|
document.setFileId(revision.getJiluWendang().trim());
|
document.setName((StringUtils.hasText(record.getJiluBianhao())
|
? record.getJiluBianhao().trim() : record.getId()) + ".docx");
|
document.setFileExtension("docx");
|
return document;
|
}
|
|
private static String currentTenant() {
|
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 StringUtils.hasText(tenantId) ? tenantId.trim() : "0";
|
}
|
|
private static String required(String value, String message) {
|
if (!StringUtils.hasText(value)) {
|
throw new DataException(message);
|
}
|
return value.trim();
|
}
|
|
@FunctionalInterface
|
interface TenantProvider {
|
String get();
|
}
|
}
|
