景龙 / gangjuren · 提交

转到一个项目

作者 刘朕
提交 82f37b7f994c76da87290d300af2166225d02ea9 1 个父辈 7f2e3047
1 个管道 的构建 通过 耗费 16 秒

api文档优化

内嵌 并排对比
正在显示 2 个修改的文件 包含 488 行增加 和 484 行删除
<?php
namespace app\api\controller;
use app\api\model\Equipment;
use app\api\model\SubscribLog;
use app\common\controller\Api;
use think\Db;
/**
* 应用端接口
*/
class App extends Api
{
protected $noNeedLogin = '*';
protected $noNeedRight = '*';
protected $api_model = null;
protected $api_request_model = null;
public function _initialize()
{
$this->api_model = new \app\api\model\Api();
$this->api_request_model = new \app\api\model\ApiRequest();
}
/**
* 获取access_token
*
* @ApiTitle (获取access_token)
* @ApiSummary (获取access_token)
* @ApiMethod (GET)
* @ApiRoute (/api/app/getAccessToken)
* @ApiParams (name="app_id", type="integer", required=true, description="应用appid")
* @ApiParams (name="app_key", type="string", required=true, description="应用appkey")
* @ApiReturnParams (name="code", type="integer", required=true, sample="0")
* @ApiReturnParams (name="msg", type="string", required=true, sample="返回成功")
* @ApiReturnParams (name="data", type="object", sample="{'user_id':'int','user_name':'string','profile':{'email':'string','age':'integer'}}", description="扩展数据返回")
* @ApiReturn ({
'code':'1',
'msg':'返回成功',
'data':'{
'access_token':'身份验证token',
'expires_in':'过期时间',
}'
})
*/
public function getAccessToken() {
if($this->request->isGet()) {
$data = $this->request->param();
$validate = new \think\Validate([
'app_id' => 'require',
'app_key' => 'require'
]);
$validate->message([
'app_id.require' => 'app_id参数错误!',
'app_key.require' => 'app_key参数错误!'
]);
if (!$validate->check($data)) {
$this->error($validate->getError());
}
// 查询数据
$api_where = $api_request = [
'app_id' => $data['app_id'],
'app_key' => $data['app_key']
];
$apiInfo = $this->api_model->where($api_where)->find();
if(!$apiInfo) {
$this->error('app_id参数错误');
}
// 添加接口访问记录并返回数据
$api_request['access_token'] = $request_data['access_token'] = sha1(md5($apiInfo['app_id'].$apiInfo['app_key']).time().createNoncestr(10));
$api_request['api_name'] = '获取access_token';
$api_request['overtime'] = time() + 7200;
$api_request['apply_data'] = json_encode($data);
$request_data['expires_in'] = 7200;
$result = $this->api_request_model->save($api_request);
if(!$result) {
$this->error('系统繁忙，请稍后再试');
}
$this->success('成功', $request_data);
} else {
$this->error('非法请求');
}
}
/**
* 数板列表
*
* @ApiTitle (数板列表)
* @ApiSummary (数板列表)
* @ApiMethod (POST)
* @ApiRoute (/api/app/getEquipmentList)
* @ApiParams (name="app_id", type="integer", required=true, description="应用appid")
* @ApiParams (name="access_token", type="string", required=true, description="身份验证token")
* @ApiParams (name="number", type="string", required=true, description="数板仪编号")
* @ApiParams (name="start_time", type="string", required=true, description="开始时间")
* @ApiParams (name="end_time", type="string", required=true, description="结束时间")
* @ApiReturnParams (name="code", type="integer", required=true, sample="0")
* @ApiReturnParams (name="msg", type="string", required=true, sample="返回成功")
* @ApiReturnParams (name="data", type="object", sample="{'user_id':'int','user_name':'string','profile':{'email':'string','age':'integer'}}", description="扩展数据返回")
* @ApiReturn ({
'code':'1',
'msg':'返回成功',
'data':'{
'access-token':'身份验证token',
'expires_in':'过期时间',
}'
})
*/
public function getEquipmentList() {
if($this->request->isPost()) {
$data = $this->request->param();
$validate = new \think\Validate([
'app_id' => 'require',
'access_token' => 'require',
'number' => 'require',
// 'start_time' => 'require',
// 'end_time' => 'require'
]);
$validate->message([
'app_id.require' => 'app_id参数错误!',
'access_token.require' => 'access_token参数错误!',
'number.require' => 'number参数错误!',
// 'start_time.require' => 'start_time参数错误!',
// 'end_time.require' => 'end_time参数错误!'
]);
if (!$validate->check($data)) {
$this->error($validate->getError());
}
$access_token = $data['access_token'];
// 验证token是否过期
$api_id = $this->check($data['app_id'],$access_token);
// 查询数板仪列表
$end_time = time();
$start_time = $end_time - 90 * 24 * 60 * 60;
$equipment_model = new Equipment();
$where = [
'number' => $data['number'],
'createtime'=> ['between',[$start_time,$end_time]]
];
$request_data = $equipment_model->where($where)->select();
$request_data = collection($request_data)->toArray();
$this->success('成功', $request_data);
} else {
$this->error('非法请求');
}
}
// 定时执行订阅信息通知（未通知成功的数据）
public function subscrib_notice() {
$subscrib_log_model = new SubscribLog();
$where = [
'is_success' => 0,
];
$list = $subscrib_log_model->where($where)->where('times','<>',0)->select();
foreach ($list as $k=>$v) {
// parse_str(substr($v['content'],1,strlen($v['content'])-2), $parameter);
$headers = ["Content-type: application/json;charset='utf-8'"];
$result = $this->curl($v['notice_url'],$v['content'],$headers);
$array = json_decode($result,true);
if($array['code'] == 200) {
// 发送订阅信息成功
$update = [
'id' => $v['id'],
'is_success' => 1,
];
$subscrib_log_model::update($update);
}
if($v['times'] > 0) {
// 减少发送订阅信息次数
$update = [
'id' => $v['id'],
'times' => $v['times'] - 1,
];
// 如果到了最后一次通知，则将通知状态改为成功
if($v['times'] == 1) {
$update['is_success'] = 1;
}
$subscrib_log_model::update($update);
}
}
// \think\facade\Log::write('执行未通知成功回调'.date('Y-m-d H:i:s',time()),'subscrib_notice');
}
// 将信息通知给订阅系统
private function notice($type, $subscrib_id, $content, $subscrib_log_type = 1) {
$where = [
'a.delete_time' => 0,
'as.type' => $type,
'as.subscrib_id' => $subscrib_id
];
$apiList = $this->api_model->alias('a')
->join('__API_SUBSCRIB__ as','a.id = as.api_id')
->field('a.id,a.times,a.callback')
->where($where)
->select();
return $this->send($apiList, $subscrib_id, $type, $content, $subscrib_log_type);
}
// 发送订阅消息
private function send($subscribList, $subscrib_id, $type, $content, $subscrib_log_type = 1) {
$subscrib_log_model = new SubscribLog();
parse_str($content,$arr);
$content = json_encode($arr);
foreach ($subscribList as $k=>$v) {
$insert = [
'api_id' => $v['id'],
'type' => $subscrib_log_type,
'subscrib_id' => $subscrib_id,
'notice_url' => $v['callback'],
'content' => $content,
'create_time' => time(),
];
if($v['times'] == 0) {
$v['times'] = -1;
}
$insert['times'] = $v['times'];
$insert_result = $subscrib_log_model::create($insert);
$headers = ["Content-type: application/json;charset='utf-8'"];
$result = json_decode($this->curl($v['callback'],$content,$headers),true);
if(empty($result['code'])) {
//发送订阅信息成功
$update = [
'id' => $insert_result->id,
'is_success' => 1
];
$subscrib_log_model::update($update);
}
// json_decode($this->curl('http://rz.178games.net/api/callback/gjr',$content,$headers),true);
}
return true;
}
/**
* 检查access-token是否过期
* @param $app_id
* @param $access_token
*/
private function check($app_id,$access_token) {
$api_request_where = [
'api_request.app_id' => $app_id,
'api_request.access_token' => $access_token
];
$apiRequestInfo = $this->api_request_model->with(['api'])->where($api_request_where)->find();
if(!$apiRequestInfo) {
$this->error('access_token不存在');
}
if($apiRequestInfo['overtime'] < time()) {
$this->error('access_token已过期');
}
return $apiRequestInfo;
}
/**
* 数管图片识别
*
* @ApiTitle (数管图片识别)
* @ApiSummary (数管图片识别)
* @ApiMethod (POST/GET)
* @ApiRoute (/api/app/getImageInfo)
* @ApiParams (name="app_id", type="integer", required=true, description="应用appid")
* @ApiParams (name="access_token", type="string", required=true, description="身份验证token")
* @ApiParams (name="customer_id", type="integer", required=true, description="用户id")
* @ApiParams (name="url", type="string", required=true, description="图片地址")
* @ApiParams (name="image_id", type="string", required=true, description="图片id")
* @ApiReturnParams (name="code", type="integer", required=true, sample="0")
* @ApiReturnParams (name="msg", type="string", required=true, sample="SUCCESS")
* @ApiReturnParams (name="data", type="object", sample="{'image_id':'int','timestamp':'string','result':{'id':'int','type':'string','total':'int','confirmation':'int','distrust':'int','image_path':'int'}}", description="扩展数据返回")
* @ApiReturn ({
'code':'1',
'msg':'返回成功',
'data':'{
'image_id':'图片id',
'timestamp':'时间戳',
'result':{
'id':'ID',
'type':'识别出的管的类型及大小',
'total':'识别总数量',
'confirmation':'确认数量',
'distrust':'疑似数量',
'image_path':'图片路径'
},
}'
})
*/
public function getImageInfo(){
$param = $this->request->param();
$validate = new \think\Validate([
'app_id' => 'require',
'customer_id' => 'require',
'access_token' => 'require',
'url' => 'require',
'image_id' => 'require',
]);
if (!$validate->check($param)) {
$this->error($validate->getError());
}
$app_id = $param['app_id'];
$customer_id = $param['customer_id'];
$access_token = $param['access_token'];
$url = $param['url'];
$image_id = $param['image_id'];
//验证token是否过期
$api = $this->check($app_id,$access_token);
//保存图片
$file = $this->saveImage($url);
//请求地址
$url = config('validate.shuguan')['url'];
$files = realpath(ltrim(".".$file, '@'));
$files = new \CURLFile($files);
$key = $this->getKey(20,false);
$param['files'] = $files;
$param['timestamp'] = date('Y-m-d H:i:s');
$param['key'] = $key;
$param['image_id'] = $image_id;
$param['sign'] = $this->getSign($param);
$result = $this->httpPost($url,$param);
$data = json_decode($result,true);
Db::startTrans();
//保存数管信息
$arr = [
'api_id' => $api['api']['id'],
'customer_id' => $api['api']['customer_id'],
'yingyong_id' => $customer_id,
'image_id' => $image_id,
'files' => $file,
'timestamp' => $param['timestamp'],
'key' => $key,
'sign' => $param['sign'],
'createtime' => time(),
];
$result1 = Db::name('shuguan')->insertGetId($arr);
if(!$result1){
Db::rollback();
$this->error('sql执行失败');
}
//保存数管接口返回数据
if(!empty($data['result'])){
$arr2 = [];
foreach($data['result'] as $key => $r){
$arr1 = [
'shuguan_id' => $result1,
'type' => $r['type'],
'total' => $r['total'],
'confirmation' => $r['confirmation'],
'distrust' => $r['distrust'],
'image_path' => $r['image_path'],
'createtime' => time(),
];
$arr2[] = $arr1;
}
$result2 = Db::name('shuguan_log')->insertAll($arr2);
if(!$result2){
Db::rollback();
$this->error('sql执行失败');
}
}
Db::commit();
$this->success('SUCCESS',$result);
}
/**
* 模拟调用
*/
public function test(){
dump(getAddress("N39.085660E117.068135"));
exit();
$url = "http://gangjuren.net/api/app/getImageInfo";
$arr = [
'url' => "http://company.zzspjob.com/6b408e79f3a21ac02746b218f6cbc99@3x.png",
'app_id' => 'gjra2g11dg56ad7bb71',
'customer_id' => '1',
'access_token' => 'e508a6c25ed2ec1237fa8a0ba8a09357ff83b8c8',
'image_id' => '1',
];
$result = $this->httpPost($url,$arr);
$this->success('',$result);
}
/**
* 保存图片
* @param $url
* @return string
*/
public function saveImage($url){
$date = date('Ymd');
$savePath = "./uploads/shuguan/$date/";
if (!file_exists($savePath)){
mkdir($savePath, 0777,true);
}
$image = file_get_contents($url);
$file_name = md5(uniqid(rand())).".png";
file_put_contents($savePath.$file_name,$image);
return "/uploads/shuguan/$date/$file_name";
}
/**
* 仿form-data提交表单
* @param $url
* @param $data
* @return mixed
*/
private function httpPost($url,$data){ // 模拟提交数据函数
$curl = curl_init(); // 启动一个CURL会话
curl_setopt($curl, CURLOPT_URL, $url); // 要访问的地址
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false); // 对认证证书来源的检查
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false); // 从证书中检查SSL加密算法是否存在
// curl_setopt($curl, CURLOPT_USERAGENT, $_SERVER['HTTP_USER_AGENT']); // 模拟用户使用的浏览器
curl_setopt($curl, CURLOPT_POST, true); // 发送一个常规的Post请求
curl_setopt($curl, CURLOPT_POSTFIELDS, $data); // Post提交的数据包
//curl_setopt($curl, CURLOPT_TIMEOUT, 120); // 设置超时限制防止死循环
curl_setopt($curl, CURLOPT_HEADER, false); // 显示返回的Header区域内容
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); // 获取的信息以文件流的形式返回
$result = curl_exec($curl); // 执行操作
if (curl_errno($curl)) {
echo 'Error POST'.curl_error($curl);
}
curl_close($curl); // 关键CURL会话
return $result; // 返回数据
}
/**
* 获取随机字符串
* @param $len 长度
* @param bool $special 是否需要特殊字符
* @return string 返回随机字符串
*/
public function getKey($len, $special=true){
$chars = array(
"a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k",
"l", "m", "n", "o", "p", "q", "r", "s", "t", "u", "v",
"w", "x", "y", "z", "A", "B", "C", "D", "E", "F", "G",
"H", "I", "J", "K", "L", "M", "N", "O", "P", "Q", "R",
"S", "T", "U", "V", "W", "X", "Y", "Z", "0", "1", "2",
"3", "4", "5", "6", "7", "8", "9"
);
if($special){
$chars = array_merge($chars, array(
"!", "@", "#", "$", "?", "|", "{", "/", ":", ";",
"%", "^", "&", "*", "(", ")", "-", "_", "[", "]",
"}", "<", ">", "~", "+", "=", ",", "."
));
}
$charsLen = count($chars) - 1;
shuffle($chars);//打乱数组顺序
$str = '';
for($i=0; $i<$len; $i++){
$str .= $chars[mt_rand(0, $charsLen)];//随机取出一位
}
return $str;
}
/**
* 生成签名
* @param array $param 要加密的数组
* @return string 返回签名
*/
protected function getSign($param){
$key = $param['key'];
unset($param['key']);
unset($param['files']);
//按照参数名ASCII字典序排序
ksort($param);
$arr = [];
foreach($param as $k => $p){
$arr[] = $k."=".$p;
}
//拼接成字符串
$str = implode('&',$arr);
//与key拼接
$str = $str."&key=".$key;
//进行加密
$signature = MD5($str);
//转换成大写
$signature = strtoupper($signature);
return $signature;
}
<?php
namespace app\api\controller;
use app\api\model\Equipment;
use app\api\model\SubscribLog;
use app\common\controller\Api;
use think\Db;
/**
* 应用端接口
*/
class App extends Api
{
protected $noNeedLogin = '*';
protected $noNeedRight = '*';
protected $api_model = null;
protected $api_request_model = null;
public function _initialize()
{
$this->api_model = new \app\api\model\Api();
$this->api_request_model = new \app\api\model\ApiRequest();
}
/**
* 获取access_token
*
* @ApiTitle (获取access_token)
* @ApiSummary (获取access_token)
* @ApiMethod (GET)
* @ApiRoute (/api/app/getAccessToken)
* @ApiParams (name="app_id", type="integer", required=true, description="应用appid")
* @ApiParams (name="app_key", type="string", required=true, description="应用appkey")
* @ApiReturnParams (name="code", type="integer", required=true, sample="0")
* @ApiReturnParams (name="msg", type="string", required=true, sample="返回成功")
* @ApiReturnParams (name="data", type="object", sample="{'user_id':'int','user_name':'string','profile':{'email':'string','age':'integer'}}", description="扩展数据返回")
* @ApiReturn ({
'code':'1',
'msg':'返回成功',
'data':'{
'access_token':'身份验证token',
'expires_in':'过期时间',
}'
})
*/
public function getAccessToken() {
if($this->request->isGet()) {
$data = $this->request->param();
$validate = new \think\Validate([
'app_id' => 'require',
'app_key' => 'require'
]);
$validate->message([
'app_id.require' => 'app_id参数错误!',
'app_key.require' => 'app_key参数错误!'
]);
if (!$validate->check($data)) {
$this->error($validate->getError());
}
// 查询数据
$api_where = $api_request = [
'app_id' => $data['app_id'],
'app_key' => $data['app_key']
];
$apiInfo = $this->api_model->where($api_where)->find();
if(!$apiInfo) {
$this->error('app_id参数错误');
}
// 添加接口访问记录并返回数据
$api_request['access_token'] = $request_data['access_token'] = sha1(md5($apiInfo['app_id'].$apiInfo['app_key']).time().createNoncestr(10));
$api_request['api_name'] = '获取access_token';
$api_request['overtime'] = time() + 7200;
$api_request['apply_data'] = json_encode($data);
$request_data['expires_in'] = 7200;
$result = $this->api_request_model->save($api_request);
if(!$result) {
$this->error('系统繁忙，请稍后再试');
}
$this->success('成功', $request_data);
} else {
$this->error('非法请求');
}
}
/**
* 数板列表
*
* @ApiTitle (数板列表)
* @ApiSummary (数板列表)
* @ApiMethod (POST)
* @ApiRoute (/api/app/getEquipmentList)
* @ApiParams (name="app_id", type="integer", required=true, description="应用appid")
* @ApiParams (name="access_token", type="string", required=true, description="身份验证token")
* @ApiParams (name="number", type="string", required=true, description="数板仪编号")
* @ApiParams (name="start_time", type="string", required=true, description="开始时间")
* @ApiParams (name="end_time", type="string", required=true, description="结束时间")
* @ApiReturnParams (name="code", type="integer", required=true, sample="0")
* @ApiReturnParams (name="msg", type="string", required=true, sample="返回成功")
* @ApiReturnParams (name="data", type="object", sample="{'user_id':'int','user_name':'string','profile':{'email':'string','age':'integer'}}", description="扩展数据返回")
* @ApiReturn ({
'code':'1',
'msg':'返回成功',
'data':'{
'access-token':'身份验证token',
'expires_in':'过期时间',
}'
})
*/
public function getEquipmentList() {
if($this->request->isPost()) {
$data = $this->request->param();
$validate = new \think\Validate([
'app_id' => 'require',
'access_token' => 'require',
'number' => 'require',
// 'start_time' => 'require',
// 'end_time' => 'require'
]);
$validate->message([
'app_id.require' => 'app_id参数错误!',
'access_token.require' => 'access_token参数错误!',
'number.require' => 'number参数错误!',
// 'start_time.require' => 'start_time参数错误!',
// 'end_time.require' => 'end_time参数错误!'
]);
if (!$validate->check($data)) {
$this->error($validate->getError());
}
$access_token = $data['access_token'];
// 验证token是否过期
$api_id = $this->check($data['app_id'],$access_token);
// 查询数板仪列表
$end_time = time();
$start_time = $end_time - 90 * 24 * 60 * 60;
$equipment_model = new Equipment();
$where = [
'number' => $data['number'],
'createtime'=> ['between',[$start_time,$end_time]]
];
$request_data = $equipment_model->where($where)->select();
$request_data = collection($request_data)->toArray();
$this->success('成功', $request_data);
} else {
$this->error('非法请求');
}
}
// 定时执行订阅信息通知（未通知成功的数据）
private function subscrib_notice() {
$subscrib_log_model = new SubscribLog();
$where = [
'is_success' => 0,
];
$list = $subscrib_log_model->where($where)->where('times','<>',0)->select();
foreach ($list as $k=>$v) {
// parse_str(substr($v['content'],1,strlen($v['content'])-2), $parameter);
$headers = ["Content-type: application/json;charset='utf-8'"];
$result = $this->curl($v['notice_url'],$v['content'],$headers);
$array = json_decode($result,true);
if($array['code'] == 200) {
// 发送订阅信息成功
$update = [
'id' => $v['id'],
'is_success' => 1,
];
$subscrib_log_model::update($update);
}
if($v['times'] > 0) {
// 减少发送订阅信息次数
$update = [
'id' => $v['id'],
'times' => $v['times'] - 1,
];
// 如果到了最后一次通知，则将通知状态改为成功
if($v['times'] == 1) {
$update['is_success'] = 1;
}
$subscrib_log_model::update($update);
}
}
// \think\facade\Log::write('执行未通知成功回调'.date('Y-m-d H:i:s',time()),'subscrib_notice');
}
// 将信息通知给订阅系统
private function notice($type, $subscrib_id, $content, $subscrib_log_type = 1) {
$where = [
'a.delete_time' => 0,
'as.type' => $type,
'as.subscrib_id' => $subscrib_id
];
$apiList = $this->api_model->alias('a')
->join('__API_SUBSCRIB__ as','a.id = as.api_id')
->field('a.id,a.times,a.callback')
->where($where)
->select();
return $this->send($apiList, $subscrib_id, $type, $content, $subscrib_log_type);
}
// 发送订阅消息
private function send($subscribList, $subscrib_id, $type, $content, $subscrib_log_type = 1) {
$subscrib_log_model = new SubscribLog();
parse_str($content,$arr);
$content = json_encode($arr);
foreach ($subscribList as $k=>$v) {
$insert = [
'api_id' => $v['id'],
'type' => $subscrib_log_type,
'subscrib_id' => $subscrib_id,
'notice_url' => $v['callback'],
'content' => $content,
'create_time' => time(),
];
if($v['times'] == 0) {
$v['times'] = -1;
}
$insert['times'] = $v['times'];
$insert_result = $subscrib_log_model::create($insert);
$headers = ["Content-type: application/json;charset='utf-8'"];
$result = json_decode($this->curl($v['callback'],$content,$headers),true);
if(empty($result['code'])) {
//发送订阅信息成功
$update = [
'id' => $insert_result->id,
'is_success' => 1
];
$subscrib_log_model::update($update);
}
// json_decode($this->curl('http://rz.178games.net/api/callback/gjr',$content,$headers),true);
}
return true;
}
/**
* 检查access-token是否过期
* @param $app_id
* @param $access_token
*/
private function check($app_id,$access_token) {
$api_request_where = [
'api_request.app_id' => $app_id,
'api_request.access_token' => $access_token
];
$apiRequestInfo = $this->api_request_model->with(['api'])->where($api_request_where)->find();
if(!$apiRequestInfo) {
$this->error('access_token不存在');
}
if($apiRequestInfo['overtime'] < time()) {
$this->error('access_token已过期');
}
return $apiRequestInfo;
}
/**
* 数管图片识别
*
* @ApiTitle (数管图片识别)
* @ApiSummary (数管图片识别)
* @ApiMethod (POST/GET)
* @ApiRoute (/api/app/getImageInfo)
* @ApiParams (name="app_id", type="integer", required=true, description="应用appid")
* @ApiParams (name="access_token", type="string", required=true, description="身份验证token")
* @ApiParams (name="customer_id", type="integer", required=true, description="用户id")
* @ApiParams (name="url", type="string", required=true, description="图片地址")
* @ApiParams (name="image_id", type="string", required=true, description="图片id")
* @ApiReturnParams (name="code", type="integer", required=true, sample="0")
* @ApiReturnParams (name="msg", type="string", required=true, sample="SUCCESS")
* @ApiReturnParams (name="data", type="object", sample="{'image_id':'int','timestamp':'string','result':{'id':'int','type':'string','total':'int','confirmation':'int','distrust':'int','image_path':'int'}}", description="扩展数据返回")
* @ApiReturn ({
'code':'1',
'msg':'返回成功',
'data':'{
'image_id':'图片id',
'timestamp':'时间戳',
'result':{
'id':'ID',
'type':'识别出的管的类型及大小',
'total':'识别总数量',
'confirmation':'确认数量',
'distrust':'疑似数量',
'image_path':'图片路径'
},
}'
})
*/
public function getImageInfo(){
$param = $this->request->param();
$validate = new \think\Validate([
'app_id' => 'require',
'customer_id' => 'require',
'access_token' => 'require',
'url' => 'require',
'image_id' => 'require',
]);
if (!$validate->check($param)) {
$this->error($validate->getError());
}
$app_id = $param['app_id'];
$customer_id = $param['customer_id'];
$access_token = $param['access_token'];
$url = $param['url'];
$image_id = $param['image_id'];
//验证token是否过期
$api = $this->check($app_id,$access_token);
//保存图片
$file = $this->saveImage($url);
//请求地址
$url = config('validate.shuguan')['url'];
$files = realpath(ltrim(".".$file, '@'));
$files = new \CURLFile($files);
$key = $this->getKey(20,false);
$param['files'] = $files;
$param['timestamp'] = date('Y-m-d H:i:s');
$param['key'] = $key;
$param['image_id'] = $image_id;
$param['sign'] = $this->getSign($param);
$result = $this->httpPost($url,$param);
file_put_contents('a.txt',print_r($result,true),FILE_APPEND);
file_put_contents('a.txt','\r\n',FILE_APPEND);
$data = json_decode($result,true);
Db::startTrans();
//保存数管信息
$arr = [
'api_id' => $api['api']['id'],
'customer_id' => $api['api']['customer_id'],
'yingyong_id' => $customer_id,
'image_id' => $image_id,
'files' => $file,
'timestamp' => $param['timestamp'],
'key' => $key,
'sign' => $param['sign'],
'createtime' => time(),
];
$result1 = Db::name('shuguan')->insertGetId($arr);
if(!$result1){
Db::rollback();
$this->error('sql执行失败');
}
//保存数管接口返回数据
if(!empty($data['result'])){
$arr2 = [];
foreach($data['result'] as $key => $r){
$arr1 = [
'shuguan_id' => $result1,
'type' => $r['type'],
'total' => $r['total'],
'confirmation' => $r['confirmation'],
'distrust' => $r['distrust'],
'image_path' => $r['image_path'],
'createtime' => time(),
];
$arr2[] = $arr1;
}
$result2 = Db::name('shuguan_log')->insertAll($arr2);
if(!$result2){
Db::rollback();
$this->error('sql执行失败');
}
}
Db::commit();
$this->success('SUCCESS',$result);
}
/**
* 模拟调用
*/
private function test(){
dump(getAddress("N39.085660E117.068135"));
exit();
$url = "http://gangjuren.net/api/app/getImageInfo";
$arr = [
'url' => "http://company.zzspjob.com/6b408e79f3a21ac02746b218f6cbc99@3x.png",
'app_id' => 'gjra2g11dg56ad7bb71',
'customer_id' => '1',
'access_token' => 'e508a6c25ed2ec1237fa8a0ba8a09357ff83b8c8',
'image_id' => '1',
];
$result = $this->httpPost($url,$arr);
$this->success('',$result);
}
/**
* 保存图片
* @param $url
* @return string
*/
private function saveImage($url){
$date = date('Ymd');
$savePath = "./uploads/shuguan/$date/";
if (!file_exists($savePath)){
mkdir($savePath, 0777,true);
}
$image = file_get_contents($url);
$file_name = md5(uniqid(rand())).".png";
file_put_contents($savePath.$file_name,$image);
return "/uploads/shuguan/$date/$file_name";
}
/**
* 仿form-data提交表单
* @param $url
* @param $data
* @return mixed
*/
private function httpPost($url,$data){ // 模拟提交数据函数
$curl = curl_init(); // 启动一个CURL会话
curl_setopt($curl, CURLOPT_URL, $url); // 要访问的地址
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false); // 对认证证书来源的检查
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false); // 从证书中检查SSL加密算法是否存在
// curl_setopt($curl, CURLOPT_USERAGENT, $_SERVER['HTTP_USER_AGENT']); // 模拟用户使用的浏览器
curl_setopt($curl, CURLOPT_POST, true); // 发送一个常规的Post请求
curl_setopt($curl, CURLOPT_POSTFIELDS, $data); // Post提交的数据包
//curl_setopt($curl, CURLOPT_TIMEOUT, 120); // 设置超时限制防止死循环
curl_setopt($curl, CURLOPT_HEADER, false); // 显示返回的Header区域内容
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); // 获取的信息以文件流的形式返回
$result = curl_exec($curl); // 执行操作
if (curl_errno($curl)) {
echo 'Error POST'.curl_error($curl);
}
curl_close($curl); // 关键CURL会话
return $result; // 返回数据
}
/**
* 获取随机字符串
* @param $len 长度
* @param bool $special 是否需要特殊字符
* @return string 返回随机字符串
*/
private function getKey($len, $special=true){
$chars = array(
"a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k",
"l", "m", "n", "o", "p", "q", "r", "s", "t", "u", "v",
"w", "x", "y", "z", "A", "B", "C", "D", "E", "F", "G",
"H", "I", "J", "K", "L", "M", "N", "O", "P", "Q", "R",
"S", "T", "U", "V", "W", "X", "Y", "Z", "0", "1", "2",
"3", "4", "5", "6", "7", "8", "9"
);
if($special){
$chars = array_merge($chars, array(
"!", "@", "#", "$", "?", "|", "{", "/", ":", ";",
"%", "^", "&", "*", "(", ")", "-", "_", "[", "]",
"}", "<", ">", "~", "+", "=", ",", "."
));
}
$charsLen = count($chars) - 1;
shuffle($chars);//打乱数组顺序
$str = '';
for($i=0; $i<$len; $i++){
$str .= $chars[mt_rand(0, $charsLen)];//随机取出一位
}
return $str;
}
/**
* 生成签名
* @param array $param 要加密的数组
* @return string 返回签名
*/
protected function getSign($param){
$key = $param['key'];
unset($param['key']);
unset($param['files']);
//按照参数名ASCII字典序排序
ksort($param);
$arr = [];
foreach($param as $k => $p){
$arr[] = $k."=".$p;
}
//拼接成字符串
$str = implode('&',$arr);
//与key拼接
$str = $str."&key=".$key;
//进行加密
$signature = MD5($str);
//转换成大写
$signature = strtoupper($signature);
return $signature;
}
}
\ No newline at end of file
... ...
此 diff 太大无法显示。