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

api/externals/controller/cmapus_donation_controller.go

@@ -0,0 +1,41 @@
+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 buildingId == "" {
+		return c.String(http.StatusBadRequest, "building_id is required")
+	}
+
+	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 get campus donation by floor")
+	}
+
+	return c.JSON(http.StatusOK, campusDonationByFloors)
+}

api/externals/repository/campus_donation_repository.go

@@ -0,0 +1,79 @@
+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("campus_donations"),
+			goqu.On(goqu.Ex{"campus_donations.teacher_id": goqu.I("teachers.id")}),
+		).
+		Select(
+			goqu.I("buildings.id").As("building_id"),
+			goqu.I("buildings.name").As("building_name"),
+			goqu.I("floors.id").As("floor_id"),
+			goqu.I("floors.floor_number").As("floor_number"),
+			goqu.I("teachers.id").As("teacher_id"),
+			goqu.I("teachers.name").As("teacher_name"),
+			goqu.I("rooms.room_name").As("room_name"),
+			goqu.I("campus_donations.price").As("price"),
+			goqu.I("teachers.is_black").As("is_black"),
+		).
+		Where(
+			goqu.Ex{"buildings.id": buildingId, "floors.id": floorId},
+		).
+		Order(
+			goqu.I("building_units.unit_number").Asc(),
+			goqu.I("floors.floor_number").Asc(),
+		).
+		ToSQL()
+
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	return cdr.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,14 @@
+package domain
+
+// CampusDonationRecord は、１行分のフラットな寄付データを表します
+type CampusDonationRecord struct {
+	BuildingId   int     `json:"building_id"`
+	BuildingName *string `json:"building_name,omitempty"`
+	FloorId      *int    `json:"floor_id,omitempty"`
+	FloorNumber  string  `json:"floor_number"`
+	TeacherId    int     `json:"teacher_id"`
+	TeacherName  string  `json:"teacher_name"`
+	RoomName     string  `json:"room_name"`
+	Price        int     `json:"price"`
+	IsBlack      *bool   `json:"is_black,omitempty"`
+}

api/internals/usecase/campus_donation_usecase.go

@@ -0,0 +1,105 @@
+package usecase
+
+import (
+	"context"
+	"log"
+
+	rep "github.com/NUTFes/FinanSu/api/externals/repository"
+	"github.com/NUTFes/FinanSu/api/generated"
+	"github.com/NUTFes/FinanSu/api/internals/domain"
+	"github.com/pkg/errors"
+)
+
+type campusDonationUseCase struct {
+	rep rep.CampusDonationRepository
+}
+
+type CampusDonationUseCase interface {
+	GetCampusDonationByFloors(context.Context, string, string) ([]CampusDonationByFloorAndBuilding, error)
+}
+
+func NewCampusDonationUseCase(rep rep.CampusDonationRepository) CampusDonationUseCase {
+	return &campusDonationUseCase{rep}
+}
+
+func (cdu *campusDonationUseCase) GetCampusDonationByFloors(c context.Context, buildingId string, floorId string) ([]CampusDonationByFloorAndBuilding, error) {
+
+	//クエリ実行
+	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)
+		}
+	}()
+
+	var campusDonationRecords []domain.CampusDonationRecord
+	for rows.Next() {
+		var campusDonationRecord domain.CampusDonationRecord
+		if err := rows.Scan(
+			&campusDonationRecord.BuildingId,
+			&campusDonationRecord.BuildingName,
+			&campusDonationRecord.FloorId,
+			&campusDonationRecord.FloorNumber,
+			&campusDonationRecord.TeacherId,
+			&campusDonationRecord.TeacherName,
+			&campusDonationRecord.RoomName,
+			&campusDonationRecord.Price,
+			&campusDonationRecord.IsBlack,
+		); err != nil {
+			return nil, errors.Wrap(err, "scanning flat campus donation record")
+		}
+		campusDonationRecords = append(campusDonationRecords, campusDonationRecord)
+	}
+
+	// --- （2）ネスト構造にマップ→スライス化 ---
+	groupMap := make(map[int]*generated.CampusDonationByFloorAndBuilding)
+	for _, r := range campusDonationRecords {
+		buildingGroup, ok := groupMap[r.BuildingId]
+		if !ok {
+			buildingGroup = &generated.CampusDonationByFloorAndBuilding{
+				BuildingId:   r.BuildingId,
+				BuildingName: r.BuildingName,
+				Floors:       []generated.FloorGroup{},
+			}
+			groupMap[r.BuildingId] = buildingGroup
+		}
+		// Floor レベル取得 or 初期化
+    var floorGroup *generated.FloorGroup
+		for i := range buildingGroup.Floors {
+        if buildingGroup.Floors[i].FloorId != nil && r.FloorId != nil &&
+            *buildingGroup.Floors[i].FloorId == *r.FloorId {
+            floorGroup = &buildingGroup.Floors[i]
+            break
+			}
+		}
+		if floorGroup == nil {
+			newFg := generated.FloorGroup{
+				FloorId:     r.FloorId,
+				FloorNumber: r.FloorNumber,
+				Donations:   []generated.CampusDonation{},
+			}
+			buildingGroup.Floors = append(buildingGroup.Floors, newFg)
+			floorGroup = &buildingGroup.Floors[len(buildingGroup.Floors)-1]
+		}
+		// Donation 追加
+		floorGroup.Donations = append(floorGroup.Donations, generated.CampusDonation{
+			TeacherId:   r.TeacherId,
+			TeacherName: r.TeacherName,
+			RoomName:    r.RoomName,
+			Price:       r.Price,
+			IsBlack:     r.IsBlack,
+		})
+	}
+	// map→slice
+	var result []generated.CampusDonationByFloorAndBuilding
+	for _, gb := range groupMap {
+		result = append(result, *gb)
+	}
+	return result, nil
+}
+
+type CampusDonationByFloorAndBuilding = generated.CampusDonationByFloorAndBuilding
+type CampusDonationRecord = domain.CampusDonationRecord

api/router/router.go

@@ -33,6 +33,7 @@ type router struct {
 	teacherController                     controller.TeacherController
 	userController                        controller.UserController
 	yearController                        controller.YearController
+	campusDonationController              controller.CampusDonationController
 }
 
 type Router interface {
@@ -67,6 +68,7 @@ func NewRouter(
 	teacherController controller.TeacherController,
 	userController controller.UserController,
 	yearController controller.YearController,
+	campusDonationController controller.CampusDonationController,
 ) Router {
 	return router{
 		activityController,
@@ -96,6 +98,7 @@ func NewRouter(
 		teacherController,
 		userController,
 		yearController,
+		campusDonationController,
 	}
 }
 
@@ -159,6 +162,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)