StoreCart.php 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382
  1. <?php
  2. /**
  3. *
  4. * @author: xaboy<365615158@qq.com>
  5. * @day: 2017/12/18
  6. */
  7. namespace app\models\store;
  8. use app\admin\model\store\StoreProductAttrValue;
  9. use app\admin\model\system\SystemGroupData;
  10. use app\admin\model\system\SystemStoreProductStock;
  11. use crmeb\basic\BaseModel;
  12. use crmeb\services\UtilService;
  13. use crmeb\traits\ModelTrait;
  14. /**
  15. * TODO 购物车Model
  16. * Class StoreCart
  17. * @package app\models\store
  18. */
  19. class StoreCart extends BaseModel
  20. {
  21. /**
  22. * 数据表主键
  23. * @var string
  24. */
  25. protected $pk = 'id';
  26. /**
  27. * 模型名称
  28. * @var string
  29. */
  30. protected $name = 'store_cart';
  31. use ModelTrait;
  32. protected $insert = ['add_time'];
  33. protected function setAddTimeAttr()
  34. {
  35. return time();
  36. }
  37. public static function setCart($uid, $product_id, $cart_num = 1, $product_attr_unique = '', $type = 'product', $is_new = 0, $combination_id = 0, $seckill_id = 0, $bargain_id = 0, $integral_id = 0)
  38. {
  39. if ($cart_num < 1) $cart_num = 1;
  40. if ($seckill_id) {
  41. $StoreSeckillinfo = StoreSeckill::getValidProduct($seckill_id);
  42. if (!$StoreSeckillinfo)
  43. return self::setErrorInfo('该产品已下架或删除');
  44. $userbuycount = StoreOrder::where('uid', $uid)->where('paid', 1)->where('seckill_id', $seckill_id)->count();
  45. if ($StoreSeckillinfo['num'] <= $userbuycount || $StoreSeckillinfo['num'] < $cart_num)
  46. return self::setErrorInfo('每人限购' . $StoreSeckillinfo['num'] . '件');
  47. $res = StoreProductAttrValue::where('product_id', $seckill_id)->where('unique', $product_attr_unique)->where('type', 1)->field('suk,quota')->find();
  48. if ($cart_num > $res['quota'])
  49. return self::setErrorInfo('该产品库存不足' . $cart_num);
  50. $product_stock = StoreProductAttrValue::where('product_id', $StoreSeckillinfo['product_id'])->where('suk', $res['suk'])->where('type', 0)->value('stock');
  51. if ($product_stock < $cart_num)
  52. return self::setErrorInfo('该产品库存不足' . $cart_num);
  53. } elseif ($bargain_id) {
  54. if (!StoreBargain::validBargain($bargain_id))
  55. return self::setErrorInfo('该产品已下架或删除');
  56. $StoreBargainInfo = StoreBargain::getBargain($bargain_id);
  57. $res = StoreProductAttrValue::where('product_id', $bargain_id)->where('type', 2)->field('suk,quota')->find();
  58. if ($cart_num > $res['quota'])
  59. return self::setErrorInfo('该产品库存不足' . $cart_num);
  60. $product_stock = StoreProductAttrValue::where('product_id', $StoreBargainInfo['product_id'])->where('suk', $res['suk'])->where('type', 0)->value('stock');
  61. if ($product_stock < $cart_num)
  62. return self::setErrorInfo('该产品库存不足' . $cart_num);
  63. } elseif ($combination_id) {//拼团
  64. $StoreCombinationInfo = StoreCombination::getCombinationOne($combination_id);
  65. if (!$StoreCombinationInfo)
  66. return self::setErrorInfo('该产品已下架或删除');
  67. $userbuycount = StoreOrder::where('uid', $uid)->where('paid', 1)->where('combination_id', $combination_id)->count();
  68. if ($StoreCombinationInfo['num'] <= $userbuycount || $StoreCombinationInfo['num'] < $cart_num)
  69. return self::setErrorInfo('每人限购' . $StoreCombinationInfo['num'] . '件');
  70. $res = StoreProductAttrValue::where('product_id', $combination_id)->where('unique', $product_attr_unique)->where('type', 3)->field('suk,quota')->find();
  71. if ($cart_num > $res['quota'])
  72. return self::setErrorInfo('该产品库存不足' . $cart_num);
  73. $product_stock = StoreProductAttrValue::where('product_id', $StoreCombinationInfo['product_id'])->where('suk', $res['suk'])->where('type', 0)->value('stock');
  74. if ($product_stock < $cart_num)
  75. return self::setErrorInfo('该产品库存不足' . $cart_num);
  76. } elseif ($integral_id) {
  77. $StoreIntegralInfo = StoreIntegral::getValidProduct($integral_id);
  78. if (!$StoreIntegralInfo)
  79. return self::setErrorInfo('该产品已下架或删除');
  80. $userbuycount = StoreOrder::where('uid', $uid)->where('paid', 1)->where('integral_id', $integral_id)->count();
  81. if ($StoreIntegralInfo['num'] <= $userbuycount || $StoreIntegralInfo['num'] < $cart_num)
  82. return self::setErrorInfo('每人限购' . $StoreIntegralInfo['num'] . '件');
  83. $res = StoreProductAttrValue::where('product_id', $integral_id)->where('unique', $product_attr_unique)->where('type', 4)->field('suk,quota')->find();
  84. if ($cart_num > $res['quota'])
  85. return self::setErrorInfo('该产品库存不足' . $cart_num);
  86. $product_stock = StoreProductAttrValue::where('product_id', $StoreIntegralInfo['product_id'])->where('suk', $res['suk'])->where('type', 0)->value('stock');
  87. if ($product_stock < $cart_num)
  88. return self::setErrorInfo('该产品库存不足' . $cart_num);
  89. } else {
  90. if (!StoreProduct::isValidProduct($product_id))
  91. return self::setErrorInfo('该产品已下架或删除');
  92. if (!StoreProductAttr::issetProductUnique($product_id, $product_attr_unique))
  93. return self::setErrorInfo('请选择有效的产品属性');
  94. if (StoreProduct::getProductStock($product_id, $product_attr_unique) < $cart_num)
  95. return self::setErrorInfo('该产品库存不足' . $cart_num);
  96. }
  97. if ($cart = self::where('type', $type)->where('uid', $uid)->where('product_id', $product_id)->where('product_attr_unique', $product_attr_unique)->where('is_new', $is_new)->where('is_pay', 0)->where('is_del', 0)->where('combination_id', $combination_id)->where('bargain_id', $bargain_id)->where('seckill_id', $seckill_id)->where('integral_id', $integral_id)->find()) {
  98. if ($is_new)
  99. $cart->cart_num = $cart_num;
  100. else
  101. $cart->cart_num = bcadd($cart_num, $cart->cart_num, 0);
  102. $cart->add_time = time();
  103. $cart->save();
  104. return $cart;
  105. } else {
  106. $add_time = time();
  107. return self::create(compact('uid', 'product_id', 'cart_num', 'product_attr_unique', 'is_new', 'type', 'combination_id', 'add_time', 'bargain_id', 'seckill_id', 'integral_id'));
  108. }
  109. }
  110. public static function removeUserCart($uid, $ids)
  111. {
  112. return self::where('uid', $uid)->where('id', 'IN', implode(',', $ids))->update(['is_del' => 1]);
  113. }
  114. public static function getUserCartNum($uid, $type, $numType)
  115. {
  116. if ($numType) {
  117. return self::where('uid', $uid)->where('type', $type)->where('is_pay', 0)->where('is_del', 0)->where('is_new', 0)->count();
  118. } else {
  119. return self::where('uid', $uid)->where('type', $type)->where('is_pay', 0)->where('is_del', 0)->where('is_new', 0)->sum('cart_num');
  120. }
  121. }
  122. /**
  123. * TODO 修改购物车库存
  124. * @param $cartId
  125. * @param $cartNum
  126. * @param $uid
  127. * @return StoreCart|bool
  128. * @throws \think\Exception
  129. * @throws \think\db\exception\DataNotFoundException
  130. * @throws \think\db\exception\ModelNotFoundException
  131. * @throws \think\exception\DbException
  132. */
  133. public static function changeUserCartNum($cartId, $cartNum, $uid)
  134. {
  135. $count = self::where('uid', $uid)->where('id', $cartId)->count();
  136. if (!$count) return self::setErrorInfo('参数错误');
  137. $cartInfo = self::where('uid', $uid)->where('id', $cartId)->field('product_id,combination_id,seckill_id,bargain_id,product_attr_unique,cart_num')->find()->toArray();
  138. $stock = 0;
  139. if ($cartInfo['bargain_id']) {
  140. //TODO 获取砍价产品的库存
  141. $stock = 0;
  142. } else if ($cartInfo['seckill_id']) {
  143. //TODO 获取秒杀产品的库存
  144. $stock = 0;
  145. } else if ($cartInfo['combination_id']) {
  146. //TODO 获取拼团产品的库存
  147. $stock = 0;
  148. } else if ($cartInfo['product_id']) {
  149. //TODO 获取普通产品的库存
  150. $stock = StoreProduct::getProductStock($cartInfo['product_id'], $cartInfo['product_attr_unique']);
  151. }
  152. if (!$stock) return self::setErrorInfo('暂无库存');
  153. if (!$cartNum) return self::setErrorInfo('库存错误');
  154. if ($stock < $cartNum) return self::setErrorInfo('库存不足' . $cartNum);
  155. if ($cartInfo['cart_num'] == $cartNum) return true;
  156. return self::where('uid', $uid)->where('id', $cartId)->update(['cart_num' => $cartNum]);
  157. }
  158. public static function getUserProductCartList($uid, $cartIds = '', $status = 0, $store_id = 0)
  159. {
  160. $productInfoField = 'id,image,price,ot_price,vip_price,postage,give_integral,sales,stock,store_name,unit_name,is_show,is_del,is_postage,cost,is_sub,temp_id,store_type';
  161. $seckillInfoField = 'id,image,price,ot_price,postage,give_integral,sales,stock,title as store_name,unit_name,is_show,is_del,is_postage,cost,temp_id,weight,volume,start_time,stop_time,time_id';
  162. $bargainInfoField = 'id,image,min_price as price,price as ot_price,postage,give_integral,sales,stock,title as store_name,unit_name,status as is_show,is_del,is_postage,cost,temp_id,weight,volume';
  163. $combinationInfoField = 'id,image,price,postage,sales,stock,title as store_name,is_show,is_del,is_postage,cost,temp_id,weight,volume';
  164. $IntegralInfoField = 'id,image,price,integral,ot_price,postage,give_integral,sales,stock,title as store_name,unit_name,is_show,is_del,is_postage,cost,temp_id,weight,volume';
  165. $model = new self();
  166. $valid = $invalid = [];
  167. $model = $model->where('uid', $uid)->where('type', 'product')->where('is_pay', 0)
  168. ->where('is_del', 0);
  169. if (!$status) $model = $model->where('is_new', 0);
  170. if ($cartIds) $model = $model->where('id', 'IN', $cartIds);
  171. $model = $model->order('add_time DESC');
  172. $list = $model->select()->toArray();
  173. if (!count($list)) return compact('valid', 'invalid');
  174. $now = time();
  175. foreach ($list as $k => $cart) {
  176. if ($cart['seckill_id']) {
  177. $product = StoreSeckill::field($seckillInfoField)
  178. ->find($cart['seckill_id'])->toArray();
  179. } elseif ($cart['bargain_id']) {
  180. $product = StoreBargain::field($bargainInfoField)
  181. ->find($cart['bargain_id'])->toArray();
  182. } elseif ($cart['combination_id']) {
  183. $product = StoreCombination::field($combinationInfoField)
  184. ->find($cart['combination_id'])->toArray();
  185. } elseif ($cart['integral_id']) {
  186. $product = StoreIntegral::field($IntegralInfoField)
  187. ->find($cart['integral_id'])->toArray();
  188. } else {
  189. $product = StoreProduct::field($productInfoField)
  190. ->find($cart['product_id'])->toArray();
  191. }
  192. $product['image'] = set_file_url($product['image']);
  193. $cart['productInfo'] = $product;
  194. //商品不存在
  195. if (!$product) {
  196. $model->where('id', $cart['id'])->update(['is_del' => 1]);
  197. //商品删除或无库存
  198. } else if (!$product['is_show'] || $product['is_del'] || !$product['stock']) {
  199. $invalid[] = $cart;
  200. //秒杀产品未开启或者已结束
  201. } else if ($cart['seckill_id'] && ($product['start_time'] > $now || $product['stop_time'] < $now - 86400)) {
  202. $invalid[] = $product;
  203. //商品属性不对应
  204. } else if (!StoreProductAttr::issetProductUnique($cart['product_id'], $cart['product_attr_unique']) && !$cart['combination_id'] && !$cart['seckill_id'] && !$cart['bargain_id'] && !$cart['integral_id']) {
  205. $invalid[] = $cart;
  206. //正常商品
  207. } else {
  208. if ($cart['seckill_id']) {
  209. $config = SystemGroupData::get($product['time_id']);
  210. if ($config) {
  211. $arr = json_decode($config->value, true);
  212. $now_hour = date('H', time());
  213. $start_hour = $arr['time']['value'];
  214. $continued = $arr['continued']['value'];
  215. $end_hour = $start_hour + $continued;
  216. if ($start_hour > $now_hour) {
  217. //'活动未开启';
  218. $invalid[] = $cart;
  219. continue;
  220. } elseif ($end_hour < $now_hour) {
  221. //'活动已结束';
  222. $invalid[] = $cart;
  223. continue;
  224. }
  225. }
  226. }
  227. if ($cart['product_attr_unique']) {
  228. $attrInfo = StoreProductAttr::uniqueByAttrInfo($cart['product_attr_unique']);
  229. //商品没有对应的属性
  230. if (!$attrInfo || !$attrInfo['stock'])
  231. $invalid[] = $cart;
  232. else {
  233. if ($store_id) {
  234. $stock_info = SystemStoreProductStock::where('store_id', $store_id)->where('unique', $cart['product_attr_unique'])->where('product_id', $cart['productInfo']['id'])->find();
  235. if ($stock_info && $stock_info['price'] > 0) $attrInfo['price'] = $stock_info['price'];
  236. }
  237. $cart['productInfo']['attrInfo'] = $attrInfo;
  238. if ($cart['combination_id'] || $cart['seckill_id'] || $cart['bargain_id'] || $cart['integral_id']) {
  239. $cart['truePrice'] = $attrInfo['price'];
  240. $cart['vip_truePrice'] = 0;
  241. $cart['integral'] = $attrInfo['integral'];
  242. } else {
  243. $cart['truePrice'] = (float)StoreProduct::setLevelPrice($attrInfo['price'], $uid, true);
  244. $cart['vip_truePrice'] = (float)StoreProduct::setLevelPrice($attrInfo['price'], $uid);
  245. $cart['integral'] = $attrInfo['integral'];
  246. }
  247. $cart['deposit'] = $attrInfo['deposit'];
  248. $cart['trueStock'] = $attrInfo['stock'];
  249. $cart['costPrice'] = $attrInfo['cost'];
  250. $cart['productInfo']['image'] = empty($attrInfo['image']) ? $cart['productInfo']['image'] : $attrInfo['image'];
  251. $valid[] = $cart;
  252. }
  253. } else {
  254. if ($cart['combination_id'] || $cart['seckill_id'] || $cart['bargain_id'] || $cart['integral_id']) {
  255. $cart['truePrice'] = $cart['productInfo']['price'];
  256. $cart['integral'] = $cart['productInfo']['integral'] ?? 0;
  257. $cart['vip_truePrice'] = 0;
  258. if ($cart['bargain_id']) {
  259. $cart['productInfo']['attrInfo'] = StoreProductAttrValue::where('product_id', $cart['bargain_id'])->where('type', 2)->find();
  260. }
  261. $cart['productInfo']['attrInfo']['weight'] = $product['weight'];
  262. $cart['productInfo']['attrInfo']['volume'] = $product['volume'];
  263. } else {
  264. $cart['truePrice'] = (float)StoreProduct::setLevelPrice($cart['productInfo']['price'], $uid, true);
  265. $cart['vip_truePrice'] = (float)StoreProduct::setLevelPrice($cart['productInfo']['price'], $uid);
  266. $cart['integral'] = $cart['productInfo']['integral'] ?? 0;
  267. }
  268. $cart['deposit'] = $cart['productInfo']['deposit'] ?? 0;
  269. $cart['trueStock'] = $cart['productInfo']['stock'];
  270. $cart['costPrice'] = $cart['productInfo']['cost'];
  271. $valid[] = $cart;
  272. }
  273. }
  274. }
  275. foreach ($valid as $k => $cart) {
  276. if ($cart['trueStock'] < $cart['cart_num']) {
  277. $cart['cart_num'] = $cart['trueStock'];
  278. $model->where('id', $cart['id'])->update(['cart_num' => $cart['cart_num']]);
  279. $valid[$k] = $cart;
  280. }
  281. unset($valid[$k]['uid'], $valid[$k]['is_del'], $valid[$k]['is_new'], $valid[$k]['is_pay'], $valid[$k]['add_time']);
  282. if (isset($valid[$k]['productInfo'])) {
  283. unset($valid[$k]['productInfo']['is_del'], $valid[$k]['productInfo']['is_del'], $valid[$k]['productInfo']['is_show']);
  284. }
  285. }
  286. foreach ($invalid as $k => $cart) {
  287. unset($valid[$k]['uid'], $valid[$k]['is_del'], $valid[$k]['is_new'], $valid[$k]['is_pay'], $valid[$k]['add_time']);
  288. if (isset($invalid[$k]['productInfo'])) {
  289. unset($invalid[$k]['productInfo']['is_del'], $invalid[$k]['productInfo']['is_del'], $invalid[$k]['productInfo']['is_show']);
  290. }
  291. }
  292. return compact('valid', 'invalid');
  293. }
  294. /**
  295. * 拼团
  296. * @param $uid
  297. * @param string $cartIds
  298. * @return array
  299. */
  300. public static function getUserCombinationProductCartList($uid, $cartIds = '')
  301. {
  302. $productInfoField = 'id,image,slider_image,price,cost,ot_price,vip_price,postage,mer_id,give_integral,cate_id,sales,stock,store_name,unit_name,is_show,is_del,is_postage';
  303. $model = new self();
  304. $valid = $invalid = [];
  305. $model = $model->where('uid', $uid)->where('type', 'product')->where('is_pay', 0)
  306. ->where('is_del', 0);
  307. if ($cartIds) $model->where('id', 'IN', $cartIds);
  308. $list = $model->select()->toArray();
  309. if (!count($list)) return compact('valid', 'invalid');
  310. foreach ($list as $k => $cart) {
  311. $product = StoreProduct::field($productInfoField)
  312. ->find($cart['product_id'])->toArray();
  313. $cart['productInfo'] = $product;
  314. //商品不存在
  315. if (!$product) {
  316. $model->where('id', $cart['id'])->update(['is_del' => 1]);
  317. //商品删除或无库存
  318. } else if (!$product['is_show'] || $product['is_del'] || !$product['stock']) {
  319. $invalid[] = $cart;
  320. //商品属性不对应
  321. // }else if(!StoreProductAttr::issetProductUnique($cart['product_id'],$cart['product_attr_unique'])){
  322. // $invalid[] = $cart;
  323. //正常商品
  324. } else {
  325. $cart['truePrice'] = (float)StoreCombination::where('id', $cart['combination_id'])->value('price');
  326. $cart['costPrice'] = (float)StoreCombination::where('id', $cart['combination_id'])->value('cost');
  327. $cart['trueStock'] = StoreCombination::where('id', $cart['combination_id'])->value('stock');
  328. $valid[] = $cart;
  329. }
  330. }
  331. foreach ($valid as $k => $cart) {
  332. if ($cart['trueStock'] < $cart['cart_num']) {
  333. $cart['cart_num'] = $cart['trueStock'];
  334. $model->where('id', $cart['id'])->update(['cart_num' => $cart['cart_num']]);
  335. $valid[$k] = $cart;
  336. }
  337. }
  338. return compact('valid', 'invalid');
  339. }
  340. /**
  341. * 产品编号
  342. * @param array $ids
  343. * @return array
  344. */
  345. public static function getCartIdsProduct(array $ids)
  346. {
  347. return self::whereIn('id', $ids)->column('product_id', 'id');
  348. }
  349. /**
  350. * 获取购物车内最新一张产品图
  351. */
  352. public static function getProductImage(array $cart_id)
  353. {
  354. return self::whereIn('a.id', $cart_id)->alias('a')->order('a.id desc')
  355. ->join('store_product p', 'p.id = a.product_id')->value('p.image');
  356. }
  357. }