后台代码解读

{ 
    "port": 3000,	
    "db": {	
        "host":"localhost",	
        "username":"root",	
        "password":"vod@2020#DEMO",	
        "port":"3306",	
        "database":"short-video"	
    },
    "secretId": "",
    "secretKey": "",
    "urlKey": "",
    "wxAppConfig": {
        "appId": "",
        "appSecret": "",
    }
} 

|-- package.json
|-- src
|   |-- conf
|   |-- controller
|   |-- dao
|   |-- dto
|   |-- entity
|   |-- index.ts
|   |-- service
|   `-- util
`-- tsconfig.json

// 媒资相关的控制器
@JsonController()
export class MediaController {
    tokenService: TokenService;
    validatorService: ValidatorService;
    videoService: VideoService;

    constructor() {
        this.tokenService = Container.get(TokenService);
        this.validatorService = Container.get(ValidatorService);
        this.videoService = Container.get(VideoService);
    }

    /*
     * 获取微信小程序视频列表
     */
    @Post("/WXAMPGetVideoList")
    public async wxampGetVideoList(@Body({ validate: false }) dto: GetVideoListDTO) {
        let requestId = uuidv4();
        let ctx = new ServiceContext(requestId);

        try {
            // 校验接口参数
            await this.validatorService.Validate(ctx, dto);

            //  获取视频列表
            let condition = {
                UserId: "",
                Status: VideoStatus.PASS,
                WechatMiniProgramStatus: VideoStatus.PASS,
                Offset: dto.Offset,
                Limit: dto.Limit,
            };
            let listVideoResult = await this.videoService.SearchVideo(ctx, condition);
            return new Response(requestId, ErrorCode.OK, "OK", {
                VideoList: listVideoResult.VideoList,
                TotalCount: listVideoResult.TotalCount,
            });
        } catch (error) {
            logger.error(ctx, `getVideoList error:`, error);
            logger.info(ctx, `getVideoList dto:`, dto);
            logger.error(ctx, `get video list fail: ${error.Code}, ${error.Message}, error:`, error);
            return new Response(requestId, error.Code, error.Message, {});
        }
    }

    // 其余代码省略...
}

// 获取视频列表的 DTO
export class GetVideoListDTO {
    @IsOptional()
    @Min(0, {
        message: "Offset must be greater than or equals to 0",
        context: {
            errorCode: ErrorCode.ParamValueLegal,
        },
    })
    Offset: number;

    @IsOptional()
    @Min(1, {
        message: "Limit must be greater than 1",
        context: {
            errorCode: ErrorCode.ParamValueLegal,
        },
    })
    @Max(100, {
        message: "Limit must be lower than 100",
        context: {
            errorCode: ErrorCode.ParamValueLegal,
        },
    })
    Limit: number;

    constructor(offset: number, limit: number) {
        this.Offset = offset;
        this.Limit = limit;
    }
}

// 视频相关的服务类
@Service()
export class VideoService {
    videoDao: VideoDao;

    constructor() {
        this.videoDao = Container.get(VideoDao);
    }

    // 搜索视频
    public async SearchVideo(ctx: ServiceContext, condition: VideoListCondition) {
        let videos = await this.videoDao.List(ctx, condition);
        let totalCount = await this.videoDao.Count(ctx, condition);
        let result: SearchVideoResult = {
            VideoList: videos,
            TotalCount: totalCount,
        };
        return result;
    }
    // 其余代码省略...
}

// 视频数据访问类
@Service()
export class VideoDao {
    // 保存视频
    public async Save(ctx: ServiceContext, video: Video) {
        try {
            const videoRepository: Repository<Video> = getManager().getRepository(Video);
            let v = videoRepository.save(video);
            logger.info(ctx, `video has been saved:`, v);
            return v;
        } catch (error) {
            logger.error(ctx, `save video fail:`, error);
            throw new VodError(ErrorCode.SaveVideoFail, "Fail to save video");
        }
    }
    // 其余代码省略...
}