forked from DigiFi/digifi-BankToProductCore
CHIEFSOFT\ameye
138 lines
5.0 KiB
Python
138 lines
5.0 KiB
Python
from flask import session, jsonify
|
|
from app.models.loan import Loan
|
|
from app.utils.logger import logger
|
|
from app.api.services.base_service import BaseService
|
|
from app.api.schemas.eligibility_check import EligibilityCheckSchema
|
|
from marshmallow import ValidationError
|
|
from app.api.enums import TransactionType
|
|
from app.api.integrations import SimbrellaIntegration
|
|
from app.extensions import db
|
|
from app.models import Offer, RACCheck, Members
|
|
from app.api.services.offer_analysis import OfferAnalysis
|
|
from app.api.helpers.response_helper import ResponseHelper
|
|
from werkzeug.security import generate_password_hash, check_password_hash
|
|
from app.api.schemas.login import LoginSchema
|
|
import datetime
|
|
import jwt
|
|
import random
|
|
from app.config import Config
|
|
|
|
|
|
class LoginService(BaseService):
|
|
|
|
@staticmethod
|
|
def process_request(data):
|
|
"""
|
|
Process the Login request.
|
|
|
|
Args:
|
|
data (dict): The request data.
|
|
|
|
Returns:
|
|
dict: A standardized response.
|
|
"""
|
|
try:
|
|
with db.session.begin():
|
|
|
|
validated_data = LoginService.validate_data(data, LoginSchema())
|
|
username = validated_data.get('username')
|
|
password = validated_data.get('password')
|
|
|
|
member = Members.get_member_by_username(username)
|
|
# pass22 = generate_password_hash(password)
|
|
# logger.info("Password generated = > {}".format(pass22) )
|
|
|
|
pass_check = check_password_hash(member.password, password)
|
|
logger.info("Password check: {}".format(pass_check))
|
|
if not member or not pass_check:
|
|
invalid_data = {
|
|
"error_message": "invalid username or password",
|
|
"message_key": "invalid_username_or_password",
|
|
}
|
|
return ResponseHelper.success(data=invalid_data)
|
|
|
|
user_data = {}
|
|
user_data["id"] = member.id,
|
|
user_data["member_id"]= member.id,
|
|
user_data["uid"] = str(member.uid),
|
|
|
|
user_token = jwt.encode(
|
|
{"user": user_data, 'exp' : datetime.datetime.utcnow() + datetime.timedelta(minutes=3330)},
|
|
Config.JWT_SECRET_KEY,
|
|
algorithm="HS256"
|
|
)
|
|
|
|
# Simulate processing
|
|
response_data = {
|
|
"member_id": member.id,
|
|
"uid": str(member.uid),
|
|
"username": member.username,
|
|
"account_name": member.account_name,
|
|
"firstname":member.firstname,
|
|
"lastname": member.lastname,
|
|
"room": member.uid,
|
|
"token": user_token
|
|
}
|
|
|
|
# user = {}
|
|
# user_data = {}
|
|
# user_data["id"] = result_data["member_id"]
|
|
# user_data["member_id"] =result_data["member_id"]
|
|
# user_data["uid"] = result_data["uid"]
|
|
|
|
# token should expire after 24 hrs
|
|
# user["token"] = jwt.encode(
|
|
# {"user": user_data, 'exp' : datetime.datetime.utcnow() + datetime.timedelta(minutes=3330)},
|
|
# Config.JWT_SECRET_KEY,
|
|
# algorithm="HS256"
|
|
# )
|
|
# user["room"] = result_data["uid"]
|
|
# response_data = {
|
|
# "message": "Successfully fetched auth token",
|
|
# "data": user_data
|
|
# }
|
|
|
|
return ResponseHelper.success(data=response_data)
|
|
|
|
except ValidationError as err:
|
|
|
|
logger.error(f"Validation Error: {getattr(err, 'messages', str(err))}")
|
|
db.session.rollback()
|
|
return ResponseHelper.unprocessable_entity(result_description="Validation exception")
|
|
|
|
except ValueError as err:
|
|
logger.error(f"{getattr(err, 'messages', str(err))}")
|
|
db.session.rollback()
|
|
return ResponseHelper.error(result_description=str(err))
|
|
|
|
except Exception as e:
|
|
logger.error(f"An error occurred: {str(e)}", exc_info=True)
|
|
db.session.rollback()
|
|
return ResponseHelper.internal_server_error()
|
|
|
|
@staticmethod
|
|
def check_loan_limits(customer_id):
|
|
"""
|
|
Checks if a customer has exceeded the loan limits for given offer.
|
|
"""
|
|
loan = Loan.get_customer_last_loan(customer_id)
|
|
|
|
if not loan:
|
|
return True
|
|
|
|
offer_id = loan.offer_id[:5]
|
|
|
|
offer = Offer.get_offer_by_id(offer_id)
|
|
if not offer:
|
|
logger.error(f"Offer not found for offer_id: {offer_id} (customer_id: {customer_id})")
|
|
return False
|
|
|
|
daily_count = Loan.get_daily_loan_count(customer_id, offer.product_id)
|
|
|
|
logger.info(f"daily_count: {daily_count}, Max: {offer.max_daily_loans}")
|
|
|
|
if offer.max_daily_loans is not None and daily_count >= offer.max_daily_loans:
|
|
return False
|
|
|
|
return True
|