modified key

[sgn.git] / lib / CXGN / Project.pm

=head1 NAME

CXGN::Project - helper class for projects

=head1 DESCRIPTION

CXGN::Project is the root object for information stored in the project table, such as trials, genotyping trials, breeding programs, folders, etc.

It should rarely be necessary to be instantiated on its own. Use the CXGN::Trial factory object to generate the appropriate object from a project_id.

=head1 SYNOPSYS

 my $project = CXGN::Project->new( { bcs_schema => $schema, trial_id => $trial_id });
 $trial->set_description("yield trial with promising varieties");
 etc.

=head1 AUTHOR

Lukas Mueller <lam87@cornell.edu>

=head1 METHODS

=cut

package CXGN::Project;

use Moose;

use Data::Dumper;
use Try::Tiny;
use Data::Dumper;
use CXGN::Trial::Folder;
use CXGN::Stock;
use CXGN::Trial::TrialLayout;
use CXGN::Trial::TrialLayoutDownload;
use SGN::Model::Cvterm;
use Time::Piece;
use Time::Seconds;
use CXGN::Calendar;
use JSON;
use File::Basename qw | basename dirname|;
use Scalar::Util qw | looks_like_number |;
use CXGN::Genotype::GenotypingProject;
use CXGN::Genotype::Protocol;

=head2 accessor bcs_schema()

accessor for bcs_schema. Needs to be set when calling the constructor.

=cut

has 'bcs_schema' => (
    isa => 'Bio::Chado::Schema',
    is => 'rw',
    required => 1,
);

has 'metadata_schema' => (
    isa => 'CXGN::Metadata::Schema',
    is => 'rw',
);

has 'phenome_schema' => (
    isa => 'CXGN::Phenome::Schema',
    is => 'rw',
);

has 'project_id' => (
    isa => 'Maybe[Int]',
    is => 'rw',
    trigger => \&set_trial_id,
    builder => 'get_trial_id',
    );

has 'name' => (
    isa => 'Str',
    is => 'rw',
    trigger => \&set_name,
    builder => 'get_name',
    lazy => 1,
    );

has 'description' => (
    isa => 'Maybe[Str]',
    is => 'rw',
    trigger => \&set_description,
    builder => 'get_description',
    lazy => 1,
    );

has 'year' => (
    isa => 'Maybe[Str]',
    is => 'rw',
    trigger => \&get_year,
    builder => 'set_year',
    lazy => 1,
    );

has 'additional_info' => (
    is  => 'rw',
    isa => 'Maybe[HashRef]'
);


sub BUILD {
    my $self = shift;
    my $args = shift;

    print STDERR "BUILD CXGN::Project... with ".$args->{trial_id}."\n";

    if (! $args->{description}) {
            $args->{description} = "(No description provided)";
    }

    my $row = $self->bcs_schema()->resultset("Project::Project")->find( { project_id => $args->{trial_id} });

    # print STDERR "PROJECT ID = $args->{trial_id}\n";
    if ($row){
            $self->name( $row->name() );
    }

    if ($args->{trial_id} && ! $row) {
            die "The trial ".$args->{trial_id}." does not exist - aborting.";
    }

    $row = $self->bcs_schema()->resultset("Project::Project")->find( { name => $args->{name } } );


    if (! $args->{trial_id} && $row) {
            die "A trial with the name $args->{name} already exists. Please choose another name.";
    }

    if (! $args->{trial_id} && ! $row) {
        print STDERR "INSERTING A NEW ROW...\n";

        my $new_row = $args->{bcs_schema}->resultset("Project::Project")->create( { name => $args->{name}, description => $args->{description} });
        my $project_id = $new_row->project_id();
        print STDERR "new project object has project id $project_id\n";

        $self->set_trial_id($project_id);
    }

    if ($args->{trial_id} && $row) {
        # print STDERR "Existing project... populating object.\n";
        $self->set_trial_id($args->{trial_id});
        $self->name($args->{name});
        $self->description($args->{description});
    }
}

=head2 accessors get_trial_id()

 Desc: get the trial id

=cut

has 'trial_id' => (isa => 'Int',
                   is => 'rw',
                   reader => 'get_trial_id',
                   writer => 'set_trial_id',
    );

=head2 accessors get_layout(), set_layout()

 Desc: set the layout object for this trial (CXGN::Trial::TrialLayout)
 (This is populated automatically by the constructor)

=cut

has 'layout' => (isa => 'CXGN::Trial::TrialLayout::Phenotyping |
                         CXGN::Trial::TrialLayout::Genotyping |
                         CXGN::Trial::TrialLayout::Analysis |
                          CXGN::Trial::TrialLayout::SamplingTrial',
                 is => 'rw',
                 reader => 'get_layout',
                 writer => 'set_layout',
                 predicate => 'has_layout',
                 lazy => 1,
                 default => sub { my $self = shift; $self->_get_layout(); }
    );

sub _get_layout {
    my $self = shift;
    print STDERR "RETRIEVING LAYOUT...\n";
    my $layout = CXGN::Trial::TrialLayout->new( { schema => $self->bcs_schema, trial_id => $self->get_trial_id(), experiment_type=>$self->get_cxgn_project_type()->{experiment_type} });
    $self->set_layout($layout);
}

=head2 accessors get_cxgn_project_type()

get the CXGN::Project type e.g. field trial, analysis, genotyping trial, etc

=cut

sub get_cxgn_project_type {
    my $self = shift;

    my $analysis_metadata_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema(), 'analysis_metadata_json', 'project_property')->cvterm_id();
    my $crossing_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema(), 'crossing_trial',  'project_type')->cvterm_id();

    my $q = "SELECT projectprop.type_id, projectprop.value FROM project JOIN projectprop USING(project_id)";
        my $h = $self->bcs_schema->storage->dbh->prepare($q);
        $h->execute();

    my $cxgn_project_type = 'field_trial_project';
    my $plot_data_level = 'plot';
    my $experiment_type = 'field_layout';
    while (my ($prop, $propvalue) = $h->fetchrow_array()) {
        if ($prop) {
            if ($prop == $crossing_trial_cvterm_id) {
                $cxgn_project_type = 'crossing_project';
            }
            if ($prop == $analysis_metadata_cvterm_id) {
                $cxgn_project_type = 'analysis_project';
                $plot_data_level = 'analysis_instance';
                $experiment_type = 'analysis_experiment';
            }
            if ($propvalue) {
                if ($propvalue eq "genotyping_plate") {
                    $cxgn_project_type = 'genotyping_plate_project';
                    $experiment_type = 'genotyping_layout';
                }
                if ($propvalue eq "sampling_trial") {
                    $cxgn_project_type = 'sampling_trial_project';
                    $experiment_type = 'sampling_layout';
                }
                if ($propvalue eq "treatment") {
                    $cxgn_project_type = 'management_factor_project';
                }
                if (($propvalue eq "genotype_data_project") || ($propvalue eq "pcr_genotype_data_project")) {
                    $cxgn_project_type = 'genotyping_data_project';
                }
                if ($propvalue eq "drone_run") {
                    $cxgn_project_type = 'drone_run_project';
                }
                if ($propvalue eq "drone_run_band") {
                    $cxgn_project_type = 'drone_run_band_project';
                }
            }
        }
    }
    return {
        cxgn_project_type => $cxgn_project_type,
        data_level => $plot_data_level,
        experiment_type => $experiment_type
    }
}

=head2 accessors get_year(), set_year()

getter/setter for the year property. The setter modifies the database.

=cut

sub get_year {
    my $self = shift;

    print STDERR "get_year()...\n";

    if ($self->year()) { return $self->year(); }

    my $type_id = $self->get_year_type_id();

    my $rs = $self->bcs_schema->resultset('Project::Project')->search( { 'me.project_id' => $self->get_trial_id() })->search_related('projectprops', { 'projectprops.type_id' => $type_id } );

    if ($rs->count() == 0) {
        return undef;
    }
    else {
        return $rs->first()->value();
    }

}

sub set_year {
    my $self = shift;
    my $year = shift;

    if (!$year) {
        print STDERR "set_year(): No year provided, not setting.\n";
        return;
    }

    print STDERR "set_year()... (with parameter $year)\n";
    my $type_id = $self->get_year_type_id();

    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find( { project_id => $self->get_trial_id(), type_id => $type_id  });

    if ($row) {
        print STDERR "Updating year to $year...\n";
        $row->value($year);
        $row->update();
    }
    else {
        print STDERR "inserting new year ($year)...\n";
        $row = $self->bcs_schema->resultset('Project::Projectprop')->create(
            {
                type_id => $type_id,
                value => $year,
                project_id =>  $self->get_trial_id()
            } );
        $year =  $row->value();
    }
    return $year;
}

=head2 accessors get_description(), set_description()

getter/setter for the description

=cut

sub get_description {
    my $self = shift;

    # print STDERR "Get description for trial id ".$self->get_trial_id()."\n";
    my $rs = $self->bcs_schema->resultset('Project::Project')->search( { project_id => $self->get_trial_id() });

    return $rs->first()->description();

}


sub set_description {
    my $self = shift;
    my $description = shift;
    my $dbh = $self->bcs_schema->storage->dbh;

    my $row = $self->bcs_schema->resultset('Project::Project')->find( { project_id => $self->get_trial_id() });

    #print STDERR "Setting new description $description for trial ".$self->get_trial_id()."\n";

    $row->description($description);

    $row->update();

    my $logged_in_user_q = "select * from logged_in_user";
    my $logged_in_user_h = $dbh -> prepare($logged_in_user_q);
    $logged_in_user_h->execute();
    my $logged_in_user_arr = $logged_in_user_h->fetchall_arrayref();
    print STDERR "logged in user Project.pm: ".Dumper($logged_in_user_arr)."\n";

}


=head2 function get_nd_experiment_id()

 Usage:        my $location = $trial->get_nd_experiment_id();
 Desc:          Every trial should have only a single nd_experiment entry of type 'field_layout'. This returns this nd_experiment_id for the trial.
 Ret:          $nd_experiment_id
 Args:
 Side Effects:
 Example:

=cut

sub get_nd_experiment_id {
    my $self = shift;
    my $nd_experiment_field_layout_type_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'field_layout', 'experiment_type')->cvterm_id();
    my $nd_experiment_genotyping_layout_type_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'genotyping_layout', 'experiment_type')->cvterm_id();
    my $nd_experiment_rs = $self->bcs_schema->resultset('NaturalDiversity::NdExperiment')->search(
        { 'me.type_id' => [$nd_experiment_field_layout_type_id, $nd_experiment_genotyping_layout_type_id], 'project.project_id' => $self->get_trial_id },
        { 'join' => {'nd_experiment_projects'=>'project'}}
    );
    if ($nd_experiment_rs->count > 1){
        return {error => "A trial cannot have more than one nd_experiment entry of type field_layout. Please contact us."};
    }
    if ($nd_experiment_rs == 1){
        return {success => 1, nd_experiment_id => $nd_experiment_rs->first->nd_experiment_id};
    } else {
        return {error => "This trial does not have an nd_experiment entry of type field_layout. Please contact us."}
    }
}

=head2 function get_location()

 Usage:        my $location = $trial->get_location();
 Desc:
 Ret:          [ location_id, 'location description' ]
 Args:
 Side Effects:
 Example:

=cut

sub get_location {
    my $self = shift;

    if ($self->get_location_type_id()) {
        my $row = $self->bcs_schema->resultset('Project::Projectprop')->find( { project_id => $self->get_trial_id() , type_id=> $self->get_location_type_id() });

        if ($row) {
            my $loc = $self->bcs_schema->resultset('NaturalDiversity::NdGeolocation')->find( { nd_geolocation_id => $row->value() });

            return [ $row->value(), $loc->description() ];
        }
        else {
            return [];
        }
    }
}

=head2 function set_location()

 Usage:        $trial->set_location($location_id);
 Desc:
 Ret:          nothing
 Args:
 Side Effects: database access
 Example:

=cut

sub set_location {
    my $self = shift;
    my $location_id = shift;
    my $schema = $self->bcs_schema();

    if (!looks_like_number($location_id)) {
        die "Location_id $location_id not an integer!\n";
    }

        my $project_id = $self->get_trial_id();
        my $type_id = $self->get_location_type_id();

    ## Use txn_do with the following coderef so that if any part fails, the entire transaction fails.
    my $coderef = sub {

        # update or create location id in projectprop
        my $row = $schema->resultset('Project::Projectprop')->find({
            project_id => $project_id,
            type_id => $type_id,
        });

        if ($row) {
                $row->value($location_id);
                $row->update();
        }
        else {
                $row = $schema->resultset('Project::Projectprop')->create({
                        project_id => $project_id,
                        type_id => $type_id,
                        value => $location_id,
                });
        }

        # update location ids for connected rows in nd_experiment
        my $nd_experiment_rs = $schema->resultset('NaturalDiversity::NdExperimentProject')->search(
            { project_id => $project_id }
        )->search_related('nd_experiment');

        foreach my $exp ($nd_experiment_rs->all()) {
            $exp->nd_geolocation_id($location_id);
            $exp->update();
        }
    };

    try {
        $schema->txn_do($coderef);
    } catch {
        print STDERR "Transaction error updating location: $_\n";
    };

}

=head2 function get_location_noaa_station_id()

 Usage:        my $noaa_station_id = $trial->get_location_noaa_station_id();
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_location_noaa_station_id {
    my $self = shift;
    my $nd_geolocation_id = $self->bcs_schema->resultset('Project::Projectprop')->find( { project_id => $self->get_trial_id() , type_id=> $self->get_location_type_id() })->value();
    my $noaa_station_id_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'noaa_station_id', 'geolocation_property')->cvterm_id();

    my $q = "SELECT value FROM nd_geolocationprop WHERE nd_geolocation_id = ? AND type_id = ?;";
    my $h = $self->bcs_schema->storage->dbh()->prepare($q);
    $h->execute($nd_geolocation_id, $noaa_station_id_cvterm_id);
    my ($noaa_station_id) = $h->fetchrow_array();
    return $noaa_station_id;
}

=head2 function get_location_country_name()

 Usage:        my $country_name = $trial->get_location_country_name();
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_location_country_name {
    my $self = shift;

    my $country_name;

    eval {
        my $nd_geolocation_id = $self->bcs_schema->resultset('Project::Projectprop')->find( { project_id => $self->get_trial_id() , type_id=> $self->get_location_type_id() })->value();
        my $country_name_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'country_name', 'geolocation_property')->cvterm_id();

        if ( $nd_geolocation_id && $country_name_cvterm_id ) {
            my $q = "SELECT value FROM nd_geolocationprop WHERE nd_geolocation_id = ? AND type_id = ?;";
            my $h = $self->bcs_schema->storage->dbh()->prepare($q);

            $h->execute($nd_geolocation_id, $country_name_cvterm_id);
            ($country_name) = $h->fetchrow_array();
        }
    };

    return $country_name;
}

=head2 function get_breeding_programs()

 Usage:
 Desc:         return associated breeding program info
 Ret:          returns a listref to [ id, name, desc ] listrefs
 Args:
 Side Effects:
 Example:

=cut

sub get_breeding_programs {
    my $self = shift;

    my $breeding_program_cvterm_id = $self->get_breeding_program_cvterm_id();

    my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->search( { 'subject_project_id' => $self->get_trial_id() } );

    my $trial_row = $trial_rs -> first();
    my $rs;
    my @projects;

    if ($trial_row) {
        $rs = $self->bcs_schema->resultset('Project::Project')->search( { 'me.project_id' => $trial_row->object_project_id(), 'projectprops.type_id'=>$breeding_program_cvterm_id }, { join => 'projectprops' }  );

        while (my $row = $rs->next()) {
            push @projects, [ $row->project_id, $row->name, $row->description ];
        }
    }
    return  \@projects;
}

=head2 function set_field_trials_source_field_trials()

 Usage:
 Desc:         sets associated source field trials for the current field trial
 Ret:          returns an arrayref [ id, name ] of arrayrefs
 Args:         an arrayref [source_trial_id1, source_trial_id2]
 Side Effects:
 Example:

=cut

sub set_field_trials_source_field_trials {
    my $self = shift;
    my $source_field_trial_ids = shift;
    my $schema = $self->bcs_schema;
    my $field_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'field_trial_from_field_trial', 'project_relationship')->cvterm_id();

    foreach (@$source_field_trial_ids){
        if ($_){
            my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->create({
                'subject_project_id' => $self->get_trial_id(),
                'object_project_id' => $_,
                'type_id' => $field_trial_from_field_trial_cvterm_id
            });
        }
    }
    my $projects = $self->get_field_trials_source_field_trials();
    return $projects;
}

=head2 function get_field_trials_source_field_trials()

 Usage:
 Desc:         return associated source field trials for the current field trial
 Ret:          returns an arrayref [ id, name ] of arrayrefs
 Args:
 Side Effects:
 Example:

=cut

sub get_field_trials_source_field_trials {
    my $self = shift;
    my $schema = $self->bcs_schema;
    my $field_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'field_trial_from_field_trial', 'project_relationship')->cvterm_id();

    my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->search({
        'me.subject_project_id' => $self->get_trial_id(),
        'me.type_id' => $field_trial_from_field_trial_cvterm_id
    }, {
        join => 'object_project', '+select' => ['object_project.name'], '+as' => ['source_trial_name']
    });

    my @projects;
    while (my $r = $trial_rs->next) {
        push @projects, [ $r->object_project_id, $r->get_column('source_trial_name') ];
    }
    return  \@projects;
}

=head2 function get_field_trials_sourced_from_field_trials()

 Usage:
 Desc:         return associated source field trials for the current field trial
 Ret:          returns an arrayref [ id, name ] of arrayrefs
 Args:
 Side Effects:
 Example:

=cut

sub get_field_trials_sourced_from_field_trials {
    my $self = shift;
    my $schema = $self->bcs_schema;
    my $field_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'field_trial_from_field_trial', 'project_relationship')->cvterm_id();

    my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->search({
        'me.object_project_id' => $self->get_trial_id(),
        'me.type_id' => $field_trial_from_field_trial_cvterm_id
    }, {
        join => 'subject_project', '+select' => ['subject_project.name'], '+as' => ['trial_name']
    });

    my @projects;
    while (my $r = $trial_rs->next) {
        push @projects, [ $r->subject_project_id, $r->get_column('trial_name') ];
    }
    return  \@projects;
}

=head2 function set_genotyping_trials_from_field_trial()

 Usage:
 Desc:         sets associated genotyping plates for the current field trial
 Ret:          returns an arrayref [ id, name ] of arrayrefs
 Args:         an arrayref [genotyping_trial_id1, genotyping_trial_id2]
 Side Effects:
 Example:

=cut

sub set_genotyping_trials_from_field_trial {
    my $self = shift;
    my $source_field_trial_ids = shift;
    my $schema = $self->bcs_schema;
    my $genotyping_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'genotyping_trial_from_field_trial', 'project_relationship')->cvterm_id();

    foreach (@$source_field_trial_ids){
        if ($_){
            my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->create({
                'subject_project_id' => $self->get_trial_id(),
                'object_project_id' => $_,
                'type_id' => $genotyping_trial_from_field_trial_cvterm_id
            });
        }
    }
    my $projects = $self->get_genotyping_trials_from_field_trial();
    return $projects;
}

=head2 function get_genotyping_trials_from_field_trial()

 Usage:
 Desc:         return associated genotyping plates for the current field trial
 Ret:          returns an arrayref [ id, name ] of arrayrefs
 Args:
 Side Effects:
 Example:

=cut

sub get_genotyping_trials_from_field_trial {
    my $self = shift;
    my $schema = $self->bcs_schema;
    my $genotyping_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'genotyping_trial_from_field_trial', 'project_relationship')->cvterm_id();

    my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->search({
        'me.subject_project_id' => $self->get_trial_id(),
        'me.type_id' => $genotyping_trial_from_field_trial_cvterm_id
    }, {
        join => 'object_project', '+select' => ['object_project.name'], '+as' => ['source_trial_name']
    });

    my @projects;
    while (my $r = $trial_rs->next) {
        push @projects, [ $r->object_project_id, $r->get_column('source_trial_name') ];
    }
    return  \@projects;
}

=head2 function set_source_field_trials_for_genotyping_trial()

 Usage:
 Desc:         sets associated field trials for the current genotyping plate
 Ret:          returns an arrayref [ id, name ] of arrayrefs
 Args:         an arrayref [field_trial_id1, field_trial_id2]
 Side Effects:
 Example:

=cut

sub set_source_field_trials_for_genotyping_trial {
    my $self = shift;
    my $source_field_trial_ids = shift;
    my $schema = $self->bcs_schema;
    my $genotyping_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'genotyping_trial_from_field_trial', 'project_relationship')->cvterm_id();

    foreach (@$source_field_trial_ids){
        if ($_){
            my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->create({
                'object_project_id' => $self->get_trial_id(),
                'subject_project_id' => $_,
                'type_id' => $genotyping_trial_from_field_trial_cvterm_id
            });
        }
    }
    my $projects = $self->get_field_trials_source_of_genotyping_trial();
    return $projects;
}

=head2 function get_field_trials_source_of_genotyping_trial()

 Usage:
 Desc:         return associated field trials for current genotying trial
 Ret:          returns an arrayref [ id, name ] of arrayrefs
 Args:
 Side Effects:
 Example:

=cut

sub get_field_trials_source_of_genotyping_trial {
    my $self = shift;
    my $schema = $self->bcs_schema;
    my $genotyping_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'genotyping_trial_from_field_trial', 'project_relationship')->cvterm_id();

    my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->search({
        'me.object_project_id' => $self->get_trial_id(),
        'me.type_id' => $genotyping_trial_from_field_trial_cvterm_id
    }, {
        join => 'subject_project', '+select' => ['subject_project.name'], '+as' => ['source_trial_name']
    });

    my @projects;
    while (my $r = $trial_rs->next) {
        push @projects, [ $r->subject_project_id, $r->get_column('source_trial_name') ];
    }
    return  \@projects;
}

=head2 function set_source_field_trials_for_sampling_trial()

 Usage:
 Desc:         sets associated field trials for the current sampling trial
 Ret:          returns an arrayref [ id, name ] of arrayrefs
 Args:         an arrayref [field_trial_id1, field_trial_id2]
 Side Effects:
 Example:

=cut

sub set_source_field_trials_for_sampling_trial {
    my $self = shift;
    my $source_field_trial_ids = shift;
    my $schema = $self->bcs_schema;
    my $sampling_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'sampling_trial_from_field_trial', 'project_relationship')->cvterm_id();

    foreach (@$source_field_trial_ids){
        if ($_){
            my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->create({
                'object_project_id' => $self->get_trial_id(),
                'subject_project_id' => $_,
                'type_id' => $sampling_trial_from_field_trial_cvterm_id
            });
        }
    }
    my $projects = $self->get_field_trials_source_of_sampling_trial();
    return $projects;
}

=head2 function get_field_trials_source_of_sampling_trial()

 Usage:
 Desc:         return associated field trials for current sampling trial
 Ret:          returns an arrayref [ id, name ] of arrayrefs
 Args:
 Side Effects:
 Example:

=cut

sub get_field_trials_source_of_sampling_trial {
    my $self = shift;
    my $schema = $self->bcs_schema;
    my $sampling_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'sampling_trial_from_field_trial', 'project_relationship')->cvterm_id();

    my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->search({
        'me.object_project_id' => $self->get_trial_id(),
        'me.type_id' => $sampling_trial_from_field_trial_cvterm_id
    }, {
        join => 'subject_project', '+select' => ['subject_project.name'], '+as' => ['source_trial_name']
    });

    my @projects;
    while (my $r = $trial_rs->next) {
        push @projects, [ $r->subject_project_id, $r->get_column('source_trial_name') ];
    }
    return  \@projects;
}

=head2 function set_crossing_trials_from_field_trial()

 Usage:
 Desc:         sets associated crossing trials for the current field trial
 Ret:          returns an arrayref [ id, name ] of arrayrefs
 Args:         an arrayref [crossing_trial_id1, crossing_trial_id2]
 Side Effects:
 Example:

=cut

sub set_crossing_trials_from_field_trial {
    my $self = shift;
    my $source_field_trial_ids = shift;
    my $schema = $self->bcs_schema;
    my $genotyping_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'crossing_trial_from_field_trial', 'project_relationship')->cvterm_id();

    foreach (@$source_field_trial_ids){
        if ($_){
            my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->create({
                'subject_project_id' => $self->get_trial_id(),
                'object_project_id' => $_,
                'type_id' => $genotyping_trial_from_field_trial_cvterm_id
            });
        }
    }
    my $projects = $self->get_crossing_trials_from_field_trial();
    return $projects;
}

=head2 function get_crossing_trials_from_field_trial()

 Usage:
 Desc:         return associated crossing trials for athe current field trial
 Ret:          returns an arrayref [ id, name ] of arrayrefs
 Args:
 Side Effects:
 Example:

=cut

sub get_crossing_trials_from_field_trial {
    my $self = shift;
    my $schema = $self->bcs_schema;
    my $crossing_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'crossing_trial_from_field_trial', 'project_relationship')->cvterm_id();

    my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->search({
        'me.subject_project_id' => $self->get_trial_id(),
        'me.type_id' => $crossing_trial_from_field_trial_cvterm_id
    }, {
        join => 'object_project', '+select' => ['object_project.name'], '+as' => ['source_trial_name']
    });

    my @projects;
    while (my $r = $trial_rs->next) {
        push @projects, [ $r->object_project_id, $r->get_column('source_trial_name') ];
    }
    return  \@projects;
}

=head2 function get_field_trials_source_of_crossing_trial()

 Usage:
 Desc:         return associated field trials for the current crossing trial
 Ret:          returns an arrayref [ id, name ] of arrayrefs
 Args:
 Side Effects:
 Example:

=cut

sub get_field_trials_source_of_crossing_trial {
    my $self = shift;
    my $schema = $self->bcs_schema;
    my $crossing_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'crossing_trial_from_field_trial', 'project_relationship')->cvterm_id();

    my $trial_rs= $self->bcs_schema->resultset('Project::ProjectRelationship')->search({
        'me.object_project_id' => $self->get_trial_id(),
        'me.type_id' => $crossing_trial_from_field_trial_cvterm_id
    }, {
        join => 'subject_project', '+select' => ['subject_project.name'], '+as' => ['source_trial_name']
    });

    my @projects;
    while (my $r = $trial_rs->next) {
        push @projects, [ $r->subject_project_id, $r->get_column('source_trial_name') ];
    }
    return  \@projects;
}


=head2 function get_project_type()

 Usage:        [ $project_type_cvterm_id, $project_type_name ] = $t -> get_project_type();
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_project_type {
    my $self = shift;

    my @project_type_ids = CXGN::Trial::get_all_project_types($self->bcs_schema());

    my @ids = map { $_->[0] } @project_type_ids;
    my $rs = $self->bcs_schema()->resultset('Project::Projectprop')->search(
        {
            type_id => { -in => [ @ids ] },
            project_id => $self->get_trial_id()
        });

    if ($rs->count() > 0) {
        my $type_id = $rs->first()->type_id();
        foreach my $pt (@project_type_ids) {
            if ($type_id == $pt->[0]) {
                #print STDERR "[get_project_type] ".$pt->[0]." ".$pt->[1]."\n";
                return $pt;
            }
        }
    }
    return undef;

}


=head2 function set_project_type()

 Usage: $t -> set_project_type($type);
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub set_project_type {
    my $self = shift;
    my $type_id = shift;
    my $type_value = shift;
    my $project_id = $self->get_trial_id();
    my @project_type_ids = CXGN::Trial::get_all_project_types($self->bcs_schema());
    my $type;

    foreach my $pt (@project_type_ids) {
        if ($pt->[0] eq $type_id) {
            $type = $pt->[1];
        }
    }

    if ($type eq 'misc_trial' && defined $type_value) {
        $type = $type_value;
    }

    my @ids = map { $_->[0] } @project_type_ids;
    my $rs = $self->bcs_schema()->resultset('Project::Projectprop')->search({
        type_id => { -in => [ @ids ] },
        project_id => $project_id
    });
    if (my $row = $rs->next()) {
        $row->delete();
    }

    my $row = $self->bcs_schema()->resultset('Project::Projectprop')->create({
            project_id => $project_id,
            type_id => $type_id,
            value => $type,
    });
}


sub set_design_type {
    my $self = shift;
    my $design_type = shift;

    my $design_cv_type = $self->bcs_schema->resultset('Cv::Cvterm')->find( { name => 'design' });
    if (!$design_cv_type) {
        print STDERR "Design CV term not found. Cannot set design type.\n";
        return;
    }
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create(
        {
            project_id => $self->get_trial_id(),
            type_id => $design_cv_type->cvterm_id(),
        });
    $row->value($design_type);
    $row->update();
}

=head2 accessors get_breeding_program(), set_breeding_program()

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_breeding_program {

    my $self = shift;

    my $rs = $self->bcs_schema()->resultset("Project::ProjectRelationship")->search({
                        subject_project_id => $self->get_trial_id(),
            type_id => $self->get_breeding_program_trial_relationship_cvterm_id(),
                });
    if ($rs->count() == 0) {
                        return undef;
    }

    my $bp_rs = $self->bcs_schema()->resultset("Project::Project")->search({
                        project_id => $rs->first()->object_project_id()
                });
    if ($bp_rs->count > 0) {
                        return $bp_rs->first()->name();
    }

    return undef;
}

sub set_breeding_program {
        my $self = shift;
        my $breeding_program_id = shift;

    if (!looks_like_number($breeding_program_id)) {
        die "Breeding_program_id $breeding_program_id is not an integer!\n";
    }

        my $trial_id = $self->get_trial_id();
        my $type_id = $self->get_breeding_program_trial_relationship_cvterm_id();

        eval {
                my $row = $self->bcs_schema->resultset("Project::ProjectRelationship")->find ({
                        subject_project_id => $trial_id,
                        type_id => $type_id,
                });

                if ($row) {
                        $row->object_project_id($breeding_program_id);
                        $row->update();
                }
                else {
                        $row = $self->bcs_schema->resultset("Project::ProjectRelationship")->create ({
                                object_project_id => $breeding_program_id,
                                subject_project_id => $trial_id,
                                type_id => $type_id,
                        });
                        $row->insert();
                }
        };

        if ($@) {
                print STDERR "ERROR: $@\n";
                return { error => "An error occurred while setting the trial's breeding program." };
        }
        return {};
}


=head2 accessors get_name(), set_name()

 Usage:
 Desc:         retrieve and store project name from/to database
 Ret:
 Args:
 Side Effects: setter modifies the database
 Example:

=cut

sub get_name {
    my $self = shift;
    my $row = $self->bcs_schema->resultset('Project::Project')->find( { project_id => $self->get_trial_id() });

    if ($row) {
        return $row->name();
    }
}

sub set_name {
    my $self = shift;
    my $name = shift;
    my $row = $self->bcs_schema->resultset('Project::Project')->find( { project_id => $self->get_trial_id() });
    if ($row) {
        $row->name($name);
        $row->update();
    }
}

=head2 accessors get_project_start_date(), set_project_start_date()

 Usage:         $t->set_project_start_date("2016/09/17");
 Desc:          sets the projects project_start_date property.
                The date format in the setter has to be
                YYYY/MM/DD
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_project_start_date {
    my $self = shift;

    my $project_start_date_cvterm_id = $self->get_project_start_date_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find({
        project_id => $self->get_trial_id(),
        type_id => $project_start_date_cvterm_id,
    });

    my $calendar_funcs = CXGN::Calendar->new({});
    return $row ? $calendar_funcs->display_start_date($row->value()) : undef;
}

sub set_project_start_date {
    my $self = shift;
    my $project_start_date = shift;

    my $calendar_funcs = CXGN::Calendar->new({});
    if (my $project_start_date_event = $calendar_funcs->check_value_format($project_start_date) ) {
        my $project_start_date_cvterm_id = $self->get_project_start_date_cvterm_id();
        my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create({
            project_id => $self->get_trial_id(),
            type_id => $project_start_date_cvterm_id,
        });

        $row->value($project_start_date_event);
        $row->update();
    } else {
        print STDERR "date format did not pass check while preparing to set project start date: $project_start_date  \n";
    }
}

=head2 accessors get_harvest_date(), set_harvest_date()

 Usage:         $t->set_harvest_date("2016/09/17");
 Desc:          sets the projects harvest_date property.
                The date format in the setter has to be
                YYYY/MM/DD
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_harvest_date {
    my $self = shift;

    my $harvest_date_cvterm_id = $self->get_harvest_date_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find(
        {
            project_id => $self->get_trial_id(),
            type_id => $harvest_date_cvterm_id,
        });

    my $calendar_funcs = CXGN::Calendar->new({});

    if ($row) {
        my $harvest_date = $calendar_funcs->display_start_date($row->value());
        return $harvest_date;
    } else {
        return;
    }
}

sub set_harvest_date {
    my $self = shift;
    my $harvest_date = shift;

    my $calendar_funcs = CXGN::Calendar->new({});

    if (my $harvest_event = $calendar_funcs->check_value_format($harvest_date) ) {

        my $harvest_date_cvterm_id = $self->get_harvest_date_cvterm_id();

        my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create(
        {
            project_id => $self->get_trial_id(),
            type_id => $harvest_date_cvterm_id,
        });

        $row->value($harvest_event);
        $row->update();
    } else {
                        print STDERR "date format did not pass check while preparing to set harvest date: $harvest_date  \n";
                }
}

sub remove_harvest_date {
    my $self = shift;
                my $harvest_date = shift;

                my $calendar_funcs = CXGN::Calendar->new({});
    if (my $harvest_event = $calendar_funcs->check_value_format($harvest_date) ) {

                        my $harvest_date_cvterm_id = $self->get_harvest_date_cvterm_id();

                        my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create(
                                {
                                        project_id => $self->get_trial_id(),
                                        type_id => $harvest_date_cvterm_id,
                                        value => $harvest_event,
                                });

        if ($row) {
                                print STDERR "Removing harvest date $harvest_event from trial ".$self->get_trial_id()."\n";
                                $row->delete();
        }
                } else {
                        print STDERR "date format did not pass check while preparing to delete harvest date: $harvest_date  \n";
                }
}


=head2 accessors get_planting_date(), set_planting_date()

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_planting_date {
    my $self = shift;

    my $planting_date_cvterm_id = $self->get_planting_date_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find(
        {
            project_id => $self->get_trial_id(),
            type_id => $planting_date_cvterm_id,
        });

    my $calendar_funcs = CXGN::Calendar->new({});

    if ($row) {
        my $planting_date = $calendar_funcs->display_start_date($row->value());
        return $planting_date;
    } else {
        return;
    }
}

sub set_planting_date {
    my $self = shift;
    my $planting_date = shift;

    my $calendar_funcs = CXGN::Calendar->new({});

    if (my $planting_event = $calendar_funcs->check_value_format($planting_date) ) { # It should be a format : "YYYY/MM/DD HH:MM:SS" or "YYYY-MM-DD"

            my $planting_date_cvterm_id = $self->get_planting_date_cvterm_id();

            my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create(
                {
                    project_id => $self->get_trial_id(),
                    type_id => $planting_date_cvterm_id,
                });

            $row->value($planting_event);
            $row->update();
    } else {
                        print STDERR "date format did not pass check while preparing to set planting date: $planting_date \n";
                }
}

sub remove_planting_date {
    my $self = shift;
                my $planting_date = shift;

                my $calendar_funcs = CXGN::Calendar->new({});
    if (my $planting_event = $calendar_funcs->check_value_format($planting_date) ) {

                        my $planting_date_cvterm_id = $self->get_planting_date_cvterm_id();

                        my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create(
                                {
                                        project_id => $self->get_trial_id(),
                                        type_id => $planting_date_cvterm_id,
                                        value => $planting_event,
                                });

        if ($row) {
                                print STDERR "Removing planting date $planting_event from trial ".$self->get_trial_id()."\n";
                                $row->delete();
        }
                } else {
                        print STDERR "date format did not pass check while preparing to delete planting date: $planting_date  \n";
                }
}

=head2 accessors get_transplanting_date(), set_transplanting_date()

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_transplanting_date {
    my $self = shift;
    my $transplanting_date_cvterm_id = $self->get_transplanting_date_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find({
        project_id => $self->get_trial_id(),
        type_id => $transplanting_date_cvterm_id,
    });

    my $calendar_funcs = CXGN::Calendar->new({});
    if ($row){
        my $harvest_date = $calendar_funcs->display_start_date($row->value());
        return $harvest_date;
    } 
    else {
        return;
    }
}

sub set_transplanting_date {
    my $self = shift;
    my $transplanting_date = shift;
    my $calendar_funcs = CXGN::Calendar->new({});

    if (my $transplanting_event = $calendar_funcs->check_value_format($transplanting_date)) {
        my $transplanting_date_cvterm_id = $self->get_transplanting_date_cvterm_id();
        my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create({
            project_id => $self->get_trial_id(),
            type_id => $transplanting_date_cvterm_id,
        });
        $row->value($transplanting_event);
        $row->update();
    } 
    else{
        print STDERR "date format did not pass check while preparing to set transplanting date: $transplanting_date \n";
    }
}

sub remove_transplanting_date {
    my $self = shift;
    my $transplanting_date = shift;
    my $calendar_funcs = CXGN::Calendar->new({});
    if (my $transplanting_event = $calendar_funcs->check_value_format($transplanting_date) ) {
        my $transplanting_date_cvterm_id = $self->get_transplanting_date_cvterm_id();
        my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create({
            project_id => $self->get_trial_id(),
            type_id => $transplanting_date_cvterm_id,  
            value => $transplanting_event,
        });
        if ($row){
            print STDERR "Removing transplanting date $transplanting_event from trial ".$self->get_trial_id()."\n";
            $row->delete();
        }   
    } 
    else {
        print STDERR "date format did not pass check while preparing to delete transplanting date: $transplanting_date  \n";
    }
}


=head2 accessors get_temperature_averaged_gdd(), set_temperature_averaged_gdd()

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_temperature_averaged_gdd {
    my $self = shift;

    my $temperature_averaged_gdd_cvterm_id = $self->get_temperature_averaged_gdd_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find({
        project_id => $self->get_trial_id(),
        type_id => $temperature_averaged_gdd_cvterm_id,
    });

    if ($row) {
        return $row->value;
    } else {
        return;
    }
}

sub set_temperature_averaged_gdd {
    my $self = shift;
    my $temperature_averaged_gdd = shift;

    my $temperature_averaged_gdd_cvterm_id = $self->get_temperature_averaged_gdd_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create({
        project_id => $self->get_trial_id(),
        type_id => $temperature_averaged_gdd_cvterm_id,
    });
    $row->value($temperature_averaged_gdd);
    $row->update();
}

sub remove_temperature_averaged_gdd {
    my $self = shift;
    my $temperature_averaged_gdd = shift;

    my $temperature_averaged_gdd_cvterm_id = $self->get_temperature_averaged_gdd_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create({
        project_id => $self->get_trial_id(),
        type_id => $temperature_averaged_gdd_cvterm_id,
        value => $temperature_averaged_gdd,
    });
    if ($row) {
        print STDERR "Removing $temperature_averaged_gdd from trial ".$self->get_trial_id()."\n";
        $row->delete();
    }
}

sub get_temperature_averaged_gdd_cvterm_id {
    my $self = shift;
    return SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'drone_run_averaged_temperature_growing_degree_days', 'project_property')->cvterm_id();
}

=head2 accessors get_precipitation_averaged_sum_gdd(), set_precipitation_averaged_sum_gdd()

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_precipitation_averaged_sum_gdd {
    my $self = shift;

    my $precipitation_cvterm_id = $self->get_precipitation_averaged_sum_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find({
        project_id => $self->get_trial_id(),
        type_id => $precipitation_cvterm_id,
    });

    if ($row) {
        return $row->value;
    } else {
        return;
    }
}

sub set_precipitation_averaged_sum_gdd {
    my $self = shift;
    my $precipitation_averaged_sum = shift;

    my $precipitation_cvterm_id = $self->get_precipitation_averaged_sum_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create({
        project_id => $self->get_trial_id(),
        type_id => $precipitation_cvterm_id,
    });
    $row->value($precipitation_averaged_sum);
    $row->update();
}

sub remove_precipitation_averaged_sum {
    my $self = shift;
    my $precipitation = shift;

    my $precipitation_cvterm_id = $self->get_precipitation_averaged_sum_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create({
        project_id => $self->get_trial_id(),
        type_id => $precipitation_cvterm_id,
        value => $precipitation,
    });
    if ($row) {
        print STDERR "Removing $precipitation from trial ".$self->get_trial_id()."\n";
        $row->delete();
    }
}

sub get_precipitation_averaged_sum_cvterm_id {
    my $self = shift;
    return SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'drone_run_averaged_precipitation_sum', 'project_property')->cvterm_id();
}

=head2 accessors get_related_time_cvterms_json(), set_related_time_cvterms_json()

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_related_time_cvterms_json {
    my $self = shift;

    my $cvterm_id = $self->get_related_time_cvterms_json_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find({
        project_id => $self->get_trial_id(),
        type_id => $cvterm_id,
    });

    if ($row) {
        return $row->value;
    } else {
        return;
    }
}

sub set_related_time_cvterms_json {
    my $self = shift;
    my $related_time_terms_json = shift;

    my $cvterm_id = $self->get_related_time_cvterms_json_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create({
        project_id => $self->get_trial_id(),
        type_id => $cvterm_id,
    });
    $row->value($related_time_terms_json);
    $row->update();
}

sub remove_related_time_cvterms_json {
    my $self = shift;
    my $related_time_terms_json = shift;

    my $cvterm_id = $self->get_related_time_cvterms_json_cvterm_id();
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create({
        project_id => $self->get_trial_id(),
        type_id => $cvterm_id,
        value => $related_time_terms_json,
    });
    if ($row) {
        print STDERR "Removing $related_time_terms_json from trial ".$self->get_trial_id()."\n";
        $row->delete();
    }
}

sub get_related_time_cvterms_json_cvterm_id {
    my $self = shift;
    return SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'drone_run_related_time_cvterms_json', 'project_property')->cvterm_id();
}

=head2 function get_management_factor_date()

        Usage:        $trial->get_management_factor_date();
        Desc:         Field management factors are a project and are therefore instantiated with CXGN::Trial. this gets the date projectprop
        Ret:          Returns string
        Args:
        Side Effects:
        Example:

=cut

sub get_management_factor_date {
    my $self = shift;

    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find({
        project_id => $self->get_trial_id(),
        type_id => $self->get_mangement_factor_date_cvterm_id()
    });
    my $calendar_funcs = CXGN::Calendar->new({});

    if ($row) {
        return $calendar_funcs->display_start_date($row->value());
    } else {
        return;
    }
}

sub set_management_factor_date {
    my $self = shift;
    my $management_factor_date = shift;

    my $calendar_funcs = CXGN::Calendar->new({});

    if (my $management_factor_event = $calendar_funcs->check_value_format($management_factor_date) ) {
        my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create({
            project_id => $self->get_trial_id(),
            type_id => $self->get_mangement_factor_date_cvterm_id()
        });

        $row->value($management_factor_event);
        $row->update();
    } else {
        print STDERR "date format did not pass check while preparing to set management factor date: $management_factor_date \n";
    }
}

sub get_mangement_factor_date_cvterm_id {
    my $self = shift;
    return SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'management_factor_date', 'project_property')->cvterm_id();
}

sub get_mangement_factor_type_cvterm_id {
    my $self = shift;
    return SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'management_factor_type', 'project_property')->cvterm_id();
}

sub get_management_factor_type {
    my $self = shift;

    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find({
        project_id => $self->get_trial_id(),
        type_id => $self->get_mangement_factor_type_cvterm_id()
    });

    if ($row) {
        return $row->value();
    } else {
        return;
    }
}

sub set_management_factor_type {
    my $self = shift;
    my $management_factor_type = shift;

    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create({
        project_id => $self->get_trial_id(),
        type_id => $self->get_mangement_factor_type_cvterm_id()
    });

    $row->value($management_factor_type);
    $row->update();
}

=head2 accessors get_phenotypes_fully_uploaded(), set_phenotypes_fully_uploaded()

 Usage: When a trial's phenotypes have been fully upload, the user can set a projectprop called 'phenotypes_fully_uploaded' with a value of 1
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_phenotypes_fully_uploaded {
    my $self = shift;
    return $self->_get_projectprop('phenotypes_fully_uploaded');
}

sub set_phenotypes_fully_uploaded {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('phenotypes_fully_uploaded', $value);
}

=head2 accessors get_raw_data_link(), set_raw_data_link()

 Usage: For genotyping plates, a genotyping facility can be set as a projectprop value e.g. 'igd'
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_raw_data_link {
    my $self = shift;
    return $self->_get_projectprop('raw_data_link');
}

sub set_raw_data_link {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('raw_data_link', $value);
}


=head2 accessors get_genotyping_facility(), set_genotyping_facility()

 Usage: For genotyping plates, a genotyping facility can be set as a projectprop value e.g. 'igd'
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_genotyping_facility {
    my $self = shift;
    return $self->_get_projectprop('genotyping_facility');
}

sub set_genotyping_facility {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('genotyping_facility', $value);
}

=head2 accessors get_genotyping_facility_submitted(), set_genotyping_facility_submitted()

 Usage: For genotyping plates, if a genotyping plate has been submitted to genotyping facility and the plate is stored in out system, this stockprop can be set to 'yes'
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_genotyping_facility_submitted {
    my $self = shift;
    return $self->_get_projectprop('genotyping_facility_submitted');
}

sub set_genotyping_facility_submitted {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('genotyping_facility_submitted', $value);
}

=head2 accessors get_genotyping_facility_status(), set_genotyping_facility_status()

 Usage: For genotyping plates, if a genotyping plate has been submitted to genotyping facility, the status of that plate can be set here
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_genotyping_facility_status {
    my $self = shift;
    return $self->_get_projectprop('genotyping_facility_status');
}

sub set_genotyping_facility_status {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('genotyping_facility_status', $value);
}

=head2 accessors get_genotyping_vendor_order_id(), set_genotyping_vendor_order_id()

 Usage: For genotyping plates, if a genotyping plate has been submitted to genotyping facility, the order id of that plate can be set here
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_genotyping_vendor_order_id {
    my $self = shift;
    return $self->_get_projectprop('genotyping_vendor_order_id');
}

sub set_genotyping_vendor_order_id {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('genotyping_vendor_order_id', $value);
}

=head2 accessors get_genotyping_vendor_submission_id(), set_genotyping_vendor_submission_id()

 Usage: For genotyping plates, if a genotyping plate has been submitted to genotyping facility, the order id of that plate can be set here
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_genotyping_vendor_submission_id {
    my $self = shift;
    return $self->_get_projectprop('genotyping_vendor_submission_id');
}

sub set_genotyping_vendor_submission_id {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('genotyping_vendor_submission_id', $value);
}

=head2 accessors get_genotyping_plate_format(), set_genotyping_plate_format()

 Usage: For genotyping plates, this records if it is 96 wells or 384 or other
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_genotyping_plate_format {
    my $self = shift;
    return $self->_get_projectprop('genotyping_plate_format');
}

sub set_genotyping_plate_format {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('genotyping_plate_format', $value);
}

=head2 accessors get_genotyping_plate_sample_type(), set_genotyping_plate_sample_type()

 Usage: For genotyping plates, this records sample type of plate e.g. DNA
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_genotyping_plate_sample_type {
    my $self = shift;
    return $self->_get_projectprop('genotyping_plate_sample_type');
}

sub set_genotyping_plate_sample_type {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('genotyping_plate_sample_type', $value);
}

=head2 accessors get_field_trial_is_planned_to_be_genotyped(), set_field_trial_is_planned_to_be_genotyped()

 Usage: For field trials, this records whether the trial will be genotyped
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_field_trial_is_planned_to_be_genotyped {
    my $self = shift;
    return $self->_get_projectprop('field_trial_is_planned_to_be_genotyped');
}

sub set_field_trial_is_planned_to_be_genotyped {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('field_trial_is_planned_to_be_genotyped', $value);
}

=head2 accessors get_field_trial_is_planned_to_cross(), set_field_trial_is_planned_to_cross()

 Usage: For field trials, this records whether the trial will be involved in crosses
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_field_trial_is_planned_to_cross {
    my $self = shift;
    return $self->_get_projectprop('field_trial_is_planned_to_cross');
}

sub set_field_trial_is_planned_to_cross {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('field_trial_is_planned_to_cross', $value);
}

=head2 accessors get_plot_width(), set_plot_width()

 Usage: For field trials, this records plot width in meters
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_plot_width {
    my $self = shift;
    return $self->_get_projectprop('plot_width');
}

sub set_plot_width {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('plot_width', $value);
}

=head2 accessors get_plot_length(), set_plot_length()

 Usage: For field trials, this records plot length in meters
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_plot_length {
    my $self = shift;
    return $self->_get_projectprop('plot_length');
}

sub set_plot_length {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('plot_length', $value);
}

=head2 accessors get_field_size(), set_field_size()

 Usage: For field trials, this recordsfield size in hectares
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_field_size {
    my $self = shift;
    return $self->_get_projectprop('field_size');
}

sub set_field_size {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('field_size', $value);
}

=head2 accessors get_additional_info(), set_additional_info()

 Usage: For field trials, this stores brapi additional information
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_additional_info {
    my $self = shift;
    my $additional_info = $self->_get_projectprop('project_additional_info');
    return $additional_info ? decode_json($additional_info) : undef;
}

sub set_additional_info {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('project_additional_info', encode_json($value));
}

=head2 accessors get_entry_numbers(), set_entry_numbers()

 Usage: For field trials, this records a map of stock ids to entry numbers
 Desc: The value of this projectprop is stored as a JSON object, where the
 key is the stock id and the value is the stock entry number
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_entry_numbers {
    my $self = shift;
    my $value = $self->_get_projectprop('project_entry_number_map');
    return $value ? decode_json($value) : undef;
}

sub set_entry_numbers {
    my $self = shift;
    my $value = shift;
    $self->_set_projectprop('project_entry_number_map', encode_json($value));
}

sub _get_projectprop {
    my $self = shift;
    my $term = shift;
    my $cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, $term, 'project_property')->cvterm_id;
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find({
        project_id => $self->get_trial_id(),
        type_id => $cvterm_id,
    });

    if ($row) {
        return $row->value;
    } else {
        return;
    }
}

sub _set_projectprop {
    my $self = shift;
    my $term = shift;
    my $value = shift;
    my $cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, $term, 'project_property')->cvterm_id;
    my $row = $self->bcs_schema->resultset('Project::Projectprop')->find_or_create({
        project_id => $self->get_trial_id(),
        type_id => $cvterm_id,
    });
    $row->value($value);
    $row->update();
}

sub get_owner_link {
    my $self = shift;
    my $owners = $self->_get_trial_owners();
    my @sp_person_ids = keys % { $owners } ;
    my $q = "SELECT first_name, last_name FROM sgn_people.sp_person WHERE sp_person_id=?;";
    my $link;
    foreach my $sp_person_id (@sp_person_ids) {
        my $h = $self->bcs_schema()->storage->dbh()->prepare($q);
        $h->execute($sp_person_id);
        my ( $first_name, $last_name )  = $h->fetchrow_array();
        my $create_date = ${ $owners }{$sp_person_id};

        $link .= '<a href="/solpeople/personal-info.pl?sp_person_id='.$sp_person_id. '">' . $first_name . " " . $last_name .  "</a> ". $create_date . "<br />";
    }
    return $link;
}

sub _get_trial_owners {
    my $self = shift;
    my $schema = $self->bcs_schema();
    my $owner_q = "SELECT sp_person_id, date(create_date) FROM phenome.project_owner WHERE project_id = ? ";
    my $owner_h = $schema->storage->dbh()->prepare($owner_q);
    $owner_h ->execute($self->get_trial_id());

    my %owners;
    while (my ($sp_person_id, $create_date) = $owner_h->fetchrow_array()) {
        $owners{$sp_person_id} = $create_date;
    }
    return \%owners;
}

sub set_trial_owner {
    my $self = shift;
    my $sp_person_id = shift;
    my $schema = $self->bcs_schema();
    my $trial_id = $self->get_trial_id();
    my $q = "INSERT INTO phenome.project_owner (project_id, sp_person_id, create_date) VALUES (?,?,now())";
    my $h =  $schema->storage->dbh()->prepare($q);
    $h->execute($trial_id,$sp_person_id);
}

=head2 function delete_phenotype_data()

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

# note: you may need to delete the metadata before deleting the phenotype data (see function).
# this function has a test!
#
sub delete_phenotype_data {
    my $self = shift;
    my $basepath = shift;
    my $dbhost = shift;
    my $dbname = shift;
    my $dbuser = shift;
    my $dbpass = shift;
    my $temp_file_nd_experiment_id = shift;

    my $trial_id = $self->get_trial_id();
    my $nd_experiment_type_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'phenotyping_experiment', 'experiment_type')->cvterm_id();

    my $q_search = "
        SELECT phenotype_id, nd_experiment_id, file_id
        FROM phenotype
        JOIN nd_experiment_phenotype using(phenotype_id)
        JOIN nd_experiment using(nd_experiment_id)
        JOIN nd_experiment_stock using(nd_experiment_id)
        JOIN nd_experiment_project using(nd_experiment_id)
        LEFT JOIN phenome.nd_experiment_md_files using(nd_experiment_id)
        JOIN stock using(stock_id)
        WHERE project_id = $trial_id
        AND nd_experiment.type_id = $nd_experiment_type_id;
        ";
    my $h = $self->bcs_schema->storage->dbh()->prepare($q_search);
    $h->execute();

    my %phenotype_ids_and_nd_experiment_ids_to_delete;
    while (my ($phenotype_id, $nd_experiment_id, $file_id) = $h->fetchrow_array()) {
        push @{$phenotype_ids_and_nd_experiment_ids_to_delete{phenotype_ids}}, $phenotype_id;
        push @{$phenotype_ids_and_nd_experiment_ids_to_delete{nd_experiment_ids}}, $nd_experiment_id;
    }
    return delete_phenotype_values_and_nd_experiment_md_values($dbhost, $dbname, $dbuser, $dbpass, $temp_file_nd_experiment_id, $basepath, $self->bcs_schema, \%phenotype_ids_and_nd_experiment_ids_to_delete);
}

#Class function
sub delete_phenotype_values_and_nd_experiment_md_values {
    my $dbhost = shift;
    my $dbname = shift;
    my $dbuser = shift;
    my $dbpass = shift;
    my $temp_file_nd_experiment_id = shift;
    my $basepath = shift;
    my $schema = shift;
    my $phenotype_ids_and_nd_experiment_ids_to_delete = shift;

    my $coderef = sub {
        my $phenotype_id_sql = join (",", @{$phenotype_ids_and_nd_experiment_ids_to_delete->{phenotype_ids}});
        my $q_pheno_delete = "DELETE FROM phenotype WHERE phenotype_id IN ($phenotype_id_sql);";
        my $h2 = $schema->storage->dbh()->prepare($q_pheno_delete);
        $h2->execute();

        print STDERR "DELETED ".scalar(@{$phenotype_ids_and_nd_experiment_ids_to_delete->{phenotype_ids}})." Phenotype Values\n";

        my $nd_experiment_id_sql = join (",", @{$phenotype_ids_and_nd_experiment_ids_to_delete->{nd_experiment_ids}});

        # check if the nd_experiment has no other associated phenotypes, since phenotypstore actually attaches many phenotypes to one nd_experiment
        #
        my $checkq = "SELECT nd_experiment_id FROM nd_experiment left join nd_experiment_phenotype using(nd_experiment_id) where nd_experiment_id in ($nd_experiment_id_sql) and phenotype_id IS NULL";
        my $check_h = $schema->storage->dbh()->prepare($checkq);
        $check_h ->execute();

        my @nd_experiment_ids;
        while (my ($nd_experiment_id) = $check_h->fetchrow_array()) {
            push @nd_experiment_ids, $nd_experiment_id;
        }

        if (scalar(@nd_experiment_ids)>0) {
            $nd_experiment_id_sql = join(",", @nd_experiment_ids);

            my $q_nd_exp_files_delete = "DELETE FROM phenome.nd_experiment_md_files WHERE nd_experiment_id IN ($nd_experiment_id_sql);";
            my $h3 = $schema->storage->dbh()->prepare($q_nd_exp_files_delete);
            $h3->execute();

            my $q_nd_json = "DELETE FROM phenome.nd_experiment_md_json WHERE nd_experiment_id IN ($nd_experiment_id_sql)";
            my $h_nd_json = $schema->storage->dbh()->prepare($q_nd_json);
            $h_nd_json->execute();

            my $q_nd_exp_files_images_delete = "DELETE FROM phenome.nd_experiment_md_images WHERE nd_experiment_id IN ($nd_experiment_id_sql);";
            my $h4 = $schema->storage->dbh()->prepare($q_nd_exp_files_images_delete);
            $h4->execute();

            open (my $fh, ">", $temp_file_nd_experiment_id ) || print STDERR  ("\nWARNING: the file $temp_file_nd_experiment_id could not be found\n" );
                foreach (@nd_experiment_ids) {
                    print $fh "$_\n";
                }
            close($fh);

            my $async_delete = CXGN::Tools::Run->new();
            $async_delete->run_async("perl $basepath/bin/delete_nd_experiment_entries.pl -H $dbhost -D $dbname -U $dbuser -P $dbpass -i $temp_file_nd_experiment_id");

            print STDERR "DELETED ".scalar(@{$phenotype_ids_and_nd_experiment_ids_to_delete->{phenotype_ids}})." Phenotype Values and nd_experiment_md_file_links (and ".scalar(@nd_experiment_ids)." nd_experiment entries may still be in deletion in asynchronous process.)\n";
        }
    };

    my $error;
    try {
        $schema->txn_do($coderef);
    } catch {
        print STDERR "ERROR: $_\n";
        $error =  $_;
    };
    return $error;
}

=head2 function delete_field_layout()

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut


# this function has a test!
#
sub delete_field_layout {
    my $self = shift;

    my $trial_id = $self->get_trial_id();

    if (scalar(@{$self->get_genotyping_trials_from_field_trial}) > 0) {
        return 'This field trial has been linked to genotyping trials already, and cannot be easily deleted.';
    }
    if (scalar(@{$self->get_field_trials_source_of_genotyping_trial}) > 0) {
        return 'This genotyping trial has been linked to field trials already, and cannot be easily deleted.';
    }
    if (scalar(@{$self->get_crossing_trials_from_field_trial}) >0) {
        return 'This field trial has been linked to crossing trials already, and cannot be easily deleted.';
    }
    if (scalar(@{$self->get_field_trials_source_of_crossing_trial}) >0) {
        return 'This crossing trial has been linked to field trials already, and cannot be easily deleted.';
    }

    # Note: metadata entries need to be deleted separately using delete_metadata()
    #
    my $error = '';
    eval {
        $self->bcs_schema()->txn_do(
            sub {
                #print STDERR "DELETING FIELD LAYOUT FOR TRIAL $trial_id...\n";
                $self->_delete_field_layout_experiment();
                #print STDERR "DELETE MANAGEMENT FACTORS FOR TRIAL $trial_id...\n";
                $self->_delete_management_factors_experiments();
            }
        );
    };
    if ($@) {
        print STDERR "ERROR $@\n";
        return "An error occurred: $@\n";
    }

    return '';
}

=head2 function get_phenotype_metadata()

 Usage:        $trial->get_phenotype_metadata();
 Desc:         retrieves metadata.md_file entries for this trial. These entries are created during StorePhenotypes
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_phenotype_metadata {
        my $self = shift;
        my $trial_id = $self->get_trial_id();
        my @file_array;
        my %file_info;
        my $q = "SELECT file_id, m.create_date, p.sp_person_id, p.username, basename, dirname, filetype FROM nd_experiment_project JOIN nd_experiment_phenotype USING(nd_experiment_id) JOIN phenome.nd_experiment_md_files ON (nd_experiment_phenotype.nd_experiment_id=nd_experiment_md_files.nd_experiment_id) LEFT JOIN metadata.md_files using(file_id) LEFT JOIN metadata.md_metadata as m using(metadata_id) LEFT JOIN sgn_people.sp_person as p ON (p.sp_person_id=m.create_person_id) WHERE project_id=? and m.obsolete = 0 and NOT (metadata.md_files.filetype='generated from plot from plant phenotypes') and NOT (metadata.md_files.filetype='direct phenotyping') ORDER BY file_id ASC";
        my $h = $self->bcs_schema->storage()->dbh()->prepare($q);
        $h->execute($trial_id);

        while (my ($file_id, $create_date, $person_id, $username, $basename, $dirname, $filetype) = $h->fetchrow_array()) {
                $file_info{$file_id} = [$file_id, $create_date, $person_id, $username, $basename, $dirname, $filetype];
        }
        foreach (keys %file_info){
                push @file_array, $file_info{$_};
        }
        return \@file_array;
}

=head2 function delete_phenotype_metadata()

 Usage:        $trial->delete_phenotype_metadata($metadata_schema, $phenome_schema);
 Desc:         obsoletes the metadata entries for this trial.
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub delete_phenotype_metadata {
    my $self = shift;
    my $metadata_schema = shift;
    my $phenome_schema = shift;

    if (!$metadata_schema || !$phenome_schema) { die "Need metadata schema parameter\n"; }

    my $trial_id = $self->get_trial_id();

    #print STDERR "Deleting metadata for trial $trial_id...\n";

    # first, deal with entries in the md_metadata table, which may reference nd_experiment (through linking table)
    #
    my $q = "SELECT distinct(metadata_id) FROM nd_experiment_project JOIN nd_experiment_phenotype USING(nd_experiment_id) LEFT JOIN phenome.nd_experiment_md_files ON (nd_experiment_phenotype.nd_experiment_id=nd_experiment_md_files.nd_experiment_id) LEFT JOIN metadata.md_files using(file_id) LEFT JOIN metadata.md_metadata using(metadata_id) WHERE project_id=?";
    my $h = $self->bcs_schema->storage()->dbh()->prepare($q);
    $h->execute($trial_id);

    while (my ($md_id) = $h->fetchrow_array()) {
        #print STDERR "Associated metadata id: $md_id\n";
        my $mdmd_row = $metadata_schema->resultset("MdMetadata")->find( { metadata_id => $md_id } );
        if ($mdmd_row) {
            #print STDERR "Obsoleting $md_id...\n";

            $mdmd_row -> update( { obsolete => 1 });
        }
    }

    #print STDERR "Deleting the entries in the linking table...\n";

    # delete the entries from the linking table...
    $q = "SELECT distinct(file_id) FROM nd_experiment_project JOIN nd_experiment_phenotype USING(nd_experiment_id) JOIN phenome.nd_experiment_md_files ON (nd_experiment_phenotype.nd_experiment_id=nd_experiment_md_files.nd_experiment_id) LEFT JOIN metadata.md_files using(file_id) LEFT JOIN metadata.md_metadata using(metadata_id) WHERE project_id=?";
    $h = $self->bcs_schema->storage()->dbh()->prepare($q);
    $h->execute($trial_id);

    while (my ($file_id) = $h->fetchrow_array()) {
        print STDERR "trying to delete association for file with id $file_id...\n";
        my $ndemdf_rs = $phenome_schema->resultset("NdExperimentMdFiles")->search( { file_id=>$file_id });
        print STDERR "Deleting md_files linking table entries...\n";
        foreach my $row ($ndemdf_rs->all()) {
            print STDERR "DELETING !!!!\n";
            $row->delete();
        }
    }
}



=head2 function delete_metadata()

 Usage:        $trial->delete_metadata();
 Desc:         obsoletes the metadata entries for this trial.
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub delete_metadata {
    my $self = shift;
    my $metadata_schema = $self->metadata_schema;
    my $phenome_schema = $self->phenome_schema;

    if (!$metadata_schema || !$phenome_schema) { die "Need metadata schema parameter\n"; }

    my $trial_id = $self->get_trial_id();

    if (scalar(@{$self->get_genotyping_trials_from_field_trial}) > 0) {
        return 'This field trial has been linked to genotyping trials already, and cannot be easily deleted.';
    }
    if (scalar(@{$self->get_field_trials_source_of_genotyping_trial}) > 0) {
        return 'This genotyping trial has been linked to field trials already, and cannot be easily deleted.';
    }
    if (scalar(@{$self->get_crossing_trials_from_field_trial}) >0) {
        return 'This field trial has been linked to crossing trials already, and cannot be easily deleted.';
    }
    if (scalar(@{$self->get_field_trials_source_of_crossing_trial}) >0) {
        return 'This crossing trial has been linked to field trials already, and cannot be easily deleted.';
    }

    #print STDERR "Deleting metadata for trial $trial_id...\n";

    # first, deal with entries in the md_metadata table, which may reference nd_experiment (through linking table)
    #
    my $q = "SELECT distinct(metadata_id) FROM nd_experiment_project JOIN phenome.nd_experiment_md_files using(nd_experiment_id) LEFT JOIN metadata.md_files using(file_id) LEFT JOIN metadata.md_metadata using(metadata_id) WHERE project_id=?";
    my $h = $self->bcs_schema->storage()->dbh()->prepare($q);
    $h->execute($trial_id);

    while (my ($md_id) = $h->fetchrow_array()) {
        #print STDERR "Associated metadata id: $md_id\n";
        my $mdmd_row = $metadata_schema->resultset("MdMetadata")->find( { metadata_id => $md_id } );
        if ($mdmd_row) {
            #print STDERR "Obsoleting $md_id...\n";

            $mdmd_row -> update( { obsolete => 1 });
        }
    }

    #print STDERR "Deleting the entries in the linking table...\n";

    # delete the entries from the linking table... (left joins are due to sometimes missing md_file entries)
    $q = "SELECT distinct(file_id) FROM nd_experiment_project LEFT JOIN phenome.nd_experiment_md_files using(nd_experiment_id) LEFT JOIN metadata.md_files using(file_id) LEFT JOIN metadata.md_metadata using(metadata_id) WHERE project_id=?";
    $h = $self->bcs_schema->storage()->dbh()->prepare($q);
    $h->execute($trial_id);

    while (my ($file_id) = $h->fetchrow_array()) {
        print STDERR "trying to delete association for file with id $file_id...\n";
        my $ndemdf_rs = $phenome_schema->resultset("NdExperimentMdFiles")->search( { file_id=>$file_id });
        print STDERR "Deleting md_files linking table entries...\n";
        foreach my $row ($ndemdf_rs->all()) {
            print STDERR "DELETING !!!!\n";
            $row->delete();
        }
    }
}


sub _delete_field_layout_experiment {
    my $self = shift;

    my $trial_id = $self->get_trial_id();

    print STDERR "_delete_field_layout_experiment...\n";

    # check if there are still associated phenotypes...
    #
    if ($self->phenotype_count() > 0) {
        print STDERR "Attempt to delete field layout that still has associated phenotype data.\n";
        die "cannot delete because of associated phenotypes\n";
        return { error => "Trial still has associated phenotyping experiment, cannot delete." };
    }

    my $field_layout_type_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'field_layout', 'experiment_type')->cvterm_id();
    my $genotyping_layout_type_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'genotyping_layout', 'experiment_type')->cvterm_id();
    my $analysis_experiment_type_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'analysis_experiment', 'experiment_type')->cvterm_id();

    my $layout_design = $self->get_layout->get_design;
    my @all_stock_ids;
    while( my($plot_num, $design_info) = each %$layout_design){
        my $plot_id = $design_info->{plot_id}; #this includes the "tissue_sample" in "genotyping_layout"
        my @plant_ids = $design_info->{plant_ids} ? @{$design_info->{plant_ids}} : ();
        my @subplot_ids = $design_info->{subplot_ids} ? @{$design_info->{subplot_ids}} : ();
        my @tissue_sample_ids = $design_info->{tissue_sample_ids} ? @{$design_info->{tissue_sample_ids}} : ();
        push @all_stock_ids, $plot_id;
        push @all_stock_ids, @plant_ids;
        push @all_stock_ids, @tissue_sample_ids;
        push @all_stock_ids, @subplot_ids;
    }

    my $phenome_schema = CXGN::Phenome::Schema->connect( sub {
            $self->bcs_schema->storage->dbh()
        },
        {
            on_connect_do => ['SET search_path TO public,phenome;']
        });
    foreach my $s (@all_stock_ids) {
        my $stock_owner_rs = $phenome_schema->resultset('StockOwner')->search({stock_id=>$s});
        while (my $stock_row = $stock_owner_rs->next) {
            $stock_row->delete();
        }
        my $stock_delete_rs = $self->bcs_schema->resultset('Stock::Stock')->search({stock_id=>$s});
        while (my $r = $stock_delete_rs->next){
            $r->delete();
        }
    }


    my $has_plants = $self->has_plant_entries();
    my $has_subplots = $self->has_subplot_entries();
    my $has_tissues = $self->has_tissue_sample_entries();

    if ($has_plants) {
        my $has_plants_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'project_has_plant_entries', 'project_property' )->cvterm_id();
        my $has_plants_prop = $self->bcs_schema->resultset("Project::Projectprop")->find({ type_id => $has_plants_cvterm_id, project_id => $trial_id });
        $has_plants_prop->delete();
    }
    if ($has_subplots) {
        my $has_subplots_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'project_has_subplot_entries', 'project_property' )->cvterm_id();
        my $has_subplots_prop = $self->bcs_schema->resultset("Project::Projectprop")->find({ type_id => $has_subplots_cvterm_id, project_id => $trial_id });
        $has_subplots_prop->delete();
    }
    if ($has_tissues) {
        my $has_tissues_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'project_has_tissue_sample_entries', 'project_property' )->cvterm_id();
        my $has_tissues_prop = $self->bcs_schema->resultset("Project::Projectprop")->find({ type_id => $has_tissues_cvterm_id, project_id => $trial_id });
        $has_tissues_prop->delete();
    }

    my $trial_layout_json_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'trial_layout_json', 'project_property')->cvterm_id();
    my $has_cached_layout_prop = $self->bcs_schema->resultset("Project::Projectprop")->find({ type_id => $trial_layout_json_cvterm_id, project_id => $trial_id });
    if ($has_cached_layout_prop){
        $has_cached_layout_prop->delete();
    }

    my $nde_rs = $self->bcs_schema()->resultset("NaturalDiversity::NdExperiment")->search({ 'me.type_id'=>[$field_layout_type_id, $genotyping_layout_type_id, $analysis_experiment_type_id], 'project.project_id'=>$trial_id }, {'join'=>{'nd_experiment_projects'=>'project'}});
    if ($nde_rs->count != 1){
        die "Project $trial_id does not have exactly one ndexperiment of type field_layout or genotyping_layout!"
    }
    while( my $r = $nde_rs->next){
        $r->delete();
    }

    #return { success => $plots_deleted };
    return { success => 1 };
}

sub _delete_management_factors_experiments {
    my $self = shift;
    my $management_factor_type_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'treatment_experiment', 'experiment_type')->cvterm_id();
    my $management_factors = $self->get_treatments;
    foreach (@$management_factors){
        my $m = CXGN::Trial->new({
            bcs_schema => $self->bcs_schema,
            metadata_schema => $self->metadata_schema,
            phenome_schema => $self->phenome_schema,
            trial_id => $_->[0]
        });
        my $nde_rs = $self->bcs_schema()->resultset("NaturalDiversity::NdExperiment")->search({ 'me.type_id'=>$management_factor_type_id, 'project.project_id'=>$m->get_trial_id }, {'join'=>{'nd_experiment_projects'=>'project'}});
        if ($nde_rs->count != 1){
            die "Management factor ".$m->get_name." does not have exactly one ndexperiment of type treatment_experiment!"
        }
        while( my $r = $nde_rs->next){
            $r->delete();
        }
        $m->delete_project_entry;
    }
    return { success => 1 };
}

=head2 function delete_project_entry()

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub delete_project_entry {
    my $self = shift;

    if ($self->phenotype_count() > 0) {
        print STDERR "Cannot delete trial with associated phenotypes.\n";
        return;
    }

    if (scalar(@{$self->get_genotyping_trials_from_field_trial}) > 0) {
        return 'This field trial has been linked to genotyping trials already, and cannot be easily deleted.';
    }
    if (scalar(@{$self->get_field_trials_source_of_genotyping_trial}) > 0) {
        return 'This genotyping trial has been linked to field trials already, and cannot be easily deleted.';
    }
    if (scalar(@{$self->get_crossing_trials_from_field_trial}) >0) {
        return 'This field trial has been linked to crossing trials already, and cannot be easily deleted.';
    }
    if (scalar(@{$self->get_field_trials_source_of_crossing_trial}) >0) {
        return 'This crossing trial has been linked to field trials already, and cannot be easily deleted.';
    }

    my $project_owner_schema = CXGN::Phenome::Schema->connect( sub {
            $self->bcs_schema->storage->dbh()
        },
        {
            on_connect_do => ['SET search_path TO public,phenome;']
        });
    my $project_owner_row = $project_owner_schema->resultset('ProjectOwner')->find( { project_id=> $self->get_trial_id() });
    if ($project_owner_row) { $project_owner_row->delete(); }
    eval {
            my $row = $self->bcs_schema->resultset("Project::Project")->find( { project_id=> $self->get_trial_id() });
            $row->delete();
        print STDERR "deleted project ".$self->get_trial_id."\n";
    };
    if ($@) {
            print STDERR "An error occurred during deletion: $@\n";
            return $@;
    }
}

=head2 function phenotype_count()

 Usage:
 Desc:         The number of phenotype measurements associated with this trial
 Ret:
 Args:
 Side Effects:
 Example:

=cut


sub phenotype_count {
    my $self = shift;
    my $phenotyping_experiment_type_id = $self->bcs_schema->resultset("Cv::Cvterm")->find( { name => 'phenotyping_experiment' })->cvterm_id();

    my $q = "SELECT count(phenotype_id)
        FROM phenotype
        JOIN nd_experiment_phenotype using(phenotype_id)
        JOIN nd_experiment_project using(nd_experiment_id)
        JOIN nd_experiment using(nd_experiment_id)
        JOIN project using(project_id)
        WHERE nd_experiment.type_id = $phenotyping_experiment_type_id
        AND project_id = ?;";
    my $h = $self->bcs_schema->storage->dbh()->prepare($q);
    $h->execute($self->get_trial_id());
    my ($count) = $h->fetchrow_array();
    return $count;
}


=head2 function total_phenotypes()

 Usage:
 Desc:         returns the total number of phenotype measurements
               associated with the trial
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub total_phenotypes {
    my $self = shift;

    my $pt_rs = $self->bcs_schema()->resultset("Phenotype::Phenotype")->search( { });
    return $pt_rs->count();
}

=head2 function add_additional_uploaded_file()

 Usage:        $trial->add_additional_uploaded_file();
 Desc:         adds metadata.md_file entry for additional_files_uploaded to trial
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub add_additional_uploaded_file {
    my $self = shift;
    my $user_id = shift;
    my $archived_filename_with_path = shift;
    my $md5checksum = shift;
    my $result = $self->get_nd_experiment_id();
    if ($result->{error}){
        return {error => $result->{error} };
    }
    my $nd_experiment_id = $result->{nd_experiment_id};

    my $md_row = $self->metadata_schema->resultset("MdMetadata")->create({create_person_id => $user_id});
    $md_row->insert();
    my $file_row = $self->metadata_schema->resultset("MdFiles")
        ->create({
            basename => basename($archived_filename_with_path),
            dirname => dirname($archived_filename_with_path),
            filetype => 'trial_additional_file_upload',
            md5checksum => $md5checksum,
            metadata_id => $md_row->metadata_id(),
        });
    my $file_id = $file_row->file_id();
    my $experiment_file = $self->phenome_schema->resultset("NdExperimentMdFiles")
        ->create({
            nd_experiment_id => $nd_experiment_id,
            file_id => $file_id,
        });

    return {success => 1, file_id=>$file_id};
}

=head2 function get_additional_uploaded_files()

 Usage:        $trial->get_additional_uploaded_files();
 Desc:         retrieves metadata.md_file entries for additional_files_uploaded to trial. these entries are created from add_additional_uploaded_file
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_additional_uploaded_files {
    my $self = shift;
    my $trial_id = $self->get_trial_id();
    my @file_array;
    my %file_info;
    my $q = "SELECT file_id, m.create_date, p.sp_person_id, p.username, basename, dirname, filetype FROM project JOIN nd_experiment_project USING(project_id) JOIN phenome.nd_experiment_md_files ON (nd_experiment_project.nd_experiment_id=nd_experiment_md_files.nd_experiment_id) LEFT JOIN metadata.md_files using(file_id) LEFT JOIN metadata.md_metadata as m using(metadata_id) LEFT JOIN sgn_people.sp_person as p ON (p.sp_person_id=m.create_person_id) WHERE project_id=? and m.obsolete = 0 and metadata.md_files.filetype='trial_additional_file_upload' ORDER BY file_id ASC";
    my $h = $self->bcs_schema->storage()->dbh()->prepare($q);
    $h->execute($trial_id);

    while (my ($file_id, $create_date, $person_id, $username, $basename, $dirname, $filetype) = $h->fetchrow_array()) {
        $file_info{$file_id} = [$file_id, $create_date, $person_id, $username, $basename, $dirname, $filetype];
    }
    foreach (keys %file_info){
        push @file_array, $file_info{$_};
    }
    return \@file_array;
}



=head2 obsolete_additional_uploaded_file

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub obsolete_additional_uploaded_file {
    my $self = shift;
    my $file_id = shift;
    my $user_id = shift;
    my $role = shift;

    my @errors;
    # check ownership of that image
    my $q = "SELECT metadata.md_metadata.create_person_id, metadata.md_metadata.metadata_id, metadata.md_files.file_id FROM metadata.md_metadata join metadata.md_files using(metadata_id) where md_metadata.obsolete=0 and md_files.file_id=? and md_metadata.create_person_id=?";

    my $dbh = $self->bcs_schema->storage()->dbh();
    my $h = $dbh->prepare($q);

    $h->execute($file_id, $user_id);

    if (my ($create_person_id, $metadata_id, $file_id) = $h->fetchrow_array()) {
        if ($create_person_id == $user_id || $role eq "curator") {
            my $uq = "UPDATE metadata.md_metadata SET obsolete=1 where metadata_id = ?";
            my $uh = $dbh->prepare($uq);
            $uh->execute($metadata_id);
        }
        else {
            push @errors, "Only the owner of the uploaded file, or a curator, can delete this file.";
        }

    }
    else {
        push @errors, "No such file currently exists.";
    }

    if (@errors >0) {
        return { errors => \@errors };
    }

    return { success => 1 };



}



=head2 function get_phenotypes_for_trait($trait_id)

 Usage:
 Desc:         returns the measurements for the given trait in this trial as an array of values, e.g. [2.1, 2, 50]
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_phenotypes_for_trait {
    my $self = shift;
    my $trait_id = shift;
    my $stock_type = shift;
    my @data;
    my $dbh = $self->bcs_schema->storage()->dbh();
        #my $schema = $self->bcs_schema();

        my $h;
        my $join_string = '';
        my $where_string = '';
        if ($stock_type) {
                my $stock_type_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, $stock_type, 'stock_type')->cvterm_id();
                $join_string = 'JOIN nd_experiment_stock USING(nd_experiment_id) JOIN stock USING(stock_id)';
                $where_string = "stock.type_id=$stock_type_id and";
        }
        my $q = "SELECT phenotype.value::real FROM cvterm JOIN phenotype ON (cvterm_id=cvalue_id) JOIN nd_experiment_phenotype USING(phenotype_id) JOIN nd_experiment_project USING(nd_experiment_id) $join_string WHERE $where_string project_id=? and cvterm.cvterm_id = ? and phenotype.value~? ORDER BY phenotype_id ASC;";
        $h = $dbh->prepare($q);

    my $numeric_regex = '^-?[0-9]+([,.][0-9]+)?$';
    $h->execute($self->get_trial_id(), $trait_id, $numeric_regex );
    while (my ($value) = $h->fetchrow_array()) {
           push @data, $value + 0;
    }
    return @data;
}

=head2 function get_stock_phenotypes_for_traits(\@trait_id, 'all', ['plot_of','plant_of'], 'accession', 'subject')

 Usage:
 Desc:         returns all observations for the given traits in this trial
 Ret:                   arrayref of [[ $stock_id, $stock_name, $trait_id, $trait_name, $phenotype_id, $pheno_uniquename, $uploader_id, $value, $rel_stock_id, $rel_stock_name ], [], ...]
 Args:                  trait_ids : arrayref of cvterm_ids
                                stock_type: the stock type that the phenotype is associated to. 'plot', or 'plant', or 'all'
                                stock_relationships: for fetching stock_relationships of the phenotyped stock. arrayref of relationships. e.g. ['plot_of', 'plant_of'].
                                relationship_stock_type: the associated stock_type from the stock_relationship. 'plot', or 'plant'
                                subject_or_object: whether the stock_relationship join should be done from the subject or object side. 'subject', or 'object'
 Side Effects:
 Example:

=cut

sub get_stock_phenotypes_for_traits {
    my $self = shift;
    my $trait_ids = shift;
    my $stock_type = shift; #plot, plant, all
    my $stock_relationships = shift; #arrayref. plot_of, plant_of
    my $relationship_stock_type = shift; #plot, plant
        my $subject_or_object = shift;
    my @data;
        #$self->bcs_schema->storage->debug(1);
    my $dbh = $self->bcs_schema->storage()->dbh();
        my $where_clause = "WHERE project_id=? and b.cvterm_id = ? and phenotype.value~? ";
        my $phenotyping_experiment_cvterm = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'phenotyping_experiment', 'experiment_type')->cvterm_id();

        if (scalar(@$trait_ids)>0){
                my $sql_trait_ids = join ("," , @$trait_ids);
                $where_clause .= "and a.cvterm_id IN ($sql_trait_ids) ";
        }

        my $relationship_join = '';
        if ($subject_or_object eq 'object') {
                $relationship_join = 'JOIN stock_relationship on (stock.stock_id=stock_relationship.object_id) JOIN stock as rel_stock on (stock_relationship.subject_id=rel_stock.stock_id) ';
        } elsif ($subject_or_object eq 'subject') {
                $relationship_join = 'JOIN stock_relationship on (stock.stock_id=stock_relationship.subject_id) JOIN stock as rel_stock on (stock_relationship.object_id=rel_stock.stock_id) ';
        }
        if ($stock_type ne 'all') {
                my $stock_type_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema(), $stock_type, 'stock_type')->cvterm_id();
                $where_clause .= "and stock.type_id=$stock_type_cvterm_id ";
        }
        my @stock_rel_or;
        foreach (@$stock_relationships) {
                my $stock_relationship_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema(), $_, 'stock_relationship')->cvterm_id();
                push @stock_rel_or, "stock_relationship.type_id=$stock_relationship_cvterm_id";
        }
        my $stock_rel_or_sql = join (" OR " , @stock_rel_or);
        if ($stock_rel_or_sql) {
                $where_clause .= "and ($stock_rel_or_sql) ";
        }
        my $rel_stock_type_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema(), $relationship_stock_type, 'stock_type')->cvterm_id();
        $where_clause .= "and rel_stock.type_id=$rel_stock_type_cvterm_id ";

        my $q = "SELECT stock.stock_id, stock.uniquename, a.cvterm_id, a.name || '|' || db.name ||  ':' || dbxref.accession, phenotype.phenotype_id, phenotype.uniquename, phenotype.sp_person_id, phenotype.value::real, rel_stock.stock_id, rel_stock.uniquename, stock_type.name
                FROM cvterm as a
                JOIN dbxref ON (a.dbxref_id = dbxref.dbxref_id)
                JOIN db USING(db_id)
                JOIN phenotype ON (a.cvterm_id=cvalue_id)
                JOIN nd_experiment_phenotype USING(phenotype_id)
                JOIN nd_experiment_project USING(nd_experiment_id)
                JOIN nd_experiment_stock USING(nd_experiment_id)
                JOIN cvterm as b ON (b.cvterm_id=nd_experiment_stock.type_id)
                JOIN stock USING(stock_id)
                JOIN cvterm as stock_type ON (stock_type.cvterm_id=stock.type_id)
                $relationship_join
                $where_clause
                ORDER BY stock.stock_id;";

    print STDERR "QUERY = $q\n";
    my $h = $dbh->prepare($q);

    my $numeric_regex = '^-?[0-9]+([,.][0-9]+)?$';
    $h->execute($self->get_trial_id(), $phenotyping_experiment_cvterm, $numeric_regex );
    while (my ($stock_id, $stock_name, $trait_id, $trait_name, $phenotype_id, $pheno_uniquename, $uploader_id, $value, $rel_stock_id, $rel_stock_name, $stock_type) = $h->fetchrow_array()) {
        push @data, [$stock_id, $stock_name, $trait_id, $trait_name, $phenotype_id, $pheno_uniquename, $uploader_id, $value + 0, $rel_stock_id, $rel_stock_name, $stock_type];
    }
    return \@data;
}

=head2 function get_traits_assayed()

 Usage:
 Desc:         returns the cvterm_id and name for traits assayed
 Ret:
 Args:          stock_type can be the cvterm name for a specific stock type like 'plot'. not providing stock_type will return all traits assayed in the trial. trait_format can be for only returning numeric, categorical, etc traits. not providing trait_format will return all trait types.
 Side Effects:
 Example:

=cut

sub get_traits_assayed {
    my $self = shift;
    my $stock_type = shift;
    my $trait_format = shift;
    my $contains_composable_cv_type = shift;
    my $schema = $self->bcs_schema;
    my $dbh = $self->bcs_schema->storage()->dbh();

    my @traits_assayed;

    my $cvtermprop_join = '';
    my $cvtermprop_where = '';
    if ($trait_format){
        my $trait_format_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema(), 'trait_format', 'trait_property')->cvterm_id();
        $cvtermprop_join = ' JOIN cvtermprop ON (cvtermprop.cvterm_id = cvterm.cvterm_id) ';
        $cvtermprop_where = " AND cvtermprop.type_id = $trait_format_cvterm_id AND cvtermprop.value = '$trait_format' ";
    }

    my $contains_relationship_rs = $schema->resultset("Cv::Cvterm")->search({ name => 'contains' });
    if ($contains_relationship_rs->count == 0) {
        die "The cvterm 'contains' was not found! Please add this cvterm! Generally this term is added when loading an ontology into the database.\n";
    }
    elsif ($contains_relationship_rs->count > 1) {
        die "The cvterm 'contains' was found more than once! Please consolidate this cvterm by updating cvterm_relationship entries and then deleting the left over cvterm entry! Generally this term is added when loading an ontology into the database.\n";
    }
    my $contains_relationship_cvterm_id = $contains_relationship_rs->first->cvterm_id;
    my $variable_relationship_rs = $schema->resultset("Cv::Cvterm")->search({ name => 'VARIABLE_OF' });
    if ($variable_relationship_rs->count == 0) {
        die "The cvterm 'VARIABLE_OF' was not found! Please add this cvterm! Generally this term is added when loading an ontology into the database.\n";
    }
    elsif ($variable_relationship_rs->count > 1) {
        die "The cvterm 'VARIABLE_OF' was found more than once! Please consolidate this cvterm by updating cvterm_relationship entries and then deleting the left over cvterm entry! Generally this term is added when loading an ontology into the database.\n";
    }

    my $composable_cv_type_cvterm_id = $contains_composable_cv_type ? SGN::Model::Cvterm->get_cvterm_row($schema, $contains_composable_cv_type, 'composable_cvtypes')->cvterm_id : '';

    my $q;
    if ($stock_type) {
        my $stock_type_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema(), $stock_type, 'stock_type')->cvterm_id();
        $q = "SELECT (((cvterm.name::text || '|'::text) || db.name::text) || ':'::text) || dbxref.accession::text AS trait, cvterm.cvterm_id, imaging_project.project_id, imaging_project.name, count(phenotype.value)
            FROM cvterm
            $cvtermprop_join
            JOIN dbxref ON (cvterm.dbxref_id = dbxref.dbxref_id)
            JOIN db ON (dbxref.db_id = db.db_id)
            JOIN phenotype ON (cvterm.cvterm_id=phenotype.cvalue_id)
            JOIN nd_experiment_phenotype USING(phenotype_id)
            JOIN nd_experiment_project USING(nd_experiment_id)
            JOIN nd_experiment_stock USING(nd_experiment_id)
            LEFT JOIN phenome.nd_experiment_md_images AS nd_experiment_md_images USING(nd_experiment_id)
            LEFT JOIN phenome.project_md_image AS project_md_image ON (nd_experiment_md_images.image_id=project_md_image.image_id)
            LEFT JOIN project AS imaging_project ON (project_md_image.project_id=imaging_project.project_id)
            JOIN stock on (stock.stock_id = nd_experiment_stock.stock_id)
            WHERE stock.type_id=$stock_type_cvterm_id and nd_experiment_project.project_id=? $cvtermprop_where
            GROUP BY trait, cvterm.cvterm_id, imaging_project.project_id, imaging_project.name
            ORDER BY trait;";
    } else {
        $q = "SELECT (((cvterm.name::text || '|'::text) || db.name::text) || ':'::text) || dbxref.accession::text AS trait, cvterm.cvterm_id, imaging_project.project_id, imaging_project.name, count(phenotype.value)
            FROM cvterm
            $cvtermprop_join
            JOIN dbxref ON (cvterm.dbxref_id = dbxref.dbxref_id)
            JOIN db ON (dbxref.db_id = db.db_id)
            JOIN phenotype ON (cvterm.cvterm_id=phenotype.cvalue_id)
            JOIN nd_experiment_phenotype USING(phenotype_id)
            JOIN nd_experiment_project USING(nd_experiment_id)
            LEFT JOIN phenome.nd_experiment_md_images AS nd_experiment_md_images USING(nd_experiment_id)
            LEFT JOIN phenome.project_md_image AS project_md_image ON (nd_experiment_md_images.image_id=project_md_image.image_id)
            LEFT JOIN project AS imaging_project ON (project_md_image.project_id=imaging_project.project_id)
            WHERE nd_experiment_project.project_id=? $cvtermprop_where
            GROUP BY trait, cvterm.cvterm_id, imaging_project.project_id, imaging_project.name
            ORDER BY trait;";
    }

    my $component_q = "SELECT COALESCE(
            json_agg(json_build_object('cvterm_id', component_cvterm.cvterm_id, 'name', component_cvterm.name, 'definition', component_cvterm.definition, 'cv_name', cv.name, 'cv_type', cv_type.name, 'cv_type_cvterm_id', cv_type.cvterm_id))
            FILTER (WHERE component_cvterm.cvterm_id IS NOT NULL), '[]'
        ) AS components
        FROM cvterm
        LEFT JOIN cvterm_relationship on (cvterm.cvterm_id = cvterm_relationship.object_id AND cvterm_relationship.type_id = $contains_relationship_cvterm_id)
        LEFT JOIN cvterm AS component_cvterm on (cvterm_relationship.subject_id = component_cvterm.cvterm_id)
        LEFT JOIN cv on (component_cvterm.cv_id = cv.cv_id)
        LEFT JOIN cvprop on (cv.cv_id = cvprop.cv_id)
        LEFT JOIN cvterm AS cv_type on (cv_type.cvterm_id = cvprop.type_id)
        WHERE cvterm.cvterm_id=? ;";

    print STDERR Dumper $q;

    my $traits_assayed_h = $dbh->prepare($q);
    my $component_h = $dbh->prepare($component_q);

    $traits_assayed_h->execute($self->get_trial_id());
    while (my ($trait_name, $trait_id, $imaging_project_id, $imaging_project_name, $count) = $traits_assayed_h->fetchrow_array()) {
        $component_h->execute($trait_id);
        my ($component_terms) = $component_h->fetchrow_array();
        $component_terms = decode_json $component_terms;
        if ($contains_composable_cv_type) {
            my $has_composable_cv_type = 0;
            foreach (@$component_terms) {
                if ($_->{cv_type_cvterm_id} && $_->{cv_type_cvterm_id} == $composable_cv_type_cvterm_id) {
                    $has_composable_cv_type = 1;
                }
            }
            if ($has_composable_cv_type == 1) {
                push @traits_assayed, [$trait_id, $trait_name, $component_terms, $count, $imaging_project_id, $imaging_project_name];
            }
        }
        else {
            push @traits_assayed, [$trait_id, $trait_name, $component_terms, $count, $imaging_project_id, $imaging_project_name];
        }
    }
    return \@traits_assayed;
}

=head2 function get_trait_components_assayed()

 Usage:
 Desc:         returns the cvterm_id and name for trait components assayed
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_trait_components_assayed {
    my $self = shift;
    my $stock_type = shift;
    my $composable_cvterm_format = shift;
    my $dbh = $self->bcs_schema->storage()->dbh();
    my $traits_assayed = $self->get_traits_assayed($stock_type);

    my %unique_components;
    my @trait_components_assayed;
    foreach (@$traits_assayed){
        my $trait_components = SGN::Model::Cvterm->get_components_from_trait($self->bcs_schema, $_->[0]);
        foreach (@$trait_components){
            if (!exists($unique_components{$_})){
                my $component_cvterm = SGN::Model::Cvterm::get_trait_from_cvterm_id($self->bcs_schema, $_, $composable_cvterm_format);
                push @trait_components_assayed, [$_, $component_cvterm];
                $unique_components{$_}++;
            }
        }
    }
    return \@trait_components_assayed;
}

=head2 function get_experiment_count()

 Usage:
 Desc:         return the total number of experiments associated
               with the trial.
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub get_experiment_count {
    my $self = shift;

    my $rs = $self->bcs_schema->resultset('NaturalDiversity::NdExperimentProject')->search( { project_id => $self->get_trial_id() });
    return $rs->count();
}

sub get_location_type_id {
    my $self = shift;
    my $rs = $self->bcs_schema->resultset('Cv::Cvterm')->search( { name => 'project location' });

    if ($rs->count() > 0) {
        return $rs->first()->cvterm_id();
    }

}

sub get_year_type_id {
    my $self = shift;

    my $rs = $self->bcs_schema->resultset('Cv::Cvterm')->search( { name => 'project year' });

    return $rs->first()->cvterm_id();
}

sub get_breeding_program_trial_relationship_cvterm_id {
    my $self = shift;

    my $breeding_program_trial_relationship_cvterm_id;
    my $breeding_program_trial_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'breeding_program_trial_relationship', 'project_relationship');
    if ($breeding_program_trial_relationship_cvterm) {
        $breeding_program_trial_relationship_cvterm_id = $breeding_program_trial_relationship_cvterm->cvterm_id();
    }

    return $breeding_program_trial_relationship_cvterm_id;
}

sub get_breeding_program_cvterm_id {
    my $self = shift;

    my $breeding_program_cvterm_id;
    my $breeding_program_cvterm = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'breeding_program', 'project_property');
    if ($breeding_program_cvterm) {
        $breeding_program_cvterm_id = $breeding_program_cvterm->cvterm_id();
    }

    return $breeding_program_cvterm_id;
}

sub get_folder {
    my $self = shift;

    my $f = CXGN::Trial::Folder->new( { bcs_schema => $self->bcs_schema(), folder_id => $self->get_trial_id() });

    my $parent_folder_data = $f->project_parent();

    if ($parent_folder_data) {
        return $parent_folder_data;
    }
    else {
        return;
    }
}

sub get_harvest_date_cvterm_id {
    my $self = shift;

    my $harvest_date_cvterm_id;
    my $harvest_date_cvterm = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'project_harvest_date', 'project_property');
    if ($harvest_date_cvterm) {
        $harvest_date_cvterm_id = $harvest_date_cvterm->cvterm_id();
    }

    return $harvest_date_cvterm_id;
}


sub get_project_start_date_cvterm_id {
    my $self = shift;

    my $start_date_cvterm_id;
    my $start_date_cvterm = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'project_start_date', 'project_property');
    if ($start_date_cvterm) {
        $start_date_cvterm_id = $start_date_cvterm->cvterm_id();
    }

    return $start_date_cvterm_id;
}

=head2 function create_plant_entities()

 Usage:        $trial->create_plant_entities($plants_per_plot);
 Desc:         Some trials require plant-level data. This function will
               add an additional layer of plant entities for each plot.
 Ret:
 Args:         the number of plants per plot to add.
 Side Effects:
 Example:

=cut

sub create_plant_entities {
    my $self = shift;
    my $plants_per_plot = shift || 30;
    my $inherits_plot_treatments = shift;
    my $plant_owner = shift;
    my $plant_owner_username = shift;

    my $create_plant_entities_txn = sub {
        my $chado_schema = $self->bcs_schema();
        my $layout = CXGN::Trial::TrialLayout->new( { schema => $chado_schema, trial_id => $self->get_trial_id(), experiment_type=>'field_layout' });
        my $design = $layout->get_design();

        my $accession_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'accession', 'stock_type')->cvterm_id();
        my $cross_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'cross', 'stock_type')->cvterm_id();
        my $family_name_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'family_name', 'stock_type')->cvterm_id();
        my $plant_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant', 'stock_type')->cvterm_id();
        my $plot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot', 'stock_type')->cvterm_id();
        my $plot_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot_of', 'stock_relationship')->cvterm_id();
        my $plant_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant_of', 'stock_relationship')->cvterm_id();
        my $plant_index_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant_index_number', 'stock_property')->cvterm_id();
        my $block_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'block', 'stock_property')->cvterm_id();
        my $plot_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot number', 'stock_property')->cvterm_id();
        my $replicate_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'replicate', 'stock_property')->cvterm_id();
        my $has_plants_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'project_has_plant_entries', 'project_property')->cvterm_id();
        my $field_layout_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'field_layout', 'experiment_type')->cvterm_id();
        my $treatment_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'treatment_experiment', 'experiment_type')->cvterm_id();
        #my $plants_per_plot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plants_per_plot', 'project_property')->cvterm_id();

        my $treatments;
        my %treatment_experiments;
        my %treatment_plots;
        if ($inherits_plot_treatments){
            $treatments = $self->get_treatments();
            foreach (@$treatments){

                my $rs = $chado_schema->resultset("Project::Projectprop")->find_or_create({
                    type_id => $has_plants_cvterm,
                    value => $plants_per_plot,
                    project_id => $_->[0],
                });

                my $treatment_nd_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $_->[0] }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $treatment_cvterm })->single();
                $treatment_experiments{$_->[0]} = $treatment_nd_experiment->nd_experiment_id();

                my $treatment_trial = CXGN::Project->new({ bcs_schema => $chado_schema, trial_id => $_->[0]});
                my $plots = $treatment_trial->get_plots();
                foreach my $plot (@$plots){
                    $treatment_plots{$_->[0]}->{$plot->[0]} = 1;
                }
            }
        }

        my $rs = $chado_schema->resultset("Project::Projectprop")->find_or_create({
            type_id => $has_plants_cvterm,
            value => $plants_per_plot,
            project_id => $self->get_trial_id(),
        });

        my $field_layout_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $self->get_trial_id() }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $field_layout_cvterm })->single();

        foreach my $plot (keys %$design) {
            #print STDERR " ... creating plants for plot $plot...\n";
            my $plot_row = $chado_schema->resultset("Stock::Stock")->find( { uniquename => $design->{$plot}->{plot_name}, type_id=>$plot_cvterm });

            if (! $plot_row) {
                print STDERR "The plot $plot is not found in the database\n";
                return "The plot $plot is not yet in the database. Cannot create plant entries.";
            }

            my $parent_plot = $plot_row->stock_id();
            my $parent_plot_name = $plot_row->uniquename();
            my $parent_plot_organism = $plot_row->organism_id();

            foreach my $plant_index_number (1..$plants_per_plot) {
                my $plant_name = $parent_plot_name."_plant_$plant_index_number";
                #print STDERR "... ... creating plant $plant_name...\n";

                $self->_save_plant_entry($chado_schema, $accession_cvterm, $cross_cvterm, $family_name_cvterm, $parent_plot_organism, $parent_plot_name,
                $parent_plot, $plant_name, $plant_cvterm, $plant_index_number, $plant_index_number_cvterm, $block_cvterm, $plot_number_cvterm,
                $replicate_cvterm, $plant_relationship_cvterm, $field_layout_experiment, $field_layout_cvterm, $inherits_plot_treatments, $treatments,
                $plot_relationship_cvterm, \%treatment_plots, \%treatment_experiments, $treatment_cvterm, $plant_owner, $plant_owner_username);
            }
        }

        $layout->generate_and_cache_layout();
    };

    eval {
        $self->bcs_schema()->txn_do($create_plant_entities_txn);
    };
    if ($@) {
        print STDERR "An error occurred creating the plant entities. $@\n";
        return 0;
    }

    print STDERR "Plant entities created.\n";
    return 1;
}

=head2 function save_plant_entries()

 Usage:        $trial->save_plant_entries(\%data, $plants_per_plot, $inherits_plot_treatments);
 Desc:         Some trials require plant-level data. It is possible to upload
                plant_names to save.
 Ret:
 Args:         Requires $plants_per_plot and \%data which is a hashref of the data parsed from the
                uploaded file.
                example: { 'myplotname1' => { 'plot_stock_id'=>123, 'plant_names'=>['plot1_plant1', 'plot1_plant2'] }, ... }
 Side Effects:
 Example:

=cut

sub save_plant_entries {
    my $self = shift;
    my $parsed_data = shift;
    my $plants_per_plot = shift;
    my $inherits_plot_treatments = shift;

    my $create_plant_entities_txn = sub {
        my $chado_schema = $self->bcs_schema();
        my $layout = CXGN::Trial::TrialLayout->new( { schema => $chado_schema, trial_id => $self->get_trial_id(), experiment_type=>'field_layout' });
        my $design = $layout->get_design();

        my $accession_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'accession', 'stock_type')->cvterm_id();
        my $cross_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'cross', 'stock_type')->cvterm_id();
        my $family_name_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'family_name', 'stock_type')->cvterm_id();
        my $plant_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant', 'stock_type')->cvterm_id();
        my $plot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot', 'stock_type')->cvterm_id();
        my $plot_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot_of', 'stock_relationship')->cvterm_id();
        my $plant_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant_of', 'stock_relationship')->cvterm_id();
        my $plant_index_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant_index_number', 'stock_property')->cvterm_id();
        my $block_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'block', 'stock_property')->cvterm_id();
        my $plot_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot number', 'stock_property')->cvterm_id();
        my $replicate_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'replicate', 'stock_property')->cvterm_id();
        my $has_plants_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'project_has_plant_entries', 'project_property')->cvterm_id();
        my $field_layout_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'field_layout', 'experiment_type')->cvterm_id();
        my $treatment_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'treatment_experiment', 'experiment_type')->cvterm_id();
        #my $plants_per_plot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plants_per_plot', 'project_property')->cvterm_id();

        my $treatments;
        my %treatment_experiments;
        my %treatment_plots;
        if ($inherits_plot_treatments){
            $treatments = $self->get_treatments();
            foreach (@$treatments){

                my $rs = $chado_schema->resultset("Project::Projectprop")->find_or_create({
                    type_id => $has_plants_cvterm,
                    value => $plants_per_plot,
                    project_id => $_->[0],
                });

                my $treatment_nd_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $_->[0] }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { type_id => $treatment_cvterm })->single();
                $treatment_experiments{$_->[0]} = $treatment_nd_experiment->nd_experiment_id();

                my $treatment_trial = CXGN::Trial->new({ bcs_schema => $chado_schema, trial_id => $_->[0]});
                my $plots = $treatment_trial->get_plots();
                foreach my $plot (@$plots){
                    $treatment_plots{$_->[0]}->{$plot->[0]} = 1;
                }
            }
        }

        my $rs = $chado_schema->resultset("Project::Projectprop")->find_or_create({
            type_id => $has_plants_cvterm,
            value => $plants_per_plot,
            project_id => $self->get_trial_id(),
        });


        my $field_layout_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $self->get_trial_id() }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $field_layout_cvterm })->single();

        while( my ($key, $val) = each %$parsed_data){
            my $plot_stock_id = $key;
            my $plot_name = $val->{plot_name};
            print STDERR " ... creating plants for plot $plot_name...\n";
            my $plot_row = $chado_schema->resultset("Stock::Stock")->find( { stock_id=>$plot_stock_id });

            if (!$plot_row) {
                print STDERR "The plot $plot_name is not found in the database\n";
                return "The plot $plot_name is not yet in the database. Cannot create plant entries.";
            }

            my $parent_plot = $plot_row->stock_id();
            my $parent_plot_name = $plot_row->uniquename();
            my $parent_plot_organism = $plot_row->organism_id();

            my $plant_index_number = 1;
            my $plant_names = $val->{plant_names};
            my $plant_index_numbers = $val->{plant_index_numbers};
            my $increment = 0;
            foreach my $plant_name (@$plant_names) {
                my $given_plant_index_number = $plant_index_numbers->[$increment];
                my $plant_index_number_save = $given_plant_index_number ? $given_plant_index_number : $plant_index_number;

                $self->_save_plant_entry($chado_schema, $accession_cvterm, $cross_cvterm, $family_name_cvterm, $parent_plot_organism, $parent_plot_name, $parent_plot, $plant_name, $plant_cvterm, $plant_index_number_save, $plant_index_number_cvterm, $block_cvterm, $plot_number_cvterm, $replicate_cvterm, $plant_relationship_cvterm, $field_layout_experiment, $field_layout_cvterm, $inherits_plot_treatments, $treatments, $plot_relationship_cvterm, \%treatment_plots, \%treatment_experiments, $treatment_cvterm);
                $plant_index_number++;
                $increment++;
            }
        }

        $layout->generate_and_cache_layout();
    };

    eval {
        $self->bcs_schema()->txn_do($create_plant_entities_txn);
    };
    if ($@) {
        print STDERR "An error occurred creating the plant entities. $@\n";
        return 0;
    }

    print STDERR "Plant entities created.\n";
    return 1;
}

=head2 function create_plant_subplot_entities()

 Usage:        $trial->create_plant_subplot_entities($plants_per_subplot);
 Desc:         Some trials require plant-level data. This function will
               add an additional layer of plant entities for each subplot.
 Ret:
 Args:         the number of plants per subplot to add.
 Side Effects:
 Example:

=cut

sub create_plant_subplot_entities {
    my $self = shift;
    my $plants_per_subplot = shift || 10;
    my $inherits_plot_treatments = shift;
    my $plant_owner = shift;
    my $plant_owner_username = shift;

    my $create_plant_entities_txn = sub {
        my $chado_schema = $self->bcs_schema();
        my $layout = CXGN::Trial::TrialLayout->new( { schema => $chado_schema, trial_id => $self->get_trial_id(), experiment_type=>'field_layout' });
        my $design = $layout->get_design();

        my $accession_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'accession', 'stock_type')->cvterm_id();
        my $cross_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'cross', 'stock_type')->cvterm_id();
        my $family_name_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'family_name', 'stock_type')->cvterm_id();
        my $plant_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant', 'stock_type')->cvterm_id();
        my $plot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot', 'stock_type')->cvterm_id();
        my $subplot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'subplot', 'stock_type')->cvterm_id();
        my $plot_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot_of', 'stock_relationship')->cvterm_id();
        my $plant_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant_of', 'stock_relationship')->cvterm_id();
        my $plant_subplot_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant_of_subplot', 'stock_relationship')->cvterm_id();
        my $plant_index_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant_index_number', 'stock_property')->cvterm_id();
        my $block_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'block', 'stock_property')->cvterm_id();
        my $plot_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot number', 'stock_property')->cvterm_id();
        my $replicate_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'replicate', 'stock_property')->cvterm_id();
        my $has_subplots_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'project_has_subplot_entries', 'project_property')->cvterm_id();
        my $has_plants_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'project_has_plant_entries', 'project_property')->cvterm_id();
        my $field_layout_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'field_layout', 'experiment_type')->cvterm_id();
        my $treatment_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'treatment_experiment', 'experiment_type')->cvterm_id();
        #my $plants_per_plot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plants_per_plot', 'project_property')->cvterm_id();

        # Calculate the number of plants per plot (subplots_per_plot * plants_per_subplot)
        my $subplots_per_plot_row = $chado_schema->resultset("Project::Projectprop")->find({
            type_id => $has_subplots_cvterm,
            project_id => $self->get_trial_id()
        });
        my $subplots_per_plot = $subplots_per_plot_row->value();
        my $plants_per_plot = $subplots_per_plot * $plants_per_subplot;

        my $treatments;
        my %treatment_experiments;
        my %treatment_plots;
        if ($inherits_plot_treatments){
            $treatments = $self->get_treatments();
            foreach (@$treatments){

                my $rs = $chado_schema->resultset("Project::Projectprop")->find_or_create({
                    type_id => $has_plants_cvterm,
                    value => $plants_per_plot,
                    project_id => $_->[0],
                });

                my $treatment_nd_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $_->[0] }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $treatment_cvterm })->single();
                $treatment_experiments{$_->[0]} = $treatment_nd_experiment->nd_experiment_id();

                my $treatment_trial = CXGN::Project->new({ bcs_schema => $chado_schema, trial_id => $_->[0]});
                my $plots = $treatment_trial->get_plots();
                foreach my $plot (@$plots){
                    $treatment_plots{$_->[0]}->{$plot->[0]} = 1;
                }
            }
        }

        my $rs = $chado_schema->resultset("Project::Projectprop")->find_or_create({
            type_id => $has_plants_cvterm,
            value => $plants_per_plot,
            project_id => $self->get_trial_id(),
        });

        my $field_layout_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $self->get_trial_id() }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $field_layout_cvterm })->single();

        foreach my $plot (keys %$design) {
            print STDERR " ... creating plants for plot $plot...\n";

            my $plot_row = $chado_schema->resultset("Stock::Stock")->find( { uniquename => $design->{$plot}->{plot_name}, type_id=>$plot_cvterm });
            if (! $plot_row) {
                print STDERR "The plot $plot is not found in the database\n";
                return "The plot $plot is not yet in the database. Cannot create plant entries.";
            }

            my $parent_plot = $plot_row->stock_id();
            my $parent_plot_name = $plot_row->uniquename();
            my $parent_plot_organism = $plot_row->organism_id();

            my $subplots = $design->{$plot}->{subplot_names};
            foreach my $subplot (@$subplots) {
                print STDERR " ... ... creating plants for subplot $subplot...\n";

                my $subplot_row = $chado_schema->resultset("Stock::Stock")->find({ uniquename => $subplot, type_id => $subplot_cvterm });
                if ( !$subplot_row ) {
                    print STDERR "The subplot $subplot is not found in the database\n";
                    return "The subplot $subplot is not yet in the database. Cannot create plant entries.";
                }

                my $parent_subplot = $subplot_row->stock_id();

                foreach my $plant_index_number (1..$plants_per_subplot) {
                    my $plant_name = $subplot."_plant_$plant_index_number";
                    print STDERR "... ... ... creating plant $plant_name...\n";

                    $self->_save_plant_entry($chado_schema, $accession_cvterm, $cross_cvterm, $family_name_cvterm, $parent_plot_organism, $parent_plot_name,
                    $parent_plot, $plant_name, $plant_cvterm, $plant_index_number, $plant_index_number_cvterm, $block_cvterm, $plot_number_cvterm,
                    $replicate_cvterm, $plant_relationship_cvterm, $field_layout_experiment, $field_layout_cvterm, $inherits_plot_treatments, $treatments,
                    $plot_relationship_cvterm, \%treatment_plots, \%treatment_experiments, $treatment_cvterm, $plant_owner, $plant_owner_username,
                    $parent_subplot, $plant_subplot_relationship_cvterm);
                }
            }
        }

        $layout->generate_and_cache_layout();
    };

    eval {
        $self->bcs_schema()->txn_do($create_plant_entities_txn);
    };
    if ($@) {
        print STDERR "An error occurred creating the plant entities. $@\n";
        return 0;
    }

    print STDERR "Plant entities created.\n";
    return 1;
}


=head2 function save_plant_subplot_entries()

 Usage:        $trial->save_plant_subplot_entries(\%data, $plants_per_subplot, $inherits_plot_treatments);
 Desc:         Some trials require plant-level data. It is possible to upload
                plant_names to save.
 Ret:
 Args:         Requires $plants_per_subplot and \%data which is a hashref of the data parsed from the
                uploaded file.
                example: { 'mysubplotname1' => { 'subplot_stock_id'=>123, 'plant_names'=>['plot1_subplot1_plant1', 'plot1_subplot1_plant2'] }, ... }
 Side Effects:
 Example:

=cut

sub save_plant_subplot_entries {
    my $self = shift;
    my $parsed_data = shift;
    my $plants_per_subplot = shift;
    my $inherits_plot_treatments = shift;
    my $plant_owner = shift;
    my $plant_owner_username = shift;

    my $create_plant_entities_txn = sub {
        my $chado_schema = $self->bcs_schema();
        my $layout = CXGN::Trial::TrialLayout->new( { schema => $chado_schema, trial_id => $self->get_trial_id(), experiment_type=>'field_layout' });
        my $design = $layout->get_design();

        my $accession_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'accession', 'stock_type')->cvterm_id();
        my $cross_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'cross', 'stock_type')->cvterm_id();
        my $family_name_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'family_name', 'stock_type')->cvterm_id();
        my $plant_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant', 'stock_type')->cvterm_id();
        my $plot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot', 'stock_type')->cvterm_id();
        my $subplot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'subplot', 'stock_type')->cvterm_id();
        my $plot_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot_of', 'stock_relationship')->cvterm_id();
        my $plant_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant_of', 'stock_relationship')->cvterm_id();
        my $subplot_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'subplot_of', 'stock_relationship')->cvterm_id();
        my $plant_subplot_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant_of_subplot', 'stock_relationship')->cvterm_id();
        my $plant_index_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant_index_number', 'stock_property')->cvterm_id();
        my $block_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'block', 'stock_property')->cvterm_id();
        my $plot_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot number', 'stock_property')->cvterm_id();
        my $replicate_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'replicate', 'stock_property')->cvterm_id();
        my $has_subplots_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'project_has_subplot_entries', 'project_property')->cvterm_id();
        my $has_plants_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'project_has_plant_entries', 'project_property')->cvterm_id();
        my $field_layout_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'field_layout', 'experiment_type')->cvterm_id();
        my $treatment_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'treatment_experiment', 'experiment_type')->cvterm_id();

        # Calculate the number of plants per plot (subplots_per_plot * plants_per_subplot)
        my $subplots_per_plot_row = $chado_schema->resultset("Project::Projectprop")->find({
            type_id => $has_subplots_cvterm,
            project_id => $self->get_trial_id()
        });
        my $subplots_per_plot = $subplots_per_plot_row->value();
        my $plants_per_plot = $subplots_per_plot * $plants_per_subplot;

        my $treatments;
        my %treatment_experiments;
        my %treatment_plots;
        if ($inherits_plot_treatments){
            $treatments = $self->get_treatments();
            foreach (@$treatments){

                my $rs = $chado_schema->resultset("Project::Projectprop")->find_or_create({
                    type_id => $has_plants_cvterm,
                    value => $plants_per_plot,
                    project_id => $_->[0],
                });

                my $treatment_nd_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $_->[0] }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $treatment_cvterm })->single();
                $treatment_experiments{$_->[0]} = $treatment_nd_experiment->nd_experiment_id();

                my $treatment_trial = CXGN::Trial->new({ bcs_schema => $chado_schema, trial_id => $_->[0]});
                my $plots = $treatment_trial->get_plots();
                foreach my $plot (@$plots){
                    $treatment_plots{$_->[0]}->{$plot->[0]} = 1;
                }
            }
        }

        my $rs = $chado_schema->resultset("Project::Projectprop")->find_or_create({
            type_id => $has_plants_cvterm,
            value => $plants_per_plot,
            project_id => $self->get_trial_id(),
        });


        my $field_layout_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $self->get_trial_id() }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $field_layout_cvterm })->single();

        while( my ($key, $val) = each %$parsed_data){
            my $subplot_stock_id = $key;
            my $subplot_name = $val->{subplot_name};
            print STDERR " ... creating plants for subplot $subplot_name...\n";

            my $subplot_row = $chado_schema->resultset("Stock::Stock")->find( { stock_id=>$subplot_stock_id });
            if (!$subplot_row) {
                print STDERR "The subplot $subplot_name is not found in the database\n";
                return "The subplot $subplot_name is not yet in the database. Cannot create plant entries.";
            }

            my $plot_relationship_row = $chado_schema->resultset("Stock::StockRelationship")->find({
                object_id => $subplot_stock_id,
                type_id => $subplot_relationship_cvterm
            });
            if (!$plot_relationship_row) {
                print STDERR "The subplot $subplot_name does not have a defined plot relationship in the database\n";
                return "The subplot $subplot_name does not have a defined plot relationship in the database. Cannot create plant entries.";
            }
            my $plot_row = $chado_schema->resultset("Stock::Stock")->find({ stock_id => $plot_relationship_row->subject_id() });
            if (!$plot_row) {
                print STDERR "The parent plot of subplot $subplot_name is not found in the database\n";
                return "The parent plot of subplot $subplot_name is not yet in the database. Cannot create plant entries.";
            }

            my $parent_plot = $plot_row->stock_id();
            my $parent_plot_name = $plot_row->uniquename();
            my $parent_plot_organism = $plot_row->organism_id();

            my $plant_index_number = 1;
            my $plant_names = $val->{plant_names};
            my $plant_index_numbers = $val->{plant_index_numbers};
            my $increment = 0;
            foreach my $plant_name (@$plant_names) {
                my $given_plant_index_number = $plant_index_numbers->[$increment];
                my $plant_index_number_save = $given_plant_index_number ? $given_plant_index_number : $plant_index_number;

                $self->_save_plant_entry($chado_schema, $accession_cvterm, $cross_cvterm, $family_name_cvterm, $parent_plot_organism, $parent_plot_name, $parent_plot, $plant_name, $plant_cvterm, $plant_index_number_save, $plant_index_number_cvterm, $block_cvterm, $plot_number_cvterm, $replicate_cvterm, $plant_relationship_cvterm, $field_layout_experiment, $field_layout_cvterm, $inherits_plot_treatments, $treatments, $plot_relationship_cvterm, \%treatment_plots, \%treatment_experiments, $treatment_cvterm, $plant_owner, $plant_owner_username,
                $subplot_stock_id, $plant_subplot_relationship_cvterm);
                $plant_index_number++;
                $increment++;
            }
        }

        $layout->generate_and_cache_layout();
    };

    eval {
        $self->bcs_schema()->txn_do($create_plant_entities_txn);
    };
    if ($@) {
        print STDERR "An error occurred creating the plant entities. $@\n";
        return 0;
    }

    print STDERR "Plant entities created.\n";
    return 1;
}

sub _save_plant_entry {
    my $self = shift;
    my $chado_schema = shift;
    my $accession_cvterm = shift;
    my $cross_cvterm = shift;
    my $family_name_cvterm = shift;
    my $parent_plot_organism = shift;
    my $parent_plot_name = shift;
    my $parent_plot = shift;
    my $plant_name = shift;
    my $plant_cvterm = shift;
    my $plant_index_number = shift;
    my $plant_index_number_cvterm = shift;
    my $block_cvterm = shift;
    my $plot_number_cvterm = shift;
    my $replicate_cvterm = shift;
    my $plant_relationship_cvterm = shift;
    my $field_layout_experiment = shift;
    my $field_layout_cvterm = shift;
    my $inherits_plot_treatments = shift;
    my $treatments = shift;
    my $plot_relationship_cvterm = shift;
    my $treatment_plots_ref = shift;
    my $treatment_experiments_ref = shift;
    my $treatment_cvterm = shift;
    my $plant_owner = shift;
    my $plant_owner_username = shift;
    my $parent_subplot = shift;
    my $plant_subplot_relationship_cvterm = shift;
    my %treatment_plots = %$treatment_plots_ref;
    my %treatment_experiments = %$treatment_experiments_ref;

    my $plant = $chado_schema->resultset("Stock::Stock")->create({
        organism_id => $parent_plot_organism,
        name       => $plant_name,
        uniquename => $plant_name,
        type_id => $plant_cvterm,
    });

    if ($plant_owner){
        my $stock = CXGN::Stock->new({schema=>$chado_schema,stock_id=>$plant->stock_id()});
        $stock->associate_owner($plant_owner,$plant_owner,$plant_owner_username, "");
    }

    my $plantprop = $chado_schema->resultset("Stock::Stockprop")->create( {
        stock_id => $plant->stock_id(),
        type_id => $plant_index_number_cvterm,
        value => $plant_index_number,
    });

    #The plant inherits the properties of the plot.
    my $plot_props = $chado_schema->resultset("Stock::Stockprop")->search({ stock_id => $parent_plot, type_id => [$block_cvterm, $plot_number_cvterm, $replicate_cvterm] });
    while (my $prop = $plot_props->next() ) {
        #print STDERR $plant->uniquename()." ".$prop->type_id()."\n";
        $plantprop = $chado_schema->resultset("Stock::Stockprop")->create( {
            stock_id => $plant->stock_id(),
            type_id => $prop->type_id(),
            value => $prop->value(),
        });
    }

    #the plant has a relationship to the plot
    my $stock_relationship = $self->bcs_schema()->resultset("Stock::StockRelationship")->create({
        subject_id => $parent_plot,
        object_id => $plant->stock_id(),
        type_id => $plant_relationship_cvterm,
    });

    #the plant has a relationship to the subplot
    if ( $parent_subplot ) {
        $self->bcs_schema()->resultset("Stock::StockRelationship")->create({
            subject_id => $plant->stock_id(),
            object_id => $parent_subplot,
            type_id => $plant_subplot_relationship_cvterm
        });
    }

    #the plant has a relationship to the accession
    my $plot_accession_rs = $self->bcs_schema()->resultset("Stock::StockRelationship")->search({'me.subject_id'=>$parent_plot, 'me.type_id'=>$plot_relationship_cvterm, 'object.type_id'=>[$accession_cvterm, $cross_cvterm, $family_name_cvterm] }, {'join'=>'object'});
    if ($plot_accession_rs->count != 1){
        die "There is not 1 stock_relationship of type plot_of between the plot $parent_plot and an accession, a cross or a family_name.";
    }
    $stock_relationship = $self->bcs_schema()->resultset("Stock::StockRelationship")->create({
        subject_id => $plant->stock_id(),
        object_id => $plot_accession_rs->first->object_id,
        type_id => $plant_relationship_cvterm,
    });

    #link plant to project through nd_experiment. also add nd_genolocation_id of plot to nd_experiment for the plant
    my $plant_nd_experiment_stock = $chado_schema->resultset("NaturalDiversity::NdExperimentStock")->create({
        nd_experiment_id => $field_layout_experiment->nd_experiment_id(),
        type_id => $field_layout_cvterm,
        stock_id => $plant->stock_id(),
    });

    if ($inherits_plot_treatments){
        if($treatments){
            foreach (@$treatments){
                my $plots = $treatment_plots{$_->[0]};
                if (exists($plots->{$parent_plot})){
                    my $plant_nd_experiment_stock = $chado_schema->resultset("NaturalDiversity::NdExperimentStock")->create({
                        nd_experiment_id => $treatment_experiments{$_->[0]},
                        type_id => $treatment_cvterm,
                        stock_id => $plant->stock_id(),
                    });
                }
            }
        }
    }
}

=head2 function has_plant_entries()

        Usage:        $trial->has_plant_entries();
        Desc:         Some trials require plant-level data. This function will determine if a trial has plants associated with it.
        Ret:          Returns 1 if trial has plants, 0 if the trial does not.
        Args:
        Side Effects:
        Example:

=cut

sub has_plant_entries {
        my $self = shift;
        my $chado_schema = $self->bcs_schema();
        my $has_plants_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'project_has_plant_entries', 'project_property' );

        my $rs = $chado_schema->resultset("Project::Projectprop")->find({
                type_id => $has_plants_cvterm->cvterm_id(),
                project_id => $self->get_trial_id(),
        });

        if ($rs) {
                return 1;
        } else {
                return 0;
        }

}

=head2 function create_tissue_samples()

 Usage:        $trial->create_tissue_samples(\@tissue_names, $inherits_plot_treatments);
 Desc:         Some trials require tissue_sample-level data. This function will
               add an additional layer of tissue samples for each plant.
 Ret:
 Args:         an arrayref of tissue names to add to sample name e.g. ['leaf','root']
 Side Effects:
 Example:

=cut

sub create_tissue_samples {
    my $self = shift;
    my $tissue_names = shift;
    my $inherits_plot_treatments = shift;
    my $use_tissue_numbers = shift;
    my $tissue_sample_owner = shift;
    my $username = shift;


    my $create_tissue_sample_entries_txn = sub {
        my $chado_schema = $self->bcs_schema();
        my $layout = CXGN::Trial::TrialLayout->new( { schema => $chado_schema, trial_id => $self->get_trial_id(), experiment_type=>'field_layout' });
        my $design = $layout->get_design();

        my $accession_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'accession', 'stock_type')->cvterm_id();
        my $cross_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'cross', 'stock_type')->cvterm_id();
        my $family_name_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'family_name', 'stock_type')->cvterm_id();
        my $plant_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant', 'stock_type')->cvterm_id();
        my $subplot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'subplot', 'stock_type')->cvterm_id();
        my $plot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot', 'stock_type')->cvterm_id();
        my $tissue_sample_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'tissue_sample', 'stock_type')->cvterm_id();
        my $plot_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot_of', 'stock_relationship')->cvterm_id();
        my $plant_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant_of', 'stock_relationship')->cvterm_id();
        my $tissue_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'tissue_sample_of', 'stock_relationship')->cvterm_id();
        my $plant_index_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plant_index_number', 'stock_property')->cvterm_id();
        my $tissue_index_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'tissue_sample_index_number', 'stock_property')->cvterm_id();
        my $has_tissues_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'project_has_tissue_sample_entries', 'project_property')->cvterm_id();
        my $block_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'block', 'stock_property')->cvterm_id();
        my $plot_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot number', 'stock_property')->cvterm_id();
        my $tissue_type_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'tissue_type', 'stock_property')->cvterm_id();
        my $replicate_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'replicate', 'stock_property')->cvterm_id();
        my $field_layout_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'field_layout', 'experiment_type')->cvterm_id();
        my $treatment_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'treatment_experiment', 'experiment_type')->cvterm_id();

        my $rs_previous_tissue = $chado_schema->resultset("Project::Projectprop")->search({
            type_id => $has_tissues_cvterm,
            project_id => $self->get_trial_id(),
        });
        my $previous_tissue_number = 0;
        if ($rs_previous_tissue->count > 0) {
            $previous_tissue_number = $rs_previous_tissue->first->value;
        }
        my $new_tissue_number = $previous_tissue_number + ($use_tissue_numbers ? scalar(@$tissue_names) : 0);

        my $treatments;
        my %treatment_experiments;
        my %treatment_plots;
        my %treatment_subplots;
        if ($inherits_plot_treatments){
            $treatments = $self->get_treatments();
            foreach (@$treatments){

                my $rs = $chado_schema->resultset('Project::Projectprop')->update_or_create({
                    type_id => $has_tissues_cvterm,
                    project_id => $_->[0],
                    rank => 0,
                    value => $new_tissue_number
                },
                {
                    key=>'projectprop_c1'
                });

                my $treatment_nd_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $_->[0] }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $treatment_cvterm })->single();
                $treatment_experiments{$_->[0]} = $treatment_nd_experiment->nd_experiment_id();

                my $treatment_trial = CXGN::Trial->new({ bcs_schema => $chado_schema, trial_id => $_->[0]});
                my $plots = $treatment_trial->get_plots();
                foreach my $plot (@$plots){
                    $treatment_plots{$_->[0]}->{$plot->[0]} = 1;
                }
                my $subplots = $treatment_trial->get_subplots();
                foreach my $subplot (@$subplots){
                    $treatment_subplots{$_->[0]}->{$subplot->[0]} = 1;
                }
            }
        }

        my $rs = $chado_schema->resultset('Project::Projectprop')->update_or_create({
            type_id => $has_tissues_cvterm,
            project_id => $self->get_trial_id(),
            rank => 0,
            value => $new_tissue_number
        },
        {
            key=>'projectprop_c1'
        });

        my $field_layout_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $self->get_trial_id() }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $field_layout_cvterm })->single();

        foreach my $plot (keys %$design) {
            my $plant_names = $design->{$plot}->{plant_names};
            my $subplot_names = $design->{$plot}->{subplot_names};
            my $subplots_plant_names = $design->{$plot}->{subplots_plant_names};
            my %plant_tissue_hash;
            foreach my $plant_name (@$plant_names){
                my $parent_plot_id = $design->{$plot}->{plot_id};
                my $parent_plot_name = $design->{$plot}->{plot_name};
                my $plant_row = $chado_schema->resultset("Stock::Stock")->find( { uniquename => $plant_name, type_id=>$plant_cvterm });

                if (! $plant_row) {
                    print STDERR "The plant $plant_name is not found in the database\n";
                    return "The plant $plant_name is not yet in the database. Cannot create tissue entries.";
                }

                my $parent_plant = $plant_row->stock_id();
                my $parent_plant_name = $plant_row->uniquename();
                my $parent_plant_organism = $plant_row->organism_id();

                my $tissue_index_number = $previous_tissue_number + 1;
                foreach my $tissue_name (@$tissue_names){
                    my $tissue_sample_name;
                    if ($use_tissue_numbers) {
                        $tissue_sample_name = $parent_plant_name."_".$tissue_name.$tissue_index_number;
                    } else {
                        $tissue_sample_name = $parent_plant_name."_".$tissue_name;
                    }
                    print STDERR "... ... creating tissue $tissue_sample_name...\n";

                    my $plant_accession_rs = $self->bcs_schema()->resultset("Stock::StockRelationship")->search({'me.subject_id'=>$parent_plant, 'me.type_id'=>$plant_relationship_cvterm, 'object.type_id'=>[$accession_cvterm, $cross_cvterm, $family_name_cvterm]}, {'join'=>'object'});
                    if ($plant_accession_rs->count != 1){
                        die "There is not 1 stock_relationship of type plant_of between the plant $parent_plant and an accession, a cross or a family_name.";
                    }

                    my @tissue_stock_props;
                    my @tissue_subjects;
                    my @tissue_objects;
                    my @tissue_nd_experiment_stocks;
                    push @tissue_stock_props, { type_id => $tissue_type_cvterm, value => $tissue_name };
                    push @tissue_stock_props, { type_id => $tissue_index_number_cvterm, value => $tissue_index_number };
                    push @tissue_subjects, { type_id => $tissue_relationship_cvterm, object_id => $parent_plant };
                    push @tissue_subjects, { type_id => $tissue_relationship_cvterm, object_id => $parent_plot_id };
                    push @tissue_subjects, { type_id => $tissue_relationship_cvterm, object_id => $plant_accession_rs->first->object_id };
                    push @tissue_nd_experiment_stocks, { nd_experiment_id => $field_layout_experiment->nd_experiment_id(), type_id => $field_layout_cvterm };

                    if ($inherits_plot_treatments){
                        if($treatments){
                            foreach (@$treatments){
                                my $plots = $treatment_plots{$_->[0]};
                                if (exists($plots->{$parent_plot_id})){
                                    push @tissue_nd_experiment_stocks, { nd_experiment_id => $treatment_experiments{$_->[0]}, type_id => $treatment_cvterm };
                                }
                            }
                        }
                    }

                    my $tissue = $chado_schema->resultset("Stock::Stock")->create({
                        organism_id => $parent_plant_organism,
                        name       => $tissue_sample_name,
                        uniquename => $tissue_sample_name,
                        type_id => $tissue_sample_cvterm,
                        stockprops => \@tissue_stock_props,
                        stock_relationship_subjects => \@tissue_subjects,
                        stock_relationship_objects => \@tissue_objects,
                        nd_experiment_stocks => \@tissue_nd_experiment_stocks,
                    });

                    if ($tissue_sample_owner) {
                        my $stock = CXGN::Stock->new({schema=>$chado_schema,stock_id=>$tissue->stock_id()});
                        $stock->associate_owner($tissue_sample_owner,$tissue_sample_owner,$username, "");
                    }

                    $tissue_index_number++;

                    push @{$plant_tissue_hash{$plant_name}}, $tissue->stock_id;

                }
            }

            foreach my $subplot_name (%$subplots_plant_names){
                my $subplot_row = $chado_schema->resultset("Stock::Stock")->find({ uniquename => $subplot_name, type_id=>$subplot_cvterm });
                foreach my $plant (@{$subplots_plant_names->{$subplot_name}}){
                    foreach my $t (@{$plant_tissue_hash{$plant}}){
                        #the tissue has a relationship to the subplot
                        my $stock_relationship = $self->bcs_schema()->resultset("Stock::StockRelationship")->create({
                            object_id => $subplot_row->stock_id(),
                            subject_id => $t,
                            type_id => $tissue_relationship_cvterm,
                        });

                        if ($inherits_plot_treatments){
                            if($treatments){
                                foreach (@$treatments){
                                    my $subplots = $treatment_subplots{$_->[0]};
                                    if (exists($subplots->{$subplot_row->stock_id})){
                                        my $plant_nd_experiment_stock = $chado_schema->resultset("NaturalDiversity::NdExperimentStock")->create({
                                            nd_experiment_id => $treatment_experiments{$_->[0]},
                                            type_id => $treatment_cvterm,
                                            stock_id => $t,
                                        });
                                    }
                                }
                            }
                        }
                    }
                }
            }
        }

        foreach (@$treatments) {
            my $layout = CXGN::Trial::TrialLayout->new( { schema => $chado_schema, trial_id => $_->[0], experiment_type=>'field_layout' });
            $layout->generate_and_cache_layout();
        }
        $layout->generate_and_cache_layout();
    };

    eval {
        $self->bcs_schema()->txn_do($create_tissue_sample_entries_txn);
    };
    if ($@) {
        print STDERR "An error occurred creating the tissue sample entities. $@\n";
        return 0;
    }

    print STDERR "Tissue sample entities created.\n";
    return 1;
}

=head2 function has_col_and_row_numbers()

        Usage:        $trial->has_col_and_row_numbers();
        Desc:         Some trials require tissue_samples from plants. This function will determine if a trial has row and column numbers for fieldMap spreadsheet download.
        Ret:          Returns 1 if trial has row and column numbers, 0 if the trial does not.
        Args:
        Side Effects:
        Example:

=cut

sub has_col_and_row_numbers {
        my $self = shift;
        my $chado_schema = $self->bcs_schema();
    my $design;
    try {
        my $layout = CXGN::Trial::TrialLayout->new( { schema => $chado_schema, trial_id => $self->get_trial_id(), experiment_type=>'field_layout' });
        $design = $layout->get_design();
    }

    my (@row_numbers, @col_numbers);
    foreach my $plot (keys %$design) {
        my $row_number = $design->{$plot}->{row_number};
        my $col_number = $design->{$plot}->{col_number};
        if ($row_number){
            push @row_numbers, $row_number;
        }
        if ($col_number){
            push @col_numbers, $col_number;
        }
    }

    if (scalar(@row_numbers) ne '0' && scalar(@col_numbers) ne '0'){
                return 1;
        } else {
                return 0;
        }

}

=head2 function has_tissue_sample_entries()

        Usage:        $trial->has_tissue_sample_entries();
        Desc:         Some trials require tissue_samples from plants. This function will determine if a trial has tissue_samples associated with it.
        Ret:          Returns 1 if trial has tissue_samples, 0 if the trial does not.
        Args:
        Side Effects:
        Example:

=cut

sub has_tissue_sample_entries {
        my $self = shift;
        my $chado_schema = $self->bcs_schema();
        my $has_tissues_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'project_has_tissue_sample_entries', 'project_property' );

        my $rs = $chado_schema->resultset("Project::Projectprop")->find({
                type_id => $has_tissues_cvterm->cvterm_id(),
                project_id => $self->get_trial_id(),
        });

        if ($rs) {
                return 1;
        } else {
                return 0;
        }

}


=head2 function create_subplot_entities()

 Usage:        $trial->create_subplot_entities($subplots_per_plot, $inherits_plot_treatments, $subplot_owner, $subplot_owner_username);
 Desc:         Some trials require subplot-level data. This function will
               add an additional layer of subplot entities for each plot.
 Ret:
 Args:         the number of subplots per plot to add.
               flag to inherit plot treatments for the subplots
               the user id of the subplot owner
               the username of the subplot owner
 Side Effects:
 Example:

=cut

sub create_subplot_entities {
    my $self = shift;
    my $subplots_per_plot = shift;
    my $inherits_plot_treatments = shift;
    my $subplot_owner = shift;
    my $subplot_owner_username = shift;

    my $create_subplot_entities_txn = sub {
        my $chado_schema = $self->bcs_schema();
        my $layout = CXGN::Trial::TrialLayout->new( { schema => $chado_schema, trial_id => $self->get_trial_id(), experiment_type=>'field_layout' });
        my $design = $layout->get_design();

        my $accession_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'accession', 'stock_type')->cvterm_id();
        my $cross_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'cross', 'stock_type')->cvterm_id();
        my $family_name_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'family_name', 'stock_type')->cvterm_id();
        my $subplot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'subplot', 'stock_type')->cvterm_id();
        my $plot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot', 'stock_type')->cvterm_id();
        my $plot_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot_of', 'stock_relationship')->cvterm_id();
        my $subplot_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'subplot_of', 'stock_relationship')->cvterm_id();
        my $subplot_index_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'subplot_index_number', 'stock_property')->cvterm_id();
        my $block_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'block', 'stock_property')->cvterm_id();
        my $plot_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot number', 'stock_property')->cvterm_id();
        my $replicate_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'replicate', 'stock_property')->cvterm_id();
        my $has_subplots_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'project_has_subplot_entries', 'project_property')->cvterm_id();
        my $field_layout_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'field_layout', 'experiment_type')->cvterm_id();
        my $treatment_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'treatment_experiment', 'experiment_type')->cvterm_id();
        #my $subplots_per_plot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'subplots_per_plot', 'project_property')->cvterm_id();

        my $treatments;
        my %treatment_experiments;
        my %treatment_plots;
        if ($inherits_plot_treatments){
            $treatments = $self->get_treatments();
            foreach (@$treatments){

                my $rs = $chado_schema->resultset("Project::Projectprop")->find_or_create({
                    type_id => $has_subplots_cvterm,
                    value => $subplots_per_plot,
                    project_id => $_->[0],
                });

                my $treatment_nd_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $_->[0] }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $treatment_cvterm })->single();
                $treatment_experiments{$_->[0]} = $treatment_nd_experiment->nd_experiment_id();

                my $treatment_trial = CXGN::Project->new({ bcs_schema => $chado_schema, trial_id => $_->[0]});
                my $plots = $treatment_trial->get_plots();
                foreach my $plot (@$plots){
                    $treatment_plots{$_->[0]}->{$plot->[0]} = 1;
                }
            }
        }

        my $rs = $chado_schema->resultset("Project::Projectprop")->find_or_create({
            type_id => $has_subplots_cvterm,
            value => $subplots_per_plot,
            project_id => $self->get_trial_id(),
        });

        my $field_layout_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $self->get_trial_id() }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $field_layout_cvterm })->single();

        foreach my $plot (keys %$design) {
            print STDERR " ... creating subplots for plot $plot...\n";
            my $plot_row = $chado_schema->resultset("Stock::Stock")->find( { uniquename => $design->{$plot}->{plot_name}, type_id=>$plot_cvterm });

            if (! $plot_row) {
                print STDERR "The plot $plot is not found in the database\n";
                return "The plot $plot is not yet in the database. Cannot create subplot entries.";
            }

            my $parent_plot = $plot_row->stock_id();
            my $parent_plot_name = $plot_row->uniquename();
            my $parent_plot_organism = $plot_row->organism_id();

            foreach my $subplot_index_number (1..$subplots_per_plot) {
                my $subplot_name = $parent_plot_name."_subplot_$subplot_index_number";
                #print STDERR "... ... creating subplot $subplot_name...\n";

                $self->_save_subplot_entry($chado_schema, $accession_cvterm, $cross_cvterm, $family_name_cvterm, $parent_plot_organism, $parent_plot_name,
                $parent_plot, $subplot_name, $subplot_cvterm, $subplot_index_number, $subplot_index_number_cvterm, $block_cvterm, $plot_number_cvterm,
                $replicate_cvterm, $subplot_relationship_cvterm, $field_layout_experiment, $field_layout_cvterm, $inherits_plot_treatments, $treatments,
                $plot_relationship_cvterm, \%treatment_plots, \%treatment_experiments, $treatment_cvterm, $subplot_owner, $subplot_owner_username);
            }
        }

        $layout->generate_and_cache_layout();
    };

    eval {
        $self->bcs_schema()->txn_do($create_subplot_entities_txn);
    };
    if ($@) {
        print STDERR "An error occurred creating the subplot entities. $@\n";
        return 0;
    }

    print STDERR "Subplot entities created.\n";
    return 1;
}


=head2 function save_subplot_entries()

 Usage:        $trial->save_subplot_entries(\%data, $subplots_per_plot, $inherits_plot_treatments);
 Desc:         Some trials require subplot-level data. It is possible to upload
                subplot_names to save.
 Ret:
 Args:         Requires $subplots_per_plot and \%data which is a hashref of the data parsed from the
                uploaded file.
                example: { 'myplotname1' => { 'plot_stock_id'=>123, 'subplot_names'=>['plot1_subplot1', 'plot1_subplot2'] }, ... }
 Side Effects:
 Example:

=cut

sub save_subplot_entries {
    my $self = shift;
    my $parsed_data = shift;
    my $subplots_per_plot = shift;
    my $inherits_plot_treatments = shift;

    my $create_subplot_entities_txn = sub {
        my $chado_schema = $self->bcs_schema();
        my $layout = CXGN::Trial::TrialLayout->new( { schema => $chado_schema, trial_id => $self->get_trial_id(), experiment_type=>'field_layout' });
        my $design = $layout->get_design();

        my $accession_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'accession', 'stock_type')->cvterm_id();
        my $cross_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'cross', 'stock_type')->cvterm_id();
        my $family_name_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'family_name', 'stock_type')->cvterm_id();
        my $subplot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'subplot', 'stock_type')->cvterm_id();
        my $plot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot', 'stock_type')->cvterm_id();
        my $plot_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot_of', 'stock_relationship')->cvterm_id();
        my $subplot_relationship_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'subplot_of', 'stock_relationship')->cvterm_id();
        my $subplot_index_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'subplot_index_number', 'stock_property')->cvterm_id();
        my $block_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'block', 'stock_property')->cvterm_id();
        my $plot_number_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'plot number', 'stock_property')->cvterm_id();
        my $replicate_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'replicate', 'stock_property')->cvterm_id();
        my $has_subplots_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'project_has_subplot_entries', 'project_property')->cvterm_id();
        my $field_layout_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'field_layout', 'experiment_type')->cvterm_id();
        my $treatment_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'treatment_experiment', 'experiment_type')->cvterm_id();
        #my $subplots_per_plot_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'subplots_per_plot', 'project_property')->cvterm_id();

        my $treatments;
        my %treatment_experiments;
        my %treatment_plots;
        if ($inherits_plot_treatments){
            $treatments = $self->get_treatments();
            foreach (@$treatments){

                my $rs = $chado_schema->resultset("Project::Projectprop")->find_or_create({
                    type_id => $has_subplots_cvterm,
                    value => $subplots_per_plot,
                    project_id => $_->[0],
                });

                my $treatment_nd_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $_->[0] }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $treatment_cvterm })->single();
                $treatment_experiments{$_->[0]} = $treatment_nd_experiment->nd_experiment_id();

                my $treatment_trial = CXGN::Trial->new({ bcs_schema => $chado_schema, trial_id => $_->[0]});
                my $plots = $treatment_trial->get_plots();
                foreach my $plot (@$plots){
                    $treatment_plots{$_->[0]}->{$plot->[0]} = 1;
                }
            }
        }

        my $rs = $chado_schema->resultset("Project::Projectprop")->find_or_create({
            type_id => $has_subplots_cvterm,
            value => $subplots_per_plot,
            project_id => $self->get_trial_id(),
        });


        my $field_layout_experiment = $chado_schema->resultset("Project::Project")->search( { 'me.project_id' => $self->get_trial_id() }, {select=>['nd_experiment.nd_experiment_id']})->search_related('nd_experiment_projects')->search_related('nd_experiment', { 'nd_experiment.type_id' => $field_layout_cvterm })->single();

        while( my ($key, $val) = each %$parsed_data){
            my $plot_stock_id = $key;
            my $plot_name = $val->{plot_name};
            print STDERR " ... creating subplots for plot $plot_name...\n";
            my $plot_row = $chado_schema->resultset("Stock::Stock")->find( { stock_id=>$plot_stock_id });

            if (!$plot_row) {
                print STDERR "The plot $plot_name is not found in the database\n";
                return "The plot $plot_name is not yet in the database. Cannot create subplot entries.";
            }

            my $parent_plot = $plot_row->stock_id();
            my $parent_plot_name = $plot_row->uniquename();
            my $parent_plot_organism = $plot_row->organism_id();

            my $subplot_index_number = 1;
            my $subplot_names = $val->{subplot_names};
            my $subplot_index_numbers = $val->{subplot_index_numbers};
            my $increment = 0;
            foreach my $subplot_name (@$subplot_names) {
                my $given_subplot_index_number = $subplot_index_numbers->[$increment];
                my $subplot_index_number_save = $given_subplot_index_number ? $given_subplot_index_number : $subplot_index_number;

                $self->_save_subplot_entry($chado_schema, $accession_cvterm, $cross_cvterm, $family_name_cvterm, $parent_plot_organism, $parent_plot_name, $parent_plot, $subplot_name, $subplot_cvterm, $subplot_index_number_save, $subplot_index_number_cvterm, $block_cvterm, $plot_number_cvterm, $replicate_cvterm, $subplot_relationship_cvterm, $field_layout_experiment, $field_layout_cvterm, $inherits_plot_treatments, $treatments, $plot_relationship_cvterm, \%treatment_plots, \%treatment_experiments, $treatment_cvterm);
                $subplot_index_number++;
                $increment++;
            }
        }

        $layout->generate_and_cache_layout();
    };

    eval {
        $self->bcs_schema()->txn_do($create_subplot_entities_txn);
    };
    if ($@) {
        print STDERR "An error occurred creating the subplot entities. $@\n";
        return 0;
    }

    print STDERR "Subplot entities created.\n";
    return 1;
}

sub _save_subplot_entry {
    my $self = shift;
    my $chado_schema = shift;
    my $accession_cvterm = shift;
    my $cross_cvterm = shift;
    my $family_name_cvterm = shift;
    my $parent_plot_organism = shift;
    my $parent_plot_name = shift;
    my $parent_plot = shift;
    my $subplot_name = shift;
    my $subplot_cvterm = shift;
    my $subplot_index_number = shift;
    my $subplot_index_number_cvterm = shift;
    my $block_cvterm = shift;
    my $plot_number_cvterm = shift;
    my $replicate_cvterm = shift;
    my $subplot_relationship_cvterm = shift;
    my $field_layout_experiment = shift;
    my $field_layout_cvterm = shift;
    my $inherits_plot_treatments = shift;
    my $treatments = shift;
    my $plot_relationship_cvterm = shift;
    my $treatment_plots_ref = shift;
    my $treatment_experiments_ref = shift;
    my $treatment_cvterm = shift;
    my $subplot_owner = shift;
    my $subplot_owner_username = shift;
    my %treatment_plots = %$treatment_plots_ref;
    my %treatment_experiments = %$treatment_experiments_ref;

    my $subplot = $chado_schema->resultset("Stock::Stock")->create({
        organism_id => $parent_plot_organism,
        name       => $subplot_name,
        uniquename => $subplot_name,
        type_id => $subplot_cvterm,
    });

    if ($subplot_owner){
        my $stock = CXGN::Stock->new({schema=>$chado_schema,stock_id=>$subplot->stock_id()});
        $stock->associate_owner($subplot_owner,$subplot_owner,$subplot_owner_username, "");
    }

    my $subplotprop = $chado_schema->resultset("Stock::Stockprop")->create( {
        stock_id => $subplot->stock_id(),
        type_id => $subplot_index_number_cvterm,
        value => $subplot_index_number,
    });

    #The subplot inherits the properties of the plot.
    my $plot_props = $chado_schema->resultset("Stock::Stockprop")->search({ stock_id => $parent_plot, type_id => [$block_cvterm, $plot_number_cvterm, $replicate_cvterm] });
    while (my $prop = $plot_props->next() ) {
        #print STDERR $subplot->uniquename()." ".$prop->type_id()."\n";
        $subplotprop = $chado_schema->resultset("Stock::Stockprop")->create( {
            stock_id => $subplot->stock_id(),
            type_id => $prop->type_id(),
            value => $prop->value(),
        });
    }

    #the subplot has a relationship to the plot
    my $stock_relationship = $self->bcs_schema()->resultset("Stock::StockRelationship")->create({
        subject_id => $parent_plot,
        object_id => $subplot->stock_id(),
        type_id => $subplot_relationship_cvterm,
    });

    #the subplot has a relationship to the accession
    my $plot_accession_rs = $self->bcs_schema()->resultset("Stock::StockRelationship")->search({'me.subject_id'=>$parent_plot, 'me.type_id'=>$plot_relationship_cvterm, 'object.type_id'=>[$accession_cvterm, $cross_cvterm, $family_name_cvterm] }, {'join'=>'object'});
    if ($plot_accession_rs->count != 1){
        die "There is not 1 stock_relationship of type plot_of between the plot $parent_plot and an accession, a cross or a family_name.";
    }
    $stock_relationship = $self->bcs_schema()->resultset("Stock::StockRelationship")->create({
        subject_id => $subplot->stock_id(),
        object_id => $plot_accession_rs->first->object_id,
        type_id => $subplot_relationship_cvterm,
    });

    #link subplot to project through nd_experiment. also add nd_genolocation_id of plot to nd_experiment for the subplot
    my $subplot_nd_experiment_stock = $chado_schema->resultset("NaturalDiversity::NdExperimentStock")->create({
        nd_experiment_id => $field_layout_experiment->nd_experiment_id(),
        type_id => $field_layout_cvterm,
        stock_id => $subplot->stock_id(),
    });

    if ($inherits_plot_treatments){
        if($treatments){
            foreach (@$treatments){
                my $plots = $treatment_plots{$_->[0]};
                if (exists($plots->{$parent_plot})){
                    my $subplot_nd_experiment_stock = $chado_schema->resultset("NaturalDiversity::NdExperimentStock")->create({
                        nd_experiment_id => $treatment_experiments{$_->[0]},
                        type_id => $treatment_cvterm,
                        stock_id => $subplot->stock_id(),
                    });
                }
            }
        }
    }
}

=head2 function has_subplot_entries()

        Usage:        $trial->has_subplot_entries();
        Desc:         Some trials require subplot-level data (splitplot designs). This function will determine if a trial has subplots associated with it.
        Ret:          Returns 1 if trial has subplots, 0 if the trial does not.
        Args:
        Side Effects:
        Example:

=cut

sub has_subplot_entries {
        my $self = shift;
        my $chado_schema = $self->bcs_schema();
        my $has_subplots_cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'project_has_subplot_entries', 'project_property' );

        my $rs = $chado_schema->resultset("Project::Projectprop")->find({
                type_id => $has_subplots_cvterm->cvterm_id(),
                project_id => $self->get_trial_id(),
        });

        if ($rs) {
                return 1;
        } else {
                return 0;
        }

}

sub get_planting_date_cvterm_id {
    my $self = shift;
    my $planting_date =  SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'project_planting_date', 'project_property');

    return $planting_date->cvterm_id();

 }

sub get_transplanting_date_cvterm_id {
    my $self = shift;
    my $transplanting_date =  SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'project_transplanting_date', 'project_property');

    return $transplanting_date->cvterm_id();

}

=head2 accessors set_design_type(), get_design_type()

  Usage:        $trial->set_design_type("RCBD");
  Desc:
  Ret:
  Args:
  Side Effects:
  Example:

=cut

sub get_design_type {
     my $self = shift;
     my $design_prop;
     my $design_type;

     my $project = $self->bcs_schema->resultset("Project::Project")->find( { project_id => $self->get_trial_id() });

     $design_prop =  $project->projectprops->find(
         { 'type.name' => 'design' },
         { join => 'type'}
         ); #there should be only one design prop.
     if (!$design_prop) {
         return;
     }
     $design_type = $design_prop->value;
     if (!$design_type) {
         return;
     }
     return $design_type;
}



sub duplicate {
}

=head2 get_accessions

 Usage:        my $accessions = $t->get_accessions();
 Desc:         retrieves the accessions or family names or cross unique ids used in this trial.
 Ret:          an arrayref of { accession_name => acc_name, stock_id => stock_id, stock_type => stock_type }
 Args:         none
 Side Effects:
 Example:

=cut

sub get_accessions {
        my $self = shift;
        my @accessions;

        my $accession_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'accession', 'stock_type' )->cvterm_id();
    my $cross_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'cross', 'stock_type' )->cvterm_id();
    my $family_name_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'family_name', 'stock_type' )->cvterm_id();
        my $field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "field_layout", "experiment_type")->cvterm_id();
        my $plot_of_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "plot_of", "stock_relationship")->cvterm_id();
        my $plant_of_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "plant_of", "stock_relationship")->cvterm_id();
        my $subplot_of_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "subplot_of", "stock_relationship")->cvterm_id();
        my $tissue_sample_of_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "tissue_sample_of", "stock_relationship")->cvterm_id();

        my $q = "SELECT DISTINCT(accession.stock_id), accession.uniquename, cvterm.name
                FROM stock as accession
        JOIN cvterm on (accession.type_id = cvterm.cvterm_id)
                JOIN stock_relationship on (accession.stock_id = stock_relationship.object_id)
                JOIN stock as plot on (plot.stock_id = stock_relationship.subject_id)
                JOIN nd_experiment_stock on (plot.stock_id=nd_experiment_stock.stock_id)
                JOIN nd_experiment using(nd_experiment_id)
                JOIN nd_experiment_project using(nd_experiment_id)
                JOIN project using(project_id)
                WHERE accession.type_id IN (?, ?, ?)
                AND stock_relationship.type_id IN (?, ?, ?, ?)
                AND project.project_id = ?
                ORDER BY accession.stock_id;";

        my $h = $self->bcs_schema->storage->dbh()->prepare($q);
        $h->execute($accession_cvterm_id, $cross_cvterm_id, $family_name_cvterm_id,$plot_of_cvterm_id, $tissue_sample_of_cvterm_id, $plant_of_cvterm_id, $subplot_of_cvterm_id,$self->get_trial_id());
        while (my ($stock_id, $uniquename, $stock_type) = $h->fetchrow_array()) {
                push @accessions, {accession_name=>$uniquename, stock_id=>$stock_id, stock_type=>$stock_type};
        }
        return \@accessions;
}

=head2 get_trial_stock_count

 Usage:        my $stock_count = $t->get_trial_stock_count();
 Desc:         retrieves the count of accessions or family names or cross unique ids used in this trial.
 Ret:          a scalar of the total count
 Args:         none
 Side Effects:
 Example:

=cut

sub get_trial_stock_count {
        my $self = shift;

        my $accessions = $self->get_accessions();
        my $stock_count = scalar(@{$accessions});

        return $stock_count;
}

=head2 get_tissue_sources

    Usage:        my $tissue_sources = $t->get_tissue_sources();
    Desc:         retrieves the sources for the tisue_samples in a trial. in field_layout trials this can only be plants. In genotyping_layout trials the source of a tissue_sample can be tissue_samples, plants, plots, or accessions
    Ret:          an arrayref of { uniquename => acc_name, type=>'plant', stock_id => stock_id }
    Args:         none
    Side Effects:
    Example:

=cut

sub get_tissue_sources {
    my $self = shift;
    my @tissue_samples;
    my $tissue_sample_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'tissue_sample', 'stock_type' )->cvterm_id();
    my $tissue_sample_of_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "tissue_sample_of", "stock_relationship")->cvterm_id();
    my $q = "SELECT DISTINCT(stock.stock_id), stock.uniquename, cvterm.name
        FROM stock
        JOIN cvterm on (stock.type_id = cvterm.cvterm_id)
        JOIN stock_relationship on (stock.stock_id = stock_relationship.object_id)
        JOIN stock as tissue_sample on (tissue_sample.stock_id = stock_relationship.subject_id)
        JOIN nd_experiment_stock on (tissue_sample.stock_id=nd_experiment_stock.stock_id)
        JOIN nd_experiment using(nd_experiment_id)
        JOIN nd_experiment_project using(nd_experiment_id)
        JOIN project using(project_id)
        WHERE tissue_sample.type_id = $tissue_sample_cvterm_id
        AND stock_relationship.type_id = $tissue_sample_of_cvterm_id
        AND project.project_id = ?
        GROUP BY (stock.stock_id, cvterm.name)
        ORDER BY (stock.stock_id);";

    my $h = $self->bcs_schema->storage->dbh()->prepare($q);
    $h->execute($self->get_trial_id());
    while (my ($stock_id, $uniquename, $type) = $h->fetchrow_array()) {
        push @tissue_samples, {uniquename=>$uniquename, type=>$type, stock_id=>$stock_id };
    }
    return \@tissue_samples;
}

=head2 get_plants

 Usage:        $plants = $t->get_plants();
 Desc:         retrieves that plants that are part of the design for this trial.
 Ret:          an array ref containing [ plant_name, plant_stock_id ]
 Args:
 Side Effects:
 Example:

=cut

sub get_plants {
    my $self = shift;
    my @plants;

    my $trial_layout_download = CXGN::Trial::TrialLayoutDownload->new({
        schema => $self->bcs_schema,
        trial_id => $self->get_trial_id(),
        data_level => 'plants',
        selected_columns => {"plant_name"=>1,"plant_id"=>1},
    });
    my $output = $trial_layout_download->get_layout_output()->{output};

    if (defined $output){
        my $header = shift @$output;
        foreach (@$output) {
            push @plants, [$_->[1], $_->[0]];
        }
    } else {
        @plants = @{$self->get_observation_units_direct('plant')};
    }
    return \@plants;
}

=head2 get_plants_per_accession

 Usage:        $plants = $t->get_plants_per_accession();
 Desc:         retrieves that plants that are part of the design for this trial grouping them by accession.
 Ret:          a hash ref containing { $accession_stock_id1 => [ [ plant_name1, plant_stock_id1 ], [ plant_name2, plant_stock_id2 ] ], ... }
 Args:
 Side Effects:
 Example:

=cut

sub get_plants_per_accession {
    my $self = shift;
    my %return;

    my $plant_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'plant', 'stock_type' )->cvterm_id();
    my $accession_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'accession', 'stock_type' )->cvterm_id();
    my $family_name_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'family_name', 'stock_type' )->cvterm_id();
    my $cross_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'cross', 'stock_type' )->cvterm_id();
    my @trial_stock_type_ids;
    push @trial_stock_type_ids, $accession_cvterm_id, $family_name_cvterm_id, $cross_cvterm_id;
    my $trial_plant_rs = $self->bcs_schema->resultset("Project::Project")->find({ project_id => $self->get_trial_id(), })->search_related("nd_experiment_projects")->search_related("nd_experiment")->search_related("nd_experiment_stocks")->search_related("stock", {'stock.type_id'=>$plant_cvterm_id, 'object.type_id'=>{ in => [@trial_stock_type_ids] }}, {join=>{'stock_relationship_subjects'=>'object'}, '+select'=>['stock_relationship_subjects.object_id'], '+as'=>['accession_stock_id']});

    my %unique_plants;
    while(my $rs = $trial_plant_rs->next()) {
        $unique_plants{$rs->uniquename} = [$rs->stock_id, $rs->get_column('accession_stock_id')];
    }
    while (my ($key, $value) = each %unique_plants) {
        push @{$return{$value->[1]}}, [$value->[0], $key];
    }
    #print STDERR Dumper \%return;
    return \%return;
}

=head2 get_seedlots

 Usage:         my $seedlots = $trial->get_seedlots();
 Desc:          returns a list of seedlots that are defined for the trial.
 Ret:           an array ref of elements that contain
                [ seedlot_name, seedlot_stock_id ]
 Args:          none
 Side Effects:  db access
 Example:

=cut

sub get_seedlots {
        my $self = shift;
        my @seedlots;

        my $seedlot_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'seedlot', 'stock_type' )->cvterm_id();
        my $seed_transaction_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "seed transaction", "stock_relationship")->cvterm_id();

        my $q = "SELECT DISTINCT(accession.stock_id), accession.uniquename
                FROM stock as accession
                JOIN stock_relationship on (accession.stock_id = stock_relationship.object_id)
                JOIN stock as plot on (plot.stock_id = stock_relationship.subject_id)
                JOIN nd_experiment_stock on (plot.stock_id=nd_experiment_stock.stock_id)
                JOIN nd_experiment using(nd_experiment_id)
                JOIN nd_experiment_project using(nd_experiment_id)
                JOIN project using(project_id)
                WHERE accession.type_id = $seedlot_cvterm_id
                AND stock_relationship.type_id IN ($seed_transaction_cvterm_id)
                AND project.project_id = ?
                GROUP BY accession.stock_id
                ORDER BY accession.stock_id;";

        #Removed nd_experiment.type_id IN ($field_trial_cvterm_id, $genotyping_trial_cvterm_id) AND

        my $h = $self->bcs_schema->storage->dbh()->prepare($q);
        $h->execute($self->get_trial_id());
        while (my ($stock_id, $uniquename) = $h->fetchrow_array()) {
                push @seedlots, [$stock_id, $uniquename];
        }

        return \@seedlots;
}

=head2 get_plots

 Usage:         my $plots = $trial->get_plots();
 Desc:          returns a list of plots that are defined for the trial.
 Ret:           an array ref of elements that contain
                [ plot_name, plot_stock_id ]
 Args:          none
 Side Effects:  db access
 Example:

=cut

sub get_plots {
    my $self = shift;
    my @plots;

    my $trial_layout_download = CXGN::Trial::TrialLayoutDownload->new({
        schema => $self->bcs_schema,
        trial_id => $self->get_trial_id(),
        data_level => 'plots',
        selected_columns => {"plot_name"=>1,"plot_id"=>1},
    });
    my $output = $trial_layout_download->get_layout_output()->{output};

    if (defined $output){
        my $header = shift @$output;
        foreach (@$output) {
            push @plots, [$_->[1], $_->[0]];
        }
    } else {
        @plots = @{$self->get_observation_units_direct('plot')};
    }
    return \@plots;
}

sub get_observation_units_direct {
    my $self = shift;
    my $stock_type = shift;
    # my $nd_experiment_types = shift || ['field_layout','treatment_experiment','genotyping_layout'];
    my $schema = $self->bcs_schema;
    my @obs;
    my $obs_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($schema, $stock_type, "stock_type")->cvterm_id();
    # my @nd_experiment_type_ids;
    # foreach (@$nd_experiment_types) {
    #     push @nd_experiment_type_ids, SGN::Model::Cvterm->get_cvterm_row($schema, $_, "experiment_type")->cvterm_id();
    # }
    my $q = "SELECT stock.uniquename, stock.stock_id FROM stock JOIN nd_experiment_stock USING(stock_id) JOIN nd_experiment_project USING(nd_experiment_id) WHERE project_id=? AND stock.type_id=? ORDER BY stock.uniquename ASC;";
    my $h = $schema->storage->dbh()->prepare($q);
    $h->execute($self->get_trial_id(), $obs_cvterm_id);
    while (my ($uniquename, $stock_id) = $h->fetchrow_array()) {
        push @obs, [$stock_id, $uniquename];
    }
    return \@obs;
}

=head2 get_plots_per_accession

 Usage:        $plots = $t->get_plots_per_accession();
 Desc:         retrieves that plots that are part of the design for this trial grouping them by accession.
 Ret:          a hash ref containing { $accession_stock_id1 => [ [ plot_name1, plot_stock_id1 ], [ plot_name2, plot_stock_id2 ] ], ... }
 Args:
 Side Effects:
 Example:

=cut

sub get_plots_per_accession {
    my $self = shift;
    my %return;

    # note: this function also retrieves stocks of type tissue_sample (for genotyping plates).
    my $plot_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'plot', 'stock_type' )->cvterm_id();
    my $accession_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'accession', 'stock_type' )->cvterm_id();
    my $cross_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'cross', 'stock_type' )->cvterm_id();
    my $family_name_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'family_name', 'stock_type' )->cvterm_id();
    my $tissue_sample_cvterm = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'tissue_sample', 'stock_type');
    my $tissue_sample_cvterm_id = $tissue_sample_cvterm ? $tissue_sample_cvterm->cvterm_id() : '';

    my @type_ids;
    push @type_ids, $plot_cvterm_id if $plot_cvterm_id;
    push @type_ids, $tissue_sample_cvterm_id if $tissue_sample_cvterm_id;

    print STDERR "TYPE IDS: ".join(", ", @type_ids);

    my @trial_stock_type_ids;
    push @trial_stock_type_ids, $accession_cvterm_id, $cross_cvterm_id, $family_name_cvterm_id;

    my $trial_plot_rs = $self->bcs_schema->resultset("Project::Project")->find({ project_id => $self->get_trial_id(), })->search_related("nd_experiment_projects")->search_related("nd_experiment")->search_related("nd_experiment_stocks")->search_related("stock", {'stock.type_id'=> { in => [@type_ids] }, 'object.type_id'=> { in => [@trial_stock_type_ids] }}, {join=>{'stock_relationship_subjects'=>'object'}, '+select'=>['stock_relationship_subjects.object_id'], '+as'=>['accession_stock_id']});

    my %unique_plots;
    while(my $rs = $trial_plot_rs->next()) {
        $unique_plots{$rs->uniquename} = [$rs->stock_id, $rs->get_column('accession_stock_id')];
    }
    while (my ($key, $value) = each %unique_plots) {
        push @{$return{$value->[1]}}, [$value->[0], $key];
    }
    #print STDERR Dumper \%return;
    return \%return;
}

=head2 get_subplots

 Usage:         my $subplots = $trial->get_subplots();
 Desc:          returns a list of subplots that are defined for the trial.
 Ret:           an array ref of elements that contain
                [ subplot_name, subplot_stock_id ]
 Args:          none
 Side Effects:  db access
 Example:

=cut

sub get_subplots {
    my $self = shift;
    my @subplots;

    my $trial_layout_download = CXGN::Trial::TrialLayoutDownload->new({
        schema => $self->bcs_schema,
        trial_id => $self->get_trial_id(),
        data_level => 'subplots',
        selected_columns => {"subplot_name"=>1,"subplot_id"=>1},
    });
    my $output = $trial_layout_download->get_layout_output()->{output};

    if (defined $output){
        my $header = shift @$output;
        foreach (@$output) {
            push @subplots, [$_->[1], $_->[0]];
        }
    } else {
        @subplots = @{$self->get_observation_units_direct('subplot')};
    }
    print STDERR Dumper \@subplots;
    return \@subplots;
}

=head2 get_tissue_samples

 Usage:        $tissues = $t->get_tissue_samples();
 Desc:         retrieves the tissue samples that are linked to plants for this trial.
 Ret:          an array ref containing [ tissue_sample_name, tissue_sample_stock_id ]
 Args:
 Side Effects:
 Example:

=cut

sub get_tissue_samples {
    my $self = shift;
    my @tissues;

    my $trial_layout_download = CXGN::Trial::TrialLayoutDownload->new({
        schema => $self->bcs_schema,
        trial_id => $self->get_trial_id(),
        data_level => 'field_trial_tissue_samples',
        selected_columns => {"tissue_sample_name"=>1,"tissue_sample_id"=>1},
    });
    my $output = $trial_layout_download->get_layout_output()->{output};
    if (defined $output){
        my $header = shift @$output;
        foreach (@$output) {
            push @tissues, [$_->[1], $_->[0]];
        }
    } else {
        @tissues = @{$self->get_observation_units_direct('tissue_sample')};
    }
    return \@tissues;
}

=head2 get_controls

 Usage:        my $controls = $t->get_controls();
 Desc:         Returns the accessions that were used as controls in the design
 Ret:          an arrayref containing
               { accession_name => control_name, stock_id => control_stock_id }
 Args:         none
 Side Effects:
 Example:

=cut

sub get_controls {
        my $self = shift;
        my @controls;

        my $accession_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'accession', 'stock_type' )->cvterm_id();
        my $field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "field_layout", "experiment_type")->cvterm_id();
        my $genotyping_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "genotyping_layout", "experiment_type")->cvterm_id();
        my $plot_of_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "plot_of", "stock_relationship")->cvterm_id();
        my $plant_of_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "plant_of", "stock_relationship")->cvterm_id();
        my $tissue_sample_of_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "tissue_sample_of", "stock_relationship")->cvterm_id();
        my $control_type_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "is a control", 'stock_property')->cvterm_id();

        my $q = "SELECT DISTINCT(accession.stock_id), accession.uniquename
                FROM stock as accession
                JOIN stock_relationship on (accession.stock_id = stock_relationship.object_id)
                JOIN stock as plot on (plot.stock_id = stock_relationship.subject_id)
                JOIN stockprop as control on (plot.stock_id=control.stock_id)
                JOIN nd_experiment_stock on (plot.stock_id=nd_experiment_stock.stock_id)
                JOIN nd_experiment using(nd_experiment_id)
                JOIN nd_experiment_project using(nd_experiment_id)
                JOIN project using(project_id)
                WHERE accession.type_id = $accession_cvterm_id
                AND stock_relationship.type_id IN ($plot_of_cvterm_id, $tissue_sample_of_cvterm_id, $plant_of_cvterm_id)
                AND project.project_id = ?
                AND control.type_id = $control_type_id
                GROUP BY accession.stock_id
                ORDER BY accession.stock_id;";

        #removed nd_experiment.type_id IN ($field_trial_cvterm_id, $genotyping_trial_cvterm_id) AND

        my $h = $self->bcs_schema->storage->dbh()->prepare($q);
        $h->execute($self->get_trial_id());
        while (my ($stock_id, $uniquename) = $h->fetchrow_array()) {
                push @controls, {accession_name=> $uniquename, stock_id=>$stock_id } ;
        }

        return \@controls;
}

=head2 get_controls_by_plot

 Usage:        my $controls = $t->get_controls_by_plot(\@plot_ids);
 Desc:         Returns the accessions that were used as controls in a trial from a list of trial plot ids. Improves on speed of get_controls by avoiding a join through nd_experiment_stock
 Ret:          an arrayref containing
               { accession_name => control_name, stock_id => control_stock_id }
 Args:         none
 Side Effects:
 Example:

=cut

sub get_controls_by_plot {
        my $self = shift;
        my $plot_ids = shift;
        my @ids = @$plot_ids;
        my @controls;

    my $accession_type_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'accession', 'stock_type')->cvterm_id();
        my $accession_rs = $self->bcs_schema->resultset('Stock::Stock')->search(
                { 'me.type_id'=>$accession_type_id, 'subject.stock_id' => { 'in' => \@ids} , 'type.name' => 'is a control' },
                { join => { stock_relationship_objects => { subject => { stockprops => 'type' }}}, group_by => 'me.stock_id',},
  );

        while(my $accession = $accession_rs->next()) {
                push @controls, { accession_name => $accession->uniquename, stock_id => $accession->stock_id };
        }

        return \@controls;
}

=head2 get_treatments

 Usage:        $plants = $t->get_treatments();
 Desc:         retrieves the treatments that are part of this trial
 Ret:          an array ref containing from project table [ treatment_name, treatment_id ]
 Args:
 Side Effects:
 Example:

=cut

sub get_treatments {
    my $self = shift;
    my @plants;
    my $treatment_rel_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, "trial_treatment_relationship", "project_relationship")->cvterm_id();

    my $treatment_rs = $self->bcs_schema->resultset("Project::ProjectRelationship")->search({ 'me.type_id'=>$treatment_rel_cvterm_id, object_project_id=>$self->get_trial_id()})->search_related('subject_project');

    my @treatments;
    while(my $rs = $treatment_rs->next()) {
        push @treatments, [$rs->project_id, $rs->name];
    }
    return \@treatments;
}

=head2 get_trial_contacts

 Usage:        my $contacts = $t->get_trial_contacts();
 Desc:         Returns an arrayref of hashrefs that contain all sp_person info fpr sp_person_ids saved as projectprops to this trial
 Ret:          an arrayref containing
               { sp_person_id => 1, salutation => 'Mr.', first_name => 'joe', last_name => 'doe', email => 'j@d.com' }
 Args:         none
 Side Effects:
 Example:

=cut

sub get_trial_contacts {
        my $self = shift;
        my @contacts;

        my $sp_person_id_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema,'sp_person_id','local')->cvterm_id;
        my $prop_rs = $self->bcs_schema->resultset('Project::Projectprop')->search(
                { 'project_id' => $self->get_trial_id, 'type_id'=>$sp_person_id_cvterm_id }
        );

        while(my $prop = $prop_rs->next()) {
                my $q = "SELECT sp_person_id, username, salutation, first_name, last_name, contact_email, user_type, phone_number, organization FROM sgn_people.sp_person WHERE sp_person_id=?;";
                my $h = $self->bcs_schema()->storage->dbh()->prepare($q);
                $h->execute($prop->value);
                while (my ($sp_person_id, $username, $salutation, $first_name, $last_name, $email, $user_type, $phone, $organization) = $h->fetchrow_array()){
                        push @contacts, {
                                sp_person_id => $sp_person_id,
                                salutation => $salutation,
                                first_name => $first_name,
                                last_name => $last_name,
                                username => $username,
                                email => $email,
                                type => $user_type,
                                phone_number => $phone,
                organization => $organization
                        };
                }
        }

        return \@contacts;
}


=head2 function get_data_agreement()

        Usage:        $trial->get_data_agreement();
        Desc:         return data agreement saved for trial.
        Ret:
        Args:
        Side Effects:
        Example:

=cut

sub get_data_agreement {
    my $self = shift;
    my $chado_schema = $self->bcs_schema();
    my $cvterm = SGN::Model::Cvterm->get_cvterm_row($chado_schema, 'data_agreement', 'project_property' );

    my $rs = $chado_schema->resultset("Project::Projectprop")->find({
        type_id => $cvterm->cvterm_id(),
        project_id => $self->get_trial_id(),
    });

    if ($rs) {
        return $rs->value();
    } else {
        return;
        }

}

=head2 suppress_plot_phenotype

 Usage:         my $suppress_return_error = $trial->suppress_plot_phenotype($trait_id, $plot_name, $plot_pheno_value, $phenotype_id);
                                 if ($suppress_return_error) {
                                   $c->stash->{rest} = { error => $suppress_return_error };
                                   return;
                                 }

 Desc:         Suppresses plot phenotype
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub suppress_plot_phenotype {
        my $self = shift;
    my $trait_id = shift;
    my $plot_name = shift;
    my $phenotype_value = shift;
        my $phenotype_id = shift;
        my $username = shift;
        my $timestamp = shift;
        my $schema = $self->bcs_schema;
    my $trial_id = $self->get_trial_id();
        my $plot_type_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'plot', 'stock_type')->cvterm_id();
        my $phenotype_outlier_type_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'phenotype_outlier', 'phenotype_property')->cvterm_id();
        my $error;
        my $json_string = { value => 1, username=>$username, timestamp=>$timestamp };

        my $prop_rs = $self->bcs_schema->resultset('Phenotype::Phenotypeprop')->search(
                { 'phenotype_id' => $phenotype_id, 'type_id'=>$phenotype_outlier_type_id }
        );

        if ($prop_rs->count == 0) {
                my $suppress_plot_pheno = $schema->resultset("Phenotype::Phenotypeprop")->create({
                        phenotype_id => $phenotype_id,
                        type_id       => $phenotype_outlier_type_id,
                        value => encode_json $json_string,
                });
        }
        else {
                $error = "This plot phenotype has already been suppressed.";
        }

        return $error;

}

=head2 delete_assayed_trait

Usage:          my $delete_trait_return_error = $trial->delete_assayed_trait($c->config->{basepath}, $c->config->{dbhost}, $c->config->{dbname}, $c->config->{dbuser}, $c->config->{dbpass}, $phenotypes_ids, [] );
                if ($delete_trait_return_error) {
                    $c->stash->{rest} = { error => $delete_trait_return_error };
                    return;
                }

 Desc:         Delete Assayed Traits
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub delete_assayed_trait {
    my $self = shift;
    my $basepath = shift;
    my $dbhost = shift;
    my $dbname = shift;
    my $dbuser = shift;
    my $dbpass = shift;
    my $temp_file_nd_experiment_id = shift;
    my $pheno_ids = shift;
    my $trait_ids = shift;

    my $trial_id = $self->get_trial_id();
    my $schema = $self->bcs_schema;
    my $phenome_schema = $self->phenome_schema;
    my ($error, @nd_expt_ids);
    my $nd_experiment_type_id = SGN::Model::Cvterm->get_cvterm_row($schema, 'phenotyping_experiment', 'experiment_type')->cvterm_id();
    my $search_params = { 'nd_experiment.type_id' => $nd_experiment_type_id, 'nd_experiment_projects.project_id' => $trial_id };
    if (scalar(@$trait_ids) > 0){
        $search_params->{'me.observable_id'} = { '-in' => $trait_ids };
    }
    if (scalar(@$pheno_ids) > 0){
        $search_params->{'me.phenotype_id'} = { '-in' => $pheno_ids };
    }
    #$schema->storage->debug(1);
    if (scalar(@$pheno_ids) > 0 || scalar(@$trait_ids) > 0 ){
        my %phenotype_ids_and_nd_experiment_ids_to_delete;
        my $delete_pheno_id_rs = $schema->resultset("Phenotype::Phenotype")->search(
        $search_params,
        {
            join => { 'nd_experiment_phenotypes' => {'nd_experiment' => 'nd_experiment_projects'} },
            '+select' => ['nd_experiment.nd_experiment_id'],
            '+as' => ['nd_expt_id'],
        });
        while ( my $res = $delete_pheno_id_rs->next()){
            push @{$phenotype_ids_and_nd_experiment_ids_to_delete{nd_experiment_ids}}, $res->get_column('nd_expt_id');
            push @{$phenotype_ids_and_nd_experiment_ids_to_delete{phenotype_ids}}, $res->phenotype_id;
        }
        return delete_phenotype_values_and_nd_experiment_md_values($dbhost, $dbname, $dbuser, $dbpass, $temp_file_nd_experiment_id, $basepath, $schema, \%phenotype_ids_and_nd_experiment_ids_to_delete);
    }
    else {
        $error = "List of trait or phenotype ids was not provided for deletion.";
    }
    return $error;
}

=head2 function delete_empty_crossing_experiment()

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub delete_empty_crossing_experiment {
    my $self = shift;

    if ($self->cross_count() > 0) {
        return 'Cannot delete crossing experiment with associated crosses.';
    }

    my $project_owner_schema = CXGN::Phenome::Schema->connect( sub {$self->bcs_schema->storage->dbh()},{on_connect_do => ['SET search_path TO public,phenome;']});
    my $project_owner_row = $project_owner_schema->resultset('ProjectOwner')->find( { project_id=> $self->get_trial_id() });
    if ($project_owner_row) {
        $project_owner_row->delete();
    }

    eval {
        my $row = $self->bcs_schema->resultset("Project::Project")->find( { project_id=> $self->get_trial_id() });
        $row->delete();
    print STDERR "deleted project ".$self->get_trial_id."\n";
    };
    if ($@) {
        print STDERR "An error occurred during deletion: $@\n";
        return $@;
    }
}

=head2 function cross_count()

 Usage:
 Desc:         The number of crosses associated with this crossing experiment
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub cross_count {
    my $self = shift;
    my $schema = $self->bcs_schema;
    my $crossing_experiment_type_id = SGN::Model::Cvterm->get_cvterm_row($schema, "cross_experiment", "experiment_type")->cvterm_id();

    my $q = "SELECT count(nd_experiment_project.nd_experiment_id)
        FROM nd_experiment_project
        JOIN nd_experiment on (nd_experiment_project.nd_experiment_id = nd_experiment.nd_experiment_id)
        WHERE nd_experiment.type_id = $crossing_experiment_type_id
        AND nd_experiment_project.project_id = ?";
    my $h = $self->bcs_schema->storage->dbh()->prepare($q);
    $h->execute($self->get_trial_id());
    my ($count) = $h->fetchrow_array();
    return $count;
}



=head2 delete_genotyping_plate_and_field_trial_linkage

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub delete_genotyping_plate_from_field_trial_linkage {
    my $self = shift;
    my $field_trial_id = shift;
    my $role = shift;
    my $plate_id = $self->get_trial_id();

    my @errors;

    #Make sure to have the right access to delete
    if ($role ne "curator") {
        push @errors, "Only a curator can delete this linkage.";
        return { errors => \@errors };
    }

    my $genotyping_trial_from_field_trial_cvterm_id = SGN::Model::Cvterm->get_cvterm_row($self->bcs_schema, 'genotyping_trial_from_field_trial', 'project_relationship')->cvterm_id();
    # check ownership of that image
    my $q = "SELECT project_relationship.project_relationship_id from project  join project_relationship on(project_id= subject_project_id)  join project as genotypeproject on (genotypeproject.project_id= project_relationship.object_project_id) where genotypeproject.project_id=? and project.project_id=? and project_relationship.type_id=?;";

    my $dbh = $self->bcs_schema->storage()->dbh();
    my $h = $dbh->prepare($q);

    $h->execute($plate_id, $field_trial_id,$genotyping_trial_from_field_trial_cvterm_id);

    if ($h->rows() == 1){
        if (my ($project_relationship_id) = $h->fetchrow_array()) {
            my $uq = "DELETE from project_relationship where project_relationship_id = ? and type_id = ? ";
            my $uh = $dbh->prepare($uq);
            $uh->execute($project_relationship_id,$genotyping_trial_from_field_trial_cvterm_id);
        }
        else {
            push @errors, "An error occurred during deletion.";
        }
    } else {
        push @errors, "Project relationship does not exists or has more than 1 occurrence.";
    }

    if (@errors >0) {
    return { errors => \@errors };
    }

    return { success => 1 };


}


=head2 function delete_empty_genotyping_project()

 Usage:
 Desc:
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub delete_empty_genotyping_project {
    my $self = shift;

    if ($self->genotyping_plate_count() > 0) {
        return 'Cannot delete genotyping project with associated genotyping plates.';
    }

    if ($self->genotyping_protocol_count() > 0) {
        return 'Cannot delete genotyping project with associated genotyping protocol.';
    }

    my $project_owner_schema = CXGN::Phenome::Schema->connect( sub {$self->bcs_schema->storage->dbh()},{on_connect_do => ['SET search_path TO public,phenome;']});
    my $project_owner_row = $project_owner_schema->resultset('ProjectOwner')->find( { project_id=> $self->get_trial_id() });
    if ($project_owner_row) {
        $project_owner_row->delete();
    }

    eval {
        my $row = $self->bcs_schema->resultset("Project::Project")->find( { project_id=> $self->get_trial_id() });
        $row->delete();
        print STDERR "deleted project ".$self->get_trial_id."\n";
    };
    if ($@) {
        print STDERR "An error occurred during deletion: $@\n";
        return $@;
    }
}


=head2 function genotyping_plate_count()

 Usage:
 Desc: The number of genotyping plates associated with this genotyping project
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub genotyping_plate_count {
    my $self = shift;
    my $schema = $self->bcs_schema;
    my $genotyping_project_id = $self->get_trial_id();

    my $plate_info = CXGN::Genotype::GenotypingProject->new({
        bcs_schema => $schema,
        project_id => $genotyping_project_id
    });
    my ($data, $plate_count) = $plate_info->get_plate_info();

    return $plate_count;
}


=head2 function genotyping_protocol_count()

 Usage:
 Desc: The number of genotyping protocols associated with this genotyping project
 Ret:
 Args:
 Side Effects:
 Example:

=cut

sub genotyping_protocol_count {
    my $self = shift;
    my $schema = $self->bcs_schema;
    my $genotyping_project_id = $self->get_trial_id();
    my @project_list = ($genotyping_project_id);
    my $protocol_search_result = CXGN::Genotype::Protocol::list($schema, undef, undef, undef, undef, undef ,\@project_list);

    my $protocol_count;
    if ($protocol_search_result) {
        $protocol_count = scalar(@$protocol_search_result);
    }

    return $protocol_count;

}




1;

##__PACKAGE__->meta->make_immutable;