diff --git a/app/routes/file_report.py b/app/routes/file_report.py index e48f87d..f533868 100644 --- a/app/routes/file_report.py +++ b/app/routes/file_report.py @@ -4,6 +4,7 @@ from flask import Blueprint, render_template, request, send_file, flash, jsonify from app.utils.helpers import login_required from app.utils.regex_utils import RegularExpression from app import db +from sqlalchemy import func import re from app.models.subcontractor_model import Subcontractor @@ -22,35 +23,165 @@ from app.services.abstract_service import AbstractReportService # --- BLUEPRINT DEFINITION --- file_report_bp = Blueprint("file_report", __name__, url_prefix="/file") - + + +# ---------------- LOCATION HELPERS ---------------- +WORK_MODELS = [TrenchExcavation, ManholeExcavation, ManholeDomesticChamber, Laying] + + +def get_distinct_locations(): + """Union of distinct, non-empty Location values across all 4 work tables.""" + locations = set() + for Model in WORK_MODELS: + rows = db.session.query(Model.Location).distinct().all() + for (loc,) in rows: + if loc and loc.strip(): + locations.add(loc.strip()) + return sorted(locations) + + +def get_subcontractors_for_location(location): + """Return Subcontractor objects that have at least one work record + (in any of the 4 category tables) at the given location. If no + location is given, returns every subcontractor. Shared by the AJAX + endpoint below and by the server-rendered dropdown so the list is + correct even before/without JS running (e.g. on page reload or a + validation-error re-render). + + Matching is case- and whitespace-insensitive, since Location is a + free-text field and stored values can drift ("Pune" vs "PUNE " etc.) + even though the dropdown options themselves come from a distinct + query and look identical.""" + location = (location or "").strip() + + if not location: + return Subcontractor.query.order_by(Subcontractor.subcontractor_name).all() + + target = location.upper() + sc_ids = set() + for Model in WORK_MODELS: + rows = ( + db.session.query(Model.subcontractor_id) + .filter(func.upper(func.trim(Model.Location)) == target) + .distinct() + .all() + ) + for (sid,) in rows: + if sid: + sc_ids.add(sid) + + if not sc_ids: + return [] + + return ( + Subcontractor.query.filter(Subcontractor.id.in_(sc_ids)) + .order_by(Subcontractor.subcontractor_name) + .all() + ) + + +@file_report_bp.route("/get_subcontractors_by_location") +@login_required +def get_subcontractors_by_location(): + """AJAX endpoint: return subcontractors that have at least one work + record (in any of the 4 category tables) at the given location.""" + location = request.args.get("location", "").strip() + subs = get_subcontractors_for_location(location) + + return jsonify([{"id": s.id, "name": s.subcontractor_name} for s in subs]) + + # ---------------- ACTION COLUMN ---------------- def add_action_columns(df, model_key): if df.empty: return df - # Edit + Delete side by side in one "Action" column, both as icon buttons. - df.insert(0, "Action", df["Id"].apply( - lambda x: ( - f'
' - f'' - f'' - f'' - f'
' - ) + df.insert(0, "Select", df["Id"].apply( + lambda x: f'' )) - df.insert(1, "Select", df["Id"].apply( - lambda x: f'' - )) + df["Update"] = df["Id"].apply( + lambda x: f' Edit' + ) - df["Id"] = range(1, len(df) + 1) - df = df.rename(columns={"Id": "Sr No"}) + df["Delete"] = df["Id"].apply( + lambda x: f'' + ) return df +# ---------------- SELECT-ALL HEADER ---------------- +def add_select_all_header(table_html, model_key): + """Swap pandas' plain 'Select' column header for a select-all checkbox + scoped to this table (via data-model), so checking it only toggles + rows in this table - not the other 3 category tables on the page.""" + return table_html.replace( + "Select", + f'', + 1 + ) + + +# ---------------- TABLE OR EMPTY-STATE ---------------- +def add_data_field_attrs(table_html, raw_fields): + """Tag each editable data with a data-field attribute naming its + underlying database column, so bulk-edit mode on the frontend knows + exactly which field to submit for each input it creates. The 'id' + column is deliberately skipped - it's the primary key and must never + be editable. + + Uses match spans (not string search-and-replace) to rebuild each row, + because a naive .replace() on duplicate cell text (e.g. two cells + that both just say "0.00") would edit the wrong cell.""" + total_cols = 1 + len(raw_fields) + 2 # Select + data columns + Update + Delete + + def process_row(m): + row_html = m.group(0) + matches = list(re.finditer(r".*?", row_html, flags=re.S)) + if len(matches) != total_cols: + return row_html # shape mismatch - leave untouched rather than guess + + pieces = [] + last_end = 0 + for i, mt in enumerate(matches): + pieces.append(row_html[last_end:mt.start()]) + cell = mt.group(0) + if 1 <= i <= len(raw_fields): + field = raw_fields[i - 1] + if field.lower() != "id": + cell = f'' + cell[len(""):] + pieces.append(cell) + last_end = mt.end() + pieces.append(row_html[last_end:]) + return "".join(pieces) + + return re.sub(r".*?", process_row, table_html, flags=re.S) + + +def render_table_or_empty(df, model_key, table_class, raw_fields=None): + """Render a table, or a friendly placeholder if there's no data. + + IMPORTANT: pandas' to_html() on a fully empty DataFrame (0 rows AND + 0 columns, which is what we get when a category has no matching + records) still emits a - just with a + header row that has zero
cells. jQuery DataTables then tries to + initialize on a table with no columns and throws, which (since the + init code runs as one synchronous block) silently kills every bit of + JS registered after it - including the select-all checkbox handler + for the OTHER tables on the page. Returning a plain message instead + of an empty avoids ever handing DataTables + something it can't initialize.""" + if df.empty: + return '
No records found.
' + html = df.to_html(classes=table_class, index=False, escape=False) + html = add_select_all_header(html, model_key) + html = add_data_field_attrs(html, raw_fields or []) + return html + + @@ -63,7 +194,7 @@ class SubcontractorBill: self.df_laying = pd.DataFrame() # self.df_abstract = pd.DataFrame() # NEW - def Fetch(self, RA_Bill_No=None, subcontractor_id=None, location=None): + def Fetch(self, RA_Bill_No=None, subcontractor_id=None, location=None, mh_no=None): filters = {} if subcontractor_id: @@ -80,7 +211,6 @@ class SubcontractorBill: # LOCATION FILTER if location: search = location.strip().lower() - print("location::",search) trench = [ t for t in trench if search in (t.Location or "").strip().lower() @@ -100,7 +230,30 @@ class SubcontractorBill: t for t in lay if search in (t.Location or "").strip().lower() ] - + + # MH NO FILTER + if mh_no: + mh_search = mh_no.strip().lower() + trench = [ + t for t in trench + if mh_search in (t.MH_NO or "").strip().lower() + ] + + mh = [ + t for t in mh + if mh_search in (t.MH_NO or "").strip().lower() + ] + + dc = [ + t for t in dc + if mh_search in (t.MH_NO or "").strip().lower() + ] + + lay = [ + t for t in lay + if mh_search in (t.MH_NO or "").strip().lower() + ] + # Set dataframe self.df_tr = pd.DataFrame([c.serialize() for c in trench]) self.df_mh = pd.DataFrame([c.serialize() for c in mh]) @@ -109,9 +262,24 @@ class SubcontractorBill: drop_cols = ["11", "_sa_instance_state", "subcontractor_id" , "created_at"] - for df in [self.df_tr, self.df_mh, self.df_dc, self.df_laying]: + # Raw (pre-format_column_names) column names for each table, e.g. + # "MH_NO" rather than the display label "MH No". Bulk-edit mode + # needs these to know which real database column each input maps + # to, since the table only shows the prettified header text. + self.tr_fields = [] + self.mh_fields = [] + self.dc_fields = [] + self.laying_fields = [] + + for df, attr in [ + (self.df_tr, "tr_fields"), + (self.df_mh, "mh_fields"), + (self.df_dc, "dc_fields"), + (self.df_laying, "laying_fields"), + ]: if not df.empty: df.drop(columns=drop_cols, errors="ignore", inplace=True) + setattr(self, attr, list(df.columns)) format_column_names(df) name = "" @@ -159,6 +327,60 @@ def delete_records(): return jsonify({"status": "error", "message": str(e)}), 500 +@file_report_bp.route("/bulk_update", methods=["POST"]) +@login_required +def bulk_update(): + """Bulk-edit save endpoint. Expects JSON shaped like: + { "tr": { "5": {"MH_NO": "12A", "Location": "Pune"}, ... }, "mh": {...}, ... } + + Field names are validated against each model's real table columns + server-side - the frontend sending a field name is not enough on its + own to permit writing it; id/subcontractor_id/created_at are always + refused regardless of what's submitted. + """ + data = request.json or {} + + model_map = { + "tr": TrenchExcavation, + "mh": ManholeExcavation, + "dc": ManholeDomesticChamber, + "laying": Laying + } + PROTECTED_FIELDS = {"id", "subcontractor_id", "created_at"} + + updated = 0 + errors = [] + + try: + for model_key, records in data.items(): + ModelClass = model_map.get(model_key) + if not ModelClass: + errors.append(f"Unknown table '{model_key}'") + continue + + valid_columns = {c.name for c in ModelClass.__table__.columns} - PROTECTED_FIELDS + + for record_id, fields in (records or {}).items(): + obj = ModelClass.query.get(record_id) + if not obj: + errors.append(f"{model_key} #{record_id}: record not found") + continue + + for field, value in (fields or {}).items(): + if field not in valid_columns: + errors.append(f"{model_key} #{record_id}: '{field}' is not editable") + continue + setattr(obj, field, value) + updated += 1 + + db.session.commit() + except Exception as e: + db.session.rollback() + return jsonify({"status": "error", "message": str(e)}), 500 + + return jsonify({"status": "success", "updated": updated, "errors": errors}) + + @file_report_bp.route("/edit//", methods=["GET", "POST"]) @login_required def edit_record(model, record_id): @@ -211,28 +433,40 @@ def edit_record(model, record_id): def report_file(): # get all subcontractor data subcontractors = Subcontractor.query.all() + locations = get_distinct_locations() tables = None abstract_html = "" selected_sc_id = None + has_data = {"tr": False, "mh": False, "dc": False, "laying": False} ra_bill_no = "" location = "" + mh_no = "" category = "" # Search or load data if request.method == "POST": # get from data - subcontractor_id = request.form.get("subcontractor_id") + subcontractor_id = request.form.get("subcontractor_id") or None ra_bill_no = request.form.get("ra_bill_no", "").strip() location = request.form.get("location", "").strip() + mh_no = request.form.get("mh_no", "").strip() category = request.form.get("category", "") action = request.form.get("action", "preview") - if not subcontractor_id: - flash("Select Subcontractor", "danger") + # Keep the subcontractor dropdown scoped to the chosen location + # even on a plain (non-JS) page render. + subcontractors = get_subcontractors_for_location(location) + + # Subcontractor is now optional - at least one other filter must + # be given so the search isn't a "return everything" query. + if not subcontractor_id and not location and not ra_bill_no and not mh_no: + flash("Enter at least a Location, RA Bill No, MH No, or Subcontractor to search", "danger") return render_template( "subcontractor_report.html", - subcontractors=subcontractors + subcontractors=subcontractors, + locations=locations, + has_data=has_data ) selected_sc_id = subcontractor_id @@ -241,7 +475,7 @@ def report_file(): if action == "excel_all": bill.Fetch(subcontractor_id=subcontractor_id) else: - bill.Fetch(ra_bill_no,subcontractor_id,location) + bill.Fetch(ra_bill_no, subcontractor_id, location, mh_no) # --------------------------------------------------------- @@ -383,6 +617,15 @@ def report_file(): bill.df_mh = add_action_columns(bill.df_mh, "mh") bill.df_dc = add_action_columns(bill.df_dc, "dc") bill.df_laying = add_action_columns(bill.df_laying, "laying") + + # Used by the template to hide Delete Selected / Bulk Edit for a + # category that has no rows to act on. + has_data = { + "tr": not bill.df_tr.empty, + "mh": not bill.df_mh.empty, + "dc": not bill.df_dc.empty, + "laying": not bill.df_laying.empty, + } # this are html classes # table_class = ( "table " "table-bordered" "table-hover " "table-striped " "table-sm " "align-middle " "datatable " "mb-0") @@ -400,21 +643,24 @@ def report_file(): # This are showing on web tables tables = { - "tr": bill.df_tr.to_html(classes=table_class, index=False, escape=False), - "mh": bill.df_mh.to_html(classes=table_class, index=False, escape=False), - "dc": bill.df_dc.to_html(classes=table_class, index=False, escape=False ), - "laying": bill.df_laying.to_html(classes=table_class, index=False, escape=False) + "tr": render_table_or_empty(bill.df_tr, "tr", table_class, bill.tr_fields), + "mh": render_table_or_empty(bill.df_mh, "mh", table_class, bill.mh_fields), + "dc": render_table_or_empty(bill.df_dc, "dc", table_class, bill.dc_fields), + "laying": render_table_or_empty(bill.df_laying, "laying", table_class, bill.laying_fields) } return render_template( "subcontractor_report.html", subcontractors=subcontractors, + locations=locations, selected_sc_id=selected_sc_id, selected_ra_bill=ra_bill_no, selected_location=location, + selected_mh_no=mh_no, selected_category=category, tables=tables, - abstract_html=abstract_html + abstract_html=abstract_html, + has_data=has_data ) diff --git a/app/templates/client_report.html b/app/templates/client_report.html index dfa2696..03f5bc3 100644 --- a/app/templates/client_report.html +++ b/app/templates/client_report.html @@ -31,7 +31,6 @@ type="button">Tr.Ex @@ -40,26 +39,9 @@ - -