Skip to content

T
token
Commit 0cc5438b authored by shajiaiming's avatar shajiaiming
Browse files
Options

取消重发逻辑

parent 2972a593
Hide whitespace changes
Inline Side-by-side
Showing with 17 additions and 13 deletions
console/controllers/CrossChainController.php
View file @ 0cc5438b
...@@ -36,11 +36,11 @@ class CrossChainController extends Controller ...@@ -36,11 +36,11 @@ class CrossChainController extends Controller
continue; continue;
} }
} }
$cache_transfering_time = $redis->hget(CoinCrossChain::CROSS_CHAIN_TRANSFERING, $val['address'] . ':' . $val['is_with_draw'] . ':' . $val['id']); // $cache_transfering_time = $redis->hget(CoinCrossChain::CROSS_CHAIN_TRANSFERING, $val['address'] . ':' . $val['is_with_draw'] . ':' . $val['id']);
if (true == $cache_transfering_time) { // if (true == $cache_transfering_time) {
continue; // continue;
} // }
$redis->hmset(CoinCrossChain::CROSS_CHAIN_TRANSFERING, $val['address'] . ':' . $val['is_with_draw'] . ':' . $val['id'], $current_time); // $redis->hmset(CoinCrossChain::CROSS_CHAIN_TRANSFERING, $val['address'] . ':' . $val['is_with_draw'] . ':' . $val['id'], $current_time);
go(function () use ($val, $redis) { go(function () use ($val, $redis) {
\Co::sleep(0.5); \Co::sleep(0.5);
...@@ -64,18 +64,22 @@ class CrossChainController extends Controller ...@@ -64,18 +64,22 @@ class CrossChainController extends Controller
$currentModel->msg = 0; $currentModel->msg = 0;
$currentModel->save(); $currentModel->save();
$redis->hdel(CoinCrossChain::CROSS_CHAIN_TRANSFERING, $val['address'] . ':' . $val['is_with_draw'] . ':' . $val['id']); $redis->hdel(CoinCrossChain::CROSS_CHAIN_TRANSFERING, $val['address'] . ':' . $val['is_with_draw'] . ':' . $val['id']);
} } else {
if (0 != $result['code'] && (true == strstr($result['msg'], 'Balance'))) {
$currentModel = CoinCrossChain::findOne($val['id']); $currentModel = CoinCrossChain::findOne($val['id']);
$currentModel->msg = $result['msg']; $currentModel->msg = $result['msg'];
$currentModel->save(); $currentModel->save();
$redis->hdel(CoinCrossChain::CROSS_CHAIN_TRANSFERING, $val['address'] . ':' . $val['is_with_draw'] . ':' . $val['id']);
} else if (0 != $result['code'] && (false == strstr($result['msg'], 'ErrDupTx'))) {
$redis->hdel(CoinCrossChain::CROSS_CHAIN_TRANSFERING, $val['address'] . ':' . $val['is_with_draw'] . ':' . $val['id']);
} else {
} }
// if (0 != $result['code'] && (true == strstr($result['msg'], 'Balance'))) {
// $currentModel = CoinCrossChain::findOne($val['id']);
// $currentModel->msg = $result['msg'];
// $currentModel->save();
// $redis->hdel(CoinCrossChain::CROSS_CHAIN_TRANSFERING, $val['address'] . ':' . $val['is_with_draw'] . ':' . $val['id']);
// } else if (0 != $result['code'] && (false == strstr($result['msg'], 'ErrDupTx'))) {
// $redis->hdel(CoinCrossChain::CROSS_CHAIN_TRANSFERING, $val['address'] . ':' . $val['is_with_draw'] . ':' . $val['id']);
// } else {
//
// }
}); });
} }
echo date('Y-m-d H:i:s') . ' STEP: ' . $step . '跨链交易成功' . PHP_EOL; echo date('Y-m-d H:i:s') . ' STEP: ' . $step . '跨链交易成功' . PHP_EOL;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment