aklast/common/models/forms/TransferForm.php

<?php

namespace common\models\forms;

use common\helpers\bonus\CalcCache;
use common\helpers\Cache;
use common\helpers\Date;
use common\components\Model;
use common\helpers\Form;
use common\helpers\LoggerTool;
use common\helpers\snowflake\SnowFake;
use common\helpers\Tool;
use common\helpers\user\Balance;
use common\helpers\user\Cash;
use common\helpers\user\Info;
use common\libs\logging\operate\UserOperate;
use common\models\Article;
use common\models\ArticleCategory;
use common\models\DealType;
use common\models\DecOrder;
use common\models\Order;
use common\models\PerfPeriod;
use common\models\Period;
use common\models\Transfer;
use common\models\User;
use common\models\UserBind;
use common\models\UserBonus;
use common\models\UserInfo;
use common\models\UserRelation;
use common\models\UserSystem;
use frontendApi\modules\v1\models\Relation;
use yii\base\Exception;
use yii\helpers\Json;

/**
 * Login form
 */
class TransferForm extends Model {
    const allowTransferType = [1, 2, 3, 4];
    const BONUS_TO_BALANCE = 1;
    const BONUS_TO_BONUS = 2;
    const BALANCE_TO_BALANCE = 3;
    const POINT_TO_BALANCE = 4;
    const LOOP_FINISH = 1;
    const LOOP_CONTINUE = 2;
    private $_periodNum = 0;

    public $toUserName;
    public $toRealName;
    public $amount;
    public $payPassword;
    public $type;
    public $remark;
    public $transferCode;

    private $_fromUserInfo;
    private $_toUserInfo;
    private $_transferProp;
    private $_transferConfig;
    private $_fee = 0;

    public function init() {
        parent::init();
        $this->userOperateLogger = new UserOperate([
            'fetchClass' => Transfer::class,
        ]);
    }

    /**
     * @inheritdoc
     */
    public function rules() {
        return [
            [['toUserName', 'toRealName', 'amount', 'type', 'remark'], 'trim'],
            [['toUserName', 'toRealName', 'amount', 'type', 'payPassword', 'transferCode'], 'required'],
            [['toUserName'], 'exist', 'targetClass' => UserInfo::class, 'targetAttribute' => 'USER_NAME'],
            [['type'], 'isType'],
            [['toUserName'], 'initUser'],
            [['amount'], 'price'],
            [['amount'], 'isAmount'],
            [['transferCode'], 'validateCode'],
            [['payPassword'], 'validatePassword'],
        ];
    }

    /**
     * 指定校验场景
     * @return array
     */
    public function scenarios() {
        $parentScenarios = parent::scenarios();
        $customScenarios = [
            'transfer' => ['type', 'toUserName', 'toRealName', 'amount', 'remark', 'payPassword', 'transferCode'],
        ];
        return array_merge($parentScenarios, $customScenarios);
    }

    public function attributeLabels() {
        return [
            'toUserName' => '转入会员编号',
            'amount' => '金额',
            'payPassword' => '支付密码',
            'transferCode' => '转账校验码',
        ];
    }

    /**
     * 初始化转入转出用户信息
     * @param $attribute
     * @return null
     * @throws Exception
     * @throws \Exception
     */
    public function initUser($attribute) {
        // 转账记录
        if(!$toUserId = Info::getUserIdByUserName($this->toUserName)){
            $this->addError($attribute, '转入会员不存在');
            return null;
        }
//        if(Info::getUserRealNameByUserId($toUserId)!=$this->toRealName){
//            $this->addError($attribute, '转入会员会员姓名不正确');
//            return null;
//        }
        $this->_toUserInfo = Info::baseInfo($toUserId);

        $fromUserId = \Yii::$app->user->id;
        $fromUser = Info::baseInfo($fromUserId);
        if (!$fromUser) {
            $this->addError($attribute, '转出会员不存在');
            return null;
        }

        // 转账是否已开启
        $transferSwitch = Cache::getSystemConfig()['transferSwitch']['VALUE'] ?? '';
        if ($transferSwitch != 1) {
            // 转账未开启,判断是否报单中心. 报单中心可开启转账
            $isDec = \frontendApi\modules\v1\models\User::getEnCodeInfo($fromUserId)['IS_DEC'];
            if ($isDec != 1) {
                throw new \Exception('转账功能已关闭');
                return null;
            }
        }


        // 转账条件判断
//        $orderAmount = Order::find()->where('USER_ID=:USER_ID', [':USER_ID' => $fromUserId])->SUM('ORDER_AMOUNT');
//        $recNum = intval(DecOrder::find()->where('REC_USER_ID=:REC_USER_ID', [':REC_USER_ID' => $fromUserId])->count());
        //$recNum = UserRelation::firstFloorChildNum($fromUserId);
//        if ($orderAmount < 300 && $recNum==0) {
//            $this->addError($attribute, '消费未满300元或未推荐新人，暂不能转账');
//            return null;
//        }
        $this->_fromUserInfo = $fromUser;
        //是否同体系转账
//        if($this->_transferConfig['isSystem']==1){
//            if($this->_toUserInfo['SYSTEM_ID']!=$this->_fromUserInfo['SYSTEM_ID']){
//                $this->addError($attribute, '只能同一体系间转账');
//                return null;
//            }
//        }

        //是否点位绑定转账
//        if ($this->_transferConfig['isBind'] == 1) {
//            if (!UserBind::sameBind($this->_toUserInfo['ID'], $this->_fromUserInfo['ID'])) {
//                $this->addError($attribute, '只能点位绑定在一起的会员之间转账');
//                return null;
//            }
//        }



        //奖金转奖金限同一身份证
        /*if ($this->type == self::BONUS_TO_BONUS) {
            $toIdCard = User::findOneAsArray('ID=:ID', [':ID' => $toUser['USER_ID']], 'ID_CARD');
            $fromIdCard = User::findOneAsArray('ID=:ID', [':ID' => $fromUser['USER_ID']], 'ID_CARD');
            if ($toIdCard['ID_CARD'] && ($toIdCard['ID_CARD'] != $fromIdCard['ID_CARD'])) {
                $this->addError($attribute, '奖金转奖金只能在同一身份证下进行');
                return null;
            }
        }*/
        //奖金转现金限一周一次
        /*if ($this->type == self::BONUS_TO_BALANCE) {
            if (Transfer::hasThisWeekTransfer(\Yii::$app->user->id)) {
                $this->addError($attribute, '转账失败，每周只可以转账一次');
                return null;
            }
        }*/

        // 转账网络限制
        // 期数
        $this->_periodNum = Period::instance()->getNowPeriodNum();

        // 发起人
        $initiator = Info::getBaseUserByUserName($fromUser['USER_NAME']);
        // 发起人是否报单中心
        $initiatorIsDec = $initiator['IS_DEC'] == 1;

        // 接受者
        $recipient = Info::getBaseUserByUserName($this->toUserName);
        // 发起人是否报单中心
        $recipientIsDec = $recipient['IS_DEC'] == 1;

        // 1. 如果发起人和接受者都是报单中心,则转账无限制
        if (($initiatorIsDec == 1) && ($recipientIsDec == 1)) {
            return true;
        }

        // 2. 如果发起人是报单中心, 则可以转账给自己的推荐网下级
        if ($initiatorIsDec == 1) {
            $sql = <<<SQL
                WITH recursive t_rec AS 
                (
                    SELECT
                        m.USER_ID,
                        U.USER_NAME,
                        m.PARENT_UID,
                        U2.USER_NAME AS PARENT_NAME,
                        1 AS node_level 
                    FROM
                        AR_USER_RELATION_NEW m 
                        LEFT JOIN AR_USER U ON U.ID = m.USER_ID
                        LEFT JOIN AR_USER U2 ON U2.ID = m.PARENT_UID
                    WHERE
                        U.USER_NAME = :USER_NAME 
                        
                    UNION ALL
                    
                    SELECT
                        t1.USER_ID,
                        U.USER_NAME,
                        t1.PARENT_UID,
                        U2.USER_NAME AS PARENT_NAME,
                        t2.node_level + 1 -- 结点层级
                        
                    FROM
                        AR_USER_RELATION_NEW t1
                        JOIN t_rec t2 ON t2.PARENT_UID = t1.USER_ID
                        LEFT JOIN AR_USER U ON U.ID = t1.USER_ID
                        LEFT JOIN AR_USER U2 ON U2.ID = t1.PARENT_UID
                    ) 
                SELECT
                    * 
                FROM
                    t_rec
SQL;
            // 查询接受者的所有上级,如果没有发起人,则不能转账
            $relationNode = \Yii::$app->db->createCommand($sql)
                ->bindValue(':USER_NAME', $this->toUserName)
                ->queryAll();

            $relationNode = array_column($relationNode, 'USER_NAME');
            if (!in_array($fromUser['USER_NAME'], $relationNode)) {
                $this->addError($attribute, '转账失败：转入会员不是您的下级');
                return null;
            }
            return true;
        }

        // 3. 如果发起人是普通会员,则只能转给自己推荐网的某个节点
        // 上级节点
        $sqlUp =<<<SQL
            WITH recursive t_rec AS 
            (
                SELECT
                    m.USER_ID,
                    U.USER_NAME,
                    m.PARENT_UID,
                    U2.USER_NAME AS PARENT_NAME,
                    1 AS node_level 
                FROM
                    AR_USER_RELATION_NEW m 
                    LEFT JOIN AR_USER U ON U.ID = m.USER_ID
                    LEFT JOIN AR_USER U2 ON U2.ID = m.PARENT_UID
                WHERE
                    U.USER_NAME = :USER_NAME 
                    
                UNION ALL
                
                SELECT
                    t1.USER_ID,
                    U.USER_NAME,
                    t1.PARENT_UID,
                    U2.USER_NAME AS PARENT_NAME,
                    t2.node_level + 1 -- 结点层级
                    
                FROM
                    AR_USER_RELATION_NEW t1
                    JOIN t_rec t2 ON t2.PARENT_UID = t1.USER_ID
                    LEFT JOIN AR_USER U ON U.ID = t1.USER_ID
                    LEFT JOIN AR_USER U2 ON U2.ID = t1.PARENT_UID
                ) 
            SELECT
                * 
            FROM
                t_rec
SQL;
        // 上级
        $relationNodeUp = \Yii::$app->db->createCommand($sqlUp)
            ->bindValue(':USER_NAME' , $fromUser['USER_NAME'])
            ->queryAll();

        $relationNodeUp = array_column($relationNodeUp, 'USER_NAME');
        unset($relationNodeUp[$fromUser['USER_NAME']]);
        if (!in_array($this->toUserName, $relationNodeUp)) {
            // 下级节点
            $sqlFloor =<<<SQL
                WITH recursive t_rec AS 
                (
                    SELECT
                        m.USER_ID,
                        U.USER_NAME,
                        m.PARENT_UID,
                        U2.USER_NAME AS PARENT_NAME,
                        1 AS node_level 
                    FROM
                        AR_USER_RELATION_NEW m 
                        LEFT JOIN AR_USER U ON U.ID = m.USER_ID
                        LEFT JOIN AR_USER U2 ON U2.ID = m.PARENT_UID
                    WHERE
                        U.USER_NAME = :USER_NAME 
                        
                    UNION ALL
                    
                    SELECT
                        t1.USER_ID,
                        U.USER_NAME,
                        t1.PARENT_UID,
                        U2.USER_NAME AS PARENT_NAME,
                        t2.node_level + 1 -- 结点层级
                        
                    FROM
                        AR_USER_RELATION_NEW t1
                        JOIN t_rec t2 ON t2.PARENT_UID = t1.USER_ID
                        LEFT JOIN AR_USER U ON U.ID = t1.USER_ID
                        LEFT JOIN AR_USER U2 ON U2.ID = t1.PARENT_UID
                    ) 
                SELECT
                    * 
                FROM
                    t_rec
SQL;
            // 下级
            $relationNodeFloor = \Yii::$app->db->createCommand($sqlFloor)
                ->bindValue(':USER_NAME' , $this->toUserName)
                ->queryAll();
            $relationNodeFloor = array_column($relationNodeFloor, 'USER_NAME');
            if (!in_array($fromUser['USER_NAME'], $relationNodeFloor)) {
                $this->addError($attribute, '转账失败：转入会员不是您的上级');
                return null;
            }
        }

        return true;
    }

    /**
     * 校验申请金额是否小于当前余额并符合配置中的设置
     * @param $attribute
     * @return null
     */
    public function isAmount($attribute) {
        if(!$this->_fromUserInfo){
            $this->addError($attribute, '会员信息未验证通过');
            return null;
        }
        if ($this->amount <= 0) {
            $this->addError($attribute, '转账金额必须大于0');
        }
        if ((int)$this->amount!=$this->amount) {
            $this->addError('scenario', '转账金额必须是整数');
        }
        $minAmount = $this->_transferConfig['outMin'];
        if ($this->amount < $minAmount) {
            $this->addError($attribute, '转账金额低于转账下限');
        }
        $maxAmount = $this->_transferConfig['outMax'];
        if ($maxAmount && $this->amount > $maxAmount) {
            $this->addError($attribute, '转账金额高于转账上限');
        }
        //周转账上限
        if($this->_transferConfig['weekMax']!=0){
            if($this->amount+Transfer::weekTransfer($this->_fromUserInfo['ID'])>$this->_transferConfig['weekMax']){
                $this->addError($attribute, '超出周转账上限');
            }
        }
        //月转账上限
        if($this->_transferConfig['monthMax']!=0){
            if($this->amount+Transfer::monthTransfer($this->_fromUserInfo['ID'])>$this->_transferConfig['weekMax']){
                $this->addError($attribute, '超出月转账上限');
            }
        }

        // 获取当前用户的可用金额
        if( $this->type == self::BALANCE_TO_BALANCE ) {
            $haveBalance = Cash::getAvailableBalance($this->_fromUserInfo['ID']);
        }else if ($this->type == self::POINT_TO_BALANCE) {
            $haveBalance = Balance::getBalanceReconsumePoints($this->_fromUserInfo['ID']);
        } else {
            $haveBalance = Balance::getAvailableBalance($this->_fromUserInfo['ID']);
        }
        if ($this->amount > $haveBalance) {
            $this->addError($attribute, '转账金额必须小于自己的可用余额');
        }
        // 转账比例
        if ($this->type == self::BONUS_TO_BALANCE) {
            $isCanTransferProp = Cache::getSystemConfig()['isCanTransferProp']['VALUE'];
            if ($isCanTransferProp == 1) {
                $maxAmount = Tool::formatPrice($this->_fromUserInfo['TRANSFER_PROP'] * Balance::getAvailableBalance($this->_fromUserInfo['ID']) * 0.01);
                if ($this->amount > $maxAmount) {
                    $this->addError($attribute, '转账金额超出转账比例限额');
                }
            }
        }

        //手续费
        if($this->_transferConfig['fee']!=0){
            $fee = Tool::formatPrice($this->amount * ($this->_transferConfig['fee']) * 0.01);
            if($this->_transferConfig['feeMin']!=0&&$fee<$this->_transferConfig['feeMin']){
                $fee = $this->_transferConfig['feeMin'];
            }
            if($this->_transferConfig['feeMax']!=0&&$fee>$this->_transferConfig['feeMax']){
                $fee = $this->_transferConfig['feeMax'];
            }
            $this->_fee = $fee;
        }
    }

    /**
     * 转账类型判断
     * @param $attribute
     */
    public function isType($attribute) {
        if (!in_array($this->type, self::allowTransferType)) {
            $this->addError($attribute, '不允许的转账类型');
        }
        //获取转账参数
        if(!$this->_transferConfig = Json::decode(Cache::getSystemConfig()['allowWallet']['VALUE'])[$this->type-1]){
            $this->addError($attribute, '错误的转账类型');
        }
        if(!$this->_transferConfig['isOpen']){
            $this->addError($attribute, '不可用的转账类型');
        }
    }

    /**
     * 校验支付密码
     * @param $attribute
     * @param $params
     */
    public function validatePassword($attribute, $params) {
        $uid = \Yii::$app->user->id;
        if(!$this->toUserName || !$this->toRealName || $this->amount == 0){
            $this->addError($attribute, '转账失败');
        }else if(!$this->_fromUserInfo){
            LoggerTool::info('transfer error, '.$uid.' '. $this->amount.' '. $this->toUserName);
            $this->addError($attribute, '转账时发生错误');
        }else if (!User::validatePayPassword($this->_fromUserInfo['ID'], $this->payPassword)) {
            $this->addError($attribute, '支付密码不正确');
        }
    }

    public function validateCode($attribute, $params) {
        $uid = \Yii::$app->user->id;
        $redisCode = \Yii::$app->redis->getset('transferCode_'.$uid,'');
        \Yii::$app->redis->del('transferCode_'.$uid);
        if ($this->transferCode!=$redisCode) {
            $this->addError($attribute, '转账校验失败'.$redisCode);
        }
    }
    /**
     * 生成随机数
     * @param $length
     * @param int $numeric
     * @return string
     */
    public function random($length, $numeric = 0) {
        $seed = base_convert(md5(microtime() . $_SERVER['DOCUMENT_ROOT']), 16, $numeric ? 10 : 35);
        $seed = $numeric ? (str_replace('0', '', $seed) . '012340567890') : ($seed . 'zZ' . strtoupper($seed));
        $hash = '';
        $max = strlen($seed) - 1;
        for ($i = 0; $i < $length; $i++) {
            $hash .= $seed[mt_rand(0, $max)];
        }
        return $hash;
    }

    /**
     * 转账
     * @return Transfer|null
     * @throws \Exception
     */
    public function transfer() {
        if (!$this->validate()) {
            return null;
        }
        $fromData = Balance::getLogData($this->_fromUserInfo['ID']);
        $toData = Balance::getLogData($this->_toUserInfo['ID']);
        if ($this->_fromUserInfo['ID']==$this->_toUserInfo['ID'] && $this->_transferConfig['out']==$this->_transferConfig['in']){
            throw new \Exception('不能给同一账户转账');
        }

        $this->userOperateLogger->saveBeforeContent=array_merge($fromData,$toData);

        $db = \Yii::$app->db;
        $transaction = $db->beginTransaction();
        try {
            $amount = Tool::formatPrice($this->amount - $this->_fee);
            // 转账记录
            $period = Period::instance();
            $model = new Transfer();
            $model->ID = SnowFake::instance()->generateId();
            $model->TRANSFER_SN = Transfer::generateSN();
            $model->OUT_UID = $this->_fromUserInfo['ID'];
            $model->LAST_OUT_USER_NAME = $this->_fromUserInfo['USER_NAME'];
            $model->LAST_OUT_REAL_NAME = $this->_fromUserInfo['REAL_NAME'];
            $model->LAST_OUT_DEC_LV = $this->_fromUserInfo['DEC_LV'];
            $model->LAST_OUT_DEC_ROLE_ID = $this->_fromUserInfo['DEC_ROLE_ID'];
            $model->OUT_WALLET = $this->_transferConfig['out'];
            $model->LAST_OUT_SYSTEM_ID = $this->_fromUserInfo['SYSTEM_ID'] ? $this->_fromUserInfo['SYSTEM_ID'] : '';
            $model->IN_UID = $this->_toUserInfo['ID'];
            $model->LAST_IN_USER_NAME = $this->_toUserInfo['USER_NAME'];
            $model->LAST_IN_REAL_NAME = $this->_toUserInfo['REAL_NAME'];
            $model->LAST_IN_DEC_LV = $this->_toUserInfo['DEC_LV'];
            $model->IN_WALLET = $this->_transferConfig['in'];
            $model->LAST_IN_SYSTEM_ID = $this->_toUserInfo['SYSTEM_ID'] ? $this->_toUserInfo['SYSTEM_ID'] : '';
            $model->ORI_AMOUNT = $this->amount;
            $model->FEE = $this->_fee;
            $model->AMOUNT = $amount;
            $model->REMARK = $this->remark;
            $model->PERIOD_NUM = $period->getNowPeriodNum();
            $model->CALC_MONTH = $period->getNowYearMonth();
            $model->CREATED_AT = Date::nowTime();
            if (!$model->save()) {
                throw new Exception(Form::formatErrorsForApi($model->getErrors()));
            }
            if ($this->type == self::BONUS_TO_BALANCE) {
                // 会员金额减少
                Balance::changeUserBonus($this->_fromUserInfo['ID'], 'bonus', -abs($this->amount), ['TRANSFER_SN' => $model->TRANSFER_SN, 'DEAL_TYPE_ID' => DealType::TRANSFER_OUT, 'REMARK' => 'To:' . $this->_toUserInfo['USER_NAME'] . '，' . $this->remark]);
                Cash::changeUserCash($this->_toUserInfo['ID'], 'CASH', abs($amount), ['TRANSFER_SN' => $model->TRANSFER_SN,'DEAL_TYPE_ID' => DealType::TRANSFER_IN, 'REMARK' => 'From:' . $this->_fromUserInfo['USER_NAME'] . '，' . $this->remark]);
            } elseif($this->type == self::BONUS_TO_BONUS) {
                // 会员金额减少
                Balance::changeUserBonus($this->_fromUserInfo['ID'], 'bonus', -abs($this->amount), ['TRANSFER_SN' => $model->TRANSFER_SN, 'DEAL_TYPE_ID' => DealType::TRANSFER_OUT, 'REMARK' => 'To:' . $this->_toUserInfo['USER_NAME'] . '，' . $this->remark]);
                Balance::changeUserBonus($this->_toUserInfo['ID'], 'bonus', abs($amount), ['TRANSFER_SN' => $model->TRANSFER_SN, 'DEAL_TYPE_ID' => DealType::TRANSFER_IN, 'REMARK' => 'From:' . $this->_fromUserInfo['USER_NAME'] . '，' . $this->remark]);
            }else if ($this->type == self::BALANCE_TO_BALANCE) {
                // 会员金额减少
                Cash::changeUserCash($this->_fromUserInfo['ID'], 'CASH', -abs($this->amount), ['TRANSFER_SN' => $model->TRANSFER_SN,'DEAL_TYPE_ID' => DealType::TRANSFER_OUT, 'REMARK' => 'To:' . $this->_toUserInfo['USER_NAME'] . '，' . $this->remark]);
                Cash::changeUserCash($this->_toUserInfo['ID'], 'CASH', abs($amount), ['TRANSFER_SN' => $model->TRANSFER_SN,'DEAL_TYPE_ID' => DealType::TRANSFER_IN, 'REMARK' => 'From:' . $this->_fromUserInfo['USER_NAME'] . '，' . $this->remark]);
            } else if ($this->type == self::POINT_TO_BALANCE) {
                // 复消积分转余额
                // 减少复消积分
                Balance::changeUserBonus(
                    $this->_fromUserInfo['ID'],
                    'reconsume_points',
                    -abs($this->amount),
                    [
                        'TRANSFER_SN' => $model->TRANSFER_SN,
                        'DEAL_TYPE_ID' => DealType::TRANSFER_OUT,
                        'REMARK' => 'To:' . $this->_toUserInfo['USER_NAME'] . ',' . $this->remark
                    ]
                );
                // 增加余额
                Cash::changeUserCash(
                    $this->_toUserInfo['ID'],
                    'CASH', abs($amount),
                    [
                        'TRANSFER_SN' => $model->TRANSFER_SN,
                        'DEAL_TYPE_ID' => DealType::TRANSFER_IN,
                        'REMARK' => 'From:' . $this->_fromUserInfo['USER_NAME'] . ',' . $this->remark
                    ]
                );
            } else {
                throw new \Exception('错误的交易类型');
            }

            $transaction->commit();
        } catch (Exception $e) {
            $transaction->rollBack();
            $this->addError('edit', $e->getMessage());
            return null;
        }

        $fromData = Balance::getLogData($this->_fromUserInfo['ID']);
        $toData = Balance::getLogData($this->_toUserInfo['ID']);
        $this->userOperateLogger->saveAfterContent=array_merge($fromData,$toData);
        unset($fromData,$toData);
        $this->userOperateLogger->clean()->save([
            'optType' => '会员转账',
            'userId' => \Yii::$app->user->id,
            'userName' => Info::getUserNameByUserId(\Yii::$app->user->id),
            'remark' => $this->remark,
        ]);
        return $model;
    }


}