EDIT

/**

* Copyright (C) 2007 EDIT

* http://www.e-taxonomy.eu

* The contents of this file are subject to the Mozilla Public License Version 1.1

* See LICENSE.TXT at the top of this package for the full license terms.

*/

public class AlgaTerraTypeImport  extends AlgaTerraSpecimenImportBase {

	private static final Logger logger = Logger.getLogger(AlgaTerraTypeImport.class);

	private static int modCount = 5000;

	private static final String pluralString = "types";

		return "TypeLocality";

	}

	public AlgaTerraTypeImport(){

		super(dbTableName, pluralString);

	}

	@Override

	protected String getIdQuery(BerlinModelImportState state) {

				+ " ORDER BY NameFk ";

		return result;

	}

	@Override

	protected String getRecordQuery(BerlinModelImportConfigurator config) {

               " ts.RefFk as tsRefFk, ts.RefDetailFk as tsRefDetailFk, ts.MaterialCategoryFK as tsMaterialCategoryFK, td.RefFk as tdRefFk, td.RefDetailFk as tdRefDetailFk, " +

               " RefDet.Details as tdRefDetails, " +

               " td.created_When as tdCreated_When, tsd.created_When as tsdCreated_When, td.updated_when as tdUpdated_when, " +

               " td.created_who as tdCreated_who, tsd.created_who as tsdCreated_who, td.updated_who tdUpdated_who,  " +

               " mc.* " +

            	+ " FULL OUTER JOIN TypeDesignation td ON  td.TypeDesignationId = tsd.TypeDesignationFk "

            	+ " LEFT OUTER JOIN TDWGGazetteer gz ON ts.TDWGGazetteerFk = gz.ID "

            	+ " LEFT OUTER JOIN RefDetail refDet ON td.RefDetailFk = refDet.RefDetailId AND td.RefFk = refDet.RefFk "

            	+ " LEFT OUTER JOIN MaterialCategory mc ON mc.MaterialCategoryId = ts.MaterialCategoryFK "

          + " ORDER BY NameFk "

            ;

		return strQuery;

	@Override

	public boolean doPartition(ResultSetPartitioner partitioner, BerlinModelImportState bmState) {

		boolean success = true;

		AlgaTerraImportState state = (AlgaTerraImportState)bmState;

		//TODO check that no duplicate vocabularies will be created, also remove redundant code here

//		and in Specimen importer

		try {

			logger.warn("Exception occurred when trying to create Type specimen vocabularies: " + e1.getMessage());

			e1.printStackTrace();

		}

		Set<TaxonNameBase> namesToSave = new HashSet<TaxonNameBase>();

		Map<String, Reference> refDetailMap = partitioner.getObjectMap(BerlinModelRefDetailImport.REFDETAIL_NAMESPACE);

		ResultSet rs = partitioner.getResultSet();

		try {

			int i = 0;

			//for each reference

            while (rs.next()){

        		if ((i++ % modCount) == 0 && i!= 1 ){ logger.info("Type designations handled: " + (i-1));}

				int nameId = rs.getInt("nameFk");

				int typeSpecimenId = rs.getInt("TypeSpecimenId");

				int typeDesignationId = rs.getInt("TypeDesignationId");

				Integer tdRefDetailFk = nullSafeInt(rs, "tdRefDetailFk");

				String tdRefDetails = rs.getString("tdRefDetails");

				Boolean restrictedFlag = nullSafeBoolean(rs, "RestrictedFlag");

				String typeSpecimenPhrase = rs.getString("TypeSpecimenPhrase");

				Integer tsMaterialCategoryFK = nullSafeInt(rs, "MaterialCategoryFK");

				boolean isIcon = typeSpecimenPhrase != null && typeSpecimenPhrase.toLowerCase().startsWith("\u005bicon");

				try {

					//source ref

					//facade

					SpecimenOrObservationType type = SpecimenOrObservationType.PreservedSpecimen;

					if (isIcon){

					}else if (tsMaterialCategoryFK != null && tsMaterialCategoryFK.equals(4)){

						type = SpecimenOrObservationType.Fossil;

					}

							( typeStatusFk.equals(39) && !tsMaterialCategoryFK.equals(14) || ! typeStatusFk.equals(39) && tsMaterialCategoryFK.equals(14) )){

						logger.warn("Living Specimen type status should be 39 and materialCategoryFk 14 but one of them wasn't");

					}

					DerivedUnitFacade facade = getDerivedUnit(state, typeSpecimenId, typeSpecimenMap, type, ecoFactMap, ecoFactId, sourceRef);

					//field observation

					handleFieldObservationSpecimen(rs, facade, state, partitioner);

//					handleTypeSpecimenSpecificFieldObservation(rs,facade, state);

					//TODO divide like in EcoFact (if necessary)

					handleTypeSpecimenSpecificSpecimen(rs,facade, state, refMap, typeSpecimenId);

					handleFirstDerivedSpecimen(rs, facade, state, partitioner);

					//Designation

					TaxonNameBase<?,?> name = getTaxonName(state, taxonNameMap, nameId);

					SpecimenTypeDesignation designation = SpecimenTypeDesignation.NewInstance();

					if (typeStatusFk != null && typeStatusFk.equals(39)){

						designation.addAnnotation(Annotation.NewInstance("Type status: Authentic strain", AnnotationType.EDITORIAL(), Language.DEFAULT()));

					}

					designation.setTypeSpecimen(facade.innerDerivedUnit());

					designation.setTypeStatus(status);

					if (tdRefFk != null){

						if (typeDesigRef == null){

							logger.warn("Type designation reference not found in maps: " + tdRefFk);

						}else{

					if (isNotBlank(tdRefDetails)){

						designation.setCitationMicroReference(tdRefDetails);

					}

					//ID: Type designations do not allow OriginalSources

					designation.addAnnotation(Annotation.NewInstance("Id in BerlinModel-TypeDesignation: " + String.valueOf(typeDesignationId), AnnotationType.TECHNICAL(), Language.UNDETERMINED()));

					if (restrictedFlag != null &&restrictedFlag.equals(true)){

						logger.warn("Restricted Flag is expected to be null or 0. TypeDesignationId" + typeDesignationId);

					}

					//Created, Updated

					this.doCreatedUpdated(state, designation, rs);

					if (name != null){

						name.addTypeDesignation(designation, true); //TODO check if true is correct

					}else{

						logger.warn("Name could not be found for type designation " + typeDesignationId);

					}

				} catch (Exception e) {

					logger.warn("Exception in TypeDesignation: TypeDesignationId " + typeDesignationId + ". " + e.getMessage());

					e.printStackTrace();

            }

//            logger.warn("Specimen: " + countSpecimen + ", Descriptions: " + countDescriptions );

			logger.warn("Names to save: " + namesToSave.size());

			return success;

		} catch (SQLException e) {

			logger.error("SQLException:" +  e);

			return false;

		}

	}

	/**

	 * same as {@link BerlinModelImportBase#doCreatedUpdatedNotes}, but handles multiple similar fields

	 */

	private void doCreatedUpdated(BerlinModelImportState state, AnnotatableEntity annotatableEntity, ResultSet rs) throws SQLException{

		BerlinModelImportConfigurator config = state.getConfig();

		if (tdCreatedWhen != null){

			createdWhen = tdCreatedWhen;

		}

		String createdWho = rs.getString("tsdCreated_Who");

		String tdCreatedWho = rs.getString("tdCreated_Who");

		if (tdCreatedWho != null){

			createdWho = tdCreatedWho;

		}

		Object updatedWhen = rs.getObject("tdUpdated_When");

		String updatedWho = rs.getString("tdUpdated_who");

		//Created When, Who, Updated When Who

		if (config.getEditor() == null || config.getEditor().equals(EDITOR.NO_EDITORS)){

			//do nothing

			logger.warn("Editor type not yet implemented: " + config.getEditor());

		}

	}

	private DateTime getDateTime(Object timeString){

		if (timeString == null){

		}

		return dateTime;

	}

		return TYPE_SPECIMEN_DERIVED_UNIT_NAMESPACE;

	}

		return TYPE_SPECIMEN_FIELD_OBSERVATION_NAMESPACE;

	}

	/**

	 * @param taxonNameMap

	 * @param nameId

	 * @return

	}

	private void handleTypeSpecimenSpecificSpecimen(ResultSet rs, DerivedUnitFacade facade, AlgaTerraImportState state, Map<String, Reference> refMap, int typeSpecimenId) throws SQLException {

		//TODO

		DerivedUnit derivedUnit = facade.innerDerivedUnit();

		Integer tsMaterialCategoryFK = nullSafeInt(rs, "tsMaterialCategoryFK");

		String matCat = rs.getString("MaterialCategory");

		if (tsMaterialCategoryFK != null){

		}else{

			logger.warn("Material Category was null. This is not expected");

		}

		//collection

		String barcode = rs.getString("Barcode");

		if (StringUtils.isNotBlank(barcode)){

			facade.setBarcode(barcode);

		}

		//RefFk + RefDetailFk

		Integer  refFk = nullSafeInt(rs, "tsRefFk");

		if (refFk != null){

			if (ref == null){

				logger.warn("TypeSpecimen reference (" + refFk + ")not found in biblioRef. TypeSpecimenId: " + typeSpecimenId);

			}else{

				derivedUnit.addSource(source);

			}

		}

		Integer refDetailFk = nullSafeInt(rs, "tsRefDetailFk");

		if (refDetailFk != null){

			logger.warn("TypeSpecimen.RefDetailFk should always be NULL but wasn't: " + typeSpecimenId);

		}

	}

	/**

	 * @param state

	 * @param ecoFactId

	 * @param derivedUnitMap

	 * @return

	 */

		//TODO implement ecoFact map - if not all null anymore

		String typeKey = String.valueOf(typeSpecimenId);

		DerivedUnit derivedUnit = typeSpecimenMap.get(typeKey);

				facade = DerivedUnitFacade.NewInstance(type);

			}

		}

		return facade;

	}

	private SpecimenTypeDesignationStatus getSpecimenTypeDesignationStatusByKey(Integer typeStatusFk) {

		if (typeStatusFk == null){ return SpecimenTypeDesignationStatus.TYPE();

		}else if (typeStatusFk == 1) { return SpecimenTypeDesignationStatus.HOLOTYPE();

			logger.warn("typeStatusFk undefined for " +  typeStatusFk);

			return SpecimenTypeDesignationStatus.TYPE();

		}

	}

	@Override

	public Map<Object, Map<String, ? extends CdmBase>> getRelatedObjectsForPartition(ResultSet rs, BerlinModelImportState state) {

		String nameSpace;

		Class<?> cdmClass;

		Set<String> idSet;

		Map<Object, Map<String, ? extends CdmBase>> result = new HashMap<Object, Map<String, ? extends CdmBase>>();

		try{

			Set<String> nameIdSet = new HashSet<String>();

			Set<String> ecoFieldObservationIdSet = new HashSet<String>();

			Set<String> collectionIdSet = new HashSet<String>();

			Set<String> referenceIdSet = new HashSet<String>();

			Set<String> refDetailIdSet = new HashSet<String>();

			while (rs.next()){

				handleForeignKey(rs, nameIdSet, "nameFk");

				handleForeignKey(rs, ecoFieldObservationIdSet, "ecoFactFk");

				handleForeignKey(rs, referenceIdSet, "tdRefFk");

				handleForeignKey(rs, refDetailIdSet, "tdRefDetailFk");

			}

			//name map

			nameSpace = BerlinModelTaxonNameImport.NAMESPACE;

			cdmClass = TaxonNameBase.class;

			idSet = referenceIdSet;

			Map<String, Reference> referenceMap = (Map<String, Reference>)getCommonService().getSourcedObjectsByIdInSource(cdmClass, idSet, nameSpace);

			result.put(nameSpace, referenceMap);

			//refDetail map

			nameSpace = BerlinModelRefDetailImport.REFDETAIL_NAMESPACE;

			cdmClass = Reference.class;

			idSet = refDetailIdSet;

			Map<String, Reference> refDetailMap= (Map<String, Reference>)getCommonService().getSourcedObjectsByIdInSource(cdmClass, idSet, nameSpace);

			result.put(nameSpace, refDetailMap);

		} catch (SQLException e) {

			throw new RuntimeException(e);

		}

	/* (non-Javadoc)

	 * @see eu.etaxonomy.cdm.io.common.CdmIoBase#isIgnore(eu.etaxonomy.cdm.io.common.IImportConfigurator)

	 */

		return ! state.getConfig().isDoTypes();

	}

}