duanju_manage/modules/OrderRefund/Services/RefundOrderService.php

<?php
/**
 *
 * @file:RefundOrderSeivce.php
 * @Date: 2023/5/29
 * @Time: 09:48
 */


namespace Modules\OrderRefund\Services;

use App\Libs\Pay\Palmpay;
use Catch\Exceptions\FailedException;
use Illuminate\Support\Facades\DB;
use Modules\Channel\Services\Order\OrderService;
use Modules\Manage\Models\Miniprogram;
use Modules\OrderRefund\Models\OrdersRefundVerify;
use Modules\User\Models\User;

class RefundOrderService extends BaseServices
{

    /**
     *  退款订单查询
     * name: orderList
     * @param array $param
     * date 2023/05/29 09:58
     */
    public static function orderList(array $param, $isAll = false)
    {   
        $list = self::listQuery($param);
        $list->orderBy("orders_refund_verify.refund_status",'asc')->orderBy("orders_refund_verify.id",'desc')->select("orders_refund_verify.id",'orders_refund_verify.order_id',"orders_refund_verify.uid","orders_refund_verify.pt_verify_remark","orders_refund_verify.user_id","orders_refund_verify.sh_verify_remark", "orders_refund_verify.sh_verify_status","orders_refund_verify.pt_verify_status","orders_refund_verify.pay_at","orders_refund_verify.refund_status","orders_refund_verify.refund_no","orders_refund_verify.trade_no","orders_refund_verify.refund_price","orders_refund_verify.order_price","orders.puser_id","orders.promotion_id","orders.miniprogram_id","orders.created_at as order_created_at","orders.ranse_created_at","promotions.name as promotion_name",'orders.order_type',"orders.pay_merchant_source");
        if ($isAll){
            $list = $list->get();
        }else{
            $list = $list->paginate(getProp($param,'limit',15));
        }
        if (!$list->isEmpty()) {
            $types = array_column(OrderService::getOrderType(), null, 'value');
            $verifTxt = self::getVerifyText();
            foreach ($list as  $val){
                $val->username = $val->user_id > 0 ? User::where('id', $val->user_id)->value('username') : "";
                $val->company_name = "-";
                $val->play_name = '-';
                $val->xcx_name = '-';
                $company = Miniprogram::where('id', $val->miniprogram_id)->first();
                if ($company) {
                    $val->company_name = $val->puser_id >  0 ? DB::table('users')->where('id',$val->puser_id)->value("username") : "-";
                    $val->play_name = $company->play_name;
                    $val->xcx_name = $company->name;
                }
                if (!$val->promotion_name){
                    $val->promotion_name = "-";
                }
                $val->tip_text = $types[$val->order_type]['name'] ?? "-";
                $val->pay_name = '微信支付';
                $val->pt_verify_status_text = $verifTxt[$val->pt_verify_status]['name'] ?? "-";
                if ($val->puser_id >  0){
                    $val->sh_verify_status_text = $verifTxt[$val->sh_verify_status]['name'] ?? "-";
                    $val->can_pay =  $val->sh_verify_status  == 1 &&  $val->pt_verify_status == 1 ? 1: 0;
                }else{
                    $val->sh_verify_status_text = "-";
                    $val->can_pay = $val->pt_verify_status == 1 ? 1: 0;
                }
                $val->status_text = $val->refund_status == 1 ? "已退款": "已付款";
            }
        }
        return $list;
    }
    protected  static  function  getVerifyText(){
        return [
            ['value' => 0,'name' => "待审核"],
            ['value' => 1,'name' => "审核通过"],
            ['value' => 2,'name' => "审核不通过"],
        ];
    }

    /**
     *  构建查询语句
     * name: listQuery
     * @param array $param
     * date 2023/05/29 09:59
     */
    private static function listQuery(array $param)
    {
        $sql = OrdersRefundVerify::query()->leftJoin("orders",'orders_refund_verify.order_id','=','orders.id')->leftJoin('promotions','orders.promotion_id','=','promotions.id')
        ->where('orders_refund_verify.refund_status', getProp($param,'refund_status',0));
        if (!empty(getProp($param, 'user_id'))) {
            $sql->where('orders.user_id', $param['user_id']);
        }
        // 公司查询
        if (!empty(getProp($param, 'puser_id'))) {
            $sql->where('orders.puser_id', $param['puser_id']);
        }
        // 小程序
        if (!empty(getProp($param, 'miniprogram_id'))) {
            $sql->where('orders.miniprogram_id', $param['miniprogram_id']);
        }

        // 推广id
        if (!empty(getProp($param, 'promotion_id'))) {
            $sql->where('orders.promotion_id', $param['promotion_id']);
        }
        // 状态查询
        if (!empty(getProp($param, 'status'))) {
            $sql->where('orders.status', $param['status']);
        }

        // 充值项类型
        if (!empty(getProp($param, 'order_type'))) {
            $sql->where('orders.order_type', $param['order_type']);
        }
        // 用户
        if (!empty(getProp($param, 'uid'))) {
            $sql->where('orders.uid', $param['uid']);
        }
        // 订单号查询
        if (!empty(getProp($param, 'trade_no'))) {
            $sql->where('orders.trade_no', "like", "%" . $param['trade_no'] . "%");
            // $sql->where('orders.trade_no',  $param['trade_no']);
        }
        // 订单创建时间
        if (getProp($param,'created_at_start','')){
            $sql->where('orders.created_at',">=",$param['created_at_start']);
        }
        if (getProp($param,'created_at_end','')){
            $end =$param['created_at_end'];
            if ($end == getProp($param,'created_at_start','')){
                $end = date("Y-m-d",strtotime($end)) . " 23:59:59";
            }
            $sql->where('orders.created_at',"<=",$end);
        }
        // 退款时间
        if (getProp($param,'pay_at_start','')){
            $sql->where('orders_refund_verify.pay_at',">=",$param['pay_at_start']);
        }
        if (getProp($param,'pay_at_start','')){
            $end =$param['pay_at_end'];
            if ($end == getProp($param,'pay_at_start','')){
                $end = date("Y-m-d",strtotime($end)) . " 23:59:59";
            }
            $sql->where('orders_refund_verify.pay_at',"<=",$end);
        }


        return $sql;
    }

    /**
     * 申请退款
     * name: applyRefund
     * @param $param
     *  $param [
     *      "order_id" =>  1, // 订单id
     *      'price' =>  1, // 金额
     *      'create_user_id' => 1, // 申请人id
     *  ];
     * date 2023/05/29 11:46
     */
    public static function applyRefund($param)
    {
        $order = DB::table('orders')->where('id',$param['order_id'])->first();
        if (empty($order)){
           self::throwErrMsg('订单不存在！');
        }
        if ($order->status != "PAID"){
            self::throwErrMsg('此订单未付款，无需退款！');
        }
        if ($param['price'] > $order->price){
            self::throwErrMsg('退款金额不能超过支付金额！');
        }

        $data = [
            'create_user_id' => $param['create_user_id'],
            'refund_no' =>  self::CreateRefundNo("RE"),
            'order_id' => $order->id,
            'puser_id' => $order->puser_id,
            'user_id' => $order->user_id,
            'uid' => $order->uid,
            'order_price' => $order->price,
            'trade_no' =>  $order->trade_no,
            'third_orderid' =>  $order->third_orderid,
            'refund_price' =>  $param['price'],
        ];
        if (OrdersRefundVerify::updateOrCreate(['order_id' => $data['order_id']],$data)){
            return '操作成功';
        }
        return '操作失败';
    }

    /**
     *  生成退款单号
     * name: CreateRefundNo
     * date 2023/05/29 13:46
     */
    private static function CreateRefundNo($prefix = '', $time = 0)
    {
        $time = $time == 0 ? time() : $time;
        $billno = $prefix . date('YmdHis', $time) . random(4, true);
        if (!empty($table)) {
            while (1) {
                $count = OrdersRefundVerify::where('refund_no',$billno)->value('id');
                if (empty($count)) {
                    break;
                }
                $billno =  $prefix . date('YmdHis') . random(4, true);
            }
        }
        return $billno;

    }

    /**
     *  更新审核状态
     * name: updateRefundVerify
     * @param $refundId 退款id
     * @param array $param
     * @param int $isPlatform 是否平台 1是 0否
     * @return string
     * date 2023/05/29 16:43
     */
    public static function updateRefundVerify($refundId, array $param, $isPlatform = 0)
    {
        $info = OrdersRefundVerify::where('id',$refundId)->first();
        if(!$info){
            self::throwErrMsg("退款申请不存在");
        }

        if ($isPlatform ==0 && $info->puser_id < 1){
            self::throwErrMsg("无需商户审核");
        }

        if ($isPlatform == 1 && $info->pt_verify_status == 1){
            self::throwErrMsg("已审核通过无需再次操作");
        }else if ($isPlatform ==0 && $info->sh_verify_status == 1){
            self::throwErrMsg("已审核通过无需再次操作");
        }
        $res = OrdersRefundVerify::where('id',$refundId)->update($param);
        return $res ? "操作成功" : "操作失败";
    }

    /**
     *  退款操作
     * name: payToUser
     * @param mixed $refundId 申请id
     * @param array $option 操作人信息
     * date 2023/05/29 16:53
     */
    public static function payToUser(mixed $refundId, array $option)
    {
        $info = OrdersRefundVerify::where('id',$refundId)->first();
        if(!$info){
            self::throwErrMsg("退款申请不存在");
        }
        if($info->status == 1){
            self::throwErrMsg("已退款，无需再次操作");
        }
        if ($info->puser_id >  0){
            if ($info->pt_verify_status != 1  || $info->sh_verify_status != 1){
                self::throwErrMsg("双方审核未全部通过，不能退款");
            }
        }else{
            if ($info->pt_verify_status != 1 ){
                self::throwErrMsg("审核未通过，不能退款");
            }
        }

        DB::beginTransaction();
        try {
            $payParam = [
                'third_orderid' =>  $info->third_orderid,
                'price' => $info->order_price,
                'refund_no' => $info->refund_no,
                'refund_price' => $info->refund_price,
            ];
            $appid = DB::table(getMiniProgramTableName(1,'users'))->where('id',$info->uid)->value('appid');
            $resut = (new Palmpay(['subAppid'=>$appid]))->refund($payParam);
            if (!$resut['status']){
                self::throwErrMsg($resut['msg']);
            }
            $param = [
                'refund_status' => 1,
                'pay_at' => get_date(),
                'pay_op_user' => $option,
            ];
            OrdersRefundVerify::where('id',$refundId)->update($param);
            DB::table('orders')->where('id',$info->order_id)->update(['status',"REFUND"]);
            DB::commit();
            return "操作成功";
        }catch (\Exception $exception){
            DB::rollBack();
            self::throwErrMsg($exception->getMessage());
        }
        self::throwErrMsg("操作失败");

    }

}