API2Q1_2 R4S2FINAL.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": 1,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "keyword o code?: keyword\n",
      "Inserisci il valore - una parola se hai scelto KEYWORD o un codice se hai scelto CODE: milk\n",
      "Lingua - codice ISO due digit IT o EN: it\n",
      "+++++ INIZIO L'ELABORAZIONE +++++\n",
      " V--- copiare da qui in caso di defect ---V\n",
      "*** PARAMETRI INSERITI PER LA CHIAMATA A API2Q1:\n",
      "Keyword o code: keyword\n",
      "Valore: milk\n",
      "Lingua: it\n",
      "URL COMPLETA DI API2Q2: https://intesa.uat01.eesa.run/api/trade-codes?classification=&field=keyword&value=milk&strict=true&language=it&limit=&offset=\n",
      "PROCEDO CON LA CHIAMATA\n",
      "IL CODE RESPONSE E': 200\n",
      "Creo il file:20200320_17_52_18 -- API2Q1_keyword-milk-it.csv\n",
      "Gli item restituiti da API2Q1 sono: 0\n",
      "#### FAI RIFERIMENTO AI FILE:\n",
      "\n",
      "Scarico della chiamata ad API2Q1 - ELENCO degli item individuati: 20200320_17_52_18 -- API2Q1_keyword-milk-it.csv\n",
      "Scarico della chiamata ad API2Q2 - STRUTTURA degli item individuati: 20200320_17_52_18 -- API2Q2.csv\n",
      "\n",
      "    \n",
      "    ______ _____ _   _ _____ _____ _____ _ _ _\n",
      "    |  ___|_   _| \\ | |_   _|_   _|  _  | | | |\n",
      "    | |_    | | |  \\| | | |   | | | | | | | | |\n",
      "    |  _|   | | | . ` | | |   | | | | | | | | |\n",
      "    | |    _| |_| |\\  |_| |_  | | \\ \\_/ /_|_|_|\n",
      "    \\_|    \\___/\\_| \\_/\\___/  \\_/  \\___/(_|_|_)\n",
      "    #\n",
      "    #\n",
      "    #\n",
      "    \n",
      "\n",
      "    TUTTAPPPPOOOOOO....\n",
      "    \n",
      "    SALUTAMI I FRANCESI:\n",
      "    \n",
      "         _\n",
      "       _| |\n",
      "     _| | |\n",
      "    | | | |\n",
      "    | | | | __\n",
      "    | | | |/  |\n",
      "    |       /\\ |\n",
      "    |      /  \\/\n",
      "    |      \\  /|\n",
      "    |       \\/ /\n",
      "     \\        /\n",
      "      |     /\n",
      "      |    |\n",
      "    \n",
      "    \n"
     ]
    }
   ],
   "source": [
    "import json\n",
    "import csv\n",
    "import requests\n",
    "from datetime import datetime\n",
    "\n",
    "# ---- GESTIONE DATE E ORE PER INFORMAZIONI AGGIUNTIVE\n",
    "now = datetime.now()  # current date and time\n",
    "year = now.strftime(\"%Y\")\n",
    "month = now.strftime(\"%m\")\n",
    "day = now.strftime(\"%d\")\n",
    "ora = now.strftime(\"%H_%M_%S\")\n",
    "ora_log = now.strftime(\"%H:%M:%S\")\n",
    "data_ora_estrazione = year + month + day + \"_\" + ora\n",
    "data_estrazione = day + chr(34) + month + chr(34) + day\n",
    "\n",
    "\n",
    "# --------------- CREA UNA PATH PYTHON\n",
    "def converti_path_python(path):\n",
    "    path_python = path.replace(chr(92), chr(92) + chr(92)) + chr(92) + chr(92)\n",
    "    return path_python\n",
    "\n",
    "\n",
    "# --------------- RIFERIMENTI CARTELLE E FILE\n",
    "path_windows = r\"C:\\Users\\ig01849\\Miei progetti\\EE SYSTEM TEST\\API2 - R4S1\"\n",
    "path_lavoro = converti_path_python(path_windows)\n",
    "######################################\n",
    "\n",
    "# --------------- CREA LA STRINGA DA SCRIVERE NEL CSV\n",
    "def crea_stringa_csv(lista):\n",
    "    lunghezza_lista = len(lista)\n",
    "    contenuto = \"\"\n",
    "    for n in range(0,lunghezza_lista):\n",
    "        if n < lunghezza_lista-1:\n",
    "            #contenuto = contenuto + str(lista[n]) + \";\"\n",
    "            #contenuto = contenuto + chr(39) + str(lista[n]) + chr(39) + \";\"\n",
    "            contenuto = contenuto + chr(34) + str(lista[n]) + chr(34) + \";\"\n",
    "        else:\n",
    "            #contenuto = contenuto + str(lista[n])\n",
    "            #contenuto = contenuto + chr(39) + str(lista[n]) + chr(39)\n",
    "            contenuto = contenuto + chr(34) + str(lista[n]) + chr(34)\n",
    "    return contenuto\n",
    "######################################\n",
    "\n",
    "\n",
    "# CREA LA URL DA RICHIAMARE SULLA BASE DEI VALORI IN LISTA\n",
    "def crea_url_da_richiamare(lista_elementi_url):\n",
    "    divisore = \"&\"\n",
    "    url_da_richiamare = lista_elementi_url[0]\n",
    "    for n in range(1, len(lista_elementi_url)):\n",
    "        elemento_url = lista_elementi_url[n]\n",
    "        if n < (len(lista_elementi_url) - 1):\n",
    "            url_da_richiamare = url_da_richiamare + elemento_url[0] + \"=\" + elemento_url[1] + divisore\n",
    "        else:\n",
    "            url_da_richiamare = url_da_richiamare + elemento_url[0] + \"=\" + elemento_url[1]\n",
    "    return url_da_richiamare\n",
    "######################################\n",
    "\n",
    "field = input(\"keyword o code?: \")\n",
    "value = input(\"Inserisci il valore - una parola se hai scelto KEYWORD o un codice se hai scelto CODE: \")\n",
    "language = input(\"Lingua - codice ISO due digit IT o EN: \")\n",
    "\n",
    "\n",
    "# ---- VARIABILI PER LA GESTIONE DEI FILE API2Q2\n",
    "nome_file_api2query1 = data_ora_estrazione + \" -- API2Q1_\" + field + \"-\" + value + \"-\" + language + \".csv\"\n",
    "\n",
    "\n",
    "# ---- VARIABILI PER LA GESTIONE DEI FILE API2Q2\n",
    "nome_file_api2query2 = data_ora_estrazione + \" -- API2Q2.csv\"\n",
    "\n",
    "\n",
    "lista_parametri_url_code_api2q1 = [\n",
    "    'https://intesa.uat01.eesa.run/api/trade-codes?',\n",
    "    ['classification', ''],\n",
    "    ['field', field],\n",
    "    ['value', value],\n",
    "    ['strict', 'true'],\n",
    "    ['language', language],\n",
    "    ['limit', ''],\n",
    "    ['offset', '']\n",
    "]\n",
    "\n",
    "intestazioni_file_risultati_api2q1 = [\"ORA ESTRAZIONE\",\n",
    "                                      \"DATA ESTRAZIONE\",\n",
    "                                      \"CLASSIFICATION\",\n",
    "                                      \"LEVEL\",\n",
    "                                      \"MAX_LEVEL\",\n",
    "                                      \"CODE\",\n",
    "                                      \"PARENT_CODE\",\n",
    "                                      \"GROUP\",\n",
    "                                      \"PATH\",\n",
    "                                      \"DESCRIPTION\",\n",
    "                                      \"ULR\",\n",
    "                                      \"RESPONSE CODE\"]\n",
    "\n",
    "intestazioni_file_risultati_api2q2 = [\"ORA ESTRAZIONE\",\n",
    "                                      \"DATA ESTRAZIONE\",\n",
    "                                      \"CODE_API2Q1\",\n",
    "                                      \"CLASSIFICATION\",\n",
    "                                      \"LEVEL\",\n",
    "                                      \"MAX_LEVEL\",\n",
    "                                      \"CODE\",\n",
    "                                      \"PARENT_CODE\",\n",
    "                                      \"GROUP\",\n",
    "                                      \"PATH\",\n",
    "                                      \"DESCRIPTION\"]\n",
    "# CREO LA UTL DI API2Q1\n",
    "urlcompleted_api1query1 = crea_url_da_richiamare(lista_parametri_url_code_api2q1)\n",
    "\n",
    "print(\"+++++ INIZIO L'ELABORAZIONE +++++\")\n",
    "print(\" V--- copiare da qui in caso di defect ---V\")\n",
    "print(\"*** PARAMETRI INSERITI PER LA CHIAMATA A API2Q1:\")\n",
    "print(\"Keyword o code: \" + field)\n",
    "print(\"Valore: \" +  value)\n",
    "print(\"Lingua: \" + language)\n",
    "print(\"URL COMPLETA DI API2Q2: \" + urlcompleted_api1query1)\n",
    "print(\"PROCEDO CON LA CHIAMATA\")\n",
    "\n",
    "\n",
    "# ---- CHIAMATA A API2Q1 DI EE\n",
    "payload = {}\n",
    "headers = {\n",
    "    'Authorization': 'Basic aW50ZXNhOjdqb0x2RFd5a21tTWR3NUc='\n",
    "}\n",
    "\n",
    "response_api2q1 = requests.request(\"GET\", urlcompleted_api1query1, headers=headers, data=payload)\n",
    "\n",
    "# ----- RESPONSE CODE ----\n",
    "response_code_api2q1_str = str(response_api2q1.status_code)\n",
    "response_code_api2q1 = response_api2q1.status_code\n",
    "\n",
    "if response_code_api2q1 != 200:\n",
    "    print(\"QUALCOSA E' ANDATO STORTO!!!!\")\n",
    "    print(\"LA RESPONSE E':\\n\")\n",
    "    print(response_code_api2q1_str)\n",
    "else:\n",
    "    print(\"IL CODE RESPONSE E': \" + response_code_api2q1_str)\n",
    "    print(\"Creo il file:\" + nome_file_api2query1)\n",
    "    # ---- APRO IL DOCUMENTO PER LA REGISTRAZIONE DELLE INFORMAZIONI DI API2Q1\n",
    "    oggetto_file_risultati_api2q1 = open(path_lavoro + nome_file_api2query1, \"a\", encoding='utf-8')\n",
    "    # ---- APRO IL DOCUMENTO PER LA REGISTRAZIONE DELLE INFORMAZIONI DI API2Q2\n",
    "    oggetto_file_risultati_api2q2 = open(path_lavoro + nome_file_api2query2, \"a\", encoding='utf-8')\n",
    "    # ---- STAMPO NEL FILE DI RISULTATI DI API2Q1 LE INTESTAZIONI DI COLONNA\n",
    "    oggetto_file_risultati_api2q1.write(crea_stringa_csv(intestazioni_file_risultati_api2q1)+\"\\n\")\n",
    "    # ---- STAMPO NEL FILE DI RISULTATI DI API2Q2 LE INTESTAZIONI DI COLONNA\n",
    "    oggetto_file_risultati_api2q2.write(crea_stringa_csv(intestazioni_file_risultati_api2q2) + \"\\n\")\n",
    "\n",
    "    data_estrazione = day + chr(47) + month + chr(47) + day\n",
    "    ora_log = now.strftime(\"%H:%M:%S\")\n",
    "    lista_orario_api2q1 = [ora_log, data_estrazione]\n",
    "    #oggetto_file_risultati_api2q1.write(crea_stringa_csv(lista_orario))\n",
    "    #oggetto_file_risultati_api2q1.close()\n",
    "    data_api2q1 = json.loads(response_api2q1.text)\n",
    "    print(\"Gli item restituiti da API2Q1 sono: \"+str(data_api2q1[\"totalItems\"]))\n",
    "    # ---- ESTRAGGO LA LISTA CHE CONTIENE I DIZIONARI CON I DATI DAI VARI ITEMS\n",
    "    items_api2q1 = data_api2q1[\"items\"]\n",
    "    dict_data_api2q1 = {}\n",
    "    i = 0\n",
    "    for n in items_api2q1:\n",
    "        i = i + 1\n",
    "        dict_data_api2q1 = n\n",
    "        classification_api2q1 = str(dict_data_api2q1[\"classification\"])\n",
    "        level_api2q1 = str(dict_data_api2q1[\"level\"])\n",
    "        max_level_api2q1 = str(dict_data_api2q1[\"max_level\"])\n",
    "        code_api2q1 = str(dict_data_api2q1[\"code\"])\n",
    "        parent_code_api2q1 = str(dict_data_api2q1[\"parent_code\"])\n",
    "        group_api2q1 = str(dict_data_api2q1[\"group\"])\n",
    "        path_api2q1 = str(dict_data_api2q1[\"path\"])\n",
    "        description_api2q1 = str(dict_data_api2q1[\"description\"])\n",
    "        elementi_risposta_api2q1 = [classification_api2q1, level_api2q1, max_level_api2q1, code_api2q1, parent_code_api2q1, group_api2q1, path_api2q1, description_api2q1]\n",
    "        code_api2q2 = code_api2q1\n",
    "        dict_data_api2q2 = n\n",
    "        lista_parametri_url_code_api2q2 = [\n",
    "            'https://intesa.uat01.eesa.run/api/trade-codes/hierarchy?',\n",
    "            ['classification', 'HS17A'],\n",
    "            ['codeValue', code_api2q1],\n",
    "            ['language', language],\n",
    "            ['limit', '10000']\n",
    "        ]\n",
    "        urlcompleted_api2query2 = crea_url_da_richiamare(lista_parametri_url_code_api2q2)\n",
    "        print(\"Elaboro l'item \" + str(i) + \" di \" + str(data_api2q1[\"totalItems\"])+\" ITEM:\" + code_api2q2+\" URL API2Q2: \" + urlcompleted_api2query2)\n",
    "        #print(\"ITEM:\" + code_api2q2+\"URL API2Q2: \" + urlcompleted_api2query2)\n",
    "        #print(\"URL API2Q2: \" + urlcompleted_api2query2)\n",
    "        # ---- CHIAMATA A API2Q2 DI EE\n",
    "        payload = {}\n",
    "        headers = {\n",
    "            'Authorization': 'Basic aW50ZXNhOjdqb0x2RFd5a21tTWR3NUc='\n",
    "        }\n",
    "        ora_log = now.strftime(\"%H:%M:%S\")\n",
    "        lista_orario_api2q2 = [ora_log, data_estrazione]\n",
    "        response_api2q2 = requests.request(\"GET\", urlcompleted_api2query2, headers=headers, data=payload)\n",
    "        response_code_api2q2_str = str(response_api2q2.status_code)\n",
    "        response_code_api2q2 = response_api2q2.status_code\n",
    "        da_stampare_api2q1 = lista_orario_api2q1 + elementi_risposta_api2q1 + [urlcompleted_api2query2] + [response_code_api2q2]\n",
    "        oggetto_file_risultati_api2q1.write(crea_stringa_csv(da_stampare_api2q1) + \"\\n\")\n",
    "\n",
    "        if response_code_api2q2 != 200:\n",
    "            print(\"La chiamata a API2Q2 è andata maluccio..\")\n",
    "            print(\"Response code: \" + response_code_api2q2_str)\n",
    "            print(\"Response: \" + response_code_api2q2_str)\n",
    "            contenuto_api2q1 = lista_orario_api2q1 + elementi_risposta_api2q1 + [response_code_api2q2,response_code_api2q2_str]\n",
    "            oggetto_file_risultati_api2q1.write(crea_stringa_csv(contenuto_api2q1))\n",
    "\n",
    "        else:\n",
    "\n",
    "            dict_data_api2q2 = {}\n",
    "            data_api2q2 = json.loads(response_api2q2.text)\n",
    "            items_api2q2 = data_api2q2[\"items\"]\n",
    "            dict_data_api2q2 = {}\n",
    "            for m in items_api2q2:\n",
    "                dict_data_api2q2 = m\n",
    "\n",
    "\n",
    "                classification_api2q2 = str(dict_data_api2q2[\"classification\"])\n",
    "                level_api2q2 = str(dict_data_api2q2[\"level\"])\n",
    "                max_level_api2q2 = str(dict_data_api2q2[\"max_level\"])\n",
    "                code_api2q2 = str(dict_data_api2q2[\"code\"])\n",
    "                parent_code_api2q2 = str(dict_data_api2q2[\"parent_code\"])\n",
    "                group_api2q2 = str(dict_data_api2q2[\"group\"])\n",
    "                path_api2q2 = str(dict_data_api2q2[\"path\"])\n",
    "                description_api2q2 = str(dict_data_api2q2[\"description\"])\n",
    "                elementi_risposta_api2q2 = [classification_api2q2, level_api2q2, max_level_api2q2, code_api2q2, parent_code_api2q2, group_api2q2, path_api2q2, description_api2q2]\n",
    "                elementi_api2q2_x_risp_api2q1 = [response_code_api2q2, items_api2q1, urlcompleted_api2query2]\n",
    "                #da_stampare_api2q1 = lista_orario_api2q1 + elementi_risposta_api2q1 + [urlcompleted_api2query2] + [response_code_api2q2]\n",
    "                #oggetto_file_risultati_api2q1.write(crea_stringa_csv(da_stampare_api2q1) + \"\\n\")\n",
    "                da_stampare_api2q2 = lista_orario_api2q2 + [code_api2q1] + elementi_risposta_api2q2\n",
    "                oggetto_file_risultati_api2q2.write(crea_stringa_csv(da_stampare_api2q2) + \"\\n\")\n",
    "\n",
    "    oggetto_file_risultati_api2q1.close()\n",
    "    oggetto_file_risultati_api2q2.close()\n",
    "\n",
    "    print(\"#### FAI RIFERIMENTO AI FILE:\\n\")\n",
    "    print(\"Scarico della chiamata ad API2Q1 - ELENCO degli item individuati: \"+nome_file_api2query1)\n",
    "    print(\"Scarico della chiamata ad API2Q2 - STRUTTURA degli item individuati: \"+nome_file_api2query2)\n",
    "    print(\"\"\"\n",
    "    \n",
    "    ______ _____ _   _ _____ _____ _____ _ _ _\n",
    "    |  ___|_   _| \\ | |_   _|_   _|  _  | | | |\n",
    "    | |_    | | |  \\| | | |   | | | | | | | | |\n",
    "    |  _|   | | | . ` | | |   | | | | | | | | |\n",
    "    | |    _| |_| |\\  |_| |_  | | \\ \\_/ /_|_|_|\n",
    "    \\_|    \\___/\\_| \\_/\\___/  \\_/  \\___/(_|_|_)\n",
    "    #\n",
    "    #\n",
    "    #\n",
    "    \"\"\")\n",
    "    print(\"\"\"\n",
    "    TUTTAPPPPOOOOOO....\n",
    "    \n",
    "    SALUTAMI I FRANCESI:\n",
    "    \n",
    "         _\n",
    "       _| |\n",
    "     _| | |\n",
    "    | | | |\n",
    "    | | | | __\n",
    "    | | | |/  |\n",
    "    |       /\\ |\n",
    "    |      /  \\/\n",
    "    |      \\  /|\n",
    "    |       \\/ /\n",
    "     \\        /\n",
    "      |     /\n",
    "      |    |\n",
    "    \n",
    "    \"\"\")\n",
    "       "
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "Python 3",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.6.4"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 2
}