Fullstack/iboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

对比图完成

Browse Source
This commit is contained in:
cheney 2026-04-26 11:41:39 +08:00
parent 342042577d
commit becf0364ad
6 changed files with 216 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
pages/api/sh300-index.js
View File

@ -22,30 +22,27 @@ async function handler(req, res) {
const params = []; const params = [];
const conditions = []; const conditions = [];
if (startDate) { if (startDate && endDate) {
conditions.push('date >= ?'); conditions.push('date BETWEEN ? AND ?');
params.push(startDate); params.push(startDate, endDate);
}
if (endDate) {
conditions.push('date <= ?');
params.push(endDate);
} }
if (conditions.length > 0) { if (conditions.length > 0) {
query += ' WHERE ' + conditions.join(' AND '); query += ' WHERE ' + conditions.join(' AND ');
} }
query += ' ORDER BY date ASC'; query += ' ORDER BY date DESC';
if (limit) {
query += ' LIMIT ?';
params.push(parseInt(limit));
}
const result = await pool.query(query, params); const result = await pool.query(query, params);
const data = result.map(row => { // 限制返回数量，默认为30
const limitValue = limit ? parseInt(limit) : 30;
const limitedResult = result.slice(0, limitValue);
// 反转顺序，使日期从早到晚
const sortedResult = limitedResult.reverse();
const data = sortedResult.map(row => {
let dateStr; let dateStr;
if (row.date instanceof Date) { if (row.date instanceof Date) {
dateStr = row.date.toISOString().split('T')[0]; dateStr = row.date.toISOString().split('T')[0];

24
pages/strategy.js
View File

@ -50,12 +50,6 @@ export default function Strategy() {
} }
] ]
useEffect(() => {
if (selectedStrategy === 'sh300-exchange-rate') {
fetchSh300ExchangeData()
}
}, [selectedStrategy, timeRange, startDate, endDate])
const handleTimeRangeChange = (range, start, end) => { const handleTimeRangeChange = (range, start, end) => {
setTimeRange(range) setTimeRange(range)
setStartDate(start) setStartDate(start)
@ -63,6 +57,7 @@ export default function Strategy() {
} }
const fetchSh300ExchangeData = async () => { const fetchSh300ExchangeData = async () => {
console.log('fetchSh300ExchangeData called')
setSh300Loading(true) setSh300Loading(true)
try { try {
let sh300Url = '/api/sh300-index' let sh300Url = '/api/sh300-index'
@ -85,13 +80,19 @@ export default function Strategy() {
exchangeUrl += '?' + params.join('&') exchangeUrl += '?' + params.join('&')
} }
console.log('Fetching from:', sh300Url, exchangeUrl)
const [sh300Res, exchangeRes] = await Promise.all([ const [sh300Res, exchangeRes] = await Promise.all([
fetch(sh300Url), fetch(sh300Url),
fetch(exchangeUrl) fetch(exchangeUrl)
]) ])
console.log('Response status:', sh300Res.status, exchangeRes.status)
const sh300Json = await sh300Res.json() const sh300Json = await sh300Res.json()
const exchangeJson = await exchangeRes.json() const exchangeJson = await exchangeRes.json()
console.log('Response data:', sh300Json, exchangeJson)
if (sh300Json.success && exchangeJson.success) { if (sh300Json.success && exchangeJson.success) {
const sh300Map = new Map(sh300Json.data.map(item => [item.date, item.close])) const sh300Map = new Map(sh300Json.data.map(item => [item.date, item.close]))
const exchangeMap = new Map(exchangeJson.data.map(item => [item.date, item.rate])) const exchangeMap = new Map(exchangeJson.data.map(item => [item.date, item.rate]))
@ -104,6 +105,7 @@ export default function Strategy() {
exchangeRate: exchangeMap.get(date) || null exchangeRate: exchangeMap.get(date) || null
})).filter(item => item.sh300 !== null && item.exchangeRate !== null) })).filter(item => item.sh300 !== null && item.exchangeRate !== null)
console.log('Merged data:', mergedData)
setSh300ExchangeData(mergedData) setSh300ExchangeData(mergedData)
} }
} catch (error) { } catch (error) {
@ -113,6 +115,12 @@ export default function Strategy() {
} }
} }
useEffect(() => {
if (selectedStrategy === 'sh300-exchange-rate') {
fetchSh300ExchangeData()
}
}, [selectedStrategy, timeRange, startDate, endDate])
return ( return (
<div className="container"> <div className="container">
<Head> <Head>
@ -371,8 +379,8 @@ export default function Strategy() {
<LineChart data={sh300ExchangeData} margin={{ top: 20, right: 60, left: 20, bottom: 5 }}> <LineChart data={sh300ExchangeData} margin={{ top: 20, right: 60, left: 20, bottom: 5 }}>
<CartesianGrid strokeDasharray="3 3" /> <CartesianGrid strokeDasharray="3 3" />
<XAxis dataKey="date" /> <XAxis dataKey="date" />
<YAxis yAxisId="left" domain={['dataMin - 100', 'dataMax + 100']} /> <YAxis yAxisId="left" domain={['auto', 'auto']} allowDataOverflow={true} />
<YAxis yAxisId="right" orientation="right" domain={['dataMin - 0.05', 'dataMax + 0.05']} tickFormatter={(value) => value.toFixed(4)} /> <YAxis yAxisId="right" orientation="right" domain={['auto', 'auto']} allowDataOverflow={true} tickFormatter={(value) => value.toFixed(4)} />
<Tooltip /> <Tooltip />
<Legend /> <Legend />
<Line yAxisId="left" type="monotone" dataKey="sh300" name="沪深300收盘价" stroke="#8884d8" strokeWidth={2} activeDot={{ r: 8 }} /> <Line yAxisId="left" type="monotone" dataKey="sh300" name="沪深300收盘价" stroke="#8884d8" strokeWidth={2} activeDot={{ r: 8 }} />

79
scripts/fetch-one-year.js Normal file
View File

@ -0,0 +1,79 @@
import { spawn } from 'child_process';
async function runScraper(scraperPath, startDate, endDate) {
return new Promise((resolve, reject) => {
const args = [scraperPath];
if (startDate) {
args.push('--start', startDate);
}
if (endDate) {
args.push('--end', endDate);
}
const proc = spawn('bun', args, { stdio: 'inherit' });
proc.on('close', (code) => {
if (code === 0) {
resolve();
} else {
reject(new Error(`Process exited with code ${code}`));
}
});
proc.on('error', (err) => {
reject(err);
});
});
}
async function fetchOneYearData() {
console.log('='.repeat(70));
console.log('📊 获取近一年数据');
console.log('='.repeat(70));
const currentDate = new Date();
const startDate = new Date(currentDate);
startDate.setFullYear(startDate.getFullYear() - 1);
const startDateStr = startDate.toISOString().split('T')[0];
const endDateStr = currentDate.toISOString().split('T')[0];
console.log(`时间范围: ${startDateStr} 至 ${endDateStr}`);
console.log('');
console.log('='.repeat(70));
console.log('💱 开始获取 USD-CNY 汇率数据...');
console.log('='.repeat(70));
let usdSuccess = false;
try {
await runScraper('./scraper/usd-cny-rate.scraper.js', startDateStr, endDateStr);
console.log(`✅ USD-CNY 汇率数据更新完成`);
usdSuccess = true;
} catch (error) {
console.error(`❌ USD-CNY 汇率数据更新失败:`, error.message);
}
console.log('');
console.log('='.repeat(70));
console.log('📈 开始获取沪深300指数数据...');
console.log('='.repeat(70));
let sh300Success = false;
try {
await runScraper('./scraper/sh300.scraper.js', startDateStr, endDateStr);
console.log(`✅ 沪深300指数数据更新完成`);
sh300Success = true;
} catch (error) {
console.error(`❌ 沪深300指数数据更新失败:`, error.message);
}
console.log('');
console.log('='.repeat(70));
console.log('📊 数据获取完成');
console.log('='.repeat(70));
console.log(`USD-CNY 汇率: ${usdSuccess ? '✅ 成功' : '❌ 失败'}`);
console.log(`沪深300指数: ${sh300Success ? '✅ 成功' : '❌ 失败'}`);
console.log('='.repeat(70));
}
fetchOneYearData();

32
scripts/scheduler/index.js
View File

@ -1,12 +1,13 @@
import cron from 'node-cron'; import cron from 'node-cron';
import { trigger as triggerUSDCNYRate } from '../scraper/usd-cny-rate.scraper.js'; import { trigger as triggerUSDCNYRate } from '../scraper/usd-cny-rate.scraper.js';
import { trigger as triggerSH300Data } from '../scraper/sh300.scraper.js';
console.log('='.repeat(70)); console.log('='.repeat(70));
console.log('🚀 启动定时任务调度器'); console.log('🚀 启动定时任务调度器');
console.log('='.repeat(70)); console.log('='.repeat(70));
// 注册定时任务 // 注册定时任务 - USD-CNY 汇率数据
const job = cron.schedule('0 0 * * *', async () => { const jobUSDCNY = cron.schedule('0 0 * * *', async () => {
console.log('\n' + '='.repeat(70)); console.log('\n' + '='.repeat(70));
console.log('⏰ 执行定时任务: USD-CNY 汇率数据更新'); console.log('⏰ 执行定时任务: USD-CNY 汇率数据更新');
console.log('📅 执行时间:', new Date().toISOString()); console.log('📅 执行时间:', new Date().toISOString());
@ -25,10 +26,34 @@ const job = cron.schedule('0 0 * * *', async () => {
timezone: 'Asia/Shanghai' timezone: 'Asia/Shanghai'
}); });
// 注册定时任务 - 沪深300指数数据
const jobSH300 = cron.schedule('0 0 * * *', async () => {
console.log('\n' + '='.repeat(70));
console.log('⏰ 执行定时任务: 沪深300指数数据更新');
console.log('📅 执行时间:', new Date().toISOString());
console.log('='.repeat(70));
try {
await triggerSH300Data();
console.log('\n✅ 任务执行成功!');
} catch (error) {
console.error('\n❌ 任务执行失败:', error.message);
} finally {
console.log('='.repeat(70));
}
}, {
scheduled: true,
timezone: 'Asia/Shanghai'
});
console.log('✅ 定时任务已启动: USD-CNY 汇率数据更新'); console.log('✅ 定时任务已启动: USD-CNY 汇率数据更新');
console.log('📅 执行表达式: 0 0 * * * (每天 0 点)'); console.log('📅 执行表达式: 0 0 * * * (每天 0 点)');
console.log('📅 下次执行时间: 明天 00:00'); console.log('📅 下次执行时间: 明天 00:00');
console.log(''); console.log('');
console.log('✅ 定时任务已启动: 沪深300指数数据更新');
console.log('📅 执行表达式: 0 0 * * * (每天 0 点)');
console.log('📅 下次执行时间: 明天 00:00');
console.log('');
console.log('按 Ctrl+C 停止...'); console.log('按 Ctrl+C 停止...');
console.log('='.repeat(70)); console.log('='.repeat(70));
@ -38,7 +63,8 @@ process.on('SIGINT', () => {
console.log('🛑 停止定时任务调度器'); console.log('🛑 停止定时任务调度器');
console.log('='.repeat(70)); console.log('='.repeat(70));
job.stop(); jobUSDCNY.stop();
jobSH300.stop();
console.log('✅ 定时任务已停止'); console.log('✅ 定时任务已停止');
console.log('\n' + '='.repeat(70)); console.log('\n' + '='.repeat(70));

44
scripts/scraper/sh300.scraper.js
View File

@ -265,13 +265,50 @@ export async function trigger(startDate = null, endDate = null) {
return await checkAndFillSH300Data(startDate, endDate); return await checkAndFillSH300Data(startDate, endDate);
} }
// 直接运行测试 function parseCommandLineArgs() {
const args = process.argv.slice(2);
let startDate = null;
let endDate = null;
for (let i = 0; i < args.length; i++) {
if (args[i] === '--start' && i + 1 < args.length) {
startDate = args[i + 1];
i++;
} else if (args[i] === '--end' && i + 1 < args.length) {
endDate = args[i + 1];
i++;
} else if (args[i] === '--help') {
console.log('使用方法:');
console.log(' bun sh300.scraper.js [选项]');
console.log('');
console.log('选项:');
console.log(' --start YYYY-MM-DD 指定开始日期');
console.log(' --end YYYY-MM-DD 指定结束日期');
console.log(' --help 显示帮助信息');
console.log('');
console.log('示例:');
console.log(' bun sh300.scraper.js');
console.log(' bun sh300.scraper.js --start 2024-01-01 --end 2024-01-31');
process.exit(0);
}
}
return { startDate, endDate };
}
async function runTest() { async function runTest() {
console.log('='.repeat(60)); console.log('='.repeat(60));
console.log('测试 sh300.scraper.js'); console.log('测试 sh300.scraper.js');
console.log('='.repeat(60)); console.log('='.repeat(60));
// 测试配置读取 const { startDate, endDate } = parseCommandLineArgs();
if (startDate) {
console.log(`\n使用命令行参数:`);
console.log(` 开始日期: ${startDate}`);
console.log(` 结束日期: ${endDate || '默认'}`);
}
console.log('\n测试数据库配置读取...'); console.log('\n测试数据库配置读取...');
const config = loadDatabaseConfig(); const config = loadDatabaseConfig();
console.log('配置读取结果:'); console.log('配置读取结果:');
@ -282,7 +319,7 @@ async function runTest() {
console.log('配置读取测试完成!'); console.log('配置读取测试完成!');
try { try {
const result = await trigger(); const result = await trigger(startDate, endDate);
console.log('\n' + '='.repeat(60)); console.log('\n' + '='.repeat(60));
console.log('测试结果:'); console.log('测试结果:');
console.log(` 开始日期: ${result.startDate}`); console.log(` 开始日期: ${result.startDate}`);
@ -298,5 +335,4 @@ async function runTest() {
} }
} }
// 运行测试
runTest(); runTest();

44
scripts/scraper/usd-cny-rate.scraper.js
View File

@ -262,13 +262,50 @@ export async function trigger(startDate = null, endDate = null) {
return await checkAndFillUSDCNYRate(startDate, endDate); return await checkAndFillUSDCNYRate(startDate, endDate);
} }
// 直接运行测试 function parseCommandLineArgs() {
const args = process.argv.slice(2);
let startDate = null;
let endDate = null;
for (let i = 0; i < args.length; i++) {
if (args[i] === '--start' && i + 1 < args.length) {
startDate = args[i + 1];
i++;
} else if (args[i] === '--end' && i + 1 < args.length) {
endDate = args[i + 1];
i++;
} else if (args[i] === '--help') {
console.log('使用方法:');
console.log(' bun usd-cny-rate.scraper.js [选项]');
console.log('');
console.log('选项:');
console.log(' --start YYYY-MM-DD 指定开始日期');
console.log(' --end YYYY-MM-DD 指定结束日期');
console.log(' --help 显示帮助信息');
console.log('');
console.log('示例:');
console.log(' bun usd-cny-rate.scraper.js');
console.log(' bun usd-cny-rate.scraper.js --start 2024-01-01 --end 2024-01-31');
process.exit(0);
}
}
return { startDate, endDate };
}
async function runTest() { async function runTest() {
console.log('='.repeat(60)); console.log('='.repeat(60));
console.log('测试 usd-cny-rate.scraper.js'); console.log('测试 usd-cny-rate.scraper.js');
console.log('='.repeat(60)); console.log('='.repeat(60));
// 测试配置读取 const { startDate, endDate } = parseCommandLineArgs();
if (startDate) {
console.log(`\n使用命令行参数:`);
console.log(` 开始日期: ${startDate}`);
console.log(` 结束日期: ${endDate || '默认'}`);
}
console.log('\n测试数据库配置读取...'); console.log('\n测试数据库配置读取...');
const config = loadDatabaseConfig(); const config = loadDatabaseConfig();
console.log('配置读取结果:'); console.log('配置读取结果:');
@ -279,7 +316,7 @@ async function runTest() {
console.log('配置读取测试完成!'); console.log('配置读取测试完成!');
try { try {
const result = await trigger(); const result = await trigger(startDate, endDate);
console.log('\n' + '='.repeat(60)); console.log('\n' + '='.repeat(60));
console.log('测试结果:'); console.log('测试结果:');
console.log(` 开始日期: ${result.startDate}`); console.log(` 开始日期: ${result.startDate}`);
@ -295,5 +332,4 @@ async function runTest() {
} }
} }
// 运行测试
runTest(); runTest();