index.ts

import * as core from "@actions/core";
import got, { Got } from "got";
import { CookieJar } from "tough-cookie";
import { LoginForm, DailyReportForm, DailyReportResponse } from "./form.js";
import { sleep, randomBetween } from "./utils.js";
import { pushNotification, isPushServicesConfigured } from "./push.js";

const LOGIN = "https://auth.bupt.edu.cn/authserver/login";
const GET_REPORT = "https://app.bupt.edu.cn/ncov/wap/default/index";
const POST_REPORT = "https://app.bupt.edu.cn/ncov/wap/default/save";
const RETRY = 100;
const TIMEOUT = 2000;

async function login(
    loginForm: LoginForm
): Promise<Got> {
    const cookieJar = new CookieJar();
    const client = got.extend({
        cookieJar,
        headers: {
            "user-agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/101.0.4951.64 Safari/537.36"
        },
        retry: {
            limit: RETRY,
            methods: ["GET", "POST"],
        },
        timeout: {
            request: TIMEOUT,
        },
        throwHttpErrors: false,
    });

    // get `execution` field, will be used in post form data
    let response = await client.get(LOGIN);
    const execution = response.body.match(/input name="execution" value=.*><input name="_eventId"/)?.[0]?.replace('input name="execution" value="', '')?.replace('"/><input name="_eventId"', '');

    if (!execution) {
        throw new Error(`parse execution field failed`);
    }

    // embed additional fields
    loginForm = {
        submit: "LOGIN",
        type: "username_password",
        _eventId: "submit",
        execution,
        ...loginForm,
    }

    // login now,
    // we need the cookie, and that's it! do not follow redirects
    response = await client.post(LOGIN, { form: loginForm, followRedirect: false });

    if (response.statusCode != 302) {
        throw new Error(`login 请求返回了 ${response.statusCode}，应是 302`);
    }

    return client;
}

async function getDailyReportFormData(
    client: Got
): Promise<DailyReportForm> {
    const response = await client.get(GET_REPORT);
    if (response.statusCode != 200) {
        throw new Error(`getFormData 请求返回了 ${response.statusCode}`);
    }
    if (response.body.indexOf("登录") != -1) {
        throw new Error("登录失败；请检查用户名与密码是否正确");
    }
    const newForm: DailyReportForm = JSON.parse(
        /var def = (\{.+\});/.exec(response.body)?.[1] ?? ""
    );
    const oldForm: DailyReportForm = JSON.parse(
        /oldInfo: (\{.+\}),/.exec(response.body)?.[1] ?? ""
    );

    if (oldForm.geo_api_info === undefined) {
        throw new Error("昨天的信息不完整；请手动填报一天后继续使用本脚本");
    }

    const geo = JSON.parse(oldForm.geo_api_info);

    // 前一天的地址
    const province = geo.addressComponent.province;
    let city = geo.addressComponent.city;
    if (geo.addressComponent.city.trim() === "" && ["北京市", "上海市", "重庆市", "天津市"].indexOf(province) > -1) {
        city = geo.addressComponent.province;
    } else {
        city = geo.addressComponent.city;
    }
    const area = geo.addressComponent.province + " "
        + geo.addressComponent.city + " "
        + geo.addressComponent.district;
    const address = geo.formattedAddress;

    Object.assign(oldForm, newForm);

    // 覆盖昨天的地址
    oldForm.province = province;
    oldForm.city = city;
    oldForm.area = area;
    oldForm.address = address;

    // 强制覆盖一些字段
    // 是否移动了位置？否
    oldForm.ismoved = "0";
    // 不在同城原因？空
    oldForm.bztcyy = "";
    // 是否省份不合？否
    oldForm.sfsfbh = "0";

    return oldForm;
}

async function postDailyReportFormData(
    client: Got,
    formData: DailyReportForm
): Promise<DailyReportResponse> {
    const response = await client.post(POST_REPORT, { form: formData });
    if (response.statusCode != 200) {
        throw new Error(`postFormData 请求返回了 ${response.statusCode}`);
    }
    return JSON.parse(response.body);
}

(async (): Promise<void> => {
    const loginForm: LoginForm = {
        username: process.env["BUPT_USERNAME"],
        password: process.env["BUPT_PASSWORD"]
    }

    if (!(!!loginForm.username && !!loginForm.password)) {
        throw new Error("无法登录；请在仓库 Settings 的 Secrets 栏填写 BUPT_USERNAME 与 BUPT_PASSWORD");
    }

    console.log("用户登录中");

    const client = await login(loginForm);

    await sleep(randomBetween(2000, 4000));

    console.log("正在获取前一天的疫情填报信息");

    const formData = await getDailyReportFormData(client);

    await sleep(randomBetween(2000, 4000));

    console.log("正在提交今日疫情填报信息");

    const reportReponse = await postDailyReportFormData(client, formData);

    console.log(`今日填报结果：${reportReponse.m}`);

    if (isPushServicesConfigured() && reportReponse.m !== "今天已经填报了") {
        await pushNotification(
            `填报成功`,
            `
    今日填报结果：${reportReponse.m}
    上次填报时间：${formData.date}
    上次填报地点：${formData.area}
`
        );
    }
})().catch((err) => {
    if (isPushServicesConfigured() && err instanceof Error) {
        pushNotification(`填报失败`, `${err.message}`);
        console.log(err);
    } else {
        throw err;
    }
}).catch((err) => {
    if (err instanceof Error) {
        console.log(err.stack);
        core.setFailed(err.message);
    } else {
        core.setFailed(err);
    }
});