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

数据库验证流程十二脚本编写

parent 1f15dc52
Hide whitespace changes
Inline Side-by-side
air_case/b6_spd3_core_business_flow_database_check/a_b4流程十一请领业务流_二级库向直送_数据库验证.air/a_b4流程十一请领业务流_二级库向直送_数据库验证.py
View file @ 5e9203d0
...@@ -1048,7 +1048,7 @@ def check_mcms_purchase_out_and_in(type=1): ...@@ -1048,7 +1048,7 @@ def check_mcms_purchase_out_and_in(type=1):
create_user = get_login_user_uxid2() create_user = get_login_user_uxid2()
if type == 1: if type == 1:
sql = "select * from mcms_purchase where branch_id='%s' and create_user='%s' order by create_time desc LIMIT 3;" % ( sql = "select * from mcms_purchase where branch_id='%s' and create_user='%s' order by create_time desc LIMIT 3;" % (
branch_id, create_user) branch_id, create_user)
else: else:
sql = "select * from mcms_purchase_detail where create_user='%s' order by create_time desc LIMIT 3;" % create_user sql = "select * from mcms_purchase_detail where create_user='%s' order by create_time desc LIMIT 3;" % create_user
result_in = check_in_check_mcms_purchase(sql) result_in = check_in_check_mcms_purchase(sql)
...@@ -1548,7 +1548,8 @@ def check_mcms_check_batch(type, check_no, order_no, hos_goods_id): ...@@ -1548,7 +1548,8 @@ def check_mcms_check_batch(type, check_no, order_no, hos_goods_id):
source_detail_id = distr_detail_id source_detail_id = distr_detail_id
mdm_goods_code = get_mdm_goods_code1(hos_goods_id) mdm_goods_code = get_mdm_goods_code1(hos_goods_id)
goods_code = get_goods_code1(hos_goods_id) goods_code = get_goods_code1(hos_goods_id)
sql = "select id from hdi_barcode where code_type='%s' and branch_id='%s' order by create_time desc LIMIT 1;" % (bill_mode,branch_id) sql = "select id from hdi_barcode where code_type='%s' and branch_id='%s' order by create_time desc LIMIT 1;" % (
bill_mode, branch_id)
barcode_id = get_id(sql) barcode_id = get_id(sql)
create_user = get_login_user_uxid() create_user = get_login_user_uxid()
create_time = get_create_time("select create_time from mcms_check_batch where pid='%s'" % check_no) create_time = get_create_time("select create_time from mcms_check_batch where pid='%s'" % check_no)
...@@ -1608,12 +1609,12 @@ def check_mcms_psi(type=1): ...@@ -1608,12 +1609,12 @@ def check_mcms_psi(type=1):
bill_mode = 66 bill_mode = 66
branch_id = get_branch_id() branch_id = get_branch_id()
sql = "select * from mcms_psi where target_branch_id='%s' and bill_mode='%s' and stock_kind='RK_YS' order by CREATE_TIME desc LIMIT 1;" % ( sql = "select * from mcms_psi where target_branch_id='%s' and bill_mode='%s' and stock_kind='RK_YS' order by CREATE_TIME desc LIMIT 1;" % (
branch_id, bill_mode) branch_id, bill_mode)
# 获取实际值 # 获取实际值
actual = check_mcms_pur_plan_sql(sql) actual = check_mcms_pur_plan_sql(sql)
print('actual', actual) print('actual', actual)
sql = "select id from mcms_psi where target_branch_id='%s' and bill_mode='%s' and stock_kind='RK_YS' order by CREATE_TIME desc LIMIT 1;" % ( sql = "select id from mcms_psi where target_branch_id='%s' and bill_mode='%s' and stock_kind='RK_YS' order by CREATE_TIME desc LIMIT 1;" % (
branch_id, bill_mode) branch_id, bill_mode)
id = get_id(sql) id = get_id(sql)
sql = "select order_no from mcms_psi where target_branch_id='%s' and bill_mode='%s' and stock_kind='RK_YS' order by CREATE_TIME desc LIMIT 1;" % ( sql = "select order_no from mcms_psi where target_branch_id='%s' and bill_mode='%s' and stock_kind='RK_YS' order by CREATE_TIME desc LIMIT 1;" % (
branch_id, bill_mode) branch_id, bill_mode)
...@@ -1626,7 +1627,7 @@ def check_mcms_psi(type=1): ...@@ -1626,7 +1627,7 @@ def check_mcms_psi(type=1):
target_stock_id = get_stockId_fromdb(stock_name) target_stock_id = get_stockId_fromdb(stock_name)
target_area_code = get_stockAreaId_new_fromDb(target_dept_name, 1) target_area_code = get_stockAreaId_new_fromDb(target_dept_name, 1)
source_id = FileUtils().r_info8('b5_spd3_core_business_flow', '验收单号', 'message15')['CHECK_NO1'] source_id = FileUtils().r_info8('b5_spd3_core_business_flow', '验收单号', 'message15')['CHECK_NO1']
source_no = get_distrBillId(branch_id,bill_mode) source_no = get_distrBillId(branch_id, bill_mode)
source_repl_id = source_no source_repl_id = source_no
source_corp_id = FileUtils().r_info8('b5_spd3_core_business_flow', '供货关系申请2', 'message')["e_corpId"] source_corp_id = FileUtils().r_info8('b5_spd3_core_business_flow', '供货关系申请2', 'message')["e_corpId"]
source_dept_id = source_corp_id source_dept_id = source_corp_id
...@@ -1647,12 +1648,12 @@ def check_mcms_psi(type=1): ...@@ -1647,12 +1648,12 @@ def check_mcms_psi(type=1):
buyOrderNo = get_buyOrderNo(branch_id, bill_mode) buyOrderNo = get_buyOrderNo(branch_id, bill_mode)
purOrderNo = get_purOrderNo(branch_id, bill_mode) purOrderNo = get_purOrderNo(branch_id, bill_mode)
purBillId = get_purBillId(branch_id, bill_mode) purBillId = get_purBillId(branch_id, bill_mode)
bill_relation_json= get_purBillDate2(branch_id, bill_mode) bill_relation_json = get_purBillDate2(branch_id, bill_mode)
purBillDate = reGetString(bill_relation_json, r'purBillDate":"', r'""distrBillId') purBillDate = reGetString(bill_relation_json, r'purBillDate":"', r'""distrBillId')
distrBillId = get_distrBillId(branch_id, bill_mode) distrBillId = get_distrBillId(branch_id, bill_mode)
distrOrderNo = get_distrOrderNo(branch_id, bill_mode) distrOrderNo = get_distrOrderNo(branch_id, bill_mode)
checkBillId = source_id checkBillId = source_id
sql="select order_no from mcms_check where id='%s';"%checkBillId sql = "select order_no from mcms_check where id='%s';" % checkBillId
checkOrderNo = get_id(sql) checkOrderNo = get_id(sql)
psiInBillId = id psiInBillId = id
psiInOrderNo = order_no psiInOrderNo = order_no
...@@ -1713,34 +1714,34 @@ def check_mcms_psi(type=1): ...@@ -1713,34 +1714,34 @@ def check_mcms_psi(type=1):
else: else:
print('error') print('error')
commonFuc().check_text_exist_result_text('error', 'succees') commonFuc().check_text_exist_result_text('error', 'succees')
#检查中心库出库单==================================================================== # 检查中心库出库单====================================================================
sql = "select * from mcms_psi where target_branch_id='%s' and bill_mode='%s' and stock_kind='CK_QL' order by CREATE_TIME desc LIMIT 1;" % ( sql = "select * from mcms_psi where target_branch_id='%s' and bill_mode='%s' and stock_kind='CK_QL' order by CREATE_TIME desc LIMIT 1;" % (
branch_id, bill_mode) branch_id, bill_mode)
# 获取实际值 # 获取实际值
actual = check_mcms_pur_plan_sql(sql) actual = check_mcms_pur_plan_sql(sql)
print('actual', actual) print('actual', actual)
sql = "select id from mcms_psi where target_branch_id='%s' and bill_mode='%s' and stock_kind='CK_QL' order by CREATE_TIME desc LIMIT 1;" % ( sql = "select id from mcms_psi where target_branch_id='%s' and bill_mode='%s' and stock_kind='CK_QL' order by CREATE_TIME desc LIMIT 1;" % (
branch_id, bill_mode) branch_id, bill_mode)
id = get_id(sql) id_out = get_id(sql)
sql = "select order_no from mcms_psi where target_branch_id='%s' and bill_mode='%s' and stock_kind='CK_QL' order by CREATE_TIME desc LIMIT 1;" % ( sql = "select order_no from mcms_psi where target_branch_id='%s' and bill_mode='%s' and stock_kind='CK_QL' order by CREATE_TIME desc LIMIT 1;" % (
branch_id, bill_mode) branch_id, bill_mode)
order_no = get_id(sql) order_no_out = get_id(sql)
target_corp_id = get_hosid() target_corp_id = get_hosid()
target_branch_id = get_branch_id() target_branch_id = get_branch_id()
target_dept_id = FileUtils().r_info8("b2_herp3_bs", "所有科室id", 'message6')['deptid2'] target_dept_id = FileUtils().r_info8("b2_herp3_bs", "所有科室id", 'message6')['deptid2']
target_dept_name = FileUtils().r_info8("b2_herp3_bs", "所有科室name", 'message6')['deptid2'] target_dept_name = FileUtils().r_info8("b2_herp3_bs", "所有科室name", 'message6')['deptid2']
stock_name = get_branch_name() + "库房" stock_name = target_dept_name + "库房"
target_stock_id = get_stockId_fromdb(stock_name) target_stock_id = get_stockId_fromdb(stock_name)
target_area_code = get_stockAreaId_new_fromDb(target_dept_name, 2) target_area_code = get_stockAreaId_new_fromDb(target_dept_name, 2)
source_id = FileUtils().r_info8('b5_spd3_core_business_flow', '验收单号', 'message15')['CHECK_NO1'] source_id_out = id
source_no = get_distrBillId(branch_id,bill_mode) source_no_out = order_no
source_repl_id = source_no source_repl_id = source_no
source_corp_id = FileUtils().r_info8('b5_spd3_core_business_flow', '供货关系申请2', 'message')["e_corpId"] source_corp_id = get_hosid()
source_dept_id = source_corp_id source_dept_id = FileUtils().r_info8("b2_herp3_bs", "所有科室id", 'message6')['deptid1']
source_dept_name = FileUtils().r_info8('b5_spd3_core_business_flow', '供货关系申请2', 'message')["e_username"] source_dept_name =FileUtils().r_info8("b2_herp3_bs", "所有科室name", 'message6')['deptid1']
source_stock_id = source_corp_id source_stock_id = source_corp_id
accounter = get_login_user_uxid_bydb(FileUtils().r_info8('b2_herp3_bs', "用户名信息", 'message3')['username1']) 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) account_date = get_create_time("select account_date from mcms_psi where id='%s';" % id_out)
buyBillId = get_buyBillId(branch_id, bill_mode) buyBillId = get_buyBillId(branch_id, bill_mode)
if type == 1: if type == 1:
...@@ -1754,53 +1755,58 @@ def check_mcms_psi(type=1): ...@@ -1754,53 +1755,58 @@ def check_mcms_psi(type=1):
buyOrderNo = get_buyOrderNo(branch_id, bill_mode) buyOrderNo = get_buyOrderNo(branch_id, bill_mode)
purOrderNo = get_purOrderNo(branch_id, bill_mode) purOrderNo = get_purOrderNo(branch_id, bill_mode)
purBillId = get_purBillId(branch_id, bill_mode) purBillId = get_purBillId(branch_id, bill_mode)
bill_relation_json= get_purBillDate2(branch_id, bill_mode) bill_relation_json = get_purBillDate2(branch_id, bill_mode)
purBillDate = reGetString(bill_relation_json, r'purBillDate":"', r'""distrBillId') purBillDate = reGetString(bill_relation_json, r'purBillDate":"', r'""distrBillId')
distrBillId = get_distrBillId(branch_id, bill_mode) distrBillId = get_distrBillId(branch_id, bill_mode)
distrOrderNo = get_distrOrderNo(branch_id, bill_mode) distrOrderNo = get_distrOrderNo(branch_id, bill_mode)
checkBillId = source_id checkBillId = source_id
sql="select order_no from mcms_check where id='%s';"%checkBillId sql = "select order_no from mcms_check where id='%s';" % checkBillId
checkOrderNo = get_id(sql) checkOrderNo = get_id(sql)
psiInBillId = id psiInBillId = id
psiInOrderNo = order_no psiInOrderNo = order_no
psiOutBillId = id_out
psiOutOrderNo = order_no_out
create_user = get_login_user_uxid_bydb(FileUtils().r_info8('b2_herp3_bs', "用户名信息", 'message3')['username1']) 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) create_time = get_create_time("select create_time from mcms_psi where id='%s';" % id_out)
last_modified = get_create_time("select last_modified from mcms_psi where id='%s';" % id) last_modified = get_create_time("select last_modified from mcms_psi where id='%s';" % id_out)
last_modified_user = create_user last_modified_user = create_user
source_branch_id = get_branch_id()
source_area_code=get_stockAreaId2_new_fromDb(source_dept_name)
if type == 1: if type == 1:
expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check', 'check_mcms_psi_out1', id, expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check', 'check_mcms_psi_out1',
order_no, target_corp_id, target_branch_id, target_dept_id, id_out,
order_no_out, target_corp_id, target_branch_id, target_dept_id,
target_dept_name, target_stock_id target_dept_name, target_stock_id
, target_area_code, source_id, source_no, source_repl_id, , target_area_code, source_id_out, source_no_out, source_repl_id,
source_corp_id, source_dept_id, source_dept_name source_corp_id, source_branch_id, source_dept_id, source_dept_name
, source_stock_id, accounter, account_date, buyBillId, planBillId, , source_stock_id, source_area_code, buyBillId, planBillId,
planOrderNo, buyOrderNo, purOrderNo, purBillId planOrderNo, buyOrderNo, purOrderNo, purBillId
, purBillDate, distrBillId, distrOrderNo, checkBillId, checkOrderNo, , purBillDate, distrBillId, distrOrderNo, checkBillId, checkOrderNo,
psiInBillId, psiInOrderNo, create_user psiInBillId, psiInOrderNo, psiOutBillId, psiOutOrderNo, create_user
, create_time, last_modified, last_modified_user) , create_time, last_modified, last_modified_user)
elif type == 2: elif type == 2:
expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check', 'check_mcms_psi2', id, expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check', 'check_mcms_psi_out2', id_out,
order_no, target_corp_id, target_branch_id, target_dept_id, order_no_out, target_corp_id, target_branch_id, target_dept_id,
target_dept_name, target_stock_id target_dept_name, target_stock_id
, target_area_code, source_id, source_no, source_repl_id, , target_area_code, source_id_out, source_no_out, source_repl_id,
source_corp_id, source_dept_id, source_dept_name source_corp_id, source_branch_id, source_dept_id, source_dept_name
, source_stock_id, accounter, account_date, buyBillId, planBillId, , source_stock_id, source_area_code, buyBillId, planBillId,
planOrderNo, buyOrderNo, purOrderNo, purBillId planOrderNo, buyOrderNo, purOrderNo, purBillId
, purBillDate, distrBillId, distrOrderNo, checkBillId, checkOrderNo, , purBillDate, distrBillId, distrOrderNo, checkBillId, checkOrderNo,
psiInBillId, psiInOrderNo, create_user psiInBillId, psiInOrderNo, psiOutBillId, psiOutOrderNo, create_user
, create_time, last_modified, last_modified_user) , create_time, last_modified, last_modified_user)
else: else:
expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check', 'check_mcms_psi3', id, expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check', 'check_mcms_psi_out3',id_out,
order_no, target_corp_id, target_branch_id, target_dept_id, order_no_out, target_corp_id, target_branch_id, target_dept_id,
target_dept_name, target_stock_id target_dept_name, target_stock_id
, target_area_code, source_id, source_no, source_repl_id, , target_area_code, source_id_out, source_no_out, source_repl_id,
source_corp_id, source_dept_id, source_dept_name source_corp_id, source_branch_id, source_dept_id, source_dept_name
, source_stock_id, accounter, account_date, buyBillId, planBillId, , source_stock_id, source_area_code, buyBillId, planBillId,
planOrderNo, buyOrderNo, purOrderNo, purBillId planOrderNo, buyOrderNo, purOrderNo, purBillId
, purBillDate, distrBillId, distrOrderNo, checkBillId, checkOrderNo, , purBillDate, distrBillId, distrOrderNo, checkBillId, checkOrderNo,
psiInBillId, psiInOrderNo, create_user psiInBillId, psiInOrderNo, psiOutBillId, psiOutOrderNo, create_user
, create_time, last_modified, last_modified_user) , create_time, last_modified, last_modified_user)
# 对比预期值和实际值是否一致 # 对比预期值和实际值是否一致
actual_value1 = get_process_list2(actual) actual_value1 = get_process_list2(actual)
...@@ -1821,6 +1827,7 @@ def check_mcms_psi(type=1): ...@@ -1821,6 +1827,7 @@ def check_mcms_psi(type=1):
print('error') print('error')
commonFuc().check_text_exist_result_text('error', 'succees') commonFuc().check_text_exist_result_text('error', 'succees')
try: try:
pro_path = commonFuc().get_pro_path2() pro_path = commonFuc().get_pro_path2()
print('pro_path', pro_path) print('pro_path', pro_path)
...@@ -1900,7 +1907,7 @@ try: ...@@ -1900,7 +1907,7 @@ try:
# # 上面暂时注释======================================== # # 上面暂时注释========================================
# check_mcms_check(1) # 调用函数检查验收单数据库写值 # check_mcms_check(1) # 调用函数检查验收单数据库写值
check_mcms_psi(1) # 调用函数检查中心库入库单数据库写值 check_mcms_psi(1) # 调用函数检查中心库入库单和出库单数据库写值
check_accept_order(2) # 高值 check_accept_order(2) # 高值
time.sleep(6) time.sleep(6)
# 这里验收后会自动生成出入库单，批次信息，需要同步验证入库单和批次信息 # 这里验收后会自动生成出入库单，批次信息，需要同步验证入库单和批次信息
...@@ -1911,9 +1918,6 @@ try: ...@@ -1911,9 +1918,6 @@ try:
check_mcms_check(3) # 调用函数检查验收单数据库写值 check_mcms_check(3) # 调用函数检查验收单数据库写值
check_mcms_psi(3) # 调用函数检查中心库入库单数据库写值 check_mcms_psi(3) # 调用函数检查中心库入库单数据库写值
# second_dept_one_key_in() # second_dept_one_key_in()
# second_dept_one_key_in() # second_dept_one_key_in()
# second_dept_one_key_in() # second_dept_one_key_in()
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment