fix(mining-admin-service): 修正调用 mining-service admin API 路径
mining-service 的 AdminController 路由前缀改为 mining/admin 后, mining-admin-service 中调用的路径也需要相应修改 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
parent
f3d460ba09
commit
0009a9358d
|
|
@ -43,11 +43,11 @@ export class ConfigController {
|
||||||
const miningServiceUrl = this.appConfigService.get<string>('MINING_SERVICE_URL', 'http://localhost:3021');
|
const miningServiceUrl = this.appConfigService.get<string>('MINING_SERVICE_URL', 'http://localhost:3021');
|
||||||
const contributionServiceUrl = this.appConfigService.get<string>('CONTRIBUTION_SERVICE_URL', 'http://localhost:3020');
|
const contributionServiceUrl = this.appConfigService.get<string>('CONTRIBUTION_SERVICE_URL', 'http://localhost:3020');
|
||||||
|
|
||||||
this.logger.log(`Fetching mining status from ${miningServiceUrl}/api/v2/admin/status`);
|
this.logger.log(`Fetching mining status from ${miningServiceUrl}/api/v2/mining/admin/status`);
|
||||||
try {
|
try {
|
||||||
// 并行获取 mining-service 状态和 contribution-service 统计数据
|
// 并行获取 mining-service 状态和 contribution-service 统计数据
|
||||||
const [miningResponse, contributionResponse] = await Promise.all([
|
const [miningResponse, contributionResponse] = await Promise.all([
|
||||||
fetch(`${miningServiceUrl}/api/v2/admin/status`),
|
fetch(`${miningServiceUrl}/api/v2/mining/admin/status`),
|
||||||
fetch(`${contributionServiceUrl}/api/v2/contribution/stats`).catch(() => null),
|
fetch(`${contributionServiceUrl}/api/v2/contribution/stats`).catch(() => null),
|
||||||
]);
|
]);
|
||||||
|
|
||||||
|
|
@ -137,7 +137,7 @@ export class ConfigController {
|
||||||
async activateMining(@Req() req: any) {
|
async activateMining(@Req() req: any) {
|
||||||
const miningServiceUrl = this.appConfigService.get<string>('MINING_SERVICE_URL', 'http://localhost:3021');
|
const miningServiceUrl = this.appConfigService.get<string>('MINING_SERVICE_URL', 'http://localhost:3021');
|
||||||
try {
|
try {
|
||||||
const response = await fetch(`${miningServiceUrl}/api/v2/admin/activate`, {
|
const response = await fetch(`${miningServiceUrl}/api/v2/mining/admin/activate`, {
|
||||||
method: 'POST',
|
method: 'POST',
|
||||||
});
|
});
|
||||||
if (!response.ok) {
|
if (!response.ok) {
|
||||||
|
|
@ -157,7 +157,7 @@ export class ConfigController {
|
||||||
async deactivateMining(@Req() req: any) {
|
async deactivateMining(@Req() req: any) {
|
||||||
const miningServiceUrl = this.appConfigService.get<string>('MINING_SERVICE_URL', 'http://localhost:3021');
|
const miningServiceUrl = this.appConfigService.get<string>('MINING_SERVICE_URL', 'http://localhost:3021');
|
||||||
try {
|
try {
|
||||||
const response = await fetch(`${miningServiceUrl}/api/v2/admin/deactivate`, {
|
const response = await fetch(`${miningServiceUrl}/api/v2/mining/admin/deactivate`, {
|
||||||
method: 'POST',
|
method: 'POST',
|
||||||
});
|
});
|
||||||
if (!response.ok) {
|
if (!response.ok) {
|
||||||
|
|
|
||||||
|
|
@ -48,7 +48,7 @@ export class BatchMiningService {
|
||||||
* 获取批量补发状态
|
* 获取批量补发状态
|
||||||
*/
|
*/
|
||||||
async getStatus(): Promise<any> {
|
async getStatus(): Promise<any> {
|
||||||
const url = `${this.miningServiceUrl}/api/v2/admin/batch-mining/status`;
|
const url = `${this.miningServiceUrl}/api/v2/mining/admin/batch-mining/status`;
|
||||||
this.logger.log(`[getStatus] 开始获取批量补发状态, URL: ${url}`);
|
this.logger.log(`[getStatus] 开始获取批量补发状态, URL: ${url}`);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
|
@ -90,7 +90,7 @@ export class BatchMiningService {
|
||||||
* 预览批量补发(计算但不执行)
|
* 预览批量补发(计算但不执行)
|
||||||
*/
|
*/
|
||||||
async preview(items: BatchMiningItem[]): Promise<any> {
|
async preview(items: BatchMiningItem[]): Promise<any> {
|
||||||
const url = `${this.miningServiceUrl}/api/v2/admin/batch-mining/preview`;
|
const url = `${this.miningServiceUrl}/api/v2/mining/admin/batch-mining/preview`;
|
||||||
this.logger.log(`[preview] 开始预览批量补发, URL: ${url}`);
|
this.logger.log(`[preview] 开始预览批量补发, URL: ${url}`);
|
||||||
this.logger.log(`[preview] 数据条数: ${items.length}`);
|
this.logger.log(`[preview] 数据条数: ${items.length}`);
|
||||||
this.logger.log(`[preview] 前3条数据: ${JSON.stringify(items.slice(0, 3))}`);
|
this.logger.log(`[preview] 前3条数据: ${JSON.stringify(items.slice(0, 3))}`);
|
||||||
|
|
@ -138,7 +138,7 @@ export class BatchMiningService {
|
||||||
request: BatchMiningRequest,
|
request: BatchMiningRequest,
|
||||||
adminId: string,
|
adminId: string,
|
||||||
): Promise<any> {
|
): Promise<any> {
|
||||||
const url = `${this.miningServiceUrl}/api/v2/admin/batch-mining/execute`;
|
const url = `${this.miningServiceUrl}/api/v2/mining/admin/batch-mining/execute`;
|
||||||
this.logger.log(`[execute] 开始执行批量补发, URL: ${url}`);
|
this.logger.log(`[execute] 开始执行批量补发, URL: ${url}`);
|
||||||
this.logger.log(`[execute] 操作人: ${request.operatorName} (${request.operatorId})`);
|
this.logger.log(`[execute] 操作人: ${request.operatorName} (${request.operatorId})`);
|
||||||
this.logger.log(`[execute] 原因: ${request.reason}`);
|
this.logger.log(`[execute] 原因: ${request.reason}`);
|
||||||
|
|
@ -212,7 +212,7 @@ export class BatchMiningService {
|
||||||
* 获取执行记录
|
* 获取执行记录
|
||||||
*/
|
*/
|
||||||
async getExecution(): Promise<any> {
|
async getExecution(): Promise<any> {
|
||||||
const url = `${this.miningServiceUrl}/api/v2/admin/batch-mining/execution`;
|
const url = `${this.miningServiceUrl}/api/v2/mining/admin/batch-mining/execution`;
|
||||||
this.logger.log(`[getExecution] 开始获取执行记录, URL: ${url}`);
|
this.logger.log(`[getExecution] 开始获取执行记录, URL: ${url}`);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
|
|
||||||
|
|
@ -642,7 +642,7 @@ export class DashboardService {
|
||||||
try {
|
try {
|
||||||
// 从 mining-service 获取已分配积分股
|
// 从 mining-service 获取已分配积分股
|
||||||
const miningResponse = await fetch(
|
const miningResponse = await fetch(
|
||||||
`${miningServiceUrl}/api/v2/admin/status`,
|
`${miningServiceUrl}/api/v2/mining/admin/status`,
|
||||||
);
|
);
|
||||||
if (miningResponse.ok) {
|
if (miningResponse.ok) {
|
||||||
const miningResult = await miningResponse.json();
|
const miningResult = await miningResponse.json();
|
||||||
|
|
|
||||||
|
|
@ -921,7 +921,7 @@ export class UsersService {
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const url = `${this.miningServiceUrl}/api/v2/admin/batch-mining/records/${accountSequence}?page=${page}&pageSize=${pageSize}`;
|
const url = `${this.miningServiceUrl}/api/v2/mining/admin/batch-mining/records/${accountSequence}?page=${page}&pageSize=${pageSize}`;
|
||||||
this.logger.log(`Fetching batch mining records from ${url}`);
|
this.logger.log(`Fetching batch mining records from ${url}`);
|
||||||
|
|
||||||
const response = await fetch(url);
|
const response = await fetch(url);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue