109 lines
3.3 KiB
PHP
109 lines
3.3 KiB
PHP
<?php
|
||
/*
|
||
* description：
|
||
* author：wh
|
||
* email：
|
||
* createTime：{2024/11/26} {15:41}
|
||
*/
|
||
|
||
set_time_limit(0);
|
||
//var_dump(111);die;
|
||
//创建一个循环，每隔三秒钟执行一次，调用接口
|
||
|
||
try {
|
||
while (true) {
|
||
//调用接口
|
||
$url = "https://ybx_prediagnosis.excn.top/api/Drugsimagesmedicalupload/queryDrugsImagesMedicalTask";
|
||
$res = curl_get($url);
|
||
//var_dump($res);
|
||
if($res['code'] == 200){
|
||
$arr_res = json_decode($res['data'],true);
|
||
//var_dump($arr_res);die;
|
||
//yes终止，no不终止
|
||
if($arr_res['data'] == 'yes'){
|
||
echo "队列消费已终止";
|
||
break;
|
||
}
|
||
|
||
|
||
sleep(3);
|
||
}else{
|
||
echo "队列消费失败，已终止";
|
||
log_to_write_txt($res);
|
||
break;
|
||
}
|
||
}
|
||
}catch (\Exception $e){
|
||
log_to_write_txt(['error'=>'队列消费异常',$e->getMessage(),$e->getTraceAsString()]);
|
||
}
|
||
|
||
function curl_get(string $url, int $timeout = 10, $header=[])
|
||
{
|
||
|
||
$header = $header?:array(
|
||
'Accept: application/json',
|
||
);
|
||
$curl = curl_init();
|
||
//curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);
|
||
//curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
|
||
//curl_setopt($curl, CURLOPT_SSLVERSION, 3);
|
||
//设置抓取的url
|
||
curl_setopt($curl, CURLOPT_URL, $url);
|
||
//设置头文件的信息作为数据流输出
|
||
curl_setopt($curl, CURLOPT_HEADER, 0);
|
||
// 超时设置,以秒为单位
|
||
curl_setopt($curl, CURLOPT_TIMEOUT, $timeout);
|
||
|
||
// 超时设置，以毫秒为单位
|
||
// curl_setopt($curl, CURLOPT_TIMEOUT_MS, 500);
|
||
|
||
// 设置请求头
|
||
curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
|
||
//设置获取的信息以文件流的形式返回，而不是直接输出。
|
||
curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
|
||
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
|
||
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
|
||
//执行命令
|
||
$data = curl_exec($curl);
|
||
|
||
// 显示错误信息
|
||
if (curl_error($curl)) {
|
||
//print "Error: ".curl_errno($curl).'-' . curl_error($curl);
|
||
//返回错误码
|
||
return ['code' => curl_errno($curl), 'msg' => curl_error($curl)];
|
||
} else {
|
||
//关闭句柄
|
||
curl_close($curl);
|
||
// 返回的内容
|
||
return ['code' => 200, 'msg' => 'cURL ok', 'data' => $data];
|
||
}
|
||
}
|
||
|
||
function log_to_write_txt($data = 'test', $dirname = '')
|
||
{
|
||
$root_path = explode('vendor',__DIR__)[0];
|
||
$runtime_path = $root_path.'runtime/';
|
||
if ($dirname) {
|
||
$filepath = $runtime_path . 'log/' . ($dirname).'/'.date('Ymd');//运行时日志
|
||
}else{
|
||
$filepath = $runtime_path . 'log/'.date('Ym');//运行时日志
|
||
}
|
||
|
||
if (!file_exists($filepath)) {
|
||
mkdir($filepath, 0777, true);
|
||
}
|
||
if($dirname){
|
||
$filepath .= '/log' . date('YmdH') . '.txt';
|
||
}else{
|
||
$filepath .= '/' . date('d') . '_error.log';
|
||
}
|
||
$ip = request()->ip();
|
||
list($t1, $t2) = explode(' ', microtime());
|
||
$write_time = date('Y-m-d H:i:s',$t2).' '.sprintf('%.0f',$t1*1000);
|
||
|
||
$str = "\n" . $write_time . ' | '. $ip.' | ' . request()->baseUrl() . "\n";
|
||
|
||
$data = is_object($data) || is_array($data) ? $str . json_encode($data, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES) : $str . $data;
|
||
|
||
file_put_contents($filepath, $data, FILE_APPEND);
|
||
} |