提交logic_ding

core/CoreApp/models/Model_logic_ding.php

@@ -137,4 +137,67 @@ class Model_logic_ding extends Lin_Model {
        // 关闭cURL会话
        curl_close($ch);  
     }
+
+    public function sendJobs2($url,$job_name,$params,$delay,$queue_name){
+         $data = json_encode([
+            'job_name'=>$job_name,
+            'params'=>$params,
+            'delay'=>$delay,
+            'queue_name'=>$queue_name,
+        ],JSON_UNESCAPED_UNICODE);
+        if ($data === false) {
+            return ['code' => -1, 'msg' => 'JSON encode failed: ' . json_last_error_msg()];
+        }
+		$token = openssl_encrypt("erp@laravel-".time(),'AES-128-CBC',"v!lvhaonjgir6amg",0,"k!lyerp6jt!6ook4");
+
+        // 3. 检查 curl_init
+        $ch = curl_init("http://mylaravel.local".$url);
+
+        if ($ch === false) {
+            return ['code' => -1, 'msg' => 'cURL init failed'];
+        }
+
+        // 设置cURL选项 
+        $options = array(
+            CURLOPT_SSL_VERIFYPEER=>false,
+            CURLOPT_SSL_VERIFYHOST=>false,
+            CURLOPT_RETURNTRANSFER => true,   
+            CURLOPT_POST => true,             
+            CURLOPT_POSTFIELDS => $data,  
+            CURLOPT_HTTPHEADER => [
+                'Content-Type: application/json',
+				'Authorization: Bearer '.$token
+            ],
+            CURLOPT_ENCODING => "gzip,deflate",
+            // 新增超时
+            CURLOPT_TIMEOUT        => 60,
+            CURLOPT_CONNECTTIMEOUT => 10,
+        );
+        // 应用这些选项到cURL会话
+        curl_setopt_array($ch, $options);
+
+        // 执行cURL会话并获取响应
+        $response = curl_exec($ch);
+       
+        
+          // 检查是否有错误发生
+       if ($response === false) {
+           $error = curl_error($ch);
+           curl_close($ch);
+           return [
+               "code"=> -1,
+               "msg"=> $error
+           ];
+       }
+
+       // 5. 检查 HTTP 状态码
+       $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+       curl_close($ch);
+
+       if ($httpCode >= 400) {
+            return ['code' => -1, 'msg' => "HTTP error: {$httpCode}", 'data' => $response];
+       }
+      
+       return $response;
+    }
 }