xny/app/common/dao/store/StoreSeckillActiveDao.php

<?php

// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2024 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
{

    /**
     *
     * @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());
        }

    }

    /**
     *  不同状态商品
     * @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');
    }
}