123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278 |
- # -*- coding: utf-8 -*-
- import datetime
- from flask import Flask, render_template
- from flask_socketio import SocketIO, emit
- from scriptBase.comon import *
- import pyautogui
- import base64
- import threading
- from yys_task import *
- from collections import deque
- import json
- app = Flask(__name__)
- socketio = SocketIO(app)
- event = threading.Event()
- g_status = ''
- last_time = 0.0
- task_queue = deque()
- last_process = ''
- isGameBegin = True
- autoTask = None
- isReset = False
- def thread_runTask():
- global last_process
- global task_queue,isReset
- while True:
- if event.is_set():
- task_queue.clear()
- if len(task_queue) != 0:
- task = task_queue[-1]
- task_queue.pop()
- last_process = task.name
- task.run()
- myTimeSleep_small()
- else:
- myTimeSleep_big()
- if isReset:
- isReset = False
- restart_game()
- @app.route('/')
- def index():
- return render_template('index.html')
- @socketio.on('connect')
- def handle_connect():
- print('Client connected')
- @socketio.on('disconnect')
- def handle_disconnect():
- print('Client disconnected')
- def send_hint(msg):#数组信息
- emit('processing_hint', msg)
- def send_status(msg):#软件执行状态
- global g_status
- try:
- if msg == '':
- emit('processing_status', g_status)
- return
- else:
- g_status = msg
-
- if msg == "结束":
- event.clear()
- emit('processing_status', msg)
- except:
- return
-
- def send_todo():#软件执行状态
- try:
- if msg == '':
- emit('processing_status', g_status)
- return
- else:
- g_status = msg
-
- if msg == "结束":
- event.clear()
- emit('processing_status', msg)
- except:
- return
- @socketio.on('monitor_begin')
- def monitor_begin():
- global last_time, last_process
- current_time = time.time()
- elapsed_time = current_time - last_time
- if elapsed_time < 0.5:
- return
- last_time = current_time
- screenshot = pyautogui.screenshot()
- binary_img = binarize_image(screenshot)
- compressed_data = compress_image(binary_img)
-
- image_data_base64 = base64.b64encode(compressed_data).decode('utf-8')
- socketio.emit('image_data', image_data_base64)
- task_arr = []
- if not event.is_set():
- task_arr.append(last_process)
- for item in reversed(task_queue):
- task_arr.append(item.name)
- send_hint(json.dumps(task_arr, ensure_ascii=False))
- send_status('')
- #print("send img")
- @socketio.on('end_script')
- def handle_end_script():
- event.set()
- @socketio.on('end_game')
- def handle_end_game():
- event.set()
- task_close_game()
- send_status("结束")
- event.clear()
- @socketio.on('beigin_baigui')
- def handle_beigin_baigui():
- task_queue.append(task_baigui())
- @socketio.on('get_title')
- def handle_get_title():
- str = task_getComputerName()
- dst = str + ' machine'
- emit('processing_title', dst)
- @socketio.on('reset_script')
- def handle_reset_script():
- python = sys.executable
- while '--reset' in sys.argv:
- # 从 sys.argv 列表中删除 --reset 参数
- sys.argv.remove('--reset')
- os.execl(python, python, *sys.argv)
- @socketio.on('restart_game')
- def handle_restart_game():
- python = sys.executable
- os.execl(python, python, *sys.argv, '--reset')
- def restart_game():
- global isGameBegin, autoTask
- isGameBegin = False
- while True:
- task_close_game()
- if True == task_start_game():
- break
- else:
- send_status("启动失败")
- isGameBegin = True
- send_status("结束")
- auto_task(None)
- @socketio.on('begin_tansuo')
- def handle_begin_tansuo(data):
- pageNum = data['pageNum'], timesNum = data['timesNum']
- for i in range(1, timesNum + 1):
- task_queue.append(task_tansuo(pageNum))
- @socketio.on('begin_teamer')
- def handle_begin_teamer():
- task_queue.appendleft(task_fightzuidui())
- @socketio.on('begin_yuhun')
- def handle_begin_yuhun():
- task_queue.appendleft(task_yuhun())
- @socketio.on('begin_tupo')
- def handle_begin_tupo():
- task_queue.append(task_topo(3))
- @socketio.on('begin_AddPersion')
- def handle_begin_AddPersion():
- task_queue.append(task_AddPerson(20))
- @socketio.on('begin_jiyang')
- def handle_begin_jiyang():
- task_queue.append(task_jiyang())
- @socketio.on('begin_zhaohuan')
- def handle_begin_zhaohuan():
- task_queue.append(task_zhaohuan())
- @socketio.on('begin_yeyuanhuo')
- def handle_begin_yeyuanhuo():
- task_queue.append(task_yeyuanhuo())
- def add_auto_task(pageNum):
- global isGameBegin
- tmp_num = 0
- ten_pm = datetime.time(4, 0, 0)
- three_am = datetime.time(5, 0, 0)
- ten_am = datetime.time(10, 0, 0)
- while not event.is_set():
- if len(task_queue) != 0:
- time.sleep(5)
- continue
- current_time = datetime.datetime.now().time()
- if current_time > three_am and current_time < ten_am:
- task_close_game()
- time.sleep(1000)
- isGameBegin = False
- continue
-
- if isGameBegin == False:
- while True:
- task_close_game()
- if True == task_start_game():
- break
- isGameBegin = True
- time.sleep(200)
- tansuo_times = random.randint(3, 6)
- tupo_times = 3
- liaotupo_times = 0
- if current_time < ten_pm:
- liaotupo_times = 2
- for i in range(liaotupo_times):
- task_queue.appendleft(task_topo(2, False))
- for i in range(tansuo_times):
- task_queue.appendleft(task_tansuo(pageNum))
- for i in range(tupo_times):
- task_queue.appendleft(task_topo(2))
- task_queue.appendleft(task_jiyang())
- task_queue.clear()
- send_status(f'自动模式结束')
- event.clear()
-
-
- @socketio.on('begin_auto')
- def handle_auto(data):
- auto_task(data)
- def auto_task(data):
- global autoTask
- if data == None:
- pageNum = 28
- else:
- pageNum = data['pageNum']
- send_status(f'开始自动模式')
- autoTask = threading.Thread(target=add_auto_task, args=(pageNum,))#启动线程往里面添加任务
- autoTask.daemon = True
- autoTask.start()
- @socketio.on('begin_daoguan')
- def handle_begin_daoguan():
- while not event.is_set():
- task_daoguan()
- send_status("结束")
- @socketio.on('begin_douji')
- def handle_begin_douji():
- task_queue.append(task_douji(20))
- @socketio.on('begin_chaoguiwang')
- def handle_begin_chaoguiwang():
- task_queue.append(task_chaoguiwang())
- if __name__ == '__main__':
- init()
- if '--reset' in sys.argv:
- isReset = True
- print("需要重启游戏")
- runTask = threading.Thread(target=thread_runTask)#启动线程往里面添加任务
- runTask.daemon = True
- runTask.start()
-
- socketio.run(app, host= '0.0.0.0', debug=True)
|