From 6369551008e0f181e902431e6a8ab3299c298b53 Mon Sep 17 00:00:00 2001
From: Terry Brady <terrence.brady@ucop.edu>
Date: Wed, 1 May 2024 15:33:17 -0700
Subject: [PATCH] objtime

---
 src-admintool/config/reports.yml              |  12 ++
 .../queries/collections_obj_by_time_query.rb  | 125 ++++++++++++++++++
 src-admintool/web/index.html                  |   1 +
 3 files changed, 138 insertions(+)
 create mode 100644 src-admintool/queries/collections_obj_by_time_query.rb

diff --git a/src-admintool/config/reports.yml b/src-admintool/config/reports.yml
index 2b39b02..704595e 100644
--- a/src-admintool/config/reports.yml
+++ b/src-admintool/config/reports.yml
@@ -293,6 +293,18 @@ collections_by_time_count:
     - year by year since the Merritt system was established
     - day by day for the past week
     - week by week for the last 4 weeks
+collections_by_time_count_obj:
+  link-title: Objects Added by Date 
+  breadcrumb: bp_ingest
+  class: CollectionObjectsByTimeQuery
+  category: collections/time
+  description: |
+    This report shows the count of objects added to each Merritt collection.
+    This report includes both system and producer files. 
+    Based on the interval parameter, the report may show Counts
+    - year by year since the Merritt system was established
+    - day by day for the past week
+    - week by week for the last 4 weeks
 collections_by_time_size:
   link-title: Bytes Added by Date 
   breadcrumb: bp_ingest
diff --git a/src-admintool/queries/collections_obj_by_time_query.rb b/src-admintool/queries/collections_obj_by_time_query.rb
new file mode 100644
index 0000000..b7b943f
--- /dev/null
+++ b/src-admintool/queries/collections_obj_by_time_query.rb
@@ -0,0 +1,125 @@
+# frozen_string_literal: true
+
+require 'date'
+
+# Query class - see config/reports.yml for description
+class CollectionObjectsByTimeQuery < AdminQuery
+  def initialize(query_factory, path, myparams)
+    super(query_factory, path, myparams)
+    @interval = get_param('interval', '')
+    @interval = @interval == 'years' || @interval == 'days' || @interval == 'weeks' ? @interval : 'years'
+    @ranges = []
+
+    if @interval == 'days'
+      @end = Date.today + 1
+      @start = @end - 7
+      rstart = @start
+      while rstart < @end
+        @ranges.push([rstart, rstart + 1])
+        rstart += 1
+      end
+    elsif @interval == 'weeks'
+      @end = Date.today - Date.today.cwday + 7
+      @start = @end - 28
+      rstart = @start
+      while rstart < @end
+        @ranges.push([rstart, rstart + 7])
+        rstart += 7
+      end
+    else
+      @end = Date.today.next_year.prev_month(Date.today.month - 1) - Date.today.mday + 1
+      @start = Date.new(2013, 0o1, 0o1)
+      rstart = @start
+      while rstart < @end
+        @ranges.push([rstart, rstart.next_year])
+        rstart = rstart.next_year
+      end
+    end
+    @headers = ['Group', 'Collection Id', 'Collection Name']
+    @types = %w[ogroup colllist name]
+    @ranges.each do |range|
+      @headers.push(range[0])
+      @types.push('dataint')
+    end
+    @headers.push('Total')
+    @types.push('dataint')
+  end
+
+  def get_headers(_results)
+    @headers
+  end
+
+  def get_types(_results)
+    @types
+  end
+
+  def get_filter_col
+    2
+  end
+
+  def get_group_col
+    0
+  end
+
+  def get_title
+    "Collection Objects Over Time (#{@start} - #{@end})"
+  end
+
+  def get_sql
+    %{
+      select distinct
+        oc.ogroup as ogroup,
+        oc.inv_collection_id as ocid,
+        oc.collection_name as ocname,
+        (
+          select
+            count(inv_object_id)
+          from
+            inv.inv_collections_inv_objects icio
+          inner join inv.inv_objects o
+            on o.id = icio.inv_object_id
+          where
+            oc.inv_collection_id = icio.inv_collection_id
+          and
+            o.created >= ?
+          and
+            o.created < ?
+        ) as sumval
+      from
+        owner_collections oc
+      group by
+        ogroup,
+        ocid,
+        ocname
+      order by
+        ogroup,
+        ocid,
+        ocname
+    }
+  end
+
+  def get_query_params(pstart, pend)
+    [
+      pstart, pend
+    ]
+  end
+
+  def run_query_sql
+    stmt = @client.prepare(get_sql)
+    params = get_query_params(@start, @end)
+
+    results = stmt.execute(*params)
+    types = get_types(results)
+    combined_data = get_result_data(results, types)
+
+    @ranges.each do |range|
+      params = get_query_params(range[0], range[1])
+      results = stmt.execute(*params)
+      data = get_result_data(results, types)
+      data.each_with_index do |r, i|
+        combined_data[i].insert(-2, r[3])
+      end
+    end
+    format_result_json(types, combined_data, get_headers(results))
+  end
+end
diff --git a/src-admintool/web/index.html b/src-admintool/web/index.html
index 7f63005..9af8426 100644
--- a/src-admintool/web/index.html
+++ b/src-admintool/web/index.html
@@ -382,6 +382,7 @@ <h3>Ingest Counts</h3>
       <ul>
         <li class="graph"><a class="json" href="{{ADMINTOOL_HOME}}?path=collections_by_time_count_producer">Producer Files Added by Date (All time)</a></li>
         <li class="graph"><a class="json" href="{{ADMINTOOL_HOME}}?path=collections_by_time_count">Files Added by Date (All time)</a></li>
+        <li class="graph"><a class="json" href="{{ADMINTOOL_HOME}}?path=collections_by_time_count_obj">Objects Added by Date (All time)</a></li>
         <li class="graph"><a class="json" href="{{ADMINTOOL_HOME}}?path=collections_by_time_size">File Size Added by Date (All time)</a></li>
         <li class="graph"><a class="json" href="{{ADMINTOOL_HOME}}?path=collections_by_time_size_cumulative">Cumulative File Size Added by Date (All time)</a></li>
         <li class="graph"><a class="json" href="{{ADMINTOOL_HOME}}?path=collections_by_time_count_producer&interval=days">Producer Files Added by Date (Last week)</a></li>