各棟ごとの合計募金額を取得するAPIの作成

api/externals/controller/cmapus_donation_controller.go

@@ -0,0 +1,48 @@
+package controller
+
+import (
+	"net/http"
+
+	"github.com/NUTFes/FinanSu/api/internals/usecase"
+	"github.com/labstack/echo/v4"
+)
+
+type campusDonationController struct {
+	u usecase.CampusDonationUseCase
+}
+
+type CampusDonationController interface {
+	IndexCampusDonationByFloor(echo.Context) error
+	IndexCampusDonationBuildingByPeriod(echo.Context) error
+}
+
+func NewCampusDonationController(u usecase.CampusDonationUseCase) CampusDonationController {
+	return &campusDonationController{u}
+}
+
+func (cdc *campusDonationController) IndexCampusDonationByFloor(c echo.Context) error {
+	ctx := c.Request().Context()
+	buildingId := c.Param("building_id")
+	floorId := c.Param("floor_id")
+
+	if floorId == "" {
+		return c.String(http.StatusBadRequest, "floor_id is required")
+	}
+
+	campusDonationByFloors, err := cdc.u.GetCampusDonationByFloors(ctx, buildingId, floorId)
+	if err != nil {
+		return c.String(http.StatusBadRequest, "failed to buy_reports")
+	}
+
+	return c.JSON(http.StatusOK, campusDonationByFloors)
+}
+
+func (f *campusDonationController) IndexCampusDonationBuildingByPeriod(c echo.Context) error {
+	ctx := c.Request().Context()
+	year := c.Param("year")
+	fundInformationBuildingByPeriod, err := f.u.GetCampusDonationBuildingByPeriod(ctx, year)
+	if err != nil {
+		return err
+	}
+	return c.JSON(http.StatusOK, fundInformationBuildingByPeriod)
+}

api/externals/repository/campus_donation_repository.go

@@ -0,0 +1,145 @@
+package repository
+
+import (
+	"context"
+	"database/sql"
+	"log"
+
+	"github.com/NUTFes/FinanSu/api/drivers/db"
+	"github.com/NUTFes/FinanSu/api/externals/repository/abstract"
+	goqu "github.com/doug-martin/goqu/v9"
+)
+
+type campusDonationRepository struct {
+	client db.Client
+	crud   abstract.Crud
+}
+
+type CampusDonationRepository interface {
+	AllCampusDonationByFloor(context.Context, string, string) (*sql.Rows, error)
+	AllBuildingsByPeriod(context.Context, string) (*sql.Rows, error)
+}
+
+func NewCampusDonationRepository(c db.Client, ac abstract.Crud) CampusDonationRepository {
+	return &campusDonationRepository{c, ac}
+}
+
+func (cdr *campusDonationRepository) AllCampusDonationByFloor(c context.Context, buildingId string, floorId string) (*sql.Rows, error) {
+
+	query, _, err := dialect.From("buildings").
+		Join(
+			goqu.T("building_units"),
+			goqu.On(goqu.Ex{"building_units.building_id": goqu.I("buildings.id")}),
+		).
+		Join(
+			goqu.T("floors"),
+			goqu.On(goqu.Ex{"floors.building_unit_id": goqu.I("building_units.id")}),
+		).
+		Join(
+			goqu.T("rooms"),
+			goqu.On(goqu.Ex{"rooms.floor_id": goqu.I("floors.id")}),
+		).
+		Join(
+			goqu.T("room_teachers"),
+			goqu.On(goqu.Ex{"room_teachers.room_id": goqu.I("rooms.id")}),
+		).
+		Join(
+			goqu.T("teachers"),
+			goqu.On(goqu.Ex{"teachers.id": goqu.I("room_teachers.teacher_id")}),
+		).
+		LeftJoin(
+			goqu.T("campus_donations"),
+			goqu.On(goqu.Ex{"campus_donations.teacher_id": goqu.I("teachers.id")}),
+		).
+		Select(
+			goqu.I("buildings.name"),
+			goqu.I("building_units.unit_number"),
+			goqu.I("floors.floor_number"),
+			goqu.I("rooms.room_name"),
+			goqu.I("teachers.id"),
+			goqu.I("teachers.name"),
+			goqu.I("teachers.is_black"),
+			goqu.COALESCE(goqu.SUM(goqu.I("campus_donations.price")), 0),
+		).
+		Where(
+			goqu.Ex{"buildings.id": buildingId, "floors.id": floorId},
+		).
+		GroupBy(
+			goqu.I("buildings.name"),
+			goqu.I("building_units.unit_number"),
+			goqu.I("floors.floor_number"),
+			goqu.I("rooms.room_name"),
+			goqu.I("teachers.id"),
+			goqu.I("teachers.name"),
+			goqu.I("teachers.is_black"),
+		).
+		Order(
+			goqu.I("building_units.unit_number").Asc(),
+			goqu.I("floors.floor_number").Asc(),
+			goqu.I("rooms.room_name").Asc(),
+			goqu.I("teachers.name").Asc(),
+		).
+		ToSQL()
+
+	if err != nil {
+		// エラーハンドリング
+		log.Fatal(err)
+	}
+
+	return cdr.crud.Read(c, query)
+
+}
+
+func (fir *campusDonationRepository) AllBuildingsByPeriod(c context.Context, year string) (*sql.Rows, error) {
+
+	db := goqu.Dialect("mysql")
+
+	ds := db.From("campus_donations").
+		Select(
+			goqu.I("buildings.id"),
+			goqu.I("buildings.name"),
+			goqu.I("campus_donations.price"),
+		).
+		Join(goqu.T("teachers"), goqu.On(goqu.Ex{
+			"campus_donations.teacher_id": goqu.I("teachers.id"),
+		})).
+		Join(goqu.T("users"), goqu.On(goqu.Ex{
+			"campus_donations.user_id": goqu.I("users.id"),
+		})).
+		Join(goqu.T("departments"), goqu.On(goqu.Ex{
+			"teachers.department_id": goqu.I("departments.id"),
+		})).
+		Join(goqu.T("room_teachers"), goqu.On(goqu.Ex{
+			"room_teachers.teacher_id": goqu.I("teachers.id"),
+		})).
+		Join(goqu.T("rooms"), goqu.On(goqu.Ex{
+			"room_teachers.room_id": goqu.I("rooms.id"),
+		})).
+		Join(goqu.T("floors"), goqu.On(goqu.Ex{
+			"rooms.floor_id": goqu.I("floors.id"),
+		})).
+		Join(goqu.T("building_units"), goqu.On(goqu.Ex{
+			"floors.building_unit_id": goqu.I("building_units.id"),
+		})).
+		Join(goqu.T("buildings"), goqu.On(goqu.Ex{
+			"building_units.building_id": goqu.I("buildings.id"),
+		})).
+		Join(goqu.T("year_periods"),
+			goqu.On(goqu.And(
+				goqu.I("campus_donations.created_at").Gt(goqu.I("year_periods.started_at")),
+				goqu.I("campus_donations.created_at").Lt(goqu.I("year_periods.ended_at")),
+			)),
+		).
+		Join(goqu.T("years"), goqu.On(goqu.Ex{
+			"year_periods.year_id": goqu.I("years.id"),
+		})).
+		Where(goqu.Ex{"years.year": year}).
+		Order(goqu.I("campus_donations.updated_at").Desc())
+
+	query, _, err := ds.ToSQL()
+	if err != nil {
+		panic(err)
+	}
+
+	return fir.crud.Read(c, query)
+}

api/internals/di/di.go

@@ -60,6 +60,7 @@ func InitializeServer() (db.Client, *echo.Echo) {
 	transactionRepository := repository.NewTransactionRepository(client, crud)
 	userRepository := repository.NewUserRepository(client, crud)
 	yearRepository := repository.NewYearRepository(client, crud)
+	campusDonationRepository := repository.NewCampusDonationRepository(client, crud)
 	// ↓
 
 	// UseCase
@@ -99,6 +100,7 @@ func InitializeServer() (db.Client, *echo.Echo) {
 	teacherUseCase := usecase.NewTeacherUseCase(teacherRepository)
 	userUseCase := usecase.NewUserUseCase(userRepository, sessionRepository)
 	yearUseCase := usecase.NewYearUseCase(yearRepository)
+	campusDonationUseCase := usecase.NewCampusDonationUseCase(campusDonationRepository)
 	// ↓
 
 	// Controller
@@ -133,6 +135,7 @@ func InitializeServer() (db.Client, *echo.Echo) {
 	teacherController := controller.NewTeacherController(teacherUseCase)
 	userController := controller.NewUserController(userUseCase)
 	yearController := controller.NewYearController(yearUseCase)
+	campusDonationController := controller.NewCampusDonationController(campusDonationUseCase)
 	// ↓
 
 	// router
@@ -164,6 +167,7 @@ func InitializeServer() (db.Client, *echo.Echo) {
 		teacherController,
 		userController,
 		yearController,
+		campusDonationController,
 	)
 
 	// ↓

api/internals/domain/campus_donation.go

@@ -0,0 +1,7 @@
+package domain
+
+type CampusDonationBuilding struct {
+	Id    int    `json:"id"`
+	Name  string `json:"name"`
+	Price int    `json:"price"`
+}