SpringBoot实现广州健康通疫苗预约提醒

2023-05-16

一、前言

终于轮到了打第二针疫苗的时候，无奈每次打开“广州健康通”或“粤康通”小程序，每次都是被预约完的状态，广州人口众多，说不定有很多人一直守在小程序前等着放号，所以这篇文章就诞生了。

二、原理

这个程序说来简单，并不能直接帮助自己预约上号，而且提醒自己去小程序进行预约。利用定时任务，每隔5分钟或者10分钟，去调“广州健康通”的查询各区剩余人数的接口（相信这时候有人在说我是在搞垮服务器，怪不得每次打开小程序都很卡，额，按我5分钟调一次的频率，一个小时也才调12次，如果它连我一小时12次的访问次数都承载不了，那它怎么才能更好地为广大人民群众服务？）如果监控到大于50个人的剩余量，那么就通过发送QQ邮件的方式通知我，微信可以绑定到QQ邮件，所以如果有50个人以上的剩余量，那么我的微信和QQ就会同时收到邮件提醒。嗯，我最开始就觉得这很棒。

目标接口：https://m.r.umiaohealth.com/Home/GetTicketReport

当然这个接口也不是随便就能调的，需要添加鉴权，可以在手机上下载一个抓包工具，我使用的是HttpCanary这个软件，通过这个工具进行抓包可以获取所需要的Cookie鉴权值。

三、实现

搭建SpringBoot项目，我这里为了偷懒，引用了Hutool的邮件工具，pom依赖如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.5.1</version>
		<relativePath /> <!-- lookup parent from repository -->
	</parent>
	<groupId>com.chen</groupId>
	<artifactId>AppointmentTask</artifactId>
	<packaging>jar</packaging>
	<version>0.0.1-SNAPSHOT</version>
	<name>AppointmentTask</name>
	<description>Demo project for Spring Boot</description>
	<properties>
		<java.version>1.8</java.version>
	</properties>
	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		<dependency>
			<groupId>cn.hutool</groupId>
			<artifactId>hutool-all</artifactId>
			<version>5.6.7</version>
		</dependency>
		<dependency>
			<groupId>com.sun.mail</groupId>
			<artifactId>javax.mail</artifactId>
			<version>1.6.2</version>
		</dependency>
		

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-mail</artifactId>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>
	</dependencies>

	<build>
    	<finalName>App</finalName>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

application.properties的配置如下，这里只有一个cron表达式的配置，我这里用的定时任务是最新的Spring Task，比quartz用起来更简洁方便，这个表达式表示每小时从零开始每5分钟

mytask.corn1=0 0/5 * * * ?

我在controller层写了两个接口，一个是启动定时任务的接口，一个是关闭定时任务的接口，代码如下：

package com.chen.controller;

import java.util.Date;
import java.util.concurrent.ScheduledFuture;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.TriggerContext;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.chen.entity.TaskConfiguration;
import com.chen.task.MyRunnableTask;

@RestController
@RequestMapping("/quartz/task")
public class DynamicTaskController {
	
	@Autowired
    private TaskConfiguration taskConfiguration;
 
    @Autowired
    private ThreadPoolTaskScheduler threadPoolTaskScheduler;
 
    private ScheduledFuture<?> future1;
 
    @Bean
    public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
        return new ThreadPoolTaskScheduler();
    }
 
    @GetMapping("/start")
    public String start() {
        future1 = threadPoolTaskScheduler.schedule(new MyRunnableTask(),new Trigger(){
            @Override
            public Date nextExecutionTime(TriggerContext triggerContext){
                return new CronTrigger(taskConfiguration.getCorn1()).nextExecutionTime(triggerContext);
            }
        });
 
        System.out.println("定时任务启动成功");
 
        return "success";
 
    }
 
    @GetMapping("/stop")
    public String stop() {
        if (future1 != null) {
            future1.cancel(true);
        }
        System.out.println("停止定时任务");
        return "success";
    }

}

配置cron，关联上在配置文件写的表达式

package com.chen.entity;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

@Component
@ConfigurationProperties(prefix = "mytask")
public class TaskConfiguration {
	private String corn1;

	public String getCorn1() {
		return corn1;
	}

	public void setCorn1(String corn1) {
		this.corn1 = corn1;
	}
}

关于调接口方面我用的是RestTemplate，简单粗暴。注意这里需要用到两个邮箱，一个是发送者邮箱，一个是接收者邮箱，发送者邮箱需要到该邮箱账号开启POP3/SMTP服务，并获得授权密码，在代码里需要用到，另外还有一个要注意，如果是写完代码后要将项目部署到阿里云服务器，则端口号不能像Hutool介绍的那样写上25端口，要和我一样改成465端口号，不然就去阿里云上申请解封25端口号，这是因为阿里云的一些安全策略导致的禁用（这个坑我踩过）。

还有一点，我这里限制了50人，表示只有剩余50人可预约的时候，才会发邮件通知我，毕竟小程序上面的数据有延时，明明显示的有好几个人剩余，但是就是一直找不到在哪个接种点。我猜这个小程序的后端应该是使用了消息中间件或者某些框架，应付这种大数据量并发进行“削峰”。

package com.chen.task;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Map;

import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import com.chen.controller.DynamicTaskController;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.extra.mail.MailAccount;
import cn.hutool.extra.mail.MailUtil;

public class MyRunnableTask implements Runnable {

	private final String APPOINTMENTURL = "https://m.r.umiaohealth.com/Home/GetTicketReport";
	private final String COOKIE = "这里写上从抓包工具HttpCanary里面从接口的请求头里面拿到的Cookie值";
	private static int num = 0; // 防止一直不断的发送邮件，我这里加了个属性去限制，只允许发送一次

	@Override
	public void run() {
		RestTemplate restTemplate = new RestTemplate();

		System.out.println("first DynamicTask，" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));

		HttpHeaders headers = new HttpHeaders();
		headers.set("Cookie", COOKIE);

		if (num <= 2) {
			System.out.println("开始获取预约数据.....");
			@SuppressWarnings("rawtypes")
			HttpEntity<Map> res = restTemplate.exchange(APPOINTMENTURL, HttpMethod.GET, new HttpEntity<>(null, headers),
					Map.class);

			Object object = res.getBody().get("aaData");
			List<Map<String, Object>> cityData = (List<Map<String, Object>>) object;
			for (int i = 0; i < cityData.size(); i++) {
				if (cityData.get(i).get("District").toString().equals("天河区")) {
					int remainingNumber = (int) cityData.get(i).get("RemainingNumber");
					System.out.println("天河区剩余 " + remainingNumber + " 人");
					if (remainingNumber >= 50 && num <= 0) {
						MailAccount account = new MailAccount();
						account.setHost("smtp.163.com");
						account.setPort(465);
						account.setAuth(true);
						account.setFrom("这里写上自己的邮箱@163.com"); // 发送者邮箱
						account.setUser("这里写上自己的邮箱@163.com"); // 发送者
						account.setPass("写上授权密码"); // 授权密码
						account.setSslEnable(true);
						MailUtil.send(account, CollUtil.newArrayList("接收人邮箱@qq.com"), "预约提醒",
								"天河区剩余 " + remainingNumber + " 人，请尽快前往广州健康通小程序预约", false);
						System.out.println("邮件发送成功");
						num++;
					}
					break;
				}
			}
		} else {
			System.out.println("暂不获取预约数据......");
		}

	}

}

在入口程序上添加注解允许定时任务启动

package com.chen;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
public class AppointmentTaskApplication {

	public static void main(String[] args) {
		SpringApplication.run(AppointmentTaskApplication.class, args);
	}

}

这个程序在阿里云上运行了一个小时不到，我就成功预约上了。程序员简单的快乐也不过如此。

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)