123

@@ -11,6 +11,7 @@ use think\addons\Controller;
 use think\Db;
 use think\Db;
 use think\Response;
 use think\Response;
 use think\Session;
 use think\Session;
+use app\api\controller\Index;
 use Yansongda\Pay\Exceptions\GatewayException;
 use Yansongda\Pay\Exceptions\GatewayException;
 use Yansongda\Pay\Pay;
 use Yansongda\Pay\Pay;
 
 
@@ -280,8 +281,7 @@ class Api extends Controller
                 $orderlog['createtime'] = time();
                 $orderlog['createtime'] = time();
                 Db::name('order_log')->insert($orderlog);
                 Db::name('order_log')->insert($orderlog);
                 $this->SendMessage($cks['id']);
                 $this->SendMessage($cks['id']);
-                $index=new \app\api\controller\Index();
-                $index->senWxmsgToDriverUser($cks['id']);
+                $this->senWxmsgToDriverUser($cks['id']);
             }
             }
         }
         }
 
 
@@ -289,4 +289,75 @@ class Api extends Controller
         //下面这句必须要执行,且在此之前不能有任何输出
         //下面这句必须要执行,且在此之前不能有任何输出
         return $pay->success()->send();
         return $pay->success()->send();
     }
     }
+
+    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['position']}", '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 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;
+    }
+    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;
+    }
+
 }
 }