各棟の各階の教員情報を取得するAPI

api/externals/controller/cmapus_donation_controller.go

@@ -0,0 +1,37 @@
+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
+}
+
+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)
+}

api/externals/repository/campus_donation_repository.go

@@ -0,0 +1,90 @@
+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)
+}
+
+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("fund_informations"),
+			goqu.On(goqu.Ex{"fund_informations.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("fund_informations.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)
+
+}

api/internals/di/di.go

@@ -61,6 +61,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
@@ -101,6 +102,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
@@ -136,6 +138,7 @@ func InitializeServer() (db.Client, *echo.Echo) {
 	teacherController := controller.NewTeacherController(teacherUseCase)
 	userController := controller.NewUserController(userUseCase)
 	yearController := controller.NewYearController(yearUseCase)
+	campusDonationController := controller.NewCampusDonationController(campusDonationUseCase)
 	// ↓
 
 	// router
@@ -168,6 +171,7 @@ func InitializeServer() (db.Client, *echo.Echo) {
 		teacherController,
 		userController,
 		yearController,
+		campusDonationController,
 	)
 
 	// ↓

api/internals/usecase/campus_donation_usecase.go

@@ -0,0 +1,59 @@
+package usecase
+
+import (
+	"context"
+	"log"
+
+	rep "github.com/NUTFes/FinanSu/api/externals/repository"
+	"github.com/NUTFes/FinanSu/api/generated"
+	"github.com/pkg/errors"
+)
+
+type campusDonationUseCase struct {
+	rep rep.CampusDonationRepository
+}
+
+type CampusDonationUseCase interface {
+	GetCampusDonationByFloors(context.Context, string, string) ([]CampusDonationByFloor, error)
+}
+
+func NewCampusDonationUseCase(rep rep.CampusDonationRepository) CampusDonationUseCase {
+	return &campusDonationUseCase{rep}
+}
+
+func (cdu *campusDonationUseCase) GetCampusDonationByFloors(c context.Context, buildingId string, floorId string) ([]CampusDonationByFloor, error) {
+	var campusDonation CampusDonationByFloor
+	var campusDonations []CampusDonationByFloor
+
+	//クエリ実行
+	rows, err := cdu.rep.AllCampusDonationByFloor(c, buildingId, floorId)
+	if err != nil {
+		return nil, err
+	}
+	defer func() {
+		if err := rows.Close(); err != nil {
+			log.Println(err)
+		}
+	}()
+
+	for rows.Next() {
+		err := rows.Scan(
+			&campusDonation.BuildingName,
+			&campusDonation.UnitNumber,
+			&campusDonation.FloorNumber,
+			&campusDonation.RoomName,
+			&campusDonation.TeacherId,
+			&campusDonation.TeacherName,
+			&campusDonation.IsBlack,
+			&campusDonation.Price,
+		)
+
+		if err != nil {
+			return nil, errors.Wrapf(err, "can not connect SQL")
+		}
+		campusDonations = append(campusDonations, campusDonation)
+	}
+	return campusDonations, nil
+}
+
+type CampusDonationByFloor = generated.CampusDonationByFloor

api/router/router.go

@@ -34,6 +34,7 @@ type router struct {
 	teacherController                     controller.TeacherController
 	userController                        controller.UserController
 	yearController                        controller.YearController
+	campusDonationController              controller.CampusDonationController
 }
 
 type Router interface {
@@ -69,6 +70,7 @@ func NewRouter(
 	teacherController controller.TeacherController,
 	userController controller.UserController,
 	yearController controller.YearController,
+	campusDonationController controller.CampusDonationController,
 ) Router {
 	return router{
 		activityController,
@@ -99,6 +101,7 @@ func NewRouter(
 		teacherController,
 		userController,
 		yearController,
+		campusDonationController,
 	}
 }
 
@@ -162,6 +165,9 @@ func (r router) ProvideRouter(e *echo.Echo) {
 	e.GET("/buy_reports/details", r.buyReportController.IndexBuyReport)
 	e.PUT("/buy_report/status/:buy_report_id", r.buyReportController.UpdateBuyReportStatus)
 
+	// campus_donationsのRoute
+	e.GET("/campus_donations/building/:building_id/floor/:floor_id", r.campusDonationController.IndexCampusDonationByFloor)
+
 	// current_user
 	e.GET("/current_user", r.userController.GetCurrentUser)