shenying/app/services/user/UserExchangeServices.php

<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2020 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------
declare (strict_types=1);

namespace app\services\user;

use app\dao\user\UserExchangeDao;
use app\model\user\User;
use app\model\user\UserExchange;
use app\model\user\UserExtract;
use app\services\BaseServices;
use app\dao\user\UserExtractDao;
use app\services\wechat\WechatUserServices;
use crmeb\exceptions\AdminException;
use crmeb\services\FormBuilder as Form;
use crmeb\traits\ServicesTrait;
use FormBuilder\Factory\Iview;
use think\exception\ValidateException;
use think\facade\Route as Url;

/**
 *
 * Class UserExtractServices
 * @package app\services\user
 * @mixin UserExtractDao
 */
class UserExchangeServices extends BaseServices
{

    use ServicesTrait;

    /**
     * UserExtractServices constructor.
     * @param UserExchangeDao $dao
     */
    public function __construct(UserExchangeDao $dao)
    {
        $this->dao = $dao;
    }

    /**
     * 获取一条提现记录
     * @param int $id
     * @param array $field
     * @return array|\think\Model|null
     */
    public function getExtract(int $id, array $field = [])
    {
        return $this->dao->get($id, $field);
    }

    /**
     * 获取某个用户提现总数
     * @param int $uid
     * @return float
     */
    public function getUserExtract(int $uid)
    {
        return $this->dao->getWhereSum(['uid' => $uid, 'status' => [0, 1]]);
    }

    /**
     * 获取某些用户的提现总数列表
     * @param array $uids
     */
    public function getUsersSumList(array $uids)
    {
        return $this->dao->getWhereSumList(['uid' => $uids, 'status' => [0, 1]]);
    }

    public function getCount(array $where = [])
    {
        return $this->dao->getCount($where);
    }

    /**
     * 获取提现列表
     * @param array $where
     * @param string $field
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getUserExtractList(array $where, string $field = '*')
    {
        [$page, $limit] = $this->getPageValue();
        $list = $this->dao->getExtractList($where, $field, $page, $limit);
        foreach ($list as &$item) {
            $item['nickname'] = $item['user']['nickname'] ?? '';
            $item['real_name'] = $item['user']['real_name'] ?? '';
            $item['card_id'] = $item['user']['card_id'] ?? '';
            $item['phone'] = $item['user']['phone'] ?? '';
        }
        $count = $this->dao->count($where);
        return compact('list', 'count');
    }

    /**
     * 获取提现总数
     * @param array $where
     */
    public function getExtractSum(array $where)
    {
        return $this->dao->getExtractMoneyByWhere($where, 'extract_num');
    }

    /**
     * 拒绝提现申请
     * @param $id
     * @param $fail_msg
     * @return bool
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function changeFail(int $id, $userExtract, $message)
    {
        $fail_time = time();
        $extract_number = bcadd((string)$userExtract['extract_num'], (string)$userExtract['extract_fee'], 2);
        $mark = '换股份失败,退回能量值' . $extract_number;
        $uid = $userExtract['uid'];
        $status = -1;
        /** @var UserServices $userServices */
        $userServices = app()->make(UserServices::class);
        $user = $userServices->getUserInfo($uid);
        if (!$user) {
            throw new ValidateException('用户不存在');
        }
        /** @var UserBillServices $userBrokerageServices */
        $userBrokerageServices = app()->make(UserBillServices::class);
        $this->transaction(function () use ($user, $userBrokerageServices, $uid, $id, $extract_number, $message, $userServices, $status, $fail_time) {
            $now_brokerage = bcadd((string)$user['energy'], (string)$extract_number, 2);
            //增加佣金记录
            $userBrokerageServices->income('exchange_fail', $uid, $extract_number, $now_brokerage, $id);
            //修改用户佣金
            if (!$userServices->update($uid, ['energy' => $now_brokerage], 'uid'))
                throw new AdminException('增加用户能量失败');
            if (!$this->dao->update($id, ['fail_time' => $fail_time, 'fail_msg' => $message, 'status' => $status])) {
                throw new AdminException('修改失败');
            }
        });
        //消息推送
        return true;
    }

    /**
     * 通过提现申请
     * @param $id
     * @return bool
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function changeSuccess(int $id, $userExtract)
    {
        $this->transaction(function () use ($id, $userExtract) {
            if (!$this->dao->update($id, ['status' => 1])) {
                throw new AdminException('修改失败');
            }
        });
        return true;
    }

    /**
     * 显示资源列表
     * @param array $where
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function index(array $where)
    {
        $list = $this->getUserExtractList($where);
        //待提现金额
        $where['status'] = 0;
        $extract_statistics['price'] = $this->getExtractSum($where);
        //已提现金额
        $where['status'] = 1;
        $extract_statistics['priced'] = $this->getExtractSum($where);
        //佣金总金额
        return compact('extract_statistics', 'list');
    }


    /**
     * 显示资源列表
     * @param array $where
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getExportList(array $where)
    {
        $list = $this->dao->getExtractAll($where);
        return $list;
    }


    /**
     * 显示编辑资源表单页.
     *
     * @param int $id
     * @return \think\Response
     */
    public function edit(int $id)
    {
        $UserExtract = $this->getExtract($id);
        if (!$UserExtract) {
            throw new AdminException('数据不存在!');
        }
        $f = array();
        $f[] = Form::input('real_name', '姓名', $UserExtract['real_name']);
        $f[] = Form::number('extract_num', '转换能量', (float)$UserExtract['extract_num'])->precision(2)->disabled(true);
        $f[] = Form::number('extract_price', '股份价格', (float)$UserExtract['extract_price'])->precision(2)->disabled(true);
        $f[] = Form::number('exchange_num', '转换股份', (float)$UserExtract['exchange_num'])->precision(2)->disabled(true);
        $f[] = Form::input('account', '账号', $UserExtract['account']);
        $f[] = Form::input('bank_code', '银行卡号', $UserExtract['bank_code']);
        $f[] = Form::input('bank_address', '开户行', $UserExtract['bank_address']);
        $f[] = Form::input('mark', '备注', $UserExtract['mark'])->type('textarea');
        return create_form('编辑', $f, Url::buildUrl('/finance/exchange/' . $id), 'PUT');
    }


    public function update(int $id, array $data)
    {
        if (!$this->dao->update($id, $data))
            throw new AdminException('修改失败');
        else
            return true;
    }

    /**
     * 拒绝
     * @param $id
     * @return mixed
     */
    public function refuse(int $id, string $message)
    {
        $extract = $this->getExtract($id);
        if (!$extract) {
            throw new AdminException('操作记录不存在!');
        }
        if ($extract->status == 1) {
            throw new AdminException('已经提现,错误操作');
        }
        if ($extract->status == -1) {
            throw new AdminException('您的提现申请已被拒绝,请勿重复操作!');
        }
        $res = $this->changeFail($id, $extract, $message);
        if ($res) {
            return true;
        } else {
            throw new AdminException('操作失败!');
        }
    }

    /**
     * 通过
     * @param $id
     * @return mixed
     */
    public function adopt(int $id)
    {
        $extract = $this->getExtract($id);
        if (!$extract) {
            throw new AdminException('操作记录不存!');
        }
        if ($extract->status == 1 || $extract->status == 2) {
            throw new AdminException('您已提现,请勿重复提现!');
        }
        if ($extract->status == -1) {
            throw new AdminException('您的提现申请已被拒绝!');
        }
        if ($this->changeSuccess($id, $extract)) {
            return true;
        } else {
            throw new AdminException('操作失败!');
        }
    }

    /**待提现的数量
     * @return int
     */
    public function userExtractCount()
    {
        return $this->dao->count(['status' => 0]);
    }

    /**
     * 银行卡提现
     * @param int $uid
     * @return mixed
     */
    public function bank(int $uid)
    {
        /** @var UserServices $userService */
        $userService = app()->make(UserServices::class);
        $user = $userService->getUserInfo($uid);
        if (!$user) {
            throw new ValidateException('数据不存在');
        }
        $data['energy'] = $user['energy'];
        //可提现佣金
        $data['minEnergy'] = sys_config('user_exchange_min_energy');//提现最低金额
        $data['exchange_fee'] = sys_config('exchange_fee');//提现手续费
        $data['stock_price'] = sys_config('stock_price');//提现手续费
        $data['bank'] = $this->dao->getLastOne($uid);
        return $data;
    }

    /**
     * 提现申请
     * @param int $uid
     * @param array $data
     */
    public function cash(int $uid, array $data)
    {
        /** @var UserServices $userService */
        $userService = app()->make(UserServices::class);
        $user = $userService->getUserInfo($uid);
        if (date('w') != 6 && date('w') != 0 && date('w') != 7) {
            throw new ValidateException('兑换只能在周末申请');
        }
        if (!$user) {
            throw new ValidateException('数据不存在');
        }
        if ($user['is_auth'] != 2) throw new ValidateException('请先完成实名认证');
        if ($data['name'] != $user['real_name']) throw new ValidateException('转换用户与实名认证不符');
        $data['money'] = $data['energy'];
        if ($data['money'] > $user['energy']) {
            throw new ValidateException('可转换能量值不足');
        }

        $extractPrice = $user['energy'];
        $userExtractMinPrice = sys_config('user_exchange_min_energy');
        if ($data['money'] < $userExtractMinPrice) {
            throw new ValidateException('转换能量值不能小于' . $userExtractMinPrice);
        }
        if ($extractPrice < 0) {
            throw new ValidateException('转换能量值不足' . $data['money']);
        }
        if ($data['money'] > $extractPrice) {
            throw new ValidateException('转换能量值不足' . $data['money']);
        }
        if ($data['money'] <= 0) {
            throw new ValidateException('转换能量值大于0');
        }
        $fee = sys_config('exchange_fee');
        $stock_price = sys_config('stock_price');
        if ($stock_price <= 0) throw new ValidateException('暂不支持转换股份');
        $extract_fee = bcdiv(bcmul($fee, $data['money'], 2), '100', 2);
        if ($extract_fee < 0) $extract_fee = 0;
        $insertData = [
            'uid' => $user['uid'],
            'account' => $data['account'],
            'extract_num' => bcsub((string)$data['money'], (string)$extract_fee, 2),
            'extract_fee' => $extract_fee,
            'extract_price' => $stock_price,
            'exchange_num' => bcdiv(bcsub((string)$data['money'], (string)$extract_fee, 2), (string)$stock_price, 2),
            'add_time' => time(),
            'balance' => $user['energy'],
            'status' => 0,
        ];
        $insertData['real_name'] = $data['name'];
        $insertData['bank_code'] = $data['cardnum'];
        $insertData['bank_address'] = $data['bankname'];
        $mark = '转换' . $data['money'] . '能量值，扣除手续费后实际转换' . $insertData['extract_num'] . '，转换时份额价格' . $stock_price . '，共转换' . $insertData['exchange_num'] . '份额';
        /** @var UserBillServices $userBrokerageServices */
        $userBrokerageServices = app()->make(UserBillServices::class);
        $res1 = $this->transaction(function () use ($insertData, $data, $uid, $userService, $user, $userBrokerageServices, $mark) {
            if (!$res1 = $this->dao->save($insertData)) {
                throw new ValidateException('转换失败');
            }
            //修改用户佣金
            $balance = bcsub((string)$user['energy'], (string)$data['money'], 2) ?? 0;
            if (!$userService->update($uid, ['energy' => $balance], 'uid')) {
                throw new ValidateException('修改用户信息失败');
            }
            //保存佣金记录
            $userBrokerageServices->income('exchange', $uid, ['mark' => $mark, 'number' => $data['money']], $balance, $res1['id']);
            return $res1;
        });
        return true;
    }

    /**
     * @param array $where
     * @param string $SumField
     * @param string $selectType
     * @param string $group
     * @return float|mixed
     */
    public function getOutMoneyByWhere(array $where, string $SumField, string $selectType, string $group = "")
    {
        switch ($selectType) {
            case "sum" :
                return $this->dao->getWhereSumField($where, $SumField);
            case "group" :
                return $this->dao->getGroupField($where, $SumField, $group);
        }
    }


    /**
     * 导入佣金到余额
     * @param int $uid
     * @param $price
     * @return bool
     */
    public function importEnergy(int $uid, $price)
    {
        $switch = sys_config('brokerage_to_energy_switch', 1);
        if (!$switch) throw new ValidateException('暂不支持');
        /** @var UserServices $userServices */
        $userServices = app()->make(UserServices::class);
        $user = $userServices->getUserInfo($uid);
        if (!$user) {
            throw new ValidateException('数据不存在');
        }
        /** @var UserBrokerageServices $userBrokerageServices */
        $userBrokerageServices = app()->make(UserBrokerageServices::class);
        $broken_commission = $userBrokerageServices->getUserFrozenPrice($uid);
        $commissionCount = bcsub((string)$user['brokerage_price'], (string)$broken_commission, 2);
        if ($price > $commissionCount) {
            throw new ValidateException('转入金额不能大于可提现佣金！');
        }
        return $this->transaction(function () use ($uid, $user, $price, $userServices) {
            $edit_data = [];
            $edit_data['energy'] = bcadd((string)$user['energy'], (string)$price, 2);
            $edit_data['brokerage_price'] = $user['brokerage_price'] > $price ? bcsub((string)$user['brokerage_price'], (string)$price, 2) : 0;
            //修改用户佣金、余额信息
            $res1 = $userServices->update($uid, $edit_data, 'uid');
            /** @var UserBillServices $userMoneyServices */
            $userMoneyServices = app()->make(UserBillServices::class);
            //余额记录
            $res2 = $userMoneyServices->income('brokerage_to_energy', $uid, $price, $edit_data['energy'], 0);
            //佣金提现记录
            /** @var UserBrokerageServices $userBrokerageServices */
            $userBrokerageServices = app()->make(UserBrokerageServices::class);
            $res3 = $userBrokerageServices->income('brokerage_to_energy', $uid, $price, $edit_data['brokerage_price'], 0);
            return $res1 && $res2 && $res3;
        });
    }
}