消息管理平台与代理价系统的技术实现及软著证书应用

# app.py

from flask import Flask, request, jsonify

import redis

app = Flask(__name__)

r = redis.Redis(host='localhost', port=6379, db=0)

@app.route('/send_message', methods=['POST'])

def send_message():

data = request.get_json()

message_id = r.incr('message:id')

r.set(f'message:{message_id}', data['content'])

return jsonify({'status': 'success', 'message_id': message_id})

@app.route('/get_messages', methods=['GET'])

def get_messages():

messages = []

for key in r.keys('message:*'):

messages.append(r.get(key).decode('utf-8'))

return jsonify(messages)

if __name__ == '__main__':

app.run(debug=True)

# price_system.py

import sqlite3

conn = sqlite3.connect('prices.db')

c = conn.cursor()

# 创建表

c.execute('''CREATE TABLE IF NOT EXISTS agents

(id INTEGER PRIMARY KEY, name TEXT, level INTEGER)''')

c.execute('''CREATE TABLE IF NOT EXISTS prices

(agent_id INTEGER, product_id INTEGER, price REAL, FOREIGN KEY(agent_id) REFERENCES agents(id))''')

conn.commit()

def set_price(agent_id, product_id, price):

c.execute("INSERT INTO prices (agent_id, product_id, price) VALUES (?, ?, ?)",

(agent_id, product_id, price))

conn.commit()

def get_price(agent_id, product_id):

c.execute("SELECT price FROM prices WHERE agent_id = ? AND product_id = ?",

(agent_id, product_id))

result = c.fetchone()

return result[0] if result else None

# 示例数据

c.execute("INSERT OR IGNORE INTO agents (id, name, level) VALUES (1, 'Agent A', 1)")

c.execute("INSERT OR IGNORE INTO agents (id, name, level) VALUES (2, 'Agent B', 2)")

set_price(1, 101, 100.0)

set_price(2, 101, 80.0)

print(get_price(1, 101)) # 输出: 100.0

print(get_price(2, 101)) # 输出: 80.0

conn.close()