shenying/app/services/product/branch/StoreBranchProductServices.php

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

namespace app\services\product\branch;


use app\dao\product\product\StoreProductDao;
use app\jobs\product\ProductSyncStoreJob;
use app\services\activity\seckill\StoreSeckillServices;
use app\services\BaseServices;
use app\services\order\StoreCartServices;
use app\services\product\brand\StoreBrandServices;
use app\services\product\product\StoreDescriptionServices;
use app\services\product\product\StoreProductRelationServices;
use app\services\product\product\StoreProductReplyCommentServices;
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\services\activity\coupon\StoreCouponIssueServices;
use app\services\product\category\StoreProductCategoryServices;
use app\services\store\SystemStoreServices;
use app\services\system\attachment\SystemAttachmentServices;
use app\services\user\UserServices;
use app\webscoket\SocketPush;
use crmeb\exceptions\AdminException;
use crmeb\traits\ServicesTrait;
use think\exception\ValidateException;

/**
 * Class StoreBranchProductServices
 * @package app\services\product\branch
 * @mixin StoreProductDao
 */
class StoreBranchProductServices extends BaseServices
{

    use ServicesTrait;

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

    /**
     * 获取平台商品ID
     * @param int $product_id
     * @param $productInfo
     * @return int
     */
    public function getStoreProductId(int $product_id, $productInfo = [])
    {
        $id = 0;
        if (!$product_id) {
            return $id;
        }
        if (!$productInfo) {
            $productInfo = $this->dao->get($product_id, ['id', 'pid']);
        }
        if ($productInfo) {
            //门店平台共享商品
            if ($productInfo['pid']) {
                $id = (int)$productInfo['pid'];
            } else {
                $id = $productInfo['id'];
            }
        }
        return $id;
    }

	/**
	 * 平台商品ID：获取在门店该商品详情
	 * @param int $uid
	 * @param int $id
	 * @param int $store_id
	 * @return array|mixed
	 * @throws \think\db\exception\DataNotFoundException
	 * @throws \think\db\exception\DbException
	 * @throws \think\db\exception\ModelNotFoundException
	 */
    public function getStoreProductInfo(int $uid, int $id, int $store_id)
    {
        /** @var StoreProductServices $productServices */
        $productServices = app()->make(StoreProductServices::class);
		try {
			$productInfo = $productServices->getCacheProductInfo($id);
		} catch (\Throwable $e) {
			$productInfo = [];
		}
        if (!$productInfo) {
            return [];
        }
        if ($productInfo['type'] != 1 && $store_id) {//查询该门店商品
            $info = $this->dao->get(['is_del' => 0, 'is_show' => 1, 'is_verify' => 1, 'pid' => $id, 'type' => 1, 'relation_id' => $store_id], ['id']);
            if ($info) {
                $id = (int)$info['id'];
            }
        }
        return $productServices->productDetail($uid, $id);
    }

    /**
     * 批量获取平台商品ID
     * @param array $product_ids
     * @return array
     */
    public function getStoreProductIds(array $product_ids)
    {
        $result = [];
        if (!$product_ids) {
            return $result;
        }
        $productInfos = $this->dao->getColumn([['id', 'IN', $product_ids]], 'id,pid', 'id');
        if ($productInfos) {
            foreach ($productInfos as $key => $productInfo) {
                //门店平台共享商品
                if ($productInfo['pid']) {
                    $id = (int)$productInfo['pid'];
                } else {
                    $id = $productInfo['id'];
                }
                $result[$key] = $id;
            }
        }
        return $result;
    }

	/**
	 * 根据商品ID，获取适用门店ids
	 * @param int $product_id
	 * @param int $type
	 * @return array
	 * @throws \think\db\exception\DataNotFoundException
	 * @throws \think\db\exception\DbException
	 * @throws \think\db\exception\ModelNotFoundException
	 */
    public function getApplicableStoreIds(int $product_id, int $type = 0)
    {
        $ids = [];
        $productInfo = [];
        switch ($type) {
            case 0://商品
                $productInfo = $this->dao->getOne(['id' => $product_id], 'id,type,relation_id,applicable_type,applicable_store_id');
                break;
            case 1://秒杀商品
                /** @var StoreSeckillServices $seckillServices */
                $seckillServices = app()->make(StoreSeckillServices::class);
                $productInfo = $seckillServices->getOne(['id' => $product_id], 'id,applicable_type,applicable_store_id');
                break;
        }
		$productInfo['applicable_type'] = 1;
        if ($productInfo) {
			switch ($productInfo['applicable_type']) {
				case 0://仅平台
					break;
				case 1://所有门店 查询有商品的门店
					if ($type == 0) {
						if (!$productInfo['type']) {//平台商品
							$ids = $this->dao->getColumn(['pid' => $product_id, 'is_show' => 1, 'is_del' => 0, 'type' => 1], 'relation_id');
						} else if ($productInfo['type'] == 1) {//门店商品
							$ids = [$productInfo['relation_id']];
						}
					}
					break;
				case 2://部分门店
					$ids = is_array($productInfo['applicable_store_id']) ? $productInfo['applicable_store_id'] : explode(',', $productInfo['applicable_store_id']);
					break;
				default:
					break;
			}
        }
        return [$ids, $productInfo['applicable_type']];
    }

    /**
     * 收银台获取门店商品
     * @param array $where
     * @param int $uid
     * @param int $staff_id
     * @param int $tourist_uid
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getCashierProductListV2(array $where, int $store_id, int $uid = 0, int $staff_id = 0, int $tourist_uid = 0)
    {
        $where['is_del'] = 0;
        $where['is_show'] = 1;
        $where['is_verify'] = 1;
        $where['type'] = 1;
        $where['relation_id'] = $store_id;

        [$page, $limit] = $this->getPageValue();
        $where['is_vip_product'] = 0;
        if ($uid) {
            /** @var UserServices $user */
            $user = app()->make(UserServices::class);
            $userInfo = $user->getUserCacheInfo($uid);
            $is_vip = $userInfo['is_money_level'] ?? 0;
            $where['is_vip_product'] = $is_vip ? -1 : 0;
        }
        //门店不展示卡密商品
        $where['product_type'] = [0, 2, 4];

        $list = $this->dao->getSearchList($where, $page, $limit, ['*'], 'sort desc,sales desc,id desc', []);
        $count = 0;
        if ($list) {
            $productIds = array_column($list, 'id');
            if ($uid || $tourist_uid) {
                if ($uid) {
                    $tourist_uid = 0;
                }
                /** @var StoreCartServices $cartServices */
                $cartServices = app()->make(StoreCartServices::class);
                $cartNumList = $cartServices->productIdByCartNum($productIds, $uid, $staff_id, $tourist_uid, $store_id);
                $data = [];
                foreach ($cartNumList as $item) {
                    $data[$item['product_id']][] = $item['cart_num'];
                }
                $newNumList = [];
                foreach ($data as $key => $item) {
                    $newNumList[$key] = array_sum($item);
                }
                $cartNumList = $newNumList;
            } else {
                $cartNumList = [];
            }
            $product = ['image' => '', 'id' => 0, 'store_name' => '', 'spec_type' => 0, 'store_info' => '', 'keyword' => '', 'price' => 0, 'stock' => 0, 'sales' => 0];
            /** @var StoreProductServices $storeProductServices */
            $storeProductServices = app()->make(StoreProductServices::class);
            $list = $storeProductServices->getProduceOtherList($list, $uid, true);
            $list = $storeProductServices->getProductPromotions($list);
            /** @var StoreCouponIssueServices $couponServices */
            $couponServices = app()->make(StoreCouponIssueServices::class);
            /** @var StoreProductCategoryServices $storeCategoryService */
            $storeCategoryService = app()->make(StoreProductCategoryServices::class);
            /** @var StoreBrandServices $storeBrandServices */
            $storeBrandServices = app()->make(StoreBrandServices::class);
            $brands = $storeBrandServices->getColumn([], 'id,pid', 'id');
            foreach ($list as &$item) {
                $product = array_merge($product, array_intersect_key($item, $product));
                $item['product'] = $product;
                $item['product_id'] = $item['id'];
                $item['cart_num'] = $cartNumList[$item['id']] ?? 0;
                $item['branch_stock'] = $item['stock'];

                $cateId = $item['cate_id'];
                $cateId = explode(',', $cateId);
                $cateId = array_merge($cateId, $storeCategoryService->cateIdByPid($cateId));
                $cateId = array_diff($cateId, [0]);
                $brandId = [];
                if ($item['brand_id']) {
                    $brandId = $brands[$item['brand_id']] ?? [];
                }
                //平台商品
                $coupons = [];
                if ($item['pid'] > 0) $coupons = $couponServices->getIssueCouponListNew($uid, ['product_id' => $item['id'], 'cate_id' => $cateId, 'brand_id' => $brandId], 'id,coupon_title,coupon_price,use_min_price', 0, 1, 'coupon_price desc,sort desc,id desc');
                $item['coupon'] = $coupons[0] ?? [];
            }
        }
		$count = $this->dao->getCount($where);
        $code = $where['store_name'] ?? '';
        $attrValue = $userInfo = null;
        if ($code) {
            /** @var StoreProductAttrValueServices $attrService */
            $attrService = app()->make(StoreProductAttrValueServices::class);
            $attrValueArr = $attrService->getColumn(['bar_code' => $code], '*', 'product_id');
            if ($attrValueArr) {
                $product_ids = array_unique(array_column($attrValueArr, 'product_id'));
                $product = $this->dao->get(['id' => $product_ids, 'type' => 1, 'relation_id' => $store_id, 'is_del' => 0, 'is_show' => 1, 'is_verify' => 1], ['id', 'type', 'relation_id']);
                if ($product) {
                    $attrValue = $attrValueArr[$product['id']] ?? [];
                }
            }
            if (!$attrValue) {
                /** @var UserServices $userService */
                $userService = app()->make(UserServices::class);
                $userInfo = $userService->get(['bar_code' => $code]);
                if ($userInfo) {
                    $userInfo = $userInfo->toArray();
                    $list = [];
                    $count = 0;
                }
            }
        }
        return compact('list', 'count', 'attrValue', 'userInfo');
    }

    /**
     * 获取商品详情
     * @param int $storeId
     * @param int $id
     * @param int $uid
     * @param int $touristUid
     * @return mixed
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getProductDetail(int $storeId, int $id, int $uid, int $touristUid)
    {
        /** @var StoreProductServices $productService */
        $productService = app()->make(StoreProductServices::class);
        $storeInfo = $productService->getOne(['id' => $id, 'is_show' => 1, 'is_del' => 0], '*');
        if (!$storeInfo) {
            throw new ValidateException('商品不存在');
        } else {
            $storeInfo = $storeInfo->toArray();
        }
        $siteUrl = sys_config('site_url');
        $storeInfo['image'] = set_file_url($storeInfo['image'], $siteUrl);
        $storeInfo['image_base'] = set_file_url($storeInfo['image'], $siteUrl);
        $storeInfo['fsales'] = $storeInfo['ficti'] + $storeInfo['sales'];

        /** @var StoreProductAttrServices $storeProductAttrServices */
        $storeProductAttrServices = app()->make(StoreProductAttrServices::class);
        $storeProductAttrServices->setItem('touristUid', $touristUid);
        [$productAttr, $productValue] = $storeProductAttrServices->getProductAttrDetail($id, $uid, 1, 0, 0, $storeInfo);
        $storeProductAttrServices->reset();

        if (!$storeInfo['spec_type']) {
            $productAttr = [];
            $productValue = [];
        }
        $data['productAttr'] = $productAttr;
        $data['productValue'] = $productValue;
        $data['storeInfo'] = $storeInfo;
        return $data;
    }

    /**
     * 保存或者修改门店数据
     * @param int $id
     * @param int $storeId
     * @param int $stock
     * @param array $data
     * @return bool
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function saveStoreProduct(int $id, int $storeId, int $stock, array $data = [])
    {
        /** @var StoreProductServices $service */
        $service = app()->make(StoreProductServices::class);
        $productData = $service->get($id, ['store_name', 'image', 'sort', 'store_info', 'keyword', 'bar_code', 'cate_id', 'is_show']);
        if (!$productData) {
            throw new ValidateException('商品不穿在');
        }
        $productData = $productData->toArray();
        $productInfo = $this->dao->get(['product_id' => $id, 'store_id' => $storeId]);
        if ($productInfo) {
            $productInfo->label_id = isset($data['label_id']) ? implode(',', $data['label_id']) : '';
            $productInfo->is_show = $data['is_show'] ?? 1;
            $productInfo->stock = $stock;
            $productInfo->image = $productData['image'];
            $productInfo->sort = $productData['sort'];
            $productInfo->store_name = $productData['store_name'];
            $productInfo->store_info = $productData['store_info'];
            $productInfo->keyword = $productData['keyword'];
            $productInfo->bar_code = $productData['bar_code'];
            $productInfo->cate_id = $productData['cate_id'];
            $productInfo->save();
        } else {
            $product = [];
            $product['product_id'] = $id;
            $product['label_id'] = isset($data['label_id']) ? implode(',', $data['label_id']) : '';
            $product['is_show'] = $data['is_show'] ?? 1;
            $product['store_id'] = $storeId;
            $product['stock'] = $stock;
            $product['image'] = $productData['image'];
            $product['sort'] = $productData['sort'];
            $product['store_name'] = $productData['store_name'];
            $product['store_info'] = $productData['store_info'];
            $product['keyword'] = $productData['keyword'];
            $product['bar_code'] = $productData['bar_code'];
            $product['cate_id'] = $productData['cate_id'];
            $product['add_time'] = time();
            $this->dao->save($product);
        }
        return true;
    }

    /**
     * 平台商品在门店是否存在
     * @param int $productId
     * @param int $storeId
     * @return array|\think\Model|null
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function isValidStoreProduct(int $productId, int $storeId)
    {
        $info = $this->dao->getOne(['id' => $productId, 'type' => 1, 'relation_id' => $storeId, 'is_del' => 0, 'is_show' => 1]);
        if ($info) {
            return $info;
        }
        return $this->dao->getOne(['pid' => $productId, 'type' => 1, 'relation_id' => $storeId, 'is_del' => 0, 'is_show' => 1]);
    }

    /**
     * 获取商品库存
     * @param int $productId
     * @param string $uniqueId
     * @return int|mixed
     */
    public function getProductStock(int $productId, int $storeId, string $uniqueId = '')
    {
        /** @var  StoreProductAttrValueServices $StoreProductAttrValue */
        $StoreProductAttrValue = app()->make(StoreProductAttrValueServices::class);
        return $uniqueId == '' ?
            $this->dao->value(['product_id' => $productId], 'stock') ?: 0
            : $StoreProductAttrValue->uniqueByStock($uniqueId);
    }

    /**
     * 回退｜扣除，门店、平台原商品库存
     * @param $order
     * @param array $cartInfo
     * @param int $platDec
     * @param int $storeDec
     * @return bool
     */
    public function regressionBranchProductStock($order, $cartInfo = [], int $platDec = 0, int $storeDec = 0, int $store_id = 0)
    {
        if (!$order || !$cartInfo) return true;
        /** @var StoreProductServices $services */
        $services = app()->make(StoreProductServices::class);
        /** @var StoreProductAttrValueServices $skuValueServices */
        $skuValueServices = app()->make(StoreProductAttrValueServices::class);
        $activity_id = (int)$order['activity_id'];
        $store_id = $store_id ? $store_id : ((int)$order['store_id'] ?? 0);
        $res = true;

        /** @var StoreBranchProductServices $branchServices */
        $branchServices = app()->make(StoreBranchProductServices::class);
        try {
            foreach ($cartInfo as $cart) {
                $productInfo = $cart['productInfo'] ?? [];
                if (!$productInfo) {
                    continue;
                }
                $type = $productInfo['type'] ?? 0;
                //增库存减销量
                $unique = isset($cart['productInfo']['attrInfo']) ? $cart['productInfo']['attrInfo']['unique'] : '';
                $cart_num = (int)$cart['cart_num'];
                $product_id = (int)$cart['product_id'];
                //原商品sku
                $suk = $skuValueServices->value(['unique' => $unique, 'product_id' => $product_id, 'type' => 0], 'suk');
                if ($type == 1) {//门店
                    $product_id = $productInfo['pid'] ?? $productInfo['id'];
                }
                //查出门店该商品ID，unique
                if ($store_id) {
                    $storeProduct = $branchServices->isValidStoreProduct((int)$product_id, $store_id);
                    if (!$storeProduct) {
                        return false;
                    }
                    $product_id = $storeProduct['id'];
                }
                switch ($order['type']) {
                    case 0://普通
                    case 6://预售
                        $productUnique = $unique;
                        if ($store_id) {
                            $productUnique = $skuValueServices->value(['suk' => $suk, 'product_id' => $product_id, 'type' => 0], 'unique');
                        }
                        break;
                    case 1://秒杀
                    case 2://砍价
                    case 3://拼团
                    case 5://套餐
                        $suk = $skuValueServices->value(['unique' => $unique, 'product_id' => $activity_id, 'type' => $order['type']], 'suk');
                        $productUnique = $skuValueServices->value(['suk' => $suk, 'product_id' => $product_id, 'type' => 0], 'unique');
                        break;
                    default:
                        $productUnique = $unique;
                        break;
                }
                switch ($platDec) {
                    case -1://不执行
                        break;
                    case 0://减销量、加库存
                        $res = $res && $services->incProductStock($cart_num, $product_id, $productUnique);
                        break;
                    case 1://增加销量、减库存
                        $res = $res && $services->decProductStock($cart_num, $product_id, $productUnique);
                        break;
                }
                switch ($storeDec) {
                    case -1://不执行
                        break;
                    case 0://减销量、加库存
                        $res = $res && $this->updataDecStock($cart_num, $product_id, $store_id, $productUnique, false);
                        break;
                    case 1://增加销量、减库存
                        $res = $res && $this->updataDecStock($cart_num, $product_id, $store_id, $productUnique);
                        break;
                }
            }
        } catch (\Throwable $e) {
            throw new ValidateException('库存不足!');
        }
        return $res;
    }

    /**
     * 加库存,减销量
     * @param $num
     * @param $productId
     * @param string $unique
     * @return bool
     */
    public function incProductStock(array $cartInfo, int $storeId)
    {
        $res = true;
        foreach ($cartInfo as $cart) {
            $unique = isset($cart['productInfo']['attrInfo']) ? $cart['productInfo']['attrInfo']['unique'] : '';
            $res = $res && $this->updataDecStock((int)$cart['cart_num'], (int)$cart['productInfo']['id'], $storeId, $unique, false);
        }
        return $res;
    }

    /**
     * 修改库存
     * @param array $cartInfo
     * @param int $storeId
     * @param bool $dec
     * @return bool
     */
    public function decProductStock(array $cartInfo, int $storeId, bool $dec = true)
    {
        $res = true;
        foreach ($cartInfo as $cart) {
            $unique = isset($cart['productInfo']['attrInfo']) ? $cart['productInfo']['attrInfo']['unique'] : '';
            $res = $res && $this->updataDecStock((int)$cart['cart_num'], (int)$cart['productInfo']['id'], $storeId, $unique, $dec);
        }
        return $res;
    }


    /**
     * 修改库存
     * @param int $num
     * @param int $productId
     * @param int $storeId
     * @param $unique
     * @param bool $dec
     * @return bool
     */
    public function updataDecStock(int $num, int $productId, int $storeId, $unique, bool $dec = true)
    {
        /** @var StoreProductAttrValueServices $skuValueServices */
        $skuValueServices = app()->make(StoreProductAttrValueServices::class);
        //原商品sku
        $suk = $skuValueServices->value(['unique' => $unique, 'product_id' => $productId, 'type' => 0], 'suk');
        //查询门店商品
        $info = $this->isValidStoreProduct($productId, $storeId);
        $res = true;
        $storeProductId = $info['id'] ?? 0;
        if ($productId && $storeProductId != $productId) {
            $productId = $storeProductId;
            //门店商品sku
            $unique = $skuValueServices->value(['suk' => $suk, 'product_id' => $productId, 'type' => 0], 'unique');
        }
        if ($dec) {
            if ($unique) {
                $res = $res && $skuValueServices->decProductAttrStock($productId, $unique, $num, 0);
            }
            $res = $res && $this->dao->decStockIncSales(['id' => $productId], $num);
        } else {
            if ($unique) {
                $res = $res && $skuValueServices->incProductAttrStock($productId, $unique, $num, 0);
            }
            $res = $res && $this->dao->incStockDecSales(['id' => $productId], $num);
        }
        return $res;
    }

    /**
     * 上下架
     * @param int $store_id
     * @param int $id
     * @param int $is_show
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function setShow(int $store_id, int $id, int $is_show)
    {
        $info = $this->dao->get($id);
        if (!$info) {
            throw new AdminException('操作失败！');
        }
        //平台统一商品
        if ($info['pid']) {
            $productInfo = $this->dao->get($info['pid']);
            if ($is_show && !$productInfo['is_show']) {
                throw new AdminException('平台该商品暂未上架！');
            }
        }
        /** @var StoreCartServices $cartService */
        $cartService = app()->make(StoreCartServices::class);
        $cartService->batchUpdate([$id], ['status' => $is_show], 'product_id');
        $update = ['is_show' => $is_show];
        if ($is_show) {//手动上架 清空定时下架状态
			if ($info['is_verify'] != 1) {//验证商品是否审核通过
				throw new AdminException('该商品暂未审核通过');
			}
            $update['auto_off_time'] = 0;
        }
        $res = $this->update($info['id'], $update);
        /** @var StoreProductRelationServices $storeProductRelationServices */
        $storeProductRelationServices = app()->make(StoreProductRelationServices::class);
        $storeProductRelationServices->setShow([$id], (int)$is_show);

        if (!$res) throw new AdminException('操作失败！');
    }

    /**
     * 门店同步库存
     * @param $ids
     * @param $storeId
     * @return mixed
     */
    public function synchStocks($ids, $storeId)
    {
        /** @var StoreProductServices $productServices */
        $productServices = app()->make(StoreProductServices::class);
        /** @var StoreProductAttrValueServices $attrValueServices */
        $attrValueServices = app()->make(StoreProductAttrValueServices::class);
        /** @var StoreBranchProductAttrValueServices $services */
        $branchAttrValueServices = app()->make(StoreBranchProductAttrValueServices::class);
        $productAllData = $productServices->getColumn([['id', 'in', $ids]], 'id,image,store_name,store_info,keyword,bar_code,cate_id,stock,label_id', 'id');
        $productBranchData = $this->dao->getColumn([['product_id', 'in', $ids], ['store_id', '=', $storeId]], 'product_id');
        $allData = $attrValueServices->getColumn([['product_id', 'in', $ids], ['type', '=', 0]], 'product_id,unique,stock,bar_code', 'unique');
        $branchData = $branchAttrValueServices->getColumn([['product_id', 'in', $ids], ['store_id', '=', $storeId]], 'unique');
        return $this->transaction(function () use ($allData, $branchData, $productAllData, $productBranchData, $storeId, $branchAttrValueServices) {
            $data = [];
            $res = true;
            $datas = [];
            foreach ($productAllData as $keys => $items) {
                if (in_array($keys, $productBranchData)) {
                    $res = $res && $this->dao->update(['product_id' => $keys, 'store_id' => $storeId], [
                            'stock' => $items['stock'],
                            'image' => $items['image'],
                            'store_name' => $items['store_name'],
                            'store_info' => $items['store_info'],
                            'keyword' => $items['keyword'],
                            'bar_code' => $items['bar_code'],
                            'cate_id' => $items['cate_id'],
                            'label_id' => $items['label_id'],
                        ]);
                } else {
                    $datas[] = [
                        'product_id' => $items['id'],
                        'image' => $items['image'],
                        'store_name' => $items['store_name'],
                        'store_info' => $items['store_info'],
                        'keyword' => $items['keyword'],
                        'bar_code' => $items['bar_code'],
                        'cate_id' => $items['cate_id'],
                        'label_id' => $items['label_id'],
                        'store_id' => $storeId,
                        'stock' => $items['stock'],
                        'add_time' => time()
                    ];
                }
            }
            if ($datas) {
                $res = $res && $this->dao->saveAll($datas);
            }
            foreach ($allData as $key => $item) {
                if (in_array($key, $branchData)) {
                    $res = $res && $branchAttrValueServices->update(['unique' => $key, 'store_id' => $storeId], ['stock' => $item['stock']]);
                } else {
                    $data[] = [
                        'product_id' => $item['product_id'],
                        'store_id' => $storeId,
                        'unique' => $item['unique'],
                        'stock' => $item['stock'],
                        'bar_code' => $item['bar_code']
                    ];
                }
            }
            if ($data) {
                $res = $res && $branchAttrValueServices->saveAll($data);
            }
            if (!$res) throw new ValidateException('同步库存失败!');
            return $res;
        });
    }


    /**
     * 同步一个商品到多个门店
     * @param int $product_id
     * @param array $store_ids
     * @return bool
     */
    public function syncProductToStores(int $product_id, int $applicable_type, array $store_ids = [])
    {
        if (!$product_id) {
            return true;
        }
        $where = ['is_del' => 0];
        //不传门店ID，默认同步至所有未删除门店
        if ($store_ids) {
            $where['id'] = $store_ids;
        }
        /** @var SystemStoreServices $storeServices */
        $storeServices = app()->make(SystemStoreServices::class);
        $stores = $storeServices->getList($where, ['id']);
        if (!$stores) {
            return true;
        }
        $ids = array_column($stores, 'id');

        //查询目前商品已经同步的门店
        $alreadyIds = $this->dao->getColumn(['type' => 1, 'pid' => $product_id], 'relation_id');
        switch ($applicable_type) {
            case 0://仅平台
                $ids = [];
                $this->dao->update(['type' => 1, 'pid' => $product_id], ['is_verify' => -1]);
                break;
            case 1://全部门店
                break;
            case 2://部分门店
                $delIds = array_merge(array_diff($alreadyIds, $ids));
                if ($delIds) $this->dao->update(['type' => 1, 'pid' => $product_id, 'relation_id' => $delIds], ['is_verify' => -1]);
                break;
        }
        foreach ($ids as $store_id) {
            ProductSyncStoreJob::dispatchDo('syncProduct', [$product_id, $store_id]);
        }
        return true;
    }

    /**
     * 同步门店商品
     * @param int $product_id
     * @param int $store_id
     * @return bool
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function syncProduct(int $product_id, int $store_id)
    {
        if (!$product_id || !$store_id) {
            return true;
        }
        /** @var StoreProductServices $productServices */
        $productServices = app()->make(StoreProductServices::class);
        //同步正常普通商品、次卡商品
        $productInfo = $productServices->get(['type' => 0, 'product_type' => [0, 4], 'id' => $product_id]);
        if (!$productInfo) {
            return true;
        }
        $productInfo = $productInfo->toArray();
        $productInfo['pid'] = $productInfo['id'];
        $productInfo['slider_image'] = json_encode($productInfo['slider_image']);
        $productInfo['custom_form'] = json_encode($productInfo['custom_form']);
        $productInfo['specs'] = is_array($productInfo['specs']) ? json_encode($productInfo['specs']) : $productInfo['specs'];
        unset($productInfo['id'], $productInfo['sales']);

        //关联补充信息
        $relationData = [];
        $relationData['cate_id'] = ($productInfo['cate_id'] ?? []) && is_string($productInfo['cate_id']) ? explode(',', $productInfo['cate_id']) : ($productInfo['cate_id'] ?? []);
        $relationData['brand_id'] = ($productInfo['brand_id'] ?? []) && is_string($productInfo['brand_id']) ? explode(',', $productInfo['brand_id']) : ($productInfo['brand_id'] ?? []);
        $relationData['store_label_id'] = ($productInfo['store_label_id'] ?? []) && is_string($productInfo['store_label_id']) ? explode(',', $productInfo['store_label_id']) : ($productInfo['store_label_id'] ?? []);
        $relationData['label_id'] = ($productInfo['label_id'] ?? []) && is_string($productInfo['label_id']) ? explode(',', $productInfo['label_id']) : ($productInfo['label_id'] ?? []);
        $relationData['ensure_id'] = ($productInfo['ensure_id'] ?? []) && is_string($productInfo['ensure_id']) ? explode(',', $productInfo['ensure_id']) : ($productInfo['ensure_id'] ?? []);
        $relationData['specs_id'] = ($productInfo['specs_id'] ?? []) && is_string($productInfo['specs_id']) ? explode(',', $productInfo['specs_id']) : ($productInfo['specs_id'] ?? []);
        $relationData['coupon_ids'] = ($productInfo['coupon_ids'] ?? []) && is_string($productInfo['coupon_ids']) ? explode(',', $productInfo['coupon_ids']) : ($productInfo['coupon_ids'] ?? []);

        $where = ['product_id' => $product_id, 'type' => 0];
        /** @var StoreProductAttrServices $productAttrServices */
        $productAttrServices = app()->make(StoreProductAttrServices::class);
        $attrInfo = $productAttrServices->getProductAttr($where);
        /** @var StoreProductAttrResultServices $productAttrResultServices */
        $productAttrResultServices = app()->make(StoreProductAttrResultServices::class);
        $attrResult = $productAttrResultServices->getResult($where);
        /** @var StoreProductAttrValueServices $productAttrValueServices */
        $productAttrValueServices = app()->make(StoreProductAttrValueServices::class);
        $attrValue = $productAttrValueServices->getList($where);
        /** @var StoreDescriptionServices $productDescriptionServices */
        $productDescriptionServices = app()->make(StoreDescriptionServices::class);
        $description = $productDescriptionServices->getDescription($where);
        $description = $description ?: '';

        $branchProductInfo = $this->dao->get(['pid' => $product_id, 'type' => 1, 'relation_id' => $store_id]);
        //存在修改
        [$id, $is_new] = $productServices->transaction(function () use (
            $branchProductInfo, $productInfo, $store_id, $attrInfo, $attrResult, $attrValue, $description,
            $productServices, $productAttrServices, $productAttrResultServices, $productAttrValueServices, $productDescriptionServices
        ) {
            $productInfo['type'] = 1;
            $productInfo['is_verify'] = 1;
            $productInfo['relation_id'] = $store_id;
            if ($branchProductInfo) {
                $id = $branchProductInfo['id'];
                $productInfo['is_verify'] = 1;
                unset($productInfo['stock'], $productInfo['is_show']);
                $res = $this->dao->update($id, $productInfo);
                if (!$res) throw new ValidateException('商品添加失败');

                $updateSuks = array_column($attrValue, 'suk');
                $oldSuks = [];
                $oldAttrValue = $productAttrValueServices->getSkuArray(['product_id' => $id, 'type' => 0], '*', 'suk');
                if ($oldAttrValue) $oldSuks = array_column($oldAttrValue, 'suk');
                $delSuks = array_merge(array_diff($oldSuks, $updateSuks));
                $dataAll = [];
                $res1 = $res2 = $res3 = true;
                foreach ($attrValue as $item) {
                    unset($item['id'], $item['stock'], $item['sales']);
                    $item['product_id'] = $id;
                    if ($oldSuks && in_array($item['suk'], $oldSuks) && isset($oldAttrValue[$item['suk']])) {
                        $attrId = $oldAttrValue[$item['suk']]['id'];
                        unset($item['suk'], $item['unique']);
                        $res1 = $res1 && $productAttrValueServices->update($attrId, $item);
                    } else {
                        $item['unique'] = $productAttrServices->createAttrUnique($id, $item['suk']);
                        $dataAll[] = $item;
                    }
                }
                if ($delSuks) {
                    $res2 = $productAttrValueServices->del($id, 0, $delSuks);
                }
                if ($dataAll) {
                    $res3 = $productAttrValueServices->saveAll($dataAll);
                }
                if (!$res1 || !$res2 || !$res3) {
                    throw new AdminException('商品规格信息保存失败');
                }
                $is_new = 0;
            } else {// 新增 保留平台库存到门店
                $res = $this->dao->save($productInfo);
                if (!$res) throw new ValidateException('商品添加失败');
                $id = (int)$res->id;
                if ($attrValue) {
                    foreach ($attrValue as &$value) {
                        unset($value['id'], $value['sales']);
                        $value['product_id'] = $id;
                        $value['unique'] = $productAttrServices->createAttrUnique($id, $value['suk']);
                    }
                    $productAttrValueServices->saveAll($attrValue);
                }
                $is_new = 1;
            }
            if ($attrInfo) {
                foreach ($attrInfo as &$attr) {
                    unset($attr['id']);
                    $attr['product_id'] = $id;
                }
                $productAttrServices->setAttr($attrInfo, $id, 0);
            }
            if ($attrResult) $productAttrResultServices->setResult($attrResult, $id, 0);
            $productDescriptionServices->saveDescription($id, $description, 0);
            return [$id, $is_new];
        });
        //商品创建事件
        event('product.create', [$id, $productInfo, [], $is_new, [], $description, 1, $relationData]);

        $this->dao->cacheTag()->clear();
        $productAttrServices->cacheTag()->clear();
        return true;
    }

	/**
	 * 删除门店、供应商同步删除商品
	 * @param array $where
	 * @param int $type
	 * @param int $relation_id
	 * @return bool
	 */
	public function deleteProducts(array $where = [], int $type = 0, int $relation_id = 0)
	{
		$where['type'] = $type;
		$where['relation_id'] = $relation_id;
		$productIds = $this->dao->getColumn($where, 'id');
		if ($productIds) {
			/** @var StoreProductAttrServices $productAttrServices */
			$productAttrServices = app()->make(StoreProductAttrServices::class);
			/** @var StoreProductAttrResultServices $productAttrResultServices */
			$productAttrResultServices = app()->make(StoreProductAttrResultServices::class);
			/** @var StoreProductAttrValueServices $productAttrValueServices */
			$productAttrValueServices = app()->make(StoreProductAttrValueServices::class);
			/** @var StoreDescriptionServices $productDescriptionServices */
			$productDescriptionServices = app()->make(StoreDescriptionServices::class);
			/** @var StoreProductRelationServices $productRelationServices */
			$productRelationServices = app()->make(StoreProductRelationServices::class);
			/** @var StoreProductReplyServices $productReplyServices */
			$productReplyServices = app()->make(StoreProductReplyServices::class);
			/** @var StoreProductReplyCommentServices $productReplyCommentServices */
			$productReplyCommentServices = app()->make(StoreProductReplyCommentServices::class);
			$idsArr = array_chunk($productIds, 100);
			foreach ($idsArr as $ids) {
				$productAttrServices->delete(['product_id' => $ids, 'type' => 0]);
				$productAttrResultServices->delete(['product_id' => $ids, 'type' => 0]);
				$productAttrValueServices->delete(['product_id' => $ids, 'type' => 0]);
				$productDescriptionServices->delete(['product_id' => $ids, 'type' => 0]);
				$productRelationServices->delete(['product_id' => $ids]);
				$this->dao->delete(['id' => $ids]);

				$replyIds = $productReplyServices->getColumn([['product_id', 'IN', $ids]], 'id');
				$replyIdsArr = array_chunk($replyIds, 100);
				foreach ($replyIdsArr as $rids) {
					$productReplyCommentServices->delete(['reply_id' => $rids]);
					$productReplyServices->delete(['id' => $rids]);
				}

				event('product.delete', [$ids]);
			}

			$this->dao->cacheTag()->clear();
			$productAttrServices->cacheTag()->clear();
		}
		return true;
	}

}