attribute_view.go 92 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412
  1. // SiYuan - Refactor your thinking
  2. // Copyright (c) 2020-present, b3log.org
  3. //
  4. // This program is free software: you can redistribute it and/or modify
  5. // it under the terms of the GNU Affero General Public License as published by
  6. // the Free Software Foundation, either version 3 of the License, or
  7. // (at your option) any later version.
  8. //
  9. // This program is distributed in the hope that it will be useful,
  10. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12. // GNU Affero General Public License for more details.
  13. //
  14. // You should have received a copy of the GNU Affero General Public License
  15. // along with this program. If not, see <https://www.gnu.org/licenses/>.
  16. package model
  17. import (
  18. "bytes"
  19. "os"
  20. "path/filepath"
  21. "sort"
  22. "strconv"
  23. "strings"
  24. "text/template"
  25. "time"
  26. "github.com/88250/gulu"
  27. "github.com/88250/lute/ast"
  28. "github.com/88250/lute/parse"
  29. "github.com/siyuan-note/dejavu/entity"
  30. "github.com/siyuan-note/filelock"
  31. "github.com/siyuan-note/logging"
  32. "github.com/siyuan-note/siyuan/kernel/av"
  33. "github.com/siyuan-note/siyuan/kernel/cache"
  34. "github.com/siyuan-note/siyuan/kernel/treenode"
  35. "github.com/siyuan-note/siyuan/kernel/util"
  36. "github.com/xrash/smetrics"
  37. )
  38. func SetDatabaseBlockView(blockID, viewID string) (err error) {
  39. node, tree, err := getNodeByBlockID(nil, blockID)
  40. if nil != err {
  41. return
  42. }
  43. attrs := parse.IAL2Map(node.KramdownIAL)
  44. attrs[av.NodeAttrView] = viewID
  45. err = setNodeAttrs(node, tree, attrs)
  46. if nil != err {
  47. logging.LogWarnf("set node [%s] attrs failed: %s", blockID, err)
  48. return
  49. }
  50. return
  51. }
  52. func GetAttributeViewPrimaryKeyValues(avID, keyword string, page, pageSize int) (attributeViewName string, databaseBlockIDs []string, keyValues *av.KeyValues, err error) {
  53. waitForSyncingStorages()
  54. attrView, err := av.ParseAttributeView(avID)
  55. if nil != err {
  56. logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err)
  57. return
  58. }
  59. attributeViewName = attrView.Name
  60. if "" == attributeViewName {
  61. attributeViewName = Conf.language(105)
  62. }
  63. databaseBlockIDs = treenode.GetMirrorAttrViewBlockIDs(avID)
  64. keyValues = attrView.GetBlockKeyValues()
  65. // 过滤掉不在视图中的值
  66. tmp := map[string]*av.Value{}
  67. for _, kv := range keyValues.Values {
  68. for _, view := range attrView.Views {
  69. switch view.LayoutType {
  70. case av.LayoutTypeTable:
  71. if !kv.IsDetached {
  72. if nil == treenode.GetBlockTree(kv.BlockID) {
  73. break
  74. }
  75. }
  76. tmp[kv.Block.ID] = kv
  77. }
  78. }
  79. }
  80. keyValues.Values = []*av.Value{}
  81. for _, v := range tmp {
  82. if strings.Contains(strings.ToLower(v.String()), strings.ToLower(keyword)) {
  83. keyValues.Values = append(keyValues.Values, v)
  84. }
  85. }
  86. if 1 > pageSize {
  87. pageSize = 16
  88. }
  89. start := (page - 1) * pageSize
  90. end := start + pageSize
  91. if len(keyValues.Values) < end {
  92. end = len(keyValues.Values)
  93. }
  94. keyValues.Values = keyValues.Values[start:end]
  95. return
  96. }
  97. func GetAttributeViewFilterSort(avID, blockID string) (filters []*av.ViewFilter, sorts []*av.ViewSort) {
  98. waitForSyncingStorages()
  99. attrView, err := av.ParseAttributeView(avID)
  100. if nil != err {
  101. logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err)
  102. return
  103. }
  104. view, err := getAttrViewViewByBlockID(attrView, blockID)
  105. if nil == view {
  106. view, err = attrView.GetCurrentView(attrView.ViewID)
  107. if nil != err {
  108. logging.LogErrorf("get current view failed: %s", err)
  109. return
  110. }
  111. }
  112. filters = []*av.ViewFilter{}
  113. sorts = []*av.ViewSort{}
  114. switch view.LayoutType {
  115. case av.LayoutTypeTable:
  116. filters = view.Table.Filters
  117. sorts = view.Table.Sorts
  118. }
  119. return
  120. }
  121. func SearchAttributeViewNonRelationKey(avID, keyword string) (ret []*av.Key) {
  122. waitForSyncingStorages()
  123. ret = []*av.Key{}
  124. attrView, err := av.ParseAttributeView(avID)
  125. if nil != err {
  126. logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err)
  127. return
  128. }
  129. for _, keyValues := range attrView.KeyValues {
  130. if av.KeyTypeRelation != keyValues.Key.Type && av.KeyTypeRollup != keyValues.Key.Type && av.KeyTypeTemplate != keyValues.Key.Type && av.KeyTypeCreated != keyValues.Key.Type && av.KeyTypeUpdated != keyValues.Key.Type {
  131. if strings.Contains(strings.ToLower(keyValues.Key.Name), strings.ToLower(keyword)) {
  132. ret = append(ret, keyValues.Key)
  133. }
  134. }
  135. }
  136. return
  137. }
  138. func SearchAttributeViewRelationKey(avID, keyword string) (ret []*av.Key) {
  139. waitForSyncingStorages()
  140. ret = []*av.Key{}
  141. attrView, err := av.ParseAttributeView(avID)
  142. if nil != err {
  143. logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err)
  144. return
  145. }
  146. for _, keyValues := range attrView.KeyValues {
  147. if av.KeyTypeRelation == keyValues.Key.Type && nil != keyValues.Key.Relation {
  148. if strings.Contains(strings.ToLower(keyValues.Key.Name), strings.ToLower(keyword)) {
  149. ret = append(ret, keyValues.Key)
  150. }
  151. }
  152. }
  153. return
  154. }
  155. func GetAttributeView(avID string) (ret *av.AttributeView) {
  156. waitForSyncingStorages()
  157. ret, _ = av.ParseAttributeView(avID)
  158. return
  159. }
  160. type SearchAttributeViewResult struct {
  161. AvID string `json:"avID"`
  162. AvName string `json:"avName"`
  163. BlockID string `json:"blockID"`
  164. HPath string `json:"hPath"`
  165. }
  166. func SearchAttributeView(keyword string) (ret []*SearchAttributeViewResult) {
  167. waitForSyncingStorages()
  168. ret = []*SearchAttributeViewResult{}
  169. keyword = strings.TrimSpace(keyword)
  170. type result struct {
  171. AvID string
  172. AvName string
  173. AvUpdated int64
  174. Score float64
  175. }
  176. var avs []*result
  177. avDir := filepath.Join(util.DataDir, "storage", "av")
  178. entries, err := os.ReadDir(avDir)
  179. if nil != err {
  180. logging.LogErrorf("read directory [%s] failed: %s", avDir, err)
  181. return
  182. }
  183. avBlockRels := av.GetBlockRels()
  184. for _, entry := range entries {
  185. if entry.IsDir() {
  186. continue
  187. }
  188. id := strings.TrimSuffix(entry.Name(), ".json")
  189. if !ast.IsNodeIDPattern(id) {
  190. continue
  191. }
  192. if nil == avBlockRels[id] {
  193. continue
  194. }
  195. name, _ := av.GetAttributeViewNameByPath(filepath.Join(avDir, entry.Name()))
  196. info, _ := entry.Info()
  197. if "" != keyword {
  198. if strings.Contains(strings.ToLower(name), strings.ToLower(keyword)) {
  199. score := smetrics.JaroWinkler(name, keyword, 0.7, 4)
  200. a := &result{AvID: id, AvName: name, Score: score}
  201. if nil != info && !info.ModTime().IsZero() {
  202. a.AvUpdated = info.ModTime().UnixMilli()
  203. }
  204. avs = append(avs, a)
  205. }
  206. } else {
  207. a := &result{AvID: id, AvName: name}
  208. if nil != info && !info.ModTime().IsZero() {
  209. a.AvUpdated = info.ModTime().UnixMilli()
  210. }
  211. avs = append(avs, a)
  212. }
  213. }
  214. if "" == keyword {
  215. sort.Slice(avs, func(i, j int) bool { return avs[i].AvUpdated > avs[j].AvUpdated })
  216. } else {
  217. sort.SliceStable(avs, func(i, j int) bool {
  218. if avs[i].Score == avs[j].Score {
  219. return avs[i].AvUpdated > avs[j].AvUpdated
  220. }
  221. return avs[i].Score > avs[j].Score
  222. })
  223. }
  224. if 12 <= len(avs) {
  225. avs = avs[:12]
  226. }
  227. var avIDs []string
  228. for _, a := range avs {
  229. avIDs = append(avIDs, a.AvID)
  230. }
  231. avBlocks := treenode.BatchGetMirrorAttrViewBlocks(avIDs)
  232. var blockIDs []string
  233. for _, avBlock := range avBlocks {
  234. blockIDs = append(blockIDs, avBlock.BlockIDs...)
  235. }
  236. blockIDs = gulu.Str.RemoveDuplicatedElem(blockIDs)
  237. trees := map[string]*parse.Tree{}
  238. for _, blockID := range blockIDs {
  239. bt := treenode.GetBlockTree(blockID)
  240. if nil == bt {
  241. continue
  242. }
  243. tree := trees[bt.RootID]
  244. if nil == tree {
  245. tree, _ = LoadTreeByBlockID(blockID)
  246. if nil != tree {
  247. trees[bt.RootID] = tree
  248. }
  249. }
  250. if nil == tree {
  251. continue
  252. }
  253. node := treenode.GetNodeInTree(tree, blockID)
  254. if nil == node {
  255. continue
  256. }
  257. if "" == node.AttributeViewID {
  258. continue
  259. }
  260. avID := node.AttributeViewID
  261. var existAv *result
  262. for _, av := range avs {
  263. if av.AvID == avID {
  264. existAv = av
  265. break
  266. }
  267. }
  268. if nil == existAv {
  269. continue
  270. }
  271. exist := false
  272. for _, result := range ret {
  273. if result.AvID == avID {
  274. exist = true
  275. break
  276. }
  277. }
  278. var hPath string
  279. baseBlock := treenode.GetBlockTreeRootByPath(node.Box, node.Path)
  280. if nil != baseBlock {
  281. hPath = baseBlock.HPath
  282. }
  283. box := Conf.Box(node.Box)
  284. if nil != box {
  285. hPath = box.Name + hPath
  286. }
  287. if !exist {
  288. ret = append(ret, &SearchAttributeViewResult{
  289. AvID: avID,
  290. AvName: existAv.AvName,
  291. BlockID: blockID,
  292. HPath: hPath,
  293. })
  294. }
  295. }
  296. return
  297. }
  298. type BlockAttributeViewKeys struct {
  299. AvID string `json:"avID"`
  300. AvName string `json:"avName"`
  301. BlockIDs []string `json:"blockIDs"`
  302. KeyValues []*av.KeyValues `json:"keyValues"`
  303. }
  304. func GetBlockAttributeViewKeys(blockID string) (ret []*BlockAttributeViewKeys) {
  305. waitForSyncingStorages()
  306. ret = []*BlockAttributeViewKeys{}
  307. attrs := GetBlockAttrsWithoutWaitWriting(blockID)
  308. avs := attrs[av.NodeAttrNameAvs]
  309. if "" == avs {
  310. return
  311. }
  312. avIDs := strings.Split(avs, ",")
  313. for _, avID := range avIDs {
  314. attrView, err := av.ParseAttributeView(avID)
  315. if nil != err {
  316. logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err)
  317. unbindBlockAv(nil, avID, blockID)
  318. return
  319. }
  320. if 1 > len(attrView.Views) {
  321. err = av.ErrViewNotFound
  322. unbindBlockAv(nil, avID, blockID)
  323. return
  324. }
  325. if !attrView.ExistBlock(blockID) {
  326. // 比如剪切后粘贴,块 ID 会变,但是属性还在块上,这里做一次数据订正
  327. // Auto verify the database name when clicking the block superscript icon https://github.com/siyuan-note/siyuan/issues/10861
  328. unbindBlockAv(nil, avID, blockID)
  329. return
  330. }
  331. var keyValues []*av.KeyValues
  332. for _, kv := range attrView.KeyValues {
  333. kValues := &av.KeyValues{Key: kv.Key}
  334. for _, v := range kv.Values {
  335. if v.BlockID == blockID {
  336. kValues.Values = append(kValues.Values, v)
  337. }
  338. }
  339. switch kValues.Key.Type {
  340. case av.KeyTypeRollup:
  341. kValues.Values = append(kValues.Values, &av.Value{ID: ast.NewNodeID(), KeyID: kValues.Key.ID, BlockID: blockID, Type: av.KeyTypeRollup, Rollup: &av.ValueRollup{Contents: []*av.Value{}}})
  342. case av.KeyTypeTemplate:
  343. kValues.Values = append(kValues.Values, &av.Value{ID: ast.NewNodeID(), KeyID: kValues.Key.ID, BlockID: blockID, Type: av.KeyTypeTemplate, Template: &av.ValueTemplate{Content: ""}})
  344. case av.KeyTypeCreated:
  345. kValues.Values = append(kValues.Values, &av.Value{ID: ast.NewNodeID(), KeyID: kValues.Key.ID, BlockID: blockID, Type: av.KeyTypeCreated})
  346. case av.KeyTypeUpdated:
  347. kValues.Values = append(kValues.Values, &av.Value{ID: ast.NewNodeID(), KeyID: kValues.Key.ID, BlockID: blockID, Type: av.KeyTypeUpdated})
  348. }
  349. if 0 < len(kValues.Values) {
  350. keyValues = append(keyValues, kValues)
  351. } else {
  352. // 如果没有值,那么就补一个默认值
  353. kValues.Values = append(kValues.Values, treenode.GetAttributeViewDefaultValue(ast.NewNodeID(), kv.Key.ID, blockID, kv.Key.Type))
  354. keyValues = append(keyValues, kValues)
  355. }
  356. }
  357. // 渲染自动生成的列值,比如模板列、关联列、汇总列、创建时间列和更新时间列
  358. // 先处理关联列、汇总列、创建时间列和更新时间列
  359. for _, kv := range keyValues {
  360. switch kv.Key.Type {
  361. case av.KeyTypeRollup:
  362. if nil == kv.Key.Rollup {
  363. break
  364. }
  365. relKey, _ := attrView.GetKey(kv.Key.Rollup.RelationKeyID)
  366. if nil == relKey {
  367. break
  368. }
  369. relVal := attrView.GetValue(kv.Key.Rollup.RelationKeyID, kv.Values[0].BlockID)
  370. if nil != relVal && nil != relVal.Relation {
  371. destAv, _ := av.ParseAttributeView(relKey.Relation.AvID)
  372. destKey, _ := destAv.GetKey(kv.Key.Rollup.KeyID)
  373. if nil != destAv && nil != destKey {
  374. for _, bID := range relVal.Relation.BlockIDs {
  375. destVal := destAv.GetValue(kv.Key.Rollup.KeyID, bID)
  376. if nil == destVal {
  377. if destAv.ExistBlock(bID) { // 数据库中存在行但是列值不存在是数据未初始化,这里补一个默认值
  378. destVal = treenode.GetAttributeViewDefaultValue(ast.NewNodeID(), kv.Key.Rollup.KeyID, bID, destKey.Type)
  379. }
  380. if nil == destVal {
  381. continue
  382. }
  383. }
  384. if av.KeyTypeNumber == destKey.Type {
  385. destVal.Number.Format = destKey.NumberFormat
  386. destVal.Number.FormatNumber()
  387. }
  388. kv.Values[0].Rollup.Contents = append(kv.Values[0].Rollup.Contents, destVal.Clone())
  389. }
  390. kv.Values[0].Rollup.RenderContents(kv.Key.Rollup.Calc, destKey)
  391. }
  392. }
  393. case av.KeyTypeRelation:
  394. if nil == kv.Key.Relation {
  395. break
  396. }
  397. destAv, _ := av.ParseAttributeView(kv.Key.Relation.AvID)
  398. if nil == destAv {
  399. break
  400. }
  401. blocks := map[string]*av.Value{}
  402. for _, blockValue := range destAv.GetBlockKeyValues().Values {
  403. blocks[blockValue.BlockID] = blockValue
  404. }
  405. kv.Values[0].Relation.Contents = nil // 先清空 https://github.com/siyuan-note/siyuan/issues/10670
  406. for _, bID := range kv.Values[0].Relation.BlockIDs {
  407. kv.Values[0].Relation.Contents = append(kv.Values[0].Relation.Contents, blocks[bID])
  408. }
  409. case av.KeyTypeCreated:
  410. createdStr := blockID[:len("20060102150405")]
  411. created, parseErr := time.ParseInLocation("20060102150405", createdStr, time.Local)
  412. if nil == parseErr {
  413. kv.Values[0].Created = av.NewFormattedValueCreated(created.UnixMilli(), 0, av.CreatedFormatNone)
  414. kv.Values[0].Created.IsNotEmpty = true
  415. } else {
  416. logging.LogWarnf("parse created [%s] failed: %s", createdStr, parseErr)
  417. kv.Values[0].Created = av.NewFormattedValueCreated(time.Now().UnixMilli(), 0, av.CreatedFormatNone)
  418. }
  419. case av.KeyTypeUpdated:
  420. ial := GetBlockAttrsWithoutWaitWriting(blockID)
  421. updatedStr := ial["updated"]
  422. updated, parseErr := time.ParseInLocation("20060102150405", updatedStr, time.Local)
  423. if nil == parseErr {
  424. kv.Values[0].Updated = av.NewFormattedValueUpdated(updated.UnixMilli(), 0, av.UpdatedFormatNone)
  425. kv.Values[0].Updated.IsNotEmpty = true
  426. } else {
  427. logging.LogWarnf("parse updated [%s] failed: %s", updatedStr, parseErr)
  428. kv.Values[0].Updated = av.NewFormattedValueUpdated(time.Now().UnixMilli(), 0, av.UpdatedFormatNone)
  429. }
  430. }
  431. }
  432. // 再处理模板列
  433. // 获取闪卡信息
  434. // TODO 目前看来使用场景不多,暂时不实现了 https://github.com/siyuan-note/siyuan/issues/10502#issuecomment-1986703280
  435. var flashcard *Flashcard
  436. //deck := Decks[builtinDeckID]
  437. //if nil != deck {
  438. // blockIDs := []string{blockID}
  439. // cards := deck.GetCardsByBlockIDs(blockIDs)
  440. // now := time.Now()
  441. // if 0 < len(cards) {
  442. // flashcard = newFlashcard(cards[0], builtinDeckID, now)
  443. // }
  444. //}
  445. // 渲染模板
  446. for _, kv := range keyValues {
  447. switch kv.Key.Type {
  448. case av.KeyTypeTemplate:
  449. if 0 < len(kv.Values) {
  450. ial := map[string]string{}
  451. block := getRowBlockValue(keyValues)
  452. if nil != block && !block.IsDetached {
  453. ial = GetBlockAttrsWithoutWaitWriting(block.BlockID)
  454. }
  455. kv.Values[0].Template.Content = renderTemplateCol(ial, flashcard, keyValues, kv.Key.Template)
  456. }
  457. }
  458. }
  459. // Attribute Panel - Database sort attributes by view column order https://github.com/siyuan-note/siyuan/issues/9319
  460. viewID := attrs[av.NodeAttrView]
  461. view, _ := attrView.GetCurrentView(viewID)
  462. if nil != view {
  463. sorts := map[string]int{}
  464. for i, col := range view.Table.Columns {
  465. sorts[col.ID] = i
  466. }
  467. sort.Slice(keyValues, func(i, j int) bool {
  468. return sorts[keyValues[i].Key.ID] < sorts[keyValues[j].Key.ID]
  469. })
  470. }
  471. blockIDs := treenode.GetMirrorAttrViewBlockIDs(avID)
  472. if 1 > len(blockIDs) {
  473. // 老数据兼容处理
  474. avBts := treenode.GetBlockTreesByType("av")
  475. for _, avBt := range avBts {
  476. if nil == avBt {
  477. continue
  478. }
  479. tree, _ := LoadTreeByBlockID(avBt.ID)
  480. if nil == tree {
  481. continue
  482. }
  483. node := treenode.GetNodeInTree(tree, avBt.ID)
  484. if nil == node {
  485. continue
  486. }
  487. if avID == node.AttributeViewID {
  488. blockIDs = append(blockIDs, avBt.ID)
  489. }
  490. }
  491. if 1 > len(blockIDs) {
  492. tree, _ := LoadTreeByBlockID(blockID)
  493. if nil != tree {
  494. node := treenode.GetNodeInTree(tree, blockID)
  495. if nil != node {
  496. if removeErr := removeNodeAvID(node, avID, nil, tree); nil != removeErr {
  497. logging.LogErrorf("remove node avID [%s] failed: %s", avID, removeErr)
  498. }
  499. }
  500. }
  501. continue
  502. }
  503. blockIDs = gulu.Str.RemoveDuplicatedElem(blockIDs)
  504. for _, blockID := range blockIDs {
  505. av.UpsertBlockRel(avID, blockID)
  506. }
  507. }
  508. ret = append(ret, &BlockAttributeViewKeys{
  509. AvID: avID,
  510. AvName: attrView.Name,
  511. BlockIDs: blockIDs,
  512. KeyValues: keyValues,
  513. })
  514. }
  515. return
  516. }
  517. func RenderRepoSnapshotAttributeView(indexID, avID string) (viewable av.Viewable, attrView *av.AttributeView, err error) {
  518. repo, err := newRepository()
  519. if nil != err {
  520. return
  521. }
  522. index, err := repo.GetIndex(indexID)
  523. if nil != err {
  524. return
  525. }
  526. files, err := repo.GetFiles(index)
  527. if nil != err {
  528. return
  529. }
  530. var avFile *entity.File
  531. for _, f := range files {
  532. if "/storage/av/"+avID+".json" == f.Path {
  533. avFile = f
  534. break
  535. }
  536. }
  537. if nil == avFile {
  538. attrView = av.NewAttributeView(avID)
  539. } else {
  540. data, readErr := repo.OpenFile(avFile)
  541. if nil != readErr {
  542. logging.LogErrorf("read attribute view [%s] failed: %s", avID, readErr)
  543. return
  544. }
  545. attrView = &av.AttributeView{}
  546. if err = gulu.JSON.UnmarshalJSON(data, attrView); nil != err {
  547. logging.LogErrorf("unmarshal attribute view [%s] failed: %s", avID, err)
  548. return
  549. }
  550. }
  551. viewable, err = renderAttributeView(attrView, "", "", 1, -1)
  552. return
  553. }
  554. func RenderHistoryAttributeView(avID, created string) (viewable av.Viewable, attrView *av.AttributeView, err error) {
  555. createdUnix, parseErr := strconv.ParseInt(created, 10, 64)
  556. if nil != parseErr {
  557. logging.LogErrorf("parse created [%s] failed: %s", created, parseErr)
  558. return
  559. }
  560. dirPrefix := time.Unix(createdUnix, 0).Format("2006-01-02-150405")
  561. globPath := filepath.Join(util.HistoryDir, dirPrefix+"*")
  562. matches, err := filepath.Glob(globPath)
  563. if nil != err {
  564. logging.LogErrorf("glob [%s] failed: %s", globPath, err)
  565. return
  566. }
  567. if 1 > len(matches) {
  568. return
  569. }
  570. historyDir := matches[0]
  571. avJSONPath := filepath.Join(historyDir, "storage", "av", avID+".json")
  572. if !gulu.File.IsExist(avJSONPath) {
  573. avJSONPath = filepath.Join(util.DataDir, "storage", "av", avID+".json")
  574. }
  575. if !gulu.File.IsExist(avJSONPath) {
  576. attrView = av.NewAttributeView(avID)
  577. } else {
  578. data, readErr := os.ReadFile(avJSONPath)
  579. if nil != readErr {
  580. logging.LogErrorf("read attribute view [%s] failed: %s", avID, readErr)
  581. return
  582. }
  583. attrView = &av.AttributeView{}
  584. if err = gulu.JSON.UnmarshalJSON(data, attrView); nil != err {
  585. logging.LogErrorf("unmarshal attribute view [%s] failed: %s", avID, err)
  586. return
  587. }
  588. }
  589. viewable, err = renderAttributeView(attrView, "", "", 1, -1)
  590. return
  591. }
  592. func RenderAttributeView(avID, viewID, query string, page, pageSize int) (viewable av.Viewable, attrView *av.AttributeView, err error) {
  593. waitForSyncingStorages()
  594. if avJSONPath := av.GetAttributeViewDataPath(avID); !filelock.IsExist(avJSONPath) {
  595. attrView = av.NewAttributeView(avID)
  596. if err = av.SaveAttributeView(attrView); nil != err {
  597. logging.LogErrorf("save attribute view [%s] failed: %s", avID, err)
  598. return
  599. }
  600. }
  601. attrView, err = av.ParseAttributeView(avID)
  602. if nil != err {
  603. logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err)
  604. return
  605. }
  606. viewable, err = renderAttributeView(attrView, viewID, query, page, pageSize)
  607. return
  608. }
  609. func renderAttributeView(attrView *av.AttributeView, viewID, query string, page, pageSize int) (viewable av.Viewable, err error) {
  610. if 1 > len(attrView.Views) {
  611. view, _, _ := av.NewTableViewWithBlockKey(ast.NewNodeID())
  612. attrView.Views = append(attrView.Views, view)
  613. attrView.ViewID = view.ID
  614. if err = av.SaveAttributeView(attrView); nil != err {
  615. logging.LogErrorf("save attribute view [%s] failed: %s", attrView.ID, err)
  616. return
  617. }
  618. }
  619. var view *av.View
  620. if "" != viewID {
  621. view, _ = attrView.GetCurrentView(viewID)
  622. if nil != view && view.ID != attrView.ViewID {
  623. attrView.ViewID = view.ID
  624. if err = av.SaveAttributeView(attrView); nil != err {
  625. logging.LogErrorf("save attribute view [%s] failed: %s", attrView.ID, err)
  626. return
  627. }
  628. }
  629. } else {
  630. view = attrView.GetView(attrView.ViewID)
  631. }
  632. if nil == view {
  633. view = attrView.Views[0]
  634. }
  635. // 做一些数据兼容和订正处理,保存的时候也会做 av.SaveAttributeView()
  636. currentTimeMillis := util.CurrentTimeMillis()
  637. for _, kv := range attrView.KeyValues {
  638. switch kv.Key.Type {
  639. case av.KeyTypeBlock: // 补全 block 的创建时间和更新时间
  640. for _, v := range kv.Values {
  641. if 0 == v.Block.Created {
  642. if "" == v.Block.ID {
  643. v.Block.ID = v.BlockID
  644. if "" == v.Block.ID {
  645. v.Block.ID = ast.NewNodeID()
  646. v.BlockID = v.Block.ID
  647. }
  648. }
  649. createdStr := v.Block.ID[:len("20060102150405")]
  650. created, parseErr := time.ParseInLocation("20060102150405", createdStr, time.Local)
  651. if nil == parseErr {
  652. v.Block.Created = created.UnixMilli()
  653. } else {
  654. v.Block.Created = currentTimeMillis
  655. }
  656. }
  657. if 0 == v.Block.Updated {
  658. v.Block.Updated = v.Block.Created
  659. }
  660. }
  661. }
  662. for _, v := range kv.Values {
  663. // 校验日期 IsNotEmpty
  664. if av.KeyTypeDate == kv.Key.Type {
  665. if nil != v.Date && 0 != v.Date.Content && !v.Date.IsNotEmpty {
  666. v.Date.IsNotEmpty = true
  667. }
  668. }
  669. // 校验数字 IsNotEmpty
  670. if av.KeyTypeNumber == kv.Key.Type {
  671. if nil != v.Number && 0 != v.Number.Content && !v.Number.IsNotEmpty {
  672. v.Number.IsNotEmpty = true
  673. }
  674. }
  675. // 补全值的创建时间和更新时间
  676. if "" == v.ID {
  677. v.ID = ast.NewNodeID()
  678. }
  679. if 0 == v.CreatedAt {
  680. createdStr := v.ID[:len("20060102150405")]
  681. created, parseErr := time.ParseInLocation("20060102150405", createdStr, time.Local)
  682. if nil == parseErr {
  683. v.CreatedAt = created.UnixMilli()
  684. } else {
  685. v.CreatedAt = currentTimeMillis
  686. }
  687. }
  688. if 0 == v.UpdatedAt {
  689. v.UpdatedAt = v.CreatedAt
  690. }
  691. }
  692. }
  693. // 补全过滤器 Value
  694. if nil != view.Table {
  695. for _, f := range view.Table.Filters {
  696. if nil != f.Value {
  697. continue
  698. }
  699. if k, _ := attrView.GetKey(f.Column); nil != k {
  700. f.Value = &av.Value{Type: k.Type}
  701. }
  702. }
  703. }
  704. switch view.LayoutType {
  705. case av.LayoutTypeTable:
  706. // 列删除以后需要删除设置的过滤和排序
  707. tmpFilters := []*av.ViewFilter{}
  708. for _, f := range view.Table.Filters {
  709. if k, _ := attrView.GetKey(f.Column); nil != k {
  710. tmpFilters = append(tmpFilters, f)
  711. }
  712. }
  713. view.Table.Filters = tmpFilters
  714. tmpSorts := []*av.ViewSort{}
  715. for _, s := range view.Table.Sorts {
  716. if k, _ := attrView.GetKey(s.Column); nil != k {
  717. tmpSorts = append(tmpSorts, s)
  718. }
  719. }
  720. view.Table.Sorts = tmpSorts
  721. viewable, err = renderAttributeViewTable(attrView, view, query)
  722. }
  723. viewable.FilterRows(attrView)
  724. viewable.SortRows(attrView)
  725. viewable.CalcCols()
  726. // 分页
  727. switch viewable.GetType() {
  728. case av.LayoutTypeTable:
  729. table := viewable.(*av.Table)
  730. table.RowCount = len(table.Rows)
  731. if 1 > view.Table.PageSize {
  732. view.Table.PageSize = 50
  733. }
  734. table.PageSize = view.Table.PageSize
  735. if 1 > pageSize {
  736. pageSize = table.PageSize
  737. }
  738. start := (page - 1) * pageSize
  739. end := start + pageSize
  740. if len(table.Rows) < end {
  741. end = len(table.Rows)
  742. }
  743. table.Rows = table.Rows[start:end]
  744. }
  745. return
  746. }
  747. func renderTemplateCol(ial map[string]string, flashcard *Flashcard, rowValues []*av.KeyValues, tplContent string) string {
  748. if "" == ial["id"] {
  749. block := getRowBlockValue(rowValues)
  750. if nil != block && nil != block.Block {
  751. ial["id"] = block.Block.ID
  752. }
  753. }
  754. if "" == ial["updated"] {
  755. block := getRowBlockValue(rowValues)
  756. if nil != block && nil != block.Block {
  757. ial["updated"] = time.UnixMilli(block.Block.Updated).Format("20060102150405")
  758. }
  759. }
  760. goTpl := template.New("").Delims(".action{", "}")
  761. tplFuncMap := util.BuiltInTemplateFuncs()
  762. SQLTemplateFuncs(&tplFuncMap)
  763. goTpl = goTpl.Funcs(tplFuncMap)
  764. tpl, tplErr := goTpl.Parse(tplContent)
  765. if nil != tplErr {
  766. logging.LogWarnf("parse template [%s] failed: %s", tplContent, tplErr)
  767. return ""
  768. }
  769. buf := &bytes.Buffer{}
  770. dataModel := map[string]interface{}{} // 复制一份 IAL 以避免修改原始数据
  771. for k, v := range ial {
  772. dataModel[k] = v
  773. // Database template column supports `created` and `updated` built-in variables https://github.com/siyuan-note/siyuan/issues/9364
  774. createdStr := ial["id"]
  775. if "" != createdStr {
  776. createdStr = createdStr[:len("20060102150405")]
  777. }
  778. created, parseErr := time.ParseInLocation("20060102150405", createdStr, time.Local)
  779. if nil == parseErr {
  780. dataModel["created"] = created
  781. } else {
  782. logging.LogWarnf("parse created [%s] failed: %s", createdStr, parseErr)
  783. dataModel["created"] = time.Now()
  784. }
  785. updatedStr := ial["updated"]
  786. updated, parseErr := time.ParseInLocation("20060102150405", updatedStr, time.Local)
  787. if nil == parseErr {
  788. dataModel["updated"] = updated
  789. } else {
  790. dataModel["updated"] = time.Now()
  791. }
  792. }
  793. if nil != flashcard {
  794. dataModel["flashcard"] = flashcard
  795. }
  796. for _, rowValue := range rowValues {
  797. if 0 < len(rowValue.Values) {
  798. v := rowValue.Values[0]
  799. if av.KeyTypeNumber == v.Type {
  800. if nil != v.Number && v.Number.IsNotEmpty {
  801. dataModel[rowValue.Key.Name] = v.Number.Content
  802. }
  803. } else if av.KeyTypeDate == v.Type {
  804. if nil != v.Date && v.Date.IsNotEmpty {
  805. dataModel[rowValue.Key.Name] = time.UnixMilli(v.Date.Content)
  806. }
  807. } else if av.KeyTypeRollup == v.Type {
  808. if 0 < len(v.Rollup.Contents) && av.KeyTypeNumber == v.Rollup.Contents[0].Type {
  809. // 模板使用汇总时支持数字计算
  810. // Template supports numerical calculations when using rollup https://github.com/siyuan-note/siyuan/issues/10810
  811. // 汇总数字时仅取第一个数字填充模板
  812. dataModel[rowValue.Key.Name] = v.Rollup.Contents[0].Number.Content
  813. }
  814. } else {
  815. dataModel[rowValue.Key.Name] = v.String()
  816. }
  817. }
  818. }
  819. if err := tpl.Execute(buf, dataModel); nil != err {
  820. logging.LogWarnf("execute template [%s] failed: %s", tplContent, err)
  821. }
  822. return buf.String()
  823. }
  824. func renderAttributeViewTable(attrView *av.AttributeView, view *av.View, query string) (ret *av.Table, err error) {
  825. ret = &av.Table{
  826. ID: view.ID,
  827. Icon: view.Icon,
  828. Name: view.Name,
  829. HideAttrViewName: view.HideAttrViewName,
  830. Columns: []*av.TableColumn{},
  831. Rows: []*av.TableRow{},
  832. Filters: view.Table.Filters,
  833. Sorts: view.Table.Sorts,
  834. }
  835. // 组装列
  836. for _, col := range view.Table.Columns {
  837. key, getErr := attrView.GetKey(col.ID)
  838. if nil != getErr {
  839. err = getErr
  840. return
  841. }
  842. ret.Columns = append(ret.Columns, &av.TableColumn{
  843. ID: key.ID,
  844. Name: key.Name,
  845. Type: key.Type,
  846. Icon: key.Icon,
  847. Options: key.Options,
  848. NumberFormat: key.NumberFormat,
  849. Template: key.Template,
  850. Relation: key.Relation,
  851. Rollup: key.Rollup,
  852. Date: key.Date,
  853. Wrap: col.Wrap,
  854. Hidden: col.Hidden,
  855. Width: col.Width,
  856. Pin: col.Pin,
  857. Calc: col.Calc,
  858. })
  859. }
  860. // 生成行
  861. rows := map[string][]*av.KeyValues{}
  862. for _, keyValues := range attrView.KeyValues {
  863. for _, val := range keyValues.Values {
  864. values := rows[val.BlockID]
  865. if nil == values {
  866. values = []*av.KeyValues{{Key: keyValues.Key, Values: []*av.Value{val}}}
  867. } else {
  868. values = append(values, &av.KeyValues{Key: keyValues.Key, Values: []*av.Value{val}})
  869. }
  870. rows[val.BlockID] = values
  871. }
  872. // 数据订正,补全关联
  873. if av.KeyTypeRelation == keyValues.Key.Type && nil != keyValues.Key.Relation {
  874. av.UpsertAvBackRel(attrView.ID, keyValues.Key.Relation.AvID)
  875. if keyValues.Key.Relation.IsTwoWay {
  876. av.UpsertAvBackRel(keyValues.Key.Relation.AvID, attrView.ID)
  877. }
  878. }
  879. }
  880. // 过滤掉不存在的行
  881. var notFound []string
  882. for blockID, keyValues := range rows {
  883. blockValue := getRowBlockValue(keyValues)
  884. if nil == blockValue {
  885. notFound = append(notFound, blockID)
  886. continue
  887. }
  888. if blockValue.IsDetached {
  889. continue
  890. }
  891. if nil != blockValue.Block && "" == blockValue.Block.ID {
  892. notFound = append(notFound, blockID)
  893. continue
  894. }
  895. if nil == treenode.GetBlockTree(blockID) {
  896. notFound = append(notFound, blockID)
  897. }
  898. }
  899. for _, blockID := range notFound {
  900. delete(rows, blockID)
  901. }
  902. // 生成行单元格
  903. for rowID, row := range rows {
  904. var tableRow av.TableRow
  905. for _, col := range ret.Columns {
  906. var tableCell *av.TableCell
  907. for _, keyValues := range row {
  908. if keyValues.Key.ID == col.ID {
  909. tableCell = &av.TableCell{
  910. ID: keyValues.Values[0].ID,
  911. Value: keyValues.Values[0],
  912. ValueType: col.Type,
  913. }
  914. break
  915. }
  916. }
  917. if nil == tableCell {
  918. tableCell = &av.TableCell{
  919. ID: ast.NewNodeID(),
  920. ValueType: col.Type,
  921. }
  922. }
  923. tableRow.ID = rowID
  924. switch tableCell.ValueType {
  925. case av.KeyTypeNumber: // 格式化数字
  926. if nil != tableCell.Value && nil != tableCell.Value.Number && tableCell.Value.Number.IsNotEmpty {
  927. tableCell.Value.Number.Format = col.NumberFormat
  928. tableCell.Value.Number.FormatNumber()
  929. }
  930. case av.KeyTypeTemplate: // 渲染模板列
  931. tableCell.Value = &av.Value{ID: tableCell.ID, KeyID: col.ID, BlockID: rowID, Type: av.KeyTypeTemplate, Template: &av.ValueTemplate{Content: col.Template}}
  932. case av.KeyTypeCreated: // 填充创建时间列值,后面再渲染
  933. tableCell.Value = &av.Value{ID: tableCell.ID, KeyID: col.ID, BlockID: rowID, Type: av.KeyTypeCreated}
  934. case av.KeyTypeUpdated: // 填充更新时间列值,后面再渲染
  935. tableCell.Value = &av.Value{ID: tableCell.ID, KeyID: col.ID, BlockID: rowID, Type: av.KeyTypeUpdated}
  936. case av.KeyTypeRelation: // 清空关联列值,后面再渲染 https://ld246.com/article/1703831044435
  937. if nil != tableCell.Value && nil != tableCell.Value.Relation {
  938. tableCell.Value.Relation.Contents = nil
  939. }
  940. }
  941. treenode.FillAttributeViewTableCellNilValue(tableCell, rowID, col.ID)
  942. tableRow.Cells = append(tableRow.Cells, tableCell)
  943. }
  944. ret.Rows = append(ret.Rows, &tableRow)
  945. }
  946. // 渲染自动生成的列值,比如关联列、汇总列、创建时间列和更新时间列
  947. for _, row := range ret.Rows {
  948. for _, cell := range row.Cells {
  949. switch cell.ValueType {
  950. case av.KeyTypeRollup: // 渲染汇总列
  951. rollupKey, _ := attrView.GetKey(cell.Value.KeyID)
  952. if nil == rollupKey || nil == rollupKey.Rollup {
  953. break
  954. }
  955. relKey, _ := attrView.GetKey(rollupKey.Rollup.RelationKeyID)
  956. if nil == relKey || nil == relKey.Relation {
  957. break
  958. }
  959. relVal := attrView.GetValue(relKey.ID, row.ID)
  960. if nil == relVal || nil == relVal.Relation {
  961. break
  962. }
  963. destAv, _ := av.ParseAttributeView(relKey.Relation.AvID)
  964. if nil == destAv {
  965. break
  966. }
  967. destKey, _ := destAv.GetKey(rollupKey.Rollup.KeyID)
  968. if nil == destKey {
  969. continue
  970. }
  971. for _, blockID := range relVal.Relation.BlockIDs {
  972. destVal := destAv.GetValue(rollupKey.Rollup.KeyID, blockID)
  973. if nil == destVal {
  974. if destAv.ExistBlock(blockID) { // 数据库中存在行但是列值不存在是数据未初始化,这里补一个默认值
  975. destVal = treenode.GetAttributeViewDefaultValue(ast.NewNodeID(), rollupKey.Rollup.KeyID, blockID, destKey.Type)
  976. }
  977. if nil == destVal {
  978. continue
  979. }
  980. }
  981. if av.KeyTypeNumber == destKey.Type {
  982. destVal.Number.Format = destKey.NumberFormat
  983. destVal.Number.FormatNumber()
  984. }
  985. cell.Value.Rollup.Contents = append(cell.Value.Rollup.Contents, destVal.Clone())
  986. }
  987. cell.Value.Rollup.RenderContents(rollupKey.Rollup.Calc, destKey)
  988. // 将汇总列的值保存到 rows 中,后续渲染模板列的时候会用到,下同
  989. // Database table view template columns support reading relation, rollup, created and updated columns https://github.com/siyuan-note/siyuan/issues/10442
  990. keyValues := rows[row.ID]
  991. keyValues = append(keyValues, &av.KeyValues{Key: rollupKey, Values: []*av.Value{{ID: cell.Value.ID, KeyID: rollupKey.ID, BlockID: row.ID, Type: av.KeyTypeRollup, Rollup: cell.Value.Rollup}}})
  992. rows[row.ID] = keyValues
  993. case av.KeyTypeRelation: // 渲染关联列
  994. relKey, _ := attrView.GetKey(cell.Value.KeyID)
  995. if nil != relKey && nil != relKey.Relation {
  996. destAv, _ := av.ParseAttributeView(relKey.Relation.AvID)
  997. if nil != destAv {
  998. blocks := map[string]*av.Value{}
  999. for _, blockValue := range destAv.GetBlockKeyValues().Values {
  1000. blocks[blockValue.BlockID] = blockValue
  1001. }
  1002. for _, blockID := range cell.Value.Relation.BlockIDs {
  1003. if val := blocks[blockID]; nil != val {
  1004. cell.Value.Relation.Contents = append(cell.Value.Relation.Contents, val)
  1005. }
  1006. }
  1007. }
  1008. }
  1009. keyValues := rows[row.ID]
  1010. keyValues = append(keyValues, &av.KeyValues{Key: relKey, Values: []*av.Value{{ID: cell.Value.ID, KeyID: relKey.ID, BlockID: row.ID, Type: av.KeyTypeRelation, Relation: cell.Value.Relation}}})
  1011. rows[row.ID] = keyValues
  1012. case av.KeyTypeCreated: // 渲染创建时间
  1013. createdStr := row.ID[:len("20060102150405")]
  1014. created, parseErr := time.ParseInLocation("20060102150405", createdStr, time.Local)
  1015. if nil == parseErr {
  1016. cell.Value.Created = av.NewFormattedValueCreated(created.UnixMilli(), 0, av.CreatedFormatNone)
  1017. cell.Value.Created.IsNotEmpty = true
  1018. } else {
  1019. cell.Value.Created = av.NewFormattedValueCreated(time.Now().UnixMilli(), 0, av.CreatedFormatNone)
  1020. }
  1021. keyValues := rows[row.ID]
  1022. createdKey, _ := attrView.GetKey(cell.Value.KeyID)
  1023. keyValues = append(keyValues, &av.KeyValues{Key: createdKey, Values: []*av.Value{{ID: cell.Value.ID, KeyID: createdKey.ID, BlockID: row.ID, Type: av.KeyTypeCreated, Created: cell.Value.Created}}})
  1024. rows[row.ID] = keyValues
  1025. case av.KeyTypeUpdated: // 渲染更新时间
  1026. ial := map[string]string{}
  1027. block := row.GetBlockValue()
  1028. if nil != block && !block.IsDetached {
  1029. ial = GetBlockAttrsWithoutWaitWriting(row.ID)
  1030. }
  1031. updatedStr := ial["updated"]
  1032. if "" == updatedStr && nil != block {
  1033. cell.Value.Updated = av.NewFormattedValueUpdated(block.Block.Updated, 0, av.UpdatedFormatNone)
  1034. cell.Value.Updated.IsNotEmpty = true
  1035. } else {
  1036. updated, parseErr := time.ParseInLocation("20060102150405", updatedStr, time.Local)
  1037. if nil == parseErr {
  1038. cell.Value.Updated = av.NewFormattedValueUpdated(updated.UnixMilli(), 0, av.UpdatedFormatNone)
  1039. cell.Value.Updated.IsNotEmpty = true
  1040. } else {
  1041. cell.Value.Updated = av.NewFormattedValueUpdated(time.Now().UnixMilli(), 0, av.UpdatedFormatNone)
  1042. }
  1043. }
  1044. keyValues := rows[row.ID]
  1045. updatedKey, _ := attrView.GetKey(cell.Value.KeyID)
  1046. keyValues = append(keyValues, &av.KeyValues{Key: updatedKey, Values: []*av.Value{{ID: cell.Value.ID, KeyID: updatedKey.ID, BlockID: row.ID, Type: av.KeyTypeUpdated, Updated: cell.Value.Updated}}})
  1047. rows[row.ID] = keyValues
  1048. }
  1049. }
  1050. }
  1051. // 最后单独渲染模板列,这样模板列就可以使用汇总、关联、创建时间和更新时间列的值了
  1052. // Database table view template columns support reading relation, rollup, created and updated columns https://github.com/siyuan-note/siyuan/issues/10442
  1053. // 获取闪卡信息
  1054. flashcards := map[string]*Flashcard{}
  1055. //deck := Decks[builtinDeckID]
  1056. //if nil != deck {
  1057. // var blockIDs []string
  1058. // for _, row := range ret.Rows {
  1059. // blockIDs = append(blockIDs, row.ID)
  1060. // }
  1061. // cards := deck.GetCardsByBlockIDs(blockIDs)
  1062. // now := time.Now()
  1063. // for _, card := range cards {
  1064. // flashcards[card.BlockID()] = newFlashcard(card, builtinDeckID, now)
  1065. // }
  1066. //}
  1067. for _, row := range ret.Rows {
  1068. for _, cell := range row.Cells {
  1069. switch cell.ValueType {
  1070. case av.KeyTypeTemplate: // 渲染模板列
  1071. keyValues := rows[row.ID]
  1072. ial := map[string]string{}
  1073. block := row.GetBlockValue()
  1074. if nil != block && !block.IsDetached {
  1075. ial = GetBlockAttrsWithoutWaitWriting(row.ID)
  1076. }
  1077. content := renderTemplateCol(ial, flashcards[row.ID], keyValues, cell.Value.Template.Content)
  1078. cell.Value.Template.Content = content
  1079. }
  1080. }
  1081. }
  1082. // 根据搜索条件过滤
  1083. query = strings.TrimSpace(query)
  1084. if "" != query {
  1085. keywords := strings.Split(query, " ")
  1086. var hitRows []*av.TableRow
  1087. for _, row := range ret.Rows {
  1088. hit := false
  1089. for _, cell := range row.Cells {
  1090. for _, keyword := range keywords {
  1091. if strings.Contains(strings.ToLower(cell.Value.String()), strings.ToLower(keyword)) {
  1092. hit = true
  1093. break
  1094. }
  1095. }
  1096. }
  1097. if hit {
  1098. hitRows = append(hitRows, row)
  1099. }
  1100. }
  1101. ret.Rows = hitRows
  1102. if 1 > len(ret.Rows) {
  1103. ret.Rows = []*av.TableRow{}
  1104. }
  1105. }
  1106. // 自定义排序
  1107. sortRowIDs := map[string]int{}
  1108. if 0 < len(view.Table.RowIDs) {
  1109. for i, rowID := range view.Table.RowIDs {
  1110. sortRowIDs[rowID] = i
  1111. }
  1112. }
  1113. sort.Slice(ret.Rows, func(i, j int) bool {
  1114. iv := sortRowIDs[ret.Rows[i].ID]
  1115. jv := sortRowIDs[ret.Rows[j].ID]
  1116. if iv == jv {
  1117. return ret.Rows[i].ID < ret.Rows[j].ID
  1118. }
  1119. return iv < jv
  1120. })
  1121. return
  1122. }
  1123. func getRowBlockValue(keyValues []*av.KeyValues) (ret *av.Value) {
  1124. for _, kv := range keyValues {
  1125. if av.KeyTypeBlock == kv.Key.Type && 0 < len(kv.Values) {
  1126. ret = kv.Values[0]
  1127. break
  1128. }
  1129. }
  1130. return
  1131. }
  1132. func (tx *Transaction) doSetAttrViewColDate(operation *Operation) (ret *TxErr) {
  1133. err := setAttributeViewColDate(operation)
  1134. if nil != err {
  1135. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  1136. }
  1137. return
  1138. }
  1139. func setAttributeViewColDate(operation *Operation) (err error) {
  1140. attrView, err := av.ParseAttributeView(operation.AvID)
  1141. if nil != err {
  1142. return
  1143. }
  1144. keyID := operation.ID
  1145. key, _ := attrView.GetKey(keyID)
  1146. if nil == key || av.KeyTypeDate != key.Type {
  1147. return
  1148. }
  1149. if nil == key.Date {
  1150. key.Date = &av.Date{}
  1151. }
  1152. key.Date.AutoFillNow = operation.Data.(bool)
  1153. err = av.SaveAttributeView(attrView)
  1154. return
  1155. }
  1156. func (tx *Transaction) doHideAttrViewName(operation *Operation) (ret *TxErr) {
  1157. err := hideAttrViewName(operation)
  1158. if nil != err {
  1159. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  1160. }
  1161. return
  1162. }
  1163. func hideAttrViewName(operation *Operation) (err error) {
  1164. attrView, err := av.ParseAttributeView(operation.AvID)
  1165. if nil != err {
  1166. logging.LogErrorf("parse attribute view [%s] failed: %s", operation.AvID, err)
  1167. return
  1168. }
  1169. view, err := getAttrViewViewByBlockID(attrView, operation.BlockID)
  1170. if nil == view {
  1171. logging.LogErrorf("get view [%s] failed: %s", operation.BlockID, err)
  1172. return
  1173. }
  1174. view.HideAttrViewName = operation.Data.(bool)
  1175. err = av.SaveAttributeView(attrView)
  1176. return
  1177. }
  1178. func (tx *Transaction) doUpdateAttrViewColRollup(operation *Operation) (ret *TxErr) {
  1179. err := updateAttributeViewColRollup(operation)
  1180. if nil != err {
  1181. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  1182. }
  1183. return
  1184. }
  1185. func updateAttributeViewColRollup(operation *Operation) (err error) {
  1186. // operation.AvID 汇总列所在 av
  1187. // operation.ID 汇总列 ID
  1188. // operation.ParentID 汇总列基于的关联列 ID
  1189. // operation.KeyID 目标列 ID
  1190. // operation.Data 计算方式
  1191. attrView, err := av.ParseAttributeView(operation.AvID)
  1192. if nil != err {
  1193. return
  1194. }
  1195. rollUpKey, _ := attrView.GetKey(operation.ID)
  1196. if nil == rollUpKey {
  1197. return
  1198. }
  1199. rollUpKey.Rollup = &av.Rollup{
  1200. RelationKeyID: operation.ParentID,
  1201. KeyID: operation.KeyID,
  1202. }
  1203. if nil != operation.Data {
  1204. data := operation.Data.(map[string]interface{})
  1205. if nil != data["calc"] {
  1206. calcData, jsonErr := gulu.JSON.MarshalJSON(data["calc"])
  1207. if nil != jsonErr {
  1208. err = jsonErr
  1209. return
  1210. }
  1211. if jsonErr = gulu.JSON.UnmarshalJSON(calcData, &rollUpKey.Rollup.Calc); nil != jsonErr {
  1212. err = jsonErr
  1213. return
  1214. }
  1215. }
  1216. }
  1217. err = av.SaveAttributeView(attrView)
  1218. return
  1219. }
  1220. func (tx *Transaction) doUpdateAttrViewColRelation(operation *Operation) (ret *TxErr) {
  1221. err := updateAttributeViewColRelation(operation)
  1222. if nil != err {
  1223. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  1224. }
  1225. return
  1226. }
  1227. func updateAttributeViewColRelation(operation *Operation) (err error) {
  1228. // operation.AvID 源 avID
  1229. // operation.ID 目标 avID
  1230. // operation.KeyID 源 av 关联列 ID
  1231. // operation.IsTwoWay 是否双向关联
  1232. // operation.BackRelationKeyID 双向关联的目标关联列 ID
  1233. // operation.Name 双向关联的目标关联列名称
  1234. // operation.Format 源 av 关联列名称
  1235. srcAv, err := av.ParseAttributeView(operation.AvID)
  1236. if nil != err {
  1237. return
  1238. }
  1239. destAv, err := av.ParseAttributeView(operation.ID)
  1240. if nil != err {
  1241. return
  1242. }
  1243. isSameAv := srcAv.ID == destAv.ID
  1244. if isSameAv {
  1245. destAv = srcAv
  1246. }
  1247. for _, keyValues := range srcAv.KeyValues {
  1248. if keyValues.Key.ID != operation.KeyID {
  1249. continue
  1250. }
  1251. srcRel := keyValues.Key.Relation
  1252. // 已经设置过双向关联的话需要先断开双向关联
  1253. if nil != srcRel {
  1254. if srcRel.IsTwoWay {
  1255. oldDestAv, _ := av.ParseAttributeView(srcRel.AvID)
  1256. if nil != oldDestAv {
  1257. isOldSameAv := oldDestAv.ID == destAv.ID
  1258. if isOldSameAv {
  1259. oldDestAv = destAv
  1260. }
  1261. oldDestKey, _ := oldDestAv.GetKey(srcRel.BackKeyID)
  1262. if nil != oldDestKey && nil != oldDestKey.Relation && oldDestKey.Relation.AvID == srcAv.ID && oldDestKey.Relation.IsTwoWay {
  1263. oldDestKey.Relation.IsTwoWay = false
  1264. oldDestKey.Relation.BackKeyID = ""
  1265. }
  1266. if !isOldSameAv {
  1267. err = av.SaveAttributeView(oldDestAv)
  1268. if nil != err {
  1269. return
  1270. }
  1271. }
  1272. }
  1273. }
  1274. av.RemoveAvRel(srcAv.ID, srcRel.AvID)
  1275. }
  1276. srcRel = &av.Relation{
  1277. AvID: operation.ID,
  1278. IsTwoWay: operation.IsTwoWay,
  1279. }
  1280. if operation.IsTwoWay {
  1281. srcRel.BackKeyID = operation.BackRelationKeyID
  1282. } else {
  1283. srcRel.BackKeyID = ""
  1284. }
  1285. keyValues.Key.Relation = srcRel
  1286. keyValues.Key.Name = operation.Format
  1287. break
  1288. }
  1289. destAdded := false
  1290. backRelKey, _ := destAv.GetKey(operation.BackRelationKeyID)
  1291. if nil != backRelKey {
  1292. backRelKey.Relation = &av.Relation{
  1293. AvID: operation.AvID,
  1294. IsTwoWay: operation.IsTwoWay,
  1295. BackKeyID: operation.KeyID,
  1296. }
  1297. destAdded = true
  1298. if operation.IsTwoWay {
  1299. name := strings.TrimSpace(operation.Name)
  1300. if "" == name {
  1301. name = srcAv.Name + " " + operation.Format
  1302. }
  1303. backRelKey.Name = strings.TrimSpace(name)
  1304. }
  1305. }
  1306. if !destAdded {
  1307. if operation.IsTwoWay {
  1308. name := strings.TrimSpace(operation.Name)
  1309. if "" == name {
  1310. name = srcAv.Name + " " + operation.Format
  1311. }
  1312. destAv.KeyValues = append(destAv.KeyValues, &av.KeyValues{
  1313. Key: &av.Key{
  1314. ID: operation.BackRelationKeyID,
  1315. Name: name,
  1316. Type: av.KeyTypeRelation,
  1317. Relation: &av.Relation{AvID: operation.AvID, IsTwoWay: operation.IsTwoWay, BackKeyID: operation.KeyID},
  1318. },
  1319. })
  1320. for _, v := range destAv.Views {
  1321. switch v.LayoutType {
  1322. case av.LayoutTypeTable:
  1323. v.Table.Columns = append(v.Table.Columns, &av.ViewTableColumn{ID: operation.BackRelationKeyID})
  1324. }
  1325. }
  1326. }
  1327. }
  1328. err = av.SaveAttributeView(srcAv)
  1329. if nil != err {
  1330. return
  1331. }
  1332. if !isSameAv {
  1333. err = av.SaveAttributeView(destAv)
  1334. util.BroadcastByType("protyle", "refreshAttributeView", 0, "", map[string]interface{}{"id": destAv.ID})
  1335. }
  1336. av.UpsertAvBackRel(srcAv.ID, destAv.ID)
  1337. return
  1338. }
  1339. func (tx *Transaction) doSortAttrViewView(operation *Operation) (ret *TxErr) {
  1340. avID := operation.AvID
  1341. attrView, err := av.ParseAttributeView(avID)
  1342. if nil != err {
  1343. logging.LogErrorf("parse attribute view [%s] failed: %s", operation.AvID, err)
  1344. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  1345. }
  1346. view := attrView.GetView(operation.ID)
  1347. if nil == view {
  1348. logging.LogErrorf("get view failed: %s", operation.BlockID)
  1349. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  1350. }
  1351. viewID := view.ID
  1352. previousViewID := operation.PreviousID
  1353. if viewID == previousViewID {
  1354. return
  1355. }
  1356. var index, previousIndex int
  1357. for i, v := range attrView.Views {
  1358. if v.ID == viewID {
  1359. view = v
  1360. index = i
  1361. break
  1362. }
  1363. }
  1364. if nil == view {
  1365. return
  1366. }
  1367. attrView.Views = append(attrView.Views[:index], attrView.Views[index+1:]...)
  1368. for i, v := range attrView.Views {
  1369. if v.ID == previousViewID {
  1370. previousIndex = i + 1
  1371. break
  1372. }
  1373. }
  1374. attrView.Views = util.InsertElem(attrView.Views, previousIndex, view)
  1375. if err = av.SaveAttributeView(attrView); nil != err {
  1376. logging.LogErrorf("save attribute view [%s] failed: %s", avID, err)
  1377. return &TxErr{code: TxErrCodeWriteTree, msg: err.Error(), id: avID}
  1378. }
  1379. return
  1380. }
  1381. func (tx *Transaction) doRemoveAttrViewView(operation *Operation) (ret *TxErr) {
  1382. var err error
  1383. avID := operation.AvID
  1384. attrView, err := av.ParseAttributeView(avID)
  1385. if nil != err {
  1386. logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err)
  1387. return &TxErr{code: TxErrCodeBlockNotFound, id: avID}
  1388. }
  1389. if 1 >= len(attrView.Views) {
  1390. logging.LogWarnf("can't remove last view [%s] of attribute view [%s]", operation.AvID, avID)
  1391. return
  1392. }
  1393. view, err := getAttrViewViewByBlockID(attrView, operation.BlockID)
  1394. if nil == view {
  1395. logging.LogWarnf("get view failed: %s", operation.BlockID)
  1396. return
  1397. }
  1398. viewID := view.ID
  1399. var index int
  1400. for i, view := range attrView.Views {
  1401. if viewID == view.ID {
  1402. attrView.Views = append(attrView.Views[:i], attrView.Views[i+1:]...)
  1403. index = i - 1
  1404. break
  1405. }
  1406. }
  1407. if 0 > index {
  1408. index = 0
  1409. }
  1410. attrView.ViewID = attrView.Views[index].ID
  1411. if err = av.SaveAttributeView(attrView); nil != err {
  1412. logging.LogErrorf("save attribute view [%s] failed: %s", avID, err)
  1413. return &TxErr{code: TxErrCodeWriteTree, msg: err.Error(), id: avID}
  1414. }
  1415. trees, nodes := getMirrorBlocksNodes(avID)
  1416. for _, node := range nodes {
  1417. attrs := parse.IAL2Map(node.KramdownIAL)
  1418. blockViewID := attrs[av.NodeAttrView]
  1419. if blockViewID == viewID {
  1420. attrs[av.NodeAttrView] = attrView.ViewID
  1421. oldAttrs, e := setNodeAttrs0(node, attrs)
  1422. if nil != e {
  1423. logging.LogErrorf("set node attrs failed: %s", e)
  1424. continue
  1425. }
  1426. cache.PutBlockIAL(node.ID, parse.IAL2Map(node.KramdownIAL))
  1427. pushBroadcastAttrTransactions(oldAttrs, node)
  1428. }
  1429. }
  1430. for _, tree := range trees {
  1431. if err = indexWriteTreeUpsertQueue(tree); nil != err {
  1432. return
  1433. }
  1434. }
  1435. return
  1436. }
  1437. func getMirrorBlocksNodes(avID string) (trees []*parse.Tree, nodes []*ast.Node) {
  1438. mirrorBlocks := treenode.GetMirrorAttrViewBlockIDs(avID)
  1439. mirrorBlockTree := map[string]*parse.Tree{}
  1440. treeMap := map[string]*parse.Tree{}
  1441. for _, mirrorBlock := range mirrorBlocks {
  1442. bt := treenode.GetBlockTree(mirrorBlock)
  1443. if nil == bt {
  1444. logging.LogErrorf("get block tree by block ID [%s] failed", mirrorBlock)
  1445. continue
  1446. }
  1447. tree := mirrorBlockTree[mirrorBlock]
  1448. if nil == tree {
  1449. tree, _ = LoadTreeByBlockID(mirrorBlock)
  1450. if nil == tree {
  1451. logging.LogErrorf("load tree by block ID [%s] failed", mirrorBlock)
  1452. continue
  1453. }
  1454. treeMap[tree.ID] = tree
  1455. mirrorBlockTree[mirrorBlock] = tree
  1456. }
  1457. }
  1458. for _, mirrorBlock := range mirrorBlocks {
  1459. tree := mirrorBlockTree[mirrorBlock]
  1460. node := treenode.GetNodeInTree(tree, mirrorBlock)
  1461. if nil == node {
  1462. logging.LogErrorf("get node in tree by block ID [%s] failed", mirrorBlock)
  1463. continue
  1464. }
  1465. nodes = append(nodes, node)
  1466. }
  1467. for _, tree := range treeMap {
  1468. trees = append(trees, tree)
  1469. }
  1470. return
  1471. }
  1472. func (tx *Transaction) doDuplicateAttrViewView(operation *Operation) (ret *TxErr) {
  1473. var err error
  1474. avID := operation.AvID
  1475. attrView, err := av.ParseAttributeView(avID)
  1476. if nil != err {
  1477. logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err)
  1478. return &TxErr{code: TxErrWriteAttributeView, id: avID}
  1479. }
  1480. masterView := attrView.GetView(operation.PreviousID)
  1481. if nil == masterView {
  1482. logging.LogErrorf("get master view failed: %s", avID)
  1483. return &TxErr{code: TxErrWriteAttributeView, id: avID}
  1484. }
  1485. node, tree, _ := getNodeByBlockID(nil, operation.BlockID)
  1486. if nil == node {
  1487. logging.LogErrorf("get node by block ID [%s] failed", operation.BlockID)
  1488. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID}
  1489. }
  1490. attrs := parse.IAL2Map(node.KramdownIAL)
  1491. attrs[av.NodeAttrView] = operation.ID
  1492. err = setNodeAttrs(node, tree, attrs)
  1493. if nil != err {
  1494. logging.LogWarnf("set node [%s] attrs failed: %s", operation.BlockID, err)
  1495. return
  1496. }
  1497. view := av.NewTableView()
  1498. view.ID = operation.ID
  1499. attrView.Views = append(attrView.Views, view)
  1500. attrView.ViewID = view.ID
  1501. view.Icon = masterView.Icon
  1502. view.Name = attrView.GetDuplicateViewName(masterView.Name)
  1503. view.LayoutType = masterView.LayoutType
  1504. view.HideAttrViewName = masterView.HideAttrViewName
  1505. for _, col := range masterView.Table.Columns {
  1506. view.Table.Columns = append(view.Table.Columns, &av.ViewTableColumn{
  1507. ID: col.ID,
  1508. Wrap: col.Wrap,
  1509. Hidden: col.Hidden,
  1510. Pin: col.Pin,
  1511. Width: col.Width,
  1512. Calc: col.Calc,
  1513. })
  1514. }
  1515. for _, filter := range masterView.Table.Filters {
  1516. view.Table.Filters = append(view.Table.Filters, &av.ViewFilter{
  1517. Column: filter.Column,
  1518. Operator: filter.Operator,
  1519. Value: filter.Value,
  1520. RelativeDate: filter.RelativeDate,
  1521. RelativeDate2: filter.RelativeDate2,
  1522. })
  1523. }
  1524. for _, s := range masterView.Table.Sorts {
  1525. view.Table.Sorts = append(view.Table.Sorts, &av.ViewSort{
  1526. Column: s.Column,
  1527. Order: s.Order,
  1528. })
  1529. }
  1530. view.Table.PageSize = masterView.Table.PageSize
  1531. view.Table.RowIDs = masterView.Table.RowIDs
  1532. if err = av.SaveAttributeView(attrView); nil != err {
  1533. logging.LogErrorf("save attribute view [%s] failed: %s", avID, err)
  1534. return &TxErr{code: TxErrWriteAttributeView, msg: err.Error(), id: avID}
  1535. }
  1536. return
  1537. }
  1538. func (tx *Transaction) doAddAttrViewView(operation *Operation) (ret *TxErr) {
  1539. var err error
  1540. avID := operation.AvID
  1541. attrView, err := av.ParseAttributeView(avID)
  1542. if nil != err {
  1543. logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err)
  1544. return &TxErr{code: TxErrWriteAttributeView, id: avID}
  1545. }
  1546. if 1 > len(attrView.Views) {
  1547. logging.LogErrorf("no view in attribute view [%s]", avID)
  1548. return &TxErr{code: TxErrWriteAttributeView, id: avID}
  1549. }
  1550. firstView := attrView.Views[0]
  1551. if nil == firstView {
  1552. logging.LogErrorf("get first view failed: %s", avID)
  1553. return &TxErr{code: TxErrWriteAttributeView, id: avID}
  1554. }
  1555. node, tree, _ := getNodeByBlockID(nil, operation.BlockID)
  1556. if nil == node {
  1557. logging.LogErrorf("get node by block ID [%s] failed", operation.BlockID)
  1558. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID}
  1559. }
  1560. attrs := parse.IAL2Map(node.KramdownIAL)
  1561. attrs[av.NodeAttrView] = operation.ID
  1562. err = setNodeAttrs(node, tree, attrs)
  1563. if nil != err {
  1564. logging.LogWarnf("set node [%s] attrs failed: %s", operation.BlockID, err)
  1565. return
  1566. }
  1567. view := av.NewTableView()
  1568. view.ID = operation.ID
  1569. attrView.Views = append(attrView.Views, view)
  1570. attrView.ViewID = view.ID
  1571. for _, col := range firstView.Table.Columns {
  1572. view.Table.Columns = append(view.Table.Columns, &av.ViewTableColumn{ID: col.ID})
  1573. }
  1574. view.Table.RowIDs = firstView.Table.RowIDs
  1575. if err = av.SaveAttributeView(attrView); nil != err {
  1576. logging.LogErrorf("save attribute view [%s] failed: %s", avID, err)
  1577. return &TxErr{code: TxErrWriteAttributeView, msg: err.Error(), id: avID}
  1578. }
  1579. return
  1580. }
  1581. func (tx *Transaction) doSetAttrViewViewName(operation *Operation) (ret *TxErr) {
  1582. var err error
  1583. avID := operation.AvID
  1584. attrView, err := av.ParseAttributeView(avID)
  1585. if nil != err {
  1586. logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err)
  1587. return &TxErr{code: TxErrWriteAttributeView, id: avID}
  1588. }
  1589. viewID := operation.ID
  1590. view := attrView.GetView(viewID)
  1591. if nil == view {
  1592. logging.LogErrorf("get view [%s] failed: %s", viewID, err)
  1593. return &TxErr{code: TxErrWriteAttributeView, id: viewID}
  1594. }
  1595. view.Name = strings.TrimSpace(operation.Data.(string))
  1596. if err = av.SaveAttributeView(attrView); nil != err {
  1597. logging.LogErrorf("save attribute view [%s] failed: %s", avID, err)
  1598. return &TxErr{code: TxErrWriteAttributeView, msg: err.Error(), id: avID}
  1599. }
  1600. return
  1601. }
  1602. func (tx *Transaction) doSetAttrViewViewIcon(operation *Operation) (ret *TxErr) {
  1603. var err error
  1604. avID := operation.AvID
  1605. attrView, err := av.ParseAttributeView(avID)
  1606. if nil != err {
  1607. logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err)
  1608. return &TxErr{code: TxErrWriteAttributeView, id: avID}
  1609. }
  1610. viewID := operation.ID
  1611. view := attrView.GetView(viewID)
  1612. if nil == view {
  1613. logging.LogErrorf("get view [%s] failed: %s", viewID, err)
  1614. return &TxErr{code: TxErrWriteAttributeView, id: viewID}
  1615. }
  1616. view.Icon = operation.Data.(string)
  1617. if err = av.SaveAttributeView(attrView); nil != err {
  1618. logging.LogErrorf("save attribute view [%s] failed: %s", avID, err)
  1619. return &TxErr{code: TxErrWriteAttributeView, msg: err.Error(), id: avID}
  1620. }
  1621. return
  1622. }
  1623. func (tx *Transaction) doSetAttrViewName(operation *Operation) (ret *TxErr) {
  1624. err := setAttributeViewName(operation)
  1625. if nil != err {
  1626. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  1627. }
  1628. return
  1629. }
  1630. const attrAvNameTpl = `<span data-av-id="${avID}" data-popover-url="/api/av/getMirrorDatabaseBlocks" class="popover__block">${avName}</span>`
  1631. func setAttributeViewName(operation *Operation) (err error) {
  1632. avID := operation.ID
  1633. attrView, err := av.ParseAttributeView(avID)
  1634. if nil != err {
  1635. return
  1636. }
  1637. attrView.Name = strings.TrimSpace(operation.Data.(string))
  1638. err = av.SaveAttributeView(attrView)
  1639. nodes := getAttrViewBoundNodes(attrView)
  1640. for _, node := range nodes {
  1641. avNames := getAvNames(node.IALAttr(av.NodeAttrNameAvs))
  1642. oldAttrs := parse.IAL2Map(node.KramdownIAL)
  1643. node.SetIALAttr(av.NodeAttrViewNames, avNames)
  1644. pushBroadcastAttrTransactions(oldAttrs, node)
  1645. }
  1646. return
  1647. }
  1648. func getAvNames(avIDs string) (ret string) {
  1649. if "" == avIDs {
  1650. return
  1651. }
  1652. avNames := bytes.Buffer{}
  1653. nodeAvIDs := strings.Split(avIDs, ",")
  1654. for _, nodeAvID := range nodeAvIDs {
  1655. nodeAvName, getErr := av.GetAttributeViewName(nodeAvID)
  1656. if nil != getErr {
  1657. continue
  1658. }
  1659. if "" == nodeAvName {
  1660. nodeAvName = Conf.language(105)
  1661. }
  1662. tpl := strings.ReplaceAll(attrAvNameTpl, "${avID}", nodeAvID)
  1663. tpl = strings.ReplaceAll(tpl, "${avName}", nodeAvName)
  1664. avNames.WriteString(tpl)
  1665. avNames.WriteString("&nbsp;")
  1666. }
  1667. if 0 < avNames.Len() {
  1668. avNames.Truncate(avNames.Len() - 6)
  1669. ret = avNames.String()
  1670. }
  1671. return
  1672. }
  1673. func getAttrViewBoundNodes(attrView *av.AttributeView) (ret []*ast.Node) {
  1674. blockKeyValues := attrView.GetBlockKeyValues()
  1675. treeMap := map[string]*parse.Tree{}
  1676. for _, blockKeyValue := range blockKeyValues.Values {
  1677. if blockKeyValue.IsDetached {
  1678. continue
  1679. }
  1680. var tree *parse.Tree
  1681. tree = treeMap[blockKeyValue.BlockID]
  1682. if nil == tree {
  1683. tree, _ = LoadTreeByBlockID(blockKeyValue.BlockID)
  1684. }
  1685. if nil == tree {
  1686. continue
  1687. }
  1688. treeMap[blockKeyValue.BlockID] = tree
  1689. node := treenode.GetNodeInTree(tree, blockKeyValue.BlockID)
  1690. if nil == node {
  1691. continue
  1692. }
  1693. ret = append(ret, node)
  1694. }
  1695. return
  1696. }
  1697. func (tx *Transaction) doSetAttrViewFilters(operation *Operation) (ret *TxErr) {
  1698. err := setAttributeViewFilters(operation)
  1699. if nil != err {
  1700. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  1701. }
  1702. return
  1703. }
  1704. func setAttributeViewFilters(operation *Operation) (err error) {
  1705. attrView, err := av.ParseAttributeView(operation.AvID)
  1706. if nil != err {
  1707. return
  1708. }
  1709. view, err := getAttrViewViewByBlockID(attrView, operation.BlockID)
  1710. if nil != err {
  1711. return
  1712. }
  1713. operationData := operation.Data.([]interface{})
  1714. data, err := gulu.JSON.MarshalJSON(operationData)
  1715. if nil != err {
  1716. return
  1717. }
  1718. switch view.LayoutType {
  1719. case av.LayoutTypeTable:
  1720. if err = gulu.JSON.UnmarshalJSON(data, &view.Table.Filters); nil != err {
  1721. return
  1722. }
  1723. }
  1724. err = av.SaveAttributeView(attrView)
  1725. return
  1726. }
  1727. func (tx *Transaction) doSetAttrViewSorts(operation *Operation) (ret *TxErr) {
  1728. err := setAttributeViewSorts(operation)
  1729. if nil != err {
  1730. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  1731. }
  1732. return
  1733. }
  1734. func setAttributeViewSorts(operation *Operation) (err error) {
  1735. attrView, err := av.ParseAttributeView(operation.AvID)
  1736. if nil != err {
  1737. return
  1738. }
  1739. view, err := getAttrViewViewByBlockID(attrView, operation.BlockID)
  1740. if nil != err {
  1741. return
  1742. }
  1743. operationData := operation.Data.([]interface{})
  1744. data, err := gulu.JSON.MarshalJSON(operationData)
  1745. if nil != err {
  1746. return
  1747. }
  1748. switch view.LayoutType {
  1749. case av.LayoutTypeTable:
  1750. if err = gulu.JSON.UnmarshalJSON(data, &view.Table.Sorts); nil != err {
  1751. return
  1752. }
  1753. }
  1754. err = av.SaveAttributeView(attrView)
  1755. return
  1756. }
  1757. func (tx *Transaction) doSetAttrViewPageSize(operation *Operation) (ret *TxErr) {
  1758. err := setAttributeViewPageSize(operation)
  1759. if nil != err {
  1760. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  1761. }
  1762. return
  1763. }
  1764. func setAttributeViewPageSize(operation *Operation) (err error) {
  1765. attrView, err := av.ParseAttributeView(operation.AvID)
  1766. if nil != err {
  1767. return
  1768. }
  1769. view, err := getAttrViewViewByBlockID(attrView, operation.BlockID)
  1770. if nil != err {
  1771. return
  1772. }
  1773. switch view.LayoutType {
  1774. case av.LayoutTypeTable:
  1775. view.Table.PageSize = int(operation.Data.(float64))
  1776. }
  1777. err = av.SaveAttributeView(attrView)
  1778. return
  1779. }
  1780. func (tx *Transaction) doSetAttrViewColCalc(operation *Operation) (ret *TxErr) {
  1781. err := setAttributeViewColumnCalc(operation)
  1782. if nil != err {
  1783. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  1784. }
  1785. return
  1786. }
  1787. func setAttributeViewColumnCalc(operation *Operation) (err error) {
  1788. attrView, err := av.ParseAttributeView(operation.AvID)
  1789. if nil != err {
  1790. return
  1791. }
  1792. view, err := getAttrViewViewByBlockID(attrView, operation.BlockID)
  1793. if nil != err {
  1794. return
  1795. }
  1796. operationData := operation.Data.(interface{})
  1797. data, err := gulu.JSON.MarshalJSON(operationData)
  1798. if nil != err {
  1799. return
  1800. }
  1801. calc := &av.ColumnCalc{}
  1802. switch view.LayoutType {
  1803. case av.LayoutTypeTable:
  1804. if err = gulu.JSON.UnmarshalJSON(data, calc); nil != err {
  1805. return
  1806. }
  1807. for _, column := range view.Table.Columns {
  1808. if column.ID == operation.ID {
  1809. column.Calc = calc
  1810. break
  1811. }
  1812. }
  1813. }
  1814. err = av.SaveAttributeView(attrView)
  1815. return
  1816. }
  1817. func (tx *Transaction) doInsertAttrViewBlock(operation *Operation) (ret *TxErr) {
  1818. err := AddAttributeViewBlock(tx, operation.SrcIDs, operation.AvID, operation.BlockID, operation.PreviousID, operation.IsDetached, operation.IgnoreFillFilterVal)
  1819. if nil != err {
  1820. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  1821. }
  1822. return
  1823. }
  1824. func AddAttributeViewBlock(tx *Transaction, srcIDs []string, avID, blockID, previousBlockID string, isDetached, ignoreFillFilter bool) (err error) {
  1825. for _, id := range srcIDs {
  1826. var tree *parse.Tree
  1827. if !isDetached {
  1828. var loadErr error
  1829. if nil != tx {
  1830. tree, loadErr = tx.loadTree(id)
  1831. } else {
  1832. tree, loadErr = LoadTreeByBlockID(id)
  1833. }
  1834. if nil != loadErr {
  1835. logging.LogErrorf("load tree [%s] failed: %s", id, err)
  1836. return loadErr
  1837. }
  1838. }
  1839. if avErr := addAttributeViewBlock(avID, blockID, previousBlockID, id, isDetached, ignoreFillFilter, tree, tx); nil != avErr {
  1840. return avErr
  1841. }
  1842. }
  1843. return
  1844. }
  1845. func addAttributeViewBlock(avID, blockID, previousBlockID, addingBlockID string, isDetached, ignoreFillFilter bool, tree *parse.Tree, tx *Transaction) (err error) {
  1846. var node *ast.Node
  1847. if !isDetached {
  1848. node = treenode.GetNodeInTree(tree, addingBlockID)
  1849. if nil == node {
  1850. err = ErrBlockNotFound
  1851. return
  1852. }
  1853. } else {
  1854. if "" == addingBlockID {
  1855. addingBlockID = ast.NewNodeID()
  1856. logging.LogWarnf("detached block id is empty, generate a new one [%s]", addingBlockID)
  1857. }
  1858. }
  1859. attrView, err := av.ParseAttributeView(avID)
  1860. if nil != err {
  1861. return
  1862. }
  1863. var content string
  1864. if !isDetached {
  1865. content = getNodeRefText(node)
  1866. }
  1867. now := time.Now().UnixMilli()
  1868. // 检查是否重复添加相同的块
  1869. blockValues := attrView.GetBlockKeyValues()
  1870. for _, blockValue := range blockValues.Values {
  1871. if blockValue.Block.ID == addingBlockID {
  1872. if !isDetached {
  1873. // 重复绑定一下,比如剪切数据库块、取消绑定块后再次添加的场景需要
  1874. bindBlockAv0(tx, avID, node, tree)
  1875. blockValue.IsDetached = isDetached
  1876. blockValue.Block.Content = content
  1877. blockValue.UpdatedAt = now
  1878. util.PushMsg(Conf.language(242), 3000)
  1879. err = av.SaveAttributeView(attrView)
  1880. }
  1881. return
  1882. }
  1883. }
  1884. blockValue := &av.Value{
  1885. ID: ast.NewNodeID(),
  1886. KeyID: blockValues.Key.ID,
  1887. BlockID: addingBlockID,
  1888. Type: av.KeyTypeBlock,
  1889. IsDetached: isDetached,
  1890. CreatedAt: now,
  1891. UpdatedAt: now,
  1892. Block: &av.ValueBlock{ID: addingBlockID, Content: content, Created: now, Updated: now}}
  1893. blockValues.Values = append(blockValues.Values, blockValue)
  1894. // 如果存在过滤条件,则将过滤条件应用到新添加的块上
  1895. view, _ := getAttrViewViewByBlockID(attrView, blockID)
  1896. if nil != view && 0 < len(view.Table.Filters) && !ignoreFillFilter {
  1897. viewable, _ := renderAttributeViewTable(attrView, view, "")
  1898. viewable.FilterRows(attrView)
  1899. viewable.SortRows(attrView)
  1900. var nearRow *av.TableRow
  1901. if 0 < len(viewable.Rows) {
  1902. if "" != previousBlockID {
  1903. for _, row := range viewable.Rows {
  1904. if row.ID == previousBlockID {
  1905. nearRow = row
  1906. break
  1907. }
  1908. }
  1909. } else {
  1910. if 0 < len(viewable.Rows) {
  1911. nearRow = viewable.Rows[0]
  1912. }
  1913. }
  1914. }
  1915. sameKeyFilterSort := false // 是否在同一个字段上同时存在过滤和排序
  1916. if 0 < len(viewable.Sorts) {
  1917. filterKeys, sortKeys := map[string]bool{}, map[string]bool{}
  1918. for _, f := range view.Table.Filters {
  1919. filterKeys[f.Column] = true
  1920. }
  1921. for _, s := range view.Table.Sorts {
  1922. sortKeys[s.Column] = true
  1923. }
  1924. for key := range filterKeys {
  1925. if sortKeys[key] {
  1926. sameKeyFilterSort = true
  1927. break
  1928. }
  1929. }
  1930. }
  1931. if !sameKeyFilterSort {
  1932. // 如果在同一个字段上仅存在过滤条件,则将过滤条件应用到新添加的块上
  1933. for _, filter := range view.Table.Filters {
  1934. for _, keyValues := range attrView.KeyValues {
  1935. if keyValues.Key.ID == filter.Column {
  1936. var defaultVal *av.Value
  1937. if nil != nearRow {
  1938. defaultVal = nearRow.GetValue(filter.Column)
  1939. }
  1940. newValue := filter.GetAffectValue(keyValues.Key, defaultVal)
  1941. if nil == newValue {
  1942. continue
  1943. }
  1944. newValue.ID = ast.NewNodeID()
  1945. newValue.KeyID = keyValues.Key.ID
  1946. newValue.BlockID = addingBlockID
  1947. newValue.IsDetached = isDetached
  1948. keyValues.Values = append(keyValues.Values, newValue)
  1949. break
  1950. }
  1951. }
  1952. }
  1953. }
  1954. }
  1955. // 处理日期字段默认填充当前创建时间
  1956. // The database date field supports filling the current time by default https://github.com/siyuan-note/siyuan/issues/10823
  1957. for _, keyValues := range attrView.KeyValues {
  1958. if av.KeyTypeDate == keyValues.Key.Type && nil != keyValues.Key.Date && keyValues.Key.Date.AutoFillNow {
  1959. dateVal := &av.Value{
  1960. ID: ast.NewNodeID(), KeyID: keyValues.Key.ID, BlockID: addingBlockID, Type: av.KeyTypeDate, IsDetached: isDetached, CreatedAt: now, UpdatedAt: now + 1000,
  1961. Date: &av.ValueDate{Content: now, IsNotEmpty: true},
  1962. }
  1963. keyValues.Values = append(keyValues.Values, dateVal)
  1964. }
  1965. }
  1966. if !isDetached {
  1967. bindBlockAv0(tx, avID, node, tree)
  1968. }
  1969. for _, v := range attrView.Views {
  1970. switch v.LayoutType {
  1971. case av.LayoutTypeTable:
  1972. if "" != previousBlockID {
  1973. changed := false
  1974. for i, id := range v.Table.RowIDs {
  1975. if id == previousBlockID {
  1976. v.Table.RowIDs = append(v.Table.RowIDs[:i+1], append([]string{addingBlockID}, v.Table.RowIDs[i+1:]...)...)
  1977. changed = true
  1978. break
  1979. }
  1980. }
  1981. if !changed {
  1982. v.Table.RowIDs = append(v.Table.RowIDs, addingBlockID)
  1983. }
  1984. } else {
  1985. v.Table.RowIDs = append([]string{addingBlockID}, v.Table.RowIDs...)
  1986. }
  1987. }
  1988. }
  1989. err = av.SaveAttributeView(attrView)
  1990. return
  1991. }
  1992. func (tx *Transaction) doRemoveAttrViewBlock(operation *Operation) (ret *TxErr) {
  1993. err := removeAttributeViewBlock(operation.SrcIDs, operation.AvID, tx)
  1994. if nil != err {
  1995. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID}
  1996. }
  1997. return
  1998. }
  1999. func RemoveAttributeViewBlock(srcIDs []string, avID string) (err error) {
  2000. err = removeAttributeViewBlock(srcIDs, avID, nil)
  2001. return
  2002. }
  2003. func removeAttributeViewBlock(srcIDs []string, avID string, tx *Transaction) (err error) {
  2004. attrView, err := av.ParseAttributeView(avID)
  2005. if nil != err {
  2006. return
  2007. }
  2008. trees := map[string]*parse.Tree{}
  2009. for _, keyValues := range attrView.KeyValues {
  2010. tmp := keyValues.Values[:0]
  2011. for i, values := range keyValues.Values {
  2012. if !gulu.Str.Contains(values.BlockID, srcIDs) {
  2013. tmp = append(tmp, keyValues.Values[i])
  2014. } else {
  2015. // Remove av block also remove node attr https://github.com/siyuan-note/siyuan/issues/9091#issuecomment-1709824006
  2016. if bt := treenode.GetBlockTree(values.BlockID); nil != bt {
  2017. tree := trees[bt.RootID]
  2018. if nil == tree {
  2019. tree, _ = LoadTreeByBlockID(values.BlockID)
  2020. }
  2021. if nil != tree {
  2022. trees[bt.RootID] = tree
  2023. if node := treenode.GetNodeInTree(tree, values.BlockID); nil != node {
  2024. if err = removeNodeAvID(node, avID, tx, tree); nil != err {
  2025. return
  2026. }
  2027. }
  2028. }
  2029. }
  2030. }
  2031. }
  2032. keyValues.Values = tmp
  2033. }
  2034. for _, view := range attrView.Views {
  2035. for _, blockID := range srcIDs {
  2036. view.Table.RowIDs = gulu.Str.RemoveElem(view.Table.RowIDs, blockID)
  2037. }
  2038. }
  2039. relatedAvIDs := av.GetSrcAvIDs(avID)
  2040. for _, relatedAvID := range relatedAvIDs {
  2041. util.BroadcastByType("protyle", "refreshAttributeView", 0, "", map[string]interface{}{"id": relatedAvID})
  2042. }
  2043. err = av.SaveAttributeView(attrView)
  2044. return
  2045. }
  2046. func removeNodeAvID(node *ast.Node, avID string, tx *Transaction, tree *parse.Tree) (err error) {
  2047. attrs := parse.IAL2Map(node.KramdownIAL)
  2048. if ast.NodeDocument == node.Type {
  2049. delete(attrs, "custom-hidden")
  2050. node.RemoveIALAttr("custom-hidden")
  2051. }
  2052. if avs := attrs[av.NodeAttrNameAvs]; "" != avs {
  2053. avIDs := strings.Split(avs, ",")
  2054. avIDs = gulu.Str.RemoveElem(avIDs, avID)
  2055. var existAvIDs []string
  2056. for _, attributeViewID := range avIDs {
  2057. if av.IsAttributeViewExist(attributeViewID) {
  2058. existAvIDs = append(existAvIDs, attributeViewID)
  2059. }
  2060. }
  2061. avIDs = existAvIDs
  2062. if 0 == len(avIDs) {
  2063. attrs[av.NodeAttrNameAvs] = ""
  2064. } else {
  2065. attrs[av.NodeAttrNameAvs] = strings.Join(avIDs, ",")
  2066. node.SetIALAttr(av.NodeAttrNameAvs, strings.Join(avIDs, ","))
  2067. avNames := getAvNames(node.IALAttr(av.NodeAttrNameAvs))
  2068. attrs[av.NodeAttrViewNames] = avNames
  2069. }
  2070. }
  2071. if nil != tx {
  2072. if err = setNodeAttrsWithTx(tx, node, tree, attrs); nil != err {
  2073. return
  2074. }
  2075. } else {
  2076. if err = setNodeAttrs(node, tree, attrs); nil != err {
  2077. return
  2078. }
  2079. }
  2080. return
  2081. }
  2082. func (tx *Transaction) doSetAttrViewColumnWidth(operation *Operation) (ret *TxErr) {
  2083. err := setAttributeViewColWidth(operation)
  2084. if nil != err {
  2085. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2086. }
  2087. return
  2088. }
  2089. func setAttributeViewColWidth(operation *Operation) (err error) {
  2090. attrView, err := av.ParseAttributeView(operation.AvID)
  2091. if nil != err {
  2092. return
  2093. }
  2094. view, err := getAttrViewViewByBlockID(attrView, operation.BlockID)
  2095. if nil != err {
  2096. return
  2097. }
  2098. switch view.LayoutType {
  2099. case av.LayoutTypeTable:
  2100. for _, column := range view.Table.Columns {
  2101. if column.ID == operation.ID {
  2102. column.Width = operation.Data.(string)
  2103. break
  2104. }
  2105. }
  2106. }
  2107. err = av.SaveAttributeView(attrView)
  2108. return
  2109. }
  2110. func (tx *Transaction) doSetAttrViewColumnWrap(operation *Operation) (ret *TxErr) {
  2111. err := setAttributeViewColWrap(operation)
  2112. if nil != err {
  2113. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2114. }
  2115. return
  2116. }
  2117. func setAttributeViewColWrap(operation *Operation) (err error) {
  2118. attrView, err := av.ParseAttributeView(operation.AvID)
  2119. if nil != err {
  2120. return
  2121. }
  2122. view, err := getAttrViewViewByBlockID(attrView, operation.BlockID)
  2123. if nil != err {
  2124. return
  2125. }
  2126. switch view.LayoutType {
  2127. case av.LayoutTypeTable:
  2128. for _, column := range view.Table.Columns {
  2129. if column.ID == operation.ID {
  2130. column.Wrap = operation.Data.(bool)
  2131. break
  2132. }
  2133. }
  2134. }
  2135. err = av.SaveAttributeView(attrView)
  2136. return
  2137. }
  2138. func (tx *Transaction) doSetAttrViewColumnHidden(operation *Operation) (ret *TxErr) {
  2139. err := setAttributeViewColHidden(operation)
  2140. if nil != err {
  2141. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2142. }
  2143. return
  2144. }
  2145. func setAttributeViewColHidden(operation *Operation) (err error) {
  2146. attrView, err := av.ParseAttributeView(operation.AvID)
  2147. if nil != err {
  2148. return
  2149. }
  2150. view, err := getAttrViewViewByBlockID(attrView, operation.BlockID)
  2151. if nil != err {
  2152. return
  2153. }
  2154. switch view.LayoutType {
  2155. case av.LayoutTypeTable:
  2156. for _, column := range view.Table.Columns {
  2157. if column.ID == operation.ID {
  2158. column.Hidden = operation.Data.(bool)
  2159. break
  2160. }
  2161. }
  2162. }
  2163. err = av.SaveAttributeView(attrView)
  2164. return
  2165. }
  2166. func (tx *Transaction) doSetAttrViewColumnPin(operation *Operation) (ret *TxErr) {
  2167. err := setAttributeViewColPin(operation)
  2168. if nil != err {
  2169. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2170. }
  2171. return
  2172. }
  2173. func setAttributeViewColPin(operation *Operation) (err error) {
  2174. attrView, err := av.ParseAttributeView(operation.AvID)
  2175. if nil != err {
  2176. return
  2177. }
  2178. view, err := getAttrViewViewByBlockID(attrView, operation.BlockID)
  2179. if nil != err {
  2180. return
  2181. }
  2182. switch view.LayoutType {
  2183. case av.LayoutTypeTable:
  2184. for _, column := range view.Table.Columns {
  2185. if column.ID == operation.ID {
  2186. column.Pin = operation.Data.(bool)
  2187. break
  2188. }
  2189. }
  2190. }
  2191. err = av.SaveAttributeView(attrView)
  2192. return
  2193. }
  2194. func (tx *Transaction) doSetAttrViewColumnIcon(operation *Operation) (ret *TxErr) {
  2195. err := setAttributeViewColIcon(operation)
  2196. if nil != err {
  2197. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2198. }
  2199. return
  2200. }
  2201. func setAttributeViewColIcon(operation *Operation) (err error) {
  2202. attrView, err := av.ParseAttributeView(operation.AvID)
  2203. if nil != err {
  2204. return
  2205. }
  2206. for _, keyValues := range attrView.KeyValues {
  2207. if keyValues.Key.ID == operation.ID {
  2208. keyValues.Key.Icon = operation.Data.(string)
  2209. break
  2210. }
  2211. }
  2212. err = av.SaveAttributeView(attrView)
  2213. return
  2214. }
  2215. func (tx *Transaction) doSortAttrViewRow(operation *Operation) (ret *TxErr) {
  2216. err := sortAttributeViewRow(operation)
  2217. if nil != err {
  2218. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2219. }
  2220. return
  2221. }
  2222. func sortAttributeViewRow(operation *Operation) (err error) {
  2223. attrView, err := av.ParseAttributeView(operation.AvID)
  2224. if nil != err {
  2225. return
  2226. }
  2227. view, err := getAttrViewViewByBlockID(attrView, operation.BlockID)
  2228. if nil != err {
  2229. return
  2230. }
  2231. var rowID string
  2232. var index, previousIndex int
  2233. for i, r := range view.Table.RowIDs {
  2234. if r == operation.ID {
  2235. rowID = r
  2236. index = i
  2237. break
  2238. }
  2239. }
  2240. if "" == rowID {
  2241. rowID = operation.ID
  2242. view.Table.RowIDs = append(view.Table.RowIDs, rowID)
  2243. index = len(view.Table.RowIDs) - 1
  2244. }
  2245. switch view.LayoutType {
  2246. case av.LayoutTypeTable:
  2247. view.Table.RowIDs = append(view.Table.RowIDs[:index], view.Table.RowIDs[index+1:]...)
  2248. for i, r := range view.Table.RowIDs {
  2249. if r == operation.PreviousID {
  2250. previousIndex = i + 1
  2251. break
  2252. }
  2253. }
  2254. view.Table.RowIDs = util.InsertElem(view.Table.RowIDs, previousIndex, rowID)
  2255. }
  2256. err = av.SaveAttributeView(attrView)
  2257. return
  2258. }
  2259. func (tx *Transaction) doSortAttrViewColumn(operation *Operation) (ret *TxErr) {
  2260. err := SortAttributeViewKey(operation.AvID, operation.BlockID, operation.ID, operation.PreviousID)
  2261. if nil != err {
  2262. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2263. }
  2264. return
  2265. }
  2266. func SortAttributeViewKey(avID, blockID, keyID, previousKeyID string) (err error) {
  2267. attrView, err := av.ParseAttributeView(avID)
  2268. if nil != err {
  2269. return
  2270. }
  2271. view, err := getAttrViewViewByBlockID(attrView, blockID)
  2272. if nil != err {
  2273. return
  2274. }
  2275. switch view.LayoutType {
  2276. case av.LayoutTypeTable:
  2277. var col *av.ViewTableColumn
  2278. var index, previousIndex int
  2279. for i, column := range view.Table.Columns {
  2280. if column.ID == keyID {
  2281. col = column
  2282. index = i
  2283. break
  2284. }
  2285. }
  2286. if nil == col {
  2287. return
  2288. }
  2289. view.Table.Columns = append(view.Table.Columns[:index], view.Table.Columns[index+1:]...)
  2290. for i, column := range view.Table.Columns {
  2291. if column.ID == previousKeyID {
  2292. previousIndex = i + 1
  2293. break
  2294. }
  2295. }
  2296. view.Table.Columns = util.InsertElem(view.Table.Columns, previousIndex, col)
  2297. }
  2298. err = av.SaveAttributeView(attrView)
  2299. return
  2300. }
  2301. func (tx *Transaction) doAddAttrViewColumn(operation *Operation) (ret *TxErr) {
  2302. var icon string
  2303. if nil != operation.Data {
  2304. icon = operation.Data.(string)
  2305. }
  2306. err := AddAttributeViewKey(operation.AvID, operation.ID, operation.Name, operation.Typ, icon, operation.PreviousID)
  2307. if nil != err {
  2308. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2309. }
  2310. return
  2311. }
  2312. func AddAttributeViewKey(avID, keyID, keyName, keyType, keyIcon, previousKeyID string) (err error) {
  2313. attrView, err := av.ParseAttributeView(avID)
  2314. if nil != err {
  2315. return
  2316. }
  2317. keyTyp := av.KeyType(keyType)
  2318. switch keyTyp {
  2319. case av.KeyTypeText, av.KeyTypeNumber, av.KeyTypeDate, av.KeyTypeSelect, av.KeyTypeMSelect, av.KeyTypeURL, av.KeyTypeEmail,
  2320. av.KeyTypePhone, av.KeyTypeMAsset, av.KeyTypeTemplate, av.KeyTypeCreated, av.KeyTypeUpdated, av.KeyTypeCheckbox,
  2321. av.KeyTypeRelation, av.KeyTypeRollup:
  2322. key := av.NewKey(keyID, keyName, keyIcon, keyTyp)
  2323. if av.KeyTypeRollup == keyTyp {
  2324. key.Rollup = &av.Rollup{Calc: &av.RollupCalc{Operator: av.CalcOperatorNone}}
  2325. }
  2326. attrView.KeyValues = append(attrView.KeyValues, &av.KeyValues{Key: key})
  2327. for _, view := range attrView.Views {
  2328. switch view.LayoutType {
  2329. case av.LayoutTypeTable:
  2330. if "" == previousKeyID {
  2331. view.Table.Columns = append([]*av.ViewTableColumn{{ID: key.ID}}, view.Table.Columns...)
  2332. break
  2333. }
  2334. added := false
  2335. for i, column := range view.Table.Columns {
  2336. if column.ID == previousKeyID {
  2337. view.Table.Columns = append(view.Table.Columns[:i+1], append([]*av.ViewTableColumn{{ID: key.ID}}, view.Table.Columns[i+1:]...)...)
  2338. added = true
  2339. break
  2340. }
  2341. }
  2342. if !added {
  2343. view.Table.Columns = append(view.Table.Columns, &av.ViewTableColumn{ID: key.ID})
  2344. }
  2345. }
  2346. }
  2347. }
  2348. err = av.SaveAttributeView(attrView)
  2349. return
  2350. }
  2351. func (tx *Transaction) doUpdateAttrViewColTemplate(operation *Operation) (ret *TxErr) {
  2352. err := updateAttributeViewColTemplate(operation)
  2353. if nil != err {
  2354. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2355. }
  2356. return
  2357. }
  2358. func updateAttributeViewColTemplate(operation *Operation) (err error) {
  2359. attrView, err := av.ParseAttributeView(operation.AvID)
  2360. if nil != err {
  2361. return
  2362. }
  2363. colType := av.KeyType(operation.Typ)
  2364. switch colType {
  2365. case av.KeyTypeTemplate:
  2366. for _, keyValues := range attrView.KeyValues {
  2367. if keyValues.Key.ID == operation.ID && av.KeyTypeTemplate == keyValues.Key.Type {
  2368. keyValues.Key.Template = operation.Data.(string)
  2369. break
  2370. }
  2371. }
  2372. }
  2373. err = av.SaveAttributeView(attrView)
  2374. return
  2375. }
  2376. func (tx *Transaction) doUpdateAttrViewColNumberFormat(operation *Operation) (ret *TxErr) {
  2377. err := updateAttributeViewColNumberFormat(operation)
  2378. if nil != err {
  2379. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2380. }
  2381. return
  2382. }
  2383. func updateAttributeViewColNumberFormat(operation *Operation) (err error) {
  2384. attrView, err := av.ParseAttributeView(operation.AvID)
  2385. if nil != err {
  2386. return
  2387. }
  2388. colType := av.KeyType(operation.Typ)
  2389. switch colType {
  2390. case av.KeyTypeNumber:
  2391. for _, keyValues := range attrView.KeyValues {
  2392. if keyValues.Key.ID == operation.ID && av.KeyTypeNumber == keyValues.Key.Type {
  2393. keyValues.Key.NumberFormat = av.NumberFormat(operation.Format)
  2394. break
  2395. }
  2396. }
  2397. }
  2398. err = av.SaveAttributeView(attrView)
  2399. return
  2400. }
  2401. func (tx *Transaction) doUpdateAttrViewColumn(operation *Operation) (ret *TxErr) {
  2402. err := updateAttributeViewColumn(operation)
  2403. if nil != err {
  2404. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2405. }
  2406. return
  2407. }
  2408. func updateAttributeViewColumn(operation *Operation) (err error) {
  2409. attrView, err := av.ParseAttributeView(operation.AvID)
  2410. if nil != err {
  2411. return
  2412. }
  2413. colType := av.KeyType(operation.Typ)
  2414. switch colType {
  2415. case av.KeyTypeBlock, av.KeyTypeText, av.KeyTypeNumber, av.KeyTypeDate, av.KeyTypeSelect, av.KeyTypeMSelect, av.KeyTypeURL, av.KeyTypeEmail,
  2416. av.KeyTypePhone, av.KeyTypeMAsset, av.KeyTypeTemplate, av.KeyTypeCreated, av.KeyTypeUpdated, av.KeyTypeCheckbox,
  2417. av.KeyTypeRelation, av.KeyTypeRollup:
  2418. for _, keyValues := range attrView.KeyValues {
  2419. if keyValues.Key.ID == operation.ID {
  2420. keyValues.Key.Name = strings.TrimSpace(operation.Name)
  2421. keyValues.Key.Type = colType
  2422. break
  2423. }
  2424. }
  2425. }
  2426. err = av.SaveAttributeView(attrView)
  2427. return
  2428. }
  2429. func (tx *Transaction) doRemoveAttrViewColumn(operation *Operation) (ret *TxErr) {
  2430. err := RemoveAttributeViewKey(operation.AvID, operation.ID)
  2431. if nil != err {
  2432. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2433. }
  2434. return
  2435. }
  2436. func RemoveAttributeViewKey(avID, keyID string) (err error) {
  2437. attrView, err := av.ParseAttributeView(avID)
  2438. if nil != err {
  2439. return
  2440. }
  2441. var removedKey *av.Key
  2442. for i, keyValues := range attrView.KeyValues {
  2443. if keyValues.Key.ID == keyID {
  2444. attrView.KeyValues = append(attrView.KeyValues[:i], attrView.KeyValues[i+1:]...)
  2445. removedKey = keyValues.Key
  2446. break
  2447. }
  2448. }
  2449. if nil != removedKey && av.KeyTypeRelation == removedKey.Type && nil != removedKey.Relation {
  2450. if removedKey.Relation.IsTwoWay {
  2451. // 删除双向关联的目标列
  2452. destAv, _ := av.ParseAttributeView(removedKey.Relation.AvID)
  2453. if nil != destAv {
  2454. destAvRelSrcAv := false
  2455. for i, keyValues := range destAv.KeyValues {
  2456. if keyValues.Key.ID == removedKey.Relation.BackKeyID {
  2457. destAv.KeyValues = append(destAv.KeyValues[:i], destAv.KeyValues[i+1:]...)
  2458. continue
  2459. }
  2460. if av.KeyTypeRelation == keyValues.Key.Type && keyValues.Key.Relation.AvID == attrView.ID {
  2461. destAvRelSrcAv = true
  2462. }
  2463. }
  2464. for _, view := range destAv.Views {
  2465. switch view.LayoutType {
  2466. case av.LayoutTypeTable:
  2467. for i, column := range view.Table.Columns {
  2468. if column.ID == removedKey.Relation.BackKeyID {
  2469. view.Table.Columns = append(view.Table.Columns[:i], view.Table.Columns[i+1:]...)
  2470. break
  2471. }
  2472. }
  2473. }
  2474. }
  2475. av.SaveAttributeView(destAv)
  2476. util.BroadcastByType("protyle", "refreshAttributeView", 0, "", map[string]interface{}{"id": destAv.ID})
  2477. if !destAvRelSrcAv {
  2478. av.RemoveAvRel(destAv.ID, attrView.ID)
  2479. }
  2480. }
  2481. srcAvRelDestAv := false
  2482. for _, keyValues := range attrView.KeyValues {
  2483. if av.KeyTypeRelation == keyValues.Key.Type && nil != keyValues.Key.Relation && keyValues.Key.Relation.AvID == removedKey.Relation.AvID {
  2484. srcAvRelDestAv = true
  2485. }
  2486. }
  2487. if !srcAvRelDestAv {
  2488. av.RemoveAvRel(attrView.ID, removedKey.Relation.AvID)
  2489. }
  2490. }
  2491. }
  2492. for _, view := range attrView.Views {
  2493. switch view.LayoutType {
  2494. case av.LayoutTypeTable:
  2495. for i, column := range view.Table.Columns {
  2496. if column.ID == keyID {
  2497. view.Table.Columns = append(view.Table.Columns[:i], view.Table.Columns[i+1:]...)
  2498. break
  2499. }
  2500. }
  2501. }
  2502. }
  2503. err = av.SaveAttributeView(attrView)
  2504. return
  2505. }
  2506. func (tx *Transaction) doReplaceAttrViewBlock(operation *Operation) (ret *TxErr) {
  2507. err := replaceAttributeViewBlock(operation, tx)
  2508. if nil != err {
  2509. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID}
  2510. }
  2511. return
  2512. }
  2513. func replaceAttributeViewBlock(operation *Operation, tx *Transaction) (err error) {
  2514. attrView, err := av.ParseAttributeView(operation.AvID)
  2515. if nil != err {
  2516. return
  2517. }
  2518. var node *ast.Node
  2519. if !operation.IsDetached {
  2520. node, _, _ = getNodeByBlockID(tx, operation.NextID)
  2521. }
  2522. // 检查是否已经存在绑定块
  2523. // Improve database primary key binding block https://github.com/siyuan-note/siyuan/issues/10945
  2524. for _, keyValues := range attrView.KeyValues {
  2525. for _, value := range keyValues.Values {
  2526. if value.BlockID == operation.NextID {
  2527. util.PushMsg(Conf.language(242), 3000)
  2528. return
  2529. }
  2530. }
  2531. }
  2532. for _, keyValues := range attrView.KeyValues {
  2533. for _, value := range keyValues.Values {
  2534. if value.BlockID == operation.PreviousID {
  2535. if value.BlockID != operation.NextID {
  2536. // 换绑
  2537. unbindBlockAv(tx, operation.AvID, value.BlockID)
  2538. }
  2539. value.BlockID = operation.NextID
  2540. if nil != value.Block {
  2541. value.Block.ID = operation.NextID
  2542. value.IsDetached = operation.IsDetached
  2543. if !operation.IsDetached {
  2544. value.Block.Content = getNodeRefText(node)
  2545. }
  2546. }
  2547. if !operation.IsDetached {
  2548. bindBlockAv(tx, operation.AvID, operation.NextID)
  2549. }
  2550. }
  2551. }
  2552. }
  2553. replacedRowID := false
  2554. for _, v := range attrView.Views {
  2555. switch v.LayoutType {
  2556. case av.LayoutTypeTable:
  2557. for i, rowID := range v.Table.RowIDs {
  2558. if rowID == operation.PreviousID {
  2559. v.Table.RowIDs[i] = operation.NextID
  2560. replacedRowID = true
  2561. break
  2562. }
  2563. }
  2564. if !replacedRowID {
  2565. v.Table.RowIDs = append(v.Table.RowIDs, operation.NextID)
  2566. }
  2567. }
  2568. }
  2569. err = av.SaveAttributeView(attrView)
  2570. return
  2571. }
  2572. func (tx *Transaction) doUpdateAttrViewCell(operation *Operation) (ret *TxErr) {
  2573. err := updateAttributeViewCell(operation, tx)
  2574. if nil != err {
  2575. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2576. }
  2577. return
  2578. }
  2579. func updateAttributeViewCell(operation *Operation, tx *Transaction) (err error) {
  2580. err = UpdateAttributeViewCell(tx, operation.AvID, operation.KeyID, operation.RowID, operation.ID, operation.Data)
  2581. return
  2582. }
  2583. func UpdateAttributeViewCell(tx *Transaction, avID, keyID, rowID, cellID string, valueData interface{}) (err error) {
  2584. attrView, err := av.ParseAttributeView(avID)
  2585. if nil != err {
  2586. return
  2587. }
  2588. var blockVal *av.Value
  2589. for _, kv := range attrView.KeyValues {
  2590. if av.KeyTypeBlock == kv.Key.Type {
  2591. for _, v := range kv.Values {
  2592. if rowID == v.Block.ID {
  2593. blockVal = v
  2594. break
  2595. }
  2596. }
  2597. break
  2598. }
  2599. }
  2600. now := time.Now().UnixMilli()
  2601. var val *av.Value
  2602. oldIsDetached := true
  2603. if nil != blockVal {
  2604. oldIsDetached = blockVal.IsDetached
  2605. }
  2606. for _, keyValues := range attrView.KeyValues {
  2607. if keyID != keyValues.Key.ID {
  2608. continue
  2609. }
  2610. for _, value := range keyValues.Values {
  2611. if cellID == value.ID {
  2612. val = value
  2613. val.Type = keyValues.Key.Type
  2614. break
  2615. }
  2616. }
  2617. if nil == val {
  2618. val = &av.Value{ID: cellID, KeyID: keyValues.Key.ID, BlockID: rowID, Type: keyValues.Key.Type, CreatedAt: now, UpdatedAt: now}
  2619. keyValues.Values = append(keyValues.Values, val)
  2620. }
  2621. break
  2622. }
  2623. isUpdatingBlockKey := av.KeyTypeBlock == val.Type
  2624. oldBoundBlockID := val.BlockID
  2625. var oldRelationBlockIDs []string
  2626. if av.KeyTypeRelation == val.Type {
  2627. if nil != val.Relation {
  2628. for _, bID := range val.Relation.BlockIDs {
  2629. oldRelationBlockIDs = append(oldRelationBlockIDs, bID)
  2630. }
  2631. }
  2632. }
  2633. data, err := gulu.JSON.MarshalJSON(valueData)
  2634. if nil != err {
  2635. return
  2636. }
  2637. if err = gulu.JSON.UnmarshalJSON(data, &val); nil != err {
  2638. return
  2639. }
  2640. if av.KeyTypeNumber == val.Type {
  2641. if nil != val.Number && !val.Number.IsNotEmpty {
  2642. val.Number.Content = 0
  2643. val.Number.FormattedContent = ""
  2644. }
  2645. } else if av.KeyTypeDate == val.Type {
  2646. if nil != val.Date && !val.Date.IsNotEmpty {
  2647. val.Date.Content = 0
  2648. val.Date.FormattedContent = ""
  2649. }
  2650. }
  2651. relationChangeMode := 0 // 0:不变(仅排序),1:增加,2:减少
  2652. if av.KeyTypeRelation == val.Type {
  2653. // 关联列得 content 是自动渲染的,所以不需要保存
  2654. val.Relation.Contents = nil
  2655. // 计算关联变更模式
  2656. if len(oldRelationBlockIDs) == len(val.Relation.BlockIDs) {
  2657. relationChangeMode = 0
  2658. } else {
  2659. if len(oldRelationBlockIDs) > len(val.Relation.BlockIDs) {
  2660. relationChangeMode = 2
  2661. } else {
  2662. relationChangeMode = 1
  2663. }
  2664. }
  2665. }
  2666. // val.IsDetached 只有更新主键的时候才会传入,所以下面需要结合 isUpdatingBlockKey 来判断
  2667. if oldIsDetached { // 之前是游离行
  2668. if !val.IsDetached { // 现在绑定了块
  2669. // 将游离行绑定到新建的块上
  2670. bindBlockAv(tx, avID, rowID)
  2671. }
  2672. } else { // 之前绑定了块
  2673. if isUpdatingBlockKey { // 正在更新主键
  2674. if val.IsDetached { // 现在是游离行
  2675. // 将绑定的块从属性视图中移除
  2676. unbindBlockAv(tx, avID, rowID)
  2677. } else { // 现在绑定了块
  2678. if oldBoundBlockID != val.BlockID { // 之前绑定的块和现在绑定的块不一样
  2679. // 换绑块
  2680. unbindBlockAv(tx, avID, oldBoundBlockID)
  2681. bindBlockAv(tx, avID, val.BlockID)
  2682. } else { // 之前绑定的块和现在绑定的块一样
  2683. // 直接返回,因为锚文本不允许更改
  2684. return
  2685. }
  2686. }
  2687. }
  2688. }
  2689. if nil != blockVal {
  2690. blockVal.Block.Updated = now
  2691. blockVal.SetUpdatedAt(now)
  2692. if isUpdatingBlockKey {
  2693. blockVal.IsDetached = val.IsDetached
  2694. }
  2695. }
  2696. val.SetUpdatedAt(now)
  2697. key, _ := attrView.GetKey(val.KeyID)
  2698. if nil != key && av.KeyTypeRelation == key.Type && nil != key.Relation {
  2699. destAv, _ := av.ParseAttributeView(key.Relation.AvID)
  2700. if nil != destAv {
  2701. if key.Relation.IsTwoWay {
  2702. // relationChangeMode
  2703. // 0:关联列值不变(仅排序),不影响目标值
  2704. // 1:关联列值增加,增加目标值
  2705. // 2:关联列值减少,减少目标值
  2706. if 1 == relationChangeMode {
  2707. addBlockIDs := val.Relation.BlockIDs
  2708. for _, bID := range oldRelationBlockIDs {
  2709. addBlockIDs = gulu.Str.RemoveElem(addBlockIDs, bID)
  2710. }
  2711. for _, blockID := range addBlockIDs {
  2712. for _, keyValues := range destAv.KeyValues {
  2713. if keyValues.Key.ID != key.Relation.BackKeyID {
  2714. continue
  2715. }
  2716. destVal := keyValues.GetValue(blockID)
  2717. if nil == destVal {
  2718. destVal = &av.Value{ID: ast.NewNodeID(), KeyID: keyValues.Key.ID, BlockID: blockID, Type: keyValues.Key.Type, Relation: &av.ValueRelation{}}
  2719. keyValues.Values = append(keyValues.Values, destVal)
  2720. }
  2721. destVal.Relation.BlockIDs = append(destVal.Relation.BlockIDs, rowID)
  2722. destVal.Relation.BlockIDs = gulu.Str.RemoveDuplicatedElem(destVal.Relation.BlockIDs)
  2723. destVal.SetUpdatedAt(now)
  2724. break
  2725. }
  2726. }
  2727. } else if 2 == relationChangeMode {
  2728. removeBlockIDs := oldRelationBlockIDs
  2729. for _, bID := range val.Relation.BlockIDs {
  2730. removeBlockIDs = gulu.Str.RemoveElem(removeBlockIDs, bID)
  2731. }
  2732. for _, blockID := range removeBlockIDs {
  2733. for _, keyValues := range destAv.KeyValues {
  2734. if keyValues.Key.ID != key.Relation.BackKeyID {
  2735. continue
  2736. }
  2737. for _, value := range keyValues.Values {
  2738. if value.BlockID == blockID {
  2739. value.Relation.BlockIDs = gulu.Str.RemoveElem(value.Relation.BlockIDs, rowID)
  2740. value.SetUpdatedAt(now)
  2741. break
  2742. }
  2743. }
  2744. }
  2745. }
  2746. }
  2747. av.SaveAttributeView(destAv)
  2748. }
  2749. }
  2750. }
  2751. relatedAvIDs := av.GetSrcAvIDs(avID)
  2752. for _, relatedAvID := range relatedAvIDs {
  2753. util.BroadcastByType("protyle", "refreshAttributeView", 0, "", map[string]interface{}{"id": relatedAvID})
  2754. }
  2755. if err = av.SaveAttributeView(attrView); nil != err {
  2756. return
  2757. }
  2758. return
  2759. }
  2760. func unbindBlockAv(tx *Transaction, avID, blockID string) {
  2761. node, tree, err := getNodeByBlockID(tx, blockID)
  2762. if nil != err {
  2763. return
  2764. }
  2765. attrs := parse.IAL2Map(node.KramdownIAL)
  2766. if "" == attrs[av.NodeAttrNameAvs] {
  2767. return
  2768. }
  2769. avIDs := strings.Split(attrs[av.NodeAttrNameAvs], ",")
  2770. avIDs = gulu.Str.RemoveElem(avIDs, avID)
  2771. if 0 == len(avIDs) {
  2772. delete(attrs, av.NodeAttrNameAvs)
  2773. node.RemoveIALAttr(av.NodeAttrNameAvs)
  2774. } else {
  2775. attrs[av.NodeAttrNameAvs] = strings.Join(avIDs, ",")
  2776. node.SetIALAttr(av.NodeAttrNameAvs, strings.Join(avIDs, ","))
  2777. }
  2778. avNames := getAvNames(attrs[av.NodeAttrNameAvs])
  2779. if "" != avNames {
  2780. attrs[av.NodeAttrViewNames] = avNames
  2781. }
  2782. if nil != tx {
  2783. err = setNodeAttrsWithTx(tx, node, tree, attrs)
  2784. } else {
  2785. err = setNodeAttrs(node, tree, attrs)
  2786. }
  2787. if nil != err {
  2788. logging.LogWarnf("set node [%s] attrs failed: %s", blockID, err)
  2789. return
  2790. }
  2791. return
  2792. }
  2793. func bindBlockAv(tx *Transaction, avID, blockID string) {
  2794. node, tree, err := getNodeByBlockID(tx, blockID)
  2795. if nil != err {
  2796. return
  2797. }
  2798. bindBlockAv0(tx, avID, node, tree)
  2799. return
  2800. }
  2801. func bindBlockAv0(tx *Transaction, avID string, node *ast.Node, tree *parse.Tree) {
  2802. attrs := parse.IAL2Map(node.KramdownIAL)
  2803. if "" == attrs[av.NodeAttrNameAvs] {
  2804. attrs[av.NodeAttrNameAvs] = avID
  2805. } else {
  2806. avIDs := strings.Split(attrs[av.NodeAttrNameAvs], ",")
  2807. avIDs = append(avIDs, avID)
  2808. avIDs = gulu.Str.RemoveDuplicatedElem(avIDs)
  2809. attrs[av.NodeAttrNameAvs] = strings.Join(avIDs, ",")
  2810. }
  2811. avNames := getAvNames(attrs[av.NodeAttrNameAvs])
  2812. if "" != avNames {
  2813. attrs[av.NodeAttrViewNames] = avNames
  2814. }
  2815. var err error
  2816. if nil != tx {
  2817. err = setNodeAttrsWithTx(tx, node, tree, attrs)
  2818. } else {
  2819. err = setNodeAttrs(node, tree, attrs)
  2820. }
  2821. if nil != err {
  2822. logging.LogWarnf("set node [%s] attrs failed: %s", node.ID, err)
  2823. return
  2824. }
  2825. return
  2826. }
  2827. func getNodeByBlockID(tx *Transaction, blockID string) (node *ast.Node, tree *parse.Tree, err error) {
  2828. if nil != tx {
  2829. tree, err = tx.loadTree(blockID)
  2830. } else {
  2831. tree, err = LoadTreeByBlockID(blockID)
  2832. }
  2833. if nil != err {
  2834. return
  2835. }
  2836. node = treenode.GetNodeInTree(tree, blockID)
  2837. if nil == node {
  2838. logging.LogWarnf("node [%s] not found in tree [%s]", blockID, tree.ID)
  2839. return
  2840. }
  2841. return
  2842. }
  2843. func (tx *Transaction) doUpdateAttrViewColOptions(operation *Operation) (ret *TxErr) {
  2844. err := updateAttributeViewColumnOptions(operation)
  2845. if nil != err {
  2846. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2847. }
  2848. return
  2849. }
  2850. func updateAttributeViewColumnOptions(operation *Operation) (err error) {
  2851. attrView, err := av.ParseAttributeView(operation.AvID)
  2852. if nil != err {
  2853. return
  2854. }
  2855. jsonData, err := gulu.JSON.MarshalJSON(operation.Data)
  2856. if nil != err {
  2857. return
  2858. }
  2859. options := []*av.SelectOption{}
  2860. if err = gulu.JSON.UnmarshalJSON(jsonData, &options); nil != err {
  2861. return
  2862. }
  2863. for _, keyValues := range attrView.KeyValues {
  2864. if keyValues.Key.ID == operation.ID {
  2865. keyValues.Key.Options = options
  2866. err = av.SaveAttributeView(attrView)
  2867. return
  2868. }
  2869. }
  2870. return
  2871. }
  2872. func (tx *Transaction) doRemoveAttrViewColOption(operation *Operation) (ret *TxErr) {
  2873. err := removeAttributeViewColumnOption(operation)
  2874. if nil != err {
  2875. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2876. }
  2877. return
  2878. }
  2879. func removeAttributeViewColumnOption(operation *Operation) (err error) {
  2880. attrView, err := av.ParseAttributeView(operation.AvID)
  2881. if nil != err {
  2882. return
  2883. }
  2884. optName := operation.Data.(string)
  2885. key, err := attrView.GetKey(operation.ID)
  2886. if nil != err {
  2887. return
  2888. }
  2889. for i, opt := range key.Options {
  2890. if optName == opt.Name {
  2891. key.Options = append(key.Options[:i], key.Options[i+1:]...)
  2892. break
  2893. }
  2894. }
  2895. for _, keyValues := range attrView.KeyValues {
  2896. if keyValues.Key.ID != operation.ID {
  2897. continue
  2898. }
  2899. for _, value := range keyValues.Values {
  2900. if nil == value || nil == value.MSelect {
  2901. continue
  2902. }
  2903. for i, opt := range value.MSelect {
  2904. if optName == opt.Content {
  2905. value.MSelect = append(value.MSelect[:i], value.MSelect[i+1:]...)
  2906. break
  2907. }
  2908. }
  2909. }
  2910. break
  2911. }
  2912. err = av.SaveAttributeView(attrView)
  2913. return
  2914. }
  2915. func (tx *Transaction) doUpdateAttrViewColOption(operation *Operation) (ret *TxErr) {
  2916. err := updateAttributeViewColumnOption(operation)
  2917. if nil != err {
  2918. return &TxErr{code: TxErrWriteAttributeView, id: operation.AvID, msg: err.Error()}
  2919. }
  2920. return
  2921. }
  2922. func updateAttributeViewColumnOption(operation *Operation) (err error) {
  2923. attrView, err := av.ParseAttributeView(operation.AvID)
  2924. if nil != err {
  2925. return
  2926. }
  2927. key, err := attrView.GetKey(operation.ID)
  2928. if nil != err {
  2929. return
  2930. }
  2931. data := operation.Data.(map[string]interface{})
  2932. oldName := data["oldName"].(string)
  2933. newName := data["newName"].(string)
  2934. newColor := data["newColor"].(string)
  2935. for i, opt := range key.Options {
  2936. if oldName == opt.Name {
  2937. key.Options[i].Name = newName
  2938. key.Options[i].Color = newColor
  2939. break
  2940. }
  2941. }
  2942. // 如果存在选项对应的值,需要更新值中的选项
  2943. for _, keyValues := range attrView.KeyValues {
  2944. if keyValues.Key.ID != operation.ID {
  2945. continue
  2946. }
  2947. for _, value := range keyValues.Values {
  2948. if nil == value || nil == value.MSelect {
  2949. continue
  2950. }
  2951. for i, opt := range value.MSelect {
  2952. if oldName == opt.Content {
  2953. value.MSelect[i].Content = newName
  2954. value.MSelect[i].Color = newColor
  2955. break
  2956. }
  2957. }
  2958. }
  2959. break
  2960. }
  2961. // 如果存在选项对应的过滤器,需要更新过滤器中设置的选项值
  2962. // Database select field filters follow option editing changes https://github.com/siyuan-note/siyuan/issues/10881
  2963. for _, view := range attrView.Views {
  2964. switch view.LayoutType {
  2965. case av.LayoutTypeTable:
  2966. table := view.Table
  2967. for _, filter := range table.Filters {
  2968. if filter.Column != key.ID {
  2969. continue
  2970. }
  2971. if nil != filter.Value && (av.KeyTypeSelect == filter.Value.Type || av.KeyTypeMSelect == filter.Value.Type) {
  2972. for i, opt := range filter.Value.MSelect {
  2973. if oldName == opt.Content {
  2974. filter.Value.MSelect[i].Content = newName
  2975. filter.Value.MSelect[i].Color = newColor
  2976. break
  2977. }
  2978. }
  2979. }
  2980. }
  2981. }
  2982. }
  2983. err = av.SaveAttributeView(attrView)
  2984. return
  2985. }
  2986. func getAttrViewViewByBlockID(attrView *av.AttributeView, blockID string) (ret *av.View, err error) {
  2987. node, _, _ := getNodeByBlockID(nil, blockID)
  2988. var viewID string
  2989. if nil != node {
  2990. viewID = node.IALAttr(av.NodeAttrView)
  2991. }
  2992. return attrView.GetCurrentView(viewID)
  2993. }