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" 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 lines_output = lines_output + '{"service_name": "","service_description": "'+linetemp['product$_identifier']+'","service_quantity": '+str(linetemp['invoicedQuantity'])+',"service_price": '+str(linetemp['unitPrice'])+',"service_vat": '+'8'+'}' 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]))