import fr.ird.observe.persistence.avdth.referential.AvdthReferentialImportResult;

 import fr.ird.observe.persistence.avdth.referential.SpeciesCache;

 import fr.ird.observe.persistence.avdth.referential.interceptors.SchoolTypeInterceptor;

 import fr.ird.observe.persistence.avdth.referential.interceptors.WeightCategoryInterceptor;

 import java.util.List;

     }

     public VesselActivity getVesselActivity(String code) {

         return Objects.requireNonNull(result, String.format("Can't find vessel activity wth code: %s", code));

     }

 import fr.ird.observe.entities.referential.ps.common.ObservedSystem;

 import fr.ird.observe.entities.referential.ps.common.TransmittingBuoyOperation;

 import fr.ird.observe.entities.referential.ps.common.TransmittingBuoyType;

 import fr.ird.observe.persistence.avdth.data.DataReader;

 import fr.ird.observe.persistence.avdth.data.ImportDataContext;

 import fr.ird.observe.persistence.avdth.data.ImportEngine;

 import org.apache.commons.lang3.mutable.MutableInt;

 import java.sql.ResultSet;

     public FloatingObject read(ImportDataContext dataContext, ResultSet resultSet) throws SQLException {

         String vesselActivityCode = resultSet.getString(13);

         Set<String> observedSystemCodes = dataContext.getObservedSystemCodes();

             boolean noDcpInObservedSystems = observedSystemCodes.stream().noneMatch(OBSERVED_SYTEM_CODES_WITH_DCP::contains);

             if (noDcpInObservedSystems) {

                 reset(dataContext);