mint/app/Http/Controllers/DhammaTermController.php

<?php

namespace App\Http\Controllers;

use App\Models\DhammaTerm;
use App\Models\Channel;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Cache;
use App\Tools\RedisClusters;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Str;
use App\Http\Api\AuthApi;
use App\Http\Api\StudioApi;
use App\Http\Api\ChannelApi;
use App\Http\Api\ShareApi;
use App\Tools\Tools;
use App\Http\Resources\TermResource;
use Illuminate\Support\Facades\App;
use PhpOffice\PhpSpreadsheet\Spreadsheet;
use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
use Illuminate\Support\Facades\Log;

class DhammaTermController extends Controller
{
    /**
     * Display a listing of the resource.
     *
     * @return \Illuminate\Http\Response
     */
    public function index(Request $request)
    {
        $result=false;
		$indexCol = ['id','guid','word','meaning',
                    'other_meaning','note','tag','language',
                    'channal','owner','editor_id',
                    'created_at','updated_at'];

		switch ($request->get('view')) {
            case 'create-by-channel':
                # 新建术语时。根据术语所在channel 给出新建术语所需数据。如语言，备选意思等。
                #获取channel信息
                $currChannel = Channel::where('uid',$request->get('channel'))->first();
                if(!$currChannel){
                    return $this->error(__('auth.failed'));
                }
                #TODO 查询studio信息
                #获取同studio的channel列表
                $studioChannels = Channel::where('owner_uid',$currChannel->owner_uid)
                                        ->select(['name','uid'])
                                        ->get();
                #获取全网意思列表
                $meanings = DhammaTerm::where('word',$request->get('word'))
                                        ->where('language',$currChannel->lang)
                                        ->select(['meaning','other_meaning'])
                                        ->get();
                $meaningList=[];
                foreach ($meanings as $key => $value) {
                    # code...
                    $meaning1 = [$value->meaning];

                    if(!empty($value->other_meaning)){
                        $meaning2 = \explode(',',$value->other_meaning);
                        $meaning1 = array_merge($meaning1,$meaning2);
                    }
                    foreach ($meaning1 as $key => $value) {
                        # code...
                        if(isset($meaningList[$value])){
                            $meaningList[$value]++;
                        }else{
                            $meaningList[$value] = 1;
                        }
                    }
                }
                $meaningCount = [];
                foreach ($meaningList as $key => $value) {
                    # code...
                    $meaningCount[] = ['meaning'=>$key,'count'=>$value];
                }
                return $this->ok([
                    "word"=>$request->get('word'),
                    "meaningCount"=>$meaningCount,
                    "studioChannels"=>$studioChannels,
                    "language"=>$currChannel->lang,
                    'studio'=>StudioApi::getById($currChannel->owner_uid),
                ]);
                break;
            case 'studio':
				# 获取 studio 内所有 term
                $user = AuthApi::current($request);
                if(!$user){
                    return $this->error(__('auth.failed'),[],401);
                }
                //判断当前用户是否有指定的studio的权限
                if($user['user_uid'] !== StudioApi::getIdByName($request->get('name'))){
                    return $this->error(__('auth.failed'),[],403);
                }
                $table = DhammaTerm::select($indexCol)
                                   ->where('owner', $user["user_uid"]);
				break;
            case 'channel':
                # 获取 studio 内所有 term
                $user = AuthApi::current($request);
                if(!$user){
                    return $this->error(__('auth.failed'));
                }
                //判断当前用户是否有指定的 channel 的权限
                $channel = Channel::find($request->get('id'));
                if($user['user_uid'] !== $channel->owner_uid ){
                    //看是否为协作
                    $power = ShareApi::getResPower($user['user_uid'],$request->get('id'));
                    if($power === 0){
                        return $this->error(__('auth.failed'),[],403);
                    }
                }
                $table = DhammaTerm::select($indexCol)
                                    ->where('channal', $request->get('id'));
                break;
            case 'show':
                return $this->ok(DhammaTerm::find($request->get('id')));
                break;
			case 'user':
				# code...
                $user = AuthApi::current($request);
                if(!$user){
                    return $this->error(__('auth.failed'));
                }
                $userUid = $user['user_uid'];
                $search = $request->get('search');
				$table = DhammaTerm::select($indexCol)
									->where('owner', $userUid);
				break;
			case 'word':
				$table = DhammaTerm::select($indexCol)
									->where('word', $request->get("word"));
				break;
            case 'hot-meaning':
                $key='term/hot_meaning';
                $value = RedisClusters::get($key, function()use($request) {
                    $hotMeaning=[];
                    $words = DhammaTerm::select('word')
                                ->where('language',$request->get("language"))
                                ->groupby('word')
                                ->get();

                    foreach ($words as $key => $word) {
                        # code...
                        $result = DhammaTerm::select(DB::raw('count(*) as word_count, meaning'))
                                ->where('language',$request->get("language"))
                                ->where('word',$word['word'])
                                ->groupby('meaning')
                                ->orderby('word_count','desc')
                                ->first();
                        if($result){
                            $hotMeaning[]=[
                                'word'=>$word['word'],
                                'meaning'=>$result['meaning'],
                                'language'=>$request->get("language"),
                                'owner'=>'',
                            ];
                        }
                    }
                    RedisClusters::put($key, $hotMeaning, 3600);
                    return $hotMeaning;
                }, config('cache.expire',3600*24));
                return $this->ok(["rows"=>$value,"count"=>count($value)]);
                break;
			default:
				# code...
				break;
		}

        $search = $request->get('search');
        if(!empty($search)){
            $table = $table->where(function($query) use($search){
                $query->where('word', 'like', $search."%")
                  ->orWhere('word_en', 'like', $search."%")
                  ->orWhere('meaning', 'like', "%".$search."%");
            });
        }
        $count = $table->count();
        $table = $table->orderBy($request->get('order','updated_at'),$request->get('dir','desc'));
        $table = $table->skip($request->get("offset",0))
                       ->take($request->get('limit',1000));
        $result = $table->get();

        return $this->ok(["rows"=>TermResource::collection($result),"count"=>$count]);
    }

    /**
     * Store a newly created resource in storage.
     *
     * @param  \Illuminate\Http\Request  $request
     * @return \Illuminate\Http\Response
     */
    public function store(Request $request)
    {
        $user = AuthApi::current($request);
        if(!$user){
            return $this->error(__('auth.failed'));
        }
        $validated = $request->validate([
            'word' => 'required',
            'meaning' => 'required',
        ]);


        /**
         * 查询重复的
         * 一个channel下面word+tag+language 唯一
         */
        $table = DhammaTerm::where('owner', $user["user_uid"])
                ->where('word',$request->get("word"))
                ->where('tag',$request->get("tag"));
        if(!empty($request->get("channel"))){
            $isDoesntExist = $table->where('channal',$request->get("channel"))
                    ->doesntExist();
        }else{
            $isDoesntExist = $table->whereNull('channal')->where('language',$request->get("language"))
                ->doesntExist();
        }

        if($isDoesntExist){
            #没有重复的 插入数据
            $term = new DhammaTerm;
            $term->id = app('snowflake')->id();
            $term->guid = Str::uuid();
            $term->word = $request->get("word");
            $term->word_en = Tools::getWordEn($request->get("word"));
            $term->meaning = $request->get("meaning");
            $term->other_meaning = $request->get("other_meaning");
            $term->note = $request->get("note");
            $term->tag = $request->get("tag");
            $term->channal = $request->get("channel");
            $term->language = $request->get("language");
            if(!empty($request->get("channel"))){
                $channelInfo = ChannelApi::getById($request->get("channel"));
                if(!$channelInfo){
                    return $this->error("channel id failed");
                }else{
                    //查看有没有channel权限
                    $power = ShareApi::getResPower($user["user_uid"],$request->get("channel"),2);
                    if($power < 20){
                        return $this->error(__('auth.failed'));
                    }
                    $term->owner = $channelInfo['studio_id'];
                    $term->language = $channelInfo['lang'];
                }
            }else{
                if($request->has("studioId")){
                    $studioId = $request->get("studioId");
                }else if($request->has("studioName")){
                    $studioId = StudioApi::getIdByName($request->get("studioName"));
                }
                if(Str::isUuid($studioId)){
                    $term->owner = $studioId;
                }else{
                    return $this->error('not valid studioId');
                }
            }
            $term->editor_id = $user["user_id"];
            $term->create_time = time()*1000;
            $term->modify_time = time()*1000;
            $term->save();
            //删除cache
            $this->deleteCache($term);
            return $this->ok(new TermResource($term));
        }else{
            return $this->error("word existed",[],200);
        }
    }

    private function deleteCache($term){
        if(empty($term->channal)){
            //通用 查询studio所有channel
            $channels = Channel::where('owner_uid',$term->owner)->select('uid')->get();
            foreach ($channels as $channel) {
                RedisClusters::forget("/term/{$channel}/{$term->word}");
            }
        }else{
            RedisClusters::forget("/term/{$term->channal}/{$term->word}");
        }
    }

    /**
     * Display the specified resource.
     *
     * @param  string  $id
     * @return \Illuminate\Http\Response
     */
    public function show(Request  $request,$id)
    {
        //
		$result  = DhammaTerm::where('guid', $id)->first();
		if($result){
			return $this->ok(new TermResource($result));
		}else{
			return $this->error("没有查询到数据");
		}

    }

    /**
     * Update the specified resource in storage.
     *
     * @param  \Illuminate\Http\Request  $request
     * @param  \App\Models\DhammaTerm  $dhammaTerm
     * @return \Illuminate\Http\Response
     */
    public function update(Request $request, string $id)
    {
        //
        $user = AuthApi::current($request);
        if(!$user){
            return $this->error(__('auth.failed'),[],401);
        }
        $dhammaTerm = DhammaTerm::find($id);
        if(!$dhammaTerm){
            return $this->error('404');
        }

        if(empty($dhammaTerm->channal)){
            //查看有没有studio权限
            if($user['user_uid'] !== $dhammaTerm->owner){
                return $this->error(__('auth.failed'),[],403);
            }
        }else{
            //查看有没有channel权限
            $power = ShareApi::getResPower($user["user_uid"],$dhammaTerm->channal,2);
            if($power < 20){
                return $this->error(__('auth.failed'),[],403);
            }
        }

        $dhammaTerm->word = $request->get("word");
        $dhammaTerm->word_en = Tools::getWordEn($request->get("word"));
        $dhammaTerm->meaning = $request->get("meaning");
        $dhammaTerm->other_meaning = $request->get("other_meaning");
        $dhammaTerm->note = $request->get("note");
        $dhammaTerm->tag = $request->get("tag");
        $dhammaTerm->language = $request->get("language");
        $dhammaTerm->editor_id = $user["user_id"];
        $dhammaTerm->create_time = time()*1000;
        $dhammaTerm->modify_time = time()*1000;
        $dhammaTerm->save();
        //删除cache
        $this->deleteCache($dhammaTerm);
		return $this->ok(new TermResource($dhammaTerm));

    }

    /**
     * Remove the specified resource from storage.
     *
     * @param  \App\Models\DhammaTerm  $dhammaTerm
     * @return \Illuminate\Http\Response
     */
    public function destroy(DhammaTerm $dhammaTerm,Request $request)
    {
        /**
         * 一次删除多个单词
         */
        $user = AuthApi::current($request);
        if(!$user){
            return $this->error(__('auth.failed'));
        }
        $count = 0;
        if($request->has("uuid")){
            //查看是否有删除权限
            foreach ($request->get("id") as $key => $uuid) {
                $term = DhammaTerm::find($uuid);
                if($term->owner !== $user['user_uid']){
                    if(!empty($term->channal)){
                        //看是否为协作
                        $power = ShareApi::getResPower($user['user_uid'],$term->channal);
                        if($power < 20){
                            continue;
                        }
                    }else{
                        continue;
                    }
                }
                $count += $term->delete();
                //删除cache
                $this->deleteCache($term);
            }
        }else{
            $arrId = json_decode($request->get("id"),true) ;
            foreach ($arrId as $key => $id) {
                # code...
                $term = DhammaTerm::where('id', $id)
                                ->where('owner', $user['user_uid']);
                $term->delete();
                $this->deleteCache($term);
                if($result){
                    $count++;
                }
            }
        }

		return $this->ok($count);
    }

    public function export(Request $request){
        $user = AuthApi::current($request);
        if(!$user){
            return $this->error(__('auth.failed'));
        }
//TODO 判断是否有导出权限
        switch ($request->get("view")) {
            case 'channel':
                # code...
                $rows = DhammaTerm::where('channal',$request->get("id"))->cursor();
                break;
            case 'studio':
                # code...
                $studioId = StudioApi::getIdByName($request->get("name"));
                $rows = DhammaTerm::where('owner',$studioId)->cursor();
                break;
            default:
                $this->error('no view');
                break;
        }

        $spreadsheet = new Spreadsheet();
        $activeWorksheet = $spreadsheet->getActiveSheet();
        $activeWorksheet->setCellValue('A1', 'id');
        $activeWorksheet->setCellValue('B1', 'word');
        $activeWorksheet->setCellValue('C1', 'meaning');
        $activeWorksheet->setCellValue('D1', 'other_meaning');
        $activeWorksheet->setCellValue('E1', 'note');
        $activeWorksheet->setCellValue('F1', 'tag');
        $activeWorksheet->setCellValue('G1', 'language');
        $activeWorksheet->setCellValue('H1', 'channel_id');

        $currLine = 2;
        foreach ($rows as $key => $row) {
            # code...
            $activeWorksheet->setCellValue("A{$currLine}", $row->guid);
            $activeWorksheet->setCellValue("B{$currLine}", $row->word);
            $activeWorksheet->setCellValue("C{$currLine}", $row->meaning);
            $activeWorksheet->setCellValue("D{$currLine}", $row->other_meaning);
            $activeWorksheet->setCellValue("E{$currLine}", $row->note);
            $activeWorksheet->setCellValue("F{$currLine}", $row->tag);
            $activeWorksheet->setCellValue("G{$currLine}", $row->language);
            $activeWorksheet->setCellValue("H{$currLine}", $row->channal);
            $currLine++;
        }
        $writer = new Xlsx($spreadsheet);
        $fId = Str::uuid();
        $filename = storage_path("app/tmp/{$fId}");
        $writer->save($filename);
        RedisClusters::put("download/tmp/{$fId}",file_get_contents($filename),300);
        unlink($filename);
        return $this->ok(['uuid'=>$fId,'filename'=>"term.xlsx",'type'=>"application/vnd.ms-excel"]);
    }

    public function import(Request $request){
        $user = AuthApi::current($request);
        if(!$user){
            return $this->error(__('auth.failed'));
        }
        /**
         * 判断是否有权限
         */
        switch ($request->get('view')) {
            case 'channel':
                # 向channel里面导入，忽略源数据的channel id 和 owner 都设置为这个channel 的
                $channel = ChannelApi::getById($request->get('id'));
                $owner_id = $channel['studio_id'];
                if($owner_id !== $user["user_uid"]){
                    //判断是否为协作
                    $power = ShareApi::getResPower($user["user_uid"],$request->get('id'));
                    if($power<20){
                        return $this->error(__('auth.failed'),[],403);
                    }
                }
                $language = $channel['lang'];
                break;
            case 'studio':
                # 向 studio 里面导入，忽略源数据的 owner 但是要检测 channel id 是否有权限
                $owner_id = StudioApi::getIdByName($request->get('name'));
                if(!$owner_id){
                    return $this->error('no studio name',[],403);
                }

                break;
        }

        $message = "";
        $filename = $request->get('filename');
        $reader = new \PhpOffice\PhpSpreadsheet\Reader\Xlsx();
        $reader->setReadDataOnly(true);
        $spreadsheet = $reader->load($filename);
        $activeWorksheet = $spreadsheet->getActiveSheet();
        $currLine = 2;
        $countFail = 0;

        do {
            # code...
            $id = $activeWorksheet->getCell("A{$currLine}")->getValue();
            $word = $activeWorksheet->getCell("B{$currLine}")->getValue();
            $meaning = $activeWorksheet->getCell("C{$currLine}")->getValue();
            $other_meaning = $activeWorksheet->getCell("D{$currLine}")->getValue();
            $note = $activeWorksheet->getCell("E{$currLine}")->getValue();
            $tag = $activeWorksheet->getCell("F{$currLine}")->getValue();
            $language = $activeWorksheet->getCell("G{$currLine}")->getValue();
            $channel_id = $activeWorksheet->getCell("H{$currLine}")->getValue();
            $query = ['word'=>$word,'tag'=>$tag];
            $channelId = null;
            switch ($request->get('view')) {
                case 'channel':
                    # 向channel里面导入，忽略源数据的channel id 和 owner 都设置为这个channel 的
                    $query['channal'] = $request->get('id');
                    $channelId = $request->get('id');
                    break;
                case 'studio':
                    # 向 studio 里面导入，忽略源数据的owner 但是要检测 channel id 是否有权限
                    $query['owner'] = $owner_id;
                    if(!empty($channel_id)){

                        //有channel 数据，查看是否在studio中
                        $channel = ChannelApi::getById($channel_id);
                        if($channel === false){
                            $message .= "没有查到版本信息：{$channel_id} - {$word}\n";
                            $currLine++;
                            $countFail++;
                            continue 2;
                        }
                        if($owner_id != $channel['studio_id']){
                            $message .= "版本不在studio中：{$channel_id} - {$word}\n";
                            $currLine++;
                            $countFail++;
                            continue 2;
                        }
                        $query['channal'] = $channel_id;
                        $channelId = $channel_id;
                    }
                    # code...
                    break;
            }

            if(empty($id) && empty($word)){
                break;
            }

            //查询此id是否有旧数据
            if(!empty($id)){
                $oldRow = DhammaTerm::find($id);
                //TODO 有 id 无 word 删除数据
                if(empty($word)){
                    //查看权限
                    if($oldRow->owner !== $user['user_uid']){
                        if(!empty($oldRow->channal)){
                            //看是否为协作
                            $power = ShareApi::getResPower($user['user_uid'],$oldRow->channal);
                            if($power < 20){
                                $message .= "无删除权限：{$id} - {$word}\n";
                                $currLine++;
                                $countFail++;
                                continue;
                            }
                        }else{
                            $message .= "无删除权限：{$id} - {$word}\n";
                            $currLine++;
                            $countFail++;
                            continue;
                        }
                    }
                    //删除
                    $oldRow->delete();
                    $currLine++;
                    continue;
                }
            }else{
                $oldRow = null;
            }
            //查询是否跟已有数据重复
            $row = DhammaTerm::where($query)->first();
            if(!$row){
                //不重复
                if(isset($oldRow) && $oldRow){
                    //找到旧的记录-修改旧数据
                    $row = $oldRow;
                }else{
                    //没找到旧的记录-新建
                    $row = new DhammaTerm();
                    $row->id = app('snowflake')->id();
                    $row->guid = Str::uuid();
                    $row->word = $word;
                    $row->create_time = time()*1000;
                }
            }else{
                //重复-如果与旧的id不同,报错
                if(isset($oldRow) && $oldRow && $row->guid !== $id){
                    $message .= "重复的数据：{$id} - {$word}\n";
                    $currLine++;
                    $countFail++;
                    continue;
                }
            }
            $row->word = $word;
            $row->word_en = Tools::getWordEn($word);
            $row->meaning = $meaning;
            $row->other_meaning = $other_meaning;
            $row->note = $note;
            $row->tag = $tag;
            $row->language = $language;
            $row->channal = $channelId;
            $row->editor_id = $user['user_id'];
            $row->owner = $owner_id;
            $row->modify_time = time()*1000;
            $row->save();

            $currLine++;
        } while (true);
        return $this->ok(["success"=>$currLine-2-$countFail,'fail'=>($countFail)],$message);
    }
}