from telegram.ext import Updater, CommandHandler, MessageHandler, Filters
from random import randint
import re
import logging
import os
import cx_Oracle

logging.basicConfig(format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
                    level=logging.INFO)

logger = logging.getLogger(__name__)


def start(bot, update):
    update.message.reply_text('Wystartowałem!')


def help(bot, update):
    update.message.reply_text('Tutaj przyjdzie kiedyś help')


def error(bot, update, error):
    logger.warning('Update "%s" caused error "%s"', update, error)

def cstat(mnr):
    mnr = input("Podaj numer maszyny: ")


    dsnStr=cx_Oracle.makedsn("nowyjorkjoł","1521","wracamtam")
    con=cx_Oracle.connect(user='cosiee', password='interesujesz', dsn=dsnStr)
    cur=con.cursor()


    cur.execute("""SELECT DISTINCT M_STATUS, STOER_TEXT
    FROM HYDADM.MASCHINEN_STATUS INNER JOIN
    (HYDADM.STOER_TABELLE INNER JOIN HYDADM.STOERTEXTE ON HYDADM.STOER_TABELLE.STOERTXT_NR = HYDADM.STOERTEXTE.STOERTXT_NR)
    ON HYDADM.MASCHINEN_STATUS.M_STATUS = HYDADM.STOER_TABELLE.STOERNR
    WHERE HYDADM.MASCHINEN_STATUS.MASCH_NR = :id""",{'id': mnr})

    for line in cur:
        wynik=str(line[0])+'-'+line[1]
        #print (wynik.replace(",","-"))

    return(wynik)

print(cstat(603501))



def main():

    updater = Updater(os.environ.get('BOTID'))

    dp = updater.dispatcher

    dp.add_handler(CommandHandler("start", start))
    dp.add_handler(CommandHandler("help", help))
    dp.add_handler(CommandHandler("cstat",  pass_args=True))


    dp.add_error_handler(error)

    updater.start_polling()

    updater.idle()


if __name__ == '__main__':
	main()