simmcws/api.py at master · Simpidbit/simmcws · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
from asyncio import ensure_future, sleep
import re
import time

import cmdarg
from send_message import *

# Send building commands to the world.
async def sendBuildingPackages(client, lines, global_var, args):
	begin_time = time.time()
	prepercent = 0
	clock = 0
	await client.send(command("title @a actionbar 进度: 0％"))
	for i in range(len(lines)):
		await client.send(command(lines[i],i))
		percent = int(i / len(lines) * 100)
		if percent > prepercent:
			await client.send(command(f"title @a actionbar 进度: {percent}％"))
			prepercent = percent
		await sleep(float(args.args["-t"]) / 1000)
	await client.send(command("title @a actionbar 进度: 100％"))
	end_time = time.time()

	# 统计信息
	all_time = int(end_time - begin_time)
	if all_time == 0:
		all_time = 1
	all_blocks_number = len(lines)
	speed = int(all_blocks_number / all_time)

	if len(global_var["bad_packages"]) > 0: await sleep(2)

	await client.send(command((ok("导入完毕!"))))
	await client.send(command(say(f"本次共导入 {all_blocks_number} 个方块,共用时 {all_time} 秒,平均速度为 {speed} 方块/秒")))

	if len(global_var["bad_packages"]) > 0:
		await client.send(command((status("正在进行补包..."))))
		print(global_var["bad_packages"])
		print("以上为需要补包的指令索引")
		for bad in global_var["bad_packages"]:
			try:
				await client.send(command(lines[bad]))
			except:
				pass
			await sleep(0.003)
		global_var["bad_packages"] = []
		# 清理垃圾
		lines = None
		await client.send(command((ok("补包完毕"))))
	await client.send(command((ok("已完成导入"))))

async def getPosAndLines(client, global_var, lines):
	"""Get player's pos to count the absolute coordinates. """
	await sleep(0.4)
	global_var["wait_sympol"] = True
	await sleep(0.4)
	await client.send(command("testfor @s"))
	await sleep(0.4)

	# 获取玩家坐标
	await client.send(command("tp @s ~~~"))
	result = json.loads(await client.recv())
	try:
		player_pos = result["body"]["destination"]
	except:
		if "外部" in str(result) or "发现" in str(result):
			while True:
				result = json.loads(await client.recv())
				if "外部" in str(result) or "发现" in str(result):
					pass
				else:
					break
			try:
				player_pos = result["body"]["destination"]
			except:
				print("="*80)
				print(result)
				print("="*80)
				await client.send(command(alert("请稍等一会，您的世界处理不了这么多请求~~~")))
				return
		else:
			print("-"*20)
			print(result)
			print("-"*20)
			return

	global_var["wait_sympol"] = False
	for each in player_pos:
		player_pos[each] = int(player_pos[each])

	await client.send(command(status("正在将相对坐标转换为绝对坐标...")))
	for i in range(len(lines)):
		time_ = 0		# 用来计算坐标是 x , y 还是 z
		cmd = lines[i].split(" ")
		# cmd = [setblock,~-8,~-32,~-4,stained_hardened_clay,10]
		for each in cmd:
			# each = "~-8"
			if "~" in each:
				# pos = ["-8"]
				pos = each.split("~")
				pos.pop(0)
				for j in pos:
					# i = -8
					try:
						j = int(j)
					except:
						j = 0
					# x 轴
					if time_ == 0 or time_ == 3:
						j = player_pos["x"] + j
					if time_ == 1 or time_ == 4:
						j = player_pos["y"] + j
					if time_ == 2 or time_ == 5:
						j = player_pos["z"] + j

					cmd_span = re.search(r"~-*\d*",lines[i]).span()
					cmd_pos = lines[i][cmd_span[0]:cmd_span[1]]
					lines[i] = lines[i].replace(cmd_pos,str(j)+" ",1)
					time_ += 1
	await client.send(command(status("转换完毕! 正在导入建筑... 期间您可以自由活动")))
	return lines