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

<?php

namespace app\api\logic;


use app\common\model\ProductArea;
use fast\Asset;
use app\common\model\LedgerTokenChangeModel;
use app\common\model\LedgerFrozenChangeModel;
use app\common\model\ProductLists;
use app\common\model\ProductOrder;
use app\common\model\UserModel;
use think\Loader;
use app\common\model\UserAirdrop;
use think\Log;
use Exception;
/**
 *  空投福利
 */
class WelfareLoginc
{
 

    /** 添加新人福利
     * @param int   $uid       用户id
     * @param array $productId 产品ID
     * @param int   $num       数量
     * @param int   $lan       语言
     */
    public static function setUserWelfareLos($uid, int $productId, $num, $tim, $lan, $typeId)
    {   
        $result = ProductLists::where('id', $productId)->field('id,'.$lan.'_name as name')->find();
      
        //添加产品
        self::setUserProductOrder($num, 0, 0, 0, $productId, $uid, $typeId);
        return ['start_time'=>$tim, 'name'=>$result->name, 'num'=>$num, 'price'=>0];
    }


    /*
    这个条件是
    向持有选定产品超过指定数量的用户空投指定数量/或比例/的指定产品，
    比如
    向持有A茶超过10套的用户，空投2套B茶
    或
    向持有A茶超过10套的用户，空投持有 数量X20%套B茶，数量取整
    */
    public static function getUserRwaProductNum(int $productId, int $rwa_num, $mod, $num): int
    {   
        //读取当前持有RWa数据
        $list = ProductOrder::getUserOrderByProductId($productId, $rwa_num);
        if(empty($list)) return 0;
        $total = 0; //总数量
        if($mod == 1 && $num > 0){
            $num = bcdiv($num, 100, 2);
            foreach ($list as $item) {
                $total += bcmul($item->total_num, $num);
            } 
        }else{
            $total = count($list) * $num;
        }
        return $total;
    }

    /**
     * 向达到一定持有量的用户空投产品
     * @param int $rwa_num //数量
     * @param $productId   //产品ID
     * @param $rwaProductId  //Rwa产品ID
     * @param $isArea
     * @param $orderId
     * @param $price
     * @param $mod
     * @param $num
     * @return int
     */
    public static function setUserExRwaNum(int $rwa_num, $productId, $rwaProductId, $isArea, $orderId, $price, $mod, $num): int
    {   
        $total = 0; //总数量
        // 使用bcdiv函数进行高精度除法运算，$num除以100，保留两位小数
        $div = bcdiv($num, 100, 2);
        $list = ProductOrder::getUserOrderByProductId($rwaProductId, $rwa_num);
        $user = new UserModel();
        foreach($list as $order){
                //根据$mod的值决定是否需要对用户的rwa_num进行乘以$div的运算
                $num = ($mod == 1)? bcmul($order->total_num, $div): $num;
                // 尝试为用户设置产品订单，如果成功，则更新用户的rwa_num
                if(!empty(self::setUserProductOrder($num, $isArea, $orderId, $price, $productId, $order->user_id, ProductOrder::Airdrop))){
                 
                    // 调用静态方法更新用户的rwa_num，增加$num的值
                    $user::updateForRwaNum($order->user_id, $user::getByParentId($order->user_id), $num, '+');
                }
        }
       return $total;
    }

    //合成订单
    public static function setSynthesisOrder($synthesis, $productId, $num, $uid):array
    {
        $result = array();
        $model = Loader::model('ProductOrder');
        foreach ($productId as $key => $item) {

            //获取需求数量
            if(!isset($synthesis[$key.'_num'])) throw new Exception(__("参数有误，无可用产品"));
            //判断持有数量足够
            $total_num = $synthesis[$key.'_num'] * $num;
            
            $order_arr = $model::getUserOrderByProductNum($uid, $item, $total_num);
            if($total_num != count($order_arr)) throw new Exception(__("材料不足"));

            //关闭持有订单
            $model::whereIn('id', $order_arr)->setField('status', $model::Closure);
            $result[$key][] = ['combine'=>$item, 'new_order'=>$order_arr];
        }
        return $result;
    }


    /**
     * 设置用户产品订单
     * 该方法根据是否需要区域信息来设置用户的订单信息如果没有指定区域，则调用setPopularNoAreaOrder方法，
     * 否则，首先查询产品关联的区域ID，然后调用setPopularAreaOrder方法设置订单信息
     * @param int $num 订单数量
     * @param bool $isArea 是否需要区域信息
     * @param mixed $orderId 订单ID
     * @param float $price 产品价格
     * @param int $productId 产品ID
     * @param int $uid 用户ID
     * @param int $typeId 订单类型ID
     * @return mixed 返回订单设置结果
     */
    public static function setUserProductOrder(int $num, $isArea, $orderId, $price, $productId, $uid, $typeId)
    {
        // 判断是否需要区域信息
        if(empty($isArea)){
            // 不需要区域信息，调用相应的方法设置订单
            $result = ProductOrder::setPopularNoAreaOrder($num, $orderId, $price, $productId, $uid, $typeId);
        }else{
            // 需要区域信息，首先查询符合条件的区域ID
            $areaArr = ProductArea::where('product_id', $productId)->where('status', ProductArea::Normal)->orderRaw('id desc')->limit($num)->column('id');
            // 使用查询到的区域ID调用相应的方法设置订单
            $result =  ProductOrder::setPopularAreaOrder($areaArr, $orderId, $price, $productId, $uid, $typeId);
        }
        // 返回订单设置结果
        return $result;
    }

    //推广空投产品
    public static function setUserEcologyAirdrop(int $uid, int $productId, int $parentId): bool
    {
        $ecology = config('ecology');
        if(!in_array($productId, $ecology['product_id'])){
            return true;
        }
        $user = Loader::model('UserModel')->getById($uid);
        if($user->is_ecology) return true;
        //空投产品
        if($ecology['airdrop']){
            $userAirdrop = Loader::model('UserAirdrop');
            foreach ($ecology['airdrop'] as $item) {
                $userAirdrop::create([
                    'user_id'       =>  $uid,
                    'type_id'       =>  UserAirdrop::TypeUser,
                    'product_id'    =>  $item['product_id'],
                    'num'           =>  $item['num'],
                    'total_num'     =>  $item['num'],
                    'remark'        =>  '生态节点空投',
                    'status'        =>  UserAirdrop::Normal,//为0 待发放层级奖励
                ]);
            }
        }
     
        //发放上级推广奖励
        $ecologyCount = Loader::model('ProductOrder')->isBuyHoldProduct($ecology['parent_hold_product_id'], $parentId);
        if($ecologyCount > 0){
            //发放上级茶宝奖励
            Loader::model('LedgerWalletModel')->changeWalletAccount($parentId, Asset::TOKEN, $ecology['parent_chabao'], LedgerTokenChangeModel::Ecology, 0);
        }

        //修改生态节点标识
        $user->is_ecology  = 1;
        return $user->save();
    }

    //添加Rwa兑换福利产品
    public static function setUserWelfareProduct(int $uid, string $productId,  int $typeId)
    {
        $productOrder = Loader::model('ProductOrder');
        $productList = explode(',', $productId);
        $result = [];
        foreach ($productList as $k=>$item) {
            $orderNo = getOrderSN('R'.$k);
            $result[] = $productOrder::setCreateOrder(0, ['product_id'=> $item, 'area_id'=>0, 'price'=>0], $typeId, $uid, 0, $orderNo, 0, 0);
        }
        return $result;
    }

}