add download, sum and total

controllers/statistics_controller.go

@@ -0,0 +1,104 @@
+package controllers
+
+import (
+	"context"
+	"go.mongodb.org/mongo-driver/mongo"
+	"hackathon-api/configs"
+	"hackathon-api/responses"
+	"net/http"
+	"time"
+
+	"github.com/gin-gonic/gin"
+	"go.mongodb.org/mongo-driver/bson"
+)
+
+//https://www.mongodb.com/blog/post/quick-start-golang--mongodb--data-aggregation-pipeline
+
+var statsCollection = configs.GetCollection(configs.DB, "donations")
+
+func CountDonationByMoney() gin.HandlerFunc {
+	return func(c *gin.Context) {
+		ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+		money := c.Param("money")
+		defer cancel()
+
+		count, err := donationCollection.CountDocuments(ctx, bson.M{"moneyType": money})
+
+		if err != nil {
+			c.JSON(http.StatusInternalServerError, responses.DonationResponse{Status: http.StatusInternalServerError, Message: "error", Data: map[string]interface{}{"data": err.Error()}})
+			return
+		}
+
+		if err != nil {
+			c.JSON(http.StatusInternalServerError, responses.DonationResponse{Status: http.StatusInternalServerError, Message: "error", Data: map[string]interface{}{"data": err.Error()}})
+			return
+		}
+
+		c.JSON(http.StatusOK,
+			responses.DonationResponse{Status: http.StatusOK, Message: "success", Data: map[string]interface{}{"data": count}},
+		)
+
+	}
+}
+
+func SumDonationsByMoney() gin.HandlerFunc {
+	return func(c *gin.Context) {
+		ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+		//money := c.Param("money")
+		defer cancel()
+
+		//matchStage := bson.D{{"$match", bson.D{{"moneyType", money}}}}
+		groupStage := bson.D{{"$group", bson.D{{"_id", "$moneyType"}, {"total", bson.D{{"$sum", "$amount"}}}}}}
+
+		resultCursor, err := statsCollection.Aggregate(ctx, mongo.Pipeline{ /*matchStage,*/ groupStage})
+		if err != nil {
+			println(err)
+		}
+
+		var resultData []bson.M
+		resultCursor.All(ctx, resultData)
+
+		if err = resultCursor.All(ctx, &resultData); err != nil {
+			panic(err)
+		}
+
+		if err != nil {
+			c.JSON(http.StatusInternalServerError, responses.DonationResponse{Status: http.StatusInternalServerError, Message: "error", Data: map[string]interface{}{"data": err.Error()}})
+			return
+		}
+
+		c.JSON(http.StatusOK, resultData)
+
+	}
+
+}
+
+func SumDonations() gin.HandlerFunc {
+	return func(c *gin.Context) {
+		ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+		defer cancel()
+
+		groupStage := bson.D{{"$group", bson.D{{"_id", ""}, {"total", bson.D{{"$sum", "$amount"}}}}}}
+
+		resultCursor, err := statsCollection.Aggregate(ctx, mongo.Pipeline{ /*matchStage,*/ groupStage})
+		if err != nil {
+			println(err)
+		}
+
+		var resultData []bson.M
+		resultCursor.All(ctx, resultData)
+
+		if err = resultCursor.All(ctx, &resultData); err != nil {
+			panic(err)
+		}
+
+		if err != nil {
+			c.JSON(http.StatusInternalServerError, responses.DonationResponse{Status: http.StatusInternalServerError, Message: "error", Data: map[string]interface{}{"data": err.Error()}})
+			return
+		}
+
+		c.JSON(http.StatusOK, resultData)
+
+	}
+
+}

main.go

@@ -25,6 +25,7 @@ func main() {
 
 	//routes
 	routes.DonationRoute(router)
+	routes.StatisticsRoute(router)
 
 	router.Run("0.0.0.0:8080")
 }

models/stats_model.go

@@ -0,0 +1,7 @@
+package models
+
+// Stats type
+type Stats struct {
+	ID    string `json:"_id,omitempty" bson:"_id,omitempty"`
+	total string `json:"total,omitempty" bson:"total,omitempty"`
+}

routes/statistics_route.go

@@ -0,0 +1,13 @@
+package routes
+
+import (
+	"hackathon-api/controllers"
+
+	"github.com/gin-gonic/gin"
+)
+
+func StatisticsRoute(router *gin.Engine) {
+	router.GET("/statistics/:money", controllers.CountDonationByMoney())
+	router.GET("/statistics/sum", controllers.SumDonationsByMoney())
+	router.GET("/statistics/total", controllers.SumDonations())
+}