StoreOrderCreateServices.php 42 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | CRMEB [ CRMEB赋能开发者,助力企业发展 ]
  4. // +----------------------------------------------------------------------
  5. // | Copyright (c) 2016~2023 https://www.crmeb.com All rights reserved.
  6. // +----------------------------------------------------------------------
  7. // | Licensed CRMEB并不是自由软件,未经许可不能去掉CRMEB相关版权
  8. // +----------------------------------------------------------------------
  9. // | Author: CRMEB Team <admin@crmeb.com>
  10. // +----------------------------------------------------------------------
  11. namespace app\services\order;
  12. use app\services\activity\advance\StoreAdvanceServices;
  13. use app\services\activity\combination\StorePinkServices;
  14. use app\services\agent\AgentLevelServices;
  15. use app\services\activity\coupon\StoreCouponUserServices;
  16. use app\services\agent\DivisionServices;
  17. use app\services\pay\PayServices;
  18. use app\services\pc\OrderServices;
  19. use app\services\product\product\StoreCategoryServices;
  20. use app\services\shipping\ShippingTemplatesFreeServices;
  21. use app\services\shipping\ShippingTemplatesRegionServices;
  22. use app\services\shipping\ShippingTemplatesServices;
  23. use app\services\user\UserInvoiceServices;
  24. use app\services\wechat\WechatUserServices;
  25. use app\services\BaseServices;
  26. use crmeb\exceptions\ApiException;
  27. use crmeb\exceptions\ApiStatusException;
  28. use crmeb\services\CacheService;
  29. use app\dao\order\StoreOrderDao;
  30. use app\services\user\UserServices;
  31. use app\services\user\UserBillServices;
  32. use app\services\user\UserAddressServices;
  33. use app\services\activity\bargain\StoreBargainServices;
  34. use app\services\activity\seckill\StoreSeckillServices;
  35. use app\services\system\store\SystemStoreServices;
  36. use app\services\activity\combination\StoreCombinationServices;
  37. use app\services\product\product\StoreProductServices;
  38. use think\facade\Cache;
  39. use think\facade\Config;
  40. use think\facade\Log;
  41. /**
  42. * 订单创建
  43. * Class StoreOrderCreateServices
  44. * @package app\services\order
  45. */
  46. class StoreOrderCreateServices extends BaseServices
  47. {
  48. /**
  49. * StoreOrderCreateServices constructor.
  50. * @param StoreOrderDao $dao
  51. */
  52. public function __construct(StoreOrderDao $dao)
  53. {
  54. $this->dao = $dao;
  55. }
  56. /**
  57. * 使用雪花算法生成订单ID
  58. * @return string
  59. * @throws \Exception
  60. */
  61. public function getNewOrderId(string $prefix = 'wx')
  62. {
  63. $snowflake = new \Godruoyi\Snowflake\Snowflake();
  64. if (Config::get('cache.default') == 'file') {
  65. //32位
  66. if (PHP_INT_SIZE == 4) {
  67. $id = abs($snowflake->id());
  68. } else {
  69. $id = $snowflake->setStartTimeStamp(strtotime('2022-01-01') * 1000)->id();
  70. }
  71. $replace = '';
  72. $chars = '0123456789';
  73. for ($i = 0; $i < 6; $i++) {
  74. $replace .= $chars[mt_rand(0, strlen($chars) - 1)];
  75. }
  76. $id = substr_replace($id, $replace, -6);
  77. } else {
  78. $is_callable = function ($currentTime) {
  79. $redis = Cache::store('redis');
  80. $swooleSequenceResolver = new \Godruoyi\Snowflake\RedisSequenceResolver($redis->handler());
  81. return $swooleSequenceResolver->sequence($currentTime);
  82. };
  83. //32位
  84. if (PHP_INT_SIZE == 4) {
  85. $id = abs($snowflake->setSequenceResolver($is_callable)->id());
  86. } else {
  87. $id = $snowflake->setStartTimeStamp(strtotime('2022-01-01') * 1000)->setSequenceResolver($is_callable)->id();
  88. }
  89. }
  90. return $prefix . $id;
  91. }
  92. /**
  93. * 核销订单生成核销码
  94. * @return false|string
  95. */
  96. public function getStoreCode()
  97. {
  98. list($msec, $sec) = explode(' ', microtime());
  99. $num = time() + mt_rand(10, 999999) . '' . substr($msec, 2, 3);//生成随机数
  100. if (strlen($num) < 12)
  101. $num = str_pad((string)$num, 12, 0, STR_PAD_RIGHT);
  102. else
  103. $num = substr($num, 0, 12);
  104. if ($this->dao->count(['verify_code' => $num])) {
  105. return $this->getStoreCode();
  106. }
  107. return $num;
  108. }
  109. /**
  110. * 创建订单
  111. * @param $uid
  112. * @param $key
  113. * @param $userInfo
  114. * @param $addressId
  115. * @param $payType
  116. * @param false $useIntegral
  117. * @param int $couponId
  118. * @param string $mark
  119. * @param int $combinationId
  120. * @param int $pinkId
  121. * @param int $seckillId
  122. * @param int $bargainId
  123. * @param int $shippingType
  124. * @param string $real_name
  125. * @param string $phone
  126. * @param int $storeId
  127. * @param false $news
  128. * @param int $advanceId
  129. * @param array $customForm
  130. * @param int $invoice_id
  131. * @return mixed
  132. * @throws \think\db\exception\DataNotFoundException
  133. * @throws \think\db\exception\DbException
  134. * @throws \think\db\exception\ModelNotFoundException
  135. * @author 吴汐
  136. * @email 442384644@qq.com
  137. * @date 2023/03/01
  138. */
  139. public function createOrder($uid, $key, $userInfo, $addressId, $payType, $useIntegral = false, $couponId = 0, $mark = '', $combinationId = 0, $pinkId = 0, $seckillId = 0, $bargainId = 0, $shippingType = 1, $real_name = '', $phone = '', $storeId = 0, $news = false, $advanceId = 0, $customForm = [], $invoice_id = 0)
  140. {
  141. /** @var StoreOrderServices $orderService */
  142. $storeOrderServices = app()->make(StoreOrderServices::class);
  143. $bargainServices = app()->make(StoreBargainServices::class);
  144. $cartGroup = $storeOrderServices->getCacheOrderInfo($uid, $key);
  145. if (!$cartGroup) {
  146. throw new ApiException(410208);
  147. }
  148. //下单前砍价验证
  149. if ($bargainId) {
  150. $bargainServices->checkBargainUser((int)$bargainId, $uid);
  151. }
  152. if ($pinkId) {
  153. $pinkId = (int)$pinkId;
  154. /** @var StorePinkServices $pinkServices */
  155. $pinkServices = app()->make(StorePinkServices::class);
  156. if ($pinkServices->isPink($pinkId, $uid))
  157. throw new ApiStatusException('ORDER_EXIST', 410210, ['orderId' => $storeOrderServices->getStoreIdPink($pinkId, $uid)]);
  158. if ($storeOrderServices->getIsOrderPink($pinkId, $uid))
  159. throw new ApiStatusException('ORDER_EXIST', 410211, ['orderId' => $storeOrderServices->getStoreIdPink($pinkId, $uid)]);
  160. }
  161. $virtual_type = $cartGroup['cartInfo'][0]['productInfo']['virtual_type'] ?? 0;
  162. //下单前发票验证
  163. if ($invoice_id) {
  164. app()->make(UserInvoiceServices::class)->checkInvoice((int)$invoice_id, $uid);
  165. }
  166. /** @var StoreOrderComputedServices $computedServices */
  167. $computedServices = app()->make(StoreOrderComputedServices::class);
  168. $priceData = $computedServices->computedOrder($uid, $userInfo, $cartGroup, $addressId, $payType, $useIntegral, $couponId, true, $shippingType);
  169. /** @var WechatUserServices $wechatServices */
  170. $wechatServices = app()->make(WechatUserServices::class);
  171. /** @var UserAddressServices $addressServices */
  172. $addressServices = app()->make(UserAddressServices::class);
  173. if ($shippingType == 1 && $virtual_type == 0) {
  174. if (!$addressId) {
  175. throw new ApiException(410045);
  176. }
  177. if (!$addressInfo = $addressServices->getOne(['uid' => $uid, 'id' => $addressId, 'is_del' => 0]))
  178. throw new ApiException(410046);
  179. $addressInfo = $addressInfo->toArray();
  180. } else {
  181. if ((!$real_name || !$phone) && $virtual_type == 0) {
  182. throw new ApiException(410245);
  183. }
  184. $addressInfo['real_name'] = $real_name;
  185. $addressInfo['phone'] = $phone;
  186. $addressInfo['province'] = '';
  187. $addressInfo['city'] = '';
  188. $addressInfo['district'] = '';
  189. $addressInfo['detail'] = '';
  190. }
  191. $cartInfo = $cartGroup['cartInfo'];
  192. $priceGroup = $cartGroup['priceGroup'];
  193. $cartIds = [];
  194. $totalNum = 0;
  195. $gainIntegral = 0;
  196. foreach ($cartInfo as $cart) {
  197. $cartIds[] = $cart['id'];
  198. $totalNum += $cart['cart_num'];
  199. if (!$seckillId) $seckillId = $cart['seckill_id'];
  200. if (!$bargainId) $bargainId = $cart['bargain_id'];
  201. if (!$combinationId) $combinationId = $cart['combination_id'];
  202. if (!$advanceId) $advanceId = $cart['advance_id'];
  203. $cartInfoGainIntegral = isset($cart['productInfo']['give_integral']) ? bcmul((string)$cart['cart_num'], (string)$cart['productInfo']['give_integral'], 0) : 0;
  204. $gainIntegral = bcadd((string)$gainIntegral, (string)$cartInfoGainIntegral, 0);
  205. }
  206. if (count($cartInfo) == 1 && isset($cartInfo[0]['productInfo']['presale']) && $cartInfo[0]['productInfo']['presale'] == 1) {
  207. $advance_id = $cartInfo[0]['product_id'];
  208. } else {
  209. $advance_id = 0;
  210. }
  211. $deduction = $seckillId || $bargainId || $combinationId;
  212. if ($deduction) {
  213. $couponId = 0;
  214. $useIntegral = false;
  215. }
  216. //$shipping_type = 1 快递发货 $shipping_type = 2 门店自提
  217. $storeSelfMention = sys_config('store_self_mention') ?? 0;
  218. if (!$storeSelfMention) $shippingType = 1;
  219. $orderInfo = [
  220. 'uid' => $uid,
  221. 'order_id' => $this->getNewOrderId('cp'),
  222. 'real_name' => $addressInfo['real_name'],
  223. 'user_phone' => $addressInfo['phone'],
  224. 'user_address' => $addressInfo['province'] . ' ' . $addressInfo['city'] . ' ' . $addressInfo['district'] . ' ' . $addressInfo['detail'],
  225. 'cart_id' => $cartIds,
  226. 'total_num' => $totalNum,
  227. 'total_price' => $priceGroup['totalPrice'],
  228. 'total_postage' => $shippingType == 1 ? $priceGroup['storePostage'] : 0,
  229. 'coupon_id' => $couponId,
  230. 'coupon_price' => $priceData['coupon_price'],
  231. 'pay_price' => $priceData['pay_price'],
  232. 'pay_postage' => $priceData['pay_postage'],
  233. 'deduction_price' => $priceData['deduction_price'],
  234. 'paid' => 0,
  235. 'pay_type' => $payType,
  236. 'use_integral' => $priceData['usedIntegral'],
  237. 'gain_integral' => $gainIntegral,
  238. 'mark' => htmlspecialchars($mark),
  239. 'combination_id' => $combinationId,
  240. 'pink_id' => $pinkId,
  241. 'seckill_id' => $seckillId,
  242. 'bargain_id' => $bargainId,
  243. 'advance_id' => $advance_id,
  244. 'cost' => $priceGroup['costPrice'],
  245. 'add_time' => time(),
  246. 'unique' => $key,
  247. 'shipping_type' => $shippingType,
  248. 'channel_type' => $userInfo['user_type'],
  249. 'province' => strval($userInfo['user_type'] == 'wechat' || $userInfo['user_type'] == 'routine' ? $wechatServices->value(['uid' => $uid, 'user_type' => $userInfo['user_type']], 'province') : ''),
  250. 'spread_uid' => 0,
  251. 'spread_two_uid' => 0,
  252. 'virtual_type' => $virtual_type,
  253. 'pay_uid' => $uid,
  254. 'custom_form' => json_encode($customForm),
  255. 'division_id' => $userInfo['division_id'],
  256. 'agent_id' => $userInfo['agent_id'],
  257. 'staff_id' => $userInfo['staff_id'],
  258. ];
  259. if ($shippingType == 2) {
  260. $orderInfo['verify_code'] = $this->getStoreCode();
  261. /** @var SystemStoreServices $storeServices */
  262. $storeServices = app()->make(SystemStoreServices::class);
  263. $orderInfo['store_id'] = $storeServices->getStoreDispose($storeId, 'id');
  264. if (!$orderInfo['store_id']) {
  265. throw new ApiException(410247);
  266. }
  267. }
  268. /** @var StoreOrderCartInfoServices $cartServices */
  269. $cartServices = app()->make(StoreOrderCartInfoServices::class);
  270. $priceData['coupon_id'] = $couponId;
  271. $order = $this->transaction(function () use ($cartIds, $orderInfo, $cartInfo, $key, $userInfo, $useIntegral, $priceData, $combinationId, $seckillId, $bargainId, $cartServices, $seckillServices, $uid, $addressId, $advanceId) {
  272. //创建订单
  273. $order = $this->dao->save($orderInfo);
  274. if (!$order) {
  275. throw new ApiException(410200);
  276. }
  277. //记录自提人电话和姓名
  278. /** @var UserServices $userService */
  279. $userService = app()->make(UserServices::class);
  280. $userService->update(['uid' => $uid], ['real_name' => $orderInfo['real_name'], 'record_phone' => $orderInfo['user_phone']]);
  281. //积分抵扣
  282. if ($priceData['usedIntegral'] > 0) {
  283. $this->deductIntegral($userInfo, $useIntegral, $priceData, (int)$userInfo['uid'], $order['id']);
  284. }
  285. //扣库存
  286. $this->decGoodsStock($cartInfo, $combinationId, $seckillId, $bargainId, $advanceId);
  287. //保存购物车商品信息
  288. $cartServices->setCartInfo($order['id'], $uid, $cartInfo);
  289. return $order;
  290. });
  291. //创建开票数据
  292. if ($invoice_id) {
  293. app()->make(StoreOrderInvoiceServices::class)->makeUp($uid, $order['order_id'], (int)$invoice_id);
  294. }
  295. // 订单创建成功后置事件
  296. event('OrderCreateAfterListener', [$order, compact('cartInfo', 'priceData', 'addressId', 'cartIds', 'news'), $uid, $key, $combinationId, $seckillId, $bargainId]);
  297. // 推送订单
  298. event('OutPushListener', ['order_create_push', ['order_id' => (int)$order['id']]]);
  299. return $order;
  300. }
  301. /**
  302. * 抵扣积分
  303. * @param array $userInfo
  304. * @param bool $useIntegral
  305. * @param array $priceData
  306. * @param int $uid
  307. * @param string $key
  308. */
  309. public function deductIntegral(array $userInfo, bool $useIntegral, array $priceData, int $uid, $orderId)
  310. {
  311. $res2 = true;
  312. if ($useIntegral && $userInfo['integral'] > 0) {
  313. /** @var UserServices $userServices */
  314. $userServices = app()->make(UserServices::class);
  315. if (!$priceData['SurplusIntegral']) {
  316. $res2 = false !== $userServices->update($uid, ['integral' => 0]);
  317. } else {
  318. $res2 = false !== $userServices->bcDec($userInfo['uid'], 'integral', $priceData['usedIntegral'], 'uid');
  319. }
  320. /** @var UserBillServices $userBillServices */
  321. $userBillServices = app()->make(UserBillServices::class);
  322. $res3 = $userBillServices->income('deduction', $uid, [
  323. 'number' => $priceData['usedIntegral'],
  324. 'deductionPrice' => $priceData['deduction_price']
  325. ], $userInfo['integral'] - $priceData['usedIntegral'], $orderId);
  326. $res2 = $res2 && false != $res3;
  327. }
  328. if (!$res2) {
  329. throw new ApiException(410227);
  330. }
  331. }
  332. /**
  333. * 扣库存
  334. * @param array $cartInfo
  335. * @param int $combinationId
  336. * @param int $seckillId
  337. * @param int $bargainId
  338. */
  339. public function decGoodsStock(array $cartInfo, int $combinationId, int $seckillId, int $bargainId, int $advanceId)
  340. {
  341. $res5 = true;
  342. /** @var StoreProductServices $services */
  343. $services = app()->make(StoreProductServices::class);
  344. /** @var StoreSeckillServices $seckillServices */
  345. $seckillServices = app()->make(StoreSeckillServices::class);
  346. /** @var StoreCombinationServices $pinkServices */
  347. $pinkServices = app()->make(StoreCombinationServices::class);
  348. /** @var StoreBargainServices $bargainServices */
  349. $bargainServices = app()->make(StoreBargainServices::class);
  350. /** @var StoreAdvanceServices $advanceServices */
  351. $advanceServices = app()->make(StoreAdvanceServices::class);
  352. try {
  353. foreach ($cartInfo as $cart) {
  354. //减库存加销量
  355. if ($combinationId) $res5 = $res5 && $pinkServices->decCombinationStock((int)$cart['cart_num'], $combinationId, isset($cart['productInfo']['attrInfo']) ? $cart['productInfo']['attrInfo']['unique'] : '');
  356. else if ($seckillId) $res5 = $res5 && $seckillServices->decSeckillStock((int)$cart['cart_num'], $seckillId, isset($cart['productInfo']['attrInfo']) ? $cart['productInfo']['attrInfo']['unique'] : '');
  357. else if ($bargainId) $res5 = $res5 && $bargainServices->decBargainStock((int)$cart['cart_num'], $bargainId, isset($cart['productInfo']['attrInfo']) ? $cart['productInfo']['attrInfo']['unique'] : '');
  358. else if ($advanceId) $res5 = $res5 && $advanceServices->decAdvanceStock((int)$cart['cart_num'], $advanceId, isset($cart['productInfo']['attrInfo']) ? $cart['productInfo']['attrInfo']['unique'] : '');
  359. else $res5 = $res5 && $services->decProductStock((int)$cart['cart_num'], (int)$cart['productInfo']['id'], isset($cart['productInfo']['attrInfo']) ? $cart['productInfo']['attrInfo']['unique'] : '');
  360. }
  361. if (!$res5) {
  362. throw new ApiException(410238);
  363. }
  364. } catch (\Throwable $e) {
  365. throw new ApiException(410238);
  366. }
  367. }
  368. /**
  369. * 订单数据创建之后的商品实际金额计算,佣金计算,优惠折扣计算,设置默认地址,清理购物车
  370. * @param $order
  371. * @param array $group
  372. * @param $activity
  373. */
  374. public function orderCreateAfter($order, array $group, $activity)
  375. {
  376. /** @var UserAddressServices $addressServices */
  377. $addressServices = app()->make(UserAddressServices::class);
  378. //设置用户默认地址
  379. if (!$addressServices->be(['is_default' => 1, 'uid' => $order['uid']])) {
  380. $addressServices->setDefaultAddress($group['addressId'], $order['uid']);
  381. }
  382. //删除购物车
  383. if ($group['news']) {
  384. array_map(function ($key) {
  385. CacheService::delete($key);
  386. }, $group['cartIds']);
  387. } else {
  388. /** @var StoreCartServices $cartServices */
  389. $cartServices = app()->make(StoreCartServices::class);
  390. $cartServices->deleteCartStatus($group['cartIds']);
  391. }
  392. $uid = (int)$order['uid'];
  393. $orderId = (int)$order['id'];
  394. try {
  395. $cartInfo = $group['cartInfo'] ?? [];
  396. $priceData = $group['priceData'] ?? [];
  397. $addressId = $group['addressId'] ?? 0;
  398. $spread_ids = [];
  399. /** @var StoreOrderCreateServices $createService */
  400. $createService = app()->make(StoreOrderCreateServices::class);
  401. if ($cartInfo && $priceData) {
  402. /** @var StoreOrderCartInfoServices $cartServices */
  403. $cartServices = app()->make(StoreOrderCartInfoServices::class);
  404. [$cartInfo, $spread_ids] = $createService->computeOrderProductTruePrice($cartInfo, $priceData, $addressId, $uid, $order);
  405. $cartServices->updateCartInfo($orderId, $cartInfo);
  406. }
  407. $orderData = [];
  408. $spread_uid = $spread_two_uid = 0;
  409. /** @var UserServices $userServices */
  410. $userServices = app()->make(UserServices::class);
  411. if ($spread_ids) {
  412. [$spread_uid, $spread_two_uid] = $spread_ids;
  413. $orderData['spread_uid'] = $spread_uid;
  414. $orderData['spread_two_uid'] = $spread_two_uid;
  415. } else {
  416. $spread_uid = $userServices->getSpreadUid($uid);
  417. $orderData = ['spread_uid' => 0, 'spread_two_uid' => 0];
  418. if ($spread_uid) {
  419. $orderData['spread_uid'] = $spread_uid;
  420. }
  421. if ($spread_uid > 0 && sys_config('brokerage_level') == 2) {
  422. $spread_two_uid = $userServices->getSpreadUid($spread_uid, [], false);
  423. if ($spread_two_uid) {
  424. $orderData['spread_two_uid'] = $spread_two_uid;
  425. }
  426. }
  427. }
  428. $isCommission = 0;
  429. if ($order['combination_id']) {
  430. //检测拼团是否参与返佣
  431. /** @var StoreCombinationServices $combinationServices */
  432. $combinationServices = app()->make(StoreCombinationServices::class);
  433. $isCommission = $combinationServices->value(['id' => $order['combination_id']], 'is_commission');
  434. }
  435. if ($cartInfo && (!$activity || $isCommission)) {
  436. /** @var StoreOrderComputedServices $orderComputed */
  437. $orderComputed = app()->make(StoreOrderComputedServices::class);
  438. if ($userServices->checkUserPromoter($spread_uid)) $orderData['one_brokerage'] = $orderComputed->getOrderSumPrice($cartInfo, 'one_brokerage', false);
  439. if ($userServices->checkUserPromoter($spread_two_uid)) $orderData['two_brokerage'] = $orderComputed->getOrderSumPrice($cartInfo, 'two_brokerage', false);
  440. $orderData['staff_brokerage'] = $orderComputed->getOrderSumPrice($cartInfo, 'staff_brokerage', false);
  441. $orderData['agent_brokerage'] = $orderComputed->getOrderSumPrice($cartInfo, 'agent_brokerage', false);
  442. $orderData['division_brokerage'] = $orderComputed->getOrderSumPrice($cartInfo, 'division_brokerage', false);
  443. }
  444. $createService->update(['id' => $orderId], $orderData);
  445. } catch (\Throwable $e) {
  446. throw new ApiException('计算订单实际优惠、积分、邮费、佣金失败,原因:' . $e->getMessage());
  447. }
  448. }
  449. /**
  450. * 计算订单每个商品真实付款价格
  451. * @param array $cartInfo
  452. * @param array $priceData
  453. * @param $addressId
  454. * @param int $uid
  455. * @return array
  456. */
  457. public function computeOrderProductTruePrice(array $cartInfo, array $priceData, $addressId, int $uid, $orderInfo)
  458. {
  459. //统一放入默认数据
  460. foreach ($cartInfo as &$cart) {
  461. $cart['use_integral'] = 0;
  462. $cart['integral_price'] = 0.00;
  463. $cart['coupon_price'] = 0.00;
  464. }
  465. try {
  466. $cartInfo = $this->computeOrderProductCoupon($cartInfo, $priceData);
  467. $cartInfo = $this->computeOrderProductIntegral($cartInfo, $priceData);
  468. } catch (\Throwable $e) {
  469. Log::error('订单商品结算失败,File:' . $e->getFile() . ',Line:' . $e->getLine() . ',Message:' . $e->getMessage());
  470. throw new ApiException(410248);
  471. }
  472. //truePice实际支付单价(存在)
  473. //几件商品总体优惠 以及积分抵扣金额
  474. foreach ($cartInfo as &$cart) {
  475. $coupon_price = $cart['coupon_price'] ?? 0;
  476. $integral_price = $cart['integral_price'] ?? 0;
  477. $cart['sum_true_price'] = bcmul((string)$cart['truePrice'], (string)$cart['cart_num'], 2);
  478. if ($coupon_price) {
  479. $cart['sum_true_price'] = bcsub((string)$cart['sum_true_price'], (string)$coupon_price, 2);
  480. $uni_coupon_price = (string)bcdiv((string)$coupon_price, (string)$cart['cart_num'], 4);
  481. $cart['truePrice'] = $cart['truePrice'] > $uni_coupon_price ? bcsub((string)$cart['truePrice'], $uni_coupon_price, 2) : 0;
  482. }
  483. if ($integral_price) {
  484. $cart['sum_true_price'] = bcsub((string)$cart['sum_true_price'], (string)$integral_price, 2);
  485. $uni_integral_price = (string)bcdiv((string)$integral_price, (string)$cart['cart_num'], 4);
  486. $cart['truePrice'] = $cart['truePrice'] > $uni_integral_price ? bcsub((string)$cart['truePrice'], $uni_integral_price, 2) : 0;
  487. }
  488. }
  489. try {
  490. [$cartInfo, $spread_ids] = $this->computeOrderProductBrokerage($uid, $cartInfo, $orderInfo);
  491. } catch (\Throwable $e) {
  492. Log::error('订单商品结算失败,File:' . $e->getFile() . ',Line:' . $e->getLine() . ',Message:' . $e->getMessage());
  493. throw new ApiException(410248);
  494. }
  495. return [$cartInfo, $spread_ids];
  496. }
  497. /**
  498. * 计算每个商品实际支付运费
  499. * @param array $cartInfo
  500. * @param array $priceData
  501. * @return array
  502. */
  503. public function computeOrderProductPostage(array $cartInfo, array $priceData, $addressId)
  504. {
  505. $storePostage = $priceData['pay_postage'] ?? 0;
  506. if ($storePostage) {
  507. /** @var UserAddressServices $addressServices */
  508. $addressServices = app()->make(UserAddressServices::class);
  509. $addr = $addressServices->getAddress($addressId);
  510. if ($addr) {
  511. $addr = $addr->toArray();
  512. //按照运费模板计算每个运费模板下商品的件数/重量/体积以及总金额 按照首重倒序排列
  513. $cityId = $addr['city_id'] ?? 0;
  514. $tempIds[] = 1;
  515. foreach ($cartInfo as $key_c => $item_c) {
  516. $tempIds[] = $item_c['productInfo']['temp_id'];
  517. }
  518. $tempIds = array_unique($tempIds);
  519. /** @var ShippingTemplatesServices $shippServices */
  520. $shippServices = app()->make(ShippingTemplatesServices::class);
  521. $temp = $shippServices->getShippingColumn(['id' => $tempIds], 'type,appoint', 'id');
  522. /** @var ShippingTemplatesRegionServices $regionServices */
  523. $regionServices = app()->make(ShippingTemplatesRegionServices::class);
  524. $regions = $regionServices->getTempRegionList($tempIds, [$cityId, 0], 'temp_id,first,first_price,continue,continue_price', 'temp_id');
  525. $temp_num = [];
  526. foreach ($cartInfo as $cart) {
  527. $tempId = $cart['productInfo']['temp_id'] ?? 1;
  528. $type = $temp[$tempId]['type'] ?? $temp[1]['type'];
  529. if ($type == 1) {
  530. $num = $cart['cart_num'];
  531. } elseif ($type == 2) {
  532. $num = $cart['cart_num'] * $cart['productInfo']['attrInfo']['weight'];
  533. } else {
  534. $num = $cart['cart_num'] * $cart['productInfo']['attrInfo']['volume'];
  535. }
  536. $region = $regions[$tempId] ?? $regions[1];
  537. if (!isset($temp_num[$cart['productInfo']['temp_id']])) {
  538. $temp_num[$cart['productInfo']['temp_id']]['cart_id'][] = $cart['id'];
  539. $temp_num[$cart['productInfo']['temp_id']]['number'] = $num;
  540. $temp_num[$cart['productInfo']['temp_id']]['type'] = $type;
  541. $temp_num[$cart['productInfo']['temp_id']]['price'] = bcmul($cart['cart_num'], $cart['truePrice'], 2);
  542. $temp_num[$cart['productInfo']['temp_id']]['first'] = $region['first'];
  543. $temp_num[$cart['productInfo']['temp_id']]['first_price'] = $region['first_price'];
  544. $temp_num[$cart['productInfo']['temp_id']]['continue'] = $region['continue'];
  545. $temp_num[$cart['productInfo']['temp_id']]['continue_price'] = $region['continue_price'];
  546. $temp_num[$cart['productInfo']['temp_id']]['temp_id'] = $cart['productInfo']['temp_id'];
  547. $temp_num[$cart['productInfo']['temp_id']]['city_id'] = $addr['city_id'];
  548. } else {
  549. $temp_num[$cart['productInfo']['temp_id']]['cart_id'][] = $cart['id'];
  550. $temp_num[$cart['productInfo']['temp_id']]['number'] += $num;
  551. $temp_num[$cart['productInfo']['temp_id']]['price'] += bcmul($cart['cart_num'], $cart['truePrice'], 2);
  552. }
  553. }
  554. $cartInfo = array_combine(array_column($cartInfo, 'id'), $cartInfo);
  555. /** @var ShippingTemplatesFreeServices $freeServices */
  556. $freeServices = app()->make(ShippingTemplatesFreeServices::class);
  557. foreach ($temp_num as $k => $v) {
  558. if (isset($temp[$v['temp_id']]['appoint']) && $temp[$v['temp_id']]['appoint']) {
  559. if ($freeServices->isFree($v['temp_id'], $v['city_id'], $v['number'], $v['price'], $v['type'])) {
  560. //免运费
  561. foreach ($v['cart_id'] as $c_id) {
  562. if (isset($cartInfo[$c_id])) $cartInfo[$c_id]['postage_price'] = 0.00;
  563. }
  564. }
  565. }
  566. }
  567. $count = 0;
  568. $compute_price = 0.00;
  569. $total_price = 0;
  570. $postage_price = 0.00;
  571. foreach ($cartInfo as &$cart) {
  572. if (isset($cart['postage_price'])) {//免运费
  573. continue;
  574. }
  575. $total_price = bcadd((string)$total_price, (string)bcmul((string)$cart['truePrice'], (string)$cart['cart_num'], 4), 2);
  576. $count++;
  577. }
  578. foreach ($cartInfo as &$cart) {
  579. if (isset($cart['postage_price'])) {//免运费
  580. continue;
  581. }
  582. if ($count > 1) {
  583. $postage_price = bcmul((string)bcdiv((string)bcmul((string)$cart['cart_num'], (string)$cart['truePrice'], 4), (string)$total_price, 4), (string)$storePostage, 2);
  584. $compute_price = bcadd((string)$compute_price, (string)$postage_price, 2);
  585. } else {
  586. $postage_price = bcsub((string)$storePostage, $compute_price, 2);
  587. }
  588. $cart['postage_price'] = $postage_price;
  589. $count--;
  590. }
  591. $cartInfo = array_merge($cartInfo);
  592. }
  593. }
  594. //保证不进运费模版计算的购物车商品postage_price字段有值
  595. foreach ($cartInfo as &$item) {
  596. if (!isset($item['postage_price'])) $item['postage_price'] = 0.00;
  597. }
  598. return $cartInfo;
  599. }
  600. /**
  601. * 计算订单商品积分实际抵扣金额
  602. * @param array $cartInfo
  603. * @param array $priceData
  604. * @return array
  605. */
  606. public function computeOrderProductIntegral(array $cartInfo, array $priceData)
  607. {
  608. $usedIntegral = $priceData['usedIntegral'] ?? 0;
  609. $deduction_price = $priceData['deduction_price'] ?? 0;
  610. if ($deduction_price) {
  611. $count = 0;
  612. $total_price = 0.00;
  613. $compute_price = 0.00;
  614. $integral_price = 0.00;
  615. $use_integral = 0;
  616. $compute_integral = 0;
  617. foreach ($cartInfo as $cart) {
  618. $total_price = bcadd((string)$total_price, (string)bcmul((string)$cart['truePrice'], (string)$cart['cart_num'], 4), 2);
  619. $count++;
  620. }
  621. foreach ($cartInfo as &$cart) {
  622. if ($count > 1) {
  623. $integral_price = bcmul((string)bcdiv((string)bcmul((string)$cart['cart_num'], (string)$cart['truePrice'], 4), (string)$total_price, 4), (string)$deduction_price, 2);
  624. $compute_price = bcadd((string)$compute_price, (string)$integral_price, 2);
  625. $use_integral = bcmul((string)bcdiv((string)bcmul((string)$cart['cart_num'], (string)$cart['truePrice'], 4), (string)$total_price, 4), (string)$usedIntegral, 0);
  626. $compute_integral = bcadd((string)$compute_integral, $use_integral, 0);
  627. } else {
  628. $integral_price = bcsub((string)$deduction_price, $compute_price, 2);
  629. $use_integral = bcsub((string)$usedIntegral, $compute_integral, 0);
  630. }
  631. $count--;
  632. $cart['integral_price'] = $integral_price;
  633. $cart['use_integral'] = $use_integral;
  634. }
  635. }
  636. return $cartInfo;
  637. }
  638. /**
  639. * 计算订单商品优惠券实际抵扣金额
  640. * @param array $cartInfo
  641. * @param array $priceData
  642. * @return array
  643. */
  644. public function computeOrderProductCoupon(array $cartInfo, array $priceData)
  645. {
  646. if ($priceData['coupon_id'] && $priceData['coupon_price'] ?? 0) {
  647. $count = 0;
  648. $total_price = 0.00;
  649. $compute_price = 0.00;
  650. $coupon_price = 0.00;
  651. /** @var StoreCouponUserServices $couponServices */
  652. $couponServices = app()->make(StoreCouponUserServices::class);
  653. $couponInfo = $couponServices->getOne(['id' => $priceData['coupon_id']], '*', ['issue']);
  654. if ($couponInfo) {
  655. $type = $couponInfo['applicable_type'] ?? 0;
  656. $counpon_id = $couponInfo['id'];
  657. switch ($type) {
  658. case 0:
  659. case 3:
  660. foreach ($cartInfo as $cart) {
  661. $total_price = bcadd((string)$total_price, (string)bcmul((string)$cart['truePrice'], (string)$cart['cart_num'], 4), 2);
  662. $count++;
  663. }
  664. foreach ($cartInfo as &$cart) {
  665. if ($count > 1) {
  666. $coupon_price = bcmul((string)bcdiv((string)bcmul((string)$cart['cart_num'], (string)$cart['truePrice'], 4), (string)$total_price, 4), (string)$couponInfo['coupon_price'], 2);
  667. $compute_price = bcadd((string)$compute_price, (string)$coupon_price, 2);
  668. } else {
  669. $coupon_price = bcsub((string)$couponInfo['coupon_price'], $compute_price, 2);
  670. }
  671. $cart['coupon_price'] = $coupon_price;
  672. $cart['coupon_id'] = $counpon_id;
  673. $count--;
  674. }
  675. break;
  676. case 1://品类券
  677. /** @var StoreCategoryServices $storeCategoryServices */
  678. $storeCategoryServices = app()->make(StoreCategoryServices::class);
  679. $coupon_category = explode(',', (string)$couponInfo['category_id']);
  680. $category_ids = $storeCategoryServices->getAllById($coupon_category);
  681. if ($category_ids) {
  682. $cateIds = array_column($category_ids, 'id');
  683. foreach ($cartInfo as $cart) {
  684. if (isset($cart['productInfo']['cate_id']) && array_intersect(explode(',', $cart['productInfo']['cate_id']), $cateIds)) {
  685. $total_price = bcadd((string)$total_price, (string)bcmul((string)$cart['truePrice'], (string)$cart['cart_num'], 4), 2);
  686. $count++;
  687. }
  688. }
  689. foreach ($cartInfo as &$cart) {
  690. $cart['coupon_id'] = 0;
  691. $cart['coupon_price'] = 0;
  692. if (isset($cart['productInfo']['cate_id']) && array_intersect(explode(',', $cart['productInfo']['cate_id']), $cateIds)) {
  693. if ($count > 1) {
  694. $coupon_price = bcmul((string)bcdiv((string)bcmul((string)$cart['cart_num'], (string)$cart['truePrice'], 4), (string)$total_price, 4), (string)$couponInfo['coupon_price'], 2);
  695. $compute_price = bcadd((string)$compute_price, (string)$coupon_price, 2);
  696. } else {
  697. $coupon_price = bcsub((string)$couponInfo['coupon_price'], $compute_price, 2);
  698. }
  699. $cart['coupon_id'] = $counpon_id;
  700. $cart['coupon_price'] = $coupon_price;
  701. $count--;
  702. }
  703. }
  704. }
  705. break;
  706. case 2://商品劵
  707. foreach ($cartInfo as $cart) {
  708. if (isset($cart['product_id']) && in_array($cart['product_id'], explode(',', $couponInfo['product_id']))) {
  709. $total_price = bcadd((string)$total_price, (string)bcmul((string)$cart['truePrice'], (string)$cart['cart_num'], 4), 2);
  710. $count++;
  711. }
  712. }
  713. foreach ($cartInfo as &$cart) {
  714. $cart['coupon_id'] = 0;
  715. $cart['coupon_price'] = 0;
  716. if (isset($cart['product_id']) && in_array($cart['product_id'], explode(',', $couponInfo['product_id']))) {
  717. if ($count > 1) {
  718. $coupon_price = bcmul((string)bcdiv((string)bcmul((string)$cart['cart_num'], (string)$cart['truePrice'], 4), (string)$total_price, 4), (string)$couponInfo['coupon_price'], 2);
  719. $compute_price = bcadd((string)$compute_price, (string)$coupon_price, 2);
  720. } else {
  721. $coupon_price = bcsub((string)$couponInfo['coupon_price'], $compute_price, 2);
  722. }
  723. $cart['coupon_id'] = $counpon_id;
  724. $cart['coupon_price'] = $coupon_price;
  725. $count--;
  726. }
  727. }
  728. break;
  729. }
  730. }
  731. }
  732. return $cartInfo;
  733. }
  734. /**
  735. * 计算实际佣金
  736. * @param int $uid
  737. * @param array $cartInfo
  738. * @return array
  739. * @throws \think\db\exception\DataNotFoundException
  740. * @throws \think\db\exception\DbException
  741. * @throws \think\db\exception\ModelNotFoundException
  742. */
  743. public function computeOrderProductBrokerage(int $uid, array $cartInfo, $orderInfo)
  744. {
  745. /** @var AgentLevelServices $agentLevelServices */
  746. $agentLevelServices = app()->make(AgentLevelServices::class);
  747. [$one_brokerage_up, $two_brokerage_up, $spread_one_uid, $spread_two_uid] = $agentLevelServices->getAgentLevelBrokerage($uid);
  748. $BrokerageOne = sys_config('store_brokerage_ratio') != '' ? sys_config('store_brokerage_ratio') : 0;
  749. $BrokerageTwo = sys_config('store_brokerage_two') != '' ? sys_config('store_brokerage_two') : 0;
  750. $storeBrokerageRatio = $BrokerageOne + (($BrokerageOne * $one_brokerage_up) / 100);
  751. $storeBrokerageTwo = $BrokerageTwo + (($BrokerageTwo * $two_brokerage_up) / 100);
  752. if (sys_config('brokerage_level') == 1) {
  753. $storeBrokerageTwo = $spread_two_uid = 0;
  754. }
  755. /** @var DivisionServices $divisionService */
  756. $divisionService = app()->make(DivisionServices::class);
  757. [$storeBrokerageRatio, $storeBrokerageTwo, $staffPercent, $agentPercent, $divisionPercent] = $divisionService->getDivisionPercent($uid, $storeBrokerageRatio, $storeBrokerageTwo, sys_config('is_self_brokerage', 0));
  758. foreach ($cartInfo as &$cart) {
  759. $oneBrokerage = '0';//一级返佣金额
  760. $twoBrokerage = '0';//二级返佣金额
  761. $staffBrokerage = '0';//店员返佣金额
  762. $agentBrokerage = '0';//代理商返佣金额
  763. $divisionBrokerage = '0';//事业部返佣金额
  764. $cartNum = (string)$cart['cart_num'] ?? '0';
  765. if (isset($cart['productInfo'])) {
  766. $productInfo = $cart['productInfo'];
  767. //计算商品金额
  768. if (sys_config('user_brokerage_type') == 1) {
  769. //按照实际支付价格返佣
  770. $price = bcmul((string)$cart['truePrice'], $cartNum, 4);
  771. } else {
  772. //按照商品价格返佣
  773. if (isset($productInfo['attrInfo'])) {
  774. $price = bcmul((string)($productInfo['attrInfo']['price'] ?? '0'), $cartNum, 4);
  775. } else {
  776. $price = bcmul((string)($productInfo['price'] ?? '0'), $cartNum, 4);
  777. }
  778. }
  779. $staffBrokerage = bcmul((string)$price, (string)bcdiv($staffPercent, 100, 4), 2);
  780. $agentBrokerage = bcmul((string)$price, (string)bcdiv($agentPercent, 100, 4), 2);
  781. $divisionBrokerage = bcmul((string)$price, (string)bcdiv($divisionPercent, 100, 4), 2);
  782. //指定返佣金额
  783. if (isset($productInfo['is_sub']) && $productInfo['is_sub'] == 1) {
  784. $oneBrokerage = bcmul((string)($productInfo['attrInfo']['brokerage'] ?? '0'), $cartNum, 2);
  785. $twoBrokerage = bcmul((string)($productInfo['attrInfo']['brokerage_two'] ?? '0'), $cartNum, 2);
  786. } else {
  787. if ($price) {
  788. //一级返佣比例 小于等于零时直接返回 不返佣
  789. if ($storeBrokerageRatio > 0) {
  790. //计算获取一级返佣比例
  791. $brokerageRatio = bcdiv($storeBrokerageRatio, 100, 4);
  792. $oneBrokerage = bcmul((string)$price, (string)$brokerageRatio, 2);
  793. }
  794. //二级返佣比例小于等于0 直接返回
  795. if ($storeBrokerageTwo > 0) {
  796. //计算获取二级返佣比例
  797. $brokerageTwo = bcdiv($storeBrokerageTwo, 100, 4);
  798. $twoBrokerage = bcmul((string)$price, (string)$brokerageTwo, 2);
  799. }
  800. }
  801. }
  802. }
  803. $cart['one_brokerage'] = $oneBrokerage;
  804. $cart['two_brokerage'] = $twoBrokerage;
  805. $cart['staff_brokerage'] = $staffBrokerage;
  806. $cart['agent_brokerage'] = $agentBrokerage;
  807. $cart['division_brokerage'] = $divisionBrokerage;
  808. }
  809. return [$cartInfo, [$spread_one_uid, $spread_two_uid]];
  810. }
  811. }