feat(flow): 添加投诉处理驳回功能

- 在ITsComplaintAcceptService接口中新增opinionReject和feedbackReject方法
- 在TsComplaintAcceptController控制器中添加意见驳回和反馈驳回的REST端点
- 实现TsComplaintAcceptServiceImpl中的驳回业务逻辑，包括状态更新和标记设置
- 为TsComplaintTask和TsPlanExecuteRel实体类添加rejectMark字段
- 更新相关BO、VO类和XML映射文件以支持驳回标记字段
- 实现驳回时对当前记录和其他关联记录的状态更新机制

klp-flow/src/main/java/com/klp/flow/service/ITsComplaintAcceptService.java

@@ -56,4 +56,14 @@ public interface ITsComplaintAcceptService {
      * 反馈下发：修改flow_status=4，按传入部门创建执行反馈记录
      */
     Boolean feedbackDispatch(Long acceptId, List<Long> deptIds);
+
+    /**
+     * 意见驳回：taskStatus→1、rejectMark→1，主表flowStatus→1，其他task的rejectMark→2
+     */
+    Boolean opinionReject(Long taskId, String reason);
+
+    /**
+     * 反馈驳回：executeStatus→1、rejectMark→1，主表flowStatus→3，其他rel的rejectMark→2
+     */
+    Boolean feedbackReject(Long relId, String reason);
 }

klp-flow/src/main/java/com/klp/flow/service/impl/TsComplaintAcceptServiceImpl.java

@@ -184,6 +184,82 @@ public class TsComplaintAcceptServiceImpl implements ITsComplaintAcceptService {
         return true;
     }
 
+    /**
+     * 意见驳回
+     * 当前task：taskStatus→1（已审核）、rejectMark→1（本部门驳回）
+     * 主表：flowStatus→1（待审核）
+     * 其他task：若rejectMark!=1则→2（存在部门驳回）
+     */
+    @Override
+    public Boolean opinionReject(Long taskId, String reason) {
+        if (taskId == null) {
+            return false;
+        }
+        TsComplaintTask currentTask = tsComplaintTaskMapper.selectById(taskId);
+        if (currentTask == null) {
+            return false;
+        }
+        Long acceptId = currentTask.getAcceptId();
+        // 1. 更新当前task：taskStatus=1, rejectMark=1
+        LambdaUpdateWrapper<TsComplaintTask> taskUw = Wrappers.lambdaUpdate();
+        taskUw.eq(TsComplaintTask::getTaskId, taskId)
+            .set(TsComplaintTask::getTaskStatus, 1L)
+            .set(TsComplaintTask::getRejectMark, 1L)
+            .set(TsComplaintTask::getDeptOpinion, reason);
+        tsComplaintTaskMapper.update(null, taskUw);
+        // 2. 主表flowStatus→1（待审核）
+        LambdaUpdateWrapper<TsComplaintAccept> acceptUw = Wrappers.lambdaUpdate();
+        acceptUw.eq(TsComplaintAccept::getAcceptId, acceptId)
+            .set(TsComplaintAccept::getFlowStatus, 1L);
+        baseMapper.update(null, acceptUw);
+        // 3. 同acceptId下其他task：若rejectMark!=1则→2
+        LambdaUpdateWrapper<TsComplaintTask> otherUw = Wrappers.lambdaUpdate();
+        otherUw.eq(TsComplaintTask::getAcceptId, acceptId)
+            .ne(TsComplaintTask::getTaskId, taskId)
+            .ne(TsComplaintTask::getRejectMark, 1L)
+            .set(TsComplaintTask::getRejectMark, 2L);
+        tsComplaintTaskMapper.update(null, otherUw);
+        return true;
+    }
+
+    /**
+     * 反馈驳回
+     * 当前rel：executeStatus→1（已反馈）、rejectMark→1（本部门驳回）
+     * 主表：flowStatus→3（待总负责人汇总方案）
+     * 其他rel：若rejectMark!=1则→2（存在部门驳回）
+     */
+    @Override
+    public Boolean feedbackReject(Long relId, String reason) {
+        if (relId == null) {
+            return false;
+        }
+        TsPlanExecuteRel currentRel = tsPlanExecuteRelMapper.selectById(relId);
+        if (currentRel == null) {
+            return false;
+        }
+        Long acceptId = currentRel.getAcceptId();
+        // 1. 更新当前rel：executeStatus=1, rejectMark=1
+        LambdaUpdateWrapper<TsPlanExecuteRel> relUw = Wrappers.lambdaUpdate();
+        relUw.eq(TsPlanExecuteRel::getRelId, relId)
+            .set(TsPlanExecuteRel::getExecuteStatus, 1L)
+            .set(TsPlanExecuteRel::getRejectMark, 1L)
+            .set(TsPlanExecuteRel::getExecuteResult, reason);
+        tsPlanExecuteRelMapper.update(null, relUw);
+        // 2. 主表flowStatus→3（待总负责人汇总方案）
+        LambdaUpdateWrapper<TsComplaintAccept> acceptUw = Wrappers.lambdaUpdate();
+        acceptUw.eq(TsComplaintAccept::getAcceptId, acceptId)
+            .set(TsComplaintAccept::getFlowStatus, 3L);
+        baseMapper.update(null, acceptUw);
+        // 3. 同acceptId下其他rel：若rejectMark!=1则→2
+        LambdaUpdateWrapper<TsPlanExecuteRel> otherUw = Wrappers.lambdaUpdate();
+        otherUw.eq(TsPlanExecuteRel::getAcceptId, acceptId)
+            .ne(TsPlanExecuteRel::getRelId, relId)
+            .ne(TsPlanExecuteRel::getRejectMark, 1L)
+            .set(TsPlanExecuteRel::getRejectMark, 2L);
+        tsPlanExecuteRelMapper.update(null, otherUw);
+        return true;
+    }
+
     /**
      * 保存前的数据校验
      */

klp-flow/src/main/java/com/klp/flow/service/impl/TsComplaintTaskServiceImpl.java

@@ -114,6 +114,7 @@ public class TsComplaintTaskServiceImpl implements ITsComplaintTaskService {
         lqw.eq(bo.getFillUserId() != null, TsComplaintTask::getFillUserId, bo.getFillUserId());
         lqw.eq(bo.getFillTime() != null, TsComplaintTask::getFillTime, bo.getFillTime());
         lqw.eq(StringUtils.isNotBlank(bo.getFillFile()), TsComplaintTask::getFillFile, bo.getFillFile());
+        lqw.eq(bo.getRejectMark() != null, TsComplaintTask::getRejectMark, bo.getRejectMark());
         return lqw;
     }
 

klp-flow/src/main/java/com/klp/flow/service/impl/TsPlanExecuteRelServiceImpl.java

@@ -111,6 +111,7 @@ public class TsPlanExecuteRelServiceImpl implements ITsPlanExecuteRelService {
         lqw.eq(bo.getFeedbackUserId() != null, TsPlanExecuteRel::getFeedbackUserId, bo.getFeedbackUserId());
         lqw.eq(bo.getFeedbackTime() != null, TsPlanExecuteRel::getFeedbackTime, bo.getFeedbackTime());
         lqw.eq(StringUtils.isNotBlank(bo.getFeedbackFile()), TsPlanExecuteRel::getFeedbackFile, bo.getFeedbackFile());
+        lqw.eq(bo.getRejectMark() != null, TsPlanExecuteRel::getRejectMark, bo.getRejectMark());
         return lqw;
     }