TheAnachronism/docspell
1
0
Fork 0
mirror of https://github.com/TheAnachronism/docspell.git synced 2025-04-04 10:29:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add source files to collective insights

Browse Source
This commit is contained in:
Eike Kettner 2020-02-23 14:48:30 +01:00
parent be8eacdbe9
commit d937e0501a
1 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
modules/store/src/main/scala/docspell/store/queries/QCollective.scala
View File

@ -14,7 +14,6 @@ object QCollective {
def getInsights(coll: Ident): ConnectionIO[InsightData] = { def getInsights(coll: Ident): ConnectionIO[InsightData] = {
val IC = RItem.Columns val IC = RItem.Columns
val AC = RAttachment.Columns
val TC = RTag.Columns val TC = RTag.Columns
val RC = RTagItem.Columns val RC = RTagItem.Columns
val q0 = selectCount( val q0 = selectCount(
@ -28,12 +27,21 @@ object QCollective {
and(IC.cid.is(coll), IC.incoming.is(Direction.outgoing)) and(IC.cid.is(coll), IC.incoming.is(Direction.outgoing))
).query[Int].unique ).query[Int].unique
val q2 = fr"SELECT sum(m.length) FROM" ++ RItem.table ++ fr"i" ++
fr"INNER JOIN" ++ RAttachment.table ++ fr"a ON" ++ AC.itemId val fileSize = sql"""
.prefix("a") select sum(length) from (
.is(IC.id.prefix("i")) ++ with attachs as
fr"INNER JOIN filemeta m ON m.id =" ++ AC.fileId.prefix("a").f ++ (select a.attachid as aid, a.filemetaid as fid
fr"WHERE" ++ IC.cid.is(coll) from attachment a
inner join item i on a.itemid = i.itemid
where i.cid = $coll)
(select a.fid,m.length from attachs a
inner join filemeta m on m.id = a.fid
union
select a.file_id,m.length from attachment_source a
inner join filemeta m on m.id = a.file_id where a.id in (select aid from attachs))
) as t""".query[Option[Long]].unique
val q3 = fr"SELECT" ++ commas( val q3 = fr"SELECT" ++ commas(
TC.name.prefix("t").f, TC.name.prefix("t").f,
@ -47,9 +55,9 @@ object QCollective {
for { for {
n0 <- q0 n0 <- q0
n1 <- q1 n1 <- q1
n2 <- q2.query[Option[Long]].unique n2 <- fileSize
n3 <- q3.query[(String, Int)].to[Vector] n3 <- q3.query[(String, Int)].to[Vector]
} yield InsightData(n0, n1, n2.getOrElse(0), Map.from(n3)) } yield InsightData(n0, n1, n2.getOrElse(0L), Map.from(n3))
} }
def getContacts( def getContacts(