133 lines
3.1 KiB
Go
133 lines
3.1 KiB
Go
package main
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"log"
|
|
"net/http"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
const SwissGridAPI = "https://www.swissgrid.ch/content/swissgrid/fr/home/operation/grid-data/current-data.apicache.json?path=/content/swissgrid/fr/home/operation/grid-data/current-data/jcr:content/parsys/livedatawidget_10292"
|
|
|
|
var (
|
|
LastFreqPlan = 50.0
|
|
GridTz *time.Location
|
|
)
|
|
|
|
func init() {
|
|
var err error
|
|
GridTz, err = time.LoadLocation("Europe/Zurich")
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
}
|
|
|
|
type SwissGridItem struct {
|
|
Id string `json:"id"`
|
|
Label string `json:"label"`
|
|
Value string `json:"value"`
|
|
MergeColumns bool `json:"mergeColumns"`
|
|
IsLabelBold bool `json:"isLabelBold"`
|
|
IsValueBold bool `json:"isValueBold"`
|
|
}
|
|
type SwissGridMaker struct {
|
|
Id string `json:"id"`
|
|
X float64 `json:"x"`
|
|
Y float64 `json:"y"`
|
|
Text1 string `json:"text1"`
|
|
Text2 string `json:"text2"`
|
|
TextColor string `json:"textColor"`
|
|
BackgroundColor string `json:"backgroundColor"`
|
|
BorderColor string `json:"borderColor"`
|
|
Type string `json:"type"`
|
|
Direction string `json:"direction"`
|
|
Rotation *string `json:"rotation"`
|
|
Opacity float64 `json:"opacity"`
|
|
FontSizeDesktop string `json:"fontSizeDesktop"`
|
|
FontSizeTablet string `json:"fontSizeTablet"`
|
|
FontSizePhone string `json:"fontSizePhone"`
|
|
}
|
|
|
|
type SwissGridData struct {
|
|
Data struct {
|
|
Table []SwissGridItem `json:"table"`
|
|
Marker []SwissGridItem `json:"marker"`
|
|
} `json:"data"`
|
|
}
|
|
|
|
func FetchFrequency() (*SwissGridData, error) {
|
|
res, err := http.Get(SwissGridAPI)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer res.Body.Close()
|
|
|
|
if res.StatusCode > 299 {
|
|
return nil, fmt.Errorf("Response failed with status code: %d", res.StatusCode)
|
|
}
|
|
|
|
dec := json.NewDecoder(res.Body)
|
|
var data SwissGridData
|
|
err = dec.Decode(&data)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &data, err
|
|
}
|
|
|
|
func WriteFrequency(writer TICWriter, freq *SwissGridData) error {
|
|
points := map[string]Point{}
|
|
horodate := time.Now()
|
|
|
|
for _, i := range freq.Data.Table {
|
|
if i.Id == "FreqPlan" {
|
|
f, err := strconv.ParseFloat(strings.Fields(i.Value)[0], 64)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if LastFreqPlan != f {
|
|
points["FREQPLAN"] = Point{
|
|
Data: []byte(fmt.Sprintf("%.0f", f*1000)),
|
|
}
|
|
LastFreqPlan = f
|
|
}
|
|
} else if i.Id == "FreqAct" {
|
|
f, err := strconv.ParseFloat(strings.Fields(i.Value)[0], 64)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
points["FREQ"] = Point{
|
|
Data: []byte(fmt.Sprintf("%.0f", f*1000)),
|
|
}
|
|
} else if i.Id == "GridTimeDev" {
|
|
f, err := strconv.ParseFloat(strings.Fields(i.Value)[0], 64)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
points["GRIDTIMEDEV"] = Point{
|
|
Data: []byte(fmt.Sprintf("%.0f", f*1000)),
|
|
}
|
|
} else if i.Id == "SampleTimestamp" {
|
|
var err error
|
|
horodate, err = time.ParseInLocation("02.01.2006 15:04:05", i.Value, GridTz)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
|
|
err := writer.AddPoints(points, horodate)
|
|
if err != nil {
|
|
log.Println("Unable to write frequency point:", err)
|
|
}
|
|
|
|
return nil
|
|
}
|