120 lines
2.9 KiB
Go
120 lines
2.9 KiB
Go
package index_management
|
|
|
|
import (
|
|
"infini.sh/framework/core/elastic"
|
|
"infini.sh/framework/core/global"
|
|
"net/http"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
|
|
"infini.sh/console/config"
|
|
model2 "infini.sh/console/model"
|
|
"infini.sh/framework/core/api"
|
|
httprouter "infini.sh/framework/core/api/router"
|
|
"infini.sh/framework/core/orm"
|
|
"infini.sh/framework/core/util"
|
|
)
|
|
|
|
type APIHandler struct {
|
|
Config *config.AppConfig
|
|
api.Handler
|
|
}
|
|
|
|
func (handler APIHandler) GetDictListAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params) {
|
|
var (
|
|
fromStr = handler.GetParameterOrDefault(req, "from", "0")
|
|
sizeStr = handler.GetParameterOrDefault(req, "size", "6")
|
|
tag = handler.GetParameterOrDefault(req, "tags", "")
|
|
name = handler.GetParameterOrDefault(req, "name", "")
|
|
from, _ = strconv.Atoi(fromStr)
|
|
size, _ = strconv.Atoi(sizeStr)
|
|
tags = strings.Split(tag, ",")
|
|
resp = newResponseBody()
|
|
)
|
|
if len(tags) > 3 {
|
|
tags = tags[0:3]
|
|
}
|
|
rel, err := model2.GetDictList(from, size, name, tags, global.MustLookupString(elastic.GlobalSystemElasticsearchID))
|
|
if err != nil {
|
|
resp["error"] = err
|
|
resp["status"] = false
|
|
handler.WriteJSON(w, resp, http.StatusOK)
|
|
return
|
|
}
|
|
resp["payload"] = rel
|
|
handler.WriteJSON(w, resp, http.StatusOK)
|
|
}
|
|
|
|
func (handler APIHandler) CreateDictItemAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params) {
|
|
id := ps.ByName("id")
|
|
if strings.Trim(id, "/") == "" {
|
|
id = util.GetUUID()
|
|
}
|
|
createdAt := time.Now()
|
|
|
|
resp := newResponseBody()
|
|
dict := model2.Dict{
|
|
ID: id,
|
|
CreatedAt: createdAt,
|
|
UpdatedAt: createdAt,
|
|
}
|
|
err := handler.DecodeJSON(req, &dict)
|
|
if err != nil {
|
|
resp["status"] = false
|
|
resp["error"] = err
|
|
handler.WriteJSON(w, resp, http.StatusOK)
|
|
return
|
|
}
|
|
|
|
err = orm.Create(&dict)
|
|
if err != nil {
|
|
resp["status"] = false
|
|
resp["error"] = err
|
|
handler.WriteJSON(w, resp, http.StatusOK)
|
|
return
|
|
}
|
|
resp["payload"] = dict
|
|
handler.WriteJSON(w, resp, http.StatusOK)
|
|
}
|
|
|
|
func (handler APIHandler) DeleteDictItemAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params) {
|
|
id := ps.ByName("id")
|
|
dict := model2.Dict{}
|
|
dict.ID = id
|
|
resp := newResponseBody()
|
|
|
|
err := orm.Delete(dict)
|
|
if err != nil {
|
|
resp["status"] = false
|
|
resp["error"] = err
|
|
handler.WriteJSON(w, resp, http.StatusOK)
|
|
return
|
|
}
|
|
handler.WriteJSON(w, resp, http.StatusOK)
|
|
}
|
|
|
|
func (handler APIHandler) UpdateDictItemAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params) {
|
|
dict := model2.Dict{}
|
|
err := handler.DecodeJSON(req, &dict)
|
|
resp := newResponseBody()
|
|
if err != nil {
|
|
resp["status"] = false
|
|
resp["error"] = err
|
|
handler.WriteJSON(w, resp, http.StatusOK)
|
|
return
|
|
|
|
}
|
|
dict.UpdatedAt = time.Now()
|
|
|
|
err = orm.Update(dict)
|
|
if err != nil {
|
|
resp["status"] = false
|
|
resp["error"] = err
|
|
handler.WriteJSON(w, resp, http.StatusOK)
|
|
return
|
|
}
|
|
resp["payload"] = dict
|
|
handler.WriteJSON(w, resp, http.StatusOK)
|
|
|
|
} |