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\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 wholeNetworkDividend(){
        $pool = sys_config('dividend_pool');
        if (!$pool|| $pool <= 0) return false;
        $user_list = Db::name('User')->where('level', '>', 0)
            ->whereOr('group_level', '>', 0)
            ->select();
        @file_put_contents('quanju.txt', json_encode($user_list) . "-分红用户列表\r\n", 8);
        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);
            }
            @file_put_contents('quanju.txt', $dividends . "-分红比例\r\n", 8);
            @file_put_contents('quanju.txt', $pool . "-分红奖池\r\n", 8);
            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;
    }

}