From e6405cd6487ceeeefc1ffecbe00950b9635c942f Mon Sep 17 00:00:00 2001 From: mkm <727897186@qq.com> Date: Sat, 8 Jun 2024 22:06:30 +0800 Subject: [PATCH] =?UTF-8?q?refactor(PayNotifyLogic):=20=E4=BC=98=E5=8C=96?= =?UTF-8?q?=E6=94=AF=E4=BB=98=E5=9B=9E=E8=B0=83=E5=A4=84=E7=90=86=E9=80=BB?= =?UTF-8?q?=E8=BE=91=EF=BC=8C=E6=8F=90=E9=AB=98=E4=BB=A3=E7=A0=81=E5=8F=AF?= =?UTF-8?q?=E8=AF=BB=E6=80=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/common/logic/PayNotifyLogic.php | 105 ++++++++++++++-------------- 1 file changed, 51 insertions(+), 54 deletions(-) diff --git a/app/common/logic/PayNotifyLogic.php b/app/common/logic/PayNotifyLogic.php index 86be5438..ea4fe775 100644 --- a/app/common/logic/PayNotifyLogic.php +++ b/app/common/logic/PayNotifyLogic.php @@ -33,19 +33,18 @@ class PayNotifyLogic extends BaseLogic try { if ($action != 'cash_pay' && $action != 'balancePay') { $payNotifyLogLogic = new PayNotifyLogLogic(); - if($action == 'refund'){ - $payNotifyLogLogic->insert($action, $extra,PayNotifyLog::TYPE_REFUND); - }else{ + if ($action == 'refund') { + $payNotifyLogLogic->insert($action, $extra, PayNotifyLog::TYPE_REFUND); + } else { $payNotifyLogLogic->insert($action, $extra); } - } self::$action($orderSn, $extra); Db::commit(); return true; } catch (\Exception $e) { Db::rollback(); - Log::error('支付回调处理失败' . $e->getMessage().',lien:'.$e->getLine().',file:'.$e->getFile()); + Log::error('支付回调处理失败' . $e->getMessage() . ',lien:' . $e->getLine() . ',file:' . $e->getFile()); throw new \Exception($e->getMessage()); } } @@ -59,7 +58,7 @@ class PayNotifyLogic extends BaseLogic * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ - public static function balancePay($orderSn, $extra = []) + public static function balancePay($orderSn, $extra = []) { $order = StoreOrder::where('order_id', $orderSn)->findOrEmpty(); $user = User::where('id', $order['uid'])->find(); @@ -102,16 +101,16 @@ class PayNotifyLogic extends BaseLogic $user = User::where('id', $order['uid'])->find(); if ($order->pay_type == 9) { $order->status = 2; - }else{ + } else { $capitalFlowDao = new CapitalFlowLogic($user); //微信支付和用户余额无关 - $capitalFlowDao->userExpense('user_order_pay', 'order', $order['id'], $order->pay_price,'',1); + $capitalFlowDao->userExpense('user_order_pay', 'order', $order['id'], $order->pay_price, '', 1); } - self::afterPay($order,$extra['transaction_id']); + self::afterPay($order, $extra['transaction_id']); //活动期间消费 - $check = DictType::where('type','activities')->find(); - if(isset($check) && $check['status'] == 1 && $user['user_ship'] == 0){ + $check = DictType::where('type', 'activities')->find(); + if (isset($check) && $check['status'] == 1 && $user['user_ship'] == 0) { self::dealChange($order['uid']); } @@ -133,7 +132,7 @@ class PayNotifyLogic extends BaseLogic public static function refund($orderSn, $extra = []) { //更新状态 - $order = StoreOrder::where('order_id',$orderSn)->findOrEmpty(); + $order = StoreOrder::where('order_id', $orderSn)->findOrEmpty(); if ($order->isEmpty() || $order->status == OrderEnum::REFUND_PAY) { return true; } @@ -144,36 +143,37 @@ class PayNotifyLogic extends BaseLogic $order->refund_num += 1; $order->save(); -// self::afterPay($order,$extra['transaction_id']); + // self::afterPay($order,$extra['transaction_id']); } public static function recharge($orderSn, $extra = []) { - $order = UserRecharge::where('order_id', $orderSn)->findOrEmpty(); - if ($order->isEmpty() || $order->paid == PayEnum::ISPAID) { - return true; - } - $price = bcdiv($extra['amount']['payer_total'], 100, 2); - $order->price = $price; - $order->paid = 1; - $order->pay_time = time(); - $order->save(); - $uid = $order->uid; - $user = User::where('id',$uid)->findOrEmpty(); - if ($user->isEmpty()) { - return true; - } - bcscale(2); - $user->now_money = bcadd($user->now_money, $price, 2); - $user->total_recharge_amount = bcadd($user->total_recharge_amount, $price, 2); - $user->save(); - //用户的财务add - $capitalFlowDao = new CapitalFlowLogic($user); - $capitalFlowDao->userIncome('user_balance_recharge', 'user_recharge', $order['id'], $price); - //更新等级 - self::dealLevel($uid,$user->total_recharge_amount); + $order = UserRecharge::where('order_id', $orderSn)->findOrEmpty(); + if ($order->isEmpty() || $order->paid == PayEnum::ISPAID) { return true; + } + $price = bcdiv($extra['amount']['payer_total'], 100, 2); + $order->price = $price; + $order->paid = 1; + $order->pay_time = time(); + $order->save(); + $uid = $order->uid; + $user = User::where('id', $uid)->findOrEmpty(); + //用户的财务add + $capitalFlowDao = new CapitalFlowLogic($user); + $capitalFlowDao->userIncome('user_balance_recharge', 'user_recharge', $order['id'], $price); + + if ($user->isEmpty()) { + return true; + } + bcscale(2); + $user->now_money = bcadd($user->now_money, $price, 2); + $user->total_recharge_amount = bcadd($user->total_recharge_amount, $price, 2); + $user->save(); + //更新等级 + self::dealLevel($uid, $user->total_recharge_amount); + return true; } /** @@ -239,7 +239,7 @@ class PayNotifyLogic extends BaseLogic * @param $order * @return void */ - public static function afterPay($order,$transaction_id=0) + public static function afterPay($order, $transaction_id = 0) { $financeLogic = new StoreFinanceFlowLogic(); $financeLogic->order = $order; @@ -252,44 +252,42 @@ class PayNotifyLogic extends BaseLogic $fees = bcdiv(bcmul($order['pay_price'], '0.02', 2), 1, 2); $financeLogic->in($transaction_id, $fees, OrderEnum::ORDER_COMMITION, $order['store_id']); //手续费入账 - $financeLogic->out($transaction_id, $order['profit'], OrderEnum::MERCHANT_ORDER_OBTAINS, $order['store_id'], $order['staff_id'], 0);//商户获得的 + $financeLogic->out($transaction_id, $order['profit'], OrderEnum::MERCHANT_ORDER_OBTAINS, $order['store_id'], $order['staff_id'], 0); //商户获得的 //冻结金额的 $frozen = bcsub($order->profit, $fees, 2); //缴纳齐全了就加商户没有就加到平台 $money_limt = SystemStore::where('id', $order['store_id'])->field('paid_deposit,security_deposit')->find(); - $deposit = bcsub($money_limt['security_deposit'], $money_limt['paid_deposit'], 2);//剩余额度 + $deposit = bcsub($money_limt['security_deposit'], $money_limt['paid_deposit'], 2); //剩余额度 if ($deposit > 0 && $frozen > 0) { $amount = min($deposit, $frozen); $financeLogic->in($transaction_id, $amount, OrderEnum::ORDER_MARGIN, $order['store_id'], $order['staff_id']); } - } $financeLogic->save(); } } //等级处理 - public static function dealLevel($uid,$total_money) + public static function dealLevel($uid, $total_money) { $userShip = UserShip::where('limit', '<=', $total_money) ->field('id,title,limit') ->order('limit', 'desc') ->find(); - $info = User::where('id',$uid)->findOrEmpty(); - if($info && $userShip){ + $info = User::where('id', $uid)->findOrEmpty(); + if ($info && $userShip) { if ($info->user_ship != $userShip['id']) { $info->user_ship = $userShip['id']; $info->save(); } } return true; - } //处理活动期间直接改用户的等级 public static function dealChange($uid) { - User::where('id',$uid)->update(['user_ship'=>UserShipEnum::LEVEL_ONE]); + User::where('id', $uid)->update(['user_ship' => UserShipEnum::LEVEL_ONE]); return true; } @@ -300,18 +298,17 @@ class PayNotifyLogic extends BaseLogic * @param $extra * @return void */ - public static function notifyLog($order,$extra) + public static function notifyLog($order, $extra) { $data = [ - 'pay_type'=>'wechat', - 'type'=>OrderEnum::PAY, - 'amount'=>$extra['amount']['payer_total'],//分 - 'order_sn'=>$order, - 'out_trade_no'=>$extra['transaction_id'], - 'attach'=>$extra['attach'], - 'create_time'=>date('Y-m-d H:i:s',time()), + 'pay_type' => 'wechat', + 'type' => OrderEnum::PAY, + 'amount' => $extra['amount']['payer_total'], //分 + 'order_sn' => $order, + 'out_trade_no' => $extra['transaction_id'], + 'attach' => $extra['attach'], + 'create_time' => date('Y-m-d H:i:s', time()), ]; PayNotify::create($data); } - }