396 lines
11 KiB
PHP
396 lines
11 KiB
PHP
<?php
|
||
/**
|
||
* @date ：2023年03月9日
|
||
* @author：刘孝全
|
||
* @email：q8197264@126.com
|
||
*
|
||
* @ 商品参数关联表
|
||
*/
|
||
namespace app\common\model\merchant\system;
|
||
|
||
use app\common\model\merchant\store\product\Spu;
|
||
use app\common\model\merchant\community\Community;
|
||
use app\common\model\merchant\store\StoreCategory;
|
||
use app\common\model\merchant\system\auth\Menu;
|
||
use app\common\model\merchant\system\merchant\Merchant;
|
||
use app\common\model\merchant\user\User;
|
||
use think\Model;
|
||
use think\exception\ValidateException;
|
||
|
||
class Relevance extends Model
|
||
{
|
||
protected $connection = 'shop';
|
||
protected $table = 'eb_relevance';
|
||
protected $pk = 'relevance_id';
|
||
|
||
//文章关联商品
|
||
const TYPE_COMMUNITY_PRODUCT = 'community_product';
|
||
//社区关注
|
||
const TYPE_COMMUNITY_FANS = 'fans';
|
||
//社区文章点赞
|
||
const TYPE_COMMUNITY_START = 'community_start';
|
||
//社区评论点赞
|
||
const TYPE_COMMUNITY_REPLY_START = 'community_reply_start';
|
||
//商户权限
|
||
const TYPE_MERCHANT_AUTH = 'mer_auth';
|
||
|
||
//指定范围类型
|
||
//0全部商品
|
||
const TYPE_ALL = 'scope_type';
|
||
//指定商品
|
||
const SCOPE_TYPE_PRODUCT = 'scope_type_product';
|
||
//指定分类
|
||
const SCOPE_TYPE_CATEGORY = 'scope_type_category';
|
||
//指定商户
|
||
const SCOPE_TYPE_STORE = 'scope_type_store';
|
||
//价格说明关联分类
|
||
const PRICE_RULE_CATEGORY = 'price_rule_category';
|
||
|
||
//商品参数关联
|
||
const PRODUCT_PARAMES_CATE = 'product_params_cate';
|
||
|
||
|
||
public function fans()
|
||
{
|
||
return $this->hasOne(User::class,'uid','left_id');
|
||
}
|
||
|
||
public function focus()
|
||
{
|
||
return $this->hasOne(User::class,'uid','right_id');
|
||
}
|
||
|
||
public function community()
|
||
{
|
||
return $this->hasOne(Community::class,'community_id','right_id')
|
||
->bind(['community_id','title','image','start','uid','create_time','count_start','author','is_type']);
|
||
}
|
||
|
||
public function getIsStartAttr()
|
||
{
|
||
return self::where('left_id', $this->right_id)
|
||
->where('right_id',$this->left_id)
|
||
->where('type', 'fans')
|
||
->count() > 0;
|
||
}
|
||
|
||
public function spu()
|
||
{
|
||
return $this->hasOne(Spu::class, 'spu_id','right_id');
|
||
}
|
||
public function merchant()
|
||
{
|
||
return $this->hasOne(Merchant::class, 'mer_id','right_id');
|
||
}
|
||
|
||
public function category()
|
||
{
|
||
return $this->hasOne(StoreCategory::class, 'store_category_id','right_id');
|
||
}
|
||
|
||
|
||
public function auth()
|
||
{
|
||
return $this->hasOne(Menu::class, 'menu_id','right_id');
|
||
}
|
||
|
||
public function searchLeftIdAttr($query, $value)
|
||
{
|
||
$query->where('left_id', $value);
|
||
}
|
||
|
||
public function searchRightIdAttr($query, $value)
|
||
{
|
||
$query->where('right_id', $value);
|
||
}
|
||
|
||
public function searchTypeAttr($query, $value)
|
||
{
|
||
$query->where('type', $value);
|
||
}
|
||
|
||
/**
|
||
* @return static
|
||
*/
|
||
public static function getInstance(): self
|
||
{
|
||
return new static();
|
||
}
|
||
|
||
/**
|
||
* TODO 搜索
|
||
* @param $where
|
||
* @return BaseModel
|
||
* @author Qinii
|
||
* @day 2020-10-16
|
||
*/
|
||
protected function getSearch(array $where)
|
||
{
|
||
foreach ($where as $key => $item) {
|
||
if ($item !== '') {
|
||
$keyArray[] = $key;
|
||
$whereArr[$key] = $item;
|
||
}
|
||
}
|
||
if(empty($keyArray)){
|
||
return self::getInstance()->db();
|
||
}else{
|
||
return self::withSearch($keyArray, $whereArr);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* TODO 添加
|
||
* @param int $leftId
|
||
* @param int $rightId
|
||
* @param string $type
|
||
* @param $check
|
||
* @return bool
|
||
* @author Qinii
|
||
* @day 10/28/21
|
||
*/
|
||
public function insert(int $leftId, int $rightId, string $type, bool $check = false)
|
||
{
|
||
if ($check && $this->checkHas($leftId, $rightId, $type)) {
|
||
return false;
|
||
}
|
||
|
||
$data = [
|
||
'left_id' => $leftId,
|
||
'right_id'=> $rightId,
|
||
'type' => $type,
|
||
];
|
||
|
||
try{
|
||
Relevance::create($data);
|
||
return true;
|
||
} catch (\Exception $exception) {
|
||
throw new ValidateException('创建失败');
|
||
}
|
||
}
|
||
|
||
/**
|
||
* TODO 删除
|
||
* @param int $leftId
|
||
* @param string $type
|
||
* @param int $rightId
|
||
* @return bool
|
||
* @author Qinii
|
||
* @day 10/28/21
|
||
*/
|
||
public function destory(int $leftId, int $rightId, string $type)
|
||
{
|
||
return $this->getSearch([
|
||
'left_id' => $leftId,
|
||
'right_id'=> $rightId,
|
||
'type' => $type,
|
||
])->delete();
|
||
}
|
||
|
||
/**
|
||
* TODO 检测是否存在
|
||
* @param int $leftId
|
||
* @param int $rightId
|
||
* @param string $type
|
||
* @return int
|
||
* @author Qinii
|
||
* @day 10/28/21
|
||
*/
|
||
public function checkHas(int $leftId, int $rightId, string $type)
|
||
{
|
||
return $this->getSearch([
|
||
'left_id' => $leftId,
|
||
'right_id'=> $rightId,
|
||
'type' => $type,
|
||
])->count();
|
||
}
|
||
|
||
/**
|
||
* TODO 根据左键批量删除
|
||
* @param int $leftId
|
||
* @param $type
|
||
* @return bool
|
||
* @author Qinii
|
||
* @day 10/28/21
|
||
*/
|
||
public function batchDelete(int $leftId, $type)
|
||
{
|
||
return $this->getSearch([
|
||
'left_id' => $leftId,
|
||
'type' => $type,
|
||
])->delete();
|
||
}
|
||
|
||
/**
|
||
* TODO 关注我的人
|
||
* @param int $uid
|
||
* @return \think\Collection
|
||
* @author Qinii
|
||
* @day 10/28/21
|
||
*/
|
||
public function getUserFans(int $uid, int $page, int $limit)
|
||
{
|
||
$query = $this->getSearch([
|
||
'right_id' => $uid,
|
||
'type' => self::TYPE_COMMUNITY_FANS,
|
||
])->with([
|
||
'fans' => function($query) {
|
||
$query->field('uid,avatar,nickname,count_fans');
|
||
}
|
||
]);
|
||
$count = $query->count();
|
||
$list = $query->page($page, $limit)->select()->append(['is_start']);
|
||
return compact('count','list');
|
||
}
|
||
|
||
/**
|
||
* TODO 我关注的人
|
||
* @param $uid
|
||
* @return \think\Collection
|
||
* @author Qinii
|
||
* @day 10/28/21
|
||
*/
|
||
public function getUserFocus(int $uid, int $page, int $limit)
|
||
{
|
||
$query = $this->getSearch([
|
||
'left_id' => $uid,
|
||
'type' => self::TYPE_COMMUNITY_FANS,
|
||
])->with([
|
||
'focus' => function($query) {
|
||
$query->field('uid,avatar,nickname,count_fans');
|
||
}
|
||
]);
|
||
$count = $query->count();
|
||
$list = $query->page($page, $limit)->select()->append(['is_fans']);
|
||
return compact('count','list');
|
||
}
|
||
|
||
|
||
/**
|
||
* TODO 我点赞过的文章
|
||
* @param int $uid
|
||
* @return \think\Collection
|
||
* @author Qinii
|
||
* @day 10/28/21
|
||
*/
|
||
public function getUserStartCommunity(array $where, int $page, int $limit)
|
||
{
|
||
$query = $this->joinUser($where)->with([
|
||
'community'=> function($query) use($where){
|
||
$query->with([
|
||
'author' => function($query){
|
||
$query->field('uid,real_name,status,avatar,nickname,count_start');
|
||
},
|
||
'is_start' => function($query) use ($where) {
|
||
$query->where('left_id',$where['uid']);
|
||
},
|
||
'topic' => function($query) {
|
||
$query->where('status', 1)->where('is_del',0);
|
||
$query->field('topic_id,topic_name,status,category_id,pic,is_del');
|
||
},
|
||
'relevance' => [
|
||
'spu' => function($query) {
|
||
$query->field('spu_id,store_name,image,price,product_type,activity_id,product_id');
|
||
}
|
||
],
|
||
'is_fans' => function($query) use($where){
|
||
$query->where('left_id',$where['uid']);
|
||
}]);
|
||
},
|
||
]);
|
||
$count = $query->count();
|
||
$list = $query->page($page, $limit)->select()->each(function ($item){
|
||
$item['time'] = date('m月d日', strtotime($item['create_time']));
|
||
return $item;
|
||
});
|
||
|
||
return compact('count','list');
|
||
}
|
||
|
||
/**
|
||
* TODO 我点赞过的文章
|
||
* @param int $uid
|
||
* @return \think\Collection
|
||
* @author Qinii
|
||
* @day 10/28/21
|
||
*/
|
||
public function getUserStartCommunityByVideos(array $where, int $page, int $limit)
|
||
{
|
||
$query = $this->joinUser($where)->with([
|
||
'community'=> function($query) {
|
||
$query->with(['author'=> function($query) {
|
||
$query->field('uid,avatar,nickname');
|
||
}]);
|
||
},
|
||
]);
|
||
$count = $query->count();
|
||
$list = $query->page($page, $limit)->select()->each(function ($item){
|
||
$item['time'] = date('m月d日', strtotime($item['create_time']));
|
||
return $item;
|
||
});
|
||
|
||
return compact('count','list');
|
||
}
|
||
|
||
public function getFieldCount(string $field, int $value, string $type)
|
||
{
|
||
return $this->getSearch([$field => $value, 'type' => $type,])->count();
|
||
}
|
||
|
||
/**
|
||
*
|
||
*/
|
||
public function createMany(int $leftId, array $rightId, string $type)
|
||
{
|
||
if (!empty($rightId)) {
|
||
foreach ($rightId as $value) {
|
||
$res[] = [
|
||
'left_id' => $leftId,
|
||
'right_id' => $value,
|
||
'type' => $type,
|
||
];
|
||
}
|
||
self::batchInsert($res);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 批量插入
|
||
*
|
||
* @param array $data
|
||
* @return int
|
||
* @author xaboy
|
||
* @day 2020/6/8
|
||
*/
|
||
public function batchInsert(array $data)
|
||
{
|
||
$rows = Relevance::insertAll($data);
|
||
|
||
return $rows;
|
||
}
|
||
|
||
|
||
// ------- 2 ---------------
|
||
public function clear(int $id, $type, string $field)
|
||
{
|
||
if (is_string($type)) $type = [$type];
|
||
return Relevance::where($field, $id)->whereIn('type', $type)->delete();
|
||
}
|
||
|
||
|
||
public function joinUser($where)
|
||
{
|
||
$query = Relevance::hasWhere('community',function($query) use($where){
|
||
$query->where('status',1)->where('is_show',1)->where('is_del',0);
|
||
$query->when(isset($where['is_type']) && $where['is_type'] !== '',function($query) use($where){
|
||
$query->where('is_type',$where['is_type']);
|
||
});
|
||
});
|
||
|
||
$query->where('left_id',$where['uid'])->where('type',self::TYPE_COMMUNITY_START);
|
||
return $query;
|
||
}
|
||
//--------------------------
|
||
|
||
}
|