xny/app/common/model/user/AwardLake.php

<?php

namespace app\common\model\user;

use app\common\model\BaseModel;
use app\common\repositories\user\AwardIntegralPriceRepository;
use app\common\repositories\user\UserBillRepository;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;
use think\Exception;

class AwardLake extends BaseModel
{
    public static function tablePk(): ?string
    {
        return 'id';
    }

    public static function tableName(): string
    {
        return 'award_lake';
    }

    /**
     * 奖池累加
     * @param int $lake_type 奖池类型 1:节能油，2:礼包
     * @param float $order_price 订单价格
     * @param int $order_id 订单ID
     * @return true
     * @throws Exception
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public function addOrderLakes($lake_type, $order_price, $order_id)
    {
        switch ($lake_type) {
            case 1:
                $model = new OilLevel();
                break;
            case 2:
                $model = new GiftLevel();
                break;
            default :
                throw new Exception('奖池类型错误');
        }
        $levels = $model->select();
        foreach ($levels as $level) {
            $lake = self::where('level', $level['id'])->where('type', $lake_type)
                ->find();
            if (!$lake) $lake = self::create([
                'level' => $level['id'],
                'type' => $lake_type,
                'award_name' => $level['name'] . '分红',
                'num' => 0,
                'send_time' => time()
            ]);
            $award = bcdiv(bcmul((string)$order_price, (string)$level['award_ratio']), '100', 2);
            AwardLakeLog::income($lake['id'], 'order_add', $award, $order_id, '用户购买商品添加分红池');
        }
        return true;
    }
//30秒执行一次
    public function autoSend()
    {
        $time = strtotime(date('Y-m-d 01:00:00'));
        if (time() < $time) {
            return true;
        }
        $lakes = self::where('send_time', '<', $time)->select();
            @file_put_contents('quanju.txt',$time."-1点的时间戳\r\n",8);
            @file_put_contents('quanju.txt',json_encode($lakes)."-发放时间小于1点的\r\n",8);
        foreach ($lakes as $lake) {
            $this->sendAward($lake['id']);
        }
        return true;
    }

    public function sendAward($lake_id)
    {
        $lake = self::where('id', $lake_id)->find();
        @file_put_contents('quanju.txt',json_encode($lake)."-奖池信息\r\n",8);
        if (!$lake) return true;
        if ($lake['num'] <= 0) {
            self::where('id', $lake['id'])->update(['send_time' => time()]);
            return true;
        }
        switch ($lake['type']) {
            case 1:
                $model = new OilLevel();
                $field = 'oil_level';
                $name = '节能油';
                $title = '节能油积分分红';
                break;
            case 2:
                $model = new GiftLevel();
                $field = 'gift_level';
                $name = '礼包';
                $title = '礼包积分分红';
                break;
            default :
                $model = new OilLevel();
                $field = 'oil_level';
                $name = '节能油';
                $title = '节能油积分分红';
        }
        $level = $model->where('id', $lake['level'])->find();
        $levels = $model->where('grade', '>=', $level['grade'])->column('id');
        $users = User::where($field, 'in', $levels)->where('status', 1)->select();
        $every = bcdiv($lake['num'], count($users), 2);  //每个用户分得的奖励
        if ($every <= 0) {
            self::where('id', $lake['id'])->update(['send_time' => time()]);
            return true;
        }
        $real_send = 0;
        $price = app()->make(AwardIntegralPriceRepository::class)->awardIntegralPrice();  //分红积分价格
        foreach ($users as $user) {
            //todo 添加用户积分  用户分的奖励除以积分价格就是积分数量
            $integral = bcdiv($every, $price, 2);
            $award_integral=User::where('uid', $user['uid'])->value('award_integral');
            $after = bcadd($award_integral, $integral, 2);
            // 创建用户账单仓库实例
            $make = app()->make(UserBillRepository::class);
            $make->incBill($user['uid'], 'award_integral', 'oil_integral', [
                'number' => $award_integral,
                'title' => $title,
                'balance' => $after,
                'status' => 1,
                'link_id' => 0,
                'mark' => $user['nickname'] . '获得' .$name.'分红积分'.$award_integral ,
            ]);
            User::where('uid', $user['uid'])->update(['award_integral' => $after]);


            //todo end
            $real_send = bcadd($real_send, $every, 2);
        }
        AwardLakeLog::expend($lake['id'], 'send', $real_send, 0, '奖池分红');
        self::where('id', $lake['id'])->update(['send_time' => time()]);
    }
}