ActivitySummary.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2023 Lluis Turró Cutiller <http://www.turro.org/>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
 
package org.turro.activity;
 
import java.util.List;
import java.util.Map;
import java.util.TreeMap;
import org.turro.elephant.context.IConstructor;
import org.turro.elephant.db.ElephantPU;
import org.turro.jpa.Dao;
import org.turro.marker.ElephantMarker;
import org.turro.sql.SqlClause;
import org.turro.util.Cached;
import org.turro.util.Converter;
 
public class ActivitySummary {
  
  public static void render(IConstructor constructor) {
    ElephantMarker marker = new ElephantMarker(constructor);
    marker.put("activities", activities());
    marker.process("summary", "activity");
  }
  
  public static Map<String, Long> activities() {
    return new ActivitySummary().getActivities();
  }
  
  /* Process */
  
  private Map<String, Long> getActivities() {
    Map<String, Long> activities = new TreeMap<>();
    SqlClause.select("x.reason, count(x)").from("Activity x")
            .where().in("x.reason", List.of("REASON_SEEN", "Related polls"))
            .groupBy("x.reason")
            .dao(dao.get())
            .forEach(Object[].class, sv -> {
              activities.put(
                      translate(Converter.STANDARD.convert(sv[0], String.class)), 
                      Converter.STANDARD.convert(sv[1], Long.class));
            });
    SqlClause.select("x.entityPath, count(x)").from("SystemLog x")
            .where().in("x.entityPath", List.of("/log/in", "/log/profile"))
            .groupBy("x.entityPath")
            .dao(dao.get())
            .forEach(Object[].class, sv -> {
              activities.put(
                      translate(Converter.STANDARD.convert(sv[0], String.class)), 
                      Converter.STANDARD.convert(sv[1], Long.class));
            });
    SqlClause.select("x.comment, count(x)").from("SystemLog x")
            .where().in("x.comment", List.of("downloaded", "uploaded"))
            .groupBy("x.comment")
            .dao(dao.get())
            .forEach(Object[].class, sv -> {
              activities.put(
                      translate(Converter.STANDARD.convert(sv[0], String.class)), 
                      Converter.STANDARD.convert(sv[1], Long.class));
            });
    SqlClause.select("count(distinct x.contactId), count(x)").from("ActivityAssistant x")
            .dao(dao.get())
            .forEach(Object[].class, sv -> {
              activities.put(
                      "Active participants", 
                      Converter.STANDARD.convert(sv[0], Long.class));
              activities.put(
                      "Total participation", 
                      Converter.STANDARD.convert(sv[1], Long.class));
            });
    return activities;
  }
  
  /* User friendly */
  
  private static Map<String, String> friendly = Map.of(
          "REASON_SEEN", "Visualizations",
          "Related polls", "Polls",
          "/log/in", "Logins",
          "/log/profile", "Profile updates",
          "uploaded", "Documents uploaded",
          "downloaded", "Documents downloaded"
  );
  
  private String translate(String label) {
    return friendly.getOrDefault(label, label);
  }
 
  /* Dao */
  
  protected final Cached<Dao> dao = Cached.instance(() -> new ElephantPU());
  
}