Skip to content
GitLab
Projects
Groups
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Sign in / Register
Toggle navigation
Menu
Open sidebar
test
autotest-airtest-web-spd
Commits
36bc5231
Commit
36bc5231
authored
Aug 20, 2024
by
xiao-hesheng
Browse files
流程十六脚本提交
parent
11f87d4a
Changes
4
Hide whitespace changes
Inline
Side-by-side
air_case/b5_spd3_core_business_flow/a_c0流程十七退货业务_中心库退供应商.air/a_c0流程十七退货业务_中心库退供应商.py
View file @
36bc5231
...
...
@@ -23,7 +23,7 @@ python runner_test.py tag id2302-20 debug mdm3
def
second_
center_Stock_return_Out
(
type
):
# 中心库退供应商
def
center_Stock_return_Out
(
type
):
# 中心库退供应商
module
=
"b5_spd3_core_business_flow"
# # 登录获取用户id等信息,使用创建的用户登录===========开始
info
=
FileUtils
().
r_info8
(
'b2_herp3_bs'
,
"用户名信息"
,
'message3'
)
...
...
@@ -629,9 +629,9 @@ def second_center_Stock_return_Out(type): # 中心库退供应商
def
main
():
try
:
updateUserLoginDefaultRange
(
get_listUserMgrRangePage1
(
1
))
# 设置登录账号默认权限是二级库
second_
center_Stock_return_Out
(
2
)
#高值耗材退货出库
second_
center_Stock_return_Out
(
1
)
#低值耗材退货出库
second_
center_Stock_return_Out
(
3
)
#试剂耗材退货出库
center_Stock_return_Out
(
2
)
#高值耗材退货出库
center_Stock_return_Out
(
1
)
#低值耗材退货出库
center_Stock_return_Out
(
3
)
#试剂耗材退货出库
commonFuc
().
check_text_exist_result_text
(
'succees'
,
'succees'
)
print
(
'================流程十七执行完毕===================='
)
...
...
air_case/b6_spd3_core_business_flow_database_check/a_b9流程十六退库业务_二级库向一级库退库_数据库验证.air/a_b9流程十六退库业务_二级库向一级库退库_数据库验证.py
View file @
36bc5231
...
...
@@ -463,7 +463,7 @@ try:
time
.
sleep
(
6
)
check_mcms_psi_in
(
1
)
# 检查中心库入库单数据库数据
updateUserLoginDefaultRange
(
get_listUserMgrRangePage1
(
2
))
# 设置登录账号默认权限是二级库
second_dept_return_Out_Stock
(
3
)
#
试剂耗材退货出库
second_dept_return_Out_Stock
(
3
)
#试剂耗材退货出库
check_mcms_psi_dept_out
(
66
)
# 检查出库单数据库数据
approval_center
()
# 审批
putaway
()
# 中心库上架
...
...
air_case/b6_spd3_core_business_flow_database_check/a_c0流程十七退货业务 中心库退供应商_数据库验证.air/a_c0流程十七退货业务 中心库退供应商_数据库验证.py
View file @
36bc5231
...
...
@@ -5,6 +5,9 @@ import traceback
from
air_case.b1_herp3_login.登录内网系统.登录内网系统
import
login_system
from
air_case.public1.public1.public1
import
*
from
common.db.sql.sql_del_branch_info
import
delData
from
common.db.sql.sql_tools
import
check_mcms_pur_plan_sql
,
get_DRID
,
get_login_user_uxid_bydb
,
get_create_time
,
\
get_buyBillId
,
get_PICK_order_no
,
get_PICK_id
,
get_planBillId
,
get_buyOrderNo
,
get_purOrderNo
,
get_purBillId
,
\
get_purBillDate2
,
get_distrBillId
,
get_distrOrderNo
from
common.fileUtls
import
FileUtils
from
common.run_cmd_script
import
execute_command
...
...
@@ -20,620 +23,243 @@ python runner_test.py tag id2303-20 debug mdm3
"""
def
check_mcms_psi_out
(
type
=
1
):
print
(
'检查中心库出库单'
)
if
type
==
1
:
bill_mode
=
16
elif
type
==
2
:
bill_mode
=
20
else
:
bill_mode
=
66
branch_id
=
get_branch_id
()
sql
=
"select * from mcms_psi where source_branch_id='%s' and bill_mode='%s' and stock_kind='CK_TH' order by CREATE_TIME desc LIMIT 1;"
%
(
branch_id
,
bill_mode
)
# 获取实际值
actual
=
check_mcms_pur_plan_sql
(
sql
)
print
(
'actual'
,
actual
)
sql
=
"select id from mcms_psi where source_branch_id='%s' and bill_mode='%s' and stock_kind='CK_TH' order by CREATE_TIME desc LIMIT 1;"
%
(
branch_id
,
bill_mode
)
id
=
get_id
(
sql
)
sql
=
"select order_no from mcms_psi where source_branch_id='%s' and bill_mode='%s' and stock_kind='CK_TH' order by CREATE_TIME desc LIMIT 1;"
%
(
branch_id
,
bill_mode
)
order_no
=
get_id
(
sql
)
target_corp_id
=
get_hosid
()
target_branch_id
=
None
target_dept_id
=
FileUtils
().
r_info8
(
"b5_spd3_core_business_flow"
,
"供货关系申请2"
,
'message'
)[
'e_corpId'
]
target_dept_name
=
FileUtils
().
r_info8
(
"b5_spd3_core_business_flow"
,
"供货关系申请2"
,
'message'
)[
'e_username'
]
stock_name
=
get_branch_name
()
+
"中心库房"
target_stock_id
=
target_dept_id
target_area_code
=
None
source_id
=
get_PICK_id
(
branch_id
,
bill_mode
)
source_no
=
None
source_repl_id
=
None
source_corp_id
=
get_hosid
()
source_branch_id
=
get_branch_id
()
source_dept_id
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室id"
,
'message6'
)[
'deptid2'
]
source_dept_name
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室name"
,
'message6'
)[
'deptid2'
]
source_stock_id
=
get_stockId_fromdb
(
source_dept_name
+
'库房'
)
source_area_code
=
get_stockAreaId_new_fromDb
(
source_dept_name
,
2
)
accounter
=
get_login_user_uxid_bydb
(
FileUtils
().
r_info8
(
'b2_herp3_bs'
,
"用户名信息"
,
'message3'
)[
'username1'
])
account_date
=
get_create_time
(
"select account_date from mcms_psi where id='%s';"
%
id
)
buyBillId
=
get_buyBillId
(
branch_id
,
bill_mode
)
if
type
==
1
:
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message2'
)[
"hosGoodsId"
]
elif
type
==
2
:
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message1'
)[
"hosGoodsId"
]
else
:
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message3'
)[
"hosGoodsId"
]
pickOrderNo
=
get_PICK_order_no
(
branch_id
,
bill_mode
)
pickBillId
=
get_PICK_id
(
branch_id
,
bill_mode
)
planBillId
=
get_planBillId
(
hos_goods_id
)
psiDeptOutBillId
=
get_id
(
"select id from mcms_psi_dept where target_branch_id='%s' and bill_mode='%s' and stock_kind='CK_TK' order by CREATE_TIME desc LIMIT 1;"
%
(
branch_id
,
bill_mode
))
psiDeptOutOrderNo
=
get_id
(
"select order_no from mcms_psi_dept where target_branch_id='%s' and bill_mode='%s' and stock_kind='CK_TK' order by CREATE_TIME desc LIMIT 1;"
%
(
branch_id
,
bill_mode
))
psiInBillId
=
id
psiInOrderNo
=
order_no
buyOrderNo
=
get_buyOrderNo
(
branch_id
,
bill_mode
)
purOrderNo
=
get_purOrderNo
(
branch_id
,
bill_mode
)
purBillId
=
get_purBillId
(
branch_id
,
bill_mode
)
bill_relation_json
=
get_purBillDate2
(
branch_id
,
bill_mode
)
purBillDate
=
reGetString
(
bill_relation_json
,
r
'purBillDate":"'
,
r
'""distrBillId'
)
distrBillId
=
get_distrBillId
(
branch_id
,
bill_mode
)
distrOrderNo
=
get_distrOrderNo
(
branch_id
,
bill_mode
)
checkBillId
=
source_id
sql
=
"select order_no from mcms_check where id='%s';"
%
checkBillId
checkOrderNo
=
get_id
(
sql
)
psiInBillId
=
id
psiInOrderNo
=
order_no
create_user
=
get_login_user_uxid_bydb
(
FileUtils
().
r_info8
(
'b2_herp3_bs'
,
"用户名信息"
,
'message3'
)[
'username1'
])
create_time
=
get_create_time
(
"select create_time from mcms_psi where id='%s';"
%
id
)
last_modified
=
get_create_time
(
"select last_modified from mcms_psi where id='%s';"
%
id
)
last_modified_user
=
create_user
if
type
==
1
:
# 检查子表
check_mcms_psi_batch_out
(
id
,
type
,
order_no
,
source_id
)
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'check_mcms_psi1_1'
,
id
,
order_no
,
target_corp_id
,
target_branch_id
,
target_dept_id
,
target_dept_name
,
target_stock_id
,
target_area_code
,
source_id
,
source_no
,
source_repl_id
,
source_corp_id
,
source_branch_id
,
source_dept_id
,
source_dept_name
,
source_stock_id
,
source_area_code
,
accounter
,
account_date
,
pickOrderNo
,
pickBillId
,
psiDeptOutBillId
,
psiDeptOutOrderNo
,
psiInBillId
,
psiInOrderNo
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
elif
type
==
2
:
check_mcms_psi_batch_out
(
id
,
type
,
order_no
,
source_id
)
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'check_mcms_psi1_2'
,
id
,
order_no
,
target_corp_id
,
target_branch_id
,
target_dept_id
,
target_dept_name
,
target_stock_id
,
target_area_code
,
source_id
,
source_no
,
source_repl_id
,
source_corp_id
,
source_branch_id
,
source_dept_id
,
source_dept_name
,
source_stock_id
,
source_area_code
,
accounter
,
account_date
,
pickOrderNo
,
pickBillId
,
psiDeptOutBillId
,
psiDeptOutOrderNo
,
psiInBillId
,
psiInOrderNo
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
else
:
check_mcms_psi_batch_out
(
id
,
type
,
order_no
,
source_id
)
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'check_mcms_psi1_3'
,
id
,
order_no
,
target_corp_id
,
target_branch_id
,
target_dept_id
,
target_dept_name
,
target_stock_id
,
target_area_code
,
source_id
,
source_no
,
source_repl_id
,
source_corp_id
,
source_branch_id
,
source_dept_id
,
source_dept_name
,
source_stock_id
,
source_area_code
,
accounter
,
account_date
,
pickOrderNo
,
pickBillId
,
psiDeptOutBillId
,
psiDeptOutOrderNo
,
psiInBillId
,
psiInOrderNo
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
# 对比预期值和实际值是否一致
actual_value1
=
get_process_list2
(
actual
)
expected_value1
=
get_process_list2
(
expected
)
actual_value2
=
actual_value1
.
replace
(
" "
,
""
)
expected_value2
=
expected_value1
.
replace
(
" "
,
""
)
# print('actual_value2',actual_value2)
print
(
'expected_value2'
)
print
(
expected_value2
)
print
(
'actual_value2'
)
print
(
actual_value2
)
result
=
(
compare_text_index
(
actual_value2
,
expected_value2
))
print
(
'result'
,
result
)
if
actual_value2
==
expected_value2
:
print
(
'ok'
)
commonFuc
().
check_text_exist_result_text
(
'succees'
,
'succees'
)
else
:
print
(
'error'
)
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
def
check_mcms_psi_batch_out
(
DR_ID
,
type
,
order_no
,
source_id1
):
if
type
==
1
:
bill_mode
=
16
elif
type
==
2
:
bill_mode
=
20
else
:
bill_mode
=
66
branch_id
=
get_branch_id
()
sql
=
" select * from mcms_psi_batch where pid='%s';"
%
(
DR_ID
)
actual
=
check_mcms_dept_buy_sql
(
sql
)
print
(
'actual'
,
actual
)
batch_main_key
=
get_id
(
"select id from mcms_psi_batch where pid='%s';"
%
DR_ID
)
pid
=
DR_ID
# order_no = get_id("select order_no from mcms_psi_dept_batch where pid='%s';" % DR_ID)
source_detail_id
=
source_id1
+
'0001'
pick_detail_id
=
None
if
type
==
1
:
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message2'
)[
"hosGoodsId"
]
elif
type
==
2
:
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message1'
)[
"hosGoodsId"
]
else
:
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message3'
)[
"hosGoodsId"
]
mdm_goods_code
=
get_mdm_goods_code1
(
hos_goods_id
)
goods_code
=
get_goods_code1
(
hos_goods_id
)
pkg_def_id
=
get_pkg_def_id
(
hos_goods_id
)
picker_name
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"用户名信息"
,
'message3'
)[
'username1'
]
picker
=
get_login_user_uxid_bydb
(
picker_name
)
source_batch_id
=
get_id
(
"select source_batch_id from mcms_psi_batch where pid='%s';"
%
DR_ID
)
distrBillId
=
get_distrBillId
(
branch_id
,
bill_mode
)
target_batch_id
=
source_batch_id
if
check_batch_id
(
source_batch_id
)
==
True
:
print
(
'ok'
)
commonFuc
().
check_text_exist_result_text
(
'succees'
,
'succees'
)
else
:
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
barcode_id
=
get_id
(
"select barcode_id from mcms_psi_batch where pid='%s';"
%
DR_ID
)
if
check_barcode_id
(
barcode_id
)
==
True
:
print
(
'ok'
)
commonFuc
().
check_text_exist_result_text
(
'succees'
,
'succees'
)
else
:
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
dept_name
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室name"
,
'message6'
)[
'deptid2'
]
shelf_code
=
get_stockAreaId_new_fromDb
(
get_branch_name
(),
1
)
create_user
=
get_login_user_uxid_bydb
(
FileUtils
().
r_info8
(
'b2_herp3_bs'
,
"用户名信息"
,
'message3'
)[
'username1'
])
create_time
=
get_create_time
(
"select create_time from mcms_psi_batch where pid='%s';"
%
DR_ID
)
last_modified
=
get_create_time
(
"select last_modified from mcms_psi_batch where pid='%s';"
%
DR_ID
)
last_modified_user
=
None
if
type
==
1
:
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_psi_batch_in1_1'
,
batch_main_key
,
pid
,
order_no
,
source_detail_id
,
hos_goods_id
,
mdm_goods_code
,
goods_code
,
source_batch_id
,
target_batch_id
,
barcode_id
,
shelf_code
,
create_user
,
create_time
,
last_modified
,
last_modified_user
def
second_center_Stock_return_Out
(
type
):
# 中心库退供应商
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等信息,使用创建的用户登录============结束
# 我要请领_手工请领_列表查询===========================
headers
=
commonFuc
().
get_business_data
(
module
,
"json_headers2"
,
commonFuc
().
get_business_data
(
module
,
"json_contentType"
),
token
,
commonFuc
().
get_business_data
(
module
,
"X-APP-CODE"
))
)
elif
type
==
2
:
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_psi_batch_in1_2'
,
batch_main_key
,
pid
,
order_no
,
source_detail_id
,
hos_goods_id
,
mdm_goods_code
,
goods_code
,
source_batch_id
,
target_batch_id
,
barcode_id
,
shelf_code
,
create_user
,
create_time
,
last_modified
,
last_modified_user
if
type
==
2
:
#高值退货出库
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等信息,使用创建的用户登录============结束
# 到库房明细查询,查询产品的udi码
get_udi
(
2
)
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_pick_submit_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"
))
# 从文件中获取必要信息
info
=
FileUtils
().
r_info8
(
module
,
"条码信息"
,
'message18'
)
# print('info', info)
list_a
=
info
[
'list_a'
]
# print('list_a', list_a[0], type(list_a), len(list_a))
UTid
=
'UT'
areaCode
=
'areaCode'
createTime
=
'createTime'
hosId
=
'hosId'
stockId
=
'stockId'
areaCode
=
'areaCode'
areaName
=
'areaName'
shelfCode
=
'shelfCode'
codeType
=
'codeType'
tagType
=
'tagType'
hosGoodsId
=
'hosGoodsId'
mdmGoodsCode
=
'mdmGoodsCode'
goodsCode
=
'goodsCode'
goodsDi
=
'goodsDi'
barName
=
'barName'
batchCode
=
'batchCode'
expdtDate
=
'expdtDate'
productDate
=
'productDate'
pkgCode
=
'pkgCode'
pkgCodeSee
=
'pkgCodeSee'
ssccCode
=
'ssccCode'
tbStatus
=
'tbStatus'
pkgDefQty
=
'pkgDefQty'
purBillId
=
'purBillId'
distrBillId
=
'distrBillId'
inStockTime
=
'inStockTime'
distrDetailId
=
'distrDetailId'
purMode
=
'purMode'
goodsMfrsName
=
'goodsMfrsName'
goodsSpec
=
'goodsSpec'
unit
=
'unit'
goodsName
=
'goodsName'
printNum
=
'printNum'
made
=
'made'
provId
=
'provId'
provName
=
'provName'
subProvId
=
'subProvId'
subProvName
=
'subProvName'
hosGoodsCode
=
'hosGoodsCode'
subSendFlag
=
'subSendFlag'
onlyKey
=
'onlyKey'
pkgDefId
=
'pkgDefId'
pkgDefName
=
'pkgDefName'
print
(
'aaaaaaaaaaaaaaaaaaaaaaaaa'
,
list_a
[
0
])
list_b
=
list_a
[
0
]
for
i
in
list_b
:
print
(
i
)
UTid
=
i
[
'id'
]
areaCode
=
i
[
'areaCode'
]
createTime
=
i
[
'createTime'
]
hosId
=
i
[
'hosId'
]
stockId
=
i
[
'stockId'
]
areaCode
=
i
[
'areaCode'
]
areaName
=
i
[
'areaName'
]
shelfCode
=
i
[
'shelfCode'
]
codeType
=
i
[
'codeType'
]
tagType
=
i
[
'tagType'
]
hosGoodsId
=
i
[
'hosGoodsId'
]
mdmGoodsCode
=
i
[
'mdmGoodsCode'
]
goodsCode
=
i
[
'goodsCode'
]
goodsDi
=
i
[
'goodsDi'
]
barName
=
i
[
'barName'
]
batchCode
=
i
[
'batchCode'
]
expdtDate
=
i
[
'expdtDate'
]
productDate
=
i
[
'productDate'
]
pkgCode
=
i
[
'pkgCode'
]
pkgCodeSee
=
i
[
'pkgCodeSee'
]
ssccCode
=
i
[
'ssccCode'
]
tbStatus
=
i
[
'tbStatus'
]
onlyKey
=
i
[
'hosGoodsId'
]
ext
=
i
[
'ext'
]
print
(
'ext'
,
ext
)
distrDetailId
=
ext
[
'distrDetailId'
]
distrBillId
=
ext
[
'distrBillId'
]
purBillId
=
ext
[
'purBillId'
]
pkgDefQty
=
ext
[
'pkgDefQty'
]
# pkgDefId = ext['pkgDefId']
# pkgDefName = ext['pkgDefName']
purMode
=
i
[
'purMode'
]
goodsMfrsName
=
i
[
'goodsMfrsName'
]
goodsSpec
=
i
[
'goodsSpec'
]
unit
=
i
[
'unit'
]
goodsName
=
i
[
'goodsName'
]
pkgDefId
=
i
[
'pkgDefId'
]
# pkgDefQty = i['pkgDefQty']
pkgDefName
=
i
[
'pkgDefName'
]
printNum
=
i
[
'printNum'
]
made
=
i
[
'made'
]
provId
=
i
[
'provId'
]
provName
=
i
[
'provName'
]
subProvId
=
i
[
'subProvId'
]
subProvName
=
i
[
'subProvName'
]
hosGoodsCode
=
i
[
'hosGoodsCode'
]
subSendFlag
=
i
[
'subSendFlag'
]
areaName
=
i
[
'areaName'
]
hosId
=
i
[
'hosId'
]
inStockTime
=
i
[
'inStockTime'
]
break
# pkgDefQty=1
deptid1
=
FileUtils
().
r_info8
(
'b2_herp3_bs'
,
'所有科室id'
,
'message6'
)[
"deptid1"
]
deptName
=
FileUtils
().
r_info8
(
'b2_herp3_bs'
,
'所有科室name'
,
'message6'
)[
"deptid1"
]
# # 请求体
request_body
=
commonFuc
().
get_business_data
(
module
,
"payload66"
,
areaCode
,
UTid
,
createTime
,
UTid
,
hosId
,
stockId
,
areaCode
,
areaName
,
shelfCode
,
codeType
,
tagType
,
hosGoodsId
,
mdmGoodsCode
,
goodsCode
,
goodsDi
,
barName
,
batchCode
,
expdtDate
,
productDate
,
pkgCode
,
pkgCodeSee
,
ssccCode
,
tbStatus
,
pkgDefQty
,
purBillId
,
distrBillId
,
inStockTime
,
distrDetailId
,
purMode
,
goodsMfrsName
,
goodsSpec
,
unit
,
goodsName
,
printNum
,
made
,
provId
,
provName
,
subProvId
,
subProvName
,
hosGoodsCode
,
subSendFlag
,
onlyKey
,
areaName
,
hosId
,
get_branch_id
(),
deptid1
,
deptName
,
stockId
)
print
(
'request_body'
,
'ccccccc'
,
request_body
)
)
else
:
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_psi_batch_in1_3'
,
batch_main_key
,
pid
,
order_no
,
source_detail_id
,
hos_goods_id
,
mdm_goods_code
,
goods_code
,
source_batch_id
,
target_batch_id
,
barcode_id
,
shelf_code
,
create_user
,
create_time
,
last_modified
,
last_modified_user
# # # # 发送请求
result
=
commonFuc
().
http_post
(
url
,
request_body
,
headers
)
print
(
'result'
,
result
)
PICK_ID
=
commonFuc
().
analysis_json
(
'data'
,
result
)
# =====================出库复核列表查询获取pickid===============
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_pick_return_page_url"
)
print
(
'url'
,
url
)
request_body
=
commonFuc
().
get_business_data
(
module
,
"payload20"
,
get_branch_id
(),
get_hosid
(),
deptid1
)
# # # # 发送请求
result
=
commonFuc
().
http_post
(
url
,
request_body
,
headers
)
print
(
'result'
,
result
)
)
# =====================出库复核列表查询获取pickid===============
# =======================查看出库单详细信息===============
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_pick_checkReview_url"
)
url
=
url
+
' '
.
join
(
PICK_ID
)
+
'?pickedFlag=true'
print
(
'url'
,
url
)
# # # # 发送请求
result
=
commonFuc
().
http_get
(
url
,
headers
)
print
(
'查看出库单详细信息result'
,
result
)
# =======================查看出库单详细信息===============
# ========================扫码复核
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_stock_hdiBarcode_scan_url"
)
url
=
url
+
pkgCode
print
(
'url'
,
url
)
# # # # 发送请求
result
=
commonFuc
().
http_get
(
url
,
headers
)
print
(
'扫码复核result'
,
result
)
data
=
commonFuc
().
analysis_json
(
'data'
,
result
)
UT_id
=
commonFuc
().
analysis_json
(
'id'
,
data
)
createTime
=
commonFuc
().
analysis_json
(
'createTime'
,
data
)
snCode
=
commonFuc
().
analysis_json
(
'snCode'
,
data
)
tbStatus
=
commonFuc
().
analysis_json
(
'tbStatus'
,
data
)
print
(
UT_id
)
# ========================扫码复核
# ========出库复核提交==========
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_stock_review_pass_submit_url"
)
print
(
'expected'
,
expected
)
print
(
'aaaaaaaaaaaaaaaaa'
)
actual_value1
=
get_process_list2
(
actual
)
expected_value1
=
get_process_list2
(
expected
)
actual_value2
=
actual_value1
.
replace
(
" "
,
""
)
expected_value2
=
expected_value1
.
replace
(
" "
,
""
)
# print('actual_value2',actual_value2)
print
(
'expected_value2'
)
print
(
expected_value2
)
print
(
'actual_value2'
)
print
(
actual_value2
)
print
(
compare_text_index
(
actual_value2
,
expected_value2
))
if
actual_value2
==
expected_value2
:
print
(
'ok'
)
commonFuc
().
check_text_exist_result_text
(
'succees'
,
'succees'
)
else
:
print
(
'error'
)
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
print
(
'url'
,
url
)
sourceId
=
' '
.
join
(
PICK_ID
)
# 请求体
request_body
=
commonFuc
().
get_business_data
(
module
,
"payload21"
,
UT_id
,
createTime
,
snCode
,
hosId
,
stockId
,
areaCode
,
areaName
,
shelfCode
,
codeType
,
tagType
,
hosGoodsId
,
mdmGoodsCode
,
goodsCode
,
goodsDi
,
barName
,
batchCode
,
expdtDate
,
productDate
,
pkgCode
,
pkgCodeSee
,
ssccCode
,
tbStatus
,
distrDetailId
,
distrBillId
,
purBillId
,
pkgDefQty
,
pkgDefId
,
pkgDefName
,
purMode
,
goodsMfrsName
,
goodsSpec
,
unit
,
goodsName
,
pkgDefId
,
pkgDefQty
,
pkgDefName
,
made
,
hosGoodsCode
,
sourceId
)
print
(
'request_body'
,
request_body
)
# # # # 发送请求
result
=
commonFuc
().
http_post
(
url
,
request_body
,
headers
)
print
(
'herpService_stock_review_pass_submit_urlresult'
,
result
)
# ========出库复核提交
elif
type
==
1
:
print
(
'低值耗材退货出库'
)
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等信息,使用创建的用户登录============结束
# 到库房明细查询,查询产品的udi码
get_udi
(
1
)
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_pick_submit_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"
))
# 从文件中获取必要信息
info
=
FileUtils
().
r_info8
(
module
,
"条码信息"
,
'message18'
)
# print('info', info)
list_a
=
info
[
'list_a'
]
UTid
=
'UT'
areaCode
=
'areaCode'
createTime
=
'createTime'
hosId
=
'hosId'
stockId
=
'stockId'
areaCode
=
'areaCode'
areaName
=
'areaName'
shelfCode
=
'shelfCode'
codeType
=
'codeType'
tagType
=
'tagType'
hosGoodsId
=
'hosGoodsId'
mdmGoodsCode
=
'mdmGoodsCode'
goodsCode
=
'goodsCode'
goodsDi
=
'goodsDi'
barName
=
'barName'
batchCode
=
'batchCode'
expdtDate
=
'expdtDate'
productDate
=
'productDate'
pkgCode
=
'pkgCode'
pkgCodeSee
=
'pkgCodeSee'
ssccCode
=
'ssccCode'
tbStatus
=
'tbStatus'
pkgDefQty
=
'pkgDefQty'
purBillId
=
'purBillId'
distrBillId
=
'distrBillId'
inStockTime
=
'inStockTime'
distrDetailId
=
'distrDetailId'
purMode
=
'purMode'
goodsMfrsName
=
'goodsMfrsName'
goodsSpec
=
'goodsSpec'
unit
=
'unit'
goodsName
=
'goodsName'
printNum
=
'printNum'
made
=
'made'
provId
=
'provId'
provName
=
'provName'
subProvId
=
'subProvId'
subProvName
=
'subProvName'
hosGoodsCode
=
'hosGoodsCode'
subSendFlag
=
'subSendFlag'
onlyKey
=
'onlyKey'
pkgDefId
=
'pkgDefId'
pkgDefName
=
'pkgDefName'
print
(
'aaaaaaaaaaaaaaaaaaaaaaaaa'
,
list_a
[
0
])
list_b
=
list_a
[
0
]
for
i
in
list_b
:
print
(
i
)
UTid
=
i
[
'id'
]
areaCode
=
i
[
'areaCode'
]
createTime
=
i
[
'createTime'
]
hosId
=
i
[
'hosId'
]
stockId
=
i
[
'stockId'
]
areaCode
=
i
[
'areaCode'
]
areaName
=
i
[
'areaName'
]
shelfCode
=
i
[
'shelfCode'
]
codeType
=
i
[
'codeType'
]
tagType
=
i
[
'tagType'
]
hosGoodsId
=
i
[
'hosGoodsId'
]
mdmGoodsCode
=
i
[
'mdmGoodsCode'
]
goodsCode
=
i
[
'goodsCode'
]
goodsDi
=
i
[
'goodsDi'
]
barName
=
i
[
'barName'
]
batchCode
=
i
[
'batchCode'
]
expdtDate
=
i
[
'expdtDate'
]
productDate
=
i
[
'productDate'
]
pkgCode
=
i
[
'pkgCode'
]
pkgCodeSee
=
i
[
'pkgCodeSee'
]
ssccCode
=
i
[
'ssccCode'
]
tbStatus
=
i
[
'tbStatus'
]
onlyKey
=
i
[
'hosGoodsId'
]
ext
=
i
[
'ext'
]
print
(
'ext'
,
ext
)
distrDetailId
=
ext
[
'distrDetailId'
]
distrBillId
=
ext
[
'distrBillId'
]
purBillId
=
ext
[
'purBillId'
]
pkgDefQty
=
ext
[
'pkgDefQty'
]
pkgDefId
=
ext
[
'pkgDefId'
]
pkgDefName
=
ext
[
'pkgDefName'
]
purMode
=
i
[
'purMode'
]
goodsMfrsName
=
i
[
'goodsMfrsName'
]
goodsSpec
=
i
[
'goodsSpec'
]
unit
=
i
[
'unit'
]
goodsName
=
i
[
'goodsName'
]
pkgDefId
=
i
[
'pkgDefId'
]
pkgDefQty
=
i
[
'pkgDefQty'
]
pkgDefName
=
i
[
'pkgDefName'
]
printNum
=
i
[
'printNum'
]
made
=
i
[
'made'
]
provId
=
i
[
'provId'
]
provName
=
i
[
'provName'
]
subProvId
=
i
[
'subProvId'
]
subProvName
=
i
[
'subProvName'
]
hosGoodsCode
=
i
[
'hosGoodsCode'
]
subSendFlag
=
i
[
'subSendFlag'
]
areaName
=
i
[
'areaName'
]
hosId
=
i
[
'hosId'
]
break
deptid1
=
FileUtils
().
r_info8
(
'b2_herp3_bs'
,
'所有科室id'
,
'message6'
)[
"deptid1"
]
deptName
=
FileUtils
().
r_info8
(
'b2_herp3_bs'
,
'所有科室name'
,
'message6'
)[
"deptid1"
]
# # 请求体
request_body
=
commonFuc
().
get_business_data
(
module
,
"payload19"
,
areaCode
,
UTid
,
createTime
,
UTid
,
hosId
,
stockId
,
areaCode
,
areaName
,
shelfCode
,
codeType
,
tagType
,
hosGoodsId
,
mdmGoodsCode
,
goodsCode
,
goodsDi
,
barName
,
batchCode
,
expdtDate
,
productDate
,
pkgCode
,
pkgCodeSee
,
ssccCode
,
tbStatus
,
distrDetailId
,
distrBillId
,
purBillId
,
pkgDefQty
,
pkgDefId
,
pkgDefName
,
purMode
,
goodsMfrsName
,
goodsSpec
,
unit
,
goodsName
,
pkgDefId
,
pkgDefQty
,
pkgDefName
,
printNum
,
made
,
provId
,
provName
,
subProvId
,
subProvName
,
hosGoodsCode
,
subSendFlag
,
onlyKey
,
areaName
,
hosId
,
get_branch_id
(),
deptid1
,
deptName
,
stockId
)
print
(
'request_body'
,
'ccccccc'
,
request_body
)
# # # # 发送请求
result
=
commonFuc
().
http_post
(
url
,
request_body
,
headers
)
print
(
'result'
,
result
)
PICK_ID
=
commonFuc
().
analysis_json
(
'data'
,
result
)
# =====================出库复核列表查询获取pickid===============
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_pick_return_page_url"
)
print
(
'url'
,
url
)
request_body
=
commonFuc
().
get_business_data
(
module
,
"payload20"
,
get_branch_id
(),
get_hosid
(),
deptid1
)
# # # # 发送请求
result
=
commonFuc
().
http_post
(
url
,
request_body
,
headers
)
print
(
'result'
,
result
)
# =====================出库复核列表查询获取pickid===============
# =======================查看出库单详细信息===============
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_pick_checkReview_url"
)
url
=
url
+
' '
.
join
(
PICK_ID
)
+
'?pickedFlag=true'
print
(
'url'
,
url
)
# # # # 发送请求
result
=
commonFuc
().
http_get
(
url
,
headers
)
print
(
'查看出库单详细信息result'
,
result
)
# =======================查看出库单详细信息===============
# ========================扫码复核
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_stock_hdiBarcode_scan_url"
)
url
=
url
+
pkgCode
print
(
'url'
,
url
)
# # # # 发送请求
result
=
commonFuc
().
http_get
(
url
,
headers
)
print
(
'扫码复核result'
,
result
)
data
=
commonFuc
().
analysis_json
(
'data'
,
result
)
UT_id
=
commonFuc
().
analysis_json
(
'id'
,
data
)
createTime
=
commonFuc
().
analysis_json
(
'createTime'
,
data
)
snCode
=
commonFuc
().
analysis_json
(
'snCode'
,
data
)
tbStatus
=
commonFuc
().
analysis_json
(
'tbStatus'
,
data
)
print
(
UT_id
)
# ========================扫码复核
# ========出库复核提交==========
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_stock_review_pass_submit_url"
)
print
(
'url'
,
url
)
sourceId
=
' '
.
join
(
PICK_ID
)
# 请求体
request_body
=
commonFuc
().
get_business_data
(
module
,
"payload21"
,
UT_id
,
createTime
,
snCode
,
hosId
,
stockId
,
areaCode
,
areaName
,
shelfCode
,
codeType
,
tagType
,
hosGoodsId
,
mdmGoodsCode
,
goodsCode
,
goodsDi
,
barName
,
batchCode
,
expdtDate
,
productDate
,
pkgCode
,
pkgCodeSee
,
ssccCode
,
tbStatus
,
distrDetailId
,
distrBillId
,
purBillId
,
pkgDefQty
,
pkgDefId
,
pkgDefName
,
purMode
,
goodsMfrsName
,
goodsSpec
,
unit
,
goodsName
,
pkgDefId
,
pkgDefQty
,
pkgDefName
,
made
,
hosGoodsCode
,
sourceId
)
print
(
'request_body'
,
request_body
)
# # # # 发送请求
result
=
commonFuc
().
http_post
(
url
,
request_body
,
headers
)
print
(
'herpService_stock_review_pass_submit_urlresult'
,
result
)
# ========出库复核提交
elif
type
==
3
:
print
(
'试剂产品退库出库'
)
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等信息,使用创建的用户登录============结束
# 到库房明细查询,查询产品的udi码
get_udi
(
3
)
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_pick_submit_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"
))
# 从文件中获取必要信息
info
=
FileUtils
().
r_info8
(
module
,
"条码信息"
,
'message18'
)
# print('info', info)
list_a
=
info
[
'list_a'
]
# print('list_a', list_a[0], type(list_a), len(list_a))
UTid
=
'UT'
areaCode
=
'areaCode'
createTime
=
'createTime'
hosId
=
'hosId'
stockId
=
'stockId'
areaCode
=
'areaCode'
areaName
=
'areaName'
shelfCode
=
'shelfCode'
codeType
=
'codeType'
tagType
=
'tagType'
hosGoodsId
=
'hosGoodsId'
mdmGoodsCode
=
'mdmGoodsCode'
goodsCode
=
'goodsCode'
goodsDi
=
'goodsDi'
barName
=
'barName'
batchCode
=
'batchCode'
expdtDate
=
'expdtDate'
productDate
=
'productDate'
pkgCode
=
'pkgCode'
pkgCodeSee
=
'pkgCodeSee'
ssccCode
=
'ssccCode'
tbStatus
=
'tbStatus'
pkgDefQty
=
'pkgDefQty'
purBillId
=
'purBillId'
distrBillId
=
'distrBillId'
inStockTime
=
'inStockTime'
distrDetailId
=
'distrDetailId'
purMode
=
'purMode'
goodsMfrsName
=
'goodsMfrsName'
goodsSpec
=
'goodsSpec'
unit
=
'unit'
goodsName
=
'goodsName'
printNum
=
'printNum'
made
=
'made'
provId
=
'provId'
provName
=
'provName'
subProvId
=
'subProvId'
subProvName
=
'subProvName'
hosGoodsCode
=
'hosGoodsCode'
subSendFlag
=
'subSendFlag'
onlyKey
=
'onlyKey'
pkgDefId
=
'pkgDefId'
pkgDefName
=
'pkgDefName'
print
(
'aaaaaaaaaaaaaaaaaaaaaaaaa'
,
list_a
[
0
])
list_b
=
list_a
[
0
]
for
i
in
list_b
:
print
(
i
)
UTid
=
i
[
'id'
]
areaCode
=
i
[
'areaCode'
]
createTime
=
i
[
'createTime'
]
hosId
=
i
[
'hosId'
]
stockId
=
i
[
'stockId'
]
areaCode
=
i
[
'areaCode'
]
areaName
=
i
[
'areaName'
]
shelfCode
=
i
[
'shelfCode'
]
codeType
=
i
[
'codeType'
]
tagType
=
i
[
'tagType'
]
hosGoodsId
=
i
[
'hosGoodsId'
]
mdmGoodsCode
=
i
[
'mdmGoodsCode'
]
goodsCode
=
i
[
'goodsCode'
]
goodsDi
=
i
[
'goodsDi'
]
barName
=
i
[
'barName'
]
batchCode
=
i
[
'batchCode'
]
expdtDate
=
i
[
'expdtDate'
]
productDate
=
i
[
'productDate'
]
pkgCode
=
i
[
'pkgCode'
]
pkgCodeSee
=
i
[
'pkgCodeSee'
]
ssccCode
=
i
[
'ssccCode'
]
tbStatus
=
i
[
'tbStatus'
]
onlyKey
=
i
[
'hosGoodsId'
]
ext
=
i
[
'ext'
]
print
(
'ext'
,
ext
)
distrDetailId
=
ext
[
'distrDetailId'
]
distrBillId
=
ext
[
'distrBillId'
]
purBillId
=
ext
[
'purBillId'
]
pkgDefQty
=
ext
[
'pkgDefQty'
]
pkgDefId
=
ext
[
'pkgDefId'
]
pkgDefName
=
ext
[
'pkgDefName'
]
purMode
=
i
[
'purMode'
]
goodsMfrsName
=
i
[
'goodsMfrsName'
]
goodsSpec
=
i
[
'goodsSpec'
]
unit
=
i
[
'unit'
]
goodsName
=
i
[
'goodsName'
]
pkgDefId
=
i
[
'pkgDefId'
]
pkgDefQty
=
i
[
'pkgDefQty'
]
pkgDefName
=
i
[
'pkgDefName'
]
printNum
=
i
[
'printNum'
]
made
=
i
[
'made'
]
provId
=
i
[
'provId'
]
provName
=
i
[
'provName'
]
subProvId
=
i
[
'subProvId'
]
subProvName
=
i
[
'subProvName'
]
hosGoodsCode
=
i
[
'hosGoodsCode'
]
subSendFlag
=
i
[
'subSendFlag'
]
areaName
=
i
[
'areaName'
]
hosId
=
i
[
'hosId'
]
break
deptid1
=
FileUtils
().
r_info8
(
'b2_herp3_bs'
,
'所有科室id'
,
'message6'
)[
"deptid1"
]
deptName
=
FileUtils
().
r_info8
(
'b2_herp3_bs'
,
'所有科室name'
,
'message6'
)[
"deptid1"
]
# # 请求体
request_body
=
commonFuc
().
get_business_data
(
module
,
"payload19"
,
areaCode
,
UTid
,
createTime
,
UTid
,
hosId
,
stockId
,
areaCode
,
areaName
,
shelfCode
,
codeType
,
tagType
,
hosGoodsId
,
mdmGoodsCode
,
goodsCode
,
goodsDi
,
barName
,
batchCode
,
expdtDate
,
productDate
,
pkgCode
,
pkgCodeSee
,
ssccCode
,
tbStatus
,
distrDetailId
,
distrBillId
,
purBillId
,
pkgDefQty
,
pkgDefId
,
pkgDefName
,
purMode
,
goodsMfrsName
,
goodsSpec
,
unit
,
goodsName
,
pkgDefId
,
pkgDefQty
,
pkgDefName
,
printNum
,
made
,
provId
,
provName
,
subProvId
,
subProvName
,
hosGoodsCode
,
subSendFlag
,
onlyKey
,
areaName
,
hosId
,
get_branch_id
(),
deptid1
,
deptName
,
stockId
)
print
(
'request_body'
,
'ccccccc'
,
request_body
)
# # # # 发送请求
result
=
commonFuc
().
http_post
(
url
,
request_body
,
headers
)
print
(
'result'
,
result
)
PICK_ID
=
commonFuc
().
analysis_json
(
'data'
,
result
)
# =====================出库复核列表查询获取pickid===============
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_pick_return_page_url"
)
print
(
'url'
,
url
)
request_body
=
commonFuc
().
get_business_data
(
module
,
"payload20"
,
get_branch_id
(),
get_hosid
(),
deptid1
)
# # # # 发送请求
result
=
commonFuc
().
http_post
(
url
,
request_body
,
headers
)
print
(
'result'
,
result
)
# =====================出库复核列表查询获取pickid===============
# =======================查看出库单详细信息===============
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_pick_checkReview_url"
)
url
=
url
+
' '
.
join
(
PICK_ID
)
+
'?pickedFlag=true'
print
(
'url'
,
url
)
# # # # 发送请求
result
=
commonFuc
().
http_get
(
url
,
headers
)
print
(
'查看出库单详细信息result'
,
result
)
# =======================查看出库单详细信息===============
# ========================扫码复核
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_stock_hdiBarcode_scan_url"
)
url
=
url
+
pkgCode
print
(
'url'
,
url
)
# # # # 发送请求
result
=
commonFuc
().
http_get
(
url
,
headers
)
print
(
'扫码复核result'
,
result
)
data
=
commonFuc
().
analysis_json
(
'data'
,
result
)
UT_id
=
commonFuc
().
analysis_json
(
'id'
,
data
)
createTime
=
commonFuc
().
analysis_json
(
'createTime'
,
data
)
snCode
=
commonFuc
().
analysis_json
(
'snCode'
,
data
)
tbStatus
=
commonFuc
().
analysis_json
(
'tbStatus'
,
data
)
print
(
UT_id
)
# ========================扫码复核
# ========出库复核提交==========
url
=
commonFuc
().
get_api_add_port_url
()
+
commonFuc
().
get_business_data
(
module
,
"herpService_stock_review_pass_submit_url"
)
print
(
'url'
,
url
)
sourceId
=
' '
.
join
(
PICK_ID
)
# 请求体
request_body
=
commonFuc
().
get_business_data
(
module
,
"payload21"
,
UT_id
,
createTime
,
snCode
,
hosId
,
stockId
,
areaCode
,
areaName
,
shelfCode
,
codeType
,
tagType
,
hosGoodsId
,
mdmGoodsCode
,
goodsCode
,
goodsDi
,
barName
,
batchCode
,
expdtDate
,
productDate
,
pkgCode
,
pkgCodeSee
,
ssccCode
,
tbStatus
,
distrDetailId
,
distrBillId
,
purBillId
,
pkgDefQty
,
pkgDefId
,
pkgDefName
,
purMode
,
goodsMfrsName
,
goodsSpec
,
unit
,
goodsName
,
pkgDefId
,
pkgDefQty
,
pkgDefName
,
made
,
hosGoodsCode
,
sourceId
)
print
(
'request_body'
,
request_body
)
# # # # 发送请求
result
=
commonFuc
().
http_post
(
url
,
request_body
,
headers
)
print
(
'herpService_stock_review_pass_submit_urlresult'
,
result
)
# ========出库复核提交
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_c0流程十七退货业务_中心库退供应商.air'
)
using
(
pro_path
+
r
'//air_case/b5_spd3_core_business_flow/a_c0流程十七退货业务_中心库退供应商.air'
)
from
a_c0流程十七退货业务_中心库退供应商
import
center_Stock_return_Out
try
:
updateUserLoginDefaultRange
(
get_listUserMgrRangePage1
(
1
))
# 设置登录账号默认权限是二级库
second_center_Stock_return_Out
(
2
)
#高值耗材退货出库
second_center_Stock_return_Out
(
1
)
#低值耗材退货出库
second_center_Stock_return_Out
(
3
)
#试剂耗材退货出库
updateUserLoginDefaultRange
(
get_listUserMgrRangePage1
(
1
))
#设置登录账号默认权限是1级库
center_Stock_return_Out
(
2
)
#高值耗材退货出库
time
.
sleep
(
6
)
check_mcms_psi_out
(
2
)
center_Stock_return_Out
(
1
)
#低值耗材退货出库
center_Stock_return_Out
(
3
)
#试剂耗材退货出库
commonFuc
().
check_text_exist_result_text
(
'succees'
,
'succees'
)
except
Exception
as
e
:
# 打印错误信息
print
(
f
"发生错误:
{
e
}
"
)
commonFuc
().
check_text_exist_result_text
(
'error'
,
'SUCCESS'
)
\ No newline at end of file
commonFuc
().
check_text_exist_result_text
(
'error'
,
'SUCCESS'
)
main1/main_text.py
View file @
36bc5231
...
...
@@ -14,7 +14,7 @@ curPath = os.path.abspath(os.path.dirname(__file__)) # 获取当前文件的所
rootPath
=
os
.
path
.
split
(
curPath
)[
0
]
# [0]表示元组中的为一个元素
# print('当前项目的根目录', rootPath)
sys
.
path
.
append
(
rootPath
)
# 将项目的根目录路径添加到环境变量中,然后在cmd命令行中就可以正常运行脚本
sys
.
path
.
append
(
os
.
path
.
join
(
rootPath
,
'common'
))
sys
.
path
.
append
(
os
.
path
.
join
(
rootPath
,
'common'
))
# print('根据当前文件获取当前文件所在目录的路径', os.path.dirname(__file__))
from
airtest.core.helper
import
using
...
...
@@ -36,9 +36,12 @@ import tkinter as tk
from
tkinter
import
*
import
tkinter.messagebox
from
common.run_cmd_script
import
execute_command
pro_path
=
commonFuc
().
get_pro_path2
()
sys
.
path
.
append
(
pro_path
+
r
'/air_case/b5_spd3_core_business_flow/execute.air'
)
using
(
pro_path
+
r
'//air_case/b5_spd3_core_business_flow/execute.air'
)
def
main_text
():
# 创建窗口
root
=
tk
.
Tk
()
...
...
@@ -54,8 +57,9 @@ def main_text():
y
=
(
window_height
-
root
.
winfo_height
())
//
2
# 设置窗口左上角的坐标
root
.
geometry
(
"+{}+{}"
.
format
(
x
,
y
))
root
.
title
(
string
=
"核心业务流"
)
root
.
resizable
(
False
,
False
)
root
.
title
(
string
=
"核心业务流"
)
root
.
resizable
(
False
,
False
)
# for a in ['n', 's', 'e', 'w', 'ne', 'nw', 'se', 'sw']:
# Button(root,
# text='anchor',
...
...
@@ -69,6 +73,7 @@ def main_text():
print
(
'流程一执行完毕'
)
# execute_command("python runner_test.py tag id2302-1 debug mdm3")
# sys.exit(0)
def
flow2
():
print
(
'调用流程二'
)
from
execute
import
flow2
...
...
@@ -76,12 +81,14 @@ def main_text():
print
(
'流程2执行完毕'
)
# execute_command("python runner_test.py tag id2302-2 debug mdm3")
# sys.exit(0)
def
flow3
():
from
execute
import
flow3
flow3
()
print
(
'流程3执行完毕'
)
# execute_command("python runner_test.py tag id2302-3 debug mdm3")
# sys.exit(0)
def
flow4
():
# execute_command("python runner_test.py tag id2302-4 debug mdm3")
from
execute
import
flow4
...
...
@@ -99,93 +106,112 @@ def main_text():
# commonFuc().check_text_exist_result_text('succees', 'succees')
print
(
'流程4执行完毕'
)
# sys.exit(0)
def
flow5
():
# execute_command("python runner_test.py tag id2302-5,id2302-6,id2302-7,id2302-8 debug mdm3")
from
execute
import
flow5
,
flow6
,
flow7
,
flow8
from
execute
import
flow5
,
flow6
,
flow7
,
flow8
flow5
()
flow6
()
flow7
()
flow8
()
print
(
'流程5执行完毕'
)
# sys.exit(0)
def
flow6
():
from
execute
import
flow9
flow9
()
print
(
'流程6执行完毕'
)
# sys.exit(0)
def
flow7
():
print
(
'流程七开始执行'
)
from
execute
import
flow10
flow10
()
print
(
'流程七执行完毕'
)
# sys.exit(0)
def
flow8
():
from
execute
import
flow11
flow11
()
print
(
'流程八执行完毕'
,
'流程八执行完毕 '
)
print
(
'流程八执行完毕'
,
'流程八执行完毕 '
)
# sys.exit(0)
def
flow9
():
# count=get_input()
# count
s
=get_input()
# print(count)
from
execute
import
flow12
flow12
()
print
(
'流程9执行完毕'
,
'流程9执行完毕'
)
counts
=
6
for
i
in
range
(
int
(
counts
)):
from
execute
import
flow12
flow12
()
print
(
'流程9执行完毕'
,
'流程9执行完毕'
,
i
)
# sys.exit(0)
def
flow10
():
from
execute
import
flow13
flow13
()
print
(
'流程十执行完毕'
,
'流程十执行完毕'
)
print
(
'流程十执行完毕'
,
'流程十执行完毕'
)
# sys.exit(0)
def
flow11
():
from
execute
import
flow14
flow14
()
print
(
'流程11执行完毕'
,
'flow11执行完毕'
)
print
(
'流程11执行完毕'
,
'flow11执行完毕'
)
# sys.exit(0)
def
flow12
():
from
execute
import
flow15
flow15
()
print
(
'流程12执行完毕'
,
'flow12执行完毕'
)
# sys.exit(0)
def
flow13
():
from
execute
import
flow16
flow16
()
print
(
'流程13执行完毕'
,
'flow13执行完毕'
)
# sys.exit(0)
def
flow14
():
from
execute
import
flow17
flow17
()
print
(
'流程14执行完毕'
,
'flow14执行完毕'
)
# sys.exit(0)
def
flow15
():
from
execute
import
flow18
flow18
()
print
(
'流程十五执行完毕'
)
# sys.exit(0)
def
flow16
():
from
execute
import
flow19
flow19
()
print
(
'流程十六执行完毕'
)
# sys.exit(0)
def
flow17
():
from
execute
import
flow20
flow20
()
print
(
'流程十七执行完毕'
)
# sys.exit(0)
def
flow18
():
from
execute
import
flow21
flow21
()
print
(
'流程十八执行完毕'
)
# sys.exit(0)
def
flow0
():
execute_command
(
"python runner_test.py tag id2302-23 debug mdm3"
)
sys
.
exit
(
0
)
def
exit
():
print
(
'退出'
)
sys
.
exit
(
0
)
def
del_data
():
# 删除自动化脚本产生的数据
result
=
confirm
()
if
result
==
True
:
result
=
confirm
()
if
result
==
True
:
result1
=
confirm1
()
if
result1
==
True
:
delData
().
Delete_branch_by_id
()
...
...
@@ -199,8 +225,9 @@ def main_text():
print
(
'===================删除垃圾数据完毕============================'
)
else
:
print
(
'Cancel'
)
def
flow5_flow18
():
#脚本运行前清空所有待审批数据
#
脚本运行前清空所有待审批数据
approval_center_all
()
try
:
flow5
()
...
...
@@ -223,8 +250,6 @@ def main_text():
print
(
"发生异常:"
,
str
(
e
))
traceback
.
print_exc
()
def
flow11_flow18
():
flow11
()
flow12
()
...
...
@@ -240,13 +265,16 @@ def main_text():
# print(result)
print
(
"用户选择了:"
,
"OK"
if
result
else
"Cancel"
)
return
result
def
confirm1
():
result
=
tkinter
.
messagebox
.
askokcancel
(
"再次确认"
,
"您确定要执行此删除操作吗?数据删除后不可逆."
)
# print(result)
print
(
"用户选择了:"
,
"OK"
if
result
else
"Cancel"
)
return
result
def
download_data
():
print
(
'从Jenkins服务器下载data数据'
)
def
del_brachdata_from_brachid
():
import
tkinter
as
tk
from
tkinter
import
ttk
...
...
@@ -270,58 +298,48 @@ def main_text():
combo
.
pack
()
root
.
mainloop
()
def
get_input
():
# import tkinter as tk
#
# def get_input():
# print("你输入的内容是: " + entry.get())
#
# root = tk.Tk()
# root.title("输入框示例")
#
# label = tk.Label(root, text="请输入内容:")
# label.pack()
#
# entry = tk.Entry(root)
# entry.pack(padx=20, pady=20)
#
# button = tk.Button(root, text="获取输入", command=get_input)
# button.pack()
# root.mainloop()
#
# return entry.get()
result
=
tkinter
.
messagebox
.
askokcancel
(
"再次确认"
,
"您确定要执行此删除操作吗?数据删除后不可逆."
)
# print(result)
print
(
"用户选择了:"
,
"OK"
if
result
else
"Cancel"
)
return
result
import
tkinter
as
tk
from
tkinter
import
simpledialog
c
=
6
count
=
tk
.
simpledialog
.
askstring
(
"输入循环次数"
,
"循环次数:"
,
initialvalue
=
"%s"
%
c
)
return
count
# 文本显示的位置。
Button
(
root
,
text
=
'流程一
\n
外网企业注册审批'
,
width
=
16
,
height
=
8
,
command
=
flow1
).
grid
(
row
=
2
,
column
=
0
)
Button
(
root
,
text
=
'流程二
\n
供货关系申请审批'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow2
).
grid
(
row
=
2
,
column
=
2
)
Button
(
root
,
text
=
'流程三
\n
流程三_产品导
\n
入和审批'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow3
).
grid
(
row
=
2
,
column
=
4
)
Button
(
root
,
text
=
'流程四
\n
内网基础模块设置'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow4
).
grid
(
row
=
2
,
column
=
6
)
Button
(
root
,
text
=
'流程五
\n
中心库入库正结算
\n
开票'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow5
).
grid
(
row
=
2
,
column
=
8
)
Button
(
root
,
text
=
'流程六
\n
中心库入库负结算'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow6
).
grid
(
row
=
2
,
column
=
10
)
Button
(
root
,
text
=
'流程七
\n
中心库入库正负结算'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow7
).
grid
(
row
=
3
,
column
=
0
)
Button
(
root
,
text
=
'流程八
\n
高值跟台业务'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow8
).
grid
(
row
=
3
,
column
=
2
)
Button
(
root
,
text
=
'流程九
\n
请领业务二级库向
\n
中心库'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow9
).
grid
(
row
=
3
,
column
=
4
)
Button
(
root
,
text
=
'流程十
\n
请领业务流_二级库
\n
向边仓'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow10
).
grid
(
row
=
3
,
column
=
6
)
Button
(
root
,
text
=
'流程十一
\n
请领业务流_二级库
\n
向直送'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow11
).
grid
(
row
=
3
,
column
=
8
)
Button
(
root
,
text
=
'流程十二
\n
请领业务流_二级库
\n
向二级库'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow12
).
grid
(
row
=
3
,
column
=
10
)
Button
(
root
,
text
=
'流程十三
\n
请领业务流_三级库
\n
向二级库'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow13
).
grid
(
row
=
4
,
column
=
0
)
Button
(
root
,
text
=
'流程十四
\n
退库业务消耗退库'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow14
).
grid
(
row
=
4
,
column
=
2
)
Button
(
root
,
text
=
'流程十五
\n
退库业务三级库向
\n
二级库退库'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow15
).
grid
(
row
=
4
,
column
=
4
)
Button
(
root
,
text
=
'流程十六
\n
退库业务_二级库向
\n
一级库退库'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow16
).
grid
(
row
=
4
,
column
=
6
)
Button
(
root
,
text
=
'流程十七
\n
退库业务_中心库退
\n
供应商'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow17
).
grid
(
row
=
4
,
column
=
8
)
Button
(
root
,
text
=
'流程十八
\n
中心库业务_拆包功能'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow18
).
grid
(
row
=
4
,
column
=
10
)
Button
(
root
,
text
=
'一键执行'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
flow0
).
grid
(
row
=
5
,
column
=
0
)
Button
(
root
,
text
=
'删除指定
\n
院区数据'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
del_brachdata_from_brachid
).
grid
(
row
=
5
,
column
=
2
)
Button
(
root
,
text
=
'流程五开始
\n
一键执行'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
flow5_flow18
).
grid
(
row
=
5
,
column
=
4
)
Button
(
root
,
text
=
'删除垃圾
\n
数据'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
del_data
).
grid
(
row
=
5
,
column
=
6
)
Button
(
root
,
text
=
'流程十一开始
\n
一键执行'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
flow11_flow18
).
grid
(
row
=
5
,
column
=
8
)
Button
(
root
,
text
=
'从jenkins
\n
下载data
\n
数据'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
download_data
).
grid
(
row
=
5
,
column
=
10
)
Button
(
root
,
text
=
'退 出'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
exit
).
grid
(
row
=
5
,
column
=
10
)
Button
(
root
,
text
=
'流程一
\n
外网企业注册审批'
,
width
=
16
,
height
=
8
,
command
=
flow1
).
grid
(
row
=
2
,
column
=
0
)
Button
(
root
,
text
=
'流程二
\n
供货关系申请审批'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow2
).
grid
(
row
=
2
,
column
=
2
)
Button
(
root
,
text
=
'流程三
\n
流程三_产品导
\n
入和审批'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow3
).
grid
(
row
=
2
,
column
=
4
)
Button
(
root
,
text
=
'流程四
\n
内网基础模块设置'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow4
).
grid
(
row
=
2
,
column
=
6
)
Button
(
root
,
text
=
'流程五
\n
中心库入库正结算
\n
开票'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow5
).
grid
(
row
=
2
,
column
=
8
)
Button
(
root
,
text
=
'流程六
\n
中心库入库负结算'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow6
).
grid
(
row
=
2
,
column
=
10
)
Button
(
root
,
text
=
'流程七
\n
中心库入库正负结算'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow7
).
grid
(
row
=
3
,
column
=
0
)
Button
(
root
,
text
=
'流程八
\n
高值跟台业务'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow8
).
grid
(
row
=
3
,
column
=
2
)
Button
(
root
,
text
=
'流程九
\n
请领业务二级库向
\n
中心库'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow9
).
grid
(
row
=
3
,
column
=
4
)
Button
(
root
,
text
=
'流程十
\n
请领业务流_二级库
\n
向边仓'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow10
).
grid
(
row
=
3
,
column
=
6
)
Button
(
root
,
text
=
'流程十一
\n
请领业务流_二级库
\n
向直送'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow11
).
grid
(
row
=
3
,
column
=
8
)
Button
(
root
,
text
=
'流程十二
\n
请领业务流_二级库
\n
向二级库'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow12
).
grid
(
row
=
3
,
column
=
10
)
Button
(
root
,
text
=
'流程十三
\n
请领业务流_三级库
\n
向二级库'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow13
).
grid
(
row
=
4
,
column
=
0
)
Button
(
root
,
text
=
'流程十四
\n
退库业务消耗退库'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow14
).
grid
(
row
=
4
,
column
=
2
)
Button
(
root
,
text
=
'流程十五
\n
退库业务三级库向
\n
二级库退库'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow15
).
grid
(
row
=
4
,
column
=
4
)
Button
(
root
,
text
=
'流程十六
\n
退库业务_二级库向
\n
一级库退库'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow16
).
grid
(
row
=
4
,
column
=
6
)
Button
(
root
,
text
=
'流程十七
\n
退库业务_中心库退
\n
供应商'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow17
).
grid
(
row
=
4
,
column
=
8
)
Button
(
root
,
text
=
'流程十八
\n
中心库业务_拆包功能'
,
anchor
=
'center'
,
width
=
16
,
height
=
8
,
command
=
flow18
).
grid
(
row
=
4
,
column
=
10
)
Button
(
root
,
text
=
'一键执行'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
flow0
).
grid
(
row
=
5
,
column
=
0
)
Button
(
root
,
text
=
'删除指定
\n
院区数据'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
del_brachdata_from_brachid
).
grid
(
row
=
5
,
column
=
2
)
Button
(
root
,
text
=
'流程五开始
\n
一键执行'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
flow5_flow18
).
grid
(
row
=
5
,
column
=
4
)
Button
(
root
,
text
=
'删除垃圾
\n
数据'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
del_data
).
grid
(
row
=
5
,
column
=
6
)
Button
(
root
,
text
=
'流程十一开始
\n
一键执行'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
flow11_flow18
).
grid
(
row
=
5
,
column
=
8
)
Button
(
root
,
text
=
'从jenkins
\n
下载data
\n
数据'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
download_data
).
grid
(
row
=
5
,
column
=
10
)
Button
(
root
,
text
=
'退 出'
,
anchor
=
'center'
,
width
=
8
,
height
=
2
,
command
=
exit
).
grid
(
row
=
5
,
column
=
10
)
# Button(root, text='anchor', anchor='e', width=30, height=4).pack()
# Button(root, text='anchor', anchor='w', width=30, height=4).pack()
...
...
@@ -331,4 +349,6 @@ def main_text():
# Button(root, text='anchor', anchor='sw', width=30, height=4).pack()
root
.
mainloop
()
main_text
()
\ No newline at end of file
main_text
()
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment