NN2025081602/app/Services/Common/DepositService.php

<?php
// +----------------------------------------------------------------------
// | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
// +----------------------------------------------------------------------
// | 版权所有 2017~2021 LARAVEL研发中心
// +----------------------------------------------------------------------
// | 官方网站: http://www.laravel.cn
// +----------------------------------------------------------------------
// | Author: laravel开发员 <laravel.qq.com>
// +----------------------------------------------------------------------

namespace App\Services\Common;

use App\Models\AccountLogModel;
use App\Models\DepositModel;
use App\Models\MemberModel;
use App\Models\MessageModel;
use App\Models\ActionLogModel;
use App\Services\BaseService;
use App\Services\ConfigService;
use App\Services\PaymentService;
use App\Services\RedisService;
use App\Services\SmsService;
use Illuminate\Support\Facades\DB;

/**
 * 保证金订单管理-服务类
 * @author laravel开发员
 * @since 2020/11/11
 * @package App\Services\Api
 */
class DepositService extends BaseService
{
    // 静态对象
    protected static $instance = null;

    /**
     * 构造函数
     * @author laravel开发员
     * @since 2020/11/11
     */
    public function __construct()
    {
        $this->model = new DepositModel();
    }

    /**
     * 静态入口
     */
    public static function make()
    {
        if (!self::$instance) {
            self::$instance = new static();
        }
        return self::$instance;
    }

    /**
     * 列表数据
     * @param $params
     * @param int $pageSize
     * @return array
     */
    public function getDataList($params, $pageSize = 15)
    {
        $query = $this->getQuery($params);
        $refundStatus = isset($params['refund_status']) ? $params['refund_status'] : -1;

        $model = clone $query;
        $counts = [
            'count'=> $model->count('a.id'),
            'total'=> $model->sum($refundStatus>=0?'a.refund_money':'a.money'),
        ];


        if($refundStatus==0){
            $query->orderBy('a.refund_status', 'asc')
                ->orderBy('a.create_time', 'desc')
                ->orderBy('a.id', 'desc');
        }else if($refundStatus>0){
            $query->orderBy('a.create_time', 'desc')
                ->orderBy('a.id', 'desc');
        }else{
            $query->orderBy('a.create_time', 'desc')
                ->orderBy('a.id', 'desc');
        }


        $field = ["a.*"];
        $list = $query->select($field)
            ->paginate($pageSize > 0 ? $pageSize : 9999999);
        $list = $list ? $list->toArray() : [];
        if ($list) {
            foreach ($list['data'] as &$item){
                $item['create_time'] = $item['create_time']? datetime($item['create_time'],'Y-m-d H:i:s') : '';
                $item['time_text'] = $item['create_time']? datetime($item['create_time'],'Y年m月d日') : '';
            }
            $datas = [
                'pageSize' => $pageSize,
                'total' => isset($list['total']) ? $list['total'] : 0,
                'list' => isset($list['data']) ? $list['data'] : [],
                'counts' => $counts,
            ];

            // 消息已读
            MessageModel::where(['is_read'=>2,'type'=>$refundStatus>=0?4:3,'mark'=>1])->update(['is_read'=>1,'update_time'=>time()]);
        }
        return $datas;
    }


    /**
     * 查询条件
     * @param $params
     * @return mixed
     */
    public function getQuery($params)
    {
        $where = ['a.status' => 0, 'a.mark' => 1];
        $status = isset($params['status']) ? $params['status'] : 0;
        if ($status > 0) {
            $where['a.status'] = $status;
        } else {
            unset($where['a.status']);
        }

        $model = $this->model->with(['user'])->from('deposit_orders as a')
            ->leftJoin('member as b','b.id','=','a.user_id')
            ->where($where)
            ->where(function ($query) use ($params) {
                $refundNo= isset($params['refund_no']) ? trim($params['refund_no']) : '';
                $orderNo = isset($params['order_no']) ? trim($params['order_no']) : '';
                $refundStatus = isset($params['refund_status']) ? $params['refund_status'] : -1;
                if($refundNo){
                    $query->where(function($query) use($refundNo){
                        $query->where('a.refund_no', 'like', "%{$refundNo}%")
                            ->orWhere('a.refund_transaction_id', 'like', "%{$refundNo}%");
                    });
                }else if($orderNo){
                    $query->where(function($query) use($orderNo){
                        $query->where('a.order_no', 'like', "%{$orderNo}%")
                            ->orWhere('a.transaction_id', 'like', "%{$orderNo}%");
                    });
                }

                if($refundStatus==0){
                    $query->where(['a.status'=>3])->where('a.refund_status','>',1);
                }else if($refundStatus>0){
                    $query->where(['a.status'=>3])->where('a.refund_status', $refundStatus);
                }

                // 用户
                $account = isset($params['account']) ? trim($params['account']) : '';
                if ($account) {
                    $query->where(function ($query) use ($account) {
                        $query->where('b.mobile', 'like', "%{$account}%")
                            ->orWhere('b.nickname', 'like', "%{$account}%");
                    });
                }

                $userId = isset($params['user_id']) ? intval($params['user_id']) : 0;
                if ($userId>0) {
                    $query->where('a.user_id', $userId);
                }
            });

        return $model;
    }

    /**
     * 详情信息
     * @param $id
     * @return mixed
     */
    public function getInfo($id)
    {
        $cacheKey = "caches:deposit:info_{$id}";
        $info = RedisService::get($cacheKey);
        if($info){
            return $info;
        }

        $info = $this->model->with(['user'])->where(['order_id' => $id])->first();
        $info = $info? $info->toArray() :[];
        if($info){
            RedisService::set($cacheKey, $info, rand(5,10));
        }
        return $info;
    }

    /**
     * 审核
     * @param $adminId
     * @param $params
     * @return array|false
     */
    public function confirm($adminId, $params)
    {
        $id = isset($params['id'])? intval($params['id']) : 0;
        $status = isset($params['refund_status'])? intval($params['refund_status']) : 0;
        $confirmRemark = isset($params['refund_confirm_remark'])? trim($params['refund_confirm_remark']) : '';

        $info = $this->model->with(['user'])->where(['id'=> $id,'mark'=>1])->first();
        $userInfo = isset($info['user'])? $info['user'] : [];
        $orderStatus = isset($info['refund_status'])? $info['refund_status'] : 0;
        $orderUserId = isset($info['user_id'])? $info['user_id'] : 0;
        $refundMoney = isset($info['refund_money'])? $info['refund_money'] : 0;
        if(empty($info) || empty($userInfo) || $orderUserId<=0 || $refundMoney<=0){
            $this->error = '退保申请信息不存在或参数错误';
            return false;
        }

        if($orderStatus != 1){
            $this->error = '退保订单状态不可操作';
            return false;
        }

        if(!in_array($status,[2,3])){
            $this->error = '退保审核状态错误';
            return false;
        }

        if($status == 3 && empty($confirmRemark)){
            $this->error = '请填写审核驳回备注';
            return false;
        }

        DB::beginTransaction();
        $updateOrder = ['refund_status'=>$status,'confirm_admin_id'=>$adminId,'update_time'=>time(),'refund_confirm_remark'=>$confirmRemark];

        // 如果驳回
        if($status == 3){
            $updateData = ['deposit'=> $refundMoney,'update_time'=>time()];
            if(!MemberModel::where(['id'=> $orderUserId])->update($updateData)){
                DB::rollBack();
                $this->error = '退保审核处理失败';
                return false;
            }
        }else if($status == 2){
            // 线上直接退款逻辑
            $payType = isset($info['pay_type'])? $info['pay_type'] : 0;
            $order = [
                'money' => $refundMoney,
                'pay_type' => $payType,
                'order_no' => isset($info['order_no'])? $info['order_no'] : '',
                'out_trade_no' => isset($info['refund_no'])? $info['refund_no'] : '',
                'transaction_id' => isset($info['transaction_id'])? $info['transaction_id'] : '',
                'remark'=> '退保'
            ];
            if(!PaymentService::make()->refund($order)){
                DB::rollBack();
                $this->error = '退保退款处理失败';
                return false;
            }

            // 支付宝调用成功直接完成
            if($payType == 20){
                $updateOrder['refund_status'] = 4;
                $updateOrder['remark'] = '已退保';
            }
        }

        if(!$this->model->where(['id'=> $id])->update($updateOrder)){
            DB::rollBack();
            $this->error = '退款审核处理失败';
            return false;
        }


        DB::commit();
        $this->error = '退款审核成功';
        return ['id'=>$id,'money'=>$refundMoney,'refund_status'=>$status];
    }

    /**
     * 打款
     * @param $adminId
     * @param $params
     * @return array|false
     */
    public function payment($adminId, $params)
    {
        $id = isset($params['id'])? intval($params['id']) : 0;

        $info = $this->model->with(['user'])->where(['id'=> $id,'mark'=>1])->first();
        $userInfo = isset($info['user'])? $info['user'] : [];
        $orderStatus = isset($info['refund_status'])? $info['refund_status'] : 0;
        $orderUserId = isset($info['user_id'])? $info['user_id'] : 0;
        $refundMoney = isset($info['refund_money'])? $info['refund_money'] : 0;
        if(empty($info) || empty($userInfo) || $orderUserId<=0 || $refundMoney<=0){
            $this->error = '退保申请信息不存在或参数错误';
            return false;
        }

        if($orderStatus == 4){
            $this->error = '退保订单已打款';
            return false;
        }

        if($orderStatus != 2){
            $this->error = '退保订单状态不可操作';
            return false;
        }

        // 线上直接退款逻辑
        $payType = isset($info['pay_type'])? $info['pay_type'] : 0;
        $order = [
            'money' => $refundMoney,
            'pay_type' => $payType,
            'order_no' => isset($info['order_no'])? $info['order_no'] : '',
            'out_trade_no' => isset($info['refund_no'])? $info['refund_no'] : '',
            'transaction_id' => isset($info['transaction_id'])? $info['transaction_id'] : '',
            'remark'=> '退保'
        ];
        DB::beginTransaction();
        if(!PaymentService::make()->refund($order)){
            DB::rollBack();
            $this->error = '退保退款处理请求失败';
            return false;
        }

        if($payType == 20 && !$this->model->where(['id'=> $id])->update(['refund_status'=>4,'remark'=>'已退保','update_time'=>time()])){
            DB::rollBack();
            $this->error = '退保退款处理失败';
            return false;
        }

        DB::commit();
        $this->error = '退保打款请求成功';
        return ['id'=>$id,'money'=>$refundMoney,'status'=>$orderStatus];
    }

    /**
     * 统计
     * @param int $type
     * @return array|mixed
     */
    public function getTotal($type=0)
    {
        $cacheKey = "caches:deposit:total_{$type}";
        $data = RedisService::get($cacheKey);
        if($data){
            return $data;
        }

        $data = $this->model->where(['mark'=>1])
            ->where(function($query) use($type){
                if($type== 1){
                    $query->where(['status'=>3])->whereIn('refund_status',[2,4]);
                }else {
                    $query->where(['status'=>3]);
                }
            })->sum('money');
        if($data){
            RedisService::set($cacheKey, $data, rand(300, 600));
        }

        return $data;
    }

    /**
     * 删除七天之前标记软删除的数据
     */
    public function delete()
    {
        // 设置日志标题
        ActionLogModel::setRecord(session('userId'), ['type' => 1, 'title' => "删除充值记录信息", 'content' => json_encode(request()->post(), 256), 'module' => 'admin']);
        ActionLogModel::record();
        $this->model->where('mark', 0)->where('update_time', '<=', time() - 7 * 86400)->delete();
        return parent::delete();
    }

}