Pythonで仮想通貨のMACD取得⑦ zaif公開API動作プログラム3

仮想通貨の売買ライブラリをCCXT(CryptoCurrency eXchange Trading Library)に変更しました。
CCXTは、APIを公開している各取引所の売買処理を、ほぼ同じインタフェースで使えるようにしたライブラリです。各取引所のAPIによっては提供有無や、仕様が違っている部分もあるため、ほぼ同じインタフェースとなります。それでも各取引所のAPIを駆使するのより簡単になりますし、別の取引所に変更する場合、修正量が少なくて済むと思います。

今回も、ビットコインで、取引所はzaifとしています。

また、ライブラリを変更した序でに、単純移動平均線、MACDの部分を別モジュールしており、売買処理部分もサブルーチン化しています。

売買処理のサブルーチンは、呼び出す部分をコメントアウトしているので動かないですが、購入申請が動くのは単体で確認しています。

slack通知部分もサブルーチン化しています。

スポンサードリンク

 

15秒間隔で市場価格を取得を想定しているため正しいMACDにはなっていないかもしれません。1分足に近くなるようにパラメータは以下のようのしています。
プログラムを動かしてみるとわかるのですが、必ずしも15秒間隔で取得できていません。APIがエラーになったり、応答時間が長くなったりしているためです。zaifを使っているとAPIエラー、応答時間の遅延が発生することが多く感じます。

単純移動平均線、ボリンジャーバンド、MACDのパラメータ

約1分足にするには、
PERIOD2 = 104 # 長期移動平均線&ボリンジャーバンドの間隔数 ※ LOOP_CNT26と同じにする
LOOP_CNT9 = 36 # MACD9のための定数(15秒間隔なので36)
LOOP_CNT12 = 48 # EMA12のための定数(15秒間隔なので48)
LOOP_CNT26 = 104 # EMA26のための定数(15秒間隔なので104)
約2分速にする場合は以下にします。
約2分足にするには、
PERIOD2 = 208
LOOP_CNT9 = 72
LOOP_CNT12 = 96
LOOP_CNT26 = 208
  • 情報収集が目的に作成しているプログラムです。
  • プライベートAPIは動かないようにしているため、売買は指定された価格、コイン数で必ず約定されるように動きます。このため、本当の売買とは動きが違うことを認識しておいてください。
    実際に売買動作させると、利確したいのにキャンセルになり、損切りに変わったりする場合があります。
  • プログラム開始時点の資産はプログラム内で指定しています。

動作環境

pythonが動くなら大丈夫だと思いますが、私の動作環境としては、NCU(4コア)に、ESXiを導入した仮想サーバーを持っているため、windows7(2仮想CPU/4GBメモリ) をインストールして常時稼働させています。リモートディスクトップは、高速リモートディスクトップ「Yule」を使っています。
python 3.6.4 は、Anaconda version 5.2.0 を導入しています。

スポンサードリンク

コード

注意
プライベートAPIはコメントアウトしていますが、テスト用部分を削除してAPIコメントアウトを生かすと売買することも可能ですが、動作確認が済んでいません。使用する場合は自己責任でお願いします。

コードをコピーするのも大変なので、GitHubに置いておきます

key.jsonの作成

config/key.json

プライベートAPIを使わないのですが、zaif_keyとzaif_secretはプラグラム的に必要なので以下のように適当に指定してください。
slack_webhook_urlは、取得したURLを指定してください。

{
    "zaif_key": "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",
    "zaif_secret": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
    "slack_webhook_url": "https://取得したURL"
}

※ slack_webhook_urlのURLに、"hooks.slack.com"を含まなければ、slack通知処理はスキップされます。

SMA_BB.py

単純移動平均線とボリンジャーバンドを取得するクラス

# coding=utf-8

"""
このモジュールでは 単純移動平均(SMA)、ボリンジャーバンド(BB) を実装しています。
カレントの価格を加味しています。
"""

import numpy as np


class SimpleMovingAverageBollingerBand:
    """
    単純移動平均(SMA)、ボリンジャーバンド(BB)のクラスです。
    """

    def __init__(self, period1=12, period2=104):
        """
        移動平均線とボリンジャーバンド
        :param period1: 短期SMA
        :param period2: 長期SMA
        """
        self.__count = 0
        self.__period1 = period1
        self.__period2 = period2
        self.__avg1 = 0
        self.__avg2 = 0
        self.__sigma = 0
        self.__avg1_pre = 0
        self.__avg2_pre = 0
        self.__sigma_pre = 0
        self.__MAL1 = []
        self.__MAL2 = []
        for var in range(0, self.__period1):
            self.__MAL1.append(0.00000)
        for var in range(0, self.__period2):
            self.__MAL2.append(0.00000)

    def add(self, price):
        """
        仮想通貨のカレントプライスを追加し、移動平均線、ボリンジャーバンドを戻す
        :param price: カレントプライス
        :return: 短期移動平均、長期移動平均、ボリンジャーバンド、一つ前の短期移動平均、一つ前の長期移動平均、一つ前のボリンジャーバンド
        """
        # self.__avg1 = np.average(self.__MAL1)
        # self.__avg2 = np.average(self.__MAL2)
        # self.__sigma = np.std(self.__MAL2, ddof=1)
        self.__count += 1
        for var in range(0, self.__period1 - 1):
            self.__MAL1[var] = self.__MAL1[var + 1]
        self.__MAL1[self.__period1 - 1] = price
        for var in range(0, self.__period2 - 1):
            self.__MAL2[var] = self.__MAL2[var + 1]
        self.__MAL2[self.__period2 - 1] = price

        if self.__count <= self.__period2 + 1:
            self.__avg1 = np.average(self.__MAL1)
            self.__avg2 = np.average(self.__MAL2)
            self.__sigma = np.std(self.__MAL2, ddof=1)
            return False, 0, 0, 0, 0, 0, 0
        else:
            self.__avg1_pre = self.__avg1
            self.__avg2_pre = self.__avg2
            self.__sigma_pre = self.__sigma

            self.__avg1 = np.average(self.__MAL1)
            self.__avg2 = np.average(self.__MAL2)
            self.__sigma = np.std(self.__MAL2, ddof=1)
            return True, self.__avg1, self.__avg2, self.__sigma, self.__avg1_pre, self.__avg2_pre, self.__sigma_pre

MACD.py

MACDとシグナルを取得するクラス

# coding=utf-8

"""
このモジュールでは MACD(Moving Average Convergence Divergence)を実装しています。
"""


class MovingAverageConvergenceDivergence:
    """
    MACD(Moving Average Convergence Divergence)のクラスです。
    """

    def __init__(self, cnt9=36, cnt12=48, cnt26=104):
        """
        MACD(Moving Average Convergence Divergence)の初期化
        :param cnt9: シグナル
        :param cnt12: 短期EMA
        :param cnt26: 長期EMA
        """
        self.__count = 0
        self.__LOOP_CNT9 = cnt9
        self.__LOOP_CNT12 = cnt12
        self.__LOOP_CNT26 = cnt26
        self.__A12AAA = 2 / (cnt12 + 1.0000)
        self.__A26AAA = 2 / (cnt26 + 1.0000)
        self.__SMA12_AVE = 0.0000
        self.__SMA26_AVE = 0.0000
        self.__MACD9_AVE = 0.0000
        self.__MACD = 0.0
        self.__MACD9_AVE_pre = 0.0000
        self.__MACD_pre = 0.0
        self.__SMA12 = []
        self.__SMA26 = []
        self.__EMA12 = []
        self.__EMA26 = []
        self.__MACD9 = []
        for var in range(0, self.__LOOP_CNT12):
            self.__SMA12.append(self.__SMA12_AVE)

        for var in range(0, self.__LOOP_CNT26):
            self.__SMA26.append(self.__SMA12_AVE)

        for var in range(0, self.__LOOP_CNT12):
            self.__EMA12.append(self.__SMA12_AVE)

        for var in range(0, self.__LOOP_CNT26):
            self.__EMA26.append(self.__SMA12_AVE)

        for var in range(0, self.__LOOP_CNT9):
            self.__MACD9.append(self.__SMA12_AVE)

    def add(self, price):
        """
        仮想通貨のカレントプライスを追加し、MACD,Signalを戻す
        :param price: カレントプライス
        :return: MACD, SIGNAL, 一つ前のMACD, 一つ前のSIGNAL
        """
        self.__count += 1
        if self.__count <= self.__LOOP_CNT26:
            for var in range(self.__LOOP_CNT12 - 1, 0, -1):
                self.__SMA12[var] = self.__SMA12[var - 1]

            for var in range(self.__LOOP_CNT26 - 1, 0, -1):
                self.__SMA26[var] = self.__SMA26[var - 1]

            self.__SMA12[0] = price
            self.__SMA26[0] = price

            sum12 = 0.0000
            sum26 = 0.0000

            for var in range(0, self.__LOOP_CNT12):
                sum12 += self.__SMA12[var]

            for var in range(0, self.__LOOP_CNT26):
                sum26 += self.__SMA26[var]

            self.__SMA12_AVE = sum12 / self.__LOOP_CNT12
            self.__SMA26_AVE = sum26 / self.__LOOP_CNT26

            return False, 0, 0, 0, 0
        else:
            self.__MACD_pre = self.__MACD
            self.__MACD9_AVE_pre = self.__MACD9_AVE

            # #######################EMAの算出#########################
            for var in range(self.__LOOP_CNT12 - 1, 0, -1):
                self.__EMA12[var] = self.__EMA12[var - 1]

            for var in range(self.__LOOP_CNT26 - 1, 0, -1):
                self.__EMA26[var] = self.__EMA26[var - 1]

            # EMA = B + α( A - B )
            self.__SMA12_AVE = self.__SMA12_AVE + (self.__A12AAA * (price - self.__SMA12_AVE))  # EMA12
            self.__SMA26_AVE = self.__SMA26_AVE + (self.__A26AAA * (price - self.__SMA26_AVE))  # EMA26

            # print('__EMA12:', self.__SMA12_AVE)
            # print('__EMS26:', self.__SMA26_AVE)

            self.__EMA12[0] = self.__SMA12_AVE
            self.__EMA26[0] = self.__SMA26_AVE
            # #######################EMAの算出#########################

            # #######################MACDの算出########################
            self.__MACD = self.__SMA12_AVE - self.__SMA26_AVE  # MACD = 基準線(EMA) - 相対線(EMA)

            for var in range(self.__LOOP_CNT9 - 1, 0, -1):
                self.__MACD9[var] = self.__MACD9[var - 1]

            self.__MACD9[0] = self.__MACD

            sum9 = 0.0000
            for var in range(0, self.__LOOP_CNT9):
                sum9 += self.__MACD9[var]

            self.__MACD9_AVE = sum9 / self.__LOOP_CNT9

            # print('__MACD:', self.__MACD)
            # print('__MACD9:', self.__MACD9_AVE)

            # #######################MACDの算出########################
            if self.__count == self.__LOOP_CNT26 + 1:
                return False, 0, 0, 0, 0
            else:
                return True, self.__MACD, self.__MACD9_AVE, self.__MACD_pre, self.__MACD9_AVE_pre

main.py

# coding=utf-8

import json
import time
import codecs
import slackweb
import datetime
import ccxt
import SMA_BB
import MACD
import urllib.error
from decimal import (Decimal)
from logger import error_logger
from logger import trade_logger

# 本プログラムは、マルチ売買申請には対応していない。必ず1申請での処理となる。
# MACDの指標でのプログラムであり、実売買はしないが、売買ルーチンやオーダーチェックのルーチンは含まれています。
# ただし、実売買ルーチン等は、まだ実働させていないことに注意してください。

with codecs.open('config/key.json', 'r', 'utf-8') as f:
    API_data = json.load(f)

WEBHOOK_URL = API_data["slack_webhook_url"]
slack_flag = 'hooks.slack.com' in WEBHOOK_URL
slack = slackweb.Slack(WEBHOOK_URL)

API_KEY = API_data["zaif_key"]
API_SECRET = API_data["zaif_secret"]
COIN_NAME = 'BTC'
COIN_PAIR = 'BTC/JPY'
EXCHANGE = 'Zaif:'

exchange = ccxt.zaif()
exchange.apiKey = API_KEY
exchange.secret = API_SECRET

trade_log = trade_logger.TradeLogger('zaif', COIN_NAME)
error_log = error_logger.ErrorLogger('error')

# 市場価格の取得間隔
loop_count = 0
LOOP_TIME = 15  # 市場価格取得間隔の秒数

# 移動平均線、ボリンジャーバンドの間隔数
PERIOD1 = 12  # 短期移動平均線
PERIOD2 = 104  # 長期移動平均線&ボリンジャーバンドの間隔数 ※ LOOP_CNT26と同じにする

# MACDの間隔数
LOOP_CNT9 = 36  # MACD9のための定数(15秒間隔なので36)
LOOP_CNT12 = 48  # EMA12のための定数(15秒間隔なので48)
LOOP_CNT26 = 104  # EMA26のための定数(15秒間隔なので104)

# デットクロス売りに移行したかのフラグ
dead_cross_flag = False

# キャンセル処理への変数
CANCEL_LOOP_MAX = 4  # キャンセルするまでのループ回数 4x15=60秒
cancel_flag = False  # 約定してない売買申請がある場合にキャンセル処理を動かすフラグ
cancel_loop_count = 0  # キャンセルまでのカウント

# 売買後にホールドする回数の変数
TRADE_HOLD_MAX = 4  # トレード直後に売買しないようにする回数 4x15=60秒
trade_hold_count = 0  # トレード後直ぐに売買処理しないようにするカウント

# 売買取引量、板情報に表示されてる売買量(情報収集)
bid_amount = 0.0  # 買い取引量
ask_amount = 0.0  # 売り取引量
bid_depth_amount = 0.0  # 板買い
ask_depth_amount = 0.0  # 板売り

# アセット
funds_jpy = 0  # 注文余力日本円
funds_coin = 0.0  # 注文余力コイン
start_funds_jpy = 0  # プログラム開始時の日本円
asset_info = False

# 最後のトレード情報
last_trade_func = ''  # 取引機能
last_trade_order_id = 0  # 最後に取引したID
last_trade_size = 0.0  # 最後に取引したサイズ
last_trade_price = 0  # 最後に取引した価格
last_trade_price_pre = 0  # 一つ前の取引した価格(キャンセルした時用)
last_trade_type = 0  # 0:購入、1:利確1、2:利確2、3:損切り

# トレードログ用
message_func = ''
message_trade = ''
message_size = 0
message_price = 0.0
date_time = datetime.datetime.now()  # print用表示タイム

# 現在の市場価格情報
current_price = 0  # 市場価格
current_price_pre = 0  # 前の市場価格
current_bid_price = 0  # 買い気配
current_ask_price = 0  # 売り気配

# プログラムの終了処理変数
END_FLAG = False  # プログラムの終了フラグ
end_datetime = datetime.datetime.now()  # 終了タイム
END_HOUR = 16  # 終了時
END_MINUTE = 30  # 終了分

#####################################
# テスト用                          #
user_coin_asset = 0.0  # 実売買しないのでテスト用コイン資産
user_jpy_asset = 5000.0  # 実売買しないのでテスト用日本円資産
#                                   #
#####################################


def order_limit_call(side, coin_amount, price):
    """
    仮想通貨指値注文
    繰り返しは5回までとしている。
    :param side: 'buy','sell'
    :param coin_amount: コイン数
    :param price: 価格
    :return: APIが正常応答したかのフラグ、オーダーID
    """
    global exchange, COIN_PAIR, error_log
    coin_float_amount = float(coin_amount)
    for _a in range(5):
        try:
            if side == 'buy':
                ccxt_result = exchange.create_limit_buy_order(COIN_PAIR, coin_float_amount, price)
            elif side == 'sell':
                ccxt_result = exchange.create_limit_sell_order(COIN_PAIR, coin_float_amount, price)
            else:
                return False, 0
        except ccxt.RequestTimeout:
            error_log.write()
            print('エラー: call ', side, ' order timeout')
            time.sleep(1)
        except ccxt.ExchangeNotAvailable:
            error_log.write()
            print('エラー: call ', side, ' order NotAvailable')
            time.sleep(1)
        except ccxt.ExchangeError:
            error_log.write()
            print('エラー: call ', side, ' order ExchangeError')
            time.sleep(1)
        else:
            return True, ccxt_result['id']

        # エラーでも申請が通っている場合があるのでチェック(タイムアウトしてた時に一度発生した)
        # 複数申請は無いプログラムでのチェック内容。
        check_flag, check_id, check_status = order_check()
        if check_flag and check_id != 0:
            return True, check_id
        for _b in range(5):
            try:
                ccxt_result = exchange.fetch_balance()
            except ccxt.RequestTimeout:
                error_log.write()
                print('エラー:balance Timeout')
                time.sleep(1)
            except ccxt.ExchangeNotAvailable:
                error_log.write()
                print('エラー:balance NotAvailable')
                time.sleep(1)
            except ccxt.ExchangeError:
                error_log.write()
                print('エラー:balance ExchangeError')
                time.sleep(1)
            else:
                if side == 'buy':
                    if ccxt_result['BTC']['total'] != 0:
                        return True, 0
                else:
                    if ccxt_result['BTC']['total'] == 0:
                        return True, 0
        else:
            print('order_limit_call balance リトライ5回失敗')
            return False, 0

    else:
        print('order_limit_call リトライ5回失敗')
        return False, 0


def order_check():
    """
    有効なオーダーがあるか確認
    :return: APIが正常応答したかのフラグ、オーダーID、オーダーステータス
    """
    global exchange, COIN_PAIR, error_log
    for _c in range(10):
        try:
            ccxt_result = exchange.fetch_open_orders(COIN_PAIR)
        except ccxt.RequestTimeout:
            error_log.write()
            print('エラー:cant open orders Timeout')
            time.sleep(1)
        except ccxt.ExchangeNotAvailable:
            error_log.write()
            print('エラー:cant open orders NotAvailable')
            time.sleep(1)
        except ccxt.ExchangeError:
            error_log.write()
            print('エラー:cant open orders ExchangeError')
            time.sleep(1)
        else:
            if len(ccxt_result) == 0:
                return True, 0, 0
            else:
                return True, ccxt_result[0]['id'], ccxt_result[0]['status']
    else:
        print('order_check リトライ10回失敗')
        return False, 0, 0


def slack_notify(message):
    """
    Slackへの通知
    :param message: 通知メッセージ
    """
    global slack_flag, slack, error_log
    if slack_flag:
        for _d in range(5):
            try:
                slack.notify(text=message)
            except urllib.error.HTTPError:
                error_log.write()
                print("エラー:slack call HTTPError")
            except urllib.error.URLError:
                error_log.write()
                print("エラー:slack call URLError")
            else:
                break
        else:
            print('slack call error')


if __name__ == '__main__':

    sma_bb = SMA_BB.SimpleMovingAverageBollingerBand(PERIOD1, PERIOD2)
    macd = MACD.MovingAverageConvergenceDivergence(LOOP_CNT9, LOOP_CNT12, LOOP_CNT26)

    sma_flag = True
    sma_avg1 = 0
    sma_avg2 = 0
    sma_sigma = 0
    sma_avg1_pre = 0
    sma_avg2_pre = 0
    sma_sigma_pre = 0
    macd_flag = True
    macd_macd = 0
    macd_signal = 0
    macd_macd_pre = 0
    macd_signal_pre = 0
    order_flag = True
    order_id = 0
    order_status = 0

    init_flag = False
    while not init_flag:
        try:
            last_trade_price = int(exchange.fetch_ticker(COIN_PAIR)['last'])
            # result = exchange.fetch_balance()
            # start_funds_jpy = result['total']['JPY']
            # if result['total'][COIN_NAME] != 0:
            #     start_funds_jpy += result['total'][COIN_NAME] * last_trade_price
            # print('start jpy:', start_funds_jpy)

            #####################################
            # テスト用                          #
            start_funds_jpy = user_jpy_asset
            #                                   #
            #####################################

        except (ccxt.RequestTimeout, ccxt.ExchangeNotAvailable, ccxt.ExchangeError):
            error_log.write()
            continue
        else:
            init_flag = True

    # 終了タイムを設定
    date_time = datetime.datetime.now()
    end_datetime = datetime.datetime(date_time.year, date_time.month, date_time.day, END_HOUR, END_MINUTE)
    END_FLAG = False
    if date_time > end_datetime:
        end_datetime += datetime.timedelta(days=1)
    print('END DATE TIME:', end_datetime)

    profit_count = 0
    loss_count = 0

    while True:
        message_func = ''
        message_trade = ''
        message_price = 0
        message_size = 0.0
        date_time = datetime.datetime.now()
        start_time = time.time()
        try:
            # result = exchange.fetch_balance()
            # funds_jpy = result['total']['JPY']
            # funds_coin = Decimal(result['total'][COIN_NAME]).quantize(Decimal('0.0001'))
            #####################################
            # テスト用                          #
            funds_coin = user_coin_asset
            funds_jpy = user_jpy_asset
            #                                   #
            #####################################

            result = exchange.fetch_ticker(COIN_PAIR)
            current_price_pre = current_price
            current_price = int(result['last'])
            current_bid_price = int(result['bid'])
            current_ask_price = int(result['ask'])

            # trades
            result = exchange.fetch_trades(COIN_PAIR)
            bid_amount = 0
            ask_amount = 0
            for currency in result:
                if currency['side'] == 'buy':
                    bid_amount += Decimal(float(currency['amount'])).quantize(Decimal('0.0001'))
                if currency['side'] == 'sell':
                    ask_amount += Decimal(float(currency['amount'])).quantize(Decimal('0.0001'))

            # depth
            result = exchange.fetch_order_book(COIN_PAIR)
            bid_depth_amount = 0
            ask_depth_amount = 0
            for currency in result['bids']:
                bid_depth_amount += Decimal(float(currency[1])).quantize(Decimal('0.0001'))
            for currency in result['asks']:
                ask_depth_amount += Decimal(float(currency[1])).quantize(Decimal('0.0001'))

        except ccxt.RequestTimeout:
            error_log.write()
            print("エラー:Cant get data Timeout")
            time.sleep(1)
            continue

        except ccxt.ExchangeNotAvailable:
            error_log.write()
            print("エラー:Cant get data NotAvailable")
            time.sleep(1)
            continue

        except ccxt.ExchangeError:
            error_log.write()
            print("エラー:Cant get data Error")
            time.sleep(1)
            continue

        else:
            loop_count += 1
            sma_flag, sma_avg1, sma_avg2, sma_sigma, sma_avg1_pre, sma_avg2_pre, sma_sigma_pre \
                = sma_bb.add(current_price)
            macd_flag, macd_macd, macd_signal, macd_macd_pre, macd_signal_pre = macd.add(current_price)

        if sma_flag:
            print('■資産、平均線、ボリンジャーバンド、MACD', loop_count)
            print(str(date_time))
            print(COIN_NAME + '資産:', str(funds_coin))
            print('jpy資産:', str(funds_jpy))
            print('市場価格:', str(current_price))
            print('市場買い気配:', str(current_bid_price))
            print('市場売り気配:', str(current_ask_price))
            print('平均  :', str(sma_avg2))
            print('高偏差:', str(sma_avg2 + sma_sigma))
            print('低偏差:', str(sma_avg2 - sma_sigma))
            print('MACD', str(macd_macd))
            print('SIGNAL', str(macd_signal))
            print("最終取引価格:" + str(last_trade_price))
            message_func = EXCHANGE + '資産、平均、標準偏差'
        else:
            print("■ 現在の情報です", loop_count)
            print(str(date_time))
            print("市場取引価格:" + str(current_price))
            print("市場買い気配:" + str(current_bid_price))
            print("市場売り気配:" + str(current_ask_price))
            print(COIN_NAME + "資産:" + str(funds_coin))
            print("jpy資産:" + str(funds_jpy))
            print("最終取引価格:" + str(last_trade_price))

        if asset_info or loop_count == 1:
            if funds_coin < 0.0001 and last_trade_order_id == 0:
                message_text = EXCHANGE + '現在の資産: ' + str(date_time) + '\njpy資産:'
                message_text += str(funds_jpy) + '\n' + COIN_NAME + '資産:' + str(funds_coin)
                message_text += '\nProfit:' + str(profit_count) + ' Loss:' + str(loss_count)
                message_text += '\nGain:' + str(funds_jpy - start_funds_jpy)
            else:
                message_text = EXCHANGE + '現在の資産: ' + str(date_time) + '\njpy資産:'
                message_text += str(funds_jpy) + '\n' + COIN_NAME + '資産:' + str(funds_coin)
                message_text += '\nProfit:' + str(profit_count) + ' Loss:' + str(loss_count)
            slack_notify(message_text)
            asset_info = False

        # コインを持っていて、デットクロス売り
        if funds_coin >= 0.0001 and trade_hold_count > TRADE_HOLD_MAX and macd_macd < macd_signal \
                and macd_macd_pre > macd_signal_pre and not dead_cross_flag:

            if last_trade_price > current_price:
                dead_cross_flag = True
                message_text = EXCHANGE + '■ デットクロス処理移行: ' + str(date_time)
                print(message_text)
                slack_notify(message_text)
                message_func += '、デットクロス処理移行'
            else:

                amount = funds_coin
                # 売り
                # order_flag, order_id = order_limit_call('sell', amount, current_price - 5)
                #####################################
                # テスト用                          #
                time.sleep(1)
                user_coin_asset -= float(amount)
                user_jpy_asset += ((current_price - 5) * float(amount))
                order_flag = True
                order_id = 0
                #                                   #
                #####################################

                if order_flag:
                    if order_id != 0:
                        cancel_flag = True
                        cancel_loop_count = 0
                    last_trade_func = 'ask'
                    last_trade_size = amount
                    last_trade_price_pre = last_trade_price
                    last_trade_price = current_price - 5
                    last_trade_order_id = order_id
                    trade_hold_count = 0
                    asset_info = True
                    dead_cross_flag = True
                    if last_trade_price_pre < last_trade_price:
                        profit_count += 1
                        last_trade_type = 2
                    else:
                        loss_count += 1
                        last_trade_type = 3

                    message_func += '、デットクロス'
                    message_trade = 'ask'
                    message_price = current_price - 5
                    message_size = amount
                    message_text = EXCHANGE + '■ デットクロス売却申請: ' + str(date_time)
                    message_text += '\nPrice:' + str(current_price - 5) + '\nSize:' + str(amount)
                    print(message_text)
                    slack_notify(message_text)

        # コインを持っていて
        if (dead_cross_flag and funds_coin >= 0.0001 and (current_price * 0.997) > last_trade_price
                and trade_hold_count > TRADE_HOLD_MAX):
            if current_price > current_price_pre and (current_price * 0.995) < last_trade_price:
                print('上昇傾向なので保留')
                message_func += '、上昇傾向'
            else:

                # 売却
                amount = funds_coin
                adjustment = 0
                if current_price > current_price_pre:
                    adjustment = 10
                elif current_price == current_price_pre:
                    adjustment = 5
                else:
                    adjustment = 0

                # 売り
                # order_flag, order_id = order_limit_call('sell', amount, current_price - 5 + adjustment)
                #####################################
                # テスト用                          #
                time.sleep(1)
                user_coin_asset -= float(amount)
                user_jpy_asset += ((current_price - 5 + adjustment) * float(amount))
                order_flag = True
                order_id = 0
                #                                   #
                #####################################

                if order_flag:
                    if order_id != 0:
                        cancel_flag = True
                        cancel_loop_count = 0
                    last_trade_func = 'ask'
                    last_trade_size = amount
                    last_trade_price_pre = last_trade_price
                    last_trade_price = current_price - 5 + adjustment
                    last_trade_order_id = order_id
                    last_trade_type = 1
                    trade_hold_count = 0
                    asset_info = True
                    profit_count += 1

                    message_func += '、利確1'
                    message_trade = 'ask'
                    message_price = current_price - 5 + adjustment
                    message_size = amount

                    message_text = EXCHANGE + '■ 利確1売却申請: ' + str(date_time)
                    message_text += '\nPrice:' + str(current_price - 5 + adjustment)
                    message_text += '\nSize:' + str(amount)
                    print(message_text)
                    slack_notify(message_text)

        # コインを持っていて平均より2%低い場合に損切り
        elif (dead_cross_flag and funds_coin >= 0.0001 and trade_hold_count > TRADE_HOLD_MAX
              and current_price < (last_trade_price * 0.998)):
            amount = funds_coin
            # 売り
            # order_flag, order_id = order_limit_call('sell', amount, current_price - 5)
            #####################################
            # テスト用                          #
            time.sleep(1)
            user_coin_asset -= float(amount)
            user_jpy_asset += ((current_price - 5) * float(amount))
            order_flag = True
            order_id = 0
            #                                   #
            #####################################

            if order_flag:
                if order_id != 0:
                    cancel_flag = True
                    cancel_loop_count = 0
                last_trade_func = 'ask'
                last_trade_size = amount
                last_trade_price_pre = last_trade_price
                last_trade_price = current_price - 5
                last_trade_order_id = order_id
                last_trade_type = 3
                trade_hold_count = 0
                asset_info = True
                loss_count += 1

                message_func += '、損切'
                message_trade = 'ask'
                message_price = current_price - 5
                message_size = amount

                message_text = EXCHANGE + '■ 損切売却申請: ' + str(date_time)
                message_text += '\nPrice:' + str(current_price - 5) + '\nSize:' + str(amount)
                print(message_text)
                slack_notify(message_text)

        # コインを最小単位持っていない場合で
        elif (funds_coin < 0.0001 and trade_hold_count > TRADE_HOLD_MAX and last_trade_order_id == 0
              and macd_macd > macd_signal and macd_macd_pre < macd_signal_pre):
            amount = Decimal(funds_jpy * 0.9 / current_price).quantize(Decimal('0.0001'))

            # 買い
            # order_flag, order_id = order_limit_call('buy', amount, current_price)
            #####################################
            # テスト用                          #
            time.sleep(1)
            user_coin_asset += float(amount)
            user_jpy_asset -= (current_price * float(amount))
            order_flag = True
            order_id = 0
            #                                   #
            #####################################

            if order_flag:
                if order_id != 0:
                    cancel_flag = True
                    cancel_loop_count = 0
                last_trade_func = 'bid'
                last_trade_size = amount
                last_trade_price_pre = last_trade_price
                last_trade_price = current_price
                last_trade_order_id = order_id
                last_trade_type = 0
                trade_hold_count = 0
                dead_cross_flag = False
                asset_info = True

                message_func += '、購入'
                message_trade = 'bid'
                message_price = current_price
                message_size = amount

                message_text = EXCHANGE + '■ 購入申請: ' + str(date_time)
                message_text += '\nPrice:' + str(current_price) + '\nSize:' + str(amount)
                print(message_text)
                slack_notify(message_text)

        if cancel_flag and cancel_loop_count > CANCEL_LOOP_MAX:
            order_flag, order_id, order_status = order_check()
            if order_flag:
                if order_id == 0:
                    print("■ 約定しました。")
                    message_func += '、約定'
                    message_text = EXCHANGE + '■ 約定しました'
                    slack_notify(message_text)
                    asset_info = True
                    last_trade_order_id = 0
                    cancel_flag = False
                else:
                    try:
                        print("■ キャンセルしました")
                        print(exchange.cancel_order(order_id, COIN_PAIR))
                    except (ccxt.RequestTimeout, ccxt.ExchangeNotAvailable, ccxt.ExchangeError):
                        error_log.write()
                        print("エラー:cant trade[info/cancel]")
                    else:
                        trade_hold_count = TRADE_HOLD_MAX
                        last_trade_price = last_trade_price_pre
                        message_func += '、キャンセル'
                        message_text = EXCHANGE + '■ キャンセルしました'
                        slack_notify(message_text)
                        asset_info = True
                        if last_trade_type == 1 or last_trade_type == 2:
                            profit_count -= 1
                        elif last_trade_type == 3:
                            loss_count -= 1
                        last_trade_type = 0
                        last_trade_order_id = 0
                        cancel_flag = False

        if sma_flag:
            trade_log.write(
                func=message_func,
                coin_asset=funds_coin,
                jpy_asset=funds_jpy,
                market_price=current_price,
                market_bid_price=current_bid_price,
                market_ask_price=current_ask_price,
                order_id=last_trade_order_id,
                trade=message_trade,
                last_trade_price=last_trade_price,
                price=message_price,
                size=message_size,
                mean_line1=sma_avg1,
                mean_line2=sma_avg2,
                bid_amount=bid_amount,
                ask_amount=ask_amount,
                bid_depth_amount=bid_depth_amount,
                ask_depth_amount=ask_depth_amount,
                sigma2=sma_sigma,
                macd=macd_macd,
                signal=macd_signal)

            cancel_loop_count += 1
            trade_hold_count += 1

        if funds_coin < 0.0001 and END_FLAG and last_trade_order_id == 0:
            message_text = EXCHANGE + 'プログラム終了\n' + str(date_time) + '\njpy資産:'
            message_text += str(funds_jpy) + '\n' + COIN_NAME + '資産:' + str(funds_coin)
            message_text += '\nProfit:' + str(profit_count) + ' Loss:' + str(loss_count)
            message_text += '\nGain:' + str(funds_jpy - start_funds_jpy)
            print(message_text)
            slack_notify(message_text)
            exit()

        if date_time > end_datetime:
            END_FLAG = True

        end_time = time.time()
        elpsed_time = end_time - start_time
        if elpsed_time > LOOP_TIME:
            elpsed_time %= LOOP_TIME
            print('ake time over', str(LOOP_TIME), 'sec')

        time.sleep(LOOP_TIME - elpsed_time)

Monappy: MBDQ39VHypMQwfyR8SshuHvfPNUz321F6B

Monacoinを投げる
モナゲ(tipmona)ってなに?
そもそもMonacoinってなに?

コメントを残す

メールアドレスが公開されることはありません。

このサイトはスパムを低減するために Akismet を使っています。コメントデータの処理方法の詳細はこちらをご覧ください