...
|
...
|
@@ -5,6 +5,7 @@ namespace app\api\controller; |
|
|
use app\api\controller\inspection\Task;
|
|
|
use app\common\controller\Api;
|
|
|
use fast\Http;
|
|
|
use think\Db;
|
|
|
|
|
|
/**
|
|
|
* 首页接口
|
...
|
...
|
@@ -20,6 +21,7 @@ class Index extends Api |
|
|
*/
|
|
|
public function index()
|
|
|
{
|
|
|
$res=$this->senWxmsgToDriverUser(284);
|
|
|
$this->success('请求成功');
|
|
|
}
|
|
|
|
...
|
...
|
@@ -89,4 +91,76 @@ class Index extends Api |
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
function senWxmsgToDriverUser($order_id)
|
|
|
{
|
|
|
$order=Db::name("order")->find($order_id);
|
|
|
|
|
|
if($order['driver_id']){
|
|
|
$driver=Db::name("driver")->find($order['driver_id']);
|
|
|
$user=Db::name("user")->find($driver['user_id']);
|
|
|
$wct_user=Db::name("wct_user")->where("unionid",$user['unionid'])->find();
|
|
|
$wxopenid=$wct_user['wx_openid'];
|
|
|
$sendInfo = array(
|
|
|
'first' => array('value' => "汽车票出票状态通知", 'color' => "#743A3A"),
|
|
|
'thing2' => array('value' => "{$order['starting_point']}-{$order['end_point']}", 'color' => '#173177'),
|
|
|
'time3' => array('value' =>urlencode(date('Y-m-d H:i:s', $order['reservation_time'])), 'color' => '#173177'),
|
|
|
'thing7' => array('value' =>"{$order['starting_point']}", 'color' => '#173177'),
|
|
|
'phone_number5' => array('value' => "{$order['phone']}", 'color' => '#173177'),
|
|
|
);
|
|
|
|
|
|
|
|
|
if ($wxopenid) {
|
|
|
$config = get_addon_config('wechat');
|
|
|
$tourl = '';
|
|
|
$ywt_appid = 'wxb7dd0c03865a94e0';
|
|
|
$pagepath = '';
|
|
|
$res = $this->sendAstuWxMsgToAgent($sendInfo, $wxopenid, $tourl, $config['app_id'], $config['secret'], $ywt_appid, $pagepath);
|
|
|
|
|
|
print_r($res);return;
|
|
|
//file_put_contents("pcl_wct_send.log", date("Y-m-d H:i:s") . "1-2-" . json_encode($res, JSON_UNESCAPED_UNICODE) . PHP_EOL, FILE_APPEND);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
function http_request($url, $data = array())
|
|
|
{
|
|
|
$ch = curl_init();
|
|
|
curl_setopt($ch, CURLOPT_URL, $url);
|
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
|
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
|
|
|
// 我们在POST数据哦!
|
|
|
curl_setopt($ch, CURLOPT_POST, 1);
|
|
|
// 把post的变量加上
|
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
|
|
|
$output = curl_exec($ch);
|
|
|
curl_close($ch);
|
|
|
return $output;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 微信公众号
|
|
|
* 经纪人审核 消息推送
|
|
|
*/
|
|
|
function sendAstuWxMsgToAgent($info, $openid, $tourl, $appid, $secret, $ywt_appid, $pagepath)
|
|
|
{
|
|
|
$myurl = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" . $appid . "&secret=" . $secret;
|
|
|
$json_token = $this->http_request($myurl);
|
|
|
$access_tokens = json_decode($json_token, true);
|
|
|
$access_token = $access_tokens['access_token'];
|
|
|
$template = array(
|
|
|
'touser' => $openid, //
|
|
|
'template_id' => 'zQaLnhEOQxdGOKJlDUAfEoNY4NTmNWy9a9vYzkZjGn8', //模板消息id 必须修改
|
|
|
'url' => $tourl, //点击链接
|
|
|
"miniprogram" => [],
|
|
|
'topcolor' => "#173177",
|
|
|
'data' => $info
|
|
|
);
|
|
|
|
|
|
$json_template = json_encode($template);
|
|
|
$url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" . $access_token;
|
|
|
$json = $this->http_request($url, urldecode($json_template));
|
|
|
$rs = json_decode($json, true);
|
|
|
return $rs;
|
|
|
}
|
|
|
} |
...
|
...
|
|