mirror of
https://github.com/HChaZZY/PiliPlus.git
synced 2025-12-06 09:13:48 +08:00
548 lines
14 KiB
Dart
548 lines
14 KiB
Dart
import 'package:flutter_smart_dialog/flutter_smart_dialog.dart';
|
||
import 'package:hive/hive.dart';
|
||
import '../common/constants.dart';
|
||
import '../models/dynamics/result.dart';
|
||
import '../models/follow/result.dart';
|
||
import '../models/member/archive.dart';
|
||
import '../models/member/coin.dart';
|
||
import '../models/member/info.dart';
|
||
import '../models/member/seasons.dart';
|
||
import '../models/member/tags.dart';
|
||
import '../utils/storage.dart';
|
||
import '../utils/utils.dart';
|
||
import '../utils/wbi_sign.dart';
|
||
import 'index.dart';
|
||
|
||
class MemberHttp {
|
||
static Future memberInfo({
|
||
int? mid,
|
||
String token = '',
|
||
}) async {
|
||
Map params = await WbiSign().makSign({
|
||
'mid': mid,
|
||
'token': token,
|
||
'platform': 'web',
|
||
'web_location': 1550101,
|
||
});
|
||
var res = await Request().get(
|
||
Api.memberInfo,
|
||
data: params,
|
||
extra: {'ua': 'pc'},
|
||
);
|
||
if (res.data['code'] == 0) {
|
||
return {
|
||
'status': true,
|
||
'data': MemberInfoModel.fromJson(res.data['data'])
|
||
};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
static Future memberStat({int? mid}) async {
|
||
var res = await Request().get(Api.userStat, data: {'vmid': mid});
|
||
if (res.data['code'] == 0) {
|
||
return {'status': true, 'data': res.data['data']};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
static Future memberCardInfo({int? mid}) async {
|
||
var res = await Request()
|
||
.get(Api.memberCardInfo, data: {'mid': mid, 'photo': true});
|
||
if (res.data['code'] == 0) {
|
||
return {'status': true, 'data': res.data['data']};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
static Future memberArchive({
|
||
int? mid,
|
||
int ps = 40,
|
||
int tid = 0,
|
||
int? pn,
|
||
String? keyword,
|
||
String order = 'pubdate',
|
||
bool orderAvoided = true,
|
||
}) async {
|
||
String dmImgStr = Utils.base64EncodeRandomString(16, 64);
|
||
String dmCoverImgStr = Utils.base64EncodeRandomString(32, 128);
|
||
Map params = await WbiSign().makSign({
|
||
'mid': mid,
|
||
'ps': ps,
|
||
'tid': tid,
|
||
'pn': pn,
|
||
'keyword': keyword ?? '',
|
||
'order': order,
|
||
'platform': 'web',
|
||
'web_location': 1550101,
|
||
'order_avoided': orderAvoided,
|
||
'dm_img_list': '[]',
|
||
'dm_img_str': dmImgStr.substring(0, dmImgStr.length - 2),
|
||
'dm_cover_img_str': dmCoverImgStr.substring(0, dmCoverImgStr.length - 2),
|
||
'dm_img_inter': '{"ds":[],"wh":[0,0,0],"of":[0,0,0]}',
|
||
});
|
||
var res = await Request().get(
|
||
Api.memberArchive,
|
||
data: params,
|
||
extra: {'ua': 'Mozilla/5.0'},
|
||
);
|
||
if (res.data['code'] == 0) {
|
||
return {
|
||
'status': true,
|
||
'data': MemberArchiveDataModel.fromJson(res.data['data'])
|
||
};
|
||
} else {
|
||
Map errMap = {
|
||
-352: '风控校验失败，请检查登录状态',
|
||
};
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': errMap[res.data['code']] ?? res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 用户动态
|
||
static Future memberDynamic({String? offset, int? mid}) async {
|
||
var res = await Request().get(Api.memberDynamic, data: {
|
||
'offset': offset ?? '',
|
||
'host_mid': mid,
|
||
'timezone_offset': '-480',
|
||
'features': 'itemOpusStyle',
|
||
});
|
||
if (res.data['code'] == 0) {
|
||
return {
|
||
'status': true,
|
||
'data': DynamicsDataModel.fromJson(res.data['data']),
|
||
};
|
||
} else {
|
||
Map errMap = {
|
||
-352: '风控校验失败，请检查登录状态',
|
||
};
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': errMap[res.data['code']] ?? res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 搜索用户动态
|
||
static Future memberDynamicSearch({int? pn, int? ps, int? mid}) async {
|
||
var res = await Request().get(Api.memberDynamic, data: {
|
||
'keyword': '海拔',
|
||
'mid': mid,
|
||
'pn': pn,
|
||
'ps': ps,
|
||
'platform': 'web'
|
||
});
|
||
if (res.data['code'] == 0) {
|
||
return {
|
||
'status': true,
|
||
'data': DynamicsDataModel.fromJson(res.data['data']),
|
||
};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 查询分组
|
||
static Future followUpTags() async {
|
||
var res = await Request().get(Api.followUpTag);
|
||
if (res.data['code'] == 0) {
|
||
return {
|
||
'status': true,
|
||
'data': res.data['data']
|
||
.map<MemberTagItemModel>((e) => MemberTagItemModel.fromJson(e))
|
||
.toList()
|
||
};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 设置分组
|
||
static Future addUsers(int? fids, String? tagids) async {
|
||
var res = await Request().post(Api.addUsers, queryParameters: {
|
||
'fids': fids,
|
||
'tagids': tagids ?? '0',
|
||
'csrf': await Request.getCsrf(),
|
||
}, data: {
|
||
'cross_domain': true
|
||
});
|
||
if (res.data['code'] == 0) {
|
||
return {'status': true, 'data': [], 'msg': '操作成功'};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 获取某分组下的up
|
||
static Future followUpGroup(
|
||
int? mid,
|
||
int? tagid,
|
||
int? pn,
|
||
int? ps,
|
||
) async {
|
||
var res = await Request().get(Api.followUpGroup, data: {
|
||
'mid': mid,
|
||
'tagid': tagid,
|
||
'pn': pn,
|
||
'ps': ps,
|
||
});
|
||
if (res.data['code'] == 0) {
|
||
// FollowItemModel
|
||
return {
|
||
'status': true,
|
||
'data': res.data['data']
|
||
.map<FollowItemModel>((e) => FollowItemModel.fromJson(e))
|
||
.toList()
|
||
};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 获取up置顶
|
||
static Future getTopVideo(String? vmid) async {
|
||
var res = await Request().get(Api.getTopVideoApi);
|
||
if (res.data['code'] == 0) {
|
||
return {
|
||
'status': true,
|
||
'data': res.data['data']
|
||
.map<MemberTagItemModel>((e) => MemberTagItemModel.fromJson(e))
|
||
.toList()
|
||
};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 获取uo专栏
|
||
static Future getMemberSeasons(int? mid, int? pn, int? ps) async {
|
||
var res = await Request().get(Api.getMemberSeasonsApi, data: {
|
||
'mid': mid,
|
||
'page_num': pn,
|
||
'page_size': ps,
|
||
});
|
||
if (res.data['code'] == 0) {
|
||
return {
|
||
'status': true,
|
||
'data': MemberSeasonsDataModel.fromJson(res.data['data']['items_lists'])
|
||
};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 最近投币
|
||
static Future getRecentCoinVideo({required int mid}) async {
|
||
Map params = await WbiSign().makSign({
|
||
'mid': mid,
|
||
'gaia_source': 'main_web',
|
||
'web_location': 333.999,
|
||
});
|
||
var res = await Request().get(
|
||
Api.getRecentCoinVideoApi,
|
||
data: {
|
||
'vmid': mid,
|
||
'gaia_source': 'main_web',
|
||
'web_location': 333.999,
|
||
'w_rid': params['w_rid'],
|
||
'wts': params['wts'],
|
||
},
|
||
);
|
||
if (res.data['code'] == 0) {
|
||
return {
|
||
'status': true,
|
||
'data': res.data['data']
|
||
.map<MemberCoinsDataModel>((e) => MemberCoinsDataModel.fromJson(e))
|
||
.toList(),
|
||
};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 最近点赞
|
||
static Future getRecentLikeVideo({required int mid}) async {
|
||
Map params = await WbiSign().makSign({
|
||
'mid': mid,
|
||
'gaia_source': 'main_web',
|
||
'web_location': 333.999,
|
||
});
|
||
var res = await Request().get(
|
||
Api.getRecentLikeVideoApi,
|
||
data: {
|
||
'vmid': mid,
|
||
'gaia_source': 'main_web',
|
||
'web_location': 333.999,
|
||
'w_rid': params['w_rid'],
|
||
'wts': params['wts'],
|
||
},
|
||
);
|
||
if (res.data['code'] == 0) {
|
||
return {
|
||
'status': true,
|
||
'data': MemberSeasonsDataModel.fromJson(res.data['data']['items_lists'])
|
||
};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 查看某个专栏
|
||
static Future getSeasonDetail({
|
||
required int mid,
|
||
required int seasonId,
|
||
bool sortReverse = false,
|
||
required int pn,
|
||
required int ps,
|
||
}) async {
|
||
var res = await Request().get(
|
||
Api.getSeasonDetailApi,
|
||
data: {
|
||
'mid': mid,
|
||
'season_id': seasonId,
|
||
'sort_reverse': sortReverse,
|
||
'page_num': pn,
|
||
'page_size': ps,
|
||
},
|
||
);
|
||
if (res.data['code'] == 0) {
|
||
try {
|
||
return {
|
||
'status': true,
|
||
'data': MemberSeasonsList.fromJson(res.data['data'])
|
||
};
|
||
} catch (err) {
|
||
print(err);
|
||
}
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 获取TV authCode
|
||
static Future getTVCode() async {
|
||
SmartDialog.showLoading(msg: "正在申请HD版二维码...");
|
||
var params = {
|
||
'appkey': Constants.appKey,
|
||
// 'local_id': 'Y952A395BB157D305D8A8340FC2AAECECE17',
|
||
'local_id': '0',
|
||
'ts': DateTime.now().millisecondsSinceEpoch.toString(),
|
||
'platform': 'android',
|
||
'mobi_app': 'android_hd',
|
||
};
|
||
String sign = Utils.appSign(
|
||
params,
|
||
Constants.appKey,
|
||
Constants.appSec,
|
||
);
|
||
var res = await Request()
|
||
.post(Api.getTVCode, queryParameters: {...params, 'sign': sign});
|
||
SmartDialog.dismiss();
|
||
print(res.data);
|
||
if (res.data['code'] == 0) {
|
||
print("getTVCode");
|
||
return {
|
||
'status': true,
|
||
'data': res.data['data']['auth_code'],
|
||
'msg': '操作成功'
|
||
};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data,
|
||
};
|
||
}
|
||
}
|
||
|
||
// 获取access_key
|
||
static Future cookieToKey() async {
|
||
var authCodeRes = await getTVCode();
|
||
if (authCodeRes['status']) {
|
||
SmartDialog.showLoading(msg: "正在确认登录...");
|
||
var confirmRes =
|
||
await Request().post(Api.qrcodeConfirm, queryParameters: {
|
||
'auth_code': authCodeRes['data'],
|
||
'local_id': '0',
|
||
'build': 1442100,
|
||
'scanning_type': 1,
|
||
'csrf': await Request.getCsrf(),
|
||
});
|
||
print("confirmRes");
|
||
print(confirmRes);
|
||
SmartDialog.dismiss();
|
||
if (confirmRes.data['code'] != 0) {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg':
|
||
"确认登录失败：${confirmRes.data['message']}\n\n请在设置中退出账号，重启app，重新登录再试",
|
||
};
|
||
}
|
||
SmartDialog.showLoading(msg: "等待500毫秒...");
|
||
await Future.delayed(const Duration(milliseconds: 500));
|
||
SmartDialog.dismiss();
|
||
SmartDialog.showLoading(msg: "正在获取登录结果（含access_key）...");
|
||
var res = await qrcodePoll(authCodeRes['data']);
|
||
SmartDialog.dismiss();
|
||
if (res['status']) {
|
||
return {'status': true, 'data': [], 'msg': res['msg']};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': "登录结果获取失败：${res.data['msg']}",
|
||
};
|
||
}
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': "TV版二维码申请失败：${authCodeRes['msg']}",
|
||
};
|
||
}
|
||
}
|
||
|
||
static Future qrcodePoll(authCode) async {
|
||
var params = {
|
||
'appkey': Constants.appKey,
|
||
'auth_code': authCode.toString(),
|
||
'local_id': '0',
|
||
'ts': (DateTime.now().millisecondsSinceEpoch ~/ 1000).toString(),
|
||
};
|
||
String sign = Utils.appSign(
|
||
params,
|
||
Constants.appKey,
|
||
Constants.appSec,
|
||
);
|
||
var res = await Request()
|
||
.post(Api.qrcodePoll, queryParameters: {...params, 'sign': sign});
|
||
if (res.data['code'] == 0) {
|
||
String accessKey = res.data['data']['access_token'];
|
||
Box localCache = GStorage.localCache;
|
||
Box userInfoCache = GStorage.userInfo;
|
||
var userInfo = userInfoCache.get('userInfoCache');
|
||
localCache.put(
|
||
LocalCacheKey.accessKey, {'mid': userInfo.mid, 'value': accessKey});
|
||
return {
|
||
'status': true,
|
||
'data': [],
|
||
'msg': '操作成功，当前获取的access_key为：$accessKey'
|
||
};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 获取up播放数、点赞数
|
||
static Future memberView({required int mid}) async {
|
||
var res = await Request().get(Api.getMemberViewApi, data: {'mid': mid});
|
||
if (res.data['code'] == 0) {
|
||
return {'status': true, 'data': res.data['data']};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
|
||
// 搜索follow
|
||
static Future getfollowSearch({
|
||
required int mid,
|
||
required int ps,
|
||
required int pn,
|
||
required String name,
|
||
}) async {
|
||
Map<String, dynamic> data = {
|
||
'vmid': mid,
|
||
'pn': pn,
|
||
'ps': ps,
|
||
'order': 'desc',
|
||
'order_type': 'attention',
|
||
'gaia_source': 'main_web',
|
||
'name': name,
|
||
'web_location': 333.999,
|
||
};
|
||
Map params = await WbiSign().makSign(data);
|
||
var res = await Request().get(Api.followSearch, data: {
|
||
...data,
|
||
'w_rid': params['w_rid'],
|
||
'wts': params['wts'],
|
||
});
|
||
if (res.data['code'] == 0) {
|
||
return {
|
||
'status': true,
|
||
'data': FollowDataModel.fromJson(res.data['data'])
|
||
};
|
||
} else {
|
||
return {
|
||
'status': false,
|
||
'data': [],
|
||
'msg': res.data['message'],
|
||
};
|
||
}
|
||
}
|
||
}
|