mirror of
https://github.com/LBRYFoundation/pool.git
synced 2025-09-20 10:09:09 +00:00
273 lines
8.5 KiB
PHP
273 lines
8.5 KiB
PHP
<?php
|
|
|
|
function doCryptopiaCancelOrder($OrderID=false)
|
|
{
|
|
if(!$OrderID) return;
|
|
|
|
$params = array('CancelType'=>'Trade', 'OrderId'=>$OrderID);
|
|
$res = cryptopia_api_user('CancelTrade', $params);
|
|
if($res && $res->Success) {
|
|
$db_order = getdbosql('db_orders', "market=:market AND uuid=:uuid", array(
|
|
':market'=>'cryptopia', ':uuid'=>$OrderID
|
|
));
|
|
if($db_order) $db_order->delete();
|
|
}
|
|
}
|
|
|
|
function doCryptopiaTrading($quick=false)
|
|
{
|
|
$savebalance = getdbosql('db_balances', "name='cryptopia'");
|
|
if(!$savebalance) return;
|
|
|
|
$balances = cryptopia_api_user('GetBalance');
|
|
|
|
if (is_object($balances) && is_array($balances->Data))
|
|
foreach($balances->Data as $balance)
|
|
{
|
|
if ($balance->Symbol == 'BTC') {
|
|
$savebalance->balance = $balance->Available;
|
|
$savebalance->save();
|
|
continue;
|
|
}
|
|
|
|
if (!YAAMP_ALLOW_EXCHANGE) {
|
|
// store available balance in market table
|
|
$coins = getdbolist('db_coins', "symbol=:symbol OR symbol2=:symbol",
|
|
array(':symbol'=>$balance->Symbol)
|
|
);
|
|
if (empty($coins)) continue;
|
|
foreach ($coins as $coin) {
|
|
$market = getdbosql('db_markets', "coinid=:coinid AND name='cryptopia'", array(':coinid'=>$coin->id));
|
|
if (!$market) continue;
|
|
if ($market->balance != $balance->Available) {
|
|
$market->balance = $balance->Available;
|
|
$market->message = $balance->StatusMessage;
|
|
if (property_exists($balance, 'Address'))
|
|
if (!empty($balance->Address) && $market->deposit_address != $balance->Address) {
|
|
debuglog("cryptopia: {$coin->symbol} deposit address updated");
|
|
$market->deposit_address = $balance->Address;
|
|
}
|
|
$market->save();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (!YAAMP_ALLOW_EXCHANGE) return;
|
|
|
|
$flushall = rand(0, 8) == 0;
|
|
if($quick) $flushall = false;
|
|
|
|
$min_btc_trade = 0.00001000; // minimum allowed by the exchange
|
|
$sell_ask_pct = 1.05; // sell on ask price + 5%
|
|
$cancel_ask_pct = 1.20; // cancel order if our price is more than ask price + 20%
|
|
|
|
// auto trade
|
|
foreach ($balances->Data as $balance)
|
|
{
|
|
if ($balance->Total == 0) continue;
|
|
if ($balance->Symbol == 'BTC') continue;
|
|
|
|
$coin = getdbosql('db_coins', "symbol=:symbol AND dontsell=0", array(':symbol'=>$balance->Symbol));
|
|
if(!$coin) continue;
|
|
$symbol = $coin->symbol;
|
|
if (!empty($coin->symbol2)) $symbol = $coin->symbol2;
|
|
|
|
$market = getdbosql('db_markets', "coinid=:coinid AND name='cryptopia'", array(':coinid'=>$coin->id));
|
|
if(!$market) continue;
|
|
$market->balance = $balance->HeldForTrades;
|
|
$market->message = $balance->StatusMessage;
|
|
|
|
$market2 = getdbosql('db_markets', "coinid={$coin->id} AND (name='bittrex' OR name='poloniex')");
|
|
if($market2) continue;
|
|
|
|
$orders = NULL;
|
|
if ($balance->HeldForTrades > 0) {
|
|
sleep(1);
|
|
$params = array('Market'=>$balance->Symbol."/BTC");
|
|
$orders = cryptopia_api_user('GetOpenOrders', $params);
|
|
|
|
sleep(1);
|
|
$ticker = cryptopia_api_query('GetMarket', $market->marketid);
|
|
if(!$ticker || !$ticker->Success || !$ticker->Data) continue;
|
|
}
|
|
|
|
// {"Success":true,"Error":null,"Data":[
|
|
// {"OrderId":1067904,"TradePairId":2186,"Market":"CHC\/BTC","Type":"Sell","Rate":4.8e-6,"Amount":1500,"Total":0.0072,
|
|
// "Remaining":1500,"TimeStamp":"2016-02-01T16:18:44.839246"},
|
|
if(is_object($orders) && $orders->Success && !empty($orders->Data))
|
|
foreach($orders->Data as $order)
|
|
{
|
|
$pairs = explode("/", $order->Market);
|
|
$pair = $order->Market;
|
|
if ($pairs[1] != 'BTC') continue;
|
|
|
|
// ignore buy orders
|
|
if(stripos($order->Type, 'Sell') === false) continue;
|
|
|
|
if($market->marketid == 0) {
|
|
$market->marketid = $order->TradePairId;
|
|
$market->save();
|
|
}
|
|
|
|
$ask = bitcoinvaluetoa($ticker->Data->AskPrice);
|
|
$sellprice = bitcoinvaluetoa($order->Rate);
|
|
|
|
// cancel orders not on the wanted ask range
|
|
if($sellprice > $ask*$cancel_ask_pct || $flushall)
|
|
{
|
|
debuglog("cryptopia: cancel order $pair at $sellprice, ask price is now $ask");
|
|
sleep(1);
|
|
doCryptopiaCancelOrder($order->OrderId);
|
|
//$params = array('CancelType'=>'Trade', 'OrderId'=>$order->OrderId);
|
|
//cryptopia_api_user('CancelTrade', $params);
|
|
|
|
//$db_order = getdbosql('db_orders', "market=:market AND uuid=:uuid", array(
|
|
// ':market'=>'cryptopia', ':uuid'=>$order->OrderId
|
|
//));
|
|
//if($db_order) $db_order->delete();
|
|
}
|
|
// store existing orders
|
|
else
|
|
{
|
|
$db_order = getdbosql('db_orders', "market=:market AND uuid=:uuid", array(
|
|
':market'=>'cryptopia', ':uuid'=>$order->OrderId
|
|
));
|
|
if($db_order) continue;
|
|
|
|
// debuglog("cryptopia: store order of {$order->Amount} {$symbol} at $sellprice BTC");
|
|
$db_order = new db_orders;
|
|
$db_order->market = 'cryptopia';
|
|
$db_order->coinid = $coin->id;
|
|
$db_order->amount = $order->Amount;
|
|
$db_order->price = $sellprice;
|
|
$db_order->ask = $ticker->Data->AskPrice;
|
|
$db_order->bid = $ticker->Data->BidPrice;
|
|
$db_order->uuid = $order->OrderId;
|
|
$db_order->created = time(); // $order->TimeStamp 2016-03-07T20:04:05.3947572"
|
|
$db_order->save();
|
|
}
|
|
}
|
|
|
|
// drop obsolete orders
|
|
$list = getdbolist('db_orders', "coinid={$coin->id} AND market='cryptopia'");
|
|
foreach($list as $db_order)
|
|
{
|
|
$found = false;
|
|
if(is_object($orders) && $orders->Success)
|
|
foreach($orders->Data as $order) {
|
|
if(stripos($order->Type, 'Sell') === false) continue;
|
|
if($order->OrderId == $db_order->uuid) {
|
|
$found = true;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if(!$found) {
|
|
// debuglog("cryptopia: delete db order {$db_order->amount} {$coin->symbol} at {$db_order->price} BTC");
|
|
$db_order->delete();
|
|
}
|
|
}
|
|
|
|
if($coin->dontsell) continue;
|
|
|
|
$market->lasttraded = time();
|
|
$market->save();
|
|
|
|
// new orders
|
|
$amount = floatval($balance->Available);
|
|
if(!$amount) continue;
|
|
|
|
if($amount*$coin->price < $min_btc_trade || !$market->marketid) continue;
|
|
|
|
sleep(1);
|
|
$data = cryptopia_api_query('GetMarketOrders', $market->marketid."/5");
|
|
if(!$data || !$data->Success || !$data->Data) continue;
|
|
|
|
if($coin->sellonbid)
|
|
for($i = 0; $i < 5 && $amount >= 0; $i++)
|
|
{
|
|
if(!isset($data->Data->Buy[$i])) break;
|
|
|
|
$nextbuy = $data->Data->Buy[$i];
|
|
if($amount*1.1 < $nextbuy->Volume) break;
|
|
|
|
$sellprice = bitcoinvaluetoa($nextbuy->Price);
|
|
$sellamount = min($amount, $nextbuy->Volume);
|
|
|
|
if($sellamount*$sellprice < $min_btc_trade) continue;
|
|
|
|
debuglog("cryptopia: selling $sellamount $symbol at $sellprice");
|
|
sleep(1);
|
|
$params = array('TradePairId'=>$market->marketid, 'Type'=>'Sell', 'Rate'=>$sellprice, 'Amount'=>$sellamount);
|
|
$res = cryptopia_api_user('SubmitTrade', $params);
|
|
if(!$res || !$res->Success || !$res->Data) {
|
|
debuglog("cryptopia SubmitTrade err: ".json_encode($res));
|
|
break;
|
|
}
|
|
|
|
$amount -= $sellamount;
|
|
}
|
|
|
|
if($amount <= 0) continue;
|
|
|
|
sleep(1);
|
|
$ticker = cryptopia_api_query('GetMarket', $market->marketid);
|
|
if(!$ticker || !$ticker->Success || !$ticker->Data) continue;
|
|
|
|
if($coin->sellonbid)
|
|
$sellprice = bitcoinvaluetoa($ticker->Data->BidPrice);
|
|
else
|
|
$sellprice = bitcoinvaluetoa($ticker->Data->AskPrice * $sell_ask_pct); // lowest ask price +5%
|
|
if($amount*$sellprice < $min_btc_trade) continue;
|
|
|
|
debuglog("cryptopia: selling $amount $symbol at $sellprice");
|
|
|
|
sleep(1);
|
|
$params = array('TradePairId'=>$market->marketid, 'Type'=>'Sell', 'Rate'=>$sellprice, 'Amount'=>$amount);
|
|
$res = cryptopia_api_user('SubmitTrade', $params);
|
|
if(!$res || !$res->Success || !$res->Data) {
|
|
debuglog("cryptopia SubmitTrade err: ".json_encode($res));
|
|
continue;
|
|
}
|
|
|
|
$db_order = new db_orders;
|
|
$db_order->market = 'cryptopia';
|
|
$db_order->coinid = $coin->id;
|
|
$db_order->amount = $amount;
|
|
$db_order->price = $sellprice;
|
|
$db_order->ask = $ticker->Data->AskPrice;
|
|
$db_order->bid = $ticker->Data->BidPrice;
|
|
$db_order->uuid = $res->Data->OrderId;
|
|
$db_order->created = time();
|
|
$db_order->save();
|
|
}
|
|
|
|
// auto withdraw
|
|
if(floatval(EXCH_AUTO_WITHDRAW) > 0 && $savebalance->balance >= (EXCH_AUTO_WITHDRAW + 0.0002))
|
|
{
|
|
$btcaddr = YAAMP_BTCADDRESS;
|
|
$amount = $savebalance->balance + 0.0002;
|
|
debuglog("cryptopia: withdraw $amount BTC to $btcaddr");
|
|
|
|
sleep(1);
|
|
$params = array("Currency"=>"BTC", "Amount"=>$amount, "Address"=>$btcaddr);
|
|
$res = cryptopia_api_user('SubmitWithdraw', $params);
|
|
if(is_object($res) && $res->Success)
|
|
{
|
|
$withdraw = new db_withdraws;
|
|
$withdraw->market = 'cryptopia';
|
|
$withdraw->address = $btcaddr;
|
|
$withdraw->amount = $amount;
|
|
$withdraw->time = time();
|
|
$withdraw->uuid = $res->Data;
|
|
$withdraw->save();
|
|
|
|
$savebalance->balance = $savebalance->balance - $amount;
|
|
$savebalance->save();
|
|
} else {
|
|
debuglog("cryptopia withdraw BTC error: ".json_encode($res));
|
|
}
|
|
}
|
|
|
|
}
|