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

air_case/b6_spd3_core_business_flow_database_check/a_b4流程十一请领业务流_二级库向直送_数据库验证.air/a_b4流程十一请领业务流_二级库向直送_数据库验证.py

@@ -2059,6 +2059,12 @@ def check_mcms_psi_dept_batch_in(DR_ID,type,order_no,source_id1):
         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)
@@ -2081,7 +2087,8 @@ def check_mcms_psi_batch_in(DR_ID,type,order_no,source_id1):
     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)
-    target_batch_id=source_batch_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')
@@ -2101,7 +2108,7 @@ def check_mcms_psi_batch_in(DR_ID,type,order_no,source_id1):
     last_modified_user = create_user
     if type == 16:
         expected = commonFuc().get_business_data('b6_spd3_core_business_flow_database_check',
-                                                 'mcms_psi_dept_batch_in4', batch_main_key, pid, order_no,source_detail_id
+                                                 'mcms_psi_batch_in4', batch_main_key, pid, order_no,source_detail_id
                                             ,pick_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
 
@@ -2157,69 +2164,70 @@ try:
     from a_b4流程十一请领业务流_二级库向直送 import check_accept_order
 
     for i in range(1):
-        updateUserLoginDefaultRange(get_listUserMgrRangePage(2))  # 设置登录账号默认权限是二级库
-        goods_move2()  # 设置产品出库渠道为直送
-        # # 低值
-        second_dept_Request(FileUtils().r_info8("b5_spd3_core_business_flow", "产品审核信息", 'message2')['hosGoodsId'], 1)
-        check_mcms_dept_buy_car(1)
-        # # 高值
-        second_dept_Request(FileUtils().r_info8("b5_spd3_core_business_flow", "产品审核信息", 'message1')['hosGoodsId'], 2)
-        check_mcms_dept_buy_car(2)
-        # # 试剂
-        second_dept_Request(FileUtils().r_info8("b5_spd3_core_business_flow", "产品审核信息", 'message3')['hosGoodsId'], 3)
-        check_mcms_dept_buy_car(3)
-        BuyCarSubmit()  # 请领车提交
-
-        list_data = ['16', '20', '66']
-        for i in list_data:
-            check_mcms_dept_buy(int(i))
-            mcms_dept_buy_detail(int(i))
-        for i in range(6):  # 三个单据共审批6次
-            approval_center()
-        list_data = ['16', '20', '66']
-        for i in list_data:
-            check_mcms_dept_buy_approval_after(int(i))
-            mcms_dept_buy_detail_approval_after(int(i))
-
-        time.sleep(20)
-        # 检查自动生成的采购计划数据
-        list_data = ['16', '20', '66']
-        for i in list_data:
-            check_mcms_mcms_pur_plan(int(i))
-        # 采购模块处理
-        purchase_module_process()
-
-        # 三个单据共审批三次
-        approval_center(FileUtils().r_info8('b5_spd3_core_business_flow', '采购计划单号试剂', 'message12'))
-        approval_center(FileUtils().r_info8('b5_spd3_core_business_flow', '采购计划单号', 'message7'))
-        approval_center(FileUtils().r_info8('b5_spd3_core_business_flow', '采购计划单号高值', 'message11'))
-        time.sleep(20)
-        list_data = ['16', '20', '66']
-        for i in list_data:
-            check_mcms_purchase(int(i))
-
-        # 检查同步到外网的采购订单数据跟内网的是否一致
-        check_mcms_purchase_out_and_in(1)
-        print('检查同步到外网的采购订单数据跟内网的是否一致')
-        check_mcms_purchase_out_and_in(2)
-        order_dp(1)  # 1低值
-        time.sleep(6)
-        order_dp(2)  # 2高值
-        time.sleep(6)
-        order_dp(3)  # 3试剂
-        time.sleep(6)
-        time.sleep(20)
-
-        list_data = ['16', '20', '66']
-        for i in list_data:
-            time.sleep(6)
-            check_hdi_distr(int(i))
-
-        time.sleep(20)
-        #到这里就是验收和中心库自动入库以及中心库出库
-        check_accept_order(1)  # 低值 验收和自动入库和出库
-        time.sleep(6)
-        check_mcms_check(1)  # 调用函数检查验收单数据库写值
+        # updateUserLoginDefaultRange(get_listUserMgrRangePage(2))  # 设置登录账号默认权限是二级库
+        # goods_move2()  # 设置产品出库渠道为直送
+        # # # 低值
+        # second_dept_Request(FileUtils().r_info8("b5_spd3_core_business_flow", "产品审核信息", 'message2')['hosGoodsId'], 1)
+        # check_mcms_dept_buy_car(1)
+        # # # 高值
+        # second_dept_Request(FileUtils().r_info8("b5_spd3_core_business_flow", "产品审核信息", 'message1')['hosGoodsId'], 2)
+        # check_mcms_dept_buy_car(2)
+        # # # 试剂
+        # second_dept_Request(FileUtils().r_info8("b5_spd3_core_business_flow", "产品审核信息", 'message3')['hosGoodsId'], 3)
+        # check_mcms_dept_buy_car(3)
+        # BuyCarSubmit()  # 请领车提交
+        #
+        # list_data = ['16', '20', '66']
+        # for i in list_data:
+        #     check_mcms_dept_buy(int(i))
+        #     mcms_dept_buy_detail(int(i))
+        # for i in range(6):  # 三个单据共审批6次
+        #     approval_center()
+        # list_data = ['16', '20', '66']
+        # for i in list_data:
+        #     check_mcms_dept_buy_approval_after(int(i))
+        #     mcms_dept_buy_detail_approval_after(int(i))
+        #
+        # time.sleep(20)
+        # # 检查自动生成的采购计划数据
+        # list_data = ['16', '20', '66']
+        # for i in list_data:
+        #     check_mcms_mcms_pur_plan(int(i))
+        # # 采购模块处理
+        # purchase_module_process()
+        #
+        # # 三个单据共审批三次
+        # approval_center(FileUtils().r_info8('b5_spd3_core_business_flow', '采购计划单号试剂', 'message12'))
+        # approval_center(FileUtils().r_info8('b5_spd3_core_business_flow', '采购计划单号', 'message7'))
+        # approval_center(FileUtils().r_info8('b5_spd3_core_business_flow', '采购计划单号高值', 'message11'))
+        # time.sleep(20)
+        # list_data = ['16', '20', '66']
+        # for i in list_data:
+        #     check_mcms_purchase(int(i))
+        #
+        # # 检查同步到外网的采购订单数据跟内网的是否一致
+        # check_mcms_purchase_out_and_in(1)
+        # print('检查同步到外网的采购订单数据跟内网的是否一致')
+        # check_mcms_purchase_out_and_in(2)
+        # order_dp(1)  # 1低值
+        # time.sleep(6)
+        # order_dp(2)  # 2高值
+        # time.sleep(6)
+        # order_dp(3)  # 3试剂
+        # time.sleep(6)
+        # time.sleep(20)
+        #
+        # list_data = ['16', '20', '66']
+        # for i in list_data:
+        #     time.sleep(6)
+        #     check_hdi_distr(int(i))
+        #
+        # time.sleep(20)
+        # #到这里就是验收和中心库自动入库以及中心库出库
+        # check_accept_order(1)  # 低值 验收和自动入库和出库
+        # time.sleep(6)
+        # check_mcms_check(1)  # 调用函数检查验收单数据库写值
+        # # 上面暂时注释========================================
         check_mcms_psi(1)  # 调用函数检查中心库入库单和出库单数据库写值
         check_accept_order(2)  # 高值 验收和自动入库和出库
         time.sleep(6)
@@ -2235,7 +2243,7 @@ try:
         second_dept_one_key_in()
         second_dept_one_key_in()
         second_dept_one_key_in()
-        # # 上面暂时注释========================================
+
         # 检查二级库入库单
         check_mcms_psi_dept_in(16)
         check_mcms_psi_dept_in(20)

data/b5_spd3_core_business_flow/message15

 验收单号:
-  CHECK_NO1: CHECKh03472024072600072
-  CHECK_NO2: CHECKh03472024072600072
+  CHECK_NO1: CHECKh03472024072600075
+  CHECK_NO2: CHECKh03472024072600075

data/b6_spd3_core_business_flow_database_check/data

@@ -114,6 +114,12 @@
 "check_mcms_psi2": '{"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": None, "source_dept_id": "%s", "source_dept_name": "%s", "source_stock_id": "%s", "source_area_code": None, "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_psi3": '{"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": None, "source_dept_id": "%s", "source_dept_name": "%s", "source_stock_id": "%s", "source_area_code": None, "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}'
 
+
+#中心库入库单子表
+"mcms_psi_batch_in1": '{"id":"%s","pid":"%s","order_no":"%s","source_detail_id":"%s","pick_detail_id":null,"pur_mode":10,"hos_goods_id":"%s","mdm_goods_code":"%s","goods_code":"%s","source_batch_id":"%s","target_batch_id":"%s","psi_price":Decimal("99.999900"),"qty":Decimal("100.00"),"unit_name":"100支/100","barcode_id":"%s","sub_barcode_id":null,"shelf_code":"%s-A-01-01","settle_flag":1,"tb_status":0,"pur_task_id":null,"create_user":"%s","create_time":%s,"last_modified":%s,"last_modified_user":"%s","version":1}'
+"mcms_psi_batch_in2": '{"id":"%s","pid":"%s","order_no":"%s","source_detail_id":"%s","pick_detail_id":null,"pur_mode":20,"hos_goods_id":"%s","mdm_goods_code":"%s","goods_code":"%s","source_batch_id":"%s","target_batch_id":"%s","psi_price":Decimal("99.999900"),"qty":Decimal("100.00"),"unit_name":"100支/100","barcode_id":"%s","sub_barcode_id":null,"shelf_code":"%s-A-01-01","settle_flag":1,"tb_status":0,"pur_task_id":null,"create_user":"%s","create_time":%s,"last_modified":%s,"last_modified_user":"%s","version":1}'
+"mcms_psi_batch_in3": '{"id":"%s","pid":"%s","order_no":"%s","source_detail_id":"%s","pick_detail_id":null,"pur_mode":60,"hos_goods_id":"%s","mdm_goods_code":"%s","goods_code":"%s","source_batch_id":"%s","target_batch_id":"%s","psi_price":Decimal("99.999900"),"qty":Decimal("100.00"),"unit_name":"100支/100","barcode_id":"%s","sub_barcode_id":null,"shelf_code":"%s-A-01-01","settle_flag":1,"tb_status":0,"pur_task_id":null,"create_user":"%s","create_time":%s,"last_modified":%s,"last_modified_user":"%s","version":1}'
+
 #中心库出库单
 "check_mcms_psi_out1": '{"id": "%s", "order_no": "%s", "bill_mode": "16", "rec_type": "YND", "psi_flag": -1, "psi_kind": "202", "stock_kind": "CK_QL", "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": "默认库区", "remark": None, "tb_status": 20, "accounter": None, "account_date": None, "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","psiOutBillId":"%s","psiOutOrderNo":"%s"}", "reject_time": None, "reject_remark": None, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "last_auditor": None, "last_audit_time": None, "reject_user": None, "initial_order": None, "source_type": "BD", "reject_reason": None, "receipt_status": 0}'
 "check_mcms_psi_out2": '{"id": "%s", "order_no": "%s", "bill_mode": "20", "rec_type": "YND", "psi_flag": -1, "psi_kind": "202", "stock_kind": "CK_QL", "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": "默认库区", "remark": None, "tb_status": 20, "accounter": None, "account_date": None, "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","psiOutBillId":"%s","psiOutOrderNo":"%s"}", "reject_time": None, "reject_remark": None, "create_user": "%s", "create_time": %s, "last_modified": %s, "last_modified_user": "%s", "version": 0, "last_auditor": None, "last_audit_time": None, "reject_user": None, "initial_order": None, "source_type": "BD", "reject_reason": None, "receipt_status": 0}'