import pymysql.cursors
import grequests
import requests
import json

connection = pymysql.connect(host='10.3.0.7',
                     user='bigfood',
                     password='ooKeeko8ciMa',
                     db='bigfood_jabba',
                     port=3306)

try:
    with connection.cursor() as cursor:
     sql = "INSERT INTO couriers (type, api_key, username, enabled, salt, roles, password," \
           " created_at, phone_number, telegram_name) VALUES (%s, %s, %s, %s, %s, %s, %s, now(), %s, %s)"

     executeparlist = [('pedestrian', '9hpbygz9f8cgccs0c88w4w8wkgossgs', 'T1', 1,
                        '9dq0sn6fuf40gcgkcsc8sg4ggg4kgco', '[]',
                        '$2y$08$9EdeeuqI1I2bF3B01UahSOFcVXrJQSWpfqr5bkJC40YdZGs9VUriC',
                        '+79603075765', 'RayneBloodlines'),
                       ('pedestrian', '9hpbygz9f8cgccs0c88w4w8wkgossg2', 'T2', 1,
                        '9dq0sn6fuf40gcgkcsc8sg4ggg4kgco', '[]',
                        '$2y$08$9EdeeuqI1I2bF3B01UahSOFcVXrJQSWpfqr5bkJC40YdZGs9VUriC',
                        '+79603075763', 't2'),
                       ('bicycle', '9hpbygz9f8cgccs0c88w4w8wkgossg3', 'T3', 1,
                        '9dq0sn6fuf40gcgkcsc8sg4ggg41234', '[]',
                        '$2y$08$9EdeeuqI1I2bF3B01UahSOFcVXrJQSWpfqr5bkJC40YdZGs9VUriC',
                        '+79603075761', 't3'),
                       ('bicycle', '9hpbygz9f8cgccs0c88w4w8wkgossg4', 'T4', 1,
                        '9dq0sn6fuf40gcgkcsc8sg4ggg4kg22', '[]',
                        '$2y$08$9EdeeuqI1I2bF3B01UahSOFcVXrJQSWpfqr5bkJC40YdZGs9VUriC',
                        '+79603075762', 't4'),
                       ('motorcycle', '9hpbygz9f8cgccs0c88w4w8wkgossg5', 'T5', 1,
                        '9dq0sn6fuf40gcgkcsc8sg4ggg4kg33', '[]',
                        '$2y$08$9EdeeuqI1I2bF3B01UahSOFcVXrJQSWpfqr5bkJC40YdZGs9VUriC',
                        '+79603075764', 't5'),
                       ('motorcycle', '9hpbygz9f8cgccs0c88w4w8wkgossg6', 'T6', 1,
                        '9dq0sn6fuf40gcgkcsc8sg4ggg4kg44', '[]',
                        '$2y$08$9EdeeuqI1I2bF3B01UahSOFcVXrJQSWpfqr5bkJC40YdZGs9VUriC',
                        '+79603075766', 't6'),
                       ('vehicle', '9hpbygz9f8cgccs0c88w4w8wkgossg7', 'T7', 1,
                        '9dq0sn6fuf40gcgkcsc8sg4ggg4kg55', '[]',
                        '$2y$08$9EdeeuqI1I2bF3B01UahSOFcVXrJQSWpfqr5bkJC40YdZGs9VUriC',
                        '+79603075767', 't7'),
                       ('vehicle', '9hpbygz9f8cgccs0c88w4w8wkgossg8', 'T8', 1,
                        '9dq0sn6fuf40gcgkcsc8sg4ggg4kg66', '[]',
                        '$2y$08$9EdeeuqI1I2bF3B01UahSOFcVXrJQSWpfqr5bkJC40YdZGs9VUriC',
                        '+79603075768', 't8')]
     for item in executeparlist:
         cursor.execute(sql, item)
         connection.commit()


    with connection.cursor() as cursor:
     sql = "UPDATE couriers SET location_date = '2018-12-30 16:59:52'" \
           "where username in ('T1','T2','T3','T4','T5','T6','T7','T8')"
     cursor.execute(sql)
     connection.commit()

    with connection.cursor() as cursor:
        sql = "UPDATE couriers SET location_latitude = %s,  location_longitude = %s where username = %s;"

        executeloclist = [('55.775365', '37.468980', 'T1'),
                          ('55.706658', '37.658636', 'T2'),
                          ('55.759195', '37.643371', 'T3'),
                          ('55.759177', '37.609677', 'T4'),
                          ('55.730480', '37.592104', 'T5'),
                          ('55.727793', '37.474156', 'T6'),
                          ('55.758664', '37.618171', 'T7'),
                          ('55.701256', '37.497081', 'T8')]
        for item in executeloclist:
            cursor.execute(sql, item)
            connection.commit()



    url_cart = 'https://jabba.foodfox.ru/api/v1/cart'
    payload_cart_Ktown = {
        "item_id": 209670
    }
    payload_cart_nana = {
        "item_id": 211
    }

    url_order = 'https://jabba.foodfox.ru/api/v1/orders/unauthorized'
    payload_order_Ktown = {
        "payment_method_id": "0",
        "phone": "9603255444",
        "without_callback": "false",
        "email": "test@tt.tdtd",
        "first_name": "test",

        "address": {
            "city": "Москва",
            "street": "Пыжевский пер",
            "house": "5с2"
        },
        "location": {
            "latitude": "55.738904",
            "longitude": "37.623066"
        }
    }

    payload_order_nana = {
        "payment_method_id": "0",
        "phone": "9603255444",
        "without_callback": "false",
        "email": "test@tt.tdtd",
        "first_name": "test",

        "address": {
            "city": "Москва",
            "street": "ул. Новокузнецкар",
            "house": "16"
        },
        "location": {
            "latitude": "55,740679",
            "longitude": "37,637093"
        }
    }

    headers = {'Content-Type': 'application/json'}
    ck = requests.post(url_cart, data=json.dumps(payload_cart_Ktown))
    ok = requests.post(url_order, headers=headers, cookies=ck.cookies, data=json.dumps(payload_order_Ktown))
    #print(ok.json())
    logout = grequests.post('https://jabba.foodfox.ru/api/v1/user/logout')

    cn = requests.post(url_cart, data=json.dumps(payload_cart_nana))
    on = requests.post(url_order, headers=headers, cookies=cn.cookies, data=json.dumps(payload_order_nana))
    #print(on.json())



finally:
    connection.close()