患者提醒定时任务设计文档

初步想法

目标与实现思路：

目标：为在微信小程序中开启提醒功能的患者，按其配置的时间点发送订阅消息推送。
调度方式：采用 Spring Task，每分钟触发一次定时任务，定时任务负责从数据库读取提醒配置并判断是否需要发送。

判定与数据来源说明：

首先检查 t_patient_reminder 表中的两项开关：
- is_notification_enabled（消息总开关），
- is_subscription_available（一次性订阅开关）。仅当两者均为 1（开启）时，才继续处理该用户的提醒逻辑。
时间点来源：
- 测量类（血压/血糖/心率）的时间点保存在对应的 *_times 字段（JSON 格式）；
- 用药提醒的时间点需联动查询 t_patient_medication 表中的 times 字段（JSON 列表）。

为避免遗漏原始表结构定义，下面以代码块保留原始 CREATE TABLE 内容（未改动）：

CREATE TABLE t_patient_reminder (
    id bigint(20) NOT NULL COMMENT '主键ID',
    patient_user_id bigint(20) NOT NULL COMMENT '患者用户ID',
    is_notification_enabled tinyint(1) DEFAULT '1' COMMENT '是否启用消息通知总开关 (0-禁用, 1-启用)',
    is_subscription_available tinyint(1) DEFAULT '1' COMMENT '一次性订阅开关 (0-需要重新授权, 1-已授权可发送)',
    is_blood_pressure_enabled tinyint(1) DEFAULT '1' COMMENT '测量血压提醒开关 (0-禁用, 1-启用)',
    blood_pressure_times text COLLATE utf8mb4_unicode_ci COMMENT '测量血压的时间点（JSON格式存储）',
    is_blood_sugar_enabled tinyint(1) DEFAULT '0' COMMENT '测量血糖提醒开关 (0-禁用, 1-启用)',
    blood_sugar_times text COLLATE utf8mb4_unicode_ci COMMENT '测量血糖的时间点（JSON格式存储）',
    is_heart_rate_enabled tinyint(1) DEFAULT '1' COMMENT '测量心率提醒开关 (0-禁用, 1-启用)',
    heart_rate_times text COLLATE utf8mb4_unicode_ci COMMENT '测量心率的时间点（JSON格式存储）',
    is_medication_enabled tinyint(1) DEFAULT '1' COMMENT '用药提醒开关 (0-禁用, 1-启用)',
    version int(11) DEFAULT '0' COMMENT '版本号（乐观锁）',
    create_user bigint(20) DEFAULT NULL COMMENT '创建者ID',
    create_time datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    update_user bigint(20) DEFAULT NULL COMMENT '更新者ID',
    update_time datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
    remark varchar(255) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '备注',
    PRIMARY KEY (id),
    UNIQUE KEY uk_patient_user_id (patient_user_id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='患者提醒设置表';

CREATE TABLE t_patient_medication (
    id bigint(20) NOT NULL COMMENT '主键ID',
    patient_user_id bigint(20) NOT NULL COMMENT '患者用户ID',
    medicine_name varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '药品名称',
    dosage varchar(50) COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '剂量规格',
    frequency varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '服用频率',
    times text COLLATE utf8mb4_unicode_ci COMMENT '服用时间点列表（JSON格式存储）',
    note text COLLATE utf8mb4_unicode_ci COMMENT '备注信息',
    version int(11) DEFAULT '0' COMMENT '版本号（乐观锁）',
    create_user bigint(20) DEFAULT NULL COMMENT '创建者ID',
    create_time datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    update_user bigint(20) DEFAULT NULL COMMENT '更新者ID',
    update_time datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
    remark varchar(255) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '备注',
    PRIMARY KEY (id),
    KEY idx_patient_user_id (patient_user_id),
    KEY idx_medicine_name (medicine_name)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='患者用药记录表';

以上内容为整理后的实现思路与原始表结构（原文信息全部保留）。后续可按该判定逻辑实现定时任务查询与消息触发。

患者提醒定时任务设计文档（重构版）

概述：

目标：为已在微信小程序中开启提醒功能的患者，按设定时间点发送订阅消息推送。
调度方式：使用 Spring Task（建议每分钟触发一次），在定时任务中读取数据库，判断需推送的用户并发送消息。

设计要点：

权限与开关判断：优先判断 t_patient_reminder 表中的两项开关：消息总开关（is_notification_enabled）与一次性订阅开关（is_subscription_available）。两者均为开启时，才继续处理该用户。
时间点来源：测量类（血压/血糖/心率）时间点存储在 *_times 字段（JSON），用药提醒时间点需要结合 t_patient_medication 表中的 times 字段来计算。
消息过滤：只在当前时间点附近（例如±30秒或自定义窗口）发送，避免重复推送。可结合去重（消息历史表或临时缓存）策略。

处理流程（高层）：

定时触发（每分钟）：获取当前时间点（考虑时区和秒级窗口）。
查询 t_patient_reminder，筛选出 is_notification_enabled=1 且 is_subscription_available=1 的记录。
对每个候选用户：
- 解析各项时间配置（血压、血糖、心率、用药等）。
- 若当前时间匹配任一时间点，构造消息负载并调用发送模块。
发送结果记录与错误重试：记录成功/失败，常见失败（如 access_token 失效）尝试重试并适当降级处理（日志告警或入队重试）。

调度与性能建议：

若用户量较大，按用户分片（按 patient_user_id 范围或 hash 分片）并使用并发线程池处理。
为防止瞬时大量并发调用微信接口，应在发送端实现速率限制和批量控制。（本项目为独立小项目，暂不考虑外部队列方案）

数据库字段与含义（摘录说明）

t_patient_reminder：患者提醒设置表，关键字段包含：
- is_notification_enabled：总开关（0/1）
- is_subscription_available：一次性订阅开关（0/1）
- is_blood_pressure_enabled、blood_pressure_times：血压开关与时间点（JSON）
- is_blood_sugar_enabled、blood_sugar_times：血糖开关与时间点（JSON）
- is_heart_rate_enabled、heart_rate_times：心率开关与时间点（JSON）
- is_medication_enabled：用药提醒总开关（用药时间由 t_patient_medication 补充）
t_patient_medication：患者用药记录表，关键字段包含：
- medicine_name、dosage、frequency、times（服用时间点 JSON）

微信订阅消息发送模块（架构说明）

建议实现一个独立的发送模块，职责包括：读取配置、获取/刷新 access_token、执行消息发送、处理接口错误码（如 token 失效重试），并把发送结果上报给定时任务模块。
可将该模块封装为一个独立的服务或库（如示例 Python 实现），定时任务只负责构造负载并调用该模块。

错误处理与监控

记录每次发送的响应及异常，针对常见错误（如 errcode 表示 token 无效）触发重试逻辑。
对失败率、平均延迟等指标建立监控与报警。

附：原始草稿（完整，未改动）

使用下方代码块可以查看并比对原始内容（未修改）。为完整保留原文，下面使用更长的代码围栏以原样嵌入原文内容：

```markdown
# 患者提醒定时任务设计文档

## 初步想法
我们这个项目还有一个核心功能没有实现，就是为微信小程序开通了提醒功能的用户发送推送消息，我打算用springtask每分钟执行一次定时任务，那么定时任务的话就是我们编写一个工具类，从数据库里获取所有用户的CREATE TABLE t_patient_reminder ( id bigint(20) NOT NULL COMMENT '主键ID', patient_user_id bigint(20) NOT NULL COMMENT '患者用户ID', is_notification_enabled tinyint(1) DEFAULT '1' COMMENT '是否启用消息通知总开关 (0-禁用, 1-启用)', is_subscription_available tinyint(1) DEFAULT '1' COMMENT '一次性订阅开关 (0-需要重新授权, 1-已授权可发送)', is_blood_pressure_enabled tinyint(1) DEFAULT '1' COMMENT '测量血压提醒开关 (0-禁用, 1-启用)', blood_pressure_times text COLLATE utf8mb4_unicode_ci COMMENT '测量血压的时间点（JSON格式存储）', is_blood_sugar_enabled tinyint(1) DEFAULT '0' COMMENT '测量血糖提醒开关 (0-禁用, 1-启用)', blood_sugar_times text COLLATE utf8mb4_unicode_ci COMMENT '测量血糖的时间点（JSON格式存储）', is_heart_rate_enabled tinyint(1) DEFAULT '1' COMMENT '测量心率提醒开关 (0-禁用, 1-启用)', heart_rate_times text COLLATE utf8mb4_unicode_ci COMMENT '测量心率的时间点（JSON格式存储）', is_medication_enabled tinyint(1) DEFAULT '1' COMMENT '用药提醒开关 (0-禁用, 1-启用)', version int(11) DEFAULT '0' COMMENT '版本号（乐观锁）', create_user bigint(20) DEFAULT NULL COMMENT '创建者ID', create_time datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', update_user bigint(20) DEFAULT NULL COMMENT '更新者ID', update_time datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', remark varchar(255) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '备注', PRIMARY KEY (id), UNIQUE KEY uk_patient_user_id (patient_user_id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='患者提醒设置表';，首先检索用户'是否启用消息通知总开关 和 一次性订阅开关是否都处于开启，如果都是开启的则分析用户需要推送的时间点，其中用药提醒的时间点需要联动获取CREATE TABLE t_patient_medication ( id bigint(20) NOT NULL COMMENT '主键ID', patient_user_id bigint(20) NOT NULL COMMENT '患者用户ID', medicine_name varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '药品名称', dosage varchar(50) COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '剂量规格', frequency varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '服用频率', times text COLLATE utf8mb4_unicode_ci COMMENT '服用时间点列表（JSON格式存储）', note text COLLATE utf8mb4_unicode_ci COMMENT '备注信息', version int(11) DEFAULT '0' COMMENT '版本号（乐观锁）', create_user bigint(20) DEFAULT NULL COMMENT '创建者ID', create_time datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', update_user bigint(20) DEFAULT NULL COMMENT '更新者ID', update_time datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', remark varchar(255) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '备注', PRIMARY KEY (id), KEY idx_patient_user_id (patient_user_id), KEY idx_medicine_name (medicine_name) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='患者用药记录表';的数据，

相关资料：

"""
本文件实现了独立的微信订阅消息发送全流程。
包含从配置读取、access_token 获取到消息发送的完整逻辑。
"""

import json
import logging
import os
import time
import requests
import certifi

class AccessTokenManager:
    """
    管理微信 access_token 的获取与刷新
    """
    def __init__(self, appid: str, secret: str):
        self.appid = appid
        self.secret = secret



    def get_access_token(self) -> str:
        """获取有效的 access_token"""
        try:
            url = f'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={self.appid}&secret={self.secret}'
            response = requests.get(url, timeout=10, verify=certifi.where())
            response.raise_for_status()
            data = response.json()
            
            if 'access_token' in data:
                return data['access_token']
            else:
                raise Exception(f'获取 access_token 失败: {data.get("errmsg", "Unknown error")}')
                
        except Exception as e:
            raise Exception(f'请求 access_token 异常: {str(e)}')

class SubscribeMessageSender:
    """
    发送微信订阅消息的客户端
    """
    def __init__(self, appid: str, secret: str):
        self.access_token_manager = AccessTokenManager(appid, secret)
        self.send_url = 'https://api.weixin.qq.com/cgi-bin/message/subscribe/send'

    def send(self, payload: dict) -> dict:
        """
        发送订阅消息
        
        Args:
            payload: 消息负载，必须包含 touser, template_id 等必要字段
            
        Returns:
            微信接口返回的响应数据
        """
        if not isinstance(payload, dict):
            raise ValueError('payload 必须为字典类型')
            
        # 第一次尝试
        access_token = self.access_token_manager.get_access_token()
        result = self._do_send(payload, access_token)
        
        # 如果 token 失效，尝试刷新后重试
        if result.get('errcode') in (40001, 40014, 42001):
            logging.info('检测到 access_token 可能失效，尝试刷新后重试')
            access_token = self.access_token_manager.get_access_token()
            result = self._do_send(payload, access_token)
            
        return result

    def _do_send(self, payload: dict, access_token: str) -> dict:
        """执行实际的发送请求"""
        url = f'{self.send_url}?access_token={access_token}'
        logging.info(f'发送订阅消息: {url}')
        logging.debug(f'请求数据: {json.dumps(payload, ensure_ascii=False)}')
        
        try:
            response = requests.post(
                url, 
                json=payload, 
                timeout=10, 
                verify=certifi.where()
            )
            result = response.json()
            logging.debug(f'响应数据: {json.dumps(result, ensure_ascii=False)}')
            return result
        except Exception as e:
            logging.error(f'发送请求异常: {str(e)}')
            return {'errcode': -1, 'errmsg': str(e)}

# 使用示例
if __name__ == '__main__':
    # 配置日志
    logging.basicConfig(
        level=logging.INFO,
        format='%(asctime)s - %(levelname)s - %(message)s'
    )
    
    # 创建发送器实例（直接传入凭证）
    appid = "wx334b14b3d0bb1547"
    secret = "0b42a3e4becb7817d08e44e91e2824dd"
    sender = SubscribeMessageSender(appid, secret)
    
    # 构造消息负载
    sample_payload = {
        "touser": "oMrLJ4upWlkcM8ngNnj849sF_sZg",  # 用户实际openid
        "template_id": "ACS7cwcbx0F0Y_YaB4GZr7rWP7BO2-7wQOtYsnUjmFI",  # 模板ID 7536
        "page": "pages/index/index",  # 建议使用完整页面路径
        "miniprogram_state": "developer",
        "lang": "zh_CN",
        "data": {
            "phrase2": {"value": "健康打卡"},  # 打卡类型
            "date3": {"value": "2025-11-21"},  # 日期
            "thing4": {"value": "请按时完成每日健康上报"}  # 温馨提示
        }
    }
    
    # 发送消息
    try:
        response = sender.send(sample_payload)
        print('发送结果:', json.dumps(response, ensure_ascii=False, indent=2))
    except Exception as e:
        print('发送失败:', str(e))

执行结果：PS D:\慢病APP\other\simple-python-server> python send_full_subscribe.py
2025-11-21 17:33:04,374 - INFO - 发送订阅消息: https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=98_0wfkclFyskJQJUWbUYVgvrXbPziTymJ4p4uI2tM-ESMJrv0f8c2smMpZAonBn9k98hfdlVxvG-Ey3flQHwD4vyGOdQH1eKVSka-EJftPTJsB7aaji4iFAmGyV0MUBWcADAYFA
发送结果: {
  "errcode": 0,
  "errmsg": "ok",
  "msgid": 4263515288072994829
}
```

PatientReminderTaskDesign.md 16 KB История Исходник

患者提醒定时任务设计文档

初步想法

患者提醒定时任务设计文档（重构版）

PatientReminderTaskDesign.md 16 KB

История Исходник