<?php

namespace App\Http\Logic\Aside\Task;


use App\Helper\Arr;
use App\Http\Logic\Aside\BaseLogic;
use App\Http\Logic\Aside\LoginLogic;
use App\Http\Logic\Aside\Manage\ManageLogic;
use App\Models\File\File;
use App\Models\Task\Task;
use App\Models\Task\TaskOwner;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Str;

/**
 * Class TaskLogic
 * @package App\Http\Logic\Aside\Task
 * @author zbj
 * @date 2023/4/27
 */
class TaskLogic extends BaseLogic
{
    public function __construct()
    {
        parent::__construct();
        $this->param = $this->requestAll;
        $this->model = new Task();
    }

    /**
     * @remark :获取数据详情
     * @name   :getTaskInfo
     * @author :lyh
     * @method :post
     * @time   :2023/8/23 16:42
     */
    public function getTaskInfo()
    {
        $info = $this->model->where(['id'=>$this->param['id']])->with('owner')->with('follow')->first();
        if($info === false){
            $this->fail('error');
        }
        $info = $this->getFileUrl($info);
        return $this->success($info);
    }

    /**
     * @remark :处理文件
     * @name   :getFileUrl
     * @author :lyh
     * @method :post
     * @time   :2023/8/23 16:15
     */
    public function getFileUrl(&$v){
        $fileModel = new File();
        $file_info = $fileModel->read(['hash'=>$v['attachment']]);
        if($file_info !== false){
            $v['attachment_name'] = basename($file_info['path']);
            if($file_info['is_cos'] == 1){
                $cos = config('filesystems.disks.cos');
                $cosCdn = $cos['cdn'];
                $v['attachment'] = $cosCdn.$file_info['path'];
            }else{
                $v['attachment'] = url('a/download_files?hash='.$v['attachment']);
            }
        }
        return $v;
    }
    public function save($param){

        DB::beginTransaction();
        try {
            $res = parent::save($param);
            $data['task_id'] = $res['id'];
            //支持分配多人
            $owner = Arr::splitFilterToArray($param['owner']);
            foreach ($owner as $manage_id){
                $data['manage_ids'][] = $manage_id;
                (new TaskOwnerLogic)->save($data);
            }
            DB::commit();
        }catch (\Exception $e){
            DB::rollBack();
            errorLog('工单保存失败', $param, $e);
            $this->fail('保存失败');
        }
        return $this->success();
    }

    /**
     * 修改状态
     * @param $param
     * @return array
     * @throws \App\Exceptions\AsideGlobalException
     * @throws \App\Exceptions\BsideGlobalException
     * @author zbj
     * @date 2023/4/27
     */
    public function status($id, $status){
        $task = $this->model->read(['id'=>$id]);
        if(!$task){
            $this->fail('任务不存在');
        }
        $manage_ids = Arr::pluck($task['owner'], 'manage_id', 'id');
        if(!in_array(LoginLogic::manage('id'), $manage_ids)){
            $this->fail('非本人任务，不能更新进程');
        }
        $task_data = [
            'id' => $id,
            'status' => $status,
        ];

        //个人任务
        $task_owner_id = array_search(LoginLogic::manage('id'), $manage_ids);
        (new TaskOwnerLogic())->status($task_owner_id, $status);

        //一个人开始，任务开始，所有人完成，任务才完成
        $owner_status = TaskOwner::where('task_id', $id)->pluck('status')->toArray();
        //所有都完成
        if(array_sum($owner_status) == count($owner_status) * TaskOwner::STATUS_DOWN){
            $task_data['status'] = Task::STATUS_DOWN;
            $task_data['done_at'] = date('Y-m-d H:i:s');
        }else{
            $task_data['status'] = Task::STATUS_DONGING;
            $task_data['doing_at'] = date('Y-m-d H:i:s');
        }

        parent::save($task_data);
        return $this->success();
    }

    public function clearCache($id)
    {
        parent::clearCache($id);

        parent::setWith(['owner', 'follow']);
        parent::clearCache($id);
    }
}