import Base from './base'
import { IUMemberModel } from '../../model/member'

/**
 * @author jiangwei
 * @desc 直连数据库查询
 * @class Db
 * @extends {Base}
 */
export default class Db extends Base{
  getProjectById(_projectId: string) {
    return this.app.db.project.findById(_projectId).lean()
  }

  getTasklistById (_tasklist: string) {
    return this.app.db.tasklist.findById(_tasklist).lean()
  }

  getStageByConds(conds: Object) {
    conds['isArchived'] = null
    return this.app.db.stage.find(conds).lean()
  }

  getTaskflowByConds (conds: Object) {
    return this.app.db.taskflow.findOne(conds).lean()
  }

  getTaskflowstatusByCounds (conds: Object) {
    conds['isDeleted'] = false
    return this.app.db.taskflowstatus.find(conds).lean()
  }

  async getMembersByProjectId(_projectId: string): Promise<IUMemberModel[]> {
    return await this.app.db.member
      .find({ _boundToObjectId: _projectId })
      .populate({
        path: '_userId',
        select: 'name'
      })
      .sort('-_id')
      .lean()
  }
}