21ic电子技术开发论坛 › 软件应用 › 平台与系统开发 › 基于之前结果，完成一个简单的测试程序 ...
返回列表 发新帖我要提问

基于之前结果，完成一个简单的测试程序

[复制链接]
1833|11
 楼主| keer_zu 发表于 2018-1-23 23:29 | 显示全部楼层 |阅读模式
测试程序, IO, API, ck, ge
cmd.go

复制
  1. package api
    


  2. 

  3. import(
    

  4. "io/ioutil"
    

  5.     "net/http"
    

  6.     "bytes"
    

  7.     jsoniter "github.com/json-iterator/go"
    

  8.     "fmt"
    

  9.     "errors"
    

  10.     "strings"
    

  11.     )
    


  12. 

  13. var http_url string = "http://10.10.1.20:8083"
    


  14. 


  15. 

  16. type Error struct {
    

  17.         Code         int                 `json:"code"`
    

  18.         Message         string         `json:"message"`
    

  19. }
    


  20. 

  21. type ApiError struct {
    

  22.         Error_code         int                 `json:"error_code"`
    

  23.         Result                 bool         `json:"result"`
    

  24. }
    


  25. 

  26. //type ApiTicker
    


  27. 

  28. func TestGetResParse(ret []byte,res interface{}) error{
    


  29. 

  30.         var resApi ApiResComm
    

  31.         resApi.SetRes(res)
    


  32. 

  33.         str :=  string(ret[1:len(ret)-1])  //需要正则
    


  34. 

  35.         strUn := strings.Replace("{"res":" + str + "}","\","",-1)
    


  36. 

  37.         byteUn :=  []byte(strUn)
    

  38.         fmt.Printf("byteUn: %s\n",byteUn)
    

  39.         
    

  40.         if err := jsoniter.Unmarshal(byteUn,&resApi); err != nil{
    

  41.                 fmt.Printf("parse error: %s\n",err.Error())
    

  42.                 return err
    

  43.         }
    


  44. 

  45.         return nil
    

  46. }
    


  47. 

  48. //================================================
    


  49. 

  50. type HttpCmd struct {
    

  51.         //CmdPost(string) (string,error)
    

  52. }
    


  53. 

  54. func (c *HttpCmd)CmdPost(jsonCmd string)([]byte,error) {
    

  55.         body := jsonCmd
    

  56.         res, err := http.Post(http_url, "application/json;charset=utf-8", bytes.NewBuffer([]byte(body)))
    

  57.         if err != nil {
    

  58.                 fmt.Println("http post error ", err.Error())
    

  59.                 return nil,err
    

  60.         }
    


  61. 

  62.         defer res.Body.Close()
    


  63. 

  64.         content, err := ioutil.ReadAll(res.Body)
    

  65.         if err != nil {
    

  66.                 fmt.Println("post, read body error ", err.Error())
    

  67.                 return nil,err
    

  68.         }
    


  69. 

  70.         return content,nil
    

  71. }
    


  72. 

  73. func (c *HttpCmd) CmdGet(getUrl string)([]byte,error) {
    


  74. 

  75.         resp, err := http.Get(getUrl)
    

  76.         if err != nil {
    

  77.                 fmt.Println("http Get error ", err.Error())
    

  78.                 return nil,err
    

  79.         }
    

  80.  
    

  81.         defer resp.Body.Close()
    

  82.         content, err := ioutil.ReadAll(resp.Body)
    

  83.         if err != nil {
    

  84.                 fmt.Println("get, read body error ", err.Error())
    

  85.                 return nil,err
    

  86.         }
    

  87.  
    

  88.         return content,nil
    

  89. }
    


  90. 

  91. func (c *HttpCmd) CmdParse (res []byte,result interface{}) (ResultComm,error){
    

  92.         var params ResultComm
    

  93.         params.SetResult(result)
    


  94. 

  95.         if err := jsoniter.Unmarshal(res,&params); err != nil{
    

  96.                 return params, err
    

  97.         }
    


  98. 

  99.         if params.GetError() != nil{
    

  100.                 errMsg := fmt.Sprintf("%v", params.GetError())
    

  101.                 return params, errors.New(errMsg)
    

  102.         }
    


  103. 

  104.         return params, nil
    

  105. }
    


  106. 

  107. func (c *HttpCmd) ApiResParse(ret []byte,res interface{})(int,error){
    


  108. 

  109.         var resApi ApiResComm
    

  110.          var apiError ApiError
    

  111.         resApi.SetRes(res)
    


  112. 

  113.         str :=  string(ret[1:len(ret)-1])  //需要正则
    


  114. 

  115.         strUn := strings.Replace("{"res":" + str + "}","\","",-1)
    


  116. 

  117.         strEt := strings.Replace(str,"\","",-1)
    


  118. 

  119.         if err := jsoniter.Unmarshal([]byte(strEt),&apiError); err != nil{
    

  120.                  fmt.Printf("api error parse error: %s\n",err.Error())
    

  121.                  return 0,err
    

  122.         }
    


  123. 

  124.         byteUn :=  []byte(strUn)
    

  125.         //fmt.Printf("byteUn: %s\n",byteUn)
    


  126. 

  127.         if apiError.Error_code != 0 {
    

  128.                 return apiError.Error_code,nil
    

  129.         }
    

  130.         
    

  131.         if err := jsoniter.Unmarshal(byteUn,&resApi); err != nil{
    

  132.                 fmt.Printf("api result parse error: %s\n",err.Error())
    

  133.                 return 0,err
    

  134.         }
    

  135.         
    

  136.         return 0,nil
    

  137. }
    


  138. 

  139. //==================================================
    


  140. 

  141. type CmdResult interface {
    

  142.         GetError()*Error
    

  143.         GetId()int
    

  144.         GetResult()interface{}
    

  145.         SetResult(interface{})
    

  146. }
    


  147. 


  148. 

  149. type ApiRes interface {
    

  150.         GetRes()interface{}
    

  151.         SetRes(interface{})
    

  152. }
    


  153. 

  154. //////////////////////////////////////////////////////////////////////////////
    


  155. 

  156. type CmdAddAsset struct {
    

  157.         HttpCmd
    

  158.         ResultComm
    

  159. }
    


  160. 

  161. type AddAssetResul struct {
    


  162. 

  163. }
    


  164. 


  165. 

  166. ///////////////////////////////////////////////////////////////////////////////////
    


  167. 

  168. type ResultComm struct {
    

  169.         Err                 *Error                 `json:"error"`
    

  170.         Result         interface{}         `json:"result"`
    

  171.         Id                 int                         `json:"id"` 
    

  172. }
    


  173. 

  174. func (r *ResultComm)GetError()*Error{
    

  175.         return r.Err
    

  176. }
    


  177. 

  178. func (r *ResultComm)GetId()int {
    

  179.         return r.Id
    

  180. }
    


  181. 

  182. func (r *ResultComm)GetResult()interface{}{
    

  183.         return r.Result
    

  184. }
    


  185. 

  186. func (r *ResultComm)SetResult(result interface{}){
    

  187.         r.Result = result
    

  188. }
    


  189. 

  190. ///////////////////////////////////////////////////////////////////////////////////
    


  191. 

  192. type ApiResComm struct {
    

  193.         Res         interface{}         `json:"res"`
    

  194. }
    


  195. 

  196. func (r *ApiResComm)GetRes()interface{}{
    

  197.         return r.Res
    

  198. }
    


  199. 

  200. func (r *ApiResComm)SetRes(res interface{}){
    

  201.         r.Res = res
    

  202. }
    


  203. 

  204. ///////////////////////////////////////////////////////////////////////////////////
    


  205. 


  206. 

  207. type CmdAddMarket struct {
    

  208.         HttpCmd
    

  209.         ResultComm
    

  210. }
    


  211. 

  212. //=======================================================
    


  213. 

  214. type CmdMarketSummary struct {
    

  215.         HttpCmd
    

  216.         ResultComm
    

  217. }
    


  218. 


  219. 

  220. type MarketSummaryResult struct {
    

  221.         Name                 string                 `json:"name"`
    

  222.         Ask_count         int                         `json:"ask_count"`
    

  223.         Ask_amount         string                `json:"ask_amount"`
    

  224.         Bid_count         int                         `json:"bid_count"`
    

  225.         bid_amount         string                 `json:"bid_amount"`
    

  226. }
    


  227. 


  228. 

  229. ////////////////////////////////////////////////////////////////////////////////////////
    


  230. 

  231. type CommCommand struct {
    

  232.         HttpCmd
    

  233.         ResultComm
    

  234. }
    


  235. 


  236. 

  237. type ApiCommand struct {
    

  238.         HttpCmd
    

  239.         ApiResComm
    

  240. }
回复

收藏 举报

相关帖子
 楼主| keer_zu 发表于 2018-1-23 23:30 | 显示全部楼层
api.go


复制
  1. package api
    


  2. 

  3. import (
    

  4.         "fmt"
    

  5. )
    


  6. 

  7. var BaseUrl string  = "http://10.10.1.20:8083/api/v1/"
    


  8. 

  9. ///////////////////////////////////////////////// 币币行情 API ////////////////////////////////////////////////////////////
    


  10. 

  11. ///////////////////////////////////获取币币行情
    

  12. func Build_ticker_cmd(market string) string{
    

  13.         str := BaseUrl + "ticker.do?market=" + market
    

  14.         return str
    

  15. }
    


  16. 

  17. //// resoponse
    


  18. 

  19. type Ticker struct {
    

  20.         Period         int                 `json:"period"`
    

  21.         Last         string         `json:"last"`
    

  22.         Open         string         `json:"open"`
    

  23.         Close         string         `json:"close"`
    

  24.         High         string         `json:"high"`
    

  25.         Low                 string         `json:"low"`
    

  26.         Volume         string         `json:"volume"`
    

  27. }
    


  28. 

  29. type TickerRes struct {
    

  30.         Date         string         `json:"date"`
    

  31.         Tick         *Ticker         `json:"ticker"`
    

  32. }
    


  33. 

  34. ////////////////////////////////////获取深度
    

  35. func Build_depth_cmd(market string) string{
    

  36.         str := BaseUrl + "depth.do?market=" + market
    

  37.         return str
    

  38. }
    


  39. 


  40. 

  41. type DepthRes struct {
    

  42.         Asks         [][]float32                 `json:"asks"`
    

  43.         Bids         [][]float32                 `json:"bids"`
    

  44. }
    


  45. 

  46. /////////////////////////////////////获取交易信息
    

  47. func Build_trades_cmd(market string,since string) string{
    

  48.         str := BaseUrl + "trades.do?market=" + market + "&since=" + since
    

  49.         return str
    

  50. }
    


  51. 


  52. 


  53. 

  54. type TradesRes struct {
    

  55.         Date         string                 `json:"date"`
    

  56.         Date_ms string                 `json:"date_ms"`
    

  57.         Price         float32                `json:"price"`
    

  58.         Amount         float32                 `json:"amount"`
    

  59.         Tid                 string                 `json:"tid"`
    

  60.         Type         string                 `json:"type"`
    

  61. }
    


  62. 


  63. 


  64. 

  65. ///////////////////////////////////////////////// 币币交易 API //////////////////////////////////////////////////////////////
    


  66. 

  67. // ////////////////////////////////////////////获取用户信息
    


  68. 

  69. // https://www.hotbit .com/api/v1/userinfo.do?AppKey=Ldwi395y2&Sign=NUhgdi784-dldjt=Ldi
    

  70. func build_userinfo_cmd(appkey string,sign string) string {
    

  71.         str := BaseUrl + "userinfo.do?AppKey=" + appkey + "&Sign=" + sign
    

  72.         return str
    

  73. }
    


  74. 


  75. 

  76. type Asset struct {
    

  77.         Available         string                 `json:"available"`
    

  78.         Freeze                 string                 `json:"freeze"`
    

  79. }
    


  80. 

  81. type UserinfoRes struct {
    

  82.         Assets                 map[string]Asset         `json:"assets"`
    

  83.         Error                 string                 `json:"error"`
    

  84. }
    


  85. 


  86. 

  87. //提交订单
    

  88. //http://www.hotbit .com/api/v1/trade.do?apikey=e3bdc2ae54f2eb47ec299d830cf0f01c&sign=123&market=EOSUSDT&type=buy&price=200&amount=12.9
    

  89. func build_trade_cmd(apikey string,sign string,market string,Type string,price string,amount string) string {
    

  90.         str := BaseUrl + "trade.do?apikey=" + apikey + "&sign=" + sign + "&market=" + market + "&type=" + Type + "&price=" + price + "&amount=" + amount
    

  91.         return str
    

  92. }
    

  93. //{"result":true,"order_id":123456}
    

  94. type TradeRes struct {
    

  95.         Result                 bool                 `json:"result"`
    

  96.         Order_id         int                         `json:"order_id"`
    

  97. }
    


  98. 


  99. 

  100. ///////////////////////////////////////////////////////////////批量下单
    

  101. //https://www.hotbit .com/api/v1/batch_trade.do?apikey=e3bdc2ae54f2eb47ec299d830cf0f01c&market=EOSUSDT&type=buy&orders_data=[{price:3,amount:5,type:'sell'},{price:4,amount:6,type:'buy'}]&sign=dkoivndiei
    

  102. type order_data struct {
    

  103.         Price         string
    

  104.         Amount          int
    

  105.         Type         string
    

  106. }
    


  107. 

  108. func build_batch_trade_cmd(apikey string,sign string,market string,Type string,orders_data []order_data) string {
    

  109.         str := BaseUrl + "batch_trade.do?apikey=" + apikey + "&sign=" + sign + "&market=" + market + "&type=" + Type + "&orders_data=["
    

  110.         for i,od := range orders_data {
    

  111.                 data := fmt.Sprintf("{price:%s,amount:%d,type:'%s'}",od.Price,od.Amount,od.Type)
    

  112.                 str += data
    

  113.                 if i < len(orders_data) - 1 {
    

  114.                         str += ","
    

  115.                 }
    

  116.         }
    


  117. 

  118.         str += "]"
    


  119. 

  120.         return str
    

  121. }
    


  122. 


  123. 


  124. 

  125. type OrderRes struct {
    

  126.         Order_id         int                 `json:"order_id"`
    

  127.         Error_code         int                 `json:"error_code"`
    

  128. }
    


  129. 


  130. 

  131. type BatchTradeRes struct {
    

  132.         Order_info                 []OrderRes         `json:"order_info"`
    

  133.         Result                         bool                 `json:"result"`
    

  134. }
    


  135. 

  136. //////////////////////////////////////////// 撤销订单 /////////////////////////////////
    

  137. //https://www.hotbit.com/api/v1/cancel_order.do?apikey=ed47e38a1fdb57e8c28744ecb390c901&market=BTCBCC&order_id=[1231,1232,1233]&sign=meoivn8gjofi9fmbf9rD
    

  138. func build_cancel_order_cmd(apikey string,sign string,market string,order_id []int) string {
    

  139.         str := BaseUrl + "cancel_order.do?apikey=" + apikey + "&sign=" + sign + "&market=" + market + "&order_id=["
    

  140.         for i,id := range order_id {
    

  141.                 str += fmt.Sprintf("%d",id)
    

  142.                 if i < len(order_id) - 1 {
    

  143.                         str += ","
    

  144.                 }
    

  145.         }
    


  146. 

  147.         str += "]"
    


  148. 

  149.         return str
    

  150. }
    

  151. //{"success":"123456,123457","error":"123458,123459"}
    

  152. type CancelOrderRes struct {
    

  153.         Success                 string                 `json:"success"`
    

  154.         Error                 string                 `json:"error"`
    

  155. }
    


  156. 


  157. 

  158. ////////////////////////////////////////////获取用户未完成订单信息
    

  159. //https://www.hotbit.com/api/v1/order_pending.do?apikey=e3bdc2ae54f2eb47ec299d830cf0f01c&market=EOSUSDT&sign=meoivn8gjofi9fmbf9rD
    

  160. func build_order_pending_cmd(apikey string,sign string,market string) string {
    

  161.         str := BaseUrl + "order_pending.do?apikey=" + apikey + "&sign=" + sign + "&market=" + market
    

  162.         return str
    

  163. }
    


  164. 


  165. 

  166. type OrderPend struct {
    

  167.         Id          int                                 `json:"id"`
    

  168.         Market     string                          `json:"market"`
    

  169.         source     string                         `json:"source"`
    

  170.         Type        int                                 `json:"type"`
    

  171.         Side        int                                 `json:"side"`
    

  172.         User            int                                 `json:"user"`
    

  173.         Ctime       float32                           `json:"ctime"`
    

  174.         Mtime       float32                         `json:"mtime"`
    

  175.         Price       string                         `json:"price"`
    

  176.         Amount      string                          `json:"amount"`
    

  177.         Taker_fee  string                          `json:"maker_fee"`
    

  178.         Maker_fee  string                         `json:"maker_fee"`
    

  179.         Left         string                         `json:"left"`
    

  180.         Deal_stock string                         `json:"deal_stock"`
    

  181.         Deal_money string                         `json:"deal_money"`
    

  182.         Deal_fee    string                         `json:"deal_fee"`
    

  183. }
    


  184. 

  185. type OrderPendingRes struct {
    

  186.         Result                 bool                         `json:"result"`
    

  187.         Orders                 *OrderPend           `json:"orders"`
    

  188. }
    


  189. 

  190. /////////////////////////////////////////////获取用户已完成订单信息
    

  191. //https://www.hotbit.com/api/v1/order_finish.do?apikey=e3bdc2ae54f2eb47ec299d830cf0f01c&start_time=152047813&end_time=15204808923&type=sell&market=EOSUSDT&sign=meoivn8gjofi9fmbf9rD
    

  192. func build_order_finish_cmd(apikey string,sign string,market string,start_time string,end_time string,Type string) string {
    

  193.         str := BaseUrl + "order_finish.do?apikey=" + apikey + "&sign=" + sign + "&market=" + market + "&start_time=" + start_time + "&end_time=" + end_time + "&type=" + Type
    

  194.         return str
    

  195. }
    


  196. 

  197. type OrderFinish struct {
    

  198.         Id          int                                 `json:"id"`
    

  199.         Ctime       float32                           `json:"ctime"`
    

  200.         Ftime       float32                         `json:"ftime"`
    

  201.         User            int                                 `json:"user"`
    

  202.         Market     string                          `json:"market"`
    

  203.         source     string                         `json:"source"`
    

  204.         Type        int                                 `json:"type"`
    

  205.         Side        int                                 `json:"side"`
    

  206.         Price       string                         `json:"price"`
    

  207.         Amount      string                          `json:"amount"`
    

  208.         Taker_fee  string                          `json:"maker_fee"`
    

  209.         Maker_fee  string                         `json:"maker_fee"`
    

  210.         Deal_stock string                         `json:"deal_stock"`
    

  211.         Deal_money string                         `json:"deal_money"`
    

  212.         Deal_fee    string                         `json:"deal_fee"`
    

  213. }
    


  214. 

  215. type OrderFinishRes struct {
    

  216.         Result                 bool                         `json:"result"`
    

  217.         Orders                 *OrderFinish           `json:"orders"`
    

  218. }
    


  219. 


  220. 


  221.
回复

收藏 举报

 楼主| keer_zu 发表于 2018-1-23 23:32 | 显示全部楼层
config.go

读取配置信息：

复制
  1. package utils
    


  2. 


  3. 

  4. import (
    

  5.         io "io/ioutil"
    

  6.         json "encoding/json"
    

  7. )
    


  8. 

  9. //////////////////// global /////////////////
    


  10. 

  11. var MeCfg *MeConfig
    


  12. 

  13. //////////////////////////////////////////////
    


  14. 

  15. type Mysql struct {
    

  16.         Host         string `json:"host"`
    

  17.         User         string `json:"user"`
    

  18.         Pass         string `json:"pass"`
    

  19.         Database        string `json:"database"`
    

  20.         MaxConn        int        `json:"maxConns"`
    

  21. }
    


  22. 

  23. type Asset struct {
    

  24.         Name         string                 `json:"name"`
    

  25.         PrecSave         int                 `json:"prec_save"`
    

  26.         PrecShow         int                 `json:"prec_show"`
    

  27. }
    


  28. 

  29. type MarketAsset struct {
    

  30.         Name         string                 `json:"name"`
    

  31.         Prec         int                         `json:"prec"`
    

  32. }
    


  33. 

  34. type Market struct {
    

  35.         Name         string                 `json:"name"`
    

  36.         MinAmount string         `json:"min_amount"`
    

  37.         Money         *MarketAsset `json:"money"`
    

  38.         Stock         *MarketAsset `json:"stock"`
    

  39. }
    


  40. 

  41. type Content struct {
    

  42.         Assets                 []*Asset         `json:"assets"`
    

  43.         Markets                 []*Market `json:"markets"`
    

  44. }
    


  45. 

  46. type MeConfig struct {
    

  47.         ErrorCode        int                 `json:"ErrorCode"`               //1100
    

  48.         ErrorMsg        string         `json:"ErrorMsg"`                //"success"
    

  49.         Con                         *Content `json:"Content"`
    

  50. }
    


  51. 

  52. type JsonConfig struct {
    

  53.         BaseUrl                 string          `json:"BaseUrl"`
    

  54.         MeConfigUrl         string         `json:"MeConfigUrl"`
    

  55.         Sql                         *Mysql         `json:"Mysql"`
    

  56. }
    


  57. 


  58. 


  59. 

  60. type JsonStruct struct{
    


  61. 

  62. }
    


  63. 


  64. 

  65. func NewJsonStruct () *JsonStruct {
    

  66.         return &JsonStruct{}
    

  67. }
    


  68. 


  69. 

  70. func (self *JsonStruct) Load (filename string, v interface{}) {
    


  71. 

  72.         data, err := io.ReadFile(filename)
    

  73.         if err != nil{
    

  74.                 return 
    

  75.         }
    


  76. 

  77.         datajson := []byte(data)
    

  78.         err = json.Unmarshal(datajson, v)
    


  79. 

  80.         if err != nil{
    

  81.                 return
    

  82.         }
    


  83. 

  84. }
    


  85. 

  86. func (self *JsonStruct) LoadFromString(cfg []byte,v interface{}) {
    


  87. 

  88.         err := json.Unmarshal(cfg, v)
    


  89. 

  90.         if err != nil{
    

  91.                 return
    

  92.         }
    

  93. }
    


  94. 


  95. 

  96. type ValueTestAtmp struct{
    


  97. 

  98.         StringValue string
    


  99. 

  100.         NumericalValue int
    


  101. 

  102.         BoolValue bool
    


  103. 

  104. }
    


  105. 


  106. 

  107. type ConfigData struct {
    


  108. 

  109.         ValueTestA ValueTestAtmp
    


  110. 

  111. }
回复

收藏 举报

 楼主| keer_zu 发表于 2018-1-23 23:33 | 显示全部楼层
get_info.go

从数据库中获取信息

复制
  1. package utils
    


  2. 

  3. import (
    

  4.         "time"
    

  5.         _ "github.com/go-sql-driver/mysql"
    

  6.         "github.com/xormplus/xorm"
    

  7.         "fmt"
    

  8.         "sync"
    

  9. )
    


  10. 

  11. type Fapi struct {
    

  12.         Id         int       `xorm:"fid"`
    

  13.         Fkey        string    `xorm:"fkey"`
    

  14.         Fsecret     string    `xorm:"fsecret"`
    

  15.         Fuser       int       `xorm:"fuser"`
    

  16.         Label       string    `xorm:"label"`
    

  17.         Fcreatetime time.Time `xorm:"fcreatetime"`
    

  18.         Fistrade    int       `xorm:"fistrade"`
    

  19.         Fiswithdraw int       `xorm:"fiswithdraw"`
    

  20.         Fisreadinfo int       `xorm:"fisreadinfo"`
    

  21.         Fip         string    `xorm:"fip"`
    

  22.         WhiteIps    string    `xorm:"whiteIps"`
    

  23. }
    


  24. 

  25. var JsonCfg *JsonConfig
    


  26. 

  27. var initEngineOnce sync.Once
    

  28. var engineMysql *xorm.Engine
    


  29. 

  30. func GetEngine(cfg *Mysql)*xorm.Engine{
    


  31. 

  32.         initEngineOnce.Do(func(){
    

  33.                 var err error
    

  34.                 dbUrl := fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8", cfg.User, cfg.Pass, cfg.Host, cfg.Database)
    

  35.                 //fmt.Printf("\n ***    %s  ***\n",dbUrl)
    

  36.                 engineMysql, err = xorm.NewEngine("mysql", dbUrl)
    

  37.                 if err != nil{
    

  38.                         panic(err)
    

  39.                 }
    

  40.                 engineMysql.SetMaxOpenConns(JsonCfg.Sql.MaxConn)
    

  41.         })
    


  42. 

  43.         return engineMysql
    

  44. }
    


  45. 

  46. func GetUserInfo(engine *xorm.Engine)([]Fapi,error) {
    


  47. 

  48.         var fapi []Fapi
    


  49. 

  50.         if err := engine.Find(&fapi);err != nil {
    

  51.                 return nil,err
    

  52.         }
    


  53. 

  54.         return fapi,nil
    

  55. }
回复

收藏 举报

 楼主| keer_zu 发表于 2018-1-23 23:33 | 显示全部楼层
main.go

测试用例的实现：

复制
  1. package main
    


  2. 

  3. import (
    

  4.     "fmt"
    

  5.     "./api"
    

  6.     "./utils"
    

  7. )
    


  8. 


  9. 


  10. 

  11. var idCount int = 1
    


  12. 


  13. 

  14. func BuildAssetAddCmd(name string,prec_save int,prec_show int) string {
    

  15.     str := fmt.Sprintf("{"method": "asset.add_new","params":["%s",%d,%d],"id":%d}",name,prec_save,prec_show,idCount)
    

  16.     idCount += 1
    

  17.     return str
    

  18. }
    


  19. 

  20. func BuildTickerUrl(market string) string{
    

  21.     str := fmt.Sprintf("http://127.0.0.1:8080/api/v1/ticker.do?market=%s",market)
    

  22.     return str
    

  23. }
    


  24. 


  25. 


  26. 

  27. func main() {
    


  28. 

  29.     fmt.Printf("----\n")
    


  30. 


  31. 

  32.     JsonParse := utils.NewJsonStruct()
    


  33. 

  34.     //v := utils.JsonConfig{}
    

  35.     utils.JsonCfg = new(utils.JsonConfig)
    


  36. 

  37.     JsonParse.Load("config.json", utils.JsonCfg)
    

  38.     api.BaseUrl = utils.JsonCfg.BaseUrl
    


  39. 

  40.     fmt.Printf("Base Url: %s\n",api.BaseUrl)
    


  41. 

  42.     fmt.Println(utils.JsonCfg)
    


  43. 

  44.     fmt.Println(utils.JsonCfg.Sql)
    


  45. 

  46.     engine := utils.GetEngine(utils.JsonCfg.Sql)
    


  47. 

  48.     a,e := utils.GetUserInfo(engine)
    

  49.     if e == nil {
    

  50.         for _, v := range a {
    

  51.             fmt.Println(v)
    

  52.         }
    

  53.     }
    


  54. 


  55. 

  56.     apiCmd := new(api.ApiCommand)
    


  57. 

  58.     meCfg,e := apiCmd.CmdGet(utils.JsonCfg.MeConfigUrl)
    


  59. 

  60.     if e != nil {
    

  61.         fmt.Printf("meCfg get error\n")
    

  62.         return
    

  63.     }
    


  64. 

  65.     utils.MeCfg = new(utils.MeConfig)
    

  66.     JsonParse.LoadFromString(meCfg,utils.MeCfg)
    


  67. 

  68.     fmt.Println(utils.MeCfg.Con.Assets[0] )
    

  69.     fmt.Println(utils.MeCfg.Con.Markets[0].Money )
    


  70. 

  71.     ticker := new(api.Ticker)
    


  72. 

  73.     for _,market := range utils.MeCfg.Con.Markets {
    

  74.         str := api.Build_ticker_cmd(market.Name)
    

  75.         fmt.Printf("url:  %s\n",str)
    

  76.         bti,et := apiCmd.CmdGet(str)
    

  77.         if et != nil {
    

  78.             fmt.Printf("market %s ,ticker get error\n",market.Name)
    

  79.             continue
    

  80.         }
    


  81. 

  82.         //fmt.Println(bti)
    


  83. 

  84.         ecode,err := apiCmd.ApiResParse(bti,ticker)
    


  85. 

  86.         if err != nil {
    

  87.             fmt.Printf("parse error %s\n",err.Error())
    

  88.             continue
    

  89.         }
    


  90. 

  91.         if ecode != 0 {
    

  92.             fmt.Printf("api get res err:  %d\n",ecode)
    

  93.             continue
    

  94.         }
    


  95. 

  96.         fmt.Printf("ticker[%s] = \n%s\n\n",market.Name,bti)
    

  97.     }
    


  98. 

  99.     
    


  100. 

  101.     
    


  102. 


  103. 

  104.    //fmt.Printf("meCfg: %s\n",meCfg)
    


  105. 


  106. 

  107.     //fmt.Println(v.ValueTestA .StringValue )
    


  108. 

  109.     
    


  110. 

  111. /*
    

  112.     str := "{"method": "market.summary", "params": ["EOSBTC"], "id": 123}"
    


  113. 

  114.     cmdMarketSummary  := new(api.CmdMarketSummary)
    

  115.     bs,es := cmdMarketSummary.CmdPost(str)
    


  116. 

  117.     if es != nil {
    

  118.         fmt.Printf("err: %v \n",es)
    

  119.         return
    

  120.     }
    


  121. 

  122.     fmt.Printf("bs:  %s\n",bs)
    


  123. 

  124.     var results  []*api.MarketSummaryResult
    

  125.     //cmdMarketSummary.SetResult(&results)
    


  126. 

  127.     cmdMarketSummary.CmdParse(bs,&results)
    


  128. 


  129. 

  130.     //fmt.Printf("result len: %d\n",len(results))
    

  131.     fmt.Printf("name: %s\n",results[0].Name)
    

  132.     fmt.Printf("Ask_count: %d\n",results[0].Ask_count)
    

  133.     fmt.Printf("Ask_amount: %s\n",results[0].Ask_amount)
    


  134. 

  135.     tickerUrl := BuildTickerUrl("BTC")
    


  136. 

  137.     apiCmd := new(api.ApiCommand)
    


  138. 

  139.     tres,e := apiCmd.CmdGet(tickerUrl)
    


  140. 

  141.     if e != nil {
    

  142.         fmt.Printf("ticker get error\n")
    

  143.         return
    

  144.     }
    


  145. 

  146.     fmt.Printf("tres: %s\n",tres)
    


  147. 


  148. 

  149.     var ae api.ApiError
    


  150. 

  151.     ecode,err := apiCmd.ApiResParse(tres,&ae)
    


  152. 

  153.     if err != nil {
    

  154.         fmt.Printf("parse error %s\n",err.Error())
    

  155.         return
    

  156.     }
    


  157. 

  158.     fmt.Printf("Error code: %d\n",ecode)
    


  159. 

  160.     if ae.Error_code != 0 {
    

  161.         fmt.Printf("api get res err:  %d\n",ae.Error_code)
    

  162.     }
    

  163. */
    

  164. }
回复

收藏 举报

 楼主| keer_zu 发表于 2018-1-23 23:34 | 显示全部楼层
config.json

配置文件

复制
  1. {
    

  2.         "MeConfigUrl":"http://10.10.1.20:8080/api/get_config?appname=matchengine_test",
    

  3.         "BaseUrl":"http://127.0.0.1:8080/api/v1/",
    

  4.         "mysql":{
    

  5.       "host":"10.10.1.20:3306",
    

  6.       "user":"admin",
    

  7.       "pass":"zxw000123",
    

  8.       "database":"hotbit_make_web",
    

  9.       "maxConns":4
    

  10.     }
    

  11. }
回复

收藏 举报

 楼主| keer_zu 发表于 2018-1-23 23:34 | 显示全部楼层
一天又码了这么多
回复

收藏 举报

kelly1989 发表于 2018-1-24 12:39 | 显示全部楼层
厉害了
回复

收藏 举报

 楼主| keer_zu 发表于 2018-1-24 23:41 | 显示全部楼层
更多的测试用例：

复制
  1. package main
    


  2. 

  3. import (
    

  4.     "fmt"
    

  5.     "./api"
    

  6.     "./utils"
    

  7.     //"time"
    

  8. )
    


  9. 


  10. 


  11. 

  12. var idCount int = 1
    


  13. 


  14. 


  15. 

  16. func main() {
    


  17. 

  18.     fmt.Printf("----\n")
    


  19. 


  20. 

  21.     JsonParse := utils.NewJsonStruct()
    


  22. 

  23.     //v := utils.JsonConfig{}
    

  24.     utils.JsonCfg = new(utils.JsonConfig)
    


  25. 

  26.     JsonParse.Load("config.json", utils.JsonCfg)
    

  27.     api.BaseUrl = utils.JsonCfg.BaseUrl
    


  28. 

  29.     //fmt.Printf("Base Url: %s\n",api.BaseUrl)
    


  30. 

  31.     //fmt.Println(utils.JsonCfg)
    


  32. 

  33.     //fmt.Println(utils.JsonCfg.Sql)
    


  34. 

  35.     engine := utils.GetEngine(utils.JsonCfg.Sql)
    


  36. 

  37.     a,e := utils.GetUserInfo(engine)
    

  38.     if e == nil {
    

  39.         for _, v := range a {
    

  40.             fmt.Println(v)
    

  41.         }
    

  42.     } else {
    

  43.         fmt.Printf("user info get error\n")
    

  44.         return
    

  45.     }
    


  46. 


  47. 

  48.     apiCmd := new(api.ApiCommand)
    


  49. 

  50.     meCfg,e := apiCmd.CmdGet(utils.JsonCfg.MeConfigUrl)
    


  51. 

  52.     if e != nil {
    

  53.         fmt.Printf("meCfg get error\n")
    

  54.         return
    

  55.     }
    


  56. 

  57.     utils.MeCfg = new(utils.MeConfig)
    

  58.     JsonParse.LoadFromString(meCfg,utils.MeCfg)
    


  59. 

  60. //////////////////////////////// trade /////////////////////////////////////
    

  61. tradeRes := new(api.TradeRes)
    


  62. 

  63. Type := "buy"
    

  64. price := "100"
    

  65. amount := "10"
    


  66. 


  67. 

  68. for _,market := range utils.MeCfg.Con.Markets {
    


  69. 

  70.     for _,v := range a {
    

  71.         //(apikey string,market string,Type string,price string,amount string)
    


  72. 

  73.         params := api.BaseTradeUrl(v.Fkey,market.Name,Type,price,amount)
    

  74.         if Type == "buy"{
    

  75.             Type = "sell"
    

  76.         } else {
    

  77.             Type = "buy"
    

  78.         }
    


  79. 

  80.         str := api.BaseUrl + params["method?"]
    


  81. 

  82.         delete(params,"method?")
    


  83. 

  84.         ps := utils.CreatParams(v.Fsecret,params)
    


  85. 

  86.         str += ps
    


  87. 

  88.         fmt.Printf("url:   %s \n",str)
    


  89. 

  90.         bu,e := apiCmd.CmdPost(str)
    

  91.         if e != nil {
    

  92.             fmt.Printf("user: %d ,trade error\n",v.Fuser)
    

  93.             continue
    

  94.         }
    


  95. 

  96.         //fmt.Printf("bu:   %s \n",bu)
    


  97. 

  98.         ecode,err := apiCmd.ApiResParse(bu,tradeRes)
    


  99. 

  100.         if err != nil {
    

  101.             fmt.Printf("parse error %s\n",err.Error())
    

  102.             continue
    

  103.         }
    


  104. 

  105.         if ecode != 0 {
    

  106.             fmt.Printf("user get info err:  %d\n",ecode)
    

  107.             continue
    

  108.         }
    


  109. 


  110. 

  111.         //fmt.Printf("user info[%s] = \n%s\n\n",v.Fuser,bu)
    


  112. 

  113.     }
    

  114. }
    


  115. 


  116. 


  117. 

  118. ////////////////////////////// balance ////////////////////////////////////
    

  119.  /*      
    

  120.     userinfoRes := new(api.UserinfoRes)
    


  121. 

  122.     for _, v := range a {
    

  123.         params := make(map[string]string)
    

  124.         params["apikey"]=v.Fkey
    

  125.         secKey := v.Fsecret
    

  126.         fmt.Printf("user:   %d \n",v.Fuser)
    

  127.         //sign := utils.CreatSign(secKey,params)
    


  128. 


  129. 

  130.         ps := utils.CreatParams(secKey,params)
    


  131. 

  132.         str := api.BaseUrl + "balance.do?" + ps//api.Build_userinfo_cmd(v.Fkey,sign)
    


  133. 

  134.         fmt.Printf("url:   %s \n",str)
    


  135. 


  136. 

  137.         bu,e := apiCmd.CmdPost(str)
    

  138.         if e != nil {
    

  139.             fmt.Printf("user: %d ,info get error\n",v.Fuser)
    

  140.             continue
    

  141.         }
    


  142. 

  143.         //fmt.Printf("bu:   %s \n",bu)
    


  144. 

  145.         ecode,err := apiCmd.ApiResParse(bu,userinfoRes)
    


  146. 

  147.         if err != nil {
    

  148.             fmt.Printf("parse error %s\n",err.Error())
    

  149.             continue
    

  150.         }
    


  151. 

  152.         if ecode != 0 {
    

  153.             fmt.Printf("user get info err:  %d\n",ecode)
    

  154.             continue
    

  155.         }
    


  156. 


  157. 

  158.         //fmt.Printf("user info[%s] = \n%s\n\n",v.Fuser,bu)
    


  159. 

  160.     }
    


  161. 

  162.     //fmt.Println(utils.MeCfg.Con.Assets[0] )
    

  163.     //fmt.Println(utils.MeCfg.Con.Markets[0].Money )
    


  164. 


  165. 

  166. //////////////////////////////// ticker test ///////////////////////////////////
    

  167.  
    

  168.     ticker := new(api.Ticker)
    


  169. 

  170.     for _,market := range utils.MeCfg.Con.Markets {
    

  171.         str := api.Build_ticker_cmd(market.Name)
    

  172.         fmt.Printf("url:  %s\n",str)
    

  173.         bti,et := apiCmd.CmdGet(str)
    

  174.         if et != nil {
    

  175.             fmt.Printf("market %s ,ticker get error\n",market.Name)
    

  176.             continue
    

  177.         }
    


  178. 

  179.         //fmt.Println(bti)
    


  180. 

  181.         ecode,err := apiCmd.ApiResParse(bti,ticker)
    


  182. 

  183.         if err != nil {
    

  184.             fmt.Printf("parse error %s\n",err.Error())
    

  185.             continue
    

  186.         }
    


  187. 

  188.         if ecode != 0 {
    

  189.             fmt.Printf("api get res err:  %d\n",ecode)
    

  190.             continue
    

  191.         }
    


  192. 

  193.         fmt.Printf("ticker[%s] = \n%s\n\n",market.Name,bti)
    

  194.     }
    


  195. 

  196.     /////////////////////////////////// depth test /////////////////////////
    


  197. 

  198.       depth := new(api.DepthRes)
    


  199. 

  200.     for _,market := range utils.MeCfg.Con.Markets {
    

  201.         str := api.Build_depth_cmd(market.Name)
    

  202.         fmt.Printf("url:  %s\n",str)
    

  203.         bdp,et := apiCmd.CmdGet(str)
    

  204.         if et != nil {
    

  205.             fmt.Printf("market %s ,depth get error\n",market.Name)
    

  206.             continue
    

  207.         }
    


  208. 

  209.         //fmt.Println(bti)
    


  210. 

  211.         ecode,err := apiCmd.ApiResParse(bdp,depth)
    


  212. 

  213.         if err != nil {
    

  214.             fmt.Printf("parse error %s\n",err.Error())
    

  215.             continue
    

  216.         }
    


  217. 

  218.         if ecode != 0 {
    

  219.             fmt.Printf("api get res err:  %d\n",ecode)
    

  220.             continue
    

  221.         }
    


  222. 

  223.         fmt.Printf("depth[%s] = \n%s\n\n",market.Name,bdp)
    

  224.     }
    

  225. ////////////////////////////////////////////////////////////////////
    


  226. 

  227.     trades := new(api.TradesRes)
    

  228.      t:=time.Now().Unix()  
    

  229.      ts := t - 86400
    

  230.      tss := fmt.Sprintf("%d",ts)
    


  231. 

  232.     for _,market := range utils.MeCfg.Con.Markets {
    

  233.         str := api.Build_trades_cmd(market.Name,tss)
    

  234.         fmt.Printf("url:  %s\n",str)
    

  235.         bdp,et := apiCmd.CmdGet(str)
    

  236.         if et != nil {
    

  237.             fmt.Printf("market %s ,trades get error\n",market.Name)
    

  238.             continue
    

  239.         }
    


  240. 

  241.         //fmt.Println(bti)
    


  242. 

  243.         ecode,err := apiCmd.ApiResParse(bdp,trades)
    


  244. 

  245.         if err != nil {
    

  246.             fmt.Printf("parse error %s\n",err.Error())
    

  247.             continue
    

  248.         }
    


  249. 

  250.         if ecode != 0 {
    

  251.             fmt.Printf("api get res err:  %d\n",ecode)
    

  252.             continue
    

  253.         }
    


  254. 

  255.         fmt.Printf("trades[%s] = \n%s\n\n",market.Name,bdp)
    

  256.     }*/
    


  257. 

  258. }
回复

收藏 举报

msblast 发表于 2018-1-25 09:50 | 显示全部楼层
版主，高大上了……
转战互联网了吗？
回复

收藏 举报

 楼主| keer_zu 发表于 2018-1-25 11:25 | 显示全部楼层
msblast 发表于 2018-1-25 09:50
版主，高大上了……
转战互联网了吗？

是的
回复

收藏 举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则

keer_zu

1488

主题

12953

帖子

55

粉丝
快速回复 在线客服 返回列表 返回顶部