@@ -2360,11 +2364,11 @@ export function ConfigPage(props: ConfigPageProps) {
+
+
+
+
);
case "about":
diff --git a/src/view/job-data/JobBrief.tsx b/src/view/job-data/JobBrief.tsx
index 0bc1b7c..c0f5789 100644
--- a/src/view/job-data/JobBrief.tsx
+++ b/src/view/job-data/JobBrief.tsx
@@ -1,5 +1,7 @@
import { useEffect, useState } from "react";
-import { Button, Empty, Skeleton, Tag, Typography } from "antd";
+import { Button, Empty, Popconfirm, Skeleton, Space, Tag, Typography, message } from "antd";
+import { invoke } from "@tauri-apps/api/core";
+import { commandErrorMessage, type CommandResult } from "../../types/command";
import {
EnvironmentOutlined,
FileTextOutlined,
@@ -43,13 +45,22 @@ function MetaItem({ label, value }: { label: string; value: React.ReactNode }) {
const JobBrief = ({
job,
analysis,
+ onDeliveryResolved,
}: {
job: JobDetail;
analysis?: InterviewJobAnalysis;
+ onDeliveryResolved?: (updated: JobDetail) => void;
}) => {
const [showRaw, setShowRaw] = useState(false);
const [parsed, setParsed] = useState
(null);
- const platform = job.platform === "liepin" ? "猎聘" : "BOSS 直聘";
+ const platform = job.platform === "51job" ? "前程无忧" : job.platform === "liepin" ? "猎聘" : "BOSS 直聘";
+ const resolveDelivery = async (delivered: boolean) => {
+ try {
+ const result = await invoke>("job51_resolve_delivery", { id: job.id, delivered });
+ if (!result.success || !result.data) { message.error(commandErrorMessage(result.error, "更新投递状态失败")); return; }
+ onDeliveryResolved?.(result.data);
+ } catch (error) { message.error(String(error)); }
+ };
useEffect(() => {
let stale = false;
@@ -80,7 +91,7 @@ const JobBrief = ({
{job.salary && {job.salary}
}
{platform}
- {job.is_send_resume ? 已投递 : 未投递 }
+ {job.resume_delivery_pending ? 投递待确认 : job.is_send_resume ? 已投递 : 未投递 }
{job.is_reply && 已回复 }
{analysis && !analysis.parse_error && (
@@ -91,6 +102,12 @@ const JobBrief = ({
+ {job.platform === "51job" && job.resume_delivery_pending &&
+ 此前提交结果未确认，自动重投已暂停。
+ void resolveDelivery(true)}>确认已投递
+ void resolveDelivery(false)}>允许重试
+ }
+
{/* ── 时间线与来源，都是表格里看不全的字段 ── */}
{job.company_name}
@@ -346,13 +349,17 @@ const JobDataPage = ({ aiConfigured, llmConfigured, onConfigureAi, focusJobId, o
const [selectedJobIds, setSelectedJobIds] = useState
([]);
const [batchAnalyzing, setBatchAnalyzing] = useState(false);
const [messageApi, contextHolder] = message.useMessage();
+ const jobsRequest = useRef(0);
+ const analysesRequest = useRef(0);
- const loadJobs = useCallback(async () => {
- setLoading(true);
+ const loadJobs = useCallback(async (showLoading = true) => {
+ const request = ++jobsRequest.current;
+ if (showLoading) setLoading(true);
try {
const result = await invoke>(
"job_list_with_status",
);
+ if (request !== jobsRequest.current) return;
if (!result.success || result.data === null) {
messageApi.error(
commandErrorMessage(result.error, "加载岗位数据失败"),
@@ -363,28 +370,36 @@ const JobDataPage = ({ aiConfigured, llmConfigured, onConfigureAi, focusJobId, o
b.created_at.localeCompare(a.created_at),
);
setJobs(sorted);
+ setCurrentJob(current => current ? sorted.find(job => job.id === current.id) ?? current : null);
} catch (error: unknown) {
+ if (request !== jobsRequest.current) return;
messageApi.error(
error instanceof Error ? error.message : "加载岗位数据失败",
);
} finally {
- setLoading(false);
+ if (request === jobsRequest.current) setLoading(false);
}
}, [messageApi]);
/// 分析结果只是列表上的附加信息，取不到不该影响岗位管理本身
const loadAnalyses = useCallback(async () => {
+ const request = ++analysesRequest.current;
try {
const result = await invoke>("analysis_list");
+ if (request !== analysesRequest.current) return;
if (!result.success || !result.data) return;
setAnalyses(
Object.fromEntries(result.data.map((item) => [item.job_id, item])),
);
} catch {
- setAnalyses({});
+ if (request === analysesRequest.current) setAnalyses({});
}
}, []);
+ useJobDataRefresh(useCallback(async () => {
+ await Promise.all([loadJobs(false), loadAnalyses()]);
+ }, [loadAnalyses, loadJobs]));
+
useEffect(() => {
void loadJobs();
void loadAnalyses();
@@ -531,7 +546,7 @@ const JobDataPage = ({ aiConfigured, llmConfigured, onConfigureAi, focusJobId, o
key: "platform",
width: 90,
render: (_: unknown, record: JobListItem) =>
- getJobPlatform(record) === "liepin" ? (
+ getJobPlatform(record) === "51job" ? 51job : getJobPlatform(record) === "liepin" ? (
猎聘
) : (
BOSS
@@ -573,7 +588,7 @@ const JobDataPage = ({ aiConfigured, llmConfigured, onConfigureAi, focusJobId, o
{
title: "操作",
key: "action",
- width: 350,
+ width: 440,
fixed: "right",
render: (_: unknown, record: JobListItem) => (
@@ -615,6 +630,14 @@ const JobDataPage = ({ aiConfigured, llmConfigured, onConfigureAi, focusJobId, o
删除
+ >("job_open_source", { id: record.id })
+ .then(result => { if (!result.success) messageApi.error(commandErrorMessage(result.error, "打开原始JD失败")); })
+ .catch(error => messageApi.error(String(error)))}>
+ 原始 JD
+
),
},
@@ -754,7 +777,7 @@ const JobDataPage = ({ aiConfigured, llmConfigured, onConfigureAi, focusJobId, o
key: "brief",
label: "岗位详情",
children: (
- { setCurrentJob(updated); void loadJobs(); }} />
),
},
{
diff --git a/src/view/job-data/job-brief.test.tsx b/src/view/job-data/job-brief.test.tsx
index a8c5292..533e6e6 100644
--- a/src/view/job-data/job-brief.test.tsx
+++ b/src/view/job-data/job-brief.test.tsx
@@ -2,7 +2,7 @@ import { afterEach, describe, expect, it, vi } from "vitest";
vi.mock("@tauri-apps/api/core", () => ({ invoke: vi.fn() }));
-import { cleanup, render, screen, waitFor } from "@testing-library/react";
+import { cleanup, fireEvent, render, screen, waitFor } from "@testing-library/react";
import { invoke } from "@tauri-apps/api/core";
import JobBrief from "./JobBrief";
import type { JobDetail, ParsedJobDescription } from "../../types/job-detail";
@@ -43,6 +43,21 @@ const mockDescription = (value: ParsedJobDescription) =>
vi.mocked(invoke).mockResolvedValue({ success: true, data: value, error: null });
describe("JobBrief", () => {
+ it("51job提交待确认时仍可明确允许重试，即使提醒已被清空", async () => {
+ const pending = { ...baseJob, id: "51job:173034896", platform: "51job" as const, resume_delivery_pending: true };
+ const onDeliveryResolved = vi.fn();
+ vi.mocked(invoke).mockImplementation(async command => command === "job51_resolve_delivery"
+ ? { success: true, data: { ...pending, resume_delivery_pending: false }, error: null }
+ : { success: true, data: described(), error: null });
+ render((null);
const [loading, setLoading] = useState(true);
const [error, setError] = useState("");
+ const reload = useRef<(() => Promise) | null>(null);
+ useJobDataRefresh(useCallback(async () => { await reload.current?.(); }, []));
useEffect(() => {
let active = true;
setLoading(true);
setError("");
- invoke>("job_search_overview", { days })
+ let latestRequest = 0;
+ const fetchOverview = () => {
+ const request = ++latestRequest;
+ return invoke>("job_search_overview", { days })
.then((result) => {
- if (!active) return;
+ if (!active || request !== latestRequest) return;
if (!result.success || !result.data) {
throw new Error(result.error?.message || "加载求职数据失败");
}
setOverview(result.data);
+ setError("");
})
.catch((reason: unknown) => {
- if (active) setError(reason instanceof Error ? reason.message : "加载求职数据失败");
+ if (active && request === latestRequest) setError(reason instanceof Error ? reason.message : "加载求职数据失败");
})
.finally(() => {
- if (active) setLoading(false);
+ if (active && request === latestRequest) setLoading(false);
});
+ };
+ reload.current = fetchOverview;
+ void fetchOverview();
return () => {
active = false;
+ reload.current = null;
};
}, [days]);
diff --git a/src/view/job-overview/job-overview.test.tsx b/src/view/job-overview/job-overview.test.tsx
new file mode 100644
index 0000000..f78a945
--- /dev/null
+++ b/src/view/job-overview/job-overview.test.tsx
@@ -0,0 +1,43 @@
+import { act, render, screen, cleanup, waitFor } from "@testing-library/react";
+import { afterEach, beforeEach, expect, it, vi } from "vitest";
+vi.mock("@tauri-apps/api/core", () => ({ invoke: vi.fn() }));
+vi.mock("../../hooks/useJobDataRefresh", () => ({ useJobDataRefresh: vi.fn() }));
+import { invoke } from "@tauri-apps/api/core";
+import { useJobDataRefresh } from "../../hooks/useJobDataRefresh";
+import JobOverviewPage from "./index";
+
+let refresh: () => Promise;
+const overview = (count: number) => ({
+ success: true, data: {
+ days: 30, high_match_score: 80,
+ metrics: { total_jobs: count, communicated_jobs: 0, replied_jobs: 0, reply_rate: 0, resume_sent_jobs: count, high_match_jobs: 0, analyzed_jobs: 0 },
+ previous_metrics: { total_jobs: 0, communicated_jobs: 0, replied_jobs: 0, reply_rate: 0, resume_sent_jobs: 0, high_match_jobs: 0, analyzed_jobs: 0 },
+ daily_activity: [], source_distribution: [], active_conversations: [],
+ },
+});
+beforeEach(() => {
+ vi.clearAllMocks();
+ vi.mocked(useJobDataRefresh).mockImplementation(callback => { refresh = callback; });
+});
+afterEach(cleanup);
+
+it("recovers the rendered overview after a temporary refresh failure", async () => {
+ vi.mocked(invoke).mockResolvedValueOnce(overview(3)).mockRejectedValueOnce(new Error("temporary refresh failure")).mockResolvedValueOnce(overview(4));
+ render( = {
+ "51job": { label: "前程无忧", shortLabel: "51job", accent: "#ff6000", description: "按岗位匹配度和投递置信度直接申请，支持单轮和周期投递。" },
boss: {
label: "BOSS 直聘",
shortLabel: "BOSS",
@@ -219,7 +221,7 @@ const TASK_STATE_ORDER: Record = {
succeeded: 2,
};
-const PLATFORM_ORDER: PlatformKind[] = ["boss", "liepin"];
+const PLATFORM_ORDER: PlatformKind[] = ["boss", "liepin", "51job"];
export function sortTasksForQueue(tasks: JobTaskInfo[]): JobTaskInfo[] {
return [...tasks].sort((left, right) => {
@@ -319,12 +321,13 @@ const WorkspacePage = ({
>({
boss: { phase: "idle", result: null, message: "" },
liepin: { phase: "idle", result: null, message: "" },
+ "51job": { phase: "idle", result: null, message: "" },
});
const [taskOverview, setTaskOverview] = useState({
tasks: [],
running_count: 0,
queued_count: 0,
- max_parallel_tasks: 2,
+ max_parallel_tasks: DEFAULT_MAX_PARALLEL_TASKS,
});
const [logContent, setLogContent] = useState("");
const [startModalOpen, setStartModalOpen] = useState(false);
@@ -878,6 +881,7 @@ const WorkspacePage = ({
{ value: "all", label: "全部" },
{ value: "boss", label: "BOSS" },
{ value: "liepin", label: "猎聘" },
+ { value: "51job", label: "前程无忧" },
]}
onChange={setQueueFilter}
/>
@@ -1004,7 +1008,7 @@ const WorkspacePage = ({
style={{ width: "100%", paddingTop: 4 }}
>
{FLOW_MODE_OPTIONS.filter(
- (option) => modalPlatform === "boss" || option.key !== "sync_chat_history",
+ (option) => modalPlatform === "51job" ? ["job_hunting", "periodic_job_hunting"].includes(option.key) : modalPlatform === "boss" || option.key !== "sync_chat_history",
).map((option) => {
const selected = selectedMode === option.key;
return (
@@ -1026,7 +1030,7 @@ const WorkspacePage = ({
{option.label}
- {option.description}
+ {modalPlatform === "51job" && option.key === "periodic_job_hunting" ? "按设定间隔直接投递，等待期间不执行聊天。" : option.description}
);
diff --git a/src/view/workspace/manual-review-drawer.tsx b/src/view/workspace/manual-review-drawer.tsx
index 37e64d7..24265c3 100644
--- a/src/view/workspace/manual-review-drawer.tsx
+++ b/src/view/workspace/manual-review-drawer.tsx
@@ -1,5 +1,5 @@
import { useCallback, useEffect, useState } from "react";
-import { Button, Drawer, Empty, List, Modal, Space, Tag, Tooltip, Typography, message } from "antd";
+import { Button, Drawer, Empty, List, Modal, Popconfirm, Space, Tag, Tooltip, Typography, message } from "antd";
import { ExclamationCircleOutlined } from "@ant-design/icons";
import { invoke } from "@tauri-apps/api/core";
import type { CommandResult } from "../../types/command";
@@ -99,11 +99,18 @@ export default function ManualReviewDrawer({
onClear,
onOpenConversation,
}: Props) {
+ const resolveDelivery = async (record: ManualReviewRecord, delivered: boolean) => {
+ try {
+ const result = await invoke