#! / USR / бен / питон


импорт jsonrpc
время импорта
импорт дата и время

из базы данных импорта *


Класс BitcoinInterface (объект):

    Защиту __init __ (Я):
        self.access = jsonrpc.ServiceProxy ("http://127.0.0.1:8332")
        вернуть

    Защиту issueBitcoinAddresses (самостоятельно):
        localBitcoinAddresses = список (Address.select (AND (Address.q.type_ == "localBitcoin", Address.q.value == None))) # Получить все нераспределенные локальные адреса Bitcoin
        для localBitcoinAddress в localBitcoinAddresses:
            localBitcoinAddress.value = self.access.getnewaddress ()
            клиент = Client.get (localBitcoinAddress.clientID)
            Распечатать "Новый адрес: \ nИмя пользователя:% s \ nClientID:% г \ nValue:% s \ п" % (Client.username, client.id, localBitcoinAddress.value)
        вернуть

    Защиту takeDeposits (самостоятельно):
        localBitcoinAddresses = список (Address.select (AND (Address.q.type_ == "localBitcoin", Address.q.value! = None))) # Получить все назначенные локальные адреса Bitcoin
        для localBitcoinAddress в localBitcoinAddresses:
            amountReceived = self.access.getamountreceived (localBitcoinAddress.value)
            если amountReceived > localBitcoinAddress.amountReceived:
                клиент = Client.get (localBitcoinAddress.clientID)
                количество = amountReceived - localBitcoinAddress.amountReceived
                client.bitcoins = client.bitcoins + количество
                localBitcoinAddress.amountReceived = amountReceived
                транзакции = транзакции (ClientID = client.id)
                transaction.datetime = datetime.datetime.now ()
                transaction.type_ = "депозит"
                количество transaction.quantity = количество # сделка положительна для "депозит"
                Распечатать "Депозит: \ nИмя пользователя:% s \ nClientID:% I \ nQuantity:% F \ п" % (Client.username, client.id, количество)
        вернуть

    Защиту issueWithdrawals (самостоятельно):
        клиенты = список (Client.select (Client.q.bitcoinsToWithdraw > 0))
        для клиента в клиентах:
            если client.bitcoinsToWithdraw <= Client.bitcoins: проверка # Избыточность
                foreignBitcoinAddress = список (Address.select (AND (Address.q.clientID == client.id, Address.q.type_ == "foreignBitcoin"))) [0]
                пытаться:
                    количество = client.bitcoinsToWithdraw
                    self.access.sendtoaddress (foreignBitcoinAddress.value, количество)
                    client.bitcoins = client.bitcoins - количество
                    транзакции = транзакции (ClientID = client.id)
                    transaction.datetime = datetime.datetime.now ()
                    transaction.type_ = "Вывод"
                    transaction.quantity = -quantity # количество транзакций отрицательное "Вывод"
                    client.bitcoinsToWithdraw = 0
                    Распечатать "Вывод: \ nИмя пользователя:% s \ nClientID:% I \ nQuantity:% F \ п" % (Client.username, client.id, количество)
                Кроме:
                    Распечатать "Ошибка Выход: \ nИмя пользователя:% s \ nClientID:% I \ nQuantity:% F \ п" % (Client.username, client.id, client.bitcoinsToWithdraw)              
            еще:
                Распечатать "Не удалось Изъятие, не хватает Bitcoins: \ nИмя пользователя:% s \ nClientID:% г \ п" % (Client.username, client.id)
        вернуть

bitcoinInterface = BitcoinInterface ()
в то время как 1:
    bitcoinInterface.issueBitcoinAddresses ()
    bitcoinInterface.takeDeposits ()
    bitcoinInterface.issueWithdrawals ()
    time.sleep (300)