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
It seems like
$this->signature_key can also be of type mixed ; however, parameter $key of hash_hmac() does only seem to accept string , maybe add an additional type check?
(
Ignorable by Annotation
)
If this is a false-positive, you can also ignore this issue in your code via the
![]() |
|||||
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 | } |