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(bot, update, args):


    try:
        mnr=args[0]
    except IndexError:
        update.message.reply_text('insert machine number first')
        mnr=''
    try:
        xmnr=int(mnr)
    except ValueError:
        update.message.reply_text('incorrect machine number format')
        xmnr=0
    if (xmnr<100000 or xmnr>999999):
        xmnr=0
        update.message.reply_text('incorrect machine number format')
    if (xmnr):

        update.message.reply_text('incorrect machine number format')



        dsnStr=cx_Oracle.makedsn("dsa.pl.dsa.com","dsa","HYD1")
        con=cx_Oracle.connect(user='dsa', password='dsa', 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]

        update.message.reply_text(wynik)






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("mstat",cstat,  pass_args=True))


    dp.add_error_handler(error)

    updater.start_polling()

    updater.idle()


if __name__ == '__main__':
	main()