Something went wrong. Try again.
A privacy-first, self-hosted, fully open source personal knowledge management software, written in typescript and golang. (PERSONAL FORK)
Something went wrong. Try again.
Go
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846484748484849485048514852485348544855485648574858485948604861486248634864486548664867486848694870487148724873487448754876487748784879488048814882488348844885488648874888488948904891489248934894489548964897489848994900490149024903490449054906490749084909491049114912491349144915491649174918491949204921492249234924492549264927492849294930493149324933493449354936493749384939494049414942494349444945494649474948494949504951495249534954495549564957495849594960496149624963496449654966496749684969497049714972497349744975497649774978497949804981498249834984498549864987498849894990499149924993499449954996499749984999500050015002500350045005500650075008500950105011501250135014501550165017501850195020502150225023502450255026502750285029503050315032503350345035503650375038503950405041504250435044504550465047504850495050505150525053505450555056505750585059506050615062506350645065506650675068506950705071507250735074507550765077507850795080508150825083508450855086508750885089509050915092509350945095509650975098509951005101510251035104510551065107510851095110511151125113511451155116511751185119512051215122512351245125512651275128512951305131513251335134513551365137513851395140514151425143514451455146514751485149515051515152515351545155515651575158515951605161516251635164516551665167516851695170517151725173517451755176517751785179518051815182518351845185518651875188518951905191519251935194519551965197519851995200520152025203520452055206520752085209521052115212521352145215521652175218521952205221522252235224522552265227522852295230523152325233523452355236523752385239524052415242524352445245524652475248524952505251525252535254525552565257525852595260526152625263526452655266526752685269527052715272527352745275527652775278527952805281528252835284528552865287528852895290529152925293529452955296529752985299530053015302530353045305530653075308530953105311531253135314531553165317531853195320532153225323532453255326532753285329533053315332533353345335533653375338533953405341534253435344534553465347534853495350535153525353535453555356535753585359536053615362536353645365536653675368536953705371537253735374537553765377537853795380538153825383538453855386538753885389539053915392539353945395539653975398539954005401540254035404540554065407540854095410541154125413541454155416541754185419542054215422542354245425542654275428542954305431543254335434543554365437543854395440544154425443544454455446544754485449545054515452545354545455545654575458545954605461546254635464546554665467546854695470547154725473547454755476547754785479548054815482548354845485548654875488548954905491549254935494549554965497549854995500550155025503550455055506550755085509551055115512551355145515551655175518551955205521552255235524552555265527552855295530553155325533553455355536553755385539554055415542554355445545554655475548554955505551555255535554555555565557555855595560556155625563556455655566556755685569557055715572557355745575557655775578557955805581558255835584558555865587558855895590559155925593559455955596559755985599560056015602560356045605560656075608560956105611561256135614561556165617561856195620562156225623562456255626562756285629563056315632563356345635563656375638563956405641564256435644564556465647564856495650565156525653565456555656565756585659566056615662566356645665566656675668566956705671567256735674567556765677567856795680568156825683568456855686568756885689569056915692569356945695569656975698569957005701570257035704570557065707570857095710571157125713571457155716571757185719572057215722572357245725572657275728572957305731573257335734573557365737573857395740574157425743574457455746574757485749575057515752575357545755575657575758575957605761576257635764576557665767576857695770577157725773577457755776577757785779578057815782578357845785578657875788578957905791579257935794579557965797579857995800580158025803580458055806580758085809581058115812581358145815581658175818581958205821582258235824582558265827582858295830583158325833583458355836583758385839584058415842584358445845584658475848// SiYuan - Refactor your thinking// Copyright (c) 2020-present, b3log.org//// This program is free software: you can redistribute it and/or modify// it under the terms of the GNU Affero General Public License as published by// the Free Software Foundation, either version 3 of the License, or// (at your option) any later version.//// This program is distributed in the hope that it will be useful,// but WITHOUT ANY WARRANTY; without even the implied warranty of// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the// GNU Affero General Public License for more details.//// You should have received a copy of the GNU Affero General Public License// along with this program. If not, see <https://www.gnu.org/licenses/>.
package model
import ( "bytes" "fmt" "math/rand" "os" "path/filepath" "slices" "sort" "strconv" "strings" "time" "unicode/utf8"
"github.com/88250/go-humanize" "github.com/88250/gulu" "github.com/88250/lute/ast" "github.com/88250/lute/parse" "github.com/jinzhu/copier" "github.com/siyuan-note/filelock" "github.com/siyuan-note/logging" "github.com/siyuan-note/siyuan/kernel/av" "github.com/siyuan-note/siyuan/kernel/cache" "github.com/siyuan-note/siyuan/kernel/filesys" "github.com/siyuan-note/siyuan/kernel/search" "github.com/siyuan-note/siyuan/kernel/sql" "github.com/siyuan-note/siyuan/kernel/treenode" "github.com/siyuan-note/siyuan/kernel/util" "github.com/xrash/smetrics")
func RemoveUnusedAttributeView(id string) { absPath := filepath.Join(util.DataDir, "storage", "av", id+".json") if !filelock.IsExist(absPath) { return }
historyDir, err := GetHistoryDir(HistoryOpClean) if err != nil { logging.LogErrorf("get history dir failed: %s", err) return }
newP := strings.TrimPrefix(absPath, util.DataDir) historyPath := filepath.Join(historyDir, newP) if filelock.IsExist(absPath) { if err = filelock.Copy(absPath, historyPath); err != nil { return } }
if err = filelock.RemoveWithoutFatal(absPath); err != nil { logging.LogErrorf("remove unused asset [%s] failed: %s", absPath, err) util.PushErrMsg(fmt.Sprintf("%s", err), 7000) return }
IncSync()
indexHistoryDir(filepath.Base(historyDir), util.NewLute()) return}
func RemoveUnusedAttributeViews() (ret []string) { ret = []string{} var size int64
msgId := util.PushMsg(Conf.Language(100), 30*1000) defer func() { msg := fmt.Sprintf(Conf.Language(280), len(ret), humanize.BytesCustomCeil(uint64(size), 2)) util.PushUpdateMsg(msgId, msg, 7000) }()
unusedAttributeViews := UnusedAttributeViews(false)
historyDir, err := GetHistoryDir(HistoryOpClean) if err != nil { logging.LogErrorf("get history dir failed: %s", err) return }
for _, unusedAv := range unusedAttributeViews { id := unusedAv.Item srcPath := filepath.Join(util.DataDir, "storage", "av", id+".json") if filelock.IsExist(srcPath) { historyPath := filepath.Join(historyDir, "storage", "av", id+".json") if err = filelock.Copy(srcPath, historyPath); err != nil { return } } }
for _, unusedAv := range unusedAttributeViews { id := unusedAv.Item absPath := filepath.Join(util.DataDir, "storage", "av", id+".json") if filelock.IsExist(absPath) { info, statErr := os.Stat(absPath) if statErr == nil { size += info.Size() }
if removeErr := filelock.RemoveWithoutFatal(absPath); removeErr != nil { logging.LogErrorf("remove unused av [%s] failed: %s", absPath, removeErr) util.PushErrMsg(fmt.Sprintf("%s", removeErr), 7000) return } } ret = append(ret, absPath) } if 0 < len(ret) { IncSync() }
indexHistoryDir(filepath.Base(historyDir), util.NewLute()) return}
func UnusedAttributeViews(sorted bool) (ret []*UnusedItem) { defer logging.Recover() ret = []*UnusedItem{}
allAvIDs, err := getAllAvIDs() if err != nil { return }
docReferencedAvIDs := map[string]bool{} luteEngine := util.NewLute() boxes := Conf.GetBoxes() for _, box := range boxes { pages := pagedPaths(filepath.Join(util.DataDir, box.ID), 32) for _, paths := range pages { var trees []*parse.Tree for _, localPath := range paths { tree, loadTreeErr := loadTree(localPath, luteEngine) if nil != loadTreeErr { continue } trees = append(trees, tree) } for _, tree := range trees { for _, id := range getAvIDs(tree, allAvIDs) { docReferencedAvIDs[id] = true } } } }
templateAvIDs := search.FindAllMatchedTargets(filepath.Join(util.DataDir, "templates"), allAvIDs) for _, id := range templateAvIDs { docReferencedAvIDs[id] = true }
checkedAvIDs := map[string]bool{} for _, id := range allAvIDs { if !docReferencedAvIDs[id] && !isRelatedSrcAvDocReferenced(id, docReferencedAvIDs, checkedAvIDs) { name, _ := av.GetAttributeViewName(id)
var modTime time.Time if sorted { p := filepath.Join(util.DataDir, "storage", "av", id+".json") if info, statErr := os.Stat(p); nil == statErr { modTime = info.ModTime() } }
ret = append(ret, &UnusedItem{Item: id, Name: name, ModTime: modTime}) } }
if sorted { sort.Slice(ret, func(i, j int) bool { if !ret[i].ModTime.Equal(ret[j].ModTime) { return ret[i].ModTime.After(ret[j].ModTime) } return ret[i].Item > ret[j].Item }) } return}
func isRelatedSrcAvDocReferenced(destAvID string, docReferencedAvIDs, checkedAvIDs map[string]bool) bool { if checkedAvIDs[destAvID] { if docReferencedAvIDs[destAvID] { return true } return false } checkedAvIDs[destAvID] = true
srcAvIDs := av.GetSrcAvIDs(destAvID) srcAvIDs = gulu.Str.RemoveElem(srcAvIDs, destAvID) // 忽略自身关联 if 1 > len(srcAvIDs) { return false }
for _, srcAvID := range srcAvIDs { if docReferencedAvIDs[srcAvID] { return true } }
// 递归检查间接关联的 av for _, srcAvID := range srcAvIDs { if isRelatedSrcAvDocReferenced(srcAvID, docReferencedAvIDs, checkedAvIDs) { return true } } return false}
func getAvIDs(tree *parse.Tree, allAvIDs []string) (ret []string) { ast.Walk(tree.Root, func(n *ast.Node, entering bool) ast.WalkStatus { if !entering { return ast.WalkContinue }
if ast.NodeAttributeView == n.Type { ret = append(ret, n.AttributeViewID) }
for _, kv := range n.KramdownIAL { ids := util.GetContainsSubStrs(kv[1], allAvIDs) if 0 < len(ids) { ret = append(ret, ids...) } }
return ast.WalkContinue })
ret = gulu.Str.RemoveDuplicatedElem(ret) return}
func getAllAvIDs() (ret []string, err error) { ret = []string{}
entries, err := os.ReadDir(filepath.Join(util.DataDir, "storage", "av")) if nil != err { return }
for _, entry := range entries { name := entry.Name() if !strings.HasSuffix(name, ".json") { continue }
id := strings.TrimSuffix(name, ".json") if !ast.IsNodeIDPattern(id) { continue }
ret = append(ret, id) } ret = gulu.Str.RemoveDuplicatedElem(ret) return}
func GetAttributeViewItemIDs(avID string, blockIDs []string) (ret map[string]string) { ret = map[string]string{} for _, blockID := range blockIDs { ret[blockID] = "" }
attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return }
blockKv := attrView.GetBlockKeyValues() for _, b := range blockKv.Values { if _, ok := ret[b.Block.ID]; ok { ret[b.Block.ID] = b.BlockID } } return}
func GetAttributeViewBoundBlockIDs(avID string, itemIDs []string) (ret map[string]string) { ret = map[string]string{} for _, itemID := range itemIDs { ret[itemID] = "" }
attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return }
blockKv := attrView.GetBlockKeyValues() for _, b := range blockKv.Values { if _, ok := ret[b.BlockID]; ok { ret[b.BlockID] = b.Block.ID } } return}
func GetAttrViewAddingBlockDefaultValues(avID, viewID, groupID, previousBlockID, addingBlockID string) (ret map[string]*av.Value) { ret = map[string]*av.Value{}
attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return }
view, _ := attrView.GetCurrentView(viewID) if nil == view { logging.LogErrorf("view [%s] not found in attribute view [%s]", viewID, avID) return }
if 1 > len(view.Filters) && !view.IsGroupView() { // 没有过滤条件也没有分组条件时忽略 return }
groupView := view if "" != groupID { groupView = view.GetGroupByID(groupID) } if nil == groupView { logging.LogErrorf("group [%s] not found in view [%s] of attribute view [%s]", groupID, viewID, avID) return }
ret = getAttrViewAddingBlockDefaultValues(attrView, view, groupView, previousBlockID, addingBlockID, true) for _, value := range ret { // 主键都不返回内容，避免闪烁 https://github.com/siyuan-note/siyuan/issues/15561#issuecomment-3184746195 if av.KeyTypeBlock == value.Type { value.Block.Content = "" } } return}
func getAttrViewAddingBlockDefaultValues(attrView *av.AttributeView, view, groupView *av.View, previousItemID, addingItemID string, isCreate bool) (ret map[string]*av.Value) { ret = map[string]*av.Value{}
if 1 > len(view.Filters) && !view.IsGroupView() { // 没有过滤条件也没有分组条件时忽略 return }
nearItem := getNearItem(attrView, view, groupView, previousItemID)
// 使用模板或汇总进行过滤或分组时，需要解析涉及到的其他字段 templateRelevantKeys, rollupRelevantKeys := map[string][]*av.Key{}, map[string]*av.Key{} for _, keyValues := range attrView.KeyValues { if av.KeyTypeTemplate == keyValues.Key.Type { if tplRelevantKeys := sql.GetTemplateKeyRelevantKeys(attrView, keyValues.Key); 0 < len(tplRelevantKeys) { for _, k := range tplRelevantKeys { templateRelevantKeys[keyValues.Key.ID] = append(templateRelevantKeys[keyValues.Key.ID], k) } } } else if av.KeyTypeRollup == keyValues.Key.Type { if nil != keyValues.Key.Rollup { relKey, _ := attrView.GetKey(keyValues.Key.Rollup.RelationKeyID) if nil != relKey && nil != relKey.Relation { if attrView.ID == relKey.Relation.AvID { if k, _ := attrView.GetKey(keyValues.Key.Rollup.KeyID); nil != k { rollupRelevantKeys[k.ID] = k } } } } } }
filterKeyIDs := map[string]bool{} for _, filter := range view.Filters { filterKeyIDs[filter.Column] = true keyValues, _ := attrView.GetKeyValues(filter.Column) if nil == keyValues { continue }
if av.KeyTypeTemplate == keyValues.Key.Type && nil != nearItem { if keys := templateRelevantKeys[keyValues.Key.ID]; 0 < len(keys) { for _, k := range keys { if nil == ret[k.ID] { ret[k.ID] = getNewValueByNearItem(nearItem, k, addingItemID) } } } continue }
if av.KeyTypeRollup == keyValues.Key.Type && nil != nearItem { if relKey, ok := rollupRelevantKeys[keyValues.Key.ID]; ok { if nil == ret[relKey.ID] { ret[relKey.ID] = getNewValueByNearItem(nearItem, relKey, addingItemID) } } continue }
if av.KeyTypeMAsset == keyValues.Key.Type { if nil != nearItem { if _, ok := ret[keyValues.Key.ID]; !ok { ret[keyValues.Key.ID] = getNewValueByNearItem(nearItem, keyValues.Key, addingItemID) } } return }
newValue := filter.GetAffectValue(keyValues.Key, addingItemID) if nil == newValue { if filter.IsValid() { newValue = getNewValueByNearItem(nearItem, keyValues.Key, addingItemID) } } if nil != newValue { if av.KeyTypeDate == keyValues.Key.Type { if nil != nearItem { nearValue := getNewValueByNearItem(nearItem, keyValues.Key, addingItemID) newValue.Date.IsNotTime = nearValue.Date.IsNotTime }
if nil != keyValues.Key.Date && keyValues.Key.Date.AutoFillNow { newValue.Date.Content = time.Now().UnixMilli() newValue.Date.IsNotEmpty = true } }
ret[keyValues.Key.ID] = newValue } }
groupKey := view.GetGroupKey(attrView) if nil == groupKey { return }
keyValues, _ := attrView.GetKeyValues(groupKey.ID) if nil == keyValues { return }
newValue := getNewValueByNearItem(nearItem, groupKey, addingItemID) if av.KeyTypeSelect == groupKey.Type || av.KeyTypeMSelect == groupKey.Type { // 因为单选或多选只能按选项分组，并且可能存在空白分组（找不到临近项），所以单选或多选类型的分组字段使用分组值内容对应的选项 if opt := groupKey.GetOption(groupView.GetGroupValue()); nil != opt && groupValueDefault != groupView.GetGroupValue() { if nil == newValue { newValue = ret[groupKey.ID] // 如果没有临近项，则尝试从过滤结果中获取 } if nil == newValue { newValue = keyValues.GetValue(addingItemID) // 尝试从已有值中获取 }
if nil != newValue { if !av.MSelectExistOption(newValue.MSelect, groupView.GetGroupValue()) { if 1 > len(newValue.MSelect) || av.KeyTypeMSelect == groupKey.Type { newValue.MSelect = append(newValue.MSelect, &av.ValueSelect{Content: opt.Name, Color: opt.Color}) } else { newValue.MSelect = []*av.ValueSelect{{Content: opt.Name, Color: opt.Color}} } } else { var vals []*av.ValueSelect if isCreate { vals = append(vals, &av.ValueSelect{Content: opt.Name, Color: opt.Color}) } else { existingVal := keyValues.GetValue(addingItemID) if nil != existingVal { if !av.MSelectExistOption(existingVal.MSelect, opt.Name) { existingVal.MSelect = append(existingVal.MSelect, &av.ValueSelect{Content: opt.Name, Color: opt.Color}) } vals = existingVal.MSelect } else { vals = append(vals, &av.ValueSelect{Content: opt.Name, Color: opt.Color}) } }
// 添加过滤结果选项的值 if nil != ret[groupKey.ID] { for _, v := range ret[groupKey.ID].MSelect { if !av.MSelectExistOption(vals, v.Content) { vals = append(vals, v) } } } newValue.MSelect = vals } } else { newValue = av.GetAttributeViewDefaultValue(ast.NewNodeID(), groupKey.ID, addingItemID, groupKey.Type, false) newValue.MSelect = append(newValue.MSelect, &av.ValueSelect{Content: opt.Name, Color: opt.Color}) } }
if nil != newValue { ret[groupKey.ID] = newValue } return }
if av.KeyTypeTemplate == keyValues.Key.Type && nil != nearItem { if keys := templateRelevantKeys[keyValues.Key.ID]; 0 < len(keys) { for _, k := range keys { if nil == ret[k.ID] { ret[k.ID] = getNewValueByNearItem(nearItem, k, addingItemID) } } } return }
if av.KeyTypeRollup == keyValues.Key.Type && nil != nearItem { if relKey, ok := rollupRelevantKeys[keyValues.Key.ID]; ok { if nil == ret[relKey.ID] { ret[relKey.ID] = getNewValueByNearItem(nearItem, relKey, addingItemID) } } return }
if nil != nearItem && filterKeyIDs[groupKey.ID] { // 临近项不为空并且分组字段和过滤字段相同时，优先使用临近项 https://github.com/siyuan-note/siyuan/issues/15591 newValue = getNewValueByNearItem(nearItem, groupKey, addingItemID) ret[groupKey.ID] = newValue
if nil != keyValues.Key.Date && keyValues.Key.Date.AutoFillNow { newValue.Date.Content = time.Now().UnixMilli() newValue.Date.IsNotEmpty = true } return }
if nil == nearItem && !filterKeyIDs[groupKey.ID] { // 没有临近项并且分组字段和过滤字段不同时，使用分组值 newValue = av.GetAttributeViewDefaultValue(ast.NewNodeID(), groupKey.ID, addingItemID, groupKey.Type, false) if av.KeyTypeText == groupView.GroupVal.Type { content := groupView.GroupVal.Text.Content if groupValueDefault == content { content = "" }
switch newValue.Type { case av.KeyTypeBlock: newValue.Block.Content = content case av.KeyTypeText: newValue.Text.Content = content case av.KeyTypeNumber: num, _ := strconv.ParseFloat(strings.Split(content, " - ")[0], 64) newValue.Number.Content = num newValue.Number.IsNotEmpty = true case av.KeyTypeURL: newValue.URL.Content = content case av.KeyTypeEmail: newValue.Email.Content = content case av.KeyTypePhone: newValue.Phone.Content = content } } else if av.KeyTypeCheckbox == groupView.GroupVal.Type { newValue.Checkbox.Checked = groupView.GroupVal.Checkbox.Checked }
ret[groupKey.ID] = newValue return }
if nil != newValue && !filterKeyIDs[groupKey.ID] { ret[groupKey.ID] = newValue
if nil != keyValues.Key.Date && keyValues.Key.Date.AutoFillNow { newValue.Date.Content = time.Now().UnixMilli() newValue.Date.IsNotEmpty = true } } return}
func (tx *Transaction) doSortAttrViewGroup(operation *Operation) (ret *TxErr) { if err := sortAttributeViewGroup(operation.AvID, operation.BlockID, operation.PreviousID, operation.ID); nil != err { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func sortAttributeViewGroup(avID, blockID, previousGroupID, groupID string) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return }
view, err := getAttrViewViewByBlockID(attrView, blockID) if err != nil { return err }
sortGroupViews(attrView, view)
var groupView *av.View var index, previousIndex int for i, g := range view.Groups { if g.ID == groupID { groupView = g index = i break } } if nil == groupView { return } view.Group.Order = av.GroupOrderMan
view.Groups = append(view.Groups[:index], view.Groups[index+1:]...) for i, g := range view.Groups { if g.ID == previousGroupID { previousIndex = i + 1 break } } view.Groups = util.InsertElem(view.Groups, previousIndex, groupView)
for i, g := range view.Groups { g.GroupSort = i }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doRemoveAttrViewGroup(operation *Operation) (ret *TxErr) { if err := removeAttributeViewGroup(operation.AvID, operation.BlockID); nil != err { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func removeAttributeViewGroup(avID, blockID string) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return err }
view, err := getAttrViewViewByBlockID(attrView, blockID) if err != nil { return err }
removeAttributeViewGroup0(view) err = av.SaveAttributeView(attrView) if err != nil { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return err } return nil}
func removeAttributeViewGroup0(view *av.View) { view.Group, view.Groups, view.GroupCreated = nil, nil, 0}
func (tx *Transaction) doSyncAttrViewTableColWidth(operation *Operation) (ret *TxErr) { err := syncAttrViewTableColWidth(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func syncAttrViewTableColWidth(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view := attrView.GetView(operation.ID) if nil == view { err = av.ErrViewNotFound logging.LogErrorf("view [%s] not found in attribute view [%s]", operation.ID, operation.AvID) return }
var width string switch view.LayoutType { case av.LayoutTypeTable: for _, column := range view.Table.Columns { if column.ID == operation.KeyID { width = column.Width break } } case av.LayoutTypeGallery, av.LayoutTypeKanban: return }
for _, v := range attrView.Views { if av.LayoutTypeTable == v.LayoutType { for _, column := range v.Table.Columns { if column.ID == operation.KeyID { column.Width = width break } } } }
err = av.SaveAttributeView(attrView) ReloadAttrView(attrView.ID) return}
func (tx *Transaction) doHideAttrViewGroup(operation *Operation) (ret *TxErr) { if err := hideAttributeViewGroup(operation.AvID, operation.BlockID, operation.ID, int(operation.Data.(float64))); nil != err { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func hideAttributeViewGroup(avID, blockID, groupID string, hidden int) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, blockID) if err != nil { return }
for _, group := range view.Groups { if group.ID == groupID { group.GroupHidden = hidden break } }
err = av.SaveAttributeView(attrView) if err != nil { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return } return}
func (tx *Transaction) doHideAttrViewAllGroups(operation *Operation) (ret *TxErr) { if err := hideAttributeViewAllGroups(operation.AvID, operation.BlockID, operation.Data.(bool)); nil != err { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func hideAttributeViewAllGroups(avID, blockID string, hidden bool) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, blockID) if err != nil { return }
for _, group := range view.Groups { if hidden { group.GroupHidden = 2 } else { group.GroupHidden = 0 } }
err = av.SaveAttributeView(attrView) if err != nil { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return } return}
func (tx *Transaction) doFoldAttrViewGroup(operation *Operation) (ret *TxErr) { if err := foldAttrViewGroup(operation.AvID, operation.BlockID, operation.ID, operation.Data.(bool)); nil != err { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func foldAttrViewGroup(avID, blockID, groupID string, folded bool) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return err }
view, err := getAttrViewViewByBlockID(attrView, blockID) if err != nil { return err }
if !view.IsGroupView() { return }
for _, group := range view.Groups { if group.ID == groupID { group.GroupFolded = folded break } }
err = av.SaveAttributeView(attrView) if err != nil { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return err } return nil}
func (tx *Transaction) doSetAttrViewGroup(operation *Operation) (ret *TxErr) { data, err := gulu.JSON.MarshalJSON(operation.Data) if nil != err { logging.LogErrorf("marshal operation data failed: %s", err) return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} }
group := &av.ViewGroup{} if err = gulu.JSON.UnmarshalJSON(data, &group); nil != err { logging.LogErrorf("unmarshal operation data failed: %s", err) return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} }
if err = SetAttributeViewGroup(operation.AvID, operation.BlockID, group); nil != err { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func SetAttributeViewGroup(avID, blockID string, group *av.ViewGroup) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return err }
view, err := getAttrViewViewByBlockID(attrView, blockID) if err != nil { return err }
setAttributeViewGroup(attrView, view, group)
err = av.SaveAttributeView(attrView) ReloadAttrView(avID) return}
func setAttributeViewGroup(attrView *av.AttributeView, view *av.View, group *av.ViewGroup) { var oldHideEmpty, firstInit, changeGroupField bool if nil != view.Group { oldHideEmpty = view.Group.HideEmpty changeGroupField = group.Field != view.Group.Field } else { firstInit = true }
groupStates := getAttrViewGroupStates(view) view.Group = group regenAttrViewGroups(attrView) setAttrViewGroupStates(view, groupStates)
if view.Group.HideEmpty != oldHideEmpty { if !oldHideEmpty && view.Group.HideEmpty { // 启用隐藏空分组 for _, g := range view.Groups { groupViewable := sql.RenderGroupView(attrView, view, g, "") // 必须经过渲染才能得到最终的条目数 renderViewableInstance(groupViewable, view, attrView, 1, -1) if g.GroupHidden == 0 && 1 > groupViewable.(av.Collection).CountItems() { g.GroupHidden = 1 } } } if oldHideEmpty && !view.Group.HideEmpty { // 禁用隐藏空分组 for _, g := range view.Groups { groupViewable := sql.RenderGroupView(attrView, view, g, "") renderViewableInstance(groupViewable, view, attrView, 1, -1) if g.GroupHidden == 1 && 1 > groupViewable.(av.Collection).CountItems() { g.GroupHidden = 0 } } } }
if firstInit || changeGroupField { // 首次设置分组时 if groupKey := view.GetGroupKey(attrView); nil != groupKey { if av.KeyTypeSelect == groupKey.Type || av.KeyTypeMSelect == groupKey.Type { // 如果分组字段是单选或多选，则将分组排序方式改为按选项排序 https://github.com/siyuan-note/siyuan/issues/15534 view.Group.Order = av.GroupOrderSelectOption sortGroupsBySelectOption(view, groupKey) } else if av.KeyTypeCheckbox == groupKey.Type { // 如果分组字段是复选框，则将分组排序改为手动排序，并且已勾选在前面 view.Group.Order = av.GroupOrderMan checked := view.GetGroupByGroupValue(av.CheckboxCheckedStr) unchecked := view.GetGroupByGroupValue("") view.Groups = nil view.Groups = append(view.Groups, checked, unchecked) }
}
for i, g := range view.Groups { g.GroupSort = i } }}
func (tx *Transaction) doSetAttrViewCardAspectRatio(operation *Operation) (ret *TxErr) { err := setAttrViewCardAspectRatio(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttrViewCardAspectRatio(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
switch view.LayoutType { case av.LayoutTypeTable: return case av.LayoutTypeGallery: view.Gallery.CardAspectRatio = av.CardAspectRatio(operation.Data.(float64)) case av.LayoutTypeKanban: view.Kanban.CardAspectRatio = av.CardAspectRatio(operation.Data.(float64)) }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewBlockView(operation *Operation) (ret *TxErr) { err := SetDatabaseBlockView(operation.BlockID, operation.AvID, operation.ID) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func (tx *Transaction) doChangeAttrViewLayout(operation *Operation) (ret *TxErr) { err := ChangeAttrViewLayout(operation.BlockID, operation.AvID, operation.Layout) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func ChangeAttrViewLayout(blockID, avID string, newLayout av.LayoutType) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, blockID) if err != nil { return }
if newLayout == view.LayoutType { return }
oldLayout := view.LayoutType view.LayoutType = newLayout
switch newLayout { case av.LayoutTypeTable: if view.Name == av.GetAttributeViewI18n("gallery") || view.Name == av.GetAttributeViewI18n("kanban") { view.Name = av.GetAttributeViewI18n("table") }
if nil != view.Table { break }
view.Table = av.NewLayoutTable() switch oldLayout { case av.LayoutTypeGallery: for _, field := range view.Gallery.CardFields { view.Table.Columns = append(view.Table.Columns, &av.ViewTableColumn{BaseField: &av.BaseField{ID: field.ID}}) } case av.LayoutTypeKanban: for _, field := range view.Kanban.Fields { view.Table.Columns = append(view.Table.Columns, &av.ViewTableColumn{BaseField: &av.BaseField{ID: field.ID}}) } } case av.LayoutTypeGallery: if view.Name == av.GetAttributeViewI18n("table") || view.Name == av.GetAttributeViewI18n("kanban") { view.Name = av.GetAttributeViewI18n("gallery") }
if nil != view.Gallery { break }
view.Gallery = av.NewLayoutGallery() switch oldLayout { case av.LayoutTypeTable: for _, col := range view.Table.Columns { view.Gallery.CardFields = append(view.Gallery.CardFields, &av.ViewGalleryCardField{BaseField: &av.BaseField{ID: col.ID}}) } case av.LayoutTypeKanban: for _, field := range view.Kanban.Fields { view.Gallery.CardFields = append(view.Gallery.CardFields, &av.ViewGalleryCardField{BaseField: &av.BaseField{ID: field.ID}}) } } case av.LayoutTypeKanban: if view.Name == av.GetAttributeViewI18n("table") || view.Name == av.GetAttributeViewI18n("gallery") { view.Name = av.GetAttributeViewI18n("kanban") }
if nil != view.Kanban { break }
view.Kanban = av.NewLayoutKanban() switch oldLayout { case av.LayoutTypeTable: for _, col := range view.Table.Columns { view.Kanban.Fields = append(view.Kanban.Fields, &av.ViewKanbanField{BaseField: &av.BaseField{ID: col.ID}}) } case av.LayoutTypeGallery: for _, field := range view.Gallery.CardFields { view.Kanban.Fields = append(view.Kanban.Fields, &av.ViewKanbanField{BaseField: &av.BaseField{ID: field.ID}}) } }
if !view.IsGroupView() { preferredGroupKey := getKanbanPreferredGroupKey(attrView) group := &av.ViewGroup{Field: preferredGroupKey.ID} setAttributeViewGroup(attrView, view, group) } }
blockIDs := treenode.GetMirrorAttrViewBlockIDs(avID) for _, bID := range blockIDs { node, tree, _ := getNodeByBlockID(nil, bID) if nil == node || nil == tree { logging.LogErrorf("get node by block ID [%s] failed", bID) continue }
changed := false attrs := parse.IAL2Map(node.KramdownIAL) if blockID == bID { // 当前操作的镜像库 attrs[av.NodeAttrView] = view.ID node.AttributeViewType = string(view.LayoutType) attrView.ViewID = view.ID changed = true } else { if view.ID == attrs[av.NodeAttrView] { // 仅更新和当前操作的镜像库指定的视图相同的镜像库 node.AttributeViewType = string(view.LayoutType) changed = true } }
if changed { err = setNodeAttrs(node, tree, attrs) if err != nil { logging.LogWarnf("set node [%s] attrs failed: %s", bID, err) return } } }
regenAttrViewGroups(attrView)
if err = av.SaveAttributeView(attrView); nil != err { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return }
ReloadAttrView(avID) return}
func (tx *Transaction) doSetAttrViewWrapField(operation *Operation) (ret *TxErr) { err := setAttrViewWrapField(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttrViewWrapField(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
allFieldWrap := operation.Data.(bool) switch view.LayoutType { case av.LayoutTypeTable: view.Table.WrapField = allFieldWrap for _, col := range view.Table.Columns { col.Wrap = allFieldWrap } case av.LayoutTypeGallery: view.Gallery.WrapField = allFieldWrap for _, field := range view.Gallery.CardFields { field.Wrap = allFieldWrap } case av.LayoutTypeKanban: view.Kanban.WrapField = allFieldWrap for _, field := range view.Kanban.Fields { field.Wrap = allFieldWrap } }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewShowIcon(operation *Operation) (ret *TxErr) { err := setAttrViewShowIcon(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttrViewShowIcon(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
switch view.LayoutType { case av.LayoutTypeTable: view.Table.ShowIcon = operation.Data.(bool) case av.LayoutTypeGallery: view.Gallery.ShowIcon = operation.Data.(bool) case av.LayoutTypeKanban: view.Kanban.ShowIcon = operation.Data.(bool) }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewFitImage(operation *Operation) (ret *TxErr) { err := setAttrViewFitImage(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttrViewFitImage(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
switch view.LayoutType { case av.LayoutTypeTable: return case av.LayoutTypeGallery: view.Gallery.FitImage = operation.Data.(bool) case av.LayoutTypeKanban: view.Kanban.FitImage = operation.Data.(bool) }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewDisplayFieldName(operation *Operation) (ret *TxErr) { err := setAttrViewDisplayFieldName(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func (tx *Transaction) doSetAttrViewFillColBackgroundColor(operation *Operation) (ret *TxErr) { err := setAttrViewFillColBackgroundColor(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttrViewDisplayFieldName(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
switch view.LayoutType { case av.LayoutTypeTable: return case av.LayoutTypeGallery: view.Gallery.DisplayFieldName = operation.Data.(bool) case av.LayoutTypeKanban: view.Kanban.DisplayFieldName = operation.Data.(bool) }
err = av.SaveAttributeView(attrView) return}
func setAttrViewFillColBackgroundColor(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
switch view.LayoutType { case av.LayoutTypeTable: return case av.LayoutTypeGallery: return case av.LayoutTypeKanban: view.Kanban.FillColBackgroundColor = operation.Data.(bool) }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewCardSize(operation *Operation) (ret *TxErr) { err := setAttrViewCardSize(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttrViewCardSize(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
switch view.LayoutType { case av.LayoutTypeTable: return case av.LayoutTypeGallery: view.Gallery.CardSize = av.CardSize(operation.Data.(float64)) case av.LayoutTypeKanban: view.Kanban.CardSize = av.CardSize(operation.Data.(float64)) }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewCoverFromAssetKeyID(operation *Operation) (ret *TxErr) { err := setAttrViewCoverFromAssetKeyID(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttrViewCoverFromAssetKeyID(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
switch view.LayoutType { case av.LayoutTypeTable: return case av.LayoutTypeGallery: view.Gallery.CoverFromAssetKeyID = operation.KeyID case av.LayoutTypeKanban: view.Kanban.CoverFromAssetKeyID = operation.KeyID }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewCoverFrom(operation *Operation) (ret *TxErr) { err := setAttrViewCoverFrom(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttrViewCoverFrom(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
switch view.LayoutType { case av.LayoutTypeTable: return case av.LayoutTypeGallery: view.Gallery.CoverFrom = av.CoverFrom(operation.Data.(float64)) case av.LayoutTypeKanban: view.Kanban.CoverFrom = av.CoverFrom(operation.Data.(float64)) }
err = av.SaveAttributeView(attrView) return}
func AppendAttributeViewDetachedBlocksWithValues(avID string, blocksValues [][]*av.Value) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return }
now := util.CurrentTimeMillis() var blockIDs []string for _, blockValues := range blocksValues { blockID := ast.NewNodeID() if v := blockValues[0]; "" != v.BlockID { blockID = v.BlockID } blockIDs = append(blockIDs, blockID) for _, v := range blockValues { keyValues, _ := attrView.GetKeyValues(v.KeyID) if nil == keyValues { err = fmt.Errorf("key [%s] not found", v.KeyID) return }
v.ID = ast.NewNodeID() v.BlockID = blockID v.Type = keyValues.Key.Type if av.KeyTypeBlock == v.Type { v.Block.Created = now v.Block.Updated = now v.Block.ID = "" } v.IsDetached = true v.CreatedAt = now v.UpdatedAt = now v.IsRenderAutoFill = false keyValues.Values = append(keyValues.Values, v)
if av.KeyTypeSelect == v.Type || av.KeyTypeMSelect == v.Type { // 保存选项 https://github.com/siyuan-note/siyuan/issues/12475 key, _ := attrView.GetKey(v.KeyID) if nil != key && 0 < len(v.MSelect) { for _, valOpt := range v.MSelect { if opt := key.GetOption(valOpt.Content); nil == opt { // 不存在的选项新建保存 opt = &av.SelectOption{Name: valOpt.Content, Color: valOpt.Color} key.Options = append(key.Options, opt) } else { // 已经存在的选项颜色需要保持不变 valOpt.Color = opt.Color } } } } } }
for _, v := range attrView.Views { for _, addingBlockID := range blockIDs { v.ItemIDs = append(v.ItemIDs, addingBlockID) } }
regenAttrViewGroups(attrView) if err = av.SaveAttributeView(attrView); err != nil { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return }
ReloadAttrView(avID) return}
func DuplicateDatabaseBlock(avID string) (newAvID, newBlockID string, err error) { storageAvDir := filepath.Join(util.DataDir, "storage", "av") oldAvPath := filepath.Join(storageAvDir, avID+".json") newAvID, newBlockID = ast.NewNodeID(), ast.NewNodeID()
oldAv, err := av.ParseAttributeView(avID) if err != nil { return }
data, err := filelock.ReadFile(oldAvPath) if err != nil { logging.LogErrorf("read attribute view [%s] failed: %s", avID, err) return }
data = bytes.ReplaceAll(data, []byte(avID), []byte(newAvID)) av.UpsertBlockRel(newAvID, newBlockID)
newAv := &av.AttributeView{} if err = gulu.JSON.UnmarshalJSON(data, newAv); err != nil { logging.LogErrorf("unmarshal attribute view [%s] failed: %s", newAvID, err) return }
if "" != newAv.Name { newAv.Name = oldAv.Name + " (Duplicated " + time.Now().Format("2006-01-02 15:04:05") + ")" }
for _, keyValues := range newAv.KeyValues { if nil != keyValues.Key.Relation && keyValues.Key.Relation.IsTwoWay { // 断开双向关联 keyValues.Key.Relation.IsTwoWay = false keyValues.Key.Relation.BackKeyID = "" } }
data, err = gulu.JSON.MarshalJSON(newAv) if err != nil { logging.LogErrorf("marshal attribute view [%s] failed: %s", newAvID, err) return }
newAvPath := filepath.Join(storageAvDir, newAvID+".json") if err = filelock.WriteFile(newAvPath, data); err != nil { logging.LogErrorf("write attribute view [%s] failed: %s", newAvID, err) return }
updateBoundBlockAvsAttribute([]string{newAvID}) return}
func GetAttributeViewKeysByID(avID string, keyIDs ...string) (ret []*av.Key) { ret = []*av.Key{}
attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return }
if 1 > len(keyIDs) { for _, keyValues := range attrView.KeyValues { key := keyValues.Key ret = append(ret, key) } return }
for _, keyValues := range attrView.KeyValues { key := keyValues.Key for _, keyID := range keyIDs { if key.ID == keyID { ret = append(ret, key) } } } return ret}
func SetDatabaseBlockView(blockID, avID, viewID string) (err error) { attrView, err := av.ParseAttributeView(avID) if nil != err { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return } if attrView.ViewID != viewID { attrView.ViewID = viewID if err = av.SaveAttributeView(attrView); err != nil { return } }
view := attrView.GetView(viewID) if nil == view { err = av.ErrViewNotFound logging.LogErrorf("view [%s] not found in attribute view [%s]", viewID, avID) return }
node, tree, err := getNodeByBlockID(nil, blockID) if err != nil { return }
node.AttributeViewType = string(view.LayoutType) attrs := parse.IAL2Map(node.KramdownIAL) attrs[av.NodeAttrView] = viewID err = setNodeAttrs(node, tree, attrs) if err != nil { logging.LogWarnf("set node [%s] attrs failed: %s", blockID, err) return } return}
func GetAttributeViewPrimaryKeyValues(avID, keyword string, page, pageSize int) (attributeViewName string, databaseBlockIDs []string, keyValues *av.KeyValues, err error) { waitForSyncingStorages()
attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return } attributeViewName = getAttrViewName(attrView)
databaseBlockIDs = treenode.GetMirrorAttrViewBlockIDs(avID)
keyValues = attrView.GetBlockKeyValues() var values []*av.Value for _, kv := range keyValues.Values { if !kv.IsDetached && !treenode.ExistBlockTree(kv.Block.ID) { continue }
if strings.Contains(strings.ToLower(kv.String(true)), strings.ToLower(keyword)) { values = append(values, kv) } } keyValues.Values = values
sort.Slice(keyValues.Values, func(i, j int) bool { return keyValues.Values[i].Block.Updated > keyValues.Values[j].Block.Updated })
if 1 > pageSize { pageSize = 16 } start := (page - 1) * pageSize end := start + pageSize if len(keyValues.Values) < end { end = len(keyValues.Values) } keyValues.Values = keyValues.Values[start:end] return}
func GetAttributeViewFilterSort(avID, blockID string) (filters []*av.ViewFilter, sorts []*av.ViewSort) { waitForSyncingStorages()
attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return }
view, err := getAttrViewViewByBlockID(attrView, blockID) if nil == view { view, err = attrView.GetCurrentView(attrView.ViewID) if nil == view || err != nil { logging.LogErrorf("get current view failed: %s", err) return } }
filters = view.Filters sorts = view.Sorts if 1 > len(filters) { filters = []*av.ViewFilter{} } if 1 > len(sorts) { sorts = []*av.ViewSort{} } return}
func SearchAttributeViewNonRelationKey(avID, keyword string) (ret []*av.Key) { waitForSyncingStorages()
ret = []*av.Key{} attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return }
for _, keyValues := range attrView.KeyValues { if av.KeyTypeRelation != keyValues.Key.Type && av.KeyTypeRollup != keyValues.Key.Type && av.KeyTypeLineNumber != keyValues.Key.Type { if strings.Contains(strings.ToLower(keyValues.Key.Name), strings.ToLower(keyword)) { ret = append(ret, keyValues.Key) } } } return}
func SearchAttributeViewRollupDestKeys(avID, keyword string) (ret []*av.Key) { waitForSyncingStorages()
ret = []*av.Key{} attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return }
for _, keyValues := range attrView.KeyValues { if av.KeyTypeRollup != keyValues.Key.Type && av.KeyTypeLineNumber != keyValues.Key.Type { if strings.Contains(strings.ToLower(keyValues.Key.Name), strings.ToLower(keyword)) { ret = append(ret, keyValues.Key) } } } return}
func SearchAttributeViewRelationKey(avID, keyword string) (ret []*av.Key) { waitForSyncingStorages()
ret = []*av.Key{} attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return }
for _, keyValues := range attrView.KeyValues { if av.KeyTypeRelation == keyValues.Key.Type && nil != keyValues.Key.Relation { if strings.Contains(strings.ToLower(keyValues.Key.Name), strings.ToLower(keyword)) { ret = append(ret, keyValues.Key) } } } return}
func GetAttributeView(avID string) (ret *av.AttributeView) { waitForSyncingStorages()
ret, _ = av.ParseAttributeView(avID) return}
type AvSearchResult struct { AvID string `json:"avID"` AvName string `json:"avName"` ViewName string `json:"viewName"` ViewID string `json:"viewID"` ViewLayout av.LayoutType `json:"viewLayout"` BlockID string `json:"blockID"` HPath string `json:"hPath"` Children []*AvSearchResult `json:"children,omitempty"`}
type AvSearchTempResult struct { AvID string AvName string AvUpdated int64 Score float64}
func SearchAttributeView(keyword string, excludeAvIDs []string) (ret []*AvSearchResult) { waitForSyncingStorages()
ret = []*AvSearchResult{} keyword = strings.TrimSpace(keyword) keywords := strings.Fields(keyword)
var avSearchTmpResults []*AvSearchTempResult avDir := filepath.Join(util.DataDir, "storage", "av") entries, err := os.ReadDir(avDir) if err != nil { logging.LogErrorf("read directory [%s] failed: %s", avDir, err) return }
avBlockRels := av.GetBlockRels() if 1 > len(avBlockRels) { return }
for _, entry := range entries { if entry.IsDir() { continue }
id := strings.TrimSuffix(entry.Name(), ".json") if !ast.IsNodeIDPattern(id) { continue }
if gulu.Str.Contains(id, excludeAvIDs) { continue }
if nil == avBlockRels[id] { continue }
name, _ := av.GetAttributeViewNameByPath(filepath.Join(avDir, entry.Name())) info, _ := entry.Info() if "" != keyword { score := 0.0 hit := false for _, k := range keywords { if strings.Contains(strings.ToLower(name), strings.ToLower(k)) { score += smetrics.JaroWinkler(name, k, 0.7, 4) hit = true } else { hit = false break } }
if hit { a := &AvSearchTempResult{AvID: id, AvName: name, Score: score} if nil != info && !info.ModTime().IsZero() { a.AvUpdated = info.ModTime().UnixMilli() } avSearchTmpResults = append(avSearchTmpResults, a) } } else { a := &AvSearchTempResult{AvID: id, AvName: name} if nil != info && !info.ModTime().IsZero() { a.AvUpdated = info.ModTime().UnixMilli() } avSearchTmpResults = append(avSearchTmpResults, a) } }
if "" == keyword { sort.Slice(avSearchTmpResults, func(i, j int) bool { return avSearchTmpResults[i].AvUpdated > avSearchTmpResults[j].AvUpdated }) } else { sort.SliceStable(avSearchTmpResults, func(i, j int) bool { if avSearchTmpResults[i].Score == avSearchTmpResults[j].Score { return avSearchTmpResults[i].AvUpdated > avSearchTmpResults[j].AvUpdated } return avSearchTmpResults[i].Score > avSearchTmpResults[j].Score }) } if 12 <= len(avSearchTmpResults) { avSearchTmpResults = avSearchTmpResults[:12] }
for _, tmpResult := range avSearchTmpResults { bIDs := avBlockRels[tmpResult.AvID] var node *ast.Node for _, bID := range bIDs { tree, _ := LoadTreeByBlockID(bID) if nil == tree { continue }
node = treenode.GetNodeInTree(tree, bID) if nil == node || "" == node.AttributeViewID || ast.NodeAttributeView != node.Type { node = nil continue }
break }
if nil == node { continue }
attrView, _ := av.ParseAttributeView(tmpResult.AvID) if nil == attrView { continue }
var hPath string baseBlock := treenode.GetBlockTreeRootByPath(node.Box, node.Path) if nil != baseBlock { hPath = baseBlock.HPath } box := Conf.Box(node.Box) if nil != box { hPath = box.Name + hPath }
name := tmpResult.AvName if "" == name { name = Conf.language(267) }
parent := &AvSearchResult{ AvID: tmpResult.AvID, AvName: tmpResult.AvName, BlockID: node.ID, HPath: hPath, } ret = append(ret, parent)
for _, view := range attrView.Views { child := &AvSearchResult{ AvID: tmpResult.AvID, AvName: tmpResult.AvName, ViewName: view.Name, ViewID: view.ID, ViewLayout: view.LayoutType, BlockID: node.ID, HPath: hPath, } parent.Children = append(parent.Children, child) } } return}
type BlockAttributeViewKeys struct { AvID string `json:"avID"` AvName string `json:"avName"` BlockIDs []string `json:"blockIDs"` KeyValues []*av.KeyValues `json:"keyValues"`}
func GetBlockAttributeViewKeys(nodeID string) (ret []*BlockAttributeViewKeys) { waitForSyncingStorages()
ret = []*BlockAttributeViewKeys{} attrs := sql.GetBlockAttrs(nodeID) avs := attrs[av.NodeAttrNameAvs] if "" == avs { return }
cachedAttrViews := map[string]*av.AttributeView{} avIDs := strings.Split(avs, ",") for _, avID := range avIDs { attrView := cachedAttrViews[avID] if nil == attrView { var err error attrView, err = av.ParseAttributeView(avID) if nil == attrView { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) continue } cachedAttrViews[avID] = attrView }
if !attrView.ExistBoundBlock(nodeID) { // 比如剪切后粘贴，块 ID 会变，但是属性还在块上，这里做一次数据订正 // Auto verify the database name when clicking the block superscript icon https://github.com/siyuan-note/siyuan/issues/10861 unbindBlockAv(nil, avID, nodeID) return }
blockVal := attrView.GetBlockValueByBoundID(nodeID) if nil == blockVal { continue }
itemID := blockVal.BlockID view, err := getRenderAttributeViewView(attrView, "", nodeID) if nil != err { continue }
// 渲染填充 attrView.KeyValues sql.RenderView(attrView, view, "")
var keyValues []*av.KeyValues for _, kv := range attrView.KeyValues { if av.KeyTypeLineNumber == kv.Key.Type { // 属性面板中不显示行号字段 // The line number field no longer appears in the database attribute panel https://github.com/siyuan-note/siyuan/issues/11319 continue }
kValues := &av.KeyValues{Key: kv.Key} for _, v := range kv.Values { if v.BlockID == itemID { kValues.Values = append(kValues.Values, v) } }
keyValues = append(keyValues, kValues) }
// 字段排序 refreshAttrViewKeyIDs(attrView, true) sorts := map[string]int{} for i, k := range attrView.KeyIDs { sorts[k] = i } sort.Slice(keyValues, func(i, j int) bool { return sorts[keyValues[i].Key.ID] < sorts[keyValues[j].Key.ID] })
blockIDs := treenode.GetMirrorAttrViewBlockIDs(avID) if 1 > len(blockIDs) { // 老数据兼容处理 avBts := treenode.GetBlockTreesByType("av") for _, avBt := range avBts { if nil == avBt { continue } tree, _ := LoadTreeByBlockID(avBt.ID) if nil == tree { continue } node := treenode.GetNodeInTree(tree, avBt.ID) if nil == node { continue } if avID == node.AttributeViewID { blockIDs = append(blockIDs, avBt.ID) } } if 1 > len(blockIDs) { tree, _ := LoadTreeByBlockID(nodeID) if nil != tree { node := treenode.GetNodeInTree(tree, nodeID) if nil != node { if removeErr := removeNodeAvID(node, avID, nil, tree); nil != removeErr { logging.LogErrorf("remove node avID [%s] failed: %s", avID, removeErr) } } } continue } blockIDs = gulu.Str.RemoveDuplicatedElem(blockIDs) for _, blockID := range blockIDs { av.UpsertBlockRel(avID, blockID) } }
ret = append(ret, &BlockAttributeViewKeys{ AvID: avID, AvName: getAttrViewName(attrView), BlockIDs: blockIDs, KeyValues: keyValues, }) } return}
func genAttrViewGroups(view *av.View, attrView *av.AttributeView) { if !view.IsGroupView() { return }
groupStates := getAttrViewGroupStates(view)
group := view.Group view.Groups = nil viewable := sql.RenderView(attrView, view, "") var items []av.Item for _, item := range viewable.(av.Collection).GetItems() { items = append(items, item) }
groupKey := view.GetGroupKey(attrView) if nil == groupKey { return }
var rangeStart, rangeEnd float64 switch group.Method { case av.GroupMethodValue: if av.GroupOrderMan != group.Order { sort.SliceStable(items, func(i, j int) bool { return items[i].GetValue(group.Field).String(false) < items[j].GetValue(group.Field).String(false) }) } case av.GroupMethodRangeNum: if nil == group.Range { return }
rangeStart, rangeEnd = group.Range.NumStart, group.Range.NumStart+group.Range.NumStep sort.SliceStable(items, func(i, j int) bool { return items[i].GetValue(group.Field).Number.Content < items[j].GetValue(group.Field).Number.Content }) case av.GroupMethodDateDay, av.GroupMethodDateWeek, av.GroupMethodDateMonth, av.GroupMethodDateYear, av.GroupMethodDateRelative: if av.KeyTypeCreated == groupKey.Type { sort.SliceStable(items, func(i, j int) bool { return items[i].GetValue(group.Field).Created.Content < items[j].GetValue(group.Field).Created.Content }) } else if av.KeyTypeUpdated == groupKey.Type { sort.SliceStable(items, func(i, j int) bool { return items[i].GetValue(group.Field).Updated.Content < items[j].GetValue(group.Field).Updated.Content }) } else if av.KeyTypeDate == groupKey.Type { sort.SliceStable(items, func(i, j int) bool { return items[i].GetValue(group.Field).Date.Content < items[j].GetValue(group.Field).Date.Content }) } }
todayStart := time.Now() todayStart = time.Date(todayStart.Year(), todayStart.Month(), todayStart.Day(), 0, 0, 0, 0, time.Local)
var relationDestAv *av.AttributeView if av.KeyTypeRelation == groupKey.Type && nil != groupKey.Relation { if attrView.ID == groupKey.Relation.AvID { relationDestAv = attrView } else { relationDestAv, _ = av.ParseAttributeView(groupKey.Relation.AvID) } }
groupItemsMap := map[string][]av.Item{} for _, item := range items { value := item.GetValue(group.Field) if value.IsBlank() { groupItemsMap[groupValueDefault] = append(groupItemsMap[groupValueDefault], item) continue }
var groupVal string switch group.Method { case av.GroupMethodValue: if av.KeyTypeSelect == groupKey.Type || av.KeyTypeMSelect == groupKey.Type { for _, s := range value.MSelect { groupItemsMap[s.Content] = append(groupItemsMap[s.Content], item) } continue } else if av.KeyTypeRelation == groupKey.Type { if nil == relationDestAv { continue }
for _, bID := range value.Relation.BlockIDs { groupItemsMap[bID] = append(groupItemsMap[bID], item) } continue }
groupVal = value.String(false) case av.GroupMethodRangeNum: if group.Range.NumStart > value.Number.Content || group.Range.NumEnd < value.Number.Content { groupVal = groupValueNotInRange break }
for rangeEnd <= group.Range.NumEnd && rangeEnd <= value.Number.Content { rangeStart += group.Range.NumStep rangeEnd += group.Range.NumStep }
if rangeStart <= value.Number.Content && rangeEnd > value.Number.Content { groupVal = fmt.Sprintf("%s - %s", strconv.FormatFloat(rangeStart, 'f', -1, 64), strconv.FormatFloat(rangeEnd, 'f', -1, 64)) } case av.GroupMethodDateDay, av.GroupMethodDateWeek, av.GroupMethodDateMonth, av.GroupMethodDateYear, av.GroupMethodDateRelative: var contentTime time.Time switch value.Type { case av.KeyTypeDate: contentTime = time.UnixMilli(value.Date.Content) case av.KeyTypeCreated: contentTime = time.UnixMilli(value.Created.Content) case av.KeyTypeUpdated: contentTime = time.UnixMilli(value.Updated.Content) } switch group.Method { case av.GroupMethodDateDay: groupVal = contentTime.Format("2006-01-02") case av.GroupMethodDateWeek: year, week := contentTime.ISOWeek() groupVal = fmt.Sprintf("%d-W%02d", year, week) case av.GroupMethodDateMonth: groupVal = contentTime.Format("2006-01") case av.GroupMethodDateYear: groupVal = contentTime.Format("2006") case av.GroupMethodDateRelative: // 过去 30 天之前的按月分组 // 过去 30 天、过去 7 天、昨天、今天、明天、未来 7 天、未来 30 天 // 未来 30 天之后的按月分组 if contentTime.Before(todayStart.AddDate(0, 0, -30)) { groupVal = contentTime.Format("2006-01") // 开头的数字用于排序 } else if contentTime.Before(todayStart.AddDate(0, 0, -7)) { groupVal = groupValueLast30Days } else if contentTime.Before(todayStart.AddDate(0, 0, -1)) { groupVal = groupValueLast7Days } else if contentTime.Before(todayStart) { groupVal = groupValueYesterday } else if (contentTime.After(todayStart) || contentTime.Equal(todayStart)) && contentTime.Before(todayStart.AddDate(0, 0, 1)) { groupVal = groupValueToday } else if contentTime.After(todayStart.AddDate(0, 0, 30)) { groupVal = contentTime.Format("2006-01") } else if contentTime.After(todayStart.AddDate(0, 0, 7)) { groupVal = groupValueNext30Days } else if contentTime.Equal(todayStart.AddDate(0, 0, 2)) || contentTime.After(todayStart.AddDate(0, 0, 2)) { groupVal = groupValueNext7Days } else { groupVal = groupValueTomorrow } } }
groupItemsMap[groupVal] = append(groupItemsMap[groupVal], item) }
if av.KeyTypeSelect == groupKey.Type || av.KeyTypeMSelect == groupKey.Type { for _, o := range groupKey.Options { if _, ok := groupItemsMap[o.Name]; !ok { groupItemsMap[o.Name] = []av.Item{} } } }
if av.KeyTypeCheckbox != groupKey.Type { if 1 > len(groupItemsMap[groupValueDefault]) { // 始终保留默认分组 https://github.com/siyuan-note/siyuan/issues/15587 groupItemsMap[groupValueDefault] = []av.Item{} } } else { // 对于复选框分组，空白分组表示未选中状态，始终保留 https://github.com/siyuan-note/siyuan/issues/15650 if nil == groupItemsMap[""] { groupItemsMap[""] = []av.Item{} } if nil == groupItemsMap[av.CheckboxCheckedStr] { groupItemsMap[av.CheckboxCheckedStr] = []av.Item{} } }
for groupValue, groupItems := range groupItemsMap { var v *av.View switch view.LayoutType { case av.LayoutTypeTable: v = av.NewTableView() v.Table = av.NewLayoutTable() case av.LayoutTypeGallery: v = av.NewGalleryView() v.Gallery = av.NewLayoutGallery() case av.LayoutTypeKanban: v = av.NewKanbanView() v.Kanban = av.NewLayoutKanban() default: logging.LogWarnf("unknown layout type [%s] for group view", view.LayoutType) return }
v.GroupItemIDs = []string{} for _, item := range groupItems { v.GroupItemIDs = append(v.GroupItemIDs, item.GetID()) }
v.Name = "" // 分组视图的名称在渲染时才填充 v.GroupHidden = 1 // 默认隐藏空白分组 v.GroupKey = groupKey v.GroupVal = &av.Value{Type: av.KeyTypeText, Text: &av.ValueText{Content: groupValue}} if av.KeyTypeSelect == groupKey.Type || av.KeyTypeMSelect == groupKey.Type { if opt := groupKey.GetOption(groupValue); nil != opt { v.GroupVal.Text = nil v.GroupVal.Type = av.KeyTypeSelect v.GroupVal.MSelect = []*av.ValueSelect{{Content: opt.Name, Color: opt.Color}} } } else if av.KeyTypeRelation == groupKey.Type { if relationDestAv != nil && groupValueDefault != groupValue { v.GroupVal.Text = nil v.GroupVal.Type = av.KeyTypeRelation v.GroupVal.Relation = &av.ValueRelation{BlockIDs: []string{groupValue}}
if destBlock := relationDestAv.GetBlockValue(groupValue); nil != destBlock { v.GroupVal.Relation.Contents = []*av.Value{destBlock} } } } else if av.KeyTypeCheckbox == groupKey.Type { v.GroupVal.Text = nil v.GroupVal.Type = av.KeyTypeCheckbox v.GroupVal.Checkbox = &av.ValueCheckbox{} if "" != groupValue { v.GroupVal.Checkbox.Checked = true } } v.GroupSort = -1 view.Groups = append(view.Groups, v) }
view.GroupCreated = time.Now().UnixMilli() setAttrViewGroupStates(view, groupStates)}
// GroupState 用于临时记录每个分组视图的状态，以便后面重新生成分组后可以恢复这些状态。type GroupState struct { ID string Folded bool Hidden int Sort int ItemIDs []string}
func getAttrViewGroupStates(view *av.View) (groupStates map[string]*GroupState) { groupStates = map[string]*GroupState{} if !view.IsGroupView() { return }
for _, groupView := range view.Groups { if av.LayoutTypeKanban == groupView.LayoutType { // 看板视图的分组不能折叠 groupView.GroupFolded = false }
groupStates[groupView.GetGroupValue()] = &GroupState{ ID: groupView.ID, Folded: groupView.GroupFolded, Hidden: groupView.GroupHidden, Sort: groupView.GroupSort, ItemIDs: groupView.GroupItemIDs, } } return}
func setAttrViewGroupStates(view *av.View, groupStates map[string]*GroupState) { for _, groupView := range view.Groups { if state, ok := groupStates[groupView.GetGroupValue()]; ok { groupView.ID = state.ID groupView.GroupFolded = state.Folded groupView.GroupHidden = state.Hidden groupView.GroupSort = state.Sort
itemIDsSort := map[string]int{} for i, itemID := range state.ItemIDs { itemIDsSort[itemID] = i }
sort.SliceStable(groupView.GroupItemIDs, func(i, j int) bool { return itemIDsSort[groupView.GroupItemIDs[i]] < itemIDsSort[groupView.GroupItemIDs[j]] }) } }
defaultGroup := view.GetGroupByGroupValue(groupValueDefault) if nil != defaultGroup { if -1 == defaultGroup.GroupSort { view.RemoveGroupByID(defaultGroup.ID) } else { defaultGroup = nil } }
for i, groupView := range view.Groups { if i != groupView.GroupSort && -1 == groupView.GroupSort { groupView.GroupSort = i } }
if nil != defaultGroup { view.Groups = append(view.Groups, defaultGroup) defaultGroup.GroupSort = len(view.Groups) - 1 }}
func GetCurrentAttributeViewImages(avID, viewID, query string) (ret []string, err error) { var attrView *av.AttributeView attrView, err = av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return } var view *av.View
if "" != viewID { view, _ = attrView.GetCurrentView(viewID) } else { view = attrView.GetView(attrView.ViewID) }
cachedAttrViews := map[string]*av.AttributeView{} rollupFurtherCollections := sql.GetFurtherCollections(attrView, cachedAttrViews) table := getAttrViewTable(attrView, view, query) av.Filter(table, attrView, rollupFurtherCollections, cachedAttrViews) av.Sort(table, attrView)
ids := map[string]bool{} for _, column := range table.Columns { ids[column.ID] = column.Hidden }
for _, row := range table.Rows { for _, cell := range row.Cells { if nil != cell.Value && av.KeyTypeMAsset == cell.Value.Type && nil != cell.Value.MAsset && !ids[cell.Value.KeyID] { for _, a := range cell.Value.MAsset { if av.AssetTypeImage == a.Type { ret = append(ret, a.Content) } } } } } return}
func (tx *Transaction) doSetAttrViewColDateFillCreated(operation *Operation) (ret *TxErr) { err := setAttributeViewColDateFillCreated(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttributeViewColDateFillCreated(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
keyID := operation.ID key, _ := attrView.GetKey(keyID) if nil == key || av.KeyTypeDate != key.Type { return }
if nil == key.Date { key.Date = &av.Date{} }
key.Date.AutoFillNow = operation.Data.(bool) err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewColDateFillSpecificTime(operation *Operation) (ret *TxErr) { err := setAttrViewColDateFillSpecificTime(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttrViewColDateFillSpecificTime(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
keyID := operation.ID dateValues, _ := attrView.GetKeyValues(keyID) if nil == dateValues || av.KeyTypeDate != dateValues.Key.Type { return }
if nil == dateValues.Key.Date { dateValues.Key.Date = &av.Date{} }
dateValues.Key.Date.FillSpecificTime = operation.Data.(bool) for _, v := range dateValues.Values { if !v.IsEmpty() { continue } if nil == v.Date { v.Date = &av.ValueDate{} } v.Date.IsNotTime = !dateValues.Key.Date.FillSpecificTime }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewCreatedIncludeTime(operation *Operation) (ret *TxErr) { err := setAttrViewCreatedIncludeTime(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttrViewCreatedIncludeTime(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
key, _ := attrView.GetKey(operation.ID) if nil == key { return }
if nil == key.Created { key.Created = &av.Created{} }
key.Created.IncludeTime = operation.Data.(bool) err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewUpdatedIncludeTime(operation *Operation) (ret *TxErr) { err := setAttrViewUpdatedIncludeTime(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttrViewUpdatedIncludeTime(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
key, _ := attrView.GetKey(operation.ID) if nil == key { return }
if nil == key.Updated { key.Updated = &av.Updated{} }
key.Updated.IncludeTime = operation.Data.(bool) err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doHideAttrViewName(operation *Operation) (ret *TxErr) { err := hideAttrViewName(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func hideAttrViewName(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", operation.AvID, err) return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if nil == view { logging.LogErrorf("get view [%s] failed: %s", operation.BlockID, err) return }
view.HideAttrViewName = operation.Data.(bool) err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doUpdateAttrViewColRollup(operation *Operation) (ret *TxErr) { err := updateAttributeViewColRollup(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func updateAttributeViewColRollup(operation *Operation) (err error) { // operation.AvID 汇总字段所在 av // operation.ID 汇总字段 ID // operation.ParentID 汇总字段基于的关联字段 ID // operation.KeyID 目标字段 ID // operation.Data 计算方式
attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
rollUpKey, _ := attrView.GetKey(operation.ID) if nil == rollUpKey { return }
rollUpKey.Rollup = &av.Rollup{ RelationKeyID: operation.ParentID, KeyID: operation.KeyID, }
if nil == operation.Data { return }
data := operation.Data.(map[string]interface{}) if nil != data["calc"] { calcData, jsonErr := gulu.JSON.MarshalJSON(data["calc"]) if nil != jsonErr { err = jsonErr return } if jsonErr = gulu.JSON.UnmarshalJSON(calcData, &rollUpKey.Rollup.Calc); nil != jsonErr { err = jsonErr return } }
// 如果存在该汇总字段的过滤条件，则移除该过滤条件 https://github.com/siyuan-note/siyuan/issues/15660 for _, view := range attrView.Views { for i, filter := range view.Filters { if filter.Column != rollUpKey.ID { continue }
view.Filters = append(view.Filters[:i], view.Filters[i+1:]...) } }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doUpdateAttrViewColRelation(operation *Operation) (ret *TxErr) { err := updateAttributeViewColRelation(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func updateAttributeViewColRelation(operation *Operation) (err error) { // operation.AvID 源 avID // operation.ID 目标 avID // operation.KeyID 源 av 关联字段 ID // operation.IsTwoWay 是否双向关联 // operation.BackRelationKeyID 双向关联的目标关联字段 ID // operation.Name 双向关联的目标关联字段名称 // operation.Format 源 av 关联字段名称
srcAv, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
destAv, err := av.ParseAttributeView(operation.ID) if err != nil { return }
isSameAv := srcAv.ID == destAv.ID if isSameAv { destAv = srcAv }
for _, keyValues := range srcAv.KeyValues { if keyValues.Key.ID != operation.KeyID { continue }
srcRel := keyValues.Key.Relation // 已经设置过双向关联的话需要先断开双向关联 if nil != srcRel { if srcRel.IsTwoWay { oldDestAv, _ := av.ParseAttributeView(srcRel.AvID) if nil != oldDestAv { isOldSameAv := oldDestAv.ID == destAv.ID if isOldSameAv { oldDestAv = destAv }
oldDestKey, _ := oldDestAv.GetKey(srcRel.BackKeyID) if nil != oldDestKey && nil != oldDestKey.Relation && oldDestKey.Relation.AvID == srcAv.ID && oldDestKey.Relation.IsTwoWay { oldDestKey.Relation.IsTwoWay = false oldDestKey.Relation.BackKeyID = "" }
if !isOldSameAv { err = av.SaveAttributeView(oldDestAv) if err != nil { return } } } }
av.RemoveAvRel(srcAv.ID, srcRel.AvID) }
srcRel = &av.Relation{ AvID: operation.ID, IsTwoWay: operation.IsTwoWay, } if operation.IsTwoWay { srcRel.BackKeyID = operation.BackRelationKeyID } else { srcRel.BackKeyID = "" } keyValues.Key.Relation = srcRel keyValues.Key.Name = operation.Format
break }
destAdded := false backRelKey, _ := destAv.GetKey(operation.BackRelationKeyID) if nil != backRelKey { backRelKey.Relation = &av.Relation{ AvID: operation.AvID, IsTwoWay: operation.IsTwoWay, BackKeyID: operation.KeyID, } destAdded = true if operation.IsTwoWay { name := strings.TrimSpace(operation.Name) if "" == name { name = srcAv.Name + " " + operation.Format } backRelKey.Name = strings.TrimSpace(name) } else { backRelKey.Relation.BackKeyID = "" } }
if !destAdded && operation.IsTwoWay { // 新建双向关联目标字段 name := strings.TrimSpace(operation.Name) if "" == name { name = srcAv.Name + " " + operation.Format name = strings.TrimSpace(name) }
destKeyValues := &av.KeyValues{ Key: &av.Key{ ID: operation.BackRelationKeyID, Name: name, Type: av.KeyTypeRelation, Relation: &av.Relation{AvID: operation.AvID, IsTwoWay: operation.IsTwoWay, BackKeyID: operation.KeyID}, }, } destAv.KeyValues = append(destAv.KeyValues, destKeyValues)
for _, v := range destAv.Views { switch v.LayoutType { case av.LayoutTypeTable: v.Table.Columns = append(v.Table.Columns, &av.ViewTableColumn{BaseField: &av.BaseField{ID: operation.BackRelationKeyID}}) case av.LayoutTypeGallery: v.Gallery.CardFields = append(v.Gallery.CardFields, &av.ViewGalleryCardField{BaseField: &av.BaseField{ID: operation.BackRelationKeyID}}) case av.LayoutTypeKanban: v.Kanban.Fields = append(v.Kanban.Fields, &av.ViewKanbanField{BaseField: &av.BaseField{ID: operation.BackRelationKeyID}}) } }
now := time.Now().UnixMilli() // 和现有值进行关联 for _, keyValues := range srcAv.KeyValues { if keyValues.Key.ID != operation.KeyID { continue }
for _, srcVal := range keyValues.Values { for _, blockID := range srcVal.Relation.BlockIDs { destVal := destAv.GetValue(destKeyValues.Key.ID, blockID) if nil == destVal { destVal = &av.Value{ID: ast.NewNodeID(), KeyID: destKeyValues.Key.ID, BlockID: blockID, Type: keyValues.Key.Type, Relation: &av.ValueRelation{}, CreatedAt: now, UpdatedAt: now + 1000} } else { destVal.Type = keyValues.Key.Type if nil == destVal.Relation { destVal.Relation = &av.ValueRelation{} } destVal.UpdatedAt = now destVal.IsRenderAutoFill = false } destVal.Relation.BlockIDs = append(destVal.Relation.BlockIDs, srcVal.BlockID) destVal.Relation.BlockIDs = gulu.Str.RemoveDuplicatedElem(destVal.Relation.BlockIDs) destKeyValues.Values = append(destKeyValues.Values, destVal) } } } }
regenAttrViewGroups(srcAv) err = av.SaveAttributeView(srcAv) if err != nil { return } if !isSameAv { regenAttrViewGroups(destAv) err = av.SaveAttributeView(destAv) ReloadAttrView(destAv.ID) }
av.UpsertAvBackRel(srcAv.ID, destAv.ID) if operation.IsTwoWay && !isSameAv { av.UpsertAvBackRel(destAv.ID, srcAv.ID) } return}
func (tx *Transaction) doSortAttrViewView(operation *Operation) (ret *TxErr) { avID := operation.AvID attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", operation.AvID, err) return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} }
view := attrView.GetView(operation.ID) if nil == view { logging.LogErrorf("get view failed: %s", operation.BlockID) return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } viewID := view.ID previousViewID := operation.PreviousID if viewID == previousViewID { return }
var index, previousIndex int for i, v := range attrView.Views { if v.ID == viewID { view = v index = i break } }
attrView.Views = append(attrView.Views[:index], attrView.Views[index+1:]...) for i, v := range attrView.Views { if v.ID == previousViewID { previousIndex = i + 1 break } } attrView.Views = util.InsertElem(attrView.Views, previousIndex, view)
if err = av.SaveAttributeView(attrView); err != nil { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return &TxErr{code: TxErrCodeWriteTree, msg: err.Error(), id: avID} } return}
func (tx *Transaction) doRemoveAttrViewView(operation *Operation) (ret *TxErr) { var err error avID := operation.AvID attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return &TxErr{code: TxErrCodeBlockNotFound, id: avID} }
if 1 >= len(attrView.Views) { logging.LogWarnf("can't remove last view [%s] of attribute view [%s]", operation.AvID, avID) return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if nil == view { logging.LogWarnf("get view failed: %s", operation.BlockID) return }
viewID := view.ID var index int for i, view := range attrView.Views { if viewID == view.ID { attrView.Views = append(attrView.Views[:i], attrView.Views[i+1:]...) index = i - 1 break } } if 0 > index { index = 0 }
view = attrView.Views[index] attrView.ViewID = view.ID if err = av.SaveAttributeView(attrView); err != nil { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return &TxErr{code: TxErrCodeWriteTree, msg: err.Error(), id: avID} }
trees, nodes := getMirrorBlocksNodes(avID) for _, node := range nodes { attrs := parse.IAL2Map(node.KramdownIAL) blockViewID := attrs[av.NodeAttrView] if blockViewID == viewID { attrs[av.NodeAttrView] = attrView.ViewID node.AttributeViewType = string(view.LayoutType) oldAttrs, e := setNodeAttrs0(node, attrs) if nil != e { logging.LogErrorf("set node attrs failed: %s", e) continue }
cache.PutBlockIAL(node.ID, parse.IAL2Map(node.KramdownIAL)) pushBroadcastAttrTransactions(oldAttrs, node) } }
for _, tree := range trees { if err = indexWriteTreeUpsertQueue(tree); err != nil { return } }
operation.RetData = view.LayoutType return}
func getMirrorBlocksNodes(avID string) (trees []*parse.Tree, nodes []*ast.Node) { mirrorBlockIDs := treenode.GetMirrorAttrViewBlockIDs(avID) mirrorBlockTrees := filesys.LoadTrees(mirrorBlockIDs) for id, tree := range mirrorBlockTrees { node := treenode.GetNodeInTree(tree, id) if nil == node { logging.LogErrorf("get node in tree by block ID [%s] failed", id) continue } nodes = append(nodes, node) }
for _, tree := range mirrorBlockTrees { trees = append(trees, tree) } return}
func (tx *Transaction) doDuplicateAttrViewView(operation *Operation) (ret *TxErr) { var err error avID := operation.AvID attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return &TxErr{code: TxErrHandleAttributeView, id: avID} }
masterView := attrView.GetView(operation.PreviousID) if nil == masterView { logging.LogErrorf("get master view failed: %s", avID) return &TxErr{code: TxErrHandleAttributeView, id: avID} }
node, tree, _ := getNodeByBlockID(nil, operation.BlockID) if nil == node { logging.LogErrorf("get node by block ID [%s] failed", operation.BlockID) return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID} }
attrs := parse.IAL2Map(node.KramdownIAL) attrs[av.NodeAttrView] = operation.ID node.AttributeViewType = string(masterView.LayoutType) err = setNodeAttrs(node, tree, attrs) if err != nil { logging.LogWarnf("set node [%s] attrs failed: %s", operation.BlockID, err) return }
var view *av.View switch masterView.LayoutType { case av.LayoutTypeTable: view = av.NewTableView() case av.LayoutTypeGallery: view = av.NewGalleryView() case av.LayoutTypeKanban: view = av.NewKanbanView() }
view.ID = operation.ID attrView.Views = append(attrView.Views, view) attrView.ViewID = view.ID
view.Icon = masterView.Icon view.Name = util.GetDuplicateName(masterView.Name) view.HideAttrViewName = masterView.HideAttrViewName view.Desc = masterView.Desc view.LayoutType = masterView.LayoutType view.PageSize = masterView.PageSize
for _, filter := range masterView.Filters { view.Filters = append(view.Filters, &av.ViewFilter{ Column: filter.Column, Qualifier: filter.Qualifier, Operator: filter.Operator, Value: filter.Value, RelativeDate: filter.RelativeDate, RelativeDate2: filter.RelativeDate2, }) }
for _, s := range masterView.Sorts { view.Sorts = append(view.Sorts, &av.ViewSort{ Column: s.Column, Order: s.Order, }) }
switch masterView.LayoutType { case av.LayoutTypeTable: for _, col := range masterView.Table.Columns { view.Table.Columns = append(view.Table.Columns, &av.ViewTableColumn{ BaseField: &av.BaseField{ ID: col.ID, Wrap: col.Wrap, Hidden: col.Hidden, Desc: col.Desc, }, Pin: col.Pin, Width: col.Width, Calc: col.Calc, }) }
view.Table.ShowIcon = masterView.Table.ShowIcon view.Table.WrapField = masterView.Table.WrapField case av.LayoutTypeGallery: for _, field := range masterView.Gallery.CardFields { view.Gallery.CardFields = append(view.Gallery.CardFields, &av.ViewGalleryCardField{ BaseField: &av.BaseField{ ID: field.ID, Wrap: field.Wrap, Hidden: field.Hidden, Desc: field.Desc, }, }) }
view.Gallery.CoverFrom = masterView.Gallery.CoverFrom view.Gallery.CoverFromAssetKeyID = masterView.Gallery.CoverFromAssetKeyID view.Gallery.CardSize = masterView.Gallery.CardSize view.Gallery.FitImage = masterView.Gallery.FitImage view.Gallery.DisplayFieldName = masterView.Gallery.DisplayFieldName view.Gallery.ShowIcon = masterView.Gallery.ShowIcon view.Gallery.WrapField = masterView.Gallery.WrapField case av.LayoutTypeKanban: for _, field := range masterView.Kanban.Fields { view.Kanban.Fields = append(view.Kanban.Fields, &av.ViewKanbanField{ BaseField: &av.BaseField{ ID: field.ID, Wrap: field.Wrap, Hidden: field.Hidden, Desc: field.Desc, }, }) }
view.Kanban.CoverFrom = masterView.Kanban.CoverFrom view.Kanban.CoverFromAssetKeyID = masterView.Kanban.CoverFromAssetKeyID view.Kanban.CardSize = masterView.Kanban.CardSize view.Kanban.FitImage = masterView.Kanban.FitImage view.Kanban.DisplayFieldName = masterView.Kanban.DisplayFieldName view.Kanban.FillColBackgroundColor = masterView.Kanban.FillColBackgroundColor view.Kanban.ShowIcon = masterView.Kanban.ShowIcon view.Kanban.WrapField = masterView.Kanban.WrapField }
view.ItemIDs = masterView.ItemIDs
if nil != masterView.Group { view.Group = &av.ViewGroup{} if copyErr := copier.Copy(view.Group, masterView.Group); nil != copyErr { logging.LogErrorf("copy group failed: %s", copyErr) return &TxErr{code: TxErrHandleAttributeView, id: avID, msg: copyErr.Error()} }
view.GroupItemIDs = masterView.GroupItemIDs regenAttrViewGroups(attrView) }
if err = av.SaveAttributeView(attrView); err != nil { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return &TxErr{code: TxErrHandleAttributeView, msg: err.Error(), id: avID} } return}
func (tx *Transaction) doAddAttrViewView(operation *Operation) (ret *TxErr) { err := addAttrViewView(operation.AvID, operation.ID, operation.BlockID, operation.Layout) if nil != err { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func addAttrViewView(avID, viewID, blockID string, layout av.LayoutType) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return }
if 1 > len(attrView.Views) { logging.LogErrorf("no view in attribute view [%s]", avID) return }
firstView := attrView.Views[0] if nil == firstView { logging.LogErrorf("get first view failed: %s", avID) return }
if "" == layout { layout = av.LayoutTypeTable }
var view *av.View switch layout { case av.LayoutTypeTable: view = av.NewTableView() switch firstView.LayoutType { case av.LayoutTypeTable: for _, col := range firstView.Table.Columns { view.Table.Columns = append(view.Table.Columns, &av.ViewTableColumn{BaseField: &av.BaseField{ID: col.ID}, Width: col.Width}) } case av.LayoutTypeGallery: for _, field := range firstView.Gallery.CardFields { view.Table.Columns = append(view.Table.Columns, &av.ViewTableColumn{BaseField: &av.BaseField{ID: field.ID}}) } case av.LayoutTypeKanban: for _, field := range firstView.Kanban.Fields { view.Table.Columns = append(view.Table.Columns, &av.ViewTableColumn{BaseField: &av.BaseField{ID: field.ID}}) } } case av.LayoutTypeGallery: view = av.NewGalleryView() switch firstView.LayoutType { case av.LayoutTypeTable: for _, col := range firstView.Table.Columns { view.Gallery.CardFields = append(view.Gallery.CardFields, &av.ViewGalleryCardField{BaseField: &av.BaseField{ID: col.ID}}) } case av.LayoutTypeGallery: for _, field := range firstView.Gallery.CardFields { view.Gallery.CardFields = append(view.Gallery.CardFields, &av.ViewGalleryCardField{BaseField: &av.BaseField{ID: field.ID}}) } case av.LayoutTypeKanban: for _, field := range firstView.Kanban.Fields { view.Gallery.CardFields = append(view.Gallery.CardFields, &av.ViewGalleryCardField{BaseField: &av.BaseField{ID: field.ID}}) } } case av.LayoutTypeKanban: view = av.NewKanbanView() switch firstView.LayoutType { case av.LayoutTypeTable: for _, col := range firstView.Table.Columns { view.Kanban.Fields = append(view.Kanban.Fields, &av.ViewKanbanField{BaseField: &av.BaseField{ID: col.ID}}) } case av.LayoutTypeGallery: for _, field := range firstView.Gallery.CardFields { view.Kanban.Fields = append(view.Kanban.Fields, &av.ViewKanbanField{BaseField: &av.BaseField{ID: field.ID}}) } case av.LayoutTypeKanban: for _, field := range firstView.Kanban.Fields { view.Kanban.Fields = append(view.Kanban.Fields, &av.ViewKanbanField{BaseField: &av.BaseField{ID: field.ID}}) } } default: err = av.ErrWrongLayoutType logging.LogErrorf("wrong layout type [%s] for attribute view [%s]", layout, avID) return }
view.ItemIDs = firstView.ItemIDs attrView.ViewID = viewID view.ID = viewID attrView.Views = append(attrView.Views, view)
if av.LayoutTypeKanban == layout { preferredGroupKey := getKanbanPreferredGroupKey(attrView) group := &av.ViewGroup{Field: preferredGroupKey.ID} setAttributeViewGroup(attrView, view, group) }
node, tree, _ := getNodeByBlockID(nil, blockID) if nil == node { logging.LogErrorf("get node by block ID [%s] failed", blockID) return }
node.AttributeViewType = string(view.LayoutType) attrs := parse.IAL2Map(node.KramdownIAL) attrs[av.NodeAttrView] = viewID err = setNodeAttrs(node, tree, attrs) if err != nil { logging.LogWarnf("set node [%s] attrs failed: %s", blockID, err) return }
if err = av.SaveAttributeView(attrView); err != nil { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return } return}
func getKanbanPreferredGroupKey(attrView *av.AttributeView) (ret *av.Key) { for _, kv := range attrView.KeyValues { if av.KeyTypeSelect == kv.Key.Type { ret = kv.Key break } }
if nil == ret { name := av.GetAttributeViewI18n("select") ret = av.NewKey(ast.NewNodeID(), name, "", av.KeyTypeSelect) attrView.KeyValues = append(attrView.KeyValues, &av.KeyValues{Key: ret}) for _, view := range attrView.Views { newField := &av.BaseField{ID: ret.ID} if nil != view.Table { newField.Wrap = view.Table.WrapField view.Table.Columns = append(view.Table.Columns, &av.ViewTableColumn{BaseField: newField}) }
if nil != view.Gallery { newField.Wrap = view.Gallery.WrapField view.Gallery.CardFields = append(view.Gallery.CardFields, &av.ViewGalleryCardField{BaseField: newField}) }
if nil != view.Kanban { newField.Wrap = view.Kanban.WrapField view.Kanban.Fields = append(view.Kanban.Fields, &av.ViewKanbanField{BaseField: newField}) } } } return}
func (tx *Transaction) doSetAttrViewViewName(operation *Operation) (ret *TxErr) { var err error avID := operation.AvID attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return &TxErr{code: TxErrHandleAttributeView, id: avID} }
viewID := operation.ID view := attrView.GetView(viewID) if nil == view { logging.LogErrorf("get view [%s] failed: %s", viewID, err) return &TxErr{code: TxErrHandleAttributeView, id: viewID} }
view.Name = strings.TrimSpace(operation.Data.(string)) if err = av.SaveAttributeView(attrView); err != nil { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return &TxErr{code: TxErrHandleAttributeView, msg: err.Error(), id: avID} } return}
func (tx *Transaction) doSetAttrViewViewIcon(operation *Operation) (ret *TxErr) { var err error avID := operation.AvID attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return &TxErr{code: TxErrHandleAttributeView, id: avID} }
viewID := operation.ID view := attrView.GetView(viewID) if nil == view { logging.LogErrorf("get view [%s] failed: %s", viewID, err) return &TxErr{code: TxErrHandleAttributeView, id: viewID} }
view.Icon = operation.Data.(string) if err = av.SaveAttributeView(attrView); err != nil { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return &TxErr{code: TxErrHandleAttributeView, msg: err.Error(), id: avID} } return}
func (tx *Transaction) doSetAttrViewViewDesc(operation *Operation) (ret *TxErr) { var err error avID := operation.AvID attrView, err := av.ParseAttributeView(avID) if err != nil { logging.LogErrorf("parse attribute view [%s] failed: %s", avID, err) return &TxErr{code: TxErrHandleAttributeView, id: avID} }
viewID := operation.ID view := attrView.GetView(viewID) if nil == view { logging.LogErrorf("get view [%s] failed: %s", viewID, err) return &TxErr{code: TxErrHandleAttributeView, id: viewID} }
view.Desc = strings.TrimSpace(operation.Data.(string)) if err = av.SaveAttributeView(attrView); err != nil { logging.LogErrorf("save attribute view [%s] failed: %s", avID, err) return &TxErr{code: TxErrHandleAttributeView, msg: err.Error(), id: avID} } return}
func (tx *Transaction) doSetAttrViewName(operation *Operation) (ret *TxErr) { err := tx.setAttributeViewName(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
const attrAvNameTpl = `<span data-av-id="${avID}" data-popover-url="/api/av/getMirrorDatabaseBlocks" class="popover__block">${avName}</span>`
func (tx *Transaction) setAttributeViewName(operation *Operation) (err error) { avID := operation.ID attrView, err := av.ParseAttributeView(avID) if err != nil { return }
attrView.Name = strings.TrimSpace(operation.Data.(string)) attrView.Name = strings.ReplaceAll(attrView.Name, "\n", " ") if 512 < utf8.RuneCountInString(attrView.Name) { attrView.Name = gulu.Str.SubStr(attrView.Name, 512) } err = av.SaveAttributeView(attrView)
_, nodes := tx.getAttrViewBoundNodes(attrView) for _, node := range nodes { avNames := getAvNames(node.IALAttr(av.NodeAttrNameAvs)) oldAttrs := parse.IAL2Map(node.KramdownIAL) node.SetIALAttr(av.NodeAttrViewNames, avNames) pushBroadcastAttrTransactions(oldAttrs, node) } return}
func getAvNames(avIDs string) (ret string) { if "" == avIDs { return } avNames := bytes.Buffer{} nodeAvIDs := strings.Split(avIDs, ",") for _, nodeAvID := range nodeAvIDs { nodeAvName, getErr := av.GetAttributeViewName(nodeAvID) if nil != getErr { continue } if "" == nodeAvName { nodeAvName = Conf.language(105) }
tpl := strings.ReplaceAll(attrAvNameTpl, "${avID}", nodeAvID) tpl = strings.ReplaceAll(tpl, "${avName}", nodeAvName) avNames.WriteString(tpl) avNames.WriteString(" ") } if 0 < avNames.Len() { avNames.Truncate(avNames.Len() - 6) ret = avNames.String() } return}
func (tx *Transaction) getAttrViewBoundNodes(attrView *av.AttributeView) (trees map[string]*parse.Tree, nodes []*ast.Node) { blockKeyValues := attrView.GetBlockKeyValues() trees = map[string]*parse.Tree{} for _, blockKeyValue := range blockKeyValues.Values { if blockKeyValue.IsDetached { continue }
var tree *parse.Tree tree = trees[blockKeyValue.Block.ID] if nil == tree { if nil == tx { tree, _ = LoadTreeByBlockID(blockKeyValue.Block.ID) } else { tree, _ = tx.loadTree(blockKeyValue.Block.ID) } } if nil == tree { continue } trees[blockKeyValue.Block.ID] = tree
node := treenode.GetNodeInTree(tree, blockKeyValue.Block.ID) if nil == node { continue }
nodes = append(nodes, node) } return}
func (tx *Transaction) doSetAttrViewFilters(operation *Operation) (ret *TxErr) { err := setAttributeViewFilters(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttributeViewFilters(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
operationData := operation.Data.([]interface{}) data, err := gulu.JSON.MarshalJSON(operationData) if err != nil { return }
if err = gulu.JSON.UnmarshalJSON(data, &view.Filters); err != nil { return }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewSorts(operation *Operation) (ret *TxErr) { err := setAttributeViewSorts(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttributeViewSorts(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
operationData := operation.Data.([]interface{}) data, err := gulu.JSON.MarshalJSON(operationData) if err != nil { return }
if err = gulu.JSON.UnmarshalJSON(data, &view.Sorts); err != nil { return }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewPageSize(operation *Operation) (ret *TxErr) { err := setAttributeViewPageSize(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttributeViewPageSize(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
view.PageSize = int(operation.Data.(float64))
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewColCalc(operation *Operation) (ret *TxErr) { err := setAttributeViewColumnCalc(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttributeViewColumnCalc(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
operationData := operation.Data.(interface{}) data, err := gulu.JSON.MarshalJSON(operationData) if err != nil { return }
calc := &av.FieldCalc{} switch view.LayoutType { case av.LayoutTypeTable: if err = gulu.JSON.UnmarshalJSON(data, calc); err != nil { return }
for _, column := range view.Table.Columns { if column.ID == operation.ID { column.Calc = calc break } } case av.LayoutTypeGallery, av.LayoutTypeKanban: return }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doInsertAttrViewBlock(operation *Operation) (ret *TxErr) { err := AddAttributeViewBlock(tx, operation.Srcs, operation.AvID, operation.BlockID, operation.ViewID, operation.GroupID, operation.PreviousID, operation.IgnoreDefaultFill) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func AddAttributeViewBlock(tx *Transaction, srcs []map[string]interface{}, avID, dbBlockID, viewID, groupID, previousItemID string, ignoreDefaultFill bool) (err error) { slices.Reverse(srcs) // https://github.com/siyuan-note/siyuan/issues/11286
now := time.Now().UnixMilli() for _, src := range srcs { boundBlockID := "" srcItemID := ast.NewNodeID() if nil != src["itemID"] { srcItemID = src["itemID"].(string) }
isDetached := src["isDetached"].(bool) var tree *parse.Tree if !isDetached { boundBlockID = src["id"].(string) if !ast.IsNodeIDPattern(boundBlockID) { continue }
var loadErr error if nil != tx { tree, loadErr = tx.loadTree(boundBlockID) } else { tree, loadErr = LoadTreeByBlockID(boundBlockID) } if nil != loadErr { logging.LogErrorf("load tree [%s] failed: %s", boundBlockID, loadErr) return loadErr } }
var srcContent string if nil != src["content"] { srcContent = src["content"].(string) } if avErr := addAttributeViewBlock(now, avID, dbBlockID, viewID, groupID, previousItemID, srcItemID, boundBlockID, srcContent, isDetached, ignoreDefaultFill, tree, tx); nil != avErr { return avErr } } return}
func addAttributeViewBlock(now int64, avID, dbBlockID, viewID, groupID, previousItemID, addingItemID, addingBoundBlockID, addingBlockContent string, isDetached, ignoreDefaultFill bool, tree *parse.Tree, tx *Transaction) (err error) { var node *ast.Node if !isDetached { node = treenode.GetNodeInTree(tree, addingBoundBlockID) if nil == node { err = ErrBlockNotFound return } } else { if "" == addingItemID { addingItemID = ast.NewNodeID() logging.LogWarnf("detached block id is empty, generate a new one [%s]", addingItemID) } }
attrView, err := av.ParseAttributeView(avID) if err != nil { return }
var blockIcon string if !isDetached { blockIcon, addingBlockContent = getNodeAvBlockText(node, "") addingBlockContent = util.UnescapeHTML(addingBlockContent) }
// 检查是否重复添加相同的块 blockValues := attrView.GetBlockKeyValues() for _, blockValue := range blockValues.Values { if "" != addingBoundBlockID && blockValue.Block.ID == addingBoundBlockID { if !isDetached { // 重复绑定一下，比如剪切数据库块、取消绑定块后再次添加的场景需要 bindBlockAv0(tx, avID, node, tree) blockValue.IsDetached = isDetached blockValue.Block.Icon = blockIcon blockValue.Block.Content = addingBlockContent blockValue.UpdatedAt = now err = av.SaveAttributeView(attrView) }
msg := fmt.Sprintf(Conf.language(269), getAttrViewName(attrView)) util.PushMsg(msg, 5000) return } }
blockValue := &av.Value{ ID: ast.NewNodeID(), KeyID: blockValues.Key.ID, BlockID: addingItemID, Type: av.KeyTypeBlock, IsDetached: isDetached, CreatedAt: now, UpdatedAt: now, Block: &av.ValueBlock{Icon: blockIcon, Content: addingBlockContent, Created: now, Updated: now}} if !isDetached { blockValue.Block.ID = addingBoundBlockID }
blockValues.Values = append(blockValues.Values, blockValue)
view, err := getAttrViewViewByBlockID(attrView, dbBlockID) if nil != err { logging.LogErrorf("get view by block ID [%s] failed: %s", dbBlockID, err) return }
if "" != viewID { view = attrView.GetView(viewID) if nil == view { logging.LogErrorf("get view by view ID [%s] failed", viewID) return av.ErrViewNotFound } }
groupView := view if "" != groupID { groupView = view.GetGroupByID(groupID) }
if !ignoreDefaultFill { fillDefaultValue(attrView, view, groupView, previousItemID, addingItemID, true) }
// 处理日期字段默认填充当前创建时间 // The database date field supports filling the current time by default https://github.com/siyuan-note/siyuan/issues/10823 for _, keyValues := range attrView.KeyValues { if av.KeyTypeDate == keyValues.Key.Type && nil != keyValues.Key.Date && keyValues.Key.Date.AutoFillNow { val := keyValues.GetValue(addingItemID) if nil == val { // 避免覆盖已有值（可能前面已经通过过滤或者分组条件填充了值） dateVal := &av.Value{ ID: ast.NewNodeID(), KeyID: keyValues.Key.ID, BlockID: addingItemID, Type: av.KeyTypeDate, IsDetached: isDetached, CreatedAt: now, UpdatedAt: now + 1000, Date: &av.ValueDate{Content: now, IsNotEmpty: true, IsNotTime: !keyValues.Key.Date.FillSpecificTime}, } keyValues.Values = append(keyValues.Values, dateVal) } else { if val.IsRenderAutoFill { val.CreatedAt, val.UpdatedAt = now, now+1000 val.Date.Content, val.Date.IsNotEmpty, val.Date.IsNotTime = now, true, !keyValues.Key.Date.FillSpecificTime val.IsRenderAutoFill = false } } } }
if !isDetached { bindBlockAv0(tx, avID, node, tree) }
// 在所有视图上添加项目 for _, v := range attrView.Views { if "" != previousItemID { changed := false for i, id := range v.ItemIDs { if id == previousItemID { v.ItemIDs = append(v.ItemIDs[:i+1], append([]string{addingItemID}, v.ItemIDs[i+1:]...)...) changed = true break } } if !changed { v.ItemIDs = append(v.ItemIDs, addingItemID) } } else { v.ItemIDs = append([]string{addingItemID}, v.ItemIDs...) }
// 在所有分组视图中添加，目的是为了在重新分组的过程中保住排序状态 https://github.com/siyuan-note/siyuan/issues/15560 for _, g := range v.Groups { if "" != previousItemID { changed := false for i, id := range g.GroupItemIDs { if id == previousItemID { g.GroupItemIDs = append(g.GroupItemIDs[:i+1], append([]string{addingItemID}, g.GroupItemIDs[i+1:]...)...) changed = true break } } if !changed { g.GroupItemIDs = append(g.GroupItemIDs, addingItemID) } } else { g.GroupItemIDs = append([]string{addingItemID}, g.GroupItemIDs...) } } }
regenAttrViewGroups(attrView) err = av.SaveAttributeView(attrView) return}
func fillDefaultValue(attrView *av.AttributeView, view, groupView *av.View, previousItemID, addingItemID string, isCreate bool) { defaultValues := getAttrViewAddingBlockDefaultValues(attrView, view, groupView, previousItemID, addingItemID, isCreate) for keyID, newValue := range defaultValues { newValue.BlockID = addingItemID keyValues, getErr := attrView.GetKeyValues(keyID) if nil != getErr { continue }
if av.KeyTypeRollup == newValue.Type { // 汇总字段的值是渲染时计算的，不需要添加到数据存储中 continue }
if (av.KeyTypeSelect == newValue.Type || av.KeyTypeMSelect == newValue.Type) && 1 > len(newValue.MSelect) && groupValueDefault != groupView.GetGroupValue() { // 单选或多选类型的值可能需要从分组条件中获取默认值 if opt := keyValues.Key.GetOption(groupView.GetGroupValue()); nil != opt { newValue.MSelect = append(newValue.MSelect, &av.ValueSelect{Content: opt.Name, Color: opt.Color}) } }
if av.KeyTypeRelation == newValue.Type && nil != keyValues.Key.Relation && keyValues.Key.Relation.IsTwoWay { // 双向关联需要同时更新目标字段的值 updateTwoWayRelationDestAttrView(attrView, keyValues.Key, newValue, 1, []string{}) }
existingVal := keyValues.GetValue(addingItemID) if nil == existingVal { newValue.IsRenderAutoFill = false keyValues.Values = append(keyValues.Values, newValue) } else { newValueRaw := newValue.GetValByType(keyValues.Key.Type) if av.KeyTypeBlock != existingVal.Type || (av.KeyTypeBlock == existingVal.Type && existingVal.IsDetached) { // 非主键的值直接覆盖，主键的值只覆盖非绑定块 existingVal.IsRenderAutoFill = false existingVal.SetValByType(keyValues.Key.Type, newValueRaw) } } }}
func getNewValueByNearItem(nearItem av.Item, key *av.Key, addingBlockID string) (ret *av.Value) { if nil == nearItem { return }
defaultVal := nearItem.GetValue(key.ID) ret = defaultVal.Clone() ret.ID = ast.NewNodeID() ret.KeyID = key.ID ret.BlockID = addingBlockID ret.CreatedAt = util.CurrentTimeMillis() ret.UpdatedAt = ret.CreatedAt + 1000 return}
func getNearItem(attrView *av.AttributeView, view, groupView *av.View, previousItemID string) (ret av.Item) { cachedAttrViews := map[string]*av.AttributeView{} rollupFurtherCollections := sql.GetFurtherCollections(attrView, cachedAttrViews) viewable := sql.RenderGroupView(attrView, view, groupView, "") av.Filter(viewable, attrView, rollupFurtherCollections, cachedAttrViews) av.Sort(viewable, attrView) items := viewable.(av.Collection).GetItems() if 0 < len(items) { if "" != previousItemID { for _, row := range items { if row.GetID() == previousItemID { ret = row return } } } else { if 0 < len(items) { ret = items[0] return } } } return}
func (tx *Transaction) doRemoveAttrViewBlock(operation *Operation) (ret *TxErr) { err := removeAttributeViewBlock(operation.SrcIDs, operation.AvID, tx) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID} } return}
func RemoveAttributeViewBlock(srcIDs []string, avID string) (err error) { err = removeAttributeViewBlock(srcIDs, avID, nil) return}
func removeAttributeViewBlock(srcIDs []string, avID string, tx *Transaction) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return }
trees := map[string]*parse.Tree{} for _, keyValues := range attrView.KeyValues { tmp := keyValues.Values[:0] for i, val := range keyValues.Values { if !gulu.Str.Contains(val.BlockID, srcIDs) { tmp = append(tmp, keyValues.Values[i]) } else { // Remove av block also remove node attr https://github.com/siyuan-note/siyuan/issues/9091#issuecomment-1709824006 if !val.IsDetached && nil != val.Block { if bt := treenode.GetBlockTree(val.Block.ID); nil != bt { tree := trees[bt.RootID] if nil == tree { tree, _ = LoadTreeByBlockID(val.Block.ID) }
if nil != tree { trees[bt.RootID] = tree if node := treenode.GetNodeInTree(tree, val.Block.ID); nil != node { if err = removeNodeAvID(node, avID, tx, tree); err != nil { return } } } } } } } keyValues.Values = tmp }
for _, view := range attrView.Views { for _, blockID := range srcIDs { view.ItemIDs = gulu.Str.RemoveElem(view.ItemIDs, blockID) } }
regenAttrViewGroups(attrView)
err = av.SaveAttributeView(attrView) if nil != err { return }
refreshRelatedSrcAvs(avID, tx)
historyDir, err := GetHistoryDir(HistoryOpUpdate) if err != nil { logging.LogErrorf("get history dir failed: %s", err) return } blockIDs := treenode.GetMirrorAttrViewBlockIDs(avID) for _, blockID := range blockIDs { tree := trees[blockID] if nil == tree { tree, _ = LoadTreeByBlockID(blockID) } if nil == tree { continue }
historyPath := filepath.Join(historyDir, tree.Box, tree.Path) absPath := filepath.Join(util.DataDir, tree.Box, tree.Path) if err = filelock.Copy(absPath, historyPath); err != nil { logging.LogErrorf("backup [path=%s] to history [%s] failed: %s", absPath, historyPath, err) return } }
srcAvPath := filepath.Join(util.DataDir, "storage", "av", avID+".json") destAvPath := filepath.Join(historyDir, "storage", "av", avID+".json") if copyErr := filelock.Copy(srcAvPath, destAvPath); nil != copyErr { logging.LogErrorf("copy av [%s] failed: %s", srcAvPath, copyErr) }
indexHistoryDir(filepath.Base(historyDir), util.NewLute()) return}
func removeNodeAvID(node *ast.Node, avID string, tx *Transaction, tree *parse.Tree) (err error) { attrs := parse.IAL2Map(node.KramdownIAL) if ast.NodeDocument == node.Type { delete(attrs, "custom-hidden") node.RemoveIALAttr("custom-hidden") }
if avs := attrs[av.NodeAttrNameAvs]; "" != avs { avIDs := strings.Split(avs, ",") avIDs = gulu.Str.RemoveElem(avIDs, avID) var existAvIDs []string for _, attributeViewID := range avIDs { if av.IsAttributeViewExist(attributeViewID) { existAvIDs = append(existAvIDs, attributeViewID) } } avIDs = existAvIDs
if 0 == len(avIDs) { attrs[av.NodeAttrNameAvs] = "" } else { attrs[av.NodeAttrNameAvs] = strings.Join(avIDs, ",") node.SetIALAttr(av.NodeAttrNameAvs, strings.Join(avIDs, ",")) avNames := getAvNames(node.IALAttr(av.NodeAttrNameAvs)) attrs[av.NodeAttrViewNames] = avNames } }
if nil != tx { if err = setNodeAttrsWithTx(tx, node, tree, attrs); err != nil { return } } else { if err = setNodeAttrs(node, tree, attrs); err != nil { return } } return}
func (tx *Transaction) doDuplicateAttrViewKey(operation *Operation) (ret *TxErr) { err := duplicateAttributeViewKey(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func duplicateAttributeViewKey(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
key, _ := attrView.GetKey(operation.KeyID) if nil == key { return }
if av.KeyTypeBlock == key.Type || av.KeyTypeRelation == key.Type { return }
copyKey := &av.Key{} if err = copier.Copy(copyKey, key); err != nil { logging.LogErrorf("clone key failed: %s", err) } copyKey.ID = operation.NextID copyKey.Name = util.GetDuplicateName(key.Name)
attrView.KeyValues = append(attrView.KeyValues, &av.KeyValues{Key: copyKey})
for _, view := range attrView.Views { switch view.LayoutType { case av.LayoutTypeTable: for i, column := range view.Table.Columns { if column.ID == key.ID { view.Table.Columns = append(view.Table.Columns[:i+1], append([]*av.ViewTableColumn{ { BaseField: &av.BaseField{ ID: copyKey.ID, Wrap: column.Wrap, Hidden: column.Hidden, Desc: column.Desc, }, Pin: column.Pin, Width: column.Width, }, }, view.Table.Columns[i+1:]...)...) break } } case av.LayoutTypeGallery: for i, field := range view.Gallery.CardFields { if field.ID == key.ID { view.Gallery.CardFields = append(view.Gallery.CardFields[:i+1], append([]*av.ViewGalleryCardField{ { BaseField: &av.BaseField{ ID: copyKey.ID, Wrap: field.Wrap, Hidden: field.Hidden, Desc: field.Desc, }, }, }, view.Gallery.CardFields[i+1:]...)...) break } } case av.LayoutTypeKanban: for i, field := range view.Kanban.Fields { if field.ID == key.ID { view.Kanban.Fields = append(view.Kanban.Fields[:i+1], append([]*av.ViewKanbanField{ { BaseField: &av.BaseField{ ID: copyKey.ID, Wrap: field.Wrap, Hidden: field.Hidden, Desc: field.Desc, }, }, }, view.Kanban.Fields[i+1:]...)...) break } } } }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewColumnWidth(operation *Operation) (ret *TxErr) { err := setAttributeViewColWidth(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttributeViewColWidth(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
switch view.LayoutType { case av.LayoutTypeTable: for _, column := range view.Table.Columns { if column.ID == operation.ID { column.Width = operation.Data.(string) break } } case av.LayoutTypeGallery, av.LayoutTypeKanban: return }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewColumnWrap(operation *Operation) (ret *TxErr) { err := setAttributeViewColWrap(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttributeViewColWrap(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
newWrap := operation.Data.(bool) allFieldWrap := true switch view.LayoutType { case av.LayoutTypeTable: for _, column := range view.Table.Columns { if column.ID == operation.ID { column.Wrap = newWrap } allFieldWrap = allFieldWrap && column.Wrap } view.Table.WrapField = allFieldWrap case av.LayoutTypeGallery: for _, field := range view.Gallery.CardFields { if field.ID == operation.ID { field.Wrap = newWrap } allFieldWrap = allFieldWrap && field.Wrap } view.Gallery.WrapField = allFieldWrap case av.LayoutTypeKanban: for _, field := range view.Kanban.Fields { if field.ID == operation.ID { field.Wrap = newWrap } allFieldWrap = allFieldWrap && field.Wrap } view.Kanban.WrapField = allFieldWrap }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewColumnHidden(operation *Operation) (ret *TxErr) { err := setAttributeViewColHidden(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttributeViewColHidden(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
switch view.LayoutType { case av.LayoutTypeTable: for _, column := range view.Table.Columns { if column.ID == operation.ID { column.Hidden = operation.Data.(bool) break } } case av.LayoutTypeGallery: for _, field := range view.Gallery.CardFields { if field.ID == operation.ID { field.Hidden = operation.Data.(bool) break } } case av.LayoutTypeKanban: for _, field := range view.Kanban.Fields { if field.ID == operation.ID { field.Hidden = operation.Data.(bool) break } } }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewColumnPin(operation *Operation) (ret *TxErr) { err := setAttributeViewColPin(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttributeViewColPin(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
switch view.LayoutType { case av.LayoutTypeTable: for _, column := range view.Table.Columns { if column.ID == operation.ID { column.Pin = operation.Data.(bool) break } } case av.LayoutTypeGallery, av.LayoutTypeKanban: return }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewColumnIcon(operation *Operation) (ret *TxErr) { err := setAttributeViewColIcon(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttributeViewColIcon(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
for _, keyValues := range attrView.KeyValues { if keyValues.Key.ID == operation.ID { keyValues.Key.Icon = operation.Data.(string) break } }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewColumnDesc(operation *Operation) (ret *TxErr) { err := setAttributeViewColDesc(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttributeViewColDesc(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
for _, keyValues := range attrView.KeyValues { if keyValues.Key.ID == operation.ID { keyValues.Key.Desc = operation.Data.(string) break } }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSortAttrViewRow(operation *Operation) (ret *TxErr) { err := sortAttributeViewRow(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func sortAttributeViewRow(operation *Operation) (err error) { if operation.ID == operation.PreviousID { // 拖拽到自己的下方，不做任何操作 https://github.com/siyuan-note/siyuan/issues/11048 return }
attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, operation.BlockID) if err != nil { return }
var itemID string var idx, previousIndex int
if nil != view.Group && "" != operation.GroupID { if groupView := view.GetGroupByID(operation.GroupID); nil != groupView { groupKey := view.GetGroupKey(attrView) isAcrossGroup := operation.GroupID != operation.TargetGroupID if isAcrossGroup && (av.KeyTypeTemplate == groupKey.Type || av.KeyTypeCreated == groupKey.Type || av.KeyTypeUpdated == groupKey.Type) { // 这些字段类型不支持跨分组移动，因为它们的值是自动计算生成的 return }
for i, id := range groupView.GroupItemIDs { if id == operation.ID { itemID = id idx = i break } } if "" == itemID { itemID = operation.ID groupView.GroupItemIDs = append(groupView.GroupItemIDs, itemID) idx = len(groupView.GroupItemIDs) - 1 } groupView.GroupItemIDs = append(groupView.GroupItemIDs[:idx], groupView.GroupItemIDs[idx+1:]...)
if isAcrossGroup { if targetGroupView := view.GetGroupByID(operation.TargetGroupID); nil != targetGroupView && !gulu.Str.Contains(itemID, targetGroupView.GroupItemIDs) { fillDefaultValue(attrView, view, targetGroupView, operation.PreviousID, itemID, false)
if val := attrView.GetValue(groupKey.ID, itemID); nil != val { if av.MSelectExistOption(val.MSelect, groupView.GetGroupValue()) { // 移除旧分组的值 val.MSelect = av.MSelectRemoveOption(val.MSelect, groupView.GetGroupValue()) }
now := time.Now().UnixMilli() val.SetUpdatedAt(now) if blockVal := attrView.GetBlockValue(itemID); nil != blockVal { blockVal.Block.Updated = now blockVal.SetUpdatedAt(now) } }
for i, r := range targetGroupView.GroupItemIDs { if r == operation.PreviousID { previousIndex = i + 1 break } } targetGroupView.GroupItemIDs = util.InsertElem(targetGroupView.GroupItemIDs, previousIndex, itemID) }
regenAttrViewGroups(attrView) } else { // 同分组内排序 for i, r := range groupView.GroupItemIDs { if r == operation.PreviousID { previousIndex = i + 1 break } } groupView.GroupItemIDs = util.InsertElem(groupView.GroupItemIDs, previousIndex, itemID) } } } else { for i, id := range view.ItemIDs { if id == operation.ID { itemID = id idx = i break } } if "" == itemID { itemID = operation.ID view.ItemIDs = append(view.ItemIDs, itemID) idx = len(view.ItemIDs) - 1 }
view.ItemIDs = append(view.ItemIDs[:idx], view.ItemIDs[idx+1:]...) for i, r := range view.ItemIDs { if r == operation.PreviousID { previousIndex = i + 1 break } } view.ItemIDs = util.InsertElem(view.ItemIDs, previousIndex, itemID) }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSortAttrViewColumn(operation *Operation) (ret *TxErr) { err := SortAttributeViewViewKey(operation.AvID, operation.BlockID, operation.ID, operation.PreviousID) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func SortAttributeViewViewKey(avID, blockID, keyID, previousKeyID string) (err error) { if keyID == previousKeyID { // 拖拽到自己的右侧，不做任何操作 https://github.com/siyuan-note/siyuan/issues/11048 return }
attrView, err := av.ParseAttributeView(avID) if err != nil { return }
view, err := getAttrViewViewByBlockID(attrView, blockID) if err != nil { return }
var curIndex, previousIndex int switch view.LayoutType { case av.LayoutTypeTable: var col *av.ViewTableColumn for i, column := range view.Table.Columns { if column.ID == keyID { col = column curIndex = i break } } if nil == col { return }
view.Table.Columns = append(view.Table.Columns[:curIndex], view.Table.Columns[curIndex+1:]...) for i, column := range view.Table.Columns { if column.ID == previousKeyID { previousIndex = i + 1 break } } view.Table.Columns = util.InsertElem(view.Table.Columns, previousIndex, col) case av.LayoutTypeGallery: var field *av.ViewGalleryCardField for i, cardField := range view.Gallery.CardFields { if cardField.ID == keyID { field = cardField curIndex = i break } } if nil == field { return }
view.Gallery.CardFields = append(view.Gallery.CardFields[:curIndex], view.Gallery.CardFields[curIndex+1:]...) for i, cardField := range view.Gallery.CardFields { if cardField.ID == previousKeyID { previousIndex = i + 1 break } } view.Gallery.CardFields = util.InsertElem(view.Gallery.CardFields, previousIndex, field) case av.LayoutTypeKanban: var field *av.ViewKanbanField for i, kanbanField := range view.Kanban.Fields { if kanbanField.ID == keyID { field = kanbanField curIndex = i break } } if nil == field { return }
view.Kanban.Fields = append(view.Kanban.Fields[:curIndex], view.Kanban.Fields[curIndex+1:]...) for i, kanbanField := range view.Kanban.Fields { if kanbanField.ID == previousKeyID { previousIndex = i + 1 break } } view.Kanban.Fields = util.InsertElem(view.Kanban.Fields, previousIndex, field) }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSortAttrViewKey(operation *Operation) (ret *TxErr) { err := SortAttributeViewKey(operation.AvID, operation.ID, operation.PreviousID) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func SortAttributeViewKey(avID, keyID, previousKeyID string) (err error) { if keyID == previousKeyID { return }
attrView, err := av.ParseAttributeView(avID) if err != nil { return }
refreshAttrViewKeyIDs(attrView, false)
var currentKeyID string var idx, previousIndex int for i, k := range attrView.KeyIDs { if k == keyID { currentKeyID = k idx = i break } } if "" == currentKeyID { return }
attrView.KeyIDs = append(attrView.KeyIDs[:idx], attrView.KeyIDs[idx+1:]...)
for i, k := range attrView.KeyIDs { if k == previousKeyID { previousIndex = i + 1 break } } attrView.KeyIDs = util.InsertElem(attrView.KeyIDs, previousIndex, currentKeyID)
err = av.SaveAttributeView(attrView) return}
func refreshAttrViewKeyIDs(attrView *av.AttributeView, needSave bool) { // 订正 keyIDs 数据
existKeyIDs := map[string]bool{} for _, keyValues := range attrView.KeyValues { existKeyIDs[keyValues.Key.ID] = true }
for k, _ := range existKeyIDs { if !gulu.Str.Contains(k, attrView.KeyIDs) { attrView.KeyIDs = append(attrView.KeyIDs, k) } }
var tmp []string for _, k := range attrView.KeyIDs { if ok := existKeyIDs[k]; ok { tmp = append(tmp, k) } } attrView.KeyIDs = tmp
if needSave { av.SaveAttributeView(attrView) }}
func (tx *Transaction) doAddAttrViewColumn(operation *Operation) (ret *TxErr) { var icon string if nil != operation.Data { icon = operation.Data.(string) } err := AddAttributeViewKey(operation.AvID, operation.ID, operation.Name, operation.Typ, icon, operation.PreviousID)
if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func AddAttributeViewKey(avID, keyID, keyName, keyType, keyIcon, previousKeyID string) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return }
currentView, err := attrView.GetCurrentView(attrView.ViewID) if nil != err { return }
keyTyp := av.KeyType(keyType) switch keyTyp { case av.KeyTypeText, av.KeyTypeNumber, av.KeyTypeDate, av.KeyTypeSelect, av.KeyTypeMSelect, av.KeyTypeURL, av.KeyTypeEmail, av.KeyTypePhone, av.KeyTypeMAsset, av.KeyTypeTemplate, av.KeyTypeCreated, av.KeyTypeUpdated, av.KeyTypeCheckbox, av.KeyTypeRelation, av.KeyTypeRollup, av.KeyTypeLineNumber:
key := av.NewKey(keyID, keyName, keyIcon, keyTyp) if av.KeyTypeRollup == keyTyp { key.Rollup = &av.Rollup{Calc: &av.RollupCalc{Operator: av.CalcOperatorNone}} }
attrView.KeyValues = append(attrView.KeyValues, &av.KeyValues{Key: key})
for _, view := range attrView.Views { newField := &av.BaseField{ID: key.ID} if nil != view.Table { newField.Wrap = view.Table.WrapField
if "" == previousKeyID { if av.LayoutTypeGallery == currentView.LayoutType || av.LayoutTypeKanban == currentView.LayoutType { // 如果当前视图是卡片或看板视图则添加到最后 view.Table.Columns = append(view.Table.Columns, &av.ViewTableColumn{BaseField: newField}) } else { view.Table.Columns = append([]*av.ViewTableColumn{{BaseField: newField}}, view.Table.Columns...) } } else { added := false for i, column := range view.Table.Columns { if column.ID == previousKeyID { view.Table.Columns = append(view.Table.Columns[:i+1], append([]*av.ViewTableColumn{{BaseField: newField}}, view.Table.Columns[i+1:]...)...) added = true break } } if !added { view.Table.Columns = append(view.Table.Columns, &av.ViewTableColumn{BaseField: newField}) } } }
if nil != view.Gallery { newField.Wrap = view.Gallery.WrapField
if "" == previousKeyID { view.Gallery.CardFields = append(view.Gallery.CardFields, &av.ViewGalleryCardField{BaseField: newField}) } else { added := false for i, field := range view.Gallery.CardFields { if field.ID == previousKeyID { view.Gallery.CardFields = append(view.Gallery.CardFields[:i+1], append([]*av.ViewGalleryCardField{{BaseField: newField}}, view.Gallery.CardFields[i+1:]...)...) added = true break } } if !added { view.Gallery.CardFields = append(view.Gallery.CardFields, &av.ViewGalleryCardField{BaseField: newField}) } } }
if nil != view.Kanban { newField.Wrap = view.Kanban.WrapField
if "" == previousKeyID { view.Kanban.Fields = append(view.Kanban.Fields, &av.ViewKanbanField{BaseField: newField}) } else { added := false for i, field := range view.Kanban.Fields { if field.ID == previousKeyID { view.Kanban.Fields = append(view.Kanban.Fields[:i+1], append([]*av.ViewKanbanField{{BaseField: newField}}, view.Kanban.Fields[i+1:]...)...) added = true break } } if !added { view.Kanban.Fields = append(view.Kanban.Fields, &av.ViewKanbanField{BaseField: newField}) } } } } }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doUpdateAttrViewColTemplate(operation *Operation) (ret *TxErr) { err := updateAttributeViewColTemplate(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func updateAttributeViewColTemplate(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
colType := av.KeyType(operation.Typ) switch colType { case av.KeyTypeTemplate: for _, keyValues := range attrView.KeyValues { if keyValues.Key.ID == operation.ID && av.KeyTypeTemplate == keyValues.Key.Type { keyValues.Key.Template = operation.Data.(string) break } } }
regenAttrViewGroups(attrView) err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doUpdateAttrViewColNumberFormat(operation *Operation) (ret *TxErr) { err := updateAttributeViewColNumberFormat(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func updateAttributeViewColNumberFormat(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
colType := av.KeyType(operation.Typ) switch colType { case av.KeyTypeNumber: for _, keyValues := range attrView.KeyValues { if keyValues.Key.ID == operation.ID && av.KeyTypeNumber == keyValues.Key.Type { keyValues.Key.NumberFormat = av.NumberFormat(operation.Format) break } } }
err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doUpdateAttrViewColumn(operation *Operation) (ret *TxErr) { err := updateAttributeViewColumn(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func updateAttributeViewColumn(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
colType := av.KeyType(operation.Typ) changeType := false switch colType { case av.KeyTypeBlock, av.KeyTypeText, av.KeyTypeNumber, av.KeyTypeDate, av.KeyTypeSelect, av.KeyTypeMSelect, av.KeyTypeURL, av.KeyTypeEmail, av.KeyTypePhone, av.KeyTypeMAsset, av.KeyTypeTemplate, av.KeyTypeCreated, av.KeyTypeUpdated, av.KeyTypeCheckbox, av.KeyTypeRelation, av.KeyTypeRollup, av.KeyTypeLineNumber: for _, keyValues := range attrView.KeyValues { if keyValues.Key.ID == operation.ID { keyValues.Key.Name = strings.TrimSpace(operation.Name)
changeType = keyValues.Key.Type != colType keyValues.Key.Type = colType
for _, value := range keyValues.Values { value.Type = colType }
break } } }
if changeType { for _, view := range attrView.Views { if nil != view.Group { if groupKey := view.GetGroupKey(attrView); nil != groupKey && groupKey.ID == operation.ID { removeAttributeViewGroup0(view) } } } }
if err = av.SaveAttributeView(attrView); nil != err { return }
if changeType { relatedAvIDs := av.GetSrcAvIDs(attrView.ID) for _, relatedAvID := range relatedAvIDs { destAv, _ := av.ParseAttributeView(relatedAvID) if nil == destAv { continue }
for _, keyValues := range destAv.KeyValues { if av.KeyTypeRollup == keyValues.Key.Type && keyValues.Key.Rollup.KeyID == operation.ID { // 置空关联过来的汇总 for _, val := range keyValues.Values { val.Rollup.Contents = nil } keyValues.Key.Rollup.Calc = &av.RollupCalc{Operator: av.CalcOperatorNone} } }
regenAttrViewGroups(destAv) av.SaveAttributeView(destAv) ReloadAttrView(destAv.ID) } } return}
func (tx *Transaction) doRemoveAttrViewColumn(operation *Operation) (ret *TxErr) { err := RemoveAttributeViewKey(operation.AvID, operation.ID, operation.RemoveDest) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func RemoveAttributeViewKey(avID, keyID string, removeRelationDest bool) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return }
var removedKey *av.Key for i, keyValues := range attrView.KeyValues { if keyValues.Key.ID == keyID { attrView.KeyValues = append(attrView.KeyValues[:i], attrView.KeyValues[i+1:]...) removedKey = keyValues.Key break } }
if nil != removedKey && av.KeyTypeRelation == removedKey.Type && nil != removedKey.Relation { if removedKey.Relation.IsTwoWay { var destAv *av.AttributeView if avID == removedKey.Relation.AvID { destAv = attrView } else { destAv, _ = av.ParseAttributeView(removedKey.Relation.AvID) }
if nil != destAv { oldDestKey, _ := destAv.GetKey(removedKey.Relation.BackKeyID) if nil != oldDestKey && nil != oldDestKey.Relation && oldDestKey.Relation.AvID == attrView.ID && oldDestKey.Relation.IsTwoWay { oldDestKey.Relation.IsTwoWay = false oldDestKey.Relation.BackKeyID = "" }
destAvRelSrcAv := false for i, keyValues := range destAv.KeyValues { if keyValues.Key.ID == removedKey.Relation.BackKeyID { if removeRelationDest { // 删除双向关联的目标字段 destAv.KeyValues = append(destAv.KeyValues[:i], destAv.KeyValues[i+1:]...) } continue }
if av.KeyTypeRelation == keyValues.Key.Type && keyValues.Key.Relation.AvID == attrView.ID { destAvRelSrcAv = true } }
if removeRelationDest { for _, view := range destAv.Views { switch view.LayoutType { case av.LayoutTypeTable: for i, column := range view.Table.Columns { if column.ID == removedKey.Relation.BackKeyID { view.Table.Columns = append(view.Table.Columns[:i], view.Table.Columns[i+1:]...) break } } case av.LayoutTypeGallery: for i, field := range view.Gallery.CardFields { if field.ID == removedKey.Relation.BackKeyID { view.Gallery.CardFields = append(view.Gallery.CardFields[:i], view.Gallery.CardFields[i+1:]...) break } } case av.LayoutTypeKanban: for i, field := range view.Kanban.Fields { if field.ID == removedKey.Relation.BackKeyID { view.Kanban.Fields = append(view.Kanban.Fields[:i], view.Kanban.Fields[i+1:]...) break } } } } }
if destAv != attrView { av.SaveAttributeView(destAv) ReloadAttrView(destAv.ID) }
if !destAvRelSrcAv { av.RemoveAvRel(destAv.ID, attrView.ID) } }
srcAvRelDestAv := false for _, keyValues := range attrView.KeyValues { if av.KeyTypeRelation == keyValues.Key.Type && nil != keyValues.Key.Relation && keyValues.Key.Relation.AvID == removedKey.Relation.AvID { srcAvRelDestAv = true } } if !srcAvRelDestAv { av.RemoveAvRel(attrView.ID, removedKey.Relation.AvID) } } }
for _, view := range attrView.Views { if nil != view.Table { for i, column := range view.Table.Columns { if column.ID == keyID { view.Table.Columns = append(view.Table.Columns[:i], view.Table.Columns[i+1:]...) break } } }
if nil != view.Gallery { for i, field := range view.Gallery.CardFields { if field.ID == keyID { view.Gallery.CardFields = append(view.Gallery.CardFields[:i], view.Gallery.CardFields[i+1:]...) break } } }
if nil != view.Kanban { for i, field := range view.Kanban.Fields { if field.ID == keyID { view.Kanban.Fields = append(view.Kanban.Fields[:i], view.Kanban.Fields[i+1:]...) break } } } }
for _, view := range attrView.Views { if nil != view.Group { if groupKey := view.GetGroupKey(attrView); nil != groupKey && groupKey.ID == keyID { removeAttributeViewGroup0(view) } } }
if err = av.SaveAttributeView(attrView); nil != err { return }
relatedAvIDs := av.GetSrcAvIDs(avID) for _, relatedAvID := range relatedAvIDs { destAv, _ := av.ParseAttributeView(relatedAvID) if nil == destAv { continue }
for _, keyValues := range destAv.KeyValues { if av.KeyTypeRollup == keyValues.Key.Type && keyValues.Key.Rollup.KeyID == keyID { // 置空关联过来的汇总 for _, val := range keyValues.Values { val.Rollup.Contents = nil } } }
regenAttrViewGroups(destAv) av.SaveAttributeView(destAv) ReloadAttrView(destAv.ID) } return}
func (tx *Transaction) doReplaceAttrViewBlock(operation *Operation) (ret *TxErr) { err := replaceAttributeViewBlock(operation.AvID, operation.PreviousID, operation.NextID, operation.IsDetached, tx) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID} } return}
func replaceAttributeViewBlock(avID, oldBlockID, newBlockID string, isDetached bool, tx *Transaction) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return }
if err = replaceAttributeViewBlock0(attrView, oldBlockID, newBlockID, isDetached, tx); nil != err { return }
if err = av.SaveAttributeView(attrView); nil != err { return } return}
func replaceAttributeViewBlock0(attrView *av.AttributeView, oldBlockID, newNodeID string, isDetached bool, tx *Transaction) (err error) { avID := attrView.ID var tree *parse.Tree var node *ast.Node if !isDetached { node, tree, _ = getNodeByBlockID(tx, newNodeID) }
now := util.CurrentTimeMillis() // 检查是否已经存在绑定块，如果存在的话则重新绑定 for _, blockVal := range attrView.GetBlockKeyValues().Values { if !isDetached && blockVal.Block.ID == newNodeID && nil != node && nil != tree { bindBlockAv0(tx, avID, node, tree) blockVal.IsDetached = false icon, content := getNodeAvBlockText(node, "") content = util.UnescapeHTML(content) blockVal.Block.Icon, blockVal.Block.Content = icon, content blockVal.UpdatedAt = now regenAttrViewGroups(attrView) return } }
for _, blockVal := range attrView.GetBlockKeyValues().Values { if blockVal.BlockID != oldBlockID { continue }
if av.KeyTypeBlock == blockVal.Type { blockVal.IsDetached = isDetached if !isDetached { if "" != blockVal.Block.ID && blockVal.Block.ID != newNodeID { unbindBlockAv(tx, avID, blockVal.Block.ID) } bindBlockAv(tx, avID, newNodeID)
blockVal.Block.ID = newNodeID icon, content := getNodeAvBlockText(node, "") content = util.UnescapeHTML(content) blockVal.Block.Icon, blockVal.Block.Content = icon, content
refreshRelatedSrcAvs(avID, tx) } else { blockVal.Block.ID = "" } } }
regenAttrViewGroups(attrView) return}
func BatchReplaceAttributeViewBlocks(avID string, isDetached bool, oldNew []map[string]string) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return }
for _, oldNewMap := range oldNew { for oldBlockID, newNodeID := range oldNewMap { if err = replaceAttributeViewBlock0(attrView, oldBlockID, newNodeID, isDetached, nil); nil != err { return } } }
if err = av.SaveAttributeView(attrView); nil != err { return } return}
func (tx *Transaction) doUpdateAttrViewCell(operation *Operation) (ret *TxErr) { _, err := UpdateAttributeViewCell(tx, operation.AvID, operation.KeyID, operation.RowID, operation.Data) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func BatchUpdateAttributeViewCells(tx *Transaction, avID string, values []interface{}) (err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return }
for _, value := range values { v := value.(map[string]interface{}) keyID := v["keyID"].(string) var itemID string if _, ok := v["itemID"]; ok { itemID = v["itemID"].(string) } else if _, ok := v["rowID"]; ok { // TODO 计划于 2026 年 6 月 30 日后删除 https://github.com/siyuan-note/siyuan/issues/15708#issuecomment-3239694546 itemID = v["rowID"].(string) } valueData := v["value"] _, err = updateAttributeViewValue(tx, attrView, keyID, itemID, valueData) if err != nil { return } } return}
func UpdateAttributeViewCell(tx *Transaction, avID, keyID, itemID string, valueData interface{}) (val *av.Value, err error) { attrView, err := av.ParseAttributeView(avID) if err != nil { return }
val, err = updateAttributeViewValue(tx, attrView, keyID, itemID, valueData) if nil != err { return } return}
func updateAttributeViewValue(tx *Transaction, attrView *av.AttributeView, keyID, itemID string, valueData interface{}) (val *av.Value, err error) { avID := attrView.ID var blockVal *av.Value for _, kv := range attrView.KeyValues { if av.KeyTypeBlock == kv.Key.Type { for _, v := range kv.Values { if itemID == v.BlockID { blockVal = v break } } break } }
now := time.Now().UnixMilli() oldIsDetached := true var oldBoundBlockID string if nil != blockVal { oldIsDetached = blockVal.IsDetached oldBoundBlockID = blockVal.Block.ID } for _, keyValues := range attrView.KeyValues { if keyID != keyValues.Key.ID { continue }
for _, value := range keyValues.Values { if itemID == value.BlockID { val = value val.Type = keyValues.Key.Type break } }
if nil == val { val = &av.Value{ID: ast.NewNodeID(), KeyID: keyID, BlockID: itemID, Type: keyValues.Key.Type, CreatedAt: now, UpdatedAt: now} keyValues.Values = append(keyValues.Values, val) } break }
isUpdatingBlockKey := av.KeyTypeBlock == val.Type var oldRelationBlockIDs []string if av.KeyTypeRelation == val.Type { if nil != val.Relation { for _, bID := range val.Relation.BlockIDs { oldRelationBlockIDs = append(oldRelationBlockIDs, bID) } } } data, err := gulu.JSON.MarshalJSON(valueData) if err != nil { logging.LogErrorf("marshal value [%+v] failed: %s", valueData, err) return } if err = gulu.JSON.UnmarshalJSON(data, &val); err != nil { logging.LogErrorf("unmarshal data [%s] failed: %s", data, err) return }
key, _ := attrView.GetKey(keyID)
if av.KeyTypeNumber == val.Type { if nil != val.Number { if !val.Number.IsNotEmpty { val.Number.Content = 0 val.Number.FormattedContent = "" } else { val.Number.FormatNumber() } } } else if av.KeyTypeDate == val.Type { if nil != val.Date && !val.Date.IsNotEmpty { val.Date.Content = 0 val.Date.FormattedContent = "" } } else if av.KeyTypeSelect == val.Type || av.KeyTypeMSelect == val.Type { if nil != key && 0 < len(val.MSelect) { var tmp []*av.ValueSelect // 移除空选项 https://github.com/siyuan-note/siyuan/issues/15533 for _, v := range val.MSelect { if "" != v.Content { tmp = append(tmp, v) } } val.MSelect = tmp
if 1 > len(val.MSelect) { return }
// The selection options are inconsistent after pasting data into the database https://github.com/siyuan-note/siyuan/issues/11409 for _, valOpt := range val.MSelect { if opt := key.GetOption(valOpt.Content); nil == opt { // 不存在的选项新建保存 color := valOpt.Color if "" == color { color = fmt.Sprintf("%d", 1+rand.Intn(14)) } opt = &av.SelectOption{Name: valOpt.Content, Color: color} key.Options = append(key.Options, opt) } else { // 已经存在的选项颜色需要保持不变 valOpt.Color = opt.Color } } } }
relationChangeMode := 0 // 0：不变（仅排序），1：增加，2：减少 if av.KeyTypeRelation == val.Type { // 关联字段得 content 是自动渲染的，所以不需要保存 val.Relation.Contents = nil val.Relation.BlockIDs = gulu.Str.RemoveDuplicatedElem(val.Relation.BlockIDs)
// 计算关联变更模式 if !slices.Equal(oldRelationBlockIDs, val.Relation.BlockIDs) { if len(oldRelationBlockIDs) > len(val.Relation.BlockIDs) { relationChangeMode = 2 } else { relationChangeMode = 1 } } }
// val.IsDetached 只有更新主键的时候才会传入，所以下面需要结合 isUpdatingBlockKey 来判断
if isUpdatingBlockKey { if oldIsDetached { // 之前是非绑定块
if !val.IsDetached { // 现在绑定了块 bindBlockAv(tx, avID, val.Block.ID) } } else { // 之前绑定了块
if val.IsDetached { // 现在是非绑定块 unbindBlockAv(tx, avID, val.Block.ID) val.Block.ID = "" } else { // 现在也绑定了块
if oldBoundBlockID != val.Block.ID { // 之前绑定的块和现在绑定的块不一样 // 换绑块 unbindBlockAv(tx, avID, oldBoundBlockID) bindBlockAv(tx, avID, val.Block.ID) val.Block.Content = util.UnescapeHTML(val.Block.Content) } else { // 之前绑定的块和现在绑定的块一样 content := strings.TrimSpace(val.Block.Content) node, tree, _ := getNodeByBlockID(tx, val.Block.ID) _, blockText := getNodeAvBlockText(node, "") if "" == content { // 使用动态锚文本 val.Block.Content = util.UnescapeHTML(blockText) updateBlockValueStaticText(tx, node, tree, avID, "") } else { val.Block.Content = content updateBlockValueStaticText(tx, node, tree, avID, content) } } } } }
if nil != blockVal { blockVal.Block.Updated = now blockVal.SetUpdatedAt(now) if isUpdatingBlockKey { blockVal.IsDetached = val.IsDetached } } val.SetUpdatedAt(now)
if nil != key && av.KeyTypeRelation == key.Type && nil != key.Relation && key.Relation.IsTwoWay { // 双向关联需要同时更新目标字段的值 updateTwoWayRelationDestAttrView(attrView, key, val, relationChangeMode, oldRelationBlockIDs) }
regenAttrViewGroups(attrView) if err = av.SaveAttributeView(attrView); nil != err { return }
refreshRelatedSrcAvs(avID, tx) return}
func refreshRelatedSrcAvs(destAvID string, tx *Transaction) { relatedAvIDs := av.GetSrcAvIDs(destAvID)
var tmp []string for _, relatedAvID := range relatedAvIDs { if relatedAvID == destAvID { // 目标和源相同则跳过 continue }
tmp = append(tmp, relatedAvID) } relatedAvIDs = tmp
if nil != tx { tx.relatedAvIDs = append(tx.relatedAvIDs, relatedAvIDs...) } else { for _, relatedAvID := range relatedAvIDs { destAv, _ := av.ParseAttributeView(relatedAvID) if nil == destAv { continue }
regenAttrViewGroups(destAv) av.SaveAttributeView(destAv) ReloadAttrView(relatedAvID) } }}
// relationChangeMode// 0：关联字段值不变（仅排序），不影响目标值// 1：关联字段值增加，增加目标值// 2：关联字段值减少，减少目标值func updateTwoWayRelationDestAttrView(attrView *av.AttributeView, relKey *av.Key, val *av.Value, relationChangeMode int, oldRelationBlockIDs []string) { var destAv *av.AttributeView if attrView.ID == relKey.Relation.AvID { destAv = attrView } else { destAv, _ = av.ParseAttributeView(relKey.Relation.AvID) }
if nil == destAv { return }
now := util.CurrentTimeMillis() if 1 == relationChangeMode { addBlockIDs := val.Relation.BlockIDs for _, bID := range oldRelationBlockIDs { addBlockIDs = gulu.Str.RemoveElem(addBlockIDs, bID) }
for _, blockID := range addBlockIDs { for _, keyValues := range destAv.KeyValues { if keyValues.Key.ID != relKey.Relation.BackKeyID { continue }
destVal := keyValues.GetValue(blockID) if nil == destVal { destVal = &av.Value{ID: ast.NewNodeID(), KeyID: keyValues.Key.ID, BlockID: blockID, Type: keyValues.Key.Type, Relation: &av.ValueRelation{}, CreatedAt: now, UpdatedAt: now + 1000} keyValues.Values = append(keyValues.Values, destVal) }
destVal.Relation.BlockIDs = append(destVal.Relation.BlockIDs, val.BlockID) destVal.Relation.BlockIDs = gulu.Str.RemoveDuplicatedElem(destVal.Relation.BlockIDs) break } } } else if 2 == relationChangeMode { removeBlockIDs := oldRelationBlockIDs for _, bID := range val.Relation.BlockIDs { removeBlockIDs = gulu.Str.RemoveElem(removeBlockIDs, bID) }
for _, blockID := range removeBlockIDs { for _, keyValues := range destAv.KeyValues { if keyValues.Key.ID != relKey.Relation.BackKeyID { continue }
for _, value := range keyValues.Values { if value.BlockID == blockID { value.Relation.BlockIDs = gulu.Str.RemoveElem(value.Relation.BlockIDs, val.BlockID) value.SetUpdatedAt(now) break } } } } }
if destAv != attrView { regenAttrViewGroups(destAv) av.SaveAttributeView(destAv) }}
// regenAttrViewGroups 重新生成分组视图。func regenAttrViewGroups(attrView *av.AttributeView) { for _, view := range attrView.Views { groupKey := view.GetGroupKey(attrView) if nil == groupKey { continue }
genAttrViewGroups(view, attrView) }}
func unbindBlockAv(tx *Transaction, avID, nodeID string) { node, tree, err := getNodeByBlockID(tx, nodeID) if err != nil { return }
attrs := parse.IAL2Map(node.KramdownIAL) if "" == attrs[av.NodeAttrNameAvs] { return }
avIDs := strings.Split(attrs[av.NodeAttrNameAvs], ",") avIDs = gulu.Str.RemoveElem(avIDs, avID) if 0 == len(avIDs) { attrs[av.NodeAttrNameAvs] = "" } else { attrs[av.NodeAttrNameAvs] = strings.Join(avIDs, ",") }
avNames := getAvNames(attrs[av.NodeAttrNameAvs]) if "" != avNames { attrs[av.NodeAttrViewNames] = avNames }
if nil != tx { err = setNodeAttrsWithTx(tx, node, tree, attrs) } else { err = setNodeAttrs(node, tree, attrs) } if err != nil { logging.LogWarnf("set node [%s] attrs failed: %s", nodeID, err) return } return}
func bindBlockAv(tx *Transaction, avID, blockID string) { node, tree, err := getNodeByBlockID(tx, blockID) if err != nil { return }
bindBlockAv0(tx, avID, node, tree) return}
func bindBlockAv0(tx *Transaction, avID string, node *ast.Node, tree *parse.Tree) { attrs := parse.IAL2Map(node.KramdownIAL) if "" == attrs[av.NodeAttrNameAvs] { attrs[av.NodeAttrNameAvs] = avID } else { avIDs := strings.Split(attrs[av.NodeAttrNameAvs], ",") avIDs = append(avIDs, avID) avIDs = gulu.Str.RemoveDuplicatedElem(avIDs) attrs[av.NodeAttrNameAvs] = strings.Join(avIDs, ",") }
avNames := getAvNames(attrs[av.NodeAttrNameAvs]) if "" != avNames { attrs[av.NodeAttrViewNames] = avNames }
var err error if nil != tx { err = setNodeAttrsWithTx(tx, node, tree, attrs) } else { err = setNodeAttrs(node, tree, attrs) } if err != nil { logging.LogWarnf("set node [%s] attrs failed: %s", node.ID, err) return } return}
func updateBlockValueStaticText(tx *Transaction, node *ast.Node, tree *parse.Tree, avID, text string) { // 设置静态锚文本 Database-bound block primary key supports setting static anchor text https://github.com/siyuan-note/siyuan/issues/10049
if nil == node { return }
attrs := parse.IAL2Map(node.KramdownIAL) attrs[av.NodeAttrViewStaticText+"-"+avID] = text var err error if nil != tx { err = setNodeAttrsWithTx(tx, node, tree, attrs) } else { err = setNodeAttrs(node, tree, attrs) } if err != nil { logging.LogWarnf("set node [%s] attrs failed: %s", node.ID, err) return }}
func getNodeByBlockID(tx *Transaction, blockID string) (node *ast.Node, tree *parse.Tree, err error) { if nil != tx { tree, err = tx.loadTree(blockID) } else { tree, err = LoadTreeByBlockID(blockID) } if err != nil { return } node = treenode.GetNodeInTree(tree, blockID) if nil == node { logging.LogWarnf("node [%s] not found in tree [%s]", blockID, tree.ID) return } return}
func (tx *Transaction) doUpdateAttrViewColOptions(operation *Operation) (ret *TxErr) { err := updateAttributeViewColumnOptions(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func updateAttributeViewColumnOptions(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
jsonData, err := gulu.JSON.MarshalJSON(operation.Data) if err != nil { return }
options := []*av.SelectOption{} if err = gulu.JSON.UnmarshalJSON(jsonData, &options); err != nil { return }
// 移除空选项 https://github.com/siyuan-note/siyuan/issues/15533 var tmp []*av.SelectOption for _, opt := range options { if "" != opt.Name { tmp = append(tmp, opt) } } options = tmp if 1 > len(options) { return }
optionSorts := map[string]int{} for i, opt := range options { optionSorts[opt.Name] = i }
addNew := false selectKey, _ := attrView.GetKey(operation.ID) if nil == selectKey { return } existingOptions := map[string]*av.SelectOption{} for _, opt := range selectKey.Options { existingOptions[opt.Name] = opt } for _, opt := range options { if existingOpt, exists := existingOptions[opt.Name]; exists { // 如果选项已经存在则更新颜色和描述 existingOpt.Color = opt.Color existingOpt.Desc = opt.Desc } else { // 如果选项不存在则添加新选项 selectKey.Options = append(selectKey.Options, &av.SelectOption{ Name: opt.Name, Color: opt.Color, Desc: opt.Desc, }) addNew = true } }
if !addNew { sort.SliceStable(selectKey.Options, func(i, j int) bool { return optionSorts[selectKey.Options[i].Name] < optionSorts[selectKey.Options[j].Name] }) }
regenAttrViewGroups(attrView) err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doRemoveAttrViewColOption(operation *Operation) (ret *TxErr) { err := removeAttributeViewColumnOption(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func removeAttributeViewColumnOption(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
optName := operation.Data.(string)
key, err := attrView.GetKey(operation.ID) if err != nil { return }
for i, opt := range key.Options { if optName == opt.Name { key.Options = append(key.Options[:i], key.Options[i+1:]...) break } }
for _, keyValues := range attrView.KeyValues { if keyValues.Key.ID != operation.ID { continue }
for _, value := range keyValues.Values { if nil == value || nil == value.MSelect { continue }
for i, opt := range value.MSelect { if optName == opt.Content { value.MSelect = append(value.MSelect[:i], value.MSelect[i+1:]...) break } } } break }
// 如果存在选项对应的过滤条件，则删除过滤条件中设置的选项值 https://github.com/siyuan-note/siyuan/issues/15536 for _, view := range attrView.Views { for _, filter := range view.Filters { if filter.Column != operation.ID { continue }
if nil != filter.Value && (av.KeyTypeSelect == filter.Value.Type || av.KeyTypeMSelect == filter.Value.Type) { if av.FilterOperatorIsEmpty == filter.Operator || av.FilterOperatorIsNotEmpty == filter.Operator { continue }
for i, opt := range filter.Value.MSelect { if optName == opt.Content { filter.Value.MSelect = append(filter.Value.MSelect[:i], filter.Value.MSelect[i+1:]...) break } } if 1 > len(filter.Value.MSelect) { // 如果删除后选项值为空，则删除过滤条件 for i, f := range view.Filters { if f.Column == operation.ID && f.Value == filter.Value { view.Filters = append(view.Filters[:i], view.Filters[i+1:]...) break } } } } } }
regenAttrViewGroups(attrView) err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doUpdateAttrViewColOption(operation *Operation) (ret *TxErr) { err := updateAttributeViewColumnOption(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func updateAttributeViewColumnOption(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
key, err := attrView.GetKey(operation.ID) if err != nil { return }
data := operation.Data.(map[string]interface{})
rename := false oldName := strings.TrimSpace(data["oldName"].(string)) newName := strings.TrimSpace(data["newName"].(string)) newDesc := strings.TrimSpace(data["newDesc"].(string)) newColor := data["newColor"].(string)
found := false if oldName != newName { rename = true
for _, opt := range key.Options { if newName == opt.Name { // 如果选项已经存在则直接使用 found = true newColor = opt.Color newDesc = opt.Desc break } } }
if !found { for i, opt := range key.Options { if oldName == opt.Name { key.Options[i].Name = newName key.Options[i].Color = newColor key.Options[i].Desc = newDesc break } } }
// 如果存在选项对应的值，需要更新值中的选项 for _, keyValues := range attrView.KeyValues { if keyValues.Key.ID != operation.ID { continue }
for _, value := range keyValues.Values { if nil == value || nil == value.MSelect { continue }
found = false for _, opt := range value.MSelect { if newName == opt.Content { found = true break } } if found && rename { idx := -1 for i, opt := range value.MSelect { if oldName == opt.Content { idx = i break } } if 0 <= idx { value.MSelect = util.RemoveElem(value.MSelect, idx) } } else { for i, opt := range value.MSelect { if oldName == opt.Content { value.MSelect[i].Content = newName value.MSelect[i].Color = newColor break } } } } break }
// 如果存在选项对应的过滤条件，需要更新过滤条件中设置的选项值 // Database select field filters follow option editing changes https://github.com/siyuan-note/siyuan/issues/10881 for _, view := range attrView.Views { for _, filter := range view.Filters { if filter.Column != key.ID { continue }
if nil != filter.Value && (av.KeyTypeSelect == filter.Value.Type || av.KeyTypeMSelect == filter.Value.Type) { for i, opt := range filter.Value.MSelect { if oldName == opt.Content { filter.Value.MSelect[i].Content = newName filter.Value.MSelect[i].Color = newColor break } } } } }
regenAttrViewGroups(attrView) err = av.SaveAttributeView(attrView) return}
func (tx *Transaction) doSetAttrViewColOptionDesc(operation *Operation) (ret *TxErr) { err := setAttributeViewColumnOptionDesc(operation) if err != nil { return &TxErr{code: TxErrHandleAttributeView, id: operation.AvID, msg: err.Error()} } return}
func setAttributeViewColumnOptionDesc(operation *Operation) (err error) { attrView, err := av.ParseAttributeView(operation.AvID) if err != nil { return }
key, err := attrView.GetKey(operation.ID) if err != nil { return }
data := operation.Data.(map[string]interface{}) name := data["name"].(string) desc := data["desc"].(string)
for i, opt := range key.Options { if name == opt.Name { key.Options[i].Desc = desc break } }
err = av.SaveAttributeView(attrView) return}
func getAttrViewViewByBlockID(attrView *av.AttributeView, blockID string) (ret *av.View, err error) { var viewID string var node *ast.Node if "" != blockID { node, _, _ = getNodeByBlockID(nil, blockID) } if nil != node { viewID = node.IALAttr(av.NodeAttrView) } return attrView.GetCurrentView(viewID)}
func getAttrViewName(attrView *av.AttributeView) string { ret := strings.TrimSpace(attrView.Name) if "" == ret { ret = Conf.language(105) } return ret}
func updateBoundBlockAvsAttribute(avIDs []string) { // 更新指定 avIDs 中绑定块的 avs 属性
cachedTrees, saveTrees := map[string]*parse.Tree{}, map[string]*parse.Tree{} luteEngine := util.NewLute() for _, avID := range avIDs { attrView, _ := av.ParseAttributeView(avID) if nil == attrView { continue }
blockKeyValues := attrView.GetBlockKeyValues() for _, blockValue := range blockKeyValues.Values { if blockValue.IsDetached { continue } bt := treenode.GetBlockTree(blockValue.BlockID) if nil == bt { continue }
tree := cachedTrees[bt.RootID] if nil == tree { tree, _ = filesys.LoadTree(bt.BoxID, bt.Path, luteEngine) if nil == tree { continue } cachedTrees[bt.RootID] = tree }
node := treenode.GetNodeInTree(tree, blockValue.BlockID) if nil == node { continue }
attrs := parse.IAL2Map(node.KramdownIAL) if "" == attrs[av.NodeAttrNameAvs] { attrs[av.NodeAttrNameAvs] = avID } else { nodeAvIDs := strings.Split(attrs[av.NodeAttrNameAvs], ",") nodeAvIDs = append(nodeAvIDs, avID) nodeAvIDs = gulu.Str.RemoveDuplicatedElem(nodeAvIDs) attrs[av.NodeAttrNameAvs] = strings.Join(nodeAvIDs, ",") saveTrees[bt.RootID] = tree }
avNames := getAvNames(attrs[av.NodeAttrNameAvs]) if "" != avNames { attrs[av.NodeAttrViewNames] = avNames }
oldAttrs, setErr := setNodeAttrs0(node, attrs) if nil != setErr { continue } cache.PutBlockIAL(node.ID, parse.IAL2Map(node.KramdownIAL)) pushBroadcastAttrTransactions(oldAttrs, node) if "" != avNames { node.RemoveIALAttr(av.NodeAttrViewNames) } } }
for _, saveTree := range saveTrees { if treeErr := indexWriteTreeUpsertQueue(saveTree); nil != treeErr { logging.LogErrorf("index write tree upsert queue failed: %s", treeErr) }
avNodes := saveTree.Root.ChildrenByType(ast.NodeAttributeView) av.BatchUpsertBlockRel(avNodes) }}