<?php
/**
+-----------------------------------------------------------------------------------------------
* GouGuOPEN [ 左手研发，右手开源，未来可期！]
+-----------------------------------------------------------------------------------------------
* @Copyright (c) 2021~2024 http://www.gouguoa.com All rights reserved.
+-----------------------------------------------------------------------------------------------
* @Licensed 勾股OA，开源且可免费使用，但并不是自由软件，未经授权许可不能去除勾股OA的相关版权信息
+-----------------------------------------------------------------------------------------------
* @Author 勾股工作室 <hdm58@qq.com>
+-----------------------------------------------------------------------------------------------
*/

declare (strict_types = 1);

namespace app\oa\controller;

use app\base\BaseController;
use app\oa\model\Work as WorkModel;
use app\oa\model\WorkRecord;
use think\facade\Db;
use think\facade\View;

class Work extends BaseController
{
	/**
     * 构造函数
     */
	protected $model;
    public function __construct()
    {
		parent::__construct(); // 调用父类构造函数
        $this->model = new WorkModel();
    }
    //获取接收汇报列表
    public function get_accept($map = [], $param = [])
    {
        $rows = empty($param['limit']) ? get_config('app.page_size') : $param['limit'];
		$Work = WorkRecord::alias('a')
			->field('a.id,a.from_uid,a.to_uid,a.send_time,a.read_time,w.id as wid,w.types,w.works,w.file_ids,w.start_date,w.end_date')
			->join('Work w','a.work_id = w.id','left')
			->where($map)
			->order('a.send_time desc')
			->paginate(['list_rows'=> $rows])
			->each(function ($item, $key) {
				$item->send_time = empty($item->send_time) ? '-' : date('Y-m-d H:i:s', $item->send_time);
				$item->from_name = Db::name('Admin')->where(['id' => $item->from_uid])->value('name');
				$item->to_name = Db::name('Admin')->where(['id' => $item->to_uid])->value('name');
				if($item->start_date>0){
					$item->start_date = date('Y-m-d',$item->start_date);
				}
				if($item->end_date>0){
					$item->end_date = date('Y-m-d',$item->end_date);
				}
				$item->files = Db::name('File')->where('id', 'in', $item->file_ids)->count();
			});
		return $Work;
    }
	
    //汇报列表
    public function datalist()
    {
        if (request()->isAjax()) {
            $param = get_params();
            $map = [];
			if($param['send']==1){
				if (!empty($param['types'])) {
					$map[] = ['types', '=', $param['types']];
				}
				//按时间检索
				if (!empty($param['diff_time'])) {
					$diff_time =explode('~', $param['diff_time']);
					$map[] = ['start_date', 'between', [strtotime(urldecode($diff_time[0])),strtotime(urldecode($diff_time[1]))]];
				}
				$map[] = ['admin_id', '=', $this->uid];         
				$map[] = ['delete_time', '=', 0];
				$list =  $this->model->get_send($param,$map);
			}
			else{
				if (!empty($param['read'])) {
					if($param['read']==1){
						$map[] = ['a.read_time', '=', 0];
					}else{
						$map[] = ['a.read_time', '>', 0];
					}                
				}
				if (!empty($param['types'])) {
					$map[] = ['w.types', '=', $param['types']];
				}
				$map[] = ['a.to_uid', '=', $this->uid];
				$map[] = ['a.delete_time', '=', 0];
				//按时间检索
				if (!empty($param['diff_time'])) {
					$diff_time =explode('~', $param['diff_time']);
					$map[] = ['a.send_time', 'between', [strtotime(urldecode($diff_time[0])),strtotime(urldecode($diff_time[1]))]];
				}
				$list = $this->get_accept($map, $param);
			}            
            return table_assign(0, '', $list);
        } else {
			$send = empty(get_params('send')) ? 1 : get_params('send');
			return view('datalist_'.$send);
        }
    }

    //新增&编辑
    public function add()
    {
		if (request()->isAjax()) {
			$param = get_params();
			$id = $param['id'] ? $param['id'] : 0;
			if(!empty($param['start_date'])){
				$param['start_date'] = strtotime($param['start_date']);
			}
			if(!empty($param['end_date'])){
				$param['end_date'] = strtotime($param['end_date']);
			}
			if(!empty($param['range_date'])){
				$range_date =explode('~', $param['range_date']);
				$param['start_date'] = strtotime(urldecode($range_date[0]));
				$param['end_date'] = strtotime(urldecode($range_date[1]));
			}
			if($id>0){
				$param['update_time'] = time();
				$res = Db::name('Work')->strict(false)->field(true)->update($param);			
				if ($res !== false) {
					add_log('edit',$id,$param);
					if($param['send']==1){
						$users = explode(',',$param['to_uids']);
						//组合要发的消息
						$send_data = [];
						foreach ($users as $key => $value) {
							if (!$value || ($value == $this->uid)) {
								continue;
							}
							$send_data[] = array(
								'work_id' => $id,//关联id
								'to_uid' => $value,//接收人
								'from_uid' => $this->uid,//发送人
								'send_time' => time()
							);
						}
						Db::name('WorkRecord')->strict(false)->field(true)->insertAll($send_data);
						Db::name('Work')->strict(false)->field('send_time')->update(['id' => $id,'send_time' => time()]);
						add_log('send',$id);
						$msg=[
							'from_uid'=>$this->uid,//发送人
							'to_uids'=>$param['to_uids'],//接收人
							'template_id'=>'work',//消息模板标识
							'content'=>[ //消息内容
								'send_time'=>date('Y-m-d H:i:s'),
								'action_id'=>$id
							]
						];
						event('SendMessage',$msg);
						return to_assign(0, '发送成功');
					}
					return to_assign();				
				}
				else{
					return to_assign(1,'操作失败');	
				}
			}
			else{
				$param['admin_id'] = $this->uid;
				$param['create_time'] = time();
				$wid = Db::name('Work')->strict(false)->field(true)->insertGetId($param);
				if ($wid !== false) {
					add_log('add',$wid,$param);
					if($param['send']==1){
						$users = explode(',',$param['to_uids']);
						//组合要发的内容
						$send_data = [];
						foreach ($users as $key => $value) {
							if (!$value || ($value == $this->uid)) {
								continue;
							}
							$send_data[] = array(
								'work_id' => $wid,//关联id
								'to_uid' => $value,//接收人
								'from_uid' => $this->uid,//发送人
								'send_time' => time()
							);
						}
						Db::name('WorkRecord')->strict(false)->field(true)->insertAll($send_data);
						Db::name('Work')->strict(false)->field('send_time')->update(['id' => $wid,'send_time' => time()]);
						add_log('send',$wid);
						$msg=[
							'from_uid'=>$this->uid,//发送人
							'to_uids'=>$param['to_uids'],//接收人
							'template_id'=>'work',//消息模板ID
							'content'=>[ //消息内容
								'create_time'=>date('Y-m-d H:i:s'),
								'action_id'=>$wid
							]
						];
						event('SendMessage',$msg);
						return to_assign(0, '发送成功');
					}					
					return to_assign();
				}
				else{
					return to_assign(1,'操作失败');	
				}
			}
		}
		else{
			$id = empty(get_params('id')) ? 0 : get_params('id');
			$types = empty(get_params('types')) ? 1 : get_params('types');
			if ($id > 0) {
				$detail = $this->model->detail($id);
				$types = $detail['types'];
				View::assign('detail', $detail);
			}
			View::assign('id', $id);
			View::assign('types', $types);
			return view('add_'.$types);
		}
    }

    //查看
    public function view()
    {
        $param = get_params();
        $id = $param['id'];
		$detail = $this->model->detail($id);
		//已读人查询
		$read_user_names = [];
		if($detail['admin_id'] !=$this->uid){
			$record = Db::name('WorkRecord')->where(['work_id' => $detail['id'],'to_uid' => $this->uid])->count();
			if ($record == 0) {
				echo '<div style="text-align:center;color:red;margin-top:20%;">该汇报不存在</div>';exit;
			}
			else{
				Db::name('WorkRecord')->where(['work_id' => $detail['id'],'to_uid' => $this->uid])->update(['read_time' => time()]);
			}
		}
		else{
			$read_user_ids= Db::name('WorkRecord')->where([['work_id','=',$detail['id']],['read_time','>',0]])->column('to_uid');
			$read_user_names = Db::name('Admin')->where('id', 'in', $read_user_ids)->column('name');
		}
		$sender = get_admin($detail['admin_id']);
		$detail['person_name'] = $sender['name'];
		if($detail['send_time']>0){
			$detail['send_time'] = date('Y-m-d H:i:s',$detail['send_time']);
		}
        //接收人查询
		$user_names = Db::name('Admin')->where('status', 1)->where('id', 'in', $detail['to_uids'])->column('name');		
        $detail['users'] = implode(",", $user_names);
		$detail['read_users'] = implode(",", $read_user_names);
		$detail['comment_auth'] = 0;
		$type_user_array = explode(",", $detail['to_uids']);
		if (in_array($this->uid, $type_user_array)) {
			$detail['comment_auth'] = 1;
		}
        View::assign('detail', $detail);
		if(is_mobile()){
			return view('qiye@/index/work_view');
		}
        return view();
    }
	
	
    //删除汇报
    public function del()
    {	
        $param = get_params();
        $id = $param['id'];
		$detail = Db::name('Work')->where(['id' => $id])->find();
		if($detail['admin_id'] == $this->uid){
			$res = Db::name('Work')->where('id',$detail['id'])->update(['delete_time' => time()]);
			if($res!==false){
				Db::name('WorkRecord')->where('work_id',$detail['id'])->update(['delete_time' => time()]);
				add_log('delete', $param['id']);
				return to_assign();
			}
			else{
				return to_assign(1, '操作失败');
			}
		}
		else{
			return to_assign(1, '无权限删除');
		}
	}
}