Mongo_Vectoring.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": 967,
   "id": "0ad23304-dcb0-4c3d-b16a-25c4f62c557b",
   "metadata": {},
   "outputs": [],
   "source": [
    "import pandas as pd\n",
    "\n",
    "import time\n",
    "from langchain.prompts import PromptTemplate\n",
    "from langchain_core.output_parsers import JsonOutputParser\n",
    "from langchain_core.output_parsers import StrOutputParser\n",
    "\n",
    "# CHroma Libs\n",
    "from langchain.embeddings import OpenAIEmbeddings\n",
    "from langchain.vectorstores.chroma import Chroma \n",
    "from dotenv import dotenv_values\n",
    "\n",
    "import os\n",
    "from tqdm import tqdm\n",
    "\n",
    "from openai import OpenAI\n",
    "\n",
    "# Postgre\n",
    "import psycopg2\n",
    "\n",
    "import numpy as np\n",
    "import ast"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "cf60096e-186e-4b90-9291-b385778162d3",
   "metadata": {},
   "source": [
    "## Configs"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 47,
   "id": "ea8f27f4-e201-4a67-9938-74e6ba2e4484",
   "metadata": {},
   "outputs": [],
   "source": [
    "os.environ['OPENAI_API_KEY'] = '<open_ai_api_key>'"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 48,
   "id": "f1ea676f-a413-44de-8967-232035ec46a9",
   "metadata": {},
   "outputs": [],
   "source": [
    "os.environ['MONGO_DB_KEY'] = \"IobZyvpsBcQRbNlS\"\n",
    "os.environ['MONGO_DB_CON_STRING'] = \\\n",
    "f\"mongodb+srv://halil10hatun:{os.environ['MONGO_DB_KEY']}@mycluster.jzt34j1.mongodb.net/?retryWrites=true&w=majority&appName=MyCluster\""
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 89,
   "id": "e49daeaa-c840-44f7-8e9a-04d6daefcb56",
   "metadata": {},
   "outputs": [],
   "source": [
    "env_vars = dotenv_values('<postgres.env_path>')"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 76,
   "id": "a8aec60f-59a7-4116-8dee-e17eaf2c5e52",
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/plain": [
       "OrderedDict([('DATABASE_NAME', 'rag_system'),\n",
       "             ('DATABASE_USER', 'postgres'),\n",
       "             ('DATABASE_PASSWORD', 'Mustafa63'),\n",
       "             ('DATABASE_HOST', 'localhost'),\n",
       "             ('OPENAI_API_KEY',\n",
       "              'sk-proj-TimFt1navUqB43NoKCkST3BlbkFJULiZCwo4pYZg1DH4upnq')])"
      ]
     },
     "execution_count": 76,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "env_vars"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "e7a701fa-6d67-4eb7-a65b-092e6cf8b3b4",
   "metadata": {},
   "source": [
    "--------------"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 7,
   "id": "5786d273-6283-42a1-b4ee-fb35e00154c3",
   "metadata": {},
   "outputs": [],
   "source": [
    "uretim_df = pd.read_excel('./Postre_Data/Gunluk_Uretim_Adetleri_Raporu_Tabular.xlsx')\n",
    "siparis_df = pd.read_excel('./Postre_Data/Siparisler_Tabular.xlsx')"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 8,
   "id": "e5f9291f-5f1b-4192-af98-c2294b23b3bf",
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/plain": [
       "Index(['Order No', 'Model Kodu', 'Model Adı', 'Müşteri', 'Bölüm', 'Tedarikçi',\n",
       "       'Müşteri Order No', 'Rpt', 'Marka', 'Renk Kodu', 'İşlem', 'RSN',\n",
       "       'Tarih', 'Adet', 'Kumaş', 'Kumaş Tipi', 'Kalite Tipi'],\n",
       "      dtype='object')"
      ]
     },
     "execution_count": 8,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "uretim_df.columns"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 9,
   "id": "6fb4e912-6e5b-4789-8e27-e51b1387b78b",
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Order No eşsiz değerleri = ['ZAR220173' 'PLM16523' 'PLM16530' ... 'PLM16326' 'PLM16448' 'PLM16506']\n",
      "Model Kodu eşsiz değerleri = ['ZAR01099' 'SMP03599-005' 'DSG08620-001' ... 'DSG08529-001'\n",
      " 'DSG08576-001' 'DSG06985-004']\n",
      "Model Adı eşsiz değerleri = ['5584-377 (UTR-1062-85/360)' 'RIB CUT OUT BODYSUIT' 'UGL-345' ...\n",
      " 'UMC-P-0250' '7125 short sleeve' 'TEEW040 OPTA']\n",
      "Müşteri eşsiz değerleri = ['ITX TRADING S.A' 'PRIMARK LIMITED' 'H&M' 'C&A Buying GmbH & Co. KG'\n",
      " 'LPP COMPANY' 'Motelrocks UK Ltd' 'LC Waikiki' 'New Look'\n",
      " 'TUVAL SANAT GALERİSİ TEKS.TUR.SAN.TİC.LTD.ŞTİ.' 'ASDA STORES LIMITED'\n",
      " 'BRAVADO MERCHANDISE A DIVISION OF UNIVERSAL MUSIC GMBH'\n",
      " 'ÜNİTEKS TEKSTİL GIDA SAN DIŞ TİC. A.Ş' 'PARK AGENCIES LTD'\n",
      " 'UNIVERSAL MUSIC SPAIN S.L.U' 'BRANDDESING SA' 'MERCH TRAFFIC'\n",
      " 'WE Fashion' 'BERSHKA BSK ESPANA S.A.' 'COTTON DIVISION' 'MANGO INC.']\n",
      "Bölüm eşsiz değerleri = ['ZR05' nan 'HM01' 'CA04' 'BM06' 'ING09' 'ZR08']\n",
      "Tedarikçi eşsiz değerleri = ['AHMET KONCA(ESKİ ÜNVAN)'\n",
      " 'Numune Dikim Bandı - C&A / ING / RESERVED  / lCW / BRAVADO'\n",
      " 'Numune Dikim Bandı - ZARA' 'SİNTAŞ TEKSTİL VE TİC. LTD. ŞTİ.'\n",
      " 'MOLA TEKSTİL İNŞ. SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'KARADAĞLAR KONF. TEKSTİL İNŞ. SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'Numune Dikim Bandı - H&M'\n",
      " 'Numune Dikim Bandı - BERSHKA / ZARA DOKUMA  / MOTELROCKS'\n",
      " 'KUZEY KAFKAS GİYİM SANAYİ TİC. LTD. ŞTİ.'\n",
      " 'AZİM DIŞ TİCARET SAN. VE LTD. ŞTİ.'\n",
      " 'KANDEMİR TEKSTİL İNŞ. GIDA SAN. VE DIŞ TİC. LTD. ŞTİ.'\n",
      " 'STORY GİYİM ANONİM ŞİRKETİ'\n",
      " 'FAYSAL TAŞKIN TAŞKIN TEKSTİL SANAYİ VE TİC.LTD.ŞTİ.'\n",
      " 'KEPSİL TEKSTİL KONFEKSİYON SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'EZKA TEKSTİL TUR. GIDA SAN. VE DIŞ TİC. LTD. ŞTİ.'\n",
      " 'ELİF NAKIŞ TEKSTİL İNŞAAT ORMAN ÜR. SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'MED TEKSTİL MEHMET SİRAÇ DEĞİRMENCİ'\n",
      " 'İEGS İÇ EGE GİYİM TURİZM SAN.VE TİC.LTD.ŞTİ.'\n",
      " 'ASLAN TEKSTİL - TEMAM TEKE (ESKİ CARİ)'\n",
      " 'ESKİ (TAŞKIN TEKSTİL FAYSAL TAŞKIN)'\n",
      " 'ALPSU ORDU TEKSTİL KONFEKSİYON SANAYİ VE TİCARET LİMİTED ŞİRKETİ(ESKİ ÜNVAN)'\n",
      " 'TEOS NAKIŞ BASKI TEKSTİL KONFEKSİYON SAN. TİC. LTD. ŞTİ.'\n",
      " 'SEFTER KURİŞ AYZE TEKSTİL'\n",
      " 'AYŞİL İNŞ. TRZ. TEKSTİL KONF. SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'MURAT IŞIK TEKSTİL MEDİKAL HAM MADDE OTOMOTİV İNŞAAT TURİZM GIDA SAN. TİC. LTD. ŞTİ.'\n",
      " 'ELA DİJİTAL BASKI TEKSTİL SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'ARES KONFEKSİYON İNŞ. TUR. SAN. VE TİC. LTD. STİ.'\n",
      " 'İCS TEKSTİL KONFEKSİYON SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'RONA TEKSTİL İNŞAAT TAAHHÜT İTHALAT İHRACAT GIDA SAN. TİC. LTD. ŞTİ.'\n",
      " 'ECEM SULTAN SAN. TİC. LTD. ŞTİ.'\n",
      " 'SRT GİYİM DIŞ TİCARET VE SANAYİ LİMİTED ŞİRKETİ'\n",
      " 'OR-Gİ İLETİŞİM VE TEKSTİL SAN.VE TİC.LTD.ŞTİ.'\n",
      " 'BARAN TEKSTİL KIYASETTİN ARIK(ESKİ CARİ)'\n",
      " 'ELİF SÜZENE NAKIŞ BASKI TESKTİL SAN.VE TİC.LTD.ŞTİ'\n",
      " 'ÖZKOÇ MODA SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'HANO TEKSTİL İNŞAAT GIDA NAKL. SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'EMPAŞ EMPRİME TEKSTİL SAN. LTD. ŞTİ.'\n",
      " 'BKA EMPRİME BASKI VE TEKSTİL SANAYİ TİCARET ANONİM ŞİRKETİ'\n",
      " 'ÇAĞAN İLİK TEKSTİL İNŞ. TUR. GIDA SAN. TİC. LTD. ŞTİ.'\n",
      " 'UÇARLAR MAKİNA TEKSTİL İNŞ. İTH. İHR. SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'TREND KURU TEMİZLEME TEKSTİL ÜRÜNLERİ GELİŞTİRME SAN. VE TİC. A.Ş.'\n",
      " 'DİJİTAL TEKSTİL SANAYİ VE DIŞ TİCARET LİMİTED ŞİRKETİ'\n",
      " 'ASEL MODATEKS TEKSTIL SANAYI VE TICARET LIMITED'\n",
      " 'AKAR TEKSTİL GIDA VE TURİZM SAN. TİC. A.Ş.'\n",
      " 'SE TEKSTİL İNŞAAT TARIM GIDA NAKLİYE TAAHHÜT İTHALAT İHRACAT SAN. TİC. LTD. ŞTİ.'\n",
      " 'DENGE YIKAMA SAN. TİC. LTD. ŞTİ.'\n",
      " 'AMASYA ELÇİN TEKSTİL İMALAT İTHALAT İHRACAT SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'AYDEMA TEKSTİL OTOMOTİV DANIŞMANLIK İNŞAAT TURİZM İTHALAT İHRACAT SANAYİ VE TİC. LTD.ŞTİ'\n",
      " 'DESMA MODA TEKSTIL SANAYI TICARET LIMITED SIRKETI'\n",
      " 'LİVA HAZIR GİYİM BOYAMA LTD. ŞTİ.'\n",
      " 'AYÇ TEKSTİL SANAYİ VE TİC. LTD. ŞTİ.'\n",
      " 'CLS TEKSTİL SANAYİ TİCARET ANONİM ŞİRKETİ'\n",
      " 'HANİFE ALTUNER - ALTA TEKSTİL '\n",
      " 'STRABON MEDİKAL TIBBİ ÜR.TEKSTİL PAZ. İTH. İHR. SAN.TİC.LTD. ŞTİ.'\n",
      " 'METİNCE TEKS. İNŞ. TAR. HAY. LTD. ŞTİ.'\n",
      " 'EV-KON TEKSTİL SANAYİ VE TİC. A.Ş.'\n",
      " 'NİKSAR ASLAN TEKSTİL SAN. VE TİC. LTD.ŞTİ.'\n",
      " 'ÖZAR TEKSTİL İÇ VE DIŞ TİC. SAN. LTD. ŞTİ.'\n",
      " 'ALZ TEKSTİL İNŞAAT SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'İRF TEKSTİL İNŞ. TURİZM GIDA SAN. TİC. LTD. ŞTİ.'\n",
      " 'SİBATEX TEKSTİL SANAYİ VE TİCARET ANONİM ŞİRKETİ'\n",
      " 'YMO TEKSTİL İNŞ. SAN. İÇ VE DIŞ TİC. LTD. ŞTİ.'\n",
      " 'MİRHAT HAZIR GİYİM SAN. VE TİC.LTD.ŞTİ'\n",
      " 'KAYATEK TEKSTİL İNŞAAT SAN.VE TİC.LTD.ŞTİ.'\n",
      " 'MENESA TEKSTİL SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'ALTATEKS GRUP TEKSTİL SAN.TİC.LTD.ŞTİ.'\n",
      " 'MKM PRINT TEKSTİL İTH. İHR. SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'FATSA EKİP TEKSTİL İNŞ. SAN. TİC. LTD. ŞTİ.'\n",
      " 'SPC MÜHENDİSLİK İNŞ. TAAH. TEKS. NAK. İTH. İHR. SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'MEDİ AKSESUAR DÜNYASI SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'EBRU TEKSTİL NAKIŞ SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'NEWTEX HAZIRGİYİM TEKSTİL KONFEKSİYON SAN. VE TİC. A.Ş.'\n",
      " 'LİDER CANSU TEKSTİL SAN. VE TİC. A.Ş.'\n",
      " 'GÜNDÜZ NAKIŞ TEKS. GIDA TUR. İNŞ. SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'EKİP TEKSTİL İNŞAAT TURİZM GIDA SANAYİ VE DIŞ TİCARET ANONİM ŞİRKETİ'\n",
      " 'İKİNCİ BAHAR TEKSTİL GÖMLEK VE KONFEKSİYON SANAYİ TİCARET LİMİTED ŞİRKETİ'\n",
      " 'İMZA GRUP TEKSTİL TİCARET SANAYİ LİMİTED ŞİRKETİ'\n",
      " 'SUN-SET EMPİRME TEKSTİLl SAN.VE DIŞ TİC. LTD. ŞTİ.'\n",
      " 'DOĞAN STİL TEKSTİL TUZR. İNŞ. SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'BEY-DUR KONFEKSİYON İMALAT İHRACAT SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'CTT TEKSTİL TURİZM İNŞAAT SANAYİ TİCARET LİMİTED ŞİRKETİ'\n",
      " 'ASYA NAKIŞ TEKSTİL SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'AS BASKI NAKIŞ ÖRME TEKSTİL SAN. TİC. A.Ş.'\n",
      " 'OSM HAZIR GİYİM TEKSTİL GIDA İNŞAAT NAK. SAN. VE TİC. A.Ş.'\n",
      " 'ORFA GİYİM SANAYİ VE DIŞ TİCARET A.Ş.'\n",
      " 'ALPSU İNŞAAT TEKSTİL SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'BETA KONFEKSİYON TEKSTİL İHRACAT İTHALAT SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'ONLY GİYİM TEKSTİL SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'ARMEN MODA GİYİM TEKSTİL İNŞAAT TURİZM DIŞ TİCARET LİMİTED ŞİRKETİ'\n",
      " 'OSKA DİKİM TEKSTİL İNŞAAT GIDA SAN. VE TİC. LTD.ŞTİ.'\n",
      " 'ÖZ SIRAÇ TEKSTIL GIDA TURIZM NAKLIYE ITHALAT İHRACAT SAN.VE TİC. LTD. ŞTİ.'\n",
      " 'DEM ÖZKANLAR TEKSTİL SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'TEKOVA TEKSTİL ÜRÜNLERİ TURİZM İNŞ. GIDA SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'KILIÇ MODA TEKSTİL SAN VE TİC LTD ŞTİ'\n",
      " 'DİBATEKS BASKI NAKIŞ KONF. SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'UĞUR21 MODA TEKSTİL İNŞAAT TARIM GIDA NAKLİYE SANAYİ TİCARET LİMİTED ŞİRKETİ'\n",
      " 'MAG GRUP KUMAŞ KONFEKSİYON TEKSTİL SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'SMART ÖRME TEKSTİL LTD. ŞTİ.'\n",
      " 'VESA TEKSTİL SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'ASLANKAYA TEKSTİL SANAYİ VE TİC. LTD. ŞTİ.'\n",
      " 'SİLİVA TEKSTİL İNŞ. NAK. TAR. SAN. TİC. LTD. ŞTİ.'\n",
      " 'PRONTO FASHİON MODA KONFEKSİYON ANONİM ŞİRKETİ'\n",
      " 'MFB TEKSTİL İNŞ. TAAH. GID. TUR. SAN.TİC.LTD.ŞTİ.'\n",
      " 'RBK YATIRIM TEKSTİL ANONİM ŞİRKETİ'\n",
      " 'BALEKAN KONFEKSİYON VE İNŞAAT SANAYİ TİCARET LİMİTED ŞİRKETİ'\n",
      " 'ALDEBARAN TEKSTİL SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'KONCA KONFEKSİYON TEKSTİL SANAYİ VE TİCARET ANONİM ŞİRKETİ'\n",
      " 'EMTAŞ TEKSTİL İNŞAAT TAAHHÜT GIDA TURİZM HAYVANCILIK SA.TİC.LTD.ŞTİ.'\n",
      " 'RUKİYE DİDEM ÖNÜR - ONURCAN TEKSTİL'\n",
      " 'SİDAR EMPRİME BASKI SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'KIYASETİN ARIK BARAN TEKSTİL KONFEKSİYON SANAYİ VE TİCARET ANONİM ŞİRKETİ'\n",
      " 'UGS GİYİM SANAYİ VE TİCARET ANONİM ŞİRKET'\n",
      " 'SELİS EMPRIME TEKSTİL SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'ZAROTEKS TEKSTİL İNŞ. TAAH. İTH. İHR. PAZ. SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'YMZ ÖZMEN TEKSTİL SANAYİ TİCARET LİMİTED ŞİRKETİ  ' nan\n",
      " 'MERAM YATIRIM İNŞAAT NAKLİYAT SAN. VE TİC. LTD. ŞTİ. '\n",
      " 'BAZEM İNŞAAT TEKSTİL SAĞLIK HİZMETLERİ LİMİTED ŞİRKETİ'\n",
      " 'TOPRAK AKARYAKIT YAYINCILIK HAY. TAR. GID. İNŞ. TE. SAN. TİC. LTD. ŞTİ. '\n",
      " 'ITX TRADING S.A' 'LPP COMPANY'\n",
      " 'BH TEKSTIL INSAAT SANAYI VE TICARET LIMITED SIRKETI' 'AHMET SÜZEN'\n",
      " 'New Look' 'POTKOVA TEKSTİL KONF. GIDA TUR. SAN. VE TİC. LTD. ŞTİ. '\n",
      " 'C&A Buying GmbH & Co. KG' 'ÖZLEM TOKKAMIŞ - SEHER TEKSTİL'\n",
      " 'AGEV TEKSTİL İTHALAT İHRACAT SANAYİ VE TİCARET ANANONİM ŞİRKETİ'\n",
      " 'GÖRTEKS TEKSTİL TURİZM  SAN.VE TİC.LTD.ŞTİ.'\n",
      " 'ARTKAR TEKSTİL SAN. TİC. LTD. ŞTİ.' 'PERİDOT TEKSTİL SAN. TİC.LTD.ŞTİ.'\n",
      " 'VEHA KONFEKSİYON SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'AKDEM HAZIR GİYİM DIŞ TİCARET LİMİTED ŞİRKETİ'\n",
      " 'SUMMANİ AYDENİZ AYCEM TEKSTİL'\n",
      " 'TANEKS TEKSTİL SAN. VE DIŞ TİC. LTD. ŞTİ.'\n",
      " 'DOĞUŞ HAZIR GİYİM SANAYİ VE TİC. LTD. ŞTİ.'\n",
      " 'BAKAY TEKSTİL GIDA TARIM HAYVANCILIK TAŞ. İTHALAT İHRACAT SAN. VE TİC.LTD.ŞTİ.'\n",
      " 'NU DEM TEKSTİL VE NAKIŞ SAN. TİC. LTD. ŞTİ.'\n",
      " 'GÜNIŞIĞI TRANSFER BASKI TEKSTİL SAN.VE TİC.LTD.ŞTİ.'\n",
      " 'ÜNİTEKS TEKSTİL GIDA SAN DIŞ TİC. A.Ş'\n",
      " 'PER BOYA TEKSTİL SAN. VE TİC. LTD.ŞTİ ( ESKİ CARİ )'\n",
      " 'Y MOMENTUM TEKSTİL DIŞ TİC.A.Ş'\n",
      " 'PER BOYA TEKSTİL SANAYİ VE TİCARET A.Ş.' 'İBRAHİM FİDAN - FİDAN KROŞETA'\n",
      " 'MARİZ TEKSTİL SANAYİ VE TİCARET LİMİTED ŞİRKETİ'\n",
      " 'NY NAKIŞ TEKS. KONF. SAN. TİC. LTD. ŞTİ.' 'ÖZGÜN BOYA SAN. TİC. A.Ş.'\n",
      " 'UZMAN SÜS DİKİŞLERİ TEKSTİL SAN. VE TİC. LTD ŞTİ.'\n",
      " 'BERRAKÖZ KONFEKSİYON EMPRİME SAN. VE TİC. LTD. ŞTİ.'\n",
      " 'TİME TEKS TEKSTİL AKS. İML. SAN. VE DIŞ TİC. LTD. ŞTİ.']\n",
      "Müşteri Order No eşsiz değerleri = ['17011-25' nan '17013-25' ... '59182-D' '272385-1636' '221424-2032']\n",
      "Rpt\n",
      "Marka eşsiz değerleri = ['Zara' 'Primark' 'H&M' 'C&A' 'Stradivarius' 'Reserved' 'Motel Rocks'\n",
      " 'Bershka' 'Lc Waikiki' 'New Look' 'TREADLER' 'PULL&BEAR'\n",
      " 'TUVAL SANAT GALERİSİ TEKS.TUR.SAN.TİC.LTD.ŞTİ.' 'GEORGE' 'BRAVADO'\n",
      " 'Uniteks' 'Lefties' 'WE Fashion' 'OYSHO' 'BRANDDESING SA' 'MANGO']\n",
      "Renk Kodu eşsiz değerleri = ['800 - Black' '0800 Black' 'Check Aop' ... '11-0601' '13-0849 TCX'\n",
      " '16-115']\n",
      "İşlem eşsiz değerleri = ['Ütü Paket' 'Kesim' 'Dikim' 'Nakış' 'Parça Baskı' 'Smok' 'Parça Boyama'\n",
      " 'Parça Yıkama' 'Çift boya' 'Yağ Sökümü' 'Taş Pres' 'Silikon' 'İlik Düğme'\n",
      " 'Pres' 'Çıt Çıt' 'Fikse' 'Şardon' 'Ram' 'Yıkama' 'Orta boya' 'Koyu boya'\n",
      " 'Termofikse' 'El İşçiliği' 'Enzim'\n",
      " 'Reaktif baskı zemin kasar beyaz yıkama' 'Açık boya'\n",
      " 'Pigment baskı açık zemin üzeri  byl  '\n",
      " 'Reaktif baskı açık zemin üzeri  byl' 'Gaze']\n",
      "RSN eşsiz değerleri = [nan '64301 665 05 116' '64301 705 37 201' ... '210673302' '210597007  '\n",
      " '210490998']\n",
      "Tarih\n",
      "Adet\n",
      "Kumaş eşsiz değerleri = [nan 'Örme Mesh 100D %80 Rcy Pes %20 Ea 80 Gr'\n",
      " 'Süprem 30/1 %100 Org Co 145Gr' ...\n",
      " 'Çelik Raporlu Ribana 28/(70/40) %49 Pes %47 BCI Co %4 Ea'\n",
      " 'Tül 40/40 %95 Pes %5 Ea' 'IRMAK 26-22 İPEKTÜL']\n",
      "Kumaş Tipi eşsiz değerleri = [nan 'Ana Kumaş' 'Diğer Kumaş']\n",
      "Kalite Tipi eşsiz değerleri = ['Sağlam' 'Kumaş Hatası' 'Dikim Hatası' 'Kumaş Kaynaklı Leke'\n",
      " 'İhracat Fazlası' 'Renk Farkı' 'Numune' 'Parça İade' 'Nakış Hatası'\n",
      " 'Baskı Kaynaklı Leke' 'Baskı Hatası' 'Taş Pres' 'Ölçü Hatası'\n",
      " 'P.Boya Hatası' 'P.Boya Kaynaklı Leke' 'El İşçiliği Hatası' 'Fire' 'İade'\n",
      " 'Tanımsız']\n"
     ]
    },
    {
     "name": "stderr",
     "output_type": "stream",
     "text": [
      "C:\\Users\\halilibrahim.hatun\\AppData\\Local\\Temp\\ipykernel_40316\\881317359.py:2: FutureWarning: is_categorical_dtype is deprecated and will be removed in a future version. Use isinstance(dtype, CategoricalDtype) instead\n",
      "  if uretim_df[column].dtype == 'object' or pd.api.types.is_categorical_dtype(uretim_df[column]):\n"
     ]
    }
   ],
   "source": [
    "for column in uretim_df.columns:\n",
    "    if uretim_df[column].dtype == 'object' or pd.api.types.is_categorical_dtype(uretim_df[column]):\n",
    "        print(f\"{column} eşsiz değerleri = {uretim_df[column].unique()}\")\n",
    "    else:\n",
    "        print(f\"{column}\")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 10,
   "id": "c3b3a8fe-ff4a-424d-abe7-5a4e0c7d017e",
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Durum eşsiz değerleri = ['Açık' 'Kapalı']\n",
      "Statü eşsiz değerleri = ['Planlandı' 'İptal Edildi' 'Onay Bekliyor' 'Başladı - Çalışıyor'\n",
      " 'Tamamlandı' 'Hazır' 'Durduruldu' 'Tedarik Bekliyor']\n",
      "Booking -> Order eşsiz değerleri = ['EVET' 'HAYIR']\n",
      "Set Order eşsiz değerleri = ['HAYIR' 'EVET']\n",
      "Set Parça Sayısı eşsiz değerleri = [nan '1' '2 Parça' '3 Parça' '7 Parça' '8 Parça' '3' '2']\n",
      "Order Tipi eşsiz değerleri = ['Firm Order' 'Booking Order']\n",
      "Booking Type eşsiz değerleri = ['Müşteri' '-']\n",
      "Order Grubu eşsiz değerleri = [nan '208695-7618' '130094-7819 set' 'SET ' '64301 344 43 814 SET' 'set'\n",
      " '132170-7618' '132485-8718' '132402-8718' '272198-7618 ' '272195-7618'\n",
      " '272402-7819' '131942-7618 ' '129816-8815' '264176-7618' 'SET' '2209535'\n",
      " 'shop order' 'shane mıne craft']\n",
      "Satış Tipi eşsiz değerleri = ['Tasarım Koleksiyonu' 'Müşteri Koleksiyonu' ' ' 'Kumaş Koleksiyonu'\n",
      " 'Tasarım Kolleksiyonu' 'Alışveriş Koleksiyonu']\n",
      "Sertifikasyon eşsiz değerleri = ['BCI + RCS' 'BCI' nan 'JL - Care For Fiber' 'RCS'\n",
      " 'JL - Care For Fiber + OCS' 'OCS + RCS' 'JL - Care For Fiber + RCS'\n",
      " 'C&A Warner Bros' 'OCS' 'JL - Care For Water + BCI' 'RCS + New Look Kind'\n",
      " 'JL - Care for Water' 'JL - Care for Fiber + Inditex Children'\n",
      " 'BCI + H&M Disney' 'RCS + H&M Disney'\n",
      " 'JL - Care For Water + BCI + Inditex Children' 'C&A Disney'\n",
      " 'New Look RCS' 'Inditex Children' 'BCI + RCS + H&M Disney'\n",
      " 'BCI + C&A Disney' 'BCI + C&A Warner Bros' 'H&M Disney'\n",
      " 'BCI + RCS + H&M NFL' 'BCI + H&M NFL'\n",
      " 'JL - Care for Fiber + RCS + Inditex Children' 'RCS + H&M NFL'\n",
      " 'BCI + New Look Kind' 'H&M NFL'\n",
      " 'RCS + H&M “Müşteri onayı aranmayan lisans türü” '\n",
      " 'H&M “Müşteri onayı aranmayan lisans türü” '\n",
      " 'OCS + H&M “Müşteri onayı aranmayan lisans türü” '\n",
      " 'BCI + H&M “Müşteri onayı aranmayan lisans türü” '\n",
      " 'BCI + RCS + H&M “Müşteri onayı aranmayan lisans türü”' 'H&M Hasbro'\n",
      " 'BCI + RCS + C&A Sanrio' 'BCI + RCS + C&A Disney']\n",
      "Order No eşsiz değerleri = ['H&M241061' 'H&M241062' 'H&M241063' ... 'H&M241060' 'H&M241059'\n",
      " 'ZAR240240']\n",
      "Order Geliş Tarihi\n",
      "Sisteme Giriş Tarihi\n",
      "Satır ya da Sütun M.İsteme Tarihi\n",
      "YIL\n",
      "AY\n",
      "HAFTA\n",
      "ÇEYREK eşsiz değerleri = ['Q3' 'Q2' 'Q4' 'Q1']\n",
      "Müşteri Order No eşsiz değerleri = ['969495-1636' '969665-1636' '970190-8716' ... '967870-5848' '968016-5882'\n",
      " '93447-D']\n",
      "RPT\n",
      "Açıklama eşsiz değerleri = [nan 'TOD29' 'PİLOT' 'OPD 20 TOD 24' 'carving provider 97'\n",
      " 'carving provider 98' 'carving provider 99' 'OPD W22- TOD W28'\n",
      " 'OPD W24 TOD W31' 'OPD W30 TOD W36' 'OPD27 TOD32' 'TOD 28'\n",
      " 'opd w20 tod w26' 'ROI' 'REPEAT' 'cami' 'İPTAL' 'opd 48 tod 52 online '\n",
      " 'opd 01 tod wk 05 online ' 'opd06 tod wk110 online '\n",
      " 'opd wk 46 tod wk 50  shop ' 'opd wk 50 tod wk02  shop'\n",
      " 'opd wk 07 tod wk 11 shop' 'pilot numuneleridir' 'BLACK FLORAL AOP'\n",
      " 'KENTUCKY BLUE FLORAL AOP' 'GREEN - PILOT' 'GREEN' 'COLOUR  2'\n",
      " 'COLOUR  3' '12-106 White Dusty Light' 'BRIDAL ROSE TIE DYE AOP'\n",
      " 'BRIDAL ROSE AOP' 'TEKLİ PAKETLEME- SOLID' 'PLANE' 'ASOS'\n",
      " 'özel testi var' 'CPSI TESTİ ' '07-194 grey medium dusty '\n",
      " 'white dusty light' 'beden aop' 'ense biye ;56-321' 'dıkkat beden metraj'\n",
      " 'SNOW WHITE FLORAL AOP' 'PASTEL LILAC FLORAL AOP'\n",
      " 'PİGMENT METRAJ BASKILI' 'metraj baskılı' 'ONLINE- ALARMSIZ' 'ASORTİLİ'\n",
      " 'SOLİD' 'PİLOT NUMUNESİ' 'BCI COT' 'MODEL ASİT YIKAMA+PARÇA BOYAMALIDIR'\n",
      " 'black' 'PIGMENT TIE DYE METRAJ BASKILI' 'renk referansı ' 'RCYCLE COT'\n",
      " 'pantone ' 'solid' 'asortili' 'preshipment' 'opd wk41 tod w46'\n",
      " 'opd wk 41 tod w47' 'opd wk43 tod w48' 'opd wk46  tod 51'\n",
      " 'opd wk46  tod 52' 'opd wk 40 tod 45' 'opd wk 41 tod wk 46  shop '\n",
      " 'opd wk 41 tod wk 51 shop ' 'opd  wk41 tod wk 46 online '\n",
      " 'opd wk 41 tod wk51 online ' 'opd wk 50 tod wk 03 '\n",
      " 'opd wk 41 tod wk 46 onlıne ' 'opd wk41 tod wk01 online '\n",
      " 'opd wk 45 tod wk 50 online ' 'opd wk 45 tod wk 5 online '\n",
      " 'opd wk 45 tod wk 50 ' 'opd wk 45 tod wk 5 ' 'ONLINE-ALARMSIZ'\n",
      " 'BATİK METRAJ ' 'metraj baskılı ' 'solid beden , ense süpremi 56-321'\n",
      " '18-1660tcx oldu' 'BCI cot' 'FLORAL METRAJ BASKILI'\n",
      " '2li paketleneck siyah-pembe' '2 li paketlenecek siyah-pembe' 'thsirt'\n",
      " '9000 ADET İPTAL' 'PRESHİPMENT' 'PRESHIPMENT' 'HAM BAŞLATILACAKTIR'\n",
      " 'MERLIS REC INTERLOK' 'MERLIS RECY INTERLOK' 'NEW' 'mavi' 'mavi '\n",
      " 'grimelanj' 'lacivert' 'opd wk 46 tod wk 51 online '\n",
      " 'opd wk 46 tod wk 07  online ' 'opd wk 52  tod wk 14 online '\n",
      " 'opd wk 52 tod wk 14 online ' 'opd wk 49 tod wk 11 store '\n",
      " 'opd wk49 tod wk11 store' 'opd wk 50 tod wk 12 store '\n",
      " 'opd wk 51 tod wlk 12 online ' 'opd wk 50 tod wk 11 store'\n",
      " 'opd wk 51 tod wk 12 online ' 'opd wk 50 tod wk 11 store '\n",
      " 'opd wk 46 tod wk 08 online ' 'opd wk 51 tod wk13 online '\n",
      " 'opd wk 45 tod wk 07 store' '3lü paket' 'RPT SİYAH' 'RPT  MİNK' 'LH'\n",
      " 'opd 47, tod w52 shop ' 'opd 50, tod  w3 shop ' 'opd 02, tod  w07 online'\n",
      " 'opd 50, tod w3 online' 'OPD W52,TOD W5 online ' 'OPD W52,TOD W8 online '\n",
      " 'OPD W52,TOD W5 shop' 'OPD W52,TOD W8  shop' 'OPD W48 , TOD W01 online'\n",
      " 'OPD W48, TOD W04 online ' 'opd wk 46 tod wk 07 store '\n",
      " 'opd wk 46 tod wk 07 online' 'opd wk 46 tod wk 07 onlime ' 'trial'\n",
      " 'OPD WK 46 TOD WK 07 ONLİNE ' 'OPD WK 46 TOD WK 07 store'\n",
      " 'opd wk 48 tod wk10 online ' 'aop baskılı interlok' 'opd wk 01 '\n",
      " 'MERTAJ BASKILI' 'DIKKAT 3LÜ SET ' '15k olarak revize edildi. '\n",
      " '5k olarak revize edildi. ' '3lü paket- marvel desen' 'tekli /set değil '\n",
      " 'tekli satılacak /set değil ' 'tekli satılacak ' 'teklı satılır '\n",
      " 'teklı satılır' 'TEKLI SATILACAK ' 'COLOUR-1' 'COLOUR-2'\n",
      " 'CONOSUR RPT-8 EK ADET' 'opd wk03 tod wk08 ' 'opd wk03 tod wk 15'\n",
      " 'opd wk 04 tod wk 09' 'opd wk 04 tod wk 16' 'opd wk 04 tod wk 09 '\n",
      " 'opd wk 09 tod wk 16' 'opd 04 tod wk 09 ' 'opd wk04 tod wk09 '\n",
      " 'opd wk04 tod wk 18' 'opd wk 04 tod wk 16 ' 'Solid varyant'\n",
      " 'pre shipment' 'SHOP' 'ONLINE' 'pre shıpment' 'tod wk15 online '\n",
      " 'tod wk 20 online ' 'tod wk21 online ' 'tod wk 16 shop '\n",
      " 'tod wk 18 shop ' 'tod wk 21 shop ' 'tod wk 23 shop ' 'tod wk 25 shop '\n",
      " 'online opd01 tod 06 ' 'shop opd01 tod 06 ' 'shop opd 01 tod 06 '\n",
      " 'FSS SİPARİŞİDİR ' 'solid varyant' 'SOLİD OPD WK 11 TOD WK 27'\n",
      " 'SOLİD OPD WK14 TOD WK20 ' 'SOLİD OPD WK14 TOD WK27 '\n",
      " 'SOLİD OPD 11 TOD  WK 16 ' 'SOLİD OPD WK 19 TOD WK 24 '\n",
      " 'SOLİD OPD WK 19 TOD WK 32 ' 'SOLİD OPD WK 22 TOD WK27 '\n",
      " 'SOLİD OPD WK22 TOD WK 36 ' 'SOLİD OPD WK 26 TOD WK32 '\n",
      " 'SOLİD OPD WK16 TOD WK 22 ' 'SOLİD OPD 21 TOD WK 26 '\n",
      " 'MELANJ OPD 14 TOD 20 ' 'MELANJ OPD 14 TOD 28 ' 'MELANJ OPD 19 TOD 24 '\n",
      " 'MELANJ OPD 22 TOD WK27 ' 'MELAJ OPD 12 TOD WK17 '\n",
      " 'MELANJ OPD 12 TD WK 28 ' 'FSS SİPARİŞİDİR. '\n",
      " '5584-411 SS22 RPT-18 DEN ÇEKİLECEKTİR. ' 'repeat' 'roi'\n",
      " 'adet 595 e düşürüldü. ' 'elde kalan 1. kalite fazlalıklar dahil edildi'\n",
      " 'new' '99' '96' '97' 'PİLOT NUMUNELERİDİR' 'tod wk17' 'pilot orderıdır'\n",
      " 'PİLOT NUMULERİDİR' 'pilot numuneleri' 'QUICK DRY OLMALI' 'COLOR-1'\n",
      " 'Pilot numuneleridir' 'VERY' 'ROI PO' 'ASOS WHOLE SALE'\n",
      " 'ASOS SİPARİŞİ-alarmsız'\n",
      " 'Bu yüklemede indirim var, fiyat 3,56eur olacak.' 'URBAN SAMPLES'\n",
      " 'DOLL KILL SAMPLES' 'NELLY SAMPLES' 'ASOS SAMPLE' 'DOLL KILL SAMPLE'\n",
      " 'GLENBEIGH SAMPLE' 'URBAN SAMPLE' 'GENERAL PANTS SAMPLE'\n",
      " 'DOLLS KILL SAMPLE' 'opd22 tod 27 ' 'opd w16' 'opd w26' 'opd w30'\n",
      " 'opd w32' 'opd w14' 'opd w17' 'opd w19 ' 'ROI '\n",
      " 'Online - fiyatsız, alarmsız' 'yurtdısı adetler' 'renk kodu temsilidir'\n",
      " 'TIE DYE' 'online, alarmsız, fiyatsız' 'opd 17 tod 23' 'opd17 tod 34 '\n",
      " 'Pilot numunesidir' 'pilot' 'uçak' 'yurtıcı' 'yurtdısı' 'AÇIK  ÜRÜNLER'\n",
      " 'KOLİLİ' 'alarmsız, fiyatsız online' 'KOLİLİ  ÜERÜNLER' 'KOLİLİ ÜRÜNLER'\n",
      " 'YURT DIŞI AÇIK  ÜRÜNLER' 'YURT DIŞI KOLİLİ ÜRÜNLER' 'AW COMPASSION'\n",
      " 'AW ACC BACK CIRCLE' 'AW POWER ENGINE' 'YURT İÇİ' 'YURT  DIŞI'\n",
      " 'SRS ORDER' 'alarmsız, fiyatsız' 'OPD WK 24 TOD WK29 TEK YÜKLEME '\n",
      " 'ALARMSIZ' 'PİLOT ORDER' 'ARNAVUTLUK ' 'conosour' 'AOP' 'ASOS GERMANY'\n",
      " 'ASOS US' 'EU MARKETPLACE' 'yurtiçi' 'yurtdışı' 'ORFA 6.08' 'KAFKAS 6.08'\n",
      " 'ÖZKOÇ 13.08' 'ÖZKOÇ 20.08' 'ÖZKOÇ 27.08' 'asos  us' 'asos germany'\n",
      " 'asos wholesale' 'UÇAK' 'TIR' 'COLOUR  2 - PILOT' 'COLOUR  3 - PILOT'\n",
      " 'zalando' 'Polonya yuklemesı' 'Metaho renginin aynısı'\n",
      " 'PİLOT NUMUNELERİDİR.' 'LISANSOR NUMUNELERI' 'roı' 'Rusya yuklemesı'\n",
      " 'gold' 'URBAN ORDER' 'yurtıcı sıparısı ' 'yurt dısı sıparısı'\n",
      " 'opd 35 tod 41 ' '99 asorti' '97 asorti' 'opd wk 37 tod wk 41 '\n",
      " 'deneme toplar yapılıyor' 'shop opd wk 43 tod wk48 '\n",
      " 'online opd wk43 tod wk 48 ' 'opd wk37 ' ' ' 'DOTCOM'\n",
      " 'LABDİP GÖNDERİLCEK.'\n",
      " 'KOLİLİ YÜKLEME. DOTCOM SİPARİŞİ.LABDİP ONAYI ALINACAK.' 'EU MARKEPLACE'\n",
      " 'opd w45 tod w49 - tod w08' 'opd w45 tod w49 tod w08 ' 'ASOS WHOLESALE'\n",
      " 'ASOS WHOSALE' 'PİLOT NUMUNE' 'opd 41 tod 45 ' 'opd43 tod 47'\n",
      " 'OPD 42 TOD 47 ' '97 ASORTİSİ' '99 ASORTİSİ'\n",
      " 'PİLOT OLARAK DHL İLE GÖNDERİLECEKTİR. ' 'fss ' 'pilot yüklemesidir'\n",
      " 'GENERAL PANTS SAMPLES' '20 ton ** 100.000 adet için ham kumaş'\n",
      " '10 ton ** 50.000 adet için. ' '10 ton ** 50.000 adet için'\n",
      " 'opd wk 47 tod 51 store' 'opd wk 50 tod wk 02 store '\n",
      " 'opd 02 tod 06 online ' 'pre' 'PRE-SHIPMENT' 'YURTDIŞI-AÇIK ÜRÜNLER '\n",
      " 'YUTRDIŞI -KOLİLİ ÜRÜNLER' 'YURTİÇİ-AÇIK ÜRÜNLER'\n",
      " 'YURTİÇİ-KOLİLİ ÜRÜNLER' 'YURTDIŞI-AÇIK ÜRÜNLER'\n",
      " 'YURTDIŞI-KOLİLİ ÜRÜNLER' 'YURTİÇİ-AÇIK ÜRÜNLER '\n",
      " 'YURTDIŞI-AÇIK  ÜRÜNLER' 'YURTİÇİ-AÇIK  ÜRÜNLE' 'YURTİÇİ-AÇIK ÜRÜNLE'\n",
      " 'opd 04 tod 08 ' 'opd 06 tod 11-12' 'opd 08 tod 12 ' 'opd 11 tod 15 '\n",
      " 'opd 07 tod 11 ' 'opd 03 tod 07' 'opd wk 01 tod wk 06 store '\n",
      " 'opd wk 05  tod wk 09 shop ' '97 asortisi' '99 asortisi' 'opd w50'\n",
      " 'OPD WK 05 TOD WK 09 ONLİNE ' '.' 'PINK' '1. BULK' '2. BULK' 'ZALANDO'\n",
      " 'opd 03 tod wk 07 online ' 'opd 05 tod wk 09  shop'\n",
      " 'opd 02 tod wk 06 online ' 'opd 05 tod wk 09 store '\n",
      " 'opd wk 04 tod ek 08 online ' 'opd 01 tod wk 06 store '\n",
      " 'opd 01 tod wk 06 ' 'FCA İSTANBUL ' 'SEA KCH' 'FCA İSTANBUL' 'KCH PORT'\n",
      " 'KCH PORT ' 'TRUCK GDANSKİ' 'TRUCK GDANSKI' 'opd wk 02 tod wk 06 store'\n",
      " 'TRUCK' 'TRCUK' 'SEA KCH  PORT ' 'SEA KCH PORT' 'truck' '40650-D / 1'\n",
      " '40650-D / 2' '1. KALİTELER' '42344-25/1' '42344-25/2' '42348-25 / 1'\n",
      " '42348-25 / 2' 'opd 01 tod 06 online ' 'opd 01 tod 06 store '\n",
      " 'PRUSZCZ GDANSKI  TRUCK' 'PRUSZCZ GDANSKI  TRUCK      '\n",
      " 'PRUSZCZ GDANSKI  TRUCK   ' 'opd 01 tod wk 05 ' 'GDANSKI TRUCK - Solid'\n",
      " 'GDANSKI TRUCK- 2 pack' 'Pruszcz Gdański - Solid' 'Pruszcz Gdański'\n",
      " 'PRUSZCZ GDANSKI' '42532-25/2 ' '42532-25/3' 'DOTCOM ' '42644-25/1'\n",
      " '42644-25/2' 'PİLOT YUKLEMESİDİR' 'opd 12 tod 16 ' 'opd 03 tod 07  shop '\n",
      " 'ASOS SİPARİŞİ' 'örgü başlatılabilmesi için renk seçilmiştir.' 'TOD w09'\n",
      " 'PİLOT NUMUNESİDİR. ' 'PİLOT NUMUNESİDİR.' 'ham stok'\n",
      " 'PİLOT YUKLEMESIDIR' 'sea' 'PILOT YUKLEMESIDIR' 'SOLID VARYANT'\n",
      " 'opd 22 tod 26 ' 'AOP VARYANT' 'opd 12  tod 16' 'opd12 tod 17 '\n",
      " 'opd 10 tod 17 ' 'OPD W13 - W14 // İPLİK ALINMASI İÇİN AÇILAN BOOKING'\n",
      " 'tod w17' 'OPD W13 - W14' 'tod 20' 'Zalando' 'opd 14 tod 19'\n",
      " 'opd wk 49 tod wk 02 shop' 'opd wk 49tod wk 02 online ' 'opd w13 tod w20'\n",
      " 'opd 13 tod 20' 'opd 14 tod 20 ' 'opd20 tod 24 '\n",
      " '1,5 cm 12-0812tcx, 0,6 cm 13-0840tcx olacaktır.' 'Preshipment'\n",
      " 'opd w15 tod w20' '1,5X1,5 CM SİYAH BEYAZ ÇİZGİLİ İPLİĞİ BOYALIDIR'\n",
      " 'SOLID RENK OLMALI' 'tod 27' 'tod 31 ' 'opd 18 tod 25 mşteri aradı  '\n",
      " 'opd 22tod 26' 'opd 21 tod 25 shop   ' ' opd 21 tod 25online '\n",
      " 'opd 21 tod 27 ' 'opd  21 tod 27' 'opd 21 tod 27' 'opd 39 tod 44'\n",
      " 'online opd 24 tod 30 ' 'online opd 32 tod 37' 'opd 24 tod 30 shop '\n",
      " 'opd 29 tod 34 shop ' 'online opd 30 tod 35 ' 'shop  opd 24 tod 30 '\n",
      " 'shop opd 30 tod 35 ' 'Opd w23 tod w28' 'ALPSU' 'KEPSİL'\n",
      " 'RENK BELLİ DEĞİL' 'sıfırlandı' '240 gsm' '220 gsm'\n",
      " 'siyah renk iptal oldu' 'tod 32-33-34' 'ALARMSIZ '\n",
      " 'H101CY beige melange renk' 'VCP 10' 'PRE-SHIPMENT - ALARMSIZ'\n",
      " 'ALARM OLMAYACAK ZALANDO SİPARİŞİ' 'PİLOT NUMUNEDİR' 'PİLOT NUMUNEDİR.'\n",
      " 'PİLOT YUKLEMESIDIR /UNITEKSE GONDERINIZ ' 'BU SATIR İPTAL.'\n",
      " 'opd wk 04  tod  08 online ' 'opd wk 04  tod wk 08 shop'\n",
      " 'opd w33 // tod w39-w45-w46 MELANGE VARYANT' 'opd w20 // yıkamalı ürün'\n",
      " 'opd w32 // yıkamalı ürün' 'opd w36 // yıkamalı ürün'\n",
      " 'opd w14 // yıkamalı ürün' 'opd w17 // yıkamalı ürün'\n",
      " 'opd w21 // yıkamalı ürün' 'opd w20 // AOP - yıkamasız' 'CN' 'US' 'EU'\n",
      " 'sadece iplik alımı için ' '10.000 adet' '7500 adet' '7000 adet'\n",
      " 'SEA KCH ' 'Pruszcz Gdański - 2 pack' '42532-25/1' 'ASOS '\n",
      " 'GDANSKI TRUCK - 2 pack' 'Pruszcz Gdański - 2 Pack' 'SEA KCH  PORT'\n",
      " 'H185R antrasite melange renk' 'pilot yuklemesidir ' 'PİLOT YÜKLEMESİDİR'\n",
      " 'ASLAN' 'bu satır iptal ' 'PİLOT ' 'ZALANDO- alarmsız, fiyatsız'\n",
      " 'PRUSZCS GDANSKI' '-' 'RENK YANLIŞ' 'siyah renk iptal' 'İPTAL ORDER'\n",
      " 'Pre-shipment' 'pre-shipment' 'STRIPE OPT' 'SOLID Opt' '746 - Natural'\n",
      " '800-Black' '902-Pink'\n",
      " 'orjınal po geldiğinde renk ve beden dağılımı girilecektir.'\n",
      " 'ORJ PO BEKLENIYOR' 'opd W05 // tod w10' 'opd w05 // tod w14'\n",
      " 'opd 8 / tod w14 ' 'iplik' 'CW U opd 19 Şubat  haftası'\n",
      " 'OPD W8 - TOD W14' 'OPD W9 - TOD W16 ' 'pr shipment' 'tod 17 opd?' 'UEX'\n",
      " 'tod w17 -- opd?'\n",
      " 'kalite hisar iplikte onaylı fakat forte ve save de geliştiriliyor. opd 6 Mayıs'\n",
      " 'OPD W10 /TOD W 19' 'OPD W10 /TOD W 18' 'OPD W10 /TOD W 20' 'OPD W09 '\n",
      " 'opd w12 tod w18' 'TOD W17' 'OPD W18' 'opd w14 tpd w21' 'opd w13 tod w19'\n",
      " 'opd w12 tod w21' 'opd w12 tod w19'\n",
      " 'OPD W14, renkler için l/d gidecek. Aba Tekstil'\n",
      " 'berlin antrasit renginde olacak beden rengi. opd W13' 'OPD W16 TOD W21'\n",
      " 'OPD W11' 'CW UU opd w18' 'CW UU opd w19' 'tod 17 ' 'tod 17 -- opd ? '\n",
      " 'SADECE HAM İPLİK ALIMI İÇİN AÇILDI'\n",
      " 'sadece iplik alımı için açıldı . kumaş gramaj 260 gr olacak'\n",
      " '8 ayrı baskılı varyanta ortalama 10-15k adet gelecek' 'opd 13 - tod w19'\n",
      " 'CW P OPDW13' 'CW RR opd W13' 'CW UU opd w13' 'CW Y opd W13'\n",
      " 'CW QQ opd W16' 'ISW21 / CW26' 'OPD W14 TOD19' 'OPD W14 TOD20'\n",
      " 'OPD W14 TOD21' 'OPD W14 TOD22' 'CW RR Gorillaz OPD W13' '928953-8716'\n",
      " 'OPD W21 EU SS & OL' 'OPD W22 EU SS & OL' 'OPD W23 EU SS & OL'\n",
      " 'OE SÜPREM - RİBANA  TODW20' 'oe süprem-rib // tod w20' 'OPD21 TOD28'\n",
      " 'PENYE SÜPREM-RİBANA - // TODW20' 'penye süprem-rib. / tod w20' 'OPD W17'\n",
      " 'opd 19 - tod 24' 'OPDW18 // TODW23' 'opd w18- Tod w22 '\n",
      " 'varyant belli değil opd W16' 'Quick demand varyant belli değil opd W18'\n",
      " 'opd w17 tod w22' 'OPD 23 TOD 29' 'S24' 'W24'\n",
      " 'RENK KODU HENÜZ NET DEĞİL // opd w24- tod w32 - ısw 34' 'GEMİ'\n",
      " 'TIR YÜKLEMESİ' 'UÇAK S24' '24.836 adet cw17 -good riddance - todw24'\n",
      " 'splash tod w26' 'opd w19 tod w24' 'tod33 ' 'OPD33 TOD39'\n",
      " 'OPDW20 // TOD W26' 'OPD W23/TOD W31' 'online' 'shop' 'opd w24 tod w29'\n",
      " 'opd w22 tod w27' 'opd w24 tod w29 - GELECEK OLAN KOLEKSİYON SİPARİŞLERİ'\n",
      " 'ISW 30 - TOD W29 - OPD W23' 'ISW W34 - TOD W32 - OPD W27'\n",
      " 'ISW W38 - TOD W36 - OPD W31 ' 'ISW W42 - TOD W40 - OPD W35'\n",
      " 'ISW W46 - TOD W44 - OPD W39' 'opd w18 // tod w26 - w27'\n",
      " 'opd w21 tod w26' 'splash 1035155 - tod 26' 'splash 1035155 - tod 27'\n",
      " 'splash 1035155 - tod 28' 'splash 1035155 - tod 29'\n",
      " 'splash 1035155 - opd w26 tod 30' 'splash 1035155 -opd w27  tod 31'\n",
      " 'splash 1035155 - opd w28 tod 32' 'splash 1035155 - tod 36'\n",
      " 'splash 1035155 - tod 37' 'opd26 tod31' 'opd 30 tod35' 'opd 33 tod38'\n",
      " 'opd 37 tod42 ' 'TOD 26' 'PRE SHIPMENT' 'Opd w20  tod w26 '\n",
      " 'OPD W24 TOD W31 ' 'opd w18 todw24' 'Opd w21  tod w27' 'OPD22 TOD28'\n",
      " 'opd21 tod26 ' 'splash 1035155 -opd w21 tod 24'\n",
      " 'splash  opd w25 tod w28 ' 'splash opd w25 tod w29'\n",
      " 'splash opd w26 tod w30' 'splash opd27 tod w31' 'splash opd w28 tod w32'\n",
      " 'splash opd w29 tod w33' 'splash opd w30 tod w34'\n",
      " 'splash opd w32 tod w36' 'splash opd w33 tod w37'\n",
      " 'OPDW26 TODW32 CF00719 kalan 783 adet için' 'Opd w25  tod w31'\n",
      " 'OPD W24 - TOD W29 - ISW W31' 'OPD W24 - TOD W30 - ISW32'\n",
      " 'OPD W24 - TOD W29 - ISW31 ' 'OPD W24 - TOD W29 - ISW31' 'OPD W23'\n",
      " 'OPD W22 - TOD  W28' 'OPD W21' 'OPD23 TOD29' 'OPD 24 TOD 29']\n",
      "Model Kodu eşsiz değerleri = ['H&M05802' 'H&M05772' 'H&M05852' ... 'BER01438' 'ZAR03590' 'ZAR03557']\n",
      "Model Adı eşsiz değerleri = ['BRANDY TRS' 'SUSIE Raglan Dress s0 1251087D-8716 ALT 1'\n",
      " 'ROCKY LO LIC T-SHIRT 1216163D-7952' ... '8016-174 CR-985'\n",
      " '5584-169 CONOSUR (UWM-4524) (ANIMAL PRINT)' '5584-631 (UWM-4731) ']\n",
      "Model Grup Kodu eşsiz değerleri = ['PTS' 'EBB' 'TSB' 'TSS' 'BDS' 'TSN' 'TPS' 'SWB' 'BLY' 'TPB' 'GMS' 'SG003'\n",
      " 'SWS' 'SG006' 'EBS' 'SWY' 'BLS' 'JCS' 'ETS' 'JCB' 'JCN' 'ATS' 'CRS' 'SRS'\n",
      " 'CRB' 'LGS' 'TKB' 'TLS' 'BDB' 'TKS' 'JGS' 'SWN' 'TPN' 'TSY' 'JGB' 'PTB'\n",
      " 'JGY' 'LGB' 'BLB' 'SRB' 'BRS' 'ATY' 'ATB' 'TLB' 'BLN' 'ETY' 'EBY' 'TPY'\n",
      " 'JGN' 'GMB' 'EBN' 'SG004' 'LGY' 'CBT' 'ETB' 'BDN' 'BDY' 'ATN' 'ACS' 'ETN']\n",
      "Model Grup Adı eşsiz değerleri = ['Solid Pantolon' 'Baskılı Elbise' 'Baskılı Tshirt' 'Solid Tshirt'\n",
      " 'Solid Body' 'Nakışlı Tshirt' 'Solid Top' 'Baskılı Sweatshirt'\n",
      " 'Yıkamalı Bluz' 'Baskılı Top' 'Solid Gömlek' 'Kapşonlu Sweatshirt'\n",
      " 'Solid Sweatshirt' 'Süveter' 'Solid Elbise' 'Yıkamalı Sweatshirt'\n",
      " 'Solid Bluz' 'Solid Jacket' 'Solid Etek' 'Baskılı Jacket'\n",
      " 'Nakışlı Jacket' 'Solid Atlet' 'Solid Cardigan' 'Solid Şort'\n",
      " 'Baskılı Cardigan' 'Solid Legging' 'Baskılı Set/Takım' 'Solid Tulum'\n",
      " 'Baskılı Body' 'Solid Set/Takım' 'Solid Jogger' 'Nakışlı Sweatshirt'\n",
      " 'Nakışlı Top' 'Yıkamalı Tshirt' 'Baskılı Jogger' 'Baskılı Pantolon'\n",
      " 'Yıkamalı Jogger' 'Baskılı Legging' 'Baskılı Bluz' 'Baskılı Şort'\n",
      " 'Solid Bra' 'Yıkamalı Atlet' 'Baskılı Atlet' 'Baskılı Tulum'\n",
      " 'Nakışlı Bluz' 'Yıkamalı Etek' 'Yıkamalı Elbise' 'Yıkamalı Top'\n",
      " 'Nakışlı Jogger' 'Baskılı Gömlek' 'Nakışlı Elbise' 'Üst'\n",
      " 'Yıkamalı Legging' 'Cepli Basic Tshirt' 'Baskılı Etek' 'Nakışlı Body'\n",
      " 'Yıkamalı Body' 'Nakışlı Atlet' 'Solid Accessories' 'Nakışlı Etek']\n",
      "Model Group Name eşsiz değerleri = ['Solid Trousers' 'Printed Dress' 'Printed Tshirt' 'Solid Tshirt'\n",
      " 'Solid Body' 'Embroidared Tshirt' 'Printed Sweatshirt' 'Washed Blouse'\n",
      " 'Solid Shirt' 'Hooded Sweatshirt ' 'Solid Sweatshirt' 'Sweater '\n",
      " 'Solid Dress' 'Washed Sweatshirt' 'Solid Blouse' 'Solid Jacket'\n",
      " 'Solid Skirt' 'Printed Jacket' 'Embroidared Jacket' 'Solid Tanktop'\n",
      " 'Solid Cardigan' 'Solid Shorts' 'Printed Cardigan' 'Solid Legging'\n",
      " 'Printed Set' 'Solid Jumpsuit' 'Printed Body' 'Solid Set'\n",
      " 'Embroidared Sweatshirt' 'Washed Tshirt' 'Printed Trousers'\n",
      " 'Washed Trousers' 'Printed Legging' 'Printed Blouse' 'Printed Shorts'\n",
      " 'Solid Bra' 'Washed Tanktop' 'Printed Tanktop' 'Printed Jumpsuit'\n",
      " 'Embroidared Blouse' 'Washed Skirt' 'Washed Dress' 'Embroidared Trousers'\n",
      " 'Printed Shirt' 'Embroidared Dress' 'Top ' 'Washed Legging'\n",
      " 'Pocket Tshirt' 'Printed Skirt' 'Embroidared Body' 'Washed Body'\n",
      " 'Embroidared Tanktop' 'Solid Accessories' 'Embroidared Skirt']\n",
      "Sezon eşsiz değerleri = ['H&M S 0' nan 'W24' 'H&M S 9' 'I-24' 'SS24' 'H&M S 7' 'H&M S 6' 'FW22'\n",
      " 'AW22' 'WINTER22' 'H&M S 5' 'SS23' 'SS22' 'AW21' 'H&M S 4' 'WINTER21'\n",
      " 'SS21' 'SUMMER22' '5' 'I-22' 'AW23' 'OAW22' 'W22' 'FW23' 'OSS23' '7'\n",
      " 'H&M S 8' '8' 'WINTER23' 'AW24' 'ss24' '9' '0' 'V24' 'S24']\n",
      "Müşteri eşsiz değerleri = ['H&M' 'ITX TRADING S.A' 'C&A Buying GmbH & Co. KG' 'New Look'\n",
      " 'LPP COMPANY' 'ASDA STORES LIMITED' 'WE Fashion' 'PRIMARK LIMITED'\n",
      " 'BERSHKA BSK ESPANA S.A.' 'BRANDDESING SA' 'INDITEX' 'Motelrocks UK Ltd'\n",
      " 'BRAVADO MERCHANDISE A DIVISION OF UNIVERSAL MUSIC GMBH' 'LC Waikiki'\n",
      " 'UNIVERSAL MUSIC SPAIN S.L.U'\n",
      " 'TUVAL SANAT GALERİSİ TEKS.TUR.SAN.TİC.LTD.ŞTİ.' 'MERCH TRAFFIC'\n",
      " 'COTTON DIVISION' 'ÜNİTEKS TEKSTİL GIDA SAN DIŞ TİC. A.Ş'\n",
      " 'PARK AGENCIES LTD' 'PRIMARK STORES LTD']\n",
      "Marka eşsiz değerleri = ['H&M' 'Zara' 'C&A' 'Bershka' 'New Look' 'Reserved' 'GEORGE'\n",
      " 'Stradivarius' 'WE Fashion' 'Primark' 'BRANDDESING SA' 'TREADLER'\n",
      " 'Motel Rocks' 'BRAVADO' 'Lc Waikiki'\n",
      " 'TUVAL SANAT GALERİSİ TEKS.TUR.SAN.TİC.LTD.ŞTİ.' 'Uniteks']\n",
      "Departman eşsiz değerleri = ['Hennes-Everyday-Tops (1636)' 'Young Girl (8716)' 'Divided Blue (7952)'\n",
      " 'Trf' 'H&M Men (5828)' 'Divided Collection Tops (1640)' 'Kids (344)'\n",
      " 'Divided Blue-Basic (5882)' 'Women Top' 'Dubbster-Young Boys (8748)'\n",
      " 'Boys (7648)' 'Men Premium' 'Men Basic' 'Men Light Graphic Jersey(7272)'\n",
      " 'Men Top' 'Yessica Basic' 'Sports (8490)' 'Bershka Sweatshirt' 'Women '\n",
      " 'HM Plus (1919)' 'Basic' 'LOGG Ladies (1660)' 'Kids Set & Dress (354)'\n",
      " 'Young Girl (8718)' 'Clockhouse' 'Men Street' 'Kids 915 '\n",
      " 'LOGG Ladies Basic (1670)' 'Clockhouse Boys' 'Yessica Shop'\n",
      " 'Divided Dress (1343)' 'Divided White (1644)' 'Men Tshirt'\n",
      " 'Hennes-Everyday-Basic (1676)' 'License Boys (7659)'\n",
      " 'Class 660-ClockHouse OL' 'Clockhouse Boys (707)' 'Divided White (1343)'\n",
      " 'Girls Legging' 'Maternity' 'Basic Top ' 'Women Bottom'\n",
      " 'Small Girls (7618)' 'Divided Plus (1652)' 'Girl Outdoor (7819)'\n",
      " 'Divided Tops Wowen (1543)' 'Ladies Jogging Top Sweat Set' 'Mama (2032)'\n",
      " 'BOYS' 'Tight (3608)' 'Young Boys (7848)' 'Men Soft'\n",
      " 'Kids Boy Project(8854)' 'HM Sport (8316)' 'Stradivarius'\n",
      " 'Ladies Top Jersey Hanging' 'Girls Skirt' 'Sweat Bottoms' 'Trend (1641)'\n",
      " 'Ladies Top' 'Kids Bottom (334)' 'Young Girl (8815)' 'BERSHKA'\n",
      " 'Women Conosur' 'LOGG Men-Heavyknit (5858)' 'Kids Exclusive (7757)'\n",
      " 'Ladies  Dress' 'Girls Dress' 'Active Wear (283)' 'Cut & Sewn'\n",
      " 'Girls Sweat' 'Small Girls (7922)' 'Small Girls (7616)'\n",
      " 'Innovation (7020)' 'Yessica Shop Bottoms (144)' 'LISANS' 'Baby' 'Casual'\n",
      " 'Divided  Test(4091)' 'Trf Conosur' 'Sport (280)' 'Dress & Skirt'\n",
      " 'Dress (260)' 'Soft Wowen' 'NPG LADIES' 'Girls Jogging Top' 'Weav (9740)'\n",
      " 'Boys Fleece' 'Boys Tshirt' 'Extreme Class (233) / Ladies Nightwear'\n",
      " 'Weekday Trousers (8404)' 'MAN PROJECTS (5771)' 'Ladies'\n",
      " 'MAN PROJECTS 2 (5741)' 'Clockhouse XL' 'Weekday Women (8121)'\n",
      " 'Boys Pant' 'Sweat Tops' 'MEN GYMWEAR' 'Divided White (1743)'\n",
      " 'Projects & Occasion (1545)' 'Ladies Clothing (08-28-81)'\n",
      " 'Underwear (1336)' 'CLK' 'KADIN ÖRME' 'Weekday Men(8201)'\n",
      " 'Divided Collection Dresses (1344)' 'Skirt/Pant ' 'NPG - Caslon'\n",
      " 'TUVAL SANAT GALERISI' 'Dress' 'Baby Basic (6515)' 'Young Boy (8768)'\n",
      " 'Campaing (3090)' 'Bershka Lisans' 'Arge' 'LOGG Men-Basic (5868)'\n",
      " 'South Hub(3010)' 'Baby Exclusive(6557)' 'Sport (8310) '\n",
      " 'Divided Black -Basic(1643)' 'Boy (7668)' 'Yessica Dress (024)' 'UNITEKS'\n",
      " 'Small Girl Basic (7920)' 'Men Jogging Top/Knitted Trousers'\n",
      " 'Berhska Bottom' 'Sport MEN (8558)' 'Sport MEN (8394)' 'LOGG Men (5848)'\n",
      " 'Hennes-Everyday- Dress/Skirt (1322)' 'Sport Kids (6283) ' 'Girls Tshirt'\n",
      " 'Toddler (346)' 'Light Basic Jersey (5832)'\n",
      " 'Divided Collection -Basic (1645)' 'G21' 'Basic Big  Girl (7930)'\n",
      " 'Small Boys License(7878)' 'Sports Kids Girl (6280)' 'MONKI (3301) '\n",
      " 'MONKI (3304)' 'Divided Collection Skirt (1444)' 'MONKI (3306)'\n",
      " 'Weekday Women (8401)' 'Heavy Graphic Jersey(7273)'\n",
      " 'Kids Boys Top Toddler(446)' 'Canda Men (603)'\n",
      " 'Toddler Set & Dress (356)' 'Monki-dress (3307)' 'Kids Boy (7656)']\n",
      "Tedarik Grubu eşsiz değerleri = ['TBC 1' '11-109' '10-204' ... '77-214' '76-206' '13-218']\n",
      "Ülke Kodu eşsiz değerleri = ['TR' 'LH' 'OE' 'OF' 'OG' 'OO' 'SW' 'BE' 'CA' 'CH' 'CO' 'DE' 'DK' 'EC'\n",
      " 'GB' 'HR' 'IX' 'ME' 'MX' 'PA' 'PL' 'RS' 'SE' 'US' nan 'OE PLW237' 'OT'\n",
      " 'DR' 'LD-L3' 'OD' 'OU' 'SW PLW067' 'OB' 'AT' 'OL' 'ES' 'FR' 'NL' 'SK'\n",
      " 'OI' 'OJ' 'OK' 'NH' 'AU' 'CL' 'PE' 'UY' 'ZA' 'TH' 'VN' 'OE NLW174'\n",
      " 'THW263' 'LH ITW128' 'SW SEW065' 'IDW262' 'OE PLW067' 'OF ITW128' 'OR'\n",
      " 'OF ESW267' 'CN' 'DC' 'HK' 'ID' 'IN' 'JP' 'KR' 'MY' 'PH' 'TW' 'LH PLW256'\n",
      " 'NO' 'RU' 'OU USW068' 'NZ' 'OU USW305' 'UK' 'IB' 'NE1-MGB' 'NE2-BOR'\n",
      " 'ROI' 'ROO' 'USA' 'OE DEW255' 'ITW018' 'EW' 'WC' 'DD (WAYR7)' 'OW'\n",
      " 'NUM-IT' 'NUM-PL' 'NUM-HR' 'MP' 'MRC' 'EB' 'GPG' 'PP' 'OG GBW264' 'WW'\n",
      " 'BARCELONA' 'EJ' 'OI-LO' 'Pruszcz Gdanski' 'KCH Port' 'UK Trial' 'EM'\n",
      " 'YM' 'MJ' 'LO' 'EI' 'WM DED002' 'NB' 'WM GBD001' 'WM' 'BEW014-BE'\n",
      " 'BEW015-BE' 'ESW038' 'WW DED002' 'WW GBD001']\n",
      "Sipariş Adedi\n",
      "Döviz Türü eşsiz değerleri = ['EUR' 'YOK!' 'GBP' 'USD' 'TL']\n",
      "Döviz Birim Fiyat\n",
      "Döviz Ciro\n",
      "EUR Ciro\n",
      "Etüt Makina Dk\n",
      "Toplam Etüt Makina Dk\n",
      "Etüt Dk\n",
      "Toplam Etüt Dk\n",
      "MA_WorkOrder_RecId\n",
      "NetsisProjectCode eşsiz değerleri = ['HM01' 'ZR05' 'CA04' 'BM06' 'ING09' 'ZR08']\n",
      "Booking Statüsü eşsiz değerleri = ['Tedarik' nan 'Kapasite']\n",
      "Order Tipi - Durum eşsiz değerleri = ['Firm Order - Açık' 'Booking Order - Açık' 'Booking Order - Kapalı'\n",
      " 'Firm Order - Kapalı']\n"
     ]
    },
    {
     "name": "stderr",
     "output_type": "stream",
     "text": [
      "C:\\Users\\halilibrahim.hatun\\AppData\\Local\\Temp\\ipykernel_40316\\3284079472.py:2: FutureWarning: is_categorical_dtype is deprecated and will be removed in a future version. Use isinstance(dtype, CategoricalDtype) instead\n",
      "  if siparis_df[column].dtype == 'object' or pd.api.types.is_categorical_dtype(siparis_df[column]):\n"
     ]
    }
   ],
   "source": [
    "for column in siparis_df.columns:\n",
    "    if siparis_df[column].dtype == 'object' or pd.api.types.is_categorical_dtype(siparis_df[column]):\n",
    "        print(f\"{column} eşsiz değerleri = {siparis_df[column].unique()}\")\n",
    "    else:\n",
    "        print(f\"{column}\")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 12,
   "id": "37855851-379b-40b2-ac20-0d68a6a9191f",
   "metadata": {},
   "outputs": [
    {
     "name": "stderr",
     "output_type": "stream",
     "text": [
      "C:\\Users\\halilibrahim.hatun\\Documents\\venvs\\uniteks_cpu\\Lib\\site-packages\\langchain_core\\_api\\deprecation.py:139: LangChainDeprecationWarning: The class `ChatOpenAI` was deprecated in LangChain 0.0.10 and will be removed in 0.2.0. An updated version of the class exists in the langchain-openai package and should be used instead. To use it run `pip install -U langchain-openai` and import as `from langchain_openai import ChatOpenAI`.\n",
      "  warn_deprecated(\n"
     ]
    }
   ],
   "source": [
    "from langchain.chat_models import ChatOpenAI\n",
    "\n",
    "def get_gpt_llm():\n",
    "    chat_params = {\n",
    "        \"model\": \"gpt-4o\", # Bigger context window\n",
    "        \"openai_api_key\": os.environ['OPENAI_API_KEY'],\n",
    "        \"temperature\": 0.2, # To avoid pure copy-pasting from docs lookup\n",
    "        \"max_tokens\": 4096 \n",
    "    }\n",
    "    llm = ChatOpenAI(**chat_params)\n",
    "    return llm\n",
    "\n",
    "llm = get_gpt_llm()"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "034be63e-45c2-4409-8081-b0c7f2dbf25b",
   "metadata": {},
   "source": [
    "## Main Router"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 167,
   "id": "f24669e0-5049-44a7-b6d0-197916102e5e",
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "'MongoDB'\n",
      "The time required to generate response by Router Chain in seconds:0.6642029285430908\n"
     ]
    }
   ],
   "source": [
    "prompt = PromptTemplate(\n",
    "    template=\"\"\"'Rol': sistem, 'İçerik': Sen bir yönlendiricisin. Görevin gelen isteği uygun kategoriye yönlendirmek. \n",
    "\n",
    "    Eğer gelen mesaj kolonları ve ilgili verileri*['Order No', 'Model Kodu', 'Model Adı', 'Müşteri', 'Bölüm', 'Tedarikçi',\n",
    "       'Müşteri Order No', 'Rpt', 'Marka', 'Renk Kodu', 'İşlem', 'RSN',\n",
    "       'Tarih', 'Adet', 'Kumaş', 'Kumaş Tipi', 'Kalite Tipi'] olan şirketin H&M, ZARA, Bershaka gibi markalara olan\n",
    "       üretim* verilerini gösteren bir mesaj ise veya\n",
    "\n",
    "       kolonları *['Durum', 'Statü', 'Booking -> Order', 'Set Order', 'Set Parça Sayısı',\n",
    "       'Order Tipi', 'Booking Type', 'Order Grubu', 'Satış Tipi',\n",
    "       'Sertifikasyon', 'Order No', 'Order Geliş Tarihi',\n",
    "       'Sisteme Giriş Tarihi', 'Satır ya da Sütun M.İsteme Tarihi', 'YIL',\n",
    "       'AY', 'HAFTA', 'ÇEYREK', 'Müşteri Order No', 'RPT', 'Açıklama',\n",
    "       'Model Kodu', 'Model Adı', 'Model Grup Kodu', 'Model Grup Adı',\n",
    "       'Model Group Name', 'Sezon', 'Müşteri', 'Marka', 'Departman',\n",
    "       'Tedarik Grubu', 'Ülke Kodu', 'Sipariş Adedi', 'Döviz Türü',\n",
    "       'Döviz Birim Fiyat', 'Döviz Ciro', 'EUR Ciro', 'Etüt Makina Dk',\n",
    "       'Toplam Etüt Makina Dk', 'Etüt Dk', 'Toplam Etüt Dk',\n",
    "       'MA_WorkOrder_RecId', 'NetsisProjectCode', 'Booking Statüsü',\n",
    "       'Order Tipi - Durum'] olan şirketin sipariş durumları hakkında* verileri gösteren bir mesaj ise bu mesaja yanıt olarak sadece 'PostgreSQL',\n",
    "      \n",
    "       \\n\\n\n",
    "\n",
    "\n",
    "    Eğer gelen mesaj *kişilerin adı, soyad, departman, semt/oturduğu yer, işe giriş tarihi, izin hakkı, kullandığı izin sayısı, gibi bilgileri ve \n",
    "    servis plakası, şoför adı/kimin sürdüğü veya kullandığı, servisin konumu veya nereye gittiği* hakkındaki bilgilerden herhangi \n",
    "    biri içeriyorsa yanıt olarak sadece 'MongoDB',\n",
    "\n",
    "    \\n\\n\n",
    "\n",
    "    Eğer gelen mesaj *ERP prosedürü ile ilgili veya seyahat prosedürü ile ilgili veya temsili/misafir ve ağırlama prosedürü* ile ilgiliyse \n",
    "    yanıt olarak sadece 'ChromaDB',\n",
    "\n",
    "    \\n\\n\n",
    "\n",
    "    Eğer gelen mesaj yukarıdakilerin hiçbiriyle hiç bir şekilde alakalı değilse senin işinin Logos şirketi için çalışmak olduğunu ve bu tür\n",
    "    sorulara cevap veremeyeceğini söyle, eğer gelen mesaj yukarıdakilerle biraz alakalı ama tam değil. Biraz daha detaylandırması için konuyla \n",
    "    ilgili sorular sor\n",
    "    \n",
    "    \\n\\n\\n\n",
    "\n",
    "    Eğer kişi sıradan bir sohbet şeklinde konuşursan yanıt olarak sadece 'Daily' dön\n",
    "    \n",
    "    'Rol': Kullanıcı, 'İÇerik': {question},\n",
    "\n",
    "    \\n\\n\\n\n",
    "    \n",
    "    'Rol': asistan, 'İçerik': \n",
    "    \"\"\",\n",
    "    input_variables=[\"question\"],\n",
    ")\n",
    "start = time.time()\n",
    "main_router = prompt | llm \n",
    "\n",
    "\n",
    "question = \"Tasarım departmanında çalışn soyadı teveoğlu olna kişi kimdir\"\n",
    "print(main_router.invoke({\"question\": question}).content)\n",
    "end = time.time()\n",
    "print(f\"The time required to generate response by Router Chain in seconds:{end - start}\")\n"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "a43ca561-4a38-4656-9574-8ac072b986a9",
   "metadata": {},
   "source": [
    "## MongoDB Router"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 982,
   "id": "eb70ad77-2228-4ca0-8d4b-dd29f13ab218",
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "İzin\n",
      "The time required to generate response by the retrieval grader in seconds:0.5963199138641357\n"
     ]
    }
   ],
   "source": [
    "prompt = PromptTemplate(\n",
    "    template=\"\"\"'Rol': sistem, 'İçerik': Sen çalışan, izin ve servis yapılarını yönlendiren bir yönlendiricisin. \n",
    "\n",
    "    Eğer içerikte kişinin adı, soyadı, departmanı, semti ve işe giriş tarihi özelliklerinin herhangi biri kullanılırsa çıktı olarak sadece 'Çalışan',\n",
    "    \\n\\n\n",
    "    Eğer içerikte kişisel bilgilerin yanında, kişinin ne kadar izin hakkı olduğu, kişinin izin hakkı sayısı, kullanılan izin sayısı, kazanılan izin hakkı sayısı özelliklerinden herhangi\n",
    "    biri varsa çıktı olarak sadece 'İzin',\n",
    "    \\n\\n\n",
    "    Eğer içerikte servislerle ilgili servis plakası, soförünün adı, servisin gideceği yer/konum özelliklerinin herhangi biri varsa çıktı olarak 'Servis'\n",
    "    dön.\n",
    "    \\n\\n\n",
    "    \n",
    "\n",
    "    \\n\\n\\n\n",
    "    \n",
    "    'Rol': kullanıcı, 'İçerik': {question}\n",
    "\n",
    "    \\n\\n\\n\n",
    "\n",
    "    'Rol': asistan, 'İçerik': \n",
    "    \"\"\",\n",
    "    input_variables=[\"question\"],\n",
    ")\n",
    "start = time.time()\n",
    "mongodb_router = prompt | llm \n",
    "\n",
    "\n",
    "question = \"Tatil  ne kadar\"\n",
    "print(mongodb_router.invoke({\"question\": question}).content)\n",
    "end = time.time()\n",
    "print(f\"The time required to generate response by the retrieval grader in seconds:{end - start}\")"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "31357b0e-8bcf-4d21-9078-9c03405d44bb",
   "metadata": {},
   "source": [
    "## PostreSQL Router"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "2971e450-a7e3-4563-8def-67ddf1286bec",
   "metadata": {},
   "source": [
    "It will be modified"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 794,
   "id": "e19d525a-1068-4349-ad4f-fb53480da178",
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Merhaba, siparişinizin durumu hakkında size yardımcı olabilmem için lütfen daha fazla bilgi verebilir misiniz? Örneğin, sipariş numaranız veya siparişinizle ilgili diğer detaylar nelerdir? Bu bilgilerle size daha doğru ve hızlı bir şekilde yardımcı olabilirim. Teşekkürler!\n",
      "The time required to generate response by the retrieval grader in seconds:1.3172378540039062\n"
     ]
    }
   ],
   "source": [
    "prompt = PromptTemplate(\n",
    "    template=\"\"\"'Rol': sistem, 'İçerik': Sen bir yönlendiricisin. Görevin gelen isteği uygun kategoriye yönlendirmek. \n",
    "\n",
    "    Eğer gelen mesaj kolonları ve ilgili verileri *['Order No', 'Model Kodu', 'Model Adı', 'Müşteri', 'Bölüm', 'Tedarikçi',\n",
    "       'Müşteri Order No', 'Rpt', 'Marka', 'Renk Kodu', 'İşlem', 'RSN',\n",
    "       'Tarih', 'Adet', 'Kumaş', 'Kumaş Tipi', 'Kalite Tipi'] olan şirketin H&M, ZARA, Bershaka gibi markalara olan\n",
    "       Üretim* verilerini gösteren bir mesaj ise sadece 'Üretim',\n",
    "    \\n\\n\n",
    "    Eğer gelen mesaj, kolonları  *['Durum', 'Statü', 'Booking -> Order', 'Set Order', 'Set Parça Sayısı',\n",
    "       'Order Tipi', 'Booking Type', 'Order Grubu', 'Satış Tipi',\n",
    "       'Sertifikasyon', 'Order No', 'Order Geliş Tarihi',\n",
    "       'Sisteme Giriş Tarihi', 'Satır ya da Sütun M.İsteme Tarihi', 'YIL',\n",
    "       'AY', 'HAFTA', 'ÇEYREK', 'Müşteri Order No', 'RPT', 'Açıklama',\n",
    "       'Model Kodu', 'Model Adı', 'Model Grup Kodu', 'Model Grup Adı',\n",
    "       'Model Group Name', 'Sezon', 'Müşteri', 'Marka', 'Departman',\n",
    "       'Tedarik Grubu', 'Ülke Kodu', 'Sipariş Adedi', 'Döviz Türü',\n",
    "       'Döviz Birim Fiyat', 'Döviz Ciro', 'EUR Ciro', 'Etüt Makina Dk',\n",
    "       'Toplam Etüt Makina Dk', 'Etüt Dk', 'Toplam Etüt Dk',\n",
    "       'MA_WorkOrder_RecId', 'NetsisProjectCode', 'Booking Statüsü',\n",
    "       'Order Tipi - Durum'] olan ve şirketin sipariş durumları hakkında* verileri gösteren bir mesaj ise bu mesaja yanıt\n",
    "       olarak sadece 'Sipariş' dön\n",
    "    \\n\\n\n",
    "    Eğer çok belirleyici bir istem gelmediyse konuya bağlı olarak detaylandırmasını kibarca iste\n",
    "\n",
    "    \\n\\n\\n\n",
    "    \n",
    "    'Rol': kullanıcı, 'İçerik': {question}\n",
    "\n",
    "    \\n\\n\\n\n",
    "\n",
    "    'Rol': asistan, 'İçerik': \n",
    "    \"\"\",\n",
    "    input_variables=[\"question\"],\n",
    ")\n",
    "start = time.time()\n",
    "postgresql_router = prompt | llm \n",
    "\n",
    "\n",
    "question = \"Ürün durumunu öğrenmek sitiyorum. siparişim nerede\"\n",
    "print(postgresql_router.invoke({\"question\": question}).content)\n",
    "end = time.time()\n",
    "print(f\"The time required to generate response by the retrieval grader in seconds:{end - start}\")"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "5ff750d8-b21a-460c-aebb-f25682cb7f09",
   "metadata": {},
   "source": [
    "## MongoDB Definings"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "49c236fc-06c6-46e4-a9c8-b8bfc7f98dfe",
   "metadata": {},
   "source": [
    "#### A. Mongo (Atlas)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 995,
   "id": "0dc5957d-a099-4878-be62-2318b8183a07",
   "metadata": {},
   "outputs": [],
   "source": [
    "from pymongo import MongoClient\n",
    "\n",
    "\n",
    "class AtlasClient():\n",
    "    \"\"\"\n",
    "    Atlas (Mongo) class to run vector search algorithm.\n",
    "    \n",
    "    \"\"\"\n",
    "    def __init__ (self, altas_uri, dbname):\n",
    "       self.mongodb_client = MongoClient(altas_uri)\n",
    "       self.database = self.mongodb_client[dbname]\n",
    "    \n",
    "    \n",
    "    ## A quick way to test if we can connect to Atlas instance\n",
    "    def ping (self):\n",
    "       self.mongodb_client.admin.command('ping')\n",
    "    \n",
    "    \n",
    "    def get_collection (self, collection_name):\n",
    "       collection = self.database[collection_name]\n",
    "       return collection\n",
    "    \n",
    "    \n",
    "    def find (self, collection_name, filter = {}, limit=10):\n",
    "       collection = self.database[collection_name]\n",
    "       items = list(collection.find(filter=filter, limit=limit))\n",
    "       return items\n",
    "    \n",
    "    \n",
    "    def vector_search(self, collection_name, index_name, attr_name, embedding_vector, limit=5):\n",
    "       collection = self.database[collection_name]\n",
    "       results = collection.aggregate([\n",
    "           {\n",
    "               '$vectorSearch': {\n",
    "                   \"index\": index_name,\n",
    "                   \"path\": attr_name,\n",
    "                   \"queryVector\": embedding_vector,\n",
    "                   \"numCandidates\": 50,\n",
    "                   \"limit\": limit,\n",
    "               }\n",
    "           },\n",
    "           ## We are extracting 'vectorSearchScore' here\n",
    "           ## columns with 1 are included, columns with 0 are excluded\n",
    "           {\n",
    "               \"$project\": {\n",
    "                   '_id' : 1,\n",
    "                   'Element_Description' : 1,\n",
    "                   \"search_score\": { \"$meta\": \"vectorSearchScore\" }\n",
    "           }\n",
    "           }\n",
    "           ])\n",
    "       return list(results)\n",
    "    \n",
    "    \n",
    "    def close_connection(self):\n",
    "       self.mongodb_client.close()"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "885597b7-5b4a-46f7-b54a-12e71f46c739",
   "metadata": {},
   "source": [
    "#### B. OpenAI"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 996,
   "id": "a0804ae4-3945-4f52-8aa5-c25753411074",
   "metadata": {},
   "outputs": [],
   "source": [
    "class OpenAIClient():\n",
    "    \"\"\"\n",
    "    Open AI class that will be used for RAG\n",
    "    \n",
    "    \"\"\"\n",
    "    def __init__(self, api_key) -> None:\n",
    "       self.client = OpenAI(\n",
    "           api_key= api_key,  # defaults to os.environ.get(\"OPENAI_API_KEY\")\n",
    "       )\n",
    "       # print (\"OpenAI Client initialized!\")\n",
    "    \n",
    "\n",
    "    \n",
    "    def get_embedding(self, text: str,  model=\"text-embedding-3-large\") -> list[float]:\n",
    "       text = text.replace(\"\\n\", \" \")\n",
    "       resp = self.client.embeddings.create (\n",
    "           input=[text],\n",
    "           model=model  )\n",
    "    \n",
    "    \n",
    "       return resp.data[0].embedding"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "0f93a697-c249-4a85-8f0f-de010e7475aa",
   "metadata": {},
   "source": [
    "## RAG_Generator"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 997,
   "id": "23d4da4d-58c9-46b5-9bb9-222b0c132365",
   "metadata": {},
   "outputs": [],
   "source": [
    "## Continue\n",
    "\n",
    "prompt = PromptTemplate(\n",
    "    template=\"\"\"'Rol': Sistem, 'İçerik': Sen Logos şirketine yardımcı olmayı ve iş süreçlerini kolaylaştıran bir sanal asistansın. \n",
    "    Aşağıda üç tırnaklar arasında verilen soruyu, <> işaretleri arasında verilen kaynağa göre yardımsever ve açıklayıcı bir biçimde açıkla. \n",
    "\n",
    "    Eğer verilen dokümandan herhangi bir bilgi bulamazsan. Bunu kibarca belirt.\n",
    "    \n",
    "    \\n\\n\\n\n",
    "    \n",
    "    'Rol': Kullanıcı, 'İçerik': \n",
    "    Soru: ```{question}```\n",
    "\n",
    "    Kaynak: <{documents}>.\n",
    "    \n",
    "    \\n\\n\\n\n",
    "\n",
    "    'Rol': Asistan, 'İçerik':\n",
    "    \"\"\",\n",
    "    input_variables=[\"question\", \"documents\"],\n",
    ")\n",
    "\n",
    "\n",
    "rag_generator = prompt | llm \n",
    "# print(mongodb_router.invoke({\"question\": question}).content)"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "0b59f8d5-4c25-4527-92ce-7a248c015eb0",
   "metadata": {},
   "source": [
    "## Casual Generator"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 998,
   "id": "8c93a94a-3196-45ba-bae6-68abd31fcab3",
   "metadata": {},
   "outputs": [],
   "source": [
    "## Continue\n",
    "\n",
    "prompt = PromptTemplate(\n",
    "    template=\"\"\"'Rol': Sistem, 'İçerik': Sen kişiyle gündelik hayat ile ilgili muhabbet etmeyi amaçlayan bir sanal asistansın. \n",
    "    Kişiye karşı kibar davran ve üç tırnaklar arasında verilen soruyu yanıtla\n",
    "    \n",
    "    \\n\\n\\n\n",
    "    \n",
    "    'Rol': Kullanıcı, 'İçerik': \n",
    "    Soru: ```{question}```\n",
    "    \n",
    "    \\n\\n\\n\n",
    "\n",
    "    'Rol': Asistan, 'İçerik':\n",
    "    \"\"\",\n",
    "    input_variables=[\"question\"],\n",
    ")\n",
    "\n",
    "\n",
    "casual_generator = prompt | llm \n"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "08f71c58-dea4-4307-bc79-0826e8f41c1d",
   "metadata": {},
   "source": [
    "# Defining Nodes"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 999,
   "id": "4bc9b7b2-9a47-448d-a124-42cea8022406",
   "metadata": {},
   "outputs": [],
   "source": [
    "from typing_extensions import TypedDict\n",
    "from typing import List\n",
    "from langchain.schema import Document\n",
    "\n",
    "class GraphState(TypedDict):\n",
    "    question : str\n",
    "    generation : str\n",
    "    documents : List[str]\n",
    "    condition: str"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1000,
   "id": "8cf1d71a-bc17-492a-bcf4-00518e4a63ee",
   "metadata": {},
   "outputs": [],
   "source": [
    "class MyConfig(object):\n",
    "   pass"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "091d1e57-47ce-4e6c-82d7-9725d5a06dd7",
   "metadata": {},
   "source": [
    "### PostgreSQL Node Class"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1033,
   "id": "c67b695d-36b5-4d7c-9079-69ae11ab4b81",
   "metadata": {},
   "outputs": [],
   "source": [
    "class PostgreNodeClass():\n",
    "    def __init__(self, postgresql_router):\n",
    "    \n",
    "        # Define router\n",
    "        self.postgresql_router = postgresql_router\n",
    "        print(env_vars)\n",
    "        self.POSTGRE_DATABASE_NAME = env_vars.get('DATABASE_NAME')\n",
    "        self.POSTGRE_DATABASE_USER = env_vars.get('DATABASE_USER')\n",
    "        self.POSTGRE_DATABASE_PASSWORD = env_vars.get('DATABASE_PASSWORD')\n",
    "        self.POSTGRE_DATABASE_HOST = env_vars.get('DATABASE_HOST')\n",
    "        self.OPENAI_API_KEY = env_vars.get('OPENAI_API_KEY')\n",
    "        print(self.POSTGRE_DATABASE_NAME)\n",
    "\n",
    "        self.openai_client = OpenAIClient(api_key=self.OPENAI_API_KEY)\n",
    "\n",
    "        self.conn = None\n",
    "        self.conn_db()\n",
    "    \n",
    "    def conn_db(self):\n",
    "        \"\"\"\n",
    "        postgresql db connecting processes\n",
    "        \"\"\"\n",
    "        \n",
    "        self.conn = psycopg2.connect(\n",
    "        dbname=self.POSTGRE_DATABASE_NAME,\n",
    "        user=self.POSTGRE_DATABASE_USER,\n",
    "        password=self.POSTGRE_DATABASE_PASSWORD,\n",
    "        host=self.POSTGRE_DATABASE_HOST)\n",
    "        \n",
    "        if(self.conn):\n",
    "            print(\"db connection successfull\")\n",
    "        else:\n",
    "            print(\"db connection failed\")          \n",
    "        \n",
    "    def similarity_search(self, query_text, embeddings, texts, k=5):\n",
    "        # Step 1: Retrieve top-k texts based on similarity to query_text\n",
    "        print(query_text)\n",
    "        query_embedding = np.array(self.openai_client.get_embedding(query_text))\n",
    "        query_embedding = query_embedding.reshape(1, -1)  # Ensure the embedding is ;\n",
    "        similarities = []\n",
    "        \n",
    "        print(\"PostgreSQL Retrieving..\")\n",
    "        \n",
    "        for emb in embeddings:\n",
    "            # Ensure the embedding is converted from string to numpy array\n",
    "            emb = np.array(ast.literal_eval(emb)).reshape(1, -1)\n",
    "            similarity = np.dot(query_embedding, emb.T) / (np.linalg.norm(query_embedding) * np.linalg.norm(emb))\n",
    "            similarities.append(similarity[0][0])\n",
    "\n",
    "        # Get top-k indices\n",
    "        top_k_indices = np.argsort(similarities)[-k:][::-1]\n",
    "\n",
    "        # Retrieve top-k texts\n",
    "        top_k_texts = [texts[idx] for idx in top_k_indices]\n",
    "        \n",
    "        return top_k_texts\n",
    "\n",
    "    \n",
    "    def do_vector_search(self, query:str, embeddings, texts, k: int = 5) -> None:\n",
    "        \"\"\"\n",
    "        DYNAMIC VECTOR SEARCH \n",
    "        \"\"\" \n",
    "\n",
    "        # Start the method\n",
    "        query = query.lower().strip()  \n",
    "        print ('query: ', query)\n",
    "        \n",
    "        retrieved_text = self.similarity_search(query, embeddings, texts)\n",
    "        \n",
    "        return retrieved_text\n",
    "        \n",
    "    \n",
    "    \n",
    "    def postgresql_routing(self, state):\n",
    "        \"\"\"\n",
    "        Postgresql ROUTING\n",
    "        \"\"\"\n",
    "        print(\"--- Postgresql Routing Process ---\")\n",
    "\n",
    "        question = state[\"question\"]\n",
    "        response_text = postgresql_router.invoke({\"question\": question}).content\n",
    "        print(\"Postgresql Router => \", response_text)\n",
    "\n",
    "        return {\"question\": question, \"condition\": response_text}\n",
    "\n",
    "    \n",
    "    def postgresql_condition(self, state):\n",
    "\n",
    "        condition = state['condition']\n",
    "\n",
    "        print(\"Postgre SQL condition: \", state)\n",
    "        # Routing\n",
    "        if \"sipariş\" in condition.lower():\n",
    "            return \"sipariş\"\n",
    "\n",
    "        elif \"üretim\" in condition.lower():\n",
    "            return \"üretim\"\n",
    "            \n",
    "        else:\n",
    "            print(\"Siktirrr\")\n",
    "            return \"Boş\"\n",
    "\n",
    "    def retrieve_siparis(self, state):\n",
    "        \"\"\"\n",
    "        SIPARIS RETRIEVING\n",
    "        \"\"\"\n",
    "        print(\"--- Retrieving Postre Sipariş ---\")\n",
    "        question = state['question']\n",
    "        cur=self.conn.cursor()\n",
    "        cur.execute(f\"SELECT text, embedding FROM siparis_embeddings\")\n",
    "        results = cur.fetchall()\n",
    "        \n",
    "        print(\"Postgre Sipariş Result: \", results)\n",
    "        \n",
    "        texts = []\n",
    "        embeddings = []\n",
    "        for row in results:\n",
    "            texts.append(row[0])\n",
    "            embeddings.append(row[1])\n",
    "            \n",
    "        results = self.do_vector_search(query=question, embeddings=embeddings, texts=texts, k=5)\n",
    "\n",
    "        return {'question': question, 'documents': results}\n",
    "     \n",
    "    def retrieve_uretim(self, state):\n",
    "        \"\"\"\n",
    "        URETIM RETRIEVING\n",
    "        \"\"\"\n",
    "        print(\"--- Retrieving Postre Uretim ---\")\n",
    "        question = state['question']\n",
    "        cur=self.conn.cursor()\n",
    "        cur.execute(f\"SELECT text, embedding FROM uretim_embeddings\")\n",
    "        results = cur.fetchall()\n",
    "\n",
    "        print(\"Postgre Üretim Result: \", results)\n",
    "        \n",
    "        texts = []\n",
    "        embeddings = []\n",
    "        for row in results:\n",
    "            texts.append(row[0])\n",
    "            embeddings.append(row[1])\n",
    "            \n",
    "        results = self.do_vector_search(query=question, embeddings=embeddings, texts=texts, k=5)\n",
    "\n",
    "        return {'question': question, 'documents': results}"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "169868ac-e8e4-4a73-b14d-fe5e69004556",
   "metadata": {},
   "source": [
    "### Mongo Node Class"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1087,
   "id": "7499b028-ee6b-4c80-a06d-043e7545d0a6",
   "metadata": {},
   "outputs": [],
   "source": [
    "class MongoNodeClass():\n",
    "    def __init__(self, db_indexes: List[str], collection_names: List[str], db_name: str, mongodb_router):\n",
    "        self.db_indexes = db_indexes\n",
    "        self.collection_names = collection_names\n",
    "    \n",
    "        # Define router\n",
    "        self.mongodb_router = mongodb_router\n",
    "        \n",
    "        \n",
    "        # my config\n",
    "        self.myconfig = MyConfig()\n",
    "        self.myconfig.ATLAS_URI = os.environ['MONGO_DB_CON_STRING']\n",
    "        self.myconfig.OPENAI_API_KEY = os.environ['OPENAI_API_KEY']\n",
    "        self.myconfig.DB_NAME = db_name # 'kuikaAI'\n",
    "        self.atlas_clients = []\n",
    "    \n",
    "        # Run build atlas clients\n",
    "        self.build_Atlas_clients()\n",
    "        self.openai_client = OpenAIClient(api_key=self.myconfig.OPENAI_API_KEY)\n",
    "        print(\"OpenAI Client is ready.\")\n",
    "    \n",
    "    \n",
    "    def build_Atlas_clients(self):\n",
    "        \"\"\"\n",
    "        Atlas client connecting processes\n",
    "        \"\"\"\n",
    "        \n",
    "        for db_index_name, collection_name in zip(self.db_indexes, self.collection_names):\n",
    "    \n",
    "            self.myconfig.INDEX_NAME = db_index_name\n",
    "            self.myconfig.COLLECTION_NAME = collection_name\n",
    "    \n",
    "            atlas_client = AtlasClient(self.myconfig.ATLAS_URI, self.myconfig.DB_NAME)\n",
    "            atlas_client.ping()\n",
    "            \n",
    "            print(f\"{collection_name} atlas is ready :)\")\n",
    "    \n",
    "            self.atlas_clients.append(atlas_client)\n",
    "            \n",
    "\n",
    "    def do_vector_search(self, query:str, collection_name_parameter: str, k: int = 5) -> None:\n",
    "        \"\"\"\n",
    "        DYNAMIC VECTOR SEARCH \n",
    "        \"\"\" \n",
    "        if collection_name_parameter == 'employee':\n",
    "            index=0\n",
    "        elif collection_name_parameter == 'izin':\n",
    "            index=1\n",
    "        elif collection_name_parameter == 'servis':\n",
    "            index=2\n",
    "        else:\n",
    "            raise ValueError(f\"{collection_name_parameter} could not found.\")\n",
    "\n",
    "        # Start the method\n",
    "        query = query.lower().strip()  \n",
    "        print ('query: ', query)\n",
    "        \n",
    "        \n",
    "        # Query Embedding\n",
    "        embedding = self.openai_client.get_embedding(query)\n",
    "        \n",
    "        # Vector Search\n",
    "        results = self.atlas_clients[index].vector_search(collection_name=self.collection_names[index], index_name=self.db_indexes[index], \n",
    "                                            attr_name='Element_Description_embedding', embedding_vector=embedding, limit=k)\n",
    "\n",
    "        return results\n",
    "    \n",
    "\n",
    "    def mongo_routing(self, state):\n",
    "        \"\"\"\n",
    "        MONGO ROUTING\n",
    "        \"\"\"\n",
    "        print(\"--- Mongo Routing Process ---\")\n",
    "\n",
    "        question = state[\"question\"]\n",
    "        response_text = self.mongodb_router.invoke({\"question\": question}).content\n",
    "        print(\"Mongo Router => \", response_text)\n",
    "\n",
    "        return {\"question\":question, \"condition\": response_text}\n",
    "\n",
    "    def mongo_condition(self, state):   \n",
    "        # Routing\n",
    "        condition = state['condition']\n",
    "        \n",
    "        if \"Çalışan\" in condition:\n",
    "            return \"Çalışan\"\n",
    "\n",
    "        elif \"İzin\" in condition:\n",
    "            return \"İzin\"\n",
    "\n",
    "        else:\n",
    "            return \"Boş\"\n",
    "\n",
    "    def retrieve_employee(self, state):\n",
    "        \"\"\"\n",
    "        EMPLOYEE RETRIEVING\n",
    "        \"\"\"\n",
    "        print(\"--- Employee Retrieving ---\")\n",
    "        question = state['question']\n",
    "        results = self.do_vector_search(query=question, collection_name_parameter='employee', k=5)\n",
    "\n",
    "        print(\"Employee Retrieving Result: \", results)\n",
    "        return_text = []\n",
    "        for idx, result in enumerate(results):\n",
    "           return_text.append(f'{result[\"Element_Description\"]}\\n')\n",
    "\n",
    "        return {\"question\": question, \"documents\": return_text}\n",
    "\n",
    "    \n",
    "    def retrieve_izin(self, state):\n",
    "        \"\"\"\n",
    "        RETRIEVE IZIN\n",
    "        \"\"\"\n",
    "        print(\"--- İzin Retrieving ---\")\n",
    "        \n",
    "        question = state['question']\n",
    "        results = self.do_vector_search(query=question, collection_name_parameter='izin', k=5)\n",
    "\n",
    "        print(\"İzin Retrieving Result: \", results)\n",
    "        return_text =[]\n",
    "        for idx, result in enumerate(results):\n",
    "           return_text.append(f'{result[\"Element_Description\"]}\\n')\n",
    "\n",
    "        return {\"question\": question, \"documents\": return_text}\n",
    "    \n",
    "\n",
    "    \n",
    "    def retrieve_servis(self, state):\n",
    "        \"\"\"\n",
    "        RETRIEVE SERVIS\n",
    "        \"\"\"\n",
    "        print(\"--- Servis Retrieving ---\")\n",
    "        \n",
    "        question = state['question']\n",
    "        results = self.do_vector_search(query=question, collection_name_parameter='servis', k=5)\n",
    "\n",
    "        print(\"Servis Retrieving Result: \", results)\n",
    "        return_text = []\n",
    "        for idx, result in enumerate(results):\n",
    "           return_text.append(f'{result[\"Element_Description\"]}\\n')\n",
    "\n",
    "        return {\"question\": question, \"documents\": return_text}\n"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "b3fcf7c4-2385-44f8-ba79-be3d79bcf6f6",
   "metadata": {},
   "source": [
    "### General Node Methods"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1035,
   "id": "a4939b1b-ed0d-40d2-b111-406f0770f089",
   "metadata": {},
   "outputs": [],
   "source": [
    "def main_routing(state):\n",
    "    \"\"\"\n",
    "    MAIN ROUTING\n",
    "    \"\"\"\n",
    "    print(\"--- Main Routing Process ---\")\n",
    "    question = state[\"question\"]\n",
    "    response_text = main_router.invoke({\"question\": question}).content\n",
    "    print(\"Main Router => \", {'question': question, 'condition': response_text})\n",
    "\n",
    "    return {'question': question, 'condition': response_text}\n",
    "\n",
    "\n",
    "def main_condition(state):\n",
    "    \n",
    "    condition = state['condition']\n",
    "    print(state['condition'])\n",
    "     # Routing\n",
    "    if \"PostgreSQL\" in condition:\n",
    "        return \"PostgreSQL\"\n",
    "\n",
    "    elif \"MongoDB\" in condition:\n",
    "        return \"MongoDB\"\n",
    "\n",
    "    elif \"ChromaDB\" in condition:\n",
    "        return \"ChromaDB\"\n",
    "\n",
    "    elif \"Daily\" in condition:\n",
    "        return \"Daily\"\n",
    "\n",
    "    else:\n",
    "        return \"Boş\""
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1036,
   "id": "b8f6f903-9ddb-44b7-9ae9-18bee45c7458",
   "metadata": {},
   "outputs": [],
   "source": [
    "def rag_generate(state):\n",
    "    \"\"\"\n",
    "    RAG GENERATING\n",
    "    \"\"\"\n",
    "\n",
    "    print(\"--- RAG generating process ---\")\n",
    "    question = state['question']\n",
    "    documents = state['documents']\n",
    "    response_text = rag_generator.invoke({'question': question, 'documents': documents}).content\n",
    "    print(\"RAG Generator result: \", response_text)\n",
    "    \n",
    "    return {\"question\": question, \"documents\": documents, \"generation\": response_text, 'condition': \"end\"}\n",
    "\n",
    "\n",
    "def rag_condition(state):\n",
    "    if state['condition'] == 'end':\n",
    "        return \"end\""
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1037,
   "id": "1bff9a2f-79ff-49bd-9328-e2befb580532",
   "metadata": {},
   "outputs": [],
   "source": [
    "def casual_generate(state):\n",
    "    \"\"\"\n",
    "    CASUAL GENERATE\n",
    "    \"\"\"\n",
    "    print(\"--- Casual generating process ---\")\n",
    "    question = state['question']\n",
    "\n",
    "    response_text = casual_generator.invoke({'question': question}).content\n",
    "    print(\"Casual Generator result: \", response_text)\n",
    "\n",
    "    return {\"question\": question, \"generation\": response_text}"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "fff3a3e3-8a7e-4ed0-aece-86cf5435a889",
   "metadata": {},
   "source": [
    "### ChromaDB Methods"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1038,
   "id": "972b9263-131a-4d97-9ff2-ef1a63736df4",
   "metadata": {},
   "outputs": [],
   "source": [
    "CHROMA_PATH = \"C:\\\\Users\\\\halilibrahim.hatun\\\\Documents\\\\Kuika-AI-Hackathon\\chroma_db\"\n",
    "\n",
    "# YOU MUST - Use same embedding function as before\n",
    "embedding_function = OpenAIEmbeddings(model='text-embedding-3-large',\n",
    "                api_key=os.environ['OPENAI_API_KEY'])\n",
    "\n",
    "# Prepare the database\n",
    "chroma_db = Chroma(persist_directory=CHROMA_PATH, embedding_function=embedding_function)\n",
    "\n",
    "def chroma_retrieve(state):\n",
    "    \"\"\"\n",
    "    CHROMA RAG GENERATING\n",
    "    \"\"\"\n",
    "    print(\"--- CHROMA RAG GENERATING ---\")\n",
    "    question = state['question']\n",
    "    \n",
    "    results = chroma_db.similarity_search_with_relevance_scores(question, k=5)\n",
    "    print(\"Chroma retrieved data:  \", [doc.page_content for doc, _score in results])\n",
    "    \n",
    "    if len(results) == 0 or results[0][1] < 0.7:\n",
    "            print(f\"Unable to find matching results.\")\n",
    "\n",
    "    return {'question': question, 'documents': [doc.page_content for doc, _score in results]}"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "c86409d7-6be1-47cc-b708-69b17cbbda91",
   "metadata": {},
   "source": [
    "# Graph"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1099,
   "id": "eb402f21-cb0e-4e6c-87b8-901b9b7cef92",
   "metadata": {},
   "outputs": [],
   "source": [
    "from langgraph.graph import END, StateGraph\n",
    "workflow = StateGraph(GraphState)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1100,
   "id": "ff91cfb2-a82d-41a7-abd8-5c79e9f3c1ea",
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "employee_list atlas is ready :)\n",
      "izin_List atlas is ready :)\n",
      "OpenAI Client is ready.\n",
      "OrderedDict([('DATABASE_NAME', 'rag_system'), ('DATABASE_USER', 'postgres'), ('DATABASE_PASSWORD', '12345'), ('DATABASE_HOST', 'localhost'), ('OPENAI_API_KEY', 'sk-proj-TimFt1navUqB43NoKCkST3BlbkFJULiZCwo4pYZg1DH4upnq')])\n",
      "rag_system\n",
      "db connection successfull\n"
     ]
    }
   ],
   "source": [
    "mongo_db_indexes =  ['vector_index_employee', 'vector_index_izin', 'vector_index_servis']\n",
    "collections = ['employee_list', 'izin_List', \"servis_List\"]\n",
    "\n",
    "mongo_node_class = MongoNodeClass(db_indexes=mongo_db_indexes, collection_names=collections, db_name='kuikaAI', mongodb_router=mongodb_router)\n",
    "postgre_node_class = PostgreNodeClass(postgresql_router)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1101,
   "id": "fccb1d4a-a7fd-459b-9f34-cbba09479006",
   "metadata": {},
   "outputs": [],
   "source": [
    "workflow.add_node('Main_routing', main_routing)\n",
    "\n",
    "# MongoDB\n",
    "workflow.add_node('Mongo_Employee_Retrieve', mongo_node_class.retrieve_employee)\n",
    "workflow.add_node('Mongo_izin_Retreieve', mongo_node_class.retrieve_izin)\n",
    "\n",
    "# PostgreSQL \n",
    "workflow.add_node('Postgre_Siparis', postgre_node_class.retrieve_siparis)\n",
    "workflow.add_node('Postgre_Uretim', postgre_node_class.retrieve_uretim)\n",
    "\n",
    "# Chroma DB\n",
    "workflow.add_node('Chroma_retrieve', chroma_retrieve)\n",
    "\n",
    "workflow.add_node('Mongo_routing', mongo_node_class.mongo_routing)\n",
    "workflow.add_node('Postgre_routing', postgre_node_class.postgresql_routing)\n",
    "\n",
    "workflow.add_node('Casual_generator', casual_generate)\n",
    "workflow.add_node('Rag_generator', rag_generate)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1102,
   "id": "1fc261aa-4aa8-435b-a351-a217888b8ab5",
   "metadata": {},
   "outputs": [],
   "source": [
    "workflow.add_conditional_edges(\n",
    "    \"Main_routing\",\n",
    "     main_condition,\n",
    "    {\n",
    "        \"PostgreSQL\": \"Postgre_routing\",\n",
    "        \"MongoDB\": \"Mongo_routing\",\n",
    "        \"ChromaDB\":\"Chroma_retrieve\",\n",
    "        \"Daily\": \"Casual_generator\",\n",
    "        \"Boş\": END\n",
    "    }\n",
    ")\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1103,
   "id": "cf482039-6189-45d3-a553-58bbe490cac5",
   "metadata": {},
   "outputs": [],
   "source": [
    "workflow.add_conditional_edges(\n",
    "    \"Mongo_routing\",\n",
    "    mongo_node_class.mongo_condition,\n",
    "    {\n",
    "        \"Çalışan\": \"Mongo_Employee_Retrieve\",\n",
    "        \"İzin\": \"Mongo_izin_Retreieve\",\n",
    "        \"Boş\": END\n",
    "    }\n",
    ")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1104,
   "id": "b7df4500-1d02-4088-90b9-1310a1a1bc7a",
   "metadata": {},
   "outputs": [],
   "source": [
    "workflow.add_conditional_edges(\n",
    "    \"Postgre_routing\",\n",
    "    postgre_node_class.postgresql_condition,\n",
    "    {\n",
    "        \"sipariş\": \"Postgre_Siparis\",\n",
    "        \"üretim\": \"Postgre_Uretim\",\n",
    "        \"Boş\": END\n",
    "    }\n",
    ")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1105,
   "id": "9d1eafbc-06b0-4e63-bb9a-f87918b5daba",
   "metadata": {},
   "outputs": [],
   "source": [
    "workflow.add_conditional_edges(\n",
    "    \"Rag_generator\",\n",
    "    rag_condition,\n",
    "    {\n",
    "        \"end\": END,\n",
    "    }\n",
    ")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1106,
   "id": "6c22a6e3-1559-4bd0-9778-99f1aaa66c6e",
   "metadata": {},
   "outputs": [],
   "source": [
    "workflow.add_edge('Chroma_retrieve', 'Rag_generator')\n",
    "workflow.add_edge('Mongo_Employee_Retrieve', 'Rag_generator')\n",
    "workflow.add_edge('Mongo_izin_Retreieve', 'Rag_generator')\n",
    "workflow.add_edge('Postgre_Siparis', 'Rag_generator')\n",
    "workflow.add_edge('Postgre_Uretim', 'Rag_generator')"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1107,
   "id": "e312684b-50e7-4df9-989f-b36e48c52e64",
   "metadata": {},
   "outputs": [],
   "source": [
    "workflow.set_entry_point(\"Main_routing\")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1108,
   "id": "fe74bf40-d019-41fa-9429-953091ed58a7",
   "metadata": {},
   "outputs": [
    {
     "ename": "ValueError",
     "evalue": "Failed to render the graph using the Mermaid.INK API. Status code: 404.",
     "output_type": "error",
     "traceback": [
      "\u001B[1;31m---------------------------------------------------------------------------\u001B[0m",
      "\u001B[1;31mValueError\u001B[0m                                Traceback (most recent call last)",
      "Cell \u001B[1;32mIn[1108], line 8\u001B[0m\n\u001B[0;32m      3\u001B[0m \u001B[38;5;28;01mfrom\u001B[39;00m \u001B[38;5;21;01mIPython\u001B[39;00m\u001B[38;5;21;01m.\u001B[39;00m\u001B[38;5;21;01mdisplay\u001B[39;00m \u001B[38;5;28;01mimport\u001B[39;00m Image, display\n\u001B[0;32m      4\u001B[0m \u001B[38;5;28;01mfrom\u001B[39;00m \u001B[38;5;21;01mlangchain_core\u001B[39;00m\u001B[38;5;21;01m.\u001B[39;00m\u001B[38;5;21;01mrunnables\u001B[39;00m\u001B[38;5;21;01m.\u001B[39;00m\u001B[38;5;21;01mgraph\u001B[39;00m \u001B[38;5;28;01mimport\u001B[39;00m CurveStyle, MermaidDrawMethod, NodeColors\n\u001B[0;32m      6\u001B[0m display(\n\u001B[0;32m      7\u001B[0m     Image(\n\u001B[1;32m----> 8\u001B[0m         \u001B[43mapp\u001B[49m\u001B[38;5;241;43m.\u001B[39;49m\u001B[43mget_graph\u001B[49m\u001B[43m(\u001B[49m\u001B[43m)\u001B[49m\u001B[38;5;241;43m.\u001B[39;49m\u001B[43mdraw_mermaid_png\u001B[49m\u001B[43m(\u001B[49m\n\u001B[0;32m      9\u001B[0m \u001B[43m            \u001B[49m\u001B[43mdraw_method\u001B[49m\u001B[38;5;241;43m=\u001B[39;49m\u001B[43mMermaidDrawMethod\u001B[49m\u001B[38;5;241;43m.\u001B[39;49m\u001B[43mAPI\u001B[49m\u001B[43m,\u001B[49m\n\u001B[0;32m     10\u001B[0m \u001B[43m        \u001B[49m\u001B[43m)\u001B[49m\n\u001B[0;32m     11\u001B[0m     )\n\u001B[0;32m     12\u001B[0m )\n",
      "File \u001B[1;32m~\\Documents\\venvs\\uniteks_cpu\\Lib\\site-packages\\langchain_core\\runnables\\graph.py:460\u001B[0m, in \u001B[0;36mGraph.draw_mermaid_png\u001B[1;34m(self, curve_style, node_colors, wrap_label_n_words, output_file_path, draw_method, background_color, padding)\u001B[0m\n\u001B[0;32m    453\u001B[0m \u001B[38;5;28;01mfrom\u001B[39;00m \u001B[38;5;21;01mlangchain_core\u001B[39;00m\u001B[38;5;21;01m.\u001B[39;00m\u001B[38;5;21;01mrunnables\u001B[39;00m\u001B[38;5;21;01m.\u001B[39;00m\u001B[38;5;21;01mgraph_mermaid\u001B[39;00m \u001B[38;5;28;01mimport\u001B[39;00m draw_mermaid_png\n\u001B[0;32m    455\u001B[0m mermaid_syntax \u001B[38;5;241m=\u001B[39m \u001B[38;5;28mself\u001B[39m\u001B[38;5;241m.\u001B[39mdraw_mermaid(\n\u001B[0;32m    456\u001B[0m     curve_style\u001B[38;5;241m=\u001B[39mcurve_style,\n\u001B[0;32m    457\u001B[0m     node_colors\u001B[38;5;241m=\u001B[39mnode_colors,\n\u001B[0;32m    458\u001B[0m     wrap_label_n_words\u001B[38;5;241m=\u001B[39mwrap_label_n_words,\n\u001B[0;32m    459\u001B[0m )\n\u001B[1;32m--> 460\u001B[0m \u001B[38;5;28;01mreturn\u001B[39;00m \u001B[43mdraw_mermaid_png\u001B[49m\u001B[43m(\u001B[49m\n\u001B[0;32m    461\u001B[0m \u001B[43m    \u001B[49m\u001B[43mmermaid_syntax\u001B[49m\u001B[38;5;241;43m=\u001B[39;49m\u001B[43mmermaid_syntax\u001B[49m\u001B[43m,\u001B[49m\n\u001B[0;32m    462\u001B[0m \u001B[43m    \u001B[49m\u001B[43moutput_file_path\u001B[49m\u001B[38;5;241;43m=\u001B[39;49m\u001B[43moutput_file_path\u001B[49m\u001B[43m,\u001B[49m\n\u001B[0;32m    463\u001B[0m \u001B[43m    \u001B[49m\u001B[43mdraw_method\u001B[49m\u001B[38;5;241;43m=\u001B[39;49m\u001B[43mdraw_method\u001B[49m\u001B[43m,\u001B[49m\n\u001B[0;32m    464\u001B[0m \u001B[43m    \u001B[49m\u001B[43mbackground_color\u001B[49m\u001B[38;5;241;43m=\u001B[39;49m\u001B[43mbackground_color\u001B[49m\u001B[43m,\u001B[49m\n\u001B[0;32m    465\u001B[0m \u001B[43m    \u001B[49m\u001B[43mpadding\u001B[49m\u001B[38;5;241;43m=\u001B[39;49m\u001B[43mpadding\u001B[49m\u001B[43m,\u001B[49m\n\u001B[0;32m    466\u001B[0m \u001B[43m\u001B[49m\u001B[43m)\u001B[49m\n",
      "File \u001B[1;32m~\\Documents\\venvs\\uniteks_cpu\\Lib\\site-packages\\langchain_core\\runnables\\graph_mermaid.py:156\u001B[0m, in \u001B[0;36mdraw_mermaid_png\u001B[1;34m(mermaid_syntax, output_file_path, draw_method, background_color, padding)\u001B[0m\n\u001B[0;32m    150\u001B[0m     img_bytes \u001B[38;5;241m=\u001B[39m asyncio\u001B[38;5;241m.\u001B[39mrun(\n\u001B[0;32m    151\u001B[0m         _render_mermaid_using_pyppeteer(\n\u001B[0;32m    152\u001B[0m             mermaid_syntax, output_file_path, background_color, padding\n\u001B[0;32m    153\u001B[0m         )\n\u001B[0;32m    154\u001B[0m     )\n\u001B[0;32m    155\u001B[0m \u001B[38;5;28;01melif\u001B[39;00m draw_method \u001B[38;5;241m==\u001B[39m MermaidDrawMethod\u001B[38;5;241m.\u001B[39mAPI:\n\u001B[1;32m--> 156\u001B[0m     img_bytes \u001B[38;5;241m=\u001B[39m \u001B[43m_render_mermaid_using_api\u001B[49m\u001B[43m(\u001B[49m\n\u001B[0;32m    157\u001B[0m \u001B[43m        \u001B[49m\u001B[43mmermaid_syntax\u001B[49m\u001B[43m,\u001B[49m\u001B[43m \u001B[49m\u001B[43moutput_file_path\u001B[49m\u001B[43m,\u001B[49m\u001B[43m \u001B[49m\u001B[43mbackground_color\u001B[49m\n\u001B[0;32m    158\u001B[0m \u001B[43m    \u001B[49m\u001B[43m)\u001B[49m\n\u001B[0;32m    159\u001B[0m \u001B[38;5;28;01melse\u001B[39;00m:\n\u001B[0;32m    160\u001B[0m     supported_methods \u001B[38;5;241m=\u001B[39m \u001B[38;5;124m\"\u001B[39m\u001B[38;5;124m, \u001B[39m\u001B[38;5;124m\"\u001B[39m\u001B[38;5;241m.\u001B[39mjoin([m\u001B[38;5;241m.\u001B[39mvalue \u001B[38;5;28;01mfor\u001B[39;00m m \u001B[38;5;129;01min\u001B[39;00m MermaidDrawMethod])\n",
      "File \u001B[1;32m~\\Documents\\venvs\\uniteks_cpu\\Lib\\site-packages\\langchain_core\\runnables\\graph_mermaid.py:279\u001B[0m, in \u001B[0;36m_render_mermaid_using_api\u001B[1;34m(mermaid_syntax, output_file_path, background_color)\u001B[0m\n\u001B[0;32m    277\u001B[0m     \u001B[38;5;28;01mreturn\u001B[39;00m img_bytes\n\u001B[0;32m    278\u001B[0m \u001B[38;5;28;01melse\u001B[39;00m:\n\u001B[1;32m--> 279\u001B[0m     \u001B[38;5;28;01mraise\u001B[39;00m \u001B[38;5;167;01mValueError\u001B[39;00m(\n\u001B[0;32m    280\u001B[0m         \u001B[38;5;124mf\u001B[39m\u001B[38;5;124m\"\u001B[39m\u001B[38;5;124mFailed to render the graph using the Mermaid.INK API. \u001B[39m\u001B[38;5;124m\"\u001B[39m\n\u001B[0;32m    281\u001B[0m         \u001B[38;5;124mf\u001B[39m\u001B[38;5;124m\"\u001B[39m\u001B[38;5;124mStatus code: \u001B[39m\u001B[38;5;132;01m{\u001B[39;00mresponse\u001B[38;5;241m.\u001B[39mstatus_code\u001B[38;5;132;01m}\u001B[39;00m\u001B[38;5;124m.\u001B[39m\u001B[38;5;124m\"\u001B[39m\n\u001B[0;32m    282\u001B[0m     )\n",
      "\u001B[1;31mValueError\u001B[0m: Failed to render the graph using the Mermaid.INK API. Status code: 404."
     ]
    }
   ],
   "source": [
    "app = workflow.compile()\n",
    "\n",
    "from IPython.display import Image, display\n",
    "from langchain_core.runnables.graph import CurveStyle, MermaidDrawMethod, NodeColors\n",
    "\n",
    "display(\n",
    "    Image(\n",
    "        app.get_graph().draw_mermaid_png(\n",
    "            draw_method=MermaidDrawMethod.API,\n",
    "        )\n",
    "    )\n",
    ")"
   ]
  },
  {
   "cell_type": "markdown",
   "id": "31e5f9b4-1622-449d-8e3e-5c778a605f60",
   "metadata": {},
   "source": [
    "###  Prediction"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1111,
   "id": "e8bffaa8-6e81-403b-b2ea-29cad17f3da2",
   "metadata": {},
   "outputs": [],
   "source": [
    "from pprint import pprint\n",
    "inputs = {\"question\": \"servis şoförleri \"}"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1112,
   "id": "7f117420-f0bc-40c0-b885-0e87cdf63c86",
   "metadata": {
    "scrolled": true
   },
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "--- Main Routing Process ---\n",
      "Main Router =>  {'question': 'servis şoförleri ', 'condition': 'MongoDB'}\n",
      "MongoDB\n",
      "'Finished running: Main_routing:'\n",
      "--- Mongo Routing Process ---\n",
      "Mongo Router =>  'Servis'\n",
      "'Finished running: Mongo_routing:'\n"
     ]
    }
   ],
   "source": [
    "for output in app.stream(inputs):\n",
    "    for key, value in output.items():\n",
    "        pprint(f\"Finished running: {key}:\")\n",
    "        \n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1079,
   "id": "e815d7bb-a3b6-42da-b803-c1b6683497cb",
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "('Merhaba! Prosedürler hakkında bilgi vermemi istemişsiniz. Verilen kaynağa '\n",
      " 'göre, prosedürlerle ilgili bazı önemli noktalar şunlardır:\\n'\n",
      " '\\n'\n",
      " '1. **Amaç**: Prosedürlerin amacı, ERP sistemi üzerinde yaşanan süreç '\n",
      " 'değişikliği, yeni süreç, iyileştirme ve süreç akışı ile ilgili yaşanan sorun '\n",
      " 've aksaklıkları sınıflandırarak çözüm bulmak ve takibini yapmaktır.\\n'\n",
      " '\\n'\n",
      " '2. **Kapsam**: Bu prosedür, Logos’da görevi gereği ERP kullanan tüm şirket '\n",
      " 'içi ve dışı kullanıcıları kapsamaktadır.\\n'\n",
      " '\\n'\n",
      " '3. **Sorumlular**: Prosedürlerin güncellenmesinden ve yayınlanmasından '\n",
      " 'sorumlu olan bölümler belirtilmiştir. Örneğin, İnsan Kaynakları Bölümü '\n",
      " 'prosedürlerin güncellenmesinden sorumludur ve Ar-Ge Merkezi Bölümü seyahat '\n",
      " 'sürecinin prosedürlere uygun yürütülmesini sağlar.\\n'\n",
      " '\\n'\n",
      " '4. **İletişim**: İyileştirme ve/veya güncellemelerin iletişimi eğitimler '\n",
      " 'yoluyla sağlanır.\\n'\n",
      " '\\n'\n",
      " '5. **Kayıtlar**: Prosedürlerin uygulanması sonucu ortaya çıkan kayıtların '\n",
      " 'nerede ve ne kadar süre ile saklanması gerektiği belirtilmiştir.\\n'\n",
      " '\\n'\n",
      " 'Eğer daha spesifik bir bilgiye ihtiyacınız varsa veya başka bir konuda '\n",
      " 'yardımcı olmamı isterseniz, lütfen belirtin. Yardımcı olmaktan memnuniyet '\n",
      " 'duyarım!')\n"
     ]
    }
   ],
   "source": [
    "pprint(value[\"generation\"])"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "925f39e7-151e-4afc-8b32-845a8d247959",
   "metadata": {},
   "outputs": [],
   "source": []
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "Uniteks CPU (Python 3.11)",
   "language": "python",
   "name": "unitekscpu"
  },
  "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.11.5"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 5
}