FoXiMao/a-share-analysis
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style(FEAT-DS-001): 统一超短行情代码格式

Browse Source
This commit is contained in:
FoXiMao
2026-08-24 21:49:48 +08:00
parent 61283c5c38
commit 1398804a6f
10 changed files with 35 additions and 52 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/apps/api/src/market-overview/aktools/aktools.client.test.ts
+6 -2
View File
@@ -27,7 +27,9 @@ describe('AKTools HTTP 客户端', () => {
});
it('将 HTTP 错误转换为脱敏的客户端错误', async () => {
const fetchImpl = vi.fn().mockResolvedValue(new Response('secret upstream detail', { status: 500 }));
const fetchImpl = vi
.fn()
.mockResolvedValue(new Response('secret upstream detail', { status: 500 }));
const client = createAktoolsClient({
enabled: true,
baseUrl: 'http://127.0.0.1:8080',
@@ -44,7 +46,9 @@ describe('AKTools HTTP 客户端', () => {
});
it('将请求超时转换为稳定错误', async () => {
const fetchImpl = vi.fn().mockRejectedValue(Object.assign(new Error('aborted'), { name: 'AbortError' }));
const fetchImpl = vi
.fn()
.mockRejectedValue(Object.assign(new Error('aborted'), { name: 'AbortError' }));
const client = createAktoolsClient({
enabled: true,
baseUrl: 'http://127.0.0.1:8080',
server/apps/api/src/market-overview/aktools/aktools.client.ts
+6 -13
View File
@@ -2,11 +2,7 @@ import type { AktoolsRuntimeConfig } from '../../../../../libs/config/src/runtim
import type { AktoolsDataClient, AktoolsRawRow } from './aktools.types';
export type AktoolsClientErrorKind =
| 'disabled'
| 'timeout'
| 'network'
| 'protocol'
| 'unavailable';
'disabled' | 'timeout' | 'network' | 'protocol' | 'unavailable';
export class AktoolsClientError extends Error {
constructor(
@@ -58,14 +54,11 @@ export function createAktoolsClient({
const controller = new AbortController();
const timeout = setTimeout(() => controller.abort(), timeoutMs);
try {
const response = await fetchImpl(
`${endpoint}${path}?date=${encodeURIComponent(tradeDate)}`,
{
method: 'GET',
headers: { accept: 'application/json' },
signal: controller.signal,
},
);
const response = await fetchImpl(`${endpoint}${path}?date=${encodeURIComponent(tradeDate)}`, {
method: 'GET',
headers: { accept: 'application/json' },
signal: controller.signal,
});
const contentLength = response.headers.get('content-length');
if (contentLength && Number(contentLength) > maxResponseBytes) {
throw new AktoolsClientError('protocol', 'AKTools 响应体超过安全上限');
server/apps/api/src/market-overview/aktools/aktools.mapper.test.ts
+2 -8
View File
@@ -1,10 +1,6 @@
import { describe, expect, it } from 'vitest';
import {
mapBrokenBoardPool,
mapLimitUpPool,
mapPreviousLimitUpPool,
} from './aktools.mapper';
import { mapBrokenBoardPool, mapLimitUpPool, mapPreviousLimitUpPool } from './aktools.mapper';
describe('AKTools 超短字段映射', () => {
it('过滤缺失连板数的记录并生成连板梯队', () => {
@@ -21,9 +17,7 @@ describe('AKTools 超短字段映射', () => {
{ board: 2, count: 1 },
{ board: 3, count: 1 },
],
industries: [
{ name: '软件服务', count: 2 },
],
industries: [{ name: '软件服务', count: 2 }],
sealFundsAmount: 1.5,
});
});
server/apps/api/src/market-overview/aktools/aktools.mapper.ts
+1 -3
View File
@@ -74,9 +74,7 @@ export function mapBrokenBoardPool(rows: readonly unknown[]): BrokenBoardSummary
return { count: rows.filter((row) => hasCode(row)).length };
}
export function mapPreviousLimitUpPool(
rows: readonly AktoolsRawRow[],
): PreviousLimitUpSummary {
export function mapPreviousLimitUpPool(rows: readonly AktoolsRawRow[]): PreviousLimitUpSummary {
const changes = rows.flatMap((row) => {
if (!hasCode(row)) return [];
const change = toNumber(row['涨跌幅']);
server/apps/api/src/market-overview/short-term.controller.ts
+2 -7
View File
@@ -1,18 +1,13 @@
import { Controller, Get, Inject } from '@nestjs/common';
import { ApiOkResponse, ApiTags } from '@nestjs/swagger';
import {
ShortTermConclusionResponseDto,
ShortTermEmotionResponseDto,
} from './short-term.dto';
import { ShortTermConclusionResponseDto, ShortTermEmotionResponseDto } from './short-term.dto';
import { ShortTermMarketService } from './short-term.service';
@ApiTags('market-overview-short-term')
@Controller('market-overview/short-term')
export class ShortTermMarketController {
constructor(
@Inject(ShortTermMarketService) private readonly service: ShortTermMarketService,
) {}
constructor(@Inject(ShortTermMarketService) private readonly service: ShortTermMarketService) {}
@Get('emotion')
@ApiOkResponse({ type: ShortTermEmotionResponseDto })
server/apps/api/src/market-overview/short-term.service.test.ts
+5 -3
View File
@@ -14,9 +14,11 @@ describe('短线行情服务', () => {
it('组合涨停、炸板和昨日涨停数据并返回新鲜情绪快照', async () => {
const client = {
getLimitUpPool: vi.fn().mockResolvedValue([
{ 代码: '000001', 连板数: 4, 所属行业: '软件服务', 封板资金: 100_000_000 },
]),
getLimitUpPool: vi
.fn()
.mockResolvedValue([
{ 代码: '000001', 连板数: 4, 所属行业: '软件服务', 封板资金: 100_000_000 },
]),
getBrokenBoardPool: vi.fn().mockResolvedValue([{ 代码: '000002' }]),
getPreviousLimitUpPool: vi.fn().mockResolvedValue([{ 代码: '000003', 涨跌幅: 2 }]),
};
server/apps/api/src/market-overview/short-term.service.ts
+1 -3
View File
@@ -98,9 +98,7 @@ function createConclusion(data: ShortTermEmotionDataDto): ShortTermConclusionDat
@Injectable()
export class ShortTermMarketService {
constructor(
@Inject(AKTOOLS_CLIENT_PORT) private readonly aktoolsClient: AktoolsDataClient,
) {}
constructor(@Inject(AKTOOLS_CLIENT_PORT) private readonly aktoolsClient: AktoolsDataClient) {}
async getEmotion(): Promise<ShortTermEmotionResponseDto> {
const tradeDate = getShanghaiDate(new Date());
server/apps/api/test/short-term.e2e-spec.ts
+6 -9
View File
@@ -4,7 +4,10 @@ import request from 'supertest';
import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest';
import { ShortTermMarketController } from '../src/market-overview/short-term.controller';
import { AKTOOLS_CLIENT_PORT, ShortTermMarketService } from '../src/market-overview/short-term.service';
import {
AKTOOLS_CLIENT_PORT,
ShortTermMarketService,
} from '../src/market-overview/short-term.service';
describe('短线行情 HTTP API', () => {
let app: INestApplication | undefined;
@@ -31,10 +34,7 @@ describe('短线行情 HTTP API', () => {
};
const moduleRef = await Test.createTestingModule({
controllers: [ShortTermMarketController],
providers: [
ShortTermMarketService,
{ provide: AKTOOLS_CLIENT_PORT, useValue: client },
],
providers: [ShortTermMarketService, { provide: AKTOOLS_CLIENT_PORT, useValue: client }],
}).compile();
app = moduleRef.createNestApplication();
app.setGlobalPrefix('api/v1');
@@ -61,10 +61,7 @@ describe('短线行情 HTTP API', () => {
};
const moduleRef = await Test.createTestingModule({
controllers: [ShortTermMarketController],
providers: [
ShortTermMarketService,
{ provide: AKTOOLS_CLIENT_PORT, useValue: client },
],
providers: [ShortTermMarketService, { provide: AKTOOLS_CLIENT_PORT, useValue: client }],
}).compile();
app = moduleRef.createNestApplication();
app.setGlobalPrefix('api/v1');
server/test/process-smoke.test.ts
+5 -1
View File
@@ -60,7 +60,11 @@ describe('NestJS 三进程入口', () => {
logLevel: 'debug',
api: Object.freeze({ host: '127.0.0.1', port: 3000 }),
tdx: Object.freeze({ baseUrl: 'http://127.0.0.1:17710', timeoutMs: 5000 }),
aktools: Object.freeze({ baseUrl: 'http://127.0.0.1:8080', enabled: false, timeoutMs: 10000 }),
aktools: Object.freeze({
baseUrl: 'http://127.0.0.1:8080',
enabled: false,
timeoutMs: 10000,
}),
redis: redisConfig,
mysql: mysqlConfig,
ai: aiConfig,