remove account api
This commit is contained in:
liugq
parent
fcd52923c2
commit
075be76bcc
|
|
@ -1,175 +0,0 @@
|
|||
package account
|
||||
|
||||
import (
|
||||
"infini.sh/console/internal/biz"
|
||||
"infini.sh/console/internal/core"
|
||||
"infini.sh/console/internal/dto"
|
||||
"infini.sh/framework/core/api"
|
||||
"infini.sh/framework/core/api/router"
|
||||
"infini.sh/framework/core/util"
|
||||
"net/http"
|
||||
)
|
||||
|
||||
type Account struct {
|
||||
api.Handler
|
||||
}
|
||||
|
||||
func init() {
|
||||
//account := Account{}
|
||||
//api.HandleAPIMethod(api.POST, "/account/login", account.Login)
|
||||
//
|
||||
//api.HandleAPIMethod(api.GET, "/account/current_user", account.CurrentUser)
|
||||
//
|
||||
//api.HandleAPIMethod(api.DELETE, "/account/logout", account.Logout)
|
||||
//api.HandleAPIMethod(api.GET, "/account/profile", m.LoginRequired(account.Profile))
|
||||
//api.HandleAPIMethod(api.PUT, "/account/password", m.LoginRequired(account.UpdatePassword))
|
||||
}
|
||||
|
||||
const userInSession = "user_session:"
|
||||
|
||||
func (h Account) Login(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
|
||||
|
||||
var req dto.Login
|
||||
err := h.DecodeJSON(r, &req)
|
||||
if err != nil {
|
||||
h.ErrorInternalServer(w, err.Error())
|
||||
return
|
||||
}
|
||||
|
||||
data, err := biz.Login(req.Username, req.Password)
|
||||
if err != nil {
|
||||
h.ErrorInternalServer(w, err.Error())
|
||||
return
|
||||
}
|
||||
data["status"] = "ok"
|
||||
|
||||
//api.SetSession(w, r, userInSession+req.Username, req.Username)
|
||||
h.WriteOKJSON(w, data)
|
||||
}
|
||||
|
||||
func (h Account) CurrentUser(w http.ResponseWriter, req *http.Request, ps httprouter.Params) {
|
||||
|
||||
exists, user := api.GetSession(w, req, userInSession)
|
||||
if exists {
|
||||
data := util.MapStr{
|
||||
"name": user,
|
||||
"avatar": "",
|
||||
"userid": "10001",
|
||||
"email": "hello@infini.ltd",
|
||||
"signature": "极限科技 - 专业的开源搜索与实时数据分析整体解决方案提供商。",
|
||||
"title": "首席设计师",
|
||||
"group": "INFINI Labs",
|
||||
"tags": []util.MapStr{
|
||||
{
|
||||
"key": "0",
|
||||
"label": "很有想法的",
|
||||
}},
|
||||
"notifyCount": 12,
|
||||
"country": "China",
|
||||
"geographic": util.MapStr{
|
||||
"province": util.MapStr{
|
||||
"label": "湖南省",
|
||||
"key": "330000",
|
||||
},
|
||||
"city": util.MapStr{
|
||||
"label": "长沙市",
|
||||
"key": "330100",
|
||||
},
|
||||
},
|
||||
"address": "岳麓区湘江金融中心",
|
||||
"phone": "4001399200",
|
||||
}
|
||||
|
||||
h.WriteJSON(w, data, 200)
|
||||
} else {
|
||||
data := util.MapStr{
|
||||
"status": "error",
|
||||
"type": "account",
|
||||
"currentAuthority": "guest",
|
||||
}
|
||||
h.WriteJSON(w, data, 403)
|
||||
}
|
||||
}
|
||||
func (h Account) Logout(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
|
||||
reqUser, err := biz.FromUserContext(r.Context())
|
||||
if err != nil {
|
||||
h.ErrorInternalServer(w, err.Error())
|
||||
return
|
||||
}
|
||||
|
||||
delete(biz.TokenMap, reqUser.UserId)
|
||||
h.WriteOKJSON(w, util.MapStr{
|
||||
"status": "ok",
|
||||
})
|
||||
}
|
||||
func (h Account) Profile(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
|
||||
reqUser, err := biz.FromUserContext(r.Context())
|
||||
if err != nil {
|
||||
h.ErrorInternalServer(w, err.Error())
|
||||
return
|
||||
}
|
||||
|
||||
if reqUser.UserId == "admin" {
|
||||
|
||||
u := util.MapStr{
|
||||
"user_id": "admin",
|
||||
"name": "admin",
|
||||
"email": "admin@infini.ltd",
|
||||
"nick_name": "admin",
|
||||
"phone": "13011111111",
|
||||
}
|
||||
h.WriteOKJSON(w, core.FoundResponse(reqUser.UserId, u))
|
||||
} else {
|
||||
user, err := biz.GetUser(reqUser.UserId)
|
||||
if err != nil {
|
||||
h.ErrorInternalServer(w, err.Error())
|
||||
return
|
||||
}
|
||||
u := util.MapStr{
|
||||
"user_id": user.ID,
|
||||
"name": user.Name,
|
||||
"email": user.Email,
|
||||
"nick_name": user.NickName,
|
||||
"phone": user.Phone,
|
||||
}
|
||||
h.WriteOKJSON(w, core.FoundResponse(reqUser.UserId, u))
|
||||
}
|
||||
|
||||
return
|
||||
}
|
||||
func (h Account) UpdatePassword(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
|
||||
reqUser, err := biz.FromUserContext(r.Context())
|
||||
if err != nil {
|
||||
h.ErrorInternalServer(w, err.Error())
|
||||
return
|
||||
}
|
||||
var req dto.UpdatePassword
|
||||
err = h.DecodeJSON(r, &req)
|
||||
if err != nil {
|
||||
h.ErrorInternalServer(w, err.Error())
|
||||
return
|
||||
}
|
||||
err = biz.UpdatePassword(reqUser, req)
|
||||
if err != nil {
|
||||
h.ErrorInternalServer(w, err.Error())
|
||||
return
|
||||
}
|
||||
h.WriteOKJSON(w, core.UpdateResponse(reqUser.UserId))
|
||||
return
|
||||
}
|
||||
func (h Account) UpdateProfile(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
|
||||
reqUser, err := biz.FromUserContext(r.Context())
|
||||
if err != nil {
|
||||
h.ErrorInternalServer(w, err.Error())
|
||||
return
|
||||
}
|
||||
var req dto.UpdateProfile
|
||||
err = h.DecodeJSON(r, &req)
|
||||
err = biz.UpdateProfile(reqUser, req)
|
||||
if err != nil {
|
||||
h.ErrorInternalServer(w, err.Error())
|
||||
return
|
||||
}
|
||||
h.WriteOKJSON(w, core.UpdateResponse(reqUser.UserId))
|
||||
return
|
||||
}
|
||||
Loading…
Reference in New Issue