MT#20027 porting number history

-drop all misleading lnp_number unique keys again
-retain lnp_provider delete cascade restrict
-lnp_numbers_actual dbix virtual view
 +groupwise maximums solely by "number"
  (no lnp_provider_id!)

Change-Id: If075ddc445825140151855ff3cc64aa63404645e

lib/NGCP/Schema/Result/lnp_numbers.pm

@@ -43,8 +43,6 @@ __PACKAGE__->add_columns(
 
 __PACKAGE__->set_primary_key("id");
 
-__PACKAGE__->add_unique_constraint("l_n_lnpproidnumber_idx", ["lnp_provider_id", "number"]);
-
 __PACKAGE__->belongs_to(
   "lnp_provider",
   "NGCP::Schema::Result::lnp_providers",
@@ -52,6 +50,14 @@ __PACKAGE__->belongs_to(
   { is_deferrable => 1, on_delete => "RESTRICT", on_update => "CASCADE" },
 );
 
+__PACKAGE__->has_many(
+  "lnp_numbers_actual",
+  "NGCP::Schema::Result::lnp_numbers_actual",
+  { "foreign.actual_ln_id" => "self.id" },
+  { join_type => 'inner' },
+  { cascade_copy => 0, cascade_delete => 0 },
+);
+
 sub TO_JSON {
     my ($self) = @_;
     return {

lib/NGCP/Schema/Result/lnp_numbers_actual.pm

@@ -0,0 +1,78 @@
+package NGCP::Schema::Result::lnp_numbers_actual;
+use Scalar::Util qw(blessed);
+use base qw/DBIx::Class::Core/;
+
+our $VERSION = '2.007';
+
+__PACKAGE__->load_components(
+  "InflateColumn::DateTime",
+  "Helper::Row::ToJSON",
+  #"+NGCP::Schema::InflateColumn::DateTime::EpochMicro",
+);
+__PACKAGE__->table_class('DBIx::Class::ResultSource::View');
+__PACKAGE__->table("lnp_numbers_actual");
+
+
+__PACKAGE__->add_columns(
+  "actual_ln_id",
+  {
+    data_type => "integer",
+    extra => { unsigned => 1 },
+    is_auto_increment => 1,
+    is_nullable => 0,
+  },
+  "number",
+  {
+    data_type => "varchar",
+    is_nullable => 0,
+    size => 31
+  },
+);
+
+
+__PACKAGE__->has_many(
+  "lnp_numbers",
+  "NGCP::Schema::Result::lnp_numbers",
+  { "foreign.number" => "self.number" },
+  { cascade_copy => 0, cascade_delete => 0 },
+);
+
+__PACKAGE__->set_primary_key("actual_ln_id");
+
+sub TO_JSON {
+    my ($self) = @_;
+    return {
+        map { blessed($_) && $_->isa('DateTime') ? $_->datetime : $_ } %{ $self->next::method }
+    };
+}
+
+__PACKAGE__->result_source_instance->is_virtual(1);
+
+#select
+#  p.id,
+#  p.prefix,
+#  n.number,
+#  n.routing_number
+#from
+#  billing.lnp_numbers n
+#  left join billing.lnp_providers p on n.lnp_provider_id = p.id
+#where
+#  n.number in ("1", "12", "123", "1234")
+#  and (n.start is null or n.start <= now())
+#  and (n.end is null or n.end >= now())
+#order by length(n.number) desc limit 1
+
+__PACKAGE__->result_source_instance->view_definition("
+select ln.number,max(ln.id) as actual_ln_id from billing.lnp_numbers ln
+    inner join
+        (select lnn.number, max(lnn.start) max_start
+        from billing.lnp_numbers lnn
+        where ( lnn.`end` >= ? OR lnn.`end` IS NULL )
+            AND ( lnn.`start` <= ? OR lnn.`start` IS NULL )
+            AND ( ? is null OR lnn.`number` LIKE ? )
+        group by lnn.number
+    ) lnn on ln.number=lnn.number and (ln.start=lnn.max_start or (lnn.max_start is null and ln.start is null))
+group by ln.number
+");
+
+1;