|
|
@@ -0,0 +1,974 @@
|
|
|
+<?php
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | 版权所有 2017~2021 LARAVEL研发中心
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | 官方网站: http://www.laravel.cn
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | Author: laravel开发员 <laravel.qq.com>
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+
|
|
|
+namespace App\Services\Api;
|
|
|
+
|
|
|
+use App\Models\GoodsCategoryModel;
|
|
|
+use App\Models\GoodsModel;
|
|
|
+use App\Models\GoodsSkuModel;
|
|
|
+use App\Models\OrderModel;
|
|
|
+use App\Services\BaseService;
|
|
|
+use App\Services\ConfigService;
|
|
|
+use App\Services\RedisService;
|
|
|
+use App\Services\SupplyService;
|
|
|
+use Illuminate\Support\Facades\DB;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 商品管理-服务类
|
|
|
+ * @author laravel开发员
|
|
|
+ * @since 2020/11/11
|
|
|
+ * Class GoodsService
|
|
|
+ * @package App\Services\Api
|
|
|
+ */
|
|
|
+class GoodsService extends BaseService
|
|
|
+{
|
|
|
+ // 静态对象
|
|
|
+ protected static $instance = null;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 构造函数
|
|
|
+ * @author laravel开发员
|
|
|
+ * @since 2020/11/11
|
|
|
+ * GoodsService constructor.
|
|
|
+ */
|
|
|
+ public function __construct()
|
|
|
+ {
|
|
|
+ $this->model = new GoodsModel();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 静态入口
|
|
|
+ * @return static|null
|
|
|
+ */
|
|
|
+ public static function make()
|
|
|
+ {
|
|
|
+ if (!self::$instance) {
|
|
|
+ self::$instance = (new static());
|
|
|
+ }
|
|
|
+ return self::$instance;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 商品列表
|
|
|
+ * @param $params
|
|
|
+ * @param int $pageSize
|
|
|
+ * @param int $userId
|
|
|
+ * @return array
|
|
|
+ */
|
|
|
+ public function getDataList($params, $pageSize = 12, $userId = 0)
|
|
|
+ {
|
|
|
+ $model = $this->model->with(['skuList'])->from('goods as a')
|
|
|
+ ->where(['a.status' => 1, 'a.mark' => 1])
|
|
|
+ ->where('a.retail_price', '>', 0)
|
|
|
+ ->where(function ($query) use ($params) {
|
|
|
+ $supplyType = isset($params['supply_type']) ? intval($params['supply_type']) : 0;
|
|
|
+ if ($supplyType > 0) {
|
|
|
+ $query->where('a.supply_type', $supplyType);
|
|
|
+ }
|
|
|
+
|
|
|
+ $cateId = isset($params['cate_id']) ? intval($params['cate_id']) : 0;
|
|
|
+ if ($cateId > 0) {
|
|
|
+ $subIds = GoodsCategoryModel::where(['pid' => $cateId, 'mark' => 1, 'status' => 1])->pluck('cate_id');
|
|
|
+ $query->where(function ($query) use ($cateId, $subIds) {
|
|
|
+ if ($subIds) {
|
|
|
+ $query->whereIn('a.cate_id', $subIds)
|
|
|
+ ->orWhere('a.cate_id', $cateId);
|
|
|
+ } else {
|
|
|
+ $query->where('a.cate_id', $cateId);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+
|
|
|
+ })
|
|
|
+ ->where(function ($query) use ($params) {
|
|
|
+ $keyword = isset($params['kw']) ? $params['kw'] : '';
|
|
|
+ if ($keyword) {
|
|
|
+ $query->where('a.goods_name', 'like', "%{$keyword}%")
|
|
|
+ ->orWhere('a.spu_name', 'like', "%{$keyword}%")
|
|
|
+ ->orWhere('a.tag', 'like', "%{$keyword}%");
|
|
|
+ }
|
|
|
+
|
|
|
+ })
|
|
|
+ ->select(['a.*']);
|
|
|
+
|
|
|
+ // 排序
|
|
|
+ $sortType = isset($params['sort_type']) ? $params['sort_type'] : 1;
|
|
|
+ if ($sortType == 2) {
|
|
|
+ $model = $model->orderBy('a.is_recommend', 'asc')->orderBy('a.sales', 'desc');
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ $list = $model->orderBy('a.create_time', 'desc')
|
|
|
+ ->paginate($pageSize > 0 ? $pageSize : 9999999);
|
|
|
+ $list = $list ? $list->toArray() : [];
|
|
|
+ if ($list) {
|
|
|
+ $locale = RedisService::get("caches:locale:lang_{$userId}");
|
|
|
+ $locale = $locale ? $locale : session('locale_lang');
|
|
|
+ $locale = $locale ? $locale : 'zh-cn';
|
|
|
+ $supplyList = config('goods.supplyList');
|
|
|
+ $usdtPrice = RedisService::get("caches:wallets:usdt_rate");
|
|
|
+ if ($usdtPrice <= 0) {
|
|
|
+ $usdtCnyPrice = ConfigService::make()->getConfigByCode('usdt_cny_price', 7.2);
|
|
|
+ $usdtPrice = $usdtCnyPrice > 0 && $usdtCnyPrice < 100 ? $usdtCnyPrice : 0;
|
|
|
+ }
|
|
|
+
|
|
|
+ $xdPrice = ConfigService::make()->getConfigByCode('xd_price', 100);
|
|
|
+ $xdPrice = $xdPrice > 0 && $xdPrice <= 10000 ? $xdPrice : 100;
|
|
|
+ $awardWaitRate = ConfigService::make()->getConfigByCode('shop_award_score_rate', 0);
|
|
|
+ $awardWaitRate = $awardWaitRate > 0 && $awardWaitRate < 1000 ? $awardWaitRate : 0;
|
|
|
+ $waitRate = ConfigService::make()->getConfigByCode('day_wait_score_rate', 0);
|
|
|
+ $waitRate = $waitRate > 0 && $waitRate < 100 ? $waitRate : 0;
|
|
|
+ foreach ($list['data'] as &$item) {
|
|
|
+ $item['detail_img'] = isset($item['detail_img']) && $item['detail_img'] ? json_decode($item['detail_img'], true) : [];
|
|
|
+ $item['supply_name'] = isset($supplyList[$item['supply_type']]) ? $supplyList[$item['supply_type']] : '';
|
|
|
+ $item['usdt_price'] = $usdtPrice;
|
|
|
+ $item['xd_price_rate'] = $xdPrice;
|
|
|
+ $item['retail_price1'] = $item['retail_price'];
|
|
|
+ $item['retail_price'] = $this->getRealSalePrice($item['cost_price']);
|
|
|
+ $item['wait_score'] = moneyFormat($item['retail_price'] * $awardWaitRate / 100 * $waitRate / 100, 2);
|
|
|
+ }
|
|
|
+ unset($item);
|
|
|
+ }
|
|
|
+
|
|
|
+ return [
|
|
|
+ 'total' => isset($list['total']) ? $list['total'] : 9,
|
|
|
+ 'pageSize' => $pageSize,
|
|
|
+ 'list' => isset($list['data']) ? $list['data'] : [],
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 详情
|
|
|
+ * @param $id
|
|
|
+ * @return array
|
|
|
+ */
|
|
|
+ public function getInfo($goodsId, $userId = 0, $updateView = true)
|
|
|
+ {
|
|
|
+ $field = ['a.*'];
|
|
|
+ $info = $this->model->from('goods as a')->with(['category', 'skuList'])
|
|
|
+ ->where(['a.goods_id' => $goodsId, 'a.status' => 1, 'a.mark' => 1])
|
|
|
+ ->select($field)
|
|
|
+ ->first();
|
|
|
+ $info = $info ? $info->toArray() : [];
|
|
|
+ if ($info) {
|
|
|
+ if (isset($info['main_img'])) {
|
|
|
+ $info['main_img'] = $info['main_img'] ? get_image_url($info['main_img']) : '';
|
|
|
+ }
|
|
|
+ if (isset($info['detail_img'])) {
|
|
|
+ $info['detail_img'] = $info['detail_img'] ? json_decode($info['detail_img'], true) : [];
|
|
|
+ $thumbs = [$info['main_img']];
|
|
|
+ $info['detail_img'] = $info['detail_img']? array_merge($thumbs,$info['detail_img']) : $thumbs;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (empty($info['detail_img'])) {
|
|
|
+ $info['detail_img'] = [$info['main_img']];
|
|
|
+ }
|
|
|
+
|
|
|
+ $supplyList = config('goods.supplyList');
|
|
|
+ $info['supply_name'] = isset($supplyList[$info['supply_type']]) ? $supplyList[$info['supply_type']] : '';
|
|
|
+
|
|
|
+ $usdtPrice = RedisService::get("caches:wallets:usdt_rate");
|
|
|
+ if ($usdtPrice <= 0) {
|
|
|
+ $usdtCnyPrice = ConfigService::make()->getConfigByCode('usdt_cny_price', 7.2);
|
|
|
+ $usdtPrice = $usdtCnyPrice > 0 && $usdtCnyPrice < 100 ? $usdtCnyPrice : 0;
|
|
|
+ }
|
|
|
+ $xdPrice = ConfigService::make()->getConfigByCode('xd_price', 100);
|
|
|
+ $xdPrice = $xdPrice > 0 && $xdPrice <= 10000 ? $xdPrice : 100;
|
|
|
+ $info['usdt_price_rate'] = $usdtPrice;
|
|
|
+ $info['xd_price'] = $xdPrice;
|
|
|
+ $info['custom_uid'] = ConfigService::make()->getConfigByCode('xl_custom_id', 100001);
|
|
|
+ $awardWaitRate = ConfigService::make()->getConfigByCode('shop_award_score_rate', 0);
|
|
|
+ $awardWaitRate = $awardWaitRate > 0 && $awardWaitRate < 1000 ? $awardWaitRate : 0;
|
|
|
+ $waitRate = ConfigService::make()->getConfigByCode('day_wait_score_rate', 0);
|
|
|
+ $waitRate = $waitRate > 0 && $waitRate < 100 ? $waitRate : 0;
|
|
|
+ if (isset($info['retail_price']) && $info['retail_price']) {
|
|
|
+ $info['retail_price1'] = $info['retail_price'];
|
|
|
+ $info['retail_price'] = $this->getRealSalePrice($info['cost_price']);
|
|
|
+ $info['wait_score'] = moneyFormat($info['retail_price'] * $awardWaitRate / 100 * $waitRate / 100, 2);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (isset($info['sku_list']) && $info['sku_list']) {
|
|
|
+ foreach ($info['sku_list'] as &$v) {
|
|
|
+ $v['detail_img'] = $v['detail_img'] ? json_decode($v['detail_img'], true) : [];
|
|
|
+ $v['attr'] = $v['attr'] ? json_decode($v['attr'], true) : [];
|
|
|
+ $v['main_img'] = $v['main_img'] ? get_image_url($v['main_img']) : '';
|
|
|
+ $v['retail_price_1'] = $v['retail_price'];
|
|
|
+ $v['retail_price'] = $this->getRealSalePrice($v['plat_price']);
|
|
|
+ $v['wait_score'] = moneyFormat($v['retail_price'] * $awardWaitRate / 100 * $waitRate / 100, 2);
|
|
|
+ }
|
|
|
+ unset($v);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 更新访问量
|
|
|
+ if ($updateView) {
|
|
|
+ $this->updateView($userId, $goodsId);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return $info;
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 实际售价
|
|
|
+ * @param $price 成本价或其他价格
|
|
|
+ * @param bool $float 是否浮动转换,1-浮动转换,2-不浮动转换,3-浮动不转换
|
|
|
+ * @return string
|
|
|
+ */
|
|
|
+ public function getRealSalePrice($price, $float = 1)
|
|
|
+ {
|
|
|
+ $usdtPrice = RedisService::get("caches:wallets:usdt_rate");
|
|
|
+ if ($usdtPrice <= 0) {
|
|
|
+ $usdtCnyPrice = ConfigService::make()->getConfigByCode('usdt_cny_price', 7.2);
|
|
|
+ $usdtPrice = $usdtCnyPrice > 0 && $usdtCnyPrice < 100 ? $usdtCnyPrice : 0;
|
|
|
+ }
|
|
|
+ $xdPrice = ConfigService::make()->getConfigByCode('xd_price', 100);
|
|
|
+ $xdPrice = $xdPrice > 0 && $xdPrice <= 10000 ? $xdPrice : 100;
|
|
|
+ $floatRate = ConfigService::make()->getConfigByCode('goods_price_float_rate', 0);
|
|
|
+ $floatRate = $floatRate > 0 && $floatRate < 100 ? $floatRate : 0;
|
|
|
+ $price = $float == 2 ? $price : floatval($price * (1 + ($floatRate / 100)));
|
|
|
+ if ($float == 3) {
|
|
|
+ return $price;
|
|
|
+ }
|
|
|
+ return $usdtPrice > 0 ? moneyFormat($price / $usdtPrice * $xdPrice, 2) : $price;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取要购买或结算的商品列表
|
|
|
+ * @param $userId
|
|
|
+ * @param array $params
|
|
|
+ * @return array|false|\Illuminate\Database\Eloquent\Builder[]|\Illuminate\Database\Eloquent\Collection
|
|
|
+ */
|
|
|
+ public function getBuyList($userId, $params = [])
|
|
|
+ {
|
|
|
+ $goodsId = isset($params['goods_id']) ? $params['goods_id'] : 0;
|
|
|
+ $skuId = isset($params['sku_id']) ? $params['sku_id'] : 0;
|
|
|
+ $num = isset($params['num']) ? $params['num'] : 0;
|
|
|
+ $cartIds = isset($params['cart_ids']) ? $params['cart_ids'] : '';
|
|
|
+ $cartIds = $cartIds ? explode('|', $cartIds) : [];
|
|
|
+ if (empty($goodsId) && empty($cartIds)) {
|
|
|
+ $this->error = 2901;
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($goodsId && (empty($skuId) || $num <= 0)) {
|
|
|
+ $this->error = 2901;
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ $cacheKey = "caches:goods:buyList:{$userId}_" . md5(json_encode($params, 256));
|
|
|
+ $datas = RedisService::get($cacheKey);
|
|
|
+ if ($datas) {
|
|
|
+ return $datas;
|
|
|
+ }
|
|
|
+
|
|
|
+ $goods = [];
|
|
|
+ $skuList = [];
|
|
|
+ $usdtPrice = RedisService::get("caches:wallets:usdt_rate");
|
|
|
+ if ($usdtPrice <= 0) {
|
|
|
+ $usdtCnyPrice = ConfigService::make()->getConfigByCode('usdt_cny_price', 7.2);
|
|
|
+ $usdtPrice = $usdtCnyPrice > 0 && $usdtCnyPrice < 100 ? $usdtCnyPrice : 0;
|
|
|
+ }
|
|
|
+ $xdPrice = ConfigService::make()->getConfigByCode('xd_price', 100);
|
|
|
+ $xdPrice = $xdPrice > 0 && $xdPrice <= 10000 ? $xdPrice : 100;
|
|
|
+
|
|
|
+ if ($goodsId) {
|
|
|
+ $info = $this->getInfo($goodsId, $userId, false);
|
|
|
+ if ($info) {
|
|
|
+
|
|
|
+ $info['num'] = $num;
|
|
|
+ $info['sku_id'] = $skuId;
|
|
|
+ $skuInfo = GoodsSkuModel::where(['goods_id' => $goodsId, 'sku_id' => $skuId, 'mark' => 1])->first();
|
|
|
+ $price = isset($skuInfo['plat_price']) ? $skuInfo['plat_price'] : 0;
|
|
|
+ if ($price) {
|
|
|
+ $info['retail_price1'] = $info['retail_price'];
|
|
|
+ $info['retail_price'] = $this->getRealSalePrice($price);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (isset($skuInfo['attr']) && $skuInfo['attr']) {
|
|
|
+ $skuInfo['attr'] = json_decode($skuInfo['attr'], true);
|
|
|
+ }
|
|
|
+
|
|
|
+ $skuList[$goodsId] = [
|
|
|
+ 'sku_id' => $skuId,
|
|
|
+ 'num' => $num
|
|
|
+ ];
|
|
|
+ $info['sku'] = $skuInfo;
|
|
|
+ $goods[] = $info;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ $goods = CartsModel::with(['sku'])->from('carts as a')
|
|
|
+ ->leftJoin('goods as b', 'b.goods_id', '=', 'a.goods_id')
|
|
|
+ ->leftJoin('goods_sku as c', 'c.sku_id', '=', 'a.sku_id')
|
|
|
+ ->whereIn('a.id', $cartIds)
|
|
|
+ ->where(['a.status' => 1, 'a.mark' => 1, 'b.status' => 1, 'b.mark' => 1])
|
|
|
+ ->where('b.retail_price', '>', 0)
|
|
|
+ ->where('a.num', '>', 0)
|
|
|
+ ->select(['b.goods_id', 'b.merch_id', 'b.goods_name', 'b.supply_type', 'b.main_img', 'b.cost_price', 'b.retail_price', 'b.limit_num', 'b.lowest_num', 'b.brand_name', 'a.num', 'a.sku_id'])
|
|
|
+ ->get();
|
|
|
+ if ($goods) {
|
|
|
+
|
|
|
+ // 价格等参数格式化
|
|
|
+ $locale = RedisService::get("caches:locale:lang_{$userId}");
|
|
|
+ $locale = $locale ? $locale : session('locale_lang');
|
|
|
+ $locale = $locale ? $locale : 'zh-cn';
|
|
|
+ $supplyList = config('goods.supplyList');
|
|
|
+
|
|
|
+ foreach ($goods as &$item) {
|
|
|
+ $item['detail_img'] = isset($item['detail_img']) && $item['detail_img'] ? json_decode($item['detail_img'], true) : [];
|
|
|
+ $item['supply_name'] = isset($supplyList[$item['supply_type']]) ? $supplyList[$item['supply_type']] : '';
|
|
|
+ $item['usdt_price'] = $usdtPrice;
|
|
|
+ $item['xd_price_rate'] = $xdPrice;
|
|
|
+ $item['retail_price1'] = $item['retail_price'];
|
|
|
+ $skuInfo = isset($item['sku']) ? $item['sku'] : [];
|
|
|
+ if (isset($skuInfo['attr']) && $skuInfo['attr']) {
|
|
|
+ $skuInfo['attr'] = json_decode($skuInfo['attr'], true);
|
|
|
+ }
|
|
|
+ $item['sku'] = $skuInfo;
|
|
|
+ $price = isset($skuInfo['plat_price']) ? $skuInfo['plat_price'] : 0;
|
|
|
+ if ($price) {
|
|
|
+ $item['retail_price'] = $this->getRealSalePrice($price);
|
|
|
+ } else {
|
|
|
+ $item['retail_price'] = $this->getRealSalePrice($item['cost_price']);
|
|
|
+ }
|
|
|
+ $skuList[$item['goods_id']] = [
|
|
|
+ 'sku_id' => $item['sku_id'],
|
|
|
+ 'num' => $item['num']
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ unset($item);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if (empty($goods)) {
|
|
|
+ $this->error = 2901;
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ RedisService::set($cacheKey, ['sku_list' => array_values($skuList), 'goods' => $goods], rand(2, 3));
|
|
|
+ return ['sku_list' => array_values($skuList), 'goods' => $goods];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 订单商品
|
|
|
+ * @param $userId
|
|
|
+ * @param $ids
|
|
|
+ * @return array
|
|
|
+ */
|
|
|
+ public function getOrderGoods($userId, $ids)
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:goodsOrder:{$userId}_" . md5(json_encode($ids, 256));
|
|
|
+ $datas = RedisService::get($cacheKey);
|
|
|
+ if ($datas) {
|
|
|
+ return $datas;
|
|
|
+ }
|
|
|
+
|
|
|
+ $goods = $this->model->from('goods as a')
|
|
|
+ ->whereIn('a.goods_id', $ids)
|
|
|
+ ->where(['a.status' => 1, 'a.mark' => 1])
|
|
|
+ ->where('a.retail_price', '>', 0)
|
|
|
+ ->select(['a.goods_id', 'a.merch_id', 'a.goods_name', 'a.cate_id', 'a.supply_type', 'a.main_img', 'a.cost_price', 'a.retail_price'])
|
|
|
+ ->get();
|
|
|
+ $goods = $goods ? $goods->toArray() : [];
|
|
|
+ if ($goods) {
|
|
|
+ RedisService::set($cacheKey, $goods, rand(5, 10));
|
|
|
+ }
|
|
|
+ return $goods;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 添加/更新购物车
|
|
|
+ * @param $userId
|
|
|
+ * @param $goodsId
|
|
|
+ * @param $params
|
|
|
+ * @return array|false
|
|
|
+ */
|
|
|
+ public function updateCart($userId, $goodsId, $params)
|
|
|
+ {
|
|
|
+ $skuId = isset($params['sku_id']) ? $params['sku_id'] : 0;
|
|
|
+ $status = isset($params['status']) ? $params['status'] : 0;
|
|
|
+ $merchId = isset($params['merch_id']) ? $params['merch_id'] : 0;
|
|
|
+ $num = isset($params['num']) ? $params['num'] : 1;
|
|
|
+ if ($skuId <= 0 || $goodsId <= 0 || $userId <= 0 || $num <= 0) {
|
|
|
+ $this->error = 2014;
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (CartsModel::where(['user_id' => $userId, 'status' => 1, 'mark' => 1])->count('id') > 20) {
|
|
|
+ $this->error = 1050;
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ $cartId = CartsModel::where(['user_id' => $userId, 'goods_id' => $goodsId, 'sku_id' => $skuId])->value('id');
|
|
|
+ if ($cartId) {
|
|
|
+ CartsModel::where(['id' => $cartId])->update(['num' => $num, 'merch_id' => $merchId, 'status' => $status, 'mark' => 1, 'update_time' => time()]);
|
|
|
+ RedisService::clear("caches:members:cartList:{$userId}");
|
|
|
+ $count = $this->getCartCount($userId, true);
|
|
|
+ return ['id' => $cartId, 'count' => $count];
|
|
|
+ } else {
|
|
|
+ $cartId = CartsModel::insertGetId(['user_id' => $userId, 'goods_id' => $goodsId, 'merch_id' => $merchId, 'sku_id' => $skuId, 'num' => $num, 'status' => $status, 'mark' => 1, 'create_time' => time()]);
|
|
|
+ RedisService::clear("caches:members:cartList:{$userId}");
|
|
|
+ $count = $this->getCartCount($userId, true);
|
|
|
+ return ['id' => $cartId, 'count' => $count];
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 删除购物车商品
|
|
|
+ * @param $userId
|
|
|
+ * @param $params
|
|
|
+ * @return bool
|
|
|
+ */
|
|
|
+ public function deleteCart($userId, $params)
|
|
|
+ {
|
|
|
+ $ids = isset($params['ids']) ? $params['ids'] : [];
|
|
|
+ if (empty($ids)) {
|
|
|
+ $this->error = 2923;
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ CartsModel::whereIn('id', $ids)->update(['status' => 2, 'update_time' => time()]);
|
|
|
+ $this->error = 1002;
|
|
|
+ RedisService::clear("caches:members:cartCount:{$userId}");
|
|
|
+ RedisService::clear("caches:members:cartList:{$userId}");
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 购物车列表
|
|
|
+ * @param $userId
|
|
|
+ * @param int $pageSize
|
|
|
+ * @return array|\Illuminate\Database\Eloquent\Builder[]|\Illuminate\Database\Eloquent\Collection|mixed
|
|
|
+ */
|
|
|
+ public function getCartList($userId, $pageSize = 30)
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:members:cartList:{$userId}";
|
|
|
+ $cacheCountKey = "caches:members:cartCount:{$userId}";
|
|
|
+ $datas = RedisService::get($cacheKey);
|
|
|
+ if ($datas) {
|
|
|
+ return $datas;
|
|
|
+ }
|
|
|
+
|
|
|
+ $datas = CartsModel::with(['sku'])->from('carts as a')
|
|
|
+ ->leftJoin('goods as b', 'b.goods_id', '=', 'a.goods_id')
|
|
|
+ ->leftJoin('goods_sku as c', 'c.sku_id', '=', 'a.sku_id')
|
|
|
+ ->where(['a.status' => 1, 'a.mark' => 1, 'b.status' => 1, 'b.mark' => 1])
|
|
|
+ ->where('b.cost_price', '>', 0)
|
|
|
+ ->where('a.num', '>', 0)
|
|
|
+ ->where('a.user_id', '=', $userId)
|
|
|
+ ->select(['a.id as cart_id', 'b.goods_id', 'b.merch_id', 'b.goods_name', 'b.supply_type', 'b.main_img', 'b.cost_price', 'b.retail_price', 'b.limit_num', 'b.lowest_num', 'b.brand_name', 'a.num', 'a.sku_id'])
|
|
|
+ ->orderBy('a.create_time', 'desc')
|
|
|
+ ->limit($pageSize)
|
|
|
+ ->get();
|
|
|
+ $datas = $datas ? $datas->toArray() : [];
|
|
|
+ if ($datas) {
|
|
|
+
|
|
|
+ // 价格等参数格式化
|
|
|
+ $locale = RedisService::get("caches:locale:lang_{$userId}");
|
|
|
+ $locale = $locale ? $locale : session('locale_lang');
|
|
|
+ $locale = $locale ? $locale : 'zh-cn';
|
|
|
+ $supplyList = config('goods.supplyList');
|
|
|
+
|
|
|
+ $usdtPrice = RedisService::get("caches:wallets:usdt_rate");
|
|
|
+ if ($usdtPrice <= 0) {
|
|
|
+ $usdtCnyPrice = ConfigService::make()->getConfigByCode('usdt_cny_price', 7.2);
|
|
|
+ $usdtPrice = $usdtCnyPrice > 0 && $usdtCnyPrice < 100 ? $usdtCnyPrice : 0;
|
|
|
+ }
|
|
|
+ $xdPrice = ConfigService::make()->getConfigByCode('xd_price', 100);
|
|
|
+ $xdPrice = $xdPrice > 0 && $xdPrice <= 10000 ? $xdPrice : 100;
|
|
|
+
|
|
|
+ foreach ($datas as &$item) {
|
|
|
+ $item['detail_img'] = isset($item['detail_img']) && $item['detail_img'] ? json_decode($item['detail_img'], true) : [];
|
|
|
+ $item['supply_name'] = isset($supplyList[$item['supply_type']]) ? $supplyList[$item['supply_type']] : '';
|
|
|
+ $item['usdt_price'] = $usdtPrice;
|
|
|
+ $item['xd_price_rate'] = $xdPrice;
|
|
|
+ $item['retail_price1'] = $item['retail_price'];
|
|
|
+ $skuInfo = isset($item['sku']) ? $item['sku'] : [];
|
|
|
+ $skuInfo['attr'] = isset($skuInfo['attr']) && $skuInfo['attr'] ? json_decode($skuInfo['attr'], true) : [];
|
|
|
+ $item['sku'] = $skuInfo;
|
|
|
+ $price = isset($skuInfo['plat_price']) ? $skuInfo['plat_price'] : 0;
|
|
|
+ if ($price) {
|
|
|
+ $item['retail_price'] = $this->getRealSalePrice($price);
|
|
|
+ } else {
|
|
|
+ $item['retail_price'] = $this->getRealSalePrice($item['cost_price']);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ unset($item);
|
|
|
+
|
|
|
+ RedisService::set($cacheCountKey, count($datas), rand(300, 600));
|
|
|
+ RedisService::set($cacheKey, $datas, rand(300, 600));
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ return $datas;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 购物车中数量
|
|
|
+ * @param $userId
|
|
|
+ * @return array|mixed
|
|
|
+ */
|
|
|
+ public function getCartCount($userId, $refresh = false)
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:member:cartCount:{$userId}";
|
|
|
+ $data = RedisService::get($cacheKey);
|
|
|
+ if ($data > 0 && !$refresh) {
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ $data = CartsModel::from('carts as a')
|
|
|
+ ->leftJoin('goods as b', 'b.goods_id', '=', 'a.goods_id')
|
|
|
+ ->where(['a.status' => 1, 'a.mark' => 1, 'b.status' => 1, 'b.mark' => 1])
|
|
|
+ ->where('a.num', '>', 0)
|
|
|
+ ->where('b.cost_price', '>', 0)
|
|
|
+ ->where('a.user_id',$userId)
|
|
|
+ ->count('a.id');
|
|
|
+ if ($data) {
|
|
|
+ RedisService::set($cacheKey, $data, rand(300, 600));
|
|
|
+ }
|
|
|
+
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 运费
|
|
|
+ */
|
|
|
+ public function getFreight($userId, $addressId, $skuList)
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:goods:freight:{$userId}_{$addressId}_" . md5(json_encode($skuList, 256));
|
|
|
+ $data = RedisService::get($cacheKey);
|
|
|
+ if ($data) {
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (empty($addressId)) {
|
|
|
+ $address = MemberAddressService::make()->getBindInfo($userId);
|
|
|
+ $streetCode = isset($address['street_code']) ? $address['street_code'] : '';
|
|
|
+ $addressId = $streetCode ? $streetCode : (isset($address['district_code']) ? $address['district_code'] : '');
|
|
|
+ }
|
|
|
+
|
|
|
+ $result = SupplyService::make()->getApiData('getFreight', ['address_id' => intval($addressId), 'sku_list' => $skuList]);
|
|
|
+ $freight = isset($result['freight']) ? floatval($result['freight']) : -1;
|
|
|
+ if ($freight >= 0) {
|
|
|
+ // 价格参数
|
|
|
+ $usdtPrice = RedisService::get("caches:wallets:usdt_rate");
|
|
|
+ if ($usdtPrice <= 0) {
|
|
|
+ $usdtCnyPrice = ConfigService::make()->getConfigByCode('usdt_cny_price', 7.2);
|
|
|
+ $usdtPrice = $usdtCnyPrice > 0 && $usdtCnyPrice < 100 ? $usdtCnyPrice : 0;
|
|
|
+ }
|
|
|
+ $xdPrice = ConfigService::make()->getConfigByCode('xd_price', 100);
|
|
|
+ $xdPrice = $xdPrice > 0 && $xdPrice <= 10000 ? $xdPrice : 100;
|
|
|
+
|
|
|
+ $xdFreight = $freight ? moneyFormat($freight / $usdtPrice * $xdPrice, 2) : 0;
|
|
|
+ RedisService::set($cacheKey, ['freight' => $xdFreight, 'fee' => $freight], rand(5, 10));
|
|
|
+ return ['freight' => $xdFreight, 'fee' => $freight];
|
|
|
+ } else {
|
|
|
+ $errorCode = SupplyService::make()->getError();
|
|
|
+ $this->error = $errorCode ? $errorCode : 1052;
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public function getSkuInfo($sakuId)
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:goodsSku:{$sakuId}";
|
|
|
+ $data = RedisService::get($cacheKey);
|
|
|
+ if ($data) {
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ $data = GoodsSkuModel::where(['sku_id' => $sakuId, 'status' => 1, 'mark' => 1])
|
|
|
+ ->select(['id', 'sku_id', 'goods_id', 'retail_price', 'plat_price', 'sku_sn', 'sku_name', 'main_img', 'attr'])
|
|
|
+ ->first();
|
|
|
+ $data = $data ? $data->toArray() : [];
|
|
|
+ if ($data) {
|
|
|
+ RedisService::set($cacheKey, $data, rand(3, 5));
|
|
|
+ }
|
|
|
+
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 更新浏览量
|
|
|
+ * @param $userId
|
|
|
+ * @param $dynamicId
|
|
|
+ * @return array|mixed
|
|
|
+ */
|
|
|
+ public function updateView($userId, $id)
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:goods:views:u{$userId}_d{$id}";
|
|
|
+ $data = RedisService::get($cacheKey);
|
|
|
+ if ($data) {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ $data = $this->model->where(['goods_id' => $id])->update(['views' => DB::raw('views + 1'), 'update_time' => time()]);
|
|
|
+ RedisService::set($cacheKey, $id, rand(1, 3) * 7200);
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 更新商品SKU数据到本地
|
|
|
+ * @param int $pageSize
|
|
|
+ * @param $params 参数
|
|
|
+ * @return array|false
|
|
|
+ */
|
|
|
+ public function updateGoodsSku($pageSize = 100, $params = [])
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:supply:goods_sku_update_{$pageSize}";
|
|
|
+ if (RedisService::get($cacheKey)) {
|
|
|
+ $this->error = 1047;
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ $page = RedisService::get($cacheKey . '_page');
|
|
|
+ $page = $page ? $page + 1 : 1;
|
|
|
+ $lastDate = GoodsSkuModel::where(['mark' => 1])->orderBy('last_update_at', 'desc')->value('last_update_at');
|
|
|
+ $params = [
|
|
|
+ 'limit' => $pageSize > 0 ? $pageSize : 50,
|
|
|
+ 'page' => $page,
|
|
|
+ 'date' => $lastDate ? $lastDate : '', // 开始时间
|
|
|
+ ];
|
|
|
+ $goods = [];
|
|
|
+ $updated = 0;
|
|
|
+ $error = 0;
|
|
|
+ $datas = SupplyService::make()->getApiData('getSkuUpdate', $params);
|
|
|
+ if ($datas && $datas['list']) {
|
|
|
+ foreach ($datas['list'] as &$item) {
|
|
|
+ $goodsId = isset($item['goods_id']) ? $item['goods_id'] : 0;
|
|
|
+ $goodsSkuSn = isset($item['sku_sn']) ? $item['sku_sn'] : '';
|
|
|
+ $changeType = isset($item['change_type']) ? $item['change_type'] : '';
|
|
|
+ if ($goodsId && $goodsSkuSn && $changeType) {
|
|
|
+
|
|
|
+ $skuInfo = SupplyService::make()->getApiData('getSkuDetail', ['sku_sn' => $goodsSkuSn]);
|
|
|
+ if ($skuInfo) {
|
|
|
+ $updateData = ['goods_id' => $goodsId, 'sku_sn' => $goodsSkuSn, 'remark' => 'SKU更新', 'update_time' => time(), 'mark' => 1, 'last_update_at' => $item['update_time']];
|
|
|
+ if (isset($skuInfo['sku_name']) && $skuInfo['sku_name']) {
|
|
|
+ $updateData['sku_name'] = $skuInfo['sku_name'];
|
|
|
+ }
|
|
|
+ if (isset($skuInfo['main_img']) && $skuInfo['main_img']) {
|
|
|
+ $updateData['main_img'] = $skuInfo['main_img'];
|
|
|
+ }
|
|
|
+ if (isset($skuInfo['spu_sn']) && $skuInfo['spu_sn']) {
|
|
|
+ $updateData['spu_sn'] = $skuInfo['spu_sn'];
|
|
|
+ }
|
|
|
+ if (isset($skuInfo['sku_id']) && $skuInfo['sku_id']) {
|
|
|
+ $updateData['sku_id'] = intval($skuInfo['sku_id']);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (isset($skuInfo['status']) && $skuInfo['status']) {
|
|
|
+ $updateData['status'] = intval($skuInfo['status']);
|
|
|
+ }
|
|
|
+ if (isset($skuInfo['retail_price']) && $skuInfo['retail_price']) {
|
|
|
+ $updateData['retail_price'] = floatval($skuInfo['retail_price']);
|
|
|
+ }
|
|
|
+ if (isset($skuInfo['plat_price']) && $skuInfo['plat_price']) {
|
|
|
+ $updateData['plat_price'] = floatval($skuInfo['plat_price']);
|
|
|
+ }
|
|
|
+ if (isset($skuInfo['detail_img']) && $skuInfo['detail_img']) {
|
|
|
+ $updateData['detail_img'] = json_encode($skuInfo['detail_img'], 256);
|
|
|
+ }
|
|
|
+ if (isset($skuInfo['attr']) && $skuInfo['attr']) {
|
|
|
+ $updateData['attr'] = json_encode($skuInfo['attr'], 256);
|
|
|
+ }
|
|
|
+
|
|
|
+ if(isset($skuInfo['status'])){
|
|
|
+ $updateGoodsData = ['update_time'=>time()];
|
|
|
+ // 下架
|
|
|
+ if($skuInfo['status'] == 0){
|
|
|
+ $updateGoodsData['status'] = 0;
|
|
|
+ }
|
|
|
+ // 删除
|
|
|
+ else if(in_array(intval($skuInfo['status']),[2,3])){
|
|
|
+ $updateGoodsData['status'] = 3;
|
|
|
+ $updateGoodsData['mark'] = 0;
|
|
|
+ }else if($skuInfo['status'] == 1){
|
|
|
+ $updateGoodsData['status'] = 1;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 更新商品状态
|
|
|
+ GoodsModel::where(['goods_id' => $goodsId])->update($updateGoodsData);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 更新商品SKU信息
|
|
|
+ if (GoodsSkuModel::where(['goods_id' => $goodsId])->value('id')) {
|
|
|
+ GoodsSkuModel::where(['goods_id' => $goodsId, 'mark' => 1])->update($updateData);
|
|
|
+ $updated++;
|
|
|
+ } else {
|
|
|
+ $error++;
|
|
|
+ }
|
|
|
+
|
|
|
+ } else {
|
|
|
+ $error++;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ $error++;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ unset($item);
|
|
|
+ RedisService::set($cacheKey . '_page', $page, rand(300, 600));
|
|
|
+ } else {
|
|
|
+ RedisService::set($cacheKey . '_page', 0, rand(300, 600));
|
|
|
+ }
|
|
|
+
|
|
|
+ return ['count' => count($goods), 'updated' => $updated, 'errorCount' => $error, 'page' => $page];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 更新商品
|
|
|
+ * @param int $pageSize
|
|
|
+ * @param $params 参数
|
|
|
+ * @return array|false
|
|
|
+ */
|
|
|
+ public function updateGoods($pageSize = 0, $params = [])
|
|
|
+ {
|
|
|
+ set_time_limit(0);
|
|
|
+ $cateId = isset($params['cate_id']) ? $params['cate_id'] : 0;
|
|
|
+ $cacheKey = "caches:supply:goods_list_update_{$pageSize}_{$cateId}";
|
|
|
+ if (RedisService::get($cacheKey)) {
|
|
|
+ $this->error = 1047;
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ $size = ConfigService::make()->getConfigByCode('goods_update_limit', 0);
|
|
|
+ $pageSize = $pageSize? $pageSize : ($size > 10 && $size <= 5000 ? $size : 500);
|
|
|
+ $page = RedisService::get($cacheKey . '_page');
|
|
|
+ $page = $page ? $page + 1 : 1;
|
|
|
+// $lastTime = $this->model->where(['mark' => 1])->orderBy('create_time', 'desc')->value('create_time');
|
|
|
+// $lastTime = $lastTime? date('Y-m-d H:i:s', strtotime($lastTime)) : '';
|
|
|
+// $lastTime = date('Y-m-d H:i:s', time() - 60 * 86400);
|
|
|
+ $lastTime = '';
|
|
|
+ $params = [
|
|
|
+ 'limit' => $pageSize > 0 ? $pageSize : 50,
|
|
|
+ 'page' => $page,
|
|
|
+ 'status' => isset($params['status']) ? $params['status'] : 1, // 状态:0-全部,1-上架的,2-下架的
|
|
|
+ 'supply_type' => isset($params['supply_type']) ? $params['supply_type'] : 0, // 渠道商
|
|
|
+ 'title' => isset($params['title']) ? $params['title'] : '', // 标题关键词
|
|
|
+ 'cate_id' => isset($params['cate_id']) ? $params['cate_id'] : '', // 分类ID
|
|
|
+ 'begin_time' => $lastTime ? $lastTime : '', // 开始时间
|
|
|
+ ];
|
|
|
+ $goods = [];
|
|
|
+ $skus = [];
|
|
|
+ $updated = 0;
|
|
|
+ $error = 0;
|
|
|
+ $infoError = 0;
|
|
|
+ $datas = SupplyService::make()->getApiData('getGoodsList', $params);
|
|
|
+ if ($datas && $datas['list']) {
|
|
|
+ foreach ($datas['list'] as &$item) {
|
|
|
+ $goodsId = isset($item['goods_id']) ? $item['goods_id'] : 0;
|
|
|
+ if ($goodsId && !$this->checkGoods($goodsId)) {
|
|
|
+
|
|
|
+ $info = $this->getApiInfo($goodsId);
|
|
|
+ if ($info) {
|
|
|
+ $skuList = isset($info['sku_list']) ? $info['sku_list'] : [];
|
|
|
+ $goods[] = [
|
|
|
+ 'goods_id' => $goodsId,
|
|
|
+ 'supply_type' => isset($item['supply_type']) ? $item['supply_type'] : 0,
|
|
|
+ 'spu_sn' => isset($item['spu_sn']) ? $item['spu_sn'] : '',
|
|
|
+ 'spu_name' => isset($info['spu_name']) ? $info['spu_name'] : '',
|
|
|
+ 'main_img' => isset($info['main_img']) ? $info['main_img'] : '',
|
|
|
+ 'detail_img' => isset($info['detail_img']) ? json_encode($info['detail_img'], 256) : '',
|
|
|
+ 'goods_name' => isset($item['goods_name']) ? $item['goods_name'] : '',
|
|
|
+ 'brand_name' => isset($info['brand_name']) ? $info['brand_name'] : '',
|
|
|
+ 'limit_num' => isset($info['limit_num']) ? intval($info['limit_num']) : 0,
|
|
|
+ 'lowest_num' => isset($info['lowest_num']) ? intval($info['lowest_num']) : 1,
|
|
|
+ 'cost_price' => isset($info['cost_price']) ? floatval($info['cost_price']) : 0,
|
|
|
+ 'retail_price' => isset($info['retail_price']) ? floatval($info['retail_price']) : 0,
|
|
|
+ 'profit' => isset($info['profit']) ? floatval($info['profit']) : 0,
|
|
|
+ 'sku_list' => $skuList ? json_encode($skuList, 256) : '',
|
|
|
+ 'sku_total' => isset($info['sku_total']) ? intval($info['sku_total']) : 0,
|
|
|
+ 'tag' => isset($item['tag']) ? json_encode($item['tag'], 256) : '',
|
|
|
+ 'status' => isset($info['status']) ? intval($info['status']) : 1,
|
|
|
+ 'cate_id' => isset($item['cate_id']) ? intval($item['cate_id']) : 0,
|
|
|
+ 'last_update_at' => isset($info['update_time']) ? $info['update_time'] : (isset($item['time']) && $item['time'] ? $item['time'] : date('Y-m-d H:i:s')),
|
|
|
+ 'create_time' => time(),
|
|
|
+ ];
|
|
|
+
|
|
|
+ foreach ($skuList as $v) {
|
|
|
+ $skus[] = [
|
|
|
+ 'sku_id' => isset($v['sku_id']) ? $v['sku_id'] : 0,
|
|
|
+ 'goods_id' => $goodsId,
|
|
|
+ 'spu_sn' => isset($v['spu_sn']) ? $v['spu_sn'] : '',
|
|
|
+ 'sku_sn' => isset($v['sku_sn']) ? $v['sku_sn'] : '',
|
|
|
+ 'sku_name' => isset($v['sku_name']) ? $v['sku_name'] : '',
|
|
|
+ 'main_img' => isset($v['main_img']) ? $v['main_img'] : '',
|
|
|
+ 'status' => isset($v['status']) ? $v['status'] : 1,
|
|
|
+ 'source_type' => isset($v['source_type']) ? $v['source_type'] : 0,
|
|
|
+ 'retail_price' => isset($v['retail_price']) ? floatval($v['retail_price']) : 0,
|
|
|
+ 'plat_price' => isset($v['plat_price']) ? floatval($v['plat_price']) : 0,
|
|
|
+ 'profit' => isset($v['profit']) ? floatval($v['profit']) : 0,
|
|
|
+ 'last_update_at' => isset($v['update_time']) ? $v['update_time'] : date('Y-m-d H:i:s'),
|
|
|
+ 'detail_img' => isset($v['detail_img']) ? json_encode($v['detail_img'], 256) : '',
|
|
|
+ 'attr' => isset($v['attr']) ? json_encode($v['attr'], 256) : '',
|
|
|
+ 'remark' => 'SKU同步创建',
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+ $updated++;
|
|
|
+ } else {
|
|
|
+ $infoError++;
|
|
|
+ }
|
|
|
+
|
|
|
+ } else {
|
|
|
+ $error++;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ unset($item);
|
|
|
+ } else {
|
|
|
+ RedisService::set($cacheKey . '_page', 0, rand(300, 600));
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($goods) {
|
|
|
+ RedisService::set($cacheKey . '_page', $page, rand(300, 600));
|
|
|
+ RedisService::set($cacheKey, $goods, rand(5, 10));
|
|
|
+ DB::beginTransaction();
|
|
|
+ try {
|
|
|
+ $this->model->insertAll($goods);
|
|
|
+ if ($skus) {
|
|
|
+ GoodsSkuModel::insert($skus);
|
|
|
+ }
|
|
|
+
|
|
|
+ DB::commit();
|
|
|
+ } catch (\Exception $exception) {
|
|
|
+ RedisService::clear($cacheKey);
|
|
|
+ DB::rollBack();
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ return ['total'=>isset($datas['list'])? count($datas['list']) : 0,'all'=>isset($datas['total'])?$datas['total']:0,'count' => count($goods), 'updated' => $updated, 'errorCount' => $error,'info_error'=>$infoError, 'page' => $page];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 更新商品分类
|
|
|
+ * @param int $pid 上级ID
|
|
|
+ * @param int $pageSize
|
|
|
+ * @param $params 参数
|
|
|
+ * @return array|false
|
|
|
+ */
|
|
|
+ public function updateGoodsCategory($pid = 0, $pageSize = 200, $params = [])
|
|
|
+ {
|
|
|
+ set_time_limit(0);
|
|
|
+ $cacheKey = "caches:supply:goods_category_update_{$pid}_{$pageSize}";
|
|
|
+ if (RedisService::get($cacheKey)) {
|
|
|
+ $this->error = 1047;
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ $params = [
|
|
|
+ 'limit' => $pageSize > 0 ? $pageSize : 50,
|
|
|
+ 'page' => 1,
|
|
|
+ 'pid' => $pid, // 上级ID
|
|
|
+ ];
|
|
|
+ $categorys = [];
|
|
|
+ $updated = 0;
|
|
|
+ $error = 0;
|
|
|
+ $datas = SupplyService::make()->getApiData('getGoodsCategory', $params);
|
|
|
+ if ($datas && $datas['data']) {
|
|
|
+ foreach ($datas['data'] as &$item) {
|
|
|
+ $cateId = isset($item['id']) ? $item['id'] : 0;
|
|
|
+ if ($cateId && !$this->checkCategory($cateId)) {
|
|
|
+ $categorys[] = [
|
|
|
+ 'cate_id' => $cateId,
|
|
|
+ 'name' => isset($item['name']) ? $item['name'] : '',
|
|
|
+ 'pid' => isset($item['pid']) ? intval($item['pid']) : 0,
|
|
|
+ 'create_time' => time(),
|
|
|
+ ];
|
|
|
+ $updated++;
|
|
|
+ } else {
|
|
|
+ $error++;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ unset($item);
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($categorys) {
|
|
|
+ RedisService::set($cacheKey, $categorys, rand(5, 10));
|
|
|
+ GoodsCategoryModel::insert($categorys);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ return ['count' => count($categorys), 'updated' => $updated, 'pid' => $pid, 'errorCount' => $error];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 验证
|
|
|
+ * @param $goodsId
|
|
|
+ * @return bool
|
|
|
+ */
|
|
|
+ public function checkGoods($goodsId)
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:goods:check_{$goodsId}";
|
|
|
+ if (RedisService::get($cacheKey) || RedisService::exists($cacheKey)) {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ $data = $this->model->where(['goods_id' => $goodsId, 'mark' => 1])->value('id');
|
|
|
+ RedisService::set($cacheKey, $data, rand(30, 60));
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 验证分类
|
|
|
+ * @param $cateId
|
|
|
+ * @return bool
|
|
|
+ */
|
|
|
+ public function checkCategory($cateId)
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:goods:category_check_{$cateId}";
|
|
|
+ if (RedisService::get($cacheKey) || RedisService::exists($cacheKey)) {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ $data = GoodsCategoryModel::where(['cate_id' => $cateId, 'mark' => 1])->value('id');
|
|
|
+ RedisService::set($cacheKey, $data, rand(30, 60));
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 接口商品详情
|
|
|
+ * @param $goodsId 商品ID
|
|
|
+ * @param int $isReal 是否实时数据,0-是,1-否
|
|
|
+ * @param int $type 数据类型:0-详情,1-仅SKU数据
|
|
|
+ * @return array|false|mixed|string
|
|
|
+ */
|
|
|
+ public function getApiInfo($goodsId, $isReal = 0, $type = 0)
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:goods:detail_{$goodsId}_{$isReal}_{$type}";
|
|
|
+ $info = RedisService::get($cacheKey);
|
|
|
+ if (empty($info)) {
|
|
|
+ $params = [
|
|
|
+ 'goods_id' => $goodsId,
|
|
|
+ 'is_real' => $isReal,
|
|
|
+ 'type' => $type
|
|
|
+ ];
|
|
|
+ $info = SupplyService::make()->getApiData('getGoodsDetail', $params);
|
|
|
+ if ($info) {
|
|
|
+ RedisService::set($cacheKey, $info, rand(5, 10));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return $info;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 购物车商品数量
|
|
|
+ * @param $userId
|
|
|
+ * @param $params
|
|
|
+ * @return bool
|
|
|
+ */
|
|
|
+ public function count($userId, $params)
|
|
|
+ {
|
|
|
+ $count = CartsModel::where(['user_id' => $userId,'status'=>1,'mark'=>1])->count();
|
|
|
+ return ['count' => $count];
|
|
|
+ }
|
|
|
+
|
|
|
+}
|