python_test/BankEra_Bot.py at master · BankeraJAPAN/python_test · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
from twitter import Twitter, OAuth
import discord
import urllib.request as req
import json
import pickle

#from coinmarketcap import Market
#from bs4 import BeautifulSoup


# 本番token
#token = "NDA1MzY1ODI0NDQyOTkwNTky.DUjV6A.kVeYsW0rldoLX4BtKczQCiXqI58"
token = "NDI3NzAyNTQ4NTI3NDQ4MDY2.DZswPw.S0PAw61ckAypOKczqXjsdHTzinY"
# テストtoken
#token = "NDA0NjE4MDA4MjA0NTQxOTYy.DUoAtQ.DqDyvVDhSIQSMD-KNRtx86WKRgo"
# 1万円計算用
yukichi = 10000

#Twitter Auth
t = Twitter(auth=OAuth(
    '935058768563339265-7eIsN2892DRYL6tCrTjzPGnySQQUHfr',
    'G3xDy4lUsRBQbR3GQ1ZEF7ankZgNY64gBpf7x0edPwBxF',
    'xMzUeWmIimG83P9QMhFnENCG4',
    'REDBG6CH9LkiR5ACBgB5hNBEYnwP00Als7TLi39WZCSdS3qLcG'
))

client = discord.Client()
client.get_all_members()


@client.event
async def on_ready():
    print('Logged in as')
    print(client.user.name)
    print(client.user.id)
    print('------')


@client.event
async def on_message(message):
    # 送り主がBotだった場合反応したくないので
    if client.user != message.author:
        if message.content.startswith("?エラリスト") | message.content.startswith("？エラリスト"):
            count = 0
            for member in client.get_all_members():
                count += 1
            m = "報告します！ 現在 " + str(count) + "人のエラリストが参加中です！"
            # メッセージが送られてきたチャンネルへメッセージを送ります
            await client.send_message(message.channel, m)
        elif message.content.startswith("?btc") | message.content.startswith("?BTC"):
            # spectrocoinから相場価格を取得(From:BNK To:BTC)
            url = 'https://spectrocoin.com/scapi/ticker/BNK/BTC'
            res = req.urlopen(url)

            # 取得した価格をjsonに変換
            price_ticker = json.loads(res.read().decode('utf8'))

            # 価格のメッセージを設定し、出力
            echo = "1BTCで約" + str(round(price_ticker['last'], 1)) + "BNK購入できます。"
            await client.send_message(message.channel, echo)

        elif message.content.startswith("?xem") | message.content.startswith("?XEM"):
            # spectrocoinから相場価格を取得(From:BNK To:XEM)
            url = 'https://spectrocoin.com/scapi/ticker/BNK/XEM'
            res = req.urlopen(url)

            # 取得した価格をjsonに変換
            price_ticker = json.loads(res.read().decode('utf8'))

            # 価格のメッセージを設定し、出力
            echo = "1XEMで約" + str(round(price_ticker['last'], 1)) + "BNK購入できます。"
            await client.send_message(message.channel, echo)

        elif message.content.startswith("?eth") | message.content.startswith("?ETH"):
            # spectrocoinから相場価格を取得(From:BNK To:XEM)
            url = 'https://spectrocoin.com/scapi/ticker/BNK/ETH'
            res = req.urlopen(url)

            # 取得した価格をjsonに変換
            price_ticker = json.loads(res.read().decode('utf8'))

            # 価格のメッセージを設定し、出力
            echo = "1ETHで約" + str(round(price_ticker['last'], 1)) + "BNK購入できます。"
            await client.send_message(message.channel, echo)

        elif message.content.startswith("?諭吉") | message.content.startswith("？諭吉"):
            # spectrocoinから相場価格を取得(From:BNK To:JPY)
            url = 'https://spectrocoin.com/scapi/ticker/BNK/JPY'
            res = req.urlopen(url)
            # 取得した価格をjsonに変換
            price_ticker = json.loads(res.read().decode('utf8'))

            # １万円あたりの購入数を算出
            bankera = price_ticker['last'] * yukichi

            # 価格のメッセージを設定し、出力
            echo = "1万円で約" + str(round(bankera, 1)) + "BNK購入できます。"
            await client.send_message(message.channel, echo)

        elif message.content.startswith("?最新情報") | message.content.startswith("？最新情報"):
            #Get list from Twitter
                userTweets      = []
                #BankeraJP ID
                user_id         = '3308453287'
                #Get Tweet
                count           = 1
                #Get TimeLine
                aTimeLine = t.statuses.user_timeline(user_id=user_id, count=count)
                msg_t = aTimeLine[0]['text']
                f = open('sample.textfile','rb')
                if f:
                    load = pickle.load(f)

                    if msg_t != load:
                        await client.send_message(message.channel, msg_t)
                    else:
                        await client.send_message(message.channel, '前回と内容が一緒です')
                        await client.send_message(message.channel, msg_t)
                else:
                    await client.send_message(message.channel, msg_t)

                f = open('sample.textfile','wb')
                pickle.dump(msg_t,f)
                f.close

client.run(token)