PHP微信公众号（微信小程序）模板消息推送

1. /**
2. * 补货订单通知
3. */
4. public function orderStockout($store_id)
5. {
6. $user = new \app\admin\model\User();
7. $user_info = $user->where('store_id',$store_id)->find();
8. if(!$user_info){
9. return ['code'=>0,'message'=>'商家不存在'];
10. }
11. if(!$user_info['openid']){
12. return ['code'=>0,'message'=>'openid未获取到,请先绑定微信账号'];
13. }
14. //获取商品
15. $where = [
16. 's.uid' => $store_id,
17. 's.is_integral' => 0,
18. 's.is_stock' => 0,
19. ];
20. $field = 's.id,g.name,s.inventory,s.stock_num';
21. $sproduct = new Product();
22. $result = $sproduct->alias('s')
23. ->join('goods_product g','g.id=s.product_id','left')
24. ->where($where)
25. ->field($field)
26. ->select();
27. if(!$result){
28. return ['code'=>0,'message'=>'暂无商品需要补货'];
29. }
30. $str = '';
31. $ids = [];
32. $number = 0;
33. foreach($result as $ka=>$va){
34. if($va['inventory'] <= $va['stock_num']){
35. $str .= $va['name'].',';
36. $ids[] = $va['id'];
37. if($number == 0){
38. $number = $va['inventory'];
39. }
40. }
41. }
42. //如果到达预警的商品数量没有
43. if(count($ids) <= 0){
44. return true;
45. }
46. //更新达到预警的商品状态
47. $sproduct::where(['id'=>['in',$ids]])->update(['is_stock'=>1]);
49. $data = array(
50. 'first' => array(
51. 'value'=> '您好,您有商品库存不足',
52. 'color'=>''
53. ),
54. 'keyword1'=>array(
55. 'value'=>implode(',',$ids),
56. 'color'=>''
57. ),
58. 'keyword2'=>array(
59. 'value'=> $str,
60. 'color'=>''
61. ),
62. 'keyword3'=>array(
63. 'value'=> $number,
64. 'color'=>''
65. ),
66. 'remark' => array(
67. 'value'=>'感谢您的使用',
68. 'color'=>''
69. ),
70. );
72. $url = '跳转页面';
73. $template_id = '微信模板消息id';
74. return $this->sendWechatMessage($user_info['openid'],$template_id,$data,$url);
75. }
77. /**
78. * 发送微信模板消息
79. * @param $order_id
80. * @param $template
81. * @return false|string|\think\response\Json
82. */
83. public function sendWechatMessage($openid,$template_id,$data,$url)
84. {
85. $data = array(
86. "touser" => $openid, //openid
87. "template_id" => $template_id, //模板id
88. "url" => $url,
89. "data" => $data //模板数据
90. );
91. //下单用户发送
92. $access_token = $this->access_token();
93. if ($access_token == 400){
94. return ['code'=>0,'message'=>'获取access_token失败'];
95. }
96. $urls = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=".$access_token;
97. $result = $this->http_post_json($urls,json_encode($data));//发送请求
98. if($result[0] == 200){
99. return ['code'=>1,'data'=>'推送成功'];
100. }
101. return ['code'=>0,'message'=>$result[1]['errmsg']];
102. }
105. public function http_post_json($url, $jsonStr)
106. {
107. $ch = curl_init();
108. curl_setopt($ch, CURLOPT_POST, 1);
109. curl_setopt($ch, CURLOPT_URL, $url);
110. curl_setopt($ch, CURLOPT_POSTFIELDS, $jsonStr);
111. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
112. curl_setopt($ch, CURLOPT_HTTPHEADER, array(
113. 'Content-Type: application/json; charset=utf-8',
114. 'Content-Length: ' . strlen($jsonStr)
115. )
116. );
117. $response = curl_exec($ch);
118. $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
119. curl_close($ch);
120. return [$httpCode,$response];
121. // return json_encode(array($httpCode, $response),true);
122. //"[200,"{\"errcode\":0,\"errmsg\":\"ok\",\"msgid\":2696398438942572550}"]"
123. }
125. //获取access_token
126. public function access_token(){
127. $appId = Config::get('wechat_config.appid');
128. $appSecret = Config::get('wechat_config.secret');
129. $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=".$appId."&secret=".$appSecret;
130. $ch = curl_init();//初始化curl
131. curl_setopt($ch, CURLOPT_URL,$url); //要访问的地址
132. curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);
133. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);//跳过证书验证
134. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); // 从证书中检查SSL加密算法是否存在
135. $data = json_decode(curl_exec($ch),true);
136. if(curl_errno($ch)){
137. var_dump(curl_error($ch)); //若错误打印错误信息
138. }
139. curl_close($ch);//关闭curl
140. return $data['access_token'];
141. }

逻辑部分可以根据具体的需求自己更改，变量格式是会根据选择用户模板而变，模板有几个变量，就写几个keyword ,小程序的话和这个大差不差，基本上就是调整一下参数就可以继续使用了