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

<?php
// +----------------------------------------------------------------------
// | saiadmin [ saiadmin快速开发框架 ]
// +----------------------------------------------------------------------
// | Author: your name
// +----------------------------------------------------------------------
namespace app\v1\logic\customer;

use plugin\saiadmin\basic\BaseLogic;
use plugin\saiadmin\exception\ApiException;
use plugin\saiadmin\utils\Helper;
use app\v1\model\customer\RoleData;
use support\think\Db;

/**
 * 角色查询逻辑层
 */
class RoleDataLogic extends BaseLogic
{
    /**
     * 构造函数
     */
    public function __construct()
    {
        $this->model = new RoleData();
    }

    /**
     * 获取角色查询列表
     */
    public function getRoleList($query)
    {
        // 获取android数据
        $table_and = Db::connect('db_game_log')->table('role_data_and')->field('* , "android" as platform')->where($query)->select()->toArray();
        // 获取ios数据
        $table_ios = Db::connect('db_game_log')->table('role_data_ios')->field('* , "ios" as platform')->where($query)->select()->toArray();

        // 合并两个表的数据
        $data = array_merge($table_and, $table_ios);

        // 1. 根据game_id 查找 main_id
        $game_ids = array_unique(array_column($data, 'game_id'));
        $main_id_arr = Db::connect('db_center')->table('pf_game')->whereIn('id', $game_ids)->column('main_id','id');


        $data = array_map(function($item) use ($main_id_arr){
           // 最后登录时间
           $item['login_time'] = Db::connect('db_origin')->table('agent_reg_'.$item['uid']%10)->where('main_id', $main_id_arr[$item['game_id']])->where('uid', $item['uid'])->value('login_time');
           $item['login_time'] = date('Y-m-d H:i:s', $item['login_time']);
           // 支付记录
           $pay_data = Db::connect('db_game_log')->table('sdk_order_success')->where('game_id', $item['game_id'])->where('uid', $item['uid'])->where('role_id', $item['role_id'])->order('pay_date', 'desc');
           // 最新的一条支付记录时间
           $item['last_recharge_time'] =  $pay_data->value('pay_date');
           // 累计充值
           $item['total_recharge'] = $pay_data->sum('money');

           return $item;
        }, $data);










        $data = $this->trandformListColumn($data,['game','media','site', 'agent']);

        return $data;

    }

    /**
     * 更新
     */
    public function update($id, $data)
    {
        $platform = $data['platform'];
        $table = $platform === 'android' ? 'role_data_and' : 'role_data_ios';
        
        // 移除platform字段，避免更新到数据库
        unset($data['platform']);
        
        // 直接使用Db更新指定表的数据
        $result = Db::connect('db_game_log')
            ->table($table)
            ->where('id', $id)
            ->update($data);
            
        if ($result === false) {
            throw new ApiException('更新失败');
        }
        
        return $result;
    }
}