Gmail AI助手：邮件Agent架构

import refrom collections import Counter INTENT_KEYWORDS = {    '询问': ['请问', '能否', '是否', '怎样', 'how'],    '催促': ['尽快', '截止', 'due', '催一下', '今天内'],    '通知': ['通知', '告知', '安排', '会议', 'schedule'],    '感谢': ['谢谢', '感谢', 'thanks', 'appreciate'],    '闲聊': ['哈哈', '最近怎么样', '有空'],} STYLE_OPENERS = {    '正式': {        '询问': '您好，感谢您的来信。关于您提到的问题，',        '催促': '您好，收到您的提醒，我和团队正在处理，',        '通知': '您好，已收到通知，我会尽快安排，',        '感谢': '您好，不客气，很高兴能帮上忙，',        '未知': '您好，来信已收到，',    },    '简洁': {        '询问': '收到，关于这个问题，',        '催促': '已收到提醒，正在处理，',        '通知': '通知收到，会跟进，',        '感谢': '不客气！很高兴帮忙，',        '未知': '收到，',    },} class Email:    def __init__(self, sender, subject, body, thread_count=1):        self.sender = sender        self.subject = subject        self.body = body        self.thread_count = thread_count     def digest(self, max_sentences=2):        sentences = [s.strip() for s in re.split(r'[。！？.!?\n]', self.body) if len(s.strip()) > 5]        scored = []        keywords = ['请', '尽快', '谢谢', '会议', '通知', '确认', '截止']        for idx, sent in enumerate(sentences):            score = 0.0            score += 0.4 * min(1.0, len(sent) / 40.0)            score += 0.3 * (1.0 if idx < 3 else 0.15)            score += 0.3 * (1.0 if any(k in sent for k in keywords) else 0.05)            scored.append((score, sent))        scored.sort(reverse=True)        return ' '.join(s for _, s in scored[:max_sentences])     def classify_intent(self):        text = (self.subject + self.body).lower()        votes = Counter()        for intent, kws in INTENT_KEYWORDS.items():            hits = sum(1 for kw in kws if kw.lower() in text)            if hits > 0:                votes[intent] += hits        if not votes:            return '未知'        top_intent, top_cnt = votes.most_common(1)[0]        total = sum(votes.values())        return top_intent if top_cnt / total >= 0.4 else '多意图混合'     def draft_reply(self, style='简洁'):        intent = self.classify_intent()        opener = STYLE_OPENERS[style].get(intent, STYLE_OPENERS[style]['未知'])        bridge = self.digest(1)        return opener + bridge + '，我会尽快跟进处理。'  def run_agent_pipeline(emails, style='简洁'):    results = []    for email in emails:        results.append({            'from': email.sender,            'digest': email.digest(),            'intent': email.classify_intent(),            'draft': email.draft_reply(style),        })    return results  def main():    emails = [        Email('alice@example.com', '项目进度询问',              '请问你们的最新版本什么时候能上线？客户在等，麻烦今天内确认一下，谢谢！'),        Email('bob@example.com', '会议安排',              '通知下周五下午三点召开项目周会，请提前准备材料。'),        Email('carlo@example.com', '闲聊',              '哈哈，最近怎么样？有空一起喝咖啡聊聊近况吧！'),    ]    for item in run_agent_pipeline(emails):        print(item['from'], '| 摘要:', item['digest'])        print('  意图:', item['intent'], '| 草稿:', item['draft'])  if __name__ == '__main__':    main()