736 lines
18 KiB
Go
736 lines
18 KiB
Go
// SiYuan - Refactor your thinking
|
||
// Copyright (c) 2020-present, b3log.org
|
||
//
|
||
// This program is free software: you can redistribute it and/or modify
|
||
// it under the terms of the GNU Affero General Public License as published by
|
||
// the Free Software Foundation, either version 3 of the License, or
|
||
// (at your option) any later version.
|
||
//
|
||
// This program is distributed in the hope that it will be useful,
|
||
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||
// GNU Affero General Public License for more details.
|
||
//
|
||
// You should have received a copy of the GNU Affero General Public License
|
||
// along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||
|
||
// Package av 包含了属性视图（Attribute View）相关的实现。
|
||
package av
|
||
|
||
import (
|
||
"errors"
|
||
"os"
|
||
"path/filepath"
|
||
"sort"
|
||
"strings"
|
||
"time"
|
||
|
||
"github.com/88250/gulu"
|
||
"github.com/88250/lute/ast"
|
||
jsoniter "github.com/json-iterator/go"
|
||
"github.com/siyuan-note/filelock"
|
||
"github.com/siyuan-note/logging"
|
||
"github.com/siyuan-note/siyuan/kernel/util"
|
||
)
|
||
|
||
// AttributeView 描述了属性视图的结构。
|
||
type AttributeView struct {
|
||
Spec int `json:"spec"` // 格式版本
|
||
ID string `json:"id"` // 属性视图 ID
|
||
Name string `json:"name"` // 属性视图名称
|
||
KeyValues []*KeyValues `json:"keyValues"` // 属性视图属性键值
|
||
KeyIDs []string `json:"keyIDs"` // 属性视图属性键 ID，用于排序
|
||
ViewID string `json:"viewID"` // 当前视图 ID
|
||
Views []*View `json:"views"` // 视图
|
||
}
|
||
|
||
// KeyValues 描述了属性视图属性列值的结构。
|
||
type KeyValues struct {
|
||
Key *Key `json:"key"` // 属性视图属性列
|
||
Values []*Value `json:"values,omitempty"` // 属性视图属性列值
|
||
}
|
||
|
||
func (kValues *KeyValues) GetValue(blockID string) (ret *Value) {
|
||
for _, v := range kValues.Values {
|
||
if v.BlockID == blockID {
|
||
ret = v
|
||
return
|
||
}
|
||
}
|
||
return
|
||
}
|
||
|
||
func (kValues *KeyValues) GetBlockValue() (ret *Value) {
|
||
for _, v := range kValues.Values {
|
||
if KeyTypeBlock != v.Type {
|
||
ret = v
|
||
return
|
||
}
|
||
}
|
||
return
|
||
}
|
||
|
||
func GetKeyBlockValue(blockKeyValues []*KeyValues) (ret *Value) {
|
||
for _, kv := range blockKeyValues {
|
||
if KeyTypeBlock == kv.Key.Type && 0 < len(kv.Values) {
|
||
ret = kv.Values[0]
|
||
break
|
||
}
|
||
}
|
||
return
|
||
}
|
||
|
||
type KeyType string
|
||
|
||
const (
|
||
KeyTypeBlock KeyType = "block"
|
||
KeyTypeText KeyType = "text"
|
||
KeyTypeNumber KeyType = "number"
|
||
KeyTypeDate KeyType = "date"
|
||
KeyTypeSelect KeyType = "select"
|
||
KeyTypeMSelect KeyType = "mSelect"
|
||
KeyTypeURL KeyType = "url"
|
||
KeyTypeEmail KeyType = "email"
|
||
KeyTypePhone KeyType = "phone"
|
||
KeyTypeMAsset KeyType = "mAsset"
|
||
KeyTypeTemplate KeyType = "template"
|
||
KeyTypeCreated KeyType = "created"
|
||
KeyTypeUpdated KeyType = "updated"
|
||
KeyTypeCheckbox KeyType = "checkbox"
|
||
KeyTypeRelation KeyType = "relation"
|
||
KeyTypeRollup KeyType = "rollup"
|
||
KeyTypeLineNumber KeyType = "lineNumber"
|
||
)
|
||
|
||
// Key 描述了属性视图属性字段的基础结构。
|
||
type Key struct {
|
||
ID string `json:"id"` // 字段 ID
|
||
Name string `json:"name"` // 字段名
|
||
Type KeyType `json:"type"` // 字段类型
|
||
Icon string `json:"icon"` // 字段图标
|
||
Desc string `json:"desc"` // 字段描述
|
||
|
||
// 以下是某些列类型的特有属性
|
||
|
||
// 单选/多选
|
||
Options []*SelectOption `json:"options,omitempty"` // 选项列表
|
||
|
||
// 数字
|
||
NumberFormat NumberFormat `json:"numberFormat"` // 列数字格式化
|
||
|
||
// 模板
|
||
Template string `json:"template"` // 模板内容
|
||
|
||
// 关联
|
||
Relation *Relation `json:"relation,omitempty"` // 关联信息
|
||
|
||
// 汇总
|
||
Rollup *Rollup `json:"rollup,omitempty"` // 汇总信息
|
||
|
||
// 日期
|
||
Date *Date `json:"date,omitempty"` // 日期设置
|
||
}
|
||
|
||
func NewKey(id, name, icon string, keyType KeyType) *Key {
|
||
return &Key{
|
||
ID: id,
|
||
Name: name,
|
||
Type: keyType,
|
||
Icon: icon,
|
||
}
|
||
}
|
||
|
||
func (k *Key) GetOption(name string) (ret *SelectOption) {
|
||
for _, option := range k.Options {
|
||
if option.Name == name {
|
||
ret = option
|
||
return
|
||
}
|
||
}
|
||
return
|
||
}
|
||
|
||
type Date struct {
|
||
AutoFillNow bool `json:"autoFillNow"` // 是否自动填充当前时间 The database date field supports filling the current time by default https://github.com/siyuan-note/siyuan/issues/10823
|
||
}
|
||
|
||
type Rollup struct {
|
||
RelationKeyID string `json:"relationKeyID"` // 关联字段 ID
|
||
KeyID string `json:"keyID"` // 目标字段 ID
|
||
Calc *RollupCalc `json:"calc"` // 计算方式
|
||
}
|
||
|
||
type RollupCalc struct {
|
||
Operator CalcOperator `json:"operator"`
|
||
Result *Value `json:"result"`
|
||
}
|
||
|
||
type Relation struct {
|
||
AvID string `json:"avID"` // 关联的属性视图 ID
|
||
IsTwoWay bool `json:"isTwoWay"` // 是否双向关联
|
||
BackKeyID string `json:"backKeyID"` // 双向关联时回链关联列的 ID
|
||
}
|
||
|
||
type SelectOption struct {
|
||
Name string `json:"name"` // 选项名称
|
||
Color string `json:"color"` // 选项颜色
|
||
Desc string `json:"desc"` // 选项描述
|
||
}
|
||
|
||
// View 描述了视图的结构。
|
||
type View struct {
|
||
ID string `json:"id"` // 视图 ID
|
||
Icon string `json:"icon"` // 视图图标
|
||
Name string `json:"name"` // 视图名称
|
||
HideAttrViewName bool `json:"hideAttrViewName"` // 是否隐藏属性视图名称
|
||
Desc string `json:"desc"` // 视图描述
|
||
|
||
LayoutType LayoutType `json:"type"` // 当前布局类型
|
||
Table *LayoutTable `json:"table,omitempty"` // 表格布局
|
||
}
|
||
|
||
// LayoutType 描述了视图布局的类型。
|
||
type LayoutType string
|
||
|
||
const (
|
||
LayoutTypeTable LayoutType = "table" // 属性视图类型 - 表格
|
||
)
|
||
|
||
func NewTableView() (ret *View) {
|
||
ret = &View{
|
||
ID: ast.NewNodeID(),
|
||
Name: getI18nName("table"),
|
||
LayoutType: LayoutTypeTable,
|
||
Table: &LayoutTable{
|
||
Spec: 0,
|
||
ID: ast.NewNodeID(),
|
||
Filters: []*ViewFilter{},
|
||
Sorts: []*ViewSort{},
|
||
PageSize: 50,
|
||
},
|
||
}
|
||
return
|
||
}
|
||
|
||
func NewTableViewWithBlockKey(blockKeyID string) (view *View, blockKey, selectKey *Key) {
|
||
name := getI18nName("table")
|
||
view = &View{
|
||
ID: ast.NewNodeID(),
|
||
Name: name,
|
||
LayoutType: LayoutTypeTable,
|
||
Table: &LayoutTable{
|
||
Spec: 0,
|
||
ID: ast.NewNodeID(),
|
||
Filters: []*ViewFilter{},
|
||
Sorts: []*ViewSort{},
|
||
PageSize: 50,
|
||
},
|
||
}
|
||
blockKey = NewKey(blockKeyID, getI18nName("key"), "", KeyTypeBlock)
|
||
view.Table.Columns = []*ViewTableColumn{{ID: blockKeyID}}
|
||
|
||
selectKey = NewKey(ast.NewNodeID(), getI18nName("select"), "", KeyTypeSelect)
|
||
view.Table.Columns = append(view.Table.Columns, &ViewTableColumn{ID: selectKey.ID})
|
||
return
|
||
}
|
||
|
||
// Viewable 描述了视图的接口。
|
||
type Viewable interface {
|
||
Filterable
|
||
Sortable
|
||
Calculable
|
||
|
||
GetType() LayoutType
|
||
GetID() string
|
||
}
|
||
|
||
func NewAttributeView(id string) (ret *AttributeView) {
|
||
view, blockKey, selectKey := NewTableViewWithBlockKey(ast.NewNodeID())
|
||
ret = &AttributeView{
|
||
Spec: 0,
|
||
ID: id,
|
||
KeyValues: []*KeyValues{{Key: blockKey}, {Key: selectKey}},
|
||
ViewID: view.ID,
|
||
Views: []*View{view},
|
||
}
|
||
return
|
||
}
|
||
|
||
func GetAttributeViewName(avID string) (ret string, err error) {
|
||
avJSONPath := GetAttributeViewDataPath(avID)
|
||
if !filelock.IsExist(avJSONPath) {
|
||
return
|
||
}
|
||
|
||
return GetAttributeViewNameByPath(avJSONPath)
|
||
}
|
||
|
||
func GetAttributeViewNameByPath(avJSONPath string) (ret string, err error) {
|
||
data, err := filelock.ReadFile(avJSONPath)
|
||
if err != nil {
|
||
logging.LogErrorf("read attribute view [%s] failed: %s", avJSONPath, err)
|
||
return
|
||
}
|
||
|
||
val := jsoniter.Get(data, "name")
|
||
if nil == val || val.ValueType() == jsoniter.InvalidValue {
|
||
return
|
||
}
|
||
ret = val.ToString()
|
||
return
|
||
}
|
||
|
||
func IsAttributeViewExist(avID string) bool {
|
||
avJSONPath := GetAttributeViewDataPath(avID)
|
||
return filelock.IsExist(avJSONPath)
|
||
}
|
||
|
||
func ParseAttributeView(avID string) (ret *AttributeView, err error) {
|
||
avJSONPath := GetAttributeViewDataPath(avID)
|
||
if !filelock.IsExist(avJSONPath) {
|
||
err = ErrViewNotFound
|
||
return
|
||
}
|
||
|
||
data, readErr := filelock.ReadFile(avJSONPath)
|
||
if nil != readErr {
|
||
logging.LogErrorf("read attribute view [%s] failed: %s", avID, readErr)
|
||
return
|
||
}
|
||
|
||
ret = &AttributeView{}
|
||
if err = gulu.JSON.UnmarshalJSON(data, ret); err != nil {
|
||
if strings.Contains(err.Error(), ".relation.contents of type av.Value") {
|
||
mapAv := map[string]interface{}{}
|
||
if err = gulu.JSON.UnmarshalJSON(data, &mapAv); err != nil {
|
||
logging.LogErrorf("unmarshal attribute view [%s] failed: %s", avID, err)
|
||
return
|
||
}
|
||
|
||
// v3.0.3 兼容之前旧版本，将 relation.contents[""] 转换为 null
|
||
keyValues := mapAv["keyValues"]
|
||
keyValuesMap := keyValues.([]interface{})
|
||
for _, kv := range keyValuesMap {
|
||
kvMap := kv.(map[string]interface{})
|
||
if values := kvMap["values"]; nil != values {
|
||
valuesMap := values.([]interface{})
|
||
for _, v := range valuesMap {
|
||
if vMap := v.(map[string]interface{}); nil != vMap["relation"] {
|
||
vMap["relation"].(map[string]interface{})["contents"] = nil
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
views := mapAv["views"]
|
||
viewsMap := views.([]interface{})
|
||
for _, view := range viewsMap {
|
||
if table := view.(map[string]interface{})["table"]; nil != table {
|
||
tableMap := table.(map[string]interface{})
|
||
if filters := tableMap["filters"]; nil != filters {
|
||
filtersMap := filters.([]interface{})
|
||
for _, f := range filtersMap {
|
||
if fMap := f.(map[string]interface{}); nil != fMap["value"] {
|
||
if valueMap := fMap["value"].(map[string]interface{}); nil != valueMap["relation"] {
|
||
valueMap["relation"].(map[string]interface{})["contents"] = nil
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
data, err = gulu.JSON.MarshalJSON(mapAv)
|
||
if err != nil {
|
||
logging.LogErrorf("marshal attribute view [%s] failed: %s", avID, err)
|
||
return
|
||
}
|
||
|
||
if err = gulu.JSON.UnmarshalJSON(data, ret); err != nil {
|
||
logging.LogErrorf("unmarshal attribute view [%s] failed: %s", avID, err)
|
||
return
|
||
}
|
||
} else {
|
||
logging.LogErrorf("unmarshal attribute view [%s] failed: %s", avID, err)
|
||
return
|
||
}
|
||
}
|
||
return
|
||
}
|
||
|
||
func SaveAttributeView(av *AttributeView) (err error) {
|
||
if "" == av.ID {
|
||
err = errors.New("av id is empty")
|
||
logging.LogErrorf("save attribute view failed: %s", err)
|
||
return
|
||
}
|
||
|
||
// 做一些数据兼容和订正处理
|
||
now := util.CurrentTimeMillis()
|
||
for _, kv := range av.KeyValues {
|
||
switch kv.Key.Type {
|
||
case KeyTypeBlock:
|
||
// 补全 block 的创建时间和更新时间
|
||
for _, v := range kv.Values {
|
||
if 0 == v.Block.Created {
|
||
logging.LogWarnf("block [%s] created time is empty", v.BlockID)
|
||
if "" == v.Block.ID {
|
||
v.Block.ID = v.BlockID
|
||
if "" == v.Block.ID {
|
||
v.Block.ID = ast.NewNodeID()
|
||
v.BlockID = v.Block.ID
|
||
}
|
||
}
|
||
|
||
createdStr := v.Block.ID[:len("20060102150405")]
|
||
created, parseErr := time.ParseInLocation("20060102150405", createdStr, time.Local)
|
||
if nil == parseErr {
|
||
v.Block.Created = created.UnixMilli()
|
||
} else {
|
||
v.Block.Created = now
|
||
}
|
||
}
|
||
if 0 == v.Block.Updated {
|
||
logging.LogWarnf("block [%s] updated time is empty", v.BlockID)
|
||
v.Block.Updated = v.Block.Created
|
||
}
|
||
}
|
||
case KeyTypeNumber:
|
||
for _, v := range kv.Values {
|
||
if nil != v.Number && 0 != v.Number.Content && !v.Number.IsNotEmpty {
|
||
v.Number.IsNotEmpty = true
|
||
}
|
||
}
|
||
}
|
||
|
||
for _, v := range kv.Values {
|
||
if "" == kv.Key.ID {
|
||
kv.Key.ID = ast.NewNodeID()
|
||
for _, val := range kv.Values {
|
||
val.KeyID = kv.Key.ID
|
||
}
|
||
if "" == v.KeyID {
|
||
logging.LogWarnf("value [%s] key id is empty", v.ID)
|
||
v.KeyID = kv.Key.ID
|
||
}
|
||
|
||
// 校验日期 IsNotEmpty
|
||
if KeyTypeDate == kv.Key.Type {
|
||
if nil != v.Date && 0 != v.Date.Content && !v.Date.IsNotEmpty {
|
||
v.Date.IsNotEmpty = true
|
||
}
|
||
}
|
||
|
||
// 校验数字 IsNotEmpty
|
||
if KeyTypeNumber == kv.Key.Type {
|
||
if nil != v.Number && 0 != v.Number.Content && !v.Number.IsNotEmpty {
|
||
v.Number.IsNotEmpty = true
|
||
}
|
||
}
|
||
|
||
// 清空关联实际值
|
||
if KeyTypeRelation == kv.Key.Type {
|
||
v.Relation.Contents = nil
|
||
}
|
||
|
||
// 清空汇总实际值
|
||
if KeyTypeRollup == kv.Key.Type {
|
||
v.Rollup.Contents = nil
|
||
}
|
||
|
||
for _, view := range av.Views {
|
||
switch view.LayoutType {
|
||
case LayoutTypeTable:
|
||
for _, column := range view.Table.Columns {
|
||
if "" == column.ID {
|
||
column.ID = kv.Key.ID
|
||
break
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
// 补全值的创建时间和更新时间
|
||
if "" == v.ID {
|
||
logging.LogWarnf("value id is empty")
|
||
v.ID = ast.NewNodeID()
|
||
}
|
||
|
||
if 0 == v.CreatedAt {
|
||
logging.LogWarnf("value [%s] created time is empty", v.ID)
|
||
createdStr := v.ID[:len("20060102150405")]
|
||
created, parseErr := time.ParseInLocation("20060102150405", createdStr, time.Local)
|
||
if nil == parseErr {
|
||
v.CreatedAt = created.UnixMilli()
|
||
} else {
|
||
v.CreatedAt = now
|
||
}
|
||
}
|
||
|
||
if 0 == v.UpdatedAt {
|
||
logging.LogWarnf("value [%s] updated time is empty", v.ID)
|
||
v.UpdatedAt = v.CreatedAt
|
||
}
|
||
}
|
||
}
|
||
|
||
// 补全过滤器 Value
|
||
for _, view := range av.Views {
|
||
if nil != view.Table {
|
||
for _, f := range view.Table.Filters {
|
||
if nil != f.Value {
|
||
continue
|
||
}
|
||
|
||
if k, _ := av.GetKey(f.Column); nil != k {
|
||
f.Value = &Value{Type: k.Type}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
// 值去重
|
||
blockValues := av.GetBlockKeyValues()
|
||
blockIDs := map[string]bool{}
|
||
var duplicatedValueIDs []string
|
||
for _, blockValue := range blockValues.Values {
|
||
if !blockIDs[blockValue.BlockID] {
|
||
blockIDs[blockValue.BlockID] = true
|
||
} else {
|
||
duplicatedValueIDs = append(duplicatedValueIDs, blockValue.ID)
|
||
}
|
||
}
|
||
var tmp []*Value
|
||
for _, blockValue := range blockValues.Values {
|
||
if !gulu.Str.Contains(blockValue.ID, duplicatedValueIDs) {
|
||
tmp = append(tmp, blockValue)
|
||
}
|
||
}
|
||
blockValues.Values = tmp
|
||
|
||
// 视图值去重
|
||
for _, view := range av.Views {
|
||
if nil != view.Table {
|
||
// 行去重
|
||
view.Table.RowIDs = gulu.Str.RemoveDuplicatedElem(view.Table.RowIDs)
|
||
// 分页大小
|
||
if 1 > view.Table.PageSize {
|
||
view.Table.PageSize = 50
|
||
}
|
||
}
|
||
}
|
||
|
||
var data []byte
|
||
if util.UseSingleLineSave {
|
||
data, err = gulu.JSON.MarshalJSON(av)
|
||
} else {
|
||
data, err = gulu.JSON.MarshalIndentJSON(av, "", "\t")
|
||
}
|
||
if err != nil {
|
||
logging.LogErrorf("marshal attribute view [%s] failed: %s", av.ID, err)
|
||
return
|
||
}
|
||
|
||
avJSONPath := GetAttributeViewDataPath(av.ID)
|
||
if err = filelock.WriteFile(avJSONPath, data); err != nil {
|
||
logging.LogErrorf("save attribute view [%s] failed: %s", av.ID, err)
|
||
return
|
||
}
|
||
return
|
||
}
|
||
|
||
func (av *AttributeView) GetView(viewID string) (ret *View) {
|
||
for _, v := range av.Views {
|
||
if v.ID == viewID {
|
||
ret = v
|
||
return
|
||
}
|
||
}
|
||
return
|
||
}
|
||
|
||
func (av *AttributeView) GetCurrentView(viewID string) (ret *View, err error) {
|
||
if "" != viewID {
|
||
ret = av.GetView(viewID)
|
||
if nil != ret {
|
||
return
|
||
}
|
||
}
|
||
|
||
for _, v := range av.Views {
|
||
if v.ID == av.ViewID {
|
||
ret = v
|
||
return
|
||
}
|
||
}
|
||
|
||
if 1 > len(av.Views) {
|
||
err = ErrViewNotFound
|
||
return
|
||
}
|
||
ret = av.Views[0]
|
||
return
|
||
}
|
||
|
||
func (av *AttributeView) ExistBlock(blockID string) bool {
|
||
for _, kv := range av.KeyValues {
|
||
if KeyTypeBlock != kv.Key.Type {
|
||
continue
|
||
}
|
||
|
||
for _, v := range kv.Values {
|
||
if v.BlockID == blockID {
|
||
return true
|
||
}
|
||
}
|
||
return false
|
||
}
|
||
return false
|
||
}
|
||
|
||
func (av *AttributeView) GetValue(keyID, blockID string) (ret *Value) {
|
||
for _, kv := range av.KeyValues {
|
||
if kv.Key.ID == keyID {
|
||
for _, v := range kv.Values {
|
||
if v.BlockID == blockID {
|
||
ret = v
|
||
return
|
||
}
|
||
}
|
||
}
|
||
}
|
||
return
|
||
}
|
||
|
||
func (av *AttributeView) GetKey(keyID string) (ret *Key, err error) {
|
||
for _, kv := range av.KeyValues {
|
||
if kv.Key.ID == keyID {
|
||
ret = kv.Key
|
||
return
|
||
}
|
||
}
|
||
err = ErrKeyNotFound
|
||
return
|
||
}
|
||
|
||
func (av *AttributeView) GetBlockKeyValues() (ret *KeyValues) {
|
||
for _, kv := range av.KeyValues {
|
||
if KeyTypeBlock == kv.Key.Type {
|
||
ret = kv
|
||
return
|
||
}
|
||
}
|
||
return
|
||
}
|
||
|
||
func (av *AttributeView) GetKeyValues(keyID string) (ret *KeyValues, err error) {
|
||
for _, kv := range av.KeyValues {
|
||
if kv.Key.ID == keyID {
|
||
ret = kv
|
||
return
|
||
}
|
||
}
|
||
err = ErrKeyNotFound
|
||
return
|
||
}
|
||
|
||
func (av *AttributeView) GetBlockKey() (ret *Key) {
|
||
for _, kv := range av.KeyValues {
|
||
if KeyTypeBlock == kv.Key.Type {
|
||
ret = kv.Key
|
||
return
|
||
}
|
||
}
|
||
return
|
||
}
|
||
|
||
func (av *AttributeView) ShallowClone() (ret *AttributeView) {
|
||
ret = &AttributeView{}
|
||
data, err := gulu.JSON.MarshalJSON(av)
|
||
if err != nil {
|
||
logging.LogErrorf("marshal attribute view [%s] failed: %s", av.ID, err)
|
||
return nil
|
||
}
|
||
if err = gulu.JSON.UnmarshalJSON(data, ret); err != nil {
|
||
logging.LogErrorf("unmarshal attribute view [%s] failed: %s", av.ID, err)
|
||
return nil
|
||
}
|
||
|
||
ret.ID = ast.NewNodeID()
|
||
if 1 > len(ret.Views) {
|
||
logging.LogErrorf("attribute view [%s] has no views", av.ID)
|
||
return nil
|
||
}
|
||
|
||
var oldKeyIDs []string
|
||
keyIDMap := map[string]string{}
|
||
for _, kv := range ret.KeyValues {
|
||
newID := ast.NewNodeID()
|
||
keyIDMap[kv.Key.ID] = newID
|
||
oldKeyIDs = append(oldKeyIDs, kv.Key.ID)
|
||
kv.Key.ID = newID
|
||
kv.Values = []*Value{}
|
||
}
|
||
|
||
oldKeyIDs = gulu.Str.RemoveDuplicatedElem(oldKeyIDs)
|
||
sorts := map[string]int{}
|
||
for i, k := range ret.KeyIDs {
|
||
sorts[k] = i
|
||
}
|
||
sort.Slice(oldKeyIDs, func(i, j int) bool {
|
||
return sorts[oldKeyIDs[i]] < sorts[oldKeyIDs[j]]
|
||
})
|
||
|
||
for _, view := range ret.Views {
|
||
view.ID = ast.NewNodeID()
|
||
view.Table.ID = ast.NewNodeID()
|
||
for _, column := range view.Table.Columns {
|
||
column.ID = keyIDMap[column.ID]
|
||
}
|
||
view.Table.RowIDs = []string{}
|
||
|
||
for _, f := range view.Table.Filters {
|
||
f.Column = keyIDMap[f.Column]
|
||
}
|
||
for _, s := range view.Table.Sorts {
|
||
s.Column = keyIDMap[s.Column]
|
||
}
|
||
}
|
||
ret.ViewID = ret.Views[0].ID
|
||
|
||
ret.KeyIDs = nil
|
||
for _, oldKeyID := range oldKeyIDs {
|
||
newKeyID := keyIDMap[oldKeyID]
|
||
ret.KeyIDs = append(ret.KeyIDs, newKeyID)
|
||
}
|
||
return
|
||
}
|
||
|
||
func GetAttributeViewDataPath(avID string) (ret string) {
|
||
av := filepath.Join(util.DataDir, "storage", "av")
|
||
ret = filepath.Join(av, avID+".json")
|
||
if !gulu.File.IsDir(av) {
|
||
if err := os.MkdirAll(av, 0755); err != nil {
|
||
logging.LogErrorf("create attribute view dir failed: %s", err)
|
||
return
|
||
}
|
||
}
|
||
return
|
||
}
|
||
|
||
func getI18nName(name string) string {
|
||
return util.AttrViewLangs[util.Lang][name].(string)
|
||
}
|
||
|
||
var (
|
||
ErrViewNotFound = errors.New("view not found")
|
||
ErrKeyNotFound = errors.New("key not found")
|
||
)
|
||
|
||
const (
|
||
NodeAttrNameAvs = "custom-avs" // 用于标记块所属的属性视图，逗号分隔 av id
|
||
NodeAttrView = "custom-sy-av-view" // 用于标记块所属的属性视图视图 view id Database block support specified view https://github.com/siyuan-note/siyuan/issues/10443
|
||
|
||
NodeAttrViewNames = "av-names" // 用于临时标记块所属的属性视图名称，空格分隔
|
||
)
|