x/icebergs
1
0
Fork 1
mirror of https://shylinux.com/x/icebergs synced 2025-04-28 18:22:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

opt some

Browse Source
This commit is contained in:
harveyshao 2022-04-15 10:20:46 +08:00
parent 95d42317a9
commit 8f98a1db7a
1 changed files with 22 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
base/mdb/zone.go
View File

@ -4,6 +4,7 @@ import (
"encoding/csv" "encoding/csv"
"os" "os"
"path" "path"
"sort"
"strings" "strings"
ice "shylinux.com/x/icebergs" ice "shylinux.com/x/icebergs"
@ -68,21 +69,29 @@ func _zone_export(m *ice.Message, prefix, chain, file string) {
fields = append(fields, EXTRA) fields = append(fields, EXTRA)
w.Write(fields) w.Write(fields)
count := 0 keys := []string{}
m.Richs(prefix, chain, FOREACH, func(key string, val map[string]interface{}) { m.Richs(prefix, chain, FOREACH, func(key string, val map[string]interface{}) {
val = kit.GetMeta(val) keys = append(keys, key)
m.Grows(prefix, kit.Keys(chain, HASH, key), "", "", func(index int, value map[string]interface{}) {
value = kit.GetMeta(value)
list := []string{}
for _, k := range fields {
list = append(list, kit.Select(kit.Format(kit.Value(val, k)), kit.Format(kit.Value(value, k))))
}
w.Write(list)
count++
})
}) })
sort.Strings(keys)
count := 0
for _, key := range keys {
m.Richs(prefix, chain, key, func(key string, val map[string]interface{}) {
val = kit.GetMeta(val)
m.Grows(prefix, kit.Keys(chain, HASH, key), "", "", func(index int, value map[string]interface{}) {
value = kit.GetMeta(value)
list := []string{}
for _, k := range fields {
list = append(list, kit.Select(kit.Format(kit.Value(val, k)), kit.Format(kit.Value(value, k))))
}
w.Write(list)
count++
})
})
}
m.Log_EXPORT(KEY, path.Join(prefix, chain), FILE, p, COUNT, count) m.Log_EXPORT(KEY, path.Join(prefix, chain), FILE, p, COUNT, count)
m.Conf(prefix, kit.Keys(chain, HASH), "") m.Conf(prefix, kit.Keys(chain, HASH), "")