InitialHEADmaster

1 files changed, 42 insertions, 0 deletions

diff --git a/main.go b/main.go
new file mode 100644
index 0000000..bb867cb
--- /dev/null
+++ b/main.go
@@ -0,0 +1,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
+}