856 lines
37 KiB
PHP
856 lines
37 KiB
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\collage;
|
||
|
||
use app\services\BaseServices;
|
||
use app\dao\activity\collage\UserCollagePartakeDao;
|
||
use app\services\product\product\StoreProductServices;
|
||
use app\services\product\sku\StoreProductAttrValueServices;
|
||
use app\services\product\branch\StoreBranchProductServices;
|
||
use app\services\store\SystemStoreServices;
|
||
use app\services\order\StoreCartServices;
|
||
use app\services\user\level\SystemUserLevelServices;
|
||
use app\services\user\member\MemberCardServices;
|
||
use app\services\user\UserServices;
|
||
use think\exception\ValidateException;
|
||
|
||
/**
|
||
*
|
||
* Class UserCollagePartakeServices
|
||
* @package app\services\activity\collage
|
||
* @mixin UserCollagePartakeDao
|
||
*/
|
||
class UserCollagePartakeServices extends BaseServices
|
||
{
|
||
/**
|
||
* UserCollagePartakeServices constructor.
|
||
* @param UserCollagePartakeDao $dao
|
||
*/
|
||
public function __construct(UserCollagePartakeDao $dao)
|
||
{
|
||
$this->dao = $dao;
|
||
}
|
||
|
||
/**用户拼单/桌码商品统计
|
||
* @param array $where
|
||
* @param string $numType
|
||
* @param int $collage_id
|
||
* @param int $store_id
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function getUserPartakeCount(array $where, string $numType = '0', int $collage_id = 0, int $store_id = 0)
|
||
{
|
||
$count = 0;
|
||
$ids = [];
|
||
$cartNums = [];
|
||
$cartList = $this->dao->getUserPartakeList($where, 'id,cart_num,product_id');
|
||
if ($cartList) {
|
||
/** @var StoreProductServices $storeProductServices */
|
||
$storeProductServices = app()->make(StoreProductServices::class);
|
||
$productInfos = $storeProductServices->getColumn([['id', 'in', array_column($cartList, 'product_id')]], 'id,pid,type,relation_id', 'id');
|
||
foreach ($cartList as $cart) {
|
||
$productInfo = $productInfos[$cart['product_id']] ?? [];
|
||
if (!$productInfo) continue;
|
||
if (in_array($productInfo['type'], [0, 2]) || ($productInfo['type'] == 1 && $productInfo['relation_id'] == $store_id) || ($productInfo['type'] == 1 && $productInfo['pid'] > 0)) {
|
||
$ids[] = $cart['id'];
|
||
$cartNums[] = $cart['cart_num'];
|
||
}
|
||
}
|
||
if ($numType) {
|
||
$count = count($ids);
|
||
} else {
|
||
$count = array_sum($cartNums);
|
||
}
|
||
}
|
||
return compact('count', 'ids');
|
||
}
|
||
|
||
/**获取购物车列表
|
||
* @param array $where
|
||
* @param int $page
|
||
* @param int $limit
|
||
* @param array $with
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function getPartakeList(array $where, int $page = 0, int $limit = 0, array $with = [])
|
||
{
|
||
return $this->search($where)->when($page && $limit, function ($query) use ($page, $limit) {
|
||
$query->page($page, $limit);
|
||
})->when(count($with), function ($query) use ($with, $where) {
|
||
$query->with($with);
|
||
})->order('add_time DESC')->select()->toArray();
|
||
}
|
||
|
||
/**
|
||
* 处理购物车数据
|
||
* @param int $uid
|
||
* @param array $cartList
|
||
* @param array $addr
|
||
* @param int $shipping_type
|
||
* @param int $store_id
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function handleCartList(int $uid, array $cartList, int $shipping_type = 1, int $store_id = 0)
|
||
{
|
||
if (!$cartList) {
|
||
return [$cartList, [], [], [], 0, [], []];
|
||
}
|
||
/** @var StoreProductServices $productServices */
|
||
$productServices = app()->make(StoreProductServices::class);
|
||
/** @var MemberCardServices $memberCardService */
|
||
$memberCardService = app()->make(MemberCardServices::class);
|
||
$vipStatus = $memberCardService->isOpenMemberCardCache('vip_price', false);
|
||
$tempIds = [];
|
||
$userInfo = [];
|
||
$discount = 100;
|
||
$productIds = $allStock = $attrUniquesArr = [];
|
||
if ($uid) {
|
||
/** @var UserServices $user */
|
||
$user = app()->make(UserServices::class);
|
||
$userInfo = $user->getUserCacheInfo($uid);
|
||
//用户等级是否开启
|
||
if (sys_config('member_func_status', 1) && $userInfo) {
|
||
$userInfo = $userInfo->toArray();
|
||
/** @var SystemUserLevelServices $systemLevel */
|
||
$systemLevel = app()->make(SystemUserLevelServices::class);
|
||
$discount = $systemLevel->getDiscount($uid, (int)$userInfo['level'] ?? 0);
|
||
}
|
||
}
|
||
if ($store_id) {//平台商品，在门店购买 验证门店库存
|
||
/** @var StoreProductAttrValueServices $skuValueServices */
|
||
$skuValueServices = app()->make(StoreProductAttrValueServices::class);
|
||
/** @var StoreBranchProductServices $branchProductServics */
|
||
$branchProductServics = app()->make(StoreBranchProductServices::class);
|
||
foreach ($cartList as $cart) {
|
||
$productInfo = $cart['productInfo'] ?? [];
|
||
if (!$productInfo) continue;
|
||
if ($productInfo['type'] == 1) {//平台、供应商商品验证门店库存
|
||
continue;
|
||
}
|
||
$productIds[] = $cart['product_id'];
|
||
$suk = $skuValueServices->value(['unique' => $cart['product_attr_unique'], 'product_id' => $cart['product_id'], 'type' => 0], 'suk');
|
||
$branchProductInfo = $branchProductServics->isValidStoreProduct((int)$cart['product_id'], $store_id);
|
||
if (!$branchProductInfo) {
|
||
continue;
|
||
}
|
||
$attrValue = $skuValueServices->get(['suk' => $suk, 'product_id' => $branchProductInfo['id'], 'type' => 0]);
|
||
if (!$attrValue) {
|
||
continue;
|
||
}
|
||
$allStock[$attrValue['unique']] = $attrValue['stock'];
|
||
$attrUniquesArr[$cart['product_attr_unique']] = $attrValue['unique'];
|
||
}
|
||
} else {
|
||
$productIds = array_unique(array_column($cartList, 'product_id'));
|
||
}
|
||
|
||
$valid = $invalid = [];
|
||
foreach ($cartList as &$item) {
|
||
if (isset($item['productInfo']['delivery_type'])) {
|
||
$item['productInfo']['delivery_type'] = is_string($item['productInfo']['delivery_type']) ? explode(',', $item['productInfo']['delivery_type']) : $item['productInfo']['delivery_type'];
|
||
} else {
|
||
$item['productInfo']['delivery_type'] = [];
|
||
}
|
||
$item['productInfo']['express_delivery'] = in_array(1, $item['productInfo']['delivery_type']);
|
||
$item['productInfo']['store_mention'] = in_array(2, $item['productInfo']['delivery_type']);
|
||
$item['productInfo']['store_delivery'] = in_array(3, $item['productInfo']['delivery_type']);
|
||
|
||
if (isset($item['attrInfo']) && $item['attrInfo'] && (!isset($item['productInfo']['attrInfo']) || !$item['productInfo']['attrInfo'])) {
|
||
$item['productInfo']['attrInfo'] = $item['attrInfo'] ?? [];
|
||
}
|
||
$item['attrStatus'] = isset($item['productInfo']['attrInfo']['stock']) && $item['productInfo']['attrInfo']['stock'];
|
||
$item['productInfo']['attrInfo']['image'] = $item['productInfo']['attrInfo']['image'] ?? $item['productInfo']['image'] ?? '';
|
||
$item['productInfo']['attrInfo']['suk'] = $item['productInfo']['attrInfo']['suk'] ?? '已失效';
|
||
if (isset($item['productInfo']['attrInfo'])) {
|
||
$item['productInfo']['attrInfo'] = get_thumb_water($item['productInfo']['attrInfo']);
|
||
}
|
||
$item['vip_truePrice'] = 0;
|
||
$item['productInfo'] = get_thumb_water($item['productInfo']);
|
||
$productInfo = $item['productInfo'];
|
||
//门店独立商品
|
||
$isBranchProduct = isset($productInfo['type']) && isset($productInfo['pid']) && $productInfo['type'] == 1 && !$productInfo['pid'];
|
||
$product_store_id = $isBranchProduct ? $productInfo['relation_id'] : 0;
|
||
if (isset($productInfo['attrInfo']['product_id']) && $item['product_attr_unique']) {
|
||
$item['costPrice'] = $productInfo['attrInfo']['cost'] ?? 0;
|
||
$item['trueStock'] = $item['branch_stock'] = $productInfo['attrInfo']['stock'] ?? 0;
|
||
$item['branch_sales'] = $productInfo['attrInfo']['sales'] ?? 0;
|
||
$item['truePrice'] = $productInfo['attrInfo']['price'] ?? 0;
|
||
$item['sum_price'] = $productInfo['attrInfo']['price'] ?? 0;
|
||
if (!$isBranchProduct) {
|
||
[$truePrice, $vip_truePrice, $type] = $productServices->setLevelPrice($productInfo['attrInfo']['price'] ?? 0, $uid, $userInfo, $vipStatus, $discount, $productInfo['attrInfo']['vip_price'] ?? 0, $productInfo['is_vip'] ?? 0, true);
|
||
$item['truePrice'] = $truePrice;
|
||
$item['vip_truePrice'] = $vip_truePrice;
|
||
$item['price_type'] = $type;
|
||
}
|
||
} else {
|
||
$item['costPrice'] = $item['productInfo']['cost'] ?? 0;
|
||
$item['trueStock'] = $item['branch_sales'] = $item['productInfo']['stock'] ?? 0;
|
||
$item['branch_sales'] = $item['productInfo']['sales'] ?? 0;
|
||
$item['truePrice'] = $item['productInfo']['price'] ?? 0;
|
||
$item['sum_price'] = $item['productInfo']['price'] ?? 0;
|
||
if (!$isBranchProduct) {
|
||
[$truePrice, $vip_truePrice, $type] = $productServices->setLevelPrice($item['productInfo']['price'] ?? 0, $uid, $userInfo, $vipStatus, $discount, $item['productInfo']['vip_price'] ?? 0, $item['productInfo']['is_vip'] ?? 0, true);
|
||
$item['truePrice'] = $truePrice;
|
||
$item['vip_truePrice'] = $vip_truePrice;
|
||
$item['price_type'] = $type;
|
||
}
|
||
}
|
||
$item['is_true_stock'] = $item['trueStock'] >= $item['cart_num'] ? true : false;
|
||
$item['total_price'] = bcmul((string)$item['truePrice'], (string)$item['cart_num'], 2);
|
||
$item['sum_price'] = bcmul((string)$item['sum_price'], (string)$item['cart_num'], 2);
|
||
if (isset($item['status']) && $item['status'] == 0) {
|
||
$item['is_valid'] = 0;
|
||
$item['invalid_desc'] = '此商品已失效';
|
||
$invalid[] = $item;
|
||
} else {
|
||
$condition = !in_array(isset($item['productInfo']['product_id']) ? $item['productInfo']['product_id'] : $item['productInfo']['id'], $productIds) || $item['cart_num'] > ($allStock[$attrUniquesArr[$item['product_attr_unique']] ?? ''] ?? 0);
|
||
switch ($shipping_type) {
|
||
case -1://购物车列表展示
|
||
if ($isBranchProduct && $store_id && $store_id != $product_store_id) {
|
||
$item['is_valid'] = 0;
|
||
$item['invalid_desc'] = '此商品超出配送/自提范围';
|
||
$invalid[] = $item;
|
||
} else {
|
||
$item['is_valid'] = 1;
|
||
$valid[] = $item;
|
||
}
|
||
break;
|
||
case 1:
|
||
//不送达
|
||
if (in_array($item['productInfo']['temp_id'], $tempIds) || (isset($item['productInfo']['delivery_type']) && !in_array(1, $item['productInfo']['delivery_type']) && !in_array(3, $item['productInfo']['delivery_type']))) {
|
||
$item['is_valid'] = 0;
|
||
$item['invalid_desc'] = '此商品超出配送/自提范围';
|
||
$invalid[] = $item;
|
||
} elseif ($isBranchProduct && $store_id && ($store_id != $product_store_id || !in_array(3, $item['productInfo']['delivery_type']))) {
|
||
$item['is_valid'] = 0;
|
||
$item['invalid_desc'] = '此商品超出配送/自提范围';
|
||
$invalid[] = $item;
|
||
} elseif (in_array($productInfo['type'], [0, 2]) && $store_id && ($condition || (!in_array(2, $item['productInfo']['delivery_type']) && !in_array(3, $item['productInfo']['delivery_type'])))) {//平台商品 在门店购买 验证门店库存
|
||
$item['is_valid'] = 0;
|
||
$item['invalid_desc'] = '此商品超出配送/自提范围';
|
||
$invalid[] = $item;
|
||
} else {
|
||
$item['is_valid'] = 1;
|
||
$valid[] = $item;
|
||
}
|
||
break;
|
||
case 2:
|
||
//不支持到店自提
|
||
if (isset($item['productInfo']['delivery_type']) && $item['productInfo']['delivery_type'] && !in_array(2, $item['productInfo']['delivery_type'])) {
|
||
$item['is_valid'] = 0;
|
||
$item['invalid_desc'] = '此商品超出配送/自提范围';
|
||
$invalid[] = $item;
|
||
} elseif ($isBranchProduct && $store_id && $store_id != $product_store_id) {
|
||
$item['is_valid'] = 0;
|
||
$item['invalid_desc'] = '此商品超出配送/自提范围';
|
||
$invalid[] = $item;
|
||
} elseif ($item['productInfo']['product_type'] == 1) {
|
||
$item['is_valid'] = 0;
|
||
$item['invalid_desc'] = '此商品超出配送/自提范围';
|
||
$invalid[] = $item;
|
||
} elseif (in_array($productInfo['type'], [0, 2]) && $store_id && $condition) {//平台、供应商商品 在门店购买 验证门店库存
|
||
$item['is_valid'] = 0;
|
||
$item['invalid_desc'] = '此商品超出配送/自提范围';
|
||
$invalid[] = $item;
|
||
} else {
|
||
$item['is_valid'] = 1;
|
||
$valid[] = $item;
|
||
}
|
||
break;
|
||
case 4:
|
||
//无库存｜｜下架
|
||
if ($isBranchProduct && $store_id && $store_id != $product_store_id) {
|
||
$item['is_valid'] = 0;
|
||
$item['invalid_desc'] = '此商品超出配送/自提范围';
|
||
$invalid[] = $item;
|
||
} elseif (in_array($productInfo['type'], [0, 2]) && $store_id && $condition) {
|
||
$item['is_valid'] = 0;
|
||
$invalid[] = $item;
|
||
} else {
|
||
$item['is_valid'] = 1;
|
||
$valid[] = $item;
|
||
}
|
||
break;
|
||
default:
|
||
$item['is_valid'] = 1;
|
||
$valid[] = $item;
|
||
break;
|
||
}
|
||
}
|
||
unset($item['attrInfo']);
|
||
}
|
||
return [$cartList, $valid, $invalid];
|
||
}
|
||
|
||
/**用户添加拼单商品
|
||
* @param int $uid
|
||
* @param int $productId
|
||
* @param int $cart_num
|
||
* @param string $product_attr_unique
|
||
* @param int $collageId
|
||
* @param int $storeId
|
||
* @param int $type
|
||
* @param int $isAdd
|
||
* @return bool|\crmeb\basic\BaseModel|mixed|\think\Model
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function addUserPartakeProduct(int $uid, int $productId, int $cart_num = 1, string $product_attr_unique = '', int $collageId = 0, int $storeId = 0, int $type = 0, int $isAdd = 1)
|
||
{
|
||
if ($cart_num < 1) $cart_num = 1;
|
||
|
||
/** @var StoreProductAttrValueServices $attrValueServices */
|
||
$attrValueServices = app()->make(StoreProductAttrValueServices::class);
|
||
|
||
if ($product_attr_unique == '') {
|
||
$product_attr_unique = $attrValueServices->value(['product_id' => $productId, 'type' => 0], 'unique');
|
||
}
|
||
//该商品已选择库存
|
||
$sum_cart_num = $this->dao->sum(['collate_code_id' => $collageId, 'product_id' => $productId, 'product_attr_unique' => $product_attr_unique, 'store_id' => $storeId, 'status' => 1], 'cart_num');
|
||
|
||
//检测库存限量
|
||
/** @var StoreCartServices $cartServices */
|
||
$cartServices = app()->make(StoreCartServices::class);
|
||
[$attrInfo, $product_attr_unique, $bargainPriceMin, $cart_num, $productInfo] = $cartServices->checkProductStock(
|
||
$uid,
|
||
$productId,
|
||
$cart_num,
|
||
$storeId,
|
||
$product_attr_unique,
|
||
false,
|
||
$type,
|
||
0,
|
||
0,
|
||
$sum_cart_num
|
||
);
|
||
$product_type = $productInfo['product_type'];
|
||
$cart = $this->dao->getOne(['uid' => $uid, 'collate_code_id' => $collageId, 'product_id' => $productId, 'product_attr_unique' => $product_attr_unique, 'store_id' => $storeId, 'status' => 1, 'is_settle' => 0]);
|
||
if ($cart) {
|
||
if ($isAdd) {
|
||
$cart->cart_num = $cart->cart_num + $cart_num;
|
||
} else {
|
||
$cart->cart_num = $cart->cart_num - $cart_num;
|
||
}
|
||
if ($cart->cart_num == 0) {
|
||
$res = $this->dao->delete($cart->id);
|
||
} else {
|
||
$cart->add_time = time();
|
||
$res = $cart->save();
|
||
}
|
||
} else {
|
||
$data = [
|
||
'uid' => $uid,
|
||
'collate_code_id' => $collageId,
|
||
'product_id' => $productId,
|
||
'product_attr_unique' => $product_attr_unique,
|
||
'product_type' => $product_type,
|
||
'store_id' => $storeId,
|
||
'cart_num' => $cart_num,
|
||
'add_time' => time()
|
||
];
|
||
$res = $this->dao->save($data);
|
||
}
|
||
return $res;
|
||
}
|
||
|
||
/**重组数组
|
||
* @param array $array
|
||
* @param int $uid
|
||
* @param int $sponsor_uid
|
||
* @return array
|
||
*/
|
||
public function array_val_chunk(array $array, int $uid, int $sponsor_uid, int $status)
|
||
{
|
||
$result = [];
|
||
foreach ($array as $key => &$value) {
|
||
if (!$value['userInfo']) {
|
||
$value['userInfo'] = [
|
||
'uid' => 0,
|
||
'nickname' => '该用户已注销'
|
||
];
|
||
}
|
||
$result [$value ['uid']]['userInfo'] = $value['userInfo'];
|
||
unset($value['userInfo']);
|
||
$result [$value ['uid']]['goods'][] = $value;
|
||
}
|
||
/** @var UserServices $userServices */
|
||
$userServices = app()->make(UserServices::class);
|
||
if (array_key_exists($uid, $result)) {
|
||
$undata = $result[$uid];
|
||
} else {
|
||
$userInfo = $userServices->getUserInfo($uid);
|
||
if (!$userInfo) {
|
||
$userInfo = [
|
||
'uid' => 0,
|
||
'nickname' => '该用户已注销'
|
||
];
|
||
}
|
||
if ($status >= 2) {
|
||
$undata = [];
|
||
} else {
|
||
$undata = [
|
||
'userInfo' => $userInfo,
|
||
'goods' => []
|
||
];
|
||
}
|
||
}
|
||
if (array_key_exists($sponsor_uid, $result)) {
|
||
$sponsordata = $result[$sponsor_uid];
|
||
} else {
|
||
$userInfo = $userServices->getUserInfo($sponsor_uid);
|
||
if (!$userInfo) {
|
||
$userInfo = [
|
||
'uid' => 0,
|
||
'nickname' => '该用户已注销'
|
||
];
|
||
}
|
||
$sponsordata = [
|
||
'userInfo' => $userInfo,
|
||
'goods' => []
|
||
];
|
||
}
|
||
foreach ($result as $key => $item) {
|
||
if ($key == $uid || $key == $sponsor_uid) {
|
||
unset($result[$key]);
|
||
}
|
||
}
|
||
if ($uid == $sponsor_uid) {
|
||
array_unshift($result, $undata);
|
||
} else {
|
||
if ($undata) {
|
||
array_unshift($result, $undata, $sponsordata);
|
||
} else {
|
||
array_unshift($result, $sponsordata);
|
||
}
|
||
}
|
||
foreach ($result as $key => $item) {
|
||
$truePrices = array_column($item['goods'], 'sum_price');
|
||
$sum = array_sum($truePrices);
|
||
$result[$key]['sum_price'] = $sum;
|
||
$result[$key]['sumPrice'] = number_format($sum, 2);
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 获取所有人拼单商品
|
||
* @param int $collage_id
|
||
* @param int $uid
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function getUserPartakeProduct(int $collage_id, int $uid)
|
||
{
|
||
/** @var UserCollageCodeServices $collageServices */
|
||
$collageServices = app()->make(UserCollageCodeServices::class);
|
||
$collage = $collageServices->get($collage_id);
|
||
$where = ['collate_code_id' => $collage_id, 'status' => 1];
|
||
[$cartList, $valid, $invalid] = $this->getUserCashierTablePartakeProduct($collage['uid'], $collage['store_id'], $where, '', ['userInfo', 'productInfo', 'attrInfo']);
|
||
$cartList = $this->array_val_chunk($cartList, $uid, $collage['uid'], $collage['status']);
|
||
return $cartList;
|
||
}
|
||
|
||
/**
|
||
* 用户清空拼单
|
||
* @param int $collage_id
|
||
* @param int $uid
|
||
* @return bool
|
||
*/
|
||
public function emptyUserCollagePartake(int $collage_id, int $uid)
|
||
{
|
||
return $this->dao->del(['collate_code_id' => $collage_id, 'uid' => $uid]);
|
||
}
|
||
|
||
/**
|
||
* 复制他人拼单商品
|
||
* @param int $collage_id
|
||
* @param int $c_uid
|
||
* @param int $uid
|
||
* @return bool
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function duplicateUserCollagePartake(int $collage_id, int $c_uid, int $uid)
|
||
{
|
||
$data = $this->dao->getUserPartakeList(['uid' => $c_uid, 'collate_code_id' => $collage_id, 'status' => 1], 'product_id,product_type,store_id,product_attr_unique,cart_num');
|
||
foreach ($data as $key => $item) {
|
||
$res = $this->addUserPartakeProduct($uid, (int)$item['product_id'], $item['cart_num'], $item['product_attr_unique'], $collage_id, $item['store_id'], 9, 1);
|
||
if (!$res) continue;
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 拼单商品写入购物车
|
||
* @param int $collage_id
|
||
* @param int $uid
|
||
* @param int $type
|
||
* @return false|string
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function allUserSettleAccountsCollage(int $collage_id, int $uid, int $type)
|
||
{
|
||
$data = $this->dao->getUserPartakeList(['collate_code_id' => $collage_id, 'status' => 1], 'id,product_id,product_type,store_id,product_attr_unique,cart_num,status,is_settle');
|
||
if (count($data) <= 0) return false;
|
||
/** @var StoreCartServices $cartServices */
|
||
$cartServices = app()->make(StoreCartServices::class);
|
||
$cartIds = [];
|
||
foreach ($data as $key => $item) {
|
||
[$key, $cart_num] = $cartServices->setCart($uid, (int)$item['product_id'], (int)$item['cart_num'], $item['product_attr_unique'], $type, true, $collage_id, 0);
|
||
if ($key && !$item['is_settle']) {
|
||
$this->dao->update($item['id'], ['is_settle' => 1]);
|
||
}
|
||
$cartIds[] = $key;
|
||
}
|
||
if (count($cartIds) < 0) return false;
|
||
/** @var UserCollageCodeServices $collageServices */
|
||
$collageServices = app()->make(UserCollageCodeServices::class);
|
||
$res = $collageServices->userUpdate($collage_id, ['status' => 1]);
|
||
if (!$res) return false;
|
||
$cartIds = array_unique($cartIds);
|
||
$cartIds = implode(',', $cartIds);
|
||
return $cartIds;
|
||
}
|
||
|
||
/**
|
||
* 根据商品id获取购物车数量
|
||
* @param array $ids
|
||
* @param int $uid
|
||
* @param int $storeId
|
||
* @param int $collate_code_id
|
||
* @return mixed
|
||
*/
|
||
public function productIdByCartNum(array $ids, int $uid, int $collate_code_id = 0)
|
||
{
|
||
return $this->search(['product_id' => $ids, 'uid' => $uid, 'collate_code_id' => $collate_code_id, 'is_settle' => 0])->group('product_attr_unique')->column('cart_num,product_id', 'product_attr_unique');
|
||
}
|
||
|
||
/**
|
||
* 用户注销信息删除拼单商品
|
||
* @param int $uid
|
||
* @return bool
|
||
*/
|
||
public function logOffUserCollagePartake(int $uid)
|
||
{
|
||
return $this->dao->del(['uid' => $uid, 'is_settle' => 0]);
|
||
}
|
||
|
||
/**
|
||
* 获取桌码商品
|
||
* @param int $tableId
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function getUserTablePartakeProduct(int $tableId)
|
||
{
|
||
/** @var UserCollageCodeServices $collageServices */
|
||
$collageServices = app()->make(UserCollageCodeServices::class);
|
||
$table = $collageServices->get($tableId);
|
||
if ($table['status'] == -1) {
|
||
throw new ValidateException('桌码已取消');
|
||
}
|
||
$where = ['collate_code_id' => $tableId, 'status' => 1];
|
||
[$cartList, $valid, $invalid] = $this->getUserCashierTablePartakeProduct($table['uid'], $table['store_id'], $where, '', ['userInfo', 'productInfo', 'attrInfo']);
|
||
$result = [];
|
||
foreach ($cartList as $key => &$value) {
|
||
if (!$value['userInfo']) {
|
||
$value['userInfo'] = [
|
||
'uid' => 0,
|
||
'nickname' => '该用户已注销'
|
||
];
|
||
}
|
||
$result [$value ['uid']]['userInfo'] = $value['userInfo'];
|
||
$result [$value ['uid']]['order_time'] = date('H:i', $value['add_time']);
|
||
unset($value['userInfo']);
|
||
$result [$value ['uid']]['goods'][] = $value;
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 订单商品信息
|
||
* @param int $uid
|
||
* @param int $store_id
|
||
* @param array $where
|
||
* @param string $field
|
||
* @param array $with
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function getUserCashierTablePartakeProduct(int $uid, int $store_id, array $where, string $field = '*', array $with = [])
|
||
{
|
||
$cartList = $this->dao->getUserPartakeProductList($where, $field, $with);
|
||
return $this->handleCartList($uid, $cartList, -1, $store_id);
|
||
}
|
||
|
||
/**
|
||
* 桌码打印信息获取
|
||
* @param int $uid
|
||
* @param int $store_id
|
||
* @param array $where
|
||
* @param string $field
|
||
* @param array $with
|
||
* @return array|mixed
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function getCashierTablePartakePrintProduct(int $uid, int $store_id, array $where, string $field = '*', array $with = [])
|
||
{
|
||
$cartList = $this->dao->getUserPartakeProductList($where, $field, $with);
|
||
if (!$cartList) return [];
|
||
$data = $this->dataPartake($cartList, true);
|
||
[$datas, $valid, $invalid] = $this->handleCartList($uid, $data['cart'], -1, $store_id);
|
||
return $datas;
|
||
}
|
||
|
||
/**
|
||
* 获取订单商品信息
|
||
* @param array $where
|
||
* @param string $field
|
||
* @param array $with
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function getCashierTablePartakeProduct(array $where, string $field = '*', array $with = [])
|
||
{
|
||
$cartList = $this->dao->getUserPartakeProductList($where, $field, $with);
|
||
if (!$cartList) return [];
|
||
return $this->dataPartake($cartList, true);
|
||
}
|
||
|
||
/**
|
||
* 桌码商品处理
|
||
* @param int $uid
|
||
* @param array $where
|
||
* @param int $store_id
|
||
* @return mixed
|
||
*/
|
||
public function getTableCatePartakeList(int $uid, array $where, int $store_id)
|
||
{
|
||
$data = $this->getPartakeList($where, 0, 0, ['productInfo', 'attrInfo']);
|
||
$data = $this->dataPartake($data, false);
|
||
[$data, $valid, $invalid] = $this->handleCartList($uid, $data['cart'], -1, $store_id);
|
||
return $valid;
|
||
}
|
||
|
||
/**
|
||
* 数据处理
|
||
* @param array $data
|
||
* @param bool $is_price
|
||
* @return array
|
||
*/
|
||
public function dataPartake(array $data, bool $is_price)
|
||
{
|
||
$cart = [];
|
||
$sum_price = 0;
|
||
$cart_num = 0;
|
||
foreach ($data as $item) {
|
||
$oneCart = [
|
||
'id' => $item['id'] ?? 0,
|
||
'uid' => $item['uid'] ?? 0,
|
||
'collate_code_id' => $item['collate_code_id'] ?? 0,
|
||
'product_id' => $item['product_id'] ?? 0,
|
||
'product_type' => $item['product_type'] ?? 0,
|
||
'product_attr_unique' => $item['product_attr_unique'] ?? '',
|
||
'status' => $item['status'] ?? 0,
|
||
'is_print' => $item['is_print'] ?? 0,
|
||
'is_settle' => $item['is_settle'] ?? 0,
|
||
'add_time' => $item['add_time'] ?? 0,
|
||
'productInfo' => $item['productInfo'] ?? [],
|
||
];
|
||
if ($oneCart['productInfo'] && isset($item['attrInfo']) && $item['attrInfo']) {
|
||
$oneCart['productInfo']['attrInfo'] = $item['attrInfo'];
|
||
unset($item['attrInfo']);
|
||
}
|
||
if (isset($cart[$item['product_id'] . $item['product_attr_unique']])) {
|
||
$cart[$item['product_id'] . $item['product_attr_unique']] = array_merge($cart[$item['product_id'] . $item['product_attr_unique']], $oneCart);
|
||
} else {
|
||
$cart[$item['product_id'] . $item['product_attr_unique']] = $oneCart;
|
||
}
|
||
|
||
if (isset($cart[$item['product_id'] . $item['product_attr_unique']]['cart_num'])) {
|
||
$cart[$item['product_id'] . $item['product_attr_unique']]['cart_num'] += $item['cart_num'];
|
||
} else {
|
||
$cart[$item['product_id'] . $item['product_attr_unique']]['cart_num'] = $item['cart_num'];
|
||
}
|
||
$cart_num += $item['cart_num'];
|
||
if ($is_price && isset($item['productInfo'])) {
|
||
$sum_price = bcadd((string)$sum_price, bcmul((string)$item['cart_num'], (string)$item['productInfo']['price'], 2), 2);
|
||
}
|
||
}
|
||
return compact('cart', 'sum_price', 'cart_num');
|
||
}
|
||
|
||
|
||
/**
|
||
* 桌码商品写入购物车
|
||
* @param int $tableId
|
||
* @param int $uid
|
||
* @param int $type
|
||
* @return false|string
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function allUserSettleAccountsTableCode(int $tableId, int $uid, int $type)
|
||
{
|
||
$data = $this->dao->getUserPartakeList(['collate_code_id' => $tableId, 'status' => 1], 'id,product_id,product_type,store_id,product_attr_unique,cart_num,status,is_settle');
|
||
if (count($data) <= 0) return false;
|
||
/** @var StoreCartServices $cartServices */
|
||
$cartServices = app()->make(StoreCartServices::class);
|
||
$cartIds = [];
|
||
$data = $this->dataPartake($data, false);
|
||
foreach ($data['cart'] as $key => $item) {
|
||
try {
|
||
[$key, $cart_num] = $cartServices->setCart($uid, (int)$item['product_id'], $item['cart_num'], $item['product_attr_unique'], $type, true, $tableId, 0);
|
||
$cartIds[] = $key;
|
||
} catch (\Exception $e) {
|
||
continue;
|
||
}
|
||
}
|
||
if (count($cartIds) < 0) return false;
|
||
$cartIds = array_unique($cartIds);
|
||
$cartIds = implode(',', $cartIds);
|
||
return $cartIds;
|
||
}
|
||
|
||
/**
|
||
* 获取最后一条记录
|
||
* @param array $where
|
||
* @return array|\crmeb\basic\BaseModel|mixed|\think\Model|null
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function getMaxTime(array $where)
|
||
{
|
||
return $this->dao->getUserPartake($where);
|
||
}
|
||
|
||
/**
|
||
* 获取用户信息
|
||
* @param $where
|
||
* @param $store_id
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function tableCodeUserAll($where, $store_id)
|
||
{
|
||
$uids = $this->dao->getUserPartakeList(['collate_code_id' => $where['table_id'], 'store_id' => $store_id], 'uid', ['userInfo']);
|
||
foreach ($uids as $key => $item) {
|
||
if (!$item['userInfo']) {
|
||
unset($uids[$key]);
|
||
}
|
||
}
|
||
$uids = array_unique($uids, SORT_REGULAR);
|
||
return array_merge($uids);
|
||
}
|
||
|
||
/**
|
||
* 获取打印订单的商品信息
|
||
* @param array $table
|
||
* @return array
|
||
*/
|
||
public function getCartInfoPrintProduct(array $table, int $is_print = 0)
|
||
{
|
||
$where = ['collate_code_id' => $table['id'], 'status' => 1, 'is_print' => $is_print];
|
||
|
||
$data = $this->getCashierTablePartakePrintProduct($table['uid'], $table['store_id'], $where, '', ['productInfo', 'attrInfo']);
|
||
$product = [];
|
||
if (!$data) return $product;
|
||
foreach ($data as $item) {
|
||
$item['productInfo']['store_name'] = substrUTf8($item['productInfo']['store_name'], 5, 'UTF-8', '');
|
||
$product[] = $item;
|
||
}
|
||
return $product;
|
||
}
|
||
|
||
/**
|
||
* 用户清空购物车
|
||
* @param int $table_id
|
||
* @return bool
|
||
*/
|
||
public function emptyUserTablePartake(int $table_id)
|
||
{
|
||
return $this->dao->del(['collate_code_id' => $table_id]);
|
||
}
|
||
|
||
/**
|
||
* 收银台购物车数量操作
|
||
* @param array $where
|
||
* @param int $store_id
|
||
* @return bool|mixed
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function editTableCartProduct(array $where, int $store_id)
|
||
{
|
||
if ($where['cartNum'] < 1) {
|
||
$cart_num = 1;
|
||
} else {
|
||
$cart_num = $where['cartNum'];
|
||
}
|
||
$cart = $this->dao->getOne(['collate_code_id' => $where['tableId'], 'product_id' => $where['productId'], 'product_attr_unique' => $where['uniqueId'], 'store_id' => $store_id]);
|
||
if (!$cart) return false;
|
||
if ($where['isAdd']) {
|
||
$cart->cart_num = $cart->cart_num + $cart_num;
|
||
} else {
|
||
$cart->cart_num = $cart->cart_num - $cart_num;
|
||
}
|
||
if ($cart->cart_num == 0) {
|
||
$res = $this->dao->delete($cart->id);
|
||
} else {
|
||
$res = $cart->save();
|
||
}
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 用户删除拼单、桌码商品
|
||
* @param int $collate_code_id
|
||
* @param int $storeId
|
||
* @param int $productId
|
||
* @param string $uniqueId
|
||
* @return bool
|
||
*/
|
||
public function delUserCatePartake(int $collate_code_id, int $storeId, int $productId, string $uniqueId)
|
||
{
|
||
return $this->dao->del(['collate_code_id' => $collate_code_id, 'store_id' => $storeId, 'product_id' => $productId, 'product_attr_unique' => $uniqueId]);
|
||
}
|
||
}
|