NN2023021801/app/api/services/BasePayServices.php

<?php
/**
 * 支付公用类
 */

namespace app\api\services;


use app\common\model\ShopGoodsModel;
use app\common\model\ShopOrderGoodsModel as OrderGoods;
use app\common\model\ShopOrderModel;
use app\common\model\ShopOrderModel as Order;
use app\common\model\UserModel;
use app\common\model\UserMoneyModel;
use app\common\model\UserShouxufeilogModel;
use app\common\model\VipOrderModel;
use jobs\VipOrderJob;
use services\CacheServices;
use think\Exception;
use think\facade\Db;
use think\facade\Env;
use utils\RedisCache;

abstract class BasePayServices
{

    /**
     * 支付状态
     * @var bool
     */
    protected $pay_status = false;

    /**
     * 支付回调信息
     * @var string
     */
    protected $notify_info = '';

    /**
     * 支付通道 1 支付宝 2 微信
     * @var int
     */
    protected $pay_way = 1;

    /**
     * 费用配置
     * @param int $uid
     * @param array $data
     * @param int $type
     * @return array
     */
    public function _payConf(int $uid, array $data, int $type = 1)
    {

        $body = $total_amount = $remarks = '';
        switch ($data['order_type']) {
            case 1: // 充值
                $body = '充值';
                $total_amount = $data['money'];
                break;
            case 2: // 实名认证
                $total_amount = Db::name('user_data')->where('uid', $uid)->value('rz_money');
                $body = '实名认证费用';
                break;
            case 3: // 开通会员
                $vip_money = Env::get('app.VIP_MONEY', 38);
                if (!$vip_money > 0) {
                    throw new Exception('会员配置不存在');
                }
                $body = '开通会员';
                $total_amount = $vip_money;
                $remarks = $data['order_id'];
                break;
            case 4: //购买商品
                $order_sn = $data['order_id'];
                $checkingOrder = Order::checkingOrder($order_sn, 0, $uid);
                if (!$checkingOrder) {
                    throw new Exception('校验订单失败');
                }
                if ($checkingOrder['flag'] !== 200) {
                    throw new Exception($checkingOrder['msg']);
                }
                $body = '购买商品';
                $total_amount = $checkingOrder['orderPayment'];
                $remarks = $order_sn;
                //更改订单支付状态为线下支付待审核状态
                if ($this->data['channel'] == 4 && $this->data['order_type'] == 4) {
                    Order::where('order_sn', 'in', $order_sn)->save(['pay_type' => 4, 'status' => 4]);
                }
                break;
        }

        if (!$body || !$total_amount || $total_amount <= 0)
            throw new Exception('配置错误');

        return [$body, $type == 1 ? $total_amount : bcmul($total_amount, 100, 2), $data['order_type'], $remarks, $data['trade_type'], $data['channel'], isset($data['voucher_img']) ? $data['voucher_img'] : ''];
    }

    /**
     * 保存订单信息
     * @param array $param
     * @param int $pay_way
     */
    public function setPaymentOrder(array $param, int $pay_way = 1)
    {
        $insert = [
            'total_fee' => $param['total_amount'],
            'trade_type' => $param['trade_type'],
            'body' => $param['body'],
            'state' => 7,
            'out_trade_no' => $param['out_trade_no'],
            'pay_way' => $param['pay_way'],
            'remarks' => $param['remarks'],
            'order_type' => $param['order_type'],
            'uid' => $param['uid'],
            'voucher_img' => $param['voucher_img'],
            'out_trade_no1'=>(isset($param['out_trade_no1'])?$param['out_trade_no1']:(isset($param[''])))
        ];
        // 信息
        $payWays = [1=>'wxpay',2=>'alipay',3=>'balancePay',14=>'huifuPay',15=>'sqzPay',16=>'sqzAliPay',17=>'sqzWxPay',18=>'sqzYljk',19=>'usdtPay',20=>'yswkPay',22=>'dkpay',56=>'ysftyPay'];
        $payWayCode = isset($payWays[$param['pay_way']])? $payWays[$param['pay_way']] : 'defpay';
        RedisCache::set("caches:payment:{$payWayCode}:otn_{$param['out_trade_no']}:{$param['uid']}_{$param['remarks']}_payment", $insert, 7200);
        Db::name('payment')->insert($insert);
    }

    /**
     * 更改订单状态
     * @return mixed
     */
    public function afterPay()
    {
        if ($this->pay_status && !empty($this->notify_info)) {
            $pay_info = Db::name('payment')->where('out_trade_no', $this->notify_info['out_trade_no'])->where('state', 7)->where('pay_way', 2)->findOrEmpty();
            if (!empty($pay_info)) {
                Db::startTrans();
                try {
                    Db::name('payment')->where('id', $pay_info['id'])->update(['state' => 6, 'pay_at' => date('Y-m-d H:i:s')]); // 更改订单状态
                    switch ($pay_info['order_type']) {
                        case 1: // 充值
                            break;
                        case 3:
                            // 充值会员
//                            break;
                        case 4: //购买商品
                            // 更改订单状态
                            $order = ShopOrderModel::where('order_sn', $pay_info['remarks'])->find();
                            $nowTime = date('Y-m-d H:i:s', time());
                            Db::name('shop_order')->where(['order_sn' => $pay_info['remarks']])
                                ->update(['pay_type' => 2, 'status' => 1, 'updated_time' => $nowTime]);

                            // 增加销量
                            $orderGoods = OrderGoods::where(['order_id' => $order['order_id']])->select()->toArray();
                            foreach ($orderGoods as $k => $v) {
                                ShopGoodsModel::where(['goods_id' => $v['goods_id']])->inc('sales_volume', $v['num'])->inc('real_sales_volume', $v['num'])->update();
                            }

                            // 送积分
                            edit_user_score(5, $order['user_id'], $order['rebate_score']);
                            edit_user_redscore(1, $order['user_id'], $order['rebate_lock_score']);

                            break;
                    }
                    Db::commit();
                    echo 'success';
                    die;

                } catch (\Exception $e) {
                    Db::rollback();
                    echo $e->getMessage();
                    die;
                }
            }
            echo 'success';
            die;
        }

        echo 'failure';
        die;
    }


}