微信公众号模板消息群发代码示例

男娘i 2021-09-26 02:32 388阅读 0赞

微信模板消息只能发给一个人.如果要群发,需要通过php循环.依次发送.

注意,如果模板消息发信息时有时无,不稳定,可能你的access\_token令牌更新缓存不及时,过期了.可以根据日志文件查看.建议300秒更新一下.否则会很烦.

模板id需要自己去公众号中设置行业后得到.

function fahuo_wechat($shopid){
    			if(_cfg("sendmobile")){
    			$thisdb = System::load_sys_class("model");
    			$access= getAccessToken();//模板id api等
    		
    		$access_token=$access['access_token'];
    		$template_id = $access['template_id'];
    		$sql = "select * from `@#_member_go_record` where  `shopid`='$shopid' and status = '已付款,未发货,未完成'";
    		$row = $thisdb->GetList($sql);
    		
    		$postUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=$access_token";
    		foreach($row as $k=>$v){
    		$uid=$v['uid'];
    		$member_band = $thisdb->GetOne("SELECT b_code,b_data FROM `@#_member_band` WHERE `b_uid` = '$uid' and b_data!='' ");
    		$mobile=$v['company_money'];
    			if(!empty($member_band['b_data'])){
    
    $url=WEB_PATH."/mobile/user/buyDetail/".$shopid;
    
    			$data = array(
    
    				"touser" => $member_band['b_code'],//一次只发一个人
    
    				"template_id"=>$template_id,
    
    				"url"=>$url, 
    //回调
    				"data" => array(
    
    					'first' =>array(
    
    						"value"=>"您好，".$v['username'].",您的牌局已组建成功。",
    
    						"color"=>"#888",
    
    						),
    
    					"keyword1"=>array(
    
    						"value"=>$v['shopname'],
    
    						"color"=>"#888",
    
    						),
    //echo date('Y-m-d H:i:s',$itemlist[0]['q_end_time'])
    					"keyword2"=>array(
    
    						"value"=>date('Y-m-d H:i:s',$v['time']),
    
    						"color"=>"#888",
    
    						),
    
    					"keyword3"=>array(
    
    						"value"=>"20分钟",
    
    						"color"=>"#888",
    
    						),
    
    					"keyword4"=>array(
    
    						"value"=>round($v['moneycount'])."金豆",
    
    						"color"=>"#888",
    
    						),
    
    					"keyword5"=>array(
    
    						"value"=>"待定",
    
    						"color"=>"#888",
    
    						),
    
    					"remark"=>array(
    
    						"value"=>" 点击查看详情",
    
    						"color"=>"#054ff7",
    
    						),
    
    				),
    
    			);
    $ddd=https_request($postUrl,json_encode($data));

if($ddd->errcode>0)//如果微信发信后的回执中不是0,说明一定是没发送成功.
    {
    	_sendmobile($mobile,'约牌成功,请进入游戏.');//微信工单失败.短信会自动提醒
    
    
    }
    		}else{
    		
    				if($mobile){
    					
    _sendmobile($mobile,'请在微信上搜索并关注我们的公众号.否则收不到微信约牌通知,谢谢。');//
    }
    			
    		}
    			
    			
    		//发送的发货提示的字符串组合成功.准备发送.  
    				
    	
    			
    			
    			//print_r($aaa);exit;
    		}
    		}
    	}
    	   //微信发货准备
    	  
    	  function getAccessToken() {
        // access_token 应该全局存储与更新，以下代码以写入到文件中做示例
    	$path = G_CACHES.'access_token.json';	
        
        $data = json_decode(file_get_contents($path),true);
    	//print_r($data);exit;
        if ($data['expire_time'] < time()) {//过期时间小于当前时间,说明过期,需要更新
    		$appid=$data['appid'];
    		$appsecret=$data['appsecret'];
          $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=$appid&secret=$appsecret";
    	  $json=getCurl($url);
          $data= json_decode($json,true);
    	  //print_r($res);exit;
          $access_token = $data['access_token'];
          if ($access_token) {
    		   $thisdb = System::load_sys_class("model");
    		$wechat= $thisdb->GetOne("select * from `@#_wechat_config` where id = 1");// 获取appid
    		
            $data['expire_time'] = time() + 300;//7200->2000 32分钟 
            $data['access_token'] = $access_token;
    		$data['template_id']=$wechat['template_id'];
    		$data['appid']=$wechat['appid'];
    		$data['appsecret']=$wechat['appsecret'];
            $fp = fopen($path, "w");
            fwrite($fp, json_encode($data));
            fclose($fp);
          }
        } 
        return $data;
      }
    	function https_request($url,$data = null){
    
    	    $curl = curl_init();//初始化一个CURL会话
    
    	    curl_setopt($curl, CURLOPT_URL, $url);//这是你想用PHP取回的URL地址。你也可以在用curl_init()函数初始化时设置这个选项
    
    	    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);//传递一个作为HTTP “POST”操作的所有数据的字符串。
    
    	    }
    
    	    curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
    		//讲curl_exec()获取的信息以文件流的形式返回，而不是直接输出。
    
    	    $output = curl_exec($curl);
    				if(!strstr($output,":0"))//如果微信发信后的回执中不包含:0,说明一定是没发送成功.所以要把不成功的放在日志中.方便找原因.
    {
    $path1 = G_CACHES.'access_token2.json';//access_token2.json为日志保存目录,请对应修改.
     file_put_contents($path1, $output,FILE_APPEND);//FILE_APPEND表示用追加的方式保存日志
    }
    
    		// if(strstr($output,"40003")&&$mobile)//如果是40003说明,,客户没关注我们,发信息提醒他.
    // {
    // _sendmobile($mobile,'请关注我们的公众号.否则收不到微信约牌通知,谢谢。');//
    // }
    
    	    curl_close($curl);
    
    	    return json_decode($output);
    
    	}	_sendmobile($mobile,'约牌成功,请进入游戏.');//微信工单失败.短信会自动提醒
    
    
    }
    		}else{
    		
    				if($mobile){
    					
    _sendmobile($mobile,'请在微信上搜索并关注我们的公众号.否则收不到微信约牌通知,谢谢。');//
    }
    			
    		}
    			
    			
    		//发送的发货提示的字符串组合成功.准备发送.  
    				
    	
    			
    			
    			//print_r($aaa);exit;
    		}
    		}
    	}
    	   //微信发货准备
    	  
    	  function getAccessToken() {
        // access_token 应该全局存储与更新，以下代码以写入到文件中做示例
    	$path = G_CACHES.'access_token.json';	
        
        $data = json_decode(file_get_contents($path),true);
    	//print_r($data);exit;
        if ($data['expire_time'] < time()) {//过期时间小于当前时间,说明过期,需要更新
    		$appid=$data['appid'];
    		$appsecret=$data['appsecret'];
          $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=$appid&secret=$appsecret";
    	  $json=getCurl($url);
          $data= json_decode($json,true);
    	  //print_r($res);exit;
          $access_token = $data['access_token'];
          if ($access_token) {
    		   $thisdb = System::load_sys_class("model");
    		$wechat= $thisdb->GetOne("select * from `@#_wechat_config` where id = 1");// 获取appid
    		
            $data['expire_time'] = time() + 300;//7200->2000 32分钟 
            $data['access_token'] = $access_token;
    		$data['template_id']=$wechat['template_id'];
    		$data['appid']=$wechat['appid'];
    		$data['appsecret']=$wechat['appsecret'];
            $fp = fopen($path, "w");
            fwrite($fp, json_encode($data));
            fclose($fp);
          }
        } 
        return $data;
      }
    	function https_request($url,$data = null){
    
    	    $curl = curl_init();//初始化一个CURL会话
    
    	    curl_setopt($curl, CURLOPT_URL, $url);//这是你想用PHP取回的URL地址。你也可以在用curl_init()函数初始化时设置这个选项
    
    	    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);//传递一个作为HTTP “POST”操作的所有数据的字符串。
    
    	    }
    
    	    curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
    		//讲curl_exec()获取的信息以文件流的形式返回，而不是直接输出。
    
    	    $output = curl_exec($curl);
    				if(!strstr($output,":0"))//如果微信发信后的回执中不包含:0,说明一定是没发送成功.所以要把不成功的放在日志中.方便找原因.
    {
    $path1 = G_CACHES.'access_token2.json';//access_token2.json为日志保存目录,请对应修改.
     file_put_contents($path1, $output,FILE_APPEND);//FILE_APPEND表示用追加的方式保存日志
    }
    
    		// if(strstr($output,"40003")&&$mobile)//如果是40003说明,,客户没关注我们,发信息提醒他.
    // {
    // _sendmobile($mobile,'请关注我们的公众号.否则收不到微信约牌通知,谢谢。');//
    // }
    
    	    curl_close($curl);
    
    	    return json_decode($output);
    
    	}

![70][]

[70]: /images/20210923/bbfb77d631684c9a884ada9784675478.png