import type { DmsPrintConfig } from '#/components/GlobalOfficeDocumentModal/types';
|
|
import { v4 as uuidv4 } from 'uuid';
|
|
import { defHttp } from '#/api/request';
|
|
export interface DmsPrintBatch {
|
id: string;
|
pages: number[];
|
items: number[];
|
state: 'READY' | 'SENDING' | 'SUBMITTED';
|
token?: string;
|
}
|
|
export interface DmsPrintAttempt {
|
id: string;
|
tenantId: string;
|
userId: string;
|
taskId: string;
|
fileVersionId: string;
|
copies: number;
|
state: 'OPEN' | 'CONFIRMED' | 'CLOSED';
|
batchesJson: string;
|
numbersJson: string;
|
}
|
|
const endpoint = '/api/dms/biz/wenjian/dayin/renwu/';
|
async function request<T>(path: string, data: unknown): Promise<T> {
|
const response = await defHttp.post<{ code: number; data: T; msg?: string }>({ url: endpoint + path, data }, { errorMessageMode: 'none' });
|
if (response.code !== 200) throw new Error(response.msg || '保存打印发送进度失败');
|
return response.data;
|
}
|
|
/** Reuse fixed task numbers; the online form controls barcode display text. */
|
export async function loadDmsPrintPreviewNumber(taskId: string, fileVersionId: string) {
|
return request<import('./dmsPrintBarcode').DmsFixedPrintNumber>('yulan-canshu', { taskId, fileVersionId });
|
}
|
|
export function prepareDmsPrintAttempt(config: DmsPrintConfig, copies: number) {
|
return request<DmsPrintAttempt>('zhunbei-fasong', {
|
requestId: uuidv4(),
|
taskId: config.printTaskId,
|
fileVersionId: config.fileVersionId,
|
copies,
|
});
|
}
|
|
export function attemptContext(attempt: DmsPrintAttempt) {
|
return { requestId: attempt.id, taskId: attempt.taskId, fileVersionId: attempt.fileVersionId, copies: attempt.copies };
|
}
|
|
export function updateDmsPrintAttempt(attempt: DmsPrintAttempt, action: string, data: Record<string, unknown> = {}) {
|
return request<DmsPrintAttempt>(action, { ...attemptContext(attempt), ...data });
|
}
|
|
export function attemptBatches(attempt: DmsPrintAttempt): DmsPrintBatch[] {
|
return JSON.parse(attempt.batchesJson);
|
}
|
|
export async function confirmDmsPrintAttempt(attempt: DmsPrintAttempt) {
|
await request('queren-fasong', { ...attemptContext(attempt), clientResult: 'SUBMITTED' });
|
}
|
|
export async function finishDmsPrintAttempt(attempt: DmsPrintAttempt) {
|
await confirmDmsPrintAttempt(attempt);
|
await request('jieshu-fasong', attemptContext(attempt));
|
}
|
|
function receiptKey(attempt: DmsPrintAttempt, batchId: string) {
|
return `dms-print-receipt:${encodeURIComponent(attempt.tenantId)}:${encodeURIComponent(attempt.userId)}:${attempt.id}:${batchId}`;
|
}
|
|
/** 只有实际成功回调才能写入此 outbox；按租户/账号隔离，恢复时仍由服务端核对令牌。 */
|
export async function recordDmsBatchSubmitted(attempt: DmsPrintAttempt, batch: DmsPrintBatch, token: string) {
|
const key = receiptKey(attempt, batch.id);
|
try {
|
localStorage.setItem(key, token);
|
} catch {
|
/* 服务端仍为权威；本地存储不可用时不能假定成功。 */
|
}
|
const saved = await updateDmsPrintAttempt(attempt, 'queren-pici', { batchId: batch.id, token });
|
try {
|
localStorage.removeItem(key);
|
} catch {
|
/* 重复回执由服务端幂等处理。 */
|
}
|
// 晚回传同样可推进正式确认，即使原页面等待已经超时。
|
if (attemptBatches(saved).every((item) => item.state === 'SUBMITTED')) await confirmDmsPrintAttempt(saved);
|
return saved;
|
}
|
|
export async function recoverDmsBatchReceipts(attempt: DmsPrintAttempt) {
|
let saved = attempt;
|
for (const batch of attemptBatches(attempt)) {
|
let token: null | string = null;
|
try {
|
token = localStorage.getItem(receiptKey(attempt, batch.id));
|
} catch {
|
/* 不具备本地证据时保持未知。 */
|
}
|
if (token) saved = await recordDmsBatchSubmitted(saved, batch, token);
|
}
|
return saved;
|
}
|
