提交数据

core/CoreApp/models/Model_logic_ding.php

@@ -87,4 +87,54 @@ class Model_logic_ding extends Lin_Model {
             'create_time'=>time(),
         ]);
     }
+
+    /**
+     * 发送执行队列  
+     * @param string $job_name 队列名称
+     * @param array $params 队列参数
+     * @param int $delay 延迟时间
+     * @param string $queue_name 队列名称
+     */
+    public function sendJobs($job_name,$params,$delay,$queue_name){
+        $data = json_encode([
+            'job_name'=>$job_name,
+            'params'=>$params,
+            'delay'=>$delay,
+            'queue_name'=>$queue_name,
+        ],JSON_UNESCAPED_UNICODE);
+		$token = openssl_encrypt("erp@laravel-".time(),'AES-128-CBC',"v!lvhaonjgir6amg",0,"k!lyerp6jt!6ook4");
+        $ch = curl_init("http://mylaravel.local/api/index");
+        // 设置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"
+        );
+        // 应用这些选项到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
+           ];
+       }
+      
+       // 关闭cURL会话
+       curl_close($ch);  
+    }
 }