import { ALL, Body, Controller, Inject, Post, Provide, Query } from '@midwayjs/core'; import { Constants, CrudController } from '@certd/lib-server'; import { AccessService } from '../../modules/pipeline/service/access-service.js'; /** * 授权 */ @Provide() @Controller('/api/pi/access') export class AccessController extends CrudController { @Inject() service: AccessService; getService(): AccessService { return this.service; } @Post('/page', { summary: Constants.per.authOnly }) async page(@Body(ALL) body) { body.query = body.query ?? {}; delete body.query.userId; const buildQuery = qb => { qb.andWhere('user_id = :userId', { userId: this.getUserId() }); }; const res = await this.service.page({ query: body.query, page: body.page, sort: body.sort, buildQuery, }); return this.ok(res); } @Post('/list', { summary: Constants.per.authOnly }) async list(@Body(ALL) body) { body.userId = this.getUserId(); return super.list(body); } @Post('/add', { summary: Constants.per.authOnly }) async add(@Body(ALL) bean) { bean.userId = this.getUserId(); return super.add(bean); } @Post('/update', { summary: Constants.per.authOnly }) async update(@Body(ALL) bean) { await this.service.checkUserId(bean.id, this.getUserId()); return super.update(bean); } @Post('/info', { summary: Constants.per.authOnly }) async info(@Query('id') id: number) { await this.service.checkUserId(id, this.getUserId()); return super.info(id); } @Post('/delete', { summary: Constants.per.authOnly }) async delete(@Query('id') id: number) { await this.service.checkUserId(id, this.getUserId()); return super.delete(id); } @Post('/define', { summary: Constants.per.authOnly }) async define(@Query('type') type: string) { const access = this.service.getDefineByType(type); return this.ok(access); } @Post('/getSecretPlain', { summary: Constants.per.authOnly }) async getSecretPlain(@Body(ALL) body: { id: number; key: string }) { const value = await this.service.getById(body.id, this.getUserId()); return this.ok(value[body.key]); } @Post('/accessTypeDict', { summary: Constants.per.authOnly }) async getAccessTypeDict() { const list = this.service.getDefineList(); const dict = []; for (const item of list) { dict.push({ value: item.name, label: item.title, }); } return this.ok(dict); } }