-
Notifications
You must be signed in to change notification settings - Fork 0
/
extract_invoice.py
100 lines (87 loc) · 4.2 KB
/
extract_invoice.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
import requests
from requests_oauthlib import OAuth2Session
import json
import sys
import webbrowser
from config import *
from cachehandler import CacheHandler
from authhandler import AuthHandler
from api import OpenbravoToBanqupAPI
from datetime import timedelta, date
def extract_invoice(document):
url = ob_api_url+"Invoice?_where=documentNo='"+document+"'&_noActiveFilter=false"
payload = {}
headers = {
'Authorization': 'Basic '+userpass_b64
}
response = requests.request("GET", url, headers=headers, data=payload) #extracts invoice header
#print(response.text)
invoice = json.loads(response.text)
#print (invoice['response']['data'][0]['businessPartner'])
lastCalculatedOnDate = invoice['response']['data'][0]['lastCalculatedOnDate']
daysTillDue = invoice['response']['data'][0]['daysTillDue']
dueDate = date(int(lastCalculatedOnDate[0:4]), int(lastCalculatedOnDate[5:7]), int(lastCalculatedOnDate[8:10])) + timedelta(days=daysTillDue)
api = OpenbravoToBanqupAPI(bq_client_id,bq_client_secret)
authUrl = api.authHandler.getAuthURL(bq_redirect_uri)
webbrowser.open(authUrl)
response = input('Paste response: ')
token = api.authHandler.retrieveToken(response, redirectUri=bq_redirect_uri)
#print(token)
businessPartner=invoice['response']['data'][0]['businessPartner']
debtor_list = api.get('debtors?client_id='+banqup_client_id+'&client_debtor_number='+businessPartner,None,None)
#print(debtor_list)
if not debtor_list[2]['results']:
print('***********************')
print('The business partner '+businessPartner+' is not registered in the Banqup portal for the customer '+invoice['response']['data'][0]['businessPartner$_identifier'])
print('Please complete the registration in Banqup and try again.')
print('***********************')
return
debtor_id = debtor_list[2]['results'][0]['id']
preferred_channel = debtor_list[2]['results'][0]['preferred_channel']
url = ob_api_url+"InvoiceLine?_where=invoice='"+invoice['response']['data'][0]['id']+"'&_noActiveFilter=false&_sortBy=lineNo"
response = requests.request("GET", url, headers=headers, data=payload) #extracts invoice lines
#print(response.text)
lines = json.loads(response.text)['response']['data']
lines_json = json.dumps(lines)
#print(lines_json)
lines = json.loads(lines_json)
lines_output = '['
first_line = True
for key in lines:
#print (key)
linetemp_json = json.dumps(key)
linetemp = json.loads(linetemp_json)
if linetemp['product'] != None:
if not first_line:
lines_output = lines_output+','
first_line = False
url = ob_api_url+"Product?_where=id='"+linetemp['product']+"'&_noActiveFilter=false"
response = requests.request("GET", url, headers=headers, data=payload) #extracts product from master
product = json.loads(response.text)['response']['data'][0]['searchKey']
if product != comment_product:
lines_output = lines_output + '{"service_name": "'+product+'","service_description": "'+linetemp['product$_identifier']+'","service_quantity": '+str(linetemp['invoicedQuantity'])+',"service_price": '+str(linetemp['unitPrice'])+',"service_vat": '+gst_rate+'}'
else:
lines_output = lines_output + '{"service_name": "'+product+'","service_description": "'+linetemp['description']+'","service_quantity": '+str(linetemp['invoicedQuantity'])+',"service_price": '+str(linetemp['unitPrice'])+',"service_vat": '+gst_rate+'}'
lines_output = lines_output+']'
#print(lines_output)
payload = json.dumps({
"sales_invoice_number": invoice['response']['data'][0]['documentNo'],
"sales_invoice_date": invoice['response']['data'][0]['invoiceDate']+"T00:00:00Z",
"sales_invoice_due_date": str(dueDate)+"T00:00:00Z",
"platform_id": banqup_platform_id,
"debtor_id": debtor_id,
"currency_code": invoice['response']['data'][0]['currency$_identifier'],
"client_id": banqup_client_id,
"delivery_channel": preferred_channel,
"invoice_lines": json.loads(lines_output, strict=False),
"po_number": "NA",
"buyer_reference": "NA",
"customer_reference": "NA",
"supplier_reference": "NA",
"contract_number": "NA"
})
#print(payload)
new_invoice = api.post('sales-invoices',json.loads(payload),None,None)
print(new_invoice)
if __name__ == '__main__':
extract_invoice(str(sys.argv[1]))