123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961 |
- <?php
- // +----------------------------------------------------------------------
- // | 萤火商城系统 [ 致力于通过产品和服务,帮助商家高效化开拓市场 ]
- // +----------------------------------------------------------------------
- // | Copyright (c) 2017~2021 https://www.yiovo.com All rights reserved.
- // +----------------------------------------------------------------------
- // | Licensed 这不是一个自由软件,不允许对程序代码以任何形式任何目的的再发行
- // +----------------------------------------------------------------------
- // | Author: 萤火科技 <admin@yiovo.com>
- // +----------------------------------------------------------------------
- declare (strict_types=1);
- namespace app\api\service\order;
- use app\api\model\card\UserRiceCard as UserRiceCardModel;
- use app\api\model\card\UserRiceCardConsume as UserRiceCardConsumeModel;
- use app\api\model\fullsend\FullSendActivity;
- use app\api\model\GoodsCategoryRel as GoodsCategoryRelModel;
- use app\api\model\GoodsPackage as GoodsPackageModel;
- use app\api\model\kj\KjActivityJoin;
- use app\api\model\member\DeductionLimit as DeductionLimitModel;
- use app\api\model\member\GoldRice as GoldRiceModel;
- use app\api\model\OrderGoodsTaocan as OrderGoodsTaocanModel;
- use app\api\model\Order as OrderModel;
- use app\api\model\PromotionMonitor;
- use app\api\model\User as UserModel;
- use app\api\model\Goods as GoodsModel;
- use app\api\model\Setting as SettingModel;
- use app\api\model\shop\Shops;
- use app\api\model\UserAddress;
- use app\api\model\UserCoupon as UserCouponModel;
- use app\api\service\User as UserService;
- use app\api\service\Payment as PaymentService;
- use app\api\service\coupon\GoodsDeduct as GoodsDeductService;
- use app\api\service\ricecard\GoodsDeduct as RiceDeductService;
- use app\api\service\points\GoodsDeduct as PointsDeductService;
- use app\api\service\order\source\checkout\Factory as CheckoutFactory;
- use app\common\enum\Setting as SettingEnum;
- use app\common\enum\order\PayType as OrderPayTypeEnum;
- use app\common\enum\order\OrderStatus as OrderStatusEnum;
- use app\common\enum\order\OrderSource as OrderSourceEnum;
- use app\common\enum\order\DeliveryType as DeliveryTypeEnum;
- use app\common\service\BaseService;
- use app\common\service\card\UserRiceCard as UserRiceCardService;
- use app\common\service\commission\RecordWaitCommission;
- use app\common\service\delivery\Express as ExpressService;
- use app\common\service\goods\source\Factory as StockFactory;
- use app\common\library\helper;
- use app\common\exception\BaseException;
- use app\common\enum\order\PayStatus as PayStatusEnum;
- use app\common\model\ShopGoodsSku;
- use app\common\model\User;
- use http\Header\Parser;
- use app\api\model\groupbuy\GroupBuyHelp;
- use app\api\model\groupbuy\GroupBuyJoin;
- use app\api\model\groupbuy\GroupBuyActivity;
- use app\api\model\order\GroupBuyPay;
- use think\facade\Log;
- /**
- * 订单结算台服务类
- * Class Checkout
- * @package app\api\service\order
- */
- class CheckoutGroupbuy extends BaseService
- {
- /* $model OrderModel 订单模型 */
- public $model;
- public $buyhelpModel;//参团模型
- public $buyjoinModel;//发起团模型
- /* @var UserModel $user 当前用户信息 */
- private $user;
- // 订单结算商品列表
- private $goodsList = [];
- // 错误信息
- protected $error;
- // 错误信息状态
- protected $errorStatus;
- /**
- * 订单结算api参数
- * @var array
- */
- private $param = [
- 'delivery' => null, // 配送方式 默认:快递配送
- 'couponId' => 0, // 优惠券id
- 'riceCardId' => 0, // 现金米卡id
- 'isUsePoints' => 0, // 是否使用积分抵扣
- 'isUseGoldRice' => 1, // 默认使用金米粒
- 'remark' => '', // 买家留言
- 'payType' => OrderPayTypeEnum::WECHAT, // 支付方式
- 'addressId' => 0, //地址ID
- 'staffUserId' => 0, //分享链接用户ID
- ];
- /**
- * 订单结算的规则
- * @var array
- */
- private $checkoutRule = [
- 'isUserGrade' => false, // 会员等级折扣
- 'isCoupon' => true, // 优惠券抵扣
- 'isRiceCard' => true, // 现金米卡抵扣
- 'isUsePoints' => false, // 是否使用积分抵扣
- ];
- /**
- * 订单来源
- * @var array
- */
- private $orderSource = [
- 'source' => OrderSourceEnum::GROUPBUY,
- 'source_id' => 0,
- ];
- /**
- * 订单结算数据
- * @var array
- */
- private $orderData = [];
- /**
- * 构造函数
- * Checkout constructor.
- * @throws BaseException
- */
- public function __construct()
- {
- parent::__construct();
- $this->user = UserService::getCurrentLoginUser(true);
- $this->model = new OrderModel;
- $this->buyhelpModel = new GroupBuyHelp;
- $this->buyjoinModel = new GroupBuyJoin;
- $this->storeId = $this->getStoreId();
- }
- /**
- * 设置结算台请求的参数
- * @param $param
- * @return array
- */
- public function setParam($param)
- {
- $this->param = array_merge($this->param, $param);
- return $this->getParam();
- }
- /**
- * 获取结算台请求的参数
- * @return array
- */
- public function getParam()
- {
- return $this->param;
- }
- /**
- * 订单结算的规则
- * @param $data
- * @return $this
- */
- public function setCheckoutRule($data)
- {
- $this->checkoutRule = array_merge($this->checkoutRule, $data);
- return $this;
- }
- /**
- * 设置订单来源(普通订单)
- * @param $data
- * @return $this
- */
- public function setOrderSource($data)
- {
- $this->orderSource = array_merge($this->orderSource, $data);
- return $this;
- }
- /**
- * 订单确认-结算台
- * @param $goodsList
- * @return array
- * @throws BaseException
- * @throws \think\db\exception\DataNotFoundException
- * @throws \think\db\exception\DbException
- * @throws \think\db\exception\ModelNotFoundException
- */
- public function onCheckout($goodsList)
- {
- // 订单确认-立即购买
- $this->goodsList = $goodsList;
- return $this->checkout();
- }
- /**
- * 订单结算台
- * @return array
- * @throws BaseException
- * @throws \think\db\exception\DataNotFoundException
- * @throws \think\db\exception\DbException
- * @throws \think\db\exception\ModelNotFoundException
- */
- private function checkout()
- {
- // 整理订单数据
- $this->orderData = $this->getOrderData();
- // 验证商品状态, 是否允许购买
- $this->validateGoodsList();
- // 设置订单商品总金额()
- $this->setOrderTotalPrice();
- //订单总运费金额
- $this->setOrderExpress();
- //金米粒抵扣-V1.4.0版本添加2022年6月6日
- $this->setOrderGolRiceAmount();
- //获取当前可用的现金卡列表
- $userRiceCardList = $this->getUserRiceCardList();
- //计算使用米卡现金券抵扣后的金额
- $this->setOrderRiceCardMoney($userRiceCardList,(int)$this->param['riceCardId']);
- // 计算订单商品的实际付款金额
- $this->setOrderGoodsPayPrice();
- // 计算订单最终金额+运费
- $this->setOrderPayPrice();
- //订单商品的所有店铺集合2021年9月28日 10:56:45
- $this->setOrderProviderIds();
- // 订单商品总数量
- $orderTotalNum = helper::getArrayColumnSum($this->goodsList, 'total_num');
- // 返回订单数据
- return array_merge([
- 'goodsList' => $this->goodsList, // 商品信息
- 'orderTotalNum' => $orderTotalNum, // 商品总数量
- // 'couponList' => array_values($couponList), // 优惠券列表
- 'hasError' => $this->hasError(),
- 'errorMsg' => $this->getError(),
- 'errorStatus' => $this->getErrorStatus(),
- ], $this->orderData);
- }
- /**
- * 设置订单使用金米粒抵扣信息
- * @return bool
- * @throws BaseException
- */
- private function setOrderGolRiceAmount()
- {
- // 设置默认数据:订单信息
- helper::setDataAttribute($this->orderData, [
- 'goldRiceAmount' => 0, // 金米粒抵扣总数量 1金米粒=0.01元
- 'goldRiceMoney' => 0.00, // 金米粒抵扣总金额
- ], false);
- // 设置默认数据:订单商品列表
- helper::setDataAttribute($this->goodsList, [
- 'gold_rice_amount' => 0, // 金米粒抵扣数量
- 'gold_rice_money' => 0, // 金米粒抵扣金额
- ], true);
- $this->orderData['isUseGoldRice'] = 0;//
- if($this->orderData['isUseGoldRice']<1){//没有使用金米粒
- return false;
- }
- $orderTotalGroupPrice = $this->orderData['orderTotalGroupPrice']; //实际支付金额
- // 如果没有可用的金米粒,直接返回
- $DeductionLimit = DeductionLimitModel::where('id','>',0)->find();
- $score = floor($DeductionLimit['discount']*$orderTotalGroupPrice);
- //不够起用数量
- if($score<$DeductionLimit['score']){
- $this->orderData['isUseGoldRice'] = -1;
- return false;
- }
- //用户可用金米粒数量不够起用数量
- if($this->user['gold_rice']<$DeductionLimit['score']){
- $this->orderData['isUseGoldRice'] = -1;
- return false;
- }
- if($score>$this->user['gold_rice']){
- $score = $this->user['gold_rice'];
- }
- // 获取优惠券信息
- $goodsListTemp = [];
- foreach ($this->goodsList as $key=> $good){
- $goodsListTemp[$key]['total_price'] = helper::bcsub($good['group_price']*$good['total_num'],0);
- }
- $RiceMoney = new RiceDeductService;
- $gold_rice_money = helper::bcdiv($score,100);
- $completed = $RiceMoney->setGoodsCouponMoney($goodsListTemp, $gold_rice_money);
- // 分配订单商品抵扣的金米粒数量
- foreach ($this->goodsList as $key => &$goods) {
- $goods['gold_rice_amount'] = isset($completed[$key]['rice_card_money']) ? $completed[$key]['rice_card_money'] : 0;
- $goods['gold_rice_money'] = helper::bcdiv($goods['gold_rice_amount'],100);
- }
- // 记录订单抵扣的金米粒数量
- $this->orderData['goldRiceAmount'] = $score;
- $this->orderData['goldRiceMoney'] = $gold_rice_money;
- return true;
- }
- //我的可用现金卡
- public function getUserRiceCardList(){
- $user = UserService::getCurrentLoginUser(true);
- $list = UserRiceCardModel::getUserRiceCardList($user['user_id'])->toArray();
- $data = [];
- foreach ($list as $key=>&$item){
- $i = 0;
- $exceptGoodsId = helper::getArrayColumn($item['riceCardGoodsExcept'],'goods_id');
- foreach ($this->goodsList as $good) {
- if(!empty($item['dk_cat_ids']) && strpos((string)$item['dk_cat_ids'],(string)$good['category']['category_id']) === false){
- unset($list[$key]);
- $i = 1;
- }
- if(!empty($exceptGoodsId) && in_array($good['goods_id'],$exceptGoodsId)){
- unset($list[$key]);
- $i = 1;
- }
- }
- if(!$i){
- unset($item['riceCardGoodsExcept']);
- $data[$item['id']] = $item;
- }
- }
- if($this->param['riceCardId']==0){ //-1表示不使用米卡
- $this->param['riceCardId'] = key($data)??0;//若果没有选择米卡,默认使用第一张
- }
- return $data;
- }
- /**
- * 整理订单数据(结算台初始化)
- * @return array
- * @throws \think\db\exception\DataNotFoundException
- * @throws \think\db\exception\DbException
- * @throws \think\db\exception\ModelNotFoundException
- */
- private function getOrderData()
- {
- // 系统支持的配送方式 (后台设置)
- $deliveryType = SettingModel::getItem(SettingEnum::DELIVERY)['delivery_type'];
- return [
- // 当前配送类型
- 'delivery' => $this->param['delivery'] > 0 ? $this->param['delivery'] : $deliveryType[0],
- // 默认地址
- 'address' => '',
- // 是否存在收货地址
- 'existAddress' => $this->user['address_id'] > 0,
- // 配送费用
- 'expressPrice' => 0.00,
- //是否使用了金米粒
- 'isUseGoldRice' => $this->param['isUseGoldRice'],
- //金米粒数量
- 'userGoldRiceNum' => $this->user['gold_rice']??0,
- // 当前用户收货城市是否存在配送规则中
- 'isIntraRegion' => true,
- // 是否允许使用积分抵扣
- 'isAllowPoints' => false,
- // 是否使用积分抵扣
- 'isUsePoints' => $this->param['isUsePoints'],
- // 积分抵扣金额
- 'pointsMoney' => 0.00,
- // 赠送的积分数量
- 'pointsBonus' => 0,
- // 支付方式
- 'payType' => $this->param['payType'],
- // 系统设置
- 'setting' => $this->getSetting(),
- // 推广监控ID
- "promotionMonitorId" => $this->param['promotionMonitorId'] ?? 0
- ];
- }
- /**
- * 获取订单页面中使用到的系统设置
- * @return array
- * @throws \think\db\exception\DataNotFoundException
- * @throws \think\db\exception\DbException
- * @throws \think\db\exception\ModelNotFoundException
- */
- private function getSetting()
- {
- // 系统支持的配送方式 (后台设置)
- $deliveryType = SettingModel::getItem(SettingEnum::DELIVERY)['delivery_type'];
- // 积分设置
- $pointsSetting = SettingModel::getItem(SettingEnum::POINTS);
- return [
- 'deliveryType' => $deliveryType, // 支持的配送方式
- 'points_name' => $pointsSetting['points_name'], // 积分名称
- 'points_describe' => $pointsSetting['describe'], // 积分说明
- ];
- }
- /**
- * 验证订单商品的状态
- * @return bool
- */
- private function validateGoodsList()
- {
- $Checkout = CheckoutFactory::getFactory(
- $this->user,
- $this->goodsList,
- $this->orderData['delivery'],
- $this->shopInfo['shop_id'] ?? 0,
- $this->orderSource['source']
- );
- $status = $Checkout->validateGoodsList();
- if(!$status){
- $this->setError($Checkout->getError());
- $this->setErrorStatus(422);
- }
- return $status;
- }
- /**
- * 设置订单的商品总金额(不含优惠折扣)
- */
- private function setOrderTotalPrice()
- {
- // 订单商品的总金额
- $this->orderData['orderTotalPrice'] = helper::number2(helper::getArrayColumnSum($this->goodsList, 'total_price'));
- //拼团总金额
- $this->orderData['orderTotalGroupPrice'] = helper::number2(helper::getArrayColumnSum($this->goodsList, 'group_price')*helper::getArrayColumnSum($this->goodsList, 'total_num'));
- }
- /**
- * 订单商品的所有店铺集合
- */
- private function setOrderProviderIds()
- {
- // 订单商品的所有店铺集合
- $this->orderData['orderProviderIds'] = implode(',',array_values(array_unique(helper::getArrayColumn($this->goodsList, 'provider_id'))));
- }
- /**
- * 设置订单的实际支付金额(含配送费)
- */
- private function setOrderPayPrice()
- {
- // 订单金额(含优惠折扣)
- //(商品总价 - N件X折 - 优惠券 - 分销员)+ 运费 = 微信支付+米卡抵扣+米卡抵扣运费
- //(total_price-coupon_money-distrbutor_total_money)+express_price = pay_price+rice_card_money+rice_card_express_money
- $this->orderData['orderPrice'] = helper::number2(helper::getArrayColumnSum($this->goodsList, 'total_pay_price'));
- // 订单实付款金额(订单金额 + 运费 - 现金卡运费抵扣金额)
- $this->orderData['orderPayPrice'] = helper::number2(helper::bcadd($this->orderData['orderPrice'], $this->orderData['expressPrice']-$this->orderData['riceCardExpressMoney']));
- }
- /**
- * 计算订单商品的实际付款金额
- * @return bool
- */
- private function setOrderGoodsPayPrice()
- {
- // 商品总价 - 优惠抵扣
- foreach ($this->goodsList as &$goods) {
- //减去现金米卡抵扣的金额
- $value = helper::bcsub($goods['group_price']*$goods['total_num'], $goods['rice_card_money']+$goods['gold_rice_money']);
- $goods['total_pay_price'] = helper::number2($value);
- }
- return true;
- }
- /**
- * 设置订单现金米卡抵扣信息
- * @param int $riceCardId 可使用米卡列表
- * @param int $riceCardId 当前选择的现金米卡id
- * @return bool
- * @throws BaseException
- */
- private function setOrderRiceCardMoney($userRiceCardList,int $riceCardId)
- {
- // 设置默认数据:订单信息
- helper::setDataAttribute($this->orderData, [
- 'riceCardId' => $riceCardId, // 用户现金米卡id
- 'riceCardMoney' => 0, // 现金米卡抵扣总金额
- 'riceCardExpressMoney' => 0, // 现金米卡抵扣运费
- 'userRiceCardList' => [], // 米卡列表
- 'userRiceCard' => [], // 已选择的米卡
- ], false);
- // 设置默认数据:订单商品列表
- helper::setDataAttribute($this->goodsList, [
- 'rice_card_id' => 0, // 用户现金米卡id
- 'rice_card_money' => 0, // 金米卡抵扣金额
- ], true);
- if($riceCardId<0){//如果米卡ID小于0表示不使用,但是也要返回可使用列表
- $this->orderData['userRiceCardList'] = array_values($userRiceCardList);
- return true;
- }
- // 验证选择的优惠券ID是否合法
- if (!$this->verifyUserRiceCard($riceCardId, $userRiceCardList)) {
- return false;
- }
- // 获取优惠券信息
- $riceCard = $this->getRiceCardInfo($riceCardId, $userRiceCardList);
- $goodsListTemp = [];
- foreach ($this->goodsList as $key=> $good){
- $goodsListTemp[$key]['total_price'] = helper::bcsub($good['group_price']*$good['total_num'],$good['gold_rice_money']);
- }
-
- $RiceMoney = new RiceDeductService;
- $completed = $RiceMoney->setGoodsCouponMoney($goodsListTemp, $riceCard['balance']);
- // 分配订单商品优惠券抵扣金额
- $rice_card_money = 0;
- foreach ($this->goodsList as $key => &$goods) {
- $goods['rice_card_money'] = isset($completed[$key]['rice_card_money']) ? $completed[$key]['rice_card_money'] / 100 : 0;
- $goods['rice_card_id'] = $riceCardId;
- $rice_card_money += $goods['rice_card_money'];
- }
- $orderTotalGroupPrice = $this->orderData['orderTotalGroupPrice']-$this->orderData['goldRiceMoney']; //实际支付金额-金米粒抵扣的金额
- //有运费,并且现金米卡可用的金额大于商品总价
- $rice_card_express_money = 0;
- if($riceCard['balance']>$orderTotalGroupPrice && $this->orderData['expressPrice']>0){
- $residueMoney = $riceCard['balance']-$orderTotalGroupPrice;
- if($residueMoney-$this->orderData['expressPrice']>0){
- $rice_card_express_money += $this->orderData['expressPrice'];
- }else{
- $rice_card_express_money += $residueMoney;
- }
- }
- // 记录订单现金米卡信息
- $this->orderData['userRiceCard'] = $userRiceCardList[$riceCardId];
- $this->orderData['riceCardId'] = $riceCardId;
- $this->orderData['riceCardMoney'] = helper::bcmul($rice_card_money+$rice_card_express_money,1);
- $this->orderData['riceCardExpressMoney'] = helper::bcmul($rice_card_express_money,1);
- $this->orderData['userRiceCardList'] = array_values($userRiceCardList);
- return true;
- }
- /**
- * 验证用户选择的现金米卡
- * @param $riceCard
- * @return bool
- * @throws BaseException
- */
- private function verifyUserRiceCard($riceCardId,$userRiceCardList)
- {
- // 是否开启现金米卡抵扣
- if (!$this->checkoutRule['isRiceCard']) {
- return false;
- }
- // 如果没有可用的现金米卡,直接返回
- if ($riceCardId <= 0) {
- return false;
- }
- // 判断优惠券是否存在
- $riceCard = $this->getRiceCardInfo($riceCardId, $userRiceCardList);
- // 如果没有现金米卡,直接返回
- if (empty($riceCard)) {
- throwError('未找到米卡信息');
- }
- return true;
- }
- /**
- * 查找指定的优惠券信息
- * @param int $couponId 优惠券ID
- * @param array $couponList 优惠券列表
- * @return false|mixed
- */
- private function getRiceCardInfo(int $riceCardId, array $userRiceCardList)
- {
- return helper::getArrayItemByColumn($userRiceCardList, 'id', $riceCardId);
- }
- /**
- * 订单配送-快递配送
- * @return bool
- * @throws \think\db\exception\DataNotFoundException
- * @throws \think\db\exception\DbException
- * @throws \think\db\exception\ModelNotFoundException
- */
- private function setOrderExpress()
- {
- // 设置默认数据:配送费用
- helper::setDataAttribute($this->goodsList, [
- 'expressPrice' => 0,
- ], true);
- // 当前用户收货城市id
- if($this->param['addressId']){ //有传参
- $addredd = UserAddress::get(['user_id' => $this->user['user_id'], 'address_id' => $this->param['addressId']]);
- $cityId = $addredd ? (int)$addredd['city_id'] : 0;
- $this->orderData['address'] = $addredd;
- }else{ //没有传参读默认地址
- $cityId = $this->user['address_default'] ? (int)$this->user['address_default']['city_id'] : 0;
- $this->orderData['address'] = $this->user['address_default'];
- }
- if ($this->param['delivery'] == DeliveryTypeEnum::EXPRESS) { // 普通快递
- // 初始化配送服务类
- $ExpressService = new ExpressService($cityId, $this->goodsList);
- // 验证商品是否在限购配送范围
- $isDeliveryLimit = $ExpressService->isDeliveryLimit();
- if($cityId > 0){
- if ($isDeliveryLimit == false) {
- $this->setError("很抱歉,您的收货地址在限购地区的配送范围内");
- $this->setErrorStatus(423);
- $this->orderData['isIntraRegion'] = $isDeliveryLimit;
- }else{
- // 验证商品是否在配送范围
- $isIntraRegion = $ExpressService->isIntraRegion();
- if ($isIntraRegion == false) {
- $notInRuleGoodsName = $ExpressService->getNotInRuleGoodsName();
- $this->setError("很抱歉,您的收货地址不在商品 [".limit_str((string)$notInRuleGoodsName)."] 的配送范围内");
- $this->setErrorStatus(423);
- }
- $this->orderData['isIntraRegion'] = $isIntraRegion;
- }
- }
- // 订单总运费金额
- $this->orderData['expressPrice'] = $ExpressService->getDeliveryFee();
- } else { // 门店自提
- $this->orderData['expressPrice'] = "0.00";
- }
-
- return true;
- }
- /**
- * 创建新订单
- * @param array $order 订单信息
- * @return bool
- */
- public function createOrder(array $order)
- {
- // 表单验证
- if (!$this->validateOrderForm($order)) {
- return false;
- }
- // 创建新的订单
- $status = $this->buyhelpModel->transaction(function () use ($order) {
- // dd($order);
- // 创建订单事件
- return $this->createOrderEvent($order);
- });
- // 余额支付标记订单已支付
- return $status;
- }
- /**
- * 创建订单事件
- * @param $order
- * @return bool
- * @throws BaseException
- * @throws \Exception
- */
- private function createOrderEvent($order)
- {
-
- // 新增订单记录
- $status = $this->add($order, $this->param['remark']);
- //金米粒处理逻辑
- if($order['orderPayPrice']>0){
- //冻结金米粒数量
- if($order['goldRiceAmount']>0) UserModel::setIncDecByField($this->user['user_id'],['gold_rice_frozen'=>(float)$order['goldRiceAmount']],['gold_rice'=>(float)$order['goldRiceAmount']]);
- }else{
- if($order['goldRiceAmount']>0){
- //写金米粒出账记录
- GoldRiceModel::add($this->user['user_id'],$this->orderData['order_no'],'下单抵扣',$order['goldRiceAmount'],0);
- //用户直接扣除金米粒
- UserModel::setDecByField($this->user['user_id'],'gold_rice',(float)$order['goldRiceAmount']);
- }
- }
- if($order['riceCardId']>0 && $order['riceCardMoney']>0){
- //根据支付的金额来判断逻辑
- if($order['orderPayPrice']>0){
- //冻结现金卡金额
- UserRiceCardModel::setIncDecByField($order['riceCardId'],['frozen_amount'=>(float)$order['riceCardMoney']],['balance'=>(float)$order['riceCardMoney']]);
- }else{//不需要结算金额
- //写现金卡出账记录
- UserRiceCardConsumeModel::add($order['userRiceCard'],$this->orderData['order_no'],$order['orderPayPrice'],$order['riceCardMoney']);
- //如果可用余额等于要抵扣的金额
- if($order['riceCardMoney']==$order['userRiceCard']['balance']){
- //现金卡直接减可用余额,并且状态改为已失效
- UserRiceCardModel::setIncDecByField($order['riceCardId'],[],['balance'=>(float)$order['riceCardMoney']],['effect_state'=>2]);
- }else{
- //现金卡直接减可用余额
- UserRiceCardModel::setDecByField($order['riceCardId'],'balance',(float)$order['riceCardMoney']);
- }
- // 更新商品销量(付款后减库存、加销量)
- $order['goods'] = $order['goodsList'];
- $order['delivery_type'] = $order['delivery'];
- StockFactory::getFactory(OrderSourceEnum::GROUPBUY)->updateStockSales($order);
- }
- }
- return $status;
- }
- /**
- * 构建支付请求的参数
- * @return array
- * @throws BaseException
- * @throws \think\db\exception\DataNotFoundException
- * @throws \think\db\exception\DbException
- * @throws \think\db\exception\ModelNotFoundException
- */
- public function onOrderPayment()
- {
- return PaymentService::orderPayment($this->model, $this->param['payType']);
- }
- /**
- * 表单验证 (订单提交)
- * @param array $order 订单信息
- * @return bool
- */
- private function validateOrderForm(array $order)
- {
- if ($order['delivery'] == DeliveryTypeEnum::EXPRESS) {
- if (empty($order['address'])) {
- $this->error = '您还没有选择配送地址';
- return false;
- }
- }
- // 余额支付时判断用户余额是否足够
- if ($order['payType'] == OrderPayTypeEnum::BALANCE) {
- if ($this->user['balance'] < $order['orderPayPrice']) {
- $this->error = '您的余额不足,无法使用余额支付';
- return false;
- }
- }
- return true;
- }
- /**
- * 当前订单是否存在和使用积分抵扣
- * @param $order
- * @return bool
- */
- private function isExistPointsDeduction($order)
- {
- return $order['isAllowPoints'] && $order['isUsePoints'];
- }
- /**
- * 新增订单记录
- * @param $order
- * @param string $remark
- * @return false|int
- */
- private function add($order, $remark = ''){
- $user = UserModel::where('user_id',$this->user['user_id'])->with(['avatar'])->find();
- //发起拼团
- $help = [];
- // 根据推广监控ID判断活动效果归属
- $promotionMonitorId = PromotionMonitor::checkActEffectOwner(4, $order['promotionMonitorId'] ?? 0, $order['group_buy_activity_id']);
- if($order['join_id']==0){
- $activity = GroupBuyActivity::where("id",$order['group_buy_activity_id'])->find();
- $join = [
- 'group_buy_activity_id' => $order['group_buy_activity_id'],
- 'people_count'=> $activity['people_count'],
- 'end_time' => Date("Y-m-d H:i:s",time() + $activity['during_time']*60*60),
- 'share_title'=>$activity['share_title'],
- 'create_time'=>time(),
- 'update_time'=>time(),
- 'user_id'=>$this->user['user_id']
- ];
- $this->buyjoinModel->save($join);
- $help = [
- 'user_id' => $this->user['user_id'],
- 'order_no' => $this->model->orderNo('PT'),
- 'group_buy_activity_id' => $order['group_buy_activity_id'],
- 'join_id'=>$this->buyjoinModel['id'],
- 'goods_num' =>$order['orderTotalNum'],
- 'head_picture'=>$user->avatar['preview_url']??'',
- 'gold_rice_amount' => $order['goldRiceAmount']??0,
- 'gold_rice_money' => $order['goldRiceMoney']??0,
- 'rice_card_id'=>$order['riceCardId']<=0?0:$order['riceCardId'],
- 'rice_card_money'=>$order['riceCardMoney'],
- 'rice_card_express_money'=>$order['riceCardExpressMoney'],
- 'pay_money'=> $order['orderPayPrice'],
- 'express_money'=> $order['expressPrice'],
- 'order_money'=> helper::bcadd($order['expressPrice'],$order['orderTotalGroupPrice']),
- 'provider_ids'=>$order['orderProviderIds'],
- 'good_rice_card_money'=>$order['goodsList'][0]['rice_card_money']??0,
- 'promotion_monitor_id' => $promotionMonitorId,
- 'staff_user_id' => $order['goodsList'][0]['staffUserId'] ?? 0,
- 'staff_shop_id' => $order['goodsList'][0]['shopId'] ?? 0
- ];
- }
- //参与拼团
- if($order['join_id']>0){
- $help = [
- 'user_id' => $this->user['user_id'],
- 'order_no' => $this->model->orderNo('PT'),
- 'group_buy_activity_id' => $order['group_buy_activity_id'],
- 'join_id'=>$order['join_id'],
- 'goods_num' =>$order['orderTotalNum'],
- 'head_picture'=>$user->avatar['preview_url']??'',
- 'gold_rice_amount' => $order['goldRiceAmount']??0,
- 'gold_rice_money' => $order['goldRiceMoney']??0,
- 'rice_card_id'=>$order['riceCardId']<=0?0:$order['riceCardId'],
- 'rice_card_money'=>$order['riceCardMoney'],
- 'rice_card_express_money'=>$order['riceCardExpressMoney'],
- 'pay_money'=> $order['orderPayPrice'],
- 'express_money'=> $order['expressPrice'],
- 'rice_card_express_money'=>$order['riceCardExpressMoney'],
- 'order_money'=> helper::bcadd($order['expressPrice'],$order['orderTotalGroupPrice']),
- 'provider_ids'=>$order['orderProviderIds'],
- 'good_rice_card_money'=>$order['goodsList'][0]['rice_card_money']??0,
- 'promotion_monitor_id' => $promotionMonitorId,
- 'staff_user_id' => $order['goodsList'][0]['staffUserId'] ?? 0,
- 'staff_shop_id' => $order['goodsList'][0]['shopId'] ?? 0
- ];
- }
- $address['user_name'] = $order['address']['name']??'';
- $address['phone'] = $order['address']['phone']??'';
- $address['province_id'] = $order['address']['province_id']??0;
- $address['city_id'] = $order['address']['city_id']??0;
- $address['region_id'] = $order['address']['region_id']??0;
- $address['detail'] = $order['address']['detail']??'';
- $help = array_merge($help,$address);
- $help['pay_type'] = $order['payType']??OrderPayTypeEnum::WECHAT;
- $isPay = false;
- //米卡兑换直接成功
- if($order['orderPayPrice']<=0 || $order['payType']==OrderPayTypeEnum::MICAH_EXCHANGE){
- $help['pay_state'] = 1;
- $help['pay_time'] = time();
-
- $partJoin = GroupBuyJoin::where('id','=',$help['join_id'])->find();
- $partJoin->help_count = $partJoin->help_count + 1;
- $partJoin->save();
- $isPay = true;
- }
- $this->orderData['order_no'] = $help['order_no'];
- // 保存参团记录
- $this->buyhelpModel->save($help);
- //米卡支付完成并且属于参团的,要看是不是成团了,成团要写订单
- if($isPay&&$order['join_id']>0){
- if($partJoin->help_count==$partJoin->people_count){
- $pay = new GroupBuyPay;
- $pay->ptSuccessNotify($help['join_id']);
- }
- }
- StockFactory::getFactory(OrderSourceEnum::GROUPBUY)->updateGoodsStock($order);
- //更新拼团活动库存的数量
- StockFactory::getFactory(OrderSourceEnum::GROUPBUY)->updateActivityStock($order);
- return true;
- }
-
- /**
- * 更新商品库存 (针对下单减库存的商品)
- * 普通快递、门店自提 分开扣库存
- * @param $order
- * @return mixed
- */
- private function updateGoodsStockNum($order)
- {
- return StockFactory::getFactory($this->model['order_source'])->updateGoodsStock($order);
- }
- /**
- * 保存砍价信息
- * @param $order
- * @return int
- */
- private function saveKjActivityJoin($order)
- {
- // 订单商品列表
- foreach ($order['goodsList'] as $key=> $goods) {
- $data[] = [
- 'where' => ['id' => $goods['bargain_id']],
- 'data' => [
- 'order_id' => $this->model['order_id'],//订单ID
- 'order_price' => helper::bcadd($goods['bargain_price'],$this->orderData['expressPrice']),//订单金额+运费
- 'is_submit_order'=>1 //是否提交订单 1是
- ]
- ];
- }
- return (new KjActivityJoin())->updateAll($data) !== false;
- }
- /**
- * 记录收货地址
- * @param $address
- * @return false|\think\Model
- */
- private function saveOrderAddress($address)
- {
- return $this->model->address()->save([
- 'user_id' => $this->user['user_id'],
- 'store_id' => $this->storeId,
- 'name' => $address['name'],
- 'phone' => $address['phone'],
- 'province_id' => $address['province_id'],
- 'city_id' => $address['city_id'],
- 'region_id' => $address['region_id'],
- 'detail' => $address['detail'],
- ]);
- }
- /**
- * 设置错误信息
- * @param $error
- */
- protected function setError($error)
- {
- empty($this->error) && $this->error = $error;
- }
- /**
- * 获取错误信息
- * @return mixed
- */
- public function getError()
- {
- return $this->error ?: '';
- }
- /**
- * 设置错误状态
- * @param $errorStatus
- */
- protected function setErrorStatus($errorStatus)
- {
- empty($this->errorStatus) && $this->errorStatus = $errorStatus;
- }
- /**
- * 获取错误信息
- * @return mixed
- */
- public function getErrorStatus()
- {
- return $this->errorStatus ?: 0;
- }
- /**
- * 是否存在错误
- * @return bool
- */
- public function hasError()
- {
- return !empty($this->error);
- }
- }
|