shenying/app/services/activity/seckill/StoreSeckillServices.php

<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2020 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------
declare (strict_types=1);

namespace app\services\activity\seckill;


use app\Request;
use app\services\activity\StoreActivityServices;
use app\services\BaseServices;
use app\dao\activity\seckill\StoreSeckillDao;
use app\services\diy\DiyServices;
use app\services\order\StoreOrderServices;
use app\services\other\QrcodeServices;
use app\services\product\branch\StoreBranchProductServices;
use app\services\product\ensure\StoreProductEnsureServices;
use app\services\product\label\StoreProductLabelServices;
use app\services\product\product\StoreDescriptionServices;
use app\services\store\SystemStoreServices;
use app\services\user\UserRelationServices;
use app\services\product\product\StoreProductReplyServices;
use app\services\product\product\StoreProductServices;
use app\services\product\sku\StoreProductAttrResultServices;
use app\services\product\sku\StoreProductAttrServices;
use app\services\product\sku\StoreProductAttrValueServices;
use app\jobs\product\ProductLogJob;
use crmeb\exceptions\AdminException;
use crmeb\services\CacheService;
use crmeb\services\SystemConfigService;
use think\exception\ValidateException;

/**
 * Class StoreSeckillServices
 * @package app\services\activity\seckill
 * @method getSeckillIdsArray(array $ids, array $field)
 * @mixin StoreSeckillDao
 */
class StoreSeckillServices extends BaseServices
{
    const OPOXMWTJ = 'k8kkOJ';

	/**
	* 商品活动类型
	 */
	const TYPE = 1;

    /**
     * StoreSeckillServices constructor.
     * @param StoreSeckillDao $dao
     */
    public function __construct(StoreSeckillDao $dao)
    {
        $this->dao = $dao;
    }

	/**
	 * @param array $productIds
	 * @return array
	 * @author 等风来
	 * @email 136327134@qq.com
	 * @date 2022/11/14
	 */
	public function getSeckillIdsArrayCache(array $productIds)
	{
		$list = $this->dao->cacheList();
		if (!$list) {
			return $this->dao->getSeckillIdsArray($productIds, ['id', 'time_id', 'product_id']);
		} else {
			$seckill = [];
			$time = time();
			foreach ($list as $item) {
				if ($item['is_del'] == 0 && $item['status'] == 1 && $item['start_time'] <= $time && $item['stop_time'] >= ($time - 86400) && in_array($item['product_id'], $productIds)) {
					$seckill[] = [
						'id' => $item['id'],
						'time_id' => $item['time_id'],
						'product_id' => $item['product_id'],
					];
				}
			}
			return $seckill;
		}
	}

    public function getCount(array $where)
    {
        $this->dao->count($where);
    }

    /**
     * 秒杀是否存在
     * @param int $id
     * @param string $field
     * @return array|int|\think\Model
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getSeckillCount(int $id = 0, string $field = 'time_id')
    {
        $where = [];
        $where[] = ['is_del', '=', 0];
        $where[] = ['status', '=', 1];$config = [];
		$currentHour = date('Hi');
		/** @var StoreSeckillTimeServices $storeSeckillTimeServices */
		$storeSeckillTimeServices = app()->make(StoreSeckillTimeServices::class);
        if ($id) {
            $time = time();
            $where[] = ['id', '=', $id];
            $where[] = ['start_time', '<=', $time];
            $where[] = ['stop_time', '>=', $time - 86400];
            $seckill_one = $this->dao->getOne($where, $field);
            if (!$seckill_one) {
                throw new ValidateException('活动已结束');
            }
			$time_id = $seckill_one['time_id'] ?? [];
			if ($time_id) {
				$time_id = is_string($time_id) ? explode(',', $time_id) : $time_id;
				$timeList = $storeSeckillTimeServices->getList(['id' => $time_id, 'status' => 1]);
				foreach ($timeList as $value) {
					$value['start_time'] = $start = str_replace(':', '', $value['start_time']);
					$value['end_time'] = $end = str_replace(':', '', $value['end_time']);
					if ($currentHour >= $start && $currentHour < $end) {
						$config = $value;
						break;
					}
				}
			}
            if (!$config) {
                throw new ValidateException('活动已结束');
            }
			//获取秒杀商品状态
			if ($config['start_time'] <= $currentHour && $config['end_time'] > $currentHour) {
				return $seckill_one;
			} else if ($config['start_time'] > $currentHour) {
				throw new ValidateException('活动未开始');
			} else {
				throw new ValidateException('活动已结束');
			}
        } else {
			$timeList = $storeSeckillTimeServices->getList(['status' => 1]);
			foreach ($timeList as $value) {
				$start = str_replace(':', '', $value['start_time']);
				$end = str_replace(':', '', $value['end_time']);
				if ($currentHour >= $start && $currentHour < $end) {
					$config = $value;
					break;
				}
			}
            if (!$config) return 0;

			//获取秒杀商品状态
			$start = substr_replace($config['start_time'], ':', 2, 0);
			$end = substr_replace($config['end_time'], ':', 2, 0);

            $startTime = strtotime(date('Y-m-d') . ' '. $start);
            $stopTime = strtotime(date('Y-m-d') . ' '. $end);

            $where[] = ['start_time', '<', $startTime];
            $where[] = ['stop_time', '>', $stopTime];
            return $this->dao->getCount($where);
        }
    }


    /**
     * 保存数据
     * @param int $id
     * @param array $data
     */
    public function saveData(int $id, array $data)
    {
        /** @var StoreProductServices $storeProductServices */
        $storeProductServices = app()->make(StoreProductServices::class);
        $productInfo = $storeProductServices->getOne(['is_show' => 1, 'is_del' => 0, 'is_verify' => 1, 'id' => $data['product_id']]);
        if (!$productInfo) {
            throw new AdminException('原商品已下架或移入回收站');
        }
        if ($productInfo['is_vip_product'] || $productInfo['is_presale_product']) {
            throw new AdminException('该商品是预售或svip专享');
        }
        $data['product_type'] = $productInfo['product_type'];
		$data['type'] = $productInfo['type'] ?? 0;
		$data['relation_id'] = $productInfo['relation_id'] ?? 0;
        $custom_form = $productInfo['custom_form'] ?? [];
        $data['custom_form'] = is_array($custom_form) ? json_encode($custom_form) : $custom_form;
		$data['system_form_id'] = $productInfo['system_form_id'] ?? 0;
		$store_label_id = $productInfo['store_label_id'] ?? [];
        $data['store_label_id'] = is_array($store_label_id) ? implode(',', $store_label_id) : $store_label_id;
        $ensure_id = $productInfo['ensure_id'] ?? [];
        $data['ensure_id'] = is_array($ensure_id) ? implode(',', $ensure_id) : $ensure_id;
        $specs = $productInfo['specs'] ?? [];
        $data['specs'] = is_array($specs) ? json_encode($specs) : $specs;
        if (in_array($data['product_type'], [1, 2, 3])) {
            $data['freight'] = 2;
            $data['temp_id'] = 0;
            $data['postage'] = 0;
        } else {
            if ($data['freight'] == 1) {
                $data['temp_id'] = 0;
                $data['postage'] = 0;
            } elseif ($data['freight'] == 2) {
                $data['temp_id'] = 0;
            } elseif ($data['freight'] == 3) {
                $data['postage'] = 0;
            }
            if ($data['freight'] == 2 && !$data['postage']) {
                throw new AdminException('请设置运费金额');
            }
            if ($data['freight'] == 3 && !$data['temp_id']) {
                throw new AdminException('请选择运费模版');
            }
        }
        $description = $data['description'];
        $detail = $data['attrs'];
        $items = $data['items'];
        $data['start_time'] = strtotime($data['section_time'][0]);
        $data['stop_time'] = strtotime($data['section_time'][1]);
        $data['image'] = $data['images'][0] ?? '';
        $data['images'] = json_encode($data['images']);
        $data['price'] = min(array_column($detail, 'price'));
        $data['ot_price'] = min(array_column($detail, 'ot_price'));
        $data['quota'] = $data['quota_show'] = array_sum(array_column($detail, 'quota'));
        if ($data['quota'] > $productInfo['stock']) {
            throw new ValidateException('限量不能超过商品库存');
        }
        $data['stock'] = array_sum(array_column($detail, 'stock'));
        unset($data['section_time'], $data['description'], $data['attrs'], $data['items']);
        /** @var StoreDescriptionServices $storeDescriptionServices */
        $storeDescriptionServices = app()->make(StoreDescriptionServices::class);
        /** @var StoreProductAttrServices $storeProductAttrServices */
        $storeProductAttrServices = app()->make(StoreProductAttrServices::class);
        $id = $this->transaction(function () use ($id, $data, $description, $detail, $items, $storeDescriptionServices, $storeProductAttrServices) {
            if ($id) {
                $res = $this->dao->update($id, $data);
                if (!$res) throw new AdminException('修改失败');
            } else {
                $data['add_time'] = time();
                $res = $this->dao->save($data);
                if (!$res) throw new AdminException('添加失败');
                $id = (int)$res->id;
            }
            $storeDescriptionServices->saveDescription((int)$id, $description, 1);
            $skuList = $storeProductAttrServices->validateProductAttr($items, $detail, (int)$id, 1);
            $valueGroup = $storeProductAttrServices->saveProductAttr($skuList, (int)$id, 1);

            $res = true;
            foreach ($valueGroup as $item) {
                $res = $res && CacheService::setStock($item['unique'], (int)$item['quota_show']);
            }
            if (!$res) {
                throw new AdminException('占用库存失败');
            }
			return $id;
        });
		$this->dao->cacheTag()->clear();
		//保存
		$seckill = $this->dao->get($id, ['*'], ['descriptions', 'activity' => function ($query) {
			$query->field('id,start_day,end_day,time_id');
		}]);
		$this->dao->cacheUpdate($seckill->toArray());
		CacheService::redisHandler('product_attr')->clear();
    }

    /**
     * 获取列表
     * @param array $where
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function systemPage(array $where)
    {
        [$page, $limit] = $this->getPageValue();
        $list = $this->dao->getList($where, $page, $limit, ['activityName']);
        $count = $this->dao->count($where);
        foreach ($list as &$item) {
            $item['store_name'] = $item['title'];
            if ($item['status']) {
                if ($item['start_time'] > time())
                    $item['start_name'] = '未开始';
                else if (bcadd($item['stop_time'], '86400') < time())
                    $item['start_name'] = '已结束';
                else if (bcadd($item['stop_time'], '86400') > time() && $item['start_time'] < time()) {
                    $item['start_name'] = '进行中';
                }
            } else $item['start_name'] = '已结束';
            $end_time = $item['stop_time'] ? (date('Y-m-d', (int)$item['stop_time']) . ' 23:59:59') : '';
            $item['_stop_time'] = $end_time;
            $item['stop_status'] = $item['stop_time'] + 86400 < time() ? 1 : 0;
        }
        return compact('list', 'count');
    }

    /**
     * 获取秒杀详情
     * @param int $id
     * @return array|\think\Model|null
     */
    public function getInfo(int $id)
    {
        $info = $this->dao->get($id);
        if ($info) {
            if ($info['start_time'])
                $start_time = date('Y-m-d', (int)$info['start_time']);

            if ($info['stop_time'])
                $stop_time = date('Y-m-d', (int)$info['stop_time']);
            if (isset($start_time) && isset($stop_time))
                $info['section_time'] = [$start_time, $stop_time];
            else
                $info['section_time'] = [];
            unset($info['start_time'], $info['stop_time']);
            $info['give_integral'] = intval($info['give_integral']);
            $info['price'] = floatval($info['price']);
            $info['ot_price'] = floatval($info['ot_price']);
            $info['postage'] = floatval($info['postage']);
            $info['cost'] = floatval($info['cost']);
            $info['weight'] = floatval($info['weight']);
            $info['volume'] = floatval($info['volume']);
            if (!$info['delivery_type']) {
                $info['delivery_type'] = [1];
            }
            if ($info['postage']) {
                $info['freight'] = 2;
            } elseif ($info['temp_id']) {
                $info['freight'] = 3;
            } else {
                $info['freight'] = 1;
            }
            /** @var StoreDescriptionServices $storeDescriptionServices */
            $storeDescriptionServices = app()->make(StoreDescriptionServices::class);
            $info['description'] = $storeDescriptionServices->getDescription(['product_id' => $id, 'type' => 1]);
            $info['attrs'] = $this->attrList($id, $info['product_id']);
			//适用门店
			$info['stores'] = [];
			if (isset($info['applicable_type']) && ($info['applicable_type'] == 1 || ($info['applicable_type'] == 2 && isset($info['applicable_store_id']) && $info['applicable_store_id']))) {//查询门店信息
				$where = ['is_del' => 0];
				if ($info['applicable_type'] == 2) {
					$store_ids = is_array($info['applicable_store_id']) ? $info['applicable_store_id'] : explode(',', $info['applicable_store_id']);
					$where['id'] = $store_ids;
				}
				$field = ['id', 'cate_id', 'name', 'phone', 'address', 'detailed_address', 'image', 'is_show', 'day_time', 'day_start', 'day_end'];
				/** @var SystemStoreServices $storeServices */
				$storeServices = app()->make(SystemStoreServices::class);
				$storeData = $storeServices->getStoreList($where, $field, '', '', 0, ['categoryName']);
				$info['stores'] = $storeData['list'] ?? [];
			}
        }
        return $info;
    }

    /**
     * 获取规格
     * @param int $id
     * @param int $pid
     * @return mixed
     */
    public function attrList(int $id, int $pid)
    {
        /** @var StoreProductAttrResultServices $storeProductAttrResultServices */
        $storeProductAttrResultServices = app()->make(StoreProductAttrResultServices::class);
        $seckillResult = $storeProductAttrResultServices->value(['product_id' => $id, 'type' => 1], 'result');
        $items = json_decode($seckillResult, true)['attr'];
        $productAttr = $this->getAttr($items, $pid, 0);
        $seckillAttr = $this->getAttr($items, $id, 1);
        foreach ($productAttr as $pk => $pv) {
            foreach ($seckillAttr as &$sv) {
                if ($pv['detail'] == $sv['detail']) {
                    $productAttr[$pk] = $sv;
                }
            }
            $productAttr[$pk]['detail'] = json_decode($productAttr[$pk]['detail']);
        }
        $attrs['items'] = $items;
        $attrs['value'] = $productAttr;
        foreach ($items as $key => $item) {
            $header[] = ['title' => $item['value'], 'key' => 'value' . ($key + 1), 'align' => 'center', 'minWidth' => 80];
        }
        $header[] = ['title' => '图片', 'slot' => 'pic', 'align' => 'center', 'minWidth' => 120];
        $header[] = ['title' => '秒杀价', 'key' => 'price', 'type' => 1, 'align' => 'center', 'minWidth' => 80];
        $header[] = ['title' => '成本价', 'key' => 'cost', 'align' => 'center', 'minWidth' => 80];
        $header[] = ['title' => '原价', 'key' => 'ot_price', 'align' => 'center', 'minWidth' => 80];
        $header[] = ['title' => '库存', 'key' => 'stock', 'align' => 'center', 'minWidth' => 80];
        $header[] = ['title' => '限量', 'key' => 'quota', 'type' => 1, 'align' => 'center', 'minWidth' => 80];
        $header[] = ['title' => '重量(KG)', 'key' => 'weight', 'align' => 'center', 'minWidth' => 80];
        $header[] = ['title' => '体积(m³)', 'key' => 'volume', 'align' => 'center', 'minWidth' => 80];
        $header[] = ['title' => '商品条形码', 'key' => 'bar_code', 'align' => 'center', 'minWidth' => 80];
        $header[] = ['title' => '商品编号', 'key' => 'code', 'align' => 'center', 'minWidth' => 80];
        $attrs['header'] = $header;
        return $attrs;
    }

    /**
     * 获取规格
     * @param $attr
     * @param $id
     * @param $type
     * @return array
     */
    public function getAttr($attr, $id, $type)
    {
        /** @var StoreProductAttrValueServices $storeProductAttrValueServices */
        $storeProductAttrValueServices = app()->make(StoreProductAttrValueServices::class);
        $value = attr_format($attr)[1];
        $valueNew = [];
        $count = 0;
        foreach ($value as $key => $item) {
            $detail = $item['detail'];
//            sort($item['detail'], SORT_STRING);
            $suk = implode(',', $item['detail']);
            $sukValue = $storeProductAttrValueServices->getSkuArray(['product_id' => $id, 'type' => $type, 'suk' => $suk], 'bar_code,code,cost,price,ot_price,stock,image as pic,weight,volume,brokerage,brokerage_two,quota,quota_show', 'suk');
            if (count($sukValue)) {
                foreach (array_values($detail) as $k => $v) {
                    $valueNew[$count]['value' . ($k + 1)] = $v;
                }
                $valueNew[$count]['detail'] = json_encode($detail);
                $valueNew[$count]['pic'] = $sukValue[$suk]['pic'] ?? '';
                $valueNew[$count]['price'] = $sukValue[$suk]['price'] ? floatval($sukValue[$suk]['price']) : 0;
                $valueNew[$count]['cost'] = $sukValue[$suk]['cost'] ? floatval($sukValue[$suk]['cost']) : 0;
                $valueNew[$count]['ot_price'] = isset($sukValue[$suk]['ot_price']) ? floatval($sukValue[$suk]['ot_price']) : 0;
                $valueNew[$count]['stock'] = $sukValue[$suk]['stock'] ? intval($sukValue[$suk]['stock']) : 0;
//                $valueNew[$count]['quota'] = $sukValue[$suk]['quota'] ? intval($sukValue[$suk]['quota']) : 0;
                $valueNew[$count]['quota'] = isset($sukValue[$suk]['quota_show']) && $sukValue[$suk]['quota_show'] ? intval($sukValue[$suk]['quota_show']) : 0;
                $valueNew[$count]['code'] = $sukValue[$suk]['code'] ?? '';
                $valueNew[$count]['bar_code'] = $sukValue[$suk]['bar_code'] ?? '';
                $valueNew[$count]['weight'] = $sukValue[$suk]['weight'] ? floatval($sukValue[$suk]['weight']) : 0;
                $valueNew[$count]['volume'] = $sukValue[$suk]['volume'] ? floatval($sukValue[$suk]['volume']) : 0;
                $valueNew[$count]['brokerage'] = $sukValue[$suk]['brokerage'] ? floatval($sukValue[$suk]['brokerage']) : 0;
                $valueNew[$count]['brokerage_two'] = $sukValue[$suk]['brokerage_two'] ? floatval($sukValue[$suk]['brokerage_two']) : 0;
                $valueNew[$count]['_checked'] = $type != 0;
                $count++;
            }
        }
        return $valueNew;
    }

    /**
     * 获取某个时间段的秒杀列表
     * @param int $time
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getListByTime(int $time, array $ids = [], bool $isStore = false)
    {
        [$page, $limit] = $this->getPageValue();
		/** @var StoreActivityServices $storeActivityServices */
		$storeActivityServices = app()->make(StoreActivityServices::class);
		$activityList = $storeActivityServices->getList(['time_id' => $time, 'type' => 1, 'status' => 1, 'is_del' => 0, 'activityTime' => true], 'id,image');
		$seckillInfo = [];
		if ($activityList) {
			$activityIds = array_column($activityList, 'id');
			$seckillInfo = $this->dao->getListByTime($activityIds, $ids, $page, $limit, $isStore);
			if (count($seckillInfo)) {
				$activityList = array_combine($activityIds, $activityList);
				foreach ($seckillInfo as $key => &$item) {
					if ($item['quota'] > 0) {
						$percent =  (float)sprintf("%.1f", (($item['quota_show'] - $item['quota']) / $item['quota_show'] * 100));
						$item['percent'] = $percent;
						$item['stock'] = $item['quota'];
					} else {
						$item['percent'] = 100;
						$item['stock'] = 0;
					}
					$item['price'] = floatval($item['price']);
					$item['ot_price'] = floatval($item['ot_price']);
					$item['discount_num'] = $item['ot_price'] ? (float)bcmul(bcdiv((string)$item['price'], (string)$item['ot_price'], 4), '10', 1) : 10;
					$item['activity_image'] = $activityList[$item['activity_id']]['image'] ?? '';
				}
			}
		}

        return $seckillInfo;
    }

	/**
	 * 获取某个时间段的秒杀商品数量
	 * @param int $time
	 * @param array $ids
	 * @param array $not_ids
	 * @param bool $isStore
	 * @return int
	 * @throws \think\db\exception\DataNotFoundException
	 * @throws \think\db\exception\DbException
	 * @throws \think\db\exception\ModelNotFoundException
	 */
	public function getCountByTime(int $time, array $ids = [], array $not_ids = [], bool $isStore = false)
	{
		/** @var StoreActivityServices $storeActivityServices */
		$storeActivityServices = app()->make(StoreActivityServices::class);
		$activityList = $storeActivityServices->getList(['time_id' => $time, 'type' => 1, 'status' => 1, 'is_del' => 0, 'activityTime' => true], 'id');
		$count = 0;
		if ($activityList) {
			$activityIds = array_column($activityList, 'id');
			$count = $this->dao->getTimeCount($activityIds, $ids, $not_ids, $isStore);
		}
		return $count;
	}

    /**
     * 获取秒杀详情
     * @param Request $request
     * @param int $id
     * @return mixed
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function seckillDetail(Request $request, int $id)
    {
        $uid = (int)$request->uid();
		//读取秒杀商品缓存信息
		$storeInfo = $this->dao->cacheRemember($id, function () use ($id) {
			$storeInfo = $this->dao->getOne(['id' => $id], '*', ['descriptions']);
			if (!$storeInfo) {
				throw new ValidateException('商品不存在');
			} else {
				$storeInfo = $storeInfo->toArray();
			}
			return $storeInfo;
		});
		$storeInfo['activity'] = [];
		if ($storeInfo['activity_id']) {
			$activityServices = app()->make(StoreActivityServices::class);
			$storeInfo['activity'] = $activityServices->getInfo((int)$storeInfo['activity_id'], ['id', 'start_day', 'end_day', 'time_id']);
		}
		/** @var DiyServices $diyServices */
		$diyServices = app()->make(DiyServices::class);
		$infoDiy = $diyServices->getProductDetailDiy();
		//diy控制参数
		if (!isset($infoDiy['is_specs']) || !$infoDiy['is_specs']) {
			$storeInfo['specs'] = [];
		}
        $configData = SystemConfigService::more(['site_url', 'routine_contact_type', 'site_name', 'share_qrcode', 'store_self_mention', 'store_func_status', 'product_poster_title']);
        $siteUrl = $configData['site_url'] ?? '';
        $storeInfo['image'] = set_file_url($storeInfo['image'], $siteUrl);
        $storeInfo['image_base'] = set_file_url($storeInfo['image'], $siteUrl);

        //品牌名称
        /** @var StoreProductServices $storeProductServices */
        $storeProductServices = app()->make(StoreProductServices::class);
		$productInfo = $storeProductServices->getCacheProductInfo((int)$storeInfo['product_id']);
        $storeInfo['brand_name'] = $storeProductServices->productIdByBrandName($storeInfo['product_id'], $productInfo);
		$delivery_type = $storeInfo['delivery_type'] ?? $productInfo['delivery_type'];
        $storeInfo['delivery_type'] = is_string($delivery_type) ? explode(',', $delivery_type) : $delivery_type;

        /**
         * 判断配送方式
         */
        $storeInfo['delivery_type'] = $storeProductServices->getDeliveryType((int)$storeInfo['type'], (int)$storeInfo['type'], (int)$storeInfo['relation_id'], $storeInfo['delivery_type']);
		$storeInfo['total'] = $productInfo['sales'] + $productInfo['ficti'];
        $storeInfo['store_label'] = $storeInfo['ensure'] = [];
        if ($storeInfo['store_label_id']) {
            /** @var StoreProductLabelServices $storeProductLabelServices */
            $storeProductLabelServices = app()->make(StoreProductLabelServices::class);
            $storeInfo['store_label'] = $storeProductLabelServices->getLabelCache($storeInfo['store_label_id'], ['id', 'label_name']);
        }
        if ($storeInfo['ensure_id'] && isset($infoDiy['is_ensure']) && $infoDiy['is_ensure']) {
            /** @var StoreProductEnsureServices $storeProductEnsureServices */
            $storeProductEnsureServices = app()->make(StoreProductEnsureServices::class);
            $storeInfo['ensure'] = $storeProductEnsureServices->getEnsurCache($storeInfo['ensure_id'], ['id', 'name', 'image', 'desc']);
        }

        /** @var QrcodeServices $qrcodeService */
        $qrcodeService = app()->make(QrcodeServices::class);
        $time = $request->param('time', '');
        $status = $request->param('status', '');
		$time_id = (int)$request->param('time_id', '');
        if (($configData['share_qrcode'] ?? 0) && request()->isWechat()) {
            $storeInfo['code_base'] = $qrcodeService->getTemporaryQrcode('seckill-' . $id . '-' . $time . '-' . $status, $uid)->url;
        } else {
            $storeInfo['code_base'] = $qrcodeService->getWechatQrcodePath($id . '_product_seckill_detail_wap.jpg', '/pages/activity/goods_seckill_details/index?id=' . $id . '&time=' . $time . '&status=' . $status);
        }

        /** @var StoreOrderServices $storeOrderServices */
        $storeOrderServices = app()->make(StoreOrderServices::class);
        $data['buy_num'] = $storeOrderServices->getBuyCount($uid, 1, $id);

        /** @var UserRelationServices $userRelationServices */
        $userRelationServices = app()->make(UserRelationServices::class);
        $storeInfo['userCollect'] = $userRelationServices->isProductRelation(['uid' => $uid, 'relation_id' => $storeInfo['product_id'], 'type' => 'collect', 'category' => UserRelationServices::CATEGORY_PRODUCT]);
        $storeInfo['userLike'] = 0;

        $storeInfo['uid'] = $uid;
        if ($storeInfo['quota'] > 0) {
            $percent = (float)sprintf("%.1f", ($storeInfo['quota_show'] - $storeInfo['quota']) / $storeInfo['quota_show'] * 100);
            $storeInfo['percent'] = $percent;
            $storeInfo['stock'] = $storeInfo['quota'];
        } else {
            $storeInfo['percent'] = 100;
            $storeInfo['stock'] = 0;
        }
		$storeInfo['last_time'] = 0;
		$time_id = $time_id ?: ($storeInfo['activity']['time_id'] ?? []);
		if ($time_id) {
			$time_id = is_string($time_id) ? explode(',', $time_id) : $time_id;
			/** @var StoreSeckillTimeServices $storeSeckillTimeServices */
			$storeSeckillTimeServices = app()->make(StoreSeckillTimeServices::class);
			$timeList = $storeSeckillTimeServices->getList(['id' => $time_id, 'status' => 1]);
			$config = [];
			$today = date('Y-m-d');
			$currentHour = date('Hi');
			if (count($timeList) <= 1) {
				$config = $timeList[0] ?? [];
			} else {
				foreach ($timeList as $value) {
					$start = str_replace(':', '', $value['start_time']);
					$end = str_replace(':', '', $value['end_time']);
					if ($currentHour >= $start && $currentHour < $end) {
						$config = $value;
						break;
					}
				}
			}

			//获取秒杀商品状态
			if ($storeInfo['status'] == 1) {
				if ($config) {//正在进行中的
					$start = str_replace(':', '', $config['start_time']);
					$end = str_replace(':', '', $config['end_time']);
					if ($start <= $currentHour && $end > $currentHour) {
						$storeInfo['status'] = 1;
						$storeInfo['last_time'] = strtotime($today. ' '. $config['end_time']);
					} else if ($start > $currentHour) {
						$storeInfo['status'] = 2;
					} else {
						$storeInfo['status'] = 0;
					}
				} else {
					$storeInfo['status'] = 0;
				}
			}
		}

        //商品详情
        $storeInfo['small_image'] = get_thumb_water($storeInfo['image']);
        $data['storeInfo'] = $storeInfo;

		$data['reply'] = [];
		$data['replyChance'] = $data['replyCount'] = 0;
		if (isset($infoDiy['is_reply']) && $infoDiy['is_reply']) {
			/** @var StoreProductReplyServices $storeProductReplyService */
			$storeProductReplyService = app()->make(StoreProductReplyServices::class);
			$reply = $storeProductReplyService->getRecProductReplyCache((int)$storeInfo['product_id'], (int)($infoDiy['reply_num'] ?? 1));
			$data['reply'] = $reply ? get_thumb_water($reply, 'small', ['pics']) : [];
			[$replyCount, $goodReply, $replyChance] = $storeProductReplyService->getProductReplyData((int)$storeInfo['product_id']);
			$data['replyChance'] = $replyChance;
			$data['replyCount'] = $replyCount;
		}

        /** @var StoreProductAttrServices $storeProductAttrServices */
        $storeProductAttrServices = app()->make(StoreProductAttrServices::class);
        [$productAttr, $productValue] = $storeProductAttrServices->getProductAttrDetailCache($id, $uid, 0, 1, $storeInfo['product_id'], $productInfo);
        $data['productAttr'] = $productAttr;
        $data['productValue'] = $productValue;
        $data['routine_contact_type'] = $configData['routine_contact_type'] ?? 0;
		$data['store_func_status'] = (int)($configData['store_func_status'] ?? 1);//门店是否开启
		$data['store_self_mention'] = $data['store_func_status'] ? (int)($configData['store_self_mention'] ?? 0) : 0;//门店自提是否开启
        $data['site_name'] = $configData['site_name'] ?? '';
        $data['share_qrcode'] = $configData['share_qrcode'] ?? 0;
		$data['product_poster_title'] = $configData['product_poster_title'] ?? '';
        //浏览记录
        ProductLogJob::dispatch(['visit', ['uid' => $uid, 'id' => $id, 'product_id' => $storeInfo['product_id']], 'seckill']);
        return $data;
    }

    /**
     * 修改秒杀库存
     * @param int $num
     * @param int $seckillId
     * @param string $unique
     * @param int $store_id
     * @return bool
     */
    public function decSeckillStock(int $num, int $seckillId, string $unique = '', int $store_id = 0)
    {
        $product_id = $this->dao->value(['id' => $seckillId], 'product_id');
		$res = true;
		if ($product_id) {
			if ($unique) {
				/** @var StoreProductAttrValueServices $skuValueServices */
				$skuValueServices = app()->make(StoreProductAttrValueServices::class);
				//减去秒杀商品的sku库存增加销量
				$res = $res &&  $skuValueServices->decProductAttrStock($seckillId, $unique, $num, 1);

				//减去当前普通商品sku的库存增加销量
				//秒杀商品sku
				$suk = $skuValueServices->value(['unique' => $unique, 'product_id' => $seckillId, 'type' => 1], 'suk');
				//平台商品sku unique
				$productUnique = $skuValueServices->value(['suk' => $suk, 'product_id' => $product_id, 'type' => 0], 'unique');
				/** @var StoreProductServices $services */
				$services = app()->make(StoreProductServices::class);
				//减去普通商品库存
				$res = $res && $services->decProductStock($num, (int)$product_id, (string)$productUnique, $store_id);
			}
			//减去秒杀库存
			$res = $res && $this->dao->decStockIncSales(['id' => $seckillId, 'type' => 1], $num);
		}
		//更新单个缓存
		$info = $this->dao->getOne(['id' => $seckillId], '*', ['descriptions']);
		if ($info) {
			$info = $info->toArray();
			$this->dao->cacheUpdate($info);
		}
        return $res;
    }

    /**
     * 加库存减销量
     * @param int $num
     * @param int $seckillId
     * @param string $unique
     * @param int $store_id
     * @return bool
     */
    public function incSeckillStock(int $num, int $seckillId, string $unique = '', int $store_id = 0)
    {
        $product_id = $this->dao->value(['id' => $seckillId], 'product_id');
		$res = true;
		if ($product_id) {
			if ($unique) {
				/** @var StoreProductAttrValueServices $skuValueServices */
				$skuValueServices = app()->make(StoreProductAttrValueServices::class);
				//增加秒杀商品的sku库存减少销量
				$res = $res && $skuValueServices->incProductAttrStock($seckillId, $unique, $num, 1);

				//减去当前普通商品sku的库存增加销量
				//秒杀商品sku
				$suk = $skuValueServices->value(['unique' => $unique, 'product_id' => $seckillId, 'type' => 1], 'suk');
				//平台商品sku unique
				$productUnique = $skuValueServices->value(['suk' => $suk, 'product_id' => $product_id, 'type' => 0], 'unique');

				/** @var StoreProductServices $services */
				$services = app()->make(StoreProductServices::class);
				//减去普通商品库存
				$res = $res && $services->incProductStock($num, (int)$product_id, (string)$productUnique, $store_id);
			}
			//增加秒杀库存减去销量
			$res = $res &&  $this->dao->incStockDecSales(['id' => $seckillId, 'type' => 1], $num);
		}
		//更新单个缓存
		$info = $this->dao->getOne(['id' => $seckillId], '*', ['descriptions']);
		if ($info) {
			$info = $info->toArray();
			$this->dao->cacheUpdate($info);
		}
        return $res;
    }

    /**
     * 下单｜加入购物车验证秒杀商品库存
     * @param int $uid
     * @param int $seckillId
     * @param int $cartNum
     * @param string $unique
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function checkSeckillStock(int $uid, int $seckillId, int $cartNum = 1, int $store_id = 0, string $unique = '')
    {
        /** @var StoreProductAttrValueServices $attrValueServices */
        $attrValueServices = app()->make(StoreProductAttrValueServices::class);
        if ($unique == '') {
            $unique = $attrValueServices->value(['product_id' => $seckillId, 'type' => 1], 'unique');
        }
        //检查商品活动状态
        $storeSeckillinfo = $this->getSeckillCount($seckillId, '*,title as store_name');
		if (!$storeSeckillinfo) {
			throw new ValidateException('该活动已下架');
		}
        if ($storeSeckillinfo['once_num'] < $cartNum) {
            throw new ValidateException('每个订单限购' . $storeSeckillinfo['once_num'] . '件');
        }
		/** @var StoreOrderServices $orderServices */
        $orderServices = app()->make(StoreOrderServices::class);
        $userBuyCount = $orderServices->getBuyCount($uid, 1, $seckillId);
        if ($storeSeckillinfo['num'] < ($userBuyCount + $cartNum)) {
            throw new ValidateException('每人总共限购' . $storeSeckillinfo['num'] . '件');
        }
        if ($storeSeckillinfo['num'] < $cartNum) {
            throw new ValidateException('每人限购' . $storeSeckillinfo['num'] . '件');
        }
        $attrInfo = $attrValueServices->getOne(['product_id' => $seckillId, 'unique' => $unique, 'type' => 1]);
        if (!$attrInfo || $attrInfo['product_id'] != $seckillId) {
            throw new ValidateException('请选择有效的商品属性');
        }
        if ($cartNum > $attrInfo['quota']) {
            throw new ValidateException('该商品库存不足' . $cartNum);
        }

		if ($store_id) {
			/** @var StoreBranchProductServices $branchProductServices */
			$branchProductServices = app()->make(StoreBranchProductServices::class);
			$branchProductInfo =  $branchProductServices->isValidStoreProduct((int)$storeSeckillinfo['product_id'], $store_id);
			if (!$branchProductInfo) {
				throw new ValidateException('门店该商品已下架');
			}
			$suk = $attrValueServices->value(['unique' => $unique, 'product_id' => $seckillId, 'type' => 1], 'suk');
			$brandAttrInfo = $attrValueServices->getOne(['product_id' => $branchProductInfo['id'], 'suk' => $suk, 'type' => 0]);
			if (!$brandAttrInfo) {
				throw new ValidateException('请选择有效的商品属性');
			}
			if ($cartNum > $brandAttrInfo['stock']) {
				throw new ValidateException('该商品库存不足' . $cartNum);
			}
		}
        return [$attrInfo, $unique, $storeSeckillinfo];
    }

    /**
     * 秒杀统计
     * @return array
     */
    public function seckillStatistics($id)
    {
        /** @var StoreOrderServices $orderServices */
        $orderServices = app()->make(StoreOrderServices::class);
        $pay_count = $orderServices->getDistinctCount(['type' => 1, 'activity_id' => $id, 'paid' => 1, 'pid' => [0, -1]], 'uid');
        $order_count = $orderServices->getDistinctCount(['type' => 1, 'activity_id' => $id, 'pid' => [0, -1]], 'uid');
        $all_price = $orderServices->sum(['type' => 1, 'activity_id' => $id, 'paid' => 1,'refund_type' => [0, 3], 'pid' => [0, -1]], 'pay_price');
        $seckillInfo = $this->dao->get($id);
        $pay_rate = $seckillInfo['quota'] . '/' . $seckillInfo['quota_show'];
        return compact('pay_count', 'order_count', 'all_price', 'pay_rate');
    }

    /**
     * 秒杀参与人统计
     * @param $id
     * @param string $keyword
     * @return array
     */
    public function seckillPeople($id, $keyword = '')
    {
        /** @var StoreOrderServices $orderServices */
        $orderServices = app()->make(StoreOrderServices::class);
        [$page, $limit] = $this->getPageValue();
        $list = $orderServices->seckillPeople($id, $keyword, $page, $limit);
        $count = $orderServices->getDistinctCount([['paid', '=', 1],['type', '=', 1],['activity_id', '=', $id], ['pid', 'in', [0, -1]], ['real_name|uid|user_phone', 'like', '%' . $keyword . '%']], 'uid', false);
        foreach ($list as &$item) {
            $item['add_time'] = date('Y-m-d H:i:s', $item['add_time']);
        }
        return compact('list', 'count');
    }

    /**
     * 秒杀订单统计
     * @param $id
     * @param array $where
     * @return array
     */
    public function seckillOrder(int $id, array $where = [])
    {
        /** @var StoreOrderServices $orderServices */
        $orderServices = app()->make(StoreOrderServices::class);
        [$page, $limit] = $this->getPageValue();
		$list = $orderServices->activityStatisticsOrder($id, 1, $where, $page, $limit);
		$where['type'] = 1;
        $where['activity_id'] = $id;
        $count = $orderServices->count($where);
        foreach ($list as &$item) {
			if ($item['is_del'] || $item['is_system_del']) {
				$item['status'] = '已删除';
			} else if ($item['paid'] == 0 && $item['status'] == 0) {
				$item['status'] = '未支付';
			} else if ($item['paid'] == 1 && $item['status'] == 4 && in_array($item['shipping_type'], [1, 3]) && $item['refund_status'] == 0) {
				$item['status'] = '部分发货';
			} else if ($item['paid'] == 1 && $item['refund_status'] == 2) {
				$item['status'] = '已退款';
			} else if ($item['paid'] == 1 && $item['status'] == 5 && $item['refund_status'] == 0) {
				$item['status'] = $item['shipping_type'] == 2 ? '部分核销' : '部分收货';
				$item['_status'] = 12;//已支付 部分核销
			} else if ($item['paid'] == 1 && $item['refund_status'] == 1) {
				$item['status'] = '申请退款';
			} else if ($item['paid'] == 1 && $item['refund_status'] == 4) {
				$item['status'] = '退款中';
			} else if ($item['paid'] == 1 && $item['status'] == 0 && in_array($item['shipping_type'], [1, 3]) && $item['refund_status'] == 0) {
				$item['status'] = '未发货';
				$item['_status'] = 2;//已支付 未发货
			} else if ($item['paid'] == 1 && in_array($item['status'], [0, 1]) && $item['shipping_type'] == 2 && $item['refund_status'] == 0) {
				$item['status'] = '未核销';
			} else if ($item['paid'] == 1 && in_array($item['status'], [1, 5]) && in_array($item['shipping_type'], [1, 3]) && $item['refund_status'] == 0) {
				$item['status'] = '待收货';
			} else if ($item['paid'] == 1 && $item['status'] == 2 && $item['refund_status'] == 0) {
				$item['status'] = '待评价';
			} else if ($item['paid'] == 1 && $item['status'] == 3 && $item['refund_status'] == 0) {
				$item['status'] = '已完成';
			} else if ($item['paid'] == 1 && $item['refund_status'] == 3) {
				$item['status'] = '部分退款';
			} else {
				$item['status'] = '未知';
			}
            $item['add_time'] = date('Y-m-d H:i:s', $item['add_time']);
            $item['pay_time'] = $item['pay_time'] ? date('Y-m-d H:i:s', $item['pay_time']) : '';
        }
        return compact('list', 'count');
    }
}