Model_logic_ding.php 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. <?php
  2. /**
  3. * 对接crm接口
  4. */
  5. class Model_logic_ding extends Lin_Model {
  6. function __construct(){
  7. parent::__construct();
  8. $this->load->_model("Model_logic_tools","logic_tools");
  9. $this->load->_model("Model_zzjobs","zzjobs");
  10. $this->load->_model("Model_zzerrlog","zzerrlog");
  11. }
  12. public $key = "ly20250115@0911";
  13. //public $key = "Hello, World!";
  14. public function getKey(){
  15. return $this->key;
  16. }
  17. public function sendToDing($error_msg){
  18. $this->zzerrlog->insert([
  19. 'content'=>$error_msg,
  20. 'created_time'=>date("Y-m-d H:i:s"),
  21. 'time'=>time(),
  22. ]);
  23. }
  24. public function sendToTmp($error_msg){
  25. $this->db->insert("crowd_zzlinshi",[
  26. 'content'=>$error_msg,
  27. 'created_time'=>date("Y-m-d H:i:s"),
  28. 'time'=>time(),
  29. ]);
  30. }
  31. public $url = "http://a25.wepolicy.cn/errorlog/ding";
  32. // public function sendToDing($error_msg){
  33. // $data = [
  34. // 'bs'=>$this->logic_tools->toolsjiami($this->key),
  35. // 'content'=>$error_msg,
  36. // ];
  37. // $data = json_encode($data,JSON_UNESCAPED_UNICODE);
  38. // $ch = curl_init($this->url);
  39. // // 设置cURL选项
  40. // $options = array(
  41. // CURLOPT_SSL_VERIFYPEER=>false,
  42. // CURLOPT_SSL_VERIFYHOST=>false,
  43. // CURLOPT_RETURNTRANSFER => true,
  44. // CURLOPT_POST => true,
  45. // CURLOPT_POSTFIELDS => $data,
  46. // CURLOPT_HTTPHEADER => [
  47. // 'Content-Type: application/json'
  48. // ],
  49. // CURLOPT_ENCODING => "gzip,deflate"
  50. // );
  51. // // 应用这些选项到cURL会话
  52. // curl_setopt_array($ch, $options);
  53. // // 执行cURL会话并获取响应
  54. // $response = curl_exec($ch);
  55. // // 检查是否有错误发生
  56. // if ($response === false) {
  57. // $error = curl_error($ch);
  58. // curl_close($ch);
  59. // return [
  60. // "code"=> -1,
  61. // "msg"=> $error
  62. // ];
  63. // }
  64. // // 关闭cURL会话
  65. // curl_close($ch);
  66. // }
  67. /**
  68. * 添加到执行队列上
  69. */
  70. public function addJobs($type,$params){
  71. $this->zzjobs->insert([
  72. 'status'=>0,
  73. 'quque'=>$type,
  74. 'payload'=>json_encode($params),
  75. 'do_interval'=>1,
  76. 'create_time'=>time(),
  77. ]);
  78. }
  79. }