Update to new database structure

[NDIRC.git] / Commands / Def.pm

diff --git a/Commands/Def.pm b/Commands/Def.pm
index e8067dd7a50b27ad147526a8bdf66acf51688914..1731689e12689e673d06cec3e0d1543e9acbb80c 100644 (file)
--- a/Commands/Def.pm
+++ b/Commands/Def.pm
@@ -53,25 +53,24 @@ sub defcall
        my $callinfo = "";
        if ($callnr){
                my $st = $dbh->prepare(q{
-SELECT covered
+SELECT status
        ,c.landing_tick - (SELECT value::integer FROM misc WHERE id = 'TICK') AS eta
        ,concat(i.shiptype||'/') AS shiptype
 FROM calls c
-       JOIN incomings i ON i.call = c.id
+       JOIN incomings i USING (call)
        LEFT OUTER JOIN users dc ON dc.uid = c.dc
-       JOIN users u ON u.uid = c.member
-WHERE c.id = ?
-GROUP BY c.id,c.landing_tick,c.covered
+WHERE c.call = ?
+GROUP BY c.call,c.landing_tick,c.status
 ORDER BY c.landing_tick;
                });
                my $call = $dbh->selectrow_hashref($st,undef,$callnr);
-               unless (defined $call->{covered}){
+               unless (defined $call->{status}){
                        $c->reply("No call with id: $callnr");
                        return;
                }
                chop($call->{shiptype});
                $callinfo = "(Anti $call->{shiptype} ETA: $call->{eta})";
-               if($call->{covered}){
+               if($call->{status} eq 'Covered'){
                        $c->reply("Call <b>$callnr</b> $callinfo is covered.");
                        return;
                }
@@ -91,10 +90,10 @@ sub settype
        my $dbh = $c->model;
 
        my $query = q{
-SELECT i.id,call,shiptype, coords(x,y,z),c.landing_tick - tick() AS eta
+SELECT inc,call,shiptype, coords(x,y,z),c.landing_tick - tick() AS eta
 FROM incomings i
-       JOIN current_planet_stats p ON i.sender = p.id
-       JOIN calls c ON i.call = c.id
+       JOIN current_planet_stats p USING (pid)
+       JOIN calls c USING (call)
        };
        my $fleets;
        my $type;
@@ -104,20 +103,20 @@ FROM incomings i
                ($call,$type) = $msg =~ /^(\d+) (.*)$/ or die 'ARGS';
 
                $fleets = $dbh->prepare($query . q{
-WHERE i.call = ?
+WHERE call = ?
                });
                $fleets->execute($call);
        }else{
                my ($id,$x,$y,$z,$t) = $msg =~ /^(\d+) (\d+):(\d+):(\d+) (.*)$/;
                if (defined $id){
                        $fleets = $dbh->prepare($query . q{
-WHERE i.call = ? AND p.id = planetid(?,?,?,tick())
+WHERE call = ? AND pid = planetid(?,?,?,tick())
                        });
                        $fleets->execute($id,$x,$y,$z);
                }else{
                        ($id,$t) = $msg =~ /^(\d+) (.*)$/ or die 'ARGS';
                        $fleets = $dbh->prepare($query . q{
-WHERE i.id = ?
+WHERE inc = ?
                        });
                        $fleets->execute($id);
                }
@@ -127,7 +126,7 @@ WHERE i.id = ?
        $type = CGI::escapeHTML($type);
        $dbh->begin_work;
        my $deflog = '';
-       my $settype = $dbh->prepare(q{UPDATE incomings SET shiptype = ? WHERE id = ?});
+       my $settype = $dbh->prepare(q{UPDATE incomings SET shiptype = ? WHERE inc = ?});
        while (my $inc = $fleets->fetchrow_hashref){
                $call //= $inc->{call};
                if ($inc->{eta} < 0){
@@ -137,9 +136,9 @@ WHERE i.id = ?
                        $dbh->rollback;
                        return;
                }
-               $settype->execute($type,$inc->{id});
-               $deflog .= "Set fleet: [B]$inc->{id} [/B] to: [B]$type [/B]\n";
-               $c->reply("Set fleet $inc->{id} from $inc->{coords} on call $call to $type (previously $inc->{shiptype})");
+               $settype->execute($type,$inc->{inc});
+               $deflog .= "Set fleet: [B]$inc->{inc} [/B] to: [B]$type [/B]\n";
+               $c->reply("Set fleet $inc->{inc} from $inc->{coords} on call $call to $type (previously $inc->{shiptype})");
        }
        if ($fleets->rows == 0){
                $c->reply("No matching fleets");
@@ -150,5 +149,82 @@ WHERE i.id = ?
        }
 }
 
+sub calltake
+       : Help(Usage: .calltake callid | sets the dc. also markes as covered/ignored with .callcov and .callignore)
+       : Type(def)
+       : ACL(irc_calltake)
+       : Alias(qw/callcov callignore/)
+{
+       my ($self,$c,$msg) = @_;
+       my ($id) = $msg =~ /^(\d+)$/ or die 'ARGS';
+       my $dbh = $c->model;
+
+       my $status = 'Open';
+
+       given ($self->{name}){
+               when('callignore'){
+                       $status = 'Ignored';
+               }
+               when('callcov'){
+                       $status = 'Covered';
+               }
+       }
+
+       $dbh->begin_work;
+       my $rows = $dbh->do(q{
+UPDATE calls SET dc = (SELECT uid FROM users WHERE hostmask ILIKE $1)
+       ,status = $3
+WHERE call = $2
+               },undef,$c->host,$id,$status);
+       if ($rows == 1){
+               $c->reply("Setting status on call $id to $status");
+               $c->def_log($id , "Changed status: [B]$status [/B]");
+               $dbh->commit;
+       }else{
+               $c->reply("$id is not a valid call");
+               $dbh->rollback;
+       }
+}
+
+sub setcalc
+       : Help(Usage: .setcalc callId calc | sets the calc for the given call.)
+       : Type(def)
+       : ACL(irc_setcalc)
+{
+       my ($self,$c,$msg) = @_;
+       my ($id,$calc) = $msg =~ /^(\d+) (.+)$/ or die 'ARGS';
+       my $dbh = $c->model;
+
+       $dbh->begin_work;
+       my $rows = $dbh->do(q{UPDATE calls SET calc = $2 WHERE id = $1}
+               ,undef,$id, $calc);
+       if ($rows == 1){
+               $c->reply("Updated calc call <b>$id</b>");
+               $calc = CGI::escapeHTML($calc);
+               $c->def_log($id , 'Updated calc to: [URL]'.$calc.'[/URL]');
+               $dbh->commit;
+       }else{
+               $c->reply("$id is not a valid call");
+               $dbh->rollback;
+       }
+}
+
+sub getcalc
+       : Help(Usage: .getcalc callId | receives the calc for the given call)
+       : Type(def)
+       : ACL(irc_getcalc)
+{
+       my ($self,$c,$msg) = @_;
+       my ($id) = $msg =~ /^(\d+)$/ or die 'ARGS';
+       my $dbh = $c->model;
+
+       my $calc = $dbh->selectrow_array(q{
+SELECT calc FROM calls WHERE id = $1}
+               ,undef,$id);
+       $calc //= "Bad call id, there is no such call.";
+       $c->reply("Calc for call <b>$id</b>: $calc");
+}
+
+
 1;