261 lines
12 KiB
PHP
261 lines
12 KiB
PHP
<?php
|
||
|
||
// +----------------------------------------------------------------------
|
||
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
|
||
// +----------------------------------------------------------------------
|
||
// | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
|
||
// +----------------------------------------------------------------------
|
||
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
|
||
// +----------------------------------------------------------------------
|
||
// | Author: CRMEB Team <admin@crmeb.com>
|
||
// +----------------------------------------------------------------------
|
||
|
||
namespace app\common\dao\store;
|
||
|
||
use app\common\model\store\StoreSeckillActive;
|
||
use app\common\dao\BaseDao;
|
||
use app\common\repositories\store\order\StoreOrderProductRepository;
|
||
use app\common\repositories\store\order\StoreOrderRepository;
|
||
use app\common\repositories\store\product\ProductAttrValueRepository;
|
||
use app\common\repositories\store\product\ProductRepository;
|
||
use app\common\repositories\store\product\SpuRepository;
|
||
use app\common\repositories\store\StoreSeckillActiveRepository;
|
||
use think\facade\Log;
|
||
|
||
class StoreSeckillActiveDao extends BaseDao
|
||
{
|
||
|
||
/**
|
||
* TODO
|
||
* @return string
|
||
* @author Qinii
|
||
* @day 2020-07-30
|
||
*/
|
||
public function getModel(): string
|
||
{
|
||
return StoreSeckillActive::class;
|
||
}
|
||
|
||
|
||
/**
|
||
* 搜索
|
||
* @param array $where
|
||
* @return mixed
|
||
* FerryZhao 2024/4/12
|
||
*/
|
||
public function search(array $where)
|
||
{
|
||
$query = $this->getModel()::getDB()
|
||
->when(isset($where['name']) && $where['name'] !== '', function ($query) use ($where) {
|
||
$query->where('name', 'like', '%' . $where['name'] . '%');
|
||
})
|
||
->when(isset($where['active_status']) && $where['active_status'] !== '', function ($query) use ($where) {
|
||
$query->where('active_status', $where['active_status']);
|
||
})
|
||
->when(isset($where['seckill_active_status']) && $where['seckill_active_status'] !== '', function ($query) use ($where) {
|
||
$query->where('status', $where['seckill_active_status']);
|
||
})
|
||
->when(isset($where['seckill_active_id']) && $where['seckill_active_id'] !== '', function ($query) use ($where) {
|
||
$query->where('seckill_active_id', $where['seckill_active_id']);
|
||
})
|
||
->when(isset($where['active_name']) && $where['active_name'] !== '', function ($query) use ($where) {
|
||
$query->whereLike('name', "%{$where['active_name']}%");
|
||
})
|
||
->when(isset($where['active_name']) && $where['active_name'] !== '', function ($query) use ($where) {
|
||
$query->whereLike('name', "%{$where['active_name']}%");
|
||
})
|
||
->when(!isset($where['sign']), function ($query) use ($where) {
|
||
$query->where('sign', 1);
|
||
})
|
||
->when(isset($where['date']) && $where['date'], function ($query) use ($where) {
|
||
$timeWhere = explode('-', $where['date']);
|
||
$query->whereTime('start_day', '>=', $timeWhere[0]);
|
||
$query->whereTime('end_day', '<=', date('Y-m-d', strtotime($timeWhere[1]) + 24 * 60 * 60));
|
||
});
|
||
|
||
$query->order('status desc,seckill_active_id desc');
|
||
return $query;
|
||
}
|
||
|
||
/**
|
||
* 检测活动状态关闭spu
|
||
* @return void
|
||
* FerryZhao 2024/4/19
|
||
*/
|
||
public function valActiveStatus()
|
||
{
|
||
try {
|
||
$storeSeckillActiveRepository = app()->make(StoreSeckillActiveRepository::class);
|
||
$changeStartIds = $this->getModel()::getDB()->where(['active_status' => 0])->whereTime('start_day', '<', date('Y-m-d H:i:s', time()))->whereTime('end_day', '>', time())->column('seckill_active_id');
|
||
if (!empty($changeStartIds)) {
|
||
$storeSeckillActiveRepository->getSearch([])->whereIn('seckill_active_id', $changeStartIds)->update(['active_status' => 1]);
|
||
}
|
||
$changeStartingIds = $this->getModel()::getDB()->where(['active_status' => 1])->whereTime('end_day', '<', time())->column('seckill_active_id');
|
||
if (!empty($changeStartingIds)) {
|
||
$storeSeckillActiveRepository->getSearch([])->whereIn('seckill_active_id', $changeStartingIds)->update(['active_status' => '-1']);
|
||
app()->make(SpuRepository::class)->getSearch([
|
||
'product_type' => 1,
|
||
'activity_ids' => $changeStartingIds
|
||
])->update(['status' => 0]);
|
||
}
|
||
} catch (\Exception $e) {
|
||
Log::error('检测活动状态关闭spu失败，' . $e->getMessage());
|
||
}
|
||
|
||
}
|
||
|
||
/**
|
||
* TODO 不同状态商品
|
||
* @param $status
|
||
* @return mixed
|
||
* @author Qinii
|
||
* @day 2020-08-19
|
||
*/
|
||
public function getStatus($status)
|
||
{
|
||
$day = date('Y-m-d', time());
|
||
$_h = date('H', time());
|
||
$query = $this->getModel()::getDB();
|
||
if ($status == 1) //未开始
|
||
$query->where('status', '<>', -1)->where(function ($query) use ($day, $_h) {
|
||
$query->whereTime('start_day', '>', $day)->whereOr(function ($query) use ($day, $_h) {
|
||
$query->whereTime('start_day', '<=', $day)->where('start_time', '>', $_h);
|
||
});
|
||
});
|
||
|
||
if ($status == 2)//进行中
|
||
$query->where('status', 1)
|
||
->whereTime('start_day', '<=', $day)->whereTime('end_day', '>', $day)
|
||
->where('start_time', '<=', $_h)->where('end_time', '>', $_h);
|
||
|
||
if ($status == 3) //结束
|
||
$query->where('status', -1)->whereOr(function ($query) use ($day, $_h) {
|
||
$query->whereTime('end_day', '<', $day)
|
||
->whereOr(function ($query) use ($day, $_h) {
|
||
$query->whereTime('start_day', '<=', $day)->whereTime('end_day', '>=', $day)->where('end_time', '<=', $_h);
|
||
});
|
||
});
|
||
return $query;
|
||
}
|
||
|
||
/**
|
||
* 活动参与人列表统计
|
||
* @param $activeId
|
||
* @param $merId
|
||
* @param $where
|
||
* @param int $page
|
||
* @param int $limit
|
||
* @return void
|
||
* FerryZhao 2024/4/28
|
||
*/
|
||
public function chartPeople($activeId, $merId = null, $where, int $page = 1, int $limit = 10)
|
||
{
|
||
$storeOrderRepository = app()->make(StoreOrderRepository::class);
|
||
$query = $storeOrderRepository->getSearch([])->alias('ORDERA')
|
||
->leftJoin('StoreOrderProduct ORDERB', 'ORDERA.order_id = ORDERB.order_id')
|
||
->leftJoin('User USER', 'USER.uid = ORDERA.uid')
|
||
->when($merId, function ($query) use ($merId) {
|
||
$query->where('ORDERA.mer_id', '=', $merId);
|
||
})
|
||
->when(isset($where['keyword']) && $where['keyword'], function ($query) use ($where) {
|
||
$query->whereLike('USER.uid|USER.nickname|USER.phone', "%{$where['keyword']}%");
|
||
})
|
||
->when(isset($where['date']) && $where['date'], function ($query) use ($where) {
|
||
getModelTime($query, $where['date'], 'ORDERA.create_time');
|
||
})
|
||
->where([
|
||
'ORDERB.activity_id' => $activeId,
|
||
'ORDERA.paid' => 1,
|
||
'ORDERA.activity_type' => 1,
|
||
])
|
||
->where('ORDERA.status','>',-1)
|
||
->group('ORDERA.uid');
|
||
$count = $query->count();
|
||
$list = $query->page($page, $limit)
|
||
->field('sum(ORDERA.total_num) as sum_total_num,sum(ORDERA.pay_price) as sum_pay_price,USER.nickname,USER.uid,count(ORDERA.order_id) as order_count,max(ORDERA.create_time) as create_time,ORDERA.is_del,ORDERA.paid,ORDERA.order_type')
|
||
->select();
|
||
return compact('count', 'list');
|
||
}
|
||
|
||
|
||
/**
|
||
* 活动订单统计列表
|
||
* @param $activeId
|
||
* @param $merId
|
||
* @param $where
|
||
* @param int $page
|
||
* @param int $limit
|
||
* @return void
|
||
* FerryZhao 2024/4/28
|
||
*/
|
||
public function chartOrder($activeId, $merId = null, $where, $statusWhere = [], int $page = 1, int $limit = 10)
|
||
{
|
||
$storeOrderRepository = app()->make(StoreOrderRepository::class);
|
||
$orderWhere = [
|
||
'ORDERB.activity_id' => $activeId,
|
||
];
|
||
if (isset($where['status']) && $where['status'] != '') {
|
||
$orderWhere['StoreOrder.status'] = $where['status'];
|
||
}
|
||
$query = $storeOrderRepository->getSearch([])->alias('StoreOrder')
|
||
->leftJoin('User USER', 'StoreOrder.uid = USER.uid')
|
||
->leftJoin('StoreOrderProduct ORDERB', 'StoreOrder.order_id = ORDERB.order_id')
|
||
->when(isset($where['keyword']) && $where['keyword'], function ($query) use ($where) {
|
||
$query->whereLike('USER.uid|USER.nickname|USER.phone', "%{$where['keyword']}%");
|
||
})
|
||
->when($merId, function ($query) use ($merId) {
|
||
$query->where('StoreOrder.mer_id', '=', $merId);
|
||
})
|
||
->when(isset($where['date']) && $where['date'], function ($query) use ($where) {
|
||
getModelTime($query, $where['date'], 'StoreOrder.create_time');
|
||
})
|
||
->where($orderWhere)->where($statusWhere);
|
||
$count = $query->count();
|
||
$list = $query->page($page, $limit)
|
||
->field('StoreOrder.order_sn,USER.nickname,USER.uid,StoreOrder.status,StoreOrder.pay_price,StoreOrder.total_num,StoreOrder.create_time,StoreOrder.pay_time,StoreOrder.is_del,StoreOrder.paid,StoreOrder.order_type')
|
||
->order('StoreOrder.order_id desc')
|
||
->select();
|
||
return compact('count', 'list');
|
||
}
|
||
|
||
/**
|
||
* 活动商品统计列表
|
||
* @param $activeId
|
||
* @param $merId
|
||
* @param $where
|
||
* @param int $page
|
||
* @param int $limit
|
||
* @return void
|
||
* FerryZhao 2024/4/28
|
||
*/
|
||
public function chartProduct($activeId, $merId = null, $where, int $page = 1, int $limit = 10)
|
||
{
|
||
$productRepository = app()->make(ProductRepository::class);
|
||
$storeOrderRepository = app()->make(StoreOrderRepository::class);
|
||
$storeOrderProductRepository = app()->make(StoreOrderProductRepository::class);
|
||
$productAttrValueRepository = app()->make(ProductAttrValueRepository::class);
|
||
$productWhere = [
|
||
'product_type' => 1,
|
||
'seckill_active_id' => $activeId
|
||
];
|
||
if (isset($where['keyword']) && $where['keyword']) {
|
||
$productWhere['keyword'] = $where['keyword'];
|
||
}
|
||
$with = ['attr', 'attrValue', 'merCateId.category', 'storeCategory', 'content', 'seckillActive',
|
||
'merchant' => function ($query) {
|
||
$query->with(['typeName', 'categoryName'])->field('mer_id,category_id,type_id,mer_avatar,mer_name,is_trader');
|
||
},
|
||
|
||
];
|
||
$query = $productRepository->search($merId, $productWhere)->with($with);
|
||
$count = $query->count();
|
||
$filed = 'Product.product_id,Product.active_id,Product.mer_id,brand_id,unit_name,spec_type,mer_status,rate,reply_count,store_info,cate_id,Product.image,slider_image,Product.store_name,Product.keyword,Product.sort,Product.is_show,Product.sales,Product.price,extension_type,refusal,cost,U.ot_price,stock,is_gift_bag,Product.care_count,Product.status,is_used,Product.create_time,Product.product_type,old_product_id,integral_total,integral_price_total,mer_labels,Product.is_good,Product.is_del,type,param_temp_id,mer_svip_status,svip_price,svip_price_type';
|
||
$list = $query->page($page, $limit)->setOption('field', [])->where(['Product.is_del' => 0, 'Product.delete' => 0])->field($filed)->select();
|
||
foreach ($list as &$item){
|
||
$item['sales'] = $storeOrderRepository->seckillOrderCounut($item['active_id'], $item['product_id']);
|
||
$item['stock'] = $productAttrValueRepository->getSearch([])->where(['product_id'=>$item['product_id']])->sum('stock');
|
||
}
|
||
return compact('count', 'list');
|
||
}
|
||
}
|