lzxt/app/models/system/SystemUserTask.php

<?php

namespace app\models\system;

use app\models\store\StoreOrder;
use app\models\user\User;
use app\models\user\UserBill;
use app\models\user\UserLevel;
use app\models\user\UserTaskFinish;
use crmeb\traits\ModelTrait;
use crmeb\basic\BaseModel;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;

/**
 * TODO 设置等级任务Model
 * Class SystemUserTask
 * @package app\models\system
 */
class SystemUserTask extends BaseModel
{
    /**
     * 数据表主键
     * @var string
     */
    protected $pk = 'id';

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

    use ModelTrait;

    /**
     * 任务类型
     * type 记录在数据库中用来区分任务
     * name 任务名 (任务名中的{$num}会自动替换成设置的数字 + 单位)
     * max_number 最大设定数值 0为不限定
     * min_number 最小设定数值
     * unit 单位
     * */
    protected static $TaskType = [
        [
            'type' => 'SatisfactionIntegral',
            'name' => '满足积分{$num}',
            'real_name' => '积分数',
            'max_number' => 0,
            'min_number' => 0,
            'unit' => '分'
        ],
        [
            'type' => 'ConsumptionAmount',
            'name' => '消费满{$num}',
            'real_name' => '消费金额',
            'max_number' => 0,
            'min_number' => 0,
            'unit' => '元'
        ],
        [
            'type' => 'SingleConsumptionAmount',
            'name' => '单次消费满{$num}',
            'real_name' => '消费金额',
            'max_number' => 0,
            'min_number' => 0,
            'unit' => '元'
        ],
        [
            'type' => 'ConsumptionFrequency',
            'name' => '消费{$num}',
            'real_name' => '消费次数',
            'max_number' => 0,
            'min_number' => 0,
            'unit' => '次'
        ],
        [
            'type' => 'TeamConsumptionFrequency',
            'name' => '团队消费{$num}',
            'real_name' => '消费次数',
            'max_number' => 0,
            'min_number' => 0,
            'unit' => '次'
        ],
        [
            'type' => 'CumulativeAttendance',
            'name' => '累计签到{$num}',
            'real_name' => '累计签到',
            'max_number' => 365,
            'min_number' => 1,
            'unit' => '天'
        ],
        [
            'type' => 'SharingTimes',
            'name' => '分享给朋友{$num}',
            'real_name' => '分享给朋友',
            'max_number' => 1000,
            'min_number' => 1,
            'unit' => '次'
        ],
        [
            'type' => 'InviteGoodFriends',
            'name' => '邀请好友{$num}成为下线',
            'real_name' => '邀请好友成为下线',
            'max_number' => 1000,
            'min_number' => 1,
            'unit' => '人'
        ],
        [
            'type' => 'InviteGoodFriendsLevel',
            'name' => '邀请好友{$num}成为会员',
            'real_name' => '邀请好友成为会员',
            'max_number' => 1000,
            'min_number' => 1,
            'unit' => '人'
        ],
    ];

    public function profile()
    {
        return $this->hasOne('SystemUserLevel', 'level_id', 'id')->field('name');
    }

    public static function getTaskTypeAll()
    {
        return self::$TaskType;
    }

    /**
     * 获取某个任务
     * @param string $type 任务类型
     * @return array
     * */
    public static function getTaskType($type)
    {
        foreach (self::$TaskType as $item) {
            if ($item['type'] == $type) return $item;
        }
    }

    /**
     * 设置任务名
     * @param string $type 任务类型
     * @param int $num 预设值
     * @return string
     * */
    public static function setTaskName($type, $num)
    {
        $systemType = self::getTaskType($type);
        return str_replace('{$num}', $num . $systemType['unit'], $systemType['name']);
    }

    /**
     * 累计消费金额
     * @param int $task_id 任务id
     * @param int $uid 用户id
     * @param int $start_time 开始时间
     * @param int $number 限定时间
     * @return boolean
     * */
    public static function ConsumptionAmount($task_id, $uid = 0, $start_time = 0, $number = 0)
    {
        $isComplete = false;
        $SumPayPrice = StoreOrder::where('paid', 1)->where('refund_status', 0)->where('is_del', 0)->where('uid', $uid)->where('add_time', '>', $start_time)->sum('pay_price');
        if ($SumPayPrice >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
        return ['还需消费{$num}元', $SumPayPrice, $isComplete];
    }
    /**
     * 单次消费金额
     * @param int $task_id 任务id
     * @param int $uid 用户id
     * @param int $start_time 开始时间
     * @param int $number 限定时间
     * @return boolean
     * */
    public static function SingleConsumptionAmount($task_id, $uid = 0, $start_time = 0, $number = 0)
    {
        $isComplete = false;
        $SumPayPrice = StoreOrder::where('paid', 1)->where('refund_status', 0)->where('is_del', 0)->where('uid', $uid)->where('add_time', '>', $start_time)->order('pay_price DESC')->find();
        if (!empty($SumPayPrice)){
            $SumPayPrice = $SumPayPrice->toArray();
            $SumPayPrice = $SumPayPrice['pay_price'];
        }else{
            $SumPayPrice = 0;
        }
        if ($SumPayPrice >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
        return ['还需消费{$num}元', $SumPayPrice, $isComplete];
    }

    /**
     * 累计消费次数
     * @param int $task_id 任务id
     * @param int $uid 用户id
     * @param int $start_time 开始时间
     * @param int $number 限定时间
     * @return boolean
     * */
    public static function ConsumptionFrequency($task_id, $uid = 0, $start_time = 0, $number = 0)
    {
        $isComplete = false;
        $countPay = StoreOrder::where('paid', 1)->where('refund_status', 0)->where('is_del', 0)->where('uid', $uid)->where('add_time', '>', $start_time)->count();
        if ($countPay >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
        return ['还需消费{$num}次', $countPay, $isComplete];
    }
    /**
     * 团队累计消费次数
     * @param int $task_id 任务id
     * @param int $uid 用户id
     * @param int $start_time 开始时间
     * @param int $number 限定时间
     * @return boolean
     * */
    public static function TeamConsumptionFrequency($task_id, $uid = 0, $start_time = 0, $number = 0)
    {
        $isComplete = false;
        $team_users = self::getAllTeamMembers($uid);
        $countPay = User::where('uid','in',$team_users)->sum('pay_count');
//        $countPay = StoreOrder::where('paid', 1)->where('refund_status', 0)->where('is_del', 0)->where('uid', $uid)->where('add_time', '>', $start_time)->count();
        if ($countPay >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
        return ['还需团队消费{$num}次', $countPay, $isComplete];
    }

    /**
     * 邀请好友成为会员
     * @param int $task_id 任务id
     * @param int $uid 用户id
     * @param int $start_time 开始时间
     * @param int $number 限定时间
     * @return boolean
     * */
    public static function InviteGoodFriendsLevel($task_id, $uid = 0, $start_time = 0, $number = 0)
    {
        $isComplete = false;
        $uids = User::where('spread_uid', $uid)->where('spread_time', '>', $start_time)->column('uid', 'uid');
        $levelCount = count($uids) ? UserLevel::setUserLevelCount($uids) : 0;
        if ($levelCount >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
        return ['还需邀请{$num}人成为会员', $levelCount, $isComplete];
    }

    /**
     * 邀请好友成为下线
     * @param int $task_id 任务id
     * @param int $uid 用户id
     * @param int $start_time 查询开始时间
     * @param int $number 限定数量
     * */
    public static function InviteGoodFriends($task_id, $uid = 0, $start_time = 0, $number = 0)
    {
        $isComplete = false;
        $spreadCount = User::where('spread_uid', $uid)->where('spread_time', '>', $start_time)->count();
        if ($spreadCount >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
        return ['还需邀请{$num}人成为下线', $spreadCount, $isComplete];
    }

    /**
     * 满足积分
     * @param int $task_id 任务id
     * @param int $uid 用户id
     * @param int $start_time 查询开始时间
     * @param int $number 限定数量
     * @return Boolean
     * */
    public static function SatisfactionIntegral($task_id, $uid = 0, $start_time = 0, $number = 0)
    {
        $isComplete = false;
        $sumNumber = UserBill::where('uid', $uid)->where('category', 'integral')->where('pm', 1)->where('add_time', '>', $start_time)->where('type', 'in', ['system_add', 'sign', 'gain'])->sum('number');
        if ($sumNumber >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
        return ['还需要{$num}经验', $sumNumber, $isComplete];
    }

    /**
     * 分享给朋友次数完成情况
     * @param int $task_id 任务id
     * @param int $uid 用户id
     * @param int $start_time 查询开始时间
     * @param int $number 限定数量
     * @return Boolean
     * */
    public static function SharingTimes($task_id, $uid = 0, $start_time = 0, $number = 0)
    {
        $isComplete = false;
        $sumCount = UserBill::where('uid', $uid)->where('category', 'share')->where('pm', 1)->where('add_time', '>', $start_time)->where('type', 'share')->count();
        if ($sumCount >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
        return ['还需分享{$num}次', $sumCount, $isComplete];
    }

    /**
     * 累计签到
     * @param int $task_id 任务id
     * @param int $uid 用户id
     * @param int $start_time 查询开始时间
     * @param int $number 限定数量
     * @return Boolean
     * */
    public static function CumulativeAttendance($task_id, $uid = 0, $start_time = 0, $number = 0)
    {
        $isComplete = false;
        $sumCount = UserBill::where('uid', $uid)->where('category', 'integral')->where('pm', 1)->where('add_time', '>', $start_time)->where('type', 'sign')->count();
        if ($sumCount >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
        return ['还需签到{$num}天', $sumCount, $isComplete];
    }

    /**
     * 设置任务完成情况
     * @param int $task_id 任务id
     * @param int $uid 用户uid
     * @param int $start_time 查询开始时间
     * @return Boolean
     * */
    public static function setTaskFinish($task_id = 0, $uid = 0, $start_time = 0)
    {
        if (!$task_id) return self::setErrorInfo('缺少任务id参数');
        if (!$uid) return self::setErrorInfo('缺少用户uid');
        $task = self::where('id', $task_id)->where('is_show', 1)->find();
        if (!$task) return self::setErrorInfo('任务不存在');
        $task_type = $task->task_type;
        if ($task_type && method_exists(self::class, $task_type)) {
            try {
                $start_time = User::getCleanTime($uid);
                return self::$task_type($task_id, $uid, $start_time, $task->number);
            } catch (\Exception $e) {
                return self::setErrorInfo($e->getMessage());
            }
        }
        return self::setErrorInfo('没有此任务');
    }

    /**
     * 设置任务显示条件
     * @param string $alert 表别名
     * @param object $model 模型实例
     * @return object
     * */
    public static function visibleWhere($alert = '', $model = null)
    {
        $model = $model === null ? new self() : $model;
        if ($alert) $model = $model->alias($alert);
        $alert = $alert ? $alert . '.' : '';
        return $model->where("{$alert}is_show", 1);
    }

    /**
     * 获取等级会员任务列表
     * @param int $level_id 会员等级id
     * @param int $uid 用户id
     * @param null $level
     * @param int $expire
     * @return array
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public static function getTashList($level_id, $uid = 0, $level = null, $expire = 1400)
    {
        $level_id = is_string($level_id) ? (int)$level_id : $level_id;
        $list = self::visibleWhere()->where('level_id', $level_id)->field('name,real_name,task_type,illustrate,number,id')->order('sort desc')->select();
        $list = count($list) ? $list->toArray() : [];
        if ($uid == 0) return $list;
        if ($level === null) $level = SystemUserLevel::getLevelInfo($uid);
        //获取下一个vip的id
        $LeveId = SystemUserLevel::getNextLevelId($level['id'], SystemUserLevel::setWhere()->where('grade', '>', $level['grade'] ?? 0)->min('grade'));
        $is_clear = SystemUserLevel::getClear($level['id']);
        if ($is_clear == false && $LeveId == $level_id) $is_clear = true;
        $reach_count = self::getTaskComplete($level_id, $uid, true);
        return [
            'list' => $list,
            'reach_count' => $reach_count,
            'task' => self::tidyTask($list, $uid, $is_clear, User::getCleanTime($uid)),
        ];
    }

    /**
     * 获取未完成任务的详细值
     * @param array $item 任务
     * @param int $uid 用户id
     * @param int $startTime 开始时间
     * @return array
     * */
    protected static function set_task_type($item, $uid, $startTime = 0)
    {
        $task = ['task_type_title' => '', 'new_number' => 0, 'speed' => 0, 'finish' => 0];
        $task_type = $item['task_type'];
        switch ($task_type) {
            case 'SatisfactionIntegral':
            case 'ConsumptionAmount':
            case 'SingleConsumptionAmount':
            case 'ConsumptionFrequency':
            case 'TeamConsumptionFrequency':
            case 'CumulativeAttendance':
            case 'SharingTimes':
            case 'InviteGoodFriends':
            case 'InviteGoodFriendsLevel':
                try {
                    list($task_type_title, $num, $isComplete) = self::$task_type($item['id'], $uid, $startTime, $item['number']);
                    if ($isComplete) {
                        $task['finish'] = 1;
                        $task['speed'] = 100;
                        $task['speed'] = $item['number'];
                        $task['new_number'] = $item['number'];
                    } else {
                        $numdata = bcsub($item['number'], $num, 0);
                        $task['task_type_title'] = str_replace('{$num}', $numdata, $task_type_title);
                        $task['speed'] = bcdiv($num, $item['number'], 2);
                        $task['speed'] = bcmul($task['speed'], 100, 0);
                        $task['new_number'] = $num;
                    }
                } catch (\Exception $e) {
                }
                break;
        }
        return [$task['new_number'], $task['speed'], $task['task_type_title'], $task['finish']];
    }


    /**
     * 设置任务完成状态,已被使用
     * @param int $level_id 会员id
     * @param int $uid 用户id
     * @return Boolean
     * */
    public static function setTarkStatus($level_id, $uid)
    {
        $taskIds = self::visibleWhere()->where('level_id', $level_id)->column('id', 'id');
        if (!count($taskIds)) return true;
        return UserTaskFinish::where('uid', $uid)->where('task_id', 'in', $taskIds)->update(['status' => 1]);
    }

    /**
     * 检查当前等级是否完成全部任务
     * @param int $level_id 会员id
     * @param int $uid 用户uid
     * @return boolean
     * */
    public static function getTaskComplete($level_id, $uid, $isCount = false)
    {
        $taskIds = self::visibleWhere()->where('level_id', $level_id)->column('id', 'id');
        $taskIdsCount = count($taskIds);
        //如果当前会员没有任务默认为直接升级为下一等级
        if ($taskIdsCount) {
            if ($isCount) {
                return UserTaskFinish::group('task_id')->where('uid', $uid)->where('task_id', 'in', $taskIds)->count();
            } else {
                $finishCount = UserTaskFinish::group('task_id')->where('status', $isCount ? 1 : 0)->where('uid', $uid)->where('task_id', 'in', implode(',', $taskIds))->count();
            }
            //如果当前任务有完成其一的,查询当前完成的任务数量,如果有任务完成则达成当前vip
            if (self::visibleWhere()->where('id', 'in', implode(',', $taskIds))->where('is_must', 0)->count() && $finishCount) {
                return true;
            }
            return $finishCount >= $taskIdsCount;
        }
        if ($isCount) return 0;
        //如果没有设置任务当前等级无需购买则返回false
        if (SystemUserLevel::be(['id' => $level_id, 'is_pay' => 0])) return false;
        return true;
    }

    /**
     * 设置任务内容完成情况
     * @param array $task 任务列表
     * @param int $uid 用户id
     * @热图图呢 array
     * */
    public static function tidyTask($task, $uid, $is_clear, $startTime)
    {
        if (!is_array($task)) return $task;
        foreach ($task as &$item) {
            //如果已完成该任务进度直接为100
            if (UserTaskFinish::where('uid', $uid)->where('task_id', $item['id'])->count()) {
                $item['new_number'] = $item['number'];
                $item['speed'] = 100;
                $item['finish'] = 1;
                $item['task_type_title'] = '';
            } else {
//                if($is_clear){
                list($new_number, $speed, $task_type_title, $finish) = self::set_task_type($item, $uid, $startTime);
                $item['new_number'] = $new_number;
                $item['speed'] = $speed;
                $item['task_type_title'] = $task_type_title;
                $item['finish'] = $finish;
//                }else {
//                    list($new_number, $speed, $task_type_title, $finish) = self::set_task_type($item,-1,time()+86400);
//                    $item['new_number'] = $new_number;
//                    $item['speed'] = $speed;
//                    $item['task_type_title'] = $task_type_title;
//                    $item['finish'] = $finish;
//                }
            }
        }
        return $task;
    }
    /**
     * 递归获取所有团队成员
     * @param int $uid 用户ID
     * @return array
     */
    public static function getAllTeamMembers($uid, &$teamUids = [])
    {
        // 获取直接下级
        $directSubordinates = User::where('spread_uid', $uid)->column('uid');

        if (!empty($directSubordinates)) {
            // 过滤掉最开始传入的UID
            $directSubordinates = array_diff($directSubordinates, [$uid]);

            // 合并当前直接下级UID到团队UID列表
            $teamUids = array_merge($teamUids, $directSubordinates);

            // 递归获取下级的下级
            foreach ($directSubordinates as $subordinateUid) {
                self::getAllTeamMembers($subordinateUid, $teamUids);
            }
        }

        return $teamUids;
    }

}