from appservices.common.util import * from appservices.v1.controllers.payout_apis import * from appservices.common.payment_gateways.wowpe_payment_gateways import * from appservices.common.payment_gateways.accurepay_payment_gateways import * from appservices.common.payment_gateways.idfc_payment_gateways import * from appservices.common.payment_gateways.lyra_payment_gateway import * from appservices.common.payment_gateways.campuslinkpro_payment_gateway import * users = Blueprint("users",__name__) @users.route("/user_signup",methods=["POST"]) def user_signup(): data_status = {"responseStatus": 0, "result": ""} fullName = request.json.get("fullName","") phoneNumber = request.json.get("phoneNumber","") email = request.json.get("email","") address = request.json.get("address","") stateId = request.json.get("stateId","") cityId = request.json.get("cityId","") blockPoId = request.json.get("blockPoId","") pincodeId = request.json.get("pincodeId","") password = request.json.get("password","") if fullName and phoneNumber and email and password and address and stateId and cityId and blockPoId and pincodeId: try: user_queryset = Users.objects(email__iexact=email).first() if user_queryset: data_status["result"]="Email id already exist!!" return data_status # userPermissionId = "66bb4abb3bcb018a213b5af5" pattern_queryset = Patterns.objects(defaultProfile=True,status__in=[0,1]).first() patternId = str(pattern_queryset.id) imeiNumber = random_digit_generate(15) user_table = Users( fullName = fullName, phoneNumber = phoneNumber, email = email, password = generate_password_hash(password), address = address, createdOn =datetime.datetime.now(), stateId = stateId, cityId = cityId, blockPoId = blockPoId, pincodeId = pincodeId, patternId = patternId, # userPermissionId = userPermissionId, merchantUniqueNumber = generate_next_serial_number(), payoutBalance = 0, walletBalance = 0, merchantType="customer", channel="app", imeiNumber = imeiNumber, status = 1 ) save_table = user_table.save() userId = str(save_table.id) if userId: user_kyc_table = UserKYC( userId=userId, channel="app", createdOn =datetime.datetime.now(), submittedDate =datetime.datetime.now(), panStatus="Pending", bankStatus="Pending", aadharStatus="Pending", businessStatus="Pending", agreementVerificationStatus="Pending", videoVerificationStatus="Pending", status = 1 ) save_table = user_kyc_table.save() user_queryset = Users.objects(id=userId).first() userLoginDetails = { "id": str(user_queryset.id), "stateId": str(user_queryset.stateId.id), "userPermissionId": str(user_queryset.patternId.userPermissionId.id), "userPermissionName": user_queryset.patternId.userPermissionId.permissionName, "fullName": user_queryset.fullName, "phoneNumber": user_queryset.phoneNumber, "email": user_queryset.email, "address": user_queryset.address, "createdOn": user_queryset.createdOn, "status": user_queryset.status, "merchantType": user_queryset.merchantType, "lastLogin": user_queryset.lastLogin } if user_queryset.tPin == 0: userLoginDetails["tPin"] = 0 else: userLoginDetails["tPin"] = user_queryset.tPin data_status["responseStatus"] = 1 data_status["result"] = "User signup successfully!" data_status["userLoginDetails"]=userLoginDetails try: email=user_queryset.email if email: merchantName = str(user_queryset.fullName) mail_subject = "Welcome to GraamPay!" recipients_list = [email] template_name = "emails/welcomeemail.html" mail_data = { "merchantName":merchantName, "mobileNumber":user_queryset.phoneNumber } mailoutputData = send_asynchronous_email(mail_subject, recipients_list, template_name, mail_data) except Exception as e: pass return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to create user signup!!" return data_status else: data_status["result"] = "Required fields are missing!!" return data_status @users.route("/user_login",methods=["POST"]) def user_login(): data_status = {"responseStatus": 0, "result": ""} phoneNumber = request.json.get("phoneNumber","") password = request.json.get("password","") deviceName = request.json.get("deviceName","") latitude = request.json.get("latitude","") longitude = request.json.get("longitude","") os = request.json.get("os","") if phoneNumber and password: try: user_queryset = Users.objects(phoneNumber__iexact=phoneNumber,status__nin=[2]).first() if not user_queryset: data_status["result"]="Invalid phone number!!" return data_status userId = str(user_queryset.id) try: user_login_report_table = LoginReportLogs( userId = userId, deviceName = deviceName, latitude = latitude, longitude = longitude, os = os, wrongPasswordAttempts=0, createdOn = datetime.datetime.now(), status = 1 ) save_user_log_table=user_login_report_table.save() logId = str(save_user_log_table.id) except Exception as e: app.logger.error(traceback.format_exc()) pass if user_queryset.status == 0: data_status["result"]="The phone number is not verified." return data_status elif user_queryset.status == 5: data_status["result"]="Your account is locked please contact to support!!" return data_status elif user_queryset.status == 3: data_status["result"]="Your account is blocked please contact to support!!" return data_status elif user_queryset.status != 1: data_status["result"]="Invalid phone number!!" return data_status if check_password_hash(user_queryset.password, password): if user_queryset.status == 1: user_queryset.lastLogin = datetime.datetime.now() user_queryset.save() userLoginDetails = { "id": str(user_queryset.id), "stateId": str(user_queryset.stateId.id), "fullName": user_queryset.fullName, "phoneNumber": user_queryset.phoneNumber, "email": user_queryset.email, "address": user_queryset.address, "createdOn": user_queryset.createdOn, "status": user_queryset.status, "merchantType": user_queryset.merchantType, "lastLogin": user_queryset.lastLogin } if user_queryset.tPin == 0: userLoginDetails["tPin"] = 0 else: userLoginDetails["tPin"] = user_queryset.tPin try: if user_queryset.patternId.userPermissionId: userLoginDetails["userPermissionId"] = str(user_queryset.patternId.userPermissionId.id) userPermissionsDetails = {} user_permissions_queryset = UserPermissions.objects(id=str(user_queryset.patternId.userPermissionId.id)).first() userPermissionsDetails = { "userPermissionId":str(user_permissions_queryset.id), "permissionName":user_permissions_queryset.permissionName, "groupingPermissionsList":user_permissions_queryset.groupingPermissionsList, "categoryPermissionsList":user_permissions_queryset.categoryPermissionsList, "servicePermissionsList":user_permissions_queryset.servicePermissionsList, "operatorPermissionsList":user_permissions_queryset.operatorPermissionsList, "otherPermissionsList":user_permissions_queryset.otherPermissionsList } userLoginDetails["userPermissionsDetails"]=userPermissionsDetails else: userLoginDetails["userPermissionId"] = "" userLoginDetails["userPermissionsDetails"] = {} except Exception as e: userLoginDetails["userPermissionId"] = "" userLoginDetails["userPermissionsDetails"] = {} data_status["responseStatus"] = 1 data_status["result"] = "User login successfull!" data_status["userLoginDetails"] = userLoginDetails return data_status else: data_status["result"] = "Please contact the admin for approval to log in!!" return data_status else: save_user_log_table.update(wrongPasswordAttempts=1) user_logs_queryset = LoginReportLogs.objects(userId=userId).order_by("-id").limit(3) if user_logs_queryset: isLock = 0 for each_user_log in user_logs_queryset: if each_user_log.wrongPasswordAttempts == 0: isLock = 1 if isLock == 0: user_queryset.update(status=5) data_status["result"]="Too many attempts. Your account is locked please contact to support!!" return data_status else: data_status["result"] = "Invalid Password!!" return data_status else: data_status["result"] = "Invalid Password!!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to user login!!" return data_status else: data_status["result"] = "Required fields are missing!!" return data_status @users.route("/add_top_up_request",methods=["POST"]) def add_top_up_request(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") depositBankId = request.json.get("depositBankId","") amount = request.json.get("amount",0) paymentMode = request.json.get("paymentMode","") transaction = request.json.get("transaction","") paymentDate = request.json.get("paymentDate","") transactionSlip = request.json.get("transactionSlip","") if depositBankId and amount and paymentMode and userId and paymentDate and transaction: try: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"]="Invalid user id!!" return data_status top_up_table = TopUpRequests( userId=userId, depositBankId = depositBankId, amount = amount, paymentMode = paymentMode, transaction = transaction, paymentDate = paymentDate, createdOn =datetime.datetime.now(), status = 1 ) save_table = top_up_table.save() if transactionSlip: image_name = upload_file_image(transactionSlip, "transactionSlips", str(get_epoch_milli_time()), "") if image_name: save_table.update(transactionSlip=image_name) data_status["responseStatus"] = 1 data_status["result"] = "User top up request successfully!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to save user top up request!!" return data_status else: data_status["result"] = "Required fields are missing!!" return data_status @users.route("/deposite_banks_list",methods=["POST"]) def deposite_banks_list(): data_status = {"responseStatus": 0, "result": ""} bankType = request.json.get("bankType") #"administrator" or "parent" if not bankType: data_status["result"]="Required fields are missing!!" return data_status depositeBanksList=[] try: deposite_banks_queryset = CompanyBankAccounts.objects(companyType=bankType,status__in=[1]).order_by("-id").all() for each_bank in deposite_banks_queryset: depositeBankDict = { "id":str(each_bank.id), "bankName":each_bank.bankName, "companyType":each_bank.companyType, "accountName":each_bank.accountName, "accountNumber":each_bank.accountNumber, "bankCode":each_bank.bankCode } if each_bank.image: depositeBankDict["image"]=domain+each_bank.image else: depositeBankDict["image"]="" depositeBanksList.append(depositeBankDict) data_status["responseStatus"] = 1 data_status["result"] = "Deposite Banks data fected successfull!" data_status["depositeBanksList"] = depositeBanksList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch deposite banks data!!" return data_status @users.route("/transaction_history",methods=["POST"]) def transaction_history(): data_status = {"responseStatus": 0, "result": ""} startDate = request.json.get("startDate") endDate = request.json.get("endDate") if startDate and endDate: transactionHistoryList=[] try: startDateTimeObject = datetime.datetime.strptime(startDate,"%m-%d-%Y") endDateTimeObject = datetime.datetime.strptime(endDate,"%m-%d-%Y") start_date = startDateTimeObject.replace(hour=0, minute=0, second=0, microsecond=0) end_date = endDateTimeObject.replace(hour=23, minute=59, second=59, microsecond=999999) transactions_queryset = TopUpRequests.objects( createdOn__gte=start_date, createdOn__lte=end_date, status__in=[1] ).order_by("-id").all() for each_transaction in transactions_queryset: transactionDict = { "id":str(each_transaction.id), "depositBankId":str(each_transaction.depositBankId.id), "depositBankName":each_transaction.depositBankId.bankName, "depositBankCode":each_transaction.depositBankId.bankCode, "depositBankAccountNumber":each_transaction.depositBankId.accountNumber, "depositBankAccountType":each_transaction.depositBankId.accountType, "paymentMode":each_transaction.paymentMode, "transaction":each_transaction.transaction, "paymentDate":each_transaction.paymentDate, "amount":each_transaction.amount } if each_transaction.transactionSlip: transactionDict["transactionSlip"]=domain+each_transaction.transactionSlip else: transactionDict["transactionSlip"]="" transactionHistoryList.append(transactionDict) data_status["responseStatus"] = 1 data_status["result"] = "Transaction history data fetched successfull!" data_status["transactionHistoryList"] = transactionHistoryList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch transaction history data!!" return data_status else: data_status["result"]="Required fields are missing!!" return data_status @users.route("/add_user_kyc",methods=["POST"]) def add_user_kyc(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") originalPanName = request.json.get("originalPanName","") panName = request.json.get("panName","") panNumber = request.json.get("panNumber","") panStatus = request.json.get("panStatus","") panDocument = request.json.get("panDocument","") bankId = request.json.get("bankId","") bankName = request.json.get("bankName","") originalBankName = request.json.get("originalBankName","") bankAccountNumber = request.json.get("bankAccountNumber","") bankStatus = request.json.get("bankStatus","") ifscCode = request.json.get("ifscCode","") aadharName = request.json.get("aadharName","") originalAadharName = request.json.get("originalAadharName","") aadharNumber = request.json.get("aadharNumber","") aadharStatus = request.json.get("aadharStatus","") aadharDocument = request.json.get("aadharDocument","") aadharBackDocument = request.json.get("aadharBackDocument","") if panNumber and panStatus: try: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"]="Invalid user id!!" return data_status user_kyc_table = UserKYC( userId=userId, panName = panName, originalPanName = originalPanName, panNumber = panNumber, panStatus = panStatus, bankName = bankName, originalBankName = originalBankName, bankId = bankId, bankAccountNumber = bankAccountNumber, bankStatus = bankStatus, ifscCode = ifscCode, aadharName = aadharName, originalAadharName = originalAadharName, aadharNumber = aadharNumber, aadharStatus = aadharStatus, channel="app", createdOn =datetime.datetime.now(), submittedDate =datetime.datetime.now(), status = 1 ) save_table = user_kyc_table.save() if panDocument: image_name = upload_file_image(panDocument, "panDocuments", str(get_epoch_milli_time()), "") if image_name: save_table.update(panDocument=image_name) if aadharDocument: image_name = upload_file_image(aadharDocument, "aadharDocuments", str(get_epoch_milli_time()), "") if image_name: save_table.update(aadharDocument=image_name) if aadharBackDocument: image_name = upload_file_image(aadharBackDocument, "aadharDocuments", str(get_epoch_milli_time()), "") if image_name: save_table.update(aadharBackDocument=image_name) data_status["responseStatus"] = 1 data_status["result"] = "User KYC added successfully!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to save user KYC!!" return data_status else: data_status["result"] = "Required fields are missing!!" return data_status # def add_user_kyc(): # data_status = {"responseStatus": 0, "result": ""} # userId = request.json.get("userId","") # panName = request.json.get("panName","") # panNumber = request.json.get("panNumber","") # panStatus = request.json.get("panStatus","") # panDocument = request.json.get("panDocument","") # bankId = request.json.get("bankId","") # bankName = request.json.get("bankName","") # bankAccountNumber = request.json.get("bankAccountNumber","") # bankStatus = request.json.get("bankStatus","") # ifscCode = request.json.get("ifscCode","") # aadharName = request.json.get("aadharName","") # aadharNumber = request.json.get("aadharNumber","") # aadharStatus = request.json.get("aadharStatus","") # aadharDocument = request.json.get("aadharDocument","") # if panNumber and panStatus: # try: # user_queryset = Users.objects(id=userId,status__in=[1]).first() # if not user_queryset: # data_status["result"]="Invalid user id!!" # return data_status # user_kyc_table = UserKYC( # userId=userId, # panName = panName, # panNumber = panNumber, # panStatus = panStatus, # bankName = bankName, # bankId = bankId, # bankAccountNumber = bankAccountNumber, # bankStatus = bankStatus, # ifscCode = ifscCode, # aadharName = aadharName, # aadharNumber = aadharNumber, # aadharStatus = aadharStatus, # createdOn =datetime.datetime.now(), # status = 1 # ) # save_table = user_kyc_table.save() # if panDocument: # image_name = upload_file_image(panDocument, "panDocuments", str(get_epoch_milli_time()), "") # if image_name: # save_table.update(panDocument=image_name) # if aadharDocument: # image_name = upload_file_image(aadharDocument, "aadharDocuments", str(get_epoch_milli_time()), "") # if image_name: # save_table.update(aadharDocument=image_name) # data_status["responseStatus"] = 1 # data_status["result"] = "User KYC added successfully!" # return data_status # except Exception as e: # app.logger.error(traceback.format_exc()) # data_status["result"] = "Unable to save user KYC!!" # return data_status # else: # data_status["result"] = "Required fields are missing!!" # return data_status @users.route("/update_user_kyc",methods=["POST"]) def update_user_kyc(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") panName = request.json.get("panName","") originalPanName = request.json.get("originalPanName","") panNumber = request.json.get("panNumber","") panStatus = request.json.get("panStatus","") panDocument = request.json.get("panDocument","") bankId = request.json.get("bankId","") bankName = request.json.get("bankName","") originalBankName = request.json.get("originalBankName","") bankHolderName = request.json.get("bankHolderName","") bankAccountNumber = request.json.get("bankAccountNumber","") bankStatus = request.json.get("bankStatus","") ifscCode = request.json.get("ifscCode","") aadharName = request.json.get("aadharName","") originalAadharName = request.json.get("originalAadharName","") aadharNumber = request.json.get("aadharNumber","") aadharStatus = request.json.get("aadharStatus","") aadharDocument = request.json.get("aadharDocument","") aadharBackDocument = request.json.get("aadharBackDocument","") if userId: try: user_queryset = Users.objects(id=userId,status=1).first() if not user_queryset: data_status["result"]="Invalid user id!!" return data_status user_kyc_queryset = UserKYC.objects(userId=userId).first() if user_kyc_queryset: if panName: user_kyc_queryset.update( panName = panName, originalPanName = originalPanName, panNumber = panNumber, panStatus = panStatus, submittedDate =datetime.datetime.now() ) if aadharName: user_kyc_queryset.update( aadharName = aadharName, originalAadharName = originalAadharName, aadharNumber = aadharNumber, aadharStatus = aadharStatus, submittedDate =datetime.datetime.now() ) if bankName: user_kyc_queryset.update( bankName = bankName,originalBankName = originalBankName, bankAccountNumber = bankAccountNumber,bankHolderName = bankHolderName, bankStatus = bankStatus,ifscCode = ifscCode, submittedDate =datetime.datetime.now() ) if bankId: user_kyc_queryset.update(bankId=ObjectId(bankId)) if panDocument: image_name = upload_file_image(panDocument, "panDocuments", str(get_epoch_milli_time()), "") if image_name: user_kyc_queryset.update(panDocument=image_name,submittedDate =datetime.datetime.now()) if aadharDocument: image_name = upload_file_image(aadharDocument, "aadharDocuments", str(get_epoch_milli_time()), "") if image_name: user_kyc_queryset.update(aadharDocument=image_name,submittedDate =datetime.datetime.now()) if aadharBackDocument: image_name = upload_file_image(aadharBackDocument, "aadharDocuments", str(get_epoch_milli_time()), "") if image_name: user_kyc_queryset.update(aadharBackDocument=image_name,submittedDate =datetime.datetime.now()) data_status["result"] = "User KYC updated successfully!" else: user_kyc_table = UserKYC( userId=userId, panName = panName, originalPanName = originalPanName, panNumber = panNumber, panStatus = panStatus, bankName = bankName, originalBankName = originalBankName, bankId = bankId, bankAccountNumber = bankAccountNumber, bankStatus = bankStatus, ifscCode = ifscCode, aadharName = aadharName, originalAadharName = originalAadharName, aadharNumber = aadharNumber, aadharStatus = aadharStatus, createdOn =datetime.datetime.now(), submittedDate =datetime.datetime.now(), status = 1 ) save_table = user_kyc_table.save() if panDocument: image_name = upload_file_image(panDocument, "panDocuments", str(get_epoch_milli_time()), "") if image_name: save_table.update(panDocument=image_name) if aadharDocument: image_name = upload_file_image(aadharDocument, "aadharDocuments", str(get_epoch_milli_time()), "") if image_name: save_table.update(aadharDocument=image_name) if aadharBackDocument: image_name = upload_file_image(aadharBackDocument, "aadharDocuments", str(get_epoch_milli_time()), "") if image_name: save_table.update(aadharBackDocument=image_name) data_status["result"] = "User KYC created successfully!" data_status["responseStatus"] = 1 return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to update user KYC!!" return data_status else: data_status["result"] = "Required fields are missing!!" return data_status @users.route("/view_all_user_kyc",methods=["POST"]) def view_all_user_kyc(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") if userId: userKycList=[] try: user_kyc_queryset = UserKYC.objects(userId=userId,status=1).order_by("-id").all() for each_user_kyc in user_kyc_queryset: userKycDict = { "id":str(each_user_kyc.id), "panName":each_user_kyc.panName, "originalPanName":each_user_kyc.originalPanName, "panNumber":each_user_kyc.panNumber, "panStatus":each_user_kyc.panStatus, "bankName":each_user_kyc.bankName, "originalBankName":each_user_kyc.originalBankName, "bankAccountNumber":each_user_kyc.bankAccountNumber, "bankStatus":each_user_kyc.bankStatus, "ifscCode":each_user_kyc.ifscCode, "aadharName":each_user_kyc.aadharName, "originalAadharName":each_user_kyc.originalAadharName, "aadharNumber":each_user_kyc.aadharNumber, "aadharStatus":each_user_kyc.aadharStatus } if each_user_kyc.aadharDocument: userKycDict["aadharDocument"]=domain+each_user_kyc.aadharDocument else: userKycDict["aadharDocument"]="" if each_user_kyc.aadharBackDocument: userKycDict["aadharBackDocument"]=domain+each_user_kyc.aadharBackDocument else: userKycDict["aadharBackDocument"]="" if each_user_kyc.panDocument: userKycDict["panDocument"]=domain+each_user_kyc.panDocument else: userKycDict["panDocument"]="" if each_user_kyc.uploadVideo: userKycDict["uploadVideo"]=domain+each_user_kyc.uploadVideo else: userKycDict["uploadVideo"]="" # if each_user_kyc.bankId: # userKycDict["bankId"]=str(each_user_kyc.bankId.id) # else: # userKycDict["bankId"]="" userKycList.append(userKycDict) data_status["responseStatus"] = 1 data_status["result"] = "User KYC data fetched successfull!" data_status["userKycList"] = userKycList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch user kyc data!!" return data_status else: data_status["result"]="Required fields are missing!!" return data_status # def view_all_user_kyc(): # data_status = {"responseStatus": 0, "result": ""} # userId = request.json.get("userId","") # if userId: # userKycList=[] # try: # user_kyc_queryset = UserKYC.objects(userId=userId,status__in=[1]).order_by("-id").all() # for each_user_kyc in user_kyc_queryset: # userKycDict = { # "id":str(each_user_kyc.id), # "panName":each_user_kyc.panName, # "panNumber":each_user_kyc.panNumber, # "panStatus":each_user_kyc.panStatus, # "bankName":each_user_kyc.bankName, # "bankAccountNumber":each_user_kyc.bankAccountNumber, # "bankStatus":each_user_kyc.bankStatus, # "ifscCode":each_user_kyc.ifscCode, # "aadharName":each_user_kyc.aadharName, # "aadharNumber":each_user_kyc.aadharNumber, # "aadharStatus":each_user_kyc.aadharStatus, # "aadharName":each_user_kyc.aadharName # } # if each_user_kyc.aadharDocument: # userKycDict["aadharDocument"]=domain+each_user_kyc.aadharDocument # else: # userKycDict["aadharDocument"]="" # if each_user_kyc.panDocument: # userKycDict["panDocument"]=domain+each_user_kyc.panDocument # else: # userKycDict["panDocument"]="" # if each_user_kyc.uploadVideo: # userKycDict["uploadVideo"]=domain+each_user_kyc.uploadVideo # else: # userKycDict["uploadVideo"]="" # # if each_user_kyc.bankId: # # userKycDict["bankId"]=str(each_user_kyc.bankId.id) # # else: # # userKycDict["bankId"]="" # userKycList.append(userKycDict) # data_status["responseStatus"] = 1 # data_status["result"] = "User KYC data fetched successfull!" # data_status["userKycList"] = userKycList # return data_status # except Exception as e: # app.logger.error(traceback.format_exc()) # data_status["result"]="Unable to fetch user kyc data!!" # return data_status # else: # data_status["result"]="Required fields are missing!!" # return data_status #Get User Personal Details API @users.route("/get_user_personal_details",methods=["POST"]) def get_user_personal_details(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") if userId: try: user_queryset = Users.objects(id=userId,status=1).first() if not user_queryset: data_status["result"]="Invalid user id!!" return data_status user_kyc_queryset = UserKYC.objects(userId=str(user_queryset.id)).first() user_details = { "id":str(user_queryset.id), "fullName":user_queryset.fullName, "merchantType":user_queryset.merchantType, "phoneNumber":user_queryset.phoneNumber, "email":user_queryset.email, "address":user_queryset.address, "pincode":user_queryset.pincodeId.pincode, "pincodeId":str(user_queryset.pincodeId.id), "stateId":str(user_queryset.stateId.id), "stateName":user_queryset.stateId.stateName, "cityId":str(user_queryset.cityId.id), "cityName":user_queryset.cityId.cityName, "blockPoId":str(user_queryset.blockPoId.id), "blockPoName":user_queryset.blockPoId.name, } try: if user_queryset.entityTypeId: user_details["entityTypeId"]=str(user_queryset.entityTypeId.id) user_details["entityType"]=user_queryset.entityTypeId.entityType user_details["isIndividual"]=user_queryset.entityTypeId.isIndividual else: user_details["entityTypeId"]="" user_details["entityType"]= "" user_details["isIndividual"]= True except Exception as e: user_details["entityTypeId"]="" user_details["entityType"]= "" user_details["isIndividual"]= True if user_queryset.pincodeId: user_details["pincode"]=user_queryset.pincodeId.pincode else: user_details["pincode"]="" if user_queryset.profilePicture: user_details["profilePicture"]=domain+user_queryset.profilePicture else: user_details["profilePicture"]="" try: if user_kyc_queryset.panNumber: user_details["panName"]=user_kyc_queryset.panName user_details["panNumber"]=user_kyc_queryset.panNumber user_details["originalPanName"]=user_kyc_queryset.originalPanName if user_kyc_queryset.panDocument: user_details["panDocument"]=domain+user_kyc_queryset.panDocument else: user_details["panDocument"]="" else: user_details["panName"]="" user_details["panNumber"]="" user_details["originalPanName"]="" user_details["panDocument"]="" except: user_details["panName"]="" user_details["panNumber"]="" user_details["originalPanName"]="" user_details["panDocument"]="" try: if user_kyc_queryset.aadharNumber: user_details["aadharName"]=user_kyc_queryset.aadharName user_details["aadharNumber"]=user_kyc_queryset.aadharNumber user_details["originalAadharName"]=user_kyc_queryset.aadharName if user_kyc_queryset.aadharDocument: user_details["aadharDocument"]=domain+user_kyc_queryset.aadharDocument else: user_details["aadharDocument"]="" if user_kyc_queryset.aadharBackDocument: user_details["aadharBackDocument"]=domain+user_kyc_queryset.aadharBackDocument else: user_details["aadharBackDocument"]="" else: user_details["aadharName"]="" user_details["aadharNumber"]="" user_details["originalAadharName"]="" user_details["aadharDocument"]="" user_details["aadharBackDocument"]="" except: print(traceback.format_exc()) user_details["aadharName"]="" user_details["aadharNumber"]="" user_details["originalAadharName"]="" user_details["aadharDocument"]="" user_details["aadharBackDocument"]="" try: if user_kyc_queryset.bankId: user_details["bankId"]=str(user_kyc_queryset.bankId.id) user_details["bankName"]=user_kyc_queryset.bankId.bankName else: user_details["bankId"]="" user_details["bankName"]="" except: user_details["bankId"]="" user_details["bankName"]="" try: if user_kyc_queryset.panReason: user_details["panReason"]=user_kyc_queryset.panReason user_details["bankReason"]=user_kyc_queryset.bankReason user_details["aadharReason"]=user_kyc_queryset.aadharReason user_details["videoVerificationReason"]=user_kyc_queryset.videoVerificationReason else: user_details["panReason"]="" user_details["bankReason"]="" user_details["aadharReason"]="" user_details["videoVerificationReason"]="" except: user_details["panReason"]="" user_details["bankReason"]="" user_details["aadharReason"]="" user_details["videoVerificationReason"]="" try: if user_kyc_queryset.panStatus: user_details["panStatus"]=user_kyc_queryset.panStatus else: user_details["panStatus"]="Pending" except Exception as e: user_details["panStatus"]="Pending" try: if user_kyc_queryset.businessStatus: user_details["businessName"]=user_kyc_queryset.businessName user_details["businessAddress"]=user_kyc_queryset.businessAddress user_details["businessStatus"]=user_kyc_queryset.businessStatus else: user_details["businessName"]="" user_details["businessAddress"]="" user_details["businessStatus"]="Pending" except Exception as e: user_details["businessName"]="" user_details["businessAddress"]="" user_details["businessStatus"]="Pending" try: if user_kyc_queryset.bankStatus: user_details["bankStatus"]=user_kyc_queryset.bankStatus else: user_details["bankStatus"]="Pending" except Exception as e: user_details["bankStatus"]="Pending" try: if user_kyc_queryset.aadharStatus: user_details["aadharStatus"]=user_kyc_queryset.aadharStatus else: user_details["aadharStatus"]="Pending" except Exception as e: user_details["aadharStatus"]="Pending" try: if user_kyc_queryset.videoVerificationStatus: user_details["videoVerificationStatus"]=user_kyc_queryset.videoVerificationStatus else: user_details["videoVerificationStatus"]="Pending" except Exception as e: user_details["videoVerificationStatus"]="Pending" try: if user_kyc_queryset.agreementVerificationStatus: user_details["agreementVerificationStatus"]=user_kyc_queryset.agreementVerificationStatus user_details["agreementVerificationReason"]=user_kyc_queryset.agreementVerificationReason else: user_details["agreementVerificationStatus"]="Pending" user_details["agreementVerificationReason"]="Pending" except Exception as e: user_details["agreementVerificationStatus"]="Pending" user_details["agreementVerificationReason"]="Pending" try: kycStatus = [ user_kyc_queryset.panStatus, user_kyc_queryset.bankStatus, user_kyc_queryset.aadharStatus, user_kyc_queryset.videoVerificationStatus, user_kyc_queryset.agreementVerificationStatus, ] businessStatus="Approved" businessStatusList=[] if user_queryset.entityTypeId.isIndividual == False: businessStatusList.append(user_kyc_queryset.businessStatus) kycStatus.append(user_kyc_queryset.businessStatus) kycStatus.append(user_kyc_queryset.shopVideoStatus) businessStatusList.append(user_kyc_queryset.shopVideoStatus) if user_kyc_queryset.shopImagesList==[]: kycStatus.append("Pending") businessStatusList.append("Pending") if user_kyc_queryset.documentsList==[]: kycStatus.append("Pending") businessStatusList.append("Pending") if user_kyc_queryset.shopImagesList==[]: kycStatus.append("Pending") businessStatusList.append("Pending") for each_image_status in user_kyc_queryset.shopImagesList: shopImageStatus = each_image_status.get("shopImageStatus") kycStatus.append(shopImageStatus) businessStatusList.append(shopImageStatus) for each_document_status in user_kyc_queryset.documentsList: documentStatus = each_document_status.get("documentStatus") kycStatus.append(documentStatus) businessStatusList.append(documentStatus) if any(status == "Rejected" for status in businessStatusList): businessStatus = "Rejected" elif all(status == "Pending" for status in businessStatusList): businessStatus = "Pending" elif all(status == "Approved" for status in businessStatusList): businessStatus = "Approved" elif any(status == "Pending" for status in businessStatusList): businessStatus = "Processing" else: businessStatus= "Submitted" user_details["businessStatus"]=businessStatus user_details["kycStatus"] = all(status == "Approved" for status in kycStatus) except Exception as e: user_details["kycStatus"] = False try: if user_kyc_queryset: user_details["originalBankName"]=user_kyc_queryset.originalBankName user_details["bankAccountNumber"]=user_kyc_queryset.bankAccountNumber user_details["ifscCode"]=user_kyc_queryset.ifscCode else: user_details["originalBankName"]="" user_details["bankAccountNumber"]="" user_details["ifscCode"]="" except Exception as e: user_details["originalBankName"]="" user_details["bankAccountNumber"]="" user_details["ifscCode"]="" try: if user_kyc_queryset.uploadVideo: user_details["uploadVideo"]=domain+user_kyc_queryset.uploadVideo else: user_details["uploadVideo"]="" except Exception as e: user_details["uploadVideo"]="" try: if user_kyc_queryset.shopVideo: user_details["shopVideo"]=domain+user_kyc_queryset.shopVideo else: user_details["shopVideo"]="" except Exception as e: user_details["shopVideo"]="" if user_queryset.signatureImage: user_details["signatureImage"]=domain+user_queryset.signatureImage user_details["agreementDocument"]=domain+user_queryset.agreementDocument else: user_details["signatureImage"]="" user_details["agreementDocument"]="" # try: # if user_kyc_queryset.panStatus == "Approved" and user_kyc_queryset.bankStatus == "Approved" and user_kyc_queryset.aadharStatus == "Approved" and user_kyc_queryset.videoVerificationStatus == "Approved": # user_details["kycStatus"] = True # else: # user_details["kycStatus"] = False # except Exception as e: # user_details["kycStatus"] = False try: if user_queryset.patternId.userPermissionId: user_details["userPermissionId"] = str(user_queryset.patternId.userPermissionId.id) userPermissionsDetails = {} user_permissions_queryset = UserPermissions.objects(id=str(user_queryset.patternId.userPermissionId.id)).first() userPermissionsDetails = { "userPermissionId":str(user_permissions_queryset.id), "permissionName":user_permissions_queryset.permissionName, "groupingPermissionsList":user_permissions_queryset.groupingPermissionsList, "categoryPermissionsList":user_permissions_queryset.categoryPermissionsList, "servicePermissionsList":user_permissions_queryset.servicePermissionsList, "operatorPermissionsList":user_permissions_queryset.operatorPermissionsList, "otherPermissionsList":user_permissions_queryset.otherPermissionsList } user_details["userPermissionsDetails"]=userPermissionsDetails else: user_details["userPermissionId"] = "" user_details["userPermissionsDetails"] = {} except Exception as e: user_details["userPermissionId"] = "" user_details["userPermissionsDetails"] = {} data_status["responseStatus"] = 1 data_status["userPersonalDetails"] = user_details data_status["result"] = "User personal details fetched successfully!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch user personal details data!!" return data_status else: data_status["result"]="Required fields are missing!!" return data_status # def get_user_personal_details(): # # data_status = {"responseStatus": 0, "result": ""} # userId = request.json.get("userId","") # if userId: # try: # user_queryset = Users.objects(id=userId,status__in=[1]).first() # user_kyc_queryset = UserKYC.objects(userId=userId,status__in=[1]).first() # if not user_queryset: # data_status["result"]="Invalid user id!!" # return data_status # user_details = { # "id":str(user_queryset.id), # "fullName":user_queryset.fullName, # "mobileNumber":user_queryset.phoneNumber, # "emailId":user_queryset.email, # "address":user_queryset.address, # "pincode":user_queryset.pincodeId.pincode, # "pincodeId":str(user_queryset.pincodeId.id), # "stateId":str(user_queryset.stateId.id), # "stateName":user_queryset.stateId.stateName, # "cityId":str(user_queryset.cityId.id), # "cityName":user_queryset.cityId.cityName, # "blockPoId":str(user_queryset.blockPoId.id), # "blockPoName":user_queryset.blockPoId.name, # } # if user_queryset.userTypeId: # user_details["userTypeId"]=str(user_queryset.userTypeId.id) # user_details["userType"]=user_queryset.userTypeId.name # else: # user_details["userTypeId"]="" # user_details["userType"]= "" # try: # if user_queryset.entityTypeId: # user_details["entityTypeId"]=str(user_queryset.entityTypeId.id) # user_details["entityType"]=user_queryset.entityTypeId.entityType # else: # user_details["entityTypeId"]="" # user_details["entityType"]= "" # except Exception as e: # user_details["entityTypeId"]="" # user_details["entityType"]= "" # if user_queryset.pincodeId: # user_details["pincode"]=user_queryset.pincodeId.pincode # else: # user_details["pincode"]="" # if user_queryset.profilePicture: # user_details["profilePicture"]=domain+user_queryset.profilePicture # else: # user_details["profilePicture"]="" # try: # if user_kyc_queryset.panName: # user_details["panName"]=user_kyc_queryset.panName # else: # user_details["panName"]="" # except: # user_details["panName"]="" # try: # if user_kyc_queryset.aadharName: # user_details["aadharName"]=user_kyc_queryset.aadharName # else: # user_details["aadharName"]="" # except: # user_details["panName"]="" # try: # if user_kyc_queryset.bankId: # user_details["bankId"]=str(user_kyc_queryset.bankId.id) # user_details["bankName"]=user_kyc_queryset.bankId.bankName # else: # user_details["bankId"]="" # user_details["bankName"]="" # except: # user_details["bankId"]="" # user_details["bankName"]="" # try: # if user_kyc_queryset.panReason: # user_details["panReason"]=user_kyc_queryset.panReason # user_details["bankReason"]=user_kyc_queryset.bankReason # user_details["aadharReason"]=user_kyc_queryset.aadharReason # user_details["videoVerificationReason"]=user_kyc_queryset.videoVerificationReason # else: # user_details["panReason"]="" # user_details["bankReason"]="" # user_details["aadharReason"]="" # user_details["videoVerificationReason"]="" # except: # user_details["panReason"]="" # user_details["bankReason"]="" # user_details["aadharReason"]="" # user_details["videoVerificationReason"]="" # try: # if user_kyc_queryset: # user_details["panStatus"]=user_kyc_queryset.panStatus # user_details["bankStatus"]=user_kyc_queryset.bankStatus # user_details["aadharStatus"]=user_kyc_queryset.aadharStatus # user_details["videoVerificationStatus"]=user_kyc_queryset.videoVerificationStatus # else: # user_details["panStatus"]="Pending" # user_details["bankStatus"]="Pending" # user_details["aadharStatus"]="Pending" # user_details["videoVerificationStatus"]="Pending" # except Exception as e: # # app.logger.error(traceback.format_exc()) # user_details["panStatus"]="Pending" # user_details["bankStatus"]="Pending" # user_details["aadharStatus"]="Pending" # user_details["videoVerificationStatus"]="Pending" # try: # kycStatus = [user_kyc_queryset.panStatus, # user_kyc_queryset.bankStatus, # user_kyc_queryset.aadharStatus, # user_kyc_queryset.videoVerificationStatus # ] # user_details["kycStatus"] = all(status == "Approved" for status in kycStatus) # except Exception as e: # user_details["kycStatus"] = False # # try: # # if user_kyc_queryset.panStatus == "Approved" and user_kyc_queryset.bankStatus == "Approved" and user_kyc_queryset.aadharStatus == "Approved" and user_kyc_queryset.videoVerificationStatus == "Approved": # # user_details["kycStatus"] = True # # else: # # user_details["kycStatus"] = False # # except Exception as e: # # user_details["kycStatus"] = False # if user_queryset.userPermissionId: # user_details["userPermissionId"] = str(user_queryset.userPermissionId.id) # userPermissionsDetails = {} # user_permissions_queryset = UserPermissions.objects(id=str(user_queryset.userPermissionId.id)).first() # userPermissionsDetails = { # "userPermissionId":str(user_permissions_queryset.id), # "permissionName":user_permissions_queryset.permissionName, # "groupingPermissionsList":user_permissions_queryset.groupingPermissionsList, # "categoryPermissionsList":user_permissions_queryset.categoryPermissionsList, # "servicePermissionsList":user_permissions_queryset.servicePermissionsList, # "operatorPermissionsList":user_permissions_queryset.operatorPermissionsList, # "otherPermissionsList":user_permissions_queryset.otherPermissionsList # } # user_details["userPermissionsDetails"]=userPermissionsDetails # else: # user_details["userPermissionId"] = "" # user_details["userPermissionsDetails"] = {} # data_status["responseStatus"] = 1 # data_status["userPersonalDetails"] = user_details # data_status["result"] = "User personal details fetched successfully!" # return data_status # except Exception as e: # app.logger.error(traceback.format_exc()) # data_status["result"]="Unable to fetch user personal details data!!" # return data_status # else: # data_status["result"]="Required fields are missing!!" # return data_status # Get User Business Details API @users.route("/get_user_business_details",methods=["POST"]) def get_user_business_details(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") if userId: try: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"]="Invalid user id!!" return data_status user_data = { "id":str(user_queryset.id) } if user_queryset.businessName: user_data["businessName"]=user_queryset.businessName else: user_data["businessName"]="" if user_queryset.businessAddress: user_data["businessAddress"]=user_queryset.businessAddress else: user_data["businessAddress"]="" data_status["responseStatus"] = 1 data_status["userBusinessDetailsList"] = user_data data_status["result"] = "User business details fetched successfully!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch user business details data!!" return data_status else: data_status["result"]="Required fields are missing!!" return data_status # Get User KYC Details API @users.route("/get_user_kyc_details",methods=["POST"]) def get_user_kyc_details(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") print(userId) print("((((((((((userId))))))))))") if userId: try: user_kyc_queryset = UserKYC.objects(userId=userId,status=1).first() if not user_kyc_queryset: data_status["result"]="Invalid user id!!" return data_status userKycDict = { "id":str(user_kyc_queryset.id), "panName":user_kyc_queryset.panName, "panNumber":user_kyc_queryset.panNumber, "panStatus":user_kyc_queryset.panStatus, "bankName":user_kyc_queryset.bankName, "bankAccountNumber":user_kyc_queryset.bankAccountNumber, "bankStatus":user_kyc_queryset.bankStatus, "ifscCode":user_kyc_queryset.ifscCode, "aadharName":user_kyc_queryset.aadharName, "aadharNumber":user_kyc_queryset.aadharNumber, "aadharStatus":user_kyc_queryset.aadharStatus, "aadharName":user_kyc_queryset.aadharName } if user_kyc_queryset.aadharDocument: userKycDict["aadharDocument"]=domain+user_kyc_queryset.aadharDocument else: userKycDict["aadharDocument"]="" if user_kyc_queryset.aadharBackDocument: userKycDict["aadharBackDocument"]=domain+user_kyc_queryset.aadharBackDocument else: userKycDict["aadharBackDocument"]="" if user_kyc_queryset.panDocument: userKycDict["panDocument"]=domain+user_kyc_queryset.panDocument else: userKycDict["panDocument"]="" if user_kyc_queryset.uploadVideo: userKycDict["uploadVideo"]=domain+user_kyc_queryset.uploadVideo else: userKycDict["uploadVideo"]="" try: if user_kyc_queryset.bankId: userKycDict["bankId"]=str(user_kyc_queryset.bankId.id) else: userKycDict["bankId"]="" except: userKycDict["bankId"]="" try: if user_kyc_queryset.panReason: userKycDict["panReason"]=user_kyc_queryset.panReason userKycDict["bankReason"]=user_kyc_queryset.bankReason userKycDict["aadharReason"]=user_kyc_queryset.aadharReason userKycDict["videoVerificationReason"]=user_kyc_queryset.videoVerificationReason else: userKycDict["panReason"]="" userKycDict["bankReason"]="" userKycDict["aadharReason"]="" userKycDict["videoVerificationReason"]="" except: userKycDict["panReason"]="" userKycDict["bankReason"]="" userKycDict["aadharReason"]="" userKycDict["videoVerificationReason"]="" data_status["responseStatus"] = 1 data_status["result"] = "User KYC data fetched successfully!" data_status["userKycData"] = userKycDict return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch user kyc data!!" return data_status else: data_status["result"]="Required fields are missing!!" return data_status # Get user verification video API @users.route("/get_user_verification_video",methods=["POST"]) def get_user_verification_video(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") if userId: try: user_kyc_queryset = UserKYC.objects(userId=userId).first() if not user_kyc_queryset: data_status["result"]="Invalid user id!!" return data_status user_data_dict = { "id":str(user_kyc_queryset.id), "merchantName":user_kyc_queryset.userId.fullName } if user_kyc_queryset.uploadVideo: user_data_dict["uploadVideo"]=domain+user_kyc_queryset.uploadVideo else: user_data_dict["uploadVideo"]="" data_status["responseStatus"] = 1 data_status["result"] = "User verification video fetched successfully!" data_status["userVideoData"] = user_data_dict return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch user video!!" return data_status else: data_status["result"]="Required fields are missing!!" return data_status #Change User Password API @users.route("/change_user_password",methods=["POST"]) def change_user_password(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") oldPassword = request.json.get("oldPassword","") newPassword = request.json.get("newPassword","") confirmPassword = request.json.get("confirmPassword","") if userId and oldPassword and newPassword and confirmPassword: if newPassword != confirmPassword: data_status["result"]="New password and confirm password should be the same!!" return data_status try: user_queryset = Users.objects(id=userId,status__in=[1]).first() if user_queryset: if check_password_hash(user_queryset.password, oldPassword): user_queryset.update(password=generate_password_hash(newPassword)) # user_queryset.password = generate_password_hash(newPassword) # user_queryset.save() data_status["responseStatus"] = 1 data_status["result"] = "Password changed successfully!" return data_status else: data_status["result"]="Old password is incorrect!!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to change password!!" return data_status else: data_status["result"]="Required fields are missing!!" return data_status # Change User Tpin API @users.route("/change_user_tpin",methods=["POST"]) def change_user_tpin(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") oldTpin = request.json.get("oldTpin","") newTpin = request.json.get("newTpin","") confirmTpin = request.json.get("confirmTpin","") print() if userId and oldTpin and newTpin and confirmTpin: if newTpin != confirmTpin: data_status["result"]="New Tpin and confirm Tpin should be the same!!" return data_status try: user_queryset = Users.objects(id=userId,status__in=[1]).first() if user_queryset: if user_queryset.tPin == oldTpin: user_queryset.update(tPin=newTpin) data_status["responseStatus"] = 1 data_status["result"] = "Tpin changed successfully!" return data_status else: data_status["result"]="Old Tpin is incorrect!!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to change Tpin!!" return data_status else: data_status["result"]="Required fields are missing!!" return data_status # #Forgot Tpin API # @users.route("/forgot_tpin",methods=["POST"]) # def forgot_tpin(): # data_status = {"responseStatus": 0, "result": ""} # userId = request.json.get("userId") # newTpin = request.json.get("newTpin") # confirmTpin = request.json.get("confirmTpin") # if userId and newTpin and confirmTpin: # try: # user_queryset = Users.objects(id=userId,status__in=[1]).first() # if user_queryset: # user_queryset.update(tpin=newTpin) # data_status["responseStatus"] = 1 # data_status["result"] = "Tpin changed successfully!" # return data_status # except Exception as e: # app.logger.error(traceback.format_exc()) # data_status["result"]="Unable to change Tpin!!" # data_status["tPin"]=tpin # return data_status # else: # data_status["result"]="Required fields are missing!!" # return data_status #Forgot Tpin API @users.route("/set_up_tpin",methods=["POST"]) def set_up_tpin(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId") tPin = request.json.get("tPin") if userId and tPin: try: user_queryset = Users.objects(id=userId,status__in=[1]).first() if user_queryset: user_queryset.update(tPin=tPin) data_status["responseStatus"] = 1 data_status["result"] = "Tpin set up successfully" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to set up Tpin!!" # data_status["tPin"]=tpin return data_status else: data_status["result"]="Required fields are missing!!" return data_status #OTP Generate API @users.route("/generate_otp",methods=["GET","POST"]) def generate_otp(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId") otpType = request.json.get("otpType","TPIN_Setup_OTP") try: if userId: user_queryset = Users.objects(id=userId,status__in=[1]).first() if user_queryset: phoneNumber = user_queryset.phoneNumber userName = user_queryset.fullName smsresponse=send_sms(phoneNumber, otpType,userName) data_status["responseStatus"] = 1 data_status["result"]="Otp generated successfully" data_status["otp"]=smsresponse.get('otp') try: email=user_queryset.email if email: merchantName = str(user_queryset.fullName) mail_subject = "Otp verification for GraamPay!" recipients_list = [email] template_name = "emails/otpverification.html" mail_data = { "merchantName":merchantName, "otpCode":smsresponse.get('otp'), } mailoutputData = send_asynchronous_email(mail_subject, recipients_list, template_name, mail_data) except Exception as e: pass return data_status else: data_status["result"]="Invalid User" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to generate OTP." return data_status @users.route("/generate_signup_otp",methods=["GET","POST"]) def generate_signup_otp(): data_status = {"responseStatus": 0, "result": ""} phoneNumber = request.json.get("phoneNumber") try: if not phoneNumber: data_status["result"]="Required fields are missing!!" return data_status user_queryset = Users.objects(phoneNumber=phoneNumber,status__in=[1]).first() if not user_queryset: try: smsResponse=send_sms(phoneNumber,"Signup_Mobile_Verification") print(smsResponse,"smsResponse") data_status["responseStatus"] = 1 data_status["result"]="Otp generated successfully" data_status["otp"]=smsResponse.get('otp') return data_status except Exception as e: data_status["result"]="Unable to generate OTP!!" return data_status else: data_status["result"]="Mobile Number already exist!!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to generate OTP." return data_status #Email Verification API @users.route("/verify_email",methods=["GET","POST"]) def verify_email(): data_status = {"responseStatus": 0, "result": ""} email = request.json.get("email") if email: try: user_queryset = Users.objects(email__iexact=email,status__in=[1]).first() if user_queryset: data_status["result"] = "Email already exists" return data_status else: otp = random.randint(100000,999999) merchantName ="User" mail_subject = "Otp verification for GraamPay!" recipients_list = [email] template_name = "emails/otpverification.html" mail_data = { "merchantName":merchantName, "otpCode":otp, } mailoutputData = send_asynchronous_email(mail_subject, recipients_list, template_name, mail_data) data_status["responseStatus"] = 1 data_status["result"]="Otp sent successfully" data_status["otp"]=otp return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to send OTP." return data_status else: data_status["result"]="Required field is missing!!" return data_status #Forgot password API @users.route("/forgot_password_otp",methods=["POST"]) def forgot_password_otp(): data_status = {"responseStatus": 0, "result": ""} phoneNumber = request.json.get("phoneNumber") if phoneNumber: try: user_queryset = Users.objects(phoneNumber__iexact=phoneNumber,status__in=[1]).first() if user_queryset: smsResponse=send_sms(phoneNumber, "Forgot_Password_OTP",userName=(user_queryset.fullName),Reason="",amount="") data_status["responseStatus"] = 1 data_status["otp"] = smsResponse.get('otp') data_status["result"] = "Otp sent successfully!" try: email=user_queryset.email if email: merchantName = str(user_queryset.fullName) mail_subject = "Otp verification for GraamPay!" recipients_list = [email] template_name = "emails/otpverification.html" mail_data = { "merchantName":merchantName, "otpCode":smsResponse.get('otp'), } mailoutputData = send_asynchronous_email(mail_subject, recipients_list, template_name, mail_data) except Exception as e: pass return data_status else: data_status["result"]="Invalid mobile number!!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to send otp!!" return data_status else: data_status["result"]="Required field is missing!!" return data_status #Update forgot password API @users.route("/update_forgot_password",methods=["POST"]) def update_forgot_password(): data_status = {"responseStatus": 0, "result": ""} phoneNumber = request.json.get("phoneNumber") password = request.json.get("password") if phoneNumber: try: user_queryset = Users.objects(phoneNumber__iexact=phoneNumber,status__in=[1]).first() if user_queryset: user_queryset.update(password = generate_password_hash(password),) data_status["responseStatus"] = 1 data_status["result"] = "Your password updated successfully!" return data_status else: data_status["result"]="Invalid mobile number!!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to change password!" return data_status else: data_status["result"]="Required field is missing!!" return data_status #Verification mobile number API @users.route("/verify_mobile_number",methods=["GET","POST"]) def verify_mobile_number(): data_status = {"responseStatus": 0, "result": ""} phoneNumber = request.json.get("phoneNumber") if phoneNumber: try: user_queryset = Users.objects(phoneNumber__iexact=phoneNumber).first() if user_queryset: data_status["result"] = "Phone number already in use!" return data_status else: smsResponse=send_sms(phoneNumber,"Signup_Mobile_Verification") print(smsResponse,"smsResponse") data_status["responseStatus"] = 1 data_status["result"]="Otp generated successfully" data_status["otp"]=smsResponse.get('otp') return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to send OTP." return data_status else: data_status["result"]="Required field is missing!!" return data_status #Fetch Login Report Details API @users.route("/get_login_reports",methods=["POST"]) def get_login_reports(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId") startDate = request.json.get("startDate","") endDate = request.json.get("endDate","") LoginReportsList = [] if userId: if startDate and endDate: startDate = startDate + " 00:00:00" endDate = endDate + " 23:59:59" start_date = datetime.datetime.strptime(startDate, "%m-%d-%Y %H:%M:%S") end_date = datetime.datetime.strptime(endDate, "%m-%d-%Y %H:%M:%S") login_reports_queryset = LoginReportLogs.objects( userId = userId, createdOn__gte = start_date, createdOn__lte = end_date ).order_by('-id').all() else: login_reports_queryset = LoginReportLogs.objects( userId = userId ).order_by('-id').all() try: for each_login_report in login_reports_queryset: ist_time=each_login_report.createdOn.replace(tzinfo=pytz.utc).astimezone(ist_timezone) login_dict = { "id":str(each_login_report.id), "deviceName":each_login_report.deviceName, "latitude":each_login_report.latitude, "longitude":each_login_report.longitude, "os":each_login_report.os, "on":ist_time.strftime("%d %b,%I:%M %p"), } LoginReportsList.append(login_dict) data_status["responseStatus"] = 1 data_status["result"] = "Login reports fetched successfully" data_status["LoginReportsList"] = LoginReportsList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fetch details" return data_status else: data_status["result"] = "Required fields are missing" return data_status ################### Add Money Wallet API's ############## @users.route("/get_payment_gateways",methods=["POST"]) @user_required def get_payment_gateways(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId") paymentGatewaysList = [] try: merchant_queryset = Users.objects(id=userId,status=1).first() if not merchant_queryset.patternId: data_status["result"]="No payment gateways available!" return data_status pattern_queryset = Patterns.objects(id=str(merchant_queryset.patternId.id)).first() if not pattern_queryset.payinPaymentGatewaysList: data_status["result"]="No payment gateways available!!" return data_status payinPaymentGatewaysList = [str(each_payin_pg.id) for each_payin_pg in pattern_queryset.payinPaymentGatewaysList] print(payinPaymentGatewaysList,"(((((((((((((payinPaymentGatewaysList)))))))))))))") startDate = datetime.datetime.now().replace(hour=0,minute=0,second=0) endDate = startDate.replace(hour=23,minute=59,second=59) print(startDate,"(((((((((startDate)))))))))") print(endDate,"(((((((((endDate)))))))))") payment_gateways_queyset = TransactionAPI.objects(id__in=payinPaymentGatewaysList,status=1).order_by('-id').all() for each_payment_gateway in payment_gateways_queyset: print(each_payment_gateway,"((((((each_payment_gateway))))))") today_wallet_txn_amount = WalletTransactions.objects(paymentGatewayId=str(each_payment_gateway.id),createdOn__gte=startDate,createdOn__lte=endDate,status__in=[1,2],userType="user",creditType="Credit").sum("amount") print(today_wallet_txn_amount,"((((((((((((today_wallet_txn_amount))))))))))))") print(each_payment_gateway.perdayTransactionLimit,"((((((((((((Per day TXN AMOUNT))))))))))))") if float(each_payment_gateway.perdayTransactionLimit)==0 or (float(each_payment_gateway.perdayTransactionLimit) > float(today_wallet_txn_amount)): paymeny_gateway_dict = { "id":str(each_payment_gateway.id), "paymentGateway":each_payment_gateway.apiName, "transactionType":each_payment_gateway.transactionType, "paramsList":each_payment_gateway.paramsList } paymentGatewaysList.append(paymeny_gateway_dict) data_status["result"] = "Payment gateways data fetched successfully!" data_status["responseStatus"] = 1 data_status["paymentGatewaysList"] = paymentGatewaysList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "unable to fetch payment gateways data!!" return data_status #Get Settlement Type's API @users.route("/get_settlement_types",methods=["POST"]) def get_settlement_types(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId") settlementPaysList = [] try: settlement_types_queyset = Settlement.objects(status__in=[1]).order_by('-id').all() for each_settlement_type in settlement_types_queyset: settlement_type_dict = { "id":str(each_settlement_type.id), "settlementPay":each_settlement_type.settlementType } settlementPaysList.append(settlement_type_dict) data_status["result"] = "Data fetched successfully" data_status["responseStatus"] = 1 data_status["settlementPaysList"] = settlementPaysList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "unable to fetch data" return data_status #Add Wallet Money API @users.route("/add_money_to_wallet",methods=["POST"]) def add_money_to_wallet(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId") amount = request.json.get("amount",0.00) paymentGatewayId = request.json.get("paymentGatewayId","") paymentType = request.json.get("paymentType","") creditType = request.json.get("creditType","") transactionId = request.json.get("transactionId","") settlementPayId = request.json.get("settlementPayId","") isConfirm = request.json.get("isConfirm",False) paymentAuthentication = request.json.get("paymentAuthentication",False) transactionData = request.json.get("transactionData") orderId = request.json.get("orderId","") status = request.json.get("status") if amount and paymentGatewayId and settlementPayId: try: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"] = "Invalid user Id" return data_status if status == 1: actuallBalance = user_queryset.walletBalance updateAmount = float(actuallBalance)+amount user_queryset.update(walletBalance = updateAmount) transactionData = [transactionData] wallet_transaction_table = WalletTransactions( userId = userId, amount = amount, paymentGatewayId = paymentGatewayId, paymentType = paymentType, creditType = creditType, transactionId = transactionId, settlementPayId = settlementPayId, isConfirm = isConfirm, transactionData = transactionData, paymentAuthentication = paymentAuthentication, orderId = orderId, walletLog="Wallet Balance is added with the amount of " + str(int(amount)) + ".", userType="user", createdBy = None, createdOn = datetime.datetime.now(), status = status ).save() walletTransactionId = str(wallet_transaction_table.id) elif status == 0: transactionData = [transactionData] wallet_transaction_table = WalletTransactions( userId = userId, amount = amount, paymentGatewayId = paymentGatewayId, paymentType = paymentType, creditType = creditType, transactionId = transactionId, settlementPayId = settlementPayId, isConfirm = isConfirm, transactionData = transactionData, paymentAuthentication = paymentAuthentication, orderId = orderId, walletLog="Unable to add money.Transaction Failed!!", userType="user", createdBy = None, createdOn = datetime.datetime.now(), status = status ).save() walletTransactionId = str(wallet_transaction_table.id) data_status["responseStatus"] = 1 data_status["walletTransactionId"] = walletTransactionId data_status["result"] = "Money added to the wallet successfully" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to add money to the wallet" return data_status else: data_status["result"] = "Required fields are missing." return data_status def fetching_wallet_transaction_reports(each_wallet_trasaction): wallet_transaction_dict = {} try: transaction_queryset = Transactions.objects(transactionId=each_wallet_trasaction.transactionId).first() wallet_transaction_dict = { "id":str(each_wallet_trasaction.id), "amount":each_wallet_trasaction.amount, # "paymentGatewayId":str(each_wallet_trasaction.paymentGatewayId.id), # "paymentGateway":each_wallet_trasaction.paymentGatewayId.sourceName, # "settlementPayId":str(each_wallet_trasaction.settlementPayId.id), # "settlementPay":each_wallet_trasaction.settlementPayId.settlementType, "paymentType":each_wallet_trasaction.paymentType, "creditType":each_wallet_trasaction.creditType, "transactionId":each_wallet_trasaction.transactionId, # "isConfirm":each_wallet_trasaction.isConfirm, # "transactionData":each_wallet_trasaction.transactionData, # "createdOn":each_wallet_trasaction.createdOn, #"serviceName":transaction_queryset.serviceName, "status":each_wallet_trasaction.status, } if transaction_queryset: wallet_transaction_dict.update({"serviceName":transaction_queryset.serviceName}), else: wallet_transaction_dict.update({"serviceName":each_wallet_trasaction.paymentType}), if each_wallet_trasaction.createdOn: ist_time=each_wallet_trasaction.createdOn.replace(tzinfo=pytz.utc).astimezone(ist_timezone) wallet_transaction_dict["createdOn"] = ist_time.strftime("%m-%d-%Y %I:%M %p") # if each_wallet_trasaction.paymentGatewayId: # wallet_transaction_dict["paymentGatewayId"] = str(each_wallet_trasaction.paymentGatewayId.id) # wallet_transaction_dict["paymentGateway"] = each_wallet_trasaction.paymentGatewayId.sourceName # else: # wallet_transaction_dict["paymentGatewayId"] = "" # wallet_transaction_dict["paymentGateway"] = "" # if each_wallet_trasaction.settlementPayId: # wallet_transaction_dict["settlementPayId"] = str(each_wallet_trasaction.settlementPayId.id) # wallet_transaction_dict["settlementPayId"] = each_wallet_trasaction.settlementPayId.settlementType # else: # wallet_transaction_dict["settlementPayId"] = "" # wallet_transaction_dict["settlementPay"] = "" except Exception as e: app.logger.error(traceback.format_exc()) return wallet_transaction_dict #Add Wallet Money API @users.route("/get_wallet_transactions",methods=["POST"]) def get_wallet_transactions(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId") startDate = request.json.get("startDate","") endDate = request.json.get("endDate","") walletTransactionsList = [] if userId: if startDate and endDate: startDate = startDate + " 00:00:00" endDate = endDate + " 23:59:59" start_date = datetime.datetime.strptime(startDate, "%m-%d-%Y %H:%M:%S") end_date = datetime.datetime.strptime(endDate, "%m-%d-%Y %H:%M:%S") wallet_transactions_queryset = WalletTransactions.objects( userId=userId, createdOn__gte=start_date, createdOn__lte=end_date, ).order_by("-id").all() else: wallet_transactions_queryset = WalletTransactions.objects( userId=userId, ).order_by("-id").all() try: for each_wallet_trasaction in wallet_transactions_queryset: wallet_transaction_data = fetching_wallet_transaction_reports(each_wallet_trasaction) walletTransactionsList.append(wallet_transaction_data) data_status["responseStatus"] = 1 data_status["result"] = "Wallet reports fetched successfully" data_status["walletTransactionsList"] = walletTransactionsList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fethc wallets data" return data_status else: data_status["result"] = "Required fields are missing" return data_status #Add Wallet Money API @users.route("/get_wallet_single_transaction",methods=["POST"]) def get_wallet_single_transaction(): data_status = {"responseStatus": 0, "result": ""} walletTransactionId = request.json.get("walletTransactionId") wallet_transaction_dict = {} if walletTransactionId: each_wallet_trasaction = WalletTransactions.objects( id=walletTransactionId, ).order_by("-id").first() try: wallet_transaction_dict = { "id":str(each_wallet_trasaction.id), "amount":each_wallet_trasaction.amount, "paymentType":each_wallet_trasaction.paymentType, "creditType":each_wallet_trasaction.creditType, "transactionId":each_wallet_trasaction.transactionId, } data_status["responseStatus"] = 1 data_status["result"] = "Wallet reports fetched successfully" data_status["walletTransactionData"] = wallet_transaction_dict return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fethc wallets data" return data_status else: data_status["result"] = "Required fields are missing" return data_status ########### Transactions API's ########## # @users.route("/add_transaction",methods=["POST"]) # def add_transaction(): # data_status = {"responseStatus": 0, "result": ""} # print(request.json,"add_transaction") # userId = request.json.get("userId","") # categoryId = request.json.get("categoryId",None) # serviceId = request.json.get("serviceId",None) # operatorId = request.json.get("operatorId",None) # transactionAPIId = request.json.get("transactionAPIId",None) # paymentType = request.json.get("paymentType","") # transactionId = request.json.get("transactionId","") # transactionData = request.json.get("transactionData") # mobileNumber = request.json.get("mobileNumber","") # categoryName = request.json.get("categoryName","") # serviceName = request.json.get("serviceName","") # operatorName = request.json.get("operatorName","") # amount = request.json.get("amount") # operatorReference = request.json.get("operatorReference","") # paymentGatewayId = request.json.get("paymentGatewayId",None) # status = request.json.get("status") # transactionData = [transactionData] # if categoryName and serviceName and operatorName and transactionId and mobileNumber and amount: # try: # user_queryset = Users.objects(id=userId,status__in=[1]).first() # if not user_queryset: # data_status["result"] = "Invalid user Id" # return data_status # commissionCharges = {} # chargeAmount = 0.0 # if user_queryset.commissionId: # commissionId = str(user_queryset.commissionId.id) # commissions_queryset = Commissions.objects(id=commissionId,status=1).order_by("-id").first() # for each_record in commissions_queryset.commissionList: # if each_record.get("operatorId") == operatorId and each_record.get("transactionAPIId") == transactionAPIId: # commissionDict = { # # "operatorId": each_record.get("operatorId"), # # "transactionAPIId": each_record.get("transactionAPIId"), # "chargeType": each_record.get("chargeType"), # "chargeValue": each_record.get("chargeValue"), # "commissionType": each_record.get("commissionType"), # "commissionValue": each_record.get("commissionValue") # } # if commissionDict.get("chargeType") == "Percentage": # chargeAmount = (float(amount)*float(commissionDict.get("chargeValue")))/100 # elif commissionDict.get("chargeType") == "Fixed": # chargeAmount = float(commissionDict.get("chargeValue")) # if commissionType.get("commissionType") == "Percentage": # commissionAmount = (float(amount)*float(commissionDict.get("commissionValue")))/100 # elif commissionDict.get("commissionType") == "Fixed": # commissionAmount = float(commissionDict.get("commissionValue")) # #Updating user commission balance # if commissionAmount: # commissionBalance = user_queryset.commissionBalance # commissionBalance += commissionAmount # user_queryset.update(commissionBalance=commissionBalance) # commissionCharges = { # "chargeType": commissionDict.get("chargeType"), # "chargeValue": commissionDict.get("chargeValue"), # "commissionType": commissionDict.get("commissionType"), # "commissionValue": commissionDict.get("commissionValue"), # "chargeAmount": chargeAmount, # "commissionAmount": commissionAmount # } # operator_queryset = Operators.objects(id=operatorId).first() # user_commission_table = UserCommissions( # userId = userId, # childUserId =None, # operatorId = operatorId, # serviceId = str(operator_queryset.serviceId.id), # transactionId = transactionId, # transactionAPIId = transactionAPIId, # totalAmount = amount, # commissionType = commissionDict.get("chargeType"), # commissionAmount = commissionAmount, # createdOn = datetime.datetime.now(), # status = 1, # ).save() # #Calulate total amount # totalAmount = float(amount) - chargeAmount # transaction_table = Transactions( # userId = userId, # categoryId = categoryId, # serviceId = serviceId, # operatorId = operatorId, # categoryName = categoryName, # serviceName = serviceName, # operatorName = operatorName, # paymentType = paymentType, # paymentGatewayId = paymentGatewayId, # transactionAPIId = transactionAPIId, # transactionId = str(transactionId), # transactionData = transactionData, # mobileNumber = mobileNumber, # amount = amount, # totalAmount = totalAmount, # commissionCharges = commissionCharges, # operatorReference = operatorReference, # createdOn = datetime.datetime.now(), # status = status # ).save() # transactionTableId = str(transaction_table.id) # # if transactionTableId: # # user_parent_method_commission_charges_details(userId,amount,operatorId,transactionAPIId,transactionId) # # service_queryset = Service.objects(id=serviceId,status__in=[1]).first() # # if service_queryset: # # serviceName = service_queryset.serviceName # # else: # # serviceName = "" # # if status in [1,2]: # # currentBalance = user_queryset.walletBalance # # updateBalance = float(currentBalance)-float(amount) # # user_queryset.update(walletBalance = updateBalance) # # #Here we need update this transaction to wallet also # # wallet_trasaction_table = WalletTransactions( # # userId = userId, # # amount =amount, # # paymentGatewayId = paymentGatewayId, # # creditType = "debit", # # transactionId = str(transactionId), # # paymentType = paymentType, # # # settlementPayId = None, # # walletLog = serviceName + " " + str(mobileNumber) + " is recharged with the amount of " + str(int(amount)) + ".", # # userType = "user", # # createdBy = None, # # createdOn = datetime.datetime.now(), # # status = 1, # # ).save() # # except Exception as e: # # app.logger.error(traceback.format_exc()) # # data_status["result"] = "Unable to make transaction" # # return data_status # if status: # data_status["responseStatus"] = status # data_status["id"] = transactionTableId # data_status["result"] = "Transaction successful" # # data_status["transactionId"] = transactionTableId # return data_status # else: # data_status["responseStatus"] = status # data_status["id"] = transactionTableId # data_status["result"] = "Transaction unsuccessful" # return data_status # except Exception as e: # app.logger.error(traceback.format_exc()) # data_status["result"] = "Unable to make transaction" # return data_status # else: # data_status['result'] = "Required fields are missing" # return data_status @users.route("/add_transaction",methods=["POST"]) def add_transaction(): data_status = {"responseStatus": 0, "result": ""} print(request.json,"add_transaction") userId = request.json.get("userId","") categoryId = request.json.get("categoryId",None) serviceId = request.json.get("serviceId",None) operatorId = request.json.get("operatorId",None) transactionAPIId = request.json.get("transactionAPIId",None) paymentType = request.json.get("paymentType","") transactionId = request.json.get("transactionId","") transactionData = request.json.get("transactionData") billPayment = request.json.get("billPayment",0) payload = request.json.get("payload",'') headers = request.json.get("headers",'') mobileNumber = request.json.get("mobileNumber","") categoryName = request.json.get("categoryName","") serviceName = request.json.get("serviceName","") operatorName = request.json.get("operatorName","") amount = request.json.get("amount") operatorReference = request.json.get("operatorReference","") errorMessage = request.json.get("errorMessage","") paymentGatewayId = request.json.get("paymentGatewayId",None) status = request.json.get("status") paymentCategory = request.json.get("paymentCategory","") cardNumber = request.json.get("cardNumber","") customerVpa = request.json.get("customerVpa","") walletName = request.json.get("walletName","") accountNumber = request.json.get("accountNumber","") ifscCode = request.json.get("ifscCode","") customeParamsList = request.json.get("customeParamsList",{}) # transactionData=json.loads(transactionData) transactionData = [transactionData] if categoryName and serviceName and operatorName and transactionId and mobileNumber and amount and operatorId and transactionAPIId: try: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"] = "Invalid user Id" return data_status commissionCharges = {} chargeAmount = 0.0 commissionDictResult=operator_based_commission_details(userId,operatorId,transactionAPIId) if commissionDictResult.get('responseStatus')==1: commissionDict=commissionDictResult.get('commissionDict') if commissionDict: if commissionDict.get("chargeType") == "Percentage": chargeAmount = (float(amount)*float(commissionDict.get("chargeValue")))/100 elif commissionDict.get("chargeType") == "Fixed": chargeAmount = float(commissionDict.get("chargeValue")) if commissionDict.get("commissionType") == "Percentage": commissionAmount = (float(amount)*float(commissionDict.get("commissionValue")))/100 elif commissionDict.get("commissionType") == "Fixed": commissionAmount = float(commissionDict.get("commissionValue")) commissionCharges = { "chargeType": commissionDict.get("chargeType"), "chargeValue": commissionDict.get("chargeValue"), "commissionType": commissionDict.get("commissionType"), "commissionValue": commissionDict.get("commissionValue"), "chargeAmount": chargeAmount, "commissionAmount": commissionAmount } #Calulate total amount billPaymentRequestData=[] billPaymentResponseData=[] totalAmount = float(amount) - float(chargeAmount) transaction_table = Transactions( userId = userId, categoryId = categoryId, serviceId = serviceId, operatorId = operatorId, categoryName = categoryName, serviceName = serviceName, operatorName = operatorName, paymentType = paymentType, paymentCategory = paymentCategory, cardNumber = cardNumber, customerVpa = customerVpa, walletName = walletName, accountNumber = accountNumber, ifscCode = ifscCode, customeParamsList = customeParamsList, paymentGatewayId = paymentGatewayId, transactionAPIId = transactionAPIId, transactionId = str(transactionId), transactionData = transactionData, billPayment = str(billPayment), billPaymentRequestData = billPaymentRequestData, billPaymentResponseData = billPaymentResponseData, mobileNumber = mobileNumber, amount = amount, totalAmount = totalAmount, commissionCharges = commissionCharges, operatorReference = operatorReference, createdOn = datetime.datetime.now(), errorMessage=errorMessage, status = status ).save() transactionTableId = str(transaction_table.id) if transactionTableId: if status==1 and billPayment==1: billPaymentRequestData.append(payload) billPaymentRequestData.append(headers) billpaymentresult=payuBillPayment(payload,headers) if billpaymentresult.get('responseStatus')==1: billpaymentresponse=billpaymentresult.get('result') billPaymentResponseData.append(billpaymentresponse) bbpsoperatorReference=billpaymentresponse.get('payload').get('additionalParams').get('txnReferenceId') if billpaymentresponse.get('status')=="SUCCESS": status=1 errorMessage=billpaymentresponse.get('status') elif billpaymentresponse.get('status')=="FAILURE": status=0 errorMessage="Payment Failed. if amount debited from your account it will be refund." transaction_table.update(billPaymentRequestData=billPaymentRequestData,billPaymentResponseData=billPaymentResponseData,operatorReference=bbpsoperatorReference,errorMessage=errorMessage,status=status) if status: data_status["responseStatus"] = status data_status["id"] = transactionTableId data_status["result"] = "Transaction successful" # data_status["transactionId"] = transactionTableId return data_status else: data_status["responseStatus"] = status data_status["id"] = transactionTableId data_status["result"] = "Transaction unsuccessful" return data_status else: data_status["id"] = "" data_status["result"] = "Transaction unsuccessful" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to make transaction" return data_status else: data_status['result'] = "Required fields are missing" return data_status def user_parent_method_commission_charges_details(userId,amount,operatorId,transactionAPIId,transactionId): try: user_queryset = Users.objects(id=userId).first() commissionCharges = {} childcommissionDict = {} parentcommissionDict = {} chargeAmount = 0.0 if user_queryset.commissionId: childcommissionId = str(user_queryset.commissionId.id) childcommissions_queryset = Commissions.objects(id=childcommissionId,status=1).order_by("-id").first() for childeach_record in childcommissions_queryset.commissionList: if childeach_record.get("operatorId") == operatorId and childeach_record.get("transactionAPIId") == transactionAPIId: childcommissionDict = { "chargeType": childeach_record.get("chargeType"), "chargeValue": childeach_record.get("chargeValue"), "commissionType": childeach_record.get("commissionType"), "commissionValue": childeach_record.get("commissionValue") } if user_queryset.parentId: parent_queryset = Users.objects(id=user_queryset.parentId).first() if parent_queryset.commissionId: parentcommissionId = str(parent_queryset.commissionId.id) parentcommissions_queryset = Commissions.objects(id=parentcommissionId,status=1).order_by("-id").first() for parenteach_record in parentcommissions_queryset.commissionList: if parenteach_record.get("operatorId") == operatorId and parenteach_record.get("transactionAPIId") == transactionAPIId: parentcommissionDict = { "chargeType": parenteach_record.get("chargeType"), "chargeValue": parenteach_record.get("chargeValue"), "commissionType": parenteach_record.get("commissionType"), "commissionValue": parenteach_record.get("commissionValue") } if parentcommissionDict.get("chargeType") == "Percentage": parentchargeAmount = (float(amount)*float(parentcommissionDict.get("chargeValue")))/100 elif parentcommissionDict.get("chargeType") == "Fixed": parentchargeAmount = float(parentcommissionDict.get("chargeValue")) if childcommissionDict.get("chargeType") == "Percentage": childchargeAmount = (float(amount)*float(childcommissionDict.get("chargeValue")))/100 elif childcommissionDict.get("chargeType") == "Fixed": childchargeAmount = float(childcommissionDict.get("chargeValue")) parentcommissionamount=childchargeAmount-parentchargeAmount operator_queryset = Operators.objects(id=operatorId).first() if parentcommissionamount: user_commission_table = UserCommissions( userId = str(parent_queryset.id), childUserId =userId, operatorId = operatorId, serviceId = str(operator_queryset.serviceId.id), transactionId = transactionId, transactionAPIId = transactionAPIId, totalAmount = amount, commissionType = parentcommissionDict.get("chargeType"), commissionAmount = parentcommissionamount, createdOn = datetime.datetime.now(), status = 1, ).save() commissionBalance = parent_queryset.commissionBalance commissionBalance += parentcommissionamount parent_queryset.update(commissionBalance=commissionBalance) user_parent_method_commission_charges_details(str(parent_queryset.id),amount,operatorId,transactionAPIId,transactionId) else: False except Exception as e: app.logger.error(traceback.format_exc()) return False def fetching_transaction_data(each_transaction): transaction_data = {} try: transaction_data = { "id":str(each_transaction.id), "categoryName":each_transaction.categoryName, "serviceName":each_transaction.serviceName, "operatorName":each_transaction.operatorName, "transactionId":each_transaction.transactionId, "mobileNumber":each_transaction.mobileNumber, "amount":each_transaction.amount, "operatorReference":each_transaction.operatorReference } if each_transaction.ifscCode: transaction_data["ifscCode"] = each_transaction.ifscCode else: transaction_data["ifscCode"] = "" if each_transaction.accountNumber: transaction_data["accountNumber"] = each_transaction.accountNumber else: transaction_data["accountNumber"] = "" if each_transaction.paymentCategory: transaction_data["paymentCategory"] = each_transaction.paymentCategory else: transaction_data["paymentCategory"] = "" if each_transaction.cardNumber: transaction_data["cardNumber"] = each_transaction.cardNumber else: transaction_data["cardNumber"] = "" if each_transaction.customerVpa: transaction_data["customerVpa"] = each_transaction.customerVpa else: transaction_data["customerVpa"] = "" if each_transaction.customeParamsList: transaction_data["customeParamsList"] = each_transaction.customeParamsList else: transaction_data["customeParamsList"] = {} if each_transaction.walletName: transaction_data["walletName"] = each_transaction.walletName else: transaction_data["walletName"] = "" if each_transaction.createdOn: # ist_time=each_transaction.createdOn.replace(tzinfo=pytz.utc).astimezone(ist_timezone) transaction_data["createdOn"] = each_transaction.createdOn.strftime("%m-%d-%Y %I:%M %p") else: transaction_data["createdOn"]="" try: if each_transaction.categoryId: transaction_data["categoryId"] = str(each_transaction.categoryId.id) transaction_data["categoryName"] = each_transaction.categoryId.categoryName else: transaction_data["categoryId"] = "" transaction_data["categoryName"] = "" except: transaction_data["categoryId"] = "" transaction_data["categoryName"] = "" try: if each_transaction.serviceId: transaction_data["serviceId"] = str(each_transaction.serviceId.id) transaction_data["serviceName"] = each_transaction.serviceId.serviceName else: transaction_data["serviceId"] = "" transaction_data["serviceName"] = "" except: transaction_data["serviceId"] = "" transaction_data["serviceName"] = "" try: if each_transaction.operatorId: transaction_data["operatorId"] = str(each_transaction.operatorId.id) transaction_data["operatorName"] = each_transaction.operatorId.operatorName else: transaction_data["operatorId"] = "" transaction_data["operatorName"] = "" except: transaction_data["operatorId"] = "" transaction_data["operatorName"] = "" if each_transaction.status == 1: transaction_data["status"] = "successful" elif each_transaction.status == 0: transaction_data["status"] = "failed" else: transaction_data["status"] = "pending" except Exception as e: app.logger.error(traceback.format_exc()) return transaction_data #Get all transactions @users.route("/get_all_transactions",methods=["POST"]) def get_all_transactions(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") startDate = request.json.get("startDate","") endDate = request.json.get("endDate","") transactionsList = [] if userId: if startDate and endDate: startDate = startDate + " 00:00:00" endDate = endDate + " 23:59:59" start_date = datetime.datetime.strptime(startDate, "%d-%m-%Y %H:%M:%S") end_date = datetime.datetime.strptime(endDate, "%d-%m-%Y %H:%M:%S") transactions_queryset = Transactions.objects( userId=userId, createdOn__gte=start_date, createdOn__lte=end_date, ).order_by("-id").all() else: transactions_queryset = Transactions.objects( userId=userId, ).order_by("-id").all() for each_transaction in transactions_queryset: transaction_data = fetching_transaction_data(each_transaction) transactionsList.append(transaction_data) data_status["result"] = "Transaction details fetched successfully" data_status["responseStatus"] = 1 data_status["transactionsList"] = transactionsList return data_status else: data_status["result"] = "Required fields are missing" return data_status @users.route("/view_single_transaction",methods=["POST"]) @user_required def view_single_transaction(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") transactionId = request.json.get("transactionId","") transactionDict = {} if userId and transactionId: transaction_queryset = Transactions.objects(id=transactionId,userId=userId).first() if not transaction_queryset: data_status["result"]="Invalid transaction id!!" return data_status transactionDict = fetching_transaction_data(transaction_queryset) data_status["result"] = "Transaction details fetched successfully" data_status["responseStatus"] = 1 data_status["transactionDict"] = transactionDict return data_status else: data_status["result"] = "Required fields are missing!!" return data_status #Get single transactions @users.route("/get_single_transaction",methods=["POST"]) def get_single_transaction(): data_status = {"responseStatus": 0, "result": "",} transactionId = request.json.get("transactionId","") if transactionId: try: transaction_data = {} each_transaction = Transactions.objects(id=transactionId).order_by('-id').first() if each_transaction: transaction_data = { "id":str(each_transaction.id), "categoryName":each_transaction.categoryName, "serviceName":each_transaction.serviceName, "operatorName":each_transaction.operatorName, "mobileNumber":each_transaction.mobileNumber, "amount":each_transaction.amount, "commissionCharges":each_transaction.commissionCharges, "customeParamsList":each_transaction.customeParamsList, } if each_transaction.createdOn: # ist_time=each_transaction.createdOn.replace(tzinfo=pytz.utc).astimezone(ist_timezone) transaction_data["createdOn"] = each_transaction.createdOn.strftime("%m-%d-%Y %I:%M %p") else: transaction_data["createdOn"] = "" payment_details = {} payment_details["transactionId"] = each_transaction.transactionId if each_transaction.operatorReference: payment_details["operatorReference"] = each_transaction.operatorReference.strip() else: payment_details["operatorReference"] = "" if each_transaction.paymentType: payment_details["debitedFrom"] = each_transaction.paymentType else: payment_details["debitedFrom"] = "" if not each_transaction.paymentType: wallet_transaction = WalletTransactions.objects(transactionId=each_transaction.transactionId).order_by('-id').first() if wallet_transaction: payment_details["debitedFrom"] = wallet_transaction.paymentType else: payment_details["debitedFrom"] = "" transaction_data["paymentDetails"] = payment_details transaction_data["accountHolderName"] = "" try: if each_transaction.operatorId.image: transaction_data["image"] = domain+each_transaction.operatorId.image else: transaction_data["image"] = "" except: transaction_data["image"] = "" if each_transaction.status == 1: transaction_data["status"] = "Successful" elif each_transaction.status == 0: transaction_data["status"] = "Failed" else: transaction_data["status"] = "Pending" if each_transaction.ifscCode: transaction_data["ifscCode"] = each_transaction.ifscCode else: transaction_data["ifscCode"] = "" if each_transaction.accountNumber: transaction_data["accountNumber"] = each_transaction.accountNumber elif each_transaction.cardNumber: transaction_data["accountNumber"] = each_transaction.cardNumber elif each_transaction.customerVpa: transaction_data["accountNumber"] = each_transaction.customerVpa else: transaction_data["accountNumber"] = "" data_status["result"] = "Transaction details fetched successfully" data_status["responseStatus"] = 1 data_status["transactionData"] = transaction_data return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fetch transaction details" return data_status else: data_status["result"] = "Required field is missing" return data_status # #Get single transactions # @users.route("/get_single_transaction",methods=["POST"]) # def get_single_transaction(): # data_status = {"responseStatus": 0, "result": ""} # transactionId = request.json.get("transactionId","") # if transactionId: # each_transaction = Transactions.objects(id=transactionId).order_by('-id').first() # transaction_data = { # "id":str(each_transaction.id), # "categoryName":each_transaction.categoryName, # "serviceName":each_transaction.serviceName, # "operatorName":each_transaction.operatorName, # "transactionId":each_transaction.transactionId, # "mobileNumber":each_transaction.mobileNumber, # "amount":each_transaction.amount, # "operatorReference":each_transaction.operatorReference, # } # if each_transaction.ifscCode: # transaction_data["ifscCode"] = each_transaction.ifscCode # else: # transaction_data["ifscCode"] = "" # if each_transaction.accountNumber: # transaction_data["accountNumber"] = each_transaction.accountNumber # else: # transaction_data["accountNumber"] = "" # if each_transaction.createdOn: # ist_time=each_transaction.createdOn.replace(tzinfo=pytz.utc).astimezone(ist_timezone) # transaction_data["createdOn"] = ist_time.strftime("%m-%d-%Y %I:%M %p") # try: # if each_transaction.categoryId: # transaction_data["categoryId"] = str(each_transaction.categoryId.id) # transaction_data["categoryName"] = each_transaction.categoryId.categoryName # else: # transaction_data["categoryId"] = "" # # transaction_data["categoryName"] = "" # except: # transaction_data["categoryId"] = "" # try: # if each_transaction.serviceId: # transaction_data["serviceId"] = str(each_transaction.serviceId.id) # transaction_data["serviceName"] = each_transaction.serviceId.serviceName # else: # transaction_data["serviceId"] = "" # # transaction_data["serviceName"] = "" # except: # transaction_data["serviceId"] = "" # try: # if each_transaction.operatorId: # transaction_data["operatorId"] = str(each_transaction.operatorId.id) # transaction_data["operatorName"] = each_transaction.operatorId.operatorName # else: # transaction_data["operatorId"] = "" # # transaction_data["operatorName"] = "" # except: # transaction_data["operatorId"] = "" # if each_transaction.status == 1: # transaction_data["status"] = "successful" # elif each_transaction.status == 0: # transaction_data["status"] = "failed" # else: # transaction_data["status"] = "pending" # data_status["result"] = "Transaction details fetched successfully" # data_status["responseStatus"] = 1 # data_status["transactionData"] = transaction_data # return data_status # else: # data_status["result"] = "Required fields are missing" # return data_status #Add Profile Picture @users.route("/add_profile_picture",methods=["POST"]) def add_profile_picture(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") profilePicture = request.json.get("profilePicture","") if userId and profilePicture: try: user_queryset = Users.objects(id=userId,status__nin=[2]).first() if not user_queryset: data_status["result"] = "Invalid user id" return data_status profile = upload_file_image(profilePicture, "userProfiles", str(get_epoch_milli_time()), "") if profile: user_queryset.update(profilePicture=profile) data_status["responseStatus"] = 1 data_status["result"] = "Profile picture added successfully" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to add profile picture" return data_status else: data_status["result"] = "Required fields are missing" return data_status ########### Internal Transfer API ########## @users.route("/add_internal_transfer",methods=["POST"]) def add_internal_transfer(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") paymentType = request.json.get("paymentType","") transactionId = request.json.get("transactionId","") mobileNumber = request.json.get("mobileNumber","") amount = request.json.get("amount") remarks = request.json.get("remarks") paymentGatewayId = request.json.get("paymentGatewayId",None) if transactionId and mobileNumber and amount and remarks and userId: try: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"] = "Invalid user Id" return data_status otheruser_queryset = Users.objects(phoneNumber=mobileNumber,status__in=[1]).first() if not otheruser_queryset: data_status["result"] = "Invalid user Id" return data_status currentBalance = user_queryset.walletBalance updateBalance = float(currentBalance)-float(amount) user_queryset.update(walletBalance = updateBalance) #Here we need update this transaction to wallet also wallet_trasaction_table = WalletTransactions( userId = userId, amount =amount, paymentGatewayId = paymentGatewayId, creditType = "debit", transactionId = transactionId, paymentType = paymentType, settlementPayId = None, walletLog = str(int(amount)) + " is transferd to " + otheruser_queryset.fullName + " (" + str(mobileNumber)+ ")", remarks = remarks, userType = "user", createdBy = None, createdOn = datetime.datetime.now(), status = 1, ).save() othercurrentBalance = otheruser_queryset.walletBalance otherupdateBalance = float(othercurrentBalance)+float(amount) otheruser_queryset.update(walletBalance = otherupdateBalance) #Here we need update this transaction to wallet also wallet_trasaction_table1 = WalletTransactions( userId = str(otheruser_queryset.id), amount =amount, paymentGatewayId = paymentGatewayId, creditType = "credit", transactionId = transactionId, paymentType = paymentType, settlementPayId = None, walletLog = str(int(amount)) + " is transferd from " + user_queryset.fullName + " (" + str(user_queryset.phoneNumber)+ ")", remarks = remarks, userType = "user", createdBy = None, createdOn = datetime.datetime.now(), status = 1, ).save() wtransactionId = str(wallet_trasaction_table1.id) if wtransactionId: data_status["responseStatus"] = 1 data_status["result"] = "Transaction successful" data_status["transactionId"] = wtransactionId return data_status else: data_status["responseStatus"] = 0 data_status["result"] = "Transaction transfered failed." return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Transaction unsuccessful" return data_status else: data_status['result'] = "Required fields are missing" return data_status ########### User Mobile Number Verify API ########## @users.route("/user_mobileNumber_verify",methods=["POST"]) def user_mobileNumber_verify(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") mobileNumber = request.json.get("mobileNumber","") if userId and mobileNumber: try: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"] = "Invalid user Id" return data_status otheruser_queryset = Users.objects(phoneNumber=mobileNumber,status__in=[1]).first() if not otheruser_queryset: data_status["result"] = "Invalid Mobile Number" return data_status else: data_status["responseStatus"] = 1 data_status["result"] = "Mobile Number Valid." return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Transaction unsuccessful" return data_status else: data_status['result'] = "Required fields are missing" return data_status @users.route("/user_upload_video",methods=["POST"]) def user_upload_video(): data_status = {"responseStatus": 0, "result": ""} userId = request.form.get("userId","") uploadVideo = request.files.get("uploadVideo","") videoVerificationStatus = request.form.get("videoVerificationStatus","") print(uploadVideo,"(((((((((((uploadVideo)))))))))))") if not userId: data_status["result"] = "Required fields are missing!!" return data_status try: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"]="Invalid user id!!" return data_status user_kyc_queryset = UserKYC.objects(userId=str(user_queryset.id)).first() if user_kyc_queryset: if uploadVideo: video_file = upload_file_video("uploadKYCVideos", userId, ".mp4", uploadVideo) print(video_file,"(((((((((((((video_file)))))))))))))") if video_file: user_kyc_queryset.update( uploadVideo=video_file, videoVerificationStatus=videoVerificationStatus, submittedDate=datetime.datetime.now() ) data_status["responseStatus"] = 1 data_status["result"] = "Video uploaded successfully!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to upload video!!" return data_status # @users.route("/operator_grouping_based_operator_parameters_list",methods=["POST"]) # def operator_grouping_based_operator_parameters_list(): # data_status = {"responseStatus": 0, "result": ""} # operatorGroupingsList = [] # try: # operator_grouping_queryset = OperatorGrouping.objects(status__in=[1]).order_by('-id').all() # for each_operator_grouping in operator_grouping_queryset: # operator_grouping_data = { # "id":str(each_operator_grouping.id), # "groupName":each_operator_grouping.groupName, # "value":each_operator_grouping.value, # } # operatorParametersList = [] # if each_operator_grouping.operatorParameterId: # operator_parameters_queryset = OperatorParameter.objects( # id=str(each_operator_grouping.operatorParameterId.id), # status__in=[1] # ).order_by("-id").all() # for each_operator_parameter in operator_parameters_queryset: # operator_parameter_dict = fetching_operator_parameter_details(each_operator_parameter) # operatorParametersList.append(operator_parameter_dict) # operator_grouping_data["operatorParametersList"] = operatorParametersList # operatorGroupingsList.append(operator_grouping_data) # data_status["responseStatus"] = 1 # data_status["result"] = "Operator grouping based operator parameters data fetched successfully!" # data_status["operatorGroupingsList"] = operatorGroupingsList # return data_status # except Exception as e: # app.logger.error(traceback.format_exc()) # data_status["result"] = "Unable to fetch operator parameters data!!" # return data_status ################################################ # @users.route("/get_single_transaction1111", methods=["POST"]) # def get_single_transaction1111(): # data_status = {"responseStatus": 0, "result": "", "transactionData": {}} # transaction_id = request.json.get("transactionId", "") # if not transaction_id: # data_status["result"] = "Required field 'transactionId' is missing" # return jsonify(data_status) # try: # each_transaction = Transactions.objects(id=transaction_id).order_by('-id').first() # if not each_transaction: # data_status["result"] = "Transaction not found" # return jsonify(data_status) # transaction_data = format_transaction_data(each_transaction) # data_status["result"] = "Transaction details fetched successfully" # data_status["responseStatus"] = 1 # data_status["transactionData"] = transaction_data # return jsonify(data_status) # except Exception as e: # app.logger.error(traceback.format_exc()) # data_status["result"] = "Unable to fetch transaction details" # return jsonify(data_status) # def format_transaction_data(transaction): # transaction_data = { # "id": str(transaction.id), # "categoryName": transaction.categoryName, # "serviceName": transaction.serviceName, # "operatorName": transaction.operatorName, # "mobileNumber": transaction.mobileNumber, # "amount": transaction.amount, # "createdOn": format_created_on(transaction.createdOn), # "paymentDetails": format_payment_details(transaction), # "accountHolderName": transaction.accountHolderName if transaction.categoryName == "Payout" else "", # "image": domain + transaction.image if hasattr(transaction, 'image') and transaction.image else "", # "status": format_transaction_status(transaction.status), # } # return transaction_data # def format_created_on(created_on): # if created_on: # ist_time = created_on.replace(tzinfo=pytz.utc).astimezone(ist_timezone) # return ist_time.strftime("%m-%d-%Y %I:%M %p") # return "" # def format_payment_details(transaction): # payment_details = {"transactionId": transaction.transactionId} # if transaction.operatorReference: # payment_details["operatorReference"] = transaction.operatorReference.strip() # else: # payment_details["operatorReference"] = "" # if transaction.paymentType: # payment_details["debitedFrom"] = transaction.paymentType # else: # wallet_transaction = WalletTransactions.objects(transactionId=transaction.transactionId).order_by('-id').first() # payment_details["debitedFrom"] = wallet_transaction.paymentType if wallet_transaction else "" # return payment_details # def format_transaction_status(status): # if status == 1: # return "Successful" # elif status == 0: # return "Failed" # else: # return "Pending" @users.route("/add_remitter_beneficiaries",methods=["POST"]) def add_remitter_beneficiaries(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") firstName = request.json.get("firstName","") lastName = request.json.get("lastName","") phoneNumber = request.json.get("phoneNumber","") pincode = request.json.get("pincode","") moneyArtRemitterId = request.json.get("moneyArtRemitterId","") monthlyLimit = request.json.get("monthlyLimit","") availableBalance = request.json.get("availableBalance","") recipientsList = request.json.get("recipientsList",[]) print(recipientsList) print("((((((((((((((recipientsList))))))))))))))") if userId: try: remitter_queryset = Remitters.objects(phoneNumber__iexact=phoneNumber,status__in=[1]).first() if not remitter_queryset: remitters_table = Remitters( userId = userId, firstName = firstName, lastName = lastName, phoneNumber = phoneNumber, pincode = pincode, moneyArtRemitterId = moneyArtRemitterId, monthlyLimit = monthlyLimit, availableBalance = availableBalance, createdOn = datetime.datetime.now(), status = 1, ).save() remitterId = str(remitters_table.id) for each_recipient in recipientsList: print(each_recipient) print("((((((((((each_recipient))))))))))") ifscCode=each_recipient.get("ifscCode") master_bank_queryset = MasterIFSCBank.objects(ifscCode=ifscCode,status__in=[1]).first() if master_bank_queryset: beneficiary_table = Beneficiaries( userId = userId, masterBankId = str(master_bank_queryset.id), beneficiaryId = beneficiaryId, fullName = fullName, mobileNumber = mobileNumber, verifyStatus = verifyStatus, accountNumber = accountNumber, createdOn = datetime.datetime.now(), status = 1, ).save() else: bankCode = ifscCode[-6:] master_bank_table = MasterIFSCBank( bankName = each_recipient.get("bankName",""), bankCode = bankCode, ifscCode = each_recipient.get("ifscCode",""), isCreditCard = False, isSettlement = False, createdOn = datetime.datetime.now(), status = 1, ).save() master_bank_table_id = str(master_bank_table.id) beneficiary_table = Beneficiaries( userId = userId, masterBankId = master_bank_table_id, beneficiaryId = each_recipient.get("beneficiaryId",""), fullName = each_recipient.get("fullName",""), mobileNumber = each_recipient.get("mobileNumber",""), verifyStatus = each_recipient.get("verifyStatus",False), accountNumber = each_recipient.get("accountNumber"), createdOn = datetime.datetime.now(), status = 1, ).save() remitter_queryset = Remitters.objects(id=remitterId,status__in=[1]).first() remittersData={ 'remitterId':str(remitter_queryset.id), # 'moneyArtRemitterId':str(remitter_queryset.moneyArtRemitterId), 'phoneNumber':remitter_queryset.phoneNumber, 'firstName':remitter_queryset.firstName, 'lastName':remitter_queryset.lastName, 'availableBalance':remitter_queryset.availableBalance, 'monthlyLimit':remitter_queryset.monthlyLimit, } if remitter_queryset.moneyArtRemitterId: remittersData["moneyArtRemitterId"] = remitter_queryset.moneyArtRemitterId else: remittersData["moneyArtRemitterId"] = "" data_status["responseStatus"] = 1 data_status ["result"] = "Remitters and beneficiaries added successfully" data_status["remittersData"]=remittersData return data_status else: remittersData={ 'remitterId':str(remitter_queryset.id), # 'moneyArtRemitterId':str(remitter_queryset.moneyArtRemitterId), 'phoneNumber':remitter_queryset.phoneNumber, 'firstName':remitter_queryset.firstName, 'lastName':remitter_queryset.lastName, 'availableBalance':remitter_queryset.availableBalance, 'monthlyLimit':remitter_queryset.monthlyLimit, } if remitter_queryset.moneyArtRemitterId: remittersData["moneyArtRemitterId"] = remitter_queryset.moneyArtRemitterId else: remittersData["moneyArtRemitterId"] = "" data_status["remittersData"]=remittersData data_status["responseStatus"] = 1 data_status["result"]="This mobile number is already in use!!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to add data" return data_status else: data_status["result"] = "The required fields are missing." return data_status @users.route("/user_based_commissions", methods=["POST"]) def user_based_commissions(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId", "") commissionList = [] if not userId: data_status["result"] = "Required fields are missing!!" return data_status try: user_queryset = Users.objects(id=userId,status__in=[0,1]).first() if not user_queryset: data_status["result"]="Invalid user id!!" return data_status commissionId = str(user_queryset.commissionId.id) commissions_queryset = Commissions.objects(id=commissionId,status__in=[1]).order_by("-id").first() commissionDict = { "id":str(commissions_queryset.id), "commissionName":commissions_queryset.commissionName } modifiedCommissionsList = [] for each_commission in commissions_queryset.commissionList: operator_queryset = Operators.objects(id=each_commission.get("operatorId")).first() operatorName = operator_queryset.operatorName transaction_api_queryset = TransactionAPI.objects(id=each_commission.get("transactionAPIId")).first() apiName = transaction_api_queryset.apiName service_queryset = Service.objects(id=each_commission.get("serviceId")).first() serviceName = service_queryset.serviceName modifiedDict = { "id":str(commissions_queryset.id), "commissionName":commissions_queryset.commissionName, "operatorId":each_commission.get("operatorId"), "transactionAPIId":each_commission.get("transactionAPIId"), "serviceId":each_commission.get("serviceId"), "operatorName":operatorName, "apiName":apiName, "serviceName":serviceName, "chargeType": each_commission.get("chargeType"), "chargeValue": each_commission.get("chargeValue"), "commissionType": each_commission.get("commissionType"), "commissionValue": each_commission.get("commissionValue") } modifiedCommissionsList.append(modifiedDict) commissionDict["commissionList"]=modifiedCommissionsList data_status["result"] = "Commissions details fetched successfully" data_status["responseStatus"] = 1 data_status["commissionDetails"] = commissionDict return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fetch commissions data!!" return data_status ##################### OLD CODE ##################### # @users.route("/operator_based_commissions", methods=["POST"]) # def operator_based_commissions(): # data_status = {"responseStatus": 0, "result": "", "commissionDict": {}} # userId = request.json.get("userId", "") # operatorId = request.json.get("operatorId", "") # transactionAPIId = request.json.get("transactionAPIId", "") # if userId and operatorId and transactionAPIId: # try: # commissionDict = {} # user_queryset = Users.objects(id=userId,status__in=[0,1]).first() # if not user_queryset: # data_status["result"]="Invalid user id!!" # return data_status # if user_queryset.commissionId: # commissionId = str(user_queryset.commissionId.id) # commissions_queryset = Commissions.objects(id=commissionId,status=1).order_by("-id").first() # for each_record in commissions_queryset.commissionList: # if each_record.get("operatorId") == operatorId and each_record.get("transactionAPIId") == transactionAPIId: # commissionDict = { # "operatorId": each_record.get("operatorId"), # "transactionAPIId": each_record.get("transactionAPIId"), # "chargeType": each_record.get("chargeType"), # "chargeValue": each_record.get("chargeValue"), # "commissionType": each_record.get("commissionType"), # "commissionValue": each_record.get("commissionValue") # } # data_status["result"] = "Commissions details fetched successfully" # data_status["responseStatus"] = 1 # data_status["commissionDict"] = commissionDict # return data_status # except Exception as e: # app.logger.error(traceback.format_exc()) # data_status["result"] = "Unable to fetch commissions data!!" # return data_status # else: # data_status["result"] = "Required fields are missing!!" # return data_status @users.route("/operator_based_commissions", methods=["POST"]) def operator_based_commissions(): data_status = {"responseStatus": 0, "result": "", "commissionDict": {}} userId = request.json.get("userId", "") operatorId = request.json.get("operatorId", "") transactionAPIId = request.json.get("transactionAPIId", "") if userId and operatorId and transactionAPIId: try: commissionDictResult=operator_based_commission_details(userId,operatorId,transactionAPIId) # data_status["result"] = "Commissions details fetched successfully" # data_status["responseStatus"] = 1 # data_status["commissionDict"] = commissionDict return commissionDictResult except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fetch commissions data!!" return data_status else: data_status["result"] = "Required fields are missing!!" return data_status def operator_based_commission_details(userId,operatorId,transactionAPIId): data_status = {"responseStatus": 0, "result": "", "commissionDict": {}} if userId and operatorId and transactionAPIId: try: commissionDict = {} user_queryset = Users.objects(id=userId,status__in=[0,1]).first() if not user_queryset: data_status["result"]="Invalid user id!!" return data_status operators_commission_queryset = Commissions.objects( paymentGatewayId=transactionAPIId, # subServiceId=subServiceId, # profileId=profileId, commissionList__operatorId=operatorId ).first() # print(operators_commission_queryset.commissionList,"operators_commission_queryset") matched_commission_index=None commissionoperatorDict={} commissionValue="0" chargeValue="0" chargeType="FLAT" commissionType="FLAT" transactionAPIId = "" if operators_commission_queryset: matched_commission_index = next((index for index, commission in enumerate(operators_commission_queryset.commissionList) if commission['operatorId'] == operatorId), None) # print(matched_commission_index,"working") else: matched_commission_index = None if matched_commission_index!=None: commissionoperatorDict=operators_commission_queryset.commissionList[matched_commission_index] # print(commissionoperatorDict,"commissionoperatorDict") # print(each_operator.operatorName,"each_operator.operatorName") commissionType=commissionoperatorDict.get('commissionType') chargeType=commissionoperatorDict.get('chargeType') chargeValue=commissionoperatorDict.get('chargeValue') commissionValue=commissionoperatorDict.get('commissionValue') transactionAPIId=commissionoperatorDict.get('transactionAPIId') operatorId=commissionoperatorDict.get('operatorId') commissionDict = { "operatorId": operatorId, "transactionAPIId": transactionAPIId, "chargeType": chargeType, "chargeValue": chargeValue, "commissionType": commissionType, "commissionValue": commissionValue } data_status["result"] = "Commissions details fetched successfully" data_status["responseStatus"] = 1 data_status["commissionDict"] = commissionDict return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fetch commissions data!!" return data_status else: data_status["result"] = "Required fields are missing!!" return data_status @users.route("/get_agents_list", methods=["POST"]) def get_agents_list(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId", "") agentsList =[] if userId: try: user_queryset = Users.objects(parentId=userId,status__nin=[2]).order_by("-id") if user_queryset: for each_user in user_queryset: userDict = fetching_user_details(each_user) agentsList.append(userDict) data_status["result"] = "Agents details fetched successfully" data_status["responseStatus"] = 1 data_status["agentsList"] = agentsList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fetch agents data!!" return data_status else: data_status["result"] = "Required fields are missing!!" return data_status @users.route("/get_single_agent_details", methods=["POST"]) def get_single_agent_details(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId", "") if userId: try: user_queryset = Users.objects(id=userId,status__nin=[2]).first() if not user_queryset: data_status["result"]="Invalid user id!!" return data_status agent_dict = fetching_user_details(user_queryset) data_status["result"] = "Agent details fetched successfully" data_status["responseStatus"] = 1 data_status["agentData"] = agent_dict return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fetch agent data!!" return data_status else: data_status["result"] = "Required fields are missing!!" return data_status @users.route("/get_commisssion_list", methods=["POST"]) def get_commisssion_list(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId", "") commissionsList = [] if userId: try: commissions_queryset = Commissions.objects(createdBy=userId,status__nin=[2]).order_by("-id").all() if commissions_queryset: for each_commission in commissions_queryset: commissions_data = fetching_commission_details(each_commission) commissionsList.append(commissions_data) data_status["result"] = "Commission details fetched successfully" data_status["responseStatus"] = 1 data_status["commissionsList"] = commissionsList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fetch commissions data!!" return data_status else: data_status["result"] = "Required fields are missing!!" return data_status @users.route("/assigned_commisssions_list", methods=["POST"]) def assigned_commisssions_list(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId", "") commissionsList = [] if userId: try: commissions_queryset = Commissions.objects( Q(createdBy=userId) | Q(createdBy=None), status__in=[1] ).order_by("-id").all() if commissions_queryset: for each_commission in commissions_queryset: commissions_data = fetching_commission_details(each_commission) commissionsList.append(commissions_data) data_status["result"] = "Commission details fetched successfully" data_status["responseStatus"] = 1 data_status["commissionsList"] = commissionsList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fetch commissions data!!" return data_status else: data_status["result"] = "Required fields are missing!!" return data_status def fetching_operator_details(operator_queryset): operator_dict = {} try: operator_dict={ "id":str(operator_queryset.id), "operatorName":operator_queryset.operatorName, "serviceId":str(operator_queryset.serviceId.id), "serviceName":operator_queryset.serviceId.serviceName, } except Exception as e: app.logger.error(traceback.format_exc()) return operator_dict def fetching_transaction_api_details(transaction_api_queryset): transaction_api_dict = {} try: transaction_api_dict={ "id":str(transaction_api_queryset.id), "apiName":transaction_api_queryset.apiName, "code":transaction_api_queryset.code, "isActive":transaction_api_queryset.isActive, "isUserWise":transaction_api_queryset.isUserWise, "transactionType":transaction_api_queryset.transactionType, "paramsList":transaction_api_queryset.paramsList } except Exception as e: app.logger.error(traceback.format_exc()) return transaction_api_dict #Get Commsion Operators List API @users.route("/get_commission_operators_list",methods=["POST","GET"]) def get_commission_operators_list(): data_status = {"responseStatus": 0, "result": ""} operatorsList = [] transactionApisList = [] try: operators_queryset = Operators.objects(status__in=[1]).order_by("-id").all() for each_operator in operators_queryset: operator_data = fetching_operator_details(each_operator) operatorsList.append(operator_data) transaction_apis_queryset = TransactionAPI.objects(status__in=[1]).order_by("-id").all() for each_transaction_api in transaction_apis_queryset: transaction_api_data = fetching_transaction_api_details(each_transaction_api) transactionApisList.append(transaction_api_data) data_status["responseStatus"] = 1 data_status["operatorsList"] = operatorsList data_status["transactionApisList"] = transactionApisList data_status["result"] = "Commission operators data fetched successfully" # return jsonify(data_status) return data_status except Exception as e: data_status["result"] = "Unable to fecth data" return data_status def fetching_commission_details(commission_queryset): commissions_dict = {} try: commissions_dict = { "id":str(commission_queryset.id), "commissionName":commission_queryset.commissionName, # "createdOn":commission_queryset.createdOn, } if commission_queryset.createdOn: ist_time=commission_queryset.createdOn.replace(tzinfo=pytz.utc).astimezone(ist_timezone) commissions_dict["createdOn"] = ist_time.strftime("%m-%d-%Y %I:%M %p") except Exception as e: app.logger.error(traceback.format_exc()) return commissions_dict #Add commission API @users.route("/add_user_commission", methods=["POST"]) def add_user_commission(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId", "") commissionName = request.json.get("commissionName","") commissionLists = request.json.get("commissionLists",[]) try: if commissionName: try: user_commission_table = Commissions( commissionName = commissionName, commissionList = commissionLists, userType = "agent", createdBy = userId, createdOn = datetime.datetime.now(), status = 1, ) save_table = user_commission_table.save() userCommissionId = str(save_table.id) data_status["result"] = "User commissions added successfully" data_status["responseStatus"] = 1 return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to add user commission" return data_status else: data_status["result"] = "Required fields are missing" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to add user commission" return data_status @users.route("/get_single_user_commission",methods=["POST","GET"]) def get_single_user_commission(): data_status = {"responseStatus": 0, "result": ""} commissionId = request.json.get("commissionId","") userId = request.json.get("userId","") commission_data ={} try: commission_queryset = Commissions.objects( id=commissionId, createdBy=userId, status__in=[0,1] ).first() if commission_queryset: # commission_data = fetching_user_commission_details(commission_queryset) commission_data = { "id":str(commission_queryset.id), "commissionName":commission_queryset.commissionName } modifiedCommissionsList = [] for each_commission in commission_queryset.commissionList: operator_queryset = Operators.objects(id=each_commission.get("operatorId")).first() operatorName = operator_queryset.operatorName transaction_api_queryset = TransactionAPI.objects(id=each_commission.get("transactionAPIId")).first() apiName = transaction_api_queryset.apiName service_queryset = Service.objects(id=each_commission.get("serviceId")).first() serviceName = service_queryset.serviceName modifiedDict = { # "id":str(commission_queryset.id), # "commissionName":commission_queryset.commissionName, "operatorId":each_commission.get("operatorId"), "transactionAPIId":each_commission.get("transactionAPIId"), "serviceId":each_commission.get("serviceId"), "operatorName":operatorName, "apiName":apiName, "serviceName":serviceName, "chargeType": each_commission.get("chargeType"), "chargeValue": each_commission.get("chargeValue"), "commissionType": each_commission.get("commissionType"), "commissionValue": each_commission.get("commissionValue") } modifiedCommissionsList.append(modifiedDict) commission_data["commissionList"]=modifiedCommissionsList data_status["responseStatus"] = 1 data_status["result"] = "Commission details fetched successfully" data_status["commissionData"] = commission_data return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fetch commission details" return data_status @users.route("/update_user_commission",methods=["POST","GET"]) def update_user_commission(): data_status = {"responseStatus": 0, "result": ""} commissionId = request.json.get("commissionId","") userId = request.json.get("userId","") commissionName = request.json.get("commissionName","") commissionLists = request.json.get("commissionLists",[]) # operatorIdslist = request.json.get("operatorIdslist",[]) # chargeTypesList = request.json.get("chargeTypesList",[]) # chargeValuesList = request.json.get("chargeValuesList",[]) # commissionTypesList = request.json.get("commissionTypesList",[]) # commissionValuesList = request.json.get("commissionValuesList",[]) # transactionApiIdsList = request.json.get("transactionApiIdsList",[]) if commissionName: try: commission_queryset = Commissions.objects(id=commissionId,createdBy=userId).first() if not commission_queryset: data_status["result"] = "Commission does not exist" return data_status # if commission_queryset: # updateCommissionList = [] # for i in range(len(operatorslist)): # operator_queryset = Operators.objects(id=operatorslist[i]).first() # serviceId = str(operator_queryset.serviceId.id) # commissionDict1 = { # "operatorId": operatorIdslist[i], # "chargeType": chargeTypesList[i], # "chargeValue": chargeTypesList[i], # "commissionType": commissionTypesList[i], # "commissionValue": commissionValuesList[i], # "transactionAPIId": transactionApiIdsList[i], # "serviceId":serviceId # } # updateCommissionList.append(commissionDict1) commission_queryset.update( commissionName=commissionName, commissionList = commissionLists ) data_status["result"] = "User Commissions updated successfully" data_status["responseStatus"] = 1 return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to update user commission!!" return data_status else: data_status["result"] = "The required field is missing" return data_status @users.route("/assign_user_commission",methods=["POST","GET"]) def assign_user_commission(): data_status = {"responseStatus": 0, "result": ""} commissionId = request.json.get("commissionId","") userId = request.json.get("userId","") parentId = request.json.get("parentId","") #Login user Id if commissionId and userId and parentId: try: user_queryset = Users.objects(id=userId,parentId=parentId).first() if not user_queryset: data_status["result"] = "User does not exist" return data_status user_queryset.update( commissionId=ObjectId(commissionId) ) data_status["result"] = "User commissions assigned successfully" data_status["responseStatus"] = 1 return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to assign user commission!!" return data_status else: data_status["result"] = "The required field is missing" return data_status @users.route("/payemnt_gateways_credentials_list",methods=["POST","GET"]) def payemnt_gateways_credentials_list(): data_status = {"responseStatus": 0, "result": ""} transactionApisList = [] try: transaction_apis_queryset = TransactionAPI.objects(transactionType="PaymentGateway",status__in=[1]).order_by("-id").all() for each_transaction_api in transaction_apis_queryset: transaction_api_data = fetching_transaction_api_details(each_transaction_api) transactionApisList.append(transaction_api_data) data_status["responseStatus"] = 1 data_status["transactionApisList"] = transactionApisList data_status["result"] = "Transaction API's data fetched successfully!" return data_status except Exception as e: data_status["result"] = "Unable to fecth transaction api data!!" return data_status @users.route("/getauthtoken", methods=["POST"]) def getauthtoken(): payloadresponse=getBbpsAuthorizationToken() print(payloadresponse.get('accessToken'),"accessToken") return payloadresponse def getBbpsAuthorizationToken(): data_status = {"responseStatus":0,"result":"","accessToken":""} try: url = "https://accounts.payu.in/oauth/token" headers = { "content-type": "application/json", "content-type": "application/x-www-form-urlencoded" } payload="client_id=35e731ff20e6bc521de9f29618b22c1240a4c69f6350c50e0fcb8e6b7d6c1bec&client_secret=610a66e8fb918d2c6a7ccf5674ea2893cb7cbbd589a0c3d9544e3f3ddf7366f4&scope=read_bills create_transactions read_billers read_biller_categories read_transactions&grant_type=client_credentials" payuresponse = requests.post(url, data=payload, headers=headers) payuresponseData = json.loads(payuresponse.text) data_status['responseStatus']=1 data_status['accessToken']=payuresponseData.get("access_token") return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch bill request data!!" return data_status @users.route("/billfetchrequest", methods=["POST"]) @user_required def billfetchrequest(): data_status = {"responseStatus":0,"result":"","authorizationToken":""} try: userId = request.json.get("userId","") payload = request.json.get("payload",{}) authorizationToken = request.json.get("authorizationToken","") clientCode = request.json.get("clientCode","") if not userId and not payload and not clientCode: data_status["result"]="Required fields are missing!!" return data_status if authorizationToken=="": authtokenresp=getBbpsAuthorizationToken() authorizationToken=authtokenresp.get('accessToken') url = "https://nbc.payu.in/payu-nbc/v1/nbc/billfetchrequest" print(payload,"PAYLOAD") headers = { "content-type": "application/json", "authorization": "Bearer "+str(authorizationToken), "clientCode": clientCode } print(headers,"headers") payuresponse = requests.post(url, json=payload, headers=headers) print(payuresponse.text,"(((((((((((((payuresponse)))))))))))))") payuresponseData = json.loads(payuresponse.text) data_status["responseStatus"]=1 data_status["result"]="Bill request data fetched successfully!" data_status["payuresponseData"]=payuresponseData data_status["authorizationToken"]=authorizationToken return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch bill request data!!" return data_status @users.route("/payin_payment_response", methods=["POST"]) @user_required def payin_payment_response(): data_status = {"responseStatus":0,"result":""} try: userId = request.json.get("userId","") paymentChannel = request.json.get("paymentChannel","") agent = request.json.get("agent","") location = request.json.get("location","") productName = request.json.get("productName","") walletId = request.json.get("walletId","") payInPaymentGatewayId = request.json.get("payInPaymentGatewayId","") responseDict = request.json.get("responseDict",{}) if not userId and not responseDict and not walletId: data_status["result"]="Required fields are missing!!" return data_status wallettran_queryset = WalletTransactions.objects(id=walletId).first() if not wallettran_queryset: data_status["result"]="Invalid Request!!" return data_status merchant_queryset = Users.objects(id=userId,status=1).first() if not merchant_queryset: data_status["result"]="Invalid Request!!" return data_status check_kyc_status = merchant_kyc_status(str(merchant_queryset.id)) if check_kyc_status.get("responseStatus") != 1: data_status["result"]="Merchant KYC is not completed please contact to admin!!" return data_status kycStatus = check_kyc_status.get("merchantKycDetails", {}).get("kycStatus") if kycStatus == False: data_status["result"]="Merchant KYC is not completed please contact to admin!!" return data_status print(responseDict,"RESPONSE DICT") print(type(responseDict),"RESPONSE DICT") cardmasked = "" customerVpa = "" cardType = "" responseDict = responseDict.replace('\\', '') responseDict = ''.join(ch for ch in responseDict if ch not in '\x00-\x1f') jsonResponseDict = responseDict.replace("'", '"') jsonResponseDict = jsonResponseDict.strip() jsonResponseDict = json.loads(jsonResponseDict) if jsonResponseDict: if wallettran_queryset.pgOrderId != jsonResponseDict.get("txnid"): data_status["result"]="Invalid Request!!" return data_status if jsonResponseDict.get("error_code")=="E000": errorMessage = jsonResponseDict.get("field9") else: errorMessage = jsonResponseDict.get("field8") bankName="" bankRefId=str(jsonResponseDict.get("bank_ref_no")) pgOrderId=str(jsonResponseDict.get("id")) paymentMode=str(jsonResponseDict.get("mode")) currency="INR" if jsonResponseDict.get("mode")=="UPI": customerVpa = jsonResponseDict.get("field1") elif jsonResponseDict.get("mode")=="CC": paymentMode="CREDIT CARD" cardType=jsonResponseDict.get("card_type") bankName=jsonResponseDict.get("issuing_bank") customerVpa=jsonResponseDict.get("ibibo_code") cardmasked=jsonResponseDict.get("card_no") elif jsonResponseDict.get("mode")=="DC": paymentMode="DEBIT CARD" cardType=jsonResponseDict.get("ibibo_code") cardmasked=jsonResponseDict.get("card_no") elif jsonResponseDict.get("mode")=="NB": paymentMode="NET BANKING" customerVpa=jsonResponseDict.get("ibibo_code") # elif jsonResponseDict.get("mode")=="NEFT": # cardmasked="" # elif jsonResponseDict.get("mode")=="AEPS": # cardmasked="" # elif jsonResponseDict.get("mode")=="IMPS": # cardmasked="" elif jsonResponseDict.get("mode")=="CASH": paymentMode="WALLET" customerVpa=jsonResponseDict.get("ibibo_code") ################################################### Slab Calculation for Payin ######################################################################### payment_mode_queryset = PaymentMode.objects(paymentMode=str(paymentMode)).first() paymentModeId="" subPaymentModeId="" if payment_mode_queryset: paymentModeId = str(payment_mode_queryset.id) if cardType!="": subPaymentMode=cardType sub_payment_mode_queryset = SubPaymentModes.objects(paymentModeId=paymentModeId,subPaymentModeType=str(subPaymentMode)).first() if sub_payment_mode_queryset: subPaymentModeId = str(sub_payment_mode_queryset.id) else: subPaymentMode=paymentMode sub_payment_mode_queryset = SubPaymentModes.objects(paymentModeId=paymentModeId,subPaymentModeType=str(subPaymentMode)).first() if sub_payment_mode_queryset: subPaymentModeId = str(sub_payment_mode_queryset.id) if subPaymentModeId=="": subPaymentMode=paymentMode sub_payment_mode_queryset = SubPaymentModes.objects(paymentModeId=paymentModeId,subPaymentModeType=str(subPaymentMode)).first() if sub_payment_mode_queryset: subPaymentModeId = str(sub_payment_mode_queryset.id) patternId = str(merchant_queryset.patternId.id) amount = jsonResponseDict.get("amount") print(amount,"(((((((((((((((AMOUNT)))))))))))))))") print(type(amount),"(((((((((((((((AMOUNT TYPE)))))))))))))))") if amount is None: amount = 0 else: amount = float(amount) if amount < 0: data_status["result"]="Insufficient amount!!" return data_status slabId = None transactionAmount = amount commissionCharges={} if paymentModeId!="" and subPaymentModeId!="" and payInPaymentGatewayId!="" and patternId!="": commissionCharges = slab_calculation_for_payin(amount,paymentModeId,subPaymentModeId,patternId,payInPaymentGatewayId) if commissionCharges.get("slabId") == None: slabId = None transactionAmount = amount else: slabId = commissionCharges.get("slabId") transactionAmount = float(commissionCharges.get("transactionAmount")) ####################################################################################################################################################### transactionData = [jsonResponseDict] if jsonResponseDict.get("status") == "success": if float(wallettran_queryset.amount)==float(amount): status=1 else: status = 6 errorMessage = "Insufficient amount credited!!" lorder_queryset = WalletTransactions.objects(id=str(walletId),status__nin=[5]).first() if lorder_queryset.status!=1 and status==1: balanceResult=user_payin_balance_update(str(merchant_queryset.id),float(transactionAmount),"Credit",str(payInPaymentGatewayId)) if balanceResult.get('responseStatus')==0: data_status["result"]="Unable to connect with server. Please Try again." return data_status payinbalancelogs_queryset=PayinBalanceLogs( transactionAPIId=str(payInPaymentGatewayId), userId=userId, previousBalance=round_last_digits(float(balanceResult.get('transactionPreviousBalance'))), currentBalance=round_last_digits(float(balanceResult.get('transactionCurrentBalance'))), orderId=str(wallettran_queryset.orderId), amount=round_last_digits(float(amount)), grandTotal=round_last_digits(float(transactionAmount)), transferType="Credit", userType="user", transactionId=str(wallettran_queryset.transactionId), createdOn=datetime.datetime.now(), status=1 ).save() lorder_queryset.update(status=status,payInResponseCallBackData=transactionData,responseCallBackTime=datetime.datetime.now(),pgOrderId=pgOrderId,bankRefId=str(bankRefId),customerVpa=customerVpa,currency=currency,errorMessage=errorMessage,grandTotal=round_last_digits(float(transactionAmount)),walletLog="Wallet Balance is added with the amount of " + str(amount) + ".",previousBalance=round_last_digits(float(balanceResult.get('userPreviousBalance'))),cardmasked=cardmasked,subPaymentModeId=ObjectId(subPaymentModeId),paymentModeId=ObjectId(paymentModeId),paymentType=paymentMode,bankName=bankName,productName=productName,currentBalance=round_last_digits(float(balanceResult.get('userCurrentBalance'))),commissionCharges=commissionCharges) try: merchantName = str(merchant_queryset.fullName) trnsactionDate = datetime.datetime.now().astimezone(ist_timezone).strftime("%d-%m-%Y %I:%M %p") mail_subject = "Load Funds for Graam Pay from Merchant " + merchantName + "." recipients_list = [admin_recieve_email] template_name = "emails/loadfunds.html" mail_data = { "merchantName":merchantName, "amount":formatINR("{:.2f}".format(float(amount))), "transactionId":str(wallettran_queryset.transactionId), "paymentMode":jsonResponseDict.get("mode"), "cardNumber":cardmasked, "orderId":str(wallettran_queryset.orderId), "bankRefId":str(jsonResponseDict.get("bank_ref_no")), "transactionDate":trnsactionDate, } mailoutputData = send_asynchronous_email(mail_subject, recipients_list, template_name, mail_data) merchant_mail_subject = "Payment Transaction Alert From Graam Pay" merchant_recipients_list = [merchant_queryset.email] mailoutputData = send_asynchronous_email(merchant_mail_subject, merchant_recipients_list, template_name, mail_data) except Exception as e: app.logger.error(traceback.format_exc()) pass try: if merchant_queryset.parentId and commissionCharges.get("slabId") != None: user_parent_payin_commission_details(str(merchant_queryset.parentId.id),amount,payInPaymentGatewayId,jsonResponseDict.get("txnid"),paymentModeId,subPaymentModeId,commissionCharges.get("chargeAmount"),commissionCharges.get("chargeValue"),commissionCharges.get("chargeType"),str(merchant_queryset.id),float(commissionCharges.get("gstAmount")),float(commissionCharges.get("tdsAmount"))) except Exception as e: app.logger.error(traceback.format_exc()) pass else: lorder_queryset.update(status=status,payInResponseCallBackData=transactionData,responseCallBackTime=datetime.datetime.now(),pgOrderId=pgOrderId,bankRefId=bankRefId,customerVpa=customerVpa,currency=currency,errorMessage=errorMessage,cardmasked=cardmasked,subPaymentModeId=ObjectId(subPaymentModeId),paymentModeId=ObjectId(paymentModeId),paymentType=paymentMode,bankName=bankName,productName=productName,grandTotal=round_last_digits(float(transactionAmount)),walletLog="Wallet Balance is added with the amount of " + str(amount) + ".",commissionCharges=commissionCharges) else: wallettran_queryset.update(status=0,payInResponseCallBackData=transactionData,responseCallBackTime=datetime.datetime.now(),pgOrderId=pgOrderId,bankRefId=bankRefId,customerVpa=customerVpa,currency=currency,errorMessage=errorMessage,cardmasked=cardmasked,subPaymentModeId=ObjectId(subPaymentModeId),paymentModeId=ObjectId(paymentModeId),paymentType=paymentMode,bankName=bankName,productName=productName,grandTotal=round_last_digits(float(transactionAmount)),walletLog="Wallet Balance is added with the amount of " + str(amount) + ".",commissionCharges=commissionCharges) data_status["responseStatus"]=1 data_status["transactionId"]=walletId data_status["result"]="Payin response data saved successfully!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to save payin response data!!" return data_status @users.route("/payin_payment_create_intent", methods=["POST"]) @user_required def payin_payment_create_intent(): data_status = {"responseStatus":0,"result":""} try: userId = request.json.get("userId","") paymentChannel = request.json.get("paymentChannel","") agent = request.json.get("agent","") customerName = request.json.get("customerName","") customerEmail = request.json.get("customerEmail","") customerPhonenumber = request.json.get("customerPhonenumber","") location = request.json.get("location","") productName = request.json.get("productName","") payInPaymentGatewayId = request.json.get("payInPaymentGatewayId","") setlementId = request.json.get("setlementId","") amount = request.json.get("amount","") otpCheckId = request.json.get("otpCheckId","") print(request.json,"request.json") if not userId and not amount and not payInPaymentGatewayId and not setlementId and not customerName != "" and not customerEmail != "" and not customerPhonenumber != "": data_status["result"]="Required fields are missing!!" return data_status if amount is None: amount = 0 else: amount = float(amount) if amount < 0: data_status["result"]="Insufficient amount!!" return data_status currentDateStart = datetime.datetime.now().replace(hour=0, minute=0, second=0, microsecond=0) currentDateEnd = currentDateStart.replace(hour=23, minute=59, second=59, microsecond=999999) checkphoneNumber = WalletTransactions.objects(customerPhonenumber=str(customerPhonenumber),status=1,createdOn__gte=currentDateStart,createdOn__lte=currentDateEnd).first() if checkphoneNumber: data_status["result"]="Only one transaction is allowed per customer per day." return data_status payin_gate_way_queryset = TransactionAPI.objects(id=str(payInPaymentGatewayId),status=1).first() if not payin_gate_way_queryset: data_status["result"]="Invalid Request." return data_status merchant_queryset = Users.objects(id=str(userId),status=1).first() if not merchant_queryset: data_status["result"]="Invalid Request." return data_status check_kyc_status = merchant_kyc_status(str(merchant_queryset.id)) if check_kyc_status.get("responseStatus") != 1: data_status["result"]="Merchant KYC is not completed please contact to admin!!" return data_status kycStatus = check_kyc_status.get("merchantKycDetails", {}).get("kycStatus") if kycStatus == False: data_status["result"]="Merchant KYC is not completed please contact to admin!!" return data_status if merchant_queryset.merchantType=="customer": if otpCheckId=="": data_status["result"]="Invalid Request." return data_status otpcheck_querryset=OtpChecks.objects(userId=str(userId),id=str(otpCheckId),status=1).first() if not otpcheck_querryset: data_status["result"]="Invalid Request." return data_status otpcheck_querryset.update(status=2) check_transaction_limits = merchant_transaction_limit_settings("Payin",payInPaymentGatewayId,userId,amount) if check_transaction_limits.get("responseStatus") == 0: data_status['result']=check_transaction_limits.get("result") return data_status paymentGateWayCode = payin_gate_way_queryset.code errorMessage="Initiated" paymentMode="" customerVpa="" cardType="" cardmasked="" patternId = str(merchant_queryset.patternId.id) slabId = None transactionAmount = amount commissionCharges={} orderId = str(get_epoch_milli_time())+random_digit_generate(2) transactionId = random_digit_generate(15) walletId="" merchantUniqueNumber=str(merchant_queryset.merchantUniqueNumber) mid_extracted = merchantUniqueNumber[1:].lstrip("0") pgOrderId=str(transaction_id_prefix)+str(mid_extracted)+str(orderId) wallet_transaction_table = WalletTransactions( userId = userId, amount = round_last_digits(float(amount)), grandTotal=round_last_digits(float(transactionAmount)), paymentGatewayId = payInPaymentGatewayId, currency="INR", paymentType = paymentMode, creditType = "Credit", transactionId = transactionId, transactionData = [request.json], orderId = orderId, walletLog="", userType="user", createdBy = None, createdOn = datetime.datetime.now(), location = location, platform = "app", agent = agent, customerEmail = customerEmail, customerName = customerName, customerPhonenumber = customerPhonenumber, previousBalance=0, currentBalance=0, paymentLinkId = None, PaymentButtonId = None, paymentPageId = None, errorMessage = errorMessage, paymentChannel = paymentChannel, bankRefId="", cardmasked=cardmasked, productName=productName, setlementId=setlementId, pgOrderId=pgOrderId, customerVpa="", commissionCharges=commissionCharges, settlementStatus = 1, status = 3 ) wallet_save=wallet_transaction_table.save() walletId=str(wallet_save.id) upi_intent_url="" if walletId: if paymentGateWayCode == "Lyra_Payin": get_client = "" get_secret = "" get_base_url = "" user_name = "" get_base_url = "" password = "" webhook_url = "" return_url = "" for each_key in payin_gate_way_queryset.paramsList: note="Online Course" client_ip="125.40.25.126" currency="INR" get_key = each_key.get("key") if get_key == "api_key": get_client = each_key.get("value") if get_key == "secret_key": get_secret = each_key.get("value") if get_key == "base_url": get_base_url = each_key.get("value") if get_key == "webhook_url": webhook_url = each_key.get("value") if get_key == "return_url": return_url = each_key.get("value") if get_key == "user_name": user_name = each_key.get("value") if get_key == "password": password = each_key.get("value") ###################################################### Lyra Payin Code ######################################################################### paymentgatewayresponseDict = lyra_payin_payment_intent(get_base_url,pgOrderId,note,amount,currency,customerName,customerPhonenumber,customerEmail,webhook_url,return_url,userId,payInPaymentGatewayId,client_ip,"api",user_name,password) ################################################################################################################################################ if paymentgatewayresponseDict.get("responseStatus") == 1: transactionId = paymentgatewayresponseDict.get("payment_request_id") transactionData = paymentgatewayresponseDict.get("transactionData") paymentChannel = paymentgatewayresponseDict.get("paymentChannel") pgOrderId=paymentgatewayresponseDict.get("pgOrderId") upi_intent_url=paymentgatewayresponseDict.get("upi_intent_url") wallet_save.update(transactionId=transactionId,transactionData=transactionData,paymentChannel=paymentChannel,paymentLink=upi_intent_url) data_status["responseStatus"]=1 data_status["transactionId"]=pgOrderId data_status["walletId"]=walletId data_status["PaymentLink"]=upi_intent_url data_status["gatewayType"]=paymentGateWayCode data_status["result"]="Payin response data saved successfully!" return data_status else: errorresult=paymentgatewayresponseDict.get("result") wallet_save.update(errorMessage=errorresult,status=0) data_status["result"]=errorresult return data_status else: data_status["responseStatus"]=1 data_status["transactionId"]=pgOrderId data_status["walletId"]=walletId data_status["PaymentLink"]=upi_intent_url data_status["gatewayType"]=paymentGateWayCode data_status["result"]="Payin response data saved successfully!" return data_status else: data_status["result"]="Unable to save payin response data!!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) print(traceback.format_exc(),"traceback_error") data_status["result"]="Unable to save payin response data!!" return data_status def fetching_transaction_details(each_transaction): transactionDict = {} try: transactionDict = { "id":str(each_transaction.id), "userId":str(each_transaction.userId.id), "paymentGatewayId":str(each_transaction.paymentGatewayId.id), "paymentGatewayName":each_transaction.paymentGatewayId.apiName, "fullName":each_transaction.userId.fullName, "amount":each_transaction.amount, "grandTotal":each_transaction.grandTotal, "previousBalance":each_transaction.previousBalance, "currentBalance":each_transaction.currentBalance, "currency":each_transaction.currency, "paymentType":each_transaction.paymentType, "cardType":each_transaction.cardType, "creditType":each_transaction.creditType, "transactionId":each_transaction.transactionId, "orderId":each_transaction.orderId, "createdOn":each_transaction.createdOn, "customerEmail":each_transaction.customerEmail, "customerName":each_transaction.customerName, "customerPhonenumber":each_transaction.customerPhonenumber, "errorMessage":each_transaction.errorMessage, "bankRefId":each_transaction.bankRefId, "cardmasked":each_transaction.cardmasked, "productName":each_transaction.productName, "customerVpa":each_transaction.customerVpa, "status":each_transaction.status, } try: if each_transaction.commissionCharges: transactionDict["commissionCharges"]=each_transaction.commissionCharges else: commissionCharges = { "aggregatorType":"", "aggregatorAmount":0, "commissionType":"", "commissionAmount":"", "chargeType":"FLAT", "chargeValue":0, "gstValue":0, "tdsValue":0, "aggregatorValue":0, "commissionValue":0, "chargeAmount":"0", "transactionAmount":"0", "gstInclude":0, "gstAmount":"0", "tdsInclude":0, "tdsAmount":0, "priceType":"Fixed", "slabId":"" } transactionDict["commissionCharges"]=commissionCharges except Exception as e: commissionCharges = { "aggregatorType":"", "aggregatorAmount":0, "commissionType":"", "commissionAmount":"", "chargeType":"FLAT", "chargeValue":0, "gstValue":0, "tdsValue":0, "aggregatorValue":0, "commissionValue":0, "chargeAmount":"0", "transactionAmount":"0", "gstInclude":0, "gstAmount":"0", "tdsInclude":0, "tdsAmount":0, "priceType":"Fixed", "slabId":"" } transactionDict["commissionCharges"]=commissionCharges except Exception as e: app.logger.error(traceback.format_exc()) return transactionDict @users.route("/wallet_passbook_transactions",methods=["POST"]) @user_required def wallet_passbook_transactions(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") startDate = request.json.get("startDate","") endDate = request.json.get("endDate","") transactionsList = [] try: if startDate and endDate: startDate = startDate + " 00:00:00" endDate = endDate + " 23:59:59" start_date = datetime.datetime.strptime(startDate, "%d-%m-%Y %H:%M:%S") end_date = datetime.datetime.strptime(endDate, "%d-%m-%Y %H:%M:%S") transactions_queryset = WalletTransactions.objects(userId=userId,createdOn__gte=start_date,createdOn__lte=end_date).order_by("-createdOn").all() else: transactions_queryset = WalletTransactions.objects(userId=userId).order_by("-createdOn").all() for each_transaction in transactions_queryset: transactionDict = fetching_transaction_details(each_transaction) transactionsList.append(transactionDict) data_status["result"] = "Transaction details fetched successfully" data_status["responseStatus"] = 1 data_status["transactionsList"] = transactionsList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch transaction data!!" return data_status @users.route("/wallet_passbook_transaction_details",methods=["POST"]) @user_required def wallet_passbook_transaction_details(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") transactionId = request.json.get("transactionId","") transactionDict = {} try: if not transactionId and not userId: data_status["result"]="Required fields are missing!!" return data_status transaction_queryset = WalletTransactions.objects(userId=userId,id=transactionId).first() if not transaction_queryset: data_status["result"]="Invalid transaction id!!" return data_status transactionDict = fetching_transaction_details(transaction_queryset) data_status["result"] = "Transaction details fetched successfully" data_status["responseStatus"] = 1 data_status["transactionDetails"] = transactionDict return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch transaction data!!" return data_status @users.route("/withdrawal_transaction_details",methods=["POST"]) @user_required def withdrawal_transaction_details(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") transactionId = request.json.get("transactionId","") transactionDict = {} try: transaction_queryset = FundTransfers.objects(userId=userId,id=transactionId).first() if not transaction_queryset: data_status["result"]="Invalid transaction id!!" return data_status transactionDict = fetching_payouts_details(transaction_queryset) data_status["result"] = "Transaction details fetched successfully" data_status["responseStatus"] = 1 data_status["transactionDetails"] = transactionDict return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch transaction data!!" return data_status @users.route("/view_merchant_wallet_balance", methods=["POST"]) def view_merchant_wallet_balance(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId", "") if userId: try: user_queryset = Users.objects(id=userId,status=1).first() if not user_queryset: data_status["result"]="Invalid merchant id!!" return data_status data_status["result"] = "Merchant wallet balance fetched successfully" data_status["responseStatus"] = 1 data_status["walletBalance"] = formatINR("{:.2f}".format(float(user_queryset.walletBalance))) data_status["payoutBalance"] = formatINR("{:.2f}".format(float(user_queryset.payoutBalance))) data_status["commissionBalance"] = formatINR("{:.2f}".format(float(user_queryset.commissionBalance))) return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to get merchant wallet balance!!" return data_status else: data_status["result"] = "Required fields are missing!!" return data_status @users.route("/payout_charges_calculation", methods=["POST"]) @user_required def payout_charges_calculation(): data_status = {"responseStatus": 0, "result":""} try: userId = request.json.get("userId","") amount = request.json.get("amount",0) paymentMode = request.json.get("paymentMode","") if not userId and not amount and not paymentMode: data_status["result"]="Required fields are missing!!" return data_status user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset.patternId: data_status["result"]="No payment gateways available!!" return data_status payment_mode_queryset = PaymentMode.objects(paymentMode=paymentMode).first() paymentModeId = str(payment_mode_queryset.id) sub_payment_mode_queryset = SubPaymentModes.objects(paymentModeId=paymentModeId,subPaymentModeType=paymentMode).first() subPaymentModeId = str(sub_payment_mode_queryset.id) patternId = str(user_queryset.patternId.id) chargeAmount=0 gstAmount=0 tdsAmount=0 withdrawalBalance=0 totalCharges=0 commissionCharges = slab_calculation_for_payout_merchant(amount,paymentModeId,subPaymentModeId,patternId) if commissionCharges.get("slabId") == None: slabId = None transactionAmount = amount else: slabId = commissionCharges.get("slabId") transactionAmount = float(commissionCharges.get("transactionAmount")) totalCharges=float(transactionAmount)-float(amount) print(transactionAmount,"transactionAmount") print(totalCharges,"totalCharges") print(user_queryset.payoutBalance,"user_queryset.payoutBalance") print(user_queryset.capBalance,"user_queryset.capBalance") if float(user_queryset.payoutBalance)<(float(transactionAmount)+float(user_queryset.capBalance)): withdrawalBalance=float(user_queryset.payoutBalance)-float(user_queryset.capBalance)-float(totalCharges) data_status['result']="Your available withdrawal balance is "+str(formatINR("{:.2f}".format(float(withdrawalBalance))))+", and the charges applied are "+str(formatINR("{:.2f}".format(float(totalCharges))))+"." return data_status else: data_status['responseStatus']=1 data_status['totalCharges']=str(formatINR("{:.2f}".format(float(totalCharges)))) return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to get merchant wallet balance!!" return data_status @users.route("/payin_charges_calculation", methods=["POST"]) @user_required def payin_charges_calculation(): data_status = {"responseStatus": 0, "result":""} try: userId = request.json.get("userId","") amount = request.json.get("amount",0) paymentMode = request.json.get("paymentMode","") subPaymentMode = request.json.get("subPaymentMode","") if not userId and not amount and not paymentMode and not subPaymentMode: data_status["result"]="Required fields are missing!!" return data_status user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset.patternId: data_status["result"]="No payment gateways available!!" return data_status payment_mode_queryset = PaymentMode.objects(paymentMode=paymentMode).first() paymentModeId = str(payment_mode_queryset.id) sub_payment_mode_queryset = SubPaymentModes.objects(paymentModeId=paymentModeId,subPaymentModeType=subPaymentMode).first() subPaymentModeId = str(sub_payment_mode_queryset.id) patternId = str(user_queryset.patternId.id) chargeAmount=0 gstAmount=0 tdsAmount=0 withdrawalBalance=0 transactionAmount=amount totalCharges=0 if float(amount)> 0 and paymentModeId and subPaymentModeId and patternId: commissionCharges = slab_calculation_for_payin_merchant(amount,paymentModeId,subPaymentModeId,patternId) if commissionCharges.get("slabId") == None: slabId = None transactionAmount = amount else: slabId = commissionCharges.get("slabId") transactionAmount = float(commissionCharges.get("transactionAmount")) totalCharges=float(amount)-float(transactionAmount) data_status['responseStatus']=1 data_status['transactionAmount']=str(formatINR("{:.2f}".format(float(transactionAmount)))) data_status['totalCharges']=str(formatINR("{:.2f}".format(float(totalCharges)))) return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to get merchant wallet balance!!" return data_status @users.route("/payout_transfer", methods=["POST"]) @user_required def payout_transfer(): data_status = {"responseStatus": 0, "result":""} random_number = str(random_digit_generate(15)) accountNumber="" accountIFSCCode="" beneficiaryName="" bankId="" beneficiaryPhone="" beneficiaryMail="" userId = request.json.get("userId","") amount = request.json.get("amount",0) accountNumber = request.json.get("accountNumber","") accountIFSCCode = request.json.get("ifscCode","") beneficiaryName = request.json.get("beneficiaryName","") bankId = request.json.get("bankId","") otpCheckId = request.json.get("otpCheckId","") narration = request.json.get("narration","transfer") paymentMode = request.json.get("paymentMode","") beneficiaryMail = request.json.get("beneficiaryMail","") beneficiaryPhone = request.json.get("beneficiaryPhone","") # Extracting client IP address if request.headers.getlist("X-Forwarded-For"): client_ip = request.headers.getlist("X-Forwarded-For")[0] else: client_ip = request.remote_addr transactionAPIId = "" requestData = [request.json] # # Here Create Client Logs Table save_client_table = save_client_logs_data(userId,"payout","fund_transfer","payout_transfer",transactionAPIId,requestData,client_ip,"app") print(request.json,"((((((((((payout_transfer request))))))))))") try: startDate = datetime.datetime.now() availability_check = check_transaction_availability(startDate, "payout") if availability_check.get('responseStatus')==0: data_status["result"]="Service Provider is not available. Please try after sometime." return data_status if amount and userId and otpCheckId: otpcheck_querryset=OtpChecks.objects(userId=str(userId),id=str(otpCheckId),status=1).first() if not otpcheck_querryset: data_status["result"]="Invalid Request." return data_status otpcheck_querryset.update(status=2) merchant_queryset = Users.objects(id=str(userId),status=1).first() if not merchant_queryset: data_status["result"]="Invalid merchant id!!" return data_status merchant_kyc_queryset = UserKYC.objects(userId=str(merchant_queryset.id),status=1).first() fundTransferType = "Instant" accountType = "bank" # "bank","upi" if beneficiaryMail=="": beneficiaryMail = merchant_queryset.email if beneficiaryPhone=="": beneficiaryPhone = merchant_queryset.phoneNumber if beneficiaryName=="": beneficiaryName = merchant_queryset.fullName if merchant_queryset.merchantType=="customer": beneficiaryName = merchant_queryset.fullName accountNumber = merchant_kyc_queryset.bankAccountNumber accountIFSCCode = merchant_kyc_queryset.ifscCode bankId = str(merchant_kyc_queryset.bankId.id) elif not accountNumber and not beneficiaryName and not accountIFSCCode: data_status["result"]="Invalid account Details." return data_status uniqueRequestNumber = "" narration = narration bankBranch = "" paymentMode = paymentMode # "IMPS" masked_account_number = mask_account_number(accountNumber) check_kyc_status = merchant_kyc_status(str(merchant_queryset.id)) if check_kyc_status.get("responseStatus") != 1: data_status["result"]="Merchant KYC is not completed please contact to admin!!" return data_status kycStatus = check_kyc_status.get("merchantKycDetails", {}).get("kycStatus") if kycStatus == False: data_status["result"]="Merchant KYC is not completed please contact to admin!!" return data_status ################################################ Checking For Velocity Rule Engine Conditions Code ################################################### # velocity_rule_check = check_payout_velocity_rule_engine_conditions(userId,amount,accountNumber) # if velocity_rule_check.get("responseStatus") == 0: # data_status["result"]=velocity_rule_check.get("result") # return data_status ###################################################################################################################################################### master_ifsc_queryset = MasterIFSCBank.objects(id=bankId,status__in=[1]).first() if not master_ifsc_queryset: data_status["result"]="Invalid bank id!!" return data_status user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset.patternId: data_status["result"]="No payment gateways available!!" return data_status transactionAPIId = str(user_queryset.patternId.payoutPaymentGatewayId.id) if not transactionAPIId: data_status["result"]="No payment gateways available!!" return data_status payout_gate_way_queryset = TransactionAPI.objects(id=transactionAPIId,status=1).first() if not payout_gate_way_queryset: data_status['result']="Payout option is diabled.Please contact to admin" return data_status # Here Update some data in client log save_client_table.update(transactionAPIId=ObjectId(transactionAPIId)) check_transaction_limits = merchant_transaction_limit_settings("Payout",transactionAPIId,userId,amount) if check_transaction_limits.get("responseStatus") == 0: data_status['result']=check_transaction_limits.get("result") return data_status # pgOrderId = str(user_queryset.merchantUniqueNumber)+"-"+str(random_number) merchant_reference_number = random_number merchantUniqueNumber=str(user_queryset.merchantUniqueNumber) mid_extracted = merchantUniqueNumber[1:].lstrip("0") pgOrderId=str(transaction_id_prefix)+str(mid_extracted)+str(merchant_reference_number) ######################################################### Slab Calculation for Payout ########################################################################### payoutPaymentGatewayId = transactionAPIId payment_mode_queryset = PaymentMode.objects(paymentMode=paymentMode).first() paymentModeId = str(payment_mode_queryset.id) sub_payment_mode_queryset = SubPaymentModes.objects(paymentModeId=paymentModeId,subPaymentModeType=paymentMode).first() subPaymentModeId = str(sub_payment_mode_queryset.id) patternId = str(user_queryset.patternId.id) commissionCharges = slab_calculation_for_payout_merchant(amount,paymentModeId,subPaymentModeId,patternId) if commissionCharges.get("slabId") == None: slabId = None transactionAmount = amount else: slabId = commissionCharges.get("slabId") transactionAmount = float(commissionCharges.get("transactionAmount")) ################################################################################################################################################################## bank_branch="" transactionId=random_digit_generate(15) if float(user_queryset.payoutBalance)<(float(transactionAmount)+float(user_queryset.capBalance)): insufficient_table = InsufficientBalanceLogs( userId=userId, orderId=merchant_reference_number, orderAmount=amount, walletAmount=float(merchant_queryset.payoutBalance), createdOn=datetime.datetime.now(), status=1 ).save() data_status["result"]="Insufficient balance!!" return data_status balance_check=payout_balance_check(transactionAPIId) print(balance_check,"balance_check") if balance_check.get('responseStatus')==0: data_status["result"]="Service provider not available. Please try after sometime." return data_status apiBalance=balance_check.get('balance') tsingleTxnUpperLimit=float(check_transaction_limits.get('singleTxnUpperLimit')) availableApiBalance=float(apiBalance)-float(amount) if tsingleTxnUpperLimit!=0 and float(tsingleTxnUpperLimit)>=float(availableApiBalance): try: sender_mail_query = SenderMails.objects(status=1,mailType="Payout_Insuficiant").first() if sender_mail_query: sapiName=str(payout_gate_way_queryset.apiName) savilablebalance=formatINR("{:.2f}".format(float(apiBalance))) smobileNumber=','.join(sender_mail_query.mobileNumber) if smobileNumber!="": smsResponse=send_sms(smobileNumber,"Insufficient_Funds",userName=sapiName,Reason="",amount=savilablebalance) if sender_mail_query.mailsList: trnsactionDate = datetime.datetime.now().astimezone(ist_timezone).strftime("%d-%m-%Y %I:%M %p") mail_subject = "Low balance alert from " + sapiName + "." recipients_list = sender_mail_query.mailsList template_name = "emails/insufficientfunds.html" mail_data = { "amount":savilablebalance, "apiName":sapiName, "transactionDate":trnsactionDate } mailoutputData = send_asynchronous_email(mail_subject, recipients_list, template_name, mail_data) except Exception as e: app.logger.error(traceback.format_exc()) pass if float(apiBalance) == 0 or float(apiBalance) 0: merchant_queryset.update(payoutBalance=currentBalance) fund_transfer_table = FundTransfers( createdBy=None, userId = str(merchant_queryset.id), amount = amount, grandTotal = beneficiaryCharges, transactionAPIId = payoutPaymentGatewayId, transferType = "Debit", userType = "user", narration = "Beneficiary validation charges for the account holder "+str(creditorName) +" | account number "+str(accountNumber), transactionUniqueId = transactionReferenceNumber, createdOn = datetime.datetime.now(), previousBalance=previousBalance, currentBalance=currentBalance, uniqueRequestNumber = "", beneficiaryName = creditorName, beneficiaryMail = "", beneficiaryPhone = "", accountIFSCCode = ifscCode, fundTransferType = "user", accountType = "", accountNumber = accountNumber, paymentMode = "wallet", bankBranch = "", bankName = bankName, errorMessage = "Beneficiary validation charges for the account holder "+str(creditorName) +" | account number "+str(accountNumber), internalId = "", pgOrderId = "", apiType = "api", merchantReferenceNumber = merchantReferenceNumber, commissionCharges = commissionCharges, status = 1 ) save_table = fund_transfer_table.save() data_status["responseStatus"] = 1 data_status["result"] = "Beneficiary created successfully!" return data_status client_id = "" secretKey = "" kid = "" get_base_url = "" aud_url = "" auth_url = "" grant_type = "" scope = "" source = "" client_assertion_type = "" debitAcountNumber = "" remitterName = "" transactionId = str(random_digit_generate(15)) # payout_gate_way_queryset = TransactionAPI.objects(code="Idfc_Payout",status=1).first() payout_gate_way_queryset = TransactionAPI.objects(id=payoutPaymentGatewayId,status=1).first() if not payout_gate_way_queryset: data_status["result"]="Invalid payment gateway id!!" return data_status if payout_gate_way_queryset.code == "Idfc_Payout": for each_key in payout_gate_way_queryset.paramsList: get_key = each_key.get("key") if get_key == "client_id": client_id = each_key.get("value").strip() if get_key == "secret_key": secretKey = each_key.get("value").strip() if get_key == "base_url": get_base_url = each_key.get("value").strip() if get_key == "kid": kid = each_key.get("value").strip() if get_key == "aud_url": aud_url = each_key.get("value").strip() if get_key == "auth_url": auth_url = each_key.get("value").strip() if get_key == "scope": scope = each_key.get("value").strip() if get_key == "grant_type": grant_type = each_key.get("value").strip() if get_key == "source": source = each_key.get("value").strip() if get_key == "client_assertion_type": client_assertion_type = each_key.get("value").strip() if get_key == "debit_acount_number": debitAcountNumber = each_key.get("value").strip() if get_key == "remitter_name": remitterName = each_key.get("value").strip() if get_key == "remitter_mobile_number": remitter_mobile_number = each_key.get("value").strip() benivalidationCheck = idfc_benivalidation(source,kid,aud_url,client_id,auth_url,grant_type,scope,client_assertion_type,secretKey,ifscCode,accountNumber,debitAcountNumber,remitterName,remitter_mobile_number,comment,transactionId) if benivalidationCheck.get("responseStatus") == 1: creditorAccountId = benivalidationCheck.get("creditorAccountId") beniValidationData = benivalidationCheck.get("beniValidationData") creditorName = benivalidationCheck.get("creditorName") transactionReferenceNumber = benivalidationCheck.get("transactionReferenceNumber") scorecheck=0.6 if creditorName=="": data_status["result"]="Given Account holder name does not match with the benificiary name." return data_status name_match_response = name_match_check(creditorName,name,scorecheck) if name_match_response.get("responseStatus") == 0: data_status["result"]="Given Account holder name does not match with the benificiary name as "+str(creditorName) return data_status benificiary_account_table = BenificiaryAccounts( userId=userId, creditorAccountNumber=creditorAccountId, ifscCode=ifscCode, creditorName=creditorName, transactionReferenceNumber=transactionReferenceNumber, name=name, bankId=bankId, beniValidationData=beniValidationData, createdOn=datetime.datetime.now(), status=1 ).save() if beneficiaryCharges > 0: merchantDebitAmount = float(merchant_queryset.payoutBalance)-float(beneficiaryCharges) merchant_queryset.update(payoutBalance=merchantDebitAmount) fund_transfer_table = FundTransfers( createdBy=None, userId = str(merchant_queryset.id), amount = amount, grandTotal = beneficiaryCharges, transactionAPIId = payoutPaymentGatewayId, transferType = "Debit", userType = "user", narration = "Beneficiary validation charges for the account holder "+str(creditorName) +" | account number "+str(accountNumber), transactionUniqueId = transactionReferenceNumber, createdOn = datetime.datetime.now(), previousBalance=previousBalance, currentBalance=currentBalance, uniqueRequestNumber = "", beneficiaryName = creditorName, beneficiaryMail = "", beneficiaryPhone = "", accountIFSCCode = ifscCode, fundTransferType = "user", accountType = "", accountNumber = accountNumber, paymentMode = "wallet", bankBranch = "", bankName = bankName, errorMessage = "Beneficiary validation charges for the account holder "+str(creditorName) +" | account number "+str(accountNumber), internalId = "", pgOrderId = "", apiType = "api", merchantReferenceNumber = merchantReferenceNumber, commissionCharges = commissionCharges, status = 1 ) save_table = fund_transfer_table.save() data_status["responseStatus"] = 1 data_status["result"] = "Beneficiary created successfully!" return data_status else: data_status["result"]=benivalidationCheck.get("message") return data_status else: data_status["result"]="Required fields are missing!!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "unable to create beneficiary data!!" return data_status @users.route("/view_all_benificiaries",methods=["POST"]) @user_required def view_all_benificiaries(): data_status = {"responseStatus": 0, "result": ""} userId = request.json.get("userId","") if not userId: data_status["result"] = "Required fields are missing!!" return data_status try: user_queryset = Users.objects(id=userId,status=1).first() if not user_queryset: data_status["result"]="Invalid user id!!" return data_status benificiariesList = [] beneficiary_accounts_queryset = BenificiaryAccounts.objects(userId=userId,status=1).order_by("-id") for each_benificary in beneficiary_accounts_queryset: beneficiaryDict = { "id":str(each_benificary.id), "userId":str(each_benificary.userId.id), "creditorAccountNumber":each_benificary.creditorAccountNumber, "creditorName":each_benificary.creditorName, "ifscCode":each_benificary.ifscCode, "name":each_benificary.name, "transactionReferenceNumber":each_benificary.transactionReferenceNumber, "createdOn":each_benificary.createdOn, "userName":each_benificary.userId.fullName } if each_benificary.bankId: beneficiaryDict["bankId"]=str(each_benificary.bankId.id) beneficiaryDict["bankName"]=each_benificary.bankId.bankName else: beneficiaryDict["bankId"]="" beneficiaryDict["bankName"]="" benificiariesList.append(beneficiaryDict) data_status["responseStatus"] = 1 data_status["result"] = "Beneficiaries data fetched successfully!" data_status["benificiariesList"]=benificiariesList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to fetch beneficiary data!!" return data_status def fundtransfer_parse_date(date_str): """ Parse date from string in format 'DD-MM-YYYY' or as an Excel serial date. """ try: # Try to parse as 'DD-MM-YYYY' parsed_date = datetime.datetime.strptime(date_str, '%d-%m-%Y %H:%M') return parsed_date except ValueError as e: app.logger.error(f"Failed to parse date '{date_str}' as 'DD-MM-YYYY': {e}") try: # Try to parse as Excel serial date excel_date = int(date_str) start_date = datetime.datetime(1899, 12, 30) # Excel epoch date delta = datetime.timedelta(days=excel_date) parsed_date = start_date + delta return parsed_date except ValueError as e: app.logger.error(f"Failed to parse date '{date_str}' as Excel serial date: {e}") pass @users.route("/bulkfundtransfer",methods=["POST"]) def bulkfundtransfer(): data_status = {"responseStatus":0,"result":""} if SERVER_STATUS == "DOWN": data_status["result"]= SERVER_MAINTAINCE_MESSAGE return data_status paymentgatewayresponseDict = {} userId = request.form.get("userId","") upload_csv_file = request.files.get("upload_csv_file") # Extracting client IP address if request.headers.getlist("X-Forwarded-For"): client_ip = request.headers.getlist("X-Forwarded-For")[0] else: client_ip = request.remote_addr try: if userId and upload_csv_file: merchant_queryset = Users.objects(id=userId,status=1).first() if not merchant_queryset: data_status["result"]="Invalid merchant id!!" return data_status check_kyc_status = merchant_kyc_status(str(merchant_queryset.id)) if check_kyc_status.get("responseStatus") != 1: data_status["result"]="Merchant KYC is not completed please contact to admin!!" return data_status kycStatus = check_kyc_status.get("merchantKycDetails", {}).get("kycStatus") if kycStatus == False: data_status["result"]="Merchant KYC is not completed please contact to admin!!" return data_status userId = str(merchant_queryset.id) try: if not merchant_queryset.patternId.payoutPaymentGatewayId: data_status["result"] = "Payout option is disabled please contact to admin!!" return data_status except Exception as e: data_status["result"] = "Payout option is disabled please contact to admin!!" return data_status payOutPaymentGatewayId = str(merchant_queryset.patternId.payoutPaymentGatewayId.id) payout_gate_way_queryset = TransactionAPI.objects(id=payOutPaymentGatewayId,status=1).first() if not payout_gate_way_queryset: data_status["result"]="Payout option is disabled please contact to admin!!" return data_status merchantUniqueNumber=str(merchant_queryset.merchantUniqueNumber) mid_extracted = merchantUniqueNumber[1:].lstrip("0") total_amount = 0 total_transaction_amount = 0 total_txn_count = 0 merchant_ref_numbers = set() transactionId=random_digit_generate(16) errorList = [] seen_merchant_ref_numbers = () # Read the file content file_content = upload_csv_file.read().decode('utf-8') # Use StringIO to read the string as a file object csvfile = StringIO(file_content) csvreader = csv.DictReader(csvfile) print(csvreader,"(((((((((((((csvreader)))))))))))))") bulkTransferList = [] for each_row in csvreader: print(each_row,"(((((((EACH ROW)))))))") req_bank_name=each_row.get("beneBankName") req_merchant_reference_number=each_row.get("Customer Ref no.") req_account_number=each_row.get("Beneficary Accunt no.") req_ifsc_code=each_row.get("IFSC code") req_account_name=each_row.get("Beneficary Name") req_amount=each_row.get("Amount") req_customer_email=each_row.get("Beneficary email id") req_customer_phone=each_row.get("Beneficiary mobile no.") req_transfer_type=each_row.get("Payment Type") req_remark=each_row.get("Remarks") req_bene_code=each_row.get("BENE_ID") total_amount=total_amount + float(req_amount) total_txn_count = total_txn_count + 1 clientOrderId = transaction_id_prefix + mid_extracted + str(get_epoch_milli_time()) amount = req_amount print(req_bene_code,"((((((((((req_bene_code))))))))))") if req_bene_code: benecode = Beneficiaries.objects(beneficiaryId=req_bene_code).first() if req_transfer_type not in ["NEFT","RTGS","IMPS"]: errorList.append("transfer should be ones in ['NEFT','RTGS','IMPS'] " +req_account_number) if req_merchant_reference_number in seen_merchant_ref_numbers: errorList.append("Two or more transactions have same Reference Number for Account Number" +req_account_number) merchant_ref_numbers.add(req_merchant_reference_number) checkorder_queryset = FundTransfers.objects(merchantReferenceNumber=req_merchant_reference_number,userId=str(userId)).first() if checkorder_queryset: errorList.append("Duplicate Merchant Reference Number for Account Number "+req_account_number) if len(req_account_number) < 11 and len(req_account_number) > 15: errorList.append("Invalid length for Account number for " +req_account_number) if len(req_ifsc_code) != 11: errorList.append("Invalid length for IFSC code for "+ req_account_number) check_transaction_limits = merchant_transaction_limit_settings("Payout",payOutPaymentGatewayId,userId,amount) if check_transaction_limits.get("responseStatus") == 0: errorList.append(check_transaction_limits.get("result")+req_account_number) ###################################################### Slab Calculation for payout code ########################################################### payment_mode_queryset = PaymentMode.objects(paymentMode=req_transfer_type).first() if not payment_mode_queryset: errorList.append(check_transaction_limits.get("result"),req_account_number) return data_status paymentModeId = str(payment_mode_queryset.id) sub_payment_mode_queryset = SubPaymentModes.objects(paymentModeId=paymentModeId,subPaymentModeType=req_transfer_type).first() subPaymentModeId = str(sub_payment_mode_queryset.id) patternId = str(merchant_queryset.patternId.id) commissionCharges={} commissionCharges = slab_calculation_for_payout_merchant(amount,paymentModeId,subPaymentModeId,patternId) if commissionCharges.get("slabId") == None: slabId = None transactionAmount = amount else: slabId = commissionCharges.get("slabId") transactionAmount = float(commissionCharges.get("transactionAmount")) total_transaction_amount=total_transaction_amount+float(transactionAmount) #################################################################################################################################################### bulkTransferDict = { "txnPaymode":req_transfer_type, "merchant_reference_number":req_merchant_reference_number, "amount":req_amount, "beneficiaryName":req_account_name, "beneCode":req_bene_code, "beneAccNum":req_account_number, "accountIFSCCode":req_ifsc_code, "commissionCharges":commissionCharges, "grandTotal":transactionAmount, "pgOrderId":clientOrderId } bulkTransferList.append(bulkTransferDict) print(bulkTransferList,"(((((((((((bulkTransferList)))))))))))") fund_transfer_table = BulkFundTransfers( userId = str(merchant_queryset.id), BulkTransactionId = transactionId, BatchNumber = 0, BulkCsvFileUpload = "", status = 2, totalAmount = total_amount, totalTransactionAmount = total_transaction_amount, totalTransactionCount = total_txn_count, clientRequestData = bulkTransferList, requestData = bulkTransferList, responseData = [], errorMessage = errorList, ErrorType = "", # "ApiProvider" or "Internal" createdOn = datetime.datetime.now(), ) save_table = fund_transfer_table.save() BulkTransferId = str(save_table.id) if len(errorList) > 0: data_status['result']="Required Fields are missing!!" data_status['errors']=errorList fund_transfer_table.errorMessage = errorList fund_transfer_table.ErrorType = "Internal" fund_transfer_table.status = 0 fund_transfer_table.save(update_fields=["errorMessage", "ErrorType", "status"]) return data_status # checkamount = float(decryptResponse.get("amount")) checkamount = total_amount ## taking total amount here if checkamount <= 0: data_status['result']="Transaction amount is insufficient!!" fund_transfer_table.errorMessage = ["Transaction amount is insufficient!!"] fund_transfer_table.ErrorType = "Internal" fund_transfer_table.status = 0 fund_transfer_table.save(update_fields=["errorMessage", "ErrorType", "status"]) return data_status check_transaction_limits = merchant_transaction_limit_settings("Payout",payOutPaymentGatewayId,userId,total_amount,"bulk") if check_transaction_limits.get("responseStatus") == 0: data_status['result']=check_transaction_limits.get("result") fund_transfer_table.errorMessage = [check_transaction_limits.get("result")] fund_transfer_table.ErrorType = "Internal" fund_transfer_table.status = 0 fund_transfer_table.save(update_fields=["errorMessage", "ErrorType", "status"]) return data_status try: payout_balance_queryset = PayoutBalances.objects(userId=userId,transactionAPIId=payOutPaymentGatewayId).first() if payout_balance_queryset.currentBalance: userPayoutBalance = payout_balance_queryset.currentBalance else: userPayoutBalance = 0 except Exception as e: userPayoutBalance = 0 if float(userPayoutBalance) < float(total_amount + float(merchant_queryset.capBalance)): insufficient_table = InsufficientBalanceLogs( userId=userId, orderId=transactionId, # id generated in our side for bulk orderAmount=total_amount, walletAmount=float(merchant_queryset.payoutBalance), createdOn=datetime.datetime.now(), status=1 ).save() data_status["result"]="Insufficient balance!!" fund_transfer_table.errorMessage = ["Insufficient balance!!"] fund_transfer_table.ErrorType = "Internal" fund_transfer_table.status = 0 fund_transfer_table.save(update_fields=["errorMessage", "ErrorType", "status"]) return data_status if float(merchant_queryset.payoutBalance) < float(total_amount + float(merchant_queryset.capBalance)): insufficient_table = InsufficientBalanceLogs( userId=userId, orderId=transactionId, # id generated in our side for bulk orderAmount=total_amount, walletAmount=float(merchant_queryset.payoutBalance), createdOn=datetime.datetime.now(), status=1 ).save() data_status["result"]="Insufficient balance!!" fund_transfer_table.errorMessage = ["Insufficient balance!!"] fund_transfer_table.ErrorType = "Internal" fund_transfer_table.status = 0 fund_transfer_table.save(update_fields=["errorMessage", "ErrorType", "status"]) return data_status totalCapBalance = float(merchant_queryset.capBalance) + float(total_amount) merchant_queryset.update(capBalance=totalCapBalance) if payout_gate_way_queryset.code == "Axis_Payout": client_id = "" client_secret = "" get_api_key="" channelId="" serviceRequestId="" corpCode="" serviceRequestVersion="" get_base_url="" corp_account_number="" for each_key in payout_gate_way_queryset.paramsList: get_key = each_key.get("key") if get_key=="client_id": client_id=each_key.get("value") if get_key=="client_secret": client_secret=each_key.get("value") if get_key=="encryption_key": get_api_key=each_key.get("value") if get_key=="channel_id": channelId=each_key.get("value") if get_key=="service_request_id": serviceRequestId=each_key.get("value") if get_key=="service_request_version": serviceRequestVersion=each_key.get("value") if get_key=="corp_code": corpCode=each_key.get("value") if get_key=="get_base_url": get_base_url=each_key.get("value") if get_key=="corp_account_number": corp_account_number=each_key.get("value") requestUUID = str(random_alphanumeric_generate(15)) ########################################################## Axis Payout Fundtransfer Functionality Code ####################################################### paymentgatewayresponseDict = axis_payout_bulk_fundtransfer(client_id,client_secret,get_api_key,channelId,get_base_url,requestUUID,serviceRequestId,serviceRequestVersion,corpCode,corp_account_number,bulkTransferList,bulk_transactionId=transactionId) ################################################################################################################################################################ else: data_status["result"]="Please contact to admin to enable payout option!!" return data_status bulkResponseData = [] if paymentgatewayresponseDict.get("responseStatus") == 1: if paymentgatewayresponseDict.get("bank_reference_number"): bank_reference_number = paymentgatewayresponseDict.get("bank_reference_number") else: bank_reference_number = "" transactionData = paymentgatewayresponseDict.get("transactionData") latest_bulk_fund_transfer_queryset = BulkFundTransfers.objects(id=BulkTransferId).first() for each_bulk_record in latest_bulk_fund_transfer_queryset.requestData: balanceResult=user_payout_balance_update(str(merchant_queryset.id),float(each_bulk_record.get("grandTotal")),"Debit",str(payOutPaymentGatewayId)) if balanceResult.get('responseStatus')==0: data_status["result"]="Insufficient balance!!" return data_status totalCapBalance = float(merchant_queryset.capBalance) - float(total_amount) merchant_queryset.update(capBalance=totalCapBalance) fund_transfer_table = FundTransfers( userId=str(merchant_queryset.id), transactionAPIId=payOutPaymentGatewayId, bankId=None, bankName=None, merchantReferenceNumber=each_bulk_record.get("merchant_reference_number"), pgOrderId=each_bulk_record.get("pgOrderId"), ### pgorderId starting with GP fundTransferType="bulk", accountType="bank", apiType="api", slabId=slabId, transferType="Debit", bankBranch=None, accountNumber=each_bulk_record.get("beneAccNum"), accountIFSCCode=each_bulk_record.get("accountIFSCCode"), beneficiaryName=each_bulk_record.get("beneficiaryName"), uniqueRequestNumber=None, amount=round(float(each_bulk_record.get("amount")),2), grandTotal=round(float(each_bulk_record.get("grandTotal")),2), previousBalance = round(float(balanceResult.get('userPreviousBalance')),2), currentBalance = round(float(balanceResult.get('userCurrentBalance')),2), beneficiaryMail=None, beneficiaryPhone=None, paymentMode=each_bulk_record.get("txnPaymode"), narration="", createdOn=datetime.datetime.now(), userType="user", status=2, clientIp=client_ip, transactionUniqueId = "", statusCheckId=each_bulk_record.get("pgOrderId"), commissionCharges=each_bulk_record.get("commissionCharges") ) save_table = fund_transfer_table.save() instantTransferId = str(save_table.id) responseDict = { "status":"Processing", "merchant_reference_number":each_bulk_record.get("merchant_reference_number"), "account_name":each_bulk_record.get('beneficiaryName'), "amount":each_bulk_record.get('amount'), "account_number":each_bulk_record.get('beneAccNum'), "ifsc_code":each_bulk_record.get('beneAccNum'), "bank_reference_number":bank_reference_number, "transfer_type":each_bulk_record.get('txnPaymode') } bulkResponseData.append(responseDict) data_status["responseStatus"]=1 data_status["result"]="Success" data_status["bulkResponseData"]=bulkResponseData return data_status else: data_status["responseStatus"]=paymentgatewayresponseDict.get("responseStatus") data_status["result"]=paymentgatewayresponseDict.get("result") return data_status else: data_status["result"]="Required fields are missing!!" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to upload csv transfer payout data!!" return data_status @users.route("/add_utility_transaction",methods=["POST"]) def add_utility_transaction(): data_status = {"responseStatus": 0, "result": ""} print(request.json,"add_utility_transaction") userId = request.json.get("userId","") categoryId = request.json.get("categoryId",None) serviceId = request.json.get("serviceId",None) operatorId = request.json.get("operatorId",None) transactionAPIId = request.json.get("transactionAPIId",None) billPayment = request.json.get("billPayment",0) payload = request.json.get("payload",'') headers = request.json.get("headers",'') mobileNumber = request.json.get("mobileNumber","") categoryName = request.json.get("categoryName","") serviceName = request.json.get("serviceName","") operatorName = request.json.get("operatorName","") amount = request.json.get("amount") operatorReference = request.json.get("operatorReference","") errorMessage = request.json.get("errorMessage","") status = request.json.get("status") customeParamsList = request.json.get("customeParamsList",{}) if categoryName and serviceName and operatorName and mobileNumber and amount and operatorId and transactionAPIId: try: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"] = "Invalid user Id" return data_status merchantUniqueNumber = str(user_queryset.merchantUniqueNumber) mid_extracted = merchantUniqueNumber[1:].lstrip("0") transactionId = transaction_id_prefix + str(mid_extracted) +str( get_epoch_milli_time()) commissionCharges = {} chargeAmount = 0.0 commissionDictResult=operator_based_commission_details(userId,operatorId,transactionAPIId) if commissionDictResult.get('responseStatus')==1: commissionDict=commissionDictResult.get('commissionDict') if commissionDict: if commissionDict.get("chargeType") == "Percentage": chargeAmount = (float(amount)*float(commissionDict.get("chargeValue")))/100 elif commissionDict.get("chargeType") == "Fixed": chargeAmount = float(commissionDict.get("chargeValue")) if commissionDict.get("commissionType") == "Percentage": commissionAmount = (float(amount)*float(commissionDict.get("commissionValue")))/100 elif commissionDict.get("commissionType") == "Fixed": commissionAmount = float(commissionDict.get("commissionValue")) commissionCharges = { "chargeType": commissionDict.get("chargeType"), "chargeValue": commissionDict.get("chargeValue"), "commissionType": commissionDict.get("commissionType"), "commissionValue": commissionDict.get("commissionValue"), "chargeAmount": chargeAmount, "commissionAmount": commissionAmount } #Calulate total amount # // billPaymentRequestData=[] # // billPaymentResponseData=[] totalAmount = float(amount) - float(chargeAmount) transaction_table = Transactions( userId = userId, categoryId = categoryId, serviceId = serviceId, operatorId = operatorId, categoryName = categoryName, serviceName = serviceName, operatorName = operatorName, # // paymentType = paymentType, # // paymentCategory = paymentCategory, # // cardNumber = cardNumber, # // customerVpa = customerVpa, # // walletName = walletName, # // accountNumber = accountNumber, # // ifscCode = ifscCode, customeParamsList = customeParamsList, # // paymentGatewayId = paymentGatewayId, transactionAPIId = transactionAPIId, transactionId = str(transactionId), # // transactionData = transactionData, billPayment = str(billPayment), # // billPaymentRequestData = billPaymentRequestData, # // billPaymentResponseData = billPaymentResponseData, mobileNumber = mobileNumber, amount = amount, totalAmount = totalAmount, commissionCharges = commissionCharges, operatorReference = operatorReference, createdOn = datetime.datetime.now(), errorMessage=errorMessage, payload=payload, headers= headers, status = 2 ).save() transactionTableId = str(transaction_table.id) if transactionTableId: data_status["id"] = transactionId data_status["responseStatus"] = 1 data_status["result"] = "Record Created successfully" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to make transaction" return data_status else: data_status['result'] = "Required fields are missing" return data_status ##business pan api check is not enabled in signzy @users.route("/validate_pan_number_and_name",methods=["POST"]) def validate_pan_number_and_name(): data_status = {"responseStatus": 0, "result": ""} try: panNumber = request.json.get("panNumber") nameOnPan = request.json.get("nameOnPan") userId = request.json.get("userId") if panNumber and nameOnPan and userId: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"] = "Invalid user Id" return data_status panKycResponseStatusDict=verify_individual_pan(panNumber) if panKycResponseStatusDict.get("responseStatus") == 1: if panKycResponseStatusDict.get("panStatus").lower() == "valid": scorecheck=0.8 name_match_response = name_match_check(panKycResponseStatusDict.get("name"),nameOnPan,scorecheck) if name_match_response.get("responseStatus") == 1: data_status["responseStatus"] = 1 data_status["OriginalBusinessPanName"] = str(panKycResponseStatusDict.get("name")) data_status["panAddress"] = str(panKycResponseStatusDict.get("address")) data_status["panResponseData"] = str(panKycResponseStatusDict.get("responseData")) data_status["result"] ="success" else: data_status["result"] ="Given Name did not match with Pan Name" else: data_status["result"] = "pan verification failed" else: data_status["result"] = "pan verification failed" return data_status else: data_status["result"]="Required field is missing!!" return data_status except Exception as e: print(traceback.format_exc()) data_status["result"] = "Unable to verify Pan." return data_status ##business pan api check is not enabled in signzy @users.route("/validate_bank_account",methods=["POST"]) def validate_bank_account(): data_status = {"responseStatus": 0, "result": ""} try: accountNumber = request.json.get("accountNumber") ifscCode = request.json.get("ifscCode") userId = request.json.get("userId") if accountNumber and userId and ifscCode: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"] = "Invalid user Id" return data_status accountHolderName=str(user_queryset.fullName) mobileNumber=str(user_queryset.phoneNumber) bankStatusDict=verify_bank_account(accountNumber,ifscCode,accountHolderName,mobileNumber) print(bankStatusDict,"bankStatusDict") if bankStatusDict.get("responseStatus") == 1: if bankStatusDict.get("nameMatch")=="": print("if name") scorecheck=0.8 name_match_response = name_match_check(bankStatusDict.get("beneficiaryName"),accountHolderName,scorecheck) print(name_match_response,"name_match_response") if name_match_response.get("responseStatus") == 1: data_status["responseStatus"] = 1 data_status["OriginalBankHolderName"] = str(bankStatusDict.get("beneficiaryName")) data_status["bankResponseData"] = str(bankStatusDict.get("apiResponse")) data_status["result"] ="success" else: data_status["result"] = "Given Account Number Name does not match with registered Name" elif bankStatusDict.get("nameMatch").lower() == "yes": print("else name") data_status["responseStatus"] = 1 data_status["OriginalBankHolderName"] = str(bankStatusDict.get("beneficiaryName")) data_status["bankResponseData"] = str(bankStatusDict.get("apiResponse")) data_status["result"] ="success" else: data_status["result"] = "Given Account Number Name does not match with registered Name" else: data_status["result"] = bankStatusDict.get('result') return data_status else: data_status["result"]="Required field is missing!!" return data_status except Exception as e: print(traceback.format_exc()) data_status["result"] = "Unable to verify Pan." return data_status #business pan api check is not enabled in signzy @users.route("/validate_aadhar_number",methods=["POST"]) def validate_aadhar_number(): data_status = {"responseStatus": 0, "result": ""} try: userId = request.json.get("userId") aadhaar_number = request.json.get("aadharNumber") aadhaar_name = request.json.get("aadharName") if aadhaar_name and userId and aadhaar_number: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"] = "Invalid user Id" return data_status aadharMobileResponse=verify_aadhar_number(aadhaar_number,aadhaar_name,"Aadhar") if aadharMobileResponse.get('responseStatus')==0 or aadharMobileResponse.get('mobileNumber')=="": data_status["result"]="Something went wrong.Please try again." return data_status mobileNumber=str(user_queryset.phoneNumber) mobileNumberlast3digits=mobileNumber[-3:] aadharMobileNumber=aadharMobileResponse.get('mobileNumber') aadharmobileNumberlast3digits=aadharMobileNumber[-3:] if aadharMobileNumber=="" or mobileNumberlast3digits!=aadharmobileNumberlast3digits: data_status["result"]="Aadhar registered mobile number not matched with registered mobile number" return data_status if aadharMobileResponse.get('responseStatus')==1: data_status["responseStatus"] = 1 data_status["otpenabled"] = aadharMobileResponse.get('otpenabled') data_status["kycApiId"] = aadharMobileResponse.get('kycApiId') data_status["accessKey"] = aadharMobileResponse.get('accessKey') data_status["aadharResponseData"] = str(aadharMobileResponse.get('aadharResponseData')) data_status["result"] ="Aadhar verified successfully." return data_status else: data_status["result"] = "aadhar verification failed." return data_status else: data_status["result"]="Required field is missing!!" return data_status except Exception as e: print(traceback.format_exc()) data_status["result"] = "Unable to verify Aadhar number." return data_status #business pan api check is not enabled in signzy @users.route("/validate_aadhar_number_otp",methods=["POST"]) def validate_aadhar_number_otp(): data_status = {"responseStatus": 0, "result": ""} try: userId = request.json.get("userId") aadhaar_number = request.json.get("aadharNumber") aadhaar_name = request.json.get("aadharName") accessKey = request.json.get("accessKey") otpCode = request.json.get("otpCode") kycApiId = request.json.get("kycApiId") if aadhaar_name and userId and aadhaar_number and otpCode and kycApiId: user_queryset = Users.objects(id=userId,status__in=[1]).first() if not user_queryset: data_status["result"] = "Invalid user Id" return data_status verifyresponse=verify_aadhar_otp(aadhaar_number,aadhaar_name,accessKey,otpCode,kycApiId) if verifyresponse.get('responseStatus')==1: data_status["responseStatus"] = 1 data_status["aadharResponseData"] = str(verifyresponse.get('aadharResponseData')) data_status["result"] ="Otp verified successfully." return data_status else: data_status["result"] = "Incorrect Otp." return data_status else: data_status["result"]="Required field is missing!!" return data_status except Exception as e: print(traceback.format_exc()) data_status["result"] = "Incorrect Otp." return data_status @users.route("/graampay_health_check", methods=["GET"]) def graampay_health_check(): healthCheckDict = {} overall_health = "red" # Default to red try: if request.method == "GET": countries_queryset = Countries.objects(status=1) if countries_queryset: healthCheckDict = {"database": True} else: healthCheckDict = {"database": False} idfc_api_queryset = TransactionAPI.objects(code="Idfc_Payout").first() if idfc_api_queryset: client_id = "" secretKey = "" kid = "" get_base_url = "" aud_url = "" auth_url = "" grant_type = "" scope = "" source = "" client_assertion_type = "" debitAcountNumber = "" remitterName = "" for each_key in idfc_api_queryset.paramsList: get_key = each_key.get("key") if get_key == "client_id": client_id = each_key.get("value").strip() if get_key == "secret_key": secretKey = each_key.get("value").strip() if get_key == "base_url": get_base_url = each_key.get("value").strip() if get_key == "kid": kid = each_key.get("value").strip() if get_key == "aud_url": aud_url = each_key.get("value").strip() if get_key == "auth_url": auth_url = each_key.get("value").strip() if get_key == "scope": scope = each_key.get("value").strip() if get_key == "grant_type": grant_type = each_key.get("value").strip() if get_key == "source": source = each_key.get("value").strip() if get_key == "client_assertion_type": client_assertion_type = each_key.get("value").strip() if get_key == "debit_acount_number": debitAcountNumber = each_key.get("value").strip() if get_key == "remitter_name": remitterName = each_key.get("value").strip() currentBalanceDict = idfc_get_payout_account_balance(debitAcountNumber,source,kid,aud_url,client_id,auth_url,grant_type,scope,client_assertion_type,secretKey) if currentBalanceDict.get("responseStatus") == 1: availableBalance = currentBalanceDict.get("availableBalance") healthCheckDict.update({"idfcStatus": True}) else: healthCheckDict.update({"idfcStatus": False}) else: healthCheckDict.update({"idfcStatus": False}) axis_api_queryset = TransactionAPI.objects(code="Axis_Payout").first() if axis_api_queryset: client_id = "" client_secret = "" get_api_key="" channelId="" serviceRequestId="" corpCode="" serviceRequestVersion="" get_base_url="" corp_account_number="" for each_key in axis_api_queryset.paramsList: get_key = each_key.get("key") if get_key=="client_id": client_id=each_key.get("value") if get_key=="client_secret": client_secret=each_key.get("value") if get_key=="encryption_key": get_api_key=each_key.get("value") if get_key=="channel_id": channelId=each_key.get("value") if get_key=="service_request_id": serviceRequestId=each_key.get("value") if get_key=="service_request_version": serviceRequestVersion=each_key.get("value") if get_key=="corp_code": corpCode=each_key.get("value") if get_key=="get_base_url": get_base_url=each_key.get("value") if get_key=="corp_account_number": corp_account_number=each_key.get("value") requestUUID = str(random_digit_generate(15)) currentBalanceDict = axis_payout_get_account_balance(client_id, client_secret, get_api_key, channelId, get_base_url, requestUUID, serviceRequestId, serviceRequestVersion, corpCode,corp_account_number) if currentBalanceDict.get("responseStatus") == 1: availableBalance = currentBalanceDict.get("availableBalance") healthCheckDict.update({"axisStatus": True}) else: healthCheckDict.update({"axisStatus": False}) else: healthCheckDict.update({"axisStatus": False}) print(healthCheckDict,"((((((((healthCheckDict))))))))") # Determine overall health status if all(healthCheckDict.values()): overall_health = "green" elif any(healthCheckDict.values()): overall_health = "orange" return render_template( "frontend/health_check.html", healthCheckDict=healthCheckDict, overall_health=overall_health, ) except Exception as e: app.logger.error(traceback.format_exc()) error = "Unable to get health check data!!" return render_template( "frontend/health_check.html", error=error, healthCheckDict=healthCheckDict, overall_health="red", ) def is_fancy_number(num): """Check if a number is a fancy number (repeated digits or strict sequential patterns).""" str_num = str(num) # Check for repeated digits (e.g., 111, 222) if len(set(str_num)) == 1: return True # Check for patterns like 121 (two unique digits with a repeat) for digit in set(str_num): count = str_num.count(digit) if count >= 3: # Handle clusters like 111, 11666 return True if count >= len(str_num) - 1: # Handle patterns like 121, 1122 return True # Check for strict sequential patterns (e.g., 123, 456, 987) if "".join(sorted(str_num)) in "0123456789" or "".join(sorted(str_num, reverse=True)) in "9876543210": return True return False # def generate_random_prices(target,loop_count=4,start=None, end=None, step=1): # """ # Generate a random number from a dynamic range while excluding: # - Rounded numbers (e.g., multiples of 10) # - Fancy numbers (repeated digits, sequential patterns). # """ # if target < 10: # return [target] # # Define the range dynamically based on the magnitude of the target # if start is None or end is None: # # Adjust the range to ±x% of the target, ensuring a minimum range of 3 for very small targets # delta = max(5, abs(target) * 2 // 100) # start = target - delta if start is None else start # end = target + delta if end is None else end # start=int(start) # end=int(end) # # Generate the range of numbers # numbers = range(start, end + 1, step) # # Filter out invalid numbers: target, rounded, and fancy numbers # filtered_numbers = [ # x for x in numbers # if x % 10 != 0 and not is_fancy_number(x) # ] # # If no valid numbers remain, return None # if not filtered_numbers: # return None # print(filtered_numbers,"filtered_numbers") # # Pick a random number from the filtered list # return random.sample(filtered_numbers,k=min(int(loop_count), len(filtered_numbers))) def generate_random_prices(target,min_limit=1,max_limit=99995, loop_count=4, start=None, end=None, step=1): """ Generate a random number from a dynamic range while excluding: - Rounded numbers (e.g., multiples of 10) - Fancy numbers (repeated digits, sequential patterns). """ if target < 10: return [target] # Define the range dynamically based on the magnitude of the target if start is None or end is None: delta = max(15, abs(target)*0.5 // 100) start = target - delta if start is None else start end = target + delta if end is None else end if float(min_limit)>float(start): start=min_limit start = int(start) if float(max_limit)",methods=["GET"]) def payupayment_dynamic_link(walletId): data_status = {"responseStatus": 0, "result": ""} # walletId = request.json.get("walletId") if not walletId: data_status["result"] = "Required fields are missing!!" try: wallet_query_set = WalletTransactions.objects(id=ObjectId(walletId),status__in=[3]).first() if wallet_query_set: paymentGatewayId = wallet_query_set.paymentGatewayId if paymentGatewayId.code == "Payu_Payin": key = "" salt = "" get_base_url = "" surl = "" furl = "" for each_key in paymentGatewayId.paramsList: get_key = each_key.get("key") if get_key == "api_key": key = each_key.get("value") if get_key == "salt": salt = each_key.get("value") if get_key == "dynamic_base_url": get_base_url = each_key.get("value") if get_key == "surl": surl = each_key.get("value") if get_key == "furl": furl = each_key.get("value") txnid = wallet_query_set.pgOrderId paymentMode = wallet_query_set.paymentType productinfo = wallet_query_set.productName amount = wallet_query_set.amount email = wallet_query_set.customerEmail firstname = wallet_query_set.customerName phone = wallet_query_set.customerPhonenumber vpa="" ccnum="" ccname="" ccvv="" ccexpmon="" ccexpyr="" bankCode="" cardType="" if paymentMode=="UPI": vpa = wallet_query_set.customerVpa elif paymentMode=="NET BANKING": bankCode = wallet_query_set.bankCode else: paymentDetailsEncrypted = wallet_query_set.paymentDetails if paymentDetailsEncrypted!="": paymentDetails=combined_decrypt(paymentDetailsEncrypted,encSecretKey) paymentDetails=json.loads(paymentDetails) ccnum = paymentDetails.get("cardNum") ccname = paymentDetails.get("customerName") ccvv = paymentDetails.get("cardCvv") ccexpmon = paymentDetails.get("cardExpMonth") ccexpyr = paymentDetails.get("cardExpYear") cardType = paymentDetails.get("cardType") testresponse = payupayment_dynamic(paymentMode=paymentMode, get_salt=salt,get_base_url=get_base_url, key= key, txnid=txnid, productinfo=productinfo,amount=amount,email=email,firstname=firstname,surl=surl,furl=furl, phone=phone,ccnum=ccnum,ccname=ccname, ccvv=ccvv, ccexpmon=ccexpmon, ccexpyr=ccexpyr, vpa=vpa, bankCode=bankCode, card_type=cardType ) return testresponse else: data_status["result"] = "Invalid transaction Id" return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "unable to test payu payment" return data_status def payupayment_dynamic(paymentMode ,get_salt,get_base_url, key,txnid,productinfo,amount,email,firstname, surl, furl, phone,ccnum="",ccname="", ccvv="", ccexpmon="", ccexpyr="", vpa="",bankCode="",card_type="",lastname=""): data_status = {"responseStatus": 0, "result": ""} bankKycResponseStatusDict={} if not key and not txnid and not productinfo and not amount and not email and not firstname and not surl and not furl and not phone : data_status["result"] = "Required fields are missing!!" return data_status requestDataDict = { "paymentMode": paymentMode, "get_base_url": get_base_url, "key": key, "txnid": txnid, "productinfo": productinfo, "amount": amount, "email": email, "firstname": firstname, "lastname": "", "surl": surl, "furl": furl, "phone": phone, } hash_value = PayuSha512HashParams(requestDataDict, get_salt) requestDataDict.update({"hash_value": hash_value}) try: print("(((((paymentmode)))))",paymentMode.lower(),paymentMode.lower() == "credit card") print({"paymentMode": paymentMode,"get_salt": get_salt,"get_base_url": get_base_url,"key": key,"txnid": txnid,"productinfo": productinfo,"amount": amount,"email": email,"firstname": firstname,"lastname": lastname,"surl": surl,"furl": furl,"phone": phone,"ccnum": ccnum,"ccname": ccname,"ccvv": ccvv,"ccexpmon": ccexpmon,"ccexpyr": ccexpyr,"vpa": vpa,"bankcode": bankCode}) if paymentMode.lower() == "credit card": print("(((((paymentmodssssssssssssssssssssssssse)))))",paymentMode.lower()) if not ccnum and not ccname and not ccvv and not ccexpmon and not ccexpyr : data_status["result"] = "Required fields are missing for card!!" return data_status enforce_paymethod="creditcard" requestDataDict.update({ "ccnum": ccnum, "ccname": ccname, "ccvv": ccvv, "ccexpmon": ccexpmon, "ccexpyr": ccexpyr, "pg": "CC", "bankcode": card_type }) elif paymentMode.lower() == "debit card": if not ccnum and not ccname and not ccvv and not ccexpmon and not ccexpyr : data_status["result"] = "Required fields are missing for card!!" return data_status enforce_paymethod="debitcard" requestDataDict.update({ "ccnum": ccnum, "ccname": ccname, "ccvv": ccvv, "ccexpmon": ccexpmon, "ccexpyr": ccexpyr, "pg": "DC", "bankcode": card_type }) elif paymentMode.lower() == "upi": if not vpa: data_status["result"] = "Required fields are missing for UPI!!" return data_status enforce_paymethod="UPI" requestDataDict.update({"pg": "UPI","bankcode": "UPI"}) elif paymentMode.lower() == "net banking": if not bankCode: data_status["result"] = "Required fields are missing for Net Banking!!" return data_status enforce_paymethod="netbanking" requestDataDict.update({"pg": "NB","bankcode": bankCode}) else: app.logger.error("Invalid Payment Mode Type ") data_status["result"] = "Invalid Payment Mode Type !!" return data_status requestDataDict.update({"enforce_paymethod": enforce_paymethod}) return render_template("frontend/payupaymenttemplate.html", requestDataDict=requestDataDict) except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"] = "Unable to verify bank detailss!!" return data_status @users.route("/checkekycDemo",methods=["GET"]) def checkekycDemo(): responsedata={"status":0} try: print("entered") url = "https://65.0.63.92/web/sign" payload = { "orgId": "200374"} headers = { "accept": "application/json", "content-type": "application/json" } response = requests.post(url, json=payload, headers=headers, verify=False) print(response.text,"response.text") responsedata=json.loads(response.text) return render_template("frontend/ekycDemo.html", responsedata=responsedata) except Exception as e: app.logger.error(traceback.format_exc()) return render_template("frontend/ekycDemo.html", responsedata=responsedata) @users.route("/banners_list",methods=["POST"]) def banners_list(): data_status = {"responseStatus":0,"result":""} bannersList = [] try: ################# For Banners Data ################## banners_queryset = AdminBanners.objects(status__in=[1]).order_by("sorting").all() for each_banner in banners_queryset: banner_dict={ "id":str(each_banner.id), "name":each_banner.name, "isBanner":each_banner.isBanner, "externalLink":each_banner.externalLink, "status":each_banner.status, "googleScript":each_banner.googleScript } if each_banner.createdOn: banner_dict["createdOn"] = each_banner.createdOn.strftime("%m-%d-%Y") else: banner_dict["createdOn"] = "" if each_banner.image: banner_dict["bannerImage"] = domain+each_banner.image else: banner_dict["bannerImage"] = "" try: if each_banner.isGrievance: banner_dict["isGrievance"]=each_banner.isGrievance else: banner_dict["isGrievance"]=False except Exception as e: banner_dict["isGrievance"]=False bannersList.append(banner_dict) data_status["responseStatus"]=1 data_status["result"]="banners data fetched successfully!" data_status["bannersList"]=bannersList return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Unable to fetch banners data!!" return data_status @users.route("/get_available_timings",methods=["POST"]) def get_available_timings(): data_status = {"responseStatus":0,"result":""} try: userId=request.json.get('userId') transactionType=request.json.get('transactionType') if not userId and not transactionType and transactionType not in ['payout','paymentgateway']: data_status["result"]="Service Provider is not available. Please try after sometime." return data_status user_queryset=Users.objects(id=str(userId),status=1).first() if not user_queryset: data_status["result"]="Service Provider is not available. Please try after sometime." return data_status startDate = datetime.datetime.now() availability_check = check_transaction_availability(startDate, transactionType) if availability_check.get('responseStatus')==0: data_status["result"]="Service Provider is not available. Please try after sometime." return data_status else: data_status["responseStatus"]=1 data_status["result"]="Service Provider is available." return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Service Provider is not available. Please try after sometime." return data_status @users.route("/randomusers",methods=["POST"]) def randomusers(): data_status = {"responseStatus":0,"result":""} try: random_record_qry = RandomCcCustomers.objects.aggregate([{ "$sample": { "size": 1 } }]) # Get a random record random_record=list(random_record_qry)[0] print("random_record",random_record) # full_file_name = app.config['SITE_ROOT']+"/static/randomNames.json" # data=[] # with open(full_file_name, "r") as file: # json_string = file.read() # data = json.loads(json_string) # # for line in file: # # data = json.loads(line) # # print('rowData',data) # # pass # for each_data in data: # save_data=RandomCcCustomers( # customerName=str(each_data.get('fullName')), # customerEmail=str(each_data.get('emailAddress')), # customerPhoneNumber=str(each_data.get('mobileNumber')) # ).save() data_status['responseStatus']=1 data_status['result']=str(random_record.get('customerName')) data_status['resultcount']=len(random_record) return data_status except Exception as e: app.logger.error(traceback.format_exc()) data_status["result"]="Service Provider is not available. Please try after sometime." return data_status