+
任务可以只执行，也可以在完成后把结果发送到指定渠道和目标。
+
{[
{ key: 'none', title: '仅执行任务', desc: '不额外推送到渠道' },
- { key: 'announce', title: '执行并公告', desc: '后续接入渠道选择与目标账号' },
+ { key: 'announce', title: '执行并发送', desc: '选择渠道账号与目标收件人' },
].map((item) => {
const active = deliveryMode === item.key;
return (
@@ -739,8 +1702,99 @@ function CronTaskDialog({ open, job, saving, onClose, onSave }: DialogProps) {
{deliveryMode === 'announce' ? (
-
- 当前先保留公告模式的视觉结构，渠道与接收人配置会在后续能力迁移时接入。
+
+
+
+ setDeliveryChannel(event.target.value)}
+ disabled={channelsLoading || availableChannelGroups.length === 0}
+ >
+ {availableChannelGroups.length > 0 ? (
+ availableChannelGroups.map((group) => (
+
+ ))
+ ) : (
+
+ )}
+
+
+
+
+
+ setSelectedDeliveryAccountId(event.target.value)}
+ disabled={channelsLoading || (selectedChannelGroup?.accounts.length ?? 0) === 0}
+ >
+ {(selectedChannelGroup?.accounts.length ?? 0) > 0 ? (
+ selectedChannelGroup?.accounts.map((account) => (
+
+ ))
+ ) : (
+
+ )}
+
+
+
+
+
+
0 ? targetListId : undefined}
+ value={deliveryTarget}
+ onChange={(event) => setDeliveryTarget(event.target.value)}
+ placeholder="例如：值班群、room-ops、https://example.com/webhook"
+ className="h-11 w-full rounded-xl border border-transparent bg-[#EDECE4] px-4 text-[14px] text-[#171717] outline-none transition-colors focus:border-[#3B6DE8] dark:bg-[#222225] dark:text-[#f3f4f6]"
+ />
+ {deliveryTargetOptions.length > 0 ? (
+
+ ) : null}
+
+ {deliveryTargetOptions.slice(0, 8).map((option) => (
+
+ ))}
+
+
+ {targetsLoading
+ ? '正在为当前渠道账号加载推荐目标...'
+ : deliveryTargetOptions.length > 0
+ ? '推荐目标已就绪，也可以继续手工输入群组、用户标识或 Webhook。'
+ : '暂未发现推荐目标，仍可手工输入群组、用户标识或 Webhook。'}
+
+
+ 预览：{deliveryPreview}
+ {selectedAccount ? 当前账号：{getDeliveryAccountDisplayName(selectedAccount)} : null}
+
+
+
+ {channelsError ?
: null}
+ {targetsError ?
: null}
+ {!channelsError && !channelsLoading && availableChannelGroups.length === 0 ? (
+
+ ) : null}
) : null}
@@ -789,7 +1843,7 @@ function CronTaskDialog({ open, job, saving, onClose, onSave }: DialogProps) {
onClick={() => {
void handleSubmit();
}}
- disabled={saving}
+ disabled={saving || !hasSelectableAgents}
>
{saving ?
:
}
{saving ? '保存中...' : job ? '保存修改' : '创建任务'}
@@ -801,6 +1855,12 @@ function CronTaskDialog({ open, job, saving, onClose, onSave }: DialogProps) {
}
export default function CronPage() {
+ const agents = useAgentsStore((state) => state.agents);
+ const agentsLoading = useAgentsStore((state) => state.loading);
+ const agentsError = useAgentsStore((state) => state.error);
+ const agentsWarning = useAgentsStore((state) => state.warning);
+ const defaultAgentId = useAgentsStore((state) => state.defaultAgentId);
+
const [jobs, setJobs] = useState
([]);
const [loading, setLoading] = useState(true);
const [error, setError] = useState(null);
@@ -810,18 +1870,28 @@ export default function CronPage() {
const [dialogSaving, setDialogSaving] = useState(false);
const [busyJobId, setBusyJobId] = useState(null);
const [busyAction, setBusyAction] = useState(null);
+ const [channelGroups, setChannelGroups] = useState([]);
+ const [channelsLoading, setChannelsLoading] = useState(false);
+ const [channelsError, setChannelsError] = useState(null);
const activeJobs = useMemo(() => jobs.filter((job) => job.enabled), [jobs]);
const pausedJobs = useMemo(() => jobs.filter((job) => !job.enabled), [jobs]);
const failedJobs = useMemo(() => jobs.filter((job) => job.lastRun && !job.lastRun.success), [jobs]);
+ const refreshing = loading || channelsLoading || agentsLoading;
+
+ const agentsById = useMemo(
+ () => new Map(agents.map((agent) => [normalizeAgentId(agent.id), agent])),
+ [agents],
+ );
async function loadJobs(): Promise {
setLoading(true);
setError(null);
try {
- const response = await hostApiFetch('/api/cron/jobs');
- setJobs(normalizeCronJobs(response));
+ const response = await hostApiFetch('/api/cron/jobs');
+ const normalizedJobs = normalizeCronJobs(response);
+ setJobs(normalizedJobs);
} catch (requestError) {
setJobs((currentJobs) => (currentJobs.length > 0 ? currentJobs : FALLBACK_CRON_JOBS));
setError(requestError instanceof Error ? requestError.message : String(requestError));
@@ -830,24 +1900,54 @@ export default function CronPage() {
}
}
+ async function loadDeliveryChannels(): Promise {
+ setChannelsLoading(true);
+ setChannelsError(null);
+
+ try {
+ const response = await hostApiFetch('/api/channels/accounts');
+ setChannelGroups(normalizeDeliveryChannelGroups(response));
+ } catch (requestError) {
+ setChannelsError(requestError instanceof Error ? requestError.message : String(requestError));
+ } finally {
+ setChannelsLoading(false);
+ }
+ }
+
useEffect(() => {
+ void agentsStore.init();
void loadJobs();
+ void loadDeliveryChannels();
}, []);
+ useEffect(() => {
+ return onGatewayEvent((event) => {
+ if (!isRuntimeChangedGatewayEvent(event)) return;
+ if (!runtimeEventHasTopic(event, 'channels', 'providers', 'agents', 'channel-targets')) return;
+ void Promise.allSettled([loadDeliveryChannels(), agentsStore.load()]);
+ });
+ }, []);
+
+ async function handleRefresh(): Promise {
+ setFeedback(null);
+ await Promise.allSettled([loadJobs(), loadDeliveryChannels(), agentsStore.load()]);
+ }
+
async function handleSave(input: CronJobCreateInput): Promise {
setDialogSaving(true);
try {
if (editingJob) {
try {
- const response = await hostApiFetch(`/api/cron/jobs/${encodeURIComponent(editingJob.id)}`, {
+ const response = await hostApiFetch(`/api/cron/jobs/${encodeURIComponent(editingJob.id)}`, {
method: 'PUT',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify(input),
});
+ const normalizedJob = normalizeCronJobResult(response);
setJobs((currentJobs) =>
- currentJobs.map((job) => (job.id === editingJob.id ? response : job)),
+ currentJobs.map((job) => (job.id === editingJob.id ? normalizedJob ?? buildLocalCronJob(input, editingJob) : job)),
);
} catch {
const fallback = buildLocalCronJob(input, editingJob);
@@ -857,13 +1957,14 @@ export default function CronPage() {
setFeedback({ tone: 'success', message: '定时任务已更新。' });
} else {
try {
- const response = await hostApiFetch('/api/cron/jobs', {
+ const response = await hostApiFetch('/api/cron/jobs', {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify(input),
});
- setJobs((currentJobs) => [...currentJobs, response]);
+ const normalizedJob = normalizeCronJobResult(response);
+ setJobs((currentJobs) => [...currentJobs, normalizedJob ?? buildLocalCronJob(input)]);
} catch {
setJobs((currentJobs) => [...currentJobs, buildLocalCronJob(input)]);
}
@@ -997,7 +2098,7 @@ export default function CronPage() {
定时任务
- 延续现有调度页的标题、统计、卡片列表和创建入口。
+ 为 Cron 任务绑定执行 Agent 与发送渠道，让调度、执行和投递信息在一个页面里闭环。
@@ -1006,10 +2107,10 @@ export default function CronPage() {
type="button"
className="flex h-9 shrink-0 items-center justify-center rounded-full border border-black/10 px-4 text-[13px] font-medium text-[#171717]/80 transition-colors hover:bg-black/5 hover:text-[#171717] dark:border-gray-700 dark:text-[#f3f4f6]/80 dark:hover:bg-white/5 dark:hover:text-[#f3f4f6]"
onClick={() => {
- void loadJobs();
+ void handleRefresh();
}}
>
-