YHT_7_part_3_10_2020_version.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": 1,
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/plain": [
       "'https://kite.trade/connect/login?api_key=w19o0chuo929jxkp&v=3'"
      ]
     },
     "execution_count": 1,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "import logging\n",
    "from kiteconnect import KiteConnect\n",
    "logging.basicConfig(level=logging.ERROR)\n",
    "import threading\n",
    "kite = KiteConnect(api_key=\"w19o0chuo929jxkp\")\n",
    "import joblib\n",
    "kite = joblib.load('kitefile.p')\n",
    "kite.login_url()"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "#####################################################\n",
    "mytoken = '1BWgO1UgTFeEiE1gS0SttoVTXT4dgcAg'        \n",
    "#####################################################\n",
    "data = kite.generate_session(mytoken,api_secret=\"gsw8ps17ex7lf3cuji4prfnwb4vlyr4y\")\n",
    "kite.set_access_token(data[\"access_token\"])\n",
    "import joblib\n",
    "joblib.dump(kite,'kitefile.p')"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "import act"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "kite.orders()[-1]"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "kite.positions()['net']"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "kite.holdings()"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "pivot price : 73.41\n",
      "\n",
      "p1b = 73.3675\n",
      "p2b = 73.325\n",
      "p3b = 73.2725\n",
      "p4b = 73.1875\n",
      "p5b = 73.05\n",
      "p6b = 73.0075\n",
      "p7b = 72.965\n",
      "\n",
      "p1s = 73.4525\n",
      "p2s = 73.495\n",
      "p3s = 73.5475\n",
      "p4s = 73.6325\n",
      "p5s = 73.77\n",
      "p6s = 73.8125\n",
      "p7s = 73.855\n",
      "\n",
      "p1q : 2\n",
      "p2q : 6\n",
      "p3q : 12\n",
      "p4q : 26\n",
      "p5q : 54\n",
      "p6q : 54\n",
      "p7q : 0\n"
     ]
    }
   ],
   "source": [
    "#####################\n",
    "pivot_price = 73.4100\n",
    "last_high = 73.5650\n",
    "last_low = 73.2050\n",
    "fullquantity = 55\n",
    "powermulti = 2\n",
    "#####################\n",
    "\n",
    "stopbuy = False\n",
    "stopsell = False\n",
    "\n",
    "total_parts = 14\n",
    "pivot_range = last_high - last_low\n",
    "scounter = int(total_parts/2)\n",
    "\n",
    "fibonmulti1=0.1180\n",
    "fibonmulti2=0.2360\n",
    "fibonmulti3=0.3820\n",
    "fibonmulti4=0.6180\n",
    "fibonmulti5=1.0000  # 100% Range\n",
    "fibonmulti6=1.1180\n",
    "fibonmulti7=1.2360\n",
    "fibonmulti8=1.3820\n",
    "fibonmulti9=1.6180\n",
    "fibonmulti10=2.0000 # Max Quantity @ 200% Range\n",
    "fibonmulti11=2.1180 # Stop Trading here\n",
    "fibonmulti12=2.3820 # STOPLOSS\n",
    "\n",
    "print()\n",
    "print('pivot price : ' +str(pivot_price))\n",
    "\n",
    "print()\n",
    "base=0.0025\n",
    "\n",
    "for i in range(1, int(total_parts/2)+1):\n",
    "    globals()['p'+str(i)+'b'] = round(pivot_price - pivot_range*(globals()['fibonmulti'+str(i)]),4)\n",
    "    globals()['p'+str(i)+'b'] = round(base * round(globals()['p'+str(i)+'b'] /base),4)\n",
    "    print('p'+str(i)+'b = '+str(globals()['p'+str(i)+'b']))\n",
    "\n",
    "print()\n",
    "for i in range(1, int(total_parts/2)+1):\n",
    "    globals()['p'+str(i)+'s'] = round(pivot_price + pivot_range*(globals()['fibonmulti'+str(i)]),4)\n",
    "    globals()['p'+str(i)+'s'] = round(base * round(globals()['p'+str(i)+'s'] /base),4)\n",
    "    print('p'+str(i)+'s = '+str(globals()['p'+str(i)+'s']))\n",
    "\n",
    "print()\n",
    "\n",
    "halfqunat = fullquantity/2\n",
    "tempcounter = 1\n",
    "\n",
    "for j in range(1):\n",
    "    for i in range(4,-1,-1):\n",
    "        globals()['p'+str(tempcounter)+'q'] = 2*int((halfqunat*j) + int(halfqunat/pow(powermulti,i)))\n",
    "        print('p'+str(tempcounter)+'q : ' + str(globals()['p'+str(tempcounter)+'q']))\n",
    "        tempcounter = tempcounter+1\n",
    "\n",
    "p6q = p5q\n",
    "p7q = 0\n",
    "print('p6q : '+ str(p6q))\n",
    "print('p7q : '+ str(p7q))"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 3,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "My Quantity : 30\n"
     ]
    }
   ],
   "source": [
    "myquantity = 0\n",
    "def getquant():\n",
    "    global myquantity\n",
    "    allpos = kite.positions()['net']\n",
    "    for i in range(len(allpos)):\n",
    "        if(allpos[i]['tradingsymbol']=='USDINR20OCTFUT'):\n",
    "            myquantity = allpos[i]['quantity']\n",
    "            print('My Quantity : ' + str(allpos[i]['quantity']))\n",
    "        \n",
    "getquant()\n",
    "\n",
    "def placeneworder(quantdiff):\n",
    "    global stopbuy\n",
    "    global stopsell\n",
    "    if(quantdiff>0):\n",
    "        try:\n",
    "                order_id= kite.place_order(tradingsymbol=\"USDINR20OCTFUT\",\n",
    "                            exchange=kite.EXCHANGE_CDS,\n",
    "                            transaction_type=kite.TRANSACTION_TYPE_BUY,\n",
    "                            quantity=abs(quantdiff),\n",
    "                            order_type=kite.ORDER_TYPE_MARKET,\n",
    "                            variety = kite.VARIETY_REGULAR,\n",
    "                            product=kite.PRODUCT_NRML)\n",
    "                getquant()\n",
    "        except Exception as e:\n",
    "            print(e)\n",
    "            getquant()\n",
    "    if(quantdiff<0):\n",
    "        try:\n",
    "                order_id= kite.place_order(tradingsymbol=\"USDINR20OCTFUT\",\n",
    "                            exchange=kite.EXCHANGE_CDS,\n",
    "                            transaction_type=kite.TRANSACTION_TYPE_SELL,\n",
    "                            quantity=abs(quantdiff),\n",
    "                            order_type=kite.ORDER_TYPE_MARKET,\n",
    "                            variety = kite.VARIETY_REGULAR,\n",
    "                            product=kite.PRODUCT_NRML)\n",
    "                getquant()\n",
    "        except Exception as e:\n",
    "            print(e)\n",
    "            getquant()\n",
    "\n",
    "\n",
    "def ckqnt (orderprice,orderquant):\n",
    "    global myquantity\n",
    "    quantdiff = orderquant - myquantity\n",
    "    placeneworder(quantdiff)\n",
    "    return myquantity\n",
    "\n",
    "def checkpivot(ltps):\n",
    "    if ((ltps>=(pivot_price-0.0050)) and (ltps<=(pivot_price+0.0050))):\n",
    "        ckqnt(pivot_price,0)\n",
    "        print('in pivot range')\n",
    "\n",
    "    for i in range(1,int(total_parts/2)+1):\n",
    "        if(i==int(total_parts/2)):\n",
    "            if (ltps < (globals()['p'+str(i)+'b']-0.0025)):\n",
    "                ckqnt(globals()['p'+str(i)+'b'],globals()['p'+str(i)+'q'])\n",
    "                print('==========' +'p'+str(i)+'b @ ' +str(ltps) + '==============' )\n",
    "                print()\n",
    "            if (ltps > (globals()['p'+str(i)+'s']+0.0025)):\n",
    "                ckqnt(globals()['p'+str(i)+'s'],-(globals()['p'+str(i)+'q']))\n",
    "                print('==========' +'p'+str(i)+'s @ ' +str(ltps) + '==============' )\n",
    "                print()\n",
    "        else:\n",
    "            if (ltps < (globals()['p'+str(i)+'b'] -0.0025) and ltps > (globals()['p'+str(i+1)+'b']+0.0025)):\n",
    "                ckqnt(globals()['p'+str(i)+'b'],globals()['p'+str(i)+'q'])\n",
    "                print('==========' +'p'+str(i)+'b @ ' +str(ltps) + '==============' )\n",
    "                print()\n",
    "            if (ltps > (globals()['p'+str(i)+'s'] +0.0025) and ltps < (globals()['p'+str(i+1)+'s']-0.0025)):\n",
    "                ckqnt(globals()['p'+str(i)+'s'],-(globals()['p'+str(i)+'q']))\n",
    "                print('==========' +'p'+str(i)+'s @ ' +str(ltps) + '==============' )\n",
    "                print()"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 5,
   "metadata": {
    "scrolled": true
   },
   "outputs": [
    {
     "ename": "ReactorNotRestartable",
     "evalue": "",
     "output_type": "error",
     "traceback": [
      "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m",
      "\u001b[0;31mReactorNotRestartable\u001b[0m                     Traceback (most recent call last)",
      "\u001b[0;32m<ipython-input-5-d2aaf729725b>\u001b[0m in \u001b[0;36m<module>\u001b[0;34m\u001b[0m\n\u001b[1;32m     27\u001b[0m \u001b[0mkws\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mon_close\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mon_close\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     28\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m---> 29\u001b[0;31m \u001b[0mkws\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mconnect\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m",
      "\u001b[0;32m~/.local/lib/python3.8/site-packages/kiteconnect/ticker.py\u001b[0m in \u001b[0;36mconnect\u001b[0;34m(self, threaded, disable_ssl_verification, proxy)\u001b[0m\n\u001b[1;32m    530\u001b[0m                 \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mwebsocket_thread\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mstart\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    531\u001b[0m             \u001b[0;32melse\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 532\u001b[0;31m                 \u001b[0mreactor\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mrun\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m**\u001b[0m\u001b[0mopts\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    533\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    534\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0mis_connected\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m~/.local/lib/python3.8/site-packages/twisted/internet/base.py\u001b[0m in \u001b[0;36mrun\u001b[0;34m(self, installSignalHandlers)\u001b[0m\n\u001b[1;32m   1280\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m   1281\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0mrun\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0minstallSignalHandlers\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0;32mTrue\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m-> 1282\u001b[0;31m         \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mstartRunning\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0minstallSignalHandlers\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0minstallSignalHandlers\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m   1283\u001b[0m         \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mmainLoop\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m   1284\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m~/.local/lib/python3.8/site-packages/twisted/internet/base.py\u001b[0m in \u001b[0;36mstartRunning\u001b[0;34m(self, installSignalHandlers)\u001b[0m\n\u001b[1;32m   1260\u001b[0m         \"\"\"\n\u001b[1;32m   1261\u001b[0m         \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_installSignalHandlers\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0minstallSignalHandlers\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m-> 1262\u001b[0;31m         \u001b[0mReactorBase\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mstartRunning\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m   1263\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m   1264\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m~/.local/lib/python3.8/site-packages/twisted/internet/base.py\u001b[0m in \u001b[0;36mstartRunning\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    763\u001b[0m             \u001b[0;32mraise\u001b[0m \u001b[0merror\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mReactorAlreadyRunning\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    764\u001b[0m         \u001b[0;32mif\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_startedBefore\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 765\u001b[0;31m             \u001b[0;32mraise\u001b[0m \u001b[0merror\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mReactorNotRestartable\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    766\u001b[0m         \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_started\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0;32mTrue\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    767\u001b[0m         \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_stopped\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0;32mFalse\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;31mReactorNotRestartable\u001b[0m: "
     ]
    }
   ],
   "source": [
    "#!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!\n",
    "#              START TRADING             !\n",
    "#!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!\n",
    "\n",
    "import logging\n",
    "from kiteconnect import KiteTicker\n",
    "logging.basicConfig(level=logging.DEBUG)\n",
    "kws = KiteTicker(\"w19o0chuo929jxkp\", \"lUL4kr5aYIlHBwNMldIKwLy8zbNpS5Ev\")\n",
    "\n",
    "def on_ticks(ws, ticks):\n",
    "    checkpivot(ticks[0]['last_price'])\n",
    "    #print(type(ticks[0]['last_price']))\n",
    "    #print('==========================')\n",
    "    #print( 'LTP : ' + str(ticks[0]['last_price']))\n",
    "    #print('==========================')\n",
    "    #print()\n",
    "\n",
    "def on_connect(ws, response):\n",
    "    ws.subscribe([690691])\n",
    "    ws.set_mode(ws.MODE_FULL, [690691])\n",
    "\n",
    "def on_close(ws, code, reason):\n",
    "    ws.stop()\n",
    "\n",
    "kws.on_ticks = on_ticks\n",
    "kws.on_connect = on_connect\n",
    "kws.on_close = on_close\n",
    "\n",
    "kws.connect()"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "import dash_core_components"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "print(dash_core_components.__version__)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "Python 3",
   "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.8.6"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 4
}