shop-php/app/common/dao/store/StoreActivityDao.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\dao\BaseDao;
use app\common\dao\store\product\CloudProductDao;
use app\common\model\BaseModel;
use app\common\model\store\GeoStreet;
use app\common\model\store\product\CloudProduct;
use app\common\model\store\StoreActivity;
use app\common\model\store\StoreActivityOrderProduct;
use app\common\repositories\store\product\SpuRepository;
use app\common\repositories\system\RelevanceRepository;
use think\exception\ValidateException;
use think\facade\Db;

/**
 *
 * Class StoreActivityDao
 * @package app\common\dao\system\merchant
 */
class StoreActivityDao extends BaseDao
{
    protected function getModel(): string
    {
        return StoreActivity::class;
    }

    public function search(array $where = [])
    {
        $where['is_del'] = 0;
        return $this->getSearch($where);
    }

    /**
     * 活动商品专区
     * @param $location
     * @param $streetCode
     * @param $activityId
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function product($location, $streetCode, $activityId)
    {
        if (!empty($location) && $location != ',') {
            [$lat, $lng] = explode(',', $location);
        } elseif (!empty($streetCode)) {
            $location = GeoStreet::where('street_code', $streetCode)->field('lng,lat')->find();
            if (!empty($location)) {
                [$lat, $lng] = [$location['lat'], $location['lng']];
            }
        }
        if (empty($lat) || empty($lng)) {
            [$lat, $lng] = ['28.889137', '105.443352'];
        }
        $cloud_product_arr = (new CloudProductDao())->getByDistance($lat, $lng, ['activity_id' => $activityId], 4);
        $cloud_product = [];
        foreach ($cloud_product_arr as $key => $value) {
            $cloud_product[] = $value['product_id'];
        }
        $where = [
            'is_show' => 1,
            'is_used' => 1,
            'status' => 1,
            'is_del' => 0,
            'mer_status' => 1,
            'product_id' => $cloud_product
        ];
        if (!$cloud_product) {
            return app('json')->success(['count' => 0, 'list' => []]);
        }
        $query = Db::name('cloud_product')->where('status', 1);
        $count = $query->where(function($query){
            $query->whereOr('mer_labels', '')
                ->whereOr('mer_labels',',5,');
        })->count();
        /** @var SpuRepository $spuRep */
        $spuRep = app()->make(SpuRepository::class);
        $products = $spuRep->getApiSearch($where, 1, 4, false, true);
        if ($products['list']) {
            $list = $products['list'];
            foreach ($cloud_product_arr as $key => $value) {
                foreach ($list as $k => $v) {
                    if ($value['product_id'] == $v['product_id']) {
                        if ($value['mer_labels'] == ',5,') {
                            $list[$k]['mer_labels_name'] = '五日达';
                        } else {
                            $list[$k]['mer_labels_name'] = '同城';
                        }
                    }
                }
            }
        }
        return ['count' => $count, 'list' => $list ?? []];
    }

    /**
     * 是否可购买活动商品
     * @param $userId
     * @param $productId
     * @return bool|int
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function canBuy($userId, $productId)
    {
        $activityId = Db::name('cloud_product')->where('product_id', $productId)->value('activity_id');
        $find = Db::name('store_activity_order_product')->where('user_id', $userId)->where('product_id',$productId)->where('status', 1)->find();
        $data=['activityId'=>$activityId,'is_true'=>true];
        if ($find && $activityId == 2) {
            $data['is_true']=false;
        }
        return $data;
    }

    /**
     * 保存活动订单商品
     * @param $activityId
     * @param $order
     * @return void
     */
    public function saveOrderProduct($activityId, $order)
    {
        $orderProductIds = array_column($order->orderProduct->toArray(), 'product_id');
        $productIds = CloudProduct::whereIn('product_id', $orderProductIds)->where('activity_id', $activityId)->column('product_id');
        foreach ($productIds as $productId) {
            $model = new StoreActivityOrderProduct();
            $model->user_id = $order['uid'];
            $model->activity_id = $activityId;
            $model->product_id = $productId;
            $model->number = 1;
            if (!$model->save()) {
                throw new ValidateException('活动商品数据保存失败');
            }
        }
    }

}