travel/service/app/server/ThirdApiService.php

129 lines
4.6 KiB
PHP
Raw Normal View History

2024-08-08 21:08:23 +08:00
<?php
namespace app\server;
2024-09-10 09:41:07 +08:00
use app\model\Orders;
2024-08-08 21:08:23 +08:00
use app\model\ThirdMobileLogs;
2024-09-10 18:09:42 +08:00
use http\Client;
2024-08-08 21:08:23 +08:00
use support\Log;
2024-09-10 18:09:42 +08:00
use support\Redis;
2024-08-08 21:08:23 +08:00
/**
* 阿里云市场相关接口
*/
2024-09-10 09:41:07 +08:00
class ThirdApiService {
private $notice = '%s token已过期请及时更换';
2024-08-08 21:08:23 +08:00
/**
* @param $mobile
* @return array|mixed
* @throws \think\db\exception\BindParamException
*/
public function getMobileArea($mobile) {
$host = "https://jumcvit.market.alicloudapi.com";
$path = "/mobile/area";
$method = "POST";
$appcode = "4402db67815049c18a55a996b5644f5b";
$headers = array();
array_push($headers, "Authorization:APPCODE " . $appcode);
//根据API的要求定义相对应的Content-Type
array_push($headers, "Content-Type".":"."application/x-www-form-urlencoded; charset=UTF-8");
$bodys = "mobile_number=" . $mobile;
$url = $host . $path;
2024-09-10 18:09:42 +08:00
$aliData = $this->curlMobileRequest($url, $method, $headers, $bodys);
2024-08-08 21:08:23 +08:00
if (isset($aliData['code']) && $aliData['code'] == 200) {
ThirdMobileLogs::query()->insert([
'mobile' => $mobile,
'area' => $aliData['data']['area'],
'originalIsp' => $aliData['data']['originalIsp'],
]);
}
return $aliData['data'] ?? [];
}
/**
* @param $url
* @param $method
* @param $headers
* @param $bodys
* @return mixed
*/
2024-09-10 18:09:42 +08:00
private function curlMobileRequest($url, $method, $headers, $bodys){
2024-08-08 21:08:23 +08:00
$curl = curl_init();
curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
curl_setopt($curl, CURLOPT_FAILONERROR, false);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
//设定返回信息中是否包含响应信息头启用时会将响应信息头作为数据流输出true 表示输出信息头, false表示不输出信息头
//如果想将响应结果json字符串转为json数组建议将 CURLOPT_HEADER 设置成 false
curl_setopt($curl, CURLOPT_HEADER, true);
if (1 == strpos("$".$url, "https://"))
{
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
}
curl_setopt($curl, CURLOPT_POSTFIELDS, $bodys);
curl_close($curl);
list($header, $body) = explode("\r\n\r\n", curl_exec($curl), 2);
return json_decode($body, true);
}
2024-09-10 09:41:07 +08:00
/**
* 发送企微提醒
* @param $message
* @return mixed
*/
public function weComNotice($os) {
$url = 'https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=e138b55c-2886-4729-922e-9a8c753f75ee';
2024-09-10 18:09:42 +08:00
$method = 'POST';
2024-09-10 09:41:07 +08:00
$message = sprintf($this->notice, Orders::OSS[$os] ?? '');
$bodys = [
'msgtype' => 'text',
'text' => [
'content' => $message
]
];
2024-09-10 18:09:42 +08:00
if (Redis::setNx('notice-' . $os, 600, 1)) {
$this->curlRequest($url, $method, [], $bodys);
}
return true;
}
/**
* @param $url
* @param $method
* @param $headers
* @param $bodys
* @return mixed
*/
private function curlRequest($url, $method, $headers, $bodys){
$curl = curl_init();
curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_FAILONERROR, false);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
//设定返回信息中是否包含响应信息头启用时会将响应信息头作为数据流输出true 表示输出信息头, false表示不输出信息头
//如果想将响应结果json字符串转为json数组建议将 CURLOPT_HEADER 设置成 false
curl_setopt($curl, CURLOPT_HEADER, true);
if (1 == strpos("$".$url, "https://"))
{
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
}
if (is_array($bodys)) {
$bodys = json_encode($bodys);
}
curl_setopt($curl, CURLOPT_POSTFIELDS, $bodys);
curl_setopt($curl, CURLOPT_HTTPHEADER, array_merge($headers, [
'Content-Type: application/json',
'Content-Length: ' . strlen($bodys)
]));
curl_close($curl);
list($header, $body) = explode("\r\n\r\n", curl_exec($curl), 2);
Log::info(sprintf('third req:%s, res:%s', $url, $body));
return json_decode($body, true);
2024-09-10 09:41:07 +08:00
}
2024-08-08 21:08:23 +08:00
}