// +---------------------------------------------------------------------- namespace app\services\order; use app\dao\order\StoreOrderPromotionsDao; use app\services\BaseServices; use crmeb\traits\ServicesTrait; use think\exception\ValidateException; /** * Class StoreOrderPromotionsServices * @package app\services\order * @mixin StoreOrderPromotionsDao */ class StoreOrderPromotionsServices extends BaseServices { use ServicesTrait; /** * StoreOrderPromotionsServices constructor. * @param StoreOrderPromotionsDao $dao */ public function __construct(StoreOrderPromotionsDao $dao) { $this->dao = $dao; } /** * 保存订单优惠详情 * @param $oid * @param array $cartInfo * @param $uid * @return int */ public function setPromotionsDetail(int $uid, int $oid, array $cartList, array $promotionsList) { $group = []; if ($promotionsList) { $time = time(); foreach ($cartList as $key => $cart) { foreach ($promotionsList as $promotions) { $details = $promotions['details'] ?? []; $unique = $cart['product_attr_unique'] ?? ''; if ($details && isset($details[$unique]['promotions_true_price'])) { $group[] = [ 'oid' => $oid, 'uid' => $uid, 'product_id' => $cart['productInfo']['id'], 'promotions_id' => $promotions['id'], 'promotions_price' => bcmul((string)($details[$unique]['promotions_true_price'] ?? 0), (string)$cart['cart_num'], 2), 'add_time' => $time ]; } } } } if ($group) { return $this->dao->saveAll($group); } return true; } /** * 获取订单商品实际参与优惠活动 以及优惠金额 * @param int $oid * @return array */ public function getOrderPromotionsDetail(int $oid) { $result = $this->dao->getPromotionsDetailList(['oid' => $oid], '*,sum(`promotions_price`) as promotions_price', ['promotions' => function($query) { $query->field('id,name,title,desc')->bind([ 'promotions_type' => 'promotions_type', 'name' => 'name', 'title' => 'title', 'desc' => 'desc' ]); }], 'promotions_id'); if ($result) { $typeArr = array_column($result, 'promotions_type'); array_multisort($typeArr, SORT_ASC, $result); } return $result; } /** * 拆分订单同步拆分优惠活动记录 * @param int $oid * @return bool * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function splitOrderPromotions(int $oid) { /** @var StoreOrderServices $storeOrderServices */ $storeOrderServices = app()->make(StoreOrderServices::class); $orderInfo = $storeOrderServices->getOne(['id' => $oid, 'is_del' => 0]); if (!$orderInfo) { throw new ValidateException('订单不存在'); } $promotions_give = []; $promotions = []; if (isset($orderInfo['promotions_give']) && $orderInfo['promotions_give']) { $promotions_give = is_string($orderInfo['promotions_give']) ? json_decode($promotions_give, true) : $orderInfo['promotions_give']; } $promotions = $promotions_give['promotions'] ?? []; $pid = $orderInfo['pid'] > 0 ? $orderInfo['pid'] : $orderInfo['id']; //查询优惠记录 $orderPromotions = $this->dao->getPromotionsDetailList(['order_id' => $oid]); //查询子订单 $spliteOrder = $storeOrderServices->getColumn(['pid' => $pid, 'is_system_del' => 0], 'id,order_id'); if ($spliteOrder && $orderPromotions && $promotions) { /** @var StoreOrderCartInfoServices $storeOrderCartInfoServices */ $storeOrderCartInfoServices = app()->make(StoreOrderCartInfoServices::class); $data_all = $data = []; $data['uid'] = $orderInfo['uid']; $data['add_time'] = time(); foreach ($spliteOrder as $order) { $cartInfo = $storeOrderCartInfoServices->getColumn(['oid' => $order['id']], 'id,product_id,cart_num,cart_info'); if (!$cartInfo) { continue; } $data['oid'] = $order['id']; foreach ($cartInfo as $key => $cart) { $data['product_id'] = $cart['product_id']; $_info = is_string($cart['cart_info']) ? json_decode($cart['cart_info'], true) : $cart['cart_info']; $unique = $_info['product_attr_unique'] ?? ''; foreach ($promotions as $key => $info) { if (isset($info['details'][$unique])) { $data['promotions_id'] = $info['id']; $data['promotions_price'] = floatval(bcmul((string)($info['details'][$unique]['promotions_true_price'] ?? 0), (string)$cart['cart_num'], 2)); $data_all[] = $data; } } } } if ($data_all) { $this->transaction(function () use ($data_all, $spliteOrder) { $this->dao->delete(['oid' => array_column($spliteOrder, 'id')]); $this->dao->saveAll($data_all); }); } } return true; } /** * 申请退款订单优惠详情处理 * @param int $oid * @param array $cartInfo * @return bool */ public function applyRefundOrderPromotions(int $oid, array $cartInfo = []) { /** @var StoreOrderServices $storeOrderServices */ $storeOrderServices = app()->make(StoreOrderServices::class); $orderInfo = $storeOrderServices->getOne(['id' => $oid, 'is_del' => 0]); if (!$orderInfo) { return []; } $promotions_give = []; $promotions = []; if (isset($orderInfo['promotions_give']) && $orderInfo['promotions_give']) { $promotions_give = is_string($orderInfo['promotions_give']) ? json_decode($promotions_give, true) : $orderInfo['promotions_give']; } $promotions = $promotions_give['promotions'] ?? []; if (!$cartInfo || !$promotions) { return []; } $data_all = []; foreach ($promotions as $key => $info) { $data = []; foreach ($cartInfo as $key => $cart) { if (isset($info['details'][$cart['product_id']])) { $data['promotions_id'] = $info['id']; $data['promotions_type'] = $info['promotions_type']; $data['name'] = $info['name']; $data['title'] = $info['title']; $data['desc'] = $info['desc']; $data['promotions_price'] = bcadd((string)($data['promotions_price'] ?? 0), (string)bcmul((string)($info['details'][$cart['product_id']]['promotions_true_price'] ?? 0), (string)$cart['cart_num'], 2), 2); } } if ($data) { $data_all[] = $data; } } if ($data_all) { $typeArr = array_column($data_all, 'promotions_type'); array_multisort($typeArr, SORT_ASC, $data_all); } return $data_all; } }