服务状态: 运行中
启动时间: ${new Date(Date.now() - process.uptime() * 1000).toLocaleString()}
`;
res.send(html);
});
// 1. 获取并解析天气数据
app.get('/weathercn-data/', async (req, res) => {
try {
console.log(`[${new Date().toISOString()}] 处理天气数据请求`);
const cacheKey = req.url;
const cachedData = cache.get(cacheKey);
if (cachedData) {
console.log(`[${new Date().toISOString()}] 使用缓存的天气数据`);
res.status(cachedData.status);
for (const [key, value] of Object.entries(cachedData.headers)) {
res.setHeader(key, value);
}
return res.send(cachedData.body);
}
const origin = req.headers.origin || `${req.protocol}://${req.get('host')}`;
const data = await handleWeatherCnData(cacheKey, origin);
if (data) {
return res.json(data);
} else {
throw new Error("处理天气数据失败");
}
} catch (error) {
console.error(`[${new Date().toISOString()}] 天气数据请求错误:`, error);
return res.status(500).json({
error: "处理天气数据时发生错误",
message: error.message
});
}
});
// 2. 代理请求：/mpf/*
app.all('/mpf/*', async (req, res) => {
try {
console.log(`[${new Date().toISOString()}] 处理MPF请求: ${req.path}`);
const pathname = req.path;
const cacheKey = req.url;
const cachedData = cache.get(cacheKey);
if (cachedData) {
console.log(`[${new Date().toISOString()}] 使用缓存的MPF数据: ${cacheKey}`);
res.status(cachedData.status);
for (const [key, value] of Object.entries(cachedData.headers)) {
res.setHeader(key, value);
}
return res.send(cachedData.body);
}
const target = `https://mpf.weather.com.cn${pathname.replace('/mpf', '')}${req.url.includes('?') ? req.url.substring(req.url.indexOf('?')) : ''}`;
const response = await fetchWithTimeout(target, {
method: req.method,
headers: {
'User-Agent': iPhoneUserAgent,
'Referer': 'https://m.weather.com.cn/',
'Host': 'mpf.weather.com.cn'
},
body: req.method !== "GET" && req.method !== "HEAD" ? req.body : undefined
}, 15000, 2);
const status = response.status;
const headers = {};
response.headers.forEach((value, key) => {
if (!['content-encoding', 'content-length'].includes(key)) {
headers[key] = value;
}
});
const body = await response.arrayBuffer();
const buffer = Buffer.from(body);
if (req.method === "GET" && status === 200) {
cache.set(cacheKey, { body: buffer, status, headers });
}
res.status(status);
for (const [key, value] of Object.entries(headers)) {
res.setHeader(key, value);
}
return res.send(buffer);
} catch (error) {
console.error(`[${new Date().toISOString()}] MPF请求错误:`, error);
return res.status(500).json({
error: "处理MPF数据时发生错误",
message: error.message
});
}
});
// 3. 特别处理 /duanlin/* 返回加工后的降水图数据
app.get("/duanlin/*", async (req, res) => {
try {
console.log(`[${new Date().toISOString()}] 处理短临降水请求: ${req.path}`);
const cacheKey = req.url;
const cachedData = cache.get(cacheKey);
if (cachedData) {
console.log(`[${new Date().toISOString()}] 使用缓存的短临降水数据: ${cacheKey}`);
res.status(cachedData.status);
for (const [key, value] of Object.entries(cachedData.headers)) {
res.setHeader(key, value);
}
return res.send(cachedData.body);
}
const origin = req.headers.origin || `${req.protocol}://${req.get('host')}`;
const data = await handleDuanlinData(req.path, cacheKey, origin);
if (data && data.rain_dl) {
if (data.rain_dl.error) {
console.warn(`[${new Date().toISOString()}] 短临降水数据处理警告: ${data.rain_dl.error}`);
}
return res.json(data);
} else {
throw new Error("处理短临降水数据失败");
}
} catch (error) {
console.error(`[${new Date().toISOString()}] 短临降水数据处理错误:`, error);
return res.status(500).json({
error: "处理短临降水数据时发生错误",
message: error.message
});
}
});
// 4. 小米代理
app.get('/wtr-v3/*', async (req, res) => {
try {
console.log(`[${new Date().toISOString()}] 处理小米天气请求: ${req.path}`);
const pathname = req.path;
const cacheKey = req.url;
const cachedData = cache.get(cacheKey);
if (cachedData) {
console.log(`[${new Date().toISOString()}] 使用缓存的小米天气数据: ${cacheKey}`);
res.status(cachedData.status);
for (const [key, value] of Object.entries(cachedData.headers)) {
res.setHeader(key, value);
}
return res.send(cachedData.body);
}
const target = `https://weatherapi.market.xiaomi.com${pathname}${req.url.includes('?') ? req.url.substring(req.url.indexOf('?')) : ''}`;
const response = await fetchWithTimeout(target, {
headers: {
'User-Agent': iPhoneUserAgent
}
}, 15000, 2);
const status = response.status;
const headers = {};
response.headers.forEach((value, key) => {
if (!['content-encoding', 'content-length'].includes(key)) {
headers[key] = value;
}
});
const body = await response.arrayBuffer();
const buffer = Buffer.from(body);
if (status === 200) {
cache.set(cacheKey, { body: buffer, status, headers });
}
res.status(status);
for (const [key, value] of Object.entries(headers)) {
res.setHeader(key, value);
}
return res.send(buffer);
} catch (error) {
console.error(`[${new Date().toISOString()}] 小米天气请求错误:`, error);
return res.status(500).json({
error: "处理小米天气数据时发生错误",
message: error.message
});
}
});
// 5. 图片代理 /img/*
app.get('/img/*', async (req, res) => {
try {
console.log(`[${new Date().toISOString()}] 处理图片代理请求: ${req.path}`);
const pathname = req.path;
const cacheKey = req.url;
const cachedData = cache.get(cacheKey);
if (cachedData) {
console.log(`[${new Date().toISOString()}] 使用缓存的图片: ${cacheKey}`);
res.status(cachedData.status);
for (const [key, value] of Object.entries(cachedData.headers)) {
res.setHeader(key, value);
}
return res.send(cachedData.buffer||cachedData.body);
}
const target = pathname.replace('/img/', '');
const response = await handleImageProxy(pathname, cacheKey);
const status = response.status;
const headers = {contentType:response.contentType};
const buffer =response.buffer;
res.status(status);
for (const [key, value] of Object.entries(headers)) {
res.setHeader(key, value);
}
return res.send(buffer);
} catch (error) {
console.error(`[${new Date().toISOString()}] 图片代理请求错误:`, error);
return res.status(500).json({
error: "处理图片代理请求时发生错误",
message: error.message
});
}
});
// 6. d3代理
app.get('/d3/*', async (req, res) => {
try {
console.log(`[${new Date().toISOString()}] 处理D3天气请求: ${req.path}`);
const pathname = req.path;
const cacheKey = req.url;
const cachedData = cache.get(cacheKey);
if (cachedData) {
console.log(`[${new Date().toISOString()}] 使用缓存的D3天气数据: ${cacheKey}`);
res.status(cachedData.status);
for (const [key, value] of Object.entries(cachedData.headers)) {
res.setHeader(key, value);
}
return res.send(cachedData.body);
}
//https://d3.weather.com.cn 证书过期了先用http
const target = `http://d3.weather.com.cn${pathname.replace('/d3', '')}${req.url.includes('?') ? req.url.substring(req.url.indexOf('?')) : ''}`;
const response = await fetchWithTimeout(target, {
headers: {
'User-Agent': iPhoneUserAgent,
'Referer': 'http://m.weather.com.cn/' //'https://m.weather.com.cn/'
}
}, 15000, 2);
const status = response.status;
const headers = {};
response.headers.forEach((value, key) => {
if (!['content-encoding', 'content-length'].includes(key)) {
headers[key] = value;
}
});
const body = await response.arrayBuffer();
const buffer = Buffer.from(body);
if (status === 200) {
cache.set(cacheKey, { body: buffer, status, headers });
}
res.status(status);
for (const [key, value] of Object.entries(headers)) {
res.setHeader(key, value);
}
return res.send(buffer);
} catch (error) {
console.error(`[${new Date().toISOString()}] D3天气请求错误:`, error);
return res.status(500).json({
error: "处理D3天气数据时发生错误",
message: error.message
});
}
});
// 7. d4代理
app.get('/d4/*', async (req, res) => {
try {
console.log(`[${new Date().toISOString()}] 处理D4天气请求: ${req.path}`);
const pathname = req.path;
const cacheKey = req.url;
const cachedData = cache.get(cacheKey);
if (cachedData) {
console.log(`[${new Date().toISOString()}] 使用缓存的D4天气数据: ${cacheKey}`);
res.status(cachedData.status);
for (const [key, value] of Object.entries(cachedData.headers)) {
res.setHeader(key, value);
}
return res.send(cachedData.body);
}
const target = `https://d4.weather.com.cn${pathname.replace('/d4', '')}${req.url.includes('?') ? req.url.substring(req.url.indexOf('?')) : ''}`;
const response = await fetchWithTimeout(target, {
headers: {
'User-Agent': iPhoneUserAgent,
'Referer': 'https://m.weather.com.cn/'
}
}, 15000, 2);
const status = response.status;
const headers = {};
response.headers.forEach((value, key) => {
if (!['content-encoding', 'content-length'].includes(key)) {
headers[key] = value;
}
});
const body = await response.arrayBuffer();
const buffer = Buffer.from(body);
if (status === 200) {
cache.set(cacheKey, { body: buffer, status, headers });
}
res.status(status);
for (const [key, value] of Object.entries(headers)) {
res.setHeader(key, value);
}
return res.send(buffer);
} catch (error) {
console.error(`[${new Date().toISOString()}] D4天气请求错误:`, error);
return res.status(500).json({
error: "处理D4天气数据时发生错误",
message: error.message
});
}
});
// 添加全局错误处理中间件
app.use((err, req, res, next) => {
console.error(`[${new Date().toISOString()}] 全局错误: ${err.message}`);
console.error(err.stack);
res.status(500).json({
error: '服务器内部错误',
message: err.message
});
});
// 404处理
app.use((req, res) => {
console.log(`[${new Date().toISOString()}] 404 未找到: ${req.originalUrl}`);
res.status(404).json({ error: 'Not Found' });
});
// 启动服务器
app.listen(PORT, () => {
console.log(`[${new Date().toISOString()}] 服务器运行在端口 ${PORT}`);
});
module.exports = app; // 为了在 Hugging Face 部署可能需要导出 app