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

<?php

namespace app\common\logic;

use Exception;
use think\Env;
use think\Cache;
use think\Loader ;
use app\common\model\UserPledge;
use app\common\model\ProductPledges;

class PledgeLogic
{

  
    //获取产品信息 user_pledge
    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)->column('id,thum,'.$lan.'_name as name');
        }
        return $list;
    }

    /*
     * 获取产品信息
     */
    public static function getHoldProductList($user_id, $product_id)
    {
        $model  = Loader::model('ProductOrder');
        return $model::where('user_id', $user_id)->where('product_id', $product_id)->where('status', $model::Paid)->field('id,order_no')->select();
      
    }

    //添加质抵押订单
    public static function setPledgeOrder(object $pledge, array $order_no, int $user_id)
    {
        $model  = Loader::model('ProductOrder');
        $order  = $model::where('user_id', $user_id)->whereIn('order_no', $order_no)->select();
        if(empty($order) || count($order) != count($order_no))  throw new Exception('订单不存在');
        $pledge_num = 1;
        if($pledge->type_id == ProductPledges::Single){
            $pledge_num = count($order);
        }
      
        //添加订单 
        Loader::model('UserPledge')::setPledgeData($user_id, $pledge->id, $pledge->product_id, $pledge->day_num, $pledge_num);
   
        //修改状态
        return $model->whereIn('order_no', $order_no)->setField('status', $model::Freeze);
    }

    //获取质抵押订单列表
    //（60*60*24）*（当前时间-最后一次收取时间）
    public static function getPledgeOrderList(int $user_id)
    {
        $model  = Loader::model('UserPledge');
        $list   = $model::where('user_id', $user_id)->where('status', $model::Ongoing)->select();
        if(empty($list))  throw new Exception('暂无质押订单');
        $day   = 86400;
        $total = 0; //当前累计收益
        $growth= 0; //增长累计收益
        $time  = time();
        foreach ($list as $item) {
           $reta  = bcdiv($item->day_num, $day, 2); //天数
           $inter = ($item->last_time == 0) ? $time - $item->create_time: $time - $item->last_time; //最后收取时间
           $total += bcmul($reta, $inter, 2) * $item->num; //累计收益
           $growth += $reta* $item->num;
        }
        return ['total' => $total, 'growth' => $growth, 'list' => $list];   
    }

    //解除质抵押订单
    public static function setPledgeRemove(int $pledge_id,int $user_id)
    {
        $model  = Loader::model('UserPledge');
        $rows   = $model::where('user_id', $user_id)->where('id', $pledge_id)->where('status', $model::Ongoing)->find();
        if(empty($rows))  throw new Exception('暂无质押订单');
        $day   = 86400;
        $total = 0; //当前累计收益
 
        $time  = time();
        $reta  = bcdiv($rows->day_num, $day, 2); //天数
        $inter = ($rows->last_time == 0) ? $time - $rows->create_time: $time - $rows->last_time; //最后收取时间
        $total = bcmul($reta, $inter, 2) * $rows->num; //累计收益
        $rows->total_self= bcadd($total, $rows->total_self, 2);
        $rows->status    = $model::Remove;
        $rows->last_time = $time;
        return  $rows->save();   
    }
    

    //判断请求限制
    public static function getCheckRequestApi(string $key, int $user_id, int $time = 300)
    {
        $timestampsKey = $key.'_'.$user_id;
        $currentTime = time();
        $timestamps = Cache::get($timestampsKey, []);
        if (count($timestamps) >= 5) {
            // 检查最早的记录是否超过5分钟前
            $oldestTime = min($timestamps);
            if ($currentTime - $oldestTime < $time) { // 5分钟内
                return false;
            } else {
                // 移除最早的记录并添加新的时间戳
                $timestamps = array_diff($timestamps, [$oldestTime]);
                $timestamps[] = $currentTime;
            }
        } else {
            // 添加新的时间戳
            $timestamps[] = $currentTime;
        }
        Cache::set($timestampsKey, $timestamps, $time); // 设置5分钟过期时间
        return true;
    }
}