package dbapi import ( "encoding/json" "strconv" ) type UserApi struct { Ip string Port int } func (api UserApi) getBasicUrl() string { if api.Ip == "" { return BASIC_URL } if api.Ip == "" { api.Ip = DEFAULT_IP } if api.Port == 0 { api.Port = DEFAULT_PORT } return "http://"+api.Ip+":"+strconv.Itoa(api.Port) } func (api UserApi) Login(username string,password string) (bool,interface{}){ url := api.getBasicUrl() + DATA_URL_PREFIX + "/user/login" client := NewClient() paramBody :=make(map[string]interface{},0) paramBody["username"]=username paramBody["password"]=password respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil) if err != nil { return false,nil } var res Result if err = json.Unmarshal(respBody, &res); err != nil { return false,nil } return res.Success,res.Data } func (api UserApi) FindAllUser(curUserId string) (bool,interface{}) { url := api.getBasicUrl() + DATA_URL_PREFIX + "/user/findAllUser" client := NewClient() query := map[string]string { "userId": curUserId, } body, err := client.DoGetRequest(url, query, nil) if err != nil { return false,nil } var res Result if err = json.Unmarshal(body, &res); err != nil { return false,nil } return true,res.Data } func (api UserApi) FindById(userId string) (bool,interface{}) { url := api.getBasicUrl() + DATA_URL_PREFIX + "/user/findById" client := NewClient() paramBody := map[string]interface{}{ "userId": userId, } respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody,nil, nil) if err != nil { return false,nil } var res Result if err = json.Unmarshal(respBody, &res); err != nil { return false,nil } return res.Success,res.Data } func (api UserApi) SaveAuth(paramBody map[string]interface{}) (bool,interface{}) { url := api.getBasicUrl() + DATA_URL_PREFIX + "/user/saveAuth" client := NewClient() respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil) if err != nil { return false,nil } var res Result if err = json.Unmarshal(respBody, &res); err != nil { return false,nil } return res.Success,res.Data } func (api UserApi) UpdatePwd(userId string, oldPwd string, newPwd string) (bool,interface{}) { url := api.getBasicUrl() + DATA_URL_PREFIX + "/user/updatePwd" client := NewClient() paramBody := map[string]interface{}{ "userId": userId, "oldPwd": oldPwd, "newPwd": newPwd, } respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody,nil, nil) if err != nil { return false,nil } var res Result if err = json.Unmarshal(respBody, &res); err != nil { return false,nil } return res.Success,res.Data } func (api UserApi) DelUser(ids []string) (bool,interface{}) { url := api.getBasicUrl() + DATA_URL_PREFIX + "/user/delUser" client := NewClient() paramBody := map[string]interface{}{ "ids": ids, } respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody,nil, nil) if err != nil { return false,nil } var res Result if err = json.Unmarshal(respBody, &res); err != nil { return false,nil } return res.Success,res.Data }