Skip to content
GitLab
Commit f201bb40 authored by xiao-hesheng's avatar xiao-hesheng
Browse files

流程五脚本提交

parent 8d272716
Hide whitespace changes
Inline Side-by-side
air_case/b6_spd3_core_business_flow_database_check/a_a1_流程一外网企业注册审批_数据库验证.air/a_a1_流程一外网企业注册审批_数据库验证.py
View file @ f201bb40
...@@ -17,14 +17,12 @@ from air_case.b1_herp3_login.登录内网系统.登录内网系统 import login_ ...@@ -17,14 +17,12 @@ from air_case.b1_herp3_login.登录内网系统.登录内网系统 import login_
from airtest.core.api import using from airtest.core.api import using
import sys import sys
pro_path = commonFuc().get_pro_path2()
print('pro_path', pro_path)
sys.path.append(pro_path + r'/air_case/b5_spd3_core_business_flow/a_a1_流程一外网企业注册审批.air')
using(pro_path + r'//air_case/b5_spd3_core_business_flow/a_a1_流程一外网企业注册审批.air')
from a_a1_流程一外网企业注册审批 import test1
def test1():
#企业注册
execute_command("python runner_test.py tag id2232 debug mdm3")
#企业审核
execute_command("python runner_test.py tag id2248 debug mdm3")
#医院注册审核
execute_command("python runner_test.py tag id2249 debug mdm3")
try: try:
test1() test1()
commonFuc().check_text_exist_result_text('succees','succees') commonFuc().check_text_exist_result_text('succees','succees')
......
air_case/b6_spd3_core_business_flow_database_check/a_a2_流程二供货关系申请提交审批_数据库验证.air/a_a2_流程二供货关系申请提交审批_数据库验证.py
View file @ f201bb40
...@@ -13,167 +13,27 @@ from common.common_func import commonFuc ...@@ -13,167 +13,27 @@ from common.common_func import commonFuc
from air_case.mdm_login.登录外网系统.登录外网系统 import login_system from air_case.mdm_login.登录外网系统.登录外网系统 import login_system
from airtest.core.api import using from airtest.core.api import using
import sys import sys
module = "b6_spd3_core_business_flow_database_check"
def h_login():
#供货关系申请_客户类型_医院_登录_医院登录获取医院id pro_path = commonFuc().get_pro_path2()
module = "a4_mdm3_cm" print('pro_path', pro_path)
#如果需要h0347医院账号登录,这里就从data文件获取登录医院的用户名 sys.path.append(pro_path + r'/air_case/b5_spd3_core_business_flow/a_a2_流程二供货关系申请提交审批.air')
#username = commonFuc().get_business_data(module, "username") using(pro_path + r'//air_case/b5_spd3_core_business_flow/a_a2_流程二供货关系申请提交审批.air')
from a_a2_流程二供货关系申请提交审批 import h_login, e_login, supply_and_marketing_apply, submitSupplyRelation_pass, \
supply_and_marketing_apply2
username = commonFuc().get_business_data(module, "username")
password = commonFuc().get_business_data(module, "password1")
print('医院名称', username)
print(username, password,'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa')
# 获取token和projectCode
import time
while True:
try:
token,projectCode,uxid,corpId,info= login_system(username, password).get_token()
except:
time.sleep(6)
continue
else:
return token,projectCode,uxid,corpId,username
def e_login(type=1):
module = "a4_mdm3_cm"
username='username'
if type==1:#注册一个新企业，并审批
pro_path=commonFuc().get_pro_path()
sys.path.append(pro_path+r'\\air_case\\a2_mdm3_ea\\企业审核.air')
using(pro_path+r'\\air_case\\a2_mdm3_ea\\企业审核.air')
from 企业审核 import test1
info = FileUtils().r_info("a2_mdm3_ea", "企业信息")
print(info)
username = info['cname']
print('aaaaaaaaaaaaaaaaaaaaaaaaaaa',username)
else:#读取文件中存入的企业信息
info = FileUtils().r_info("a2_mdm3_ea", "企业信息")
print(info)
username = info['cname']
print('aaaaaaaaaaaaaaaaaaaaaaaaaaa', username)
#a2供货关系申请_客户类型_医院_登录_企业登录
# print('医院名称',username)
password = commonFuc().get_business_data(module, "password")
print(username, password)
# 获取token和projectCode
import time
i=1
while True:
if i==1000:
print('6000秒过去了，新注册的企业还未登录,检查同步是否正常')
break
try:
token,projectCode,uxid,corpId,info= login_system(username, password).get_token()
except:
print('新注册的企业登录失败,等待6秒')
time.sleep(6)
i=i+1
continue
else:
return token, projectCode, uxid, corpId, username
# break
def supply_and_marketing_apply():
token, projectCode, uxid, corpId, username = e_login()
# 获取医院corpId
h_token, h_projectCode, h_uxid, h_corpId, h_name = h_login()
module = "a4_mdm3_cm"
# a3供货关系申请_客户类型_医院_供销关系申请提交
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "submitSupplyRelation_url")
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
projectCode)
contactUser = commonFuc().randomString(5)
contactWay = contactUser
request_body = commonFuc().get_business_data(module, "payload", h_corpId, contactUser, contactWay)
# 发送请求
result = commonFuc().http_post(url, request_body, headers)
print('result', result)
# #获取接口返回数据
#
check_dict = commonFuc().get_business_data(module, "checkDict")
commonFuc().check_result(check_dict, result)
e_corpId = corpId
e_username = username
return e_corpId, h_corpId, e_username, h_name
def submitSupplyRelation_pass():
module = "a4_mdm3_cm"
token, projectCode, uxid, corpId, h_name = h_login()
print(token, projectCode, uxid, corpId, h_name)
pro_path = commonFuc().get_pro_path()
#查询待审核数据=========================================
# a11供货关系审核_驳回_客户类型_医院_供销关系审核_查询待审核数据1
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "listVoPage_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, "payload6", corpId)
# 发送请求
result = commonFuc().http_post(url, request_body, headers)
print('result', result)
id1 = commonFuc().analysis_json('id', commonFuc().analysis_json('data', commonFuc().analysis_json('data', result)))
print('id1', id1)
# 查询待审核数据======================================
#b15供货关系审核_通过_客户类型_医院
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "auditSupplyRelation_url")
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
projectCode)
contactUser=commonFuc().randomString(5)
contactWay=contactUser
request_body = commonFuc().get_business_data(module, "payload7_2", id1,contactUser,contactWay)
# 发送请求
result = commonFuc().http_post(url, request_body, headers)
print('result', result)
#断言
checkDict=commonFuc().get_business_data(module,'checkDict')
commonFuc().check_result(checkDict,result)
def supply_and_marketing_apply2():
pro_path=commonFuc().get_pro_path()
token,projectCode,uxid,corpId,username=e_login(2)
#获取医院corpId
h_token,h_projectCode,h_uxid,h_corpId,h_name=h_login()
module = "a4_mdm3_cm"
#a3供货关系申请_客户类型_医院_供销关系申请提交
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "submitSupplyRelation_url")
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
projectCode)
contactUser=commonFuc().randomString(5)
contactWay=contactUser
request_body = commonFuc().get_business_data(module, "payload_2",h_corpId,contactUser,contactWay)
# 发送请求
result = commonFuc().http_post(url, request_body, headers)
print('result',result)
# #获取接口返回数据
#
check_dict= commonFuc().get_business_data(module, "checkDict")
commonFuc().check_result(check_dict,result)
e_corpId=corpId
e_username=username
return e_corpId,h_corpId,e_username,h_name
try: try:
h_login()#医院登录 module = "b5_spd3_core_business_flow"
e_login(1)#企业登录 h_login() # 医院登录
#供应关系申请-客户类型医院 e_login(1) # 企业登录
# 供应关系申请-客户类型医院
FileUtils().w_info1(supply_and_marketing_apply(), module, '供货关系申请') FileUtils().w_info1(supply_and_marketing_apply(), module, '供货关系申请')
submitSupplyRelation_pass() submitSupplyRelation_pass()
#供应关系申请-客户类型厂商 # 供应关系申请-客户类型厂商
FileUtils().w_info1(supply_and_marketing_apply2(), module, '供货关系申请2') FileUtils().w_info1(supply_and_marketing_apply2(), module, '供货关系申请2')
submitSupplyRelation_pass() submitSupplyRelation_pass()
commonFuc().check_text_exist_result_text('succees','succees') commonFuc().check_text_exist_result_text('succees', 'succees')
except: print('=================流程二结束=================')
print('a_a2_流程二供货关系申请提交审批,出现异常,请检查') except Exception as e:
\ No newline at end of file # 打印错误信息
print(f"发生错误: {e}")
print('a_a2_流程二供货关系申请提交审批,出现异常,请检查')
air_case/b6_spd3_core_business_flow_database_check/a_a3_流程三_产品导入和审批_数据库验证.air/a_a3_流程三_产品导入和审批_数据库验证.py
View file @ f201bb40
...@@ -16,381 +16,33 @@ from air_case.mdm_login.登录外网系统.登录外网系统 import login_syste ...@@ -16,381 +16,33 @@ from air_case.mdm_login.登录外网系统.登录外网系统 import login_syste
from airtest.core.api import using from airtest.core.api import using
import sys import sys
module = "b6_spd3_core_business_flow_database_check"
def h_login():
module = "a4_mdm3_cm"
username = commonFuc().get_business_data(module, "username")
password = commonFuc().get_business_data(module, "password1")
print('医院名称', username)
print(username, password, 'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa')
# 获取token和projectCode
import time
while True:
try:
token, projectCode, uxid, corpId, info = login_system(username, password).get_token()
except:
time.sleep(6)
continue
else:
return token, projectCode, uxid, corpId, username
def e_login(type=1):
module = "a4_mdm3_cm"
username = 'username'
if type == 1: # 注册一个新企业，并审批
pro_path = commonFuc().get_pro_path()
sys.path.append(pro_path + r'\\air_case\\a2_mdm3_ea\\企业审核.air')
using(pro_path + r'\\air_case\\a2_mdm3_ea\\企业审核.air')
from 企业审核 import test1
info = FileUtils().r_info("a2_mdm3_ea", "企业信息")
print(info)
username = info['cname']
print('aaaaaaaaaaaaaaaaaaaaaaaaaaa', username)
else: # 读取文件中存入的企业信息
info = FileUtils().r_info("a2_mdm3_ea", "企业信息")
print(info)
username = info['cname']
print('aaaaaaaaaaaaaaaaaaaaaaaaaaa', username)
# a2供货关系申请_客户类型_医院_登录_企业登录
# print('医院名称',username)
password = commonFuc().get_business_data(module, "password")
print(username, password)
# 获取token和projectCode
import time
while True:
try:
token, projectCode, uxid, corpId, info = login_system(username, password).get_token()
except:
time.sleep(6)
continue
else:
return token, projectCode, uxid, corpId, username
# break
# 高值
def add_goods():
token, projectCode, uxid, corpId, e_name = e_login(2)
# 获取医院corpId
h_token, h_projectCode, h_uxid, h_corpId, h_name = h_login()
module = "a5_mdm3_pdm"
# b18供货目录申请_客户类型_医院_提交供货申请单_添加产品
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "addGoodsHandleInfos_url")
print('url', url)
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
projectCode)
goodsname = commonFuc().randomString(5)
request_body = commonFuc().get_business_data(module, "payload_1", h_corpId, h_name, corpId, e_name, goodsname,
e_name)
# request_body = commonFuc().get_business_data(module, "payload10_1")
# 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:
commonFuc().check_text_exist(code, result)
else:
commonFuc().check_text_exist(-1, result)
def apply():
module = "a5_mdm3_pdm"
token, projectCode, uxid, corpId, username = e_login(2)
# 获取医院corpId
h_token, h_projectCode, h_uxid, h_corpId, h_name = h_login()
# 登录
username = h_name
password = commonFuc().get_business_data(module, "password1")
print(username, password)
# 获取token和projectCode
token, projectCode, uxid, corpId, info = login_system(username, password).get_token()
# 审批产品驳回
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "singleAudit_url")
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
projectCode)
info = FileUtils().r_info6(module, "产品审核信息", 'message2')
print(info)
MSPid = info['MSPid']
hosId = info['hosId']
hosGoodsId = info['hosGoodsId']
provGoodsid = info['provGoodsid']
goodsAuditBillId = info['goodsAuditBillId']
targetId = info['targetId']
request_body = commonFuc().get_business_data(module, "payload3_1", MSPid, hosId, hosGoodsId, provGoodsid,
goodsAuditBillId, targetId)
print('产品信息审核查询请求体', request_body)
# 发送请求
result = commonFuc().http_post(url, request_body, headers)
print("产品信息审核查询返回结果", result)
checkDict = commonFuc().get_business_data(module, 'checkDict')
commonFuc().check_result(checkDict, result)
def select1(messageNO='message2'):
module = "a5_mdm3_pdm"
token, projectCode, uxid, corpId, username = e_login(2)
# 获取医院corpId
h_token, h_projectCode, h_uxid, h_corpId, h_name = h_login()
# 登录
username = h_name
password = commonFuc().get_business_data(module, "password1")
print(username, password)
# 获取token和projectCode
token, projectCode, uxid, corpId, info = login_system(username, password).get_token()
# 产品信息审核查询
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "getAuditGoodsListByPage_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, "payload2", h_corpId)
# print('产品信息审核查询请求体', request_body)
# 发送请求
result = commonFuc().http_post(url, request_body, headers)
print("产品信息审核查询返回结果", result)
data = commonFuc().analysis_json('data', result)
total = commonFuc().analysis_json('total', data)
data1 = commonFuc().analysis_json('data', data)
if total >= 1:
id1 = commonFuc().analysis_json('id', data1[0])
auditOrgId = commonFuc().analysis_json('hosId', data1[0])
hosGoodsId = commonFuc().analysis_json('hosGoodsid', data1[0])
provGoodsid = commonFuc().analysis_json('provGoodsid', data1[0])
goodsAuditBillId = commonFuc().analysis_json('billId', data1[0])
targetId = commonFuc().analysis_json('id', data1[0])
print(id1, auditOrgId, hosGoodsId, provGoodsid, goodsAuditBillId, targetId)
info = (id1, auditOrgId, hosGoodsId, provGoodsid, goodsAuditBillId, targetId)
titlename = ("MSPid", 'hosId', 'hosGoodsId', 'provGoodsid', 'goodsAuditBillId', 'targetId')
# 将产品审核信息写入到b5_spd3_core_business_flow模块messsage文件中
FileUtils().w_info6(info, module, '产品审核信息', titlename, 'message2')
# 将产品审核信息写入到文件中
FileUtils().w_info8(info, 'b5_spd3_core_business_flow', '产品审核信息', titlename, messageNO)
else:
commonFuc().check_text_exist(0, result)
def add_goods1(): # 低值
token, projectCode, uxid, corpId, e_name = e_login(2)
# 获取医院corpId
h_token, h_projectCode, h_uxid, h_corpId, h_name = h_login()
module = "a5_mdm3_pdm"
# b18供货目录申请_客户类型_医院_提交供货申请单_添加产品
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "addGoodsHandleInfos_url")
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
projectCode)
goodsname = commonFuc().randomString(5)
request_body = commonFuc().get_business_data(module, "payload", h_corpId, h_name, corpId, e_name, goodsname, e_name)
# request_body = commonFuc().get_business_data(module, "payload10_1")
# 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:
commonFuc().check_text_exist(code, result)
else:
commonFuc().check_text_exist(-1, result)
def add_goods2(): # 试剂
token, projectCode, uxid, corpId, e_name = e_login(2)
# 获取医院corpId
h_token, h_projectCode, h_uxid, h_corpId, h_name = h_login()
module = "a5_mdm3_pdm"
# b18供货目录申请_客户类型_医院_提交供货申请单_添加产品
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "addGoodsHandleInfos_url")
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
projectCode)
goodsname = commonFuc().randomString(5)
request_body = commonFuc().get_business_data(module, "payload_2", h_corpId, h_name, corpId, e_name, goodsname,
e_name)
# request_body = commonFuc().get_business_data(module, "payload10_1")
# 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:
commonFuc().check_text_exist(code, result)
else:
commonFuc().check_text_exist(-1, result)
def add_goods3():
token, projectCode, uxid, corpId, e_name = e_login(2)
# 获取医院corpId
h_token, h_projectCode, h_uxid, h_corpId, h_name = h_login()
module = "a5_mdm3_pdm"
# b18供货目录申请_客户类型_医院_提交供货申请单_添加产品
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "addGoodsHandleInfos_url")
print('url', url)
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
projectCode)
goodsname = commonFuc().randomString(5)
request_body = commonFuc().get_business_data(module, "payload_1_1", h_corpId, h_name, corpId, e_name, goodsname,
'浙江高仰医疗科技有限公司', 'p10d95')
# request_body = commonFuc().get_business_data(module, "payload10_1")
# 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:
commonFuc().check_text_exist(code, result)
else:
commonFuc().check_text_exist(-1, result)
def add_goods4():
token, projectCode, uxid, corpId, e_name = e_login(2)
# 获取医院corpId
h_token, h_projectCode, h_uxid, h_corpId, h_name = h_login()
module = "a5_mdm3_pdm"
# b18供货目录申请_客户类型_医院_提交供货申请单_添加产品
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "addGoodsHandleInfos_url")
print('url', url)
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
projectCode)
goodsname = commonFuc().randomString(5)
request_body = commonFuc().get_business_data(module, "payload_1_2", h_corpId, h_name, corpId, e_name, goodsname,
'浙江高仰医疗科技有限公司', 'p10d95')
# request_body = commonFuc().get_business_data(module, "payload10_1")
# 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:
commonFuc().check_text_exist(code, result)
else:
commonFuc().check_text_exist(-1, result)
def supplyProvHosGoods_add_DI():
module = "a5_mdm3_pdm"
token, projectCode, uxid, corpId, e_name = e_login(2)
# 维护产品DI信息列表查询
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "hdiFusion_getHosGoodsForDiList_url")
print('维护产品DI信息列表查询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, "payload6", get_hosid())
# 发送请求
result = commonFuc().http_post(url, request_body, headers)
# import pdb
# pdb.set_trace()
print('维护产品DI信息列表查询result', result)
data = commonFuc().analysis_json('data', commonFuc().analysis_json('data', result))
print('维护产品DI信息列表查询data', data)
for i in data:
hosGoodsId = commonFuc().analysis_json('id', i)
url1 = commonFuc().get_api_url() + commonFuc().get_business_data(module, "hdiFusion_getGoodsinfoAndDiLst_url")
request_body1 = commonFuc().get_business_data(module, "payload6_1", hosGoodsId)
print('request_body1', request_body1)
result1 = commonFuc().http_post(url1, request_body1, headers)
packUnit = commonFuc().analysis_json('unit', commonFuc().analysis_json('goodsInfo',
commonFuc().analysis_json('data',
result1)))
basGoodsId = commonFuc().analysis_json('spdGoodsCode', commonFuc().analysis_json('goodsInfo',
commonFuc().analysis_json(
'data', result1)))
url2 = commonFuc().get_api_url() + commonFuc().get_business_data(module, "hdiFusion_supplyProvHosGoods_add_url")
request_body2 = commonFuc().get_business_data(module, "payload6_2", packUnit, basGoodsId)
print('request_body2', request_body2)
result2 = commonFuc().http_post(url2, request_body2, headers)
print('result2', result2)
# 删除上次新增的产品，避免产生过多的重复数据====这里不能每天删除，万一导入产品功能出现问题会影响后续脚本
# 每隔一段时间来删除重复的产品数据即可，内外网同步删除
# try:
# list2=[]
# for i in range(1, 6):
# info = FileUtils().r_info8('b5_spd3_core_business_flow', "产品审核信息", 'message%s' % i)
# hosGoodsId = info['hosGoodsId']
# list2.append(hosGoodsId)
# print(list2)
# for i in list2:
# print(i,'aaaaaaaaaaaaaaaa')
# delData().Del_goods_info(i)
# except:
# print('产品数据删除出现异常')
# 删除上次新增的产品，避免产生过多的重复数据====这里不能每天删除，万一导入产品功能出现问题会影响后续脚本 # 删除上次新增的产品，避免产生过多的重复数据====这里不能每天删除，万一导入产品功能出现问题会影响后续脚本
# 每隔一段时间来删除重复的产品数据即可，内外网同步删除 # 每隔一段时间来删除重复的产品数据即可，内外网同步删除
pro_path = commonFuc().get_pro_path2()
print('pro_path', pro_path)
sys.path.append(pro_path + r'/air_case/b5_spd3_core_business_flow/a_a3_流程三_产品导入和审批.air')
using(pro_path + r'//air_case/b5_spd3_core_business_flow/a_a3_流程三_产品导入和审批.air')
from a_a3_流程三_产品导入和审批 import add_goods, select1, apply, add_goods1, add_goods2, add_goods3, add_goods4, \
supplyProvHosGoods_add_DI
try: try:
# ==============分割线 暂时注释=============== # ==============分割线 暂时注释===============
add_goods()#直销高值 add_goods() # 直销高值
select1('message1') select1('message1')
apply() apply()
add_goods1()#直销低值 add_goods1() # 直销低值
select1('message2') select1('message2')
apply() apply()
add_goods2()#直销试剂 add_goods2() # 直销试剂
select1('message3') select1('message3')
apply() apply()
add_goods3()#集配 add_goods3() # 集配
select1('message4') select1('message4')
apply() apply()
add_goods4()#定向 "isSubprov": "1" add_goods4() # 定向 "isSubprov": "1"
select1('message5') select1('message5')
apply() apply()
#20240618外网在配送的时候增加了DI验证，加入维护di的脚本 # 20240618外网在配送的时候增加了DI验证，加入维护di的脚本
supplyProvHosGoods_add_DI() supplyProvHosGoods_add_DI()
# ==============分割线 暂时注释=============== # ==============分割线 暂时注释===============
commonFuc().check_text_exist_result_text('succees', 'succees') commonFuc().check_text_exist_result_text('succees', 'succees')
...@@ -399,5 +51,6 @@ except: ...@@ -399,5 +51,6 @@ except:
commonFuc().check_text_exist_result_text('产品新增失败', '产品新增成功') commonFuc().check_text_exist_result_text('产品新增失败', '产品新增成功')
else: else:
# 删除今天之前的产品信息(包含内外网) # 删除今天之前的产品信息(包含内外网)
delData().Del_goods_info_all() # delData().Del_goods_info_all()
commonFuc().check_text_exist_result_text('succees', 'succees') commonFuc().check_text_exist_result_text('succees', 'succees')
print('=================流程三结束=================')
air_case/b6_spd3_core_business_flow_database_check/a_a4_流程四_基础模块设置_数据库验证.air/a_a4_流程四_基础模块设置_数据库验证.py
View file @ f201bb40
...@@ -21,289 +21,28 @@ import time ...@@ -21,289 +21,28 @@ import time
module = "b6_spd3_core_business_flow_database_check" module = "b6_spd3_core_business_flow_database_check"
def test1():
# 院区新增
execute_command("python runner_test.py tag id2263-4 debug sit")
# 新增科室
execute_command(
"python runner_test.py tag id2263-19,id2263-20,id2263-21,id2263-22,id2263-23,id2263-24,id2263-25,id2263-26 debug sit")
# 一键导入所有产品
execute_command("python runner_test.py tag id2263-48 debug sit")
#导入同步过来的新产品，防止因同步时间差导致新建的产品没有导入过来
for i in range(1, 6):
info = FileUtils().r_info8('b5_spd3_core_business_flow', "产品审核信息", 'message%s' % i)
hosGoodsId = info['hosGoodsId']
import_goods(hosGoodsId)
# r_b8库房管理_库区设置_同步库房信息
execute_command("python runner_test.py tag id2263-221 debug sit")
# 新增用户
execute_command("python runner_test.py tag id2263-253 debug sit")
# 根据院区名称查询中心库房id
execute_command("python runner_test.py tag id2263-222 debug sit")
# 新增库区
execute_command("python runner_test.py tag id2263-226 debug sit")
# 查询库区
execute_command("python runner_test.py tag id2263-228 debug sit")
# r_d0库房管理_库区设置_人员管理_添加人员_查询人员 pro_path = commonFuc().get_pro_path2()
execute_command("python runner_test.py tag id2263-233 debug sit") print('pro_path', pro_path)
# r_d2库房管理_库区设置_人员管理_添加人员 sys.path.append(pro_path + r'/air_case/b5_spd3_core_business_flow/a_a4_流程四_基础模块设置.air')
execute_command("python runner_test.py tag id2263-235 debug sit") using(pro_path + r'//air_case/b5_spd3_core_business_flow/a_a4_流程四_基础模块设置.air')
# r_d4库房管理_库区设置_货位管理_添加货位 from a_a4_流程四_基础模块设置 import test1,test2, grants_user, add_StockArea
execute_command("python runner_test.py tag id2263-237 debug sit")
# 科室管理-科室人员查询 设置科室负责人
execute_command("python runner_test.py tag id2263-219 debug sit")
def import_goods(hosGoodsId):
module = "b2_herp3_bs"
# 内网登录
username = commonFuc().get_business_data(module, "username")
# print('医院名称',username)
password = commonFuc().get_business_data(module, "password")
# print(username, password,'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa')
# 获取token和projectCode
token, projectCode, uxid, corpId, info = login_system(username, password).get_token()
# 院区产品设置_查询院区产品
url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "mcmsDeptGoodsInfo_url")
print('院区产品设置_查询院区产品',url)
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
commonFuc().get_business_data(module, "X-APP-CODE"))
# 获取院区id
branch_id = FileUtils().r_info(module, '院区新增')["branch_id"]
# hosGoodsId = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message2')["hosGoodsId"]
goodsId=hosGoodsId.replace(get_hosid(), "")
# #请求体
request_body = commonFuc().get_business_data(module, "payload32_1",get_hosid(), goodsId,branch_id)
print('import_goods',request_body)
# # # 发送请求
result='result'
# j=1
while True:
# if j==600:
# print('600秒过去了，导入产品需要停止')
# break
result = commonFuc().http_post(url, request_body, headers)
total=commonFuc().analysis_json('total',commonFuc().analysis_json('data',result))
print('import_goods', total)
if total==0:
print('产品暂时没有同步到内网,等待6秒')
# j=j+6
time.sleep(6)
# 再次调用一键导入产品
execute_command("python runner_test.py tag id2263-48 debug sit")
else:
break
print('result', result)
def test2(): # 科室添加产品信息(产品是从外网同步过来的)
module = "b2_herp3_bs"
# 内网登录
username = commonFuc().get_business_data(module, "username")
# print('医院名称',username)
password = commonFuc().get_business_data(module, "password")
# print(username, password,'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa')
# 获取token和projectCode
token, projectCode, uxid, corpId, info = login_system(username, password).get_token()
#
url = commonFuc().get_api_add_port_url()+commonFuc().get_business_data(module, "basic_mcmsGoodsInfo_insert")
print('basic_mcmsGoodsInfo_insert',url)
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
commonFuc().get_business_data(module, "X-APP-CODE"))
list2 = []
i = 1
while True:
if i == 1000:
print('6000秒过去了，产品还没过来，检查同步是否正常')
break
try:
for i in range(1, 6):
info = FileUtils().r_info8('b5_spd3_core_business_flow', "产品审核信息", 'message%s' % i)
hosGoodsId = info['hosGoodsId']
list2.append(hosGoodsId)
except:
print('产品没有同步过来，等待6秒')
time.sleep(6)
i = i + 1
continue
else:
break
dept2_id = FileUtils().r_info(module, '科室信息')["dept2_id"]
j=1
for i in list2:
# 请求体
if j==1:
request_body = commonFuc().get_business_data(module, "payload58_6_3", dept2_id, i,20)
elif j==2:
request_body = commonFuc().get_business_data(module, "payload58_6_3", dept2_id, i, 10)
elif j==3:
request_body = commonFuc().get_business_data(module, "payload58_6_3", dept2_id, i, 60)
else:
request_body = commonFuc().get_business_data(module, "payload58_6_3", dept2_id, i,20)
j=j+1
request_body = '[' + str(request_body) + ']'
new_request_body = request_body.replace("'", '"')
print(new_request_body)
import json
request_body_json = json.loads(new_request_body)
# # # 发送请求
result = commonFuc().http_post(url, request_body_json, headers)
print('resultaaaaaaaaaaaaaaaaaaaaaaaaaaa', result)
# 断言
# checkDict=commonFuc().get_business_data(module,'checkDict10')
# commonFuc().check_result(checkDict,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)
def grants_user(orgName='d69a68df361a4289b2262e4ef75b55a5', mgrRangeId='feb0cc16618c437fb4d033cd339a0377'):
module = "b2_herp3_bs"
# 登录获取用户id等信息，使用创建的用户登录===========开始
info = FileUtils().r_info8(module, "用户名信息", 'message3')
print(info)
username1 = info['username1']
username = username1
## print('医院名称',username)
password = commonFuc().get_business_data(module, "password")
# print(username, password,'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa')
# 获取token和projectCode
token1, projectCode1, uxid1, corpId1, info1 = login_system(username, password).get_token()
# 登录获取用户id等信息，使用创建的用户登录============结束
# 内网登录
username = commonFuc().get_business_data(module, "username")
## print('医院名称',username)
password = commonFuc().get_business_data(module, "password")
# print(username, password,'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa')
# 获取token和projectCode
token, projectCode, uxid, corpId, info = login_system(username, password).get_token()
# print( token,projectCode,uxid,corpId,info)
url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "sys_user_grants_url")
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
commonFuc().get_business_data(module, "X-APP-CODE"))
userId = uxid1
mgrBranchId = FileUtils().r_info(module, '院区新增')["branch_id"]
mgrBranchName = FileUtils().r_info(module, '院区新增')["branch_name"]
deptid1 = FileUtils().r_info8(module, '所有科室id','message6')["deptid1"]
deptid2 = FileUtils().r_info8(module, '所有科室id','message6')["deptid2"]
deptid3 = FileUtils().r_info8(module, '所有科室id','message6')["deptid3"]
deptid4 = FileUtils().r_info8(module, '所有科室id','message6')["deptid4"]
# # 请求体
request_body = commonFuc().get_business_data(module, "payload63_12_2", userId, mgrBranchId, mgrBranchName, deptid1,
mgrBranchId, mgrBranchName, deptid2, mgrBranchId, mgrBranchName,
deptid3, mgrBranchId, mgrBranchName, deptid4
)
print('request_body', request_body)
# # # # 发送请求
result = commonFuc().http_post(url, request_body, headers)
print('resultaaaaaaaaaaaaaaaaaaa', result)
# 断言
code = commonFuc().analysis_json('code', result)
data = commonFuc().analysis_json('data', result)
if code == 0 and data == 4:
commonFuc().check_text_exist(0, result)
else:
commonFuc().check_text_exist('error', result)
def add_StockArea():#添加货位
module='b2_herp3_bs'
# 登录获取用户id等信息，使用创建的用户登录===========开始
info = FileUtils().r_info8(module, "用户名信息", 'message3')
print(info)
username1 = info['username1']
username = username1
## print('医院名称',username)
password = commonFuc().get_business_data(module, "password")
# print(username, password,'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa')
# 获取token和projectCode
token, projectCode, uxid, corpId, info = login_system(username, password).get_token()
# 登录获取用户id等信息，使用创建的用户登录============结束
# 获取库区id
deptid1 = FileUtils().r_info8(module, '所有科室id','message6')["deptid1"]
branch_name = FileUtils().r_info(module, '院区新增')["branch_name"]
stockId = get_stockId(branch_name + '中心库房')
url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "basic_stockShelf_page_url")
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
commonFuc().get_business_data(module, "X-APP-CODE"))
request_body = commonFuc().get_business_data(module, "payload62_6", deptid1, stockId)
print('request_body',request_body)
result = commonFuc().http_post(url, request_body, headers)
print('result',result)
data = commonFuc().analysis_json('data', result)
data1 = commonFuc().analysis_json('data', data)
id1 = commonFuc().analysis_json('id', data1)
shelfCode = commonFuc().analysis_json('shelfCode', data1)
createTime = commonFuc().analysis_json('createTime', data1)
stockId = commonFuc().analysis_json('stockId', data1)
shelfName = commonFuc().analysis_json('shelfName', data1)
address = commonFuc().analysis_json('address', data1)
recPhone = commonFuc().analysis_json('recPhone', data1)
lastModified = commonFuc().analysis_json('lastModified', data1)
shelfNo = commonFuc().analysis_json('shelfNo', data1)
print(id1, lastModified, shelfCode, createTime, stockId, shelfName, address, recPhone, shelfNo)
print('resultaaaaaaaaaaaaaaaaaaaaaaaaaaa', result)
# r_d4库房管理_库区设置_货位管理_添加货位
url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "basic_stockUser_insertShelf_url")
print('添加货位url',url)
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
commonFuc().get_business_data(module, "X-APP-CODE"))
# # 请求体
request_body = commonFuc().get_business_data(module, "payload62_12", id1, shelfCode, stockId, id1)
print('request_body', request_body)
# # # # 发送请求
result = commonFuc().http_post(url, request_body, headers)
print('resultbbbbbbbbbbb', result)
code = commonFuc().analysis_json('code', result)
data = commonFuc().analysis_json('data', result)
# pageSize = commonFuc().analysis_json('pageSize', data)
# print(pageSize, type(pageSize))
if code == 0 and data == 4:
commonFuc().check_text_exist(0, result)
else:
commonFuc().check_text_exist('error', result)
try: try:
# ==============删除业务数据和报表数据 # ==============删除业务数据和报表数据
# delData().Delete_business_Data()#删除业务数据 # delData().Delete_business_Data()#删除业务数据
# delData().Del_reporter_data() # 删除报表数据 # delData().Del_reporter_data() # 删除报表数据
#==============删除业务数据和报表数据 #==============删除业务数据和报表数据
test1() test1()#参数2是新增院区后缀为6位数的参数1是老模式
test2()# 科室添加产品信息(产品是从外网同步过来的) test2()# 科室添加产品信息(产品是从外网同步过来的)
dept_query_all()# 科室查询，将科室id写入文件中 dept_query_all()# 科室查询，将科室id写入文件中
grants_user()#给用户授权 grants_user()#给用户授权
set_dept_lead1() #设置一级科室负责人 set_dept_lead1() #设置一级科室负责人
add_StockArea()#添加库区 add_StockArea()#添加库区
commonFuc().check_text_exist_result_text('succees', 'succees') commonFuc().check_text_exist_result_text('succees', 'succees')
print('=================流程四结束=================')
except Exception as e: except Exception as e:
commonFuc().check_text_exist_result_text('succees','error') commonFuc().check_text_exist_result_text('succees','error')
print("发生异常：", str(e)) print("发生异常：", str(e))
\ No newline at end of file
air_case/b6_spd3_core_business_flow_database_check/a_a7流程五_中心库入库结算_正结算3_内网验收入库结算_数据库验证.air/a_a7流程五_中心库入库结算_正结算3_内网验收入库结算_数据库验证.py
View file @ f201bb40
...@@ -609,7 +609,7 @@ def check_mcms_out_balance(type=1, OBh_ID=""): ...@@ -609,7 +609,7 @@ def check_mcms_out_balance(type=1, OBh_ID=""):
else: else:
commonFuc().check_text_exist_result_text('error', 'success') commonFuc().check_text_exist_result_text('error', 'success')
expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check', expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
'check_mcms_out_balance_0918', id, 'check_mcms_out_balance_1008', id,
order_no, branch_id, hos_id, prov_id, prov_name, settle_month, order_no, branch_id, hos_id, prov_id, prov_name, settle_month,
settle_start_time, settle_end_time, create_user, create_time, settle_start_time, settle_end_time, create_user, create_time,
last_modified, last_modified_user last_modified, last_modified_user
...@@ -1152,9 +1152,10 @@ try: ...@@ -1152,9 +1152,10 @@ try:
# time.sleep(6) # time.sleep(6)
# check_mcms_psi(3) # check_mcms_psi(3)
# time.sleep(3) # time.sleep(3)
OBD_ID = settle()# 生成结算单 # OBD_ID = settle()# 生成结算单
print(OBD_ID) # print(OBD_ID)
time.sleep(6) # time.sleep(6)
OBD_ID='OBh0347202410080005'
check_mcms_out_balance(1, OBD_ID) # 检查审批前的结算数据 check_mcms_out_balance(1, OBD_ID) # 检查审批前的结算数据
# 调用审批结算单 # 调用审批结算单
approval_center(OBD_ID) approval_center(OBD_ID)
......
data/b6_spd3_core_business_flow_database_check/data
View file @ f201bb40
...@@ -449,7 +449,7 @@ ...@@ -449,7 +449,7 @@
#手工采购计划入库_结算数据主表 #手工采购计划入库_结算数据主表
"check_mcms_out_balance_1008": '{"id": "%s", "order_no": "%s", "branch_id": "%s", "hos_id": "%s", "prov_id": "%s", "prov_name": "%s", "settle_dept_id": None, "tb_status": 0, "sum_row": 2, "settle_amount": Decimal("19999.980000"), "settle_way": 0, "settle_month": "%s", "settle_start_time": %s, "settle_end_time": %s, "remark": None, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "check_msg": None, "settle_qty": Decimal("0.0000"), "check_user": None, "check_time": None}' "check_mcms_out_balance_1008": '{"id": "%s", "order_no": "%s", "branch_id": "%s", "hos_id": "%s", "prov_id": "%s", "prov_name": "%s", "settle_dept_id": None, "tb_status": 0, "sum_row": 2, "settle_amount": Decimal("19999.980000"), "settle_way": 0, "settle_month": "%s", "settle_start_time": %s, "settle_end_time": %s, "remark": None, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "check_msg": None, "settle_qty": Decimal("200.0000"), "check_user": None, "check_time": None}'
#手工采购计划入库_结算数据子表 #手工采购计划入库_结算数据子表
"check_mcms_out_balance_detail_1008_1": '{"id": "%s", "pid": "%s", "prov_id": "%s", "prov_name": "%s", "sub_prov_id": "%s", "sub_prov_name": "%s", "out_dept_id": "%s", "out_dept_name": "%s", "account_date": %s, "pur_mode": 10, "from_table": "mcms_psi_batch", "from_id": "%s", "from_order_no": "%s", "hos_goods_id": "%s", "bar_id": "%s", "bar_code": "%s", "distr_detail_id": "%s", "hos_batch_id": "%s", "tb_status": 10, "price": Decimal("99.999900"), "settle_qty": Decimal("-100.00"), "invoice_qty": Decimal("0.00"), "settle_amount": Decimal("-9999.9900"), "un_settle_id": "%s", "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "settle_type": 1, "contract_id": None, "normal_contract_id": None, "temp_purchase": 0, "hos_id": "%s", "fcat_id": None, "invoice_price": Decimal("99.999900"), "online_kind": "10"}' "check_mcms_out_balance_detail_1008_1": '{"id": "%s", "pid": "%s", "prov_id": "%s", "prov_name": "%s", "sub_prov_id": "%s", "sub_prov_name": "%s", "out_dept_id": "%s", "out_dept_name": "%s", "account_date": %s, "pur_mode": 10, "from_table": "mcms_psi_batch", "from_id": "%s", "from_order_no": "%s", "hos_goods_id": "%s", "bar_id": "%s", "bar_code": "%s", "distr_detail_id": "%s", "hos_batch_id": "%s", "tb_status": 10, "price": Decimal("99.999900"), "settle_qty": Decimal("-100.00"), "invoice_qty": Decimal("0.00"), "settle_amount": Decimal("-9999.9900"), "un_settle_id": "%s", "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "settle_type": 1, "contract_id": None, "normal_contract_id": None, "temp_purchase": 0, "hos_id": "%s", "fcat_id": None, "invoice_price": Decimal("99.999900"), "online_kind": "10"}'
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment