解决催办指定节点的bug

src/main/java/com/lz/modules/flow/dao/FlowRecordMapper.java

@@ -109,4 +109,6 @@ public interface FlowRecordMapper extends BaseMapper<FlowRecord> {
     List<FlowRecord> selectFlowRecordByRecordIdsFlowProcess(@Param("recordIds") List<Long> recordIds, @Param("flowProcess") Long flowProcess);
 
 	List<FlowRecord> selectFlowRecordByRecordIdsStatus(@Param("recordIds") List<Long> recordIds, @Param("status") int status);
+
+	List<FlowRecord> selectFlowRecordByRecordIdsFlowProcessAndStatus(List<Long> recordIds, Long flowProcess, int status);
 }

src/main/java/com/lz/modules/flow/service/FlowRecordService.java

@@ -105,4 +105,6 @@ public interface FlowRecordService extends IService<FlowRecord> {
     List<FlowRecord> selectFlowRecordByRecordIdsFlowProcess(List<Long> recordIds, Long flowProcess);
 
 	List<FlowRecord> selectFlowRecordByRecordIdsStatus(List<Long> recordIds, int status);
+
+	List<FlowRecord> selectFlowRecordByRecordIdsFlowProcessAndStatus(List<Long> recordIds, Long flowProcess, int status);
 }

src/main/java/com/lz/modules/flow/service/impl/FlowRecordServiceImpl.java

@@ -276,4 +276,9 @@ public class FlowRecordServiceImpl extends ServiceImpl<FlowRecordMapper, FlowRec
 		return flowRecordMapper.selectFlowRecordByRecordIdsStatus(recordIds,status);
 	}
 
+	@Override
+	public List<FlowRecord> selectFlowRecordByRecordIdsFlowProcessAndStatus(List<Long> recordIds, Long flowProcess, int status){
+		return flowRecordMapper.selectFlowRecordByRecordIdsFlowProcessAndStatus(recordIds, flowProcess, status);
+	}
+
 }

src/main/java/com/lz/modules/performance/controller/AssessManagerController.java

@@ -301,7 +301,7 @@ public class AssessManagerController extends AbstractController{
                         log.info("催当前节点的人员，数量{}", flowRecords.size());
                     }else{
                         flowRecords =
-                                flowRecordService.selectFlowRecordByRecordIdsFlowProcess(recordIds, flowProcess);
+                                flowRecordService.selectFlowRecordByRecordIdsFlowProcessAndStatus(recordIds, flowProcess, 2);
                         log.info("催指定节点的人员，数量{}", flowRecords.size());
                     }
 

src/main/resources/mapper/flow/FlowRecordMapper.xml

@@ -384,5 +384,15 @@
 
     </select>
 
+    <select id="selectFlowRecordByRecordIdsFlowProcessAndStatus" resultType="com.lz.modules.flow.entity.FlowRecord">
+        select * from lz_flow_record  where  is_delete = 0
+        and record_id in
+        <foreach item="recordId" collection="recordIds"  open="(" separator="," close=")">
+            #{recordId}
+        </foreach>
+        and flow_process = #{flowProcess} and status=#{status}
+
+    </select>
+
 </mapper>