话西游GM代码列表

bfdz49

我今天做个代码 可以拿源代码来实现他有什么帮助可以在下面留言我会回复

看图

（1）定义GM日志记录函数

1. import sqlite3
   
2. from datetime import datetime
   
3. 
   
4. def log_gm_action(db_connection, gm_id, command_id, player_id, action_details):
   
5.     cursor = db_connection.cursor()
   
6.     cursor.execute("""
   
7.         INSERT INTO GMLogs (gm_id, command_id, player_id, timestamp, action_details)
   
8.         VALUES (?, ?, ?, ?, ?)
   
9.     """, (gm_id, command_id, player_id, datetime.now(), action_details))
   
10.     db_connection.commit()

复制代码

定义GM指令执行函数

1. def execute_gm_command(db_connection, gm_id, command_name, player_id, params):
   
2.     cursor = db_connection.cursor()
   
3.    
   
4.     # 查询指令信息
   
5.     cursor.execute("SELECT command_id, required_permission FROM GMCommands WHERE command_name = ?", (command_name,))
   
6.     command = cursor.fetchone()
   
7.     if not command:
   
8.         print("Invalid command.")
   
9.         return
   
10.    
    
11.     command_id, required_permission = command
    
12.    
    
13.     # 模拟权限检查
    
14.     cursor.execute("SELECT permission_level FROM GMAccounts WHERE gm_id = ?", (gm_id,))
    
15.     gm_permission = cursor.fetchone()
    
16.     if not gm_permission or gm_permission[0] < required_permission:
    
17.         print("Permission denied.")
    
18.         return
    
19.    
    
20.     # 根据指令类型执行操作
    
21.     if command_name == ".modify":
    
22.         attribute, value = params.split()
    
23.         cursor.execute(f"UPDATE Players SET {attribute} = ? WHERE player_id = ?", (value, player_id))
    
24.         db_connection.commit()
    
25.         log_gm_action(db_connection, gm_id, command_id, player_id, f"Modified {attribute} to {value}")
    
26.         print(f"Modified player {player_id}'s {attribute} to {value}.")
    
27.     elif command_name == ".additem":
    
28.         item_id, quantity = params.split()
    
29.         cursor.execute("UPDATE Players SET items = json_set(items, '$.items', json(items || json(?))) WHERE player_id = ?", (f'{{"item_id":{item_id}, "quantity":{quantity}}}', player_id))
    
30.         db_connection.commit()
    
31.         log_gm_action(db_connection, gm_id, command_id, player_id, f"Added item {item_id} x{quantity}")
    
32.         print(f"Added item {item_id} x{quantity} to player {player_id}.")
    
33.     else:
    
34.         print("Command not implemented.")

复制代码

服务端接收GM指令服务端需要监听GM工具发送的指令，并调用相应的存储函数执行操作

1. import socket
   
2. import threading
   
3. 
   
4. def handle_client(client_socket, db_connection):
   
5.     while True:
   
6.         try:
   
7.             command = client_socket.recv(1024).decode('utf-8')
   
8.             if not command:
   
9.                 break
   
10.             print(f"Received command: {command}")
    
11.             # 解析指令并执行
    
12.             gm_id, command_name, player_id, params = command.split('|')
    
13.             execute_gm_command(db_connection, int(gm_id), command_name, int(player_id), params)
    
14.         except Exception as e:
    
15.             print(f"Error: {e}")
    
16.             break
    
17.     client_socket.close()
    
18. 
    
19. def start_server():
    
20.     db_connection = sqlite3.connect("game.db")
    
21.     server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
22.     server_socket.bind(('0.0.0.0', 8888))
    
23.     server_socket.listen(5)
    
24.     print("Server started. Listening on port 8888...")
    
25. 
    
26.     while True:
    
27.         client_socket, addr = server_socket.accept()
    
28.         print(f"Accepted connection from {addr}")
    
29.         client_handler = threading.Thread(target=handle_client, args=(client_socket, db_connection))
    
30.         client_handler.start()
    
31. 
    
32. if __name__ == "__main__":
    
33.     start_server()

复制代码

客户端发送GM指令客户端通过网络连接到服务端，发送GM指令

1. import socket
   
2. 
   
3. def send_gm_command(gm_id, command_name, player_id, params):
   
4.     client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
   
5.     client_socket.connect(('127.0.0.1', 8888))
   
6.     command = f"{gm_id}|{command_name}|{player_id}|{params}"
   
7.     client_socket.send(command.encode('utf-8'))
   
8.     client_socket.close()
   
9. 
   
10. # 示例：发送GM指令
    
11. send_gm_command(1, ".modify", 123, "hp 1000")
    
12. send_gm_command(1, ".additem", 123, "101 5")

复制代码

创建数据库表

1. CREATE TABLE GMAccounts (
   
2.     gm_id INT PRIMARY KEY,
   
3.     username VARCHAR(255) NOT NULL,
   
4.     password_hash VARCHAR(255) NOT NULL,
   
5.     permission_level INT NOT NULL
   
6. );
   
7. 
   
8. CREATE TABLE GMCommands (
   
9.     command_id INT PRIMARY KEY,
   
10.     command_name VARCHAR(255) NOT NULL,
    
11.     description TEXT,
    
12.     required_permission INT NOT NULL
    
13. );
    
14. 
    
15. CREATE TABLE GMLogs (
    
16.     log_id INT PRIMARY KEY,
    
17.     gm_id INT NOT NULL,
    
18.     command_id INT NOT NULL,
    
19.     player_id INT NOT NULL,
    
20.     timestamp DATETIME NOT NULL,
    
21.     action_details TEXT
    
22. );
    
23. 
    
24. CREATE TABLE Players (
    
25.     player_id INT PRIMARY KEY,
    
26.     name VARCHAR(255) NOT NULL,
    
27.     level INT NOT NULL,
    
28.     hp INT NOT NULL,
    
29.     mana INT NOT NULL,
    
30.     gold INT NOT NULL,
    
31.     items TEXT
    
32. );

复制代码

she1380915