230 lines
8.4 KiB
Dart
230 lines
8.4 KiB
Dart
import 'package:dio/dio.dart';
|
||
import 'package:hgdj/hj_model/drama/drama_models.dart';
|
||
import 'package:hgdj/hj_model/drama_media_info.dart';
|
||
import 'package:hgdj/hj_model/list_base_model.dart';
|
||
import 'package:hgdj/hj_model/media_content.dart';
|
||
import 'package:hgdj/tools_base/net/base_resp_bean.dart';
|
||
import 'package:hgdj/tools_base/net/http_manager.dart';
|
||
|
||
/// 短剧接口。金币解锁已并入 PayManager/BuyService，这里只剩读操作 + 两个计数型写操作：
|
||
/// 信息流翻页去重、分享互动计数，都必须带 `X-Request-ID`——同一次业务的重试要复用同一个 id，
|
||
/// 换新 id 就会重复计数
|
||
class DramaService {
|
||
static Options _idempotent(String requestId) =>
|
||
Options(headers: {'X-Request-ID': requestId});
|
||
|
||
/// AI短剧信息流：一条 = 一部剧 + 该剧第 1 集。
|
||
/// 排序、去重、已看沉底全在服务端，客户端不得二次排序，也不分页页码——每次请求都是下一批
|
||
static Future<ListBaseModel<DramaFeedItem>?> fetchFeed(
|
||
{int size = 20, String? requestId}) async {
|
||
final result = await httpManager.fetchResponseByGET(
|
||
'/media/drama/feed',
|
||
param: {'pageSize': size},
|
||
options: requestId == null ? null : _idempotent(requestId),
|
||
jsonTransformation: (json) => ListBaseModel<DramaFeedItem>.fromJson(json),
|
||
);
|
||
return result.isSuccess ? result.data : null;
|
||
}
|
||
|
||
/// 短剧专题列表（热门短剧 Tab，按 sort 倒序已由服务端排好）
|
||
static Future<List<DramaTopic>?> fetchTopics() async {
|
||
final result = await httpManager.fetchResponseByGET(
|
||
'/media/drama/topics',
|
||
jsonTransformation: (json) =>
|
||
(json['list'] as List?)
|
||
?.map((e) => DramaTopic.fromJson(e))
|
||
.toList() ??
|
||
<DramaTopic>[],
|
||
);
|
||
return result.isSuccess ? result.data : null;
|
||
}
|
||
|
||
/// 专题作品列表（热门短剧橱窗）
|
||
static Future<ListBaseModel<DramaMediaInfo>?> fetchTopicWorks(
|
||
String topicId, {
|
||
int page = 1,
|
||
int size = 20,
|
||
}) async {
|
||
if (topicId.isEmpty) return null;
|
||
final result = await httpManager.fetchResponseByGET(
|
||
'/media/drama/topic/works',
|
||
param: {
|
||
'topicId': topicId,
|
||
'pageNumber': page,
|
||
'pageSize': size,
|
||
},
|
||
jsonTransformation: (json) =>
|
||
ListBaseModel<DramaMediaInfo>.fromJson(json),
|
||
);
|
||
return result.isSuccess ? result.data : null;
|
||
}
|
||
|
||
/// 搜索短剧：`GET /media/search`，[kind] 固定 4
|
||
/// [sortType] 1 最新上架、2 最多观看；默认 1
|
||
static Future<DramaSearchResult?> search({
|
||
required String keyword,
|
||
int page = 1,
|
||
int size = 20,
|
||
int sortType = 1,
|
||
}) async {
|
||
final result = await httpManager.fetchResponseByGET(
|
||
'/media/search',
|
||
param: {
|
||
'keyword': keyword,
|
||
'kind': 4,
|
||
'pageNumber': page,
|
||
'pageSize': size,
|
||
'sortType': sortType,
|
||
},
|
||
jsonTransformation: (json) => DramaSearchResult.fromJson(json),
|
||
);
|
||
return result.isSuccess ? result.data : null;
|
||
}
|
||
|
||
/// 短剧详情(剧信息 + resume 续播位置，不含分集)
|
||
static Future<DramaMediaInfo?> fetchDetail(String? dramaId) async {
|
||
if (dramaId?.isNotEmpty != true) return null;
|
||
final result = await httpManager.fetchResponseByGET(
|
||
'/media/info',
|
||
param: {'id': dramaId},
|
||
jsonTransformation: (json) => DramaMediaInfo.fromJson(json),
|
||
);
|
||
return result.isSuccess ? result.data : null;
|
||
}
|
||
|
||
/// 短剧片库搜索：标签页用它按标签取剧，走的是和 ACG 片库同一个接口。
|
||
/// [tagIds] 空/不传 = 不按标签筛；[sortType] 1热门推荐 2最新上架 4最多收藏
|
||
static Future<ListBaseModel<DramaMediaInfo>?> searchLibrary({
|
||
int page = 1,
|
||
int size = 20,
|
||
List<String>? tagIds,
|
||
int? sortType,
|
||
}) async {
|
||
final param = <String, dynamic>{
|
||
'pageNumber': page,
|
||
'pageSize': size,
|
||
'mediaType': 'drama',
|
||
'sortType': sortType,
|
||
'tagIds': tagIds,
|
||
}..removeWhere((k, v) => v == null || (v is List && v.isEmpty));
|
||
final result = await httpManager.fetchResponseByPOST(
|
||
'/media/library/search',
|
||
param: param,
|
||
jsonTransformation: (json) =>
|
||
ListBaseModel<DramaMediaInfo>.fromJson(json),
|
||
);
|
||
return result.isSuccess ? result.data : null;
|
||
}
|
||
|
||
/// 分集列表(选集面板用) [sortType] 0-正序 1-倒序
|
||
static Future<ListBaseModel<MediaContent>?> fetchEpisodeList(
|
||
String dramaId, int page, int size) async {
|
||
if (dramaId.isEmpty) return null; // 与 fetchDetail 一致：没有剧 id 就别发空请求
|
||
final result = await httpManager.fetchResponseByGET(
|
||
'/media_content/list',
|
||
param: {
|
||
'mediaId': dramaId,
|
||
'pageNumber': page,
|
||
'pageSize': size,
|
||
'sortType': 0
|
||
},
|
||
jsonTransformation: (json) => ListBaseModel<MediaContent>.fromJson(json),
|
||
);
|
||
return result.isSuccess ? result.data : null;
|
||
}
|
||
|
||
/// 分集详情：播放地址 + canPlay + 未解锁时的 paywall。
|
||
/// 列表里的播放地址会过期，每次起播都得重新拉这个接口，不能跨时长缓存
|
||
static Future<MediaContent?> fetchEpisode(String? contentId) async {
|
||
if (contentId?.isNotEmpty != true) return null;
|
||
final result = await httpManager.fetchResponseByGET(
|
||
'/media_content/info',
|
||
param: {'id': contentId},
|
||
jsonTransformation: (json) => MediaContent.fromJson(json),
|
||
);
|
||
return result.isSuccess ? result.data : null;
|
||
}
|
||
|
||
/// 我的喜欢-短剧
|
||
static Future<ListBaseModel<DramaMediaInfo>?> fetchLikes(int page,
|
||
{int size = 20}) async {
|
||
final result = await httpManager.fetchResponseByGET(
|
||
'/mine/like',
|
||
param: {'likeType': 'drama', 'pageNumber': page, 'pageSize': size},
|
||
jsonTransformation: (json) =>
|
||
ListBaseModel<DramaMediaInfo>.fromJson(json),
|
||
);
|
||
return result.isSuccess ? result.data : null;
|
||
}
|
||
|
||
/// 我的收藏-短剧 [sortType] 0-最新收藏 1-最近更新
|
||
static Future<ListBaseModel<DramaMediaInfo>?> fetchFavorites(int page,
|
||
{int size = 20, int sortType = 0}) async {
|
||
final result = await httpManager.fetchResponseByGET(
|
||
'/media_bookshelf/list',
|
||
param: {
|
||
'type': 'drama',
|
||
'sortType': sortType,
|
||
'pageNumber': page,
|
||
'pageSize': size
|
||
},
|
||
jsonTransformation: (json) =>
|
||
ListBaseModel<DramaMediaInfo>.fromJson(json),
|
||
);
|
||
return result.isSuccess ? result.data : null;
|
||
}
|
||
|
||
/// 我的已购-短剧(按剧去重，点进去看每集的 hasBuy)
|
||
static Future<ListBaseModel<DramaMediaInfo>?> fetchPurchased(int page,
|
||
{int size = 20}) async {
|
||
final result = await httpManager.fetchResponseByGET(
|
||
'/media/my_buy',
|
||
param: {'mediaType': 'drama', 'pageNumber': page, 'pageSize': size},
|
||
jsonTransformation: (json) =>
|
||
ListBaseModel<DramaMediaInfo>.fromJson(json),
|
||
);
|
||
return result.isSuccess ? result.data : null;
|
||
}
|
||
|
||
/// 短剧单集下载授权：**下载链路唯一入口**。
|
||
/// 登录态、上下架、短剧权益、钱包下载次数校验 + 扣 1 次 + 幂等，服务端一次做完并回下载地址，
|
||
/// 前端不要再调 `/mine/privilege/consume` 或 `/mine/download/use`——那两个只扣次不给资源，会重复扣。
|
||
/// [requestId] 同一次下载(含超时重试、刷新过期地址)必须复用，换新的会再扣一次；
|
||
/// 返回整个 [BaseRespBean]：失败要按 code 分流引导，不能只看有没有数据
|
||
static Future<BaseRespBean> authorizeDownload({
|
||
required String mediaId,
|
||
required String contentId,
|
||
required String requestId,
|
||
}) {
|
||
return httpManager.fetchResponseByPOST(
|
||
'/media/drama/download/authorize',
|
||
param: {'mediaId': mediaId, 'contentId': contentId},
|
||
options: _idempotent(requestId),
|
||
jsonTransformation: (json) => DramaDownloadAuth.fromJson(json),
|
||
);
|
||
}
|
||
|
||
/// 分享落地：服务端按 [eventId] 幂等累计分享互动数，返回二维码 PNG 的 base64
|
||
static Future<String?> shareOutput({
|
||
required String content,
|
||
required String? mediaId,
|
||
String? contentId,
|
||
required String eventId,
|
||
}) async {
|
||
final result = await httpManager.fetchResponseByPOST(
|
||
'/share/output',
|
||
param: {
|
||
'content': content,
|
||
'objType': 'drama',
|
||
'mediaID': mediaId,
|
||
'contentID': contentId ?? '',
|
||
'eventId': eventId,
|
||
},
|
||
options: _idempotent(eventId),
|
||
);
|
||
return result.isSuccess
|
||
? (result.data is Map ? result.data['qrCode'] : null)
|
||
: null;
|
||
}
|
||
}
|