feat(route): add Shanghai weather alert (#22087)
* feat: add Shanghai weather alert * chore: update `updated` field by alert deactivate time * chore: fix import path * chore: remove cache time * fix: disable cache age extend --------- Co-authored-by: Tinko <24890691+TinkoLiu@users.noreply.github.com>
This commit is contained in:
Tinko
GitHub
parent
7386c170c0
commit
5542e787e3
|
|
@ -0,0 +1,11 @@
|
|||
import type { Namespace } from '@/types';
|
||||
|
||||
export const namespace: Namespace = {
|
||||
name: 'SoWeather',
|
||||
url: 'wx.soweather.com',
|
||||
categories: ['forecast'],
|
||||
lang: 'zh-CN',
|
||||
zh: {
|
||||
name: '上海天气预警',
|
||||
},
|
||||
};
|
||||
|
|
@ -0,0 +1,133 @@
|
|||
import sanitizeHtml from 'sanitize-html';
|
||||
|
||||
import { config } from '@/config';
|
||||
import type { Data, DataItem, Route } from '@/types';
|
||||
import cache from '@/utils/cache';
|
||||
import ofetch from '@/utils/ofetch';
|
||||
import { parseDate } from '@/utils/parse-date';
|
||||
import timezone from '@/utils/timezone';
|
||||
|
||||
const rootUrl = 'https://wx.soweather.com';
|
||||
const pageUrl = `${rootUrl}/wxapp/warn.jsp`;
|
||||
const dataUrl = `${rootUrl}/wxapp/jsondata/warn.js`;
|
||||
const specialIssuers = new Set(['上海市民防办', '中国铁路上海局集团有限公司上海站', '上海申通地铁集团有限公司', '市交通委指挥中心']);
|
||||
const warningGroups = [
|
||||
['市级预警', 'warns'],
|
||||
['市级历史预警', 'historywarns'],
|
||||
['分区预警', 'fqwarns'],
|
||||
['分区历史预警', 'fqhistorywarns'],
|
||||
] as const;
|
||||
|
||||
interface RawWarning {
|
||||
isActive: boolean;
|
||||
yjid: string;
|
||||
htmlword: string;
|
||||
yjfbdw: string;
|
||||
yjfbtype: string;
|
||||
name: string;
|
||||
id: number;
|
||||
district: string;
|
||||
fbsj: string;
|
||||
jcsj?: string | null;
|
||||
lqImage1?: string | null;
|
||||
icon?: string | null;
|
||||
gtyjstatus?: string | null;
|
||||
}
|
||||
|
||||
async function handler(): Promise<Data | null> {
|
||||
const response = await cache.tryGet(`soweather:warn:${dataUrl}`, () => ofetch<string>(dataUrl, { parseResponse: (txt) => txt }), config.cache.routeExpire, false);
|
||||
const warnings = warningGroups.flatMap(([groupName, variableName]) =>
|
||||
parseWarnings(response, variableName)
|
||||
.filter((warning) => isRealWarning(warning))
|
||||
.map((warning) => buildItem(warning, groupName))
|
||||
);
|
||||
|
||||
return {
|
||||
title: '上海天气预警',
|
||||
description: '上海天气预警',
|
||||
link: pageUrl,
|
||||
item: warnings,
|
||||
language: 'zh-CN',
|
||||
};
|
||||
}
|
||||
|
||||
export const route: Route = {
|
||||
path: '/warn',
|
||||
name: 'Shanghai Weather Alert',
|
||||
url: 'wx.soweather.com/wxapp/warn.jsp',
|
||||
maintainers: ['TinkoLiu'],
|
||||
example: '/soweather/warn',
|
||||
categories: ['forecast'],
|
||||
handler,
|
||||
zh: {
|
||||
name: '上海天气预警',
|
||||
example: '/soweather/warn',
|
||||
path: '/warn',
|
||||
maintainers: ['TinkoLiu'],
|
||||
handler,
|
||||
},
|
||||
};
|
||||
|
||||
function parseWarnings(script: string, variableName: string): RawWarning[] {
|
||||
const pattern = new RegExp(`var\\s+${variableName}\\s*=\\s*(\\[[\\s\\S]*?\\])\\s*(?=var\\s+\\w+\\s*=|$)`);
|
||||
const json = pattern.exec(script)?.[1];
|
||||
|
||||
return json ? (JSON.parse(json) as RawWarning[]) : [];
|
||||
}
|
||||
|
||||
function isRealWarning(warning: RawWarning): boolean {
|
||||
return !['Exercise', 'Test'].includes(warning.gtyjstatus ?? '');
|
||||
}
|
||||
|
||||
function buildItem(warning: RawWarning, groupName: string): DataItem {
|
||||
const title = buildTitle(warning);
|
||||
const content = buildContent(warning);
|
||||
const guid = `${warning.district}-${warning.id}-${warning.yjid}`;
|
||||
const image = warning.icon ? `${rootUrl}/wxapp/images/icon/${warning.icon.replaceAll('-', '_')}` : undefined;
|
||||
const updated = !warning.isActive && warning.jcsj ? timezone(parseDate(warning.jcsj, 'YYYY-MM-DD HH:mm'), 8) : undefined;
|
||||
|
||||
return {
|
||||
title,
|
||||
link: `${pageUrl}#${encodeURIComponent(guid)}`,
|
||||
guid,
|
||||
description: content,
|
||||
content: {
|
||||
html: content,
|
||||
text: content
|
||||
.replaceAll(/<br\s*\/?>/gi, '\n')
|
||||
.replaceAll(/<[^>]+>/g, '')
|
||||
.trim(),
|
||||
},
|
||||
pubDate: timezone(parseDate(warning.fbsj, 'YYYY-MM-DD HH:mm'), 8),
|
||||
updated,
|
||||
author: warning.yjfbdw,
|
||||
category: [groupName, warning.district, warning.name, warning.isActive ? '生效中' : '已解除'],
|
||||
image,
|
||||
};
|
||||
}
|
||||
|
||||
function buildTitle(warning: RawWarning): string {
|
||||
const suffix = specialIssuers.has(warning.yjfbdw) ? '' : '预警';
|
||||
|
||||
return `${warning.isActive ? '' : '【已解除】'}${warning.yjfbdw}${warning.yjfbtype}${warning.name}${suffix}`;
|
||||
}
|
||||
|
||||
function buildContent(warning: RawWarning): string {
|
||||
const sections = [
|
||||
!warning.isActive && warning.jcsj ? `解除时间：${warning.jcsj}<br>` : '',
|
||||
sanitizeHtml(getWarningInfo(warning.htmlword), {
|
||||
allowedTags: [...sanitizeHtml.defaults.allowedTags, 'br'],
|
||||
allowedAttributes: {},
|
||||
}),
|
||||
warning.lqImage1 ? `<p><img src="${new URL(warning.lqImage1.replaceAll('\\', '/'), `${rootUrl}/wxapp/`).href}"></p>` : '',
|
||||
];
|
||||
|
||||
return sections.join('');
|
||||
}
|
||||
|
||||
function getWarningInfo(htmlword: string): string {
|
||||
return htmlword
|
||||
.split('防御指引')[0]
|
||||
.replaceAll(/(?:(?:\s| )*<br\s*\/?>)+\s*$/gi, '')
|
||||
.trim();
|
||||
}
|
||||
Loading…
Reference in New Issue