From 244acd929816308a9e48a78bbee8ced9317905ee Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Tue, 2 Feb 2021 20:52:59 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BE=9B=E6=89=B9=E9=87=8F=E5=88=A0?= =?UTF-8?q?=E9=99=A4=E5=90=8C=E6=AD=A5=E4=BB=BB=E5=8A=A1=E7=9A=84API?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/rpc/services/service_node_task.go | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/internal/rpc/services/service_node_task.go b/internal/rpc/services/service_node_task.go index 57535e72..becc8cb5 100644 --- a/internal/rpc/services/service_node_task.go +++ b/internal/rpc/services/service_node_task.go @@ -170,6 +170,24 @@ func (this *NodeTaskService) DeleteNodeTask(ctx context.Context, req *pb.DeleteN return this.Success() } +// 批量删除任务 +func (this *NodeTaskService) DeleteNodeTasks(ctx context.Context, req *pb.DeleteNodeTasksRequest) (*pb.RPCSuccess, error) { + _, err := this.ValidateAdmin(ctx, 0) + if err != nil { + return nil, err + } + + var tx = this.NullTx() + for _, taskId := range req.NodeTaskIds { + err = models.SharedNodeTaskDAO.DeleteNodeTask(tx, taskId) + if err != nil { + return nil, err + } + } + + return this.Success() +} + // 计算正在执行的任务数量 func (this *NodeTaskService) CountDoingNodeTasks(ctx context.Context, req *pb.CountDoingNodeTasksRequest) (*pb.RPCCountResponse, error) { _, err := this.ValidateAdmin(ctx, 0)