pip3 install flask
pip3 install flask-apscheduler

import json
import requests
import datetime

from flask import Flask, jsonify, request
from flask_apscheduler import APScheduler
app = Flask(__name__)
scheduler = APScheduler()

scheduler.start()

def push_notification(push_data):
    if push_data["push_way"] == 'Gotify':
        resp = requests.post(f'https://push.xxx.xxx/message?token={push_data["push_token"]}', json={
        "message": f'「{push_data["sender"]}」发送了消息给你。',
        "priority": 8,
        "title": "新消息！"
        })
        print(resp)
        return
    if push_data["push_way"] == 'Bary':
        try:
            response = requests.post(
                url="https://api.day.app/push",
                headers={
                    "Content-Type": "application/json; charset=utf-8",
                },
                data=json.dumps({
                    "body": f'「{push_data["sender"]}」发送了消息给你。',
                    "device_key": push_data["push_token"],
                    "title": "新消息！",
                    "category": "category",
                    "sound": "minuet.caf",
                })
            )
            print('Response HTTP Status Code: {status_code}'.format(
                status_code=response.status_code))
            print('Response HTTP Response Body: {content}'.format(
                content=response.content))
        except requests.exceptions.RequestException:
            print('HTTP Request failed')
        return


# Our route that will receive the webhooks from Duffel's servers
@app.route('/_matrix/push/v1/notify', methods=['POST'])
def hello_world():
    push_data = {}
    event = None

    try:
        event = request.json
        print(event)

    except:
        return jsonify(success=False)

    # Handle the event
    if event["notification"]["type"] == 'm.room.message' or event["notification"]["type"] == 'm.room.encrypted':
        app_id = event["notification"]["devices"][0]["app_id"]
        push_data["push_way"], push_data["push_token"] = event["notification"]["devices"][0]["pushkey"].split('-')
        push_data["sender"] = event["notification"]["sender_display_name"]

        scheduler.add_job(
            func=push_notification,
            args=(push_data,),
            # trigger="date",
            next_run_time=datetime.datetime.now() + datetime.timedelta(seconds=25),
            id=app_id,
            replace_existing=True,
        )

        print('✅add push job!')

    if event["notification"]["type"] == None and event["notification"]["id"] == '':
        app_id = event["notification"]["devices"][0]["app_id"]
        try:
            scheduler.remove_job(id=app_id)
        except:
            pass
        print('✅remove push!')

    return jsonify(success=True)