import {ApiUrlBase, IBidTask, IResp, ITask, TaskTypeKey, UseHistoryMockKey} from "/src-com";
|
import {StorageLocal} from "gs-br-ext";
|
import {Db} from "/src-com/db";
|
import {isNumber} from "gs-base";
|
|
const TaskKey = 'remoteTask';
|
|
export class RemoteTask {
|
static async get(reserve: boolean = false): Promise<ITask | undefined> {
|
// 检查是否开启模拟数据
|
const useMock = await StorageLocal.getValue(UseHistoryMockKey);
|
if (useMock !== false) {
|
const data = await this.getMockTask(useMock);
|
if (data) {
|
return data;
|
}
|
}
|
|
// 原有逻辑
|
const taskType = await StorageLocal.getValue(TaskTypeKey)
|
const url = new URL(`${ApiUrlBase}/task/get`);
|
if (reserve) {
|
url.searchParams.append('reserve', '1');
|
}
|
if (taskType) {
|
url.searchParams.append('type', taskType);
|
}
|
const httpResp = await fetch(url);
|
if (!httpResp.ok) {
|
throw new Error(httpResp.statusText);
|
}
|
const resp: IResp<ITask> = await httpResp.json();
|
if (resp.code != 200) {
|
throw new Error(resp.message);
|
}
|
const {data} = resp || {} as IResp<ITask>;
|
await StorageLocal.setValue(TaskKey, data);
|
return data;
|
}
|
|
// noinspection JSUnusedLocalSymbols
|
static async end(task: ITask): Promise<void> {
|
}
|
|
// 获取模拟任务数据
|
private static async getMockTask(useMock: boolean | number): Promise<IBidTask | undefined> {
|
try {
|
// 从历史记录中随机获取一条数据
|
const mockData = await Db.bidTaskAddedHistory.batchRead(async (store) => {
|
if(isNumber(useMock)) {
|
return await store.get(useMock as number);
|
}
|
const count = await store.count();
|
if (count === 0) return null;
|
const randomIndex = Math.ceil(Math.random() * count);
|
return await store.get(randomIndex);
|
});
|
|
if (!mockData) {
|
return undefined;
|
}
|
|
// 转换为IBidTask类型
|
const bidTask: IBidTask = {
|
id: `mock-${Date.now()}`,
|
type: mockData.taskType === 0 ? 'bid' : 'buyItNow',
|
params: {
|
goodsId: mockData.goodsId,
|
bid: mockData.bid
|
}
|
};
|
|
console.log('生成的模拟任务:', bidTask);
|
await StorageLocal.setValue(TaskKey, bidTask);
|
return bidTask;
|
} catch (error) {
|
console.error('获取模拟任务失败:', error);
|
return undefined;
|
}
|
}
|
}
|
