2 files changed, 73 insertions, 0 deletions
diff --git a/perllib/FixMyStreet/DB/ResultSet/Nearby.pm b/perllib/FixMyStreet/DB/ResultSet/Nearby.pm
new file mode 100644
index 000000000..3b3a3d90b
--- /dev/null
+++ b/perllib/FixMyStreet/DB/ResultSet/Nearby.pm
@@ -0,0 +1,50 @@
+package FixMyStreet::DB::ResultSet::Nearby;
+use base 'DBIx::Class::ResultSet';
+
+use strict;
+use warnings;
+
+sub nearby {
+    my ( $rs, $c, $dist, $ids, $limit, $mid_lat, $mid_lon, $interval ) = @_;
+
+    my $params = {
+        state => [ 'confirmed', 'fixed' ],
+    };
+    $params->{'current_timestamp-lastupdate'} = { '<', \"'$interval'::interval" }
+        if $interval;
+    $params->{id} = { -not_in => $ids }
+        if $ids;
+    $params = {
+        %{ $c->cobrand->problems_clause },
+        %$params
+    } if $c->cobrand->problems_clause;
+
+    my $attrs = {
+        join => 'problem',
+        columns => [
+            'problem.id', 'problem.title', 'problem.latitude',
+            'problem.longitude', 'distance', 'problem.state',
+            'problem.confirmed'
+        ],
+        bind => [ $mid_lat, $mid_lon, $dist ],
+        order_by => [ 'distance', { -desc => 'created' } ],
+        rows => $limit,
+    };
+
+    my @problems = mySociety::Locale::in_gb_locale { $rs->search( $params, $attrs )->all };
+    return \@problems;
+}
+
+# XXX Not currently used, so not migrating at present.
+#sub fixed_nearby {
+#    my ($dist, $mid_lat, $mid_lon) = @_;
+#    mySociety::Locale::in_gb_locale { select_all(
+#        "select id, title, latitude, longitude, distance
+#        from problem_find_nearby(?, ?, $dist) as nearby, problem
+#        where nearby.problem_id = problem.id and state='fixed'
+#        site_restriction
+#        order by lastupdate desc", $mid_lat, $mid_lon);
+#    }
+#}
+
+1;
diff --git a/perllib/FixMyStreet/DB/ResultSet/Problem.pm b/perllib/FixMyStreet/DB/ResultSet/Problem.pm
index af850ecd0..ea146cd54 100644
--- a/perllib/FixMyStreet/DB/ResultSet/Problem.pm
+++ b/perllib/FixMyStreet/DB/ResultSet/Problem.pm
@@ -63,6 +63,29 @@ sub recent {
     return $result;
 }
 
+# Problems around a location
+
+sub around_map {
+    my ( $rs, $min_lat, $max_lat, $min_lon, $max_lon, $interval, $limit ) = @_;
+    my $attr = {
+        order_by => { -desc => 'created' },
+        columns => [
+            'id', 'title' ,'latitude', 'longitude', 'state', 'confirmed'
+        ],
+    };
+    $attr->{rows} = $limit if $limit;
+
+    my $q = {
+            state => [ 'confirmed', 'fixed' ],
+            latitude => { '>=', $min_lat, '<', $max_lat },
+            longitude => { '>=', $min_lon, '<', $max_lon },
+    };
+    $q->{'current_timestamp - lastupdate'} = { '<', \"'$interval'::interval" };
+
+    my @problems = mySociety::Locale::in_gb_locale { $rs->search( $q, $attr )->all };
+    return \@problems;
+}
+
 # Admin functions
 
 sub timeline {