[fix] Task group queue query all list error (#10237)

Add support query all task queue by not given specific groupId

close: #10102

dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/controller/TaskGroupController.java

@@ -297,6 +297,10 @@ public class TaskGroupController extends BaseController {
     /**
      * query task group queue list paging
      *
+     * @param groupId     ID for task group
+     * @param taskName    Task Name
+     * @param processName Process instance name
+     * @param status      Task queue status
      * @param loginUser   login user
      * @param pageNo      page number
      * @param pageSize    page size
@@ -304,7 +308,10 @@ public class TaskGroupController extends BaseController {
      */
     @ApiOperation(value = "queryTasksByGroupId", notes = "QUERY_ALL_TASKS_NOTES")
     @ApiImplicitParams({
-        @ApiImplicitParam(name = "groupId", value = "GROUP_ID", required = true, dataType = "Int", example = "1"),
+        @ApiImplicitParam(name = "groupId", value = "GROUP_ID", required = false, dataType = "Int", example = "1", defaultValue = "-1"),
+        @ApiImplicitParam(name = "taskInstanceName", value = "TASK_INSTANCE_NAME", required = false, dataType = "String", example = "taskName"),
+        @ApiImplicitParam(name = "processInstanceName", value = "PROCESS_INSTANCE_NAME", required = false, dataType = "String", example = "processName"),
+        @ApiImplicitParam(name = "status", value = "STATUS", required = false, dataType = "Int", example = "1"),
         @ApiImplicitParam(name = "pageNo", value = "PAGE_NO", required = true, dataType = "Int", example = "1"),
         @ApiImplicitParam(name = "pageSize", value = "PAGE_SIZE", required = true, dataType = "Int", example = "20")
     })
@@ -313,7 +320,7 @@ public class TaskGroupController extends BaseController {
     @ApiException(QUERY_TASK_GROUP_QUEUE_LIST_ERROR)
     @AccessLogAnnotation(ignoreRequestArgs = "loginUser")
     public Result queryTasksByGroupId(@ApiIgnore @RequestAttribute(value = Constants.SESSION_USER) User loginUser,
-                                      @RequestParam("groupId") Integer groupId,
+                                      @RequestParam(value = "groupId", required = false, defaultValue = "-1") Integer groupId,
                                       @RequestParam(value = "taskInstanceName",required = false) String taskName,
                                       @RequestParam(value = "processInstanceName",required = false) String processName,
                                       @RequestParam(value = "status",required = false) Integer status,

dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/TaskGroupQueueService.java

@@ -30,6 +30,9 @@ public interface TaskGroupQueueService {
      * query tasks in task group queue by group id
      * @param loginUser   login user
      * @param groupId     group id
+     * @param taskName    Task Name
+     * @param processName Process instance name
+     * @param status      Task queue status
      * @param pageNo      page no
      * @param pageSize    page size
 

dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskGroupQueueMapper.xml

@@ -134,7 +134,10 @@
         left join t_ds_process_definition p_f on process.process_definition_code = p_f.code
         and process.process_definition_version = p_f.version
         join t_ds_project as p on p_f.project_code = p.code
-        where queue.group_id = #{groupId}
+        <where>
+            <if test="groupId != null and groupId != -1">
+                queue.group_id = #{groupId}
+            </if>
             <if test="taskName != null and taskName != ''">
                 and task_name like concat('%', #{taskName}, '%')
             </if>
@@ -150,6 +153,7 @@
                     #{i.code}
                 </foreach>
             </if>
+        </where>
         order by queue.update_time desc
     </select>