Update daemon.py

dev-linux
Ivan Maslov 6 years ago
parent 369fd1f41e
commit c624015f63

@ -0,0 +1,337 @@
from http.server import BaseHTTPRequestHandler, HTTPServer
import pdb
import pywinauto
import json
import subprocess
import zlib
import tkinter
import tkinter.ttk
import os
#ProcessChildSendString
def ProcessChildSendString(lProcess,lString):
lByteString = zlib.compress(lString.encode("utf-8"))
#Вернуть потенциальные \n
lByteString = lByteString.replace(b'\n',b'{{n}}')
#Отправить сообщение в дочерний процесс
lProcess.stdin.write(lByteString+bytes('\n',"utf-8"))
#print(str(lByteString+bytes('\n',"utf-8")))
lProcess.stdin.flush()
#Вернуть результат
return
#ProcessChildReadWaitString
def ProcessChildReadWaitString(lProcess):
#Ожидаем ответ от процесса
lResult = lProcess.stdout.readline()
#Вернуть потенциальные \n
lResult = lResult.replace(b'{{n}}',b'\n')
#print("check")
#print(str(lResult))
lResult = zlib.decompress(lResult[0:-1])
lResult = lResult.decode("utf-8")
#Вернуть результат
return lResult
#ProcessChildSendObject
def ProcessChildSendObject(inProcess,inObject):
#Выполнить отправку сконвертированного объекта в JSON
ProcessChildSendString(inProcess,json.dumps(inObject))
return
#ProcessChildReadWaitObject
def ProcessChildReadWaitObject(inProcess):
#Выполнить получение и разбор объекта
lResult=json.loads(ProcessChildReadWaitString(inProcess));
return lResult;
#ProcessChildSendReadWaitString
def ProcessChildSendReadWaitString(lProcess,lString):
ProcessChildSendString(lProcess,lString)
#Вернуть результат
return ProcessChildReadWaitString(lProcess)
#ProcessChildSendReadWaitObject
def ProcessChildSendReadWaitObject(inProcess,inObject):
ProcessChildSendObject(inProcess,inObject)
#Вернуть результат
return ProcessChildReadWaitString(inProcess)
#pywinauto
def checkBitnessIs64():
lResult=True
return lResult;
def GetControl(inControlSpecificationArray):
#Выполнить идентификацию объектов, если передан массив
lResultList=[];
if len(inControlSpecificationArray) > 0:
#Выполнить подключение к объекту
lRPAApplication = pywinauto.Application()
#Проверка разрядности
lRPAApplication.connect(**inControlSpecificationArray[0])
lTempObject=lRPAApplication.window(**inControlSpecificationArray[0])
#Циклическое прохождение к недрам объекта
for lWindowSpecification in inControlSpecificationArray[1:]:
lTempObject=lTempObject.window(**lWindowSpecification)
#Получить инфо объект
lTempObjectInfo = lTempObject.wrapper_object().element_info
#Добавить информацию об обнаруженом объекте
lResultList.append({"name":lTempObjectInfo.name, "rich_text":lTempObjectInfo.rich_text, "process_id":lTempObjectInfo.process_id,"handle":lTempObjectInfo.handle});
return lResultList
def GetChildControls(inControlSpecificationArray):
#Выполнить идентификацию объектов, если передан массив
lResultList=[];
if len(inControlSpecificationArray) > 0:
#Выполнить подключение к объекту
lRPAApplication = pywinauto.Application()
lRPAApplication.connect(**inControlSpecificationArray[0])
lTempObject=lRPAApplication.window(**inControlSpecificationArray[0])
#Циклическое прохождение к недрам объекта
for lWindowSpecification in inControlSpecificationArray[1:]:
lTempObject=lTempObject.window(**lWindowSpecification)
#Получить инфо объект
lTempObjectInfo = lTempObject.wrapper_object().element_info
#Добавить информацию об обнаруженом объекте
lResultList.append({"name":lTempObjectInfo.name, "rich_text":lTempObjectInfo.rich_text, "process_id":lTempObjectInfo.process_id,"handle":lTempObjectInfo.handle});
return lResultList
def GetWindowList(inWindowSpecificationArray = []):
#Выполнить идентификацию объектов, если передан массив
lResultList={};
if len(inWindowSpecificationArray) > 0:
#Выполнить подключение к объекту
lRPAApplication = pywinauto.Application()
lTempObject=lRPAApplication.connect(**inWindowSpecificationArray[0])
#Циклическое прохождение к недрам объекта
for lWindowSpecification in inWindowSpecificationArray[1:]:
lTempObject=lTempObject.window(**lWindowSpecification)
lTempObjectInfo = lTempObject.wrapper_object().element_info
lResultList2.append({"name":lTempObjectInfo.name, "rich_text":lTempObjectInfo.rich_text, "process_id":lTempObjectInfo.process_id,"handle":lTempObjectInfo.handle});
#Получить список объектов
lResultList=pywinauto.findwindows.find_elements()
else:
#Получить список объектов
lResultList=pywinauto.findwindows.find_elements()
lResultList2=[]
for lI in lResultList:
lResultList2.append({"name":lI.name, "rich_text":lI.rich_text, "process_id":lI.process_id,"handle":lI.handle});
return lResultList2
# HTTPRequestHandler class
class testHTTPServer_RequestHandler(BaseHTTPRequestHandler):
# GET
def do_GET(self):
if self.path == "/":
# Send response status code
self.send_response(200)
#pdb.set_trace()
# Send headers
self.send_header('Content-type','text/html')
self.end_headers()
# Send message back to client
f = open("Index.xhtml", "r")
message = f.read()
f.close()
# Write content as utf-8 data
self.wfile.write(bytes(message, "utf8"))
if self.path == '/3rdParty/Semantic-UI-CSS-master/semantic.min.css':
# Send response status code
self.send_response(200)
#pdb.set_trace()
# Send headers
self.send_header('Content-type','text/css')
self.end_headers()
# Send message back to client
f = open("3rdParty\Semantic-UI-CSS-master\semantic.min.css", "r")
message = f.read()
f.close()
# Write content as utf-8 data
self.wfile.write(bytes(message, "utf8"))
if self.path == '/3rdParty/Semantic-UI-CSS-master/semantic.min.js':
# Send response status code
self.send_response(200)
#pdb.set_trace()
# Send headers
self.send_header('Content-type','application/javascript')
self.end_headers()
# Send message back to client
f = open("3rdParty\Semantic-UI-CSS-master\semantic.min.js", "r")
message = f.read()
f.close()
# Write content as utf-8 data
self.wfile.write(bytes(message, "utf8"))
if self.path == '/3rdParty/jQuery/jquery-3.1.1.min.js':
# Send response status code
self.send_response(200)
# Send headers
self.send_header('Content-type','application/javascript')
self.end_headers()
# Send message back to client
f = open("3rdParty\jQuery\jquery-3.1.1.min.js", "r")
message = f.read()
f.close()
# Write content as utf-8 data
self.wfile.write(bytes(message, "utf8"))
if self.path == '/3rdParty/Google/LatoItalic.css':
# Send response status code
self.send_response(200)
# Send headers
self.send_header('Content-type','text/css')
self.end_headers()
# Send message back to client
f = open("3rdParty\Google\LatoItalic.css", "r")
message = f.read()
f.close()
# Write content as utf-8 data
self.wfile.write(bytes(message, "utf8"))
if self.path == '/3rdParty/Semantic-UI-CSS-master/themes/default/assets/fonts/icons.woff2':
# Send response status code
self.send_response(200)
# Send headers
self.send_header('Content-type','font/woff2')
self.end_headers()
# Send message back to client
f = open("3rdParty\Semantic-UI-CSS-master\themes\default\assets\fonts\icons.woff2", "r")
message = f.read()
f.close()
# Write content as utf-8 data
self.wfile.write(bytes(message, "utf8"))
#Action ObjectInspector GetObjectList
if self.path == '/ObjectDetector/JSONGetWindowList':
#ReadRequest
#lInputByteArray=self.rfile.read()
#print(str(len(os.stat(self.rfile).st_size)))
# Send response status code
self.send_response(200)
# Send headers
self.send_header('Content-type','application/json')
self.end_headers()
# Send message back to client
#{'functionName':'', 'argsArray':[]}
lRequestObject={'functionName':'ElementGetChildElementList','argsArray':[]}
#Отправить запрос в дочерний процесс, который отвечает за работу с Windows окнами
ProcessChildSendObject(p,lRequestObject)
#Получить ответ от дочернего процесса
lResponseObject=ProcessChildReadWaitObject(p)
message = json.dumps(lResponseObject)
# Write content as utf-8 data
self.wfile.write(bytes(message, "utf8"))
# POST
def do_POST(self):
#Action ObjectInspector GetObjectList
if self.path == '/ObjectDetector/JSONGetWindowListArgs':
#ReadRequest
lInputByteArrayLength = int(self.headers.get('Content-Length'))
lInputByteArray=self.rfile.read(lInputByteArrayLength)
#Превращение массива байт в объект
print(lInputByteArray.decode('utf8'))
lInputObject=json.loads(lInputByteArray.decode('utf8'))
# Send response status code
self.send_response(200)
# Send headers
self.send_header('Content-type','application/json')
self.end_headers()
# Send message back to client
#{'functionName':'', 'argsArray':[]}
lRequestObject={'functionName':'ElementGetChildElementList','argsArray':lInputObject}
#Отправить запрос в дочерний процесс, который отвечает за работу с Windows окнами
ProcessChildSendObject(p,lRequestObject)
#Получить ответ от дочернего процесса
lResponseObject=ProcessChildReadWaitObject(p)
print(str(lResponseObject))
message = json.dumps(lResponseObject)
# Write content as utf-8 data
self.wfile.write(bytes(message, "utf8"))
if self.path == '/GUIAction':
#ReadRequest
lInputByteArrayLength = int(self.headers.get('Content-Length'))
lInputByteArray=self.rfile.read(lInputByteArrayLength)
#Превращение массива байт в объект
lInputObject=json.loads(lInputByteArray.decode('utf8'))
# Send response status code
self.send_response(200)
# Send headers
self.send_header('Content-type','application/json')
self.end_headers()
# Send message back to client
#{'functionName':'', 'argsArray':[]}
lRequestObject=lInputObject
#Отправить запрос в дочерний процесс, который отвечает за работу с Windows окнами
ProcessChildSendObject(p,lRequestObject)
#Получить ответ от дочернего процесса
lResponseObject=ProcessChildReadWaitObject(p)
message = json.dumps(lResponseObject)
# Write content as utf-8 data
self.wfile.write(bytes(message, "utf8"))
return
def run():
print('starting server...')
# Server settings
# Choose port 8080, for port 80, which is normally used for a http server, you need root access
server_address = ('127.0.0.1', 8081)
httpd = HTTPServer(server_address, testHTTPServer_RequestHandler)
print('running server...')
httpd.serve_forever()
#Start childprocess
p = subprocess.Popen(['C:\\Users\\Acer\\AppData\\Local\\Programs\\Python\\Python37\\python.exe','C:\\Abs\\archive\\scopeSrcUL\\OpenRPA\\winGUI.py'],stdin=subprocess.PIPE,stdout=subprocess.PIPE)
#print(ChildProcessReadWaitString(p))
run()
def Constructor():
lWindow=tkinter.Tk()
#{'functionName':'', 'argsArray':[]}
lRequestObject={'functionName':'ElementGetChildElementList','argsArray':[]}
#Отправить запрос в дочерний процесс, который отвечает за работу с Windows окнами
ProcessChildSendObject(p,lRequestObject)
#Получить ответ от дочернего процесса
lResponseObject=ProcessChildReadWaitObject(p)
print("Response:"+str(lResponseObject))
#Создать дерево
lWidgetTree = tkinter.ttk.Treeview(lWindow)
lIterator = 0
#Добавить информацию об объектах в дерево
for lListItem in lResponseObject['outputObject']:
lIterator=lIterator+1
lItemText=lListItem['name']
if type(lItemText) is str:
if len(lItemText) == 0:
lItemText="No text (Len 0)"
else:
lItemText="No Text (NoneType)"
lWidgetTree.insert("", lIterator, "Item"+str(lIterator), text=lItemText)
lWidgetTree.pack()
return
#Constructor()
Loading…
Cancel
Save