package jnpf.dmsService;
|
|
import jnpf.dmsEntity.storage.form.DmsApprovedRegistrationCallback;
|
import jnpf.dmsEntity.storage.approval.DmsApprovedBatch;
|
import jnpf.dmsEntity.wenjianbianhao.form.DmsFlowEventForm;
|
import jnpf.dmsMapper.DmsApprovedBatchMapper;
|
import jnpf.dmsPermission.DmsCurrentIdentity;
|
import jnpf.dmsService.impl.DmsWenjianBanbenServiceImpl;
|
import jnpf.exception.DataException;
|
import jnpf.flowable.WorkFlowApi;
|
import jnpf.flowable.entity.TaskEntity;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
|
/** Orchestration deliberately has no encompassing transaction. Approval, activation and projection are separate facts. */
|
@Slf4j
|
@Service
|
@RequiredArgsConstructor
|
public class DmsApprovedFlowService {
|
private final WorkFlowApi workflow;
|
private final DmsCurrentIdentity identity;
|
private final DmsApprovedFileAcceptanceService acceptance;
|
private final DmsApprovedFileRetryService retry;
|
private final DmsWenjianBanbenServiceImpl business;
|
private final DmsApprovedBatchMapper receipts;
|
private final DmsTemplateNotificationService notifications;
|
|
public void sync(DmsFlowEventForm form, String type) {
|
String taskId = form.getTaskId().trim(), flowId = form.getFlowId().trim();
|
TaskEntity task = workflow.getInfoSubmit(taskId);
|
if (task == null || !taskId.equals(task.getId()) || task.getStatus() == null
|
|| (!flowId.equals(task.getFlowId()) && !flowId.equals(task.getTemplateId())))
|
throw new DataException("未找到匹配的工作流任务");
|
if (!Integer.valueOf(2).equals(task.getStatus())) {
|
if ("xinzeng_shenhe".equals(type)) business.syncNewAuditFlow(flowId, taskId, task.getStatus(), form.getEventType());
|
else business.syncRevisionAuditFlow(flowId, taskId, task.getStatus(), form.getEventType());
|
return;
|
}
|
jnpf.base.UserInfo user = identity.requireUser();
|
if (task.getEndTime() == null) throw new DataException("批准任务缺少结束时间");
|
// Commit approval facts and both progress tables before entering the file service.
|
DmsApprovedBatch queued = acceptance.enqueue(identity.tenantId(user), flowId, taskId, type,
|
user.getUserId(), task.getEndTime());
|
if ("xiuding_shenhe".equals(type)) notifications.approved(queued.getTenantId(), taskId);
|
retry.process(queued);
|
}
|
|
/** Called through the existing trusted registration callback, outside the acceptance transaction. */
|
public DmsApprovedBatch completeRegistration(DmsApprovedRegistrationCallback form, String serviceId) {
|
DmsApprovedBatch accepted = acceptance.accept(form, serviceId);
|
activateAndApply(accepted);
|
DmsApprovedBatch result = receipts.find(accepted.getTenantId(), accepted.getTaskId(), accepted.getAuditType());
|
if (result == null) throw new DataException("登记确认后未找到批次回执");
|
result.setItems(receipts.items(result.getTenantId(), result.getId()));
|
return result;
|
}
|
|
public void activateAndApply(DmsApprovedBatch receipt) {
|
retry.advance(receipt);
|
}
|
}
|
