From 7a1aa81f9f2636cf74fee1b5b317df6cf9acc4bc Mon Sep 17 00:00:00 2001 From: Akira Date: Sun, 22 Feb 2026 09:27:27 +0900 Subject: [PATCH] =?UTF-8?q?=E5=AE=9F=E8=A3=85=E5=AE=8C=E4=BA=86=20?= =?UTF-8?q?=E4=BD=9C=E6=88=90=E3=83=BB=E5=A4=89=E6=9B=B4=E3=81=97=E3=81=9F?= =?UTF-8?q?=E3=83=95=E3=82=A1=E3=82=A4=E3=83=AB=20=E3=83=90=E3=83=83?= =?UTF-8?q?=E3=82=AF=E3=82=A8=E3=83=B3=E3=83=89=EF=BC=88=E6=96=B0=E8=A6=8F?= =?UTF-8?q?=EF=BC=89:?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit apps/mail/models.py — MailSender, MailEmail, MailNotificationToken apps/mail/serializers.py apps/mail/views.py — Windmill用API、フィードバック、ルール管理 apps/mail/urls.py apps/mail/admin.py マイグレーション（自動生成・適用済み） バックエンド（変更）: settings.py — apps.mail 追加、MAIL_API_KEY/FRONTEND_URL 環境変数 urls.py — /api/mail/ 追加 フロントエンド（新規）: mail/feedback/[token]/page.tsx — 認証不要、フィードバック3択＋スコープ選択 mail/rules/page.tsx — ルール管理（一覧・追加・削除） フロントエンド（変更）: Navbar.tsx — 「メールルール」メニュー追加 types/index.ts — MailSender, MailEmailFeedback 型追加 次のステップ（Windmill側） Keinaシステム側の実装は完了しています。次はWindmillにIMAPポーリングスクリプトを書く必要があります。Windmillのスクリプトが必要になったタイミングでお声がけください。 --- CLAUDE.md | 9 + backend/apps/mail/__init__.py | 0 backend/apps/mail/admin.py | 23 ++ backend/apps/mail/migrations/0001_initial.py | 71 +++++ backend/apps/mail/migrations/__init__.py | 0 backend/apps/mail/models.py | 99 +++++++ backend/apps/mail/serializers.py | 42 +++ backend/apps/mail/urls.py | 19 ++ backend/apps/mail/views.py | 204 +++++++++++++ backend/keinasystem/settings.py | 5 + backend/keinasystem/urls.py | 1 + document/メールフィルタ/PythonFilter試案.md | 108 +++++++ document/メールフィルタ/mail_filter_spec.md | 265 +++++++++++++++++ .../src/app/mail/feedback/[token]/page.tsx | 271 ++++++++++++++++++ frontend/src/app/mail/rules/page.tsx | 218 ++++++++++++++ frontend/src/components/Navbar.tsx | 13 +- frontend/src/types/index.ts | 20 ++ 17 files changed, 1367 insertions(+), 1 deletion(-) create mode 100644 backend/apps/mail/__init__.py create mode 100644 backend/apps/mail/admin.py create mode 100644 backend/apps/mail/migrations/0001_initial.py create mode 100644 backend/apps/mail/migrations/__init__.py create mode 100644 backend/apps/mail/models.py create mode 100644 backend/apps/mail/serializers.py create mode 100644 backend/apps/mail/urls.py create mode 100644 backend/apps/mail/views.py create mode 100644 document/メールフィルタ/PythonFilter試案.md create mode 100644 document/メールフィルタ/mail_filter_spec.md create mode 100644 frontend/src/app/mail/feedback/[token]/page.tsx create mode 100644 frontend/src/app/mail/rules/page.tsx diff --git a/CLAUDE.md b/CLAUDE.md index 8f5c376..e38aa89 100644 --- a/CLAUDE.md +++ b/CLAUDE.md @@ -214,6 +214,14 @@ Variety (品種マスタ) - 圃場一覧「対応表」モード（共済漢字地名・中山間所在地の一覧表示、直接紐づけ追加・解除） - 圃場詳細画面の共済/中山間リンク管理（+追加、×解除、面積参考表示） - 共通 LinkModal コンポーネント +7. **メールフィルタリング機能**（Windmill連携）: + - Django `apps/mail` アプリ（MailSender, MailEmail, MailNotificationToken） + - Windmill向けAPI（APIキー認証）: `GET /api/mail/sender-rule/`, `GET /api/mail/sender-context/`, `POST /api/mail/emails/` + - フィードバックAPI（認証不要・UUIDトークン）: `GET/POST /api/mail/feedback//` + - ルール管理API（JWT認証）: `GET/POST/DELETE /api/mail/senders/` + - フィードバックページ: `/mail/feedback/[token]`（LINEからタップ一発、認証不要） + - ルール管理ページ: `/mail/rules/` + - 仕様書: `document/メールフィルタ/mail_filter_spec.md` ### 🚧 既知の課題・技術的負債 @@ -325,6 +333,7 @@ docker-compose exec backend python manage.py migrate ## 📝 更新履歴 +- 2026-02-22: メールフィルタリング機能を実装。`apps/mail` Django app、Windmill向けAPI（APIキー認証）、フィードバックページ、ルール管理ページを追加。仕様書: `document/メールフィルタ/mail_filter_spec.md` - 2026-02-21: マスタードキュメント体系を導入。`document/10_マスタードキュメント_圃場管理編.md` を追加。セッション推奨フローにマスタードキュメント参照を追加 - 2026-02-18: E-2（対応付け可視化・紐づけ管理）仕様追加。画面設計書・差異レポート・次タスク一覧を更新。完了済みタスク(A-8, D-1〜D-4, E-1)を既知の課題から除外 - 2026-02-17: ドキュメント一斉更新（差異レポートA〜E反映、CSV→PDF統一、M:N関係、中山間モデル17列化、インライン編集方式、Navbar追加、既知の課題・次タスク一覧追加） diff --git a/backend/apps/mail/__init__.py b/backend/apps/mail/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/backend/apps/mail/admin.py b/backend/apps/mail/admin.py new file mode 100644 index 0000000..82c928e --- /dev/null +++ b/backend/apps/mail/admin.py @@ -0,0 +1,23 @@ +from django.contrib import admin +from .models import MailSender, MailEmail, MailNotificationToken + + +@admin.register(MailSender) +class MailSenderAdmin(admin.ModelAdmin): + list_display = ('__str__', 'rule', 'note', 'created_at') + list_filter = ('rule',) + search_fields = ('email', 'domain', 'note') + + +@admin.register(MailEmail) +class MailEmailAdmin(admin.ModelAdmin): + list_display = ('subject', 'sender_email', 'account', 'llm_verdict', 'feedback', 'received_at') + list_filter = ('account', 'llm_verdict', 'feedback') + search_fields = ('subject', 'sender_email', 'sender_domain') + readonly_fields = ('message_id', 'received_at', 'notified_at', 'feedback_at') + + +@admin.register(MailNotificationToken) +class MailNotificationTokenAdmin(admin.ModelAdmin): + list_display = ('token', 'email', 'created_at') + readonly_fields = ('token', 'created_at') diff --git a/backend/apps/mail/migrations/0001_initial.py b/backend/apps/mail/migrations/0001_initial.py new file mode 100644 index 0000000..62b887d --- /dev/null +++ b/backend/apps/mail/migrations/0001_initial.py @@ -0,0 +1,71 @@ +# Generated by Django 5.0 on 2026-02-22 00:20 + +import django.db.models.deletion +import uuid +from django.db import migrations, models + + +class Migration(migrations.Migration): + + initial = True + + dependencies = [ + ] + + operations = [ + migrations.CreateModel( + name='MailEmail', + fields=[ + ('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')), + ('account', models.CharField(choices=[('xserver', 'Xserver'), ('gmail', 'Gmail'), ('hotmail', 'Hotmail')], max_length=20, verbose_name='アカウント')), + ('message_id', models.CharField(max_length=500, unique=True, verbose_name='Message-ID')), + ('sender_email', models.EmailField(max_length=254, verbose_name='送信者アドレス')), + ('sender_domain', models.CharField(max_length=255, verbose_name='送信者ドメイン')), + ('subject', models.CharField(max_length=500, verbose_name='件名')), + ('body_preview', models.TextField(verbose_name='本文冒頭')), + ('received_at', models.DateTimeField(verbose_name='受信日時')), + ('llm_verdict', models.CharField(choices=[('important', '重要'), ('not_important', '重要でない')], max_length=20, verbose_name='LLM判定')), + ('notified_at', models.DateTimeField(blank=True, null=True, verbose_name='LINE通知日時')), + ('feedback', models.CharField(blank=True, choices=[('important', '重要だった'), ('not_important', '普通のメール'), ('never_notify', '今後通知しない')], max_length=20, null=True, verbose_name='フィードバック')), + ('feedback_at', models.DateTimeField(blank=True, null=True, verbose_name='フィードバック日時')), + ], + options={ + 'verbose_name': '受信メール', + 'verbose_name_plural': '受信メール', + 'ordering': ['-received_at'], + }, + ), + migrations.CreateModel( + name='MailSender', + fields=[ + ('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')), + ('email', models.EmailField(blank=True, max_length=254, null=True, verbose_name='メールアドレス')), + ('domain', models.CharField(blank=True, max_length=255, null=True, verbose_name='ドメイン')), + ('rule', models.CharField(choices=[('never_notify', '通知しない')], default='never_notify', max_length=20, verbose_name='ルール')), + ('note', models.TextField(blank=True, verbose_name='メモ')), + ('created_at', models.DateTimeField(auto_now_add=True)), + ('updated_at', models.DateTimeField(auto_now=True)), + ], + options={ + 'verbose_name': '送信者ルール', + 'verbose_name_plural': '送信者ルール', + }, + ), + migrations.CreateModel( + name='MailNotificationToken', + fields=[ + ('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')), + ('token', models.UUIDField(default=uuid.uuid4, unique=True, verbose_name='トークン')), + ('created_at', models.DateTimeField(auto_now_add=True)), + ('email', models.OneToOneField(on_delete=django.db.models.deletion.CASCADE, related_name='notification_token', to='mail.mailemail', verbose_name='メール')), + ], + options={ + 'verbose_name': '通知トークン', + 'verbose_name_plural': '通知トークン', + }, + ), + migrations.AddConstraint( + model_name='mailsender', + constraint=models.CheckConstraint(check=models.Q(models.Q(('domain__isnull', True), ('email__isnull', False)), models.Q(('domain__isnull', False), ('email__isnull', True)), _connector='OR'), name='mail_sender_email_or_domain'), + ), + ] diff --git a/backend/apps/mail/migrations/__init__.py b/backend/apps/mail/migrations/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/backend/apps/mail/models.py b/backend/apps/mail/models.py new file mode 100644 index 0000000..b2b075a --- /dev/null +++ b/backend/apps/mail/models.py @@ -0,0 +1,99 @@ +import uuid +from django.db import models + + +class MailSender(models.Model): + """送信者ルール（never_notify: 通知しない）""" + email = models.EmailField(null=True, blank=True, verbose_name="メールアドレス") + domain = models.CharField(max_length=255, null=True, blank=True, verbose_name="ドメイン") + rule = models.CharField( + max_length=20, + choices=[('never_notify', '通知しない')], + default='never_notify', + verbose_name="ルール" + ) + note = models.TextField(blank=True, verbose_name="メモ") + created_at = models.DateTimeField(auto_now_add=True) + updated_at = models.DateTimeField(auto_now=True) + + class Meta: + verbose_name = "送信者ルール" + verbose_name_plural = "送信者ルール" + constraints = [ + models.CheckConstraint( + check=( + models.Q(email__isnull=False, domain__isnull=True) | + models.Q(email__isnull=True, domain__isnull=False) + ), + name='mail_sender_email_or_domain' + ) + ] + + def __str__(self): + value = self.email or self.domain + kind = "アドレス" if self.email else "ドメイン" + return f"[{kind}] {value}" + + +ACCOUNT_CHOICES = [ + ('xserver', 'Xserver'), + ('gmail', 'Gmail'), + ('hotmail', 'Hotmail'), +] + +FEEDBACK_CHOICES = [ + ('important', '重要だった'), + ('not_important', '普通のメール'), + ('never_notify', '今後通知しない'), +] + + +class MailEmail(models.Model): + """受信メール記録（LLMに渡したメール）""" + account = models.CharField(max_length=20, choices=ACCOUNT_CHOICES, verbose_name="アカウント") + message_id = models.CharField(max_length=500, unique=True, verbose_name="Message-ID") + sender_email = models.EmailField(verbose_name="送信者アドレス") + sender_domain = models.CharField(max_length=255, verbose_name="送信者ドメイン") + subject = models.CharField(max_length=500, verbose_name="件名") + body_preview = models.TextField(verbose_name="本文冒頭") + received_at = models.DateTimeField(verbose_name="受信日時") + llm_verdict = models.CharField( + max_length=20, + choices=[('important', '重要'), ('not_important', '重要でない')], + verbose_name="LLM判定" + ) + notified_at = models.DateTimeField(null=True, blank=True, verbose_name="LINE通知日時") + feedback = models.CharField( + max_length=20, + choices=FEEDBACK_CHOICES, + null=True, blank=True, + verbose_name="フィードバック" + ) + feedback_at = models.DateTimeField(null=True, blank=True, verbose_name="フィードバック日時") + + class Meta: + verbose_name = "受信メール" + verbose_name_plural = "受信メール" + ordering = ['-received_at'] + + def __str__(self): + return f"{self.subject} ({self.sender_email})" + + +class MailNotificationToken(models.Model): + """LINEフィードバックURL用トークン（有効期限なし）""" + email = models.OneToOneField( + MailEmail, + on_delete=models.CASCADE, + related_name='notification_token', + verbose_name="メール" + ) + token = models.UUIDField(default=uuid.uuid4, unique=True, verbose_name="トークン") + created_at = models.DateTimeField(auto_now_add=True) + + class Meta: + verbose_name = "通知トークン" + verbose_name_plural = "通知トークン" + + def __str__(self): + return str(self.token) diff --git a/backend/apps/mail/serializers.py b/backend/apps/mail/serializers.py new file mode 100644 index 0000000..4fa64e2 --- /dev/null +++ b/backend/apps/mail/serializers.py @@ -0,0 +1,42 @@ +from rest_framework import serializers +from .models import MailSender, MailEmail + + +class MailSenderSerializer(serializers.ModelSerializer): + type = serializers.SerializerMethodField() + + class Meta: + model = MailSender + fields = ['id', 'type', 'email', 'domain', 'rule', 'note', 'created_at'] + + def get_type(self, obj): + return 'address' if obj.email else 'domain' + + def validate(self, data): + email = data.get('email') + domain = data.get('domain') + if not email and not domain: + raise serializers.ValidationError("email または domain のどちらかを指定してください") + if email and domain: + raise serializers.ValidationError("email と domain を同時に指定することはできません") + return data + + +class MailEmailCreateSerializer(serializers.ModelSerializer): + """Windmill からの POST 用""" + class Meta: + model = MailEmail + fields = [ + 'account', 'message_id', 'sender_email', 'sender_domain', + 'subject', 'body_preview', 'received_at', 'llm_verdict' + ] + + +class FeedbackDetailSerializer(serializers.ModelSerializer): + """フィードバックページ表示用""" + class Meta: + model = MailEmail + fields = [ + 'id', 'sender_email', 'sender_domain', 'subject', + 'body_preview', 'received_at', 'feedback' + ] diff --git a/backend/apps/mail/urls.py b/backend/apps/mail/urls.py new file mode 100644 index 0000000..3150a41 --- /dev/null +++ b/backend/apps/mail/urls.py @@ -0,0 +1,19 @@ +from django.urls import path, include +from rest_framework.routers import DefaultRouter +from . import views + +router = DefaultRouter() +router.register(r'senders', views.MailSenderViewSet, basename='mail-sender') + +urlpatterns = [ + # Windmill向けAPI（APIキー認証） + path('sender-rule/', views.SenderRuleView.as_view(), name='mail-sender-rule'), + path('sender-context/', views.SenderContextView.as_view(), name='mail-sender-context'), + path('emails/', views.MailEmailCreateView.as_view(), name='mail-email-create'), + + # フィードバック（認証不要、UUIDトークン） + path('feedback//', views.FeedbackView.as_view(), name='mail-feedback'), + + # ルール管理（JWT認証） + path('', include(router.urls)), +] diff --git a/backend/apps/mail/views.py b/backend/apps/mail/views.py new file mode 100644 index 0000000..5b30490 --- /dev/null +++ b/backend/apps/mail/views.py @@ -0,0 +1,204 @@ +import secrets +from django.conf import settings +from django.shortcuts import get_object_or_404 +from django.utils import timezone +from rest_framework import viewsets, permissions, status +from rest_framework.views import APIView +from rest_framework.response import Response +from rest_framework.permissions import BasePermission, AllowAny, IsAuthenticated +from django.db.models import Count, Q + +from .models import MailSender, MailEmail, MailNotificationToken +from .serializers import ( + MailSenderSerializer, + MailEmailCreateSerializer, + FeedbackDetailSerializer, +) + + +class MailAPIKeyPermission(BasePermission): + """X-API-Key ヘッダーで認証（Windmill向け）""" + + def has_permission(self, request, view): + key = request.headers.get('X-API-Key', '') + expected = getattr(settings, 'MAIL_API_KEY', '') + if not key or not expected: + return False + return secrets.compare_digest(key, expected) + + +# --------------------------------------------------------------------------- +# Windmill 向け API（APIキー認証） +# --------------------------------------------------------------------------- + +class SenderRuleView(APIView): + """ + GET /api/mail/sender-rule/?email=...&domain=... + 送信者ルールを確認する（アドレス優先 > ドメイン優先） + """ + permission_classes = [MailAPIKeyPermission] + authentication_classes = [] + + def get(self, request): + email = request.query_params.get('email', '') + domain = request.query_params.get('domain', '') + + # アドレスルールを先に確認（具体的なほど優先） + if email: + sender = MailSender.objects.filter(email=email).first() + if sender: + return Response({ + 'matched': True, + 'rule': sender.rule, + 'match_type': 'address', + }) + + # ドメインルールを確認 + if domain: + sender = MailSender.objects.filter(domain=domain).first() + if sender: + return Response({ + 'matched': True, + 'rule': sender.rule, + 'match_type': 'domain', + }) + + return Response({'matched': False}) + + +class SenderContextView(APIView): + """ + GET /api/mail/sender-context/?email=...&domain=... + LLM用フィードバック集計を返す（トークン肥大化防止のため集計値のみ） + """ + permission_classes = [MailAPIKeyPermission] + authentication_classes = [] + + def get(self, request): + email = request.query_params.get('email', '') + domain = request.query_params.get('domain', '') + + # アドレスで絞り込み（なければドメインで絞り込み） + if email: + qs = MailEmail.objects.filter(sender_email=email) + elif domain: + qs = MailEmail.objects.filter(sender_domain=domain) + else: + return Response({ + 'total_notified': 0, + 'important': 0, + 'not_important': 0, + 'never_notify': 0, + 'no_feedback': 0, + }) + + total = qs.count() + important = qs.filter(feedback='important').count() + not_important = qs.filter(feedback='not_important').count() + never_notify = qs.filter(feedback='never_notify').count() + no_feedback = qs.filter(feedback__isnull=True).count() + + return Response({ + 'total_notified': total, + 'important': important, + 'not_important': not_important, + 'never_notify': never_notify, + 'no_feedback': no_feedback, + }) + + +class MailEmailCreateView(APIView): + """ + POST /api/mail/emails/ + メールを記録する。llm_verdict == 'important' の場合はトークンも発行する。 + """ + permission_classes = [MailAPIKeyPermission] + authentication_classes = [] + + def post(self, request): + serializer = MailEmailCreateSerializer(data=request.data) + if not serializer.is_valid(): + return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST) + + mail_email = serializer.save() + response_data = {'id': mail_email.id} + + if mail_email.llm_verdict == 'important': + token_obj = MailNotificationToken.objects.create(email=mail_email) + mail_email.notified_at = timezone.now() + mail_email.save(update_fields=['notified_at']) + + frontend_url = getattr(settings, 'FRONTEND_URL', 'http://localhost:3000') + response_data['feedback_url'] = f"{frontend_url}/mail/feedback/{token_obj.token}" + + return Response(response_data, status=status.HTTP_201_CREATED) + + +# --------------------------------------------------------------------------- +# フィードバックビュー（認証不要） +# --------------------------------------------------------------------------- + +class FeedbackView(APIView): + """ + GET /api/mail/feedback// メール情報と現在のフィードバックを返す + POST /api/mail/feedback// フィードバックを保存する + """ + permission_classes = [AllowAny] + authentication_classes = [] + + def _get_mail_email(self, token): + token_obj = get_object_or_404(MailNotificationToken, token=token) + return token_obj.email + + def get(self, request, token): + mail_email = self._get_mail_email(token) + serializer = FeedbackDetailSerializer(mail_email) + return Response(serializer.data) + + def post(self, request, token): + mail_email = self._get_mail_email(token) + + feedback = request.data.get('feedback') + valid_feedbacks = ['important', 'not_important', 'never_notify'] + if feedback not in valid_feedbacks: + return Response( + {'error': f'feedback は {valid_feedbacks} のいずれかを指定してください'}, + status=status.HTTP_400_BAD_REQUEST + ) + + # フィードバックを更新（再選択も可能） + mail_email.feedback = feedback + mail_email.feedback_at = timezone.now() + mail_email.save(update_fields=['feedback', 'feedback_at']) + + # 「今後通知しない」の場合、送信者ルールを作成/更新 + if feedback == 'never_notify': + scope = request.data.get('scope') # 'address' or 'domain' + if scope == 'address': + MailSender.objects.update_or_create( + email=mail_email.sender_email, + defaults={'domain': None, 'rule': 'never_notify'} + ) + elif scope == 'domain': + MailSender.objects.update_or_create( + domain=mail_email.sender_domain, + defaults={'email': None, 'rule': 'never_notify'} + ) + + return Response({'status': 'ok'}) + + +# --------------------------------------------------------------------------- +# ルール管理（JWT認証） +# --------------------------------------------------------------------------- + +class MailSenderViewSet(viewsets.ModelViewSet): + """ + GET /api/mail/senders/ ルール一覧 + POST /api/mail/senders/ ルール追加 + DELETE /api/mail/senders/{id}/ ルール削除 + """ + queryset = MailSender.objects.all().order_by('-created_at') + serializer_class = MailSenderSerializer + permission_classes = [IsAuthenticated] + http_method_names = ['get', 'post', 'delete', 'head', 'options'] diff --git a/backend/keinasystem/settings.py b/backend/keinasystem/settings.py index 7d1d492..d034e7a 100644 --- a/backend/keinasystem/settings.py +++ b/backend/keinasystem/settings.py @@ -40,6 +40,7 @@ INSTALLED_APPS = [ 'apps.fields', 'apps.plans', 'apps.reports', + 'apps.mail', ] MIDDLEWARE = [ @@ -148,3 +149,7 @@ CORS_ALLOWED_ORIGINS = [ "http://localhost:3000", "http://127.0.0.1:3000", ] + +# メールフィルタリング機能 +MAIL_API_KEY = os.environ.get('MAIL_API_KEY', '') +FRONTEND_URL = os.environ.get('FRONTEND_URL', 'http://localhost:3000') diff --git a/backend/keinasystem/urls.py b/backend/keinasystem/urls.py index 49c24c3..0d79bac 100644 --- a/backend/keinasystem/urls.py +++ b/backend/keinasystem/urls.py @@ -32,4 +32,5 @@ urlpatterns = [ path('api/reports/', include('apps.reports.urls')), path('api/auth/jwt/create/', TokenObtainPairView.as_view(), name='token_obtain_pair'), path('api/auth/jwt/refresh/', TokenRefreshView.as_view(), name='token_refresh'), + path('api/mail/', include('apps.mail.urls')), ] diff --git a/document/メールフィルタ/PythonFilter試案.md b/document/メールフィルタ/PythonFilter試案.md new file mode 100644 index 0000000..ab1a92d --- /dev/null +++ b/document/メールフィルタ/PythonFilter試案.md @@ -0,0 +1,108 @@ +# 最適化フィルタ仕様書 (v2.1) + +## 1. システム目的 + +Gmailから取得した生データを、プログラムによる**「脊髄反射的処理（静的フィルタ）」**で徹底的に選別・加工し、人間と同等の判断が必要な**「思考的処理（LLM判定）」**へ渡すトークン量を極限まで削減する。 + +## 2. 処理フロー概略 + +1. **静的除外**: ドメイン・キーワードによる即時廃棄。 +2. **定型処理**: 認証・通知・配送状況などの「構造が既知」なメールの自動抽出。 +3. **クレンジング**: HTML・署名・引用の完全除去による軽量化。 +4. **LLM判定**: 絞り込まれたテキストのみを最小トークンで判定。 + +--- + +## 3. 詳細仕様 + +### 3.1. フェーズ1：静的フィルタ（LLMバイパス） + +以下の条件に合致する場合、LLMステップを呼び出さず処理を完了させる。 + +* **ブラックリスト判定**: 以下のドメイン・送信元は即時廃棄（または「通知不要」としてDB記録）。 +* `mail.aliexpress.com`, `instagram.com`, `facebookmail.com`, 各種メルマガ（件名に「PR」「メルマガ」を含むもの）。 + + +* **認証・セッション系**: +* **対象キーワード**: `認証コード`, `セキュリティコード`, `ログインのお知らせ`, `ワンタイムパスワード`. +* **処理**: `From` と `Subject` を結合した文字列のみをLINE通知へ送り、終了。 + + +* **重複排除（Deduplication）**: +* 過去24時間以内に同一の「送信者＋送り状番号（ヤマト等）」または「送信者＋件名」を処理済みの場合、ステータス更新のみを行い、新規通知としては扱わない。 + + + +### 3.2. フェーズ2：定型データ抽出（正規表現エンジン） + +LLMに文脈を読ませるのではなく、正規表現で特定の値を抜き出し、通知文を自己生成する。 + +* **配送状況（ヤマト運輸・Amazon等）**: +* `[0-9]{4}-[0-9]{4}-[0-9]{4}`（伝票番号）を抽出。 +* 「お届け予定」「完了」などのキーワードを抽出し、固定フォーマット化。 + + +* **金融・決済（JAバンク・カード会社）**: +* `[0-9,]+円`（金額）および `[0-9/]{5,10}`（日付）を抽出。 +* 「支払金額：〇〇円、期日：〇〇」として構造化。 + + + +### 3.3. フェーズ3：テキスト・プリプロセッサ（クレンジング） + +LLMに渡す場合でも、以下の処理を「必ず」事前に行う。 + +1. **HTML剥離**: `BeautifulSoup` 等を用い、タグ・スタイル・スクリプトを完全除去。 +2. **ノイズ除去**: +* `https?://\S+` → `[URL]` へ置換。 +* 行頭の `>`（引用）および、空行・連続スペースの削除。 +* 定型フッター（「本メールに心当たりがない場合」「配信停止は」等）をキーワードリストに基づき一括削除。 + + +3. **ペイロード制限**: +* `From`, `Subject`, `Body`（先頭300文字）をJSON形式にパックする。 + + + +--- + +## 4. LLM判定フェーズ（最終関門） + +### 4.1. プロンプト定義 + +出力トークンを最小化するため、LLMには**「1文字のランク」**のみを返させる。 + +* **Input**: `{"from": "...", "sub": "...", "body": "..."}` +* **System Prompt**: 「このメールが吉田さんの業務（農業・システム開発）や資産保護において、即座に確認すべき『重要』なものか判定せよ。 +* `1`: 即時通知が必要（重要・緊急） +* `2`: 1日の終わりにまとめて通知（低緊急・要確認） +* `3`: 通知不要 +出力は数字1文字のみとせよ。」 + + + +--- + +## 5. フィードバック・学習仕様 + +システムを改善し続けるためのデータ循環構造。 + +* **通知インターフェース**: LINE通知の下部に「不要」「毎日」のリンクを設置。 +* **データベース（PostgreSQL）**: +* `feedback_table`: `sender_domain`, `subject_pattern`, `user_decision` を記録。 + + +* **動的更新**: `user_decision` が `ignore` になったドメインは、自動的に「3.1. ブラックリスト」へ同期される。 + +--- + +## 6. 実装上の留意点（Antigravity等） + +* **タイムアウト対策**: 1通あたりの処理時間を最小化するため、DB照会はインデックスを貼った高速なものにすること。 +* **エラーハンドリング**: Gmail APIの取得失敗時や、LLMが数字以外を返した際のデフォルト値は「通知（1）」として、重要なメールの消失を防ぐ。 + +--- + +仕様書は以上となります。Antigravityでの実装において、具体的なPythonコードの記述や、LINE Botとの連携部分でサポートが必要になりましたら、いつでもお声がけください。 + +次は何をお手伝いしましょうか？ \ No newline at end of file diff --git a/document/メールフィルタ/mail_filter_spec.md b/document/メールフィルタ/mail_filter_spec.md new file mode 100644 index 0000000..48c0aef --- /dev/null +++ b/document/メールフィルタ/mail_filter_spec.md @@ -0,0 +1,265 @@ +# メールフィルタリング機能 仕様書 + +> **作成**: 2026-02-21 +> **ステータス**: 仕様確定 → 実装フェーズへ + +--- + +## 概要 + +複数のメールアカウントに届くメールをLLMで重要度判定し、重要なメールだけをLINEで通知する。 +フィードバックを積み重ねることで判定が賢くなっていく仕組みを持つ。 + +--- + +## システム構成 + +``` +[Xserver/Gmail/Hotmail IMAP] + ↓ Windmill スケジュール実行（ポーリング） +[メール取得・正規化] + ↓ +[重要度判定エンジン]（Django API経由でDBを参照） +├─ アドレスルールあり → ルールに従う（never_notify → スキップ） +├─ ドメインルールあり → ルールに従う（never_notify → スキップ） +└─ ルールなし → LLM（Claude API）に判定させる + ↓ 文脈として「過去フィードバック集計」を渡す + ↓ 重要と判断されたメール +[LINE Messaging API で通知] +「件名: ○○ / 送信者: △△ + 👉 https://keinafarm.net/mail/feedback/{token}」 + ↓ タップ +[KeinaシステムのDjangoビュー /mail/feedback/{token}] + ↓ フィードバック選択 +[KeinaシステムのPostgreSQL更新] + ↓ 次回ポーリング時にWindmillが参照 +``` + +--- + +## 技術スタック + +| 役割 | 技術 | +|------|------| +| ワークフロー実行 | Windmill（既にサーバーで稼働中） | +| メール取得 | IMAP統一（Xserver/Gmail/Hotmail） | +| LLM判定 | Claude API | +| LINE通知 | LINE Messaging API（既に連携済み） | +| フィードバック画面・API | Keinaシステム（Django）に機能追加 | +| DB | KeinaシステムのPostgreSQL | +| Windmill ↔ Keinasystem連携 | Django REST API（APIキー認証） | + +--- + +## メールアカウント + +- Xserver のメールサービス（自前ドメイン）→ IMAP +- Gmail → IMAP +- Hotmail（Outlook）→ IMAP + +ルールは複数アカウントをまたいで共通（アカウントを区別しない）。 + +--- + +## 判定フロー（詳細） + +``` +新着メール受信 + ↓ +1. mail_senders に一致するアドレスルールがあるか？ + → never_notify: スキップ（LLM呼ばない、記録もしない） + ↓ +2. mail_senders に一致するドメインルールがあるか？ + → never_notify: スキップ（LLM呼ばない、記録もしない） + ↓ +3. LLM判定（Claude API） + 入力: + - 送信者メールアドレス・ドメイン + - 件名 + - 本文冒頭（200字程度） + - 過去フィードバック集計（後述） + 出力: + - important / not_important + ↓ +4. important → mail_emails に記録 → トークン発行 → LINE通知 + not_important → mail_emails に記録（通知なし） +``` + +### 優先順位 + +**アドレスルール > ドメインルール > LLM判断**（具体的なほど優先） + +### LLMに渡す過去フィードバック集計 + +トークン肥大化を防ぐため、生の履歴ではなく集計値を渡す： + +``` +送信者: promo@example.com (example.com) +過去に通知したメール: 8通 + - 重要だった: 2回 + - 普通のメール: 5回 + - 今後通知しない: 0回 + - フィードバック未提供: 1回 + +件名: ××のご案内 +本文冒頭: ...（200字） +``` + +--- + +## データモデル + +### `mail_senders`（送信者ルール） + +| フィールド | 型 | 説明 | +|---|---|---| +| id | AutoField | | +| email | EmailField (nullable) | アドレス指定 例: info@amazon.co.jp | +| domain | CharField (nullable) | ドメイン指定 例: amazon.co.jp | +| rule | CharField | 'never_notify' のみ（MVP） | +| note | TextField | メモ（「○○の営業メール」など） | +| created_at | DateTimeField | | +| updated_at | DateTimeField | | + +- `email` か `domain` のどちらか一方のみ設定する +- アドレスルールとドメインルールが両方存在する場合、アドレスが優先 + +### `mail_emails`（通知メール記録） + +| フィールド | 型 | 説明 | +|---|---|---| +| id | AutoField | | +| account | CharField | 'xserver' / 'gmail' / 'hotmail' | +| message_id | CharField (unique) | メールのMessage-ID（重複防止） | +| sender_email | EmailField | | +| sender_domain | CharField | | +| subject | CharField | | +| body_preview | TextField | 本文冒頭200字程度 | +| received_at | DateTimeField | | +| llm_verdict | CharField | 'important' / 'not_important' | +| notified_at | DateTimeField (nullable) | LINE通知日時 | +| feedback | CharField (nullable) | 'important' / 'not_important' / 'never_notify' | +| feedback_at | DateTimeField (nullable) | フィードバック日時 | + +### `mail_notification_tokens`（フィードバック用トークン） + +| フィールド | 型 | 説明 | +|---|---|---| +| id | AutoField | | +| email | OneToOneField(MailEmail) | 1メール1トークン | +| token | UUIDField (unique) | 推測不可能なランダムUUID | +| created_at | DateTimeField | | + +- 有効期限なし +- フィードバック変更可能（同じURLで何度でも再選択できる） + +--- + +## API エンドポイント（WindmillからDjangoへ） + +認証: リクエストヘッダー `X-API-Key: ` で行う。 + +| メソッド | URL | 用途 | +|---|---|---| +| GET | `/api/mail/sender-rule/` | 送信者ルール確認 | +| GET | `/api/mail/sender-context/` | LLM用フィードバック集計取得 | +| POST | `/api/mail/emails/` | メール記録＋トークン発行 | + +### GET `/api/mail/sender-rule/` + +クエリパラメータ: `?email=promo@example.com&domain=example.com` + +レスポンス例: +```json +{ + "matched": true, + "rule": "never_notify", + "match_type": "domain" +} +``` + +### GET `/api/mail/sender-context/` + +クエリパラメータ: `?email=promo@example.com&domain=example.com` + +レスポンス例: +```json +{ + "total_notified": 8, + "important": 2, + "not_important": 5, + "never_notify": 0, + "no_feedback": 1 +} +``` + +### POST `/api/mail/emails/` + +リクエストボディ: +```json +{ + "account": "gmail", + "message_id": "", + "sender_email": "promo@example.com", + "sender_domain": "example.com", + "subject": "○○のご案内", + "body_preview": "...", + "received_at": "2026-02-21T10:30:00Z", + "llm_verdict": "important" +} +``` + +レスポンス（important の場合のみトークンを返す）: +```json +{ + "id": 42, + "feedback_url": "https://keinafarm.net/mail/feedback/550e8400-e29b-41d4-a716-446655440000" +} +``` + +--- + +## フロントエンド画面 + +### 1. フィードバックページ（`/mail/feedback/{token}`） + +- 認証不要（LINEからタップ一発でアクセス） +- 表示内容: 送信者、件名、受信日時、本文冒頭 +- 現在のフィードバック状態を表示（変更済みの場合、どれを選んでいるか分かるように） +- フィードバック選択肢: + 1. ✅ 重要だった + 2. 📧 普通のメール + 3. 🔇 今後通知しない + +「今後通知しない」を選ぶと展開： +``` +○ このアドレスだけ（promo@example.com） +○ このドメインごと（example.com） +[確定する] +``` + +- 送信後: 「受け付けました」と表示 +- 再選択可能（同じURLを再度開いて変更できる） + +「今後通知しない」でフィードバック確定時、`mail_senders` にルールを自動追加する。 + +### 2. ルール管理ページ（`/mail/rules/`） + +ナビゲーションにメニュー追加。 + +表示内容: +- ルール一覧テーブル（種別、値、メモ、設定日、削除ボタン） +- 手動でルール追加フォーム（アドレスまたはドメイン、メモを入力） + +--- + +## 実装順序 + +1. **DBテーブル定義・マイグレーション**（Django apps/mail/） +2. **Windmill向けDjango API**（sender-rule, sender-context, emails POST） +3. **フィードバックページ**（/mail/feedback/{token}） +4. **ルール管理ページ**（/mail/rules/） +5. **WindmillのIMAPポーリングスクリプト**（まず1アカウントから） +6. **LLM判定ロジック**（Claude API呼び出し、集計文脈付き） +7. **LINE通知**（フィードバックURL付き） +8. **残りのメールアカウントを追加** diff --git a/frontend/src/app/mail/feedback/[token]/page.tsx b/frontend/src/app/mail/feedback/[token]/page.tsx new file mode 100644 index 0000000..7142845 --- /dev/null +++ b/frontend/src/app/mail/feedback/[token]/page.tsx @@ -0,0 +1,271 @@ +'use client'; + +import { useState, useEffect } from 'react'; +import { useParams } from 'next/navigation'; + +interface MailEmailFeedback { + id: number; + sender_email: string; + sender_domain: string; + subject: string; + body_preview: string; + received_at: string; + feedback: 'important' | 'not_important' | 'never_notify' | null; +} + +const API_URL = process.env.NEXT_PUBLIC_API_URL || 'http://localhost:8000'; + +export default function FeedbackPage() { + const params = useParams(); + const token = params.token as string; + + const [email, setEmail] = useState(null); + const [loading, setLoading] = useState(true); + const [error, setError] = useState(null); + + const [selected, setSelected] = useState<'important' | 'not_important' | 'never_notify' | null>(null); + const [showScopeChoice, setShowScopeChoice] = useState(false); + const [scope, setScope] = useState<'address' | 'domain'>('address'); + const [submitting, setSubmitting] = useState(false); + const [submitted, setSubmitted] = useState(false); + + useEffect(() => { + const fetchEmail = async () => { + try { + const res = await fetch(`${API_URL}/api/mail/feedback/${token}/`); + if (!res.ok) { + if (res.status === 404) { + setError('このフィードバックリンクは無効です'); + } else { + setError('メール情報の取得に失敗しました'); + } + return; + } + const data = await res.json(); + setEmail(data); + if (data.feedback) { + setSelected(data.feedback); + if (data.feedback === 'never_notify') { + setShowScopeChoice(true); + } + } + } catch { + setError('サーバーに接続できませんでした'); + } finally { + setLoading(false); + } + }; + fetchEmail(); + }, [token]); + + const handleSelect = (value: 'important' | 'not_important' | 'never_notify') => { + setSelected(value); + setShowScopeChoice(value === 'never_notify'); + setSubmitted(false); + if (value !== 'never_notify') { + submitFeedback(value, undefined); + } + }; + + const submitFeedback = async ( + feedback: 'important' | 'not_important' | 'never_notify', + feedbackScope: 'address' | 'domain' | undefined + ) => { + setSubmitting(true); + try { + const body: Record = { feedback }; + if (feedbackScope) body.scope = feedbackScope; + + const res = await fetch(`${API_URL}/api/mail/feedback/${token}/`, { + method: 'POST', + headers: { 'Content-Type': 'application/json' }, + body: JSON.stringify(body), + }); + if (!res.ok) throw new Error('送信に失敗しました'); + setSubmitted(true); + setShowScopeChoice(false); + setEmail((prev) => (prev ? { ...prev, feedback } : prev)); + } catch { + setError('送信に失敗しました。もう一度お試しください。'); + } finally { + setSubmitting(false); + } + }; + + const handleNeverNotifyConfirm = () => { + submitFeedback('never_notify', scope); + }; + + const formatDate = (iso: string) => { + const d = new Date(iso); + return d.toLocaleString('ja-JP', { + year: 'numeric', month: '2-digit', day: '2-digit', + hour: '2-digit', minute: '2-digit', + }); + }; + + if (loading) { + return ( +
+

読み込み中...

+
+ ); + } + + if (error && !email) { + return ( +
+
+

{error}

+
+
+ ); + } + + if (!email) return null; + + const feedbackLabel = { + important: '✅ 重要だった', + not_important: '📧 普通のメール', + never_notify: '🔇 今後通知しない', + }; + + return ( +
+
+ + {/* ヘッダー */} +
+

KeinaSystem

+

メール通知フィードバック

+
+ + {/* メール情報 */} +
+
+ 送信者 + {email.sender_email} +
+
+ 件名 + {email.subject} +
+
+ 受信 + {formatDate(email.received_at)} +
+ {email.body_preview && ( +
+ {email.body_preview} +
+ )} +
+ + {/* フィードバック操作 */} +
+ {submitted && ( +
+ 受け付けました +
+ )} + + {error && ( +
+ {error} +
+ )} + + {/* 現在のフィードバック表示 */} + {email.feedback && !submitted && ( +

+ 現在の評価: {feedbackLabel[email.feedback]} （変更できます） +

+ )} + +
+ {/* 重要だった */} + + + {/* 普通のメール */} + + + {/* 今後通知しない */} + + + {/* 今後通知しない → スコープ選択 */} + {showScopeChoice && ( +
+

通知をやめる範囲を選んでください

+ + + +
+ )} +
+
+
+
+ ); +} diff --git a/frontend/src/app/mail/rules/page.tsx b/frontend/src/app/mail/rules/page.tsx new file mode 100644 index 0000000..6f09934 --- /dev/null +++ b/frontend/src/app/mail/rules/page.tsx @@ -0,0 +1,218 @@ +'use client'; + +import { useState, useEffect } from 'react'; +import { useRouter } from 'next/navigation'; +import { Trash2, Plus, Mail } from 'lucide-react'; +import Navbar from '@/components/Navbar'; +import { api } from '@/lib/api'; + +interface MailSender { + id: number; + type: 'address' | 'domain'; + email: string | null; + domain: string | null; + rule: 'never_notify'; + note: string; + created_at: string; +} + +export default function MailRulesPage() { + const router = useRouter(); + const [senders, setSenders] = useState([]); + const [loading, setLoading] = useState(true); + const [error, setError] = useState(null); + + // 追加フォーム + const [addType, setAddType] = useState<'address' | 'domain'>('address'); + const [addValue, setAddValue] = useState(''); + const [addNote, setAddNote] = useState(''); + const [adding, setAdding] = useState(false); + const [addError, setAddError] = useState(null); + + useEffect(() => { + fetchSenders(); + }, []); + + const fetchSenders = async () => { + setLoading(true); + setError(null); + try { + const res = await api.get('/mail/senders/'); + setSenders(res.data); + } catch { + setError('ルール一覧の取得に失敗しました'); + } finally { + setLoading(false); + } + }; + + const handleDelete = async (id: number) => { + if (!confirm('このルールを削除してもよいですか？')) return; + try { + await api.delete(`/mail/senders/${id}/`); + setSenders((prev) => prev.filter((s) => s.id !== id)); + } catch { + alert('削除に失敗しました'); + } + }; + + const handleAdd = async (e: React.FormEvent) => { + e.preventDefault(); + setAddError(null); + + if (!addValue.trim()) { + setAddError('値を入力してください'); + return; + } + + setAdding(true); + try { + const body: Record = { + rule: 'never_notify', + note: addNote.trim(), + }; + if (addType === 'address') { + body.email = addValue.trim(); + } else { + body.domain = addValue.trim(); + } + + const res = await api.post('/mail/senders/', body); + setSenders((prev) => [res.data, ...prev]); + setAddValue(''); + setAddNote(''); + } catch (err: unknown) { + if (err && typeof err === 'object' && 'response' in err) { + const axiosError = err as { response?: { data?: Record } }; + const data = axiosError.response?.data; + if (data) { + const messages = Object.values(data).flat().join(' '); + setAddError(messages || '追加に失敗しました'); + } else { + setAddError('追加に失敗しました'); + } + } else { + setAddError('追加に失敗しました'); + } + } finally { + setAdding(false); + } + }; + + const formatDate = (iso: string) => { + const d = new Date(iso); + return d.toLocaleDateString('ja-JP', { year: 'numeric', month: '2-digit', day: '2-digit' }); + }; + + return ( +
+ +
+
+ +

メール通知ルール

+
+ + {/* 追加フォーム */} +
+

ルールを追加

+
+
+ + setAddValue(e.target.value)} + placeholder={addType === 'address' ? 'promo@example.com' : 'example.com'} + className="flex-1 px-3 py-2 border border-gray-300 rounded-md text-sm focus:outline-none focus:ring-2 focus:ring-green-500" + /> +
+
+ setAddNote(e.target.value)} + placeholder="メモ（任意）例: ○○の営業メール" + className="flex-1 px-3 py-2 border border-gray-300 rounded-md text-sm focus:outline-none focus:ring-2 focus:ring-green-500" + /> + +
+ {addError && ( +

{addError}

+ )} +
+
+ + {/* ルール一覧 */} +
+
+

+ 通知しない送信者一覧 + {!loading && （{senders.length}件）} +

+
+ + {loading && ( +
読み込み中...
+ )} + + {error && ( +
{error}
+ )} + + {!loading && !error && senders.length === 0 && ( +
+ 登録されているルールはありません +
+ )} + + {!loading && !error && senders.length > 0 && ( +
+ {senders.map((sender) => ( +
+ + {sender.type === 'address' ? 'アドレス' : 'ドメイン'} + +
+

+ {sender.email || sender.domain} +

+ {sender.note && ( +

{sender.note}

+ )} +
+ {formatDate(sender.created_at)} + +
+ ))} +
+ )} +
+
+
+ ); +} diff --git a/frontend/src/components/Navbar.tsx b/frontend/src/components/Navbar.tsx index cd149bc..3d74cdc 100644 --- a/frontend/src/components/Navbar.tsx +++ b/frontend/src/components/Navbar.tsx @@ -1,7 +1,7 @@ 'use client'; import { useRouter, usePathname } from 'next/navigation'; -import { LogOut, Wheat, MapPin, FileText, Upload, LayoutDashboard } from 'lucide-react'; +import { LogOut, Wheat, MapPin, FileText, Upload, LayoutDashboard, Mail } from 'lucide-react'; import { logout } from '@/lib/api'; export default function Navbar() { @@ -78,6 +78,17 @@ export default function Navbar() { データ取込 +
diff --git a/frontend/src/types/index.ts b/frontend/src/types/index.ts index b076ef7..1745c6c 100644 --- a/frontend/src/types/index.ts +++ b/frontend/src/types/index.ts @@ -55,3 +55,23 @@ export interface Plan { variety_name: string; notes: string | null; } + +export interface MailSender { + id: number; + type: 'address' | 'domain'; + email: string | null; + domain: string | null; + rule: 'never_notify'; + note: string; + created_at: string; +} + +export interface MailEmailFeedback { + id: number; + sender_email: string; + sender_domain: string; + subject: string; + body_preview: string; + received_at: string; + feedback: 'important' | 'not_important' | 'never_notify' | null; +}