fix

console/controllers/IssueCoinController.php

@@ -4,6 +4,7 @@ namespace console\controllers;
 
 use common\models\psources\Coin;
 use common\models\psources\CoinIssueCoin;
+use common\models\psources\CoinIssueTransfer;
 use common\service\chain33\Chain33Service;
 use Yii;
 use yii\console\Controller;
@@ -69,6 +70,15 @@ class IssueCoinController extends Controller
 
     public function actionManualIssue()
     {
+        $issue_transfer = CoinIssueTransfer::find()->where(['send_result' => 0, 'msg' => 0])->asArray()->all();
+        if (false == $issue_transfer) {
+            echo date('Y-m-d H:i:s') . '暂无发行任务' . PHP_EOL;
+            return 0;
+        }
+        foreach ($issue_transfer as $val) {
+
+        }
+
         $issue_coin_model = CoinIssueCoin::find()
             ->select('id, name, platform_id, symbol, introduction, total, category, owner')
             ->where(['status' => CoinIssueCoin::ALLOW_ISSUE])
@@ -83,8 +93,8 @@ class IssueCoinController extends Controller
         $node = Yii::$app->params['chain_nodes']['STO'];
         $chain_service = new Chain33Service($node);
         foreach ($issue_coin_model as $issue_coin) {
-            go(function () use ($issue_coin, $chain_service) {
-                \Co::sleep(0.5);
+            #go(function () use ($issue_coin, $chain_service) {
+            #    \Co::sleep(0.5);
                 $params = [
                     'name' => $issue_coin->name,
                     'symbol' => $issue_coin->symbol,
@@ -114,7 +124,7 @@ class IssueCoinController extends Controller
                         'id' => $issue_coin['id'],
                     ]);
                 }
-            });
+            #});
         }
         echo date('Y-m-d H:i:s') . '发行成功' . PHP_EOL;
         return 0;