Compare commits
15 Commits
568428b5d0
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
| 5577576112 | |||
| ce0e4f90cf | |||
| 1d83534a95 | |||
| 446778a50c | |||
| 5ddfb1f440 | |||
| 96a3a79731 | |||
| 310ab40bf9 | |||
| c5b3e7bd60 | |||
| bb56f00a6c | |||
| 8353bb6426 | |||
| 21f8576e33 | |||
| 5ab11bc5a6 | |||
| 45bfd4b592 | |||
| 1dceb640bd | |||
| 359847958d |
5
.gitignore
vendored
5
.gitignore
vendored
@@ -13,8 +13,7 @@ venv
|
||||
|
||||
# Ignore Log files ss
|
||||
logs/
|
||||
|
||||
# Ignore db folders
|
||||
instance/
|
||||
*.log
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -36,7 +36,8 @@ The Comparison Project is designed to:
|
||||
|
||||
## Tech Stack
|
||||
|
||||
**Backend Framework**: Flask
|
||||
**Frontend Framework**: HTML, CSS, Js, Bootstrap
|
||||
**Backend Framework**: Python Flask
|
||||
**Database**: SQL Database (MySQL/PostgreSQL/SQLite configured via environment variables)
|
||||
**ORM**: SQLAlchemy
|
||||
**File Processing**: Pandas, OpenPyXL, XlsxWriter
|
||||
@@ -580,4 +581,4 @@ Open browser: `http://127.0.0.1:5000/`
|
||||
|
||||
For issues, feature requests, or contributions, please contact the development team.
|
||||
|
||||
**Last Updated:** January 2026
|
||||
**Last Updated:** April 2026
|
||||
@@ -1,6 +1,7 @@
|
||||
from flask import Flask, redirect, url_for
|
||||
from app.config import Config
|
||||
from app.services.db_service import db
|
||||
from app.services.logger_service import LoggerService
|
||||
|
||||
def create_app():
|
||||
app = Flask(__name__)
|
||||
@@ -9,6 +10,9 @@ def create_app():
|
||||
# Initialize extensions
|
||||
db.init_app(app)
|
||||
|
||||
# Initialize Logger
|
||||
LoggerService.init_app(app)
|
||||
|
||||
# Register blueprints
|
||||
register_blueprints(app)
|
||||
# Register error handlers
|
||||
@@ -43,10 +47,15 @@ def register_blueprints(app):
|
||||
|
||||
|
||||
def register_error_handlers(app):
|
||||
|
||||
from flask import current_app
|
||||
|
||||
@app.errorhandler(404)
|
||||
def page_not_found(e):
|
||||
current_app.logger.warning("404 Page Not Found")
|
||||
return "Page Not Found", 404
|
||||
|
||||
@app.errorhandler(500)
|
||||
def internal_error(e):
|
||||
return "Internal Server Error", 500
|
||||
current_app.logger.exception("500 Internal Server Error")
|
||||
return "Internal Server Error", 500
|
||||
11
app/constants/http_status.py
Normal file
11
app/constants/http_status.py
Normal file
@@ -0,0 +1,11 @@
|
||||
class HTTPStatus:
|
||||
OK = 200
|
||||
CREATED = 201
|
||||
BAD_REQUEST = 400
|
||||
UNAUTHORIZED = 401
|
||||
FORBIDDEN = 403
|
||||
NOT_FOUND = 404
|
||||
METHOD_NOT_ALLOWED = 405
|
||||
CONFLICT = 409
|
||||
UNPROCESSABLE_ENTITY = 422
|
||||
INTERNAL_SERVER_ERROR = 500
|
||||
17
app/constants/messages.py
Normal file
17
app/constants/messages.py
Normal file
@@ -0,0 +1,17 @@
|
||||
class SuccessMessage:
|
||||
FETCHED = "Data fetched successfully"
|
||||
CREATED = "Resource created successfully"
|
||||
UPDATED = "Resource updated successfully"
|
||||
DELETED = "Resource deleted successfully"
|
||||
LOGIN = "Login successful"
|
||||
LOGOUT = "Logout successful"
|
||||
|
||||
|
||||
class ErrorMessage:
|
||||
INVALID_REQUEST = "Invalid request data"
|
||||
UNAUTHORIZED = "Unauthorized access"
|
||||
FORBIDDEN = "Access forbidden"
|
||||
NOT_FOUND = "Resource not found"
|
||||
VALIDATION_FAILED = "Validation failed"
|
||||
INTERNAL_ERROR = "Internal server error"
|
||||
DUPLICATE_ENTRY = "Duplicate record found"
|
||||
66
app/errors/error_handlers.py
Normal file
66
app/errors/error_handlers.py
Normal file
@@ -0,0 +1,66 @@
|
||||
from flask import request, render_template
|
||||
from app.utils.response_handler import ResponseHandler
|
||||
from app.utils.exceptions import APIException
|
||||
from app.constants.http_status import HTTPStatus
|
||||
from app.constants.messages import ErrorMessage
|
||||
from app.services.db_service import db
|
||||
import traceback
|
||||
|
||||
|
||||
def register_error_handlers(app):
|
||||
|
||||
# Custom API Exception
|
||||
@app.errorhandler(APIException)
|
||||
def handle_api_exception(e):
|
||||
db.session.rollback()
|
||||
|
||||
if request.path.startswith("/api"):
|
||||
return ResponseHandler.error(
|
||||
message=e.message,
|
||||
errors=e.errors,
|
||||
status_code=e.status_code
|
||||
)
|
||||
|
||||
return render_template("errors/500.html"), e.status_code
|
||||
|
||||
|
||||
# 404
|
||||
@app.errorhandler(404)
|
||||
def handle_404(e):
|
||||
if request.path.startswith("/api"):
|
||||
return ResponseHandler.error(
|
||||
message=ErrorMessage.NOT_FOUND,
|
||||
status_code=HTTPStatus.NOT_FOUND
|
||||
)
|
||||
|
||||
return render_template("errors/404.html"), 404
|
||||
|
||||
|
||||
# 500
|
||||
@app.errorhandler(500)
|
||||
def handle_500(e):
|
||||
db.session.rollback()
|
||||
traceback.print_exc()
|
||||
|
||||
if request.path.startswith("/api"):
|
||||
return ResponseHandler.error(
|
||||
message=ErrorMessage.INTERNAL_ERROR,
|
||||
status_code=HTTPStatus.INTERNAL_SERVER_ERROR
|
||||
)
|
||||
|
||||
return render_template("errors/500.html"), 500
|
||||
|
||||
|
||||
# Catch All
|
||||
@app.errorhandler(Exception)
|
||||
def handle_general_exception(e):
|
||||
db.session.rollback()
|
||||
traceback.print_exc()
|
||||
|
||||
if request.path.startswith("/api"):
|
||||
return ResponseHandler.error(
|
||||
message=ErrorMessage.INTERNAL_ERROR,
|
||||
status_code=HTTPStatus.INTERNAL_SERVER_ERROR
|
||||
)
|
||||
|
||||
return render_template("errors/500.html"), 500
|
||||
@@ -1,9 +1,7 @@
|
||||
from app import db
|
||||
from datetime import datetime
|
||||
from sqlalchemy import event
|
||||
import re
|
||||
# REGEX PATTERN
|
||||
PIPE_MM_PATTERN = re.compile(r"^pipe_\d+_mm$")
|
||||
from app.utils.regex_utils import RegularExpression
|
||||
|
||||
class LayingClient(db.Model):
|
||||
__tablename__ = "laying_client"
|
||||
@@ -13,33 +11,33 @@ class LayingClient(db.Model):
|
||||
# Basic Fields
|
||||
Location = db.Column(db.String(500))
|
||||
MH_NO = db.Column(db.String(100))
|
||||
CC_length = db.Column(db.Float)
|
||||
CC_length = db.Column(db.Float, default=0)
|
||||
# Bedding Qty.
|
||||
Outer_dia_of_MH_m = db.Column(db.Float)
|
||||
Bedding_Length = db.Column(db.Float)
|
||||
Width = db.Column(db.Float)
|
||||
Depth = db.Column(db.Float)
|
||||
Qty = db.Column(db.Float)
|
||||
Outer_dia_of_MH_m = db.Column(db.Float, default=0)
|
||||
Bedding_Length = db.Column(db.Float, default=0)
|
||||
Width = db.Column(db.Float, default=0)
|
||||
Depth = db.Column(db.Float, default=0)
|
||||
Qty = db.Column(db.Float, default=0)
|
||||
|
||||
# PIPE LAYING Qty.
|
||||
Pipe_Dia_mm = db.Column(db.Float)
|
||||
ID_of_MH_m = db.Column(db.Float)
|
||||
Laying_Length = db.Column(db.Float)
|
||||
Pipe_Dia_mm = db.Column(db.Float, default=0)
|
||||
ID_of_MH_m = db.Column(db.Float, default=0)
|
||||
Laying_Length = db.Column(db.Float, default=0)
|
||||
|
||||
pipe_150_mm = db.Column(db.Float)
|
||||
pipe_200_mm = db.Column(db.Float)
|
||||
pipe_250_mm = db.Column(db.Float)
|
||||
pipe_300_mm = db.Column(db.Float)
|
||||
pipe_350_mm = db.Column(db.Float)
|
||||
pipe_400_mm = db.Column(db.Float)
|
||||
pipe_450_mm = db.Column(db.Float)
|
||||
pipe_500_mm = db.Column(db.Float)
|
||||
pipe_600_mm = db.Column(db.Float)
|
||||
pipe_700_mm = db.Column(db.Float)
|
||||
pipe_900_mm = db.Column(db.Float)
|
||||
pipe_1200_mm = db.Column(db.Float)
|
||||
pipe_150_mm = db.Column(db.Float, default=0)
|
||||
pipe_200_mm = db.Column(db.Float, default=0)
|
||||
pipe_250_mm = db.Column(db.Float, default=0)
|
||||
pipe_300_mm = db.Column(db.Float, default=0)
|
||||
pipe_350_mm = db.Column(db.Float, default=0)
|
||||
pipe_400_mm = db.Column(db.Float, default=0)
|
||||
pipe_450_mm = db.Column(db.Float, default=0)
|
||||
pipe_500_mm = db.Column(db.Float, default=0)
|
||||
pipe_600_mm = db.Column(db.Float, default=0)
|
||||
pipe_700_mm = db.Column(db.Float, default=0)
|
||||
pipe_900_mm = db.Column(db.Float, default=0)
|
||||
pipe_1200_mm = db.Column(db.Float, default=0)
|
||||
|
||||
Total = db.Column(db.Float)
|
||||
Total = db.Column(db.Float, default=0)
|
||||
Remarks = db.Column(db.String(500))
|
||||
RA_Bill_No=db.Column(db.String(500))
|
||||
|
||||
@@ -52,25 +50,13 @@ class LayingClient(db.Model):
|
||||
def serialize(self):
|
||||
return {c.name: getattr(self, c.name) for c in self.__table__.columns}
|
||||
|
||||
|
||||
def sum_laying_fields():
|
||||
return [
|
||||
"pipe_150_mm", "pipe_200_mm", "pipe_250_mm",
|
||||
"pipe_300_mm", "pipe_350_mm", "pipe_400_mm",
|
||||
"pipe_450_mm", "pipe_500_mm", "pipe_600_mm",
|
||||
"pipe_700_mm", "pipe_900_mm", "pipe_1200_mm"
|
||||
]
|
||||
|
||||
# ===============================
|
||||
|
||||
# AUTO TOTAL USING REGEX
|
||||
# ===============================
|
||||
def calculate_laying_total(mapper, connection, target):
|
||||
total = 0
|
||||
|
||||
for column in target.__table__.columns:
|
||||
if PIPE_MM_PATTERN.match(column.name):
|
||||
if RegularExpression.PIPE_MM_PATTERN.match(column.name):
|
||||
total += getattr(target, column.name) or 0
|
||||
|
||||
target.Total = total
|
||||
|
||||
event.listen(LayingClient, "before_insert", calculate_laying_total)
|
||||
|
||||
@@ -1,9 +1,7 @@
|
||||
from app import db
|
||||
from datetime import datetime
|
||||
from sqlalchemy import event
|
||||
import re
|
||||
# REGEX PATTERN
|
||||
PIPE_MM_PATTERN = re.compile(r"^pipe_\d+_mm$")
|
||||
from app.utils.regex_utils import RegularExpression
|
||||
|
||||
class Laying(db.Model):
|
||||
__tablename__ = "laying"
|
||||
@@ -17,25 +15,25 @@ class Laying(db.Model):
|
||||
# Pipe Laying Fields
|
||||
Location = db.Column(db.String(500))
|
||||
MH_NO = db.Column(db.String(100))
|
||||
CC_length = db.Column(db.Float)
|
||||
Pipe_Dia_mm = db.Column(db.Float)
|
||||
ID_of_MH_m = db.Column(db.Float)
|
||||
Laying_Length = db.Column(db.Float)
|
||||
CC_length = db.Column(db.Float, default=0)
|
||||
Pipe_Dia_mm = db.Column(db.Float, default=0)
|
||||
ID_of_MH_m = db.Column(db.Float, default=0)
|
||||
Laying_Length = db.Column(db.Float, default=0)
|
||||
|
||||
pipe_150_mm = db.Column(db.Float)
|
||||
pipe_200_mm = db.Column(db.Float)
|
||||
pipe_250_mm = db.Column(db.Float)
|
||||
pipe_300_mm = db.Column(db.Float)
|
||||
pipe_350_mm = db.Column(db.Float)
|
||||
pipe_400_mm = db.Column(db.Float)
|
||||
pipe_450_mm = db.Column(db.Float)
|
||||
pipe_500_mm = db.Column(db.Float)
|
||||
pipe_600_mm = db.Column(db.Float)
|
||||
pipe_700_mm = db.Column(db.Float)
|
||||
pipe_900_mm = db.Column(db.Float)
|
||||
pipe_1200_mm = db.Column(db.Float)
|
||||
pipe_150_mm = db.Column(db.Float, default=0)
|
||||
pipe_200_mm = db.Column(db.Float, default=0)
|
||||
pipe_250_mm = db.Column(db.Float, default=0)
|
||||
pipe_300_mm = db.Column(db.Float, default=0)
|
||||
pipe_350_mm = db.Column(db.Float, default=0)
|
||||
pipe_400_mm = db.Column(db.Float, default=0)
|
||||
pipe_450_mm = db.Column(db.Float, default=0)
|
||||
pipe_500_mm = db.Column(db.Float, default=0)
|
||||
pipe_600_mm = db.Column(db.Float, default=0)
|
||||
pipe_700_mm = db.Column(db.Float, default=0)
|
||||
pipe_900_mm = db.Column(db.Float, default=0)
|
||||
pipe_1200_mm = db.Column(db.Float, default=0)
|
||||
|
||||
Total = db.Column(db.Float)
|
||||
Total = db.Column(db.Float, default=0)
|
||||
Remarks = db.Column(db.String(500))
|
||||
RA_Bill_No=db.Column(db.String(500))
|
||||
|
||||
@@ -49,24 +47,12 @@ class Laying(db.Model):
|
||||
return {c.name: getattr(self, c.name) for c in self.__table__.columns}
|
||||
|
||||
|
||||
def sum_laying_fields():
|
||||
return [
|
||||
"pipe_150_mm", "pipe_200_mm", "pipe_250_mm",
|
||||
"pipe_300_mm", "pipe_350_mm", "pipe_400_mm",
|
||||
"pipe_450_mm", "pipe_500_mm", "pipe_600_mm",
|
||||
"pipe_700_mm", "pipe_900_mm", "pipe_1200_mm"
|
||||
]
|
||||
|
||||
# ===============================
|
||||
# AUTO TOTAL USING REGEX
|
||||
# ===============================
|
||||
def calculate_laying_total(mapper, connection, target):
|
||||
total = 0
|
||||
|
||||
for column in target.__table__.columns:
|
||||
if PIPE_MM_PATTERN.match(column.name):
|
||||
if RegularExpression.PIPE_MM_PATTERN.match(column.name):
|
||||
total += getattr(target, column.name) or 0
|
||||
|
||||
target.Total = total
|
||||
|
||||
event.listen(Laying, "before_insert", calculate_laying_total)
|
||||
|
||||
@@ -1,10 +1,7 @@
|
||||
from app import db
|
||||
from datetime import datetime
|
||||
from sqlalchemy import event
|
||||
import re
|
||||
|
||||
# REGEX PATTERN
|
||||
D_RANGE_PATTERN = re.compile(r"^d_\d+(?:_\d+)?_to_\d+(?:_\d+)?$")
|
||||
from app.utils.regex_utils import RegularExpression
|
||||
|
||||
class ManholeDomesticChamber(db.Model):
|
||||
__tablename__ = "manhole_domestic_chamber"
|
||||
@@ -18,35 +15,35 @@ class ManholeDomesticChamber(db.Model):
|
||||
# Basic Fields
|
||||
Location = db.Column(db.String(500))
|
||||
MH_NO = db.Column(db.String(100))
|
||||
Depth_of_MH = db.Column(db.Float)
|
||||
Depth_of_MH = db.Column(db.Float, default=0)
|
||||
|
||||
# Excavation categories
|
||||
d_0_to_0_75 = db.Column(db.Float)
|
||||
d_0_76_to_1_05 = db.Column(db.Float)
|
||||
d_1_06_to_1_65 = db.Column(db.Float)
|
||||
d_1_66_to_2_15 = db.Column(db.Float)
|
||||
d_2_16_to_2_65 = db.Column(db.Float)
|
||||
d_2_66_to_3_15 = db.Column(db.Float)
|
||||
d_3_16_to_3_65= db.Column(db.Float)
|
||||
d_3_66_to_4_15 = db.Column(db.Float)
|
||||
d_4_16_to_4_65 = db.Column(db.Float)
|
||||
d_4_66_to_5_15 = db.Column(db.Float)
|
||||
d_5_16_to_5_65 = db.Column(db.Float)
|
||||
d_5_66_to_6_15 = db.Column(db.Float)
|
||||
d_6_16_to_6_65 = db.Column(db.Float)
|
||||
d_6_66_to_7_15 = db.Column(db.Float)
|
||||
d_7_16_to_7_65 = db.Column(db.Float)
|
||||
d_7_66_to_8_15 = db.Column(db.Float)
|
||||
d_8_16_to_8_65 = db.Column(db.Float)
|
||||
d_8_66_to_9_15 = db.Column(db.Float)
|
||||
d_9_16_to_9_65 = db.Column(db.Float)
|
||||
d_0_to_0_75 = db.Column(db.Float, default=0)
|
||||
d_0_76_to_1_05 = db.Column(db.Float, default=0)
|
||||
d_1_06_to_1_65 = db.Column(db.Float, default=0)
|
||||
d_1_66_to_2_15 = db.Column(db.Float, default=0)
|
||||
d_2_16_to_2_65 = db.Column(db.Float, default=0)
|
||||
d_2_66_to_3_15 = db.Column(db.Float, default=0)
|
||||
d_3_16_to_3_65= db.Column(db.Float, default=0)
|
||||
d_3_66_to_4_15 = db.Column(db.Float, default=0)
|
||||
d_4_16_to_4_65 = db.Column(db.Float, default=0)
|
||||
d_4_66_to_5_15 = db.Column(db.Float, default=0)
|
||||
d_5_16_to_5_65 = db.Column(db.Float, default=0)
|
||||
d_5_66_to_6_15 = db.Column(db.Float, default=0)
|
||||
d_6_16_to_6_65 = db.Column(db.Float, default=0)
|
||||
d_6_66_to_7_15 = db.Column(db.Float, default=0)
|
||||
d_7_16_to_7_65 = db.Column(db.Float, default=0)
|
||||
d_7_66_to_8_15 = db.Column(db.Float, default=0)
|
||||
d_8_16_to_8_65 = db.Column(db.Float, default=0)
|
||||
d_8_66_to_9_15 = db.Column(db.Float, default=0)
|
||||
d_9_16_to_9_65 = db.Column(db.Float, default=0)
|
||||
|
||||
Domestic_Chambers = db.Column(db.Float)
|
||||
DWC_Pipe_Length = db.Column(db.Float)
|
||||
UPVC_Pipe_Length = db.Column(db.Float)
|
||||
Domestic_Chambers = db.Column(db.Float, default=0)
|
||||
DWC_Pipe_Length = db.Column(db.Float, default=0)
|
||||
UPVC_Pipe_Length = db.Column(db.Float, default=0)
|
||||
RA_Bill_No=db.Column(db.String(500))
|
||||
|
||||
Total = db.Column(db.Float)
|
||||
Total = db.Column(db.Float, default=0)
|
||||
created_at = db.Column(db.DateTime, default=datetime.today)
|
||||
|
||||
def __repr__(self):
|
||||
@@ -56,28 +53,13 @@ class ManholeDomesticChamber(db.Model):
|
||||
return {c.name: getattr(self, c.name) for c in self.__table__.columns}
|
||||
|
||||
|
||||
def sum_mh_dc_fields():
|
||||
return [
|
||||
"d_0_to_0_75", "d_0_76_to_1_05", "d_1_06_to_1_65",
|
||||
"d_1_66_to_2_15", "d_2_16_to_2_65", "d_2_66_to_3_15",
|
||||
"d_3_16_to_3_65", "d_3_66_to_4_15", "d_4_16_to_4_65",
|
||||
"d_4_66_to_5_15", "d_5_16_to_5_65", "d_5_66_to_6_15",
|
||||
"d_6_16_to_6_65", "d_6_66_to_7_15", "d_7_16_to_7_65",
|
||||
"d_7_66_to_8_15", "d_8_16_to_8_65", "d_8_66_to_9_15",
|
||||
"d_9_16_to_9_65"]
|
||||
|
||||
# ===============================
|
||||
# AUTO TOTAL USING REGEX
|
||||
# ===============================
|
||||
def calculate_mh_dc_total(mapper, connection, target):
|
||||
total = 0
|
||||
|
||||
for column in target.__table__.columns:
|
||||
if D_RANGE_PATTERN.match(column.name):
|
||||
if RegularExpression.D_RANGE_PATTERN.match(column.name):
|
||||
total += getattr(target, column.name) or 0
|
||||
|
||||
target.Total = total
|
||||
|
||||
|
||||
event.listen(ManholeDomesticChamber, "before_insert", calculate_mh_dc_total)
|
||||
event.listen(ManholeDomesticChamber, "before_update", calculate_mh_dc_total)
|
||||
@@ -1,6 +1,7 @@
|
||||
from app import db
|
||||
from datetime import datetime
|
||||
from sqlalchemy import event
|
||||
from app.utils.regex_utils import RegularExpression
|
||||
|
||||
class ManholeExcavation(db.Model):
|
||||
__tablename__ = "manhole_excavation"
|
||||
@@ -15,47 +16,47 @@ class ManholeExcavation(db.Model):
|
||||
Location = db.Column(db.String(500))
|
||||
MH_NO = db.Column(db.String(100))
|
||||
|
||||
Upto_IL_Depth = db.Column(db.Float)
|
||||
Cutting_Depth = db.Column(db.Float)
|
||||
ID_of_MH_m = db.Column(db.Float)
|
||||
Ex_Dia_of_Manhole = db.Column(db.Float)
|
||||
Area_of_Manhole = db.Column(db.Float)
|
||||
Upto_IL_Depth = db.Column(db.Float, default=0)
|
||||
Cutting_Depth = db.Column(db.Float, default=0)
|
||||
ID_of_MH_m = db.Column(db.Float, default=0)
|
||||
Ex_Dia_of_Manhole = db.Column(db.Float, default=0)
|
||||
Area_of_Manhole = db.Column(db.Float, default=0)
|
||||
|
||||
# Excavation categories
|
||||
Soft_Murum_0_to_1_5 = db.Column(db.Float)
|
||||
Soft_Murum_1_5_to_3_0 = db.Column(db.Float)
|
||||
Soft_Murum_3_0_to_4_5 = db.Column(db.Float)
|
||||
Soft_Murum_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Soft_Murum_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Soft_Murum_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Murum_0_to_1_5 = db.Column(db.Float)
|
||||
Hard_Murum_1_5_to_3_0 = db.Column(db.Float)
|
||||
Hard_Murum_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Hard_Murum_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
|
||||
Soft_Rock_0_to_1_5 = db.Column(db.Float)
|
||||
Soft_Rock_1_5_to_3_0 = db.Column(db.Float)
|
||||
Soft_Rock_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Soft_Rock_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Rock_0_to_1_5 = db.Column(db.Float)
|
||||
Hard_Rock_1_5_to_3_0 = db.Column(db.Float)
|
||||
Hard_Rock_3_0_to_4_5 = db.Column(db.Float)
|
||||
Hard_Rock_4_5_to_6_0 = db.Column(db.Float)
|
||||
Hard_Rock_6_0_to_7_5 = db.Column(db.Float)
|
||||
Hard_Rock_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_4_5_to_6_0 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_6_0_to_7_5 = db.Column(db.Float, default=0)
|
||||
|
||||
# Totals
|
||||
Soft_Murum_0_to_1_5_total = db.Column(db.Float)
|
||||
Soft_Murum_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Soft_Murum_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Soft_Murum_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Soft_Murum_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Soft_Murum_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Murum_0_to_1_5_total = db.Column(db.Float)
|
||||
Hard_Murum_1_5_and_above_total = db.Column(db.Float)
|
||||
Hard_Murum_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Hard_Murum_1_5_and_above_total = db.Column(db.Float, default=0)
|
||||
|
||||
Soft_Rock_0_to_1_5_total = db.Column(db.Float)
|
||||
Soft_Rock_1_5_and_above_total = db.Column(db.Float)
|
||||
Soft_Rock_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Soft_Rock_1_5_and_above_total = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Rock_0_to_1_5_total = db.Column(db.Float)
|
||||
Hard_Rock_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Hard_Rock_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Hard_Rock_4_5_to_6_0_total = db.Column(db.Float)
|
||||
Hard_Rock_6_0_to_7_5_total = db.Column(db.Float)
|
||||
Hard_Rock_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_4_5_to_6_0_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_6_0_to_7_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Total = db.Column(db.Float)
|
||||
Total = db.Column(db.Float, default=0)
|
||||
Remarks = db.Column(db.String(500))
|
||||
RA_Bill_No=db.Column(db.String(500))
|
||||
|
||||
@@ -67,13 +68,11 @@ class ManholeExcavation(db.Model):
|
||||
def serialize(self):
|
||||
return {c.name: getattr(self, c.name) for c in self.__table__.columns}
|
||||
|
||||
# ==========================================
|
||||
# AUTO CALCULATE GRAND TOTAL
|
||||
# ==========================================
|
||||
# AUTO TOTAL USING REGEX
|
||||
def calculate_Manhole_total(mapper, connection, target):
|
||||
total = 0
|
||||
for column in target.__table__.columns:
|
||||
if column.name.endswith("_total"):
|
||||
if RegularExpression.STR_TOTAL_PATTERN.match(column.name):
|
||||
total += getattr(target, column.name) or 0
|
||||
target.Total = total
|
||||
|
||||
|
||||
@@ -1,45 +1,37 @@
|
||||
from app import db
|
||||
from datetime import datetime
|
||||
from sqlalchemy import event
|
||||
import re
|
||||
|
||||
# REGEX PATTERN
|
||||
D_RANGE_PATTERN = re.compile(r"^d_\d+(?:_\d+)?_to_\d+(?:_\d+)?$")
|
||||
from app.utils.regex_utils import RegularExpression
|
||||
|
||||
class ManholeDomesticChamberClient(db.Model):
|
||||
__tablename__ = "mh_dc_client"
|
||||
|
||||
id = db.Column(db.Integer, primary_key=True)
|
||||
# Foreign Key to Subcontractor table
|
||||
# subcontractor_id = db.Column(db.Integer, db.ForeignKey("subcontractors.id"), nullable=False)
|
||||
# Relationship for easy access (subcontractor.subcontractor_name)
|
||||
# subcontractor = db.relationship("Subcontractor", backref="mh_dc_records")
|
||||
|
||||
# Basic Fields
|
||||
RA_Bill_No=db.Column(db.String(500))
|
||||
Location = db.Column(db.String(500))
|
||||
MH_NO = db.Column(db.String(100))
|
||||
MH_TOP_LEVEL = db.Column(db.Float)
|
||||
MH_IL_LEVEL = db.Column(db.Float)
|
||||
Depth_of_MH = db.Column(db.Float)
|
||||
MH_TOP_LEVEL = db.Column(db.Float, default=0)
|
||||
MH_IL_LEVEL = db.Column(db.Float, default=0)
|
||||
Depth_of_MH = db.Column(db.Float, default=0)
|
||||
|
||||
|
||||
# Excavation categories
|
||||
d_0_to_1_5 = db.Column(db.Float)
|
||||
d_1_5_to_2_0 = db.Column(db.Float)
|
||||
d_2_0_to_2_5 = db.Column(db.Float)
|
||||
d_2_5_to_3_0 = db.Column(db.Float)
|
||||
d_3_0_to_3_5 = db.Column(db.Float)
|
||||
d_3_5_to_4_0 = db.Column(db.Float)
|
||||
d_4_0_to_4_5= db.Column(db.Float)
|
||||
d_4_5_to_5_0 = db.Column(db.Float)
|
||||
d_5_0_to_5_5 = db.Column(db.Float)
|
||||
d_5_5_to_6_0 = db.Column(db.Float)
|
||||
d_6_0_to_6_5 = db.Column(db.Float)
|
||||
d_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
d_1_5_to_2_0 = db.Column(db.Float, default=0)
|
||||
d_2_0_to_2_5 = db.Column(db.Float, default=0)
|
||||
d_2_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
d_3_0_to_3_5 = db.Column(db.Float, default=0)
|
||||
d_3_5_to_4_0 = db.Column(db.Float, default=0)
|
||||
d_4_0_to_4_5= db.Column(db.Float, default=0)
|
||||
d_4_5_to_5_0 = db.Column(db.Float, default=0)
|
||||
d_5_0_to_5_5 = db.Column(db.Float, default=0)
|
||||
d_5_5_to_6_0 = db.Column(db.Float, default=0)
|
||||
d_6_0_to_6_5 = db.Column(db.Float, default=0)
|
||||
|
||||
Domestic_Chambers = db.Column(db.Float)
|
||||
Domestic_Chambers = db.Column(db.Float, default=0)
|
||||
|
||||
Total = db.Column(db.Float)
|
||||
Total = db.Column(db.Float, default=0)
|
||||
created_at = db.Column(db.DateTime, default=datetime.today)
|
||||
|
||||
def __repr__(self):
|
||||
@@ -49,27 +41,13 @@ class ManholeDomesticChamberClient(db.Model):
|
||||
def serialize(self):
|
||||
return {c.name: getattr(self, c.name) for c in self.__table__.columns}
|
||||
|
||||
|
||||
def sum_mh_dc_fields():
|
||||
return [
|
||||
"d_0_to_0_75", "d_0_76_to_1_05", "d_1_06_to_1_65",
|
||||
"d_1_66_to_2_15", "d_2_16_to_2_65", "d_2_66_to_3_15",
|
||||
"d_3_16_to_3_65", "d_3_66_to_4_15", "d_4_16_to_4_65",
|
||||
"d_4_66_to_5_15", "d_5_16_to_5_65", "d_5_66_to_6_15",
|
||||
"d_6_16_to_6_65", "d_6_66_to_7_15", "d_7_16_to_7_65",
|
||||
"d_7_66_to_8_15", "d_8_16_to_8_65", "d_8_66_to_9_15",
|
||||
"d_9_16_to_9_65" ]
|
||||
|
||||
# ===============================
|
||||
|
||||
# AUTO TOTAL USING REGEX
|
||||
# ===============================
|
||||
def calculate_mh_dc_total(mapper, connection, target):
|
||||
total = 0
|
||||
|
||||
for column in target.__table__.columns:
|
||||
if D_RANGE_PATTERN.match(column.name):
|
||||
if RegularExpression.D_RANGE_PATTERN.match(column.name):
|
||||
total += getattr(target, column.name) or 0
|
||||
|
||||
target.Total = total
|
||||
|
||||
|
||||
|
||||
@@ -1,79 +1,76 @@
|
||||
from app import db
|
||||
from datetime import datetime
|
||||
from sqlalchemy import event
|
||||
from app.utils.regex_utils import RegularExpression
|
||||
|
||||
class ManholeExcavationClient(db.Model):
|
||||
__tablename__ = "mh_ex_client"
|
||||
|
||||
id = db.Column(db.Integer, primary_key=True)
|
||||
# Foreign Key to Subcontractor table
|
||||
# subcontractor_id = db.Column(db.Integer, db.ForeignKey("subcontractors.id"), nullable=False)
|
||||
# Relationship for easy access (subcontractor.subcontractor_name)
|
||||
# subcontractor = db.relationship("Subcontractor", backref="mh_ex_records")
|
||||
|
||||
# Basic Fields
|
||||
RA_Bill_No=db.Column(db.String(500))
|
||||
Location = db.Column(db.String(500))
|
||||
MH_NO = db.Column(db.String(100))
|
||||
Ground_Level = db.Column(db.Float)
|
||||
MH_Invert_Level = db.Column(db.Float)
|
||||
MH_Top_Level = db.Column(db.Float)
|
||||
Ex_Level = db.Column(db.Float)
|
||||
Cutting_Depth = db.Column(db.Float)
|
||||
MH_Depth = db.Column(db.Float)
|
||||
ID_of_MH_m = db.Column(db.Float)
|
||||
Ground_Level = db.Column(db.Float, default=0)
|
||||
MH_Invert_Level = db.Column(db.Float, default=0)
|
||||
MH_Top_Level = db.Column(db.Float, default=0)
|
||||
Ex_Level = db.Column(db.Float, default=0)
|
||||
Cutting_Depth = db.Column(db.Float, default=0)
|
||||
MH_Depth = db.Column(db.Float, default=0)
|
||||
ID_of_MH_m = db.Column(db.Float, default=0)
|
||||
|
||||
Dia_of_MH_Cutting = db.Column(db.Float)
|
||||
Area_of_Manhole = db.Column(db.Float)
|
||||
Dia_of_MH_Cutting = db.Column(db.Float, default=0)
|
||||
Area_of_Manhole = db.Column(db.Float, default=0)
|
||||
|
||||
# Excavation categories
|
||||
Marshi_Muddy_Slushy_0_to_1_5 = db.Column(db.Float)
|
||||
Marshi_Muddy_Slushy_1_5_to_3_0 = db.Column(db.Float)
|
||||
Marshi_Muddy_Slushy_3_0_to_4_5 = db.Column(db.Float)
|
||||
Marshi_Muddy_Slushy_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Marshi_Muddy_Slushy_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Marshi_Muddy_Slushy_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
|
||||
Soft_Murum_0_to_1_5 = db.Column(db.Float)
|
||||
Soft_Murum_1_5_to_3_0 = db.Column(db.Float)
|
||||
Soft_Murum_3_0_to_4_5 = db.Column(db.Float)
|
||||
Soft_Murum_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Soft_Murum_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Soft_Murum_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Murum_0_to_1_5 = db.Column(db.Float)
|
||||
Hard_Murum_1_5_to_3_0 = db.Column(db.Float)
|
||||
Hard_Murum_3_0_to_4_5 = db.Column(db.Float)
|
||||
Hard_Murum_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Hard_Murum_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Hard_Murum_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
|
||||
Soft_Rock_0_to_1_5 = db.Column(db.Float)
|
||||
Soft_Rock_1_5_to_3_0 = db.Column(db.Float)
|
||||
Soft_Murum_3_0_to_4_5 = db.Column(db.Float)
|
||||
Soft_Rock_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Soft_Rock_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Soft_Murum_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Rock_0_to_1_5 = db.Column(db.Float)
|
||||
Hard_Rock_1_5_to_3_0 = db.Column(db.Float)
|
||||
Hard_Rock_3_0_to_4_5 = db.Column(db.Float)
|
||||
Hard_Rock_4_5_to_6_0 = db.Column(db.Float)
|
||||
Hard_Rock_6_0_to_7_5 = db.Column(db.Float)
|
||||
Hard_Rock_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_4_5_to_6_0 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_6_0_to_7_5 = db.Column(db.Float, default=0)
|
||||
|
||||
# Totals
|
||||
Marshi_Muddy_Slushy_0_to_1_5_total = db.Column(db.Float)
|
||||
Marshi_Muddy_Slushy_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Marshi_Muddy_Slushy_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Marshi_Muddy_Slushy_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Marshi_Muddy_Slushy_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Marshi_Muddy_Slushy_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Soft_Murum_0_to_1_5_total = db.Column(db.Float)
|
||||
Soft_Murum_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Soft_Murum_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Soft_Murum_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Soft_Murum_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Soft_Murum_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Murum_0_to_1_5_total = db.Column(db.Float)
|
||||
Hard_Murum_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Hard_Murum_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Hard_Murum_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Hard_Murum_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Hard_Murum_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Soft_Rock_0_to_1_5_total = db.Column(db.Float)
|
||||
Soft_Rock_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Soft_Rock_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Soft_Rock_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Soft_Rock_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Soft_Rock_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Rock_0_to_1_5_total = db.Column(db.Float)
|
||||
Hard_Rock_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Hard_Rock_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Hard_Rock_4_5_to_6_0_total = db.Column(db.Float)
|
||||
Hard_Rock_6_0_to_7_5_total = db.Column(db.Float)
|
||||
Hard_Rock_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_4_5_to_6_0_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_6_0_to_7_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Remarks = db.Column(db.String(500))
|
||||
Total = db.Column(db.Float)
|
||||
Total = db.Column(db.Float, default=0)
|
||||
|
||||
created_at = db.Column(db.DateTime, default=datetime.today)
|
||||
|
||||
@@ -84,13 +81,11 @@ class ManholeExcavationClient(db.Model):
|
||||
return {c.name: getattr(self, c.name) for c in self.__table__.columns}
|
||||
|
||||
|
||||
# ==========================================
|
||||
# AUTO CALCULATE GRAND TOTAL
|
||||
# ==========================================
|
||||
# AUTO TOTAL USING REGEX
|
||||
def calculate_Manhole_total(mapper, connection, target):
|
||||
total = 0
|
||||
for column in target.__table__.columns:
|
||||
if column.name.endswith("_total"):
|
||||
if RegularExpression.STR_TOTAL_PATTERN.match(column.name):
|
||||
total += getattr(target, column.name) or 0
|
||||
target.Total = total
|
||||
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
from app import db
|
||||
from datetime import datetime
|
||||
from sqlalchemy import event
|
||||
from app.utils.regex_utils import RegularExpression
|
||||
|
||||
class TrenchExcavationClient(db.Model):
|
||||
__tablename__ = "tr_ex_client"
|
||||
@@ -11,69 +12,69 @@ class TrenchExcavationClient(db.Model):
|
||||
RA_Bill_No=db.Column(db.String(500))
|
||||
Location = db.Column(db.String(500))
|
||||
MH_NO = db.Column(db.String(100))
|
||||
CC_length = db.Column(db.Float)
|
||||
Actual_Trench_Length = db.Column(db.Float)
|
||||
Ground_Level = db.Column(db.Float)
|
||||
Invert_Level = db.Column(db.Float)
|
||||
Excavated_level = db.Column(db.Float)
|
||||
Cutting_Depth = db.Column(db.Float)
|
||||
Avg_Depth = db.Column(db.Float)
|
||||
Pipe_Dia_mm = db.Column(db.Float)
|
||||
CC_length = db.Column(db.Float, default=0)
|
||||
Actual_Trench_Length = db.Column(db.Float, default=0)
|
||||
Ground_Level = db.Column(db.Float, default=0)
|
||||
Invert_Level = db.Column(db.Float, default=0)
|
||||
Excavated_level = db.Column(db.Float, default=0)
|
||||
Cutting_Depth = db.Column(db.Float, default=0)
|
||||
Avg_Depth = db.Column(db.Float, default=0)
|
||||
Pipe_Dia_mm = db.Column(db.Float, default=0)
|
||||
|
||||
# width
|
||||
Width_0_to_1_5_m = db.Column(db.Float)
|
||||
Width_1_5_to_3_0_m = db.Column(db.Float)
|
||||
Width_3_0_to_4_5_m = db.Column(db.Float)
|
||||
Width_4_5_to_6_0_m = db.Column(db.Float)
|
||||
Width_6_0_to_7_5_m = db.Column(db.Float)
|
||||
Width_0_to_1_5_m = db.Column(db.Float, default=0)
|
||||
Width_1_5_to_3_0_m = db.Column(db.Float, default=0)
|
||||
Width_3_0_to_4_5_m = db.Column(db.Float, default=0)
|
||||
Width_4_5_to_6_0_m = db.Column(db.Float, default=0)
|
||||
Width_6_0_to_7_5_m = db.Column(db.Float, default=0)
|
||||
|
||||
# Excavation categories
|
||||
Marshi_Muddy_Slushy_0_to_1_5 = db.Column(db.Float)
|
||||
Marshi_Muddy_Slushy_1_5_to_3_0 = db.Column(db.Float)
|
||||
Marshi_Muddy_Slushy_3_0_to_4_5 = db.Column(db.Float)
|
||||
Marshi_Muddy_Slushy_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Marshi_Muddy_Slushy_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Marshi_Muddy_Slushy_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
|
||||
Soft_Murum_0_to_1_5 = db.Column(db.Float)
|
||||
Soft_Murum_1_5_to_3_0 = db.Column(db.Float)
|
||||
Soft_Murum_3_0_to_4_5 = db.Column(db.Float)
|
||||
Soft_Murum_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Soft_Murum_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Soft_Murum_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Murum_0_to_1_5 = db.Column(db.Float)
|
||||
Hard_Murum_1_5_to_3_0 = db.Column(db.Float)
|
||||
Hard_Murum_3_0_to_4_5 = db.Column(db.Float)
|
||||
Hard_Murum_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Hard_Murum_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Hard_Murum_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
|
||||
Soft_Rock_0_to_1_5 = db.Column(db.Float)
|
||||
Soft_Rock_1_5_to_3_0 = db.Column(db.Float)
|
||||
Soft_Rock_3_0_to_4_5 = db.Column(db.Float)
|
||||
Soft_Rock_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Soft_Rock_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Soft_Rock_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Rock_0_to_1_5 = db.Column(db.Float)
|
||||
Hard_Rock_1_5_to_3_0 = db.Column(db.Float)
|
||||
Hard_Rock_3_0_to_4_5 = db.Column(db.Float)
|
||||
Hard_Rock_4_5_to_6_0 = db.Column(db.Float)
|
||||
Hard_Rock_6_0_to_7_5 = db.Column(db.Float)
|
||||
Hard_Rock_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_4_5_to_6_0 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_6_0_to_7_5 = db.Column(db.Float, default=0)
|
||||
|
||||
# Totals
|
||||
Marshi_Muddy_Slushy_0_to_1_5_total = db.Column(db.Float)
|
||||
Marshi_Muddy_Slushy_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Marshi_Muddy_Slushy_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Marshi_Muddy_Slushy_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Marshi_Muddy_Slushy_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Marshi_Muddy_Slushy_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Soft_Murum_0_to_1_5_total = db.Column(db.Float)
|
||||
Soft_Murum_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Soft_Murum_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Soft_Murum_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Soft_Murum_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Soft_Murum_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Murum_0_to_1_5_total = db.Column(db.Float)
|
||||
Hard_Murum_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Hard_Murum_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Hard_Murum_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Hard_Murum_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Hard_Murum_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Soft_Rock_0_to_1_5_total = db.Column(db.Float)
|
||||
Soft_Rock_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Soft_Rock_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Soft_Rock_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Soft_Rock_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Soft_Rock_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Rock_0_to_1_5_total = db.Column(db.Float)
|
||||
Hard_Rock_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Hard_Rock_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Hard_Rock_4_5_to_6_0_total = db.Column(db.Float)
|
||||
Hard_Rock_6_0_to_7_5_total = db.Column(db.Float)
|
||||
Hard_Rock_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_4_5_to_6_0_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_6_0_to_7_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Total = db.Column(db.Float)
|
||||
Total = db.Column(db.Float, default=0)
|
||||
Remarks = db.Column(db.String(500))
|
||||
|
||||
created_at = db.Column(db.DateTime, default=datetime.today)
|
||||
@@ -85,17 +86,13 @@ class TrenchExcavationClient(db.Model):
|
||||
return {c.name: getattr(self, c.name) for c in self.__table__.columns}
|
||||
|
||||
|
||||
# ==========================================
|
||||
# AUTO CALCULATE GRAND TOTAL
|
||||
# ==========================================
|
||||
|
||||
# AUTO TOTAL USING REGEX
|
||||
def calculate_trench_client_total(mapper, connection, target):
|
||||
total = 0
|
||||
for column in target.__table__.columns:
|
||||
if column.name.endswith("_total"):
|
||||
if RegularExpression.STR_TOTAL_PATTERN.match(column.name):
|
||||
total += getattr(target, column.name) or 0
|
||||
target.Total = total
|
||||
|
||||
|
||||
event.listen(TrenchExcavationClient, "before_insert", calculate_trench_client_total)
|
||||
event.listen(TrenchExcavationClient, "before_update", calculate_trench_client_total)
|
||||
@@ -1,6 +1,7 @@
|
||||
from app import db
|
||||
from datetime import datetime
|
||||
from sqlalchemy import event
|
||||
from app.utils.regex_utils import RegularExpression
|
||||
|
||||
class TrenchExcavation(db.Model):
|
||||
__tablename__ = "trench_excavation"
|
||||
@@ -14,59 +15,59 @@ class TrenchExcavation(db.Model):
|
||||
# Basic Fields
|
||||
Location = db.Column(db.String(500))
|
||||
MH_NO = db.Column(db.String(100))
|
||||
CC_length = db.Column(db.Float)
|
||||
Invert_Level = db.Column(db.Float)
|
||||
MH_Top_Level = db.Column(db.Float)
|
||||
Ground_Level = db.Column(db.Float)
|
||||
ID_of_MH_m = db.Column(db.Float)
|
||||
Actual_Trench_Length = db.Column(db.Float)
|
||||
Pipe_Dia_mm = db.Column(db.Float)
|
||||
CC_length = db.Column(db.Float, default=0)
|
||||
Invert_Level = db.Column(db.Float, default=0)
|
||||
MH_Top_Level = db.Column(db.Float, default=0)
|
||||
Ground_Level = db.Column(db.Float, default=0)
|
||||
ID_of_MH_m = db.Column(db.Float, default=0)
|
||||
Actual_Trench_Length = db.Column(db.Float, default=0)
|
||||
Pipe_Dia_mm = db.Column(db.Float, default=0)
|
||||
|
||||
# width
|
||||
Width_0_to_2_5 = db.Column(db.Float)
|
||||
Width_2_5_to_3_0 = db.Column(db.Float)
|
||||
Width_3_0_to_4_5 = db.Column(db.Float)
|
||||
Width_4_5_to_6_0 = db.Column(db.Float)
|
||||
Width_0_to_2_5 = db.Column(db.Float, default=0)
|
||||
Width_2_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Width_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
Width_4_5_to_6_0 = db.Column(db.Float, default=0)
|
||||
|
||||
Upto_IL_Depth = db.Column(db.Float)
|
||||
Cutting_Depth = db.Column(db.Float)
|
||||
Avg_Depth = db.Column(db.Float)
|
||||
Upto_IL_Depth = db.Column(db.Float, default=0)
|
||||
Cutting_Depth = db.Column(db.Float, default=0)
|
||||
Avg_Depth = db.Column(db.Float, default=0)
|
||||
|
||||
# Excavation categories
|
||||
Soft_Murum_0_to_1_5 = db.Column(db.Float)
|
||||
Soft_Murum_1_5_to_3_0 = db.Column(db.Float)
|
||||
Soft_Murum_3_0_to_4_5 = db.Column(db.Float)
|
||||
Soft_Murum_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Soft_Murum_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Soft_Murum_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Murum_0_to_1_5 = db.Column(db.Float)
|
||||
Hard_Murum_1_5_to_3_0 = db.Column(db.Float)
|
||||
Hard_Murum_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Hard_Murum_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
|
||||
Soft_Rock_0_to_1_5 = db.Column(db.Float)
|
||||
Soft_Rock_1_5_to_3_0 = db.Column(db.Float)
|
||||
Soft_Rock_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Soft_Rock_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Rock_0_to_1_5 = db.Column(db.Float)
|
||||
Hard_Rock_1_5_to_3_0 = db.Column(db.Float)
|
||||
Hard_Rock_3_0_to_4_5 = db.Column(db.Float)
|
||||
Hard_Rock_4_5_to_6_0 = db.Column(db.Float)
|
||||
Hard_Rock_6_0_to_7_5 = db.Column(db.Float)
|
||||
Hard_Rock_0_to_1_5 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_1_5_to_3_0 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_3_0_to_4_5 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_4_5_to_6_0 = db.Column(db.Float, default=0)
|
||||
Hard_Rock_6_0_to_7_5 = db.Column(db.Float, default=0)
|
||||
|
||||
# Totals
|
||||
Soft_Murum_0_to_1_5_total = db.Column(db.Float)
|
||||
Soft_Murum_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Soft_Murum_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Soft_Murum_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Soft_Murum_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Soft_Murum_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Murum_0_to_1_5_total = db.Column(db.Float)
|
||||
Hard_Murum_1_5_and_above_total = db.Column(db.Float)
|
||||
Hard_Murum_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Hard_Murum_1_5_and_above_total = db.Column(db.Float, default=0)
|
||||
|
||||
Soft_Rock_0_to_1_5_total = db.Column(db.Float)
|
||||
Soft_Rock_1_5_and_above_total = db.Column(db.Float)
|
||||
Soft_Rock_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Soft_Rock_1_5_and_above_total = db.Column(db.Float, default=0)
|
||||
|
||||
Hard_Rock_0_to_1_5_total = db.Column(db.Float)
|
||||
Hard_Rock_1_5_to_3_0_total = db.Column(db.Float)
|
||||
Hard_Rock_3_0_to_4_5_total = db.Column(db.Float)
|
||||
Hard_Rock_4_5_to_6_0_total = db.Column(db.Float)
|
||||
Hard_Rock_6_0_to_7_5_total = db.Column(db.Float)
|
||||
Hard_Rock_0_to_1_5_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_1_5_to_3_0_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_3_0_to_4_5_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_4_5_to_6_0_total = db.Column(db.Float, default=0)
|
||||
Hard_Rock_6_0_to_7_5_total = db.Column(db.Float, default=0)
|
||||
|
||||
Total = db.Column(db.Float)
|
||||
Total = db.Column(db.Float, default=0)
|
||||
Remarks = db.Column(db.String(500))
|
||||
RA_Bill_No=db.Column(db.String(500))
|
||||
|
||||
@@ -79,44 +80,12 @@ class TrenchExcavation(db.Model):
|
||||
def serialize(self):
|
||||
return {c.name: getattr(self, c.name) for c in self.__table__.columns}
|
||||
|
||||
def excavation_category_sums(self):
|
||||
|
||||
def safe(val):
|
||||
return val or 0
|
||||
|
||||
return {
|
||||
"Soft_Murum_Total": (
|
||||
safe(self.Soft_Murum_0_to_1_5)
|
||||
+ safe(self.Soft_Murum_1_5_to_3_0)
|
||||
+ safe(self.Soft_Murum_3_0_to_4_5)
|
||||
),
|
||||
|
||||
"Hard_Murum_Total": (
|
||||
safe(self.Hard_Murum_0_to_1_5)
|
||||
+ safe(self.Hard_Murum_1_5_to_3_0)
|
||||
),
|
||||
|
||||
"Soft_Rock_Total": (
|
||||
safe(self.Soft_Rock_0_to_1_5)
|
||||
+ safe(self.Soft_Rock_1_5_to_3_0)
|
||||
),
|
||||
|
||||
"Hard_Rock_Total": (
|
||||
safe(self.Hard_Rock_0_to_1_5)
|
||||
+ safe(self.Hard_Rock_1_5_to_3_0)
|
||||
+ safe(self.Hard_Rock_3_0_to_4_5)
|
||||
+ safe(self.Hard_Rock_4_5_to_6_0)
|
||||
+ safe(self.Hard_Rock_6_0_to_7_5)
|
||||
),
|
||||
}
|
||||
|
||||
# ==========================================
|
||||
# AUTO CALCULATE GRAND TOTAL
|
||||
# ==========================================
|
||||
# AUTO TOTAL USING REGEX
|
||||
def calculate_trench_total(mapper, connection, target):
|
||||
total = 0
|
||||
for column in target.__table__.columns:
|
||||
if column.name.endswith("_total"):
|
||||
if RegularExpression.STR_TOTAL_PATTERN.match(column.name):
|
||||
total += getattr(target, column.name) or 0
|
||||
target.Total = total
|
||||
|
||||
|
||||
@@ -5,7 +5,7 @@ class User(db.Model):
|
||||
__tablename__ = "users"
|
||||
|
||||
id = db.Column(db.Integer, primary_key=True)
|
||||
name = db.Column(db.String(120), nullable=False)
|
||||
name = db.Column(db.String(200), nullable=False)
|
||||
email = db.Column(db.String(120), unique=True, nullable=False)
|
||||
password_hash = db.Column(db.String(255), nullable=False)
|
||||
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
import matplotlib
|
||||
matplotlib.use("Agg")
|
||||
|
||||
from flask import Blueprint, render_template, session, redirect, url_for, jsonify
|
||||
from flask import Blueprint, render_template, session, redirect, url_for, jsonify, request
|
||||
import matplotlib.pyplot as plt
|
||||
import io
|
||||
import base64
|
||||
@@ -13,101 +13,16 @@ from app.models.trench_excavation_model import TrenchExcavation
|
||||
from app.models.manhole_excavation_model import ManholeExcavation
|
||||
from app.models.laying_model import Laying
|
||||
|
||||
from app.models.subcontractor_model import Subcontractor
|
||||
|
||||
dashboard_bp = Blueprint("dashboard", __name__, url_prefix="/dashboard")
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
# import matplotlib
|
||||
# matplotlib.use("Agg")
|
||||
|
||||
# from flask import Blueprint, render_template, session, redirect, url_for
|
||||
# import matplotlib.pyplot as plt
|
||||
# import io
|
||||
# import base64
|
||||
# from app.utils.plot_utils import plot_to_base64
|
||||
# from app.services.dashboard_service import DashboardService
|
||||
|
||||
# dashboard_bp = Blueprint("dashboard", __name__, url_prefix="/dashboard")
|
||||
|
||||
# # dashboard_bp = Blueprint("dashboard", __name__)
|
||||
|
||||
# # charts
|
||||
# # def plot_to_base64():
|
||||
# # img = io.BytesIO()
|
||||
# # plt.savefig(img, format="png", bbox_inches="tight")
|
||||
# # plt.close()
|
||||
# # img.seek(0)
|
||||
# # return base64.b64encode(img.getvalue()).decode()
|
||||
|
||||
# # bar chart
|
||||
# def bar_chart():
|
||||
# categories = ["Trench", "Manhole", "Pipe Laying", "Restoration"]
|
||||
# values = [120, 80, 150, 60]
|
||||
|
||||
# plt.figure()
|
||||
# plt.bar(categories, values)
|
||||
# plt.title("Work Category Report")
|
||||
# plt.xlabel("test Category")
|
||||
# plt.ylabel("test Quantity")
|
||||
|
||||
|
||||
# return plot_to_base64(plt)
|
||||
|
||||
# # Pie chart
|
||||
# def pie_chart():
|
||||
# labels = ["Completed", "In Progress", "Pending"]
|
||||
# sizes = [55, 20, 25]
|
||||
|
||||
# plt.figure()
|
||||
# plt.pie(sizes, labels=labels, autopct="%1.1f%%", startangle=140)
|
||||
# plt.title("Project Status")
|
||||
|
||||
# return plot_to_base64(plt)
|
||||
|
||||
# # Histogram chart
|
||||
# def histogram_chart():
|
||||
# daily_work = [5, 10, 15, 20, 20, 25, 30, 35, 40, 45, 50]
|
||||
|
||||
# plt.figure()
|
||||
# plt.hist(daily_work, bins=5)
|
||||
# plt.title("Daily Work Distribution")
|
||||
# plt.xlabel("Work Units")
|
||||
# plt.ylabel("Frequency")
|
||||
|
||||
# return plot_to_base64(plt)
|
||||
|
||||
# # Dashboaed page
|
||||
# @dashboard_bp.route("/")
|
||||
# def dashboard():
|
||||
# if not session.get("user_id"):
|
||||
# return redirect(url_for("auth.login"))
|
||||
|
||||
# return render_template(
|
||||
# "dashboard.html",
|
||||
# title="Dashboard",
|
||||
# bar_chart=bar_chart(),
|
||||
# pie_chart=pie_chart(),
|
||||
# histogram=histogram_chart()
|
||||
# )
|
||||
|
||||
# # subcontractor dashboard
|
||||
# @dashboard_bp.route("/subcontractor_dashboard", methods=["GET", "POST"])
|
||||
# def subcontractor_dashboard():
|
||||
# if not session.get("user_id"):
|
||||
# return redirect(url_for("auth.login"))
|
||||
|
||||
# tr_dash = DashboardService().bar_chart_of_tr_ex
|
||||
|
||||
|
||||
# return render_template(
|
||||
# "subcontractor_dashboard.html",
|
||||
# title="Dashboard",
|
||||
# bar_chart=tr_dash
|
||||
# )
|
||||
@dashboard_bp.route("/")
|
||||
def dashboard():
|
||||
if not session.get("user_id"):
|
||||
return redirect(url_for("auth.login"))
|
||||
return render_template("dashboard.html", title="Business Intelligence Dashboard")
|
||||
|
||||
|
||||
@dashboard_bp.route("/api/live-stats")
|
||||
@@ -144,25 +59,56 @@ def live_stats():
|
||||
except Exception as e:
|
||||
return jsonify({"error": str(e)}), 500
|
||||
|
||||
@dashboard_bp.route("/")
|
||||
def dashboard():
|
||||
if not session.get("user_id"):
|
||||
return redirect(url_for("auth.login"))
|
||||
return render_template("dashboard.html", title="Business Intelligence Dashboard")
|
||||
|
||||
|
||||
|
||||
# subcontractor dashboard
|
||||
@dashboard_bp.route("/subcontractor_dashboard", methods=["GET", "POST"])
|
||||
@dashboard_bp.route("/subcontractor_dashboard")
|
||||
def subcontractor_dashboard():
|
||||
|
||||
if not session.get("user_id"):
|
||||
return redirect(url_for("auth.login"))
|
||||
|
||||
tr_dash = DashboardService().bar_chart_of_tr_ex
|
||||
|
||||
|
||||
subcontractors = Subcontractor.query.all()
|
||||
|
||||
return render_template(
|
||||
"subcontractor_dashboard.html",
|
||||
title="Dashboard",
|
||||
bar_chart=tr_dash
|
||||
)
|
||||
subcontractors=subcontractors
|
||||
)
|
||||
|
||||
|
||||
# API FOR CHART DATA
|
||||
@dashboard_bp.route("/api/subcontractor-chart")
|
||||
def subcontractor_chart():
|
||||
|
||||
subcontractor_id = request.args.get("subcontractor")
|
||||
category = request.args.get("category")
|
||||
ra_bill = request.args.get("ra_bill")
|
||||
|
||||
query = db.session.query(
|
||||
TrenchExcavation.excavation_category,
|
||||
func.sum(TrenchExcavation.Total)
|
||||
)
|
||||
|
||||
if subcontractor_id:
|
||||
query = query.filter(TrenchExcavation.subcontractor_id == subcontractor_id)
|
||||
|
||||
if category:
|
||||
query = query.filter(TrenchExcavation.subcontractor_id == subcontractor_id)
|
||||
|
||||
if ra_bill:
|
||||
query = query.filter(TrenchExcavation.RA_Bill_No == ra_bill)
|
||||
|
||||
results = query.group_by(TrenchExcavation.excavation_category).all()
|
||||
|
||||
labels = []
|
||||
values = []
|
||||
|
||||
for r in results:
|
||||
labels.append(r[0])
|
||||
values.append(float(r[1] or 0))
|
||||
|
||||
return jsonify({
|
||||
"labels": labels,
|
||||
"values": values
|
||||
})
|
||||
@@ -1,5 +1,6 @@
|
||||
from flask import Blueprint, render_template, send_from_directory, abort, current_app
|
||||
from app.utils.helpers import login_required
|
||||
from app.utils.file_utils import get_download_format_folder
|
||||
import os
|
||||
|
||||
file_format_bp = Blueprint("file_format", __name__)
|
||||
@@ -14,10 +15,7 @@ def download_format():
|
||||
@login_required
|
||||
def download_excel_format(filename):
|
||||
|
||||
download_folder = os.path.join(
|
||||
current_app.root_path, "static", "downloads/format"
|
||||
)
|
||||
|
||||
download_folder = get_download_format_folder()
|
||||
file_path = os.path.join(download_folder, filename)
|
||||
|
||||
if not os.path.exists(file_path):
|
||||
|
||||
@@ -141,20 +141,23 @@ def report_file():
|
||||
download_all=download_all
|
||||
)
|
||||
|
||||
# --- client report only ---
|
||||
|
||||
# --- CLIENT REPORT (PREVIEW + DOWNLOAD) ---
|
||||
@file_report_bp.route("/client_report", methods=["GET", "POST"])
|
||||
@login_required
|
||||
def client_vs_all_subcontractor():
|
||||
tables = {"tr": None, "mh": None, "dc": None}
|
||||
ra_val = ""
|
||||
|
||||
|
||||
if request.method == "POST":
|
||||
|
||||
# ⚠ MUST match HTML name
|
||||
RA_Bill_No = request.form.get("RA_Bill_No")
|
||||
ra_val = RA_Bill_No
|
||||
|
||||
|
||||
if not RA_Bill_No:
|
||||
flash("Please enter RA Bill No.", "danger")
|
||||
return render_template("client_report.html", tables=tables, ra_val=ra_val)
|
||||
return render_template("generate_comparison_client_vs_subcont.html", tables=tables, ra_val=ra_val)
|
||||
|
||||
clientBill = ClientBill()
|
||||
clientBill.Fetch(RA_Bill_No=RA_Bill_No)
|
||||
@@ -164,7 +167,7 @@ def client_vs_all_subcontractor():
|
||||
# --- SAFETY CHECK: Verify data exists before merging ---
|
||||
if clientBill.df_tr.empty and clientBill.df_mh.empty:
|
||||
flash(f"No Client records found for RA Bill {RA_Bill_No}", "warning")
|
||||
return render_template("client_report.html", tables=tables, ra_val=ra_val)
|
||||
return render_template("generate_comparison_client_vs_subcont.html", tables=tables, ra_val=ra_val)
|
||||
|
||||
qty_cols = [...] # (Keep your existing list)
|
||||
mh_dc_qty_cols = [...] # (Keep your existing list)
|
||||
|
||||
@@ -2,7 +2,7 @@ from flask import Blueprint, render_template, request, send_file, flash
|
||||
from collections import defaultdict
|
||||
import pandas as pd
|
||||
import io
|
||||
|
||||
|
||||
from app.models.subcontractor_model import Subcontractor
|
||||
from app.models.trench_excavation_model import TrenchExcavation
|
||||
from app.models.manhole_excavation_model import ManholeExcavation
|
||||
@@ -15,17 +15,13 @@ from app.models.mh_dc_client_model import ManholeDomesticChamberClient
|
||||
from app.models.laying_client_model import LayingClient
|
||||
|
||||
from app.utils.helpers import login_required
|
||||
import re
|
||||
from app.utils.regex_utils import RegularExpression
|
||||
|
||||
|
||||
generate_report_bp = Blueprint("generate_report", __name__, url_prefix="/report")
|
||||
|
||||
|
||||
# sum field of pipe laying (pipe_150_mm)
|
||||
PIPE_MM_PATTERN = re.compile(r"^pipe_\d+_mm$")
|
||||
# sum fields of MH dc (d_0_to_0_75)
|
||||
D_RANGE_PATTERN = re.compile( r"^d_\d+(?:_\d+)?_to_\d+(?:_\d+)?$")
|
||||
|
||||
|
||||
|
||||
# NORMALIZER
|
||||
def normalize_key(value):
|
||||
@@ -80,6 +76,7 @@ def build_comparison(client_rows, contractor_rows, key_field):
|
||||
used_index = defaultdict(int) # 🔥 THIS FIXES YOUR ISSUE
|
||||
|
||||
for c in client_rows:
|
||||
|
||||
client_location = normalize_key(c.get("Location"))
|
||||
client_key = normalize_key(c.get(key_field))
|
||||
|
||||
@@ -104,16 +101,16 @@ def build_comparison(client_rows, contractor_rows, key_field):
|
||||
float(v or 0)
|
||||
for k, v in c.items()
|
||||
if k.endswith("_total")
|
||||
or D_RANGE_PATTERN.match(k)
|
||||
or PIPE_MM_PATTERN.match(k)
|
||||
or RegularExpression.D_RANGE_PATTERN.match(k)
|
||||
or RegularExpression.PIPE_MM_PATTERN.match(k)
|
||||
)
|
||||
|
||||
sub_total = sum(
|
||||
float(v or 0)
|
||||
for k, v in s.items()
|
||||
if k.endswith("_total")
|
||||
or D_RANGE_PATTERN.match(k)
|
||||
or PIPE_MM_PATTERN.match(k)
|
||||
or RegularExpression.D_RANGE_PATTERN.match(k)
|
||||
or RegularExpression.PIPE_MM_PATTERN.match(k)
|
||||
)
|
||||
|
||||
row = {
|
||||
@@ -138,7 +135,9 @@ def build_comparison(client_rows, contractor_rows, key_field):
|
||||
output.append(row)
|
||||
|
||||
df = pd.DataFrame(output)
|
||||
# formatting headers
|
||||
df.columns = [format_header(col) for col in df.columns]
|
||||
|
||||
return df
|
||||
|
||||
|
||||
@@ -225,15 +224,12 @@ def comparison_report():
|
||||
subcontractor_id=subcontractor_id
|
||||
).all()]
|
||||
df_dc = build_comparison(dc_client, dc_sub, "MH_NO")
|
||||
# df_dc = build_comparison_mh_dc(dc_client, dc_sub, "MH_NO")
|
||||
|
||||
lay_client = [r.serialize() for r in LayingClient.query.all()]
|
||||
lay_sub = [r.serialize() for r in Laying.query.filter_by(
|
||||
subcontractor_id=subcontractor_id
|
||||
).all()]
|
||||
df_lay = build_comparison(lay_client, lay_sub, "MH_NO")
|
||||
# df_lay = build_comparison_laying(lay_client, lay_sub, "MH_NO")
|
||||
|
||||
|
||||
# -------- EXCEL --------
|
||||
output = io.BytesIO()
|
||||
@@ -254,106 +250,4 @@ def comparison_report():
|
||||
)
|
||||
|
||||
return render_template("generate_comparison_report.html",subcontractors=subcontractors)
|
||||
|
||||
|
||||
# def build_comparison_mh_dc(client_rows, contractor_rows, key_field):
|
||||
# contractor_lookup = make_lookup(contractor_rows, key_field)
|
||||
# mh_dc_fields = ManholeDomesticChamberClient.sum_mh_dc_fields()
|
||||
|
||||
# output = []
|
||||
|
||||
# for c in client_rows:
|
||||
# loc = normalize_key(c.get("Location"))
|
||||
# key = normalize_key(c.get(key_field))
|
||||
# if not loc or not key:
|
||||
# continue
|
||||
|
||||
# s = contractor_lookup.get((loc, key))
|
||||
# if not s:
|
||||
# continue
|
||||
|
||||
# client_total = sum(float(c.get(f, 0) or 0) for f in mh_dc_fields)
|
||||
# sub_total = sum(float(s.get(f, 0) or 0) for f in mh_dc_fields)
|
||||
|
||||
# row = {
|
||||
# "Location": loc,
|
||||
# key_field.replace("_", " "): key
|
||||
# }
|
||||
|
||||
# # CLIENT – ALL FIELDS
|
||||
# for k, v in c.items():
|
||||
# if k in ["id", "created_at"]:
|
||||
# continue
|
||||
# row[f"Client-{k}"] = v
|
||||
|
||||
# row["Client-Total"] = round(client_total, 2)
|
||||
# row[" "] = ""
|
||||
|
||||
# # SUBCONTRACTOR – ALL FIELDS
|
||||
# for k, v in s.items():
|
||||
# if k in ["id", "created_at", "subcontractor_id"]:
|
||||
# continue
|
||||
# row[f"Subcontractor-{k}"] = v
|
||||
|
||||
# row["Subcontractor-Total"] = round(sub_total, 2)
|
||||
# row["Diff"] = round(client_total - sub_total, 2)
|
||||
|
||||
# output.append(row)
|
||||
|
||||
# df = pd.DataFrame(output)
|
||||
# df.columns = [format_header(col) for col in df.columns]
|
||||
# return df
|
||||
|
||||
|
||||
# def build_comparison_laying(client_rows, contractor_rows, key_field):
|
||||
# contractor_lookup = make_lookup(contractor_rows, key_field)
|
||||
# laying_fields = Laying.sum_laying_fields()
|
||||
|
||||
# output = []
|
||||
|
||||
# for c in client_rows:
|
||||
# loc = normalize_key(c.get("Location"))
|
||||
# key = normalize_key(c.get(key_field))
|
||||
# if not loc or not key:
|
||||
# continue
|
||||
|
||||
# s = contractor_lookup.get((loc, key))
|
||||
# if not s:
|
||||
# continue
|
||||
|
||||
# client_total = sum(float(c.get(f, 0) or 0) for f in laying_fields)
|
||||
# sub_total = sum(float(s.get(f, 0) or 0) for f in laying_fields)
|
||||
|
||||
# print("--------------",key,"----------")
|
||||
# print("sum -client_total ",client_total)
|
||||
# print("sum -sub_total ",sub_total)
|
||||
# print("Diff ---- ",client_total - sub_total)
|
||||
# print("------------------------")
|
||||
# row = {
|
||||
# "Location": loc,
|
||||
# key_field.replace("_", " "): key
|
||||
# }
|
||||
|
||||
# # CLIENT – ALL FIELDS
|
||||
# for k, v in c.items():
|
||||
# if k in ["id", "created_at"]:
|
||||
# continue
|
||||
# row[f"Client-{k}"] = v
|
||||
|
||||
# row["Client-Total"] = round(client_total, 2)
|
||||
# row[" "] = ""
|
||||
|
||||
# # SUBCONTRACTOR – ALL FIELDS
|
||||
# for k, v in s.items():
|
||||
# if k in ["id", "created_at", "subcontractor_id"]:
|
||||
# continue
|
||||
# row[f"Subcontractor-{k}"] = v
|
||||
|
||||
# row["Subcontractor-Total"] = round(sub_total, 2)
|
||||
# row["Diff"] = round(client_total - sub_total, 2)
|
||||
|
||||
# output.append(row)
|
||||
|
||||
# df = pd.DataFrame(output)
|
||||
# df.columns = [format_header(col) for col in df.columns]
|
||||
# return df
|
||||
|
||||
@@ -1,191 +1,159 @@
|
||||
from flask import Blueprint, render_template, request, redirect, flash
|
||||
from app import db
|
||||
from flask import Blueprint, render_template, request, redirect, flash, current_app, url_for
|
||||
from app.services.db_service import db
|
||||
from app.models.subcontractor_model import Subcontractor
|
||||
from app.utils.helpers import login_required
|
||||
|
||||
|
||||
subcontractor_bp = Blueprint("subcontractor", __name__, url_prefix="/subcontractor")
|
||||
|
||||
# ---------------- ADD -----------------
|
||||
@subcontractor_bp.route("/add")
|
||||
@login_required
|
||||
def add_subcontractor():
|
||||
return render_template("subcontractor/add.html")
|
||||
@subcontractor_bp.route("/save", methods=["POST"])
|
||||
@login_required
|
||||
def save_subcontractor():
|
||||
# 1. Get and clean the name from the form
|
||||
name = request.form.get("subcontractor_name", "").strip()
|
||||
|
||||
# 2. Basic validation: Ensure the name isn't empty
|
||||
if not name:
|
||||
flash("Subcontractor name cannot be empty.", "danger")
|
||||
return redirect("/subcontractor/add")
|
||||
|
||||
# 3. Check if a subcontractor with this name already exists
|
||||
existing_sub = Subcontractor.query.filter_by(subcontractor_name=name).first()
|
||||
|
||||
if existing_sub:
|
||||
flash(f"Subcontractor with name '{name}' already exists!", "danger")
|
||||
return redirect("/subcontractor/add")
|
||||
|
||||
# 4. If no duplicate is found, proceed to save
|
||||
try:
|
||||
subcontractor = Subcontractor(
|
||||
subcontractor_name=name,
|
||||
contact_person=request.form.get("contact_person"),
|
||||
mobile_no=request.form.get("mobile_no"),
|
||||
email_id=request.form.get("email_id"),
|
||||
gst_no=request.form.get("gst_no")
|
||||
)
|
||||
|
||||
db.session.add(subcontractor)
|
||||
db.session.commit()
|
||||
flash("Subcontractor added successfully!", "success")
|
||||
|
||||
except Exception as e:
|
||||
db.session.rollback()
|
||||
flash("An error occurred while saving. Please try again.", "danger")
|
||||
|
||||
return redirect("/subcontractor/list")
|
||||
|
||||
# ---------------- LIST -----------------
|
||||
@subcontractor_bp.route("/list")
|
||||
@login_required
|
||||
def subcontractor_list():
|
||||
subcontractors = Subcontractor.query.all()
|
||||
return render_template("subcontractor/list.html", subcontractors=subcontractors)
|
||||
|
||||
# ---------------- EDIT -----------------
|
||||
@subcontractor_bp.route("/edit/<int:id>")
|
||||
@login_required
|
||||
def edit_subcontractor(id):
|
||||
subcontractor = Subcontractor.query.get_or_404(id)
|
||||
return render_template("subcontractor/edit.html", subcontractor=subcontractor)
|
||||
|
||||
# ---------------- UPDATE -----------------
|
||||
@subcontractor_bp.route("/update/<int:id>", methods=["POST"])
|
||||
@login_required
|
||||
def update_subcontractor(id):
|
||||
subcontractor = Subcontractor.query.get_or_404(id)
|
||||
new_name = request.form.get("subcontractor_name")
|
||||
|
||||
# Check if the new name is taken by someone ELSE (not this current ID)
|
||||
duplicate = Subcontractor.query.filter(
|
||||
Subcontractor.subcontractor_name == new_name,
|
||||
Subcontractor.id != id
|
||||
).first()
|
||||
|
||||
if duplicate:
|
||||
flash("Another subcontractor already uses this name.", "danger")
|
||||
return redirect(f"/subcontractor/edit/{id}")
|
||||
|
||||
subcontractor.subcontractor_name = new_name
|
||||
|
||||
db.session.commit()
|
||||
|
||||
flash("Subcontractor updated successfully!", "success")
|
||||
return redirect("/subcontractor/list")
|
||||
|
||||
# ---------------- DELETE -----------------
|
||||
@subcontractor_bp.route("/delete/<int:id>")
|
||||
@login_required
|
||||
def delete_subcontractor(id):
|
||||
subcontractor = Subcontractor.query.get_or_404(id)
|
||||
|
||||
db.session.delete(subcontractor)
|
||||
db.session.commit()
|
||||
|
||||
flash("Subcontractor deleted successfully!", "success")
|
||||
return redirect("/subcontractor/list")
|
||||
from flask import Blueprint, render_template, request, redirect, flash
|
||||
from app import db
|
||||
from app.models.subcontractor_model import Subcontractor
|
||||
from app.utils.helpers import login_required
|
||||
|
||||
subcontractor_bp = Blueprint("subcontractor", __name__, url_prefix="/subcontractor")
|
||||
|
||||
|
||||
|
||||
# ---------------- ADD -----------------
|
||||
@subcontractor_bp.route("/add")
|
||||
@login_required
|
||||
def add_subcontractor():
|
||||
current_app.logger.info("Opened Add Subcontractor Page")
|
||||
return render_template("subcontractor/add.html")
|
||||
|
||||
|
||||
# ---------------- SAVE -----------------
|
||||
@subcontractor_bp.route("/save", methods=["POST"])
|
||||
@login_required
|
||||
def save_subcontractor():
|
||||
|
||||
name = request.form.get("subcontractor_name", "").strip()
|
||||
|
||||
if not name:
|
||||
current_app.logger.warning("Empty subcontractor name submitted")
|
||||
flash("Subcontractor name cannot be empty.", "danger")
|
||||
return redirect("/subcontractor/add")
|
||||
return redirect(url_for("subcontractor.add_subcontractor"))
|
||||
|
||||
existing_sub = Subcontractor.query.filter_by(subcontractor_name=name).first()
|
||||
|
||||
|
||||
if existing_sub:
|
||||
current_app.logger.warning(f"Duplicate subcontractor attempt: {name}")
|
||||
flash(f"Subcontractor with name '{name}' already exists!", "danger")
|
||||
return redirect("/subcontractor/add")
|
||||
return redirect(url_for("subcontractor.add_subcontractor"))
|
||||
|
||||
try:
|
||||
subcontractor = Subcontractor(
|
||||
subcontractor_name=name,
|
||||
contact_person=request.form.get("contact_person"),
|
||||
address=request.form.get("address"),
|
||||
mobile_no=request.form.get("mobile_no"),
|
||||
email_id=request.form.get("email_id"),
|
||||
gst_no=request.form.get("gst_no")
|
||||
gst_no=request.form.get("gst_no"),
|
||||
pan_no=request.form.get("pan_no")
|
||||
)
|
||||
|
||||
|
||||
db.session.add(subcontractor)
|
||||
db.session.commit()
|
||||
|
||||
current_app.logger.info(f"Subcontractor Created Successfully: {name}")
|
||||
flash("Subcontractor added successfully!", "success")
|
||||
|
||||
except Exception as e:
|
||||
|
||||
except Exception:
|
||||
db.session.rollback()
|
||||
flash("An error occurred while saving. Please try again.", "danger")
|
||||
|
||||
return redirect("/subcontractor/list")
|
||||
|
||||
# ---------------- LIST -----------------
|
||||
current_app.logger.exception("Error while saving subcontractor")
|
||||
flash("An error occurred while saving.", "danger")
|
||||
|
||||
return redirect(url_for("subcontractor.subcontractor_list"))
|
||||
|
||||
|
||||
# ---------------- LIST (UPDATED WITH PAGINATION) -----------------
|
||||
@subcontractor_bp.route("/list")
|
||||
@login_required
|
||||
def subcontractor_list():
|
||||
subcontractors = Subcontractor.query.all()
|
||||
return render_template("subcontractor/list.html", subcontractors=subcontractors)
|
||||
|
||||
|
||||
page = request.args.get("page", 1, type=int)
|
||||
per_page = 10 # Change how many records per page
|
||||
|
||||
pagination = Subcontractor.query.order_by(
|
||||
Subcontractor.created_at
|
||||
).paginate(
|
||||
page=page,
|
||||
per_page=per_page,
|
||||
error_out=False
|
||||
)
|
||||
|
||||
subcontractors = pagination.items
|
||||
|
||||
current_app.logger.info(f"Viewed Subcontractor List - Page {page}")
|
||||
|
||||
return render_template(
|
||||
"subcontractor/list.html",
|
||||
subcontractors=subcontractors,
|
||||
pagination=pagination
|
||||
)
|
||||
|
||||
|
||||
# ---------------- EDIT -----------------
|
||||
@subcontractor_bp.route("/edit/<int:id>")
|
||||
@login_required
|
||||
def edit_subcontractor(id):
|
||||
subcontractor = Subcontractor.query.get_or_404(id)
|
||||
current_app.logger.info(f"Editing Subcontractor ID: {id}")
|
||||
return render_template("subcontractor/edit.html", subcontractor=subcontractor)
|
||||
|
||||
|
||||
|
||||
# ---------------- UPDATE -----------------
|
||||
@subcontractor_bp.route("/update/<int:id>", methods=["POST"])
|
||||
@login_required
|
||||
def update_subcontractor(id):
|
||||
|
||||
subcontractor = Subcontractor.query.get_or_404(id)
|
||||
new_name = request.form.get("subcontractor_name")
|
||||
|
||||
# Check if the new name is taken by someone ELSE (not this current ID)
|
||||
new_name = request.form.get("subcontractor_name", "").strip()
|
||||
|
||||
duplicate = Subcontractor.query.filter(
|
||||
Subcontractor.subcontractor_name == new_name,
|
||||
Subcontractor.id != id
|
||||
).first()
|
||||
|
||||
|
||||
if duplicate:
|
||||
current_app.logger.warning(f"Duplicate update attempt: {new_name}")
|
||||
flash("Another subcontractor already uses this name.", "danger")
|
||||
return redirect(f"/subcontractor/edit/{id}")
|
||||
|
||||
subcontractor.subcontractor_name = new_name
|
||||
db.session.commit()
|
||||
|
||||
flash("Subcontractor updated successfully!", "success")
|
||||
return redirect("/subcontractor/list")
|
||||
|
||||
return redirect(url_for("subcontractor.edit_subcontractor", id=id))
|
||||
|
||||
try:
|
||||
old_name = subcontractor.subcontractor_name
|
||||
|
||||
subcontractor.subcontractor_name = new_name
|
||||
subcontractor.contact_person = request.form.get("contact_person")
|
||||
subcontractor.address = request.form.get("address")
|
||||
subcontractor.mobile_no = request.form.get("mobile_no")
|
||||
subcontractor.email_id = request.form.get("email_id")
|
||||
subcontractor.gst_no = request.form.get("gst_no")
|
||||
subcontractor.pan_no = request.form.get("pan_no")
|
||||
subcontractor.status = request.form.get("status")
|
||||
|
||||
db.session.commit()
|
||||
|
||||
current_app.logger.info(f"Subcontractor Updated: {old_name} → {new_name}")
|
||||
flash("Subcontractor updated successfully!", "success")
|
||||
|
||||
except Exception:
|
||||
db.session.rollback()
|
||||
current_app.logger.exception("Error updating subcontractor")
|
||||
flash("Update failed!", "danger")
|
||||
|
||||
return redirect(url_for("subcontractor.subcontractor_list"))
|
||||
|
||||
|
||||
# ---------------- DELETE -----------------
|
||||
@subcontractor_bp.route("/delete/<int:id>")
|
||||
@login_required
|
||||
def delete_subcontractor(id):
|
||||
subcontractor = Subcontractor.query.get_or_404(id)
|
||||
|
||||
db.session.delete(subcontractor)
|
||||
db.session.commit()
|
||||
try:
|
||||
name = subcontractor.subcontractor_name
|
||||
db.session.delete(subcontractor)
|
||||
db.session.commit()
|
||||
|
||||
flash("Subcontractor deleted successfully!", "success")
|
||||
return redirect("/subcontractor/list")
|
||||
current_app.logger.info(f"Subcontractor Deleted: {name}")
|
||||
flash("Subcontractor deleted successfully!", "success")
|
||||
|
||||
except Exception:
|
||||
db.session.rollback()
|
||||
current_app.logger.exception("Error deleting subcontractor")
|
||||
flash("Delete failed!", "danger")
|
||||
|
||||
return redirect(url_for("subcontractor.subcontractor_list"))
|
||||
@@ -1,11 +1,13 @@
|
||||
from flask import Blueprint, render_template
|
||||
from app.services.user_service import UserService
|
||||
from app.utils.helpers import login_required
|
||||
from flask import current_app
|
||||
|
||||
user_bp = Blueprint("user", __name__, url_prefix="/user")
|
||||
|
||||
@user_bp.route("/list")
|
||||
@login_required
|
||||
def list_users():
|
||||
current_app.logger.info("User list viewed")
|
||||
users = UserService.get_all_users()
|
||||
return render_template("users.html", users=users, title="Users")
|
||||
return render_template("users.html", users=users, title="Users")
|
||||
0
app/services/comparison_service.py
Normal file
0
app/services/comparison_service.py
Normal file
79
app/services/logger_service.py
Normal file
79
app/services/logger_service.py
Normal file
@@ -0,0 +1,79 @@
|
||||
import os
|
||||
import logging
|
||||
from logging.handlers import RotatingFileHandler
|
||||
from flask import request, session, has_request_context
|
||||
|
||||
|
||||
class RequestContextFilter(logging.Filter):
|
||||
|
||||
def filter(self, record):
|
||||
|
||||
if has_request_context():
|
||||
record.user = session.get("user_email", "Anonymous")
|
||||
record.ip = request.remote_addr
|
||||
record.method = request.method
|
||||
record.url = request.url
|
||||
else:
|
||||
record.user = "System"
|
||||
record.ip = "N/A"
|
||||
record.method = "N/A"
|
||||
record.url = "N/A"
|
||||
|
||||
return True
|
||||
|
||||
|
||||
class LoggerService:
|
||||
|
||||
@staticmethod
|
||||
def init_app(app):
|
||||
|
||||
if not os.path.exists("logs"):
|
||||
os.makedirs("logs")
|
||||
|
||||
formatter = logging.Formatter(
|
||||
"%(asctime)s | %(levelname)s | "
|
||||
"User:%(user)s | IP:%(ip)s | "
|
||||
"Method:%(method)s | URL:%(url)s | "
|
||||
"%(message)s"
|
||||
)
|
||||
|
||||
# INFO LOG
|
||||
info_handler = RotatingFileHandler(
|
||||
"logs/app.log",
|
||||
maxBytes=5 * 1024 * 1024,
|
||||
backupCount=5
|
||||
)
|
||||
info_handler.setLevel(logging.INFO)
|
||||
info_handler.setFormatter(formatter)
|
||||
|
||||
# ERROR LOG
|
||||
error_handler = RotatingFileHandler(
|
||||
"logs/error.log",
|
||||
maxBytes=5 * 1024 * 1024,
|
||||
backupCount=5
|
||||
)
|
||||
error_handler.setLevel(logging.ERROR)
|
||||
error_handler.setFormatter(formatter)
|
||||
|
||||
# CONSOLE
|
||||
console_handler = logging.StreamHandler()
|
||||
console_handler.setLevel(logging.DEBUG)
|
||||
console_handler.setFormatter(formatter)
|
||||
|
||||
# 🔹 ADD FILTER (important)
|
||||
context_filter = RequestContextFilter()
|
||||
|
||||
info_handler.addFilter(context_filter)
|
||||
error_handler.addFilter(context_filter)
|
||||
console_handler.addFilter(context_filter)
|
||||
|
||||
app.logger.setLevel(logging.DEBUG)
|
||||
|
||||
app.logger.addHandler(info_handler)
|
||||
app.logger.addHandler(error_handler)
|
||||
app.logger.addHandler(console_handler)
|
||||
|
||||
# Log every request automatically
|
||||
@app.before_request
|
||||
def log_request():
|
||||
app.logger.info("Request Started")
|
||||
@@ -29,20 +29,25 @@
|
||||
<ul class="nav nav-tabs" id="reportTabs" role="tablist">
|
||||
<li class="nav-item">
|
||||
<button class="nav-link active" id="tr-tab" data-bs-toggle="tab" data-bs-target="#tr"
|
||||
type="button">Tr.Ex Comparison</button>
|
||||
type="button">Tr.Ex </button>
|
||||
</li>
|
||||
<li class="nav-item">
|
||||
<button class="nav-link" id="mh-tab" data-bs-toggle="tab" data-bs-target="#mh" type="button">Mh.Ex
|
||||
Comparison</button>
|
||||
</button>
|
||||
</li>
|
||||
<li class="nav-item">
|
||||
<button class="nav-link" id="dc-tab" data-bs-toggle="tab" data-bs-target="#dc" type="button">MH & DC
|
||||
Comparison</button>
|
||||
</button>
|
||||
</li>
|
||||
<li class="nav-item">
|
||||
<<<<<<< HEAD
|
||||
<button class="nav-link" id="laying-tab" data-bs-toggle="tab" data-bs-target="#laying"
|
||||
type="button">Laying
|
||||
& Bedding Comparison</button>
|
||||
=======
|
||||
<button class="nav-link" id="laying-tab" data-bs-toggle="tab" data-bs-target="#laying" type="button">Laying
|
||||
& Bedding </button>
|
||||
>>>>>>> 1dceb640bd930c37888799f10f02fe90b219be67
|
||||
</ul>
|
||||
|
||||
<div class="tab-content mt-3" id="reportTabsContent">
|
||||
@@ -71,4 +76,5 @@
|
||||
{% endif %}
|
||||
|
||||
</div>
|
||||
{% endblock %}
|
||||
</div>
|
||||
{% endblock %}
|
||||
@@ -2,7 +2,7 @@
|
||||
|
||||
{% block content %}
|
||||
<div class="container-fluid px-2 px-md-4">
|
||||
<h4 class="mb-3 text-center text-md-start">Comparison dSoftware Solapur (UGD) - Live Dashboard</h4>
|
||||
<h4 class="mb-3 text-center text-md-start">Comparison Software Solapur (UGD) - Live Dashboard</h4>
|
||||
|
||||
<div class="row g-3 mb-4">
|
||||
<div class="col-12 col-md-4">
|
||||
|
||||
@@ -2,39 +2,49 @@
|
||||
{% block content %}
|
||||
|
||||
<div class="card shadow-sm p-4">
|
||||
|
||||
<h4 class="mb-3">Add New Subcontractor</h4>
|
||||
|
||||
<form action="/subcontractor/save" method="POST">
|
||||
<form action="{{ url_for('subcontractor.save_subcontractor') }}" method="POST">
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">Subcontractor Name</label>
|
||||
<label class="form-label">Subcontractor Name:</label>
|
||||
<input type="text" class="form-control" name="subcontractor_name" required>
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">Contact Person Name</label>
|
||||
<label class="form-label">Contact Person Name:</label>
|
||||
<input type="text" class="form-control" name="contact_person">
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">Mobile</label>
|
||||
<label class="form-label">Address:</label>
|
||||
<textarea type="text" class="form-control" name="address"></textarea>
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">Mobile No:</label>
|
||||
<input type="text" class="form-control" name="mobile_no">
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">Email</label>
|
||||
<label class="form-label">Email:</label>
|
||||
<input type="email" class="form-control" name="email_id">
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">GST No</label>
|
||||
<label class="form-label">GST No:</label>
|
||||
<input type="text" class="form-control" name="gst_no">
|
||||
</div>
|
||||
|
||||
<button class="btn btn-success">Save</button>
|
||||
</form>
|
||||
<div class="mb-3">
|
||||
<label class="form-label">PAN No:</label>
|
||||
<input type="text" class="form-control" name="pan_no">
|
||||
</div>
|
||||
|
||||
<button class="btn btn-success">Save</button>
|
||||
<a href="{{ url_for('subcontractor.subcontractor_list') }}" class="btn btn-secondary">Back</a>
|
||||
|
||||
</form>
|
||||
</div>
|
||||
|
||||
{% endblock %}
|
||||
@@ -4,36 +4,58 @@
|
||||
<div class="card shadow-sm p-4">
|
||||
<h4 class="mb-3">Edit Subcontractor</h4>
|
||||
|
||||
<form action="/subcontractor/update/{{ subcontractor.id }}" method="POST">
|
||||
<form action="{{ url_for('subcontractor.update_subcontractor', id=subcontractor.id) }}" method="POST">
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">Subcontractor Name</label>
|
||||
<label class="form-label">Subcontractor Name:</label>
|
||||
<input type="text" class="form-control" name="subcontractor_name"
|
||||
value="{{ subcontractor.subcontractor_name }}" required>
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">Contact Person</label>
|
||||
<label class="form-label">Contact Person Name:</label>
|
||||
<input type="text" class="form-control" name="contact_person" value="{{ subcontractor.contact_person }}">
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">Mobile</label>
|
||||
<label class="form-label">Address:</label>
|
||||
<input type="text" class="form-control" name="address" value="{{ subcontractor.address }}">
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">Mobile No:</label>
|
||||
<input type="text" class="form-control" name="mobile_no" value="{{ subcontractor.mobile_no }}">
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">Email</label>
|
||||
<label class="form-label">Email:</label>
|
||||
<input type="email" class="form-control" name="email_id" value="{{ subcontractor.email_id }}">
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">GST No</label>
|
||||
<label class="form-label">GST No:</label>
|
||||
<input type="text" class="form-control" name="gst_no" value="{{ subcontractor.gst_no }}">
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">PAN No:</label>
|
||||
<input type="text" class="form-control" name="pan_no" value="{{ subcontractor.pan_no }}">
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label class="form-label">Status:</label>
|
||||
<select name="status" class="form-control">
|
||||
<option value="Active" {% if subcontractor.status=="Active" %}selected{% endif %}>
|
||||
Active
|
||||
</option>
|
||||
<option value="Inactive" {% if subcontractor.status=="Inactive" %}selected{% endif %}>
|
||||
Inactive
|
||||
</option>
|
||||
</select>
|
||||
</div>
|
||||
|
||||
<button class="btn btn-success">Update</button>
|
||||
<a href="/subcontractor/list" class="btn btn-secondary">Back</a>
|
||||
<a href="{{ url_for('subcontractor.subcontractor_list') }}" class="btn btn-secondary">Back</a>
|
||||
|
||||
</form>
|
||||
</div>
|
||||
|
||||
@@ -1,89 +1,160 @@
|
||||
{% extends "base.html" %}
|
||||
{% block content %}
|
||||
|
||||
<div class="card shadow-sm p-3 p-md-4">
|
||||
<div class="container mt-4">
|
||||
|
||||
<!-- Header -->
|
||||
<div class="row mb-3 align-items-center">
|
||||
<div class="col-12 col-md-6 ">
|
||||
<h4 class="mb-2 mb-md-0 text-center text-md-start">
|
||||
Subcontractor List
|
||||
</h4>
|
||||
</div>
|
||||
<div class="d-flex flex-column flex-md-row justify-content-between align-items-md-center mb-3">
|
||||
<h4 class="mb-3 mb-md-0">Subcontractor List</h4>
|
||||
|
||||
<div class="col-12 col-md-3 text-center text-md-end">
|
||||
<a href="/subcontractor/add" class="btn btn-success w-100 w-md-auto">
|
||||
➕ Add Subcontractor
|
||||
</a>
|
||||
</div>
|
||||
<a href="{{ url_for('subcontractor.add_subcontractor') }}" class="btn btn-primary btn-sm">
|
||||
+ Add Subcontractor
|
||||
</a>
|
||||
</div>
|
||||
|
||||
<div class="card shadow-sm">
|
||||
<div class="card-body p-2 p-md-3">
|
||||
|
||||
<div class="table-responsive">
|
||||
<table class="table table-bordered table-striped align-middle text-nowrap">
|
||||
<thead class="table-dark">
|
||||
<tr>
|
||||
<th>ID</th>
|
||||
<th>Name</th>
|
||||
<th class="d-none d-md-table-cell">Mobile</th>
|
||||
<th class="d-none d-lg-table-cell">Email</th>
|
||||
<th class="d-none d-lg-table-cell">GST No</th>
|
||||
<th class="text-center">Action</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<!-- Desktop Table View -->
|
||||
<div class="table-responsive d-none d-md-block">
|
||||
<table class="table table-bordered table-hover align-middle">
|
||||
<thead class="table-dark">
|
||||
<tr>
|
||||
<th>Sr. No</th>
|
||||
<th>Subcontractor Name</th>
|
||||
<th>GST No</th>
|
||||
<th>Mobile</th>
|
||||
<th>Email</th>
|
||||
<th>Status</th>
|
||||
<th width="150">Action</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
{% for s in subcontractors %}
|
||||
<tr>
|
||||
<td>{{ s.id }}</td>
|
||||
<td>{{ s.subcontractor_name }}</td>
|
||||
<td>{{ s.gst_no }}</td>
|
||||
<td>{{ s.mobile_no }}</td>
|
||||
<td>{{ s.email_id }}</td>
|
||||
<td>
|
||||
{% if s.status == "Active" %}
|
||||
<span class="badge bg-success">Active</span>
|
||||
{% else %}
|
||||
<span class="badge bg-danger">Inactive</span>
|
||||
{% endif %}
|
||||
</td>
|
||||
<td>
|
||||
<a href="{{ url_for('subcontractor.edit_subcontractor', id=s.id) }}"
|
||||
class="btn btn-sm btn-warning mb-1">
|
||||
Edit
|
||||
</a>
|
||||
|
||||
<tbody>
|
||||
<a href="{{ url_for('subcontractor.delete_subcontractor', id=s.id) }}"
|
||||
class="btn btn-sm btn-danger" onclick="return confirm('Are you sure to delete?')">
|
||||
Delete
|
||||
</a>
|
||||
</td>
|
||||
</tr>
|
||||
{% endfor %}
|
||||
</tbody>
|
||||
</table>
|
||||
</div>
|
||||
|
||||
<!-- Mobile Card View -->
|
||||
<div class="d-md-none">
|
||||
{% for s in subcontractors %}
|
||||
<tr>
|
||||
<td>{{ s.id }}</td>
|
||||
<div class="card mb-3 shadow-sm">
|
||||
<div class="card-body p-3">
|
||||
<h5 class="fw-bold mb-2">{{ s.subcontractor_name }}</h5>
|
||||
|
||||
<td class="fw-semibold text-wrap">
|
||||
{{ s.subcontractor_name }}
|
||||
</td>
|
||||
<p class="mb-1"><strong>GST No:</strong> {{ s.gst_no }}</p>
|
||||
<p class="mb-1"><strong>Mobile:</strong> {{ s.mobile_no }}</p>
|
||||
<p class="mb-1"><strong>Email:</strong> {{ s.email_id }}</p>
|
||||
|
||||
<td class="d-none d-md-table-cell">
|
||||
{{ s.mobile_no }}
|
||||
</td>
|
||||
<p class="mb-2">
|
||||
<strong>Status:</strong>
|
||||
{% if s.status == "Active" %}
|
||||
<span class="badge bg-success">Active</span>
|
||||
{% else %}
|
||||
<span class="badge bg-danger">Inactive</span>
|
||||
{% endif %}
|
||||
</p>
|
||||
|
||||
<td class="d-none d-lg-table-cell">
|
||||
{{ s.email_id }}
|
||||
</td>
|
||||
|
||||
<td class="d-none d-lg-table-cell">
|
||||
{{ s.gst_no }}
|
||||
</td>
|
||||
|
||||
<!-- Action Buttons -->
|
||||
<td class="text-center">
|
||||
<div class="d-flex flex-column gap-1">
|
||||
<a href="/subcontractor/edit/{{ s.id }}" class="btn btn-sm btn-warning">
|
||||
<div class="d-flex gap-2">
|
||||
<a href="{{ url_for('subcontractor.edit_subcontractor', id=s.id) }}"
|
||||
class="btn btn-sm btn-warning w-50">
|
||||
Edit
|
||||
</a>
|
||||
<a href="/subcontractor/delete/{{ s.id }}" class="btn btn-sm btn-danger"
|
||||
onclick="return confirm('Are you sure?')">
|
||||
|
||||
<a href="{{ url_for('subcontractor.delete_subcontractor', id=s.id) }}"
|
||||
class="btn btn-sm btn-danger w-50" onclick="return confirm('Are you sure to delete?')">
|
||||
Delete
|
||||
</a>
|
||||
</div>
|
||||
</td>
|
||||
</tr>
|
||||
</div>
|
||||
</div>
|
||||
{% endfor %}
|
||||
</tbody>
|
||||
</div>
|
||||
|
||||
<!-- TOTAL ROW -->
|
||||
<tfoot>
|
||||
<tr class="table-secondary fw-bold">
|
||||
<td colspan="2" class="text-end"> Total Subcontractors</td>
|
||||
<!-- Pagination -->
|
||||
<nav>
|
||||
<ul class="pagination justify-content-center flex-wrap mt-4">
|
||||
|
||||
<td class="d-none d-lg-table-cell">-</td>
|
||||
<td class="d-none d-lg-table-cell">-</td>
|
||||
<td class="d-none d-lg-table-cell">-</td>
|
||||
{% if pagination.has_prev %}
|
||||
<li class="page-item">
|
||||
<a class="page-link" href="{{ url_for('subcontractor.subcontractor_list', page=1) }}">
|
||||
First
|
||||
</a>
|
||||
</li>
|
||||
|
||||
<td class="text-center">{{ subcontractors|length }}</td>
|
||||
<li class="page-item">
|
||||
<a class="page-link"
|
||||
href="{{ url_for('subcontractor.subcontractor_list', page=pagination.prev_num) }}">
|
||||
Prev
|
||||
</a>
|
||||
</li>
|
||||
{% endif %}
|
||||
|
||||
</tr>
|
||||
</tfoot>
|
||||
{% for page_num in pagination.iter_pages() %}
|
||||
{% if page_num %}
|
||||
{% if page_num != pagination.page %}
|
||||
<li class="page-item">
|
||||
<a class="page-link" href="{{ url_for('subcontractor.subcontractor_list', page=page_num) }}">
|
||||
{{ page_num }}
|
||||
</a>
|
||||
</li>
|
||||
{% else %}
|
||||
<li class="page-item active">
|
||||
<span class="page-link">{{ page_num }}</span>
|
||||
</li>
|
||||
{% endif %}
|
||||
{% else %}
|
||||
<li class="page-item disabled">
|
||||
<span class="page-link">...</span>
|
||||
</li>
|
||||
{% endif %}
|
||||
{% endfor %}
|
||||
|
||||
</table>
|
||||
{% if pagination.has_next %}
|
||||
<li class="page-item">
|
||||
<a class="page-link"
|
||||
href="{{ url_for('subcontractor.subcontractor_list', page=pagination.next_num) }}">
|
||||
Next
|
||||
</a>
|
||||
</li>
|
||||
|
||||
<li class="page-item">
|
||||
<a class="page-link"
|
||||
href="{{ url_for('subcontractor.subcontractor_list', page=pagination.pages) }}">
|
||||
Last
|
||||
</a>
|
||||
</li>
|
||||
{% endif %}
|
||||
|
||||
</ul>
|
||||
</nav>
|
||||
|
||||
</div>
|
||||
</div>
|
||||
|
||||
</div>
|
||||
|
||||
@@ -1,29 +1,105 @@
|
||||
{% extends "base.html" %}
|
||||
|
||||
{% block content %}
|
||||
|
||||
<div class="container-fluid px-2 px-md-4">
|
||||
<div class="container-fluid mt-3">
|
||||
|
||||
<h4 class="mb-3 text-center text-md-start">Subcontractor Dashboard </h4>
|
||||
<h4 class="mb-4">Subcontractor Dashboard</h4>
|
||||
|
||||
<!-- Charts -->
|
||||
<div class="row g-3">
|
||||
<div class="row mb-3">
|
||||
|
||||
<!-- Bar Chart -->
|
||||
<div class="col-12 col-md-6">
|
||||
<div class="card shadow-sm h-100">
|
||||
<div class="card-header bg-dark text-white text-center text-md-start">
|
||||
Work Category Bar Chart
|
||||
</div>
|
||||
<div class="card-body text-center">
|
||||
<img src="data:image/png;base64,{{ bar_chart }}" class="img-fluid" style="max-height:300px;">
|
||||
</div>
|
||||
</div>
|
||||
<div class="col-md-4">
|
||||
<select id="subcontractor" class="form-control">
|
||||
<option value="">Select Subcontractor</option>
|
||||
|
||||
{% for s in subcontractors %}
|
||||
<option value="{{s.id}}">{{s.subcontractor_name}}</option>
|
||||
{% endfor %}
|
||||
|
||||
</select>
|
||||
</div>
|
||||
|
||||
<div class="col-md-4">
|
||||
<select id="category" class="form-control">
|
||||
<option value="">Select Category</option>
|
||||
<option value="Soft Murum">Soft Murum</option>
|
||||
<option value="Hard Murum">Hard Murum</option>
|
||||
<option value="Soft Rock">Soft Rock</option>
|
||||
<option value="Hard Rock">Hard Rock</option>
|
||||
</select>
|
||||
</div>
|
||||
|
||||
<div class="col-md-4">
|
||||
<select id="ra_bill" class="form-control">
|
||||
<option value="">RA Bill</option>
|
||||
</select>
|
||||
</div>
|
||||
|
||||
</div>
|
||||
|
||||
|
||||
<div class="card shadow">
|
||||
<div class="card-body">
|
||||
|
||||
<canvas id="comparisonChart" height="120"></canvas>
|
||||
|
||||
</div>
|
||||
</div>
|
||||
|
||||
</div>
|
||||
|
||||
|
||||
<script src="https://cdn.jsdelivr.net/npm/chart.js"></script>
|
||||
|
||||
<script>
|
||||
|
||||
let chart;
|
||||
|
||||
function loadChart() {
|
||||
|
||||
let subcontractor = document.getElementById("subcontractor").value
|
||||
let category = document.getElementById("category").value
|
||||
let ra_bill = document.getElementById("ra_bill").value
|
||||
|
||||
|
||||
fetch(`/dashboard/api/subcontractor-chart?subcontractor=${subcontractor}&category=${category}&ra_bill=${ra_bill}`)
|
||||
|
||||
.then(res => res.json())
|
||||
.then(data => {
|
||||
|
||||
if (chart) {
|
||||
chart.destroy()
|
||||
}
|
||||
|
||||
const ctx = document.getElementById("comparisonChart")
|
||||
|
||||
chart = new Chart(ctx, {
|
||||
type: "bar",
|
||||
data: {
|
||||
labels: data.labels,
|
||||
datasets: [{
|
||||
label: "Subcontractor Quantity",
|
||||
data: data.values,
|
||||
backgroundColor: "#0d6efd"
|
||||
}]
|
||||
},
|
||||
options: {
|
||||
responsive: true,
|
||||
plugins: {
|
||||
legend: { display: true }
|
||||
}
|
||||
}
|
||||
})
|
||||
|
||||
})
|
||||
|
||||
}
|
||||
|
||||
document.getElementById("subcontractor").addEventListener("change", loadChart)
|
||||
document.getElementById("category").addEventListener("change", loadChart)
|
||||
document.getElementById("ra_bill").addEventListener("change", loadChart)
|
||||
|
||||
loadChart()
|
||||
|
||||
</script>
|
||||
|
||||
{% endblock %}
|
||||
8
app/utils/exceptions.py
Normal file
8
app/utils/exceptions.py
Normal file
@@ -0,0 +1,8 @@
|
||||
from app.constants.http_status import HTTPStatus
|
||||
|
||||
class APIException(Exception):
|
||||
def __init__(self, message, status_code=HTTPStatus.BAD_REQUEST, errors=None):
|
||||
self.message = message
|
||||
self.status_code = status_code
|
||||
self.errors = errors
|
||||
super().__init__(self.message)
|
||||
@@ -1,6 +1,16 @@
|
||||
import os
|
||||
from flask import current_app
|
||||
from app.config import Config
|
||||
|
||||
|
||||
def get_download_format_folder():
|
||||
return os.path.join(
|
||||
current_app.root_path,
|
||||
"static",
|
||||
"downloads",
|
||||
"format"
|
||||
)
|
||||
|
||||
def ensure_upload_folder():
|
||||
if not os.path.exists(Config.UPLOAD_FOLDER):
|
||||
os.makedirs(Config.UPLOAD_FOLDER)
|
||||
os.makedirs(Config.UPLOAD_FOLDER)
|
||||
12
app/utils/regex_utils.py
Normal file
12
app/utils/regex_utils.py
Normal file
@@ -0,0 +1,12 @@
|
||||
import re
|
||||
|
||||
class RegularExpression:
|
||||
|
||||
# sum fields of TrEx, MhEx (_total)
|
||||
STR_TOTAL_PATTERN = re.compile(r".*_total$")
|
||||
|
||||
# sum fields of pipe laying (pipe_150_mm)
|
||||
PIPE_MM_PATTERN = re.compile(r"^pipe_\d+_mm$")
|
||||
|
||||
# sum fields of MH dc (d_0_to_0_75)
|
||||
D_RANGE_PATTERN = re.compile( r"^d_\d+(?:_\d+)?_to_\d+(?:_\d+)?$")
|
||||
23
app/utils/response_handler.py
Normal file
23
app/utils/response_handler.py
Normal file
@@ -0,0 +1,23 @@
|
||||
from flask import jsonify
|
||||
from app.constants.http_status import HTTPStatus
|
||||
|
||||
|
||||
class ResponseHandler:
|
||||
|
||||
@staticmethod
|
||||
def success(message, data=None, status_code=HTTPStatus.OK):
|
||||
return jsonify({
|
||||
"status": "success",
|
||||
"message": message,
|
||||
"data": data if data else {},
|
||||
"errors": []
|
||||
}), status_code
|
||||
|
||||
@staticmethod
|
||||
def error(message, errors=None, status_code=HTTPStatus.BAD_REQUEST):
|
||||
return jsonify({
|
||||
"status": "error",
|
||||
"message": message,
|
||||
"data": {},
|
||||
"errors": errors if errors else []
|
||||
}), status_code
|
||||
Binary file not shown.
Reference in New Issue
Block a user