巡检模块-审批流程-批量审批

airport-admin/src/main/java/com/sundot/airport/web/controller/check/CheckCorrectionController.java

@@ -5,6 +5,7 @@ import java.util.List;
 import javax.servlet.http.HttpServletResponse;
 
 import cn.hutool.core.collection.CollUtil;
+import com.sundot.airport.common.core.domain.ApprovalWorkflowBatchDto;
 import com.sundot.airport.common.core.domain.DataPermissionResult;
 import com.sundot.airport.web.core.utils.DataPermissionUtils;
 import org.springframework.security.access.prepost.PreAuthorize;
@@ -172,4 +173,24 @@ public class CheckCorrectionController extends BaseController {
     public AjaxResult rejectTask(@RequestBody CheckCorrection checkCorrection) {
         return success(checkCorrectionService.rejectTask(checkCorrection));
     }
+
+    /**
+     * 批量审批任务（同意）
+     */
+    @PreAuthorize("@ss.hasPermi('check:checkCorrection:edit')")
+    @Log(title = "批量审批任务（同意）", businessType = BusinessType.UPDATE)
+    @PostMapping("/approveTaskBatch")
+    public AjaxResult approveTaskBatch(@RequestBody ApprovalWorkflowBatchDto approvalWorkflowBatchDto) {
+        return success(checkCorrectionService.approveTaskBatch(approvalWorkflowBatchDto));
+    }
+
+    /**
+     * 批量审批任务（驳回）
+     */
+    @PreAuthorize("@ss.hasPermi('check:checkCorrection:edit')")
+    @Log(title = "批量审批任务（驳回）", businessType = BusinessType.UPDATE)
+    @PostMapping("/rejectTaskBatch")
+    public AjaxResult rejectTaskBatch(@RequestBody ApprovalWorkflowBatchDto approvalWorkflowBatchDto) {
+        return success(checkCorrectionService.rejectTaskBatch(approvalWorkflowBatchDto));
+    }
 }

airport-check/src/main/java/com/sundot/airport/check/service/ICheckCorrectionService.java

@@ -4,6 +4,7 @@ import java.util.List;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sundot.airport.check.domain.CheckCorrection;
+import com.sundot.airport.common.core.domain.ApprovalWorkflowBatchDto;
 
 /**
  * 问题整改Service接口
@@ -75,4 +76,20 @@ public interface ICheckCorrectionService extends IService<CheckCorrection> {
      * @return 结果
      */
     public int rejectTask(CheckCorrection checkCorrection);
+
+    /**
+     * 批量审批任务（同意）
+     *
+     * @param approvalWorkflowBatchDto 批量审批参数
+     * @return 结果
+     */
+    public int approveTaskBatch(ApprovalWorkflowBatchDto approvalWorkflowBatchDto);
+
+    /**
+     * 批量审批任务（驳回）
+     *
+     * @param approvalWorkflowBatchDto 批量审批参数
+     * @return 结果
+     */
+    public int rejectTaskBatch(ApprovalWorkflowBatchDto approvalWorkflowBatchDto);
 }

airport-check/src/main/java/com/sundot/airport/check/service/impl/CheckCorrectionServiceImpl.java

@@ -13,6 +13,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sundot.airport.check.domain.CheckProjectItem;
 import com.sundot.airport.check.domain.CheckUser;
+import com.sundot.airport.common.core.domain.ApprovalWorkflowBatchDto;
 import com.sundot.airport.check.service.ICheckProjectItemService;
 import com.sundot.airport.check.service.ICheckUserService;
 import com.sundot.airport.common.constant.Constants;
@@ -29,6 +30,9 @@ import com.sundot.airport.common.utils.DateUtils;
 import com.sundot.airport.common.utils.SecurityUtils;
 import com.sundot.airport.common.utils.StringUtils;
 import com.sundot.airport.system.domain.approval.ApprovalInstance;
+import com.sundot.airport.system.domain.approval.ApprovalTask;
+import com.sundot.airport.system.mapper.approval.ApprovalInstanceMapper;
+import com.sundot.airport.system.mapper.approval.ApprovalTaskMapper;
 import com.sundot.airport.system.service.approval.IApprovalEngineService;
 import com.sundot.airport.system.service.approval.ICheckApprovalService;
 import lombok.SneakyThrows;
@@ -63,6 +67,10 @@ public class CheckCorrectionServiceImpl extends ServiceImpl<CheckCorrectionMappe
     private ICheckApprovalService checkApprovalService;
     @Autowired
     private IApprovalEngineService approvalEngineService;
+    @Autowired
+    private ApprovalTaskMapper taskMapper;
+    @Autowired
+    private ApprovalInstanceMapper instanceMapper;
 
     /**
      * 查询问题整改
@@ -407,4 +415,48 @@ public class CheckCorrectionServiceImpl extends ServiceImpl<CheckCorrectionMappe
             throw new ServiceException("被检查级别数据异常");
         }
     }
+
+    /**
+     * 批量审批任务（同意）
+     *
+     * @param approvalWorkflowBatchDto 批量审批参数
+     * @return 结果
+     */
+    @SneakyThrows
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public int approveTaskBatch(ApprovalWorkflowBatchDto approvalWorkflowBatchDto) {
+        approvalWorkflowBatchDto.getTaskIdList().forEach(taskId -> {
+            ApprovalTask task = taskMapper.selectApprovalTaskById(taskId);
+            ApprovalInstance instance = instanceMapper.selectApprovalInstanceById(task.getInstanceId());
+            CheckCorrection checkCorrection = selectCheckCorrectionById(instance.getBusinessId());
+            Map<String, Object> formData = BeanUtil.beanToMap(checkCorrection);
+            try {
+                checkApprovalService.approveTask(taskId, approvalWorkflowBatchDto.getComment(), formData, SecurityUtils.getLoginUser().getUserId(), SecurityUtils.getLoginUser().getUsername());
+            } catch (Exception e) {
+                throw new ServiceException("审批失败");
+            }
+        });
+        return 1;
+    }
+
+    /**
+     * 批量审批任务（驳回）
+     *
+     * @param approvalWorkflowBatchDto 批量审批参数
+     * @return 结果
+     */
+    @SneakyThrows
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public int rejectTaskBatch(ApprovalWorkflowBatchDto approvalWorkflowBatchDto) {
+        approvalWorkflowBatchDto.getTaskIdList().forEach(taskId -> {
+            try {
+                checkApprovalService.rejectTask(taskId, approvalWorkflowBatchDto.getComment(), SecurityUtils.getLoginUser().getUserId(), SecurityUtils.getLoginUser().getUsername());
+            } catch (Exception e) {
+                throw new ServiceException("审批失败");
+            }
+        });
+        return 1;
+    }
 }

airport-common/src/main/java/com/sundot/airport/common/core/domain/ApprovalWorkflowBatchDto.java

@@ -0,0 +1,26 @@
+package com.sundot.airport.common.core.domain;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 批量审批参数
+ *
+ * @author ruoyi
+ * @date 2025-09-07
+ */
+@Data
+public class ApprovalWorkflowBatchDto {
+
+    /**
+     * 任务ID列表
+     */
+    private List<Long> taskIdList;
+
+    /**
+     * 审批意见
+     */
+    private String comment;
+
+}