流程十五脚本提交

air_case/b6_spd3_core_business_flow_database_check/a_b9流程十六退库业务_二级库向一级库退库_数据库验证.air/a_b9流程十六退库业务_二级库向一级库退库_数据库验证.py

@@ -7,7 +7,8 @@ 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_dept_buy_sql, get_PICK_id, get_buyBillId, get_PICK_order_no, \
     get_buyOrderNo, get_login_user_uxid_bydb, get_create_time, get_pick_detail_id, get_mdm_goods_code1, get_goods_code1, \
-    get_pkg_def_id, check_batch_id, check_barcode_id
+    get_pkg_def_id, check_batch_id, check_barcode_id, check_mcms_pur_plan_sql, get_distrBillId, get_planBillId, \
+    get_planOrderNo, get_purOrderNo, get_purBillId, get_purBillDate2, get_distrOrderNo, get_DRID
 
 from common.fileUtls import FileUtils
 from common.run_cmd_script import execute_command
@@ -205,6 +206,221 @@ def check_mcms_psi_dept_batch(DR_ID,type,order_no):
         commonFuc().check_text_exist_result_text('error', 'succees')
 
 
+def check_mcms_psi_in(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 target_branch_id='%s' and bill_mode='%s' and stock_kind='RK_TK' 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 target_branch_id='%s' and bill_mode='%s' and stock_kind='RK_TK' order by   CREATE_TIME desc LIMIT 1;" % (
+        branch_id, bill_mode)
+    id = get_id(sql)
+    sql = "select order_no from  mcms_psi  where target_branch_id='%s' and bill_mode='%s' and stock_kind='RK_TK' order by   CREATE_TIME desc LIMIT 1;" % (
+        branch_id, bill_mode)
+    order_no = get_id(sql)
+    target_corp_id = get_hosid()
+    target_branch_id = get_branch_id()
+    target_dept_id = FileUtils().r_info8("b2_herp3_bs", "所有科室id", 'message6')['deptid1']
+    target_dept_name = FileUtils().r_info8("b2_herp3_bs", "所有科室name", 'message6')['deptid1']
+    stock_name = get_branch_name() + "中心库房"
+    target_stock_id = get_stockId_fromdb(stock_name)
+    target_area_code = get_stockAreaId_new_fromDb(target_dept_name, 1)
+    source_id = get_DRID(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"]
+    planBillId = get_planBillId(hos_goods_id)
+    planOrderNo = get_planOrderNo(hos_goods_id)
+    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_in(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, buyBillId, planBillId,
+                                                 planOrderNo, buyOrderNo, purOrderNo, purBillId
+                                                 , purBillDate, distrBillId, distrOrderNo, checkBillId, checkOrderNo,
+                                                 psiInBillId, psiInOrderNo, create_user
+                                                 , create_time, last_modified, last_modified_user)
+    elif type == 2:
+        check_mcms_psi_batch_in(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, buyBillId, planBillId,
+                                                 planOrderNo, buyOrderNo, purOrderNo, purBillId
+                                                 , purBillDate, distrBillId, distrOrderNo, checkBillId, checkOrderNo,
+                                                 psiInBillId, psiInOrderNo, create_user
+                                                 , create_time, last_modified, last_modified_user)
+    else:
+        check_mcms_psi_batch_in(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, buyBillId, planBillId,
+                                                 planOrderNo, buyOrderNo, purOrderNo, purBillId
+                                                 , purBillDate, distrBillId, distrOrderNo, checkBillId, checkOrderNo,
+                                                 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_in(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 = get_id(
+        "select id from mcms_hos_batch where hos_goods_id='%s' order by create_time desc LIMIT 1;" % hos_goods_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 = create_user
+    if type == 1:
+        expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
+                                                 'mcms_psi_batch_in1', 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
+
+                                                 )
+    elif type == 2:
+        expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
+                                                 'mcms_psi_batch_in2', 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
+
+                                                 )
+    else:
+        expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
+                                                 'mcms_psi_batch_in3', 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
+
+                                                 )
+
+    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')
+
+
+
 
 pro_path = commonFuc().get_pro_path2()
 print('pro_path', pro_path)
@@ -216,9 +432,12 @@ from a_b9流程十六退库业务_二级库向一级库退库 import second_dept
 try:
     # updateUserLoginDefaultRange(get_listUserMgrRangePage1(2))#设置登录账号默认权限是二级库
     # second_dept_return_Out_Stock(2)#高值耗材退货出库
-    check_mcms_psi_dept_out(20)#检查出库单数据库数据
-    approval_center()#审批
-    putaway()#中心库上架
+    # time.sleep(6)
+    # check_mcms_psi_dept_out(20)#检查出库单数据库数据
+    # approval_center()#审批
+    # putaway()#中心库上架
+    # time.sleep(6)
+    check_mcms_psi_in(2)#检查中心单入库单数据库数据
     updateUserLoginDefaultRange(get_listUserMgrRangePage1(2))#设置登录账号默认权限是二级库
     second_dept_return_Out_Stock(1)#低值耗材退货出库
     approval_center()  # 审批

common/db/sql/sql_tools.py

@@ -531,6 +531,11 @@ def get_distrBillId(branch_id, bill_mode):
             branch_id, bill_mode))
     return distr_main_key
 
+def get_DRID(branch_id, bill_mode):
+    DRID = 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))
+    return DRID
 
 def get_distr_detail_id(branch_id, bill_mode):
     distr_main_key = get_distrBillId(branch_id, bill_mode)

data/b6_spd3_core_business_flow_database_check/data

@@ -204,3 +204,8 @@
 "mcms_psi_dept_tkck1_1": '{"id":"%s","order_no":"%s","bill_mode":"16","rec_type":"YND","psi_flag":-1,"psi_kind":"203","stock_kind":"CK_TK","target_corp_id":"%s","target_branch_id":"%s","target_dept_id":"%s","target_dept_name":"%s","target_stock_id":"%s","target_area_code":%s,"target_area_name":null,"source_id":"%s","source_no":null,"source_repl_id":null,"source_corp_id":"%s","source_branch_id":"%s","source_dept_id":"%s","source_dept_name":"%s","source_stock_id":"%s","source_area_code":"%s","source_area_name":"默认库区","consume_type":0,"patient_id":null,"patient_name":null,"machine_id":null,"machine_name":null,"his_charge_no":null,"remark":"","tb_status":10,"accounter":%s,"account_date":%s,"bill_relation_json":"{"pickOrderNo":"%s","pickBillId":"%s","psiDeptOutBillId":"%s","psiDeptOutOrderNo":"%s"}","create_user":"%s","create_time":%s,"last_modified":%s,"last_modified_user":"%s","version":0,"last_auditor":null,"last_audit_time":null,"reject_reason":null,"reject_user":null,"reject_time":null,"initial_order":null,"source_type":"SG","target_coding_type":null}'
 "mcms_psi_dept_tkck1_2": '{"id":"%s","order_no":"%s","bill_mode":"20","rec_type":"YND","psi_flag":-1,"psi_kind":"203","stock_kind":"CK_TK","target_corp_id":"%s","target_branch_id":"%s","target_dept_id":"%s","target_dept_name":"%s","target_stock_id":"%s","target_area_code":%s,"target_area_name":null,"source_id":"%s","source_no":null,"source_repl_id":null,"source_corp_id":"%s","source_branch_id":"%s","source_dept_id":"%s","source_dept_name":"%s","source_stock_id":"%s","source_area_code":"%s","source_area_name":"默认库区","consume_type":0,"patient_id":null,"patient_name":null,"machine_id":null,"machine_name":null,"his_charge_no":null,"remark":"","tb_status":10,"accounter":%s,"account_date":%s,"bill_relation_json":"{"pickOrderNo":"%s","pickBillId":"%s","psiDeptOutBillId":"%s","psiDeptOutOrderNo":"%s"}","create_user":"%s","create_time":%s,"last_modified":%s,"last_modified_user":"%s","version":0,"last_auditor":null,"last_audit_time":null,"reject_reason":null,"reject_user":null,"reject_time":null,"initial_order":null,"source_type":"SG","target_coding_type":null}'
 "mcms_psi_dept_tkck1_3": '{"id":"%s","order_no":"%s","bill_mode":"66","rec_type":"YND","psi_flag":-1,"psi_kind":"203","stock_kind":"CK_TK","target_corp_id":"%s","target_branch_id":"%s","target_dept_id":"%s","target_dept_name":"%s","target_stock_id":"%s","target_area_code":%s,"target_area_name":null,"source_id":"%s","source_no":null,"source_repl_id":null,"source_corp_id":"%s","source_branch_id":"%s","source_dept_id":"%s","source_dept_name":"%s","source_stock_id":"%s","source_area_code":"%s","source_area_name":"默认库区","consume_type":0,"patient_id":null,"patient_name":null,"machine_id":null,"machine_name":null,"his_charge_no":null,"remark":"","tb_status":10,"accounter":%s,"account_date":%s,"bill_relation_json":"{"pickOrderNo":"%s","pickBillId":"%s","psiDeptOutBillId":"%s","psiDeptOutOrderNo":"%s"}","create_user":"%s","create_time":%s,"last_modified":%s,"last_modified_user":"%s","version":0,"last_auditor":null,"last_audit_time":null,"reject_reason":null,"reject_user":null,"reject_time":null,"initial_order":null,"source_type":"SG","target_coding_type":null}'
+
+#二级库退货中心库入库单
+"check_mcms_psi1_1": '{"id": "%s", "order_no": "%s", "bill_mode": "16", "rec_type": "YND", "psi_flag": 1, "psi_kind": "101", "stock_kind": "RK_YS", "target_corp_id": "%s", "target_branch_id": "%s", "target_dept_id": "%s", "target_dept_name": "%s", "target_stock_id": "%s", "target_area_code": "%s", "target_area_name": "默认库区", "source_id": "%s", "source_no": "%s", "source_repl_id": "%s", "source_corp_id": "%s", "source_branch_id": "%s", "source_dept_id": "%s", "source_dept_name": "%s", "source_stock_id": "%s", "source_area_code": "%s", "source_area_name": None, "remark": None, "tb_status": 30, "accounter": "%s", "account_date": %s, "bill_relation_json": "{"buyBillId":"%s","planBillId":"%s","planOrderNo":"%s","buyOrderNo":"%s","purOrderNo":"%s","purBillId":"%s","purBillDate":"%s","distrBillId":"%s","distrOrderNo":"%s","checkBillId":"%s","checkOrderNo":"%s","psiInBillId":"%s","psiInOrderNo":"%s"}", "reject_time": None, "reject_remark": None, "create_user": "%s","create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 1, "last_auditor": None, "last_audit_time": None, "reject_user": None, "initial_order": None, "source_type": "BD", "reject_reason": None, "receipt_status": 0}'
+"check_mcms_psi1_2": '{"id": "%s", "order_no": "%s", "bill_mode": "20", "rec_type": "YND", "psi_flag": 1, "psi_kind": "101", "stock_kind": "RK_YS", "target_corp_id": "%s", "target_branch_id": "%s", "target_dept_id": "%s", "target_dept_name": "%s", "target_stock_id": "%s", "target_area_code": "%s", "target_area_name": "默认库区", "source_id": "%s", "source_no": "%s", "source_repl_id": "%s", "source_corp_id": "%s", "source_branch_id": "%s", "source_dept_id": "%s", "source_dept_name": "%s", "source_stock_id": "%s", "source_area_code": "%s", "source_area_name": None, "remark": None, "tb_status": 30, "accounter": "%s", "account_date": %s, "bill_relation_json": "{"buyBillId":"%s","planBillId":"%s","planOrderNo":"%s","buyOrderNo":"%s","purOrderNo":"%s","purBillId":"%s","purBillDate":"%s","distrBillId":"%s","distrOrderNo":"%s","checkBillId":"%s","checkOrderNo":"%s","psiInBillId":"%s","psiInOrderNo":"%s"}", "reject_time": None, "reject_remark": None, "create_user": "%s","create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 1, "last_auditor": None, "last_audit_time": None, "reject_user": None, "initial_order": None, "source_type": "BD", "reject_reason": None, "receipt_status": 0}'
+"check_mcms_psi1_3": '{"id": "%s", "order_no": "%s", "bill_mode": "66", "rec_type": "YND", "psi_flag": 1, "psi_kind": "101", "stock_kind": "RK_YS", "target_corp_id": "%s", "target_branch_id": "%s", "target_dept_id": "%s", "target_dept_name": "%s", "target_stock_id": "%s", "target_area_code": "%s", "target_area_name": "默认库区", "source_id": "%s", "source_no": "%s", "source_repl_id": "%s", "source_corp_id": "%s", "source_branch_id": "%s", "source_dept_id": "%s", "source_dept_name": "%s", "source_stock_id": "%s", "source_area_code": "%s", "source_area_name": None, "remark": None, "tb_status": 30, "accounter": "%s", "account_date": %s, "bill_relation_json": "{"buyBillId":"%s","planBillId":"%s","planOrderNo":"%s","buyOrderNo":"%s","purOrderNo":"%s","purBillId":"%s","purBillDate":"%s","distrBillId":"%s","distrOrderNo":"%s","checkBillId":"%s","checkOrderNo":"%s","psiInBillId":"%s","psiInOrderNo":"%s"}", "reject_time": None, "reject_remark": None, "create_user": "%s","create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 1, "last_auditor": None, "last_audit_time": None, "reject_user": None, "initial_order": None, "source_type": "BD", "reject_reason": None, "receipt_status": 0}'
\ No newline at end of file