org.openbravo.kikobar.banqup/extract_invoice.py

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']
			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+'}'
	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),
	    "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]))