from __future__ import absolute_import, unicode_literals

from celery import shared_task , task
from userapp.models import *
from .models import *
import requests
import json


@task
def get_coins():
	pass



@task
def get_mazacoins():
	print('celery task started')
	address = {}
	corn_coins = {}
	try:
		data = UserCoinInfo.objects.all()
		for i in data:
			address[i.user_id] = i.coinaddress
		for i in address:
			coinaddress_val = address[i]
			url = 'http://173.199.124.155:2100/MazaCoinService.asmx/Get_Balance_By_Addres?ADDRESS=' + coinaddress_val + '&PASSWORD=0nly@Coin123'
			resp = requests.get(url)
			if resp.status_code == 200:
				json_resp = json.loads(resp.text)
				if json_resp:
					if json_resp['Success'] == 1:
						availablecoin = json_resp['Result']
			corn_coins[i] = availablecoin
		for i in corn_coins:
			UserInfo.objects.filter(user_id=i).update(corn_coins=float(corn_coins[i]))
	except:
		pass