import pandas as pd
import random
import ccxt
import threading, time, datetime
import json
import urllib
import datetime
import requests

# 異常監(jiān)控用
def send_dingding_msg1(content, robot_id='你的釘釘機器人ID'):
  try:
    msg = {
      "msgtype": "text",
      "text": {"content": content + '\n' + datetime.datetime.now().strftime("%m-%d %H:%M:%S")}
    }
    headers = {"Content-Type": "application/json ;charset=utf-8 "}
    url = 'https://oapi.dingtalk.com/robot/send?access_token=' + robot_id
    body = json.dumps(msg)
    status = requests.post(url, data=body, headers=headers)
    if status.status_code == 200:
      return status.json()
    return status
  except Exception as err:
print ( '釘釘發(fā)送失敗' , err)

while True:
  try:
    address = '你的比特幣錢包地址' # 比特幣錢包地址
    url = 'https://chain.api.btc.com/v3/address/' + address # 獲取余額地址
    # 可以用f'https://chain.api.btc.com/v3/address/{address}'替代
    response = requests.get(url)
    if response.text: # 發(fā)現(xiàn)有時候會出現(xiàn)錯誤導致返回數(shù)據(jù)為空，加此目的當數(shù)據(jù)為空時繼續(xù)獲取余額
      # print(response.json())
      BTC = float(response.json()['data']['balance']) / 10e7 # 科學計數(shù)法，處理返回數(shù)據(jù)
      print('BTC', BTC)
    else:
      continue
    if BTC > 1: # 當余額大于1時實現(xiàn)釘釘提醒
      print('BTC', BTC)
      content = 'BTC錢包充值到賬' #
      send_msg1 = send_dingding_msg1(content)
      print(send_msg1)
      break
    time.sleep(5)
  except Exception as order_err:
    print("查詢出錯，繼續(xù)嘗試", order_err)
    time.sleep(3)

while True:
  try:
    apikey = '你在https://etherscan.io申請的apikey'
    address = '你的以太坊地址'
    # 查詢以太坊地址
    url1 = 'https://api.etherscan.io/api?module=account&action=balance&address='+address+'&tag=latest&apikey='+apikey

    # 查詢ERC20地址
    contractaddress = '0xd26114cd6EE289AccF82350c8d8487fedB8A0C07' ##OMG合約地址
    url2 = 'https://api.etherscan.io/api?module=account&action=tokenbalance&contractaddress='+ contractaddress+ '&address='+ address+'&tag=latest&apikey='+ apikey
    response1 = requests.get(url1)
    response2 = requests.get(url2)
    # print(response.json())
    asset1 = 'ETH'
    asset2 = 'OMG'
    ban1 = float(response1.json()['result']) / 10e17 # 科學計數(shù)法，處理返回數(shù)據(jù)
    ban2 = float(response2.json()['result']) / 10e17 # 科學計數(shù)法，處理返回數(shù)據(jù)
    print(asset1, ban1)
    print(asset2, ban2)
    if ban1 > 10:
      print(asset1, ban1)
      content = 'ETH錢包充值到賬'
      send_msg1 = send_dingding_msg1(content)
      print(send_msg1)
      break
    time.sleep(5)
  except Exception as order_err:
    print("查詢出錯，繼續(xù)嘗試", order_err)
    time.sleep(3)

while True:
  try:
    url = "https://api.chainx.org.cn/account/你的PCX錢包地址/balance"
    headers = {
      "Content-type": "application/json; charset=utf-8",
      'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/76.0.3809.100 Safari/537.36'
    }
    response = requests.get(url, headers=headers)
    balance = response.json()
    # print(balance)
    asset = 'PCX'
    PCX = balance[1]['Free']/100000000 # 此處注意PCX代幣的位置，如果在第0個就改成[0]
    print('PCX', PCX)

    if PCX > 30:
      print('PCX', PCX)
      content = 'PCX購買已到賬，余額為' + str(PCX) # 發(fā)一個變量，用str轉換下
      send_msg1 = send_dingding_msg1(content)
      print(send_msg1)
      break
    time.sleep(3)
  except Exception as order_err:
    print("查詢出錯，繼續(xù)嘗試", order_err)
    time.sleep(3)