erp/core/CoreApp/models/Model_logic_ding.php

<?php
/**
 * 对接crm接口
 */
class Model_logic_ding extends Lin_Model {
    function __construct(){
        parent::__construct();
        $this->load->_model("Model_logic_tools","logic_tools");
        $this->load->_model("Model_zzjobs","zzjobs");
        $this->load->_model("Model_zzerrlog","zzerrlog");
    }
    public $key = "ly20250115@0911";

    //public $key = "Hello, World!";


    public function getKey(){
        return $this->key;
    }

    public function sendToDing($error_msg){
        $this->zzerrlog->insert([
            'content'=>$error_msg,
            'created_time'=>date("Y-m-d H:i:s"),
            'time'=>time(),      
        ]);
    }


    public function sendToTmp($error_msg){
        $this->db->insert("crowd_zzlinshi",[
            'content'=>$error_msg,
            'created_time'=>date("Y-m-d H:i:s"),
            'time'=>time(),      
        ]);
    }
    public $url = "http://a25.wepolicy.cn/errorlog/ding";
   
    // public function sendToDing($error_msg){
    //     $data = [
    //         'bs'=>$this->logic_tools->toolsjiami($this->key),
    //         'content'=>$error_msg,
    //     ];
    //     $data = json_encode($data,JSON_UNESCAPED_UNICODE);
    //     $ch = curl_init($this->url);
    //     // 设置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'
    //         ],
    //         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);  
    // }
    /**
     * 添加到执行队列上
     */
    public function addJobs($type,$params){
        $this->zzjobs->insert([
            'status'=>0,
            'quque'=>$type,
            'payload'=>json_encode($params),
            'do_interval'=>1,
            '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);  
    }
}