更新

app/common/dao/store/consumption/CommissionDao.php

@@ -10,6 +10,7 @@ use app\common\model\system\merchant\FinancialRecord;
 use app\common\model\system\merchant\Merchant;
 use app\common\model\user\User;
 use app\common\repositories\system\merchant\MerchantRepository;
+use crmeb\utils\AsynClient;
 use crmeb\utils\Curl;
 use think\facade\Log;
 
@@ -139,8 +140,10 @@ class CommissionDao
         $iv = $aes->buildIv($timestamp);
         $encrypt = $aes->encrypt($json, $iv);
         $api = in_array($type, [1, 2]) ? 'user_first_order_share_profit' : 'user_order_share_profit';
-        $url = env('task.new_worker_host_url') . '/api/shop_call/' . $api;
+        // $url = env('task.new_worker_host_url') . '/api/shop_call/' . $api;
-        $result = $curl->post($url, ['timestamp' => $timestamp, 'data' => $encrypt]);
+        // $result = $curl->post($url, ['timestamp' => $timestamp, 'data' => $encrypt]);
+        (new AsynClient())->post( env('task.new_worker_host_url'),'/api/shop_call/' . $api,$encrypt);
+
         // $result = json_decode($result, true);
         // if ($result['code'] != 1) {
         //     Log::error('发送佣金失败：' . var_export($result, true));

crmeb/utils/AsynClient.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace crmeb\utils;
+use Swoole\Coroutine\Http\Client;
+use function Swoole\Coroutine\run;
+
+class AsynClient
+{
+
+    function post($host='',$url='',$data)
+    {
+        run(function () use($host,$url,$data) {
+            $cli = new Client($host);
+            $cli->post($url,$data);
+            echo $cli->body;
+            $cli->close();
+        });
+    }
+}