小明：最近在做一个项目，需要处理大量的招标文件，感觉有点手忙脚乱。你有没有什么好的建议？

小李：你是不是在用传统的文件管理方式？如果能引入一个消息管理中心，可能会更高效。

小明：消息管理中心？听起来挺专业的，具体是做什么的？

小李：消息管理中心是一个用来处理、分发和记录消息的系统。它可以帮你自动化处理招标文件的接收、解析、存储和通知，避免手动操作带来的错误。

小明：那怎么和招标文件结合起来呢？我需要一些具体的例子。

小李：我们可以设计一个流程：当招标文件上传到系统后，消息管理中心会接收到这个事件，然后触发一系列动作，比如解析文件内容、提取关键信息、保存到数据库，并发送通知给相关人员。

小明：听起来不错，但我对具体的实现不太了解。你能给我演示一下吗？

小李：当然可以。我们可以用Python来写一个简单的消息中心，再结合一个招标文件处理模块。

小明：好啊，那我们先从消息管理中心开始吧。

小李：首先，我们需要一个消息队列，比如RabbitMQ或者Kafka。这里我用RabbitMQ作为例子，因为它简单易用。

小明：那我得先安装RabbitMQ了。

小李：没错。你可以用pip安装pika库，它是Python中连接RabbitMQ的客户端。

小明：明白了。那消息管理中心的代码应该怎么写呢？

小李：我们可以创建一个消息生产者，用于将招标文件的信息发布到消息队列中。下面是一个简单的示例：

import pika

# 连接到RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 声明一个队列
channel.queue_declare(queue='bid_file')

# 发送一条消息
message = '招标文件已上传，文件名：example_bid.pdf'
channel.basic_publish(exchange='',
                      routing_key='bid_file',
                      body=message)

print(" [x] Sent '%s'" % message)
connection.close()
    

小明：这段代码看起来很基础，但确实能发送消息。那消费者部分呢？

小李：消费者负责接收消息并处理招标文件。下面是一个消费者示例：

import pika

def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
    # 这里可以添加处理招标文件的逻辑
    process_bid_file(body.decode())

def process_bid_file(file_info):
    # 模拟处理招标文件
    print(f"正在处理: {file_info}")
    # 可以在这里解析文件、提取信息、保存到数据库等

# 连接到RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 声明队列
channel.queue_declare(queue='bid_file')

# 注册回调函数
channel.basic_consume(queue='bid_file',
                      on_message_callback=callback,
                      auto_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()
    

小明：这样就实现了消息的生产和消费。那怎么把招标文件本身也传进去呢？

小李：通常我们会把文件的元数据（如文件名、大小、上传时间）发送到消息队列，而实际的文件内容可能存储在文件系统或云存储中。不过，如果你真的想传递文件内容，可以把它转换成Base64编码再发送。

小明：那我可以修改上面的代码，把文件内容也传过去吗？

小李：当然可以。下面是一个示例，展示如何读取文件并将其作为消息发送：

import pika
import base64

# 读取文件内容
with open('example_bid.pdf', 'rb') as f:
    file_data = f.read()

# 编码为Base64
encoded_data = base64.b64encode(file_data).decode('utf-8')

# 连接到RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 声明队列
channel.queue_declare(queue='bid_file')

# 发送消息
channel.basic_publish(
    exchange='',
    routing_key='bid_file',
    body=encoded_data
)

print(" [x] Sent file content")
connection.close()
    

小明：那消费者那边怎么处理呢？

小李：消费者可以接收到Base64字符串，然后解码还原文件内容。下面是消费者处理文件的代码：

import pika
import base64

def callback(ch, method, properties, body):
    print(" [x] Received Base64 data")
    decoded_data = base64.b64decode(body)
    
    # 保存文件
    with open('received_bid.pdf', 'wb') as f:
        f.write(decoded_data)
    
    print(" [x] File saved as received_bid.pdf")

# 连接到RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 声明队列
channel.queue_declare(queue='bid_file')

# 注册回调函数
channel.basic_consume(queue='bid_file',
                      on_message_callback=callback,
                      auto_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()
    

小明：这样就能完整地处理招标文件了。那后续还能做哪些扩展呢？

小李：你可以增加文件解析功能，比如使用PDF解析库提取招标内容，或者使用正则表达式提取关键信息，如投标截止时间、项目编号等。

小明：那我应该用什么库来解析PDF呢？

小李：Python中有PyPDF2或pdfplumber这样的库，可以用来提取PDF中的文本内容。例如：

import pdfplumber

with pdfplumber.open('example_bid.pdf') as pdf:
    for page in pdf.pages:
        text = page.extract_text()
        print(text)
    # 你可以在这里处理提取出的文本
    # 比如查找“投标截止时间”字段
    if "投标截止时间" in text:
        print("找到了投标截止时间！")
    else:
        print("未找到投标截止时间")
    

小明：这太有用了！那接下来是不是可以把这些信息保存到数据库中？

小李：是的。你可以用SQLAlchemy或者Django ORM等工具，将提取的信息存入数据库。比如创建一个BidFile表，包含文件名、上传时间、投标截止时间等字段。

小明：那数据库部分的代码该怎么写呢？

小李：这里是一个简单的示例，使用SQLite和SQLAlchemy：

from sqlalchemy import create_engine, Column, Integer, String, DateTime
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
import datetime

Base = declarative_base()

class BidFile(Base):
    __tablename__ = 'bid_files'

    id = Column(Integer, primary_key=True)
    filename = Column(String)
    upload_time = Column(DateTime)
    deadline = Column(String)

# 创建数据库连接
engine = create_engine('sqlite:///bids.db')
Base.metadata.create_all(engine)

Session = sessionmaker(bind=engine)
session = Session()

# 示例数据
new_file = BidFile(
    filename="example_bid.pdf",
    upload_time=datetime.datetime.now(),
    deadline="2025-12-31"
)

session.add(new_file)
session.commit()
    

小明：这样就可以把招标文件的信息持久化了。那整个流程就完成了。

小李：没错。通过消息管理中心，我们可以实现招标文件的自动化处理，提高效率，减少人为错误。

小明：谢谢你，这次真是学到了很多！

小李：不客气，如果你还有其他问题，随时问我。