BBT-Trap-2.1.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "import math\n",
    "from nsepy import get_history\n",
    "import pandas as pd\n",
    "import requests\n",
    "import sys\n",
    "from tvDatafeed import TvDatafeed, Interval\n",
    "tv = TvDatafeed()\n",
    "import talib\n",
    "import socket\n",
    "\n",
    "chat_id_group = \"-1002245236166\" #Group where Telegram will receive updates, had to add that BOT in that group as admin\n",
    "TOKEN = \"7419116752:AAFTGAcg9uuvl_j7andYX_r_kJfmgsxIKCo\"\n",
    "#Suppressing Console Output\n",
    "original_stdout = sys.stdout\n",
    "sys.stdout = None\n",
    "sys.stdout = original_stdout\n",
    "df = pd.read_csv(\"ind_nifty100list.csv\")\n",
    "stocks = df['New Symbol'].unique().tolist() #Sending Output string\n",
    "stocks[12] = 'BAJAJ_AUTO'\n",
    "stocks[62] = 'M_M'\n",
    "# INTERVAL_1_MINUTE = \"1m\", INTERVAL_5_MINUTES = \"5m\", INTERVAL_15_MINUTES = \"15m\", INTERVAL_30_MINUTES = \"30m\", INTERVAL_1_HOUR = \"1h\", INTERVAL_2_HOURS = \"2h\", INTERVAL_4_HOURS = \"4h\", INTERVAL_1_DAY = \"1d\", INTERVAL_1_WEEK = \"1W\", INTERVAL_1_MONTH = \"1M\"\n",
    "values_list = []\n",
    "def sendTeleAlert(message, chat_id):\n",
    " url = f\"https://api.telegram.org/bot{TOKEN}/sendMessage?chat_id={chat_id}&text={message}\"\n",
    " response = requests.get(url)\n",
    "\n",
    "color_dictionary = {(2,3):\"🔴\",(3,4):\"🟡\",(4,50):\"🟢\"}\n",
    "def get_color(num):\n",
    " for num_range, color in color_dictionary.items():\n",
    "  if num_range[0] <= num < num_range[1]:\n",
    "   return color\n",
    "\n",
    "def posSz(entry_price, stoploss, target):\n",
    " try:\n",
    "     posSz = math.floor(abs(float(200 / (entry_price - stoploss))))\n",
    "    #  print(f'Position sizing for Max Loss 200 is {posSz} \\n')\n",
    "     values_list.append(posSz)  # 0\n",
    " except ZeroDivisionError:\n",
    "     print('Position sizing not found as Entry Price equals Stoploss')\n",
    "def riskreward(entry_price, stoploss, target):\n",
    "  try:\n",
    "    num = float(abs(entry_price - target) / abs(entry_price - stoploss))\n",
    "    string = f'1:{num}'\n",
    "    # print(f' The Risk to Reward ratio is {string} \\n')\n",
    "    values_list.append(num) #1\n",
    "  except ZeroDivisionError:\n",
    "    print('Risk Reward not found as Entry Price equals Stoploss')\n",
    "def stocks_calc(entry_price, stoploss, target):\n",
    " total_caps = [45000, 100000] #,60000]\n",
    " for i in range(len(total_caps)):\n",
    "  num_stocks = math.floor(float(total_caps[i]/  entry_price))\n",
    "  total_capital_used = float(entry_price * num_stocks)\n",
    "  targetgains = float(abs(entry_price - target) * num_stocks)\n",
    "  maxloss = float((abs(entry_price - stoploss)) * num_stocks)\n",
    "  values_list.append(num_stocks) #2,6,10\n",
    "  values_list.append(total_capital_used) #3,7,11\n",
    "  values_list.append(targetgains) #4,8,12\n",
    "  values_list.append(maxloss) #5,9,13\n",
    "\n",
    "retries = 3\n",
    "count = 0\n",
    "\n",
    "retries = 5  # Set the number of retries\n",
    "retry_delay = 5  # Delay between retries in seconds\n",
    "\n",
    "while True:  \n",
    " count = 0\n",
    " for n in range(101):\n",
    "     try:\n",
    "         stock_data = tv.get_hist(stocks[n], exchange='NSE', interval=Interval.in_15_minute, n_bars=45)\n",
    "         bbands = talib.BBANDS(stock_data['close'], timeperiod=20, nbdevup=2.0, nbdevdn=2.0, matype=0)\n",
    "         bbands = tuple(series.loc[series.index.date == bbands[0].index[-1].date()] for series in bbands)\n",
    "         stock_data = stock_data[stock_data.index.date == stock_data.index[-1].date()]\n",
    "         \n",
    "         for i in range(len(bbands[0])):\n",
    "             if stock_data.iloc[-i]['low'] > bbands[0].iloc[-i]:  # Sell \n",
    "                 posSz(stock_data.iloc[-i]['low'], stock_data.iloc[-i]['high'], bbands[1].iloc[-i])\n",
    "                 riskreward(stock_data.iloc[-i]['low'], stock_data.iloc[-i]['high'], bbands[1].iloc[-i])\n",
    "                 if values_list[1] < 2:  # Segregating Risk Reward Ratio > 1:2\n",
    "                     continue\n",
    "                 x = get_color(values_list[1])\n",
    "                 stocks_calc(stock_data.iloc[-i]['low'], stock_data.iloc[-i]['high'], bbands[1].iloc[-i])\n",
    "\n",
    "                 message = f\"SELL CASE: {x}{stocks[n]}, Time: {stock_data.index[-i+1]},\\n\\n Entry Price: {stock_data.iloc[-i]['low']}\\n Stoploss: {stock_data.iloc[-i]['high']}\\n Target: {bbands[1].iloc[-i]}\\n Risk-Reward is 1:{values_list[1]} \\n\\n Position Sizing is {values_list[0]} stocks for Max Loss of 200 and corresponding Total Capital is {stock_data.iloc[-i]['low']*values_list[0]} with Target Gains of {values_list[0]*(stock_data.iloc[-i]['low']-bbands[1].iloc[-i])} \\n\\n Total Capital Used is {values_list[3]} \\n Number of stocks is {values_list[2]} \\n Target Gains = {values_list[4]} \\n Max Loss is = {values_list[2]*(stock_data.iloc[-i]['low'] - stock_data.iloc[-i]['high'])}\\n\\n\"\n",
    "                 print(message)\n",
    "                 sendTeleAlert(message, chat_id_group)\n",
    "                 count += 1\n",
    "\n",
    "             elif stock_data.iloc[-i]['high'] < bbands[2].iloc[-i]:  # Buy  \n",
    "                 posSz(stock_data.iloc[-i]['high'], stock_data.iloc[-i]['low'], bbands[1].iloc[-i])\n",
    "                 riskreward(stock_data.iloc[-i]['high'], stock_data.iloc[-i]['low'], bbands[1].iloc[-i])\n",
    "                 if values_list[1] < 2:  # Segregating Risk Reward Ratio > 1:2\n",
    "                     continue\n",
    "                 x = get_color(values_list[1])\n",
    "                 stocks_calc(stock_data.iloc[-i]['high'], stock_data.iloc[-i]['low'], bbands[1].iloc[-i])\n",
    "\n",
    "                 message = f\"BUY CASE: {x}{stocks[n]}, Time: {stock_data.index[-i+1]},\\n\\n Entry Price: {stock_data.iloc[-i]['high']}\\n Stoploss: {stock_data.iloc[-i]['low']}\\n Target: {bbands[1].iloc[-i]}\\n Risk-Reward is 1:{values_list[1]} \\n\\n Position Sizing is {values_list[0]} stocks for Max Loss of 200 and corresponding Total Capital is {stock_data.iloc[-i]['high']*values_list[0]} with Target Gains of {values_list[0]*(bbands[1].iloc[-i]-stock_data.iloc[-i]['high'])} \\n\\n Total Capital Used is {values_list[3]} \\n Number of stocks is {values_list[2]} \\n Target Gains = {values_list[4]} \\n Max Loss is = {values_list[2]*(stock_data.iloc[-i]['high'] - stock_data.iloc[-i]['low'])} \\n\\n\"\n",
    "                 print(message)\n",
    "                 sendTeleAlert(message, chat_id_group)\n",
    "                 count += 1\n",
    "\n",
    "             else:\n",
    "                 continue\n",
    "\n",
    "     except (ConnectionError, TimeoutError, socket.timeout) as e:\n",
    "         print(f\"Connection Error processing {stocks[n]}: {e}\")\n",
    "         for attempt in range(retries):\n",
    "             try:\n",
    "                 time.sleep(retry_delay)  # Add delay between retries\n",
    "                 stock_data = tv.get_hist(stocks[n], exchange='NSE', interval=Interval.in_15_minute, n_bars=45)\n",
    "                 if stock_data is not None:\n",
    "                     break\n",
    "             except Exception as e:\n",
    "                 print(f\"Retrying {stocks[n]}... Attempt {attempt + 1} of {retries}. Error: {e}\")\n",
    "     except Exception as e:\n",
    "         print(f\"Exception Error processing {stocks[n]}: {e}\")\n",
    "     finally:\n",
    "         values_list.clear()\n",
    "         \n",
    " print(count)\n"
   ]
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": ".venv",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.11.0"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 2
}