package jnpf.dmsService.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import jnpf.audit.sdk.annotation.AuditLog;
|
import jnpf.dmsEntity.DmsWenjianFushenYanqiShenqingEntity;
|
import jnpf.dmsEntity.DmsWenjianFushenYanqiShenqingZixiangEntity;
|
import jnpf.dmsEntity.storage.form.DmsFileExtendValidityForm;
|
import jnpf.dmsEntity.storage.form.DmsFileExtendValidityForm.FileRequest;
|
import jnpf.dmsMapper.DmsWenjianFushenYanqiShenqingMapper;
|
import jnpf.dmsMapper.DmsWenjianFushenYanqiShenqingZixiangMapper;
|
import jnpf.dmsMapper.DmsWenjianZiyuanMapper;
|
import jnpf.dmsService.DmsFileValidityService;
|
import jnpf.dmsService.DmsWenjianFushenYanqiShenqingTongguoService;
|
import jnpf.exception.DataException;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.text.SimpleDateFormat;
|
import java.time.LocalDate;
|
import java.time.ZoneId;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.UUID;
|
|
@Service
|
@RequiredArgsConstructor
|
public class DmsWenjianFushenYanqiShenqingTongguoServiceImpl
|
implements DmsWenjianFushenYanqiShenqingTongguoService {
|
|
private static final String DATE_TIME_PATTERN = "yyyy-MM-dd HH:mm:ss";
|
|
private final DmsWenjianFushenYanqiShenqingMapper shenqingMapper;
|
private final DmsWenjianFushenYanqiShenqingZixiangMapper zixiangMapper;
|
private final DmsWenjianZiyuanMapper ziyuanMapper;
|
private final DmsFileValidityService fileValidityService;
|
private final jnpf.dmsService.DmsBusinessLifecycleGuard businessOccupancy;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
@AuditLog(
|
action = "FILE_REVIEW_EXTENSION_APPROVE",
|
label = "文件复审延期申请审批通过",
|
bizModule = "文件复审延期申请",
|
bizType = "DMS_FILE_REVIEW_EXTENSION",
|
bizCodeExpr = "#result",
|
targetTable = "wenjian_fushen_yanqi_shenqing",
|
targetIdExpr = "#result"
|
)
|
public String tongguo(String flowId, String taskId) throws DataException {
|
String normalizedFlowId = requireValue(flowId, "流程ID(flow_id)");
|
String normalizedTaskId = requireValue(taskId, "流程任务ID(task_id)");
|
DmsWenjianFushenYanqiShenqingEntity shenqing = findApplication(
|
normalizedFlowId, normalizedTaskId);
|
List<DmsWenjianFushenYanqiShenqingZixiangEntity> zixiangs = findZixiangs(shenqing.getId());
|
var receipts=businessOccupancy.requireCurrentUserExtension(normalizedTaskId,shenqing.getId(),
|
zixiangs.stream().map(DmsWenjianFushenYanqiShenqingZixiangEntity::getWenjianId).toList());
|
String fushenRiqi = formatDate(shenqing.getShenqingRiqi());
|
|
if (!zixiangs.isEmpty()) {
|
fileValidityService.extendValidity(buildExtendValidityForm(
|
normalizedFlowId, normalizedTaskId, zixiangs, receipts));
|
}
|
for (DmsWenjianFushenYanqiShenqingZixiangEntity zixiang : zixiangs) {
|
String wenjianId = requireValue(zixiang.getWenjianId(), "文件复审延期申请子项wenjian_id");
|
int updated = ziyuanMapper.updateReviewExtension(
|
wenjianId, zixiang.getYanqiZhi(), shenqing.getId(), fushenRiqi);
|
if (updated != 1) {
|
throw new DataException("未找到可更新的文件资源：wenjian_id=" + wenjianId);
|
}
|
}
|
businessOccupancy.completeExecution(receipts);
|
return shenqing.getId();
|
}
|
|
private DmsFileExtendValidityForm buildExtendValidityForm(
|
String flowId, String taskId,
|
List<DmsWenjianFushenYanqiShenqingZixiangEntity> zixiangs,
|
List<jnpf.dmsBusinessOccupancy.BusinessFileOccupancy> receipts) throws DataException {
|
List<FileRequest> files = new ArrayList<>(zixiangs.size());
|
for (DmsWenjianFushenYanqiShenqingZixiangEntity zixiang : zixiangs) {
|
String wenjianId = requireValue(zixiang.getWenjianId(), "文件复审延期申请子项wenjian_id");
|
String fileVersionId = requireValue(receipts.isEmpty() ? ziyuanMapper.selectFileVersionIdByWenjianId(wenjianId)
|
: receipts.stream().filter(r -> wenjianId.equals(r.getFileId())).findFirst().orElseThrow().getCenterVersionId(),
|
"文件中心版本ID：wenjian_id=" + wenjianId);
|
FileRequest file = new FileRequest();
|
try {
|
file.setFileVersionId(UUID.fromString(fileVersionId));
|
} catch (IllegalArgumentException exception) {
|
throw new DataException("文件中心版本ID格式不正确：wenjian_id=" + wenjianId);
|
}
|
file.setEffectiveTo(endOfDay(zixiang.getYanqiZhi()));
|
files.add(file);
|
}
|
DmsFileExtendValidityForm form = new DmsFileExtendValidityForm();
|
form.setSourceId(flowId);
|
form.setTaskId(taskId);
|
form.setFiles(files);
|
return form;
|
}
|
|
private DmsWenjianFushenYanqiShenqingEntity findApplication(String flowId, String taskId)
|
throws DataException {
|
LambdaQueryWrapper<DmsWenjianFushenYanqiShenqingEntity> query = new LambdaQueryWrapper<>();
|
query.eq(DmsWenjianFushenYanqiShenqingEntity::getFlowId, flowId)
|
.eq(DmsWenjianFushenYanqiShenqingEntity::getFlowTaskId, taskId)
|
.isNull(DmsWenjianFushenYanqiShenqingEntity::getDeleteMark);
|
List<DmsWenjianFushenYanqiShenqingEntity> applications = shenqingMapper.selectList(query);
|
if (applications == null || applications.isEmpty()) {
|
throw new DataException("未找到文件复审延期申请：flow_id=" + flowId + ", task_id=" + taskId);
|
}
|
if (applications.size() > 1) {
|
throw new DataException("flow_id与task_id关联了多条文件复审延期申请，无法确认通过记录");
|
}
|
return applications.get(0);
|
}
|
|
private List<DmsWenjianFushenYanqiShenqingZixiangEntity> findZixiangs(String shenqingId) {
|
LambdaQueryWrapper<DmsWenjianFushenYanqiShenqingZixiangEntity> query = new LambdaQueryWrapper<>();
|
query.eq(DmsWenjianFushenYanqiShenqingZixiangEntity::getForeignId, shenqingId)
|
.isNull(DmsWenjianFushenYanqiShenqingZixiangEntity::getDeleteMark);
|
return zixiangMapper.selectList(query);
|
}
|
|
private String formatDate(Date value) {
|
return value == null ? null : new SimpleDateFormat(DATE_TIME_PATTERN).format(value);
|
}
|
|
private Date endOfDay(Date value) throws DataException {
|
if (value == null) {
|
throw new DataException("文件复审延期申请子项yanqi_zhi不能为空");
|
}
|
ZoneId zoneId = ZoneId.of("Asia/Shanghai");
|
LocalDate date = value.toInstant().atZone(zoneId).toLocalDate();
|
return Date.from(date.plusDays(1).atStartOfDay(zoneId).toInstant());
|
}
|
|
private String requireValue(String value, String fieldName) throws DataException {
|
String result = value == null ? "" : value.trim();
|
if (result.isEmpty()) {
|
throw new DataException(fieldName + "不能为空");
|
}
|
return result;
|
}
|
}
|
