BUY SELL REPEAT 1 SECOND ORDER

TREDING NIFTY SYMBALTOKEN-26000 , BANKNIFTY - SYMBALTOKEN-26009

import numpy as np import datetime from SmartApi import SmartConnect import pyotp from logzero import logger import os import time # Importing time module for sleep # Setup API connection api_key = 'nxsnx' username = 'M767627sn' password = '724656' smartApi = SmartConnect(api_key) # Sample order status status_options = ['pending', 'rejected', 'executed', 'cancelled'] # Orders data structure to store orders orders = {} # Function to generate OTP def generate_otp(token, correlation_id): """ Generates an OTP using the provided token. """ try: otp = pyotp.TOTP(token).now() logger.info(f"[{correlation_id}] Generated OTP: {otp}") return otp except Exception as e: logger.error(f"[{correlation_id}] Invalid Token: The provided token is not valid. Error: {str(e)}") raise e # Function to prepare order parameters for placing a NORMAL order def prepare_order_params(entry_price, lot_size, quantity, correlation_id, status='pending', orderstatus=''): """ Prepares the order parameters for placing both BUY and SELL orders (LIMIT). """ buy_order_params = { "variety": "NORMAL", "tradingsymbol": "NIFTY20MAR2522750CE", "symboltoken": "50205", "transactiontype": "BUY", "instrumenttype": "OPTIDX", "optiontype": "call", "exchange": "NFO", "ordertype": "LIMIT", # Use LIMIT order type instead of STOPLOSS_LIMIT "producttype": "INTRADAY", "duration": "DAY", "orderid": "", "text": "", "status": status, # Dynamic status "orderstatus": orderstatus, # Dynamic order status "price": str(entry_price), "trailingstoploss": "1.50", "quantity": str(quantity) } sell_order_params_1 = { "variety": "STOPLOSS", "tradingsymbol": "NIFTY20MAR2522750CE", "symboltoken": "50205", "transactiontype": "SELL", "instrumenttype": "OPTIDX", "optiontype": "call", "exchange": "NFO", "ordertype": "STOPLOSS_LIMIT", # Use LIMIT order type instead of STOPLOSS_LIMIT "producttype": "INTRADAY", "duration": "DAY", "price": str(entry_price), # Example of selling at an even lower price "triggerprice": str(entry_price), "trailingstoploss": "1.50", "quantity": str(quantity) } logger.info(f"[{correlation_id}] Buy Order Parameters: {buy_order_params}") logger.info(f"[{correlation_id}] Sell Order 1 Parameters: {sell_order_params_1}") return buy_order_params, sell_order_params_1 # Function to place an order def place_order(order_params, correlation_id): """ Places an order using the provided order parameters. """ try: order_id = smartApi.placeOrder(order_params) logger.info(f"[{correlation_id}] Order placed: {order_id}") return order_id # Return the order ID so we can cancel it later except Exception as e: logger.error(f"[{correlation_id}] Failed to place order: {str(e)}") return None # Function to cancel an order def cancel_order(order_id, correlation_id): """ Cancels the order using the provided order ID. """ try: cancel_params = { "variety": "NORMAL", # Always using NORMAL variety "orderid": order_id # The unique order ID to be canceled } response = smartApi.cancelOrder(cancel_params) # Call the cancel order API method if response.get("status", "") == "success": logger.info(f"[{correlation_id}] Order {order_id} successfully cancelled.") else: logger.error(f"[{correlation_id}] Failed to cancel order {order_id}: {response}") except Exception as e: logger.error(f"[{correlation_id}] Failed to cancel order {order_id}: {str(e)}") # Main Logic def main(): correlation_id = "abcde" # Unique identifier for tracking the flow try: # Generate OTP token = os.getenv("OTP_SECRET_TOKEN", "7HJSD65PXNMNMCNNKSJAKS9E8YWGVXMSX,") # Secure OTP token otp = generate_otp(token, correlation_id) # Generate session data session_data = smartApi.generateSession(username, password, otp) # Handle session generation failure if session_data.get('status', False): jwt_token = session_data['data'].get('jwtToken', None) refresh_token = session_data['data'].get('refreshToken', None) if jwt_token and refresh_token: # Fetch feed token feed_token = smartApi.getfeedToken() # Get user profile information profile_response = smartApi.getProfile(refresh_token) smartApi.generateToken(refresh_token) exchanges = profile_response['data']['exchanges'] # Define number of lots and lot size num_lots = 1 lot_size = 75 quantity = num_lots * lot_size # Define dynamic entry price (this can be updated as per market data) entry_price = 21 # Example entry price # Prepare the order parameters (using NORMAL variety) status = 'pending' # This could be dynamic based on user input or other logic orderstatus = 'orderplaced' # This could be dynamic as well buy_order_params, sell_order_params_1 = prepare_order_params(entry_price, lot_size, quantity, correlation_id, status, orderstatus) # Place the BUY order buy_order_id = place_order(buy_order_params, correlation_id) if buy_order_id: logger.info(f"[{correlation_id}] Buy Order placed successfully with ID: {buy_order_id}") # Place the SELL order exactly 10 times with 2 seconds interval for i in range(1): # Place the SELL order sell_order_id_1 = place_order(sell_order_params_1, correlation_id) if sell_order_id_1: logger.info(f"[{correlation_id}] Sell Order {i+1} placed successfully with ID: {sell_order_id_1}") # Wait for 2 seconds before placing the next sell order time.sleep(2) # Ask the user if they want to cancel any of the orders from the terminal cancel_input = input(f"[{correlation_id}] Do you want to cancel any order? (buy/sell1/n): ").strip().lower() if cancel_input == 'buy': cancel_order(buy_order_id, correlation_id) elif cancel_input == 'sell1': cancel_order(sell_order_id_1, correlation_id) else: logger.error(f"[{correlation_id}] Missing JWT or refresh token in session data.") else: logger.error(f"[{correlation_id}] Session generation failed: {session_data}") except Exception as e: logger.exception(f"[{correlation_id}] An error occurred: {e}") # Execute the main logic if __name__ == "__main__": main()

Copied Text: