|  |  | 
 |  |  |         return prIntakeMapper.getSupperByVillageId(vaId); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 保存修改实体 | 
 |  |  |      * | 
 |  |  |      * @param po 实体 | 
 |  |  |      * @return 数量 | 
 |  |  |      */ | 
 |  |  |  | 
 |  |  |     public int update(PrIntake po) { | 
 |  |  | //        if (po.getTownId() == null || po.getTownId() == 0) { | 
 |  |  | //            Long townId = getSupperByVillageId(po.getVillageId()); | 
 |  |  | 
 |  |  | //        return this.prIntakeMapper.updateByPrimaryKey(po); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 根据指定条件获取取水口记录 | 
 |  |  |      * | 
 |  |  |      * @param queryVo 查询视图 | 
 |  |  |      * @return 取水口记录列表 | 
 |  |  |      */ | 
 |  |  |     public QueryResultVo<List<VoIntake>> getIntakes(QueryVo queryVo) { | 
 |  |  |         Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo); | 
 |  |  |         Long itemTotal = prIntakeMapper.getRecordCount(params); | 
 |  |  | 
 |  |  |         return rsVo; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 根据指定条件导出取水口列表 | 
 |  |  |      * | 
 |  |  |      * @param queryVo | 
 |  |  |      * @return | 
 |  |  |      */ | 
 |  |  |     public List<VoIntake> exportIntakes(QueryVo queryVo) { | 
 |  |  |         Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo); | 
 |  |  |         List<VoIntake> rsVo = prIntakeMapper.getIntakes(params); | 
 |  |  |         return rsVo; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 得到所有取水口 | 
 |  |  |      * | 
 |  |  |      * @return 所有取水口集合 | 
 |  |  |      */ | 
 |  |  |     public QueryResultVo<List<VoAllIntake>> selectAll() { | 
 |  |  |         QueryResultVo<List<VoAllIntake>> rsVo = new QueryResultVo<>(); | 
 |  |  |         rsVo.obj = this.prIntakeMapper.selectAll(); | 
 |  |  |         return rsVo; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 得到一个取水口 | 
 |  |  |      * | 
 |  |  |      * @param id 取水口ID | 
 |  |  |      * @return 取水口实体 | 
 |  |  |      */ | 
 |  |  |     public VoAllIntake selectById(Long id) { | 
 |  |  |         return this.prIntakeMapper.selectByPrimaryKey(id); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 逻辑删除实体 | 
 |  |  |      * | 
 |  |  |      * @param id 实体ID | 
 |  |  |      * @return 数量 | 
 |  |  |      */ | 
 |  |  |     @Transactional | 
 |  |  |     public int delete(Long id) { | 
 |  |  |         return this.prIntakeMapper.deleteLogicById(id); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 根据取水口编号获取未删除的取水口数量 | 
 |  |  |      * | 
 |  |  |      * @param intakeId | 
 |  |  |      * @return | 
 |  |  |      */ | 
 |  |  |     public Integer getRecordCountOfIntake(Long intakeId) { | 
 |  |  |         return prIntakeMapper.getRecordCountOfIntake(intakeId); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 根据村Id获取全部地址 | 
 |  |  |      * | 
 |  |  |      * @param villageId 村Id | 
 |  |  |      * @return address  全部五级地址 | 
 |  |  |      */ | 
 |  |  |     public String getAddressByVillageId(long villageId) { | 
 |  |  |         return prIntakeMapper.getAddressByVillageId(villageId); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 根据区域Id获取区域等级 | 
 |  |  |      * | 
 |  |  |      * @param regionId 区域Id | 
 |  |  |      * @return Level  区域等级 | 
 |  |  |      */ | 
 |  |  |     public int getLevelByRegionId(long regionId) { | 
 |  |  |         return prIntakeMapper.getLevelByRegionId(regionId); | 
 |  |  |     } | 
 |  |  | 
 |  |  |         return prIntakeMapper.getUsedIntakes(jsonArray.toJSONString(), operator); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 发送命令 | 
 |  |  |      * | 
 |  |  |      * @return | 
 |  |  |      */ | 
 |  |  |     protected BaseResponse sendCom2Mw(Command com) { | 
 |  |  |         String url = UriComponentsBuilder.fromUriString(comSendUrl) | 
 |  |  |                 .build() | 
 |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 取水口名称换取水口ID,验证是否重复名称使用 | 
 |  |  |      * | 
 |  |  |      * @param intakeName | 
 |  |  |      * @return | 
 |  |  |      */ | 
 |  |  |     public List<Long> getIntakeIdsByName(String intakeName) { | 
 |  |  |         return prIntakeMapper.getIntakeIdsByName(intakeName); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 取水口名称换取水口ID,验证是否重复名称使用 | 
 |  |  |      * | 
 |  |  |      * @param intakeName | 
 |  |  |      * @return | 
 |  |  |      */ | 
 |  |  |     public List<Long> getIntakeIdByNameExcludeId(Long id, String intakeName) { | 
 |  |  |         return prIntakeMapper.getIntakeIdByNameExcludeId(id, intakeName); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * app修改取水口经纬度 | 
 |  |  |      * @param po | 
 |  |  |      * @return | 
 |  |  |      */ | 
 |  |  |     public int updateIntakeLngLat(IntakeUpdateLngLat po) { | 
 |  |  |         return prIntakeMapper.updateByPrimaryKeySelective1(po); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 获取未绑定到轮灌组的取水口列表 | 
 |  |  |      * @return | 
 |  |  |      */ | 
 |  |  |     public List<VoIntakeSimple> getFreeIntakes(QoIntake queryVo) { | 
 |  |  |         Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo); | 
 |  |  |         return prIntakeMapper.getFreeIntakes(params); |