// Copyright 2013-2014 Fuzamei tech Ltd. All rights reserved.
package tick
// 本文件实现oanda数据源的tick数据获取下载和保存
import (
"errors"
"fmt"
"io/ioutil"
"log"
"net/http"
"regexp"
"strconv"
"strings"
"time"
"tickserver/markinfo"
"tickserver/server/market"
)
type oandaPairStatistics struct {
Date time.Time
BuyPercent float64
Rates float64
Symbol string
}
var oanda_base = int(200)
var oanda_prev = make(map[string]*oandaPairStatistics)
var fetchoandaurl = "http://fxtrade.oanda.com/lang/cns/analysis/open-position-ratios"
func getOandaStatistics(ch chan<- *oandaPairStatistics) (err error) {
html, err := httpDownload(fetchoandaurl)
if err != nil {
return err
}
regex := regexp.MustCompile("(?is)
]*>(.*?)<\\/ol>")
matches := regex.FindAllStringSubmatch(html, -1)
if len(matches) != 2 {
return errors.New("regex matche error.")
}
//货币对--BuyPercent--SellPercent
ratio_graph := get_span(matches[0][0])
//货币对--Rates
rates := get_span(matches[1][0])
//精确到微妙
t := match_time(html)
if len(ratio_graph)%3 == 0 && len(rates)%2 == 0 && len(ratio_graph)/3 == len(rates)/2 {
for i := 0; i < len(ratio_graph)/3; i++ {
ops := &oandaPairStatistics{}
ops.Symbol = strings.Replace(ratio_graph[3*i], "/", "", -1)
ops.BuyPercent, _ = strconv.ParseFloat(ratio_graph[3*i+1], 64)
ops.Rates, _ = strconv.ParseFloat(rates[2*i+1], 64)
ops.Date = time.Unix(t/1000, (t%1000)*(1e6))
sendOanda(ch, ops)
}
} else {
return errors.New("invalid data.")
}
return
}
func sendOanda(ch chan<- *oandaPairStatistics, data *oandaPairStatistics) {
if prev_data, ok := oanda_prev[data.Symbol]; ok {
if *prev_data == *data {
return
}
}
// log.Println("oa client", data)
oanda_prev[data.Symbol] = data
select {
case ch <- data:
default:
}
}
func httpDownload(url string) (string, error) {
body, err := http.Get(url)
if err != nil {
fmt.Println(err)
return "", err
}
defer body.Body.Close()
b, err := ioutil.ReadAll(body.Body)
if err != nil {
fmt.Println(err)
return "", err
}
return string(b), nil
}
var timeregex = regexp.MustCompile("(?is)")
func match_time(html string) int64 {
result := timeregex.FindAllStringSubmatch(html, -1)
var time int64
if len(result) == 1 && len(result[0]) == 2 {
time, _ = strconv.ParseInt(result[0][1], 10, 64)
}
return time
}
var spanregex = regexp.MustCompile("(?is)]+>.*?")
func get_span(text string) []string {
result := spanregex.FindAllString(text, -1)
for i := 0; i < len(result); i++ {
result[i] = strings.Trim(strip_tags(result[i]), " \t\r\n%")
}
return result
}
var stripregex = regexp.MustCompile("(?is)<[^>]+>")
func strip_tags(text string) string {
return stripregex.ReplaceAllString(text, "")
}
var oandaInss = []string{
"EURCHF",
"XAGUSD",
"EURGBP",
"USDJPY",
"USDCAD",
"AUDJPY",
"USDCHF",
"XAUUSD",
"EURJPY",
"EURUSD",
"GBPCHF",
"AUDUSD",
"EURAUD",
"NZDUSD",
"GBPJPY",
"GBPUSD",
}
// OandaDS 实现数据源dataSource接口的定义
type OandaDS struct {
*DSBase
conf *DsConf
//insMap map[string]*market.Instrument
}
func init() {
drivers[Oanda] = newOandaDS
}
func newOandaDS(conf *DsConf) (DataSource, error) {
log.Println("newOandaDS")
ods := &OandaDS{
DSBase: NewDsBase(conf),
conf: conf,
//insMap: oandaInsMap(),
}
ods.insMap = oandaInsMap()
return ods, nil
}
func (ods *OandaDS) Name() string {
return Oanda
}
//func (ods *OandaDS) SubIns() *event.Event {
//return ods.insPublisher.Event()
//}
func (ods *OandaDS) onMarket(ps *oandaPairStatistics) {
//insId := market.OandaPrefix + ps.Symbol
insId, _ := markinfo.SymbolId(ps.Symbol)
_, ok := ods.insMap[int64(insId)]
if !ok {
log.Fatal("OandaDS.onMarket error: insId is NOT in insMap:", insId)
}
//mk := ins.GetMk()
mk := &Market{}
mk.Type = IntOanda
mk.InsId = int64(insId)
mk.Timestamp = ps.Date.Unix() * 1000
mk.LastPrice = 100 - ps.BuyPercent
mk.LastVolume = 1
//ins.SetMk(mk)
ods.Save(mk)
}
/*func (ods *OandaDS) runHour() {
ht := time.Tick(time.Hour)
for _ = range ht {
for _, ins := range ods.insMap {
ods.Save(ins.GetMk())
}
}
}*/
func (ods *OandaDS) Run() {
log.Println("OandaDS.run")
//for _, ins := range ods.insMap {
//ods.insPublisher.Publish(ins)
//}
// go ods.runHour()
//go ods.RunSave(4)
ch := make(chan *oandaPairStatistics, 1024)
go func() {
for {
ps := <-ch
ods.onMarket(ps)
}
}()
for {
var err error
for {
err = getOandaStatistics(ch)
if err != nil {
log.Println(err)
}
time.Sleep(3 * time.Second)
}
}
}
func oandaInsMap() map[int64]*Instrument {
insMap := make(map[int64]*Instrument)
for _, x := range oandaInss {
//id := market.OandaPrefix + x
id, _ := markinfo.SymbolId(x)
u, _ := markinfo.SymbolUint(x)
ins := &Instrument{
Id: int64(id),
Name: x,
ExId: market.Oanda,
Type: market.Forex,
PriceInc: u,
StartTime: time.Now().Unix() * 1000,
}
insMap[int64(id)] = ins
}
return insMap
}