mirror of http://gitlab.batiao8.com/yic/film.git
95 lines
2.3 KiB
Go
95 lines
2.3 KiB
Go
package haha
|
|
|
|
import (
|
|
"encoding/json"
|
|
"film/base/httputil"
|
|
"fmt"
|
|
log "github.com/sirupsen/logrus"
|
|
"github.com/spf13/cast"
|
|
)
|
|
|
|
type ProcessorConfig struct {
|
|
Token string
|
|
}
|
|
type Processor struct {
|
|
token string
|
|
}
|
|
|
|
func NewProcessor(cfg *ProcessorConfig) *Processor {
|
|
return &Processor{
|
|
token: cfg.Token,
|
|
}
|
|
}
|
|
|
|
func (p *Processor) checkError(body []byte) (interface{}, error) {
|
|
result := make(map[string]interface{})
|
|
if err := json.Unmarshal(body, &result); err != nil {
|
|
log.Errorf("json.unmarshal [%s] error : %s", string(body), err.Error())
|
|
return nil, err
|
|
}
|
|
if cast.ToInt(result["status"]) != 200 || cast.ToInt(result["code"]) != 200 {
|
|
log.Errorf("status[%d] code[%d] message[%s]", cast.ToInt(result["status"]), cast.ToInt(result["code"]), cast.ToString(result["msg"]))
|
|
return nil, fmt.Errorf("%d:%s", cast.ToInt(result["code"]), cast.ToString(result["msg"]))
|
|
}
|
|
return result["data"], nil
|
|
}
|
|
|
|
func (p *Processor) BidPrice(id int64, price int64) error {
|
|
reqUrl := "https://hahapiao.cn/api/Synchro/toPrice"
|
|
params := map[string]interface{}{
|
|
"id": cast.ToString(id),
|
|
"price": fmt.Sprintf("%.2f", float64(price)/100),
|
|
}
|
|
header := map[string]interface{}{
|
|
"token": p.token,
|
|
}
|
|
body, err := httputil.HttpPostForm(reqUrl, header, params)
|
|
if err != nil {
|
|
log.Error("httpPost error : %s", err.Error())
|
|
return err
|
|
}
|
|
|
|
_, err = p.checkError(body)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (p *Processor) queryBid(params map[string]interface{}) ([]*BidOrder, error) {
|
|
reqUrl := "https://hahapiao.cn/api/Synchro/getOrderList"
|
|
|
|
header := map[string]interface{}{
|
|
"token": p.token,
|
|
}
|
|
body, err := httputil.HttpPostForm(reqUrl, header, params)
|
|
if err != nil {
|
|
log.Error("httpPost error : %s", err.Error())
|
|
return nil, err
|
|
}
|
|
|
|
datas, err := p.checkError(body)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
result := make([]*BidOrder, 0)
|
|
for _, d := range cast.ToSlice(datas) {
|
|
data := cast.ToStringMap(d)
|
|
o := new(BidOrder)
|
|
o.OrderId = cast.ToInt64(data["id"])
|
|
o.OrderNo = cast.ToString(data["orderNumber"])
|
|
o.Status = cast.ToString(data["status"])
|
|
o.BidTime = cast.ToInt64(data["bindd_time"])
|
|
o.BidPrice = int64(cast.ToFloat64(data["price"]) * 100)
|
|
result = append(result, o)
|
|
}
|
|
return result, nil
|
|
}
|
|
|
|
func (p *Processor) QueryBidding() error {
|
|
|
|
return nil
|
|
}
|