package jnpf.dmsService;
|
|
import jnpf.audit.sdk.annotation.AuditLog;
|
import jnpf.base.UserInfo;
|
import jnpf.dmsEntity.fenfa.DmsWenjianDayinJiluEntity;
|
import jnpf.dmsEntity.fenfa.form.DmsWenjianGuidangForm;
|
import jnpf.dmsEntity.fenfa.vo.DmsWenjianHuishouMingxiVO;
|
import jnpf.dmsMapper.DmsWenjianFenfaMapper;
|
import jnpf.dmsMapper.DmsWenjianGuidangMapper;
|
import jnpf.dmsPermission.DmsCurrentIdentity;
|
import jnpf.exception.DataException;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.*;
|
|
/** 复用档案存档申请及接收，文件副本状态始终以打印记录为准。 */
|
@Service
|
@RequiredArgsConstructor
|
public class DmsWenjianGuidangService {
|
private final DmsCurrentIdentity identity;
|
private final DmsWenjianChongdaGuard reprintGuard;
|
private final DmsWenjianFenfaMapper fenfaMapper;
|
private final DmsWenjianGuidangMapper mapper;
|
|
@Transactional(rollbackFor = Exception.class)
|
@AuditLog(action = "FILE_ARCHIVE_CONFIRM", label = "文件确认归档", bizModule = "文件归档",
|
bizType = "DMS_FILE_ARCHIVE", bizCodeExpr = "", bizCodeRequired = false,
|
targetTable = "dms_wenjian_dayin_jilu", targetIdsExpr = "#p0.dayinJiluIds",
|
targetIdExpr = "#p0.dayinJiluIds[0]", reasonExpr = "#p0.beizhuShuoming",
|
extraExpr = "{'dayin_jilu_ids': #p0.dayinJiluIds, 'before_statuses': #p0.beforeStatuses, 'after_status': 'daiguidang'}",
|
diff = false, entityClass = DmsWenjianDayinJiluEntity.class)
|
public int confirm(DmsWenjianGuidangForm form) throws DataException {
|
if (form == null || blank(form.getBizSign())) throw new DataException("确认归档签名不能为空");
|
List<String> ids = resolveIds(form.getDayinJiluIds());
|
UserInfo user = identity.requireUser();
|
String tenantId = identity.tenantId(user);
|
List<DmsWenjianHuishouMingxiVO> prints = fenfaMapper.selectRecyclePrintsForUpdate(tenantId, ids);
|
if (prints.size() != ids.size()) throw new DataException("存在不存在、已删除或跨租户的文件副本");
|
Map<String, String> beforeStatuses = new LinkedHashMap<>();
|
Map<String, List<String>> byStatus = new TreeMap<>();
|
for (DmsWenjianHuishouMingxiVO print : prints) {
|
DmsWenjianHuishouPolicy.requireEligible(print);
|
reprintGuard.requireUnlocked(tenantId, print.getDayinJiluId());
|
beforeStatuses.put(print.getDayinJiluId(), print.getBizStatus());
|
byStatus.computeIfAbsent(print.getBizStatus(), key -> new ArrayList<>()).add(print.getDayinJiluId());
|
}
|
form.setBeforeStatuses(beforeStatuses);
|
Date now = new Date();
|
int count = 0;
|
for (Map.Entry<String, List<String>> group : byStatus.entrySet()) {
|
int updated = mapper.changeStatus(tenantId, group.getValue(), group.getKey(), "daiguidang", user.getUserId(), now);
|
if (updated != group.getValue().size()) throw new DataException("文件状态已变化，请刷新后重试");
|
count += updated;
|
}
|
DmsWenjianHuishouPolicy.completeDistributions(fenfaMapper, tenantId, prints, user.getUserId(), now);
|
return count;
|
}
|
|
/** 发起申请前返回服务端可信的名称、编号、版本和流水号。 */
|
@Transactional(rollbackFor = Exception.class)
|
public List<DmsWenjianHuishouMingxiVO> prepare(DmsWenjianGuidangForm form) throws DataException {
|
if (form == null) throw new DataException("归档申请参数不能为空");
|
List<String> ids = resolveIds(form.getDayinJiluIds());
|
String tenantId = identity.tenantId();
|
List<DmsWenjianHuishouMingxiVO> prints = lockPrints(tenantId, ids, "daiguidang");
|
ensureNoConflict(tenantId, ids, blank(form.getShenqingId()) ? null : form.getShenqingId().trim());
|
return prints;
|
}
|
|
private List<DmsWenjianHuishouMingxiVO> lockPrints(String tenantId, List<String> ids, String expected)
|
throws DataException {
|
List<DmsWenjianHuishouMingxiVO> prints = fenfaMapper.selectRecyclePrintsForUpdate(tenantId, ids);
|
if (prints.size() != ids.size()) throw new DataException("存在不存在、已删除或跨租户的文件副本");
|
for (DmsWenjianHuishouMingxiVO print : prints)
|
if (!expected.equals(print.getBizStatus())) throw new DataException("文件状态不允许本次归档操作：" + print.getDayinLiushuihao());
|
return prints;
|
}
|
|
private void ensureNoConflict(String tenantId, List<String> ids, String applicationId) throws DataException {
|
if (!mapper.selectConflicts(tenantId, ids, applicationId).isEmpty())
|
throw new DataException("文件已存在有效归档申请，请处理原申请，勿重复发起");
|
}
|
|
private List<String> resolveIds(List<String> values) throws DataException {
|
if (values == null || values.isEmpty()) throw new DataException("请至少选择一条文件副本");
|
Set<String> ids = new TreeSet<>();
|
for (String id : values) {
|
if (blank(id) || !ids.add(id.trim())) throw new DataException("文件副本ID不能为空或重复");
|
}
|
return new ArrayList<>(ids);
|
}
|
|
private boolean blank(String value) { return value == null || value.trim().isEmpty(); }
|
}
|
