流程五脚本编写

air_case/b5_spd3_core_business_flow/a_a7流程五_中心库入库结算_正结算3_内网验收入库结算.air/a_a7流程五_中心库入库结算_正结算3_内网验收入库结算.py

@@ -118,7 +118,7 @@ def check_accept_order(type=1):
 
     sourceId = sourceOrderNo
     url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "check_wait_detail_url")
-    print('url',url)
+    print('url', url)
     request_body = commonFuc().get_business_data(module, "payload1", sourceId, sourceType, billMode, branch_id)
 
     # print('request_body',request_body)
@@ -126,8 +126,8 @@ def check_accept_order(type=1):
     while True:
         time.sleep(6)
         result = commonFuc().http_post(url, request_body, headers)
-        code=commonFuc().analysis_json('code',result)
-        if code==0:
+        code = commonFuc().analysis_json('code', result)
+        if code == 0:
             break
         else:
             print('验收单数据未同步完成，等待6秒')
@@ -218,7 +218,7 @@ def putaway():
     # # 获取token和projectCode
     token, projectCode, uxid, corpId, info = login_system(username, password).get_token()
     # 登录获取用户id等信息，使用创建的用户登录============结束
-    #=====================上架入库列表查询==========================
+    # =====================上架入库列表查询==========================
     headers = commonFuc().get_business_data(module, "json_headers2",
                                             commonFuc().get_business_data(module, "json_contentType"), token,
                                             projectCode)
@@ -229,12 +229,12 @@ def putaway():
     request_body = commonFuc().get_business_data(module, "payload6", branch_id, hosId)
     result = commonFuc().http_post(url, request_body, headers)
     print('result', result)
-    data=commonFuc().analysis_json('data', result)
-    total=commonFuc().analysis_json('total', data)
-    if total>=1:
+    data = commonFuc().analysis_json('data', result)
+    total = commonFuc().analysis_json('total', data)
+    if total >= 1:
         # 将上架入库列表数据写入文件
         data = commonFuc().analysis_json('data', result)
-        data1= commonFuc().analysis_json('data', data)
+        data1 = commonFuc().analysis_json('data', data)
         list_a = []
         list_b = []
         list_c = []
@@ -258,7 +258,7 @@ def putaway():
     info = FileUtils().r_info8('b5_spd3_core_business_flow', "上架入库列表数据", 'message16')
     list_a = info['list_a']
     print('list_a', list_a)
-    sourceId='sourceId'
+    sourceId = 'sourceId'
     for i in list_a:
         for j in i:
             sourceId = j['sourceId']
@@ -316,8 +316,8 @@ def putaway():
         print('i', i)
         for j in i:
             viewId = j["viewId"]
-            shelfCode=j['shelfCode']
-            sourceId=j['id']
+            shelfCode = j['shelfCode']
+            sourceId = j['id']
             break
     # 从message16文件中获取信息
     info = FileUtils().r_info8('b5_spd3_core_business_flow', "上架入库列表数据", 'message16')
@@ -326,18 +326,20 @@ def putaway():
     for i in list_a:
         for j in i:
             sourceId = j['sourceId']
-            targetAreaName= j['areaName']
-            targetAreaCode= j['areaCode']
+            targetAreaName = j['areaName']
+            targetAreaCode = j['areaCode']
             break
     request_body = commonFuc().get_business_data(module, "payload5", viewId, shelfCode, sourceId, sourceType,
                                                  sourceVersion, targetDeptId,
                                                  targetDeptName, targetAreaCode, targetAreaName)
-    print('request_body',request_body)
+    print('request_body', request_body)
     time.sleep(3)
     result = commonFuc().http_post(url, request_body, headers)
     print('result', result)
     # ================================入库上架================================
-def settle():#结算相关
+
+
+def settle():  # 结算相关
     # # 登录获取用户id等信息，使用创建的用户登录===========开始
     info = FileUtils().r_info8('b2_herp3_bs', "用户名信息", 'message3')
     # print(info)
@@ -352,44 +354,46 @@ def settle():#结算相关
     headers = commonFuc().get_business_data(module, "json_headers2",
                                             commonFuc().get_business_data(module, "json_contentType"), token,
                                             projectCode)
-    #================生成结算单列表查询===================
+    # ================生成结算单列表查询===================
     url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "mcmsOutUnBalance_listVoPage_url")
     print(url)
     branch_id = FileUtils().r_info('b2_herp3_bs', '院区新增')["branch_id"]
     hosId = branch_id[0:5]
-    request_body = commonFuc().get_business_data(module, "payload7", hosId,hosId)
+    request_body = commonFuc().get_business_data(module, "payload7", hosId, hosId)
     result = commonFuc().http_post(url, request_body, headers)
     print('result', result)
-    data=commonFuc().analysis_json('data',result)
-    data1=commonFuc().analysis_json('data',data)
-    #取结算单id
-    list_a=[]
+    data = commonFuc().analysis_json('data', result)
+    data1 = commonFuc().analysis_json('data', data)
+    # 取结算单id
+    list_a = []
     for i in data1:
-       id= commonFuc().analysis_json('id', i)
-       list_a.append(id)
+        id = commonFuc().analysis_json('id', i)
+        list_a.append(id)
     print(list_a)
-    print(list_a[0],list_a[1],type(list_a[0]))
-    #===================生成结算单列表查询======================
-    #================== 生成结算单==============================
-    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "mcmsOutUnBalance_genBalanceBill_url")
+    print(list_a[0], list_a[1], type(list_a[0]))
+    # ===================生成结算单列表查询======================
+    # ================== 生成结算单==============================
+    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
+                                                                             "mcmsOutUnBalance_genBalanceBill_url")
     print(url)
-    request_body = commonFuc().get_business_data(module, "payload8", hosId, list_a[0],list_a[1],hosId)
-    print('request_body',request_body)
+    request_body = commonFuc().get_business_data(module, "payload8", hosId, list_a[0], list_a[1], hosId)
+    print('request_body', request_body)
     result = commonFuc().http_post(url, request_body, headers)
     print('result', result)
     # ================== 生成结算单==============================
 
+
 try:
-    #验收
-    check_accept_order(1)#低值
-    check_accept_order(2)#高值
-    check_accept_order(3)#试剂
-    #入库上架
+    # 验收
+    check_accept_order(1)  # 低值
+    check_accept_order(2)  # 高值
+    check_accept_order(3)  # 试剂
+    # 入库上架
     putaway()
     putaway()
     putaway()
-    settle()#生成结算单
-    #调用审批结算单
+    settle()  # 生成结算单
+    # 调用审批结算单
     approval_center()
 except Exception as e:
     print('脚本出现异常，请检查脚本或者数据')

air_case/b5_spd3_core_business_flow/a_a8流程五_中心库入库结算_正结算3_外网开票.air/a_a8流程五_中心库入库结算_正结算3_外网开票.py

@@ -38,6 +38,7 @@ def invoice():
     module = "a6_mdm3_si"
     # 发票录入列表查询=================================================
     url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "listGoodsPage_url")
+    print('发票录入列表查询url',url)
     # 获取请求头信息
     headers = commonFuc().get_business_data(module, "json_headers2",
                                             commonFuc().get_business_data(module, "json_contentType"), token,
@@ -47,18 +48,27 @@ def invoice():
 
     # print('request_body',request_body)
     # 发送请求
+    i=1
     while True:
-        time.sleep(3)
+        time.sleep(6)
         result = commonFuc().http_post(url, request_body, headers)
         print('result', result)
         try:
             data = commonFuc().analysis_json('data', result)
-            data1 = commonFuc().analysis_json('data', data)
-            pid = commonFuc().analysis_json('pid', data1[0])
+            total = commonFuc().analysis_json('total', data)
+            if total==0:
+                print('数据暂时未同步过来，或者内网没有生成结算单')
+                i=i+1
+                if i >= 100:
+                    print('600秒过去了，数据还未查询出来，调用一下内网结算函数')
+                    settle()
+                    approval_center()
+                continue
+            else:
+                break
         except:
             continue
-        else:
-            break
+
     # 将发票信息写入文件
     data = commonFuc().analysis_json('data', result)
     data1 = commonFuc().analysis_json('data', data)
@@ -118,6 +128,7 @@ def invoice():
             viewId=j['viewId']
             break
     list2=[]
+    detailList=None
     for i in list_a:
         detailList = i['detailList']
     list2=detailList
@@ -181,8 +192,159 @@ def invoice():
     result = commonFuc().http_post(url, request_body, headers)
     print('result', result)
     #===============发票确认
+    #==============内网发票核对============
+    module = "b5_spd3_core_business_flow"
+    # # 登录获取用户id等信息，使用创建的用户登录===========开始
+    info = FileUtils().r_info8('b2_herp3_bs', "用户名信息", 'message3')
+    username = info['username1']
+    password = commonFuc().get_business_data("b2_herp3_bs", "password")
+    print('username,password', username, password)
+    # # 获取token和projectCode
+    token, projectCode, uxid, corpId, info = login(username, password,2)
+    # 登录获取用户id等信息，使用创建的用户登录============结束
+    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "mcmsInvoice_listVoPage_url")
+    print('url',url)
+    # 获取请求头信息
+    headers = commonFuc().get_business_data(module, "json_headers2",
+                                            commonFuc().get_business_data(module, "json_contentType"), token,
+                                            projectCode)
+    request_body = commonFuc().get_business_data(module, "payload9", timeUtils.get_time_hms(5),timeUtils.get_time_hms(5),get_hosid(),get_hosid())
+    print('request_body',request_body)
+    # 发送请求
+    i = 1
+    while True:
+        time.sleep(6)
+        result = commonFuc().http_post(url, request_body, headers)
+        print('result', result)
+        try:
+            data = commonFuc().analysis_json('data', result)
+            total = commonFuc().analysis_json('total', data)
+            if total == 0:
+                print('数据暂时未同步过来')
+                i = i + 1
+                if i >= 100:
+                    print('600秒过去了，数据还未查询出来，检查一下脚本或者被测软件')
+                continue
+            else:
+                break
+        except:
+            continue
+
+    print('result','内网发票核对', result)
+    data1=commonFuc().analysis_json('data',commonFuc().analysis_json('data',result))
+    VI_id=commonFuc().analysis_json('id',data1[0])
+    print('VI_id',VI_id)
+    #==============发票列表查询
+    #==============发票核对提交
+    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "mcmsInvoice_invoiceUpdateStatusList_url")
+    print('url', url)
+    request_body = commonFuc().get_business_data(module, "payload10",VI_id,get_hosid())
+    print('request_body', request_body)
+    result = commonFuc().http_post(url, request_body, headers)
+    print('result',result)
+    # ==============发票核对提交
+    #==============内网发票核对============
+    #==============内网发票提交开始
+    #列表查询
+    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
+                                                                             "mcmsInvoice_listVoPage_url")
+    print('url', url)
+    request_body = commonFuc().get_business_data(module, "payload11",timeUtils.get_time_hms(5),timeUtils.get_time_hms(5),get_hosid(),get_hosid())
+    print('request_body', request_body)
+    result = commonFuc().http_post(url, request_body, headers)
+    print('result','内网发票提交列表查询结果', result)
+    data1 = commonFuc().analysis_json('data', commonFuc().analysis_json('data', result))
+    total=commonFuc().analysis_json('total', commonFuc().analysis_json('data', result))
+    if total==0:
+        print('检查被测程序，发票提交列表查询数据是否正确')
+    else:
+        for i in range(total):
+            VI_id2 = commonFuc().analysis_json('id', data1[i])
+            if VI_id2==VI_id:
+                break
+    print('VI_id2', VI_id2)
+    # ==============发票提交,下一步归档
+    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
+                                                                             "mcmsInvoice_invoiceUpdateStatusList_url")
+    print('url', url)
+    request_body = commonFuc().get_business_data(module, "payload12", VI_id, get_hosid())
+    print('request_body', request_body)
+    result = commonFuc().http_post(url, request_body, headers)
+    print('result','发票提交,下一步归档', result)
+    # ==============发票提交，下一步归档
+    #==============发票归档列表查询
+    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
+                                                                             "mcmsInvoice_listVoPage_url")
+    print('url', url)
+    request_body = commonFuc().get_business_data(module, "payload13", timeUtils.get_time_hms(5),
+                                                 timeUtils.get_time_hms(5), get_hosid(), get_hosid())
+    print('request_body', request_body)
+    result = commonFuc().http_post(url, request_body, headers)
+    print('result', '发票归档列表查询', result)
+    data1 = commonFuc().analysis_json('data', commonFuc().analysis_json('data', result))
+    total = commonFuc().analysis_json('total', commonFuc().analysis_json('data', result))
+    if total == 0:
+        print('检查被测程序，发票归档列表查询查询数据是否正确')
+    else:
+        for i in range(total):
+            VI_id3 = commonFuc().analysis_json('id', data1[i])
+            if VI_id3 == VI_id2:
+                break
+    print('VI_id3', VI_id3)
+    # ==============发票归档列表查询
+    #==================发票归档提交
+    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
+                                                                             "mcmsInvoice_invoiceUpdateStatusList_url")
+    print('url', url)
+    request_body = commonFuc().get_business_data(module, "payload14", VI_id, get_hosid())
+    print('request_body', request_body)
+    result = commonFuc().http_post(url, request_body, headers)
+    print('result', '发票归档提交,下一步付款', result)
+    #==================发票归档提交
+    #==================付款单列表查询
+    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
+                                                                             "mcmsInvoice_listVoPage_url")
+    print('url', url)
+    request_body = commonFuc().get_business_data(module, "payload15", get_hosid(), get_hosid())
+    print('request_body', request_body)
+    result = commonFuc().http_post(url, request_body, headers)
+    print('result', '付款单列表查询', result)
+    data1 = commonFuc().analysis_json('data', commonFuc().analysis_json('data', result))
+    total = commonFuc().analysis_json('total', commonFuc().analysis_json('data', result))
+    if total == 0:
+        print('检查被测程序，发票归档列表查询查询数据是否正确')
+    else:
+        for i in range(total):
+            VI_id4 = commonFuc().analysis_json('id', data1[i])
+            if VI_id4 == VI_id3:
+                break
+    print('VI_id4', VI_id4)
+    #==================付款单列表查询
+    # ==================付款提交
+    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
+                                                                             "mcmsInvoice_genPaymentBills_url")
+    print('url', url)
+    request_body = commonFuc().get_business_data(module, "payload16", VI_id, get_hosid())
+    print('request_body', request_body)
+    result = commonFuc().http_post(url, request_body, headers)
+    print('result', '付款提交', result)
+    # 断言
+    code = commonFuc().analysis_json('code', result)
+    data = commonFuc().analysis_json('data', result)
+    if code == 0 and data== 1:
+        commonFuc().check_text_exist(0, result)
+    else:
+        commonFuc().check_text_exist('error', result)
+    # ==================付款提交
+
+    # ==============内网发票提交
+
+
 
 try:
+    settle()
+    # 调用审批结算单
+    approval_center()
     invoice()
 except Exception as e:
     print('脚本出现异常，请检查脚本或者数据')

air_case/public1/public1/public1.py

@@ -90,4 +90,48 @@ def login(username,password,type=1):
     else:
         from air_case.b1_herp3_login.登录内网系统.登录内网系统 import login_system
         token, projectCode, uxid, corpId, info = login_system(username, password).get_token()
-    return token, projectCode, uxid, corpId, info
+    return token, projectCode, uxid, corpId, info
\ No newline at end of file
+
+def settle():  # 结算相关
+    module = "b5_spd3_core_business_flow"
+    # # 登录获取用户id等信息，使用创建的用户登录===========开始
+    info = FileUtils().r_info8('b2_herp3_bs', "用户名信息", 'message3')
+    # print(info)
+    username = info['username1']
+    password = commonFuc().get_business_data("b2_herp3_bs", "password")
+
+    print('username,password', username, password)
+    # # print(username, password,'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa')
+    # # 获取token和projectCode
+    token, projectCode, uxid, corpId, info = login_system(username, password).get_token()
+    # 登录获取用户id等信息，使用创建的用户登录============结束
+    headers = commonFuc().get_business_data(module, "json_headers2",
+                                            commonFuc().get_business_data(module, "json_contentType"), token,
+                                            projectCode)
+    # ================生成结算单列表查询===================
+    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "mcmsOutUnBalance_listVoPage_url")
+    print(url)
+    branch_id = FileUtils().r_info('b2_herp3_bs', '院区新增')["branch_id"]
+    hosId = branch_id[0:5]
+    request_body = commonFuc().get_business_data(module, "payload7", hosId, hosId)
+    result = commonFuc().http_post(url, request_body, headers)
+    print('result', result)
+    data = commonFuc().analysis_json('data', result)
+    data1 = commonFuc().analysis_json('data', data)
+    # 取结算单id
+    list_a = []
+    for i in data1:
+        id = commonFuc().analysis_json('id', i)
+        list_a.append(id)
+    print(list_a)
+    print(list_a[0], list_a[1], type(list_a[0]))
+    # ===================生成结算单列表查询======================
+    # ================== 生成结算单==============================
+    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
+                                                                             "mcmsOutUnBalance_genBalanceBill_url")
+    print(url)
+    request_body = commonFuc().get_business_data(module, "payload8", hosId, list_a[0], list_a[1], hosId)
+    print('request_body', request_body)
+    result = commonFuc().http_post(url, request_body, headers)
+    print('result', result)
+    # ================== 生成结算单==============================
\ No newline at end of file

data/a2_mdm3_ea/message

 企业信息:
-  e_id: CR202404240057
-  cname: 国药集团公司BJong
+  e_id: CR202404250076
+  cname: 国药集团公司bcmfE

data/a3_mdm3_hs/message

 医院信息:
-  h_id: 湖南省人民医院9n8tw
-  h_name: 湖南省人民医院9n8tw
+  h_id: 湖南省人民医院zkOr^
+  h_name: 湖南省人民医院zkOr^

data/a5_mdm3_pdm/message2

 产品审核信息:
-  MSPid: MSP2404240017_1
+  MSPid: MSP2404250022_1
   hosId: h0347
-  hosGoodsId: h034700003083
-  provGoodsid: provGood-99220192
-  goodsAuditBillId: MSP2404240017
-  targetId: MSP2404240017_1
+  hosGoodsId: h034700003116
+  provGoodsid: provGood-99220225
+  goodsAuditBillId: MSP2404250022
+  targetId: MSP2404250022_1

data/b2_herp3_bs/message

 院区新增:
-  branch_id: h0347-3516
-  branch_name: 东土城路院区W%SH#
+  branch_id: h0347-3519
+  branch_name: 东土城路院区dD7&m
 科室信息:
-  dept2_id: 6060ec04938e4c7181bb51fb04a7f7da
+  dept2_id: 0538cdc4d76142c988c53927079462cd
   dept2_name: 二级检验科002

data/b5_spd3_core_business_flow/data

@@ -7,7 +7,9 @@
 "stock_in_page_url": "/api/herpService/stock/in/page"
 "mcmsOutUnBalance_listVoPage_url": "/api/herpService/mcmsOutUnBalance/listVoPage"
 "mcmsOutUnBalance_genBalanceBill_url": "/api/herpService/mcmsOutUnBalance/genBalanceBill"
-
+"mcmsInvoice_listVoPage_url": "/api/herpService/mcmsInvoice/listVoPage"
+"mcmsInvoice_invoiceUpdateStatusList_url": "/api/herpService/mcmsInvoice/invoiceUpdateStatusList"
+"mcmsInvoice_genPaymentBills_url": "/api/herpService/mcmsInvoice/genPaymentBills"
 
 "username": "xhs1009"
 "password": "1qaz!QAZ"
@@ -30,4 +32,12 @@ json_headers2: {
 "payload5": {"batchList":[{"viewId":"%s","shelfCode":"%s"}],"sourceId":"%s","sourceType":"%s","sourceVersion":"%s","targetDeptId":"%s","targetDeptName":"%s","targetAreaCode":"%s","targetAreaName":"%s","pkgTaskId":null}
 "payload6": {"pageNum":1,"pageSize":50,"orderBy":"","queryObject":{"branchId":"%s","taskType":0,"stockKind":"","sourceOrgName":"","hosId":"%s"}}
 "payload7": {"pageNum":1,"pageSize":50,"queryObject":{"goodsInfo":"","barCodeInfo":"","fromOrderNo":"","purModeList":[],"accountDate1":"","accountDate2":"","tbStatus":0,"hosId":"%s"},"hosId":"%s"}
-"payload8": {"genTypeEnum":"0","queryInfo":{"pageNum":1,"pageSize":50,"queryObject":{"goodsInfo":"","barCodeInfo":"","fromOrderNo":"","purModeList":[],"accountDate1":"","accountDate2":"","tbStatus":0,"hosId":"%s"}},"idList":["%s","%s"],"hosId":"%s"}
+"payload8": {"genTypeEnum":"0","queryInfo":{"pageNum":1,"pageSize":50,"queryObject":{"goodsInfo":"","barCodeInfo":"","fromOrderNo":"","purModeList":[],"accountDate1":"","accountDate2":"","tbStatus":0,"hosId":"%s"}},"idList":["%s","%s"],"hosId":"%s"}
\ No newline at end of file
+"payload9": {"pageNum":1,"pageSize":50,"queryObject":{"invoiceNumber":"","invoiceDate1":"%s","invoiceDate2":"%s","tbStatus":"10","hosId":"%s"},"hosId":"%s"}
+"payload10": {"billList":[{"id":"%s","version":1}],"tbStatus":"15","comment":"","hosId":"%s"}
+"payload11": {"pageNum":1,"pageSize":50,"queryObject":{"invoiceNumber":"","invoiceDate1":"","invoiceDate2":"","checkDate1":"%s","checkDate2":"%s","tbStatus":"15","hosId":"%s"},"hosId":"%s"}
+"payload12": {"billList":[{"id":"%s","version":2}],"tbStatus":"20","hosId":"%s"}
+"payload13": {"pageNum":1,"pageSize":50,"queryObject":{"invoiceNumber":"","invoiceDate1":"%sT01:18:05.672Z","invoiceDate2":"%sT01:18:05.672Z","checkDate1":"","checkDate2":"","tbStatus":"20","hosId":"%s"},"hosId":"%s"}
+"payload14": {"billList":[{"id":"%s","version":3}],"tbStatus":"30","hosId":"%s"}
+"payload15": {"pageNum":1,"pageSize":50,"queryObject":{"invoiceNumber":"","invoiceDate1":"","invoiceDate2":"","checkDate1":"","checkDate2":"","tbStatus":"30","hosId":"%s"},"hosId":"%s"}
+"payload16": {"invoiceBillIdList":["%s"],"payChannelEnum":"YGPT","hosId":"%s"}
\ No newline at end of file

report/summary.html

@@ -56,7 +56,7 @@
         <tr width="600">
             <td class='details-col-elapsed'>1</td>
             <td class='details-col-elapsed'>1</td>
-            <td class='details-col-elapsed'>0分7秒</td>
+            <td class='details-col-elapsed'>0分25秒</td>
             <td class="details-col-elapsed">100.0%</td>
         </tr>
     </table>
@@ -74,7 +74,7 @@
         <tr width="600">
             <td class="details-col-elapsed"><a href='../log/a_a8流程五_中心库入库结算_正结算3_外网开票/log.html' target='_blank'>a_a8流程五_中心库入库结算_正结算3_外网开票</a></td>
             <td class="success">成功</td>
-            <td class="details-col-elapsed">6.979</td>
+            <td class="details-col-elapsed">25.005</td>
             <td class="details-col-elapsed">xiaohesheng</td>
         </tr>