使用Python在SAP GUI中进行多处理

Question

我的汁液很老，我无法用它拨打API。因此，我必须操纵SAP的GUI才能做我的事情。

我正在尝试使用Python在两个不同的窗口中同时访问两项SAP交易。

为此，我正在使用库：pywin32，子进程和多处理。

但是我会收到以下错误：

TypeError：无法泡菜'Pyidispatch'对象

和

常规：[WinError 5] Acess拒绝

我到目前为止所获得的是打开两个窗口（创建两个SAP GUI会话），并在不同的窗口中访问交易，但一个接一个地，换句话说，而不是同时。

该测试程序构成3个分开的脚本：

• 一个类可以创建连接，创建第一个会话并登录到帐户中。
• 第二类是“操纵” SAP GUI
• 最后一个是主要脚本。

脚本：

1. createConnection.py

     subcrocess Import popen
   进口时间
   来自win32com.client import getObject
   
   
   SAP类：
       def __init __（self，sap_env，user_id，user_password，语言=“ en”，
           新闻= false，connectby = 2）：
           self.sap_file =“ c：\\ program文件（x86）\\ sap \\ frontend \\ sapgui” +\ \ \ \ \ \ \ \ \
                           “ \\ saplogon.exe”
           self.sap_env = sap_env
           self.user_id = user_id
           self.user_password = user_password
           self.language =语言
           self.connectby =连接
           self.newsession =新闻
   
       def __get_sap_gui __（self）：
           尝试：
               返回getObject（'sapgui'）。getCriptingEngine
           除了：
               时间。
               返回self .__ get_sap_gui __（）
   
       def get_sap_connection（self）：
           如果self.connectby == 3：
               popen（self.sap_file +'' + self.sap_env）
               sapgui = self .__ get_sap_gui __（）
               conn = sapgui.connections（0）
               超时= 10
               而conn.sessions.count == 0和超时：
                   时间。
                   超时 -  = 1
               如果超时== 0：提高异常（“无法连接”）
           别的：
               popen（self.sap_file）
               sapgui = self .__ get_sap_gui __（）
               conn =无
               如果self.connectby == 1：
                   如果sapgui.connections.count＆gt; 0：＃不好，我稍后再解决
                       对于sapgui.connections中的conn：
                           如果conn.description == self.sap_env：
                               休息
                   如果不是conn：
                       conn = sapgui.openconnection（self.sap_env）
               别的：
                   如果sapgui.connections.count＆gt; 0：
                       对于sapgui.connections中的conn：
                           如果在conn.connectionstring中self.sap_env：
                               休息
                   如果不是conn：
                       conn = sapgui.openconnectionbyconnectionstring（self.sap_env）
           返回连接
   
       def get_sap_session（self，conn）：
           如果self.newsession：
               numsessions = conn.sessions.count + 1
               conn.sessions（0）.createsession（）
               而Conn.Sessions.Count＆Lt;数字：通过
               session = conn.sessions（numsessions-1）
           别的：
               会话= conn.sessions（0）
   
           如果session.findbyid（'wnd [0]/sbar'）。text.startswith（'snc登录'）：
               session.findbyid（'wnd [0]/usr/txtrsyst-langu'）。text = self.language
               session.findbyid（'wnd [0]'）。sendvkey（0）
               session.findbyid（'wnd [0]'）。sendvkey（0）
           elif session.info.user ==''：
               session.findbyid（'wnd [0]/usr/txtrsyst-bname'）。text = self.user_id
               session.findbyid（'wnd [0]/usr/pwdrsyst-bcode'）。文本= \
                   self.user_password
               session.findbyid（'wnd [0]/usr/txtrsyst-langu'）。text = self.language
               session.findbyid（'wnd [0]'）。sendvkey（0）
           session.findbyid（'wnd [0]'）。最大化（）
           返回会话
    

2. manipulatesap.py

    
   从createConnection导入SAP
   
   
   类Querysap（SAP）：
       def __init __（self，sap_env，user_id，user_password，语言）：
           super（）。
           self.connection = self.get_sap_connection（）
           self.session = self.get_sap_session（self.connection）
           self.new_session =无
   
       def open_new_windows（self）：
           self.connection。课程（0）.createsession（）
           self.connection。课程（0）.createsession（）
           self.new_session = self.connection.sessions（1）
   
       @财产
       def sess1（self）：
           返回自我
   
       @财产
       def sess2（self）：
           返回self.new_session
    

3. main.py

    来自ManiPulateSap Import QuerySap
   从多处理进口池，过程
   从时间进口睡眠
   
   def goto_trasaction（会话，transacion）：
       session.findbyid（“ wnd [0]/tbar [0]/okcd”）。text = transacion
       session.findbyid（“ wnd [0]”）。sendvkey（0）
       睡眠（5）
   
   
   def sap_interface_multi_process（USR，PW，Env）：
       sap_nav = querysap（sap_env = env，user_id = usr，user_password = pw，
                          语言=“ pt”）
       sap_nav.open_new_windows（）
       session1 = sap_nav.sess1
       session2 = sap_nav.sess2
       p1 = process（target = goto_trasaction，args =（session1，“ transacion a”））
       p2 = process（target = goto_trasaction，args =（session2，“ transaction b”））
       p1.start（）
       p2.start（）
       p1.join（）
       p1.join（）
   
   def main（）：
       打印（“＆gt;＆gt;＆gt; start”）
       sap_env =“ string_for_connection”
       sap_interface_multi_process（“ usr_id”，“ usr_pw”，sap_env）
       打印（“＆gt;＆gt;＆gt; terinial”）
   
   如果__name__ ==“ __ -main __”：
       主要的（）
    

你们能帮我找到我想念的东西以及我应该做什么吗？

非常感谢。

Answer 1

终于，在VACTION的一段时间后，我得到了解决方案。

但是我不得不重复大量的代码。

我所做的是将SAP类实例化到一个对象，然后将此对象传递给将在并行执行的函数。在此功能内部，我使用SAP类方法来创建连接并创建会话。

这是我的解决方案。不漂亮，但是有效：

from Modules.Sap.sapinit import Sap

def create_sap_session(sap_obj,  extra_num_sessions):
    sap_conn = sap_obj.get_sap_connection()
    sap_obj.get_sap_session(sap_conn)
    if extra_num_sessions < 1:
        return
    for _ in range(extra_num_sessions):
        sap_conn.Sessions(0).createsession()
    return

def parallel_sap_query(sap_obj, sessions_num, transaction):
    sap_conn = sap_obj.get_sap_connection()
    sap_session = sap_conn.Sessions(sessions_num)
    session.findById("wnd[0]/tbar[0]/okcd").text = transaction
    session.findById("wnd[0]").sendVKey(0)

def execute_cancellations(sap_obj):
    create_sap_session(sap_obj, 2)
    sleep(3)
    p1 = Process(target=parallel_sap_query, args=(sap_obj, 0, "A", ))
    p2 = Process(target=parallel_sap_query, args=(sap_obj, 1, "B", ))
    p3 = Process(target=parallel_sap_query, args=(sap_obj, 2, "C", ))
    p1.start()
    p2.start()
    p3.start()
    p1.join()
    p2.join()
    p3.join()
    close_sap_sessions(sap_obj, 2, 1, 0)

def close_sap_sessions(sap_obj, *sessions):
    sap_conn = sap_obj.get_sap_connection()
    for session in sessions:
        sap_session = sap_conn.Sessions(session)
        sap_session.findById("wnd[0]").close()
    sap_session.findById("wnd[1]/usr/btnSPOP-OPTION1").press()


def main():
    sap_obj = Sap(sap_env, sap_id, sap_pw, "PT")
    execute_cancellations(sap_obj)