1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
package main
import "log"
const (
OFZ_URL = `https://iss.moex.com/iss/engines/stock/markets/bonds/boards/TQOB/securities.xml?iss.meta=off&iss.only=securities&securities.columns=SECID,NEXTCOUPON,COUPONVALUE,SECNAME,COUPONPERCENT,MATDATE,COUPONPERIOD`
CORP_URL = `https://iss.moex.com/iss/engines/stock/markets/bonds/boards/TQCB/securities.xml?iss.meta=off&iss.only=securities&securities.columns=SECID,NEXTCOUPON,COUPONVALUE,SECNAME,COUPONPERCENT,MATDATE,COUPONPERIOD`
)
func main() {
d1, err := processFile(OFZ_URL)
if err != nil {
log.Fatal(err)
}
if err := export("офз.csv", d1); err != nil {
log.Fatal(err)
}
d2, err := processFile(CORP_URL)
if err != nil {
log.Fatal(err)
}
if err := export("корп.csv", d2); err != nil {
log.Fatal(err)
}
}
func processFile(url string) ([]*Document, error) {
in, err := download(url)
if err != nil {
return nil, err
}
var documents []*Document
for _, item := range in.Data.Rows.Items {
d, err := parse(item)
if err != nil {
log.Println(err)
continue
}
documents = append(documents, d)
}
return documents, nil
}
|
