package jnpf.dmsService.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import jnpf.dmsEntity.DmsDanganCundangShenqingEntity;
|
import jnpf.dmsEntity.DmsDanganCundangShenqingGuidangEntity;
|
import jnpf.dmsEntity.recordprint.DmsJiluDayinLiushuiEntity;
|
import jnpf.dmsMapper.DmsDanganCundangShenqingGuidangMapper;
|
import jnpf.dmsMapper.DmsDanganCundangShenqingMapper;
|
import jnpf.dmsMapper.DmsJiluDayinLiushuiMapper;
|
import jnpf.dmsMapper.DmsWenjianFenfaMapper;
|
import jnpf.dmsService.DmsDanganCundangShenqingTongguoService;
|
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;
|
|
@Service
|
@RequiredArgsConstructor
|
public class DmsDanganCundangShenqingTongguoServiceImpl
|
implements DmsDanganCundangShenqingTongguoService {
|
|
private final DmsDanganCundangShenqingMapper shenqingMapper;
|
private final DmsDanganCundangShenqingGuidangMapper guidangMapper;
|
private final DmsJiluDayinLiushuiMapper jiluLiushuiMapper;
|
private final DmsWenjianFenfaMapper wenjianFenfaMapper;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void tongguo(String flowId, String taskId) throws DataException {
|
DmsDanganCundangShenqingEntity shenqing = findApplication(
|
requireValue(flowId, "流程ID(flow_id)"), requireValue(taskId, "流程任务ID(task_id)"));
|
List<DmsDanganCundangShenqingGuidangEntity> details = findGuidangDetails(shenqing.getId());
|
Set<String> jiluLiushuiIds = new LinkedHashSet<>();
|
Set<String> wenjianLiushuiIds = new LinkedHashSet<>();
|
for (DmsDanganCundangShenqingGuidangEntity detail : details) {
|
addIfPresent(jiluLiushuiIds, detail.getJiluLiushuiId());
|
addIfPresent(wenjianLiushuiIds, detail.getWenjianLiushuiId());
|
}
|
markJiluLiushuiGuidang(jiluLiushuiIds);
|
markWenjianLiushuiGuidang(wenjianLiushuiIds);
|
}
|
|
private DmsDanganCundangShenqingEntity findApplication(String flowId, String taskId) throws DataException {
|
LambdaQueryWrapper<DmsDanganCundangShenqingEntity> query = new LambdaQueryWrapper<>();
|
query.eq(DmsDanganCundangShenqingEntity::getFlowId, flowId)
|
.eq(DmsDanganCundangShenqingEntity::getFlowTaskId, taskId)
|
.isNull(DmsDanganCundangShenqingEntity::getDeleteMark);
|
List<DmsDanganCundangShenqingEntity> applications = shenqingMapper.selectList(query);
|
if (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<DmsDanganCundangShenqingGuidangEntity> findGuidangDetails(String shenqingId) {
|
LambdaQueryWrapper<DmsDanganCundangShenqingGuidangEntity> query = new LambdaQueryWrapper<>();
|
query.eq(DmsDanganCundangShenqingGuidangEntity::getForeignId, shenqingId)
|
.isNull(DmsDanganCundangShenqingGuidangEntity::getDeleteMark);
|
return guidangMapper.selectList(query);
|
}
|
|
private void markJiluLiushuiGuidang(Set<String> ids) {
|
if (ids.isEmpty()) {
|
return;
|
}
|
LambdaUpdateWrapper<DmsJiluDayinLiushuiEntity> update = new LambdaUpdateWrapper<>();
|
update.in(DmsJiluDayinLiushuiEntity::getId, ids)
|
.isNull(DmsJiluDayinLiushuiEntity::getDeleteMark)
|
.set(DmsJiluDayinLiushuiEntity::getIsGuidang, 1);
|
jiluLiushuiMapper.update(null, update);
|
}
|
|
private void markWenjianLiushuiGuidang(Set<String> serialNumbers) {
|
if (!serialNumbers.isEmpty()) {
|
wenjianFenfaMapper.archivePrintRecords(new ArrayList<>(serialNumbers));
|
}
|
}
|
|
private void addIfPresent(Set<String> values, String value) {
|
String resolved = trimToEmpty(value);
|
if (!resolved.isEmpty()) {
|
values.add(resolved);
|
}
|
}
|
|
private String requireValue(String value, String fieldName) throws DataException {
|
String resolved = trimToEmpty(value);
|
if (resolved.isEmpty()) {
|
throw new DataException(fieldName + "不能为空");
|
}
|
return resolved;
|
}
|
|
private String trimToEmpty(String value) {
|
return value == null ? "" : value.trim();
|
}
|
}
|
