From cfefe4f738301701535ba1fa58da0f0f3f0273c7 Mon Sep 17 00:00:00 2001
From: Xiyuan Chen <52963600+GareArc@users.noreply.github.com>
Date: Wed, 20 Aug 2025 00:38:14 -0700
Subject: [PATCH] Feat: Education (#24208)

Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
---
 api/controllers/console/workspace/account.py  | 11 ++++-
 api/controllers/inner_api/mail.py             | 45 ++++++++++++-------
 api/controllers/inner_api/wraps.py            | 16 +++++++
 api/services/billing_service.py               |  2 +-
 api/services/enterprise/mail_service.py       | 18 --------
 ..._enterprise_task.py => mail_inner_task.py} |  2 +-
 6 files changed, 56 insertions(+), 38 deletions(-)
 delete mode 100644 api/services/enterprise/mail_service.py
 rename api/tasks/{mail_enterprise_task.py => mail_inner_task.py} (89%)

diff --git a/api/controllers/console/workspace/account.py b/api/controllers/console/workspace/account.py
index 4d5357cd1..3f6d6bf54 100644
--- a/api/controllers/console/workspace/account.py
+++ b/api/controllers/console/workspace/account.py
@@ -1,3 +1,5 @@
+from datetime import datetime
+
 import pytz
 from flask import request
 from flask_login import current_user
@@ -327,6 +329,9 @@ class EducationVerifyApi(Resource):
 class EducationApi(Resource):
     status_fields = {
         "result": fields.Boolean,
+        "is_student": fields.Boolean,
+        "expire_at": TimestampField,
+        "allow_refresh": fields.Boolean,
     }
 
     @setup_required
@@ -354,7 +359,11 @@ class EducationApi(Resource):
     def get(self):
         account = current_user
 
-        return BillingService.EducationIdentity.is_active(account.id)
+        res = BillingService.EducationIdentity.status(account.id)
+        # convert expire_at to UTC timestamp from isoformat
+        if res and "expire_at" in res:
+            res["expire_at"] = datetime.fromisoformat(res["expire_at"]).astimezone(pytz.utc)
+        return res
 
 
 class EducationAutoCompleteApi(Resource):
diff --git a/api/controllers/inner_api/mail.py b/api/controllers/inner_api/mail.py
index ce3373d65..7b96f88f5 100644
--- a/api/controllers/inner_api/mail.py
+++ b/api/controllers/inner_api/mail.py
@@ -1,27 +1,38 @@
-from flask_restful import (
-    Resource,  # type: ignore
-    reqparse,
-)
+from flask_restful import Resource, reqparse
 
 from controllers.console.wraps import setup_required
 from controllers.inner_api import api
-from controllers.inner_api.wraps import enterprise_inner_api_only
-from services.enterprise.mail_service import DifyMail, EnterpriseMailService
+from controllers.inner_api.wraps import billing_inner_api_only, enterprise_inner_api_only
+from tasks.mail_inner_task import send_inner_email_task
+
+_mail_parser = reqparse.RequestParser()
+_mail_parser.add_argument("to", type=str, action="append", required=True)
+_mail_parser.add_argument("subject", type=str, required=True)
+_mail_parser.add_argument("body", type=str, required=True)
+_mail_parser.add_argument("substitutions", type=dict, required=False)
 
 
-class EnterpriseMail(Resource):
-    @setup_required
-    @enterprise_inner_api_only
+class BaseMail(Resource):
+    """Shared logic for sending an inner email."""
+
     def post(self):
-        parser = reqparse.RequestParser()
-        parser.add_argument("to", type=str, action="append", required=True)
-        parser.add_argument("subject", type=str, required=True)
-        parser.add_argument("body", type=str, required=True)
-        parser.add_argument("substitutions", type=dict, required=False)
-        args = parser.parse_args()
-
-        EnterpriseMailService.send_mail(DifyMail(**args))
+        args = _mail_parser.parse_args()
+        send_inner_email_task.delay(
+            to=args["to"],
+            subject=args["subject"],
+            body=args["body"],
+            substitutions=args["substitutions"],
+        )
         return {"message": "success"}, 200
 
 
+class EnterpriseMail(BaseMail):
+    method_decorators = [setup_required, enterprise_inner_api_only]
+
+
+class BillingMail(BaseMail):
+    method_decorators = [setup_required, billing_inner_api_only]
+
+
 api.add_resource(EnterpriseMail, "/enterprise/mail")
+api.add_resource(BillingMail, "/billing/mail")
diff --git a/api/controllers/inner_api/wraps.py b/api/controllers/inner_api/wraps.py
index 9e7b3d4f2..c5aa318f5 100644
--- a/api/controllers/inner_api/wraps.py
+++ b/api/controllers/inner_api/wraps.py
@@ -10,6 +10,22 @@ from extensions.ext_database import db
 from models.model import EndUser
 
 
+def billing_inner_api_only(view):
+    @wraps(view)
+    def decorated(*args, **kwargs):
+        if not dify_config.INNER_API:
+            abort(404)
+
+        # get header 'X-Inner-Api-Key'
+        inner_api_key = request.headers.get("X-Inner-Api-Key")
+        if not inner_api_key or inner_api_key != dify_config.INNER_API_KEY:
+            abort(401)
+
+        return view(*args, **kwargs)
+
+    return decorated
+
+
 def enterprise_inner_api_only(view):
     @wraps(view)
     def decorated(*args, **kwargs):
diff --git a/api/services/billing_service.py b/api/services/billing_service.py
index 476fce005..40d45af37 100644
--- a/api/services/billing_service.py
+++ b/api/services/billing_service.py
@@ -123,7 +123,7 @@ class BillingService:
             return BillingService._send_request("GET", "/education/verify", params=params)
 
         @classmethod
-        def is_active(cls, account_id: str):
+        def status(cls, account_id: str):
             params = {"account_id": account_id}
             return BillingService._send_request("GET", "/education/status", params=params)
 
diff --git a/api/services/enterprise/mail_service.py b/api/services/enterprise/mail_service.py
deleted file mode 100644
index 630e7679a..000000000
--- a/api/services/enterprise/mail_service.py
+++ /dev/null
@@ -1,18 +0,0 @@
-from pydantic import BaseModel
-
-from tasks.mail_enterprise_task import send_enterprise_email_task
-
-
-class DifyMail(BaseModel):
-    to: list[str]
-    subject: str
-    body: str
-    substitutions: dict[str, str] = {}
-
-
-class EnterpriseMailService:
-    @classmethod
-    def send_mail(cls, mail: DifyMail):
-        send_enterprise_email_task.delay(
-            to=mail.to, subject=mail.subject, body=mail.body, substitutions=mail.substitutions
-        )
diff --git a/api/tasks/mail_enterprise_task.py b/api/tasks/mail_inner_task.py
similarity index 89%
rename from api/tasks/mail_enterprise_task.py
rename to api/tasks/mail_inner_task.py
index 9c80da06e..101f7ebaa 100644
--- a/api/tasks/mail_enterprise_task.py
+++ b/api/tasks/mail_inner_task.py
@@ -11,7 +11,7 @@ from libs.email_i18n import get_email_i18n_service
 
 
 @shared_task(queue="mail")
-def send_enterprise_email_task(to: list[str], subject: str, body: str, substitutions: Mapping[str, str]):
+def send_inner_email_task(to: list[str], subject: str, body: str, substitutions: Mapping[str, str]):
     if not mail.is_inited():
         return