回传接口crm

app/Http/Services/CrmService.php

@@ -5,7 +5,6 @@ namespace App\Http\Services;
 use GuzzleHttp\Client;
 use App\Model\RedisModel;
 use App\Model\SupplierChannelModel;
-use Illuminate\Support\Facades\DB;
 
 class CrmService
 {
@@ -46,7 +45,7 @@ class CrmService
     }
 
     /**
-     * 回传CRM供应商转化确认结果
+     * 回传CRM供应商转化确认结果（队列推送）
      * @param string $supplierName 供应商名称
      * @param string $approverName 审批人姓名
      * @param string $approveResult 审批结果：completed(通过)/purchase_rejected(采购驳回)
@@ -56,55 +55,52 @@ class CrmService
     public static function confirmCrmSupplier($supplierName, $approverName, $approveResult, $remark = '')
     {
         try {
-            $url = env('CRM_URL') . '/open/customer/confirmSupplierApproval';
-            $client = new Client();
-            $response = $client->post($url, [
-                'form_params' => [
-                    'customer_name' => $supplierName,
-                    'approver' => $approverName,
-                    'approve_result' => $approveResult,
-                    'remark' => $remark,
-                ]
-            ]);
-            $result = json_decode($response->getBody()->getContents(), true);
-            if (isset($result['code']) && $result['code'] == 0) {
-                return true;
-            }
-            \Illuminate\Support\Facades\Log::warning('[CRM回传]回传审批结果失败', ['response' => $result, 'supplier_name' => $supplierName]);
-            return false;
+            $data = [
+                'customer_name' => $supplierName,
+                'approver' => $approverName,
+                'approve_result' => $approveResult,
+                'remark' => $remark,
+            ];
+            (new QueueDeliveryService())->setQueueName('lie_queue_crm')->push(
+                QueueDeliveryService::PUSH_TYPE_QUEUE,
+                '/sync/synSuppAuditResultToCrm',
+                $data,
+                (string)$supplierName
+            );
+            \Illuminate\Support\Facades\Log::info('[CRM回传]回传审批结果已推送到队列', ['supplier_name' => $supplierName, 'approve_result' => $approveResult]);
+            return true;
         } catch (\Exception $e) {
-            \Illuminate\Support\Facades\Log::error('[CRM回传]回传审批结果异常: ' . $e->getMessage(), ['supplier_name' => $supplierName]);
+            \Illuminate\Support\Facades\Log::error('[CRM回传]回传审批结果推送队列异常: ' . $e->getMessage(), ['supplier_name' => $supplierName]);
             return false;
         }
     }
 
     /**
-     * 同步供应商状态变更到CRM系统
+     * 同步供应商状态变更到CRM系统（队列推送）
      * @param string $supplierName 供应商名称
      * @param string $supplierStatus CRM供应商状态：rejected/passed/blacklist/disable_trade
      * @param string $remark 备注
+     * @param string $supplierName 供应商名称（作为searchKey）
      * @return bool
      */
     public static function syncSupplierStatus($supplierName, $supplierStatus, $remark = '')
     {
         try {
-            $url = env('CRM_URL') . '/open/customer/syncSupplierStatus';
-            $client = new Client();
-            $response = $client->post($url, [
-                'form_params' => [
-                    'customer_name' => $supplierName,
-                    'supplier_status' => $supplierStatus,
-                    'remark' => $remark,
-                ]
-            ]);
-            $result = json_decode($response->getBody()->getContents(), true);
-            if (isset($result['code']) && $result['code'] == 0) {
-                return true;
-            }
-            \Illuminate\Support\Facades\Log::warning('[CRM回传]同步供应商状态失败', ['response' => $result, 'supplier_name' => $supplierName]);
-            return false;
+            $data = [
+                'customer_name' => $supplierName,
+                'supplier_status' => $supplierStatus,
+                'remark' => $remark,
+            ];
+            (new QueueDeliveryService())->setQueueName('lie_queue_crm')->push(
+                QueueDeliveryService::PUSH_TYPE_QUEUE,
+                '/sync/synSuppAuditResultToCrm',
+                $data,
+                (string)$supplierName
+            );
+            \Illuminate\Support\Facades\Log::info('[CRM回传]同步供应商状态已推送到队列', ['supplier_name' => $supplierName, 'status' => $supplierStatus]);
+            return true;
         } catch (\Exception $e) {
-            \Illuminate\Support\Facades\Log::error('[CRM回传]同步供应商状态异常: ' . $e->getMessage(), ['supplier_name' => $supplierName]);
+            \Illuminate\Support\Facades\Log::error('[CRM回传]同步供应商状态推送队列异常: ' . $e->getMessage(), ['supplier_name' => $supplierName]);
             return false;
         }
     }