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

'12-30'

... ... @@ -75,6 +75,24 @@ class Article extends BaseApi
]);
//6.查询数据
$article = model('article')->where('id',$article['id'])->find();
//7.获取关注自己的的用户id 并推送消息
$user_ids = model('user_attention')->where('in_user_id',$this->auth->id)->column('id');
if ($user_ids){
foreach ($user_ids as $val){
//增加消息
$message = [
'user_id'=>$val,
'in_user_id'=>$article['user_id'],
'avatar'=>$this->auth->avatar,
'nickname'=>$this->auth->nickname,
'title'=>'您关注的 \"'.$this->auth->nickname.'\" 发布了新的动态',
'brief'=>$article['content'],
'status'=>2,
'key_id'=>$article['id'],
];
model('message')->create($message);
}
}
//7.返回结果
$this->success('增加动态成功',$article);
}
... ... @@ -286,6 +304,8 @@ class Article extends BaseApi
$data['user_id'] = $this->auth->id;
$data['zan_num'] = 0;
$res = model('article_comment')->create($data);
//3.增加动态评论数据
model('article')->where('id',$data['article_id'])->setInc('ping_num');
Db::commit();
} catch (Exception $e) {
Db::rollback();
... ... @@ -690,8 +710,25 @@ class Article extends BaseApi
if ($order['status'] == 1)$fail('您的订单已经支付');
$order->status = 1;
$order->save();
//查询用户和动态
$user = model('user')->where('id',$order['user_id'])->find();
$article = model('article')->where('id',$order['article_id'])->find();
//给礼物用户一个通知
//
if ($user){
$str = empty($order['gift_id'])?'自定义礼物':$order['gift_name'];
$message = [
'user_id'=>$order['article_user_id'],
'in_user_id'=>$user['id'],
'avatar'=>$user['avatar'],
'nickname'=>$user['nickname'],
'title'=>$article['content'],
'brief'=>'用户:'.$this->auth->nickname.' 送给您的动态一个:'.$str,
'status'=>3,
'key_id'=>$article['id'],
];
model('message')->create($message);
}
});
$response->send(); // Laravel 里请使用:return $response;
}
... ...
<?php
namespace app\api\controller;
/**
* 消息相关
* @package app\api\controller
*/
class Message extends BaseApi
{
}
\ No newline at end of file
... ...
<?php
namespace app\common\model;
class Message extends BaseModel
{
}
\ No newline at end of file
... ...