soul-yongping/soul-api/internal/handler/db_person.go

package handler

import (
	"fmt"
	"net/http"
	"time"

	"soul-api/internal/database"
	"soul-api/internal/model"

	"github.com/gin-gonic/gin"
)

func DBPersonList(c *gin.Context) {
	var rows []model.Person
	if err := database.DB().Order("name ASC").Find(&rows).Error; err != nil {
		c.JSON(http.StatusOK, gin.H{"success": false, "error": err.Error()})
		return
	}
	c.JSON(http.StatusOK, gin.H{"success": true, "persons": rows})
}

func DBPersonSave(c *gin.Context) {
	var body struct {
		PersonID string `json:"personId"`
		Name     string `json:"name"`
		Label    string `json:"label"`
	}
	if err := c.ShouldBindJSON(&body); err != nil {
		c.JSON(http.StatusOK, gin.H{"success": false, "error": "请求体无效"})
		return
	}
	if body.Name == "" {
		c.JSON(http.StatusOK, gin.H{"success": false, "error": "name 必填"})
		return
	}
	if body.PersonID == "" {
		body.PersonID = fmt.Sprintf("%s_%d", body.Name, time.Now().UnixMilli())
	}
	db := database.DB()
	var existing model.Person
	if db.Where("person_id = ?", body.PersonID).First(&existing).Error == nil {
		existing.Name = body.Name
		existing.Label = body.Label
		db.Save(&existing)
		c.JSON(http.StatusOK, gin.H{"success": true, "person": existing})
		return
	}
	p := model.Person{PersonID: body.PersonID, Name: body.Name, Label: body.Label}
	if err := db.Create(&p).Error; err != nil {
		c.JSON(http.StatusOK, gin.H{"success": false, "error": err.Error()})
		return
	}
	c.JSON(http.StatusOK, gin.H{"success": true, "person": p})
}

func DBPersonDelete(c *gin.Context) {
	pid := c.Query("personId")
	if pid == "" {
		c.JSON(http.StatusOK, gin.H{"success": false, "error": "缺少 personId"})
		return
	}
	if err := database.DB().Where("person_id = ?", pid).Delete(&model.Person{}).Error; err != nil {
		c.JSON(http.StatusOK, gin.H{"success": false, "error": err.Error()})
		return
	}
	c.JSON(http.StatusOK, gin.H{"success": true})
}

func DBLinkTagList(c *gin.Context) {
	var rows []model.LinkTag
	if err := database.DB().Order("label ASC").Find(&rows).Error; err != nil {
		c.JSON(http.StatusOK, gin.H{"success": false, "error": err.Error()})
		return
	}
	c.JSON(http.StatusOK, gin.H{"success": true, "linkTags": rows})
}

func DBLinkTagSave(c *gin.Context) {
	var body struct {
		TagID    string `json:"tagId"`
		Label    string `json:"label"`
		URL      string `json:"url"`
		Type     string `json:"type"`
		AppID    string `json:"appId"`
		PagePath string `json:"pagePath"`
	}
	if err := c.ShouldBindJSON(&body); err != nil {
		c.JSON(http.StatusOK, gin.H{"success": false, "error": "请求体无效"})
		return
	}
	if body.TagID == "" || body.Label == "" {
		c.JSON(http.StatusOK, gin.H{"success": false, "error": "tagId 和 label 必填"})
		return
	}
	if body.Type == "" {
		body.Type = "url"
	}
	db := database.DB()
	var existing model.LinkTag
	if db.Where("tag_id = ?", body.TagID).First(&existing).Error == nil {
		existing.Label = body.Label
		existing.URL = body.URL
		existing.Type = body.Type
		existing.AppID = body.AppID
		existing.PagePath = body.PagePath
		db.Save(&existing)
		c.JSON(http.StatusOK, gin.H{"success": true, "linkTag": existing})
		return
	}
	t := model.LinkTag{TagID: body.TagID, Label: body.Label, URL: body.URL, Type: body.Type, AppID: body.AppID, PagePath: body.PagePath}
	if err := db.Create(&t).Error; err != nil {
		c.JSON(http.StatusOK, gin.H{"success": false, "error": err.Error()})
		return
	}
	c.JSON(http.StatusOK, gin.H{"success": true, "linkTag": t})
}

func DBLinkTagDelete(c *gin.Context) {
	tid := c.Query("tagId")
	if tid == "" {
		c.JSON(http.StatusOK, gin.H{"success": false, "error": "缺少 tagId"})
		return
	}
	if err := database.DB().Where("tag_id = ?", tid).Delete(&model.LinkTag{}).Error; err != nil {
		c.JSON(http.StatusOK, gin.H{"success": false, "error": err.Error()})
		return
	}
	c.JSON(http.StatusOK, gin.H{"success": true})
}