StoreProduct.php 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618
  1. <?php
  2. /**
  3. *
  4. * @author: xaboy<365615158@qq.com>
  5. * @day: 2017/12/12
  6. */
  7. namespace app\models\store;
  8. use app\admin\model\store\StoreProductAttrValue as StoreProductAttrValueModel;
  9. use app\models\system\SystemUserLevel;
  10. use app\models\user\UserLevel;
  11. use crmeb\basic\BaseModel;
  12. use crmeb\services\GroupDataService;
  13. use crmeb\services\workerman\ChannelService;
  14. use crmeb\traits\ModelTrait;
  15. use app\models\store\{
  16. StoreBargain, StoreCombination, StoreSeckill
  17. };
  18. /**
  19. * TODO 产品Model
  20. * Class StoreProduct
  21. * @package app\models\store
  22. */
  23. class StoreProduct extends BaseModel
  24. {
  25. /**
  26. * 数据表主键
  27. * @var string
  28. */
  29. protected $pk = 'id';
  30. /**
  31. * 模型名称
  32. * @var string
  33. */
  34. protected $name = 'store_product';
  35. use ModelTrait;
  36. protected function getSliderImageAttr($value)
  37. {
  38. $sliderImage = json_decode($value, true) ?: [];
  39. foreach ($sliderImage as &$item) {
  40. $item = str_replace('\\', '/', $item);
  41. }
  42. return $sliderImage;
  43. }
  44. protected function getImageAttr($value)
  45. {
  46. return str_replace('\\', '/', $value);
  47. }
  48. public function getDescriptionAttr($value)
  49. {
  50. return htmlspecialchars_decode($value);
  51. }
  52. public static function getValidProduct($productId, $field = 'add_time,browse,cate_id,code_path,ficti,give_integral,id,image,is_sub,is_bargain,is_benefit,is_best,is_del,is_hot,is_new,is_postage,is_seckill,is_show,keyword,mer_id,mer_use,ot_price,postage,price,sales,slider_image,sort,stock,store_info,store_name,unit_name,vip_price,spec_type,IFNULL(sales,0) + IFNULL(ficti,0) as fsales,video_link,is_gp,out_amount,recommend,team')
  53. {
  54. $Product = self::where('is_del', 0)->where('is_show', 1)->where('id', $productId)->field($field)->find();
  55. if ($Product) return $Product->toArray();
  56. else return false;
  57. }
  58. public static function getGoodList($limit = 18, $field = '*')
  59. {
  60. $list = self::validWhere()->where('is_good', 1)->order('sort desc,id desc')->limit($limit)->field($field)->select();
  61. $list = count($list) ? $list->toArray() : [];
  62. if (!empty($list)) {
  63. foreach ($list as $k => $v) {
  64. $list[$k]['activity'] = self::activity($v['id']);
  65. }
  66. }
  67. return $list;
  68. }
  69. public static function validWhere()
  70. {
  71. return self::where('is_del', 0)->where('is_show', 1)->where('mer_id', 0);
  72. }
  73. public static function getProductList($data, $uid)
  74. {
  75. $sId = $data['sid'];
  76. $cId = $data['cid'];
  77. $keyword = $data['keyword'];
  78. $priceOrder = $data['priceOrder'];
  79. $salesOrder = $data['salesOrder'];
  80. $news = $data['news'];
  81. $page = $data['page'];
  82. $limit = $data['limit'];
  83. $type = $data['type']; // 某些模板需要购物车数量 1 = 需要查询,0 = 不需要
  84. $model = self::validWhere();
  85. if ($sId) {
  86. $model->whereIn('id', function ($query) use ($sId) {
  87. $query->name('store_product_cate')->where('cate_id', $sId)->field('product_id')->select();
  88. });
  89. } elseif ($cId) {
  90. $model->whereIn('id', function ($query) use ($cId) {
  91. $query->name('store_product_cate')->whereIn('cate_id', function ($q) use ($cId) {
  92. $q->name('store_category')->where('pid', $cId)->field('id')->select();
  93. })->field('product_id')->select();
  94. });
  95. }
  96. if (!empty($keyword)) $model->where('keyword|store_name', 'LIKE', htmlspecialchars("%$keyword%"));
  97. if ($news != 0) $model->where('is_new', 1);
  98. if (intval($data['is_gp']) == 1) $model->where('is_gp', 1);else $model->where('is_gp', 0);
  99. $baseOrder = '';
  100. if ($priceOrder) $baseOrder = $priceOrder == 'desc' ? 'price DESC' : 'price ASC';
  101. // if($salesOrder) $baseOrder = $salesOrder == 'desc' ? 'sales DESC' : 'sales ASC';//真实销量
  102. if ($salesOrder) $baseOrder = $salesOrder == 'desc' ? 'sales DESC' : 'sales ASC';//虚拟销量
  103. if ($baseOrder) $baseOrder .= ', ';
  104. $model->order($baseOrder . 'sort DESC, add_time DESC');
  105. $list = $model->page((int)$page, (int)$limit)->field('id,store_name,cate_id,image,IFNULL(sales,0) + IFNULL(ficti,0) as sales,price,stock,spec_type,is_gp,out_amount,recommend,team')->select()->each(function ($item) use ($uid, $type) {
  106. if ($type) {
  107. if ($item['spec_type']) {
  108. $item['is_att'] = StoreProductAttrValueModel::where(['product_id' => $item['id'], 'type' => 0])->count() ? true : false;
  109. } else {
  110. $item['is_att'] = false;
  111. }
  112. if ($uid) $item['cart_num'] = StoreCart::where('is_pay', 0)->where('is_del', 0)->where('is_new', 0)->where('type', 'product')->where('product_id', $item['id'])->where('uid', $uid)->value('cart_num');
  113. else $item['cart_num'] = 0;
  114. if (is_null($item['cart_num'])) $item['cart_num'] = 0;
  115. }
  116. });
  117. $list = count($list) ? $list->toArray() : [];
  118. if (!empty($list)) {
  119. foreach ($list as $k => $v) {
  120. $list[$k]['activity'] = self::activity($v['id']);
  121. }
  122. }
  123. return self::setLevelPrice($list, $uid);
  124. }
  125. /*
  126. * 分类搜索
  127. * @param string $value
  128. * @return array
  129. * */
  130. public static function getSearchStorePage($keyword, $page, $limit, $uid, $cutApart = [' ', ',', '-'])
  131. {
  132. $model = self::validWhere();
  133. $keyword = trim($keyword);
  134. if (strlen($keyword)) {
  135. $cut = false;
  136. foreach ($cutApart as $val) {
  137. if (strstr($keyword, $val) !== false) {
  138. $cut = $val;
  139. break;
  140. }
  141. }
  142. if ($cut !== false) {
  143. $keywordArray = explode($cut, $keyword);
  144. $sql = [];
  145. foreach ($keywordArray as $item) {
  146. $sql[] = '(`store_name` LIKE "%' . $item . '%" OR `keyword` LIKE "%' . $item . '%")';
  147. }
  148. $model = $model->where(implode(' OR ', $sql));
  149. } else {
  150. $model = $model->where('store_name|keyword', 'LIKE', "%$keyword%");
  151. }
  152. }
  153. $list = $model->field('id,store_name,cate_id,image,ficti as sales,price,stock')->page($page, $limit)->select();
  154. $list = count($list) ? $list->toArray() : [];
  155. if (!empty($list)) {
  156. foreach ($list as $k => $v) {
  157. $list[$k]['activity'] = self::activity($v['id']);
  158. }
  159. }
  160. return self::setLevelPrice($list, $uid);
  161. }
  162. /**
  163. * 新品产品
  164. * @param string $field
  165. * @param int $limit
  166. * @return false|\PDOStatement|string|\think\Collection
  167. */
  168. public static function getNewProduct($field = '*', $limit = 0, $uid = 0, bool $bool = true, $page = 0, $limits = 0)
  169. {
  170. if (!$limit && !$bool) return [];
  171. $model = self::where('is_new', 1)->where('is_del', 0)->where('mer_id', 0)
  172. ->where('stock', '>', 0)->where('is_show', 1)->field($field)
  173. ->order('sort DESC, id DESC');
  174. if ($limit) $model->limit($limit);
  175. if ($page) $model->page((int)$page, (int)$limits);
  176. $list = $model->select();
  177. $list = count($list) ? $list->toArray() : [];
  178. if (!empty($list)) {
  179. foreach ($list as $k => $v) {
  180. $list[$k]['activity'] = self::activity($v['id']);
  181. }
  182. }
  183. return self::setLevelPrice($list, $uid);
  184. }
  185. /**
  186. * 热卖产品
  187. * @param string $field
  188. * @param int $limit
  189. * @return false|\PDOStatement|string|\think\Collection
  190. */
  191. public static function getHotProduct($field = '*', $limit = 0, $uid = 0, $page = 0, $limits = 0)
  192. {
  193. $model = self::where('is_hot', 1)->where('is_del', 0)->where('mer_id', 0)
  194. ->where('stock', '>', 0)->where('is_show', 1)->field($field)
  195. ->order('sort DESC, id DESC');
  196. if ($limit) $model->limit($limit);
  197. if ($page) $model->page((int)$page, (int)$limits);
  198. $list = $model->select();
  199. $list = count($list) ? $list->toArray() : [];
  200. if (!empty($list)) {
  201. foreach ($list as $k => $v) {
  202. $list[$k]['activity'] = self::activity($v['id']);
  203. }
  204. }
  205. return self::setLevelPrice($list, $uid);
  206. }
  207. /**
  208. * 热卖产品
  209. * @param string $field
  210. * @param int $page
  211. * @param int $limit
  212. * @return array|\think\Collection
  213. * @throws \think\db\exception\DataNotFoundException
  214. * @throws \think\db\exception\ModelNotFoundException
  215. * @throws \think\exception\DbException
  216. */
  217. public static function getHotProductLoading($field = '*', $page = 0, $limit = 0)
  218. {
  219. if (!$limit) return [];
  220. $model = self::where('is_hot', 1)->where('is_del', 0)->where('mer_id', 0)
  221. ->where('stock', '>', 0)->where('is_show', 1)->field($field)
  222. ->order('sort DESC, id DESC');
  223. if ($page) $model->page($page, $limit);
  224. $list = $model->select();
  225. if (is_object($list)) return $list->toArray();
  226. return $list;
  227. }
  228. /**
  229. * 精品产品
  230. * @param string $field
  231. * @param int $limit
  232. * @return false|\PDOStatement|string|\think\Collection
  233. */
  234. public static function getBestProduct($field = '*', $limit = 0, $uid = 0, bool $bool = true, $page = 0, $limits = 0)
  235. {
  236. if (!$limit && !$bool) return [];
  237. $model = self::where('is_best', 1)->where('is_del', 0)->where('mer_id', 0)
  238. ->where('stock', '>', 0)->where('is_show', 1)->field($field)
  239. ->order('sort DESC, id DESC');
  240. if ($limit) $model->limit($limit);
  241. if ($page) $model->page((int)$page, (int)$limits);
  242. $list = $model->select();
  243. $list = count($list) ? $list->toArray() : [];
  244. if (!empty($list)) {
  245. foreach ($list as $k => $v) {
  246. $list[$k]['activity'] = self::activity($v['id']);
  247. }
  248. }
  249. return self::setLevelPrice($list, $uid);
  250. }
  251. /**
  252. * 设置会员价格
  253. * @param object | array $list 产品列表
  254. * @param int $uid 用户uid
  255. * @return array
  256. * */
  257. public static function setLevelPrice($list, $uid, $isSingle = false)
  258. {
  259. if (is_object($list)) $list = count($list) ? $list->toArray() : [];
  260. if (!sys_config('vip_open')) {
  261. if (is_array($list)) return $list;
  262. return $isSingle ? $list : 0;
  263. }
  264. $levelId = UserLevel::getUserLevel($uid);
  265. if ($levelId) {
  266. $discount = UserLevel::getUserLevelInfo($levelId, 'discount');
  267. $discount = bcsub(1, bcdiv($discount, 100, 2), 2);
  268. } else {
  269. $discount = SystemUserLevel::getLevelDiscount();
  270. $discount = bcsub(1, bcdiv($discount, 100, 2), 2);
  271. }
  272. //如果不是数组直接执行减去会员优惠金额
  273. if (!is_array($list))
  274. //不是会员原价返回
  275. if ($levelId)
  276. //如果$isSingle==true 返回优惠后的总金额,否则返回优惠的金额
  277. return $isSingle ? bcsub($list, bcmul($discount, $list, 2), 2) : bcmul($discount, $list, 2);
  278. else
  279. return $isSingle ? $list : 0;
  280. //当$list为数组时$isSingle==true为一维数组 ,否则为二维
  281. if ($isSingle)
  282. $list['vip_price'] = isset($list['price']) ? bcsub($list['price'], bcmul($discount, $list['price'], 2), 2) : 0;
  283. else
  284. foreach ($list as &$item) {
  285. $item['vip_price'] = isset($item['price']) ? bcsub($item['price'], bcmul($discount, $item['price'], 2), 2) : 0;
  286. }
  287. return $list;
  288. }
  289. /**
  290. * 优惠产品
  291. * @param string $field
  292. * @param int $limit
  293. * @return false|\PDOStatement|string|\think\Collection
  294. */
  295. public static function getBenefitProduct($field = '*', $limit = 0, $page = 0, $limits = 0)
  296. {
  297. $model = self::where('is_benefit', 1)
  298. ->where('is_del', 0)->where('mer_id', 0)->where('stock', '>', 0)
  299. ->where('is_show', 1)->field($field)
  300. ->order('sort DESC, id DESC');
  301. if ($limit) $model->limit($limit);
  302. if ($page) $model->page((int)$page, (int)$limits);
  303. $data = $model->select();
  304. if (count($data) > 0) {
  305. foreach ($data as $k => $v) {
  306. $data[$k]['activity'] = self::activity($v['id']);
  307. }
  308. }
  309. return $data;
  310. }
  311. public static function cateIdBySimilarityProduct($cateId, $field = '*', $limit = 0)
  312. {
  313. $pid = StoreCategory::cateIdByPid($cateId) ?: $cateId;
  314. $cateList = StoreCategory::pidByCategory($pid, 'id') ?: [];
  315. $cid = [$pid];
  316. foreach ($cateList as $cate) {
  317. $cid[] = $cate['id'];
  318. }
  319. $model = self::where('cate_id', 'IN', $cid)->where('is_show', 1)->where('is_del', 0)
  320. ->field($field)->order('sort DESC,id DESC');
  321. if ($limit) $model->limit($limit);
  322. return $model->select();
  323. }
  324. public static function isValidProduct($productId)
  325. {
  326. return self::be(['id' => $productId, 'is_del' => 0, 'is_show' => 1]) > 0;
  327. }
  328. /**
  329. * 获取单个商品得属性unique
  330. * @param int $productId
  331. * @param int $type
  332. * @return bool|mixed
  333. */
  334. public static function getSingleAttrUnique(int $productId, int $id = 0, int $type = 0)
  335. {
  336. if ($type != 2 && self::be(['id' => $productId, 'spec_type' => 1])) {
  337. return false;
  338. } else {
  339. $unique = StoreProductAttr::storeProductAttrValueDb()->where(['product_id' => $id ?: $productId, 'type' => $type])->value('unique');
  340. return $unique ?: false;
  341. }
  342. }
  343. public static function getProductStock($productId, $uniqueId = '')
  344. {
  345. return $uniqueId == '' ?
  346. self::where('id', $productId)->value('stock') ?: 0
  347. : StoreProductAttr::uniqueByStock($uniqueId);
  348. }
  349. /**
  350. * 加销量减销量
  351. * @param $num
  352. * @param $productId
  353. * @param string $unique
  354. * @return bool
  355. */
  356. public static function decProductStock($num, $productId, $unique = '')
  357. {
  358. if ($unique) {
  359. $res = false !== StoreProductAttrValueModel::decProductAttrStock($productId, $unique, $num, 0);
  360. $res = $res && self::where('id', $productId)->dec('stock', $num)->inc('sales', $num)->update();
  361. } else {
  362. $res = false !== self::where('id', $productId)->dec('stock', $num)->inc('sales', $num)->update();
  363. }
  364. if ($res) {
  365. $stock = self::where('id', $productId)->value('stock');
  366. $replenishment_num = sys_config('store_stock') ?? 0;//库存预警界限
  367. if ($replenishment_num >= $stock) {
  368. try {
  369. ChannelService::instance()->send('STORE_STOCK', ['id' => $productId]);
  370. } catch (\Exception $e) {
  371. }
  372. }
  373. }
  374. return $res;
  375. }
  376. /**
  377. * 减少销量,增加库存
  378. * @param int $num 增加库存数量
  379. * @param int $productId 产品id
  380. * @param string $unique 属性唯一值
  381. * @return boolean
  382. */
  383. public static function incProductStock($num, $productId, $unique = '')
  384. {
  385. $product = self::where('id', $productId)->field(['sales', 'stock'])->find();
  386. if (!$product) return true;
  387. if ($product->sales > 0) $product->sales = bcsub($product->sales, $num, 0);
  388. if ($product->sales < 0) $product->sales = 0;
  389. $res = true;
  390. if ($unique) {
  391. $res = false !== StoreProductAttrValueModel::incProductAttrStock($productId, $unique, $num);
  392. }
  393. $product->stock = bcadd($product->stock, $num, 0);
  394. $res = $res && $product->save();
  395. return $res;
  396. }
  397. /**
  398. * 获取产品分销佣金最低和最高
  399. * @param $storeInfo
  400. * @param $productValue
  401. * @return int|string
  402. */
  403. public static function getPacketPrice($storeInfo, $productValue)
  404. {
  405. $store_brokerage_ratio = sys_config('store_brokerage_ratio');
  406. $store_brokerage_ratio = bcdiv($store_brokerage_ratio, 100, 2);
  407. if (isset($storeInfo['is_sub']) && $storeInfo['is_sub'] == 1) {
  408. $Maxkey = self::getArrayMax($productValue, 'brokerage');
  409. $Minkey = self::getArrayMin($productValue, 'brokerage');
  410. $maxPrice = bcadd(isset($productValue[$Maxkey]) ? $productValue[$Maxkey]['brokerage'] : 0, 0, 0);
  411. $minPrice = bcadd(isset($productValue[$Minkey]) ? $productValue[$Minkey]['brokerage'] : 0, 0, 0);
  412. } else {
  413. $Maxkey = self::getArrayMax($productValue, 'price');
  414. $Minkey = self::getArrayMin($productValue, 'price');
  415. $maxPrice = bcmul($store_brokerage_ratio, bcadd(isset($productValue[$Maxkey]) ? $productValue[$Maxkey]['price'] : 0, 0, 0), 0);
  416. $minPrice = bcmul($store_brokerage_ratio, bcadd(isset($productValue[$Minkey]) ? $productValue[$Minkey]['price'] : 0, 0, 0), 0);
  417. }
  418. if ($minPrice == 0 && $maxPrice == 0)
  419. return 0;
  420. else
  421. return $minPrice . '~' . $maxPrice;
  422. }
  423. /**
  424. * 获取二维数组中最大的值
  425. * @param $arr
  426. * @param $field
  427. * @return int|string
  428. */
  429. public static function getArrayMax($arr, $field)
  430. {
  431. $temp = [];
  432. foreach ($arr as $k => $v) {
  433. $temp[] = $v[$field];
  434. }
  435. if (!count($temp)) return 0;
  436. $maxNumber = max($temp);
  437. foreach ($arr as $k => $v) {
  438. if ($maxNumber == $v[$field]) return $k;
  439. }
  440. return 0;
  441. }
  442. /**
  443. * 获取二维数组中最小的值
  444. * @param $arr
  445. * @param $field
  446. * @return int|string
  447. */
  448. public static function getArrayMin($arr, $field)
  449. {
  450. $temp = [];
  451. foreach ($arr as $k => $v) {
  452. $temp[] = $v[$field];
  453. }
  454. if (!count($temp)) return 0;
  455. $minNumber = min($temp);
  456. foreach ($arr as $k => $v) {
  457. if ($minNumber == $v[$field]) return $k;
  458. }
  459. return 0;
  460. }
  461. /**
  462. * 产品名称 图片
  463. * @param array $productIds
  464. * @return array
  465. */
  466. public static function getProductStoreNameOrImage(array $productIds)
  467. {
  468. return self::whereIn('id', $productIds)->column('store_name,image', 'id');
  469. }
  470. /**
  471. * TODO 获取某个字段值
  472. * @param $id
  473. * @param string $field
  474. * @return mixed
  475. */
  476. public static function getProductField($id, $field = 'store_name')
  477. {
  478. if (is_array($id))
  479. return self::where('id', 'in', $id)->field($field)->select();
  480. else
  481. return self::where('id', $id)->value($field);
  482. }
  483. /**
  484. * 获取产品返佣金额
  485. * @param array $cartId
  486. * @param bool $type true = 一级返佣, fasle = 二级返佣
  487. * @return int|string
  488. */
  489. public static function getProductBrokerage(array $cartId, bool $type = true)
  490. {
  491. $cartInfo = StoreOrderCartInfo::whereIn('cart_id', $cartId)->column('cart_info');
  492. $oneBrokerage = 0;//一级返佣金额
  493. $twoBrokerage = 0;//二级返佣金额
  494. $sumProductPrice = 0;//非指定返佣商品总金额
  495. foreach ($cartInfo as $value) {
  496. $product = json_decode($value, true);
  497. $cartNum = $product['cart_num'] ?? 0;
  498. if (isset($product['productInfo'])) {
  499. $productInfo = $product['productInfo'];
  500. //指定返佣金额
  501. if (isset($productInfo['is_sub']) && $productInfo['is_sub'] == 1) {
  502. $oneBrokerage = bcadd($oneBrokerage, bcmul($cartNum, $productInfo['attrInfo']['brokerage'] ?? 0, 2), 2);
  503. $twoBrokerage = bcadd($twoBrokerage, bcmul($cartNum, $productInfo['attrInfo']['brokerage_two'] ?? 0, 2), 2);
  504. } else {
  505. //比例返佣
  506. if (isset($productInfo['attrInfo'])) {
  507. $sumProductPrice = bcadd($sumProductPrice, bcmul($cartNum, $productInfo['attrInfo']['price'] ?? 0, 2), 2);
  508. } else {
  509. $sumProductPrice = bcadd($sumProductPrice, bcmul($cartNum, $productInfo['price'] ?? 0, 2), 2);
  510. }
  511. }
  512. }
  513. }
  514. if ($type) {
  515. //获取后台一级返佣比例
  516. $storeBrokerageRatio = sys_config('store_brokerage_ratio');
  517. //一级返佣比例 小于等于零时直接返回 不返佣
  518. if ($storeBrokerageRatio <= 0) {
  519. return $oneBrokerage;
  520. }
  521. //计算获取一级返佣比例
  522. $brokerageRatio = bcdiv($storeBrokerageRatio, 100, 2);
  523. $brokeragePrice = bcmul($sumProductPrice, $brokerageRatio, 2);
  524. //固定返佣 + 比例返佣 = 一级总返佣金额
  525. return bcadd($oneBrokerage, $brokeragePrice, 2);
  526. } else {
  527. //获取二级返佣比例
  528. $storeBrokerageTwo = sys_config('store_brokerage_two');
  529. //二级返佣比例小于等于0 直接返回
  530. if ($storeBrokerageTwo <= 0) {
  531. return $twoBrokerage;
  532. }
  533. //计算获取二级返佣比例
  534. $brokerageRatio = bcdiv($storeBrokerageTwo, 100, 2);
  535. $brokeragePrice = bcmul($sumProductPrice, $brokerageRatio, 2);
  536. //固定返佣 + 比例返佣 = 二级总返佣金额
  537. return bcadd($twoBrokerage, $brokeragePrice, 2);
  538. }
  539. }
  540. /**
  541. * 获取商品在此时段活动优先类型
  542. */
  543. public static function activity($id, $status = true)
  544. {
  545. $activity = self::where('id', $id)->value('activity');
  546. if (!$activity) $activity = '1,2,3';//如果老商品没有活动顺序,默认活动顺序,秒杀-砍价-拼团
  547. $activity = explode(',', $activity);
  548. $activityId = [];
  549. $time = 0;
  550. $seckillId = StoreSeckill::where('is_del', 0)->where('status', 1)->where('start_time', '<=', time())->where('stop_time', '>=', time() - 86400)->where('product_id', $id)->field('id,time_id')->select();
  551. if ($seckillId) {
  552. foreach ($seckillId as $v) {
  553. $timeInfo = GroupDataService::getDataNumber((int)$v['time_id']);
  554. if ($timeInfo && isset($timeInfo['time']) && isset($timeInfo['continued'])) {
  555. if (date('H') >= $timeInfo['time'] && date('H') < ($timeInfo['time'] + $timeInfo['continued'])) {
  556. $activityId[1] = $v['id'];
  557. $time = strtotime(date("Y-m-d"), time()) + 3600 * ($timeInfo['time'] + $timeInfo['continued']);
  558. }
  559. }
  560. }
  561. }
  562. $bargainId = StoreBargain::where('is_del', 0)->where('status', 1)->where('start_time', '<=', time())->where('stop_time', '>=', time())->where('product_id', $id)->value('id');
  563. if ($bargainId) $activityId[2] = $bargainId;
  564. $combinationId = StoreCombination::where('is_del', 0)->where('is_show', 1)->where('start_time', '<=', time())->where('stop_time', '>=', time())->where('product_id', $id)->value('id');
  565. if ($combinationId) $activityId[3] = $combinationId;
  566. $data = [];
  567. foreach ($activity as $k => $v) {
  568. if (array_key_exists($v, $activityId)) {
  569. if ($status) {
  570. $data['type'] = $v;
  571. $data['id'] = $activityId[$v];
  572. if ($v == 1) $data['time'] = $time;
  573. break;
  574. } else {
  575. $arr['type'] = $v;
  576. $arr['id'] = $activityId[$v];
  577. if ($v == 1) $arr['time'] = $time;
  578. $data[] = $arr;
  579. }
  580. }
  581. }
  582. return $data;
  583. }
  584. }