python: Mediator Pattern

# encoding: utf-8# 版权所有  2026 ©涂聚文有限公司™ ®# 许可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎# 描述：中介者模式（Mediator Pattern）# Author    : geovindu,Geovin Du 涂聚文.# IDE       : PyCharm 2024.3.6 python 3.11# os        : windows 10# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j# Datetime  : 2026/2/27 22:24# User      :  geovindu# Product   : PyCharm# Project   : pydesginpattern# File      : Message.pyfrom abc import ABC, abstractmethodfrom dataclasses import dataclass# ====================== 新增：消息对象（封装消息属性） ======================@dataclassclass Message:    """    消息实体类，记录消息核心信息    """    sender: str          # 发送者名称    receiver: str        # 接收者名称（或"全体"）    content: str         # 消息内容    is_confirmed: bool = False  # 是否已确认收到    send_mode: str = "auto"     # 发送模式：auto（自动）/ manual（人为）

# encoding: utf-8# 版权所有  2026 ©涂聚文有限公司™ ®# 许可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎# 描述：中介者模式（Mediator Pattern）# Author    : geovindu,Geovin Du 涂聚文.# IDE       : PyCharm 2024.3.6 python 3.11# os        : windows 10# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j# Datetime  : 2026/2/27 22:05# User      :  geovindu# Product   : PyCharm# Project   : pydesginpattern# File      : JewelryMediator.pyfrom abc import ABC, abstractmethod# ====================== 第一步：定义抽象中介者 ======================class JewelryMediator(ABC):    """    珠宝交易中介者抽象类，定义所有交互接口    """    @abstractmethod    def register_buyer(self, buyer):        """        注册买家        :param buyer:        :return:        """        pass    @abstractmethod    def register_seller(self, seller):        """        注册卖家        :param seller:        :return:        """        pass    @abstractmethod    def register_appraiser(self, appraiser):        """        注册鉴定师        :param appraiser:        :return:        """        pass    @abstractmethod    def notify(self, sender, message):        """        核心方法：接收一方的消息，转发给相关方        :param sender:        :param message:        :return:        """        pass

# encoding: utf-8# 版权所有  2026 ©涂聚文有限公司™ ®# 许可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎# 描述：中介者模式（Mediator Pattern）# Author    : geovindu,Geovin Du 涂聚文.# IDE       : PyCharm 2024.3.6 python 3.11# os        : windows 10# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j# Datetime  : 2026/2/27 22:06# User      :  geovindu# Product   : PyCharm# Project   : pydesginpattern# File      : Colleague.pyfrom abc import ABC, abstractmethodfrom MediatorPattern.JewelryMediator import JewelryMediatorfrom MediatorPattern.Message import Message# ====================== 第二步：定义抽象同事类 ======================class Colleague(ABC):    """    所有参与交易的角色的抽象父类    """    def __init__(self, mediator: JewelryMediator, name):        """        :param mediator:        :param name:        """        self.mediator = mediator  # 持有中介者引用        self.name = name        self.received_messages = []  # 存储收到的未处理消息    @abstractmethod    def send_message(self, message: Message):        """        发送消息（通过中介者）        :param message:        :return:        """        pass    @abstractmethod    def receive_message(self, message: Message):        """        接收来自中介者的消息        :param message:        :return:        """        pass    def confirm_message(self, msg_index: int):        """        人为确认收到某条消息（通过索引指定）        :param msg_index:        :return:        """        if 0 <= msg_index < len(self.received_messages):            msg = self.received_messages[msg_index]            msg.is_confirmed = True            print(f"\n【{self.name}】已确认收到消息：{msg.content}")            return msg        else:            print(f"\n【{self.name}】消息索引错误，无此消息")            return None    def manual_send(self, msg_index: int, reply_content: str):        """        人为触发发送回复（需先确认消息）        :param msg_index:        :param reply_content:        :return:        """        confirmed_msg = self.confirm_message(msg_index)        if confirmed_msg and confirmed_msg.send_mode == "manual":            # 构造回复消息            reply_msg = Message(                sender=self.name,                receiver=confirmed_msg.sender,                content=reply_content,                send_mode="manual"            )            self.send_message(reply_msg)

# encoding: utf-8# 版权所有  2026 ©涂聚文有限公司™ ®# 许可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎# 描述：中介者模式（Mediator Pattern）# Author    : geovindu,Geovin Du 涂聚文.# IDE       : PyCharm 2024.3.6 python 3.11# os        : windows 10# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j# Datetime  : 2026/2/27 22:09# User      :  geovindu# Product   : PyCharm# Project   : pydesginpattern# File      : Buyer.pyfrom MediatorPattern.Colleague import Colleaguefrom MediatorPattern.Message import Message# ====================== 第三步：实现具体同事类 ======================class Buyer(Colleague):    """    买家：默认人为模式（需手动回复）    """    def send_message(self, message: Message):        """        :param message:        :return:        """        print(f"\n【买家 {self.name}】{'自动'if message.send_mode=='auto'else'手动'}发送：{message.content}")        self.mediator.notify(self, message)    def receive_message(self, message: Message):        """        买家收到消息后暂存，默认需人为确认        """        message.send_mode = "manual"  # 买家消息强制人为模式        self.received_messages.append(message)        print(f"【买家 {self.name}】收到新消息（待确认）：{message.content}")# encoding: utf-8# 版权所有  2026 ©涂聚文有限公司™ ®# 许可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎# 描述：中介者模式（Mediator Pattern）# Author    : geovindu,Geovin Du 涂聚文.# IDE       : PyCharm 2024.3.6 python 3.11# os        : windows 10# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j# Datetime  : 2026/2/27 22:10# User      :  geovindu# Product   : PyCharm# Project   : pydesginpattern# File      : Seller.pyfrom MediatorPattern.Colleague import Colleaguefrom MediatorPattern.Message import Message# ====================== 第三步：实现具体同事类 ======================class Seller(Colleague):    """    卖家：混合模式（出售消息自动，回复消息人为）    """    def send_message(self, message: Message):        """        :param message:        :return:        """        print(f"\n【卖家 {self.name}】{'自动'if message.send_mode == 'auto'else'手动'}发送：{message.content}")        self.mediator.notify(self, message)    def receive_message(self, message: Message):        """        卖家收到求购消息需人为确认，收到鉴定结果自动处理"        :param message:        :return:        """""        if "求购" in message.content:            message.send_mode = "manual"  # 求购消息→人为模式        else:            message.send_mode = "auto"  # 鉴定结果→自动模式        self.received_messages.append(message)        print(f"【卖家 {self.name}】收到新消息（{message.send_mode}模式）：{message.content}")# encoding: utf-8# 版权所有  2026 ©涂聚文有限公司™ ®# 许可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎# 描述：中介者模式（Mediator Pattern）# Author    : geovindu,Geovin Du 涂聚文.# IDE       : PyCharm 2024.3.6 python 3.11# os        : windows 10# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j# Datetime  : 2026/2/27 22:12# User      :  geovindu# Product   : PyCharm# Project   : pydesginpattern# File      : Appraiser.pyfrom MediatorPattern.Colleague import Colleaguefrom MediatorPattern.Message import Message# ====================== 第三步：实现具体同事类 ======================class Appraiser(Colleague):    """    鉴定师：默认自动模式（收到请求自动出结果）    """    def send_message(self, message: Message):        """        :param message:        :return:        """        print(f"\n【鉴定师 {self.name}】{'自动'if message.send_mode == 'auto'else'手动'}发送：{message.content}")        self.mediator.notify(self, message)    def receive_message(self, message: Message):        """        鉴定师收到请求后自动处理        :param message:        :return:        """        message.send_mode = "auto"  # 鉴定请求强制自动模式        self.received_messages.append(message)        print(f"【鉴定师 {self.name}】收到新消息（自动处理）：{message.content}")        # 自动模式：立即生成鉴定结果并发送（修复索引错误）        if message.send_mode == "auto" and "请鉴定" in message.content:            # 修复点1：优化物品名称提取逻辑，增加异常处理            try:                # 先按"的"分割（更符合消息格式），再提取物品名称                # 消息格式：请鉴定卖家王老板的天然翡翠手镯（A货），价格5万元                jewelry_part = message.content.split("的")[-1]  # 取"的"后面的部分                # 去掉价格部分，只保留珠宝名称                if "，价格" in jewelry_part:                    jewelry_name = jewelry_part.split("，价格")[0]                else:                    jewelry_name = jewelry_part            except IndexError:                # 分割失败时使用默认名称，避免程序崩溃                jewelry_name = "未知珠宝"            # 生成鉴定结果（使用提取到的珠宝名称）            appraisal_result = f"鉴定结果：{jewelry_name}为正品，市场价值5万元"            appraisal_msg = Message(                sender=self.name,                receiver="全体",                content=appraisal_result,                send_mode="auto"            )            self.send_message(appraisal_msg)

# encoding: utf-8# 版权所有  2026 ©涂聚文有限公司™ ®# 许可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎# 描述：中介者模式（Mediator Pattern）# Author    : geovindu,Geovin Du 涂聚文.# IDE       : PyCharm 2024.3.6 python 3.11# os        : windows 10# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j# Datetime  : 2026/2/27 22:13# User      :  geovindu# Product   : PyCharm# Project   : pydesginpattern# File      : JewelryExchange.pyfrom MediatorPattern.JewelryMediator import JewelryMediatorfrom MediatorPattern.Buyer import Buyerfrom MediatorPattern.Seller import Sellerfrom MediatorPattern.Appraiser import Appraiserfrom MediatorPattern.Message import Message# ====================== 第四步：实现具体中介者 ======================class JewelryExchange(JewelryMediator):    """    珠宝交易所（具体中介者），协调所有角色的交互    """    def __init__(self):        """        """        self.buyers = []       # 注册的买家        self.sellers = []      # 注册的卖家        self.appraisers = []   # 注册的鉴定师    def register_buyer(self, buyer):        """        :param buyer:        :return:        """        self.buyers.append(buyer)    def register_seller(self, seller):        """        :param seller:        :return:        """        self.sellers.append(seller)    def register_appraiser(self, appraiser):        """        :param appraiser:        :return:        """        self.appraisers.append(appraiser)    def notify(self, sender, message: Message):        """        根据发送者和消息内容转发，适配Message对象        :param sender:        :param message:        :return:        """        # 1. 买家求购 → 转发给所有卖家        if isinstance(sender, Buyer) and "求购" in message.content:            for seller in self.sellers:                seller.receive_message(Message(                    sender=sender.name,                    receiver=seller.name,                    content=f"买家{sender.name}：{message.content}"                ))        # 2. 卖家出售 → 转发给所有买家 + 通知鉴定师        elif isinstance(sender, Seller) and "出售" in message.content:            # 转发给买家            for buyer in self.buyers:                buyer.receive_message(Message(                    sender=sender.name,                    receiver=buyer.name,                    content=f"卖家{sender.name}：{message.content}"                ))            # 通知鉴定师            for appraiser in self.appraisers:                appraiser.receive_message(Message(                    sender=sender.name,                    receiver=appraiser.name,                    content=f"请鉴定卖家{sender.name}的{message.content.split('：')[1]}"                ))        # 3. 鉴定结果/手动回复 → 转发给对应角色        elif isinstance(sender, Appraiser) or message.send_mode == "manual":            # 转发给买家            for buyer in self.buyers:                buyer.receive_message(Message(                    sender=sender.name,                    receiver=buyer.name,                    content=f"{message.sender}：{message.content}"                ))            # 转发给卖家            for seller in self.sellers:                seller.receive_message(Message(                    sender=sender.name,                    receiver=seller.name,                    content=f"{message.sender}：{message.content}"                ))

# encoding: utf-8# 版权所有  2026 ©涂聚文有限公司™ ®# 许可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎# 描述：中介者模式（Mediator Pattern）# Author    : geovindu,Geovin Du 涂聚文.# IDE       : PyCharm 2024.3.6 python 3.11# os        : windows 10# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  Oracle 21c Neo4j# Datetime  : 2026/2/27 22:19# User      :  geovindu# Product   : PyCharm# Project   : pydesginpattern# File      : MediatorBll.pyfrom MediatorPattern.Buyer import Buyerfrom MediatorPattern.Seller import Sellerfrom MediatorPattern.Appraiser import Appraiserfrom MediatorPattern.JewelryExchange import JewelryExchangefrom MediatorPattern.Message import Message# ====================== 测试代码 ======================class MediatorBll(object):    """    """    def demo(self):        """        :return:        """        # 1. 创建中介者和角色        exchange = JewelryExchange()        buyer_zhang = Buyer(exchange, "张三")        seller_wang = Seller(exchange, "王老板")        appraiser_li = Appraiser(exchange, "李鉴定师")        exchange.register_buyer(buyer_zhang)        exchange.register_seller(seller_wang)        exchange.register_appraiser(appraiser_li)        # 2. 第一步：买家发送求购（人为模式，需确认后回复）        print("===== 第一步：买家发送求购消息 =====")        buy_msg = Message(            sender=buyer_zhang.name,            receiver="全体卖家",            content="求购：天然翡翠手镯（A货）",            send_mode="manual"        )        buyer_zhang.send_message(buy_msg)        # 3. 第二步：卖家收到求购消息，先确认，再手动回复出售消息        print("\n===== 第二步：卖家确认消息并手动回复 =====")        # 卖家确认第0条收到的消息        seller_wang.confirm_message(0)        # 卖家手动发送出售回复        sell_msg = Message(            sender=seller_wang.name,            receiver="全体买家",            content="出售：天然翡翠手镯（A货），价格5万元",            send_mode="manual"        )        seller_wang.send_message(sell_msg)        # 4. 第三步：买家收到出售消息，确认后手动出价        print("\n===== 第三步：买家确认消息并手动出价 =====")        # 买家确认第0条收到的消息（出售消息）        buyer_zhang.confirm_message(0)        # 买家手动发送出价回复        bid_msg = Message(            sender=buyer_zhang.name,            receiver="王老板",            content="出价：4.8万元购买该翡翠手镯",            send_mode="manual"        )        buyer_zhang.send_message(bid_msg)

# encoding: utf-8# 版权所有 2026 ©涂聚文有限公司™ ®# 许可信息查看：言語成了邀功盡責的功臣，還需要行爲每日來值班嗎# 描述：# Author    : geovindu,Geovin Du 涂聚文.# IDE       : PyCharm 2023.1 python 3.11# OS        : windows 10# database  : mysql 9.0 sql server 2019, postgreSQL 17.0  oracle 21c Neo4j# Datetime  : 2026/2/18 20:58# User      : geovindu# Product   : PyCharm# Project   : pydesginpattern# File      : main.py# explain   : 学习from bll.MementoBll import MementoBllfrom bll.CommandBll import CommandBllfrom bll.StateBll import StateBllfrom bll.TemplateMethodBll import TemplateMethodBllfrom bll.VisitorBll import VisitorBllfrom bll.StrategyBll import StrategyBllfrom bll.ObserveBll import ObserveBllfrom bll.MediatorBll import MediatorBllif __name__ == '__main__':    #实现备忘录模式（Memento Pattern）    #mementobll= MementoBll()    #mementobll.demo()    #命令模式（Command Pattern）    #commandBll= CommandBll()    #commandBll.demo()    # 状态模式 State Pattern    #stateBll =StateBll()    #stateBll.demo()    # 模板方法模式 Template Method Pattern    #templateMethodBll= TemplateMethodBll()    #templateMethodBll.demo()    # 访问者模式（Visitor Pattern）    #visitor = VisitorBll()    #visitor.demo()    # 策略模式（Strategy Pattern）    #strategyBll = StrategyBll()    #strategyBll.demo()    # 观察者模式（Observer Pattern）    #observeBll= ObserveBll()    #observeBll.demo()    # 中介者模式（Mediator Pattern）    mediatorBll=MediatorBll()    mediatorBll.demo()    print('hi,welcome geovindu.')