PHP实现小程序批量通知推送

<form bindsubmit=\"getFormId\" report-submit=\"true\">
  <button formType=\'submit\'>获取formId</button>
</form>

getFormId:function(e){
 let formId = e.detail.formId;
 //得到formId，将formId传到后台存储到表里
}

GET https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET

POST https://api.weixin.qq.com/cgi-bin/message/wxopen/template/send?access_token=ACCESS_TOKEN

//需要修改的字段
//1.小程序AppId,小程序secret，去微信公众平台找
//2.表名，时间字段
//3.模板ID，去我的模板里找
//4.跳转地址，你知道的
$url = \'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=小程序AppId&secret=小程序secret\';
   $info = file_get_contents($url);
   $json = json_decode($info);/*对json数据解码*/
   $arr = get_ _vars($json);
   $access_token = $arr[\'access_token\'];
   
   function send_post( $url, $post_data ) {
   $options = array(
    \'http\' => array(
     \'method\' => \'POST\',
     \'header\' => \'Content-type:application/json\',/*header 需要设置为 JSON*/
     \'content\' => $post_data,
     \'timeout\' => 60/*超时时间*/
    )
   );
   $context = stream_context_create( $options );
   $result = file_get_contents( $url, false, $context );
   return $result;
 };
 
 $sql = \"SELECT * FROM 表名 where date_sub(curdate(), INTERVAL 6 DAY) <= date(时间字段) and used=0 group by openid\";
 $rs = $pdo->query($sql);
 $row = $rs->fetchAll();
 $resultsArr = array();
 $updateArr = array();
 $successNum = 0;
 $  = $_GET[\' \'];
 $time = date(\'y年m月d日 h:i\',time());
 for($i=0;$i<count($row);$i++){
  $openid = $row[$i][\'openid\'];
  $formid = $row[$i][\'formId\'];
  $id = $row[$i][\'id\'];
  $post_data = array(
   \"touser\"=> $openid,
   \"template_id\"=> \"模板ID\",
   \"page\"=> \"跳转地址\",
   \"form_id\"=> $formid,
   \"data\"=> array(
    \"keyword1\"=> array(
       \"value\"=> $ 
     ),
     \"keyword2\"=> array(
       \"value\"=> $time
     ),
     \"keyword3\"=> array(
       \"value\"=> \"戳我进入涂呀首页查看\"
     )),
   // \"emphasis_keyword\"=> \"keyword1.DATA\"  设置大字，自己试试就知道了
  ); 
  $post_data = json_encode($post_data);
  $postResults = send_post(\'https://api.weixin.qq.com/cgi-bin/message/wxopen/template/send?access_token=\'.$access_token, $post_data);
  $res = json_decode($postResults);
  $res = get_ _vars($res);
  $errcode = $res[\'errcode\'];
  if($errcode==0){
  $sql1 = \"update formIdList set used=1 where id=$id\";
  $pdo->exec($sql1);
  $successNum+=1;
  };
  array_push($resultsArr, array(\'errcode\'=>$errcode));
 };
 $Results = array(
     \'code\'=>1,
     \'Results\'=>array(
     \'successNum\'=>$successNum,
     \'resultsArr\'=>$resultsArr
     ),
     \'msg\'=>\'\'
   );
   $Results = json_encode($Results);
   echo $Results;