<?php

namespace App\Http\Container\AppSection\Controllers;

use App\Helpers\JsonResource;
use App\Models\Activity;
use App\Models\ActivityShareUser;
use App\Models\Pivots\UserActivityCollectionPivot;
use App\Models\Pivots\UserProjectPivot;
use App\Models\Project;
use App\Models\SystemConfig;
use Hikoon\LaravelApi\Support\ApiController;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\DB;


class AuditionController extends ApiController
{

    public function collection(Request $request)
    {
        $status       = $request->get('status', 'all');
        $text         = $request->get('text', '');
        $pageSize     = $request->integer('size', 10);
        $song_type    = $request->get('song_type', 1);
        $user_id      = Auth::id();
        $activity_ids = DB::table('user_activity_collections')
            ->where('user_id', $user_id)
            ->whereNull('deleted_at')
            ->orderByDesc('created_at')
            ->pluck('activity_id')->toArray();
        $query        = Activity::query();
        if (!empty($text)) {
            $query->where('song_name', 'like', '%' . $text . '%');
        }
        if ($status === 'active') {
            $query->where('status', 1);
        }
        $data               = $query
            ->with('user:id,nick_name,avatar')
            ->whereIn('id', $activity_ids)
            ->where('song_type', $song_type)
            ->with(['tags:id,name', 'submitUsers:id,nick_name,intro,real_name,avatar,province,city,company,rate'])
            ->select(['id', 'cover', 'song_name', 'status', 'is_official', 'created_at', 'sub_title', 'guide', 'guide_clip', 'project_id', 'user_id', 'lyric', 'clip_lyric', 'sex', 'mark', 'speed', 'lang'])
            ->withCount(['attend_user as attend_count', 'viewUsersCount as view_count'])
            ->orderByRaw(DB::raw("FIELD(id, " . implode(',', $activity_ids) . ")"))
            ->paginate($pageSize);
        $config_ids         = DB::table('system_config')
            ->whereIn('identifier', ['activity_lang', 'activity_speed', 'activity_sex', 'activity_mark'])
            ->whereNull('deleted_at')
            ->pluck('id')
            ->toArray();
        $configs            = DB::table('system_config')
            ->whereIn('parent_id', $config_ids)
            ->whereNull('deleted_at')->get(['identifier', 'name', 'content']);
        $view_activity_ids  = array_column($data->items(), 'id');
        $collection_at_list = DB::table('user_activity_collections')
            ->whereIn('activity_id', $view_activity_ids)
            ->where('user_id', $user_id)
            ->whereNull('deleted_at')
            ->pluck('created_at', 'activity_id')
            ->toArray();
        $projectIds         = array_column($data->items(), 'project_id');
        $projectList        = Project::query()->leftJoin('users', 'users.id', '=', 'projects.master_id')->whereIn('projects.id', $projectIds)
            ->where('projects.status', '=', 1)
            ->where('projects.deleted_at', '=', NULL)->select(['projects.*', 'users.nick_name', 'users.real_name', 'users.avatar'])->get()->toArray();
        foreach ($projectList as $k => $v) {
            $projectList[$k]['master'] = [
                'id'        => $v['master_id'],
                'nick_name' => $v['nick_name'],
                'real_name' => $v['real_name'],
                'avatar'    => $v['avatar']
            ];
            unset($projectList[$k]['nick_name']);
            unset($projectList[$k]['real_name']);
            unset($projectList[$k]['avatar']);
        }
        $data->each(static function (Activity $activity) use ($configs) {
            $langs = [];
            $lang  = $activity->lang ?? [];
            foreach ($configs as $c) {
                if ($c->identifier == $activity->sex) {
                    $activity->setAttribute('sex', $c->name ?? NULL);
                }
                if ($c->identifier == $activity->mark) {
                    $activity->setAttribute('mark', $c->content ?? NULL);
                }
                if ($c->identifier == $activity->speed) {
                    $activity->setAttribute('speed', $c->name ?? NULL);
                }
                if (in_array($c->identifier, $lang)) {
                    $langs[] = $c->name ?? NULL;
                }
            }
            $activity->setAttribute('lang', $langs);
            $activity->setRelation('attend_user', $activity->getRelation('submitUsers')?->unique()->take(6) ?? []);
            $activity->unsetRelation('submitUsers');
        });
        $result = json_decode(json_encode($data->items()), true);
        foreach ($result as &$v) {
            $project = array_filter(array_map(static fn($item) => $item['id'] === $v['project_id'] ? $item : NULL, $projectList));

            $v['project']       = array_values($project);
            $v['collection_at'] = !empty($collection_at_list[$v['id']]) ? $collection_at_list[$v['id']] : '';
            unset($v['user_id'], $v['project_id']);
        }

        return JsonResource::success(JsonResource::SUCCESS, ['activitys' => $result, 'count' => $data->total()]);
    }

    public function sub(Request $request)
    {
        $activity_id = $request->get('activity_id', '');
        if (empty($activity_id)) {
            return JsonResource::success('收藏失败-参数错误。请联系管理员', code: 201);
        }
        $user_id     = Auth::id();
        $is_activity = DB::table('user_activity_collections')
            ->where('user_id', $user_id)
            ->where('activity_id', $activity_id)
            ->whereNull('deleted_at')
            ->orderByDesc('created_at')
            ->pluck('id')->first();
        if (!empty($is_activity)) {
            return JsonResource::success('请勿重复收藏', code: 400);
        }
        DB::table('user_activity_collections')->insert([
            'user_id'     => $user_id,
            'activity_id' => $activity_id,
            'created_at'  => date('Y-m-d H:i:s', time()),
            'updated_at'  => date('Y-m-d H:i:s', time())
        ]);
        $user        = DB::table('users')->where('id', $user_id)->first();
        $business_id = $user->business_id;
        $role        = $user->role;
        # 有商务且为歌手
        if ($business_id && $role === 'Singer') {
            $msg_data = [
                'title'       => '',
                'content'     => '',
                'sender_id'   => $user_id,
                'receiver_id' => $user_id,
                'activity_id' => $activity_id,
                'type'        => 2,
                'is_read'     => 0,
                'is_bind'     => 1,
                'created_at'  => date('Y-m-d H:i:s', time()),
                'updated_at'  => date('Y-m-d H:i:s', time())
            ];
            DB::table('user_messages')->insert($msg_data);
        }

        return JsonResource::success('收藏成功');
    }

    public function unsub(Request $request)
    {
        $activity_id = $request->get('activity_id');
        $user_id     = Auth::id();
        $is_activity = DB::table('user_activity_collections')
            ->where('user_id', $user_id)
            ->where('activity_id', $activity_id)
            ->whereNull('deleted_at')
            ->orderByDesc('created_at')
            ->first();
        if (empty($is_activity)) {
            return JsonResource::success('未收藏不能取消', code: 400);
        }
        DB::table('user_activity_collections')->where('id', $is_activity->id)->update([
            'updated_at' => date('Y-m-d H:i:s', time()),
            'deleted_at' => date('Y-m-d H:i:s', time())
        ]);
        $m_data = ['sender_id' => $user_id, 'activity_id' => $activity_id, 'type' => 2, 'is_read' => 0];
        DB::table('user_messages')->where($m_data)->update([
            'deleted_at' => date('Y-m-d H:i:s', time())
        ]);
        return JsonResource::success('已取消收藏');
    }

    public function bandLinkActivity(Request $request)
    {
        $id        = $request->get('id');
        $pageSize  = $request->integer('size', 10);
        $page      = $request->integer('page', 1);
        $song_type = $request->get('song_type', 1);
        $song_name = $request->get('song_name', '');
        $user_id   = Auth::id();
        $query     = DB::table('activitys')
            ->where('project_id', $id)
            ->where('audit_status', 1)
            ->where('status', 1)
            ->where('song_type', $song_type);
        if (!empty($song_name)) {
            $query->where('song_name', 'like', '%' . $song_name . '%');
        }
        $activity_ids = $query
            ->whereNull('deleted_at')
            ->pluck('id')->toArray();
        if (empty($activity_ids)) {
            return JsonResource::success(JsonResource::SUCCESS, ['data' => [], 'count' => 0]);
        }
        $unlike_activity_ids = DB::table('user_activity_unlikes')
            ->where('user_id', $user_id)
            ->whereNull('deleted_at')
            ->pluck('activity_id')->toArray();
        $activity_id_list    = [];
        foreach ($activity_ids as $v) {
            if (!in_array($v, $unlike_activity_ids)) {
                $activity_id_list[] = $v;
            }
        }
        if (empty($activity_id_list)) {
            return JsonResource::success(JsonResource::SUCCESS, ['data' => [], 'count' => 0]);
        }
        $def_sql = "select activitys.id,activitys.song_name,activitys.project_id,activitys.sub_title,activitys.created_at,
              IF(uva.id IS NULL,0,1) AS `is_listen`,
              IF(ahu.id IS NULL,0,1) AS `is_submit`,
              IF(uac.id IS NULL,0,1) AS `is_collection`,
              IF(ahu.`status`=1,1,0) AS `is_take`,
              (select count(*) from user_view_activitys where user_view_activitys.activity_id = activitys.id ) as view_count,
          (select count(*) from activity_has_users where activity_has_users.activity_id = activitys.id and activity_has_users.type='Submit' AND  activity_has_users.deleted_at is NULL )  as attend_count
              from `activitys`
          left join `user_activity_collections` as uac on `uac`.`activity_id` = `activitys`.`id` and `uac`.user_id=" . $user_id . " and `uac`.deleted_at is NULL
          left join `user_view_activitys` as uva on `uva`.`activity_id` = `activitys`.`id` and `uva`.user_id=" . $user_id . "
          left join `activity_has_users` as ahu on `ahu`.`activity_id` = `activitys`.`id` and `ahu`.user_id=" . $user_id . " and  `ahu`.`type`='Submit' and `ahu`.deleted_at is NULL
          where activitys.id IN (" . implode(',', $activity_ids) . ") AND activitys.`status`=1 AND audit_status=1 AND  activitys.deleted_at is NULL GROUP BY activitys.id,uac.id,uva.id,ahu.id ";
        if ($song_type == 2) {
            $sort_sql = "order by p_is_top desc,publish_at desc";
        } else {
            $sort_sql = "order by p_is_top desc,is_listen asc,activitys.weight desc,activitys.created_at desc";
        }
        $def_sql = $def_sql . $sort_sql;

        $sql                = $def_sql . " limit " . $pageSize . " offset " . ($page - 1) * $pageSize;
        $total_sql          = "SELECT COUNT(*) AS total_count FROM (" . $def_sql . ") AS subquery";
        $total              = DB::select($total_sql)[0]->total_count;
        $result             = DB::select($sql);
        $list               = json_decode(json_encode($result), true);
        $search_activity_id = array_column($list, 'id');
        $data               = Activity::query()
            ->whereIn('id', $search_activity_id)
            ->with(['linkArranger:id,nick_name', 'tags:id,name', 'project:id,name,cover,is_promote', 'comfirmTime:project_id,average_day,updated_at'])
            ->select(['id', 'cover', 'song_name', 'status', 'sub_title', 'guide', 'guide_clip', 'project_id', 'user_id', 'lyric', 'clip_lyric', 'sex', 'mark', 'speed', 'lang', 'p_is_top', 'publish_at', 'estimate_release_at', 'guide_duration', 'guide_clip_duration', 'karaoke', 'karaoke_clip', 'expand'])
            ->withCount(['publicAudio as public_audio_count', 'totalSong as total_song_count', 'onlineSong as online_song_count'])
            ->paginate($pageSize, pageName: 'limit');
        // 获取用户收藏
        $userCollection   = UserActivityCollectionPivot::query()
            ->selectRaw('activity_id,1 as num')
            ->where('user_id', $user_id)
            ->pluck('num', 'activity_id')->toArray();
        $config           = SystemConfig::query()->where('status', 1)
            ->whereHas('parent', fn(Builder $builder) => $builder->where('status', 1)->whereIn('identifier', ['activity_mark', 'activity_lang', 'activity_speed', 'activity_sex']))
            ->get(['name', 'identifier', 'content']);
        $now_activity_ids = array_column($data->items(), 'id');
        $now_project_ids  = array_column($data->items(), 'project_id');
        $view_id_list     = DB::table('user_view_activitys')
            ->whereIn('activity_id', $now_activity_ids)
            ->where('user_id', $user_id)
            ->whereNull('deleted_at')
            ->pluck('activity_id')
            ->toArray();
        $last_ids_list    = DB::table('activitys')
            ->whereIn('id', $now_activity_ids)
            ->where('created_at', '>=', now()->subDays(7))
            ->whereNull('deleted_at')
            ->pluck('id')
            ->toArray();
        $master_list      = UserProjectPivot::query()
            ->whereIn('project_id', $now_project_ids)
            ->where('user_id', $user_id)
            ->pluck('project_id')
            ->toArray();
        $share_user       = ActivityShareUser::query()
            ->whereIn('activity_id', $now_activity_ids)
            ->where('user_id', $user_id)
            ->pluck('activity_id')
            ->toArray();

        $data->each(static function (Activity $activity) use ($userCollection, $config, $view_id_list, $last_ids_list, $master_list, $share_user) {
            $isCollection = $userCollection[$activity->getKey()] ?? 0;
            $activity->setAttribute('arranger', ['in_side' => $activity->linkArranger, 'out_side' => $activity->expand['arranger']['supplement'] ?? []]);
            unset($activity->linkArranger, $activity->expand);

            $langs = [];
            $lang  = $activity->lang ?? [];
            foreach ($config as $c) {
                if ($c->identifier == $activity->sex) {
                    $activity->setAttribute('sex', $c->name ?? NULL);
                }
                if ($c->identifier == $activity->mark) {
                    $activity->setAttribute('mark', $c->content ?? NULL);
                }
                if ($c->identifier == $activity->speed) {
                    $activity->setAttribute('speed', $c->name ?? NULL);
                }
                if (in_array($c->identifier, $lang)) {
                    $langs[] = $c->name ?? NULL;
                }
            }

            $now_id = $activity->getAttribute('id');
            $is_new = 'new';
            if (in_array($now_id, $view_id_list)) {
                $is_new = 'listened';
            }
            if (!in_array($now_id, $view_id_list) && in_array($now_id, $last_ids_list)) {
                $is_new = 'listened';
            }

            $activity->setAttribute('lang', $langs);
            $activity->setAttribute('project', []);
            $activity->setAttribute('status_tag', $is_new);
            $is_confirm_share = in_array($now_id, $share_user);
            $activity->setAttribute('is_confirm_share', $is_confirm_share);
            $is_master = in_array($activity->getAttribute('project_id'), $master_list);
            $activity->setAttribute('is_master', $is_master);

            $activity->setAttribute('is_collection', $isCollection);
            $is_promote = 0;
            if ($activity->getRelation('project')) {
                $is_promote = $activity->getRelation('project')->is_promote;
                $project    = $activity->getRelation('project')->toArray();
                unset($project['is_promote']);
                $activity->setAttribute('project', [$project]);
            }
            $activity->setAttribute('is_promote', $is_promote);
            $activity->unsetRelation('project');

        });
        $result     = json_decode(json_encode($data->items()), true);
        $result_map = [];
        foreach ($result as &$v) {
            unset($v['user_id'], $v['project_id']);
            $result_map[$v['id']] = $v;
        }
        $activity_list = [];
        foreach ($search_activity_id as $k) {
            $activity_list[] = $result_map[$k];
        }
        unset($result, $result_map, $data);
        return JsonResource::success(JsonResource::SUCCESS, ['data' => $activity_list, 'count' => $total]);

    }

}