- static html页面目录
- configs 配置文件读取处理
- routes 路由处理
- etc 配置文件处理
- utils 通用处理，错误信息
- dbs 数据库处理文件
- eths 以太坊相关处理
go get -u github.com/BurntSushi/toml
先安装crypto,labstack使用了该库，需要借助github，go get不能用
cd $GOPATH/src
mkdir -p golang.org/x/
cd golang.org/x/
git clone https://github.com/golang/crypto.git
安装echo
go get -u github.com/labstack/echo
go get -u github.com/labstack/echo-contrib/session
mysql的go语言驱动安装
go get -u github.com/go-sql-driver/mysql
其他可能涉及的库
go get -u github.com/labstack/gommon/
go get -u github.com/dgrijalva/jwt-go
go get -u github.com/go-sql-driver/mysql
| 名称 | 说明 |
|---|---|
| url | /account |
| method | POST |
| 请求数据 | json:email,identity_id,username |
| 响应数据 | json:errno,errmsg |
响应举例
{"errno":"0","errmsg":"成功","data":null}
| 名称 | 说明 |
|---|---|
| url | /session |
| method | GET |
| 请求数据 | 无 |
| 响应数据 | json:errno,errmsg |
响应举例
{"errno":"0","errmsg":"成功","data":null}
| 名称 | 说明 |
|---|---|
| url | /login |
| method | POST |
| 请求数据 | json:identity_id,username |
| 响应数据 | json:errno,errmsg |
响应举例
{"errno":"0","errmsg":"成功","data":null}
| 名称 | 说明 |
|---|---|
| url | /content |
| method | POST |
| 请求数据 | form中文件二进制数据 |
| 响应数据 | json:errno,errmsg |
请求举例
curl --form "fileupload=@wyz.jpg" http://localhost:8086/content
| 名称 | 说明 |
|---|---|
| url | /content |
| method | GET |
| 请求数据 | 无 |
| 响应数据 | json:{Errno,Errmsg,Data:{total_page,current_page,contents:[]}} |
说明：contents 是一个结构体数组，举例如下：
{
"errno": "0",
"errmsg": "成功",
"data": {
"contents": [{
"content_hash": "2b48f7f9b1156bd26d13d498d2a2441ca857922d743e5ab7d8fde20dd18e3f21",
"title": "马夏尔2.jpeg",
"token_id":"3"
}, {
"content_hash": "f72d0385722cb58fddaa493557950fe83fe317a0aa41d44ddb386c82f902d9dd",
"title": "鸟叔2.jpg",
"token_id":"4"
}, {
"content_hash": "6bb7e5ec0c5f057cfdb25e54a2f0f09bca5819213761697fa57e6368eed1ec9d",
"title": "am9.jpg",
"token_id":"5"
}],
"current_page": 1,
"total_page": 1
}
}
| 名称 | 说明 |
|---|---|
| url | /content/:title |
| method | GET |
| 请求数据 | 无 |
| 响应数据 | 图片二进制数据 |
用户自行发起拍卖，指定份数，指定价格
| 名称 | 说明 |
|---|---|
| url | /auction |
| method | POST |
| 请求数据 | json:{content_hash,percent,price,token_id} |
| 响应数据 | json:errno,errmsg |
请求数据举例：
content_hash: "6bb7e5ec0c5f057cfdb25e54a2f0f09bca5819213761697fa57e6368eed1ec9d",
percent: 30,
price: 20,
token_id:6
| 名称 | 说明 |
|---|---|
| url | /auctions |
| method | GET |
| 请求数据 | 无 |
| 响应数据 | json:{errno,errmsg,data:[{price,title,token_id,content_hash}]} |
响应数据举例
{"errno":"0","errmsg":"成功","data":[{"price":"100","title":"马夏尔和女友.jpeg","token_id":"6"}]}
| 名称 | 说明 |
|---|---|
| url | /auction/bid |
| method | GET |
| 请求数据 | price,tokenid |
| 响应数据 | json:{errno,errmsg} |
package utils
import (
"fmt"
"io/ioutil"
"net/http"
"strings"
"github.com/labstack/echo"
)
const (
RECODE_OK = "0"
RECODE_DBERR = "4001"
RECODE_NODATA = "4002"
RECODE_DATAEXIST = "4003"
RECODE_DATAERR = "4004"
RECODE_SESSIONERR = "4101"
RECODE_LOGINERR = "4102"
RECODE_PARAMERR = "4103"
RECODE_USERERR = "4104"
RECODE_HASHERR = "4105"
RECODE_PWDERR = "4106"
RECODE_EXISTSERR = "4201"
RECODE_IPCERR = "4202"
RECODE_THIRDERR = "4301"
RECODE_IOERR = "4302"
RECODE_SERVERERR = "4500"
RECODE_UNKNOWERR = "4501"
)
var recodeText = map[string]string{
RECODE_OK: "成功",
RECODE_DBERR: "数据库操作错误",
RECODE_NODATA: "无数据",
RECODE_DATAEXIST: "数据已存在",
RECODE_DATAERR: "数据错误",
RECODE_SESSIONERR: "用户未登录",
RECODE_LOGINERR: "用户登录失败",
RECODE_PARAMERR: "参数错误",
RECODE_USERERR: "用户不存在或密码错误",
RECODE_HASHERR: "HASH错误",
RECODE_PWDERR: "密码错误",
RECODE_EXISTSERR: "重复上传错误",
RECODE_IPCERR: "IPC错误",
RECODE_THIRDERR: "与以太坊交互失败",
RECODE_IOERR: "文件读写错误",
RECODE_SERVERERR: "内部错误",
RECODE_UNKNOWERR: "未知错误",
}
func RecodeText(code string) string {
str, ok := recodeText[code]
if ok {
return str
}
return recodeText[RECODE_UNKNOWERR]
}
type Resp struct {
Errno string `json:"errno"`
ErrMsg string `json:"errmsg"`
Data interface{} `json:"data"`
}
//resp数据响应
func ResponseData(c echo.Context, resp *Resp) {
resp.ErrMsg = RecodeText(resp.Errno)
c.JSON(http.StatusOK, resp)
}
//读取dir目录下文件名带address的文件
func GetFileName(address, dirname string) (string, error) {
data, err := ioutil.ReadDir(dirname)
if err != nil {
fmt.Println("read dir err", err)
return "", err
}
for _, v := range data {
if strings.Index(v.Name(), address) > 0 {
//代表找到文件
return v.Name(), nil
}
}
return "", nil
}
func LogDataUnpack(start, end int, val interface{}, data []byte) (err error) {
length := len(data)
fmt.Println("call--- LogDataUnpack begin", reflect.TypeOf(val).String(), length)
if start >= length || end > length {
return errors.New("too short datas")
}
pdata := data[start:end]
fmt.Println(string(data), string(pdata))
if reflect.TypeOf(val).String() == "int64" || reflect.TypeOf(val).String() == "*int64" {
var tmpval *int64 = val.(*int64)
*tmpval, err = strconv.ParseInt(string(pdata), 16, 32)
fmt.Println("call ParseInt", val)
} else if reflect.TypeOf(val).String() == "string" || reflect.TypeOf(val).String() == "*string" {
var tmpval *string = val.(*string)
*tmpval = string(pdata)
fmt.Println("call ParseInt", val)
}
fmt.Println("call--- LogDataUnpack end", val)
return nil
}
func ParseMintEvent2Db(data []byte) error {
fmt.Println(string(data))
var tokenId int64
err := LogDataUnpack(32*5, 32*6, &tokenId, data)
if err != nil {
fmt.Println("faile to get tokenid", err)
return err
}
fmt.Println("tokenid===", tokenId)
var pixHash string
err = LogDataUnpack(32*0, 32*2, &pixHash, data)
if err != nil {
return err
}
fmt.Println("pixHash===", pixHash)
var pixAddr string
err = LogDataUnpack(88, 128, &pixAddr, data)
if err != nil {
return err
}
pixAddr = "0x" + pixAddr
fmt.Println("pixAddr===", pixAddr)
//插入到数据库中
sql := fmt.Sprintf("insert into account_content(content_hash,token_id,address) values('%s',%d,'%s')", pixHash, tokenId, pixAddr)
_, err = dbs.Create(sql)
if err != nil {
fmt.Println("failed to insert into mysql ", sql, err)
return err
}
return nil
}