Add stats for huskelapp

Author: dragutin-nav

src/main/java/no/nav/pto/veilarbportefolje/huskelapp/HuskelappStats.java

@@ -0,0 +1,63 @@
+package no.nav.pto.veilarbportefolje.huskelapp;
+
+import io.micrometer.core.instrument.Gauge;
+import io.micrometer.core.instrument.MeterRegistry;
+import io.micrometer.core.instrument.Tags;
+import io.micrometer.core.instrument.binder.MeterBinder;
+import lombok.NonNull;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import static no.nav.pto.veilarbportefolje.database.PostgresTable.HUSKELAPP;
+
+@Component
+@RequiredArgsConstructor
+@Slf4j
+public class HuskelappStats implements MeterBinder {
+
+    @Qualifier("PostgresJdbcReadOnly")
+    private final JdbcTemplate jdbcTemplate;
+
+    Map<String, Integer> huskelappStats = new ConcurrentHashMap<>();
+
+    @Override
+    public void bindTo(@NonNull MeterRegistry meterRegistry) {
+        huskelappStats.keySet().forEach(enhet_id -> {
+            Tags tags = Tags.of("enhet_id", enhet_id);
+            Gauge.builder("huskelapp_antall", huskelappStats, map -> map.get(enhet_id))
+                    .tags(tags)
+                    .register(meterRegistry);
+        });
+
+    }
+
+    @Scheduled(cron = "0 */6 * * 1-5")
+    public void oppdaterMetrikk() {
+        try {
+            huskelappStats.clear();
+
+            String query = String.format("select %s, count(*) as huskelapp_antall from %s where %s = 'AKTIV' group by %s", HUSKELAPP.ENHET_ID, HUSKELAPP.TABLE_NAME, HUSKELAPP.STATUS, HUSKELAPP.ENHET_ID);
+            Map<String, Integer> huskelappAntall = this.jdbcTemplate.queryForObject(query, (rs, rowNum) -> {
+                        Map<String, Integer> stats = new HashMap<>();
+                        while (rs.next()) {
+                            huskelappStats.put(rs.getString(HUSKELAPP.ENHET_ID), rs.getInt("huskelapp_antall"));
+                        }
+                        return stats;
+                    }
+            );
+            if (huskelappAntall != null) {
+                huskelappStats.putAll(huskelappAntall);
+            }
+        } catch (Exception e) {
+            log.error("Can not fetch huskelapp metrics");
+        }
+    }
+}