| package com.dy.pipIrrGlobal.daoIr; | 
|   | 
| import com.baomidou.mybatisplus.core.mapper.BaseMapper; | 
| import com.dy.pipIrrGlobal.pojoIr.IrIntakeOperate; | 
| import com.dy.pipIrrGlobal.voIr.VoIntakeResult; | 
| import com.dy.pipIrrGlobal.voIr.VoToTerminateIntakes; | 
| import org.apache.ibatis.annotations.Mapper; | 
| import org.apache.ibatis.annotations.Param; | 
|   | 
| import java.util.List; | 
|   | 
| /** | 
|  * @author ZhuBaoMin | 
|  * @date 2025-04-02 10:54 | 
|  * @LastEditTime 2025-04-02 10:54 | 
|  * @Description | 
|  */ | 
|   | 
| @Mapper | 
| public interface IrIntakeOperateMapper extends BaseMapper<IrIntakeOperate> { | 
|     int deleteByPrimaryKey(Long id); | 
|   | 
|     int insert(IrIntakeOperate record); | 
|   | 
|     int insertSelective(IrIntakeOperate record); | 
|   | 
|     IrIntakeOperate selectByPrimaryKey(Long id); | 
|   | 
|     int updateByPrimaryKeySelective(IrIntakeOperate record); | 
|   | 
|     int updateByPrimaryKey(IrIntakeOperate record); | 
|   | 
|     /** | 
|      * 根据命令ID更新取水口操作记录 | 
|      * @param commandId | 
|      * @param commandResult | 
|      * @return | 
|      */ | 
|     int updateByCommandId(@Param("commandId") Long commandId, @Param("commandResult") Byte commandResult, @Param("failureFactors") String failureFactors); | 
|   | 
|     /** | 
|      * 根据主键修改命令ID | 
|      * @param commandId | 
|      * @param id | 
|      * @return | 
|      */ | 
|     int updateCommandId(@Param("commandId") Long commandId, @Param("id") Long id); | 
|   | 
|     /** | 
|      * 根据计划ID获取待终止的取水口ID(已发布开发命令,无论是否成功) | 
|      * @param planId | 
|      * @return | 
|      */ | 
|     List<Long> getToTerminateIntakeIds(Long planId); | 
|   | 
|     /** | 
|      * 根据计划ID获取待终止的命令ID | 
|      * @param planId | 
|      * @return | 
|      */ | 
|     List<Long> getTerminateCommandIds(Long planId); | 
|   | 
|     /** | 
|      * 根据计划ID获取待终止的取水口列表(开阀成功的) | 
|      * @param planId | 
|      * @return | 
|      */ | 
|     List<VoToTerminateIntakes> getToTerminateIntakes(Long planId); | 
|   | 
|     /** | 
|      * 根据计划ID及管轮组ID获取取水口发布发布结果 | 
|      * @param planId | 
|      * @param groupId | 
|      * @return | 
|      */ | 
|     List<VoIntakeResult> getIntakeResult(@Param("planId") Long planId, @Param("groupId") Long groupId); | 
|   | 
|     /** | 
|      * 根据计划ID获取取水口命令发布失败数量,灌溉计划详情页使用 | 
|      * @param planId | 
|      * @return | 
|      */ | 
|     Integer getFailureCount(Long planId); | 
| } |