RWACha-API/application/api/logic/PledgeLogic.php

<?php

namespace app\api\logic;

use Exception;
use think\Env;
use think\Cache;
use think\Loader ;
use fast\Asset;
use app\common\model\LedgerFrozenChangeModel;
use app\common\model\LedgerTokenChangeModel;
use app\common\model\ProductLists;
use app\common\model\ProductOrder;
use app\common\model\LedgerTeacChangeModel;
use app\common\model\ProductPledges;

//质押抵扣
class PledgeLogic
{
    //获取产品信息
    public  static function getByProductIdList(object $list, string $lan = 'zh')
    {
        $model  = Loader::model('ProductLists');
        
        foreach ($list as &$item) {
            $item['product_list'] = $model->whereIn('id', $item->product_id);
            if($item->type_id == ProductPledges::Combin) $item['product_list'] = $model->orderRaw('field(id,'. $item->product_id.')');
            $item['product_list'] = $model->field('id,thum,'.$lan.'_name as name')->select();
            $item['day_num'] = round($item['day_num'], 2);
        }
        return $list;
    }

    /*
     * 获取产品信息
     */
    public static function getHoldProductList($user_id, $product_id)
    {
        $model  = Loader::model('ProductOrder');
        return $model::alias('a')
        ->join('product_list b', 'a.product_id = b.id', 'left')
        ->where('b.is_show', ProductLists::Normal)
        ->where('a.user_id', $user_id)
        ->where('a.product_id', $product_id)
        ->where('a.status', $model::Paid)
        ->field('a.id,a.order_no')->select();
    }

    //添加质抵押订单
    public static function setPledgeOrder(object $pledge, array $order_id, int $user_id, int $count, string $pay_type, float $price)
    {
        $product=  self::getOrderProductList($user_id, $order_id, $count);

        if(empty($product) || count($product) < $count)  throw new Exception('订单不存在');
        //数量
        $pledge_num = ($pledge->type_id == ProductPledges::Single)? $count: 1;
        
        //添加订单 
        Loader::model('UserPledge')::setPledgeData($user_id, $pledge->id, $pledge->product_id, 
        $product, //订单信息
        $pledge->day_num, $pledge_num);
          
        self::setPledgeFee($user_id, $pay_type, $price);
       
        //修改状态
        return Loader::model('ProductOrder')->whereIn('id', $order_id)->setField('status', ProductOrder::Freeze);
    }


    //获取质抵押订单列表
    public static function getPledgeOrderList(int $user_id)//: array
    {
        $model  = Loader::model('UserPledge');
        $time  = time();
        $list   = $model::alias('a')
            ->join('product_pledge b', 'a.pledge_id = b.id', 'left')
            ->where('a.user_id', $user_id)
            ->where('a.status', '>', $model::Close)
            ->field('a.*,b.title,b.type_id,b.day_num,b.token,b.teac,b.is_renew')
            ->select();
        if(empty($list)) throw new Exception('暂无存储订单');
        $day   = 86400;
        $total = 0; //当前累计收益
        $growth= 0; //增长累计收益
        foreach ($list as $item) {
            if($item->end_time >  $time){
                if($item->status == $model::Remove) {
                    $total += $item->total_self;
                }else{
                    $reta  = bcdiv($item->day_num, $day, 6); //天
                    $inter = ($item->last_time == 0) ? $time - $item->create_time: $time - $item->last_time; //最后收取时间
                    $total += bcmul($reta, $inter, 6)* $item->num; //累计收益
                    $growth += $reta* $item->num; //增长收益
                }
            }
        }
        return ['total' => $total, 'growth' => $growth, 'list' => $list];   
    }

    //解除质抵押订单
    public static function setPledgeRemove(int $pledge_id, string $order_id, int $user_id, $team_level_id, $address_level)
    {
        
        $model  = Loader::model('UserPledge');
        $time  = time();
        $rows   = $model::alias('a')
                ->join('product_pledge b', 'a.pledge_id = b.id', 'left')
                ->where('a.user_id', $user_id)
                ->where('a.id', $pledge_id)
                ->where('a.status', $model::Ongoing)
                ->where('a.end_time', '>', $time)
                ->field('a.*,b.day_num,b.type_id')
                ->find();
        if(empty($rows))  throw new Exception('暂无质押订单');

        $orderId  = explode(',', $order_id);
        $detail   = json_decode($rows->details, true);
        $count    = count($orderId);
        $num = $rows->num;
        if(count($orderId) == count($detail)) {
            $rows->status  = $model::Remove;
        }else{
            $result = [];
            foreach ($detail as &$item) 
                if(!in_array($item['id'], $orderId)) $result[] = $item;
            $num             = $count;
            $rows->num       = count($result);
            $rows->details   = json_encode($result, JSON_UNESCAPED_UNICODE);
        }

        $day   = 86400;
        $total = 0; //当前累计收益
        $reta  = bcdiv($rows->day_num, $day, 6); //天数
        $inter = ($rows->last_time == 0) ? $time - $rows->create_time: $time - $rows->last_time; //最后收取时间
        $total = bcmul($reta, $inter, 6) * $num; //累计收益
        $rows->total_self= bcadd($total, $rows->total_self, 6);

        //修改状态
        Loader::model('ProductOrder')::where('user_id', $user_id)->whereIn('id', $orderId)->setField('status', ProductOrder::Paid);

        //等级
        if($rows->type_id == 2) CommonLogic::setIsOuLevelSave($user_id, $team_level_id, $address_level);
        //更新领取状态
        $rows->last_time = $time;
        return  $rows->save();   
    }

    
    //收取质抵押订单列表:（60*60*24）*（当前时间-最后一次收取时间）
    public static function getPledgeCollect(int $user_id)
    {   
        $model  = Loader::model('UserPledge');
        $time  = time();
        $list   = $model::alias('a')
                ->join('product_pledge b', 'a.pledge_id = b.id', 'left')
                ->where('a.user_id', $user_id)
                ->where('a.status', '>', $model::Close)
                ->where('a.end_time', '>', $time)
                ->field('a.*,b.day_num')
                ->select();

        if(empty($list)) throw new Exception('暂无质押订单');
        $day   = 86400;
        $total = 0; //当前累计收益
        foreach ($list as $item) {
            //解冻
            if($item->status == $model::Remove) {
                $total += $item->total_self;
                $item->status = $model::Close; //关闭
            }else{
                $reta  = bcdiv($item->day_num, $day, 6); //天数
                $inter = ($item->last_time == 0) ? $time - $item->create_time: $time - $item->last_time; //最后收取时间
                $total_inco = bcmul($reta, $inter, 6) * $item->num; //累计收益
                $item->last_time = $time; //收取时间
                $item->total_self= bcadd($total_inco, $item->total_self, 2); //累计收益
                $total += $total_inco; //累计收益
            }
            //更新领取状态
            $item->save();
        }

        //等级分佣
        CommonLogic::setTeamLevelIncome($user_id, $total, Asset::TEAC, LedgerTeacChangeModel::TeamLevel);

        //更新用户资产
        return Loader::model('LedgerWalletModel')->changeWalletAccount($user_id, Asset::TEAC, $total, LedgerTeacChangeModel::Pledge, 0);  
    }

    //存储订单续费
    public static function setPledgeOrderRenew(object $pledge, int $user_id, string $pay_type)
    {   
        //扣除支付金额
        self::setPledgeFee($user_id, $pay_type, $pledge[$pay_type]);

        $pledge->end_time = $pledge->end_time + config('pledge_end_time');
        return $pledge->save();
    }


    //添加用户存储产品
    public static function setPledgeProductAdd(object $pledge, int $user_id, int $count, array $order_id)
    {
        $product = self::getOrderProductList($user_id, $order_id, $count);
        if(empty($product) || count($product) < $count)  throw new Exception('订单不存在');
        
        //修改订单状态
        Loader::model('ProductOrder')::where('user_id', $user_id)->whereIn('id', $order_id)->setField('status', ProductOrder::Freeze);

        //添加产品
        $detail = json_decode($pledge->details, true);
        $pledge->details = json_encode(array_merge($detail, $product), JSON_UNESCAPED_UNICODE);   
        $pledge->num =   $pledge->num + $count ; 
        return $pledge->save();
    }

    //判断用户余额 
    public static function isUserBalance(object $user, int $pay_type, string $pay)
    {
        $result = true;
        if ($pay_type == 1 && bcadd($user['token'], $user['frozen'], 6) < $pay) $result = false;
        if ($pay_type == 2 && $user['teac'] < $pay) $result = false;
        return $result;
    }

    //扣除存储手续费
    private static function setPledgeFee(int $user_id, string $pay_type, float $price)
    {
        if( empty($price)) return true;
        //扣除支付金额
        if ($pay_type == Asset::TEAC) {
            Loader::model('LedgerWalletModel')->changeWalletAccount($user_id, $pay_type, -$price, LedgerTeacChangeModel::PledgeFee, 0);
        }else{
            Loader::model('LedgerWalletModel')->setChangeFrozen($user_id, $price, LedgerFrozenChangeModel::Pledge, LedgerTokenChangeModel::Pledge, '-');
        }
        
    }


    //获取订单产品
    private static function getOrderProductList(int $user_id, array $order_id, int $count)
    {
        return Loader::model('ProductOrder')::alias('a')
            ->join('product_list b', 'a.product_id = b.id', 'left')
            ->where('a.user_id', $user_id)
            ->where('a.status', ProductOrder::Paid)
            ->whereIn('a.id', $order_id)->field('a.id,b.zh_name,b.thum,a.order_no')->select();
    }
}