作者 何书鹏
1 个管道 的构建 通过 耗费 0 秒

留言发送模板消息

@@ -396,6 +396,7 @@ class HouseBoard extends Api @@ -396,6 +396,7 @@ class HouseBoard extends Api
396 'is_read_user' => 1 396 'is_read_user' => 1
397 ]; 397 ];
398 $res_msg = $msg_model->edit($update); 398 $res_msg = $msg_model->edit($update);
  399 + $message_id = $msg['id'];
399 } else { 400 } else {
400 $insert = $where_m; 401 $insert = $where_m;
401 $insert['type'] = 3; 402 $insert['type'] = 3;
@@ -403,6 +404,7 @@ class HouseBoard extends Api @@ -403,6 +404,7 @@ class HouseBoard extends Api
403 $insert['image'] = $param['image']; 404 $insert['image'] = $param['image'];
404 $insert['is_read_user'] = 2; 405 $insert['is_read_user'] = 2;
405 $res_msg = $msg_model->add($insert); 406 $res_msg = $msg_model->add($insert);
  407 + $message_id = $msg_model->where($where_m)->value('id');
406 } 408 }
407 // 发送模板消息 409 // 发送模板消息
408 $send_data = array( 410 $send_data = array(
@@ -412,7 +414,7 @@ class HouseBoard extends Api @@ -412,7 +414,7 @@ class HouseBoard extends Api
412 "remark" => '', 414 "remark" => '',
413 ); 415 );
414 $openid = Db::name('third')->where('user_id',$param['house_user_id'])->value('openid'); 416 $openid = Db::name('third')->where('user_id',$param['house_user_id'])->value('openid');
415 - $url = config('option.vue_url') . '/liuyanxiaoxi?is_template=1&id='.$res_msg['id']; 417 + $url = config('option.vue_url') . '/liuyanxiaoxi?is_template=1&id='.$message_id;
416 $this->wxsendmessage($openid,$send_data,config('option.template')['msg'],$url); 418 $this->wxsendmessage($openid,$send_data,config('option.template')['msg'],$url);
417 Db::commit(); 419 Db::commit();
418 } catch (PDOException $e) { 420 } catch (PDOException $e) {
@@ -697,14 +697,19 @@ class User extends Api @@ -697,14 +697,19 @@ class User extends Api
697 ]; 697 ];
698 $res_msg = $msg_model->edit($update); 698 $res_msg = $msg_model->edit($update);
699 // 发送模板消息 699 // 发送模板消息
700 -// $send_data = array(  
701 -// "first" => '',  
702 -// 'keyword1' => '',  
703 -// "keyword2" => '',  
704 -// "keyword3" => date('Y-m-s',time()),  
705 -// "remark" => '',  
706 -// );  
707 -// $this->wxsendmessage('','',''); 700 + $send_data = array(
  701 + "first" => '您有一条新的消息',
  702 + 'keyword1' => $param['content'] ? $param['content'] : '【图片消息】',
  703 + "keyword2" => date('Y-m-s H:i:s',time()),
  704 + "remark" => '',
  705 + );
  706 + $openid = Db::name('third')->where('user_id',$msg['object_user_id'])->value('openid');
  707 + if($msg['type'] == 2) {
  708 + $url = config('option.vue_url') . '/messageto?is_template=1&id='.$msg['id'];
  709 + } elseif($msg['type'] == 3) {
  710 + $url = config('option.vue_url') . '/liuyanxiaoxi?is_template=1&id='.$msg['id'];
  711 + }
  712 + $this->wxsendmessage($openid,$send_data,config('option.template')['msg'],$url);
708 Db::commit(); 713 Db::commit();
709 } catch (PDOException $e) { 714 } catch (PDOException $e) {
710 Db::rollback(); 715 Db::rollback();