open-source/qinglong
1
0
Fork 0
mirror of https://github.com/whyour/qinglong.git synced 2025-05-24 07:16:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

修复订阅任务创建逻辑

Browse Source
This commit is contained in:
whyour 2022-05-29 22:51:20 +08:00
parent 4f925b92d0
commit 026fc43695
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
back/loaders/initTask.ts
View File

@ -26,6 +26,11 @@ export default async () => {
// 运行所有订阅 // 运行所有订阅
const subs = await subscriptionService.list(); const subs = await subscriptionService.list();
for (const sub of subs) { for (const sub of subs) {
await subscriptionService.handleTask(sub, true, true, true); await subscriptionService.handleTask(
sub,
!sub.is_disabled,
true,
!sub.is_disabled,
);
} }
}; };

3
back/services/subscription.ts
View File

@ -286,7 +286,7 @@ export default class SubscriptionService {
public async update(payload: Subscription): Promise<Subscription> { public async update(payload: Subscription): Promise<Subscription> {
const newDoc = await this.updateDb(payload); const newDoc = await this.updateDb(payload);
await this.handleTask(newDoc); await this.handleTask(newDoc, !newDoc.is_disabled);
return newDoc; return newDoc;
} }
@ -360,7 +360,6 @@ export default class SubscriptionService {
this.logger.silly(error); this.logger.silly(error);
} }
} }
await this.handleTask(doc, false);
const command = this.formatCommand(doc); const command = this.formatCommand(doc);
const err = await this.killTask(command); const err = await this.killTask(command);
const absolutePath = await this.handleLogPath(doc.log_path as string); const absolutePath = await this.handleLogPath(doc.log_path as string);