Source media view

src/main/java/com/wechi/adweb/bridge/google/analytics/GADataService.java

@@ -32,9 +32,6 @@ import java.util.Objects;
 @Service
 public class GADataService {
 
-    @Value("${spring.application.name}")
-    private String applicationName;
-
     @Value("${google.service.account.key}")
     private String serviceAccountKey;
 

src/main/java/com/wechi/adweb/bridge/google/analytics/dto/report/GAReportRowDTO.java

@@ -1,10 +0,0 @@
-package com.wechi.adweb.bridge.google.analytics.dto.report;
-
-import com.google.analytics.data.v1beta.Row;
-
-/**
- * @author wfansh
- */
-public interface GAReportRowDTO {
-
-}

src/main/java/com/wechi/adweb/bridge/google/analytics/dto/report/ReportConstant.java

@@ -6,7 +6,13 @@ package com.wechi.adweb.bridge.google.analytics.dto.report;
 public class ReportConstant {
 
     public static final String METRIC_TOTAL_USERS = "totalUsers";
+    public static final String METRIC_NEW_USERS = "newUsers";
+    public static final String METRIC_SESSIONS = "sessions";
+    public static final String METRIC_BOUNCE_RATE = "bounceRate";
+    public static final String METRIC_AVG_SESSION_DURATION = "averageSessionDuration";
+    public static final String METRIC_SCREEN_PAGE_VIEWS_PER_SESSION = "screenPageViewsPerSession";
 
     public static final String DIMENSION_COUNTRY = "country";
     public static final String DIMENSION_DATE = "date";
+    public static final String DIMENSION_SESSION_SOURCE_MEDIUM = "sessionSourceMedium";
 }

src/main/java/com/wechi/adweb/bridge/google/analytics/dto/report/ReportType.java

@@ -11,7 +11,16 @@ import java.util.List;
  */
 @Getter
 public enum ReportType {
-    ADWEB3_COUNTRY_CHART(List.of(METRIC_TOTAL_USERS), List.of(DIMENSION_COUNTRY));
+    ADWEB_COUNTRY_CHART(List.of(METRIC_TOTAL_USERS), List.of(DIMENSION_COUNTRY)),
+    ADWEB_SOURCE_MEDIUM_VIEW(
+            List.of(
+                    METRIC_TOTAL_USERS,
+                    METRIC_NEW_USERS,
+                    METRIC_SESSIONS,
+                    METRIC_BOUNCE_RATE,
+                    METRIC_AVG_SESSION_DURATION,
+                    METRIC_SCREEN_PAGE_VIEWS_PER_SESSION),
+            List.of(DIMENSION_SESSION_SOURCE_MEDIUM));
 
     private ReportType(List<String> defaultMetrics, List<String> defaultDimensions) {
         this.defaultMetrics = defaultMetrics;

src/main/java/com/wechi/adweb/bridge/google/analytics/dto/report/CountryChartRowDTO.java → src/main/java/com/wechi/adweb/bridge/google/analytics/dto/report/row/CountryChartRow.java

@@ -1,6 +1,9 @@
-package com.wechi.adweb.bridge.google.analytics.dto.report;
+package com.wechi.adweb.bridge.google.analytics.dto.report.row;
+
+import static com.wechi.adweb.bridge.google.analytics.dto.report.ReportConstant.*;
 
 import com.google.analytics.data.v1beta.Row;
+import com.wechi.adweb.bridge.google.analytics.dto.report.GAReportRequestDTO;
 
 import lombok.Builder;
 import lombok.Data;
@@ -12,18 +15,18 @@ import java.util.List;
  */
 @Data
 @Builder
-public class CountryChartRowDTO implements GAReportRowDTO {
+public class CountryChartRow implements GAReportRowDTO {
     private String country;
     private int num;
 
-    public static List<CountryChartRowDTO> fromReportRows(
+    public static List<CountryChartRow> fromReportRows(
             List<Row> reportRows, GAReportRequestDTO reportRequest) {
-        int indexCountry = reportRequest.getDimensions().indexOf(ReportConstant.DIMENSION_COUNTRY);
+        int indexCountry = reportRequest.getDimensions().indexOf(DIMENSION_COUNTRY);
 
         return reportRows.stream()
                 .map(
                         row ->
-                                CountryChartRowDTO.builder()
+                                CountryChartRow.builder()
                                         .country(row.getDimensionValues(indexCountry).getValue())
                                         // The first metric value.
                                         .num(Integer.parseInt(row.getMetricValues(0).getValue()))

src/main/java/com/wechi/adweb/bridge/google/analytics/dto/report/row/GAReportRowDTO.java

@@ -0,0 +1,6 @@
+package com.wechi.adweb.bridge.google.analytics.dto.report.row;
+
+/**
+ * @author wfansh
+ */
+public interface GAReportRowDTO {}

src/main/java/com/wechi/adweb/bridge/google/analytics/dto/report/row/SourceMediaViewRow.java

@@ -0,0 +1,86 @@
+package com.wechi.adweb.bridge.google.analytics.dto.report.row;
+
+import static com.wechi.adweb.bridge.google.analytics.dto.report.ReportConstant.*;
+
+import com.google.analytics.data.v1beta.Row;
+import com.wechi.adweb.bridge.google.analytics.dto.report.GAReportRequestDTO;
+import com.wechi.adweb.bridge.util.NumberUtils;
+
+import lombok.Builder;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author wfansh
+ */
+@Data
+@Builder
+public class SourceMediaViewRow implements GAReportRowDTO {
+    private String type;
+
+    private int totalUsers;
+
+    private int newUsers;
+
+    private int sessions;
+
+    private String bounceRate;
+
+    private String avgSessionDuration;
+
+    private String pageViewsPerSession;
+
+    public static List<SourceMediaViewRow> fromReportRows(
+            List<Row> reportRows, GAReportRequestDTO reportRequest) {
+        int indexType = reportRequest.getDimensions().indexOf(DIMENSION_SESSION_SOURCE_MEDIUM);
+        int indexTotalUsers = reportRequest.getMetrics().indexOf(METRIC_TOTAL_USERS);
+        int indexNewUsers = reportRequest.getMetrics().indexOf(METRIC_NEW_USERS);
+        int indexSessions = reportRequest.getMetrics().indexOf(METRIC_SESSIONS);
+        int indexBounceRate = reportRequest.getMetrics().indexOf(METRIC_BOUNCE_RATE);
+        int indexAvgSessionDuration =
+                reportRequest.getMetrics().indexOf(METRIC_AVG_SESSION_DURATION);
+        int indexPageViewsPerSession =
+                reportRequest.getMetrics().indexOf(METRIC_SCREEN_PAGE_VIEWS_PER_SESSION);
+
+        return reportRows.stream()
+                .map(
+                        row ->
+                                SourceMediaViewRow.builder()
+                                        .type(row.getDimensionValues(indexType).getValue())
+                                        .totalUsers(
+                                                Integer.parseInt(
+                                                        row.getMetricValues(indexTotalUsers)
+                                                                .getValue()))
+                                        .newUsers(
+                                                Integer.parseInt(
+                                                        row.getMetricValues(indexNewUsers)
+                                                                .getValue()))
+                                        .sessions(
+                                                Integer.parseInt(
+                                                        row.getMetricValues(indexSessions)
+                                                                .getValue()))
+                                        .bounceRate(
+                                                NumberUtils.formatPercentage(
+                                                        Double.parseDouble(
+                                                                row.getMetricValues(indexBounceRate)
+                                                                        .getValue()),
+                                                        2))
+                                        .avgSessionDuration(
+                                                NumberUtils.formatDecimal(
+                                                        Double.parseDouble(
+                                                                row.getMetricValues(
+                                                                                indexAvgSessionDuration)
+                                                                        .getValue()),
+                                                        2))
+                                        .pageViewsPerSession(
+                                                NumberUtils.formatDecimal(
+                                                        Double.parseDouble(
+                                                                row.getMetricValues(
+                                                                                indexPageViewsPerSession)
+                                                                        .getValue()),
+                                                        2))
+                                        .build())
+                .toList();
+    }
+}

src/main/java/com/wechi/adweb/bridge/util/NumberUtils.java

@@ -0,0 +1,37 @@
+package com.wechi.adweb.bridge.util;
+
+import java.math.RoundingMode;
+import java.text.NumberFormat;
+
+/**
+ * @author wfansh
+ */
+public class NumberUtils {
+
+    private static final NumberFormat DECIMAL_FORMAT = NumberFormat.getNumberInstance();
+
+    private static final NumberFormat PERCENTAGE_FORMAT = NumberFormat.getPercentInstance();
+
+    static {
+        DECIMAL_FORMAT.setRoundingMode(RoundingMode.HALF_UP);
+        // No grouping with ',' delimiter.
+        DECIMAL_FORMAT.setGroupingUsed(false);
+
+        PERCENTAGE_FORMAT.setRoundingMode(RoundingMode.HALF_UP);
+        PERCENTAGE_FORMAT.setGroupingUsed(false);
+    }
+
+    public static String formatDecimal(double number, int fractionDigits) {
+        DECIMAL_FORMAT.setMinimumFractionDigits(fractionDigits);
+        DECIMAL_FORMAT.setMaximumFractionDigits(fractionDigits);
+
+        return DECIMAL_FORMAT.format(number);
+    }
+
+    public static String formatPercentage(double number, int fractionDigits) {
+        PERCENTAGE_FORMAT.setMinimumFractionDigits(fractionDigits);
+        PERCENTAGE_FORMAT.setMaximumFractionDigits(fractionDigits);
+
+        return PERCENTAGE_FORMAT.format(number);
+    }
+}