Skip to content
GitLab
Commit 17cbb13f authored by xiao-hesheng's avatar xiao-hesheng
Browse files

流程五脚本编写

parent 62665759
Hide whitespace changes
Inline Side-by-side
air_case/b5_spd3_core_business_flow/a_a8流程五_中心库入库结算_正结算3_外网开票.air/a_a8流程五_中心库入库结算_正结算3_外网开票.py
View file @ 17cbb13f
......@@ -38,7 +38,7 @@ def invoice():
module = "a6_mdm3_si"
# 发票录入列表查询=================================================
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "listGoodsPage_url")
print('发票录入列表查询url',url)
print('发票录入列表查询url', url)
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
......@@ -48,7 +48,7 @@ def invoice():
# print('request_body',request_body)
# 发送请求
i=1
i = 1
while True:
time.sleep(6)
result = commonFuc().http_post(url, request_body, headers)
......@@ -56,9 +56,9 @@ def invoice():
try:
data = commonFuc().analysis_json('data', result)
total = commonFuc().analysis_json('total', data)
if total==0:
if total == 0:
print('数据暂时未同步过来，或者内网没有生成结算单')
i=i+1
i = i + 1
if i >= 100:
print('600秒过去了，数据还未查询出来，调用一下内网结算函数')
settle()
......@@ -91,17 +91,28 @@ def invoice():
info = FileUtils().r_info8(module, "结算开票信息", 'message')
# print('info', info)
list_a = info['list_a']
print('list_a', list_a,type(list_a),len(list_a))
pid='pid'
print('list_a', list_a, type(list_a), len(list_a))
pid = 'pid'
settleMonth = "settleMonth"
hosGoodsId = 'hosGoodsId'
batchCode = 'batchCode'
distrDetailId = 'distrDetailId'
distrId='distrId'
distrOrderNo='distrOrderNo';settlePrice='settlePrice';maxSettleQty='maxSettleQty'
maxSettleAmount='maxSettleAmount';curSettleQty='curSettleQty';curSettleAmount='curSettleAmount'
leftSettleQty='leftSettleQty';leftSettleAmount='leftSettleAmount';hosId='hosId';provId='provId'
branchId='branchId'; balanceDetId='balanceDetId'; purMode='purMode';barCode='barCode';viewId='viewId'
distrId = 'distrId'
distrOrderNo = 'distrOrderNo';
settlePrice = 'settlePrice';
maxSettleQty = 'maxSettleQty'
maxSettleAmount = 'maxSettleAmount';
curSettleQty = 'curSettleQty';
curSettleAmount = 'curSettleAmount'
leftSettleQty = 'leftSettleQty';
leftSettleAmount = 'leftSettleAmount';
hosId = 'hosId';
provId = 'provId'
branchId = 'branchId';
balanceDetId = 'balanceDetId';
purMode = 'purMode';
barCode = 'barCode';
viewId = 'viewId'
for i in list_a:
pid = i['pid']
settleMonth = i['settleMonth']
......@@ -109,7 +120,7 @@ def invoice():
detailList = i['detailList']
for j in detailList:
batchCode = j['batchCode']
distrDetailId=j['distrDetailId']
distrDetailId = j['distrDetailId']
distrId = j['distrId']
distrOrderNo = j['distrOrderNo']
settlePrice = j['settlePrice']
......@@ -125,25 +136,26 @@ def invoice():
balanceDetId = j['balanceDetId']
purMode = j['purMode']
barCode = j['barCode']
viewId=j['viewId']
viewId = j['viewId']
break
list2=[]
detailList=None
list2 = []
detailList = None
for i in list_a:
detailList = i['detailList']
list2=detailList
list2 = detailList
for k in list2:
maxSettleQty = k['leftSettleQty']
maxSettleAmount= k['settlePrice']
curSettleQty= k['curSettleQty']
curSettleAmount=k['curSettleAmount']
leftSettleQty=k['leftSettleQty']
maxSettleAmount = k['settlePrice']
curSettleQty = k['curSettleQty']
curSettleAmount = k['curSettleAmount']
leftSettleQty = k['leftSettleQty']
request_body = commonFuc().get_business_data(module, "payload3_1_1_1", pid, settleMonth, hosGoodsId, batchCode,
distrDetailId, distrId, distrOrderNo, settlePrice, maxSettleQty,
maxSettleAmount, curSettleQty, curSettleAmount, leftSettleQty,leftSettleAmount, hosId,
maxSettleAmount, curSettleQty, curSettleAmount, leftSettleQty,
leftSettleAmount, hosId,
provId,
branchId, balanceDetId,purMode, barCode,viewId)
branchId, balanceDetId, purMode, barCode, viewId)
print('request_body', request_body)
# request_body = "[" + str(request_body) + "]"
# print('request_body', request_body)
......@@ -153,24 +165,25 @@ def invoice():
# new_request_body2=new_request_body1.replace("None", 'null')
# print(new_request_body2)
# request_body_json = json.loads(new_request_body2,encoding='utf-8')
request_body_json=get_process_list(request_body)
request_body_json = get_process_list(request_body)
result = commonFuc().http_post(url, request_body_json, headers)
print('result',result)
print('result', result)
# ===========发票暂存===============================================
#==============发票提交===========================================
# ==============发票提交===========================================
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "submitCache_url")
hosVersion=3
hosName=commonFuc().get_business_data(module,'hosName')
invoiceQty=leftSettleQty
invoiceAmount=leftSettleAmount
invoiceDate=timeUtils().get_time_hms(5)
request_body = commonFuc().get_business_data(module, "payload3_2_2_2",hosName,invoiceQty,invoiceAmount,invoiceDate,hosId,hosVersion)
print('request_body',request_body)
hosVersion = 3
hosName = commonFuc().get_business_data(module, 'hosName')
invoiceQty = leftSettleQty
invoiceAmount = leftSettleAmount
invoiceDate = timeUtils().get_time_hms(5)
request_body = commonFuc().get_business_data(module, "payload3_2_2_2", hosName, invoiceQty, invoiceAmount,
invoiceDate, hosId, hosVersion)
print('request_body', request_body)
# 发送请求
result = commonFuc().http_post(url, request_body, headers)
print('result', result)
#==============发票提交===========================================
#===============发票确认列表查询
# ==============发票提交===========================================
# ===============发票确认列表查询
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "listVoPage_url1")
request_body = commonFuc().get_business_data(module, "payload3_3")
......@@ -178,12 +191,12 @@ def invoice():
# 发送请求
result = commonFuc().http_post(url, request_body, headers)
print('result', result)
data=commonFuc().analysis_json('data', result)
data1=commonFuc().analysis_json('data', data)
data = commonFuc().analysis_json('data', result)
data1 = commonFuc().analysis_json('data', data)
id1 = commonFuc().analysis_json('id', data1[0])
print(id1)
#===============发票确认列表查询
#===============发票确认
# ===============发票确认列表查询
# ===============发票确认
url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "invoiceUpdateStatus_url")
request_body = commonFuc().get_business_data(module, "payload3_4", id1)
......@@ -191,8 +204,8 @@ def invoice():
# 发送请求
result = commonFuc().http_post(url, request_body, headers)
print('result', result)
#===============发票确认
#==============内网发票核对============
# ===============发票确认
# ==============内网发票核对============
module = "b5_spd3_core_business_flow"
# # 登录获取用户id等信息，使用创建的用户登录===========开始
info = FileUtils().r_info8('b2_herp3_bs', "用户名信息", 'message3')
......@@ -200,16 +213,17 @@ def invoice():
password = commonFuc().get_business_data("b2_herp3_bs", "password")
print('username,password', username, password)
# # 获取token和projectCode
token, projectCode, uxid, corpId, info = login(username, password,2)
token, projectCode, uxid, corpId, info = login(username, password, 2)
# 登录获取用户id等信息，使用创建的用户登录============结束
url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "mcmsInvoice_listVoPage_url")
print('url',url)
print('url', url)
# 获取请求头信息
headers = commonFuc().get_business_data(module, "json_headers2",
commonFuc().get_business_data(module, "json_contentType"), token,
projectCode)
request_body = commonFuc().get_business_data(module, "payload9", timeUtils.get_time_hms(5),timeUtils.get_time_hms(5),get_hosid(),get_hosid())
print('request_body',request_body)
request_body = commonFuc().get_business_data(module, "payload9", timeUtils.get_time_hms(5),
timeUtils.get_time_hms(5), get_hosid(), get_hosid())
print('request_body', request_body)
# 发送请求
i = 1
while True:
......@@ -230,37 +244,39 @@ def invoice():
except:
continue
print('result','内网发票核对', result)
data1=commonFuc().analysis_json('data',commonFuc().analysis_json('data',result))
VI_id=commonFuc().analysis_json('id',data1[0])
print('VI_id',VI_id)
#==============发票列表查询
#==============发票核对提交
url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "mcmsInvoice_invoiceUpdateStatusList_url")
print('result', '内网发票核对', result)
data1 = commonFuc().analysis_json('data', commonFuc().analysis_json('data', result))
VI_id = commonFuc().analysis_json('id', data1[0])
print('VI_id', VI_id)
# ==============发票列表查询
# ==============发票核对提交
url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
"mcmsInvoice_invoiceUpdateStatusList_url")
print('url', url)
request_body = commonFuc().get_business_data(module, "payload10",VI_id,get_hosid())
request_body = commonFuc().get_business_data(module, "payload10", VI_id, get_hosid())
print('request_body', request_body)
result = commonFuc().http_post(url, request_body, headers)
print('result',result)
print('result', result)
# ==============发票核对提交
#==============内网发票核对============
#==============内网发票提交开始
#列表查询
# ==============内网发票核对============
# ==============内网发票提交开始
# 列表查询
url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
"mcmsInvoice_listVoPage_url")
print('url', url)
request_body = commonFuc().get_business_data(module, "payload11",timeUtils.get_time_hms(5),timeUtils.get_time_hms(5),get_hosid(),get_hosid())
request_body = commonFuc().get_business_data(module, "payload11", timeUtils.get_time_hms(5),
timeUtils.get_time_hms(5), get_hosid(), get_hosid())
print('request_body', request_body)
result = commonFuc().http_post(url, request_body, headers)
print('result','内网发票提交列表查询结果', result)
print('result', '内网发票提交列表查询结果', result)
data1 = commonFuc().analysis_json('data', commonFuc().analysis_json('data', result))
total=commonFuc().analysis_json('total', commonFuc().analysis_json('data', result))
if total==0:
total = commonFuc().analysis_json('total', commonFuc().analysis_json('data', result))
if total == 0:
print('检查被测程序，发票提交列表查询数据是否正确')
else:
for i in range(total):
VI_id2 = commonFuc().analysis_json('id', data1[i])
if VI_id2==VI_id:
if VI_id2 == VI_id:
break
print('VI_id2', VI_id2)
# ==============发票提交,下一步归档
......@@ -270,9 +286,9 @@ def invoice():
request_body = commonFuc().get_business_data(module, "payload12", VI_id, get_hosid())
print('request_body', request_body)
result = commonFuc().http_post(url, request_body, headers)
print('result','发票提交,下一步归档', result)
print('result', '发票提交,下一步归档', result)
# ==============发票提交，下一步归档
#==============发票归档列表查询
# ==============发票归档列表查询
url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
"mcmsInvoice_listVoPage_url")
print('url', url)
......@@ -292,7 +308,7 @@ def invoice():
break
print('VI_id3', VI_id3)
# ==============发票归档列表查询
#==================发票归档提交
# ==================发票归档提交
url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
"mcmsInvoice_invoiceUpdateStatusList_url")
print('url', url)
......@@ -300,8 +316,8 @@ def invoice():
print('request_body', request_body)
result = commonFuc().http_post(url, request_body, headers)
print('result', '发票归档提交,下一步付款', result)
#==================发票归档提交
#==================付款单列表查询
# ==================发票归档提交
# ==================付款单列表查询
url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
"mcmsInvoice_listVoPage_url")
print('url', url)
......@@ -319,7 +335,7 @@ def invoice():
if VI_id4 == VI_id3:
break
print('VI_id4', VI_id4)
#==================付款单列表查询
# ==================付款单列表查询
# ==================付款提交
url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module,
"mcmsInvoice_genPaymentBills_url")
......@@ -331,16 +347,15 @@ def invoice():
# 断言
code = commonFuc().analysis_json('code', result)
data = commonFuc().analysis_json('data', result)
if code == 0 and data== 1:
if code == 0 and data == 1:
commonFuc().check_text_exist(0, result)
else:
commonFuc().check_text_exist('error', result)
# ==================付款提交
# ==============内网发票提交
#================发票查询列表页面验证
#================发票查询列表页面验证
# ================发票查询列表页面验证
# ================发票查询列表页面验证
try:
......
air_case/b5_spd3_core_business_flow/a_a9流程六_中心库入库结算_负结算.air/a_a9流程六_中心库入库结算_负结算.py
View file @ 17cbb13f
......@@ -196,7 +196,7 @@ def center_warehouse_return():
try:
test1() # 提交采购计划 # 外网配送 # 内网验收入库结算
# test1() # 提交采购计划 # 外网配送 # 内网验收入库结算
# 先查询所有的部门信息写入文件
dept_query_all()
# 设置库房人员，根据传入的科室id和科室名称来设置库房
......
air_case/public1/public1/public1.py
View file @ 17cbb13f
......@@ -588,8 +588,8 @@ def invoice(type=1,OBh_ID='OBhxxxxxxxxxxxxxxx'):
break
list2=detailList
for k in list2:
maxSettleQty = k['leftSettleQty']
maxSettleAmount= k['settlePrice']
maxSettleQty = k['maxSettleQty']
maxSettleAmount= k['maxSettleAmount']
curSettleQty= k['curSettleQty']
curSettleAmount=k['curSettleAmount']
leftSettleQty=k['leftSettleQty']
......
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