""" Page for similarities """ ################ # DEPENDENCIES # ################ import streamlit as st import pandas as pd from scipy.sparse import load_npz import pickle from sentence_transformers import SentenceTransformer from modules.multimatch_result_table import show_multi_table from modules.singlematch_result_table import show_single_table from functions.filter_projects import filter_projects from functions.filter_single import filter_single from functions.calc_matches import calc_matches from functions.same_country_filter import same_country_filter from functions.single_similar import find_similar import psutil import os import gc def get_process_memory(): process = psutil.Process(os.getpid()) return process.memory_info().rss / (1024 * 1024) # Catch DATA # Load Similarity matrix @st.cache_data def load_sim_matrix(): loaded_matrix = load_npz("src/extended_similarities.npz") dense_matrix = loaded_matrix.toarray() return dense_matrix # Load Non Similar Orga Matrix @st.cache_data def load_nonsameorga_sim_matrix(): loaded_matrix = load_npz("src/extended_similarities_nonsimorga.npz") dense_matrix = loaded_matrix.toarray() return dense_matrix # Load Projects DFs @st.cache_data def load_projects(): orgas_df = pd.read_csv("src/projects/project_orgas.csv") region_df = pd.read_csv("src/projects/project_region.csv") sector_df = pd.read_csv("src/projects/project_sector.csv") status_df = pd.read_csv("src/projects/project_status.csv") texts_df = pd.read_csv("src/projects/project_texts.csv") projects_df = pd.merge(orgas_df, region_df, on='iati_id', how='inner') projects_df = pd.merge(projects_df, sector_df, on='iati_id', how='inner') projects_df = pd.merge(projects_df, status_df, on='iati_id', how='inner') projects_df = pd.merge(projects_df, texts_df, on='iati_id', how='inner') iati_search_list = [f'{row.iati_id}' for row in projects_df.itertuples()] title_search_list = [f'{row.title_main} ({row.orga_abbreviation.upper()})' for row in projects_df.itertuples()] return projects_df, iati_search_list, title_search_list # Load CRS 3 data @st.cache_data def getCRS3(): # Read in CRS3 CODELISTS crs3_df = pd.read_csv('src/codelists/crs3_codes.csv') CRS3_CODES = crs3_df['code'].tolist() CRS3_NAME = crs3_df['name'].tolist() CRS3_MERGED = {f"{name} - {code}": code for name, code in zip(CRS3_NAME, CRS3_CODES)} return CRS3_MERGED # Load CRS 5 data @st.cache_data def getCRS5(): # Read in CRS3 CODELISTS crs5_df = pd.read_csv('src/codelists/crs5_codes.csv') CRS5_CODES = crs5_df['code'].tolist() CRS5_NAME = crs5_df['name'].tolist() CRS5_MERGED = {code: [f"{name} - {code}"] for name, code in zip(CRS5_NAME, CRS5_CODES)} return CRS5_MERGED # Load SDG data @st.cache_data def getSDG(): # Read in SDG CODELISTS sdg_df = pd.read_csv('src/codelists/sdg_goals.csv') SDG_NAMES = sdg_df['name'].tolist() return SDG_NAMES # Load Country Data @st.cache_data def getCountry(): # Read in countries from codelist country_df = pd.read_csv('src/codelists/country_codes_ISO3166-1alpha-2.csv') COUNTRY_CODES = country_df['Alpha-2 code'].tolist() COUNTRY_NAMES = country_df['Country'].tolist() COUNTRY_OPTION_LIST = [f"{COUNTRY_NAMES[i]} ({COUNTRY_CODES[i][-3:-1].upper()})"for i in range(len(COUNTRY_NAMES))] return COUNTRY_OPTION_LIST # Load Sentence Transformer Model @st.cache_resource def load_model(): model = SentenceTransformer('all-MiniLM-L6-v2') return model # Load Embeddings @st.cache_data def load_embeddings_and_index(): # Load embeddings with open("src/embeddings.pkl", "rb") as fIn: stored_data = pickle.load(fIn) embeddings = stored_data["embeddings"] return embeddings # USE CACHE FUNCTIONS sim_matrix = load_sim_matrix() nonsameorgas_sim_matrix = load_nonsameorga_sim_matrix() projects_df, iati_search_list, title_search_list = load_projects() CRS3_MERGED = getCRS3() CRS5_MERGED = getCRS5() SDG_NAMES = getSDG() COUNTRY_OPTION_LIST = getCountry() # LOAD MODEL FROM CACHE FO SEMANTIC SEARCH model = load_model() embeddings = load_embeddings_and_index() def show_multi_matching_page(): #st.write(f"Current RAM usage of this app: {get_process_memory():.2f} MB") #st.write(" ") with st.expander("Explanation"): st.caption(""" The Multi-Project Matching Feature uncovers synergy opportunities among various development banks and organizations by facilitating the search for similar projects within a selected filter setting. This innovative tool leverages an AI-driven similarity score to compare all available projects against those meeting the filter criteria, identifying potential matches that may not directly qualify under the selected filter settings. It integrates projects listed in the IATI database from leading organizations, including BMZ, KfW, GIZ, IAD, ADB, AfDB, EIB, WB, WBTF, and the German Federal Foreign Office (AA), offering a comprehensive platform for enhancing collaboration and maximizing the impact of development efforts. """) #st.write("----------------------") col1, col2, col3 = st.columns([10, 1, 10]) with col1: st.subheader("Sector Filters (required)") st.caption(""" Sector filters must be applied to see results. The CRS5 and CRS3 classifications organise development aid into categories, with the 5-digit level providing more specific detail within the broader 3-digit categories. The SDGs are 17 UN goals that aim to achieve global sustainability, peace and prosperity by 2030. Futhermore you can Search for projects with the query field. """) with col3: st.subheader("Additional Filters") st.caption(""" The additional filters allow for a more detailed search for the Multi-Project Matching. """) st.session_state.crs5_option_disabled = True col1, col2, col3 = st.columns([10, 1, 10]) with col1: # CRS 3 SELECTION crs3_option = st.multiselect( 'CRS 3', CRS3_MERGED, placeholder="Select a CRS 3 code" ) # CRS 5 SELECTION ## Only enable crs5 select field when crs3 code is selected if crs3_option != []: st.session_state.crs5_option_disabled = False ## define list of crs5 codes dependend on crs3 codes crs5_list = [txt[0].replace('"', "") for crs3_item in crs3_option for code, txt in CRS5_MERGED.items() if str(code)[:3] == str(crs3_item)[-3:]] ## crs5 select field crs5_option = st.multiselect( 'CRS 5', crs5_list, placeholder="Select a CRS 5 code", disabled=st.session_state.crs5_option_disabled ) # SDG SELECTION sdg_option = st.selectbox( label = 'Sustainable Development Goal (SDG)', index = None, placeholder = "Select a SDG", options = SDG_NAMES[:-1], ) # SEARCH BOX query = st.text_input("Search Query") with col3: # COUNTRY SELECTION country_option = st.multiselect( 'Country / Countries', COUNTRY_OPTION_LIST, placeholder="All countries selected" ) # ORGA SELECTION orga_abbreviation = projects_df["orga_abbreviation"].unique() orga_full_names = projects_df["orga_full_name"].unique() orga_list = [f"{orga_full_names[i]} ({orga_abbreviation[i].upper()})"for i in range(len(orga_abbreviation))] orga_option = st.multiselect( 'Development Bank / Organization', orga_list, placeholder="All organizations selected" ) different_orga_checkbox = st.checkbox("Only matches between different organizations", value=True) filterd_country_only_checkbox = st.checkbox("Only matches between filtered countries", value=True) # CRS CODE LIST crs3_list = [i[-3:] for i in crs3_option] crs5_list = [i[-5:] for i in crs5_option] # SDG CODE LIST if sdg_option != None: sdg_str = sdg_option.split(".")[0] print(sdg_str) else: sdg_str = "" # COUNTRY CODES LIST country_code_list = [option[-3:-1] for option in country_option] # ORGANIZATION CODES LIST orga_code_list = [option.split("(")[1][:-1].lower() for option in orga_option] # FILTER DF WITH SELECTED FILTER OPTIONS TOP_X_PROJECTS = 30 filtered_df = filter_projects(projects_df, crs3_list, crs5_list, sdg_str, country_code_list, orga_code_list, query, model, embeddings, TOP_X_PROJECTS) if isinstance(filtered_df, pd.DataFrame) and len(filtered_df) != 0: # FIND MATCHES ## If only same country checkbox i sactivated if filterd_country_only_checkbox: with st.spinner('Please wait...'): compare_df = same_country_filter(projects_df, country_code_list) else: compare_df = projects_df ## if show only different orgas checkbox is activated if different_orga_checkbox: with st.spinner('Please wait...'): p1_df, p2_df = calc_matches(filtered_df, compare_df, nonsameorgas_sim_matrix, TOP_X_PROJECTS) else: with st.spinner('Please wait...'): p1_df, p2_df = calc_matches(filtered_df, compare_df, sim_matrix, TOP_X_PROJECTS) # SHOW THE RESULT show_multi_table(p1_df, p2_df) del p1_df, p2_df else: st.write("-----") col1, col2, col3 = st.columns([1, 1, 1]) with col2: st.write(" ") st.markdown("There are no results for the applied filter. Try another filter!", unsafe_allow_html=True) del crs3_list, crs5_list, sdg_str, filtered_df gc.collect() def show_single_matching_page(): with st.expander("Explanation"): st.caption(""" Single Project Matching empowers you to choose an individual project using either the project IATI ID or title, and then unveils the top 10 projects that bear the closest resemblance to your selected one. This selection is refined using a sophisticated AI algorithm that evaluates similarity based on several key dimensions: Sustainable Development Goals (SDG), Creditor Reporting System (CRS) codes, and textual analysis of project titles and descriptions. """) #st.write("---------") col1, col2 = st.columns([11, 20]) with col1: st.subheader("Select a reference project") st.caption(""" Select a reference project either by its title or IATI ID to find the 10 projects most similar to it. """) with col2: st.subheader("Filters for similar projects") st.caption(""" The filters are applied to find the similar projects and are independend of the selected reference project. """) col1, col2, col3, col4 = st.columns([10, 1, 10, 10]) with col1: search_option = st.selectbox( label = 'Search with project title or IATI ID', index = 0, placeholder = " ", options = ["Search with IATI ID", "Search with project title"], ) if search_option == "Search with IATI ID": search_list = iati_search_list else: search_list = title_search_list project_option = st.selectbox( label = 'Search for a project', index = None, placeholder = " ", options = search_list, ) with col3: # ORGA SELECTION orga_abbreviation = projects_df["orga_abbreviation"].unique() orga_full_names = projects_df["orga_full_name"].unique() orga_list = [f"{orga_full_names[i]} ({orga_abbreviation[i].upper()})"for i in range(len(orga_abbreviation))] orga_option_s = st.multiselect( 'Development Bank / Organization ', orga_list, placeholder="All organizations selected " ) different_orga_checkbox_s = st.checkbox("Only matches between different organizations ", value=True) with col4: # COUNTRY SELECTION country_option_s = st.multiselect( 'Country / Countries ', COUNTRY_OPTION_LIST, placeholder="All countries selected " ) st.write("--------------") #selected_index = None if project_option: selected_project_index = search_list.index(project_option) # COUNTRY CODES LIST country_code_list = [option[-3:-1] for option in country_option_s] # ORGANIZATION CODES LIST orga_code_list = [option.split("(")[1][:-1].lower() for option in orga_option_s] TOP_X_PROJECTS = 10 with st.spinner('Please wait...'): filtered_df_s = filter_single(projects_df, country_code_list, orga_code_list) if isinstance(filtered_df_s, pd.DataFrame) and len(filtered_df_s) != 0: if different_orga_checkbox_s: with st.spinner('Please wait...'): top_projects_df = find_similar(selected_project_index, nonsameorgas_sim_matrix, filtered_df_s, 10) else: with st.spinner('Please wait...'): top_projects_df = find_similar(selected_project_index, sim_matrix, filtered_df_s, 10) show_single_table(selected_project_index, projects_df, top_projects_df) else: st.write("-----") col1, col2, col3 = st.columns([1, 1, 1]) with col2: st.write(" ") st.markdown("Ther are no results for this filter!", unsafe_allow_html=True)