gc/app/models/user/DividendsRecord.php

<?php
/**
 * Created by CRMEB.
 * Copyright (c) 2017~2019 http://www.crmeb.com All rights reserved.
 * Author: liaofei <136327134@qq.com>
 * Date: 2019/3/27 21:44
 */

namespace app\models\user;

use app\admin\model\system\AwardLake;
use app\models\store\StoreOrder;
use app\models\system\SystemGroupLevel;
use app\models\system\SystemUserLevel;
use think\facade\Cache;
use crmeb\traits\ModelTrait;
use crmeb\basic\BaseModel;
use think\facade\Db;

/**
 * TODO 用户消费新增金额明细 model
 * Class UserBill
 * @package app\models\user
 */
class DividendsRecord extends BaseModel
{
    /**
     * 数据表主键
     * @var string
     */
    protected $pk = 'id';

    /**
     * 模型名称
     * @var string
     */
    protected $name = 'dividends_record';

    use ModelTrait;

    public static function income($title, $uid, $type, $number , $mark = '', $status = 1)
    {
        $pm = 1;
        $add_time = time();
        return self::create(compact('title', 'uid', 'type', 'number', 'mark', 'status', 'pm', 'add_time'));
    }

//    public static function expend($title, $uid, $category, $type, $number, $link_id = 0, $balance = 0, $mark = '', $status = 1)
//    {
//        $pm = 0;
//        $add_time = time();
//        return self::create(compact('title', 'uid', 'link_id', 'category', 'type', 'number', 'balance', 'mark', 'status', 'pm', 'add_time'));
//    }
    public static function setWhereList($where)
    {
        $time['data'] = '';
        if ($where['start_time'] != '' && $where['end_time'] != '') {
            $time['data'] = $where['start_time'] . ' - ' . $where['end_time'];
        }
        $model = self::getModelTime($time, self::alias('A')
            ->join('user B', 'B.uid=A.uid')
//            ->where('A.category', 'not in', 'integral')
            ->order('A.add_time desc'), 'A.add_time');
//        if (trim($where['type']) != '') {
//            $model = $model->where('A.type', $where['type']);
//        } else {
//            $model = $model->where('A.type', 'not in', 'gain,system_sub,deduction,sign');
//        }
        if ($where['nickname'] != '') {
            $model = $model->where('B.nickname|B.uid', 'like', "%$where[nickname]%");
        }
        return $model->field(['A.*', 'FROM_UNIXTIME(A.add_time,"%Y-%m-%d %H:%i:%s") as add_time', 'B.uid', 'B.nickname']);
    }
    /**
     * 积分/佣金 使用记录
     * @param $uid
     * @param $page
     * @param $limit
     * @param string $category
     * @return array|\think\Collection
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function userBillList($uid, $page, $limit, $where = [])
    {
//        if ($page) {
            $list = self::where('uid', $uid)
//                ->where('category', $category)
                ->field('mark,pm,number,add_time')
                ->where('status', 1)
                ->where($where)
                ->order('add_time DESC')
                ->page((int)$page, (int)$limit)
                ->select();
//        } else {
//            $list = self::where('uid', $uid)
//                ->where('category', $category)
//                ->field('mark,pm,number,add_time')
//                ->where('status', 1)
//                ->where($where)
//                ->order('add_time DESC')
//                ->select();
//        }
        $list = count($list) ? $list->toArray() : [];
        foreach ($list as &$v) {
            $v['add_time'] = date('Y/m/d H:i', $v['add_time']);
            $v['number'] = floatval($v['number']);
        }
        return $list;
    }

    /*
     * 获取用户账单明细
     * @param int $uid 用户uid
     * @param int $page 页码
     * @param int $limit 展示多少条
     * @param int $type 展示类型
     * @return array
     * */
    public static function getUserBillList($uid, $page, $limit)
    {
        if (!$limit) return [];
        $model = self::where('uid', $uid)->order('add_time desc')->where('number', '<>', 0)
            ->field('FROM_UNIXTIME(add_time,"%Y-%m") as time,group_concat(id SEPARATOR ",") ids')->group('time');

        if ($page) $model = $model->page((int)$page, (int)$limit);
        $list = ($list = $model->select()) ? $list->toArray() : [];
        $data = [];
        foreach ($list as $item) {
            $value['time'] = $item['time'];
            $value['list'] = self::where('id', 'in', $item['ids'])->field('FROM_UNIXTIME(add_time,"%Y-%m-%d %H:%i") as add_time,title,number,pm,status,mark')->order('add_time DESC')->select();
            array_push($data, $value);
        }
        return $data;
    }
//    全网分红
    public static function spread_rewards(){
//        $pool = sys_config('dividend_pool');
//        if (!$pool|| $pool <= 0) return false;
//        $user_list = Db::name('User')->where('level', '>', 0)
//            ->whereOr('group_level', '>', 0)
//            ->select();
//
//        foreach ($user_list as $user){
//            $dividends=0;
//            if ($user['level'] > 0){
//                $level_grade = SystemUserLevel::where('id', $user['level'])->value('grade');
//                $level_dividends = SystemUserLevel::where('grade', '<=', $level_grade)->sum('dividends');
//                $dividends = bcadd($level_dividends, $dividends, 2);
//            }
//            if ($user['group_level'] > 0){
//                $group_level_grade = SystemGroupLevel::where('id', $user['group_level'])->value('grade');
//                $group_level_dividends = SystemGroupLevel::where('grade', '<=', $group_level_grade)->sum('dividends');
//                $dividends = bcadd($group_level_dividends, $dividends, 2);
//            }
//
//            if ($dividends > 0){
//                $brokerage = bcmul($pool, bcdiv($dividends, 100, 2), 2);
//
//                $id = self::income('全网分红', $user['uid'], 'brokerage_price', $brokerage, '订单推荐佣金');
//                $blance = bcadd($user['brokerage_price'], $brokerage, 2);
//                UserBill::income('全网分红', $user['uid'], 'brokerage_price', 'dividend', $brokerage, $id, $blance, '全网分红奖励');
//                User::where('uid', $user['uid'])->update(['brokerage_price' => $blance]);
//            }
//        }


        return true;
    }


    public static function wholeNetworkDividend()
    {
        try {
//            $spread_uid = User::where('uid', $order['uid'])->value('spread_uid');

            // 获取今日0点的时间戳
            $today_start_timestamp = strtotime('today midnight');

            // 获取奖池
            $award_lake = AwardLake::where('add_time', $today_start_timestamp)->find();
            if (!$award_lake) {
//                // 如果今天0点时间戳的数据不存在，则新建一条数据
//                $award_lake = AwardLake::create([
//                    'add_time' => $today_start_timestamp,
//                    'num' => $order['total_price'],
//                    'update_time' => time()
//                ]);
                return true;
            }
            $pool = $award_lake->num;

            // 获取所有用户
//            $user_list = User::all();

            // 处理会员等级分红
            $user_levels = SystemUserLevel::where('is_del',0)->where('is_show',1)->where('dividends','>',0)->order('grade', 'asc')->select();
            foreach ($user_levels as $level) {
                @file_put_contents('quanju.txt',   json_encode($level)."-每日分红等级\r\n", 8);

                // 计算当前等级及以下所有等级的分红比例总和
                $total_dividends = SystemUserLevel::where('grade', $level->grade)->value('dividends'); //奖池比例
                $level_lst = SystemUserLevel::where('grade', '>=', $level->grade)->where('is_del',0)->where('is_show',1)->where('dividends','>',0)->column('id'); //统计高等级id
                $level_lst = array_values($level_lst);
                @file_put_contents('quanju.txt',   json_encode($level_lst)."-统计低等级id\r\n", 8);
                @file_put_contents('quanju.txt',   SystemUserLevel::getLastSql()."-你妈的\r\n", 8);

                // 计算当前等级及以下所有等级的用户人数
                $user_count = User::where('level', 'in', $level_lst)->count();
                @file_put_contents('quanju.txt',   json_encode($user_count)."-分红的人数\r\n", 8);
                if ($user_count > 0) {
                    // 计算当前等级的奖池
                    $level_pool = bcmul($pool, bcdiv($total_dividends, 100, 2), 2);

                    // 计算每个用户的分红金额
                    $brokerage_per_user = bcdiv($level_pool, $user_count, 2);
                    if ($brokerage_per_user > 0){
                        // 更新每个用户的分红金额
                        $users = User::where('level', 'in', $level_lst)->select();
                        foreach ($users as $user) {
                            $new_brokerage = bcadd($user->brokerage_price, $brokerage_per_user, 2);
                            $id = self::income('全网分红', $user['uid'], 'brokerage_price', $brokerage_per_user, $level->name.'会员等级分红');
                            UserBill::income('全网分红', $user->uid, 'brokerage_price', 'dividend', $brokerage_per_user, $id, $new_brokerage, $level->name.'会员等级分红');

                            User::where('uid', $user->uid)->update(['brokerage_price' => $new_brokerage]);
                        }
                    }
                }
            }

            // 处理团队等级分红
            $group_levels = SystemGroupLevel::where('is_del',0)->order('grade', 'asc')->select();
            @file_put_contents('quanju.txt',   json_encode($group_levels)."-每日团队分红等级2\r\n", 8);

            foreach ($group_levels as $group_level) {
                @file_put_contents('quanju.txt',   json_encode($group_level)."-每日团队分红等级\r\n", 8);
                // 计算当前团队等级的奖池
                $group_pool = bcmul($pool, bcdiv($group_level->dividends, 100, 4), 2);

                // 计算当前团队等级的用户人数
                $group_user_count = User::where('group_level', $group_level->id)->count();

                if ($group_user_count > 0) {
                    // 计算每个用户的分红金额
                    $group_brokerage_per_user = bcdiv($group_pool, $group_user_count, 2);
                    @file_put_contents('quanju.txt',   json_encode($group_brokerage_per_user)."-每日团队分红\r\n", 8);

                    if ($group_brokerage_per_user > 0){
                        // 更新每个用户的分红金额
                        $group_users = User::where('group_level', $group_level->id)->select();
                        foreach ($group_users as $user) {
                            $new_brokerage = bcadd($user->brokerage_price, $group_brokerage_per_user, 2);
                            $id = self::income('团队分红', $user['uid'], 'brokerage_price', $group_brokerage_per_user, $group_level->name.'团队等级分红');
                            UserBill::income('团队分红', $user->uid, 'brokerage_price', 'dividend', $group_brokerage_per_user, $id, $new_brokerage, '团队分红奖励');
                            User::where('uid', $user->uid)->update(['brokerage_price' => $new_brokerage]);
                        }
                    }

                }
            }

            return true;
        } catch (\Exception $e) {
            // 处理异常
            @file_put_contents('quanju.txt', json_encode(['line' => $e->getLine(), 'message' => $e->getMessage(), 'file' => $e->getFile()]) . "-全网分红报错内容\r\n", 8);

            return false;
        }
    }


}