junte/Model
1
0
Fork 0
mirror of https://github.com/Hestia-Homes/Model.git synced 2026-06-08 11:17:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Added ciga list id

Browse source
This commit is contained in:
Khalim Conn-Kowlessar 2024-02-22 12:42:04 +00:00
parent 615f2289e7
commit a1b2f9bf5b
1 changed files with 15 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
etl/eligibility/ha_15_32/ha_analysis_batch_3.py
View file

@ -195,6 +195,7 @@ class DataLoader:
ciga_list = pd.DataFrame(ciga_rows, columns=[cell.value for cell in ciga_sheet[1]])
# Remove columns that are None
ciga_list = ciga_list.loc[:, ciga_list.columns.notnull()]
survey_list["survey_list_row_id"] = [ha_name + "_ciga_" + str(i) for i in range(0, len(survey_list))]
# Perform ciga list merge
if not ciga_list.empty:
ciga_list = self.create_ciga_list_house_no(ha_name, ciga_list)
@ -440,14 +441,14 @@ class DataLoader:
df = df[df["matching_postcode"].str.lower().str.contains(row["Post Code"].lower())]
if df.shape[0] != 1:
postcode_lower = row["Post Code"].lower()
if postcode_lower in missed_postcodes:
matching_lookup.append(
{
"survey_list_row_id": row["survey_list_row_id"],
"asset_list_row_id": None,
}
)
continue
# if postcode_lower in missed_postcodes:
# matching_lookup.append(
# {
# "survey_list_row_id": row["survey_list_row_id"],
# "asset_list_row_id": None,
# }
# )
# continue
print(row["Street / Block Name"])
print(house_number)
@ -456,13 +457,18 @@ class DataLoader:
matching_lookup.append(
{
"survey_list_row_id": row["survey_list_row_id"],
"ciga_list_row_id": row["ciga_list_row_id"],
"asset_list_row_id": df["asset_list_row_id"].values[0],
}
)
matching_lookup = pd.DataFrame(matching_lookup)
# Merge onto the ciga list
ciga_list = ciga_list.merge(matching_lookup, how='left', on="ciga_list_row_id")
return ciga_list
@staticmethod
def identify_built_form_ha6(property_string):
"""