fixed import of ht stats so it doesn't include last month since that is always No...
[eq/.git] / bin / import_ward_data
index 6bbfe5657c72c750d25b1dd097ec60d8b06c8a03..a9e70c6f3136a709f74afd4ae9fd72b8c4697bb7 100755 (executable)
@@ -138,13 +138,19 @@ sub update_tc_individual_table
                $phone = $membership_data{$index}{'Household Phone'};
                $priesthood = $membership_data{$index}{'Priesthood'};
                $hhposition = $membership_data{$index}{'HH Position'};
-               $organization = $organization_by_id{$id};
+               $steward = ""; # This will be set correctly in a later method
+               # Set the default stewardship if the "Organization data per member.csv" isn't available.
+               # Only validate priesthood holders that match the $default_stewardship since 
+               # we don't have any other data available to us to make this call if we don't have the report.
+               if((! -e "$datadir/Organization\ class\ per\ member.csv") && ($priesthood =~ /$default_stewardship/i)) { 
+                       $steward = "$default_stewardship";
+               }
                $attending = 0;
                if(($organization =~ /Elders/) ||
                   ($organization =~ /Young Men/) ||
                   ($organization =~ /Sunday School/) ||
                   ($organization =~ /Primary/)
-                  ) { $attending = 1; }
+                 ) { $attending = 1; }
                if($phone =~ /(\d\d\d-\d\d\d\d)/) { $phone = "$areacode-$1"; }
                if($phone =~ /^\(\d\d\d\) (\d\d\d-\d\d\d\d)/) { $phone = "$1-$2"; }
                $email = $membership_data{$index}{'indiv E-mail'};
@@ -157,7 +163,7 @@ sub update_tc_individual_table
                if($rows == 0) {
                        # No existing records found for this individual, make a new entry
                        print "   Adding new individual: $individual_name\n";
-                       $sth = $dbh->prepare("insert into tc_individual values (NULL,'$id',\"$individual_name\",'$address','$phone','$email','$hhposition','$priesthood','',NULL,$attending,1)");
+                       $sth = $dbh->prepare("insert into tc_individual values (NULL,'$id',\"$individual_name\",'$address','$phone','$email','$hhposition','$priesthood','$steward',NULL,$attending,1)");
                        $sth->execute or die "-E- DB error: $DBI::errstr\n";
                } elsif($rows == 1) {
                        # An existing record was found for this individual, update it
@@ -221,6 +227,7 @@ sub update_tc_calling_table()
                $name =~ s/\'/\\'/g; #'
                $organization = $organization_data{$index}{'Organization'};
                $organization_by_name{$name} = $organization;
+               $indiv_id = $organization_data{$index}{'Indiv ID'};
                $organization_by_id{$indiv_id} = $organization;
                $position = $organization_data{$index}{'Position'};
                $sustained = $organization_data{$index}{'Sustained'};
@@ -232,37 +239,6 @@ sub update_tc_calling_table()
        }
 }
 
-# TC_DISTRICT
-#+------------+------------------+------+-----+---------+-------+
-#| Field      | Type             | Null | Key | Default | Extra |
-#+------------+------------------+------+-----+---------+-------+
-#| district   | int(16) unsigned |      | PRI | 0       |       |
-#| name       | varchar(30)      | YES  |     | NULL    |       |
-#| supervisor | int(16) unsigned | YES  |     | NULL    |       |
-#| valid      | tinyint(1)       | YES  |     | NULL    |       |
-#+------------+------------------+------+-----+---------+-------+
-sub update_tc_district_table
-{
-    # Districts should be created by hand. This subroutine only
-    # updates the supervisor's ID in each district.
-    print "\n-> Updating tc_district table\n";
-    $sth = $dbh->prepare("select * from tc_district");
-    $sth->execute or die "-E- DB error: $DBI::errstr\n";
-    while($sqlhashref = $sth->fetchrow_hashref) {
-               $supervisor_name = $sqlhashref->{name};
-               $district = $sqlhashref->{district};
-               $sth2 = $dbh->prepare("select * from tc_individual where name='$supervisor_name'");
-               $sth2->execute or die "-E- DB error: $DBI::errstr\n";
-               $sqlhashref2 = $sth2->fetchrow_hashref;
-               $supervisor_id = $sqlhashref2->{individual};
-               $sth2->finish();
-               $sth2 = $dbh->prepare("update tc_district set supervisor='$supervisor_id' where district='$district'");
-               $sth2->execute or die "-E- DB error: $DBI::errstr\n";
-               $sth2->finish();
-    }
-    $sth->finish();
-}
-
 # TC_COMPANIONSHIP
 #+----------------------+------------------+------+-----+---------+-------+
 #| Field                | Type             | Null | Key | Default | Extra |
@@ -426,6 +402,8 @@ sub update_tc_visit_table
        ($second, $minute, $hour, $dayOfMonth, $month, $yearOffset, $dayOfWeek, $dayOfYear, $daylightSavings) = localtime();
        my %visit_status = ('X', 'y', '-', 'n', '', '');
        
+       $sth = $dbh->prepare("TRUNCATE TABLE tc_visit");
+       $sth->execute or die "-E- DB error: $DBI::errstr\n";
        foreach $index (keys %hometeaching_stats_data)
        {
                $hashref = $hometeaching_stats_data{$index};
@@ -472,7 +450,7 @@ sub update_tc_visit_table
                #print "$month_header\n";
                #print $hometeaching_stats_data{$index}{$month_header};
                #print "\n";
-               foreach $i (reverse(0..$#history)) {
+               foreach $i (reverse(0..$#history-1)) {
                        # went back a calendar year, decrement $data_year
                        if ($months{$data_months[$i]} > $data_month)
                        {
@@ -575,8 +553,7 @@ sub update_tc_scheduling_priority_table
        print "\n-> Updating scheduling priority table\n";
        
        # individuals
-       # TODO: make steward flexible with a setting in the config file
-       $sth = $dbh->prepare("select * from tc_individual where steward='Elder' and valid=1");
+       $sth = $dbh->prepare("select * from tc_individual where steward='$default_stewardship' and valid=1");
        $sth->execute or die "-E- DB error: $DBI::errstr\n";
        while($sqlhashref = $sth->fetchrow_hashref) {
                $individual = $sqlhashref->{individual};
@@ -590,10 +567,10 @@ sub update_tc_scheduling_priority_table
                        $sth2->execute or die "-E- DB error: $DBI::errstr\n";
                }
        }
+       &remove_obsolete_scheduling_priority("tc_individual");
        
        # families
-       # TODO: make steward flexible with a setting in the config file
-       $sth = $dbh->prepare("select tf.scheduling_priority, tf.family from tc_family AS tf JOIN tc_individual AS ti ON tf.individual=ti.individual and ti.steward='Elder' and tf.valid=1");
+       $sth = $dbh->prepare("select tf.scheduling_priority, tf.family from tc_family AS tf JOIN tc_individual AS ti ON tf.individual=ti.individual and ti.steward='$default_stewardship' and tf.valid=1");
        $sth->execute or die "-E- DB error: $DBI::errstr\n";
        while($sqlhashref = $sth->fetchrow_hashref) {
                $family = $sqlhashref->{family};
@@ -608,10 +585,10 @@ sub update_tc_scheduling_priority_table
                        $sth2->execute or die "-E- DB error: $DBI::errstr\n";
                }
        }
+       &remove_obsolete_scheduling_priority("tc_family");
        
        # companionships
-       # TODO: make steward flexible with a setting in the config file
-       $sth = $dbh->prepare("select tc.individual, tc.scheduling_priority from tc_companionship AS tc JOIN tc_individual AS ti ON tc.individual=ti.individual and (ti.steward='Elder' or ti.steward='') and tc.valid=1");
+       $sth = $dbh->prepare("select tc.individual, tc.scheduling_priority from tc_companionship AS tc JOIN tc_individual AS ti ON tc.individual=ti.individual and (ti.steward='$default_stewardship' or ti.steward='') and tc.valid=1");
        $sth->execute or die "-E- DB error: $DBI::errstr\n";
        while($sqlhashref = $sth->fetchrow_hashref) {
                $individual = $sqlhashref->{individual};
@@ -626,7 +603,35 @@ sub update_tc_scheduling_priority_table
                        $sth2->execute or die "-E- DB error: $DBI::errstr\n";
                }
        }
+       &remove_obsolete_scheduling_priority("tc_companionship");
+}
+
+sub remove_obsolete_scheduling_priority
+{
+       my $table_name = $_[0];
+
+       #print "\n-> Cleaning $table_name\n";
        
+       #$sth = $dbh->prepare("SELECT scheduling_priority FROM $table_name where scheduling_priority IS NOT NULL AND valid=0");
+       $sth = $dbh->prepare("SELECT * FROM $table_name WHERE valid=0");
+       $sth->execute or die "-E- DB error: $DBI::errstr\n";
+       while($sqlhashref = $sth->fetchrow_hashref) {
+               $scheduling_priority = $sqlhashref->{scheduling_priority};
+               $individual = $sqlhashref->{individual};
+               #$name = $sqlhashref->{name};
+               if ($scheduling_priority != "NULL") {
+                       #print "$name\n";
+                       # set scheduling_priority to NULL
+                       #print "UPDATE $table_name SET scheduling_priority=NULL WHERE individual=$individual\n";
+                       $sth2 = $dbh->prepare("UPDATE $table_name SET scheduling_priority=NULL WHERE individual=$individual");
+                       $sth2->execute or die "-E- DB error: $DBI::errstr\n";
+                       
+                       # remove entry from tc_scheduling_priority
+                       #print "DELETE FROM tc_scheduling_priority WHERE scheduling_priority=$scheduling_priority\n";
+                       $sth2 = $dbh->prepare("DELETE FROM tc_scheduling_priority WHERE scheduling_priority=$scheduling_priority");
+                       $sth2->execute or die "-E- DB error: $DBI::errstr\n";
+               }
+       }
 }
 
 ######################################################################
@@ -664,13 +669,14 @@ if(defined $opt_o) {
 
 ###################################################
 # Process command line options
+our $datadir;
 if(defined $opt_n) { $datadir = $opt_n; }
 else { $datadir = shift(@ARGV); }
 print "\n-> Processing all ward data files in $datadir\n";
 
 ###################################################
 # Parse Ward Data Files
-&csv_to_hash("$datadir/Organization\ class\ per\ member.csv", \%organization_class_data);
+&optional_csv_to_hash("$datadir/Organization\ class\ per\ member.csv", \%organization_class_data);
 &csv_to_hash("$datadir/Membership.csv",\%membership_data);
 &csv_to_hash("$datadir/HomeTeaching.csv",\%hometeaching_data);
 &csv_to_hash("$datadir/Organization.csv",\%organization_data);
@@ -691,10 +697,9 @@ if($opt_v) {
 
 if($opt_s) { $dbh->disconnect(); exit; }
 
-# Now update the various eq DB tables
+# Now update the various DB tables
 &update_tc_calling_table();
 &update_tc_individual_table();
-&update_tc_district_table();
 &update_tc_companionship_table();
 &update_tc_family_table();
 &update_tc_visit_table();