package jnpf.dmsService;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import jnpf.audit.sdk.annotation.AuditLog;
|
import jnpf.base.ActionResult;
|
import jnpf.base.ActionResultCode;
|
import jnpf.dms.DmsResourceApi;
|
import jnpf.dmsEntity.DmsWenjianBanbenEntity;
|
import jnpf.dmsEntity.permission.form.DmsPersonalFolderFileForm;
|
import jnpf.dmsEntity.print.form.DmsWorkflowPrintFilesGrantForm;
|
import jnpf.dmsEntity.print.vo.DmsWorkflowPrintFilesGrantResultVO;
|
import jnpf.dmsEntity.waifa.DmsWenjianWaifaShenqingDetailEntity;
|
import jnpf.dmsEntity.waifa.DmsWenjianWaifaShenqingEntity;
|
import jnpf.dmsMapper.DmsWenjianBanbenMapper;
|
import jnpf.dmsMapper.DmsWenjianWaifaShenqingDetailMapper;
|
import jnpf.dmsMapper.DmsWenjianWaifaShenqingMapper;
|
import jnpf.exception.DataException;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.LinkedHashSet;
|
import java.util.List;
|
import java.util.Set;
|
import java.util.UUID;
|
|
/** 文件辅助管理中的外发打印授权业务。 */
|
@Service
|
@RequiredArgsConstructor
|
public class DmsWenjianFuzhuGuanliWaifaService {
|
|
private static final String FLOWABLE_SERVICE_ID = "jnpf-flowable";
|
|
private final DmsWenjianWaifaShenqingMapper shenqingMapper;
|
private final DmsWenjianWaifaShenqingDetailMapper zixiangMapper;
|
private final DmsWenjianBanbenMapper banbenMapper;
|
private final DmsResourceApi dmsResourceApi;
|
|
/** 按外发申请明细 ID 标记为已打印。 */
|
public void waifaYidayin(String id) {
|
String normalizedId = requireValue(id, "外发申请明细ID(id)");
|
LambdaUpdateWrapper<DmsWenjianWaifaShenqingDetailEntity> update =
|
new LambdaUpdateWrapper<>();
|
update.eq(DmsWenjianWaifaShenqingDetailEntity::getId, normalizedId)
|
.set(DmsWenjianWaifaShenqingDetailEntity::getShifouYidayin, "yes");
|
if (zixiangMapper.update(null, update) != 1) {
|
throw new DataException("未找到对应的外发申请明细：id=" + normalizedId);
|
}
|
}
|
|
/** 根据流程对应的外发申请，为申请人永久授予相关文件版本的打印权限。 */
|
public DmsWorkflowPrintFilesGrantResultVO waifaWenjianShouquan(
|
String flowId, String flowTaskId) {
|
String normalizedFlowId = requireValue(flowId, "流程ID(flow_id)");
|
String normalizedFlowTaskId = requireValue(flowTaskId, "流程任务ID(flow_task_id)");
|
DmsWenjianWaifaShenqingEntity shenqing = findShenqing(
|
normalizedFlowId, normalizedFlowTaskId);
|
Set<String> banbenIds = findBanbenIds(shenqing.getId());
|
List<DmsWenjianBanbenEntity> banbens = findBanbens(banbenIds);
|
DmsWorkflowPrintFilesGrantForm grantForm = buildGrantForm(shenqing, banbens);
|
|
ActionResult<DmsWorkflowPrintFilesGrantResultVO> response;
|
try {
|
response = dmsResourceApi.grantWorkflowPrintFiles(
|
FLOWABLE_SERVICE_ID, grantForm);
|
} catch (RuntimeException exception) {
|
throw new DataException("调用DMS文件打印授权接口失败");
|
}
|
if (response == null || !ActionResultCode.SUCCESS.getCode().equals(response.getCode())
|
|| response.getData() == null) {
|
String message = response == null ? null : response.getMsg();
|
throw new DataException(isBlank(message) ? "外发文件授权失败或响应数据不完整" : message);
|
}
|
return response.getData();
|
}
|
|
/** 查询流程唯一对应的未删除外发申请。 */
|
private DmsWenjianWaifaShenqingEntity findShenqing(String flowId, String flowTaskId) {
|
LambdaQueryWrapper<DmsWenjianWaifaShenqingEntity> query = new LambdaQueryWrapper<>();
|
query.eq(DmsWenjianWaifaShenqingEntity::getFlowId, flowId)
|
.eq(DmsWenjianWaifaShenqingEntity::getFlowTaskId, flowTaskId)
|
.isNull(DmsWenjianWaifaShenqingEntity::getDeleteMark);
|
List<DmsWenjianWaifaShenqingEntity> rows = shenqingMapper.selectList(query);
|
if (rows.isEmpty()) {
|
throw new DataException("未找到文件外发申请：flow_id=" + flowId
|
+ ", flow_task_id=" + flowTaskId);
|
}
|
if (rows.size() > 1) {
|
throw new DataException("flow_id与flow_task_id关联了多条文件外发申请，无法授权");
|
}
|
return rows.get(0);
|
}
|
|
/** 查询申请明细并提取非空的业务版本 ID，保持原顺序去重。 */
|
private Set<String> findBanbenIds(String shenqingId) {
|
LambdaQueryWrapper<DmsWenjianWaifaShenqingDetailEntity> query =
|
new LambdaQueryWrapper<>();
|
query.eq(DmsWenjianWaifaShenqingDetailEntity::getRequestId, shenqingId)
|
.isNull(DmsWenjianWaifaShenqingDetailEntity::getDeleteMark);
|
List<DmsWenjianWaifaShenqingDetailEntity> rows = zixiangMapper.selectList(query);
|
if (rows.isEmpty()) {
|
throw new DataException("文件外发申请未关联外发明细，无法授权");
|
}
|
Set<String> ids = new LinkedHashSet<>();
|
for (DmsWenjianWaifaShenqingDetailEntity row : rows) {
|
ids.add(requireValue(row.getBanbenId(), "文件外发明细版本ID(banben_id)"));
|
}
|
return ids;
|
}
|
|
/** 按明细版本 ID 查询全部未删除的业务文件版本。 */
|
private List<DmsWenjianBanbenEntity> findBanbens(Set<String> banbenIds) {
|
LambdaQueryWrapper<DmsWenjianBanbenEntity> query = new LambdaQueryWrapper<>();
|
query.in(DmsWenjianBanbenEntity::getId, banbenIds)
|
.isNull(DmsWenjianBanbenEntity::getDeleteMark);
|
List<DmsWenjianBanbenEntity> rows = banbenMapper.selectList(query);
|
if (rows.size() != banbenIds.size()) {
|
throw new DataException("部分外发明细未找到对应的有效文件版本");
|
}
|
return rows;
|
}
|
|
/** 组装永久有效的文件打印授权请求。 */
|
private DmsWorkflowPrintFilesGrantForm buildGrantForm(
|
DmsWenjianWaifaShenqingEntity shenqing,
|
List<DmsWenjianBanbenEntity> banbens) {
|
List<DmsPersonalFolderFileForm.FileRelation> files = new ArrayList<>(banbens.size());
|
for (DmsWenjianBanbenEntity banben : banbens) {
|
DmsPersonalFolderFileForm.FileRelation relation =
|
new DmsPersonalFolderFileForm.FileRelation();
|
try {
|
relation.setDocumentId(UUID.fromString(banben.getWenjianZhongxinWenjianId()));
|
relation.setFileVersionId(UUID.fromString(banben.getWenjianZhongxinBanbenId()));
|
} catch (IllegalArgumentException exception) {
|
throw new DataException("文件中心文件ID或版本ID格式不正确：banben_id="
|
+ banben.getId());
|
}
|
relation.setValidTo(null);
|
files.add(relation);
|
}
|
|
DmsWorkflowPrintFilesGrantForm form = new DmsWorkflowPrintFilesGrantForm();
|
form.setUserId(requireValue(
|
shenqing.getApplicantUserId(), "文件外发申请人(shenqing_ren)"));
|
form.setFiles(files);
|
return form;
|
}
|
|
private String requireValue(String value, String fieldName) {
|
if (isBlank(value)) {
|
throw new DataException(fieldName + "不能为空");
|
}
|
return value.trim();
|
}
|
|
private boolean isBlank(String value) {
|
return value == null || value.trim().isEmpty();
|
}
|
}
|
