mirror of
https://github.com/gitbucket/gitbucket.git
synced 2025-11-03 03:55:58 +01:00
58 lines
2.4 KiB
Scala
58 lines
2.4 KiB
Scala
package service
|
|
|
|
import model.Profile._
|
|
import profile.simple._
|
|
import model.Milestone
|
|
// TODO [Slick 2.0]NOT import directly?
|
|
import model.Profile.dateColumnType
|
|
|
|
trait MilestonesService {
|
|
|
|
def createMilestone(owner: String, repository: String, title: String, description: Option[String],
|
|
dueDate: Option[java.util.Date])(implicit s: Session): Unit =
|
|
Milestones insert Milestone(
|
|
userName = owner,
|
|
repositoryName = repository,
|
|
title = title,
|
|
description = description,
|
|
dueDate = dueDate,
|
|
closedDate = None
|
|
)
|
|
|
|
def updateMilestone(milestone: Milestone)(implicit s: Session): Unit =
|
|
Milestones
|
|
.filter (t => t.byPrimaryKey(milestone.userName, milestone.repositoryName, milestone.milestoneId))
|
|
.map (t => (t.title, t.description.?, t.dueDate.?, t.closedDate.?))
|
|
.update (milestone.title, milestone.description, milestone.dueDate, milestone.closedDate)
|
|
|
|
def openMilestone(milestone: Milestone)(implicit s: Session): Unit =
|
|
updateMilestone(milestone.copy(closedDate = None))
|
|
|
|
def closeMilestone(milestone: Milestone)(implicit s: Session): Unit =
|
|
updateMilestone(milestone.copy(closedDate = Some(currentDate)))
|
|
|
|
def deleteMilestone(owner: String, repository: String, milestoneId: Int)(implicit s: Session): Unit = {
|
|
Issues.filter(_.byMilestone(owner, repository, milestoneId)).map(_.milestoneId.?).update(None)
|
|
Milestones.filter(_.byPrimaryKey(owner, repository, milestoneId)).delete
|
|
}
|
|
|
|
def getMilestone(owner: String, repository: String, milestoneId: Int)(implicit s: Session): Option[Milestone] =
|
|
Milestones.filter(_.byPrimaryKey(owner, repository, milestoneId)).firstOption
|
|
|
|
def getMilestonesWithIssueCount(owner: String, repository: String)(implicit s: Session): List[(Milestone, Int, Int)] = {
|
|
val counts = Issues
|
|
.filter { t => (t.byRepository(owner, repository)) && (t.milestoneId.? isDefined) }
|
|
.groupBy { t => t.milestoneId -> t.closed }
|
|
.map { case (t1, t2) => t1._1 -> t1._2 -> t2.length }
|
|
.toMap
|
|
|
|
getMilestones(owner, repository).map { milestone =>
|
|
(milestone, counts.getOrElse((milestone.milestoneId, false), 0), counts.getOrElse((milestone.milestoneId, true), 0))
|
|
}
|
|
}
|
|
|
|
def getMilestones(owner: String, repository: String)(implicit s: Session): List[Milestone] =
|
|
Milestones.filter(_.byRepository(owner, repository)).sortBy(_.milestoneId asc).list
|
|
|
|
}
|