dms-api/app/v1/logic/customer/SdkOrderLogic.php

<?php

namespace app\v1\logic\customer;

use plugin\saiadmin\basic\BaseLogic;
use plugin\saiadmin\exception\ApiException;
use DateTime;
use support\Redis;
use support\think\Db;

/**
 * 用户订单记录逻辑层
 */
class SdkOrderLogic extends BaseLogic
{
    /**
     * 构造函数
     */
    public function __construct()
    {

    }

    /**
     * 获取订单列表
     */
    public function getOrderList($params)
    {
        $orderBy = $params['orderBy'] ?: 'pay_date';
        $orderType = $params['orderType'] ?: 'DESC';

        if(!$params['pay_time']){
            throw new ApiException('请选择时间范围');
        }
        // 获取年月
        $yearRange = getYearRange($params['pay_time'][0], $params['pay_time'][1]);

        $eqWhere = ["game_id", "user_name", "order_id", "trade_id", "role_id", "role_name"];
        $where = [];
        foreach ($eqWhere as $field){
            if (!empty($params[$field])) {
                $where[$field] = $params[$field];
            }
        }

        if($params['send_status']!=''){
            $where['send_status'] = $params['send_status'];
        }

        if($params['sync_status']!=''){
            $where['sync_status'] = $params['sync_status'];
        }


        $where[] = ['pay_time', 'between', [strtotime($params['pay_time'][0].'00:00:00'), strtotime($params['pay_time'][1].'23:59:59')]];

        $db = Db::connect('db_game_log');
        $unionQuery = [];
        foreach ($yearRange as $year){
            $tableName = 'sdk_order_' . $year;
            $unionQuery[] = $db->table($tableName)->where($where)->buildSql();
        }
        $fullSql = "(" . implode(' UNION ALL ', $unionQuery) . ") as unTable";


        $list = $db->table($fullSql)->order($orderBy, $orderType)->paginate($params['limit'])->toArray();
     
        $list['data'] = $this->trandformListColumn($list['data'], ['game', 'pay_channel']);

        $allMoney = $db->table($fullSql)->where(["sync_status"=>1])->value("round(sum(money), 2)");
        $list['totalRow'] = [
            'money' => $allMoney,
        ];


        return $list;
    }

    /**
     * 补发
     */
    public function send($params)
    {
        $orderId = $params['order_id'];
        $desc = $params['desc'];
         $userInfo = getCurrentInfo();
        
        Db::connect('db_game_log')->table("sdk_order_resend")
            ->save([
                'order_id' => $orderId,
                'desc' => $desc,
                'created_user' => $userInfo['id']
            ]);

        return true;
    }


    /**
     * 审核补单
     */
    public function auditResend($params)
    {
        $id = $params['id'];
        $status = $params['status'];
        $error = $params['error'];
        $userInfo = getCurrentInfo();

        
        Db::connect('db_game_log')->table("sdk_order_resend")
            ->where("id", $id)
            ->update([
                'status' => $status,
                'error' => $error,
                'updated_user' => $userInfo['id']
            ]);
        return $this->success();
    }

    // 补单管理审核列表
    public function getReissueAuditList($params)
    {
       
        $orderId = $params['order_id'] ?? '';
        $status = $params['status'] ?? '';
        $resendType = $params['resend_type'] ?? '';



        $where = [];
        if(!empty($orderId)){
            $where[] = ['order_id', '=', $orderId];
        }
        if($resendType!=''){
            $where[] = ['resend_type', '=', $resendType];
        }
        if(!empty($status)){
            $where[] = ['status', '=', $status];
        }

        $data = Db::connect('db_game_log')->table('sdk_order_resend')
                    ->where($where)
                    ->order('create_time', 'desc')
                    ->select()->toArray();
        return [
            'data'=>$this->trandformListColumn($data, ['author']),
            'total'=>count($data)
        ];
    }

    // 补单审核
    public function reissueAudit($params): mixed
    {
        $id = $params['id'];
        $status = $params['status'];
        $userInfo = getCurrentInfo();

        Db::connect('db_game_log')->table('sdk_order_resend')
            ->where("id", $id)
            ->update([
                'status' => $status,
                'update_user' => $userInfo['id'],
            ]);
        return true;
    }
}