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
ebb62d7d
Commit
ebb62d7d
authored
Jul 17, 2024
by
肖 和生
Browse files
Merge remote-tracking branch 'remotes/origin/master' into core_flow
parents
e595d311
da5c1087
Changes
7
Hide whitespace changes
Inline
Side-by-side
air_case/b5_spd3_core_business_flow/a_b2流程九请领业务流_二级库向中心库.air/a_b2流程九请领业务流_二级库向中心库.py
View file @
ebb62d7d
...
...
@@ -481,7 +481,11 @@ def main():
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室name"
,
'message6'
)[
'deptid2'
],
2
)
# get_stockAreaId_new(FileUtils().r_info8("b2_herp3_bs", "所有科室id", 'message6')['deptid3'],FileUtils().r_info8("b2_herp3_bs", "所有科室name", 'message6')['deptid3'],3)
# 设置库区联系人
set_stockShelf_Linkman
()
# set_stockShelf_Linkman()
deptName2
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室name"
,
'message6'
)[
'deptid2'
]
# 设置库区联系人
set_stockShelf_Linkman
(
FileUtils
().
r_info8
(
'b2_herp3_bs'
,
'所有科室id'
,
'message6'
)[
"deptid2"
],
get_stockAreaId2_new_fromDb
(
deptName2
,
2
))
# 低值
second_dept_Request
(
FileUtils
().
r_info8
(
"b5_spd3_core_business_flow"
,
"产品审核信息"
,
'message2'
)[
'hosGoodsId'
],
1
)
# 高值
...
...
air_case/b6_spd3_core_business_flow_database_check/a_b4流程十一请领业务流_二级库向直送_数据库验证.air/a_b4流程十一请领业务流_二级库向直送_数据库验证.py
View file @
ebb62d7d
...
...
@@ -6,7 +6,8 @@ from air_case.b1_herp3_login.登录内网系统.登录内网系统 import login_
from
air_case.public1.public1.public1
import
*
from
common.db.sql.sql_del_branch_info
import
delData
from
common.db.sql.sql_tools
import
get_create_time
,
check_mcms_dept_buy_car_sql
,
get_dept_buy_id
,
\
check_mcms_dept_buy_sql
,
get_mdm_goods_code
,
get_expdt_date
,
check_mcms_pur_plan_sql
check_mcms_dept_buy_sql
,
get_mdm_goods_code
,
get_expdt_date
,
check_mcms_pur_plan_sql
,
check_in_check_mcms_purchase
from
common.db.sql.sql_tools_out
import
check_out_check_mcms_purchase
from
common.fileUtls
import
FileUtils
from
common.run_cmd_script
import
execute_command
...
...
@@ -38,7 +39,7 @@ def check_mcms_dept_buy_car(type=1):
print
(
'create_time'
,
create_time
)
id
=
get_id
(
"select id from mcms_dept_buy_car where branch_id='%s'and hos_goods_id='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
hos_goods_id
))
branch_id
,
hos_goods_id
))
print
(
'id'
,
id
)
create_user
=
get_id
(
"select create_user from mcms_dept_buy_car where branch_id='%s'and hos_goods_id='%s' order by create_time desc LIMIT 1;;"
%
(
...
...
@@ -50,7 +51,7 @@ def check_mcms_dept_buy_car(type=1):
print
(
actual_value1
)
deptid2
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室id"
,
'message6'
)[
'deptid2'
]
deptname2
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室name"
,
'message6'
)[
'deptid2'
]
areaCode
=
get_stockAreaId_new_fromDb
(
deptname2
,
2
)
areaCode
=
get_stockAreaId_new_fromDb
(
deptname2
,
2
)
areaName
=
'默认库区'
# 读取文件中的信息
info
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
"二级库请领产品信息"
,
'message21'
)
...
...
@@ -102,6 +103,7 @@ def check_mcms_dept_buy_car(type=1):
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
# 检查二级库请领单审批前的子表数据
def
mcms_dept_buy_detail
(
type
=
16
):
branch_id
=
get_branch_id
()
# 获取主表主键
...
...
@@ -183,6 +185,7 @@ def mcms_dept_buy_detail(type=16):
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
# 检查二级库请领单审批前的主表数据
def
check_mcms_dept_buy
(
type
=
16
):
branch_id
=
get_branch_id
()
sql
=
"""select * from mcms_dept_buy where branch_id='%s' and bill_mode='%s' order by create_time desc LIMIT 1;
...
...
@@ -286,6 +289,7 @@ def check_mcms_dept_buy(type=16):
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
# 检查二级库请领单审批后的主表数据
def
check_mcms_dept_buy_approval_after
(
type
=
16
):
branch_id
=
get_branch_id
()
sql
=
"""select * from mcms_dept_buy where branch_id='%s' and bill_mode='%s' order by create_time desc LIMIT 1;
...
...
@@ -391,6 +395,7 @@ def check_mcms_dept_buy_approval_after(type=16):
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
# 检查二级库请领单审批后的子表数据
def
mcms_dept_buy_detail_approval_after
(
type
=
16
):
branch_id
=
get_branch_id
()
# 获取主表主键
...
...
@@ -475,6 +480,7 @@ def mcms_dept_buy_detail_approval_after(type=16):
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
# 检查采购计划主表
def
check_mcms_mcms_pur_plan
(
type
=
16
):
branch_id
=
get_branch_id
()
# 获取请领单主键id
...
...
@@ -527,18 +533,19 @@ def check_mcms_mcms_pur_plan(type=16):
branch_id
,
id1
))
last_modified
=
create_time
last_modified_user
=
create_user
planOrderNo
=
PLAN_order_no
planOrderNo
=
PLAN_order_no
if
type
==
16
:
# 验证子表数据
check_mcms_mcms_pur_plan_detail
(
id2
,
type
,
source_id
,
planOrderNo
)
check_mcms_mcms_pur_plan_detail
(
id2
,
type
,
planOrderNo
)
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_pur_plan'
,
id2
,
PLAN_order_no
,
hos_id
,
get_branch_id
(),
dept_id1
,
dept_name1
,
rec_org_id
,
rec_org_name
,
area_code
,
area_name
,
source_id
,
rec_user
,
rec_addr
,
bill_expdt_date
,
buyBillId
,
planBillId
,
planOrderNo
,
buyOrderNo
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
rec_addr
,
bill_expdt_date
,
buyBillId
,
planBillId
,
planOrderNo
,
buyOrderNo
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
elif
type
==
20
:
check_mcms_mcms_pur_plan_detail
(
id2
,
type
,
source_id
,
planOrderNo
)
check_mcms_mcms_pur_plan_detail
(
id2
,
type
,
planOrderNo
)
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_pur_plan2'
,
id2
,
PLAN_order_no
,
hos_id
,
get_branch_id
(),
dept_id1
,
dept_name1
,
rec_org_id
,
rec_org_name
,
...
...
@@ -547,15 +554,16 @@ def check_mcms_mcms_pur_plan(type=16):
buyOrderNo
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
elif
type
==
66
:
check_mcms_mcms_pur_plan_detail
(
id2
,
type
,
source_id
,
planOrderNo
)
check_mcms_mcms_pur_plan_detail
(
id2
,
type
,
planOrderNo
)
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_pur_plan3'
,
id2
,
PLAN_order_no
,
hos_id
,
get_branch_id
(),
dept_id1
,
dept_name1
,
rec_org_id
,
rec_org_name
,
area_code
,
area_name
,
source_id
,
rec_user
,
rec_addr
,
bill_expdt_date
,
buyBillId
,
planBillId
,
planOrderNo
,
buyOrderNo
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
rec_addr
,
bill_expdt_date
,
buyBillId
,
planBillId
,
planOrderNo
,
buyOrderNo
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
else
:
expected
=
None
expected
=
None
actual_value1
=
get_process_list2
(
actual
)
expected_value1
=
get_process_list2
(
expected
)
actual_value2
=
actual_value1
.
replace
(
" "
,
""
)
...
...
@@ -575,14 +583,15 @@ def check_mcms_mcms_pur_plan(type=16):
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
def
check_mcms_mcms_pur_plan_detail
(
id
,
type
,
source_id
,
planOrderNo
):
# 检查采购计划子表
def
check_mcms_mcms_pur_plan_detail
(
id
,
type
,
planOrderNo
):
branch_id
=
get_branch_id
()
# 根据采购计划主表的id获取采购计划单子表主键
sql
=
"select id from mcms_pur_plan_detail where pid='%s' order by create_time desc LIMIT 1;"
%
(
id
)
id2
=
process_tuple
(
get_dept_buy_id
(
sql
))
# 采购计划单子表主键
sql
=
"select order_no from mcms_pur_plan where id='%s' order by create_time desc LIMIT 1;"
%
(
id2
)
id2
)
PLAN_order_no
=
process_tuple
(
get_dept_buy_id
(
sql
))
# 采购计划单子表order_no
# 要验证的数据sql
sql1
=
"select * from mcms_pur_plan_detail where id='%s' order by create_time desc LIMIT 1;"
%
(
...
...
@@ -600,49 +609,53 @@ def check_mcms_mcms_pur_plan_detail(id,type,source_id,planOrderNo):
create_user
=
rec_user
# last_modified = create_time
last_modified_user
=
create_user
pid
=
id
pid
=
id
if
type
==
16
:
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message2'
)[
"hosGoodsId"
]
mdm_goods_code
=
process_tuple
(
get_id
(
"select mdm_goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
mdm_goods_code
=
process_tuple
(
get_id
(
"select mdm_goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
# print(mdm_goods_code)
goods_code
=
process_tuple
(
get_id
(
"select goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
goods_code
=
process_tuple
(
get_id
(
"select goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
pkg_def_id
=
process_tuple
(
get_id
(
"select pkg_def_id from mcms_pkg where hos_goods_id='%s' LIMIT 1;"
%
hos_goods_id
))
supply_id
=
process_tuple
(
get_id
(
"select supply_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
prov_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_corpId"
]
prov_name
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_username"
]
sub_prov_id
=
prov_id
supply_id
=
process_tuple
(
get_id
(
"select supply_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
prov_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_corpId"
]
prov_name
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_username"
]
sub_prov_id
=
prov_id
create_time
=
get_create_time
(
"select create_time from mcms_pur_plan_detail where id='%s';"
%
(
id2
))
"select create_time from mcms_pur_plan_detail where id='%s';"
%
(
id2
))
last_modified
=
create_time
sub_prov_name
=
prov_name
sub_prov_name
=
prov_name
source_id
=
process_tuple
(
get_id
(
"select source_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
hos_goods_id
,
id2
)))
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_pur_plan_detail'
,
id2
,
pid
,
planOrderNo
,
source_id
,
hos_goods_id
,
mdm_goods_code
,
goods_code
,
pkg_def_id
,
supply_id
,
prov_id
,
prov_name
,
sub_prov_id
,
sub_prov_name
,
'mcms_pur_plan_detail'
,
id2
,
pid
,
planOrderNo
,
source_id
,
hos_goods_id
,
mdm_goods_code
,
goods_code
,
pkg_def_id
,
supply_id
,
prov_id
,
prov_name
,
sub_prov_id
,
sub_prov_name
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
elif
type
==
20
:
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message1'
)[
"hosGoodsId"
]
mdm_goods_code
=
process_tuple
(
get_id
(
"select mdm_goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
hos_goods_id
,
id2
)))
# print(mdm_goods_code)
goods_code
=
process_tuple
(
get_id
(
"select goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
hos_goods_id
,
id2
)))
pkg_def_id
=
process_tuple
(
get_id
(
"select pkg_def_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
hos_goods_id
,
id2
)))
supply_id
=
process_tuple
(
get_id
(
"select supply_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
hos_goods_id
,
id2
)))
prov_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_corpId"
]
prov_name
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_username"
]
sub_prov_id
=
prov_id
...
...
@@ -655,9 +668,10 @@ def check_mcms_mcms_pur_plan_detail(id,type,source_id,planOrderNo):
get_id
(
"select source_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_pur_plan_detail2'
,
id2
,
pid
,
planOrderNo
,
source_id
,
hos_goods_id
,
'mcms_pur_plan_detail2'
,
id2
,
pid
,
planOrderNo
,
source_id
,
hos_goods_id
,
mdm_goods_code
,
goods_code
,
supply_id
,
prov_id
,
prov_name
,
sub_prov_id
,
sub_prov_name
,
sub_prov_id
,
sub_prov_name
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
...
...
@@ -685,13 +699,341 @@ def check_mcms_mcms_pur_plan_detail(id,type,source_id,planOrderNo):
id2
))
last_modified
=
create_time
sub_prov_name
=
prov_name
source_id
=
process_tuple
(
get_id
(
"select source_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_pur_plan_detail3'
,
id2
,
pid
,
planOrderNo
,
source_id
,
hos_goods_id
,
mdm_goods_code
,
goods_code
,
pkg_def_id
,
supply_id
,
prov_id
,
prov_name
,
sub_prov_id
,
sub_prov_name
,
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_purchase
(
type
=
16
):
branch_id
=
get_branch_id
()
# 获取采购订单主键id
sql
=
"select id from mcms_purchase where branch_id='%s' and bill_mode='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
type
)
print
(
sql
)
id1
=
process_tuple
(
get_dept_buy_id
(
sql
))
sql
=
"select order_no from mcms_purchase where branch_id='%s' and bill_mode='%s'and id='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
type
,
id1
)
print
(
sql
)
order_no
=
process_tuple
(
get_dept_buy_id
(
sql
))
sql
=
"select id from mcms_dept_buy where branch_id='%s' and bill_mode='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
type
)
print
(
sql
)
buyBillId
=
process_tuple
(
get_dept_buy_id
(
sql
))
# 要验证的数据sql
sql1
=
"select * from mcms_purchase where branch_id='%s' and bill_mode='%s' and id='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
type
,
id1
)
print
(
sql1
)
# 获取实际值
actual
=
check_mcms_pur_plan_sql
(
sql1
)
print
(
'actual'
,
actual
)
hos_id
=
get_hosid
()
dept_id1
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室id"
,
'message6'
)[
'deptid1'
]
dept_name1
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室name"
,
'message6'
)[
'deptid1'
]
dept_name2
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室name"
,
'message6'
)[
'deptid2'
]
rec_org_id
=
process_tuple
(
get_id
(
"select id from sys_org where branch_id='%s' and ename='%s';"
%
(
branch_id
,
dept_name2
)))
rec_org_name
=
dept_name2
info
=
FileUtils
().
r_info8
(
"b5_spd3_core_business_flow"
,
"库区信息"
,
'message22'
)
list_a
=
info
[
'list_a'
]
area_code
=
commonFuc
().
analysis_json
(
'shelfCode'
,
list_a
)
area_name
=
'默认库区'
rec_user
=
FileUtils
().
r_info8
(
'b2_herp3_bs'
,
"用户名信息"
,
'message3'
)[
'username1'
]
# rec_user = get_login_user_uxid()
rec_addr
=
'自动化测试'
sql
=
"select bill_expdt_date from mcms_pur_plan where branch_id='%s' and source_id='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
buyBillId
)
print
(
sql
)
bill_expdt_date
=
get_expdt_date
(
sql
)
create_user
=
get_login_user_uxid
()
create_time
=
get_create_time
(
"select create_time from mcms_purchase where branch_id='%s' and id='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
id1
))
last_modified
=
get_create_time
(
"select last_modified from mcms_purchase where branch_id='%s' and id='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
id1
))
last_modified_user
=
create_user
last_auditor
=
rec_user
last_audit_time
=
get_create_time
(
"select last_audit_time from mcms_purchase where branch_id='%s' and id='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
id1
))
if
type
==
16
:
# 验证子表数据
# check_mcms_mcms_pur_plan_detail(id2, type, planOrderNo)
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message2'
)[
"hosGoodsId"
]
planBillId
=
process_tuple
(
get_id
(
"select pid from mcms_pur_plan_detail where hos_goods_id='%s' order by create_time desc LIMIT 1;"
%
(
hos_goods_id
)))
planOrderNo
=
process_tuple
(
get_id
(
"select order_no from mcms_pur_plan_detail where hos_goods_id='%s' order by create_time desc LIMIT 1;"
%
(
hos_goods_id
)))
sql
=
"select order_no from mcms_dept_buy where branch_id='%s' and bill_mode='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
type
)
print
(
sql
)
buyOrderNo
=
process_tuple
(
get_dept_buy_id
(
sql
))
purOrderNo
=
order_no
purBillId
=
id1
prov_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_corpId"
]
prov_name
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_username"
]
exe_prov_id
=
prov_id
exe_prov_name
=
prov_name
close_date
=
get_create_time
(
"select close_date from mcms_purchase where id='%s';"
%
(
id1
))
source_id
=
planBillId
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_purchase'
,
id1
,
order_no
,
hos_id
,
get_branch_id
(),
dept_id1
,
dept_name1
,
rec_org_id
,
rec_org_name
,
area_code
,
area_name
,
bill_expdt_date
,
source_id
,
rec_user
,
rec_addr
,
prov_id
,
prov_name
,
exe_prov_id
,
exe_prov_name
,
buyBillId
,
planBillId
,
planOrderNo
,
buyOrderNo
,
purOrderNo
,
purBillId
,
close_date
,
create_user
,
create_time
,
last_modified
,
last_auditor
,
last_audit_time
)
elif
type
==
20
:
# check_mcms_mcms_pur_plan_detail(id2, type, planOrderNo)
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message1'
)[
"hosGoodsId"
]
planBillId
=
process_tuple
(
get_id
(
"select pid from mcms_pur_plan_detail where hos_goods_id='%s' order by create_time desc LIMIT 1;"
%
(
hos_goods_id
)))
planOrderNo
=
process_tuple
(
get_id
(
"select order_no from mcms_pur_plan_detail where hos_goods_id='%s' order by create_time desc LIMIT 1;"
%
(
hos_goods_id
)))
sql
=
"select order_no from mcms_dept_buy where branch_id='%s' and bill_mode='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
type
)
print
(
sql
)
buyOrderNo
=
process_tuple
(
get_dept_buy_id
(
sql
))
purOrderNo
=
order_no
purBillId
=
id1
prov_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_corpId"
]
prov_name
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_username"
]
exe_prov_id
=
prov_id
exe_prov_name
=
prov_name
close_date
=
get_create_time
(
"select close_date from mcms_purchase where id='%s';"
%
(
id1
))
source_id
=
planBillId
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_purchase2'
,
id1
,
order_no
,
hos_id
,
get_branch_id
(),
dept_id1
,
dept_name1
,
rec_org_id
,
rec_org_name
,
area_code
,
area_name
,
bill_expdt_date
,
source_id
,
rec_user
,
rec_addr
,
prov_id
,
prov_name
,
exe_prov_id
,
exe_prov_name
,
buyBillId
,
planBillId
,
planOrderNo
,
buyOrderNo
,
purOrderNo
,
purBillId
,
close_date
,
create_user
,
create_time
,
last_modified
,
last_auditor
,
last_audit_time
)
elif
type
==
66
:
# check_mcms_mcms_pur_plan_detail(id2, type, planOrderNo)
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message3'
)[
"hosGoodsId"
]
planBillId
=
process_tuple
(
get_id
(
"select pid from mcms_pur_plan_detail where hos_goods_id='%s' order by create_time desc LIMIT 1;"
%
(
hos_goods_id
)))
planOrderNo
=
process_tuple
(
get_id
(
"select order_no from mcms_pur_plan_detail where hos_goods_id='%s' order by create_time desc LIMIT 1;"
%
(
hos_goods_id
)))
sql
=
"select order_no from mcms_dept_buy where branch_id='%s' and bill_mode='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
type
)
print
(
sql
)
buyOrderNo
=
process_tuple
(
get_dept_buy_id
(
sql
))
purOrderNo
=
order_no
purBillId
=
id1
prov_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_corpId"
]
prov_name
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_username"
]
exe_prov_id
=
prov_id
exe_prov_name
=
prov_name
close_date
=
get_create_time
(
"select close_date from mcms_purchase where id='%s';"
%
(
id1
))
source_id
=
planBillId
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_purchase3'
,
id1
,
order_no
,
hos_id
,
get_branch_id
(),
dept_id1
,
dept_name1
,
rec_org_id
,
rec_org_name
,
area_code
,
area_name
,
bill_expdt_date
,
source_id
,
rec_user
,
rec_addr
,
prov_id
,
prov_name
,
exe_prov_id
,
exe_prov_name
,
buyBillId
,
planBillId
,
planOrderNo
,
buyOrderNo
,
purOrderNo
,
purBillId
,
close_date
,
create_user
,
create_time
,
last_modified
,
last_auditor
,
last_audit_time
)
else
:
expected
=
None
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_purchase_detail
(
id
,
type
,
planOrderNo
):
branch_id
=
get_branch_id
()
# 根据采购计划主表的id获取采购计划单子表主键
sql
=
"select id from mcms_pur_plan_detail where pid='%s' order by create_time desc LIMIT 1;"
%
(
id
)
id2
=
process_tuple
(
get_dept_buy_id
(
sql
))
# 采购计划单子表主键
sql
=
"select order_no from mcms_pur_plan where id='%s' order by create_time desc LIMIT 1;"
%
(
id2
)
PLAN_order_no
=
process_tuple
(
get_dept_buy_id
(
sql
))
# 采购计划单子表order_no
# 要验证的数据sql
sql1
=
"select * from mcms_pur_plan_detail where id='%s' order by create_time desc LIMIT 1;"
%
(
id2
)
# 获取实际值
actual
=
check_mcms_pur_plan_sql
(
sql1
)
print
(
'actual'
,
actual
)
hos_id
=
get_hosid
()
dept_id1
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室id"
,
'message6'
)[
'deptid1'
]
dept_name1
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室name"
,
'message6'
)[
'deptid1'
]
dept_name2
=
FileUtils
().
r_info8
(
"b2_herp3_bs"
,
"所有科室name"
,
'message6'
)[
'deptid2'
]
rec_org_id
=
process_tuple
(
get_id
(
"select id from sys_org where branch_id='%s' and ename='%s';"
%
(
branch_id
,
dept_name2
)))
rec_user
=
get_login_user_uxid
()
create_user
=
rec_user
# last_modified = create_time
last_modified_user
=
create_user
pid
=
id
if
type
==
16
:
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message2'
)[
"hosGoodsId"
]
mdm_goods_code
=
process_tuple
(
get_id
(
"select mdm_goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
# print(mdm_goods_code)
goods_code
=
process_tuple
(
get_id
(
"select goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
pkg_def_id
=
process_tuple
(
get_id
(
"select pkg_def_id from mcms_pkg where hos_goods_id='%s' LIMIT 1;"
%
hos_goods_id
))
supply_id
=
process_tuple
(
get_id
(
"select supply_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
prov_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_corpId"
]
prov_name
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_username"
]
sub_prov_id
=
prov_id
create_time
=
get_create_time
(
"select create_time from mcms_pur_plan_detail where id='%s';"
%
(
id2
))
last_modified
=
create_time
sub_prov_name
=
prov_name
source_id
=
process_tuple
(
get_id
(
"select source_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_pur_plan_detail'
,
id2
,
pid
,
planOrderNo
,
source_id
,
hos_goods_id
,
mdm_goods_code
,
goods_code
,
pkg_def_id
,
supply_id
,
prov_id
,
prov_name
,
sub_prov_id
,
sub_prov_name
,
sub_prov_id
,
sub_prov_name
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
elif
type
==
20
:
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message1'
)[
"hosGoodsId"
]
mdm_goods_code
=
process_tuple
(
get_id
(
"select mdm_goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
# print(mdm_goods_code)
goods_code
=
process_tuple
(
get_id
(
"select goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
# pkg_def_id = process_tuple(
# get_id("select pkg_def_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';" % (
# hos_goods_id, id2)))
supply_id
=
process_tuple
(
get_id
(
"select supply_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
prov_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_corpId"
]
prov_name
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_username"
]
sub_prov_id
=
prov_id
create_time
=
get_create_time
(
"select create_time from mcms_pur_plan_detail where id='%s';"
%
(
id2
))
last_modified
=
create_time
sub_prov_name
=
prov_name
source_id
=
process_tuple
(
get_id
(
"select source_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_pur_plan_detail2'
,
id2
,
pid
,
planOrderNo
,
source_id
,
hos_goods_id
,
mdm_goods_code
,
goods_code
,
supply_id
,
prov_id
,
prov_name
,
sub_prov_id
,
sub_prov_name
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
else
:
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message3'
)[
"hosGoodsId"
]
mdm_goods_code
=
process_tuple
(
get_id
(
"select mdm_goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
# print(mdm_goods_code)
goods_code
=
process_tuple
(
get_id
(
"select goods_code from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
pkg_def_id
=
process_tuple
(
get_id
(
"select pkg_def_id from mcms_pkg where hos_goods_id='%s' LIMIT 1;"
%
hos_goods_id
))
supply_id
=
process_tuple
(
get_id
(
"select supply_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
prov_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_corpId"
]
prov_name
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_username"
]
sub_prov_id
=
prov_id
create_time
=
get_create_time
(
"select create_time from mcms_pur_plan_detail where id='%s';"
%
(
id2
))
last_modified
=
create_time
sub_prov_name
=
prov_name
source_id
=
process_tuple
(
get_id
(
"select source_id from mcms_pur_plan_detail where hos_goods_id='%s' and id='%s';"
%
(
hos_goods_id
,
id2
)))
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_pur_plan_detail3'
,
id2
,
pid
,
planOrderNo
,
source_id
,
hos_goods_id
,
mdm_goods_code
,
goods_code
,
pkg_def_id
,
supply_id
,
prov_id
,
prov_name
,
sub_prov_id
,
sub_prov_name
,
create_user
,
create_time
,
last_modified
,
last_modified_user
)
...
...
@@ -712,13 +1054,157 @@ def check_mcms_mcms_pur_plan_detail(id,type,source_id,planOrderNo):
else
:
print
(
'error'
)
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
def
check_mcms_purchase_out_and_in
(
type
=
1
):
if
type
==
1
:
sql
=
"select * from mcms_purchase order by create_time desc LIMIT 3;"
else
:
sql
=
"select * from mcms_purchase_detail order by create_time desc LIMIT 3;"
result_in
=
check_in_check_mcms_purchase
(
sql
)
result_out
=
check_out_check_mcms_purchase
(
sql
)
result
=
(
compare_text_index
(
result_in
,
result_out
))
print
(
result
)
print
(
result_in
)
print
(
result_out
)
i
=
0
while
True
:
if
i
==
1000
:
print
(
'采购订单同步到外网已经过去16分钟未完成,请检查同步是否出现问题'
)
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
break
result_in
=
check_in_check_mcms_purchase
(
sql
)
result_out
=
check_out_check_mcms_purchase
(
sql
)
if
result_in
==
result_out
:
print
(
'ok'
)
commonFuc
().
check_text_exist_result_text
(
'succees'
,
'succees'
)
break
else
:
print
(
'error'
)
time
.
sleep
(
10
)
i
=
1
+
10
continue
def
check_hdi_distr
(
type
=
16
):
branch_id
=
get_branch_id
()
#验证配送单主表
sql
=
"select * from hdi_distr where branch_id = '%s' and bill_mode='%s'order by create_time desc LIMIT 1;"
%
(
branch_id
,
type
)
# 获取实际值
actual
=
check_mcms_pur_plan_sql
(
sql
)
print
(
'actual'
,
actual
)
hos_id
=
get_hosid
()
if
type
==
16
:
# 验证子表数据
# check_mcms_mcms_pur_plan_detail(id2, type, planOrderNo)
#获取采购订单id
purchase_id
=
get_id
(
"select id from mcms_purchase where branch_id = '%s' and bill_mode='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
type
))
#查询配送单主键
distr_main_key
=
get_id
(
"select id from hdi_distr a where branch_id = '%s' and bill_mode='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
type
))
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_purchase'
,
id1
,
order_no
,
hos_id
,
get_branch_id
(),
dept_id1
,
dept_name1
,
rec_org_id
,
rec_org_name
,
area_code
,
area_name
,
bill_expdt_date
,
source_id
,
rec_user
,
rec_addr
,
prov_id
,
prov_name
,
exe_prov_id
,
exe_prov_name
,
buyBillId
,
planBillId
,
planOrderNo
,
buyOrderNo
,
purOrderNo
,
purBillId
,
close_date
,
create_user
,
create_time
,
last_modified
,
last_auditor
,
last_audit_time
)
elif
type
==
20
:
# check_mcms_mcms_pur_plan_detail(id2, type, planOrderNo)
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message1'
)[
"hosGoodsId"
]
planBillId
=
process_tuple
(
get_id
(
"select pid from mcms_pur_plan_detail where hos_goods_id='%s' order by create_time desc LIMIT 1;"
%
(
hos_goods_id
)))
planOrderNo
=
process_tuple
(
get_id
(
"select order_no from mcms_pur_plan_detail where hos_goods_id='%s' order by create_time desc LIMIT 1;"
%
(
hos_goods_id
)))
sql
=
"select order_no from mcms_dept_buy where branch_id='%s' and bill_mode='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
type
)
print
(
sql
)
buyOrderNo
=
process_tuple
(
get_dept_buy_id
(
sql
))
purOrderNo
=
order_no
purBillId
=
id1
prov_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_corpId"
]
prov_name
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_username"
]
exe_prov_id
=
prov_id
exe_prov_name
=
prov_name
close_date
=
get_create_time
(
"select close_date from mcms_purchase where id='%s';"
%
(
id1
))
source_id
=
planBillId
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_purchase2'
,
id1
,
order_no
,
hos_id
,
get_branch_id
(),
dept_id1
,
dept_name1
,
rec_org_id
,
rec_org_name
,
area_code
,
area_name
,
bill_expdt_date
,
source_id
,
rec_user
,
rec_addr
,
prov_id
,
prov_name
,
exe_prov_id
,
exe_prov_name
,
buyBillId
,
planBillId
,
planOrderNo
,
buyOrderNo
,
purOrderNo
,
purBillId
,
close_date
,
create_user
,
create_time
,
last_modified
,
last_auditor
,
last_audit_time
)
elif
type
==
66
:
# check_mcms_mcms_pur_plan_detail(id2, type, planOrderNo)
hos_goods_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'产品审核信息'
,
'message3'
)[
"hosGoodsId"
]
planBillId
=
process_tuple
(
get_id
(
"select pid from mcms_pur_plan_detail where hos_goods_id='%s' order by create_time desc LIMIT 1;"
%
(
hos_goods_id
)))
planOrderNo
=
process_tuple
(
get_id
(
"select order_no from mcms_pur_plan_detail where hos_goods_id='%s' order by create_time desc LIMIT 1;"
%
(
hos_goods_id
)))
sql
=
"select order_no from mcms_dept_buy where branch_id='%s' and bill_mode='%s' order by create_time desc LIMIT 1;"
%
(
branch_id
,
type
)
print
(
sql
)
buyOrderNo
=
process_tuple
(
get_dept_buy_id
(
sql
))
purOrderNo
=
order_no
purBillId
=
id1
prov_id
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_corpId"
]
prov_name
=
FileUtils
().
r_info8
(
'b5_spd3_core_business_flow'
,
'供货关系申请2'
,
'message'
)[
"e_username"
]
exe_prov_id
=
prov_id
exe_prov_name
=
prov_name
close_date
=
get_create_time
(
"select close_date from mcms_purchase where id='%s';"
%
(
id1
))
source_id
=
planBillId
expected
=
commonFuc
().
get_business_data
(
'b6_spd3_core_business_flow_database_check'
,
'mcms_purchase3'
,
id1
,
order_no
,
hos_id
,
get_branch_id
(),
dept_id1
,
dept_name1
,
rec_org_id
,
rec_org_name
,
area_code
,
area_name
,
bill_expdt_date
,
source_id
,
rec_user
,
rec_addr
,
prov_id
,
prov_name
,
exe_prov_id
,
exe_prov_name
,
buyBillId
,
planBillId
,
planOrderNo
,
buyOrderNo
,
purOrderNo
,
purBillId
,
close_date
,
create_user
,
create_time
,
last_modified
,
last_auditor
,
last_audit_time
)
else
:
expected
=
None
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'
)
try
:
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_b4流程十一请领业务流_二级库向直送.air'
)
using
(
pro_path
+
r
'//air_case/b5_spd3_core_business_flow/a_b4流程十一请领业务流_二级库向直送.air'
)
#
updateUserLoginDefaultRange(get_listUserMgrRangePage(2)) # 设置登录账号默认权限是二级库
updateUserLoginDefaultRange
(
get_listUserMgrRangePage
(
2
))
# 设置登录账号默认权限是二级库
from
a_b4流程十一请领业务流_二级库向直送
import
goods_move2
...
...
@@ -751,20 +1237,29 @@ try:
# for i in list_data:
# check_mcms_dept_buy_approval_after(int(i))
# mcms_dept_buy_detail_approval_after(int(i))
#
# # 检查自动生成的采购计划数据
# list_data = ['16', '20', '66']
# for i in list_data:
# check_mcms_mcms_pur_plan(int(i))
# # 采购模块处理
# purchase_module_process()
#
# for i in range(3): # 三个单据共审批3次
# approval_center()
#
# list_data = ['16', '20', '66']
# for i in list_data:
# check_mcms_purchase(int(i))
#
# #检查同步到外网的采购订单数据跟内网的是否一致
# check_mcms_purchase_out_and_in(1)
# check_mcms_purchase_out_and_in(2)
# order_dp(1) # 1低值
# order_dp(2) # 2高值
# order_dp(3) # 3试剂
# 上面暂时注释=========================================
# 检查自动生成的采购计划数据
list_data
=
[
'16'
,
'20'
,
'66'
]
for
i
in
list_data
:
check_mcms_mcms_pur_plan
(
int
(
i
))
# 采购模块处理
purchase_module_process
()
for
i
in
range
(
3
):
# 三个单据共审批3次
approval_center
()
order_dp
(
1
)
# 1低值
order_dp
(
2
)
# 2高值
order_dp
(
3
)
# 3试剂
check_hdi_distr
()
check_accept_order
(
1
)
# 低值
check_accept_order
(
2
)
# 高值
check_accept_order
(
3
)
# 试剂
...
...
air_case/public1/public1/public1.py
View file @
ebb62d7d
...
...
@@ -3193,10 +3193,11 @@ def second_dept_one_key_in(type=2):
# # # # 发送请求
result
=
commonFuc
().
http_post
(
url
,
request_body
,
headers
)
print
(
'一键入库result'
,
result
)
data
=
commonFuc
().
analysis_json
(
'data'
,
result
)
code
=
commonFuc
().
analysis_json
(
'code'
,
result
)
if
code
==
1010
:
commonFuc
().
check_text_exist_result_text
(
'error'
,
'succees'
)
return
data
# 一键入库====================================================
...
...
common/db/sql/sql_tools.py
View file @
ebb62d7d
...
...
@@ -176,5 +176,17 @@ def get_mdm_goods_code(sql):
results
=
cursor
.
fetchall
()
cursor
.
close
()
return
results
def
check_in_check_mcms_purchase
(
sql
):
db
,
cursor
=
get_sql_conn
()
cursor
.
execute
(
sql
)
results
=
cursor
.
fetchone
()
str1
=
str
(
results
)
new_str1
=
str1
.
replace
(
',)'
,
''
)
new_str1
=
new_str1
.
replace
(
'('
,
''
)
new_str1
=
new_str1
.
replace
(
','
,
''
)
new_str1
=
new_str1
.
replace
(
"'"
,
''
)
# print(new_str1)
cursor
.
close
()
return
new_str1
# hos_goods_id = 'h034700004220'
# main2(hos_goods_id)
\ No newline at end of file
common/db/sql/sql_tools_out.py
0 → 100644
View file @
ebb62d7d
import
pymysql
from
common.fileUtls
import
FileUtils
def
get_db
():
# 打开数据库连接
db
=
pymysql
.
connect
(
host
=
"10.17.65.108"
,
user
=
"root"
,
password
=
"Cmic.2023"
,
database
=
"spd_hdiorder_test2"
,
charset
=
"utf8"
)
return
db
def
get_sql_conn
():
"""
获取数据库连接
"""
db
=
get_db
()
cursor
=
db
.
cursor
()
return
db
,
cursor
def
get_index_dict
(
cursor
):
"""
获取数据库对应表中的字段名
"""
index_dict
=
dict
()
index
=
0
for
desc
in
cursor
.
description
:
index_dict
[
desc
[
0
]]
=
index
index
=
index
+
1
return
index_dict
def
get_dict_data_sql
(
cursor
,
sql
):
"""
运行sql语句,获取结果,并根据表中字段名,转化成dict格式(默认是tuple格式)
"""
cursor
.
execute
(
sql
)
data
=
cursor
.
fetchall
()
index_dict
=
get_index_dict
(
cursor
)
res
=
[]
for
datai
in
data
:
resi
=
dict
()
for
indexi
in
index_dict
:
resi
[
indexi
]
=
datai
[
index_dict
[
indexi
]]
res
.
append
(
resi
)
return
res
def
check_mcms_dept_buy_car_sql
(
sql
):
db
,
cursor
=
get_sql_conn
()
res_dict
=
get_dict_data_sql
(
cursor
,
sql
)
print
(
'res_dict'
,
res_dict
)
cursor
.
close
()
return
res_dict
def
check_mcms_dept_buy_sql
(
sql
):
db
,
cursor
=
get_sql_conn
()
res_dict
=
get_dict_data_sql
(
cursor
,
sql
)
print
(
'res_dict'
,
res_dict
)
cursor
.
close
()
return
res_dict
def
check_mcms_pur_plan_sql
(
sql
):
db
,
cursor
=
get_sql_conn
()
res_dict
=
get_dict_data_sql
(
cursor
,
sql
)
print
(
'res_dict'
,
res_dict
)
cursor
.
close
()
return
res_dict
def
get_create_time
(
sql
):
db
,
cursor
=
get_sql_conn
()
cursor
.
execute
(
sql
)
results
=
cursor
.
fetchone
()
str1
=
str
(
results
)
new_str1
=
str1
.
replace
(
',)'
,
''
)
new_str1
=
new_str1
.
replace
(
'(date'
,
'date'
)
# new_str1 = new_str1.replace(',', '')
# print(new_str1)
cursor
.
close
()
return
new_str1
def
get_expdt_date
(
sql
):
db
,
cursor
=
get_sql_conn
()
cursor
.
execute
(
sql
)
results
=
cursor
.
fetchone
()
str1
=
str
(
results
)
new_str1
=
str1
.
replace
(
',)'
,
''
)
new_str1
=
new_str1
.
replace
(
'(date'
,
'date'
)
# new_str1 = new_str1.replace(',', '')
# print(new_str1)
cursor
.
close
()
return
new_str1
def
get_id
(
sql
):
db
,
cursor
=
get_sql_conn
()
cursor
.
execute
(
sql
)
results
=
cursor
.
fetchone
()
str1
=
str
(
results
)
new_str1
=
str1
.
replace
(
',)'
,
''
)
new_str1
=
new_str1
.
replace
(
'('
,
''
)
new_str1
=
new_str1
.
replace
(
','
,
''
)
new_str1
=
new_str1
.
replace
(
"'"
,
''
)
# print(new_str1)
cursor
.
close
()
return
new_str1
def
get_dept_buy_id
(
sql
):
db
,
cursor
=
get_sql_conn
()
cursor
.
execute
(
sql
)
results
=
cursor
.
fetchall
()
cursor
.
close
()
return
results
def
process_tuple
(
tuple1
):
str1
=
str
(
tuple1
)
new_str1
=
str1
.
replace
(
',)'
,
''
)
new_str1
=
new_str1
.
replace
(
'('
,
''
)
new_str1
=
new_str1
.
replace
(
','
,
''
)
new_str1
=
new_str1
.
replace
(
"'"
,
''
)
return
new_str1
def
get_mdm_goods_code
(
sql
):
db
,
cursor
=
get_sql_conn
()
cursor
.
execute
(
sql
)
results
=
cursor
.
fetchall
()
cursor
.
close
()
return
results
def
check_out_check_mcms_purchase
(
sql
):
db
,
cursor
=
get_sql_conn
()
cursor
.
execute
(
sql
)
results
=
cursor
.
fetchone
()
str1
=
str
(
results
)
new_str1
=
str1
.
replace
(
',)'
,
''
)
new_str1
=
new_str1
.
replace
(
'('
,
''
)
new_str1
=
new_str1
.
replace
(
','
,
''
)
new_str1
=
new_str1
.
replace
(
"'"
,
''
)
# print(new_str1)
cursor
.
close
()
return
new_str1
# hos_goods_id = 'h034700004220'
# main2(hos_goods_id)
\ No newline at end of file
data/b6_spd3_core_business_flow_database_check/data
View file @
ebb62d7d
...
...
@@ -32,4 +32,12 @@
"mcms_pur_plan_detail": '{"id": "%s", "pid": "%s", "order_no": "%s", "source_id": "%s", "hos_goods_id": "%s", "mdm_goods_code": "%s", "goods_code": "%s", "pur_mode": 10, "pkg_def_id": "%s", "pkg_def_name": "100", "pkg_def_qty": Decimal("100.00"), "plan_pkg_qty": Decimal("1.00"), "plan_qty": Decimal("100.00"), "pkg_qty": Decimal("1.00"), "price": Decimal("99.999900"), "qty": Decimal("100.00"), "in_settlement": None, "supply_id": "%s", "prov_id": "%s", "prov_name": "%s", "sub_send_flag": 10, "sub_prov_id": "%s", "sub_prov_name": "%s", "contract_id": None, "remark": None, "close_status": 0, "tb_status": 10, "pur_task_id": None, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "coding_type": 0}'
"mcms_pur_plan_detail2": '{"id": "%s", "pid": "%s", "order_no": "%s", "source_id": "%s", "hos_goods_id": "%s", "mdm_goods_code": "%s", "goods_code": "%s", "pur_mode": 20, "pkg_def_id": None, "pkg_def_name": None, "pkg_def_qty": Decimal("1.00"), "plan_pkg_qty": Decimal("1.00"), "plan_qty": Decimal("1.00"), "pkg_qty": Decimal("1.00"), "price": Decimal("99.999900"), "qty": Decimal("1.00"), "in_settlement": None, "supply_id": "%s", "prov_id": "%s", "prov_name": "%s", "sub_send_flag": 10, "sub_prov_id": "%s", "sub_prov_name": "%s", "contract_id": None, "remark": None, "close_status": 0, "tb_status": 10, "pur_task_id": None, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "coding_type": 0}'
\ No newline at end of file
"mcms_pur_plan_detail2": '{"id": "%s", "pid": "%s", "order_no": "%s", "source_id": "%s", "hos_goods_id": "%s", "mdm_goods_code": "%s", "goods_code": "%s", "pur_mode": 20, "pkg_def_id": None, "pkg_def_name": None, "pkg_def_qty": Decimal("1.00"), "plan_pkg_qty": Decimal("1.00"), "plan_qty": Decimal("1.00"), "pkg_qty": Decimal("1.00"), "price": Decimal("99.999900"), "qty": Decimal("1.00"), "in_settlement": None, "supply_id": "%s", "prov_id": "%s", "prov_name": "%s", "sub_send_flag": 10, "sub_prov_id": "%s", "sub_prov_name": "%s", "contract_id": None, "remark": None, "close_status": 0, "tb_status": 10, "pur_task_id": None, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "coding_type": 0}'
"mcms_pur_plan_detail3": '{"id": "%s", "pid": "%s", "order_no": "%s", "source_id": "%s", "hos_goods_id": "%s", "mdm_goods_code": "%s", "goods_code": "%s", "pur_mode": 60, "pkg_def_id": "%s", "pkg_def_name": "100", "pkg_def_qty": Decimal("100.00"), "plan_pkg_qty": Decimal("1.00"), "plan_qty": Decimal("100.00"), "pkg_qty": Decimal("1.00"), "price": Decimal("99.999900"), "qty": Decimal("100.00"), "in_settlement": None, "supply_id": "%s", "prov_id": "%s", "prov_name": "%s", "sub_send_flag": 10, "sub_prov_id": "%s", "sub_prov_name": "%s", "contract_id": None, "remark": None, "close_status": 0, "tb_status": 10, "pur_task_id": None, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "coding_type": 0}'
"mcms_purchase": '{"id": "%s", "order_no": "%s", "bill_mode": "16", "rec_type": "HDI", "hos_id": "%s", "branch_id": "%s", "dept_id": "%s", "dept_name": "%s", "rec_org_id": "%s", "rec_org_name": "%s", "area_code": "%s", "area_name": "%s", "bill_expdt_date": %s, "source_id": "%s", "source_type": "CGJH", "in_settlement": None, "rec_user": "%s", "rec_phone": "None", "rec_addr": "%s", "prov_id": "%s", "prov_name": "%s", "sub_send_flag": 10, "exe_prov_id": "%s", "exe_prov_name": "%s", "bill_relation_json": "{"buyBillId":"%s","planBillId":"%s","planOrderNo":"%s","buyOrderNo":"%s","purOrderNo":"%s","purBillId":"%s"}", "ext_info": "{"epidemicFlag":0,"purMode":10}", "barcode_flag": 1, "pkg_flag": 1, "remark": "", "priority": 0, "close_status": 0, "close_date": %s, "up_status": 0, "tb_status": 30, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": None, "version": 0, "del_flag": 0, "last_auditor": "%s", "last_audit_time": %s}'
"mcms_purchase2": '{"id": "%s", "order_no": "%s", "bill_mode": "20", "rec_type": "HDI", "hos_id": "%s", "branch_id": "%s", "dept_id": "%s", "dept_name": "%s", "rec_org_id": "%s", "rec_org_name": "%s", "area_code": "%s", "area_name": "%s", "bill_expdt_date": %s, "source_id": "%s", "source_type": "CGJH", "in_settlement": None, "rec_user": "%s", "rec_phone": "None", "rec_addr": "%s", "prov_id": "%s", "prov_name": "%s", "sub_send_flag": 10, "exe_prov_id": "%s", "exe_prov_name": "%s", "bill_relation_json": "{"buyBillId":"%s","planBillId":"%s","planOrderNo":"%s","buyOrderNo":"%s","purOrderNo":"%s","purBillId":"%s"}", "ext_info": "{"epidemicFlag":0,"purMode":20}", "barcode_flag": 1, "pkg_flag": 0, "remark": "", "priority": 0, "close_status": 0, "close_date": %s, "up_status": 0, "tb_status": 30, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": None, "version": 0, "del_flag": 0, "last_auditor": "%s", "last_audit_time": %s}'
"mcms_purchase3": '{"id": "%s", "order_no": "%s", "bill_mode": "66", "rec_type": "HDI", "hos_id": "%s", "branch_id": "%s", "dept_id": "%s", "dept_name": "%s", "rec_org_id": "%s", "rec_org_name": "%s", "area_code": "%s", "area_name": "%s", "bill_expdt_date": %s, "source_id": "%s", "source_type": "CGJH", "in_settlement": None, "rec_user": "%s", "rec_phone": "None", "rec_addr": "%s", "prov_id": "%s", "prov_name": "%s", "sub_send_flag": 10, "exe_prov_id": "%s", "exe_prov_name": "%s", "bill_relation_json": "{"buyBillId":"%s","planBillId":"%s","planOrderNo":"%s","buyOrderNo":"%s","purOrderNo":"%s","purBillId":"%s"}", "ext_info": "{"epidemicFlag":0,"purMode":60}", "barcode_flag": 1, "pkg_flag": 1, "remark": "", "priority": 0, "close_status": 0, "close_date": %s, "up_status": 0, "tb_status": 30, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": None, "version": 0, "del_flag": 0, "last_auditor": "%s", "last_audit_time": %s}'
"hdi_distr": '{"id": "PSh0347202407160001", "order_no": "PSh0347202407160001", "bill_mode": "16", "rec_type": "YND", "hos_id": "h0347", "hos_name": "邹城市人民医院(test)", "branch_id": "h0347-3755", "source_id": "Ch034720240716000007", "source_type": "CGD", "pur_bill_id": "Ch034720240716000007", "prov_id": "p1e35e", "prov_name": "国药集团公司S57ui", "sub_send_flag": 10, "exe_prov_id": "p1e35e", "exe_prov_name": "国药集团公司S57ui", "settlement": None, "pur_dept_id": "63c734f07fcc422ea80f49ca8e5bbd95", "pur_dept_name": "设备科001", "rec_org_id": "63c734f07fcc422ea80f49ca8e5bbd95", "rec_org_name": "设备科001", "rec_user": "自动化测试w&vqF", "rec_phone": "xhs", "rec_addr": "自动化测试", "bill_relation_json": "{"planBillId":"Ph034720240716029565","planOrderNo":"PLAN2024071632920","purOrderNo":"CG2024071621454","purBillId":"Ch034720240716000007","purBillDate":"2024-07-16 08:11:19","distrBillId":"PSh0347202407160001","distrOrderNo":"PSh0347202407160001"}", "ext_info": "{"epidemicFlag":0,"purMode":10,"distrUser":"p1e35e:UID-052165"}", "barcode_flag": 1, "pkg_flag": 1, "remark": "", "task_id": None, "convert_flag": 1, "convert_time": None, "convert_user_name": None, "reject_status": 40, "tb_status": 25, "create_user": "p1e35e:UID-052165", "create_user_name": "国药集团公司S57ui", "create_time": datetime.datetime(2024, 7, 16, 8, 11, 42), "last_modified": datetime.datetime(2024, 7, 16, 8, 12, 53), "last_modified_user": "h0347_UID-051420", "version": 2, "del_flag": 0, "last_auditor": None, "last_audit_time": None, "initial_order": None}'
\ No newline at end of file
report/summary.html
View file @
ebb62d7d
...
...
@@ -95,7 +95,7 @@ setInterval(updateTime, 1000); // 每秒更新一次时间
<tr
width=
"600"
>
<td
class=
"details-col-elapsed"
><a
href=
'../log/r_b8库房管理_库区设置_同步库房信息/log.html'
target=
'_blank'
>
r_b8库房管理_库区设置_同步库房信息
</a></td>
<td
class=
"success"
>
成功
</td>
<td
class=
"details-col-elapsed"
>
8.
45
1
</td>
<td
class=
"details-col-elapsed"
>
8.
31
1
</td>
<td
class=
"details-col-elapsed"
>
xiaohesheng
</td>
</tr>
...
...
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