Ivan Maslov
5 years ago
parent
9fea1e51b1
commit
d39ea067b1
@ -1,158 +0,0 @@
|
|||||||
import psutil, datetime, logging, os, json
|
|
||||||
# # # # # # # ORCHESTRATOR CONTROL PANEL <Robot name> # # # # # # #
|
|
||||||
# Init parameters
|
|
||||||
gRobotStartFilePathStr = r"path\to\start\file" # path\to\start\file
|
|
||||||
gRobotProcessNameWOEXEStr = "process name" # RobotProcessName
|
|
||||||
gRobotADLoginStr = "Login" # Login of the robot session
|
|
||||||
gRobotADPasswordStr = "Password" # Password for session
|
|
||||||
gRobotKeyStr = "Robot_Template"
|
|
||||||
gRDPSessionKeyStr = "RDP_Template"
|
|
||||||
gRDPSessionHostStr = "localhost" # Rdp session host
|
|
||||||
gRDPSessionPortStr = "3389" # Default 3389
|
|
||||||
gControlPanelKeyStr = "ControlPanel_Template"
|
|
||||||
gControlPanelCheckRobotProcessFromOrchestratorUserBool = True # Check process activity from orchestrator GUI session (with help of task manager, when users on the same machine)
|
|
||||||
# !! ATTENTION !! SCHEDULE TIME START STOP FILL BELOW IN ACTIVITY SECTION
|
|
||||||
gRobotToOrchestratorKeyList = ["Storage",gRobotKeyStr,"RobotToOrchestrator"]
|
|
||||||
gOrchestratorToRobotResetKeyList = ["Storage",gRobotKeyStr,"OrchestratorToRobotReset"]
|
|
||||||
gOrchestratorToRobotResetSafeStopKeyList = gOrchestratorToRobotResetKeyList+["SafeTurnOffBool"]
|
|
||||||
|
|
||||||
# # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # #
|
|
||||||
# Activity list
|
|
||||||
## Robot START (create RDP session, send CMD to start process)
|
|
||||||
gActivityROBOTStartTimeHH_MMStr = "03:00" # Time "HH:MM" [Server time] to execute activity, example "05:10"
|
|
||||||
gActivityROBOTStartWeekdayList = [0,1,2,3,4] # WeekdayList when atcivity is starting, default [0,1,2,3,4,5,6]
|
|
||||||
gActivityROBOTStartList = [
|
|
||||||
{ # Start RDP Session
|
|
||||||
"DefNameStr":"RDPSessionConnect", # Function name in RobotRDPActive.Processor
|
|
||||||
"ArgList":[], # Args list
|
|
||||||
"ArgDict":{"inRDPSessionKeyStr": gRDPSessionKeyStr, "inHostStr": gRDPSessionHostStr, "inPortStr": gRDPSessionPortStr, "inLoginStr": gRobotADLoginStr, "inPasswordStr": gRobotADPasswordStr} # Args dictionary
|
|
||||||
},
|
|
||||||
{ # Run robot file in RDP session
|
|
||||||
"DefNameStr":"RDPSessionProcessStartIfNotRunning", # Function name in RobotRDPActive.Processor
|
|
||||||
"ArgList":[], # Args list
|
|
||||||
"ArgDict":{"inRDPSessionKeyStr": gRDPSessionKeyStr, "inProcessNameWEXEStr": f"{gRobotProcessNameWOEXEStr}.exe", "inFilePathStr": gRobotStartFilePathStr, "inFlagGetAbsPathBool": False} # Args dictionary
|
|
||||||
}
|
|
||||||
]
|
|
||||||
## Robot FORCE STOP (send CMD to stop process, logoff)
|
|
||||||
gActivityROBOTStopTimeHH_MMStr = "08:00" # Time "HH:MM" [Server time] to execute activity, example "05:10"
|
|
||||||
gActivityROBOTStopWeekdayList = [0,1,2,3,4] # WeekdayList when atcivity is starting, default [0,1,2,3,4,5,6]
|
|
||||||
gActivityROBOTStopList = [
|
|
||||||
{ # Kill process
|
|
||||||
"DefNameStr":"RDPSessionProcessStop", # Function name in RobotRDPActive.Processor
|
|
||||||
"ArgList":[], # Args list
|
|
||||||
"ArgDict":{"inRDPSessionKeyStr": gRDPSessionKeyStr, "inProcessNameWEXEStr":f"{gRobotProcessNameWOEXEStr}.exe","inFlagForceCloseBool": True} # Args dictionary
|
|
||||||
},
|
|
||||||
{ # Logoff RDP Session
|
|
||||||
"DefNameStr":"RDPSessionLogoff", # Function name in RobotRDPActive.Processor
|
|
||||||
"ArgList":[], # Args list
|
|
||||||
"ArgDict":{"inRDPSessionKeyStr": gRDPSessionKeyStr} # Args dictionary
|
|
||||||
}
|
|
||||||
]
|
|
||||||
# # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # #
|
|
||||||
# Function, which is generate Dict for front-endswith
|
|
||||||
def ControlPanelRenderDict(inGSettings):
|
|
||||||
"""result={
|
|
||||||
"HeaderLeftText":"<Robot name>",
|
|
||||||
"HeaderRightText":"<header>",
|
|
||||||
"DataStorageKey":"Robot_Name", #Use key for set current dict in mGlobal.DataStorage["DataStorageKey"] on client side
|
|
||||||
"SubheaderText": "State: <span style=\"color:green\">Turned on</span>",
|
|
||||||
"BodyKeyValueList":[
|
|
||||||
{"Key":"Session list","Value":""},
|
|
||||||
{"Key":"Session list","Value":""}
|
|
||||||
],
|
|
||||||
"FooterText":"Last update: 9:38:00 09.10.2019",
|
|
||||||
"FooterButtonX2List":[
|
|
||||||
{"Text":"Turn on", "Color":"green", "Link":"", "OnClick": lOnClickRunButton.replace("\\","\\\\")},
|
|
||||||
],
|
|
||||||
"FooterButtonX1List":[
|
|
||||||
{"Text":"Kill", "Color":"red", "Link":"", "OnClick": lOnClickForceCloseButton.replace("\\","\\\\")}
|
|
||||||
]
|
|
||||||
}"""
|
|
||||||
# START :: Create activities :: START #
|
|
||||||
## Robot START (create RDP session, send CMD to start process)
|
|
||||||
lActivityROBOTStartEscaped = f"mGlobal.Processor.ServerValueOperatorPlus({json.dumps(['RobotRDPActive','ActivityList'])},{json.dumps(gActivityROBOTStartList)});".replace("\"","\'")
|
|
||||||
## Robot SAFE STOP (SAFE STOP COMMAND (FROM ROBOT RULES), Logoff must do robot when safe turn off)
|
|
||||||
lActivityROBOTSafeStopEscaped = f"mGlobal.Processor.ServerValueOperatorPlus({json.dumps(gOrchestratorToRobotResetSafeStopKeyList)},true);".replace("\"","\'")
|
|
||||||
## Robot FORCE STOP (send CMD to stop process, logoff)
|
|
||||||
lActivityROBOTStopEscaped = f"mGlobal.Processor.ServerValueOperatorPlus({json.dumps(['RobotRDPActive','ActivityList'])},{json.dumps(gActivityROBOTStopList)});".replace("\"","\'")
|
|
||||||
# END :: Create activities :: END #
|
|
||||||
# START :: Init result dict template :: START #
|
|
||||||
# lBodyKeyValue_r3_start=f'<a onclick="{lActivityROBOTStartEscaped}" style=\"color:green\">Start</a>'
|
|
||||||
lResultDict={
|
|
||||||
"HeaderLeftText":"ROBOT KEYWORD",
|
|
||||||
"HeaderRightText":"ROBOT NAME",
|
|
||||||
"DataStorageKey":gControlPanelKeyStr, # CLIENT SIDE:: Use key for set current dict in mGlobal.DataStorage["DataStorageKey"] on client side
|
|
||||||
"SubheaderText":"<Subheader text, state filled below>",
|
|
||||||
"BodyKeyValueList":[
|
|
||||||
{"Key":"Scheduler","Value":""},
|
|
||||||
{"Key":"Start","Value":f"at {gActivityROBOTStartTimeHH_MMStr} in weekdays {gActivityROBOTStartWeekdayList}"},
|
|
||||||
{"Key":"Stop (kill)","Value":f"at {gActivityROBOTStopTimeHH_MMStr} in weekdays {gActivityROBOTStopWeekdayList}"},
|
|
||||||
{"Key":"Statistic","Value":""},
|
|
||||||
{"Key":"...","Value":""}
|
|
||||||
],
|
|
||||||
"FooterText":"Last update: 9:38:00 09.10.2019",
|
|
||||||
"FooterButtonX2List":[
|
|
||||||
{"Text":"Turn on", "Color":"green", "Link":"", "OnClick": lActivityROBOTStartEscaped},
|
|
||||||
{"Text":"Safe turn off", "Color":"orange", "Link":"", "OnClick": lActivityROBOTSafeStopEscaped}
|
|
||||||
],
|
|
||||||
"FooterButtonX1List":[
|
|
||||||
{"Text":"Kill", "Color":"red", "Link":"", "OnClick": lActivityROBOTStopEscaped}
|
|
||||||
],
|
|
||||||
# "GlobalStorage": inGSettings.get("Storage",{}) # UNCOMMENT FOR DEBUG PURPOSE TO WATCH inGSettings on client side
|
|
||||||
}
|
|
||||||
# END :: Init result dict template :: END #
|
|
||||||
# START :: Fill BodyKeyValueList :: START #
|
|
||||||
|
|
||||||
# END :: Fill BodyKeyValueList :: END #
|
|
||||||
# START :: Fill SubheaderText :: START #
|
|
||||||
## FILL Robot state by the check the RDP session state
|
|
||||||
lSubheaderRunTrueText="State: <span style=\"color:green\">Turned on</span>"
|
|
||||||
lSubheaderRunFalseText="State: <span style=\"color:red\">Turned off</span>"
|
|
||||||
if gControlPanelCheckRobotProcessFromOrchestratorUserBool and gRDPSessionKeyStr in inGSettings["RobotRDPActive"]["RDPList"]:
|
|
||||||
lResultDict["SubheaderText"]=lSubheaderRunTrueText
|
|
||||||
else:
|
|
||||||
lResultDict["SubheaderText"]=lSubheaderRunFalseText
|
|
||||||
# END :: Fill SubheaderText :: END #
|
|
||||||
# Fill FooterText
|
|
||||||
lResultDict["FooterText"]=f'Last update: {datetime.datetime.now().strftime("%H:%M:%S %d.%m.%Y")}'
|
|
||||||
return lResultDict
|
|
||||||
|
|
||||||
# Technical def - Get item by the list of keys
|
|
||||||
def TechDictKeyList_ItemGet(inDict, inKeyList, inDefault={}):
|
|
||||||
lResult=inDict
|
|
||||||
for lItem in inKeyList:
|
|
||||||
if lResult:
|
|
||||||
lResult = lResult.get(lItem,None)
|
|
||||||
if lResult is None:
|
|
||||||
lResult=inDefault
|
|
||||||
return lResult
|
|
||||||
# # # # # # # # # # # # # # # # # # # # # # # #
|
|
||||||
# Scheduler to start/stop process
|
|
||||||
## Start ROBOT at time
|
|
||||||
lActivityTimeItemRobotStart = {
|
|
||||||
"TimeHH:MM": gActivityROBOTStartTimeHH_MMStr, #Time [HH:MM] to trigger activity
|
|
||||||
"WeekdayList": gActivityROBOTStartWeekdayList, #List of the weekday index when activity is applicable, Default [1,2,3,4,5,6,7]
|
|
||||||
"Activity":{
|
|
||||||
"Type": "GlobalDictKeyListValueOperator+", #Activity type
|
|
||||||
"KeyList": ['RobotRDPActive','ActivityList'], # RobotRDP Active ActivityList
|
|
||||||
"Value": gActivityROBOTStartList # ActivityList - see upper
|
|
||||||
}
|
|
||||||
}
|
|
||||||
## Force stop ROBOT at time
|
|
||||||
lActivityTimeItemRobotStop = {
|
|
||||||
"TimeHH:MM": gActivityROBOTStopTimeHH_MMStr, #Time [HH:MM] to trigger activity
|
|
||||||
"WeekdayList": gActivityROBOTStopWeekdayList, #List of the weekday index when activity is applicable, Default [1,2,3,4,5,6,7]
|
|
||||||
"Activity":{
|
|
||||||
"Type": "GlobalDictKeyListValueOperator+", #Activity type
|
|
||||||
"KeyList": ['RobotRDPActive','ActivityList'], # RobotRDP Active ActivityList
|
|
||||||
"Value": gActivityROBOTStopList # ActivityList - see upper
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#Orchestrator settings update
|
|
||||||
def SettingsUpdate(inGSettings):
|
|
||||||
#Add RobotRDPActive in control panel
|
|
||||||
inGSettings["ControlPanelDict"]["RobotList"].append({"RenderFunction": ControlPanelRenderDict, "KeyStr": gControlPanelKeyStr})
|
|
||||||
# Add scheduler activity in Scheduler.ActivityTimeList
|
|
||||||
inGSettings["Scheduler"]["ActivityTimeList"].append(lActivityTimeItemRobotStart)
|
|
||||||
inGSettings["Scheduler"]["ActivityTimeList"].append(lActivityTimeItemRobotStop)
|
|
||||||
return inGSettings
|
|
||||||
@ -0,0 +1,122 @@
|
|||||||
|
#### Settings file - all initialization goes here!
|
||||||
|
import sys #For std operations
|
||||||
|
import logging #Logger for robot
|
||||||
|
import datetime #For test purpose
|
||||||
|
import os # os defs
|
||||||
|
import socket # Detect VM name
|
||||||
|
from pyOpenRPA.Robot import OrchestratorConnector # Lib for connection with orchestrator
|
||||||
|
|
||||||
|
## # # # # # # # # # # # # # # # # ##
|
||||||
|
# GLOBAL PARAMETERS
|
||||||
|
gSettings = None
|
||||||
|
# Auto detect version which should be started
|
||||||
|
gHostnameVersionDict={ # Dict for versions
|
||||||
|
"MACHINE NAME DEV":"DEV", "MACHINE NAME TST":"TST", "MACHINE NAME PRD":"PRD"
|
||||||
|
}
|
||||||
|
gADLogin = "LOGIN"; gADPassword = "PASSWORD"
|
||||||
|
gResourceFullPath = os.path.join(os.getcwd(),"..\\Resources\\")
|
||||||
|
gSourceLocationRelative = r"..\Sources" # Path to Source folder, which contains package. Need if you want to import some py files from source package
|
||||||
|
sys.path.insert(0, os.path.abspath(gSourceLocationRelative)) # Add to has feature to import module from Source package pyPackageName
|
||||||
|
from pyPackage import pyModule # Import pyPackage from Source folder
|
||||||
|
|
||||||
|
## # # # # # # # # # # # # # # # # ##
|
||||||
|
# ORCHESTRATOR CONNECTION PARAMETERS
|
||||||
|
lOrchestratorHost="localhost"; lOrchestratorPort=8080
|
||||||
|
lOrchestratorProtocol="http"; lOrchestratorAuthToken="ORCHESTRATOR AUTH TOKEN"
|
||||||
|
|
||||||
|
## # # # # # # # # # # # # # # # # ##
|
||||||
|
gVMHostNameStr = socket.gethostname().upper() # Get VM host name
|
||||||
|
gVersionStr = gHostnameVersionDict[gVMHostNameStr] # DEV Or TST or PRD
|
||||||
|
gCWDAbsPathStr = os.getcwd()
|
||||||
|
|
||||||
|
## # # # # # # # # # # # # # # # # ##
|
||||||
|
# INIT GLOBAL DICT WITH ALL SETTINGS
|
||||||
|
if __name__ == "__main__":
|
||||||
|
gSettings={
|
||||||
|
"VersionStr":gVersionStr, # DEV Or TST or PRD
|
||||||
|
"Package_1": { # package description
|
||||||
|
"TempFolderPath": os.path.abspath("Temp"), # Temp location settings
|
||||||
|
"Folder": { # Listen network folder
|
||||||
|
"FolderReadyPostfixStr":"Ready", # Folder ready postfix
|
||||||
|
"FolderPathList": [ # DEV is below.
|
||||||
|
{ "PathStr": os.path.abspath(r"Test1"), "TypeStr": "TYPE1" },
|
||||||
|
{ "PathStr": os.path.abspath(r"Test2"), "TypeStr": "TYPE2" }
|
||||||
|
] if gVersionStr == "DEV" else [ # DEV is upper, TST is below
|
||||||
|
{"PathStr": os.path.abspath(r"Test1"), "TypeStr": "TYPE1"},
|
||||||
|
] if gVersionStr == "TST" else [ # TST is upper, PRD is below
|
||||||
|
{"PathStr": os.path.abspath(r"Test2"), "TypeStr": "TYPE2"},
|
||||||
|
] if gVersionStr == "PRD" else [], # PRD is upper, None is below
|
||||||
|
},
|
||||||
|
},
|
||||||
|
"Package_2": { "Key1":"Value1" }, # package description
|
||||||
|
"Package_3": { "Key1":"Value1" }, # package description
|
||||||
|
"BI": { # BI TOOL TO COLLECT BUSINESS EFFECTS
|
||||||
|
"VersionStr": gVersionStr, # DEV, TST, PRD
|
||||||
|
"ADUserStr": gADLogin, # USER SESSION, where robot is starting
|
||||||
|
"VMNameStr": gVMHostNameStr # Test VM
|
||||||
|
},
|
||||||
|
"Log": { # LOGGER
|
||||||
|
"Instance": logging.getLogger("pyFord"),
|
||||||
|
"ShowInConsoleBool" : True, #True - Show exception in console window
|
||||||
|
"FolderPathStr": f"Logs", #Folder path to save all logs
|
||||||
|
},
|
||||||
|
"Orchestrator": { # ORCHESTRATOR
|
||||||
|
"Storage": {
|
||||||
|
"O2R_Reset": {}, # Orchestrator to robot reset storage
|
||||||
|
"R2O_Const": {}, # Robot to orchestrator constant storage
|
||||||
|
"O2R_Const": {} # Orchestrator to robot constant storage
|
||||||
|
},
|
||||||
|
"TerminateDef": OrchestratorConnector.IntervalTerminateAll, # Call this function when program must be shutted down (to kill threads from OrchestratorConnector)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
## # # # # # # # # # # # # # # # # ##
|
||||||
|
# ORCHESTRATOR CONNECTOR INIT
|
||||||
|
gSettings["OrchestratorConnector"]={
|
||||||
|
"IntervalDataSendAsync": [
|
||||||
|
#{
|
||||||
|
# "Interval": 1.1,
|
||||||
|
# "RobotStorage": gSettings,
|
||||||
|
# "RobotStorageKey": "Statistics",
|
||||||
|
# "OrchestratorKeyList": ["Storage", "pyFord","RobotToOrchestrator","Statistics"],
|
||||||
|
# "OrchestratorProtocol": lOrchestratorProtocol, "OrchestratorHost": lOrchestratorHost,
|
||||||
|
# "OrchestratorPort": lOrchestratorPort, "OrchestratorAuthToken": lOrchestratorAuthToken
|
||||||
|
#}
|
||||||
|
],
|
||||||
|
"IntervalDataReceiveResetAsync": [
|
||||||
|
{
|
||||||
|
"Interval": 3,
|
||||||
|
"RobotStorage": gSettings,
|
||||||
|
"RobotStorageKey": "OrchestratorToRobotReset",
|
||||||
|
"RobotResetValue": {"TurnOffSafeBool":False},
|
||||||
|
"OrchestratorKeyList": ["Storage", "pyFord","OrchestratorToRobotReset"],
|
||||||
|
"OrchestratorProtocol": lOrchestratorProtocol, "OrchestratorHost": lOrchestratorHost,
|
||||||
|
"OrchestratorPort": lOrchestratorPort, "OrchestratorAuthToken": lOrchestratorAuthToken
|
||||||
|
}
|
||||||
|
],
|
||||||
|
"IntervalDataReceiveAsync": [ ]
|
||||||
|
}
|
||||||
|
OrchestratorConnector.LoggerSetLevelError() # Turn off many warnings from orchestrator connector logger
|
||||||
|
OrchestratorConnector.ConfigurationInit(gSettings["OrchestratorConnector"]) # Run OrchestratorConnector initialization
|
||||||
|
|
||||||
|
## # # # # # # # # # # # # # # # # ##
|
||||||
|
# LOGGER CONFIG
|
||||||
|
if not os.path.exists(gSettings["Log"]["FolderPathStr"]):
|
||||||
|
os.makedirs(gSettings["Log"]["FolderPathStr"])
|
||||||
|
lL=gSettings["Log"]["Instance"]
|
||||||
|
lL.setLevel(logging.INFO if gVersionStr == "PRD" else logging.DEBUG) # Log debug if not prd
|
||||||
|
# create the logging file handler
|
||||||
|
lLFH = logging.FileHandler(os.path.join(gSettings["Log"]["FolderPathStr"], datetime.datetime.now().strftime("%Y_%m_%d") + ".log"), encoding ="UTF-8")
|
||||||
|
lLF = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
|
||||||
|
lLFH.setFormatter(lLF)
|
||||||
|
lL.addHandler(lLFH) # add handler to logger object
|
||||||
|
if gSettings["Log"]["ShowInConsoleBool"]: # Add console output
|
||||||
|
handler = logging.StreamHandler(sys.stdout); handler.setFormatter(lLF); lL.addHandler(handler)
|
||||||
|
|
||||||
|
## # # # # # # # # # # # # # # # # ##
|
||||||
|
# START ROBOT
|
||||||
|
lL.info("# # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # #")
|
||||||
|
lL.info("ROBOT NAME ITERATION START")
|
||||||
|
lL.info("# # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # #")
|
||||||
|
lL.info(f"VM host name: {gVMHostNameStr}, Program version {gVersionStr}, Working directory: {gCWDAbsPathStr}") # Init info
|
||||||
|
pyModule.pyModule(inGSettings = gSettings) # Execute main def in Source/pyPackage.pyModule.pyModule
|
||||||
@ -0,0 +1,4 @@
|
|||||||
|
cd %~dp0
|
||||||
|
copy /Y ..\Resources\WPy64-3720\python-3.7.2.amd64\python.exe ..\Resources\WPy64-3720\python-3.7.2.amd64\pyRobotName.exe
|
||||||
|
..\Resources\WPy64-3720\python-3.7.2.amd64\pyRobotName.exe "pyRobotName_Settings.py"
|
||||||
|
pause >nul
|
||||||
Loading…
Reference in new issue