<?php
namespace backend\modules\api\controllers;
use common\models\SmsReport;
use common\models\Aes;
use common\models\Counter;
use common\models\Phone;
use common\models\City;
use common\models\oss\oss;
use common\models\PersonLooking;
use Yii;
use yii\rest\Controller;
use backend\modules\api\common\lib\Helper;
use backend\modules\api\models\User;
use backend\modules\api\models\FreeDelivery;
use backend\modules\api\models\Register;
use backend\modules\api\common\lib\HttpUploadFile;
use yii\base\Object;
use backend\modules\api\models\Login;
use backend\modules\api\models\Equipment;
use backend\modules\api\models\Active;
use backend\modules\api\models\Order;
use backend\modules\api\models\AdminDelivery;
use backend\modules\api\models\ShopActive;
use backend\modules\api\models\Abnormal;
use backend\modules\api\models\WxUser;
header(‘Access-Control-Allow-origin:*‘);
header(‘Access-Control-Allow-Credentials:true‘);
header(‘Access-Control-Allow-Methods: GET, POST, PUT, DELETE, OPTIONS‘);
header(‘Access-Control-Allow-Headers:Origin, No-Cache, X-Requested-With, If-Modified-Since, Pragma, Last-Modified, Cache-Control, Expires, Content-Type, X-E4M-With‘);
header(‘Content-Type: text/html; charset=utf-8‘);
class WechatController extends Controller {
public function actionIndex(){
$nonce = Yii::$app->request->get(‘nonce‘);
$token = ‘adshare‘;
$timestamp = Yii::$app->request->get(‘timestamp‘);
$echostr = Yii::$app->request->get(‘echostr‘);
$signature = Yii::$app->request->get(‘signature‘);
$array = array();
$array = array($nonce,$timestamp,$token);
sort($array);
$str = sha1(implode($array));
if($str == $signature && $echostr){
return $echostr;
}else{
self::actionMessage();
}
}
public function actionGetUserInfo($token,$openid){
$url = ‘https://api.weixin.qq.com/cgi-bin/user/info?access_token=‘.$token.‘&openid=‘.$openid.‘&lang=zh_CN‘;
$res= self::actionCurlRequest($url);
return json_decode($res,true);
}
public function actionMessage(){
$postArr = $GLOBALS[‘HTTP_RAW_POST_DATA‘];
$postObj = simplexml_load_string($postArr);
if(strtolower($postObj->MsgType) == ‘event‘){
if(strtolower($postObj->Event) == ‘subscribe‘){
$UserInfo = WxUser::find()->where([‘openid‘=>$postObj->FromUserName])->one();
if(!empty($UserInfo)){
$UserInfo->is_subscribe = 1;
$model->save(false);
}else{
//获取用户信息
$token = self::actionGetToken();
$res = self::actionGetUserInfo($token,$postObj->FromUserName);
$model = new WxUser();
$model->openid = $res[‘openid‘];
$model->unionid = $res[‘unionid‘];
$model->sex = $res[‘sex‘];
$model->imgs = $res[‘headimgurl‘];
$model->username = $res[‘nickname‘];
$model->create_time = time();
$model->login_time = time();
$model->login_ip = $_SERVER["REMOTE_ADDR"];
$model->create_ip = $_SERVER["REMOTE_ADDR"];
//$model->lng = $Longitude;
//$model->lat = $Latitude;
$model->save(false);
}
$toUser = $postObj->FromUserName;//用户的openid
$fromUser = $postObj->ToUserName;
$time = time();
$Msgtype = ‘news‘;
$arr = array(
array(
‘Title‘=>‘欢迎关注AD共享‘,
‘Description‘=>‘这是一个属于互联网传媒的时代‘,
‘PicUrl‘=>‘http://fx.peita.net/adShared/img/icon/banner.png‘,
‘Url‘=>‘http://fx.peita.net/adShared/pages/home.html‘
)
);
$template = "<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[%s]]></MsgType>
<ArticleCount>".count($arr)."</ArticleCount>
<Articles>";
foreach($arr as $key=>$v){
$template .="<item>
<Title><![CDATA[".$v[‘Title‘]."]]></Title>
<Description><![CDATA[".$v[‘Description‘]."]]></Description>
<PicUrl><![CDATA[".$v[‘PicUrl‘]."]]></PicUrl>
<Url><![CDATA[".$v[‘Url‘]."]]></Url>
</item>";
}
$template .="</Articles>
</xml>";
$info = sprintf($template,$toUser,$fromUser,$time,$Msgtype);
echo $info;
/*$toUser = $postObj->FromUserName;
$fromUser = $postObj->ToUserName;
$time = time();
$Msgtype = ‘text‘;
//$Content = $postObj->FromUserName;
$Content = ‘欢迎关注AD共享公众号‘;
$template = "<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[%s]]></MsgType>
<Content><![CDATA[%s]]></Content>
</xml>";
$info = sprintf($template,$toUser,$fromUser,$time,$Msgtype,$Content);
echo $info;*/
}
if($postObj->Event == ‘LOCATION‘){
$model = WxUser::find()->where([‘openid‘=>$postObj->FromUserName])->one();
$model->lng = $postObj->Longitude;
$model->lat = $postObj->Latitude;
$model->save(false);
/*$toUser = $postObj->FromUserName;
$fromUser = $postObj->ToUserName;
$time = time();
$Msgtype = ‘text‘;
//$Content = $postObj->FromUserName;
$Content = ‘已经上报您的地理位置信息‘;
$template = "<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[%s]]></MsgType>
<Content><![CDATA[%s]]></Content>
</xml>";
$info = sprintf($template,$toUser,$fromUser,$time,$Msgtype,$Content);
echo $info;*/
}
if(strtolower($postObj->Event) == ‘unsubscribe‘){
$model = WxUser::find()->where([‘openid‘=>$postObj->FromUserName])->one();
if(!empty($model)){
$model->is_subscribe = 2;
$model->save(false);
}
}
if($postObj->Event == ‘CLICK‘ && $postObj->EventKey == ‘balance‘){
$data = WxUser::find()->select(‘openid,username,all_money‘)->where([‘openid‘=>$postObj->FromUserName])->one();
if(empty($data)){
$toUser = $postObj->FromUserName;
$fromUser = $postObj->ToUserName;
$time = time();
$Msgtype = ‘text‘;
//$Content = $postObj->FromUserName;
$Content = ‘未获取到您的个人信息，您可以试着重新关注一下‘;
$template = "<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[%s]]></MsgType>
<Content><![CDATA[%s]]></Content>
</xml>";
$info = sprintf($template,$toUser,$fromUser,$time,$Msgtype,$Content);
echo $info;
die;
}
if(!empty(Yii::$app->session[‘wx_token‘])){
$token = Yii::$app->session[‘wx_token‘];
}else{
unset(Yii::$app->session[‘wx_token‘]);
$token = self::actionGetToken();
}
$toUser = $data->openid;
$url = ‘https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=‘.$token;
$sj = date(‘Y-m-d H:i:s‘,time());
$money = $data->all_money.‘元‘;
$message = [
‘touser‘=>$toUser,
‘template_id‘=>‘egyvsRQoBVnOwiyNLk94yhNkhNSDCWKA68GwDf_1QZg‘,
‘data‘=>[
‘first‘=>[‘value‘=>‘您好，账户余额信息如下：‘,‘color‘=>‘#FF0000‘],
‘keyword1‘=>[‘value‘=>$data->username,‘color‘=>‘#173177‘],
‘keyword2‘=>[‘value‘=>$money,‘color‘=>‘#173177‘],
‘keyword3‘=>[‘value‘=>$sj,‘color‘=>‘#173177‘],
‘remark‘=>[‘value‘=>‘如有任何疑问请登录会员系统联系在线客服‘,‘color‘=>‘#173177‘]
]
];
$data2 = json_encode($message);
$res = self::actionCurlRequest($url,$data2);
return $res;
}
if($postObj->Event == ‘VIEW‘ && $postObj->EventKey == ‘http://fx.peita.net/adShared/pages/home.html‘){
$model = WxUser::find()->where([‘openid‘=>$postObj->FromUserName])->one();
if(!empty($model)){
$model->login_ip = $_SERVER["REMOTE_ADDR"];
$model->save(false);
}
}
}
}
//发送模版消息
public function actionPushMessage($openid,$all_money,$username){
//$wxinfo = WxUser::find()->select(‘openid,username,all_money‘)->where([‘<‘, ‘all_money‘, 10])->asArray()->all();
if(!empty(Yii::$app->session[‘wx_token‘])){
$token = Yii::$app->session[‘wx_token‘];
}else{
unset(Yii::$app->session[‘wx_token‘]);
$token = self::actionGetToken();
}
$url = ‘https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=‘.$token;
$time = date(‘Y-m-d H:i:s‘,time());
$cz_url = ‘http://www.peita.net‘;
$message = [
‘touser‘=>$openid,
‘template_id‘=>‘SudqvwsNYy4AFqBO4_KaWklYlhrc69c74jiAF3VBoCU‘,
‘url‘=>$cz_url,
‘data‘=>[
‘first‘=>[‘value‘=>‘您好，您的账户余额不足。请尽快充值，以免影响您的使用。‘,‘color‘=>‘#FF0000‘],
‘keyword1‘=>[‘value‘=>$username,‘color‘=>‘#173177‘],
‘keyword2‘=>[‘value‘=>$all_money.‘元‘,‘color‘=>‘#173177‘],
‘keyword3‘=>[‘value‘=>$cz_url,‘color‘=>‘#173177‘],
‘keyword4‘=>[‘value‘=>$time,‘color‘=>‘#173177‘],
‘remark‘=>[‘value‘=>‘如有任何疑问请登录会员系统联系在线客服‘,‘color‘=>‘#173177‘]
]
];
$data = json_encode($message);
$res = self::actionCurlRequest($url,$data);
}
//充值成功模板
public function actionRechargePushMessage(){
if(!empty(Yii::$app->session[‘wx_token‘])){
$token = Yii::$app->session[‘wx_token‘];
}else{
unset(Yii::$app->session[‘wx_token‘]);
$token = self::actionGetToken();
}
$url = ‘https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=‘.$token;
$time = date(‘Y-m-d H:i:s‘,time());
$message = [
‘touser‘=>‘oH9aS1fyOd-GNXKM59Gx1y3RJNd4‘,
‘template_id‘=>‘f1ZvxWXPmwE-FdRmdEwG7H_S3bfa98rhVw5ERQHPSMc‘,
‘data‘=>[
‘first‘=>[‘value‘=>‘您好，你已成功进行账户充值。‘,‘color‘=>‘#FF0000‘],
‘accountType‘=>[‘value‘=>‘充值账户‘,‘color‘=>‘#173177‘],
‘account‘=>[‘value‘=>‘张伟‘,‘color‘=>‘#173177‘],
‘amount‘=>[‘value‘=>‘100元‘,‘color‘=>‘#173177‘],
‘result‘=>[‘value‘=>‘充值成功‘,‘color‘=>‘#173177‘],
‘remark‘=>[‘value‘=>‘如有任何疑问请登录会员系统联系在线客服‘,‘color‘=>‘#173177‘]
]
];
$data = json_encode($message);
$res = self::actionCurlRequest($url,$data);
return json_decode($res,true);
}
public function actionGetToken(){
$url = ‘https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=wx69c7f72146629b05&secret=7367d829b543a55dc99ddf01c9ca0023‘;
$res = json_decode(self::actionCurlRequest($url));
Yii::$app->session[‘wx_token‘] = $res->access_token;
return $res->access_token;
}
public function actionSetMenu(){
if(!empty(Yii::$app->session[‘wx_token‘])){
$token = Yii::$app->session[‘wx_token‘];
}else{
unset(Yii::$app->session[‘wx_token‘]);
$token = self::actionGetToken();
}
$url = ‘https://api.weixin.qq.com/cgi-bin/menu/create?access_token=‘.$token;
$data = array(
‘button‘=>array(
array(
‘type‘=>‘view‘,
‘name‘=>‘广告投放‘,
‘url‘=>‘https://open.weixin.qq.com/connect/oauth2/authorize?appid=wx69c7f72146629b05&redirect_uri=http://fx.peita.net/adShared/index.html&response_type=code&scope=snsapi_base&state=123&connect_redirect=1#wechat_redirect‘
),
array(
‘name‘=>‘我的‘,
‘sub_button‘=>array(
array(
‘type‘=>‘view‘,
‘name‘=>‘充值‘,
‘url‘=>‘http://www.peita.net‘
),
array(
‘type‘=>‘click‘,
‘name‘=>‘查看余额‘,
‘key‘=>‘balance‘
)
)
),
),
);
//创建菜单
$res= self::actionCurlRequest($url,json_encode($data,JSON_UNESCAPED_UNICODE));
return $res;
}
public function actionDelMenu(){
if(!empty(Yii::$app->session[‘wx_token‘])){
$token = Yii::$app->session[‘wx_token‘];
}else{
unset(Yii::$app->session[‘wx_token‘]);
$token = self::actionGetToken();
}
$url = ‘https://api.weixin.qq.com/cgi-bin/menu/delete?access_token=‘.$token;
$res= self::actionCurlRequest($url);
return $res;
}
public function actionCurlRequest($url,$data=null){
$curl = curl_init();
curl_setopt($curl,CURLOPT_URL,$url);
curl_setopt($curl,CURLOPT_SSL_VERIFYPEER,FALSE);
curl_setopt($curl,CURLOPT_SSL_VERIFYHOST,FALSE);
if(!empty($data)){
curl_setopt($curl,CURLOPT_POST,1);
curl_setopt($curl,CURLOPT_POSTFIELDS,$data);
}
curl_setopt($curl,CURLOPT_RETURNTRANSFER,1);
$output = curl_exec($curl);
curl_close($curl);
return $output;
}
public function actionCodeGetUserInfo(){
$code = Yii::$app->request->get(‘code‘);
$url = ‘https://api.weixin.qq.com/sns/oauth2/access_token?appid=wx69c7f72146629b05&secret=7367d829b543a55dc99ddf01c9ca0023&code=‘.$code.‘&grant_type=authorization_code‘;
$res = json_decode(self::actionCurlRequest($url));
$openid = $res->openid;
$data = WxUser::find()->where([‘openid‘=>$openid])->one();
if(empty($data)) return Helper::format_data(SUCC,null);
return Helper::format_data(SUCC,$data);
}
/*
* ipad 返回
* @param browser总浏览量，type 根据1，2，3判断返回的广告来源，1付费用户，2商家用户，3后台用户，equipment_imei设备imei，active_id 该设备投放的广告主键id，shop_id 设备所属商家id
*/
public function actionReturnPlay(){
$request = Yii::$app->request->post();
$money = $request[‘browser‘]*0.01;
if($request[‘type‘] == 1){
$model = new WxUser();
$user = new User();
$models = new Active();
$order = new Order();
$Person = new PersonLooking();
$time = date(‘Ymd‘,time());
$equipment = equipment::find()->select(‘equipment_id,equipment_imei‘)->where([‘equipment_imei‘=>$request[‘equipment_imei‘]])->andwhere([‘fault_status‘=>0])->one();
if(empty($equipment)) {
return Helper::format_data(IMEI,null);
}
$PersonLooking = $Person->find()->where([‘equipment_id‘=>$equipment->equipment_id])->andWhere([‘create_time‘=>$time])->one();
if(empty($PersonLooking)){
$Person->equipment_id = $equipment->equipment_id;
$Person->hour_looking = $request[‘browser‘];
$Person->create_time = $time;
$Person->save(false);
}else{
$PersonLooking->hour_looking += $request[‘browser‘];
$PersonLooking->save(false);
}
if($request[‘status‘] == 1){
$active = $models->find()->where([‘a_id‘=>$request[‘active_id‘]])->where([‘shop_type‘=>1])->one();
}elseif($request[‘status‘] == 2){
$active = $models->find()->where([‘a_id‘=>$request[‘active_id‘]])->where([‘shop_type‘=>2])->one();
}
$wx_id = $active->user_id;
$active->browser += $request[‘browser‘];
$str = $user->find()->where([‘id‘=>$request[‘shop_id‘]])->one();
if(empty($str)){
return Helper::format_data(INVALID_ACCESS_TOKEN,null);
}
$money_all = $money*0.3;
$str->current_money += $money_all;
$str->money_count += $money_all;
if($active->save(false) == false){
return Helper::format_data(ERROR_ACTIVE,$active->getErrors());
}
$arr = $order->find()->where([‘order_id‘=>$request[‘order_id‘]])->one();
if(empty($arr)){
return Helper::format_data(INVALID_ACCESS_TOKEN,null);
}
$arr->price += $money;
if($arr->save(false) == false){
return Helper::format_data(ERROR_ORDER,$arr>getErrors());
}
if($request[‘status‘] == 1){ //微信推送
$data = $model->find()->where([‘id‘=>$wx_id])->one();
if(empty($data)){
return Helper::format_data(INVALID_ACCESS_TOKEN,null);
}
if($data->amount < $money){
$result = FreeDelivery::deleteAll([‘shop_id‘=>$request[‘shop_id‘]]);
$data->amount -= $money;
if($data->save(false)){
$data->all_money += $data->amount;
$data->amount = 0;
if($data->save(false)){
if($str->save(false)){
$res = self::actionPushMessage($data->openid,$data->all_money,$data->username);
return Helper::format_data(SUCC,[‘shop_id‘=>$request[‘shop_id‘],‘type‘=>1,‘res‘=>json_decode($res)]);
}
}
}
}
$data->amount -= $money;
$data->save(false);
if($data->save(false) == false) return Helper::format_data(ERROR_WXUSER,$data->getErrors());
if($str->save(false)){
return Helper::format_data(SUCC,$str->id);
}
}elseif($request[‘status‘] == 2){ //个推
$data = $user->find()->where([‘id‘=>$wx_id])->one();
if(empty($data)){
return Helper::format_data(INVALID_ACCESS_TOKEN,null);
}
if($data->amount < $money){
$result = FreeDelivery::deleteAll([‘shop_id‘=>$request[‘shop_id‘]]);
if($data->save(false)){
$data->money_count += $data->amount;
$data->amount = 0;
if($data->save(false)){
if($str->save(false)){
return Helper::format_data(SUCC,[‘shop_id‘=>$request[‘shop_id‘],‘type‘=>1]);
}
}
}
}
$data->amount -= $money;
$data->save(false);
if($data->save(false) == false) return Helper::format_data(ERROR_WXUSER,$data->getErrors());
if($str->save(false)){
return Helper::format_data(SUCC,$str->id);
}
}
}elseif($request[‘type‘] == 2){
$models = new ShopActive();
$active = $models->find()->where([‘a_id‘=>$request[‘active_id‘]])->one();
$active->browser += $request[‘browser‘];
if($active->save(false)){
return Helper::format_data(SUCC,$active->a_id);
}
return Helper::format_data(ERROR_ORDER,$active->getErrors());
}
$AdminDelivery = new AdminDelivery();
$data = $AdminDelivery->find()->where([‘active_id‘=>$request[‘active_id‘]])->one();
if(empty($data)){
$AdminDelivery->shop_id = $request[‘shop_id‘];
$AdminDelivery->active_id = $request[‘active_id‘];
$AdminDelivery->price = $money;
$AdminDelivery->delivery_time = date(‘Ymd‘);
$AdminDelivery->browse_num = $request[‘browser‘];
if($AdminDelivery->save()){
return Helper::format_data(SUCC,$AdminDelivery->id);
}
return Helper::format_data(ERROR_ORDER,$AdminDelivery->getErrors());
}
$data->price += $money;
$data->browse_num += $request[‘browser‘];
if($data->save(false)){
return Helper::format_data(SUCC,$data->id);
}
return Helper::format_data(ERROR_ORDER,$data->getErrors());
}
}
时间： 2024-10-26 06:16:10