xny/app/common/dao/store/product/ProductPresellDao.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\product;

use app\common\dao\BaseDao;
use app\common\model\store\product\ProductPresell;
use app\common\model\system\merchant\Merchant;
use app\common\repositories\store\product\SpuRepository;
use app\common\repositories\system\merchant\MerchantRepository;

class ProductPresellDao extends BaseDao
{
    protected function getModel(): string
    {
        return ProductPresell::class;
    }

    public function search(array $where)
    {
        $query = ProductPresell::hasWhere('product',function($query)use($where){
            $query->when(isset($where['product_show']) && $where['product_show'] !== '',function($query)use($where){
                    $query->where('is_del',0)->where('mer_status',1);
                })
                ->when(isset($where['product_type']) && $where['product_type'] !== '',function($query)use($where){
                    $query->where('product_type',2);
                })
                ->where('status',1);
        });
        $query->join('StoreSpu U', 'ProductPresell.product_presell_id = U.activity_id')->where('U.product_type', 2);
        $query->when(isset($where['product_presell_id']) && $where['product_presell_id'] !== '',function($query)use($where){
                $query->where('product_presell_id',$where['product_presell_id']);
            })
            ->when(isset($where['mer_id']) && $where['mer_id'] !== '',function($query)use($where){
                $query->where('ProductPresell.mer_id',$where['mer_id']);
            })
            ->when(isset($where['is_del']) && $where['is_del'] !== '',function($query)use($where){
                $query->where('ProductPresell.is_del',$where['is_del']);
            })
            ->when(isset($where['action_status']) && $where['action_status'] !== '',function($query)use($where){
                $query->where('ProductPresell.action_status',$where['action_status']);
            })
            ->when(isset($where['keyword']) && $where['keyword'] !== '',function($query)use($where){
                $query->whereLike('ProductPresell.store_name|ProductPresell.product_id|ProductPresell.product_presell_id',"%{$where['keyword']}%");
            })
            ->when(isset($where['product_status']) && $where['product_status'] !== '',function($query)use($where){
                if($where['product_status'] == -1){
                    $query->where('ProductPresell.product_status','in',[-1,-2]);
                }else{
                    $query->where('ProductPresell.product_status',$where['product_status']);
                }
            })
            ->when(isset($where['presell_type']) && $where['presell_type'] !== '',function($query)use($where){
                $query->where('ProductPresell.presell_type',$where['presell_type']);
            })
            ->when(isset($where['type']) && $where['type'] !== '',function($query)use($where){
                switch ($where['type']){
                    case 0: //未开始
                        if(isset($where['api_type'])){
                            $query->where('product_status',1);
                        }
                        $query->where('action_status',1);
                        $query->where(function($query){
                            $query->whereTime('start_time','>',time())->whereOr(function ($query){
                                $query->whereTime('start_time','<',time())->whereTime('end_time','>',time())->where(function($query){
                                    $query->where('ProductPresell.product_status','<>',1)->whereOr('ProductPresell.is_show','<>',1)->whereOr('ProductPresell.status','<>',1);
                                });
                            });
                        });
                        break;
                    case 1: //进行中
                        $query->where('action_status',1)
                            ->whereTime('start_time','<=',time())
                            ->whereTime('end_time','>',time())
                            ->where('product_status',1)
                            ->where('ProductPresell.status',1)
                            ->where('ProductPresell.is_show',1);
                        break;
                    case 2: //已结束
                            $query->where(function($query){
                                $query->where('action_status',-1)->whereOr('end_time','<= TIME',time());
                            });
                        break;
                    case 3: //已关闭
                        $query->where(function($query){
                            $query->where(function($query){
                                $query->where('ProductPresell.presell_type',1)->whereTime('end_time','<',time());
                            })->whereOr(function($query){
                                $query->where('ProductPresell.presell_type',2)->whereTime('final_end_time','<',time());
                            });
                        });
                        break;
                    default:
                        $query->where(function($query){
                            $query->where(function($query){
                                $query->where('ProductPresell.presell_type',1)->whereTime('end_time','>',time());
                            })->whereOr(function($query){
                                $query->where('ProductPresell.presell_type',2)->whereTime('final_end_time','>',time());
                            });
                        });
                        break;
                }
            })
            ->when(isset($where['status']) && $where['status'] !== '',function($query)use($where){
                $query->where('ProductPresell.status',$where['status']);
            })
            ->when(isset($where['is_show']) && $where['is_show'] !== '',function($query)use($where){
                $query->where('ProductPresell.is_show',$where['is_show']);
            })
            ->when(isset($where['mer_name']) && $where['mer_name'] !== '',function($query)use($where){
                $make = app()->make(MerchantRepository::class);
                $mer_id = $make->search(['keyword' => $where['mer_name']])->column('mer_id');
                $query->whereIn('ProductPresell.mer_id',$mer_id);
            })
            ->when(isset($where['is_trader']) && $where['is_trader'] !== '',function($query)use($where){
                $make = app()->make(MerchantRepository::class);
                $mer_id = $make->search(['is_trader' => $where['is_trader']])->column('mer_id');
                $query->whereIn('ProductPresell.mer_id',$mer_id);
            })
            ->when(isset($where['us_status']) && $where['us_status'] !== '',function($query)use($where){
               if($where['us_status'] == 0) {
                  $query->where('ProductPresell.is_show',0)->where('ProductPresell.status',1)->where('ProductPresell.product_status',1);
               }
               if($where['us_status'] == 1) {
                   $query->where('ProductPresell.is_show',1)->where('ProductPresell.status',1)->where('ProductPresell.product_status',1);
               }
               if($where['us_status'] == -1) {
                   $query->where(function($query){
                       $query->where('ProductPresell.status',0)->whereOr('ProductPresell.product_status','<>',1);
                   });
               }
            });
        $query->when(isset($where['mer_labels']) && $where['mer_labels'] !== '', function ($query) use ($where) {
                $query->whereLike('U.mer_labels', "%,{$where['mer_labels']},%");
            })
            ->when(isset($where['sys_labels']) && $where['sys_labels'] !== '', function ($query) use ($where) {
                $query->whereLike('U.sys_labels', "%,{$where['sys_labels']},%");
            })
            ->when(isset($where['star']),function($query)use($where){
                $query->when($where['star'] !== '', function ($query) use ($where) {
                    $query->where('U.star', $where['star']);
                });
                $query->order('U.star DESC,U.rank DESC,ProductPresell.create_time DESC');
            });
        $query->where('ProductPresell.is_del',0);
        return $query;
    }

    /**
     *  移动端展示 条件
     * @return array
     * @author Qinii
     * @day 2020-10-19
     */
    public function actionShow()
    {
        return [
            'product_show' => 1,
            //'product_status' => 1,
            'status' => 1,
            'is_show' => 1,
            'api_type' => 1,
            'is_del' => 0,
        ];
    }

    /**
     * 检查并更新过期活动的状态
     * 该方法用于定期检查所有活动的结束时间，如果活动已经结束，则将其状态设置为失效（-1）。
     * 同时，它也会更新关联的SPU（Special Product Unit）的状态，将这些SPU的活动状态设置为失效。
     * 这样做的目的是为了维护数据库中活动和SPU状态的准确性，确保只有当前有效的活动和SPU被展示或参与。
     */
    public function valActiveStatus()
    {
        // 根据当前时间，查询所有已经结束的活动，这些活动的状态为1（进行中）
        $query = $this->getModel()::getDB()->whereTime('end_time','<=',time())->where('action_status',1);
        // 获取这些活动的ID
        $id = $query->column($this->getPk());

        // 如果查询到了已结束的活动ID
        if($id){
            // 更新这些活动的状态为-1（失效）
            $this->getModel()::getDB()->where($this->getPk(),'in',$id)->update(['action_status' => -1]);
            // 准备更新SPU状态的条件，即活动类型为2且活动ID在已结束的活动ID列表中
            $where = [
                'product_type' => 2,
                'activity_ids' => $id
            ];
            // 更新所有符合条件的SPU的状态为0（失效）
            app()->make(SpuRepository::class)->getSearch($where)->update(['status' => 0]);
        }
    }


    /**
     *  软删除商户的所有商品
     * @param $merId
     * @author Qinii
     * @day 5/15/21
     */
    public function clearProduct($merId)
    {
        $this->getModel()::getDb()->where('mer_id', $merId)->update(['is_del' => 1]);
    }

}