vendor-management-api/service/asset_service.py

from dao.asset_dao import *
from datetime import datetime

def genrateAssetCode(data,mongo):
    asset_code=[]
    try:
        asset_type=str(data['asset_type'])
        place=str(data['place'])
        qty=int(data['qty'])
        count={}
        for counter in range(1,qty+1): 
            asset_count=create_asset_id(asset_type,count,mongo) 
            
            asset_code.append("KEF_"+((place).upper())[:3]+"_"+((asset_type).upper())[:3]+"_"+asset_count)
            if asset_type in count:
                count[asset_type]=count[asset_type]+1
            else:
                count[asset_type]=1
    except Exception as err:
        pass
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        
    return asset_code

def create_asset_id(asset_type,count,mongo):
    asset_count = ''
    try:
        asset_count = getInserterdAssetsCount(asset_type, mongo)
        if asset_type in count:
            asset_count=count[asset_type]+asset_count

        asset_count = str(asset_count + 1) if asset_count + 1 > 9 else '0' + str(asset_count +1)
    except Exception as err:
        print(err)

    return asset_count

def getAllAssetsListService(mongo): # 
    queryResult=[]
    try:
        queryResult=getAllAssetsListDao(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 getAssetCategoryList( mongo):  # Validate email id and password
    queryResult = []
    try:
        queryResult = getAssetCategoryListDao(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 updateAssetReportDetailsService(data,mongo):
    response={'status':'failure','message':'Something went wrong!'}
    try:
        update_obj={}
        if 'type' in data and data['type']=='sale':
            update_obj['sale']=True
            update_obj['sale_amount']=int(data['amount'])
            update_obj['sale_at']=int(datetime.now().timestamp()*1000)
        elif 'type' in data and data['type']=='write-off':
            update_obj['write_off']=True
            update_obj['write_off_amount']=int(data['amount'])
            update_obj['write_off_at']=int(datetime.now().timestamp()*1000)

        response={'status':'success','message':'Updated successfully!'}
        updateAssetReportDetailsDao(data['asset_id'],update_obj,mongo)
    except Exception as err:
        print(err)
        # insert_into_error_log({'timestamp':int(datetime.now().timestamp()*1000),'type':'api','err':str(err),'function':'validateLogin'},mongo)
        
    return response