重要メールが届いたら自動でGoogle Homeが読み上げ＆LINE通知！

pip install chardet line-bot-sdk

{
    "email": {
        "imap_server": "imap.mail.yahoo.co.jp",
        "port": "993",
        "address": "<Yahooメールアドレス>",
        "password": "<アプリケーションパスワード>"
    },
    "line": {
        "channel": {
            "information": {
                "access_token": "<アクセストークン>",
                "to_userid_or_groupid": "<通知先ユーザーIDまたはグループID>"
            },
            "<学校名チャンネル>": {
                "access_token": "<アクセストークン>",
                "to_userid_or_groupid": "<通知先ユーザーIDまたはグループID>"
            }
        }
    }
}

[
    {
        "searchfrom":  "*fts-center@fulltimesystem.jp*",
        "searchtitle": "*荷物滞留*",
        "searchbody":  "*ボックス番号：{%1}■*",
        "message":     "ロッカーに荷物が滞留しているので取り出してください。ボックス番号は、{%1}番です。",
        "linenotification": "True",
        "linemessage": "",
        "linechannel": ""
    },
    {
        "searchfrom":  "*<学校メールアドレス>*",
        "searchtitle": "{%2}",
        "searchbody":  "{%1}",
        "message":     "<学校名>からのお知らせ：{%2}\n{%1}",
        "linenotification": "True",
        "linemessage": "",
        "linechannel": "<学校名チャンネル>"
    },
    {
        "searchfrom":  "*abccard.co.jp*",
        "searchtitle": "*利用代金ご請求金額*",
        "searchbody":  "*年{%1}月分のご請求金額をご案内いたします。*＜当月ご請求金額＞*合計{%2}円*＜当月お支払日＞{%3}月{%4}日*",
        "message":     "ABCカードの、{%1}月の請求金額が確定しました。請求金額は、{%2}円です。支払日は、{%3}月{%4}日です。",
        "linenotification": "True",
        "linemessage": "",
        "linechannel": ""
    },
    {
        "searchfrom":  "*yokohama@bousai-mail.jp*",
        "searchtitle": "*特別*",
        "searchbody":  "{%1}詳細は*",
        "message":     "{%1}",
        "linenotification": "True",
        "linemessage": "",
        "linechannel": ""
    }
]

# -*- coding: utf-8 -*-
from linebot import LineBotApi
from linebot.models import TextSendMessage, ImageSendMessage

class Notify:
    def __init__(self, linechannel: dict):
        self.linechannel = linechannel
        self.line_bot_api = LineBotApi(self.linechannel['access_token'])
        self.to_userid_or_groupid = self.linechannel['to_userid_or_groupid']

    def send(self, message: str):
        self.line_bot_api.push_message(
            self.to_userid_or_groupid,
            TextSendMessage(text=message)
        )

    def send_image(self, imagefile_url: str):
        self.line_bot_api.push_message(
            self.to_userid_or_groupid,
            ImageSendMessage(
                original_content_url=imagefile_url,
                preview_image_url=imagefile_url
            )
        )

# -*- coding: utf-8 -*-
import imaplib
import email
from email.header import decode_header
import time
import datetime
import json
import googlehome
import line
import chardet

# settings.json の読み込み
with open('/home/<username>/smarthome/config/settings.json', 'r') as f:
    settings = json.load(f)

def main():
    google_notify = googlehome.Notify(googlehome.GoogleHome.LIVING)

    with open('/home/<username>/smarthome/config/mails.json', 'r') as f:
        search_mails = json.load(f)

    mail = connect_mail_server()
    connected_datetime = datetime.datetime.now()

    mail.select('INBOX')
    status, email_ids = mail.search(None, 'ALL')
    last_loaded_email_id = int(email_ids[0].split()[-1])

    while True:
        mail.select('INBOX')
        try:
            status, email_ids = mail.search(None, 'ALL')
        except imaplib.IMAP4.error:
            mail.close(); mail.logout()
            time.sleep(3)
            mail = connect_mail_server()
            mail.select('INBOX')
            continue

        latest_email_id = int(email_ids[0].split()[-1])

        for email_id in range(last_loaded_email_id + 1, latest_email_id + 1):
            status, msg_data = mail.fetch(str(email_id), '(RFC822)')
            if status == 'OK':
                msg = email.message_from_bytes(msg_data[0][1])
                sender, encoding = decode_header(msg['From'])[0]
                if encoding:
                    sender = sender.decode(encoding)
                sender = str(sender)

                subject, encoding = decode_header(msg['Subject'])[0]
                if encoding:
                    subject = subject.decode(encoding)
                subject = str(subject)

                body = ''
                for part in msg.walk():
                    if part.get_content_type() == 'text/plain':
                        payload = part.get_payload(decode=True) or b''
                        result = chardet.detect(payload)
                        body = payload.decode(result['encoding'], errors='replace')

                for search_mail in search_mails:
                    # 差出人・件名・本文がすべてルールに一致するか確認
                    if (like(sender, search_mail['searchfrom'])
                            and like(subject, search_mail['searchtitle'])
                            and like(body, search_mail['searchbody'])):

                        notice_message = search_mail['message']
                        # {%1}〜{%8} をメール内容から抽出して置換
                        for i in range(1, 9):
                            replace_value = get_replace_value(sender, search_mail['searchfrom'], i)
                            if not replace_value:
                                replace_value = get_replace_value(subject, search_mail['searchtitle'], i)
                            if not replace_value:
                                replace_value = get_replace_value(body, search_mail['searchbody'], i)
                            for _ in range(5):
                                notice_message = notice_message.replace('{%' + str(i) + '}', replace_value)

                        # Google Home で読み上げ
                        google_notify.speak(notice_message)

                        # LINE 通知が有効な場合は LINE にも送信
                        if search_mail['linenotification'].upper() == 'TRUE':
                            notice_message_for_line = search_mail['linemessage'] or notice_message
                            if search_mail['linechannel']:
                                line_notify = line.Notify(settings['line']['channel'][search_mail['linechannel']])
                            else:
                                line_notify = line.Notify(settings['line']['channel']['information'])
                            line_notify.send(notice_message_for_line)
                        break

        last_loaded_email_id = latest_email_id
        time.sleep(10)

        # 30 分ごとに再ログイン（IMAP セッション維持のため）
        if datetime.datetime.now() > connected_datetime + datetime.timedelta(minutes=30):
            mail.close(); mail.logout()
            mail = connect_mail_server()
            connected_datetime = datetime.datetime.now()

def connect_mail_server():
    mail = imaplib.IMAP4_SSL(
        settings['email']['imap_server'],
        int(settings['email']['port'])
    )
    mail.login(settings['email']['address'], settings['email']['password'])
    return mail

def like(target: str, pattern: str) -> bool:
    """
    * をワイルドカード、{%N} をキャプチャグループとして扱う簡易マッチング。
    fnmatch に近いが {%N} を * として扱う点が異なる。
    """
    import fnmatch
    normalized = pattern.replace('{%1}', '*').replace('{%2}', '*') \
                        .replace('{%3}', '*').replace('{%4}', '*') \
                        .replace('{%5}', '*').replace('{%6}', '*') \
                        .replace('{%7}', '*').replace('{%8}', '*')
    return fnmatch.fnmatch(target, normalized)

def get_replace_value(target: str, search: str, number: int) -> str:
    """
    search パターン中の {%number} に対応する部分文字列を target から抽出する。
    例：search = "*ボックス番号：{%1}■*", target = "... ボックス番号：3A■ ..."
    → number=1 のとき "3A" を返す
    """
    returnValue = ''
    targetValue = target
    if search == '{%' + str(number) + '}':
        return targetValue
    for splitTextA in search.split('*'):
        searchWords = []
        isFirstFound = True
        for splitTextP in splitTextA.split('{%'):
            if isFirstFound:
                searchWords.append(splitTextP)
                isFirstFound = False
            else:
                searchWords.append(splitTextP[2:])
        foundSplitPoint = 0
        for i in range(len(searchWords) - 1):
            foundSplitPoint = splitTextA.find('{%', foundSplitPoint)
            replaceNumber = splitTextA[foundSplitPoint + 2]
            foundSplitPoint += 1
            if replaceNumber != str(number):
                targetValue = targetValue[targetValue.find(searchWords[i]) + len(searchWords[i]):]
                continue
            replaceStartPoint = targetValue.find(searchWords[i])
            if replaceStartPoint == -1:
                continue
            replaceStartPoint += len(searchWords[i])
            replaceEndPoint = targetValue.find(searchWords[i + 1], replaceStartPoint)
            if replaceEndPoint == -1:
                continue
            returnValue = targetValue[replaceStartPoint:replaceEndPoint] or targetValue[replaceStartPoint:]
            targetValue = targetValue[targetValue.find(searchWords[i]) + len(searchWords[i]):]
            if returnValue:
                break
    return returnValue.strip()

if __name__ == '__main__':
    main()

[Unit]
Description=Mail Rule Notice Service
After=network.target

[Service]
ExecStart=/usr/bin/python3 /home/<username>/smarthome/core/notify/mail_rule/mail_rule_notice.py
Restart=always
User=<username>

[Install]
WantedBy=multi-user.target

sudo systemctl enable mail_rule_notice.service
sudo systemctl start mail_rule_notice.service

payload = part.get_payload(decode=True) or b''
result = chardet.detect(payload)
body = payload.decode(result['encoding'], errors='replace')