137 lines
3.3 KiB
Go
137 lines
3.3 KiB
Go
package handlers
|
|
|
|
import (
|
|
"net/http"
|
|
"smart-customer-service/internal/models"
|
|
"database/sql"
|
|
"encoding/json"
|
|
"fmt"
|
|
"strconv"
|
|
)
|
|
|
|
// TenantHandler 租户处理器
|
|
type TenantHandler struct {
|
|
// 这里可以添加 database 连接
|
|
}
|
|
|
|
// Create 创建租户
|
|
func (h *TenantHandler) Create(w http.ResponseWriter, r *http.Request) {
|
|
var tenant models.Tenant
|
|
if err := json.NewDecoder(r.Body).Decode(&tenant); err != nil {
|
|
http.Error(w, err.Error(), http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
// 验证必填字段
|
|
if tenant.Name == "" || tenant.Email == "" {
|
|
http.Error(w, `{"error": "name and email are required"}`, http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
// TODO: 保存到数据库
|
|
// db.Create(&tenant)
|
|
|
|
// 返回响应
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(http.StatusCreated)
|
|
json.NewEncoder(w).Encode(map[string]interface{}{
|
|
"message": "租户创建成功",
|
|
"data": tenant,
|
|
})
|
|
}
|
|
|
|
// List 获取租户列表
|
|
func (h *TenantHandler) List(w http.ResponseWriter, r *http.Request) {
|
|
// 获取分页参数
|
|
page, _ := strconv.Atoi(r.URL.Query().Get("page"))
|
|
if page == 0 {
|
|
page = 1
|
|
}
|
|
perPage, _ := strconv.Atoi(r.URL.Query().Get("per_page"))
|
|
if perPage == 0 {
|
|
perPage = 20
|
|
}
|
|
|
|
// TODO: 查询数据库
|
|
// var tenants []models.Tenant
|
|
// db.Offset((page-1)*perPage).Limit(perPage).Find(&tenants)
|
|
|
|
var tenants []models.Tenant
|
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
json.NewEncoder(w).Encode(map[string]interface{}{
|
|
"total": 0,
|
|
"page": page,
|
|
"per_page": perPage,
|
|
"total_pages": 0,
|
|
"data": tenants,
|
|
})
|
|
}
|
|
|
|
// Get 获取单个租户
|
|
func (h *TenantHandler) Get(w http.ResponseWriter, r *http.Request) {
|
|
id, err := strconv.ParseUint(r.URL.Query().Get("id"), 10, 32)
|
|
if err != nil {
|
|
http.Error(w, `{"error": "invalid id"}`, http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
// TODO: 查询数据库
|
|
// var tenant models.Tenant
|
|
// db.First(&tenant, id)
|
|
|
|
var tenant models.Tenant
|
|
|
|
if tenant.ID == 0 {
|
|
http.Error(w, `{"error": "tenant not found"}`, http.StatusNotFound)
|
|
return
|
|
}
|
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
json.NewEncoder(w).Encode(tenant)
|
|
}
|
|
|
|
// Update 更新租户
|
|
func (h *TenantHandler) Update(w http.ResponseWriter, r *http.Request) {
|
|
id, err := strconv.ParseUint(r.URL.Query().Get("id"), 10, 32)
|
|
if err != nil {
|
|
http.Error(w, `{"error": "invalid id"}`, http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
var tenant models.Tenant
|
|
if err := json.NewDecoder(r.Body).Decode(&tenant); err != nil {
|
|
http.Error(w, err.Error(), http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
// TODO: 更新数据库
|
|
// db.Model(&tenant).Where("id = ?", id).Updates(map[string]interface{}{
|
|
// "name": tenant.Name,
|
|
// "email": tenant.Email,
|
|
// })
|
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
json.NewEncoder(w).Encode(map[string]interface{}{
|
|
"message": "租户更新成功",
|
|
"data": tenant,
|
|
})
|
|
}
|
|
|
|
// Delete 删除租户
|
|
func (h *TenantHandler) Delete(w http.ResponseWriter, r *http.Request) {
|
|
id, err := strconv.ParseUint(r.URL.Query().Get("id"), 10, 32)
|
|
if err != nil {
|
|
http.Error(w, `{"error": "invalid id"}`, http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
// TODO: 软删除
|
|
// db.Where("id = ?", id).Update("deleted_at", time.Now())
|
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
json.NewEncoder(w).Encode(map[string]interface{}{
|
|
"message": fmt.Sprintf("租户 %d 删除成功", id),
|
|
})
|
|
}
|