1 | <?php |
||
2 | |||
0 ignored issues
–
show
Coding Style
introduced
by
![]() |
|||
3 | namespace FeiYuCRM; |
||
4 | |||
5 | /** |
||
6 | * FeiYuCRM system class |
||
7 | * @author haosijia <[email protected]> |
||
0 ignored issues
–
show
|
|||
8 | */ |
||
0 ignored issues
–
show
|
|||
9 | class FeiYu |
||
10 | { |
||
11 | // Server address |
||
0 ignored issues
–
show
|
|||
12 | public $host = ''; |
||
0 ignored issues
–
show
|
|||
13 | // Data fetch route |
||
0 ignored issues
–
show
|
|||
14 | public $pull_route = ''; |
||
0 ignored issues
–
show
|
|||
15 | // Upload data route |
||
0 ignored issues
–
show
|
|||
16 | public $push_route = ''; |
||
0 ignored issues
–
show
|
|||
17 | // Encryption key |
||
0 ignored issues
–
show
|
|||
18 | public $signature_key = ''; |
||
0 ignored issues
–
show
|
|||
19 | // Token |
||
0 ignored issues
–
show
|
|||
20 | public $token = ''; |
||
0 ignored issues
–
show
|
|||
21 | |||
22 | // Timestamp |
||
0 ignored issues
–
show
|
|||
23 | protected $timestamp = ''; |
||
0 ignored issues
–
show
|
|||
24 | // Signature |
||
0 ignored issues
–
show
|
|||
25 | protected $signature = ''; |
||
0 ignored issues
–
show
|
|||
26 | // Start time |
||
0 ignored issues
–
show
|
|||
27 | protected $start_time = ''; |
||
0 ignored issues
–
show
|
|||
28 | // End time |
||
0 ignored issues
–
show
|
|||
29 | protected $end_time = ''; |
||
0 ignored issues
–
show
|
|||
30 | // Page size |
||
0 ignored issues
–
show
|
|||
31 | protected $page_size = ''; |
||
0 ignored issues
–
show
|
|||
32 | // Run route |
||
0 ignored issues
–
show
|
|||
33 | protected $fetch_route = ''; |
||
0 ignored issues
–
show
|
|||
34 | // Data from host |
||
0 ignored issues
–
show
|
|||
35 | protected $res_data = ''; |
||
0 ignored issues
–
show
|
|||
36 | // Push data source |
||
0 ignored issues
–
show
|
|||
37 | protected $push_data = ''; |
||
0 ignored issues
–
show
|
|||
38 | |||
39 | 2 | public function __construct($options) |
|
0 ignored issues
–
show
|
|||
40 | { |
||
0 ignored issues
–
show
|
|||
41 | 2 | $this->host = isset($options['host'])?$options['host']:$this->host; |
|
0 ignored issues
–
show
|
|||
42 | 2 | $this->pull_route = isset($options['pull_route'])?$options['pull_route']:$this->pull_route; |
|
0 ignored issues
–
show
|
|||
43 | 2 | $this->push_route = isset($options['push_route'])?$options['push_route']:$this->push_route; |
|
0 ignored issues
–
show
|
|||
44 | 2 | $this->signature_key = isset($options['signature_key'])?$options['signature_key']:$this->signature_key; |
|
0 ignored issues
–
show
|
|||
45 | 2 | $this->token = isset($options['token'])?$options['token']:$this->token; |
|
0 ignored issues
–
show
|
|||
46 | 2 | $this->timestamp = time(); |
|
0 ignored issues
–
show
|
|||
47 | 2 | } |
|
0 ignored issues
–
show
|
|||
48 | |||
49 | /** |
||
0 ignored issues
–
show
|
|||
50 | * pull data |
||
0 ignored issues
–
show
|
|||
51 | * @param string $start_time ['Y-m-d'] |
||
0 ignored issues
–
show
|
|||
52 | * @param string $end_time ['Y-m-d'] |
||
0 ignored issues
–
show
|
|||
53 | * @param int $page_size |
||
0 ignored issues
–
show
|
|||
54 | * @return $this |
||
0 ignored issues
–
show
|
|||
55 | */ |
||
56 | 1 | public function pullData($start_time, $end_time, $page_size) |
|
0 ignored issues
–
show
|
|||
57 | { |
||
0 ignored issues
–
show
|
|||
58 | 1 | $this->start_time = strtotime($start_time); |
|
0 ignored issues
–
show
|
|||
59 | 1 | $this->end_time = strtotime($end_time); |
|
0 ignored issues
–
show
|
|||
60 | 1 | $this->page_size = $page_size; |
|
0 ignored issues
–
show
|
|||
61 | 1 | $this->fetch_route = $this->pull_route; |
|
0 ignored issues
–
show
|
|||
62 | 1 | return $this; |
|
0 ignored issues
–
show
|
|||
63 | } |
||
0 ignored issues
–
show
|
|||
64 | |||
65 | /** |
||
0 ignored issues
–
show
|
|||
66 | * push data |
||
0 ignored issues
–
show
|
|||
67 | * @param array $data |
||
0 ignored issues
–
show
|
|||
68 | * @return bool |
||
0 ignored issues
–
show
|
|||
69 | */ |
||
70 | 1 | public function pushData($data) |
|
0 ignored issues
–
show
|
|||
71 | { |
||
0 ignored issues
–
show
|
|||
72 | 1 | if(!isset($data['clue_convert_state']) || !isset($data['clue_id'])){ |
|
0 ignored issues
–
show
|
|||
73 | throw new FeiYuException("Upload data is missing the necessary parameters", 1); |
||
0 ignored issues
–
show
|
|||
74 | } |
||
0 ignored issues
–
show
|
|||
75 | 1 | if(!is_numeric($data['clue_convert_state'])){ |
|
0 ignored issues
–
show
|
|||
76 | throw new FeiYuException("'clue_convert_state' must be a numeric type", 1); |
||
0 ignored issues
–
show
|
|||
77 | } |
||
0 ignored issues
–
show
|
|||
78 | 1 | $data['clue_convert_state'] = (int)$data['clue_convert_state']; |
|
0 ignored issues
–
show
|
|||
79 | 1 | $this->push_data = json_encode([ |
|
0 ignored issues
–
show
|
|||
80 | 1 | 'source' => 0, |
|
0 ignored issues
–
show
|
|||
81 | 'data' => [ |
||
0 ignored issues
–
show
|
|||
82 | 1 | 'clue_id' => $data['clue_id'], |
|
83 | 1 | 'clue_convert_state' => $data['clue_convert_state'], |
|
84 | ], |
||
0 ignored issues
–
show
|
|||
85 | ]); |
||
0 ignored issues
–
show
For multi-line function calls, the closing parenthesis should be on a new line.
If a function call spawns multiple lines, the coding standard suggests to move the closing parenthesis to a new line: someFunctionCall(
$firstArgument,
$secondArgument,
$thirdArgument
); // Closing parenthesis on a new line.
![]() |
|||
86 | 1 | $this->fetch_route = $this->push_route; |
|
0 ignored issues
–
show
|
|||
87 | 1 | $this->fetchCurl(); |
|
0 ignored issues
–
show
|
|||
88 | return !$this->getResData()['status']; |
||
0 ignored issues
–
show
|
|||
89 | } |
||
0 ignored issues
–
show
|
|||
90 | |||
91 | /** |
||
0 ignored issues
–
show
|
|||
92 | * get result data from curl |
||
0 ignored issues
–
show
|
|||
93 | * @return string |
||
0 ignored issues
–
show
|
|||
94 | */ |
||
95 | public function getResData() |
||
0 ignored issues
–
show
|
|||
96 | { |
||
0 ignored issues
–
show
|
|||
97 | return $this->res_data; |
||
0 ignored issues
–
show
|
|||
98 | } |
||
0 ignored issues
–
show
|
|||
99 | |||
100 | /** |
||
0 ignored issues
–
show
|
|||
101 | * get all page data and run callback function in every page |
||
0 ignored issues
–
show
|
|||
102 | * @return string |
||
0 ignored issues
–
show
|
|||
103 | */ |
||
104 | 1 | public function run($callback) |
|
0 ignored issues
–
show
|
|||
105 | { |
||
0 ignored issues
–
show
|
|||
106 | 1 | $page = 1; |
|
0 ignored issues
–
show
|
|||
107 | |||
108 | do { |
||
0 ignored issues
–
show
|
|||
109 | 1 | $this->fetchCurl($page); |
|
0 ignored issues
–
show
|
|||
110 | |||
111 | if (call_user_func($callback, $this->res_data['data']) === false) { |
||
0 ignored issues
–
show
|
|||
112 | return false; |
||
0 ignored issues
–
show
|
|||
113 | } |
||
0 ignored issues
–
show
|
|||
114 | |||
115 | $page++; |
||
0 ignored issues
–
show
|
|||
116 | } while (($page-1)*($this->page_size) < $this->res_data['count']); |
||
0 ignored issues
–
show
|
|||
117 | |||
118 | return true; |
||
0 ignored issues
–
show
|
|||
119 | } |
||
0 ignored issues
–
show
|
|||
120 | |||
121 | /** |
||
0 ignored issues
–
show
|
|||
122 | * encrypt url and start_time and end_time to signature |
||
0 ignored issues
–
show
|
|||
123 | * @return $this |
||
0 ignored issues
–
show
|
|||
124 | */ |
||
125 | 2 | protected function encryptData() |
|
0 ignored issues
–
show
|
|||
126 | { |
||
0 ignored issues
–
show
|
|||
127 | // 拼接中的空格很重要 |
||
0 ignored issues
–
show
|
|||
128 | 2 | if($this->fetch_route == $this->pull_route){ |
|
0 ignored issues
–
show
|
|||
129 | 1 | $data = $this->fetch_route.'?start_time='.$this->start_time.'&end_time='.$this->end_time.' '.$this->timestamp; |
|
0 ignored issues
–
show
|
|||
130 | } else { |
||
0 ignored issues
–
show
|
|||
131 | 1 | $data = $this->fetch_route.' '.$this->timestamp; |
|
0 ignored issues
–
show
|
|||
132 | } |
||
0 ignored issues
–
show
|
|||
133 | 2 | $this->signature = base64_encode(hash_hmac('sha256', $data, $this->signature_key)); |
|
0 ignored issues
–
show
|
|||
134 | 2 | return $this; |
|
0 ignored issues
–
show
|
|||
135 | } |
||
0 ignored issues
–
show
|
|||
136 | |||
137 | /** |
||
0 ignored issues
–
show
|
|||
138 | * fetch data by curl |
||
0 ignored issues
–
show
|
|||
139 | * @param string $page |
||
0 ignored issues
–
show
|
|||
140 | * @return $this |
||
0 ignored issues
–
show
|
|||
141 | */ |
||
142 | 2 | protected function fetchCurl($page = 1) |
|
0 ignored issues
–
show
|
|||
143 | { |
||
0 ignored issues
–
show
|
|||
144 | 2 | $this->encryptData(); |
|
0 ignored issues
–
show
|
|||
145 | 2 | $ch = curl_init(); |
|
0 ignored issues
–
show
|
|||
146 | 2 | if(!$ch){ |
|
0 ignored issues
–
show
|
|||
147 | throw new FeiYuException('cURL init failed', 1); |
||
0 ignored issues
–
show
|
|||
148 | } |
||
0 ignored issues
–
show
|
|||
149 | 2 | curl_setopt($ch, CURLOPT_URL, $this->host.$this->fetch_route.'?page='.$page.'&page_size='.$this->page_size.'&start_time='.$this->start_time.'&end_time='.$this->end_time); |
|
0 ignored issues
–
show
|
|||
150 | 2 | curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); |
|
0 ignored issues
–
show
|
|||
151 | 2 | curl_setopt($ch, CURLOPT_TIMEOUT, 5); |
|
0 ignored issues
–
show
|
|||
152 | 2 | curl_setopt($ch, CURLOPT_HTTPHEADER, [ |
|
0 ignored issues
–
show
|
|||
153 | 2 | 'Content-Type: application/json;charset=UTF-8', |
|
154 | 2 | 'Signature: ' . $this->signature, |
|
155 | 2 | 'Timestamp: ' . $this->timestamp, |
|
156 | 2 | 'Access-Token: ' . $this->token, |
|
157 | ]); |
||
0 ignored issues
–
show
For multi-line function calls, the closing parenthesis should be on a new line.
If a function call spawns multiple lines, the coding standard suggests to move the closing parenthesis to a new line: someFunctionCall(
$firstArgument,
$secondArgument,
$thirdArgument
); // Closing parenthesis on a new line.
![]() |
|||
158 | 2 | if($this->fetch_route == $this->push_route){ |
|
0 ignored issues
–
show
|
|||
159 | 1 | curl_setopt($ch, CURLOPT_POST, true); |
|
0 ignored issues
–
show
|
|||
160 | 1 | curl_setopt($ch, CURLOPT_POSTFIELDS, $this->push_data); |
|
0 ignored issues
–
show
|
|||
161 | } |
||
0 ignored issues
–
show
|
|||
162 | 2 | $output = curl_exec($ch); |
|
0 ignored issues
–
show
|
|||
163 | 2 | $error = curl_error($ch); |
|
0 ignored issues
–
show
|
|||
164 | 2 | curl_close($ch); |
|
0 ignored issues
–
show
|
|||
165 | 2 | if($error != ''){ |
|
0 ignored issues
–
show
|
|||
166 | throw new FeiYuException($error, 1); |
||
0 ignored issues
–
show
|
|||
167 | } |
||
0 ignored issues
–
show
|
|||
168 | 2 | $this->res_data = json_decode($output, true); |
|
0 ignored issues
–
show
|
|||
169 | 2 | if($this->res_data['status'] != 'success'){ |
|
0 ignored issues
–
show
|
|||
170 | 2 | if(is_array($this->res_data['msg'])){ |
|
0 ignored issues
–
show
|
|||
171 | throw new FeiYuException(json_encode($this->res_data['msg']), 1); |
||
0 ignored issues
–
show
|
|||
172 | } |
||
0 ignored issues
–
show
|
|||
173 | 2 | throw new FeiYuException($this->res_data['msg'], 1); |
|
0 ignored issues
–
show
|
|||
174 | } |
||
0 ignored issues
–
show
|
|||
175 | return $this; |
||
0 ignored issues
–
show
|
|||
176 | } |
||
0 ignored issues
–
show
|
|||
177 | } |
||
178 | |||
179 | class FeiYuException extends \Exception |
||
0 ignored issues
–
show
|
|||
180 | { |
||
181 | |||
182 | } |