vendor-management-api/service/vendor_service.py

from dao.vendor_dao import *
from dao.project_dao import getUserDetailsFromMaster
from config import V_BASE_CODE
from utils.error_log import insert_into_error_log
from utils.UploadImage import uploadImagetoFolder
from datetime import datetime

def validateVendorCode(v_code,mongo): # Validate email id and password
    queryResult={}
    try:
        query_response=validateVendorCodeDao(v_code,mongo)
        if len(query_response)!=0:
            queryResult={'status':'failure','message': 'The Vendor Code is already in use!'}
        else:
            queryResult={'status':'success','message': 'Vendor Code is available!'}
        

    except Exception as err:
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        queryResult={'status':'failure','message': 'Something went wrong!'}

    return queryResult

def validatePANService(v_pan,mongo): # Validate email id and password
    queryResult={}
    try:
        query_response=validatePANDao(v_pan,mongo)
        if len(query_response)!=0:
            queryResult={'status':'failure','message': 'The PAN is already in use!'}
        else:
            queryResult={'status':'success','message': 'The PAN is available!'}
        

    except Exception as err:
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        queryResult={'status':'failure','message': 'Something went wrong!'}

    return queryResult

def addVendorService(files,data,app,mongo):
    queryResult={}
    try:
        
        if data['id']=='0':
            data['created_on']=int(datetime.now().timestamp()*1000)
            data['status']='PENDING'
            # Validate PAN number
            pan_response=validatePANService(data['v_pan'],mongo)
            if pan_response['status']=='success':
                # Genrate vendor code
                v_code=V_BASE_CODE+(getTotalUserCount(mongo)+1)
                
                pan_new_name=''
                dec_new_name=''
                cheq_new_name=''
                v_pan_file = files['v_pan_file']
                v_declaration_file=files['v_declaration_file']
                v_cheque_file=files['v_cheque_file']
                panImageResponse=uploadImagetoFolder(v_pan_file,'pan_',app)
                decImageResponse=uploadImagetoFolder(v_declaration_file,'dec_',app)
                cheqImageResponse=uploadImagetoFolder(v_cheque_file,'cheq_',app)
                if panImageResponse['status']=='success':
                    pan_new_name=panImageResponse['message']
                if decImageResponse['status']=='success':
                    dec_new_name=decImageResponse['message']
                if cheqImageResponse['status']=='success':
                    cheq_new_name=cheqImageResponse['message']

                data['v_status']='active'
                data['v_code']=v_code
                data['v_pan_file']=pan_new_name
                data['v_declaration_file']=dec_new_name
                data['v_cheque_file']=cheq_new_name

                # Insert into vendor master
                insertIntoVendorMaster(data,mongo)

                queryResult={'status':'success','message': 'Vendor registered successfully!','v_code':v_code}
            else:
                queryResult=pan_response
        else:
            data['updated_on']=int(datetime.now().timestamp()*1000)
            # Insert into vendor master
            insertIntoVendorMaster(data,mongo)
            queryResult={'status':'success','message': 'Vendor updated successfully!'}
    except Exception as err:
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        queryResult={'status':'failure','message': 'Something went wrong!'}

    return queryResult

def updateVendorStatus(data,mongo):
    queryResult={}
    try:
        data['updated_on']=int(datetime.now().timestamp()*1000)
        status=""
        if data['flag']=='approve':
            status="APPROVED"
        elif data['flag']=='decline':
            status="DECLINED"
            
        data['status']=status

        if status!="":
            # Insert into vendor master
            updateVendorStatusDao(data,data['requestKey'],mongo)
            queryResult={'status':'success','message': 'Vendor updated successfully!'}
        else:
            queryResult={'status':'failure','message': 'Something went wrong!'}
        
    except Exception as err:
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        queryResult={'status':'failure','message': 'Something went wrong!'}

    return queryResult

def updateVendorStatusAdmin(data,mongo):
    queryResult={}
    try:
        # Insert into vendor master
        updateVendorStatusAdminDao({'v_status':data['status']},data['vendor_id'],mongo)
        queryResult={'status':'success','message': 'Vendor updated successfully!'}
        
    except Exception as err:
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        queryResult={'status':'failure','message': 'Something went wrong!'}

    return queryResult

def update_rating_service(data,mongo):
    queryResult={}
    try:
        data['updated_on']=int(datetime.now().timestamp()*1000)
        data['user_name']=''
        user_details=getUserDetailsFromMaster(data['user_id'],mongo)
        for user_obj in user_details:
            data['user_name']=user_obj['first_name']
        updateVendorRatingDao(data,mongo)
        queryResult={'status':'success','message': 'Vendor Rating Updated Successfully!'}
    except Exception as err:
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        queryResult={'status':'failure','message': 'Something went wrong!'}

    return queryResult

def getVendorList(u_id,mongo): # Validate email id and password
    queryResult=[]
    try:
        queryResult=getVendorListByUID(u_id,mongo)
    except Exception as err:
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        queryResult=[]

    return queryResult

def getAllVendorList(mongo): # 
    queryResult=[]
    try:
        queryResult=getAllVendorListDao(mongo)
    except Exception as err:
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        queryResult=[]

    return queryResult

def getAllUnregisteredVendorList(mongo): # 
    queryResult=[]
    try:
        queryResult=getAllUnregisteredVendorListDao(mongo)
    except Exception as err:
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        queryResult=[]

    return queryResult


def getAllUserList(mongo): # 
    queryResult=[]
    try:
        queryResult=getAllUserListDao(mongo)
    except Exception as err:
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        queryResult=[]

    return queryResult

def getVendorDetails(id,mongo): # Validate email id and password
    queryResult=[]
    try:
        queryResult=getVendorDetailsDao(id,mongo)
    except Exception as err:
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        queryResult=[]

    return queryResult

def getVendorRatingsService(id,mongo): # Validate email id and password
    queryResult=[]
    try:
        queryResult=getVendorRatingsDao(id,mongo)
    except Exception as err:
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        queryResult=[]

    return queryResult