-
Notifications
You must be signed in to change notification settings - Fork 50
Expand file tree
/
Copy pathmodule.js
More file actions
327 lines (284 loc) · 8.09 KB
/
module.js
File metadata and controls
327 lines (284 loc) · 8.09 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
/**
* 模块数据接口 (T4接口)
* 封装 /api/:module 相关的所有接口调用
*/
import { get, post } from '../request'
import { API_PATHS, MODULE_ACTIONS, PAGINATION } from '../config'
import axios from 'axios'
/**
* 构建模块接口URL
* @param {string} module - 模块名称
* @returns {string} 完整的接口URL
*/
const buildModuleUrl = (module) => {
// 对模块名称进行URL编码以支持中文字符
const encodedModule = encodeURIComponent(module)
return `${API_PATHS.MODULE}/${encodedModule}`
}
/**
* 直接调用站点API
* @param {string} apiUrl - 站点API地址
* @param {object} params - 请求参数
* @returns {Promise} API响应
*/
const directApiCall = async (apiUrl, params = {}) => {
try {
const response = await axios.get(apiUrl, {
params,
timeout: 30000,
headers: {
'Accept': 'application/json'
}
})
return response.data
} catch (error) {
console.error('直接API调用失败:', error)
throw error
}
}
/**
* 获取首页数据(默认接口)
* @param {string} module - 模块名称
* @param {object} options - 选项参数
* @param {number} options.filter - 过滤条件(1表示启用,默认启用)
* @param {string} options.extend - 接口数据扩展参数
* @param {string} options.apiUrl - 站点API地址(可选,如果提供则直接使用)
* @returns {Promise} 首页数据
*/
export const getHomeData = async (module, options = {}) => {
const { filter = 1, extend, apiUrl } = options
const params = { filter }
if (extend) {
params.extend = extend
}
// 如果提供了apiUrl,直接使用站点的API地址
if (apiUrl) {
return directApiCall(apiUrl, params)
}
// 否则使用原来的代理方式
return get(buildModuleUrl(module), params)
}
/**
* 获取分类数据
* @param {string} module - 模块名称
* @param {object} params - 分类参数
* @param {string} params.ac - 固定值 "category"
* @param {string} params.t - 分类ID
* @param {number} params.pg - 页码(从1开始)
* @param {string} params.ext - base64编码的筛选条件JSON字符串
* @param {string} params.extend - 接口数据扩展参数
* @param {string} params.apiUrl - 可选的直接API地址
* @returns {Promise} 分类数据
*/
export const getCategoryData = async (module, params) => {
const {
t: typeId,
pg = PAGINATION.DEFAULT_PAGE,
ext,
extend,
apiUrl
} = params
const requestParams = {
ac: MODULE_ACTIONS.CATEGORY,
t: typeId,
pg
}
if (ext) {
requestParams.ext = ext
}
if (extend) {
requestParams.extend = extend
}
// 如果提供了apiUrl,直接使用站点的API地址
if (apiUrl) {
return directApiCall(apiUrl, requestParams)
}
// 否则使用原来的代理方式
return get(buildModuleUrl(module), requestParams)
}
/**
* 获取视频详情
* @param {string} module - 模块名称
* @param {object} params - 详情参数
* @param {string} params.ids - 视频ID
* @param {string} params.extend - 接口数据扩展参数
* @param {string} params.apiUrl - 可选的直接API地址
* @returns {Promise} 视频详情数据
*/
export const getVideoDetail = async (module, params) => {
const { ids, extend, apiUrl } = params
const requestParams = {
ac: MODULE_ACTIONS.DETAIL,
ids
}
if (extend) {
requestParams.extend = extend
}
// 如果提供了apiUrl,直接使用站点的API地址
if (apiUrl) {
return directApiCall(apiUrl, requestParams)
}
// 否则使用原来的代理方式
return get(buildModuleUrl(module), requestParams)
}
/**
* 播放接口
* @param {string} module - 模块名称
* @param {object} params - 播放参数
* @param {string} params.play - 播放地址或ID
* @param {string} params.extend - 接口数据扩展参数
* @param {string} params.apiUrl - 可选的直接API地址
* @returns {Promise} 播放数据
*/
export const getPlayData = async (module, params) => {
const { play, extend, apiUrl } = params
const requestParams = {
ac: MODULE_ACTIONS.PLAY,
play
}
if (extend) {
requestParams.extend = extend
}
// 如果提供了apiUrl,直接使用站点的API地址
if (apiUrl) {
return directApiCall(apiUrl, requestParams)
}
// 否则使用原来的代理方式
return get(buildModuleUrl(module), requestParams)
}
/**
* 搜索接口
* @param {string} module - 模块名称
* @param {object} params - 搜索参数
* @param {string} params.wd - 搜索关键词
* @param {number} params.pg - 页码(从1开始)
* @param {string} params.extend - 接口数据扩展参数
* @param {string} params.apiUrl - 可选的直接API地址
* @returns {Promise} 搜索结果
*/
export const searchVideos = async (module, params) => {
const {
wd: keyword,
pg = PAGINATION.DEFAULT_PAGE,
extend,
apiUrl
} = params
const requestParams = {
wd: keyword,
pg
}
if (extend) {
requestParams.extend = extend
}
// 如果提供了apiUrl,直接使用站点的API地址
if (apiUrl) {
return directApiCall(apiUrl, requestParams)
}
// 否则使用原来的代理方式
return get(buildModuleUrl(module), requestParams)
}
/**
* 动作接口(POST请求)
* @param {string} module - 模块名称
* @param {object} data - 动作数据
* @param {string} data.action - 动作类型
* @param {string} data.extend - 接口数据扩展参数
* @param {string} data.apiUrl - 可选的直接API地址
* @returns {Promise} 动作执行结果
*/
export const executeAction = async (module, data) => {
const { action, extend, apiUrl, ...otherData } = data
const requestData = {
ac: MODULE_ACTIONS.ACTION,
action,
...otherData
}
if (extend) {
requestData.extend = extend
}
console.log('executeAction调用参数:', {
module,
data,
requestData,
apiUrl
})
// 如果提供了apiUrl,直接使用站点的API地址
if (apiUrl) {
const axios = (await import('axios')).default
console.log('直接调用API:', apiUrl, requestData)
// 如果是测试用的JSON文件,使用GET请求
if (apiUrl.endsWith('.json')) {
const response = await axios.get(apiUrl, {
timeout: 30000,
headers: {
'Accept': 'application/json'
}
})
console.log('API响应 (GET):', response.data)
return response.data
} else {
// 否则使用POST请求
const response = await axios.post(apiUrl, requestData, {
timeout: 30000,
headers: {
'Accept': 'application/json',
'Content-Type': 'application/json'
}
})
console.log('API响应 (POST):', response.data)
return response.data
}
}
// 否则使用原来的代理方式
console.log('使用代理方式调用:', buildModuleUrl(module), requestData)
const result = await post(buildModuleUrl(module), requestData)
console.log('代理响应:', result)
return result
}
/**
* 刷新模块数据
* @param {string} module - 模块名称
* @param {string} extend - 接口数据扩展参数
* @param {string} apiUrl - 可选的直接API地址
* @returns {Promise} 刷新结果
*/
export const refreshModule = async (module, extend, apiUrl) => {
const params = {
refresh: '1'
}
if (extend) {
params.extend = extend
}
// 如果提供了apiUrl,直接使用站点的API地址
if (apiUrl) {
return directApiCall(apiUrl, params)
}
// 否则使用原来的代理方式
return get(buildModuleUrl(module), params)
}
/**
* 通用模块接口调用
* @param {string} module - 模块名称
* @param {object} params - 请求参数
* @param {string} method - 请求方法 ('GET' | 'POST')
* @returns {Promise} 接口响应
*/
export const callModuleApi = async (module, params = {}, method = 'GET') => {
const url = buildModuleUrl(module)
if (method.toUpperCase() === 'POST') {
return post(url, params)
} else {
return get(url, params)
}
}
// 默认导出所有接口
export default {
getHomeData,
getCategoryData,
getVideoDetail,
getPlayData,
searchVideos,
executeAction,
refreshModule,
callModuleApi
}