php/app/common/dao/backup/BackupUserChangeDao.php

<?php

namespace app\common\dao\backup;

use app\common\dao\BaseDao;
use app\common\model\backup\BackupUserChange;

class BackupUserChangeDao extends BaseDao
{
    protected function getModel(): string
    {
        return BackupUserChange::class;
    }

    /**
     * @param array $dataList
     * @return array批量更新
     */
    public function saveAll(array $dataList): array
    {
        try {
            return $this->getModel()->getInstance()->allowField(array_keys(reset($dataList)))->saveAll($dataList)->toArray();
        } catch (\Exception $e) {
            return [];
        }
    }
    /**
     * 根据 order_id 获取用户本人变更数据（user=1）
     */
    public function getUserOneChangeFromOrderId($orderId)
    {
        return $this::getModel()::getDB()
            ->where('order_id', '=', $orderId)
            ->where('user', '=', 1)
            ->field('pv, vr, score, contribute, annuity, uid')
            ->find();
    }

    /**
     * 根据 order_id 获取一级推荐人变更数据（user=2）
     */
    public function getUserTwoChangeFromOrderId($orderId)
    {
        return $this::getModel()::getDB()
            ->where('order_id', '=', $orderId)
            ->where('user', '=', 2)
            ->field('brokerage_price, score, per_contribute, annuity, uid')
            ->find();
    }

    /**
     * 根据 order_id 获取第二推荐人佣金变更数据（user=3）
     */
    public function getUserThreeChangeFromOrderId($orderId)
    {
        return $this::getModel()::getDB()
            ->where('order_id', '=', $orderId)
            ->where('user', '=', 3)
            ->field('brokerage_price, uid')
            ->find();
    }

    /**
     * 根据 order_id 获取扫码推荐人积分变更数据（user=4）
     */
    public function getUserFourChangeFromOrderId($orderId)
    {
        return $this::getModel()::getDB()
            ->where('order_id', '=', $orderId)
            ->where('user', '=', 4)
            ->field('score, uid')
            ->find();
    }
}