Compare commits
2
Commits
6d3c17d19d
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9ea9a4291c | ||
|
|
41325ba574 |
No files matched your search
@@ -12,6 +12,7 @@ import (
|
||||
"log"
|
||||
"net/url"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/robfig/cron/v3"
|
||||
@@ -295,13 +296,31 @@ func (s *Scheduler) universe(ctx context.Context) error {
|
||||
}
|
||||
|
||||
// market pulls top-changes (1 class x 2 periods), most-traded, idx-total,
|
||||
// brokers/top — the cheap context block of the cycle.
|
||||
// brokers/top — the cheap context block of the cycle. The top-changes call
|
||||
// also enriches universe company names (MoverRow.Name) at no extra credit —
|
||||
// n_stock is free; cost is classes×periods only.
|
||||
func (s *Scheduler) market(ctx context.Context) error {
|
||||
if g, l, err := s.Sectors.TopChanges(ctx,
|
||||
[]string{"top_gainers"}, []string{"1d", "7d"}, "", 5); err == nil {
|
||||
[]string{"top_gainers"}, []string{"1d", "7d"}, "", 750); err == nil {
|
||||
if raw, err := json.Marshal(map[string]any{"top_gainers": g, "top_losers": l}); err == nil {
|
||||
_ = s.DB.SaveSnapshot("IDX", time.Now().Format("2006-01-02"), "top-changes", string(raw))
|
||||
}
|
||||
// Capture company names from whatever mover rows came back.
|
||||
names := map[string]string{}
|
||||
collect := func(rows map[string][]sectors.MoverRow) {
|
||||
for _, rs := range rows {
|
||||
for _, r := range rs {
|
||||
if r.Name != "" {
|
||||
names[strings.TrimSuffix(r.Symbol, ".JK")] = r.Name
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
collect(g)
|
||||
collect(l)
|
||||
if err := s.DB.SetCompanyNames(names); err != nil {
|
||||
log.Printf("scheduler: set company names: %v", err)
|
||||
}
|
||||
} else {
|
||||
return err
|
||||
}
|
||||
|
||||
@@ -682,6 +682,30 @@ func (db *DB) CompanyNames(tickers []string) (map[string]string, error) {
|
||||
return out, rows.Err()
|
||||
}
|
||||
|
||||
// SetCompanyNames bulk-upserts company_name for tickers (from top-changes
|
||||
// snapshots). Only non-empty names are written; existing names win (skip
|
||||
// blank overwrite) so a later richer source doesn't clobber a good one.
|
||||
func (db *DB) SetCompanyNames(names map[string]string) error {
|
||||
if len(names) == 0 {
|
||||
return nil
|
||||
}
|
||||
tx, err := db.Begin()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
defer tx.Rollback()
|
||||
for t, nm := range names {
|
||||
nm = strings.TrimSpace(nm)
|
||||
if nm == "" || strings.EqualFold(nm, t) {
|
||||
continue
|
||||
}
|
||||
if _, err := tx.Exec(`UPDATE universe SET company_name = ? WHERE ticker = ? AND company_name = ''`, nm, t); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
return tx.Commit()
|
||||
}
|
||||
|
||||
// TickerHit is one local search result over the universe table.
|
||||
type TickerHit struct {
|
||||
Symbol string
|
||||
|
||||
@@ -155,3 +155,47 @@ func TestUniverseSearch(t *testing.T) {
|
||||
t.Fatal("TLKM has no name, must be omitted")
|
||||
}
|
||||
}
|
||||
|
||||
// SetCompanyNames fills blank names; never overwrites existing ones; skips
|
||||
// blanks and ticker-equal names.
|
||||
func TestSetCompanyNames(t *testing.T) {
|
||||
db, err := Open(t.TempDir() + "/names.db")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
defer db.Close()
|
||||
uni := []UniverseRow{
|
||||
{Symbol: "BBCA.JK", Close: 100, Date: "2026-09-16", CompanyName: "PT Bank Central Asia Tbk"},
|
||||
{Symbol: "TLKM.JK", Close: 90, Date: "2026-09-16"},
|
||||
{Symbol: "BBRI.JK", Close: 80, Date: "2026-09-16"},
|
||||
}
|
||||
if err := db.SaveUniverse(uni); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
// Fill TLKM + BBRI; BBCA already has a name (must NOT be clobbered);
|
||||
// "UNVR" would be a new row (INSERT OR IGNORE means it's skipped).
|
||||
err = db.SetCompanyNames(map[string]string{
|
||||
"TLKM": "PT Telkom Indonesia (Persero) Tbk",
|
||||
"BBRI": "PT Bank Rakyat Indonesia (Persero) Tbk",
|
||||
"BBCA": "SHOULD NOT OVERWRITE",
|
||||
"UNVR": "PT Unilever Indonesia Tbk",
|
||||
"EMTK": "PT Elang Mahkota Teknologi Tbk", // no universe row -> no-op
|
||||
"BLAH": "BLAH", // ticker-equal -> skip
|
||||
})
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
names, err := db.CompanyNames([]string{"BBCA", "TLKM", "BBRI", "UNVR"})
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if names["BBCA"] != "PT Bank Central Asia Tbk" {
|
||||
t.Fatalf("BBCA clobbered: %q", names["BBCA"])
|
||||
}
|
||||
if names["TLKM"] != "PT Telkom Indonesia (Persero) Tbk" || names["BBRI"] != "PT Bank Rakyat Indonesia (Persero) Tbk" {
|
||||
t.Fatalf("names = %+v, want TLKM+BBRI filled", names)
|
||||
}
|
||||
if _, ok := names["UNVR"]; ok {
|
||||
t.Fatal("UNVR not in universe must be absent")
|
||||
}
|
||||
}
|
||||
Reference in new issue
Block a user