发布推送
This commit is contained in:
ROmani
48
app/Models/Post/PostHistoryModel.php
Normal file
48
app/Models/Post/PostHistoryModel.php
Normal file
@ -0,0 +1,48 @@
|
||||
<?php
|
||||
namespace App\Models\Post;
|
||||
|
||||
use App\Exceptions\ModelException;
|
||||
use App\Models\Base\BaseModel;
|
||||
|
||||
class PostHistoryModel extends BaseModel
|
||||
{
|
||||
protected $table = 'customer_post_history';
|
||||
protected $primaryKey = 'id';
|
||||
protected $fillable = [
|
||||
'id',
|
||||
'method',
|
||||
'oid',
|
||||
'uuid',
|
||||
'mid',
|
||||
'uid',
|
||||
'media',
|
||||
'content',
|
||||
'created_at',
|
||||
];
|
||||
|
||||
const METHOD_ADD = 1;
|
||||
const METHOD_DEL = 2;
|
||||
const METHOD_EDIT = 4;
|
||||
const METHOD = [
|
||||
self::METHOD_ADD => '新增',
|
||||
self::METHOD_DEL => '删除',
|
||||
self::METHOD_EDIT => '编辑',
|
||||
];
|
||||
|
||||
/**
|
||||
* @throws ModelException
|
||||
*/
|
||||
function addPostHistory($method, $aItem): \Illuminate\Database\Eloquent\Model|\Illuminate\Database\Eloquent\Builder|array|null
|
||||
{
|
||||
if(!in_array($method,self::METHOD)) throw new ModelException('addPostHistory method error');
|
||||
if(!isset($aItem['uuid'])) throw new ModelException('addPostHistory params error');
|
||||
$aItem['oid'] = $aItem['id'];
|
||||
unset($aItem['id']);
|
||||
$sDateTime = date('Y-m-d H:i:s');
|
||||
$aItem['created_at'] = $sDateTime;
|
||||
$aItem['method'] = $method;
|
||||
return $this->addItem($aItem);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
133
app/Models/Post/PostModel.php
Normal file
133
app/Models/Post/PostModel.php
Normal file
@ -0,0 +1,133 @@
|
||||
<?php
|
||||
namespace App\Models\Post;
|
||||
|
||||
use App\Exceptions\ModelException;
|
||||
use App\Models\Base\BaseModel;
|
||||
use App\Tools\Tools;
|
||||
use Illuminate\Database\Eloquent\SoftDeletes;
|
||||
|
||||
class PostModel extends BaseModel
|
||||
{
|
||||
//软删除
|
||||
use SoftDeletes;
|
||||
|
||||
protected $table = 'customer_post';
|
||||
protected $primaryKey = 'id';
|
||||
protected $fillable = [
|
||||
'id',
|
||||
'uuid',
|
||||
'mid',
|
||||
'uid',
|
||||
'media',
|
||||
'content',
|
||||
'created_at',
|
||||
'deleted_at',
|
||||
];
|
||||
|
||||
/**
|
||||
* @throws ModelException
|
||||
*/
|
||||
function addPost($uid, $content = null, $media = null): \Illuminate\Database\Eloquent\Model|\Illuminate\Database\Eloquent\Builder|array|null
|
||||
{
|
||||
if(!$content && !$media) throw new ModelException('addPost params error');
|
||||
$aItem['uid'] = $uid;
|
||||
$aItem['uuid'] = Tools::genUuid();
|
||||
$aItem['media'] = $media;
|
||||
$aItem['content'] = $content;
|
||||
$sDateTime = date('Y-m-d H:i:s');
|
||||
$aItem['created_at'] = $sDateTime;
|
||||
$res = $this->addItem($aItem);
|
||||
if($res){
|
||||
|
||||
}
|
||||
return $res;
|
||||
}
|
||||
|
||||
/**
|
||||
* @throws ModelException
|
||||
*/
|
||||
function delPostById($id)
|
||||
{
|
||||
$oPost = $this->findItem($id);
|
||||
$res = $this->delItem($id);
|
||||
if($res){
|
||||
$oPostHistoryModel = new PostHistoryModel();
|
||||
$oPostHistoryModel->addPostHistory(PostHistoryModel::METHOD_DEL,$oPost->toArray());
|
||||
}
|
||||
return $res;
|
||||
}
|
||||
|
||||
/**
|
||||
* @throws ModelException
|
||||
*/
|
||||
function delPostByUuid($uuid)
|
||||
{
|
||||
$oPost = $this->findItemByWhere(['uuid'=>$uuid]);
|
||||
$res = $this->newQuery()->where('uuid', $uuid)->delete();
|
||||
if($res){
|
||||
$oPostHistoryModel = new PostHistoryModel();
|
||||
$oPostHistoryModel->addPostHistory(PostHistoryModel::METHOD_DEL,$oPost->toArray());
|
||||
}
|
||||
return $res;
|
||||
}
|
||||
|
||||
function getPostListByUid($uid): \Illuminate\Database\Eloquent\Collection|array
|
||||
{
|
||||
return $this->getItemsByWhere(['uid'=>$uid]);
|
||||
}
|
||||
|
||||
function getPostById($id): \Illuminate\Database\Eloquent\Model|\Illuminate\Database\Eloquent\Collection|\Illuminate\Database\Eloquent\Builder|array|null
|
||||
{
|
||||
return $this->findItem($id);
|
||||
}
|
||||
|
||||
/**
|
||||
* @throws ModelException
|
||||
*/
|
||||
function updatePostById($aItem): bool|int
|
||||
{
|
||||
if(!isset($aItem['id'])) throw new ModelException('updatePostById params error');
|
||||
if(empty($aItem['id'])) throw new ModelException('updatePostById params error');
|
||||
$oPost = $this->findItem($aItem['id']);
|
||||
$res = $this->updateItem($aItem);
|
||||
if($res){
|
||||
$oPostHistoryModel = new PostHistoryModel();
|
||||
$oPostHistoryModel->addPostHistory(PostHistoryModel::METHOD_EDIT,$oPost->toArray());
|
||||
}
|
||||
return $res;
|
||||
}
|
||||
|
||||
/**
|
||||
* @throws ModelException
|
||||
*/
|
||||
function updatePostByUuid($aItem): bool|int
|
||||
{
|
||||
if(!isset($aItem['uuid'])) throw new ModelException('updatePostByUuid params error');
|
||||
if(empty($aItem['uuid'])) throw new ModelException('updatePostByUuid params error');
|
||||
$oPost = $this->findItemByWhere(['uuid'=>$aItem['uuid']]);
|
||||
$res = $this->updateItem($aItem,'uuid');
|
||||
if($res){
|
||||
$oPostHistoryModel = new PostHistoryModel();
|
||||
$oPostHistoryModel->addPostHistory(PostHistoryModel::METHOD_EDIT,$oPost->toArray());
|
||||
}
|
||||
return $res;
|
||||
}
|
||||
|
||||
function getPostListByMid($mid): \Illuminate\Database\Eloquent\Collection|array
|
||||
{
|
||||
return $this->getItemsByWhere(['mid'=>$mid]);
|
||||
}
|
||||
|
||||
|
||||
function getPostListByUidMid($uid,$mid): \Illuminate\Database\Eloquent\Collection|array
|
||||
{
|
||||
return $this->getItemsByWhere(['uid'=>$uid,'mid'=>$mid]);
|
||||
}
|
||||
function getPostListByUids($uids,$sDateLimit = null): \Illuminate\Database\Eloquent\Collection|array
|
||||
{
|
||||
if($sDateLimit == null) $sDateLimit = date('Y-m-d H:i:s',strtotime('-3 day'));
|
||||
return $this->newQuery()->where('created_at',$sDateLimit)->whereIn('uid',$uids)->get();
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
180
app/Models/Post/PostPushBoxModel.php
Normal file
180
app/Models/Post/PostPushBoxModel.php
Normal file
@ -0,0 +1,180 @@
|
||||
<?php
|
||||
|
||||
namespace App\Models\Post;
|
||||
|
||||
use App\Exceptions\ModelException;
|
||||
use App\Models\Base\BaseModel;
|
||||
use App\Models\Customer\CustomerUserExtendModel;
|
||||
use App\Models\Follow\FollowModel;
|
||||
use App\Tools\CollectOffsetLimit;
|
||||
|
||||
class PostPushBoxModel extends BaseModel
|
||||
{
|
||||
|
||||
protected $table = 'customer_post_push_box';
|
||||
protected $primaryKey = 'id';
|
||||
protected $fillable = [
|
||||
'id',
|
||||
'uid',
|
||||
'pid',
|
||||
'puuid',
|
||||
'is_like',
|
||||
'is_repost',
|
||||
'is_bookmark',
|
||||
'is_read',
|
||||
'created_at',
|
||||
'created_box_at',
|
||||
'deleted_at',
|
||||
];
|
||||
|
||||
const IS_LIKE_DEFAULT = 1;
|
||||
const IS_LIKE_YES = 2;
|
||||
const IS_LIKE_NO = 3;
|
||||
const IS_LIKE = [
|
||||
self::IS_LIKE_DEFAULT => '默认',
|
||||
self::IS_LIKE_YES => '喜欢',
|
||||
self::IS_LIKE_NO => '不喜欢',
|
||||
];
|
||||
|
||||
const IS_REPOST_DEFAULT = 1;
|
||||
const IS_REPOST_YES = 2;
|
||||
const IS_REPOST = [
|
||||
self::IS_REPOST_DEFAULT => '默认',
|
||||
self::IS_REPOST_YES => '已转发',
|
||||
];
|
||||
|
||||
const IS_BOOKMARK_DEFAULT = 1;
|
||||
const IS_BOOKMARK_YES = 2;
|
||||
const IS_BOOKMARK = [
|
||||
self::IS_BOOKMARK_DEFAULT => '默认',
|
||||
self::IS_BOOKMARK_YES => '已收藏',
|
||||
];
|
||||
|
||||
const IS_READ_DEFAULT = 1;
|
||||
const IS_READ_YES = 2;
|
||||
const IS_READ = [
|
||||
self::IS_READ_DEFAULT => '默认',
|
||||
self::IS_READ_YES => '已收藏',
|
||||
];
|
||||
|
||||
|
||||
/**
|
||||
* 提交后调用事件
|
||||
* @throws ModelException
|
||||
*/
|
||||
function newPostPushTask($id = null, $uuid = null)
|
||||
{
|
||||
$oPostModel = new PostModel();
|
||||
$oPost = null;
|
||||
if ($id) $oPost = $oPostModel->findItem($id);
|
||||
if ($uuid) $oPost = $oPostModel->findItemByWhere(['uuid' => $uuid]);
|
||||
if (!$oPost) throw new ModelException('post not found');
|
||||
$iConfigFansPushLimit = intval(env('CONFIG_FANS_PUSH_LIMIT', 2000));
|
||||
|
||||
//查询粉丝数
|
||||
$CustomerUserExtendModel = new CustomerUserExtendModel();
|
||||
$CustomerUserExtend = $CustomerUserExtendModel->findItem($oPost->uid);
|
||||
if (!$CustomerUserExtend) throw new ModelException('user extend not found');
|
||||
|
||||
//粉丝数少于$iConfigFansPushLimit的用户走写扩散流程（所有粉丝信箱插入一条）
|
||||
$bSendMode = $CustomerUserExtend->fans_num < $iConfigFansPushLimit;
|
||||
|
||||
$iTotalCount = $this->countSendFans($bSendMode, $oPost->uid); //计算发送总数
|
||||
//分批发送
|
||||
$oCollectOffsetLimit = new CollectOffsetLimit();
|
||||
$oCollectOffsetLimit->setITotalCount($iTotalCount)->runWhile(function ($offset, $limit) use ($oPost, $bSendMode) {
|
||||
$oFollowList = $this->getFansListWithPage($bSendMode, $oPost->uid, $offset, $limit);
|
||||
$this->sendPostToBox($oPost, $oFollowList);
|
||||
});
|
||||
|
||||
}
|
||||
|
||||
function getFansListWithPage($bAllFans, $uid, $offset = 0, $limit = 2000): \Illuminate\Database\Eloquent\Collection|array|\Illuminate\Support\Collection
|
||||
{
|
||||
$oFollowModel = new FollowModel();
|
||||
//粉丝数少于$iConfigFansPushLimit的用户走写扩散流程（所有粉丝信箱插入一条）
|
||||
if ($bAllFans) {
|
||||
$oFollowList = $oFollowModel->getFansList($uid, ['uid'], $offset, $limit); //获取所有粉丝列表
|
||||
} else { //读扩散流程（只针对活跃粉丝信箱插入一条）
|
||||
//获取活跃粉丝列表
|
||||
//@活跃粉丝数量过大需要分批处理
|
||||
$oFollowList = $oFollowModel->getActiveFansUidList($uid, ['a.uid'], $offset, $limit);
|
||||
}
|
||||
return $oFollowList;
|
||||
}
|
||||
|
||||
function countSendFans($bAllFans, $uid): int
|
||||
{
|
||||
$oFollowModel = new FollowModel();
|
||||
if ($bAllFans) {
|
||||
$iCount = $oFollowModel->getFansCount($uid); //获取所有粉丝列表
|
||||
} else { //读扩散流程（只针对活跃粉丝信箱插入一条）
|
||||
//获取活跃粉丝列表
|
||||
$iCount = $oFollowModel->getActiveFansUidListCount($uid);
|
||||
}
|
||||
return $iCount;
|
||||
}
|
||||
|
||||
//发送到推送信箱
|
||||
function sendPostToBox($oPost, $oFollowList): void
|
||||
{
|
||||
if (!$oFollowList) return;
|
||||
$date = date('Y-m-d H:i:s');
|
||||
foreach ($oFollowList as $oFollow) {
|
||||
$aItem['uid'] = $oFollow->uid;
|
||||
$aItem['pid'] = $oPost->id;
|
||||
$aItem['puuid'] = $oPost->uuid;
|
||||
$aItem['created_at'] = $oPost->created_at;
|
||||
$aItem['created_box_at'] = $date;
|
||||
$this->addItem($aItem);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 拉取推送信箱列表
|
||||
* @param $uid
|
||||
* @param $last_id //上次最后一条id
|
||||
* @param $limit
|
||||
* @return \Illuminate\Database\Eloquent\Collection|array
|
||||
*/
|
||||
function getPushBoxList($uid, $last_id = 0, $limit = 20): \Illuminate\Database\Eloquent\Collection|array
|
||||
{
|
||||
//活跃用户直接拉取未读消息
|
||||
return $this->newQuery()->where('uid', $uid)->where('id', '>', $last_id)->where('is_read', self::IS_READ_DEFAULT)->orderBy('created_at', 'desc')->limit($limit)->get();
|
||||
//非活跃用户拉取大v消息，在用户状态更新时已经调用过，此处不用在做处理
|
||||
}
|
||||
|
||||
//非活跃拉取已跟随大v最新文章。
|
||||
//放在用户状态更新时调用
|
||||
function pullBigFanMasterPost($uid)
|
||||
{
|
||||
$iConfigFansPushLimit = intval(env('CONFIG_FANS_PUSH_LIMIT', 2000));
|
||||
//@此处需针对大量数据进行分批获取
|
||||
$oFollowModel = new FollowModel();
|
||||
$oFollowList = $oFollowModel->getFollowListWithFansLimit($uid,$iConfigFansPushLimit,['a.follow_uid']);
|
||||
if ($oFollowList->isEmpty()) return null;
|
||||
$aFollowList = $oFollowList->toArray();
|
||||
$aFollowUid = array_column($aFollowList,'follow_uid');
|
||||
$oPostModel = new PostModel();
|
||||
$oPostList = $oPostModel->getPostListByUids($aFollowUid);
|
||||
|
||||
//将推文发送到信箱
|
||||
$this->sendPostToBoxByUid($oPostList,$uid);
|
||||
|
||||
}
|
||||
|
||||
function sendPostToBoxByUid($oPostList, $uid): void
|
||||
{
|
||||
$date = date('Y-m-d H:i:s');
|
||||
foreach ($oPostList as $oPost) {
|
||||
$aItem['uid'] = $uid;
|
||||
$aItem['pid'] = $oPost->id;
|
||||
$aItem['puuid'] = $oPost->uuid;
|
||||
$aItem['created_at'] = $oPost->created_at;
|
||||
$aItem['created_box_at'] = $date;
|
||||
$this->addItem($aItem);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user