mirror of
https://github.com/acepanel/panel.git
synced 2026-02-04 13:47:15 +08:00
104 lines
2.2 KiB
Go
104 lines
2.2 KiB
Go
package service
|
|
|
|
import (
|
|
"net/http"
|
|
|
|
"github.com/libtnb/chix"
|
|
|
|
"github.com/acepanel/panel/internal/biz"
|
|
"github.com/acepanel/panel/internal/http/request"
|
|
"github.com/acepanel/panel/pkg/types"
|
|
)
|
|
|
|
type ProjectService struct {
|
|
projectRepo biz.ProjectRepo
|
|
}
|
|
|
|
func NewProjectService(project biz.ProjectRepo) *ProjectService {
|
|
return &ProjectService{
|
|
projectRepo: project,
|
|
}
|
|
}
|
|
|
|
func (s *ProjectService) List(w http.ResponseWriter, r *http.Request) {
|
|
req, err := Bind[request.Paginate](r)
|
|
if err != nil {
|
|
Error(w, http.StatusUnprocessableEntity, "%v", err)
|
|
return
|
|
}
|
|
|
|
typ := types.ProjectType(r.URL.Query().Get("type"))
|
|
projects, total, err := s.projectRepo.List(typ, req.Page, req.Limit)
|
|
if err != nil {
|
|
Error(w, http.StatusInternalServerError, "%v", err)
|
|
return
|
|
}
|
|
|
|
Success(w, chix.M{
|
|
"total": total,
|
|
"items": projects,
|
|
})
|
|
}
|
|
|
|
func (s *ProjectService) Get(w http.ResponseWriter, r *http.Request) {
|
|
req, err := Bind[request.ID](r)
|
|
if err != nil {
|
|
Error(w, http.StatusUnprocessableEntity, "%v", err)
|
|
return
|
|
}
|
|
|
|
project, err := s.projectRepo.Get(req.ID)
|
|
if err != nil {
|
|
Error(w, http.StatusInternalServerError, "%v", err)
|
|
return
|
|
}
|
|
|
|
Success(w, project)
|
|
}
|
|
|
|
func (s *ProjectService) Create(w http.ResponseWriter, r *http.Request) {
|
|
req, err := Bind[request.ProjectCreate](r)
|
|
if err != nil {
|
|
Error(w, http.StatusUnprocessableEntity, "%v", err)
|
|
return
|
|
}
|
|
|
|
project, err := s.projectRepo.Create(req)
|
|
if err != nil {
|
|
Error(w, http.StatusInternalServerError, "%v", err)
|
|
return
|
|
}
|
|
|
|
Success(w, project)
|
|
}
|
|
|
|
func (s *ProjectService) Update(w http.ResponseWriter, r *http.Request) {
|
|
req, err := Bind[request.ProjectUpdate](r)
|
|
if err != nil {
|
|
Error(w, http.StatusUnprocessableEntity, "%v", err)
|
|
return
|
|
}
|
|
|
|
if err = s.projectRepo.Update(req); err != nil {
|
|
Error(w, http.StatusInternalServerError, "%v", err)
|
|
return
|
|
}
|
|
|
|
Success(w, nil)
|
|
}
|
|
|
|
func (s *ProjectService) Delete(w http.ResponseWriter, r *http.Request) {
|
|
req, err := Bind[request.ID](r)
|
|
if err != nil {
|
|
Error(w, http.StatusUnprocessableEntity, "%v", err)
|
|
return
|
|
}
|
|
|
|
if err = s.projectRepo.Delete(req.ID); err != nil {
|
|
Error(w, http.StatusInternalServerError, "%v", err)
|
|
return
|
|
}
|
|
|
|
Success(w, nil)
|
|
}
|