<?php

namespace Controller;

use Lib\Mail\Mail;
use Lib\Mail\MailFun;
use Lib\UploadFile;
use Lib\Verify;
use Model\bodySql;
use Model\emailSql;
use Model\folderSql;
use Model\listsSql;
use Model\sendJobsSql;
use PHPMailer\PHPMailer\PHPMailer;
use PHPMailer\PHPMailer\SMTP;
use function Swoole\Coroutine\Http\request;


/**
 * @author：dc
 * @time 2023/2/13 11:28
 * Class Home
 * @package Controller
 */
class Home extends Base {


    /**
     * 邮件列表
     * @author：dc
     * @time 2023/2/17 14:12
     */
    public function lists(){

        // 分页 页数
        $page   =   app()->request('page',1,'intval');
        $page   =   $page ? $page : 1;

        $limit   =   app()->request('limit',20,'intval');
        $limit   =   $limit ? $limit : 1;

        // 指定id
        $ids = app()->request('mail_id');
        $ids = is_array($ids) ? $ids : [$ids];
        foreach ($ids as $i=>$d){
            if(!is_numeric($d)){
                unset($ids[$i]);
            }
        }

        // 附件
        $attachment =   app()->request('attachment',0,'bool_Val');
        // 已读/未读
        $seen =   app()->request('seen',-1,'intval');
        // 软删
        $deleted =   app()->request('deleted',0,'intval');


        $where = ['email_id'=>$this->getEmails('id')];

        // 目录
        $folder = app()->request('folder','收件箱');
        $folderList = db()->all(folderSql::all($where['email_id']));
        $folder_id = [];
        // 文件夹id
        if($folderList){
            foreach ($folderList as $item){
                if(
                    // 数组文件夹
                    (is_array($folder) && in_array($item['folder'],$folder))
                    || $item['folder'] == $folder
                ){
                    $folder_id[] = $item['id'];
                }
            }
        }
        if(!$folder_id){
            app()->e('folder_not_fount');
        }

        //目录
        $where['folder_id'] = $folder_id;
        if($ids) $where['id'] = $ids;

        if(paramHas('attachment')){
            $where['is_file'] = $attachment ? 1 : 0; //附件
        }


        // 软删
        $where['deleted'] = $deleted;
        // 已读/未读
        if(paramHas('seen')){
            if(in_array($seen,[0,1])){
                $where['seen'] = $seen;
            }
        }

        $where['_'] = [];
        // 搜索关键字
        $keyword = app()->request('keyword','',['htmlspecialchars','addslashes']);
        if($keyword){
            $where['_'][] = '`subject` like "%'.$keyword.'%"';
        }

        // 那个发的
        $address = app()->request('address');
        if($address){
            if(is_array($address)){
                // 发贱人
                if(Verify::sEmail($address['from']??'')){
                    $where['from'] = $address['from'];
                }
                // 收件人
                if(Verify::sEmail($address['to']??'')){
                    $where['_'][] = '`to_name` like "%'.$address.'%"';
                }

            }else if(Verify::sEmail($address)){
                // 收件人/发件人
                $where['_'][] = '(`from` = "'.$address.'" or `to_name` like "%'.$address.'%")';
            }
        }
        // from
        if(app()->requestHas('from')){
            $where['from'] = app()->request('from');
            if(!$where['from']){
                // 不让查询数据
                $where['id'] = 0;
            }
        }


        // 回复
        if (paramHas('answered')){
            $where['answered'] = app()->request('answered',0,'bool_Val')?1:0;
        }

        $fromto = app()->request('formorto');
        if($fromto=='from'){
            $where['from'] = $this->getEmails('email');
        }elseif ($fromto=='to'){
            $where['from.notin'] = $this->getEmails('email');
        }

        $lists = db()->all(
            listsSql::lists(
                dbWhere($where),
                $page,
                $limit
            )
        );

        // 总数
        $total  = db()->count(
            listsSql::listCount(dbWhere($where))
        );

        app()->_json(listsPage($lists,$total,$page,$limit));

    }


    /**
     * 检测邮箱状态
     * @author：dc
     * @time 2023/3/28 16:19
     */
    public function check(){

        $lists = db()->all(emailSql::getValues(['email'=>web_request_emails()],'`id`,`pwd_error`,`email`'));

        return array_column($lists,'pwd_error','email');

    }


    /**
     * 发送邮件
     * @author：dc
     * @time 2023/2/18 17:32
     */
    public function send_mail(){

        $email = $this->getEmail();

        $yzemail = function(&$value,$field){
            if($value){
                if(!is_array($value)){
                    if(@json_decode($value,true)){
                        $value =    json_decode($value,true);
                    }else{
                        $value = [['email'=>$value,'name'=>'']];
                    }
                }
                foreach ($value as $item){
                    if(!Verify::sEmail($item['email'])){
                        app()->e([$field.'_verify_error',$item['email']]);
                    }
                }
            }
        };

        $formData = Verify::checks([
            'nickname|'.__('nickname')  =>  ['max'=>50],
            'subject|'.__('subject')  =>  ['required','max'=>150],
            'body|'.__('body_email')  =>  ['required'],
            'tos|'.__('to_email')  =>  ['required',$yzemail],
            'cc|'.__('to_cc')  =>  [$yzemail],
            'bcc|'.__('to_bcc')  =>  [$yzemail],
            'priority|'.__('priority_email')  =>  ['in'=>[1,3,5]],
            'attachment|'.__('files_email')  =>  [
                'file'=>[
                    'ext'   =>  [],
                    'size'  =>  1024*1024*5,
                    'mine'  =>  []
                ]
            ],
            'receipt|'.__('receipt_email')  =>  []
        ],[

        ]);


        $sendData = [];
        $sendData['email']   =   $email['email'];
        $sendData['nickname']   =   $formData['nickname']??'';
        $sendData['tos']   =   $formData['tos'];
        if(count($sendData['tos'])>100){
            app()->e(['tos_number_error',100]);
        }
//        抄送
        $sendData['cc'] = [];
        if(($formData['isCc']??0) && !empty($formData['cc'])){
            $sendData['cc'] =   $formData['cc'];
        }
        if(count($sendData['cc'])>10){
            app()->e(['cc_number_error',10]);
        }
        // 密送
        $sendData['bcc'] = [];
        if(($formData['isBcc']??0) && !empty($formData['bcc'])){
            $sendData['bcc'] =   $formData['bcc'];
        }
        if(count($sendData['bcc'])>10){
            app()->e(['bcc_number_error',10]);
        }
        $sendData['reply_to'] = [];//回复到那个邮件
        //Attachments 附件 上传的
        $sendData['attachment'] = [];
        $attachment = app()->file('attachment');
        if($attachment){
            foreach ($attachment as $file){
                if($file->move()){
                    $sendData['attachment'][] = [
                        'name'  =>  $file->name,
                        'filename'  =>  $file->name,
                        'signName'  =>  $file->saveName,
                        'path'  =>  $file->savePath.$file->saveName
                    ];
                }else{
                    app()->e(['attachment_upload_error',$file->name]);
                }
            }
        }
        // 远程路径，云文件
        $attachmentUrl = app()->request('attachmentUrl');
        if(is_array($attachmentUrl)){
            foreach ($attachmentUrl as $file){
                $file = is_array($file) ? $file : json_decode($file,true);
                if(!empty($file['url']) && !empty($file['name'])){
                    $file = new UploadFile($file['name'],$file['url']);
                    if($file->move()){
                        $sendData['attachment'][] = [
                            'name'  =>  $file->name,
                            'filename'  =>  $file->name,
                            'signName'  =>  $file->saveName,
                            'path'  =>  $file->savePath.$file->saveName
                        ];
                    }else{
                        app()->e(['attachment_upload_error',$file->name]);
                    }
                }

            }
        }
        $sendData['receipt'] = empty($formData['receipt']) ? '' : 1;// 回执，阅读后收回执的邮箱
        $sendData['priority'] = $formData['priority']??3;// 是否紧急邮件
        $sendData['subject'] = $formData['subject'];// //Content 主题，标题
        $sendData['body'] = $formData['body'];
        // 不重要的信息
        $sendData['jobName'] = $formData['jobName']??'';//任务标题
        $sendData['massSuit'] = $formData['massSuit']??0;// 是否是群发单显

        // 定时发送时间
        $timer = app()->request('timerValue',0);
        if(is_numeric($timer) && $timer){
            $timer = time()+$timer;
        }else if (is_string($timer)){
            $timer = strtotime($timer);
        }else{
            $timer = 0;
        }
        // 是否存草稿
        if(app()->request('saveType')=='draft'){
            // 保存
            $draftid =  listsSql::saveDraft($sendData,$email,app()->request('draft_id',0,'intval'));
            // 保存失败
           if($draftid){
                app()->_json(['draft_id'=>$draftid]);
           }
           app()->e('save_draft_error');

        }
        // 定时发送 或者是单条发送
        else if((app()->request('timer') &&  $timer > time()) || $sendData['massSuit']){

            if($sendData['massSuit']){
                // 每次发送间隔的时间
                $sendData['masssuit_interval_send']  = app()->request('masssuit_interval_send');
                $sendData['masssuit_interval_send']['start'] = intval($sendData['masssuit_interval_send']['start']??0);
                $sendData['masssuit_interval_send']['end'] = intval($sendData['masssuit_interval_send']['end']??1);
            }

            // 插入任务
            $job_id = db()->insert(sendJobsSql::$table,[
                'email_id'  =>  $email['id'],
                'maildata'  =>  $sendData,
                'title'  =>  $sendData['jobName'] ? : $sendData['subject'],
                'total'  =>  count($sendData['tos']),
                'send_time' =>  $timer
            ]);
            if($job_id){
                // 返回任务id
                app()->_json(['job_id'=>$job_id]);
            }

            app()->e('send_timer_job_error');
        }
        else{
            // 立即发送
            $result = MailFun::sendEmail($sendData,$email);
            if($result[0]){
                app()->_json(['messageId'   => $result[1]]);
            }
            // 错误
            app()->e($result[1]);
        }

    }


    /**
     * 收到前端的同步请求操作
     * @author：dc
     * @time 2023/3/10 10:38
     */
    public function sync(){

        $emails = web_request_emails();

        if(empty($emails)){
            app()->e('sync_request_param_error');
        }else{
            // 查询id
            if(count($emails)===1){
                $emails = $emails[0];
            }
            $datas = db()->all(emailSql::getValues(['email'=>$emails],'`id`,`email`,`pwd_error`'));
            foreach ($datas as $k=>$v){
                if(!$v['pwd_error']){
                    $blacklist = app()->request('blacklist');
                    if(is_array($blacklist)){
                        $blacklist = [
                            'emails' =>   $blacklist['emails']??[],
                            'domain' =>   $blacklist['domain']??[],
                        ];
                        // 黑名单,7天过期时间
                        redis()->set('blacklist:'.$v['id'],$blacklist,86400*7);
                    }

                    redis()->rPush('sync_email_lists', $v['id']);
                }
                $datas[$k]['have_new'] = redis()->getDel('have_new_mail_'.$v['id']);
            }
            // 返回成功的参数值
            app()->_json($datas);
        }

    }


    /**
     * 标记为已读
     * @throws \Lib\Err
     * @author：dc
     * @time 2023/3/17 16:15
     */
    public function seen_2_unseen(){
        $this->setFlags('seen');
    }

    /**
     * 是否已回复
     * @throws \Lib\Err
     * @author：dc
     * @time 2023/4/10 16:30
     */
    public function answered_2_unanswered(){
        $this->setFlags('answered');
    }



    /**
     * 邮件移动
     * @author：dc
     * @time 2023/3/21 11:41
     */
    public function move(){
        $emails = $this->getEmails();

        $mail_ids = app()->request('mail_ids');
        if(!($mail_ids && is_array($mail_ids))){
            app()->e('param_request_error');
        }
        foreach ($mail_ids as $k=>$id){
            if(!is_numeric($id)){
                unset($mail_ids[$k]);
            }
        }
        // 移动到的文件夹
        $to_folder = app()->request('folder');
        if(empty($to_folder)){
            app()->e('folder_move_error');
        }
        if($to_folder == '草稿箱'){
            app()->e('folder_move_to_draft_error');
        }
        if($to_folder == '发件箱'){
            app()->e('folder_move_to_send_error');
        }

        $data  = db()->all(listsSql::first(dbWhere(['id'=>$mail_ids,'email_id'=>array_column($emails,'id')]),'`id`,`uid`,`email_id`,`folder_id`'));
        if($data){
            // 查询邮箱
            $emails = array_column($emails,null,'id');
            $uids = [];
            foreach ($data as $datum){
                // 只有草稿箱才没有uid
                if(!$datum['uid']){
                    // 删除
                    if ($to_folder == '回收站'){
                        // 删除数据,真实删除
                        db()->delete(listsSql::$table,[
                            'id'    =>  $datum['id']
                        ]);
                        continue;
                    }
                }

                if(empty($uids[$datum['email_id']])){
                    $uids[$datum['email_id']][$datum['folder_id']] = [];
                }
                $uids[$datum['email_id']][$datum['folder_id']][] = [
                    'uid'   =>   $datum['uid'],
                    'id'   =>   $datum['id'],
                ];
            }

            foreach ($uids as $eid=>$arr){
                // 查询需要移动的文件夹
                $to_origin_folder = db()->first(folderSql::first(['email_id'=>$eid,'folder'=>$to_folder]));
                if($to_origin_folder){
                    foreach ($arr as $fid=>$uid){
                        // 查询目录
                        $folder = db()->first(folderSql::first($fid));
                        if($folder){
                            // 开始远程
                            $mailInstance = new Mail($emails[$eid]['email'],base64_decode($emails[$eid]['password']),$emails[$eid]['imap']);

                            if($mailInstance->login()){
                                // TODO:: 这个过程无法保证原子性。没办法
                                // 先复制
                                $ret = $mailInstance->move(array_column($uid,'uid'),$folder['origin_folder'],$to_origin_folder['origin_folder']);
                                if($ret){
                                    $uret = db()->update(listsSql::$table,['deleted'=>1],dbWhere(['id'=>array_column($uid,'id')]));
                                }

                                $mailInstance = null;
                            }

                        }
                        $folder = null;
                    }
                }


            }

        }


        app()->_json([
            'mail_id'    =>  $mail_ids
        ]);
    }




    /**
     * 远程标签
     * @param $d
     * @throws \Lib\Err
     * @author：dc
     * @time 2023/3/21 14:28
     */
    private function setFlags($d){
        $emails = $this->getEmails();

        $mail_ids = app()->request('mail_ids');
        if(!($mail_ids && is_array($mail_ids))){
            app()->e('param_request_error');
        }
        foreach ($mail_ids as $k=>$id){
            if(!is_numeric($id)){
                unset($mail_ids[$k]);
            }
        }
        // 已读或未读
        $fv = (int) app()->request($d);
        $fv = $fv ? 1 : 0;

        $data  = db()->all(listsSql::first(dbWhere(['id'=>$mail_ids,'email_id'=>array_column($emails,'id')]),'`id`,`uid`,`email_id`,`folder_id`'));
        if($data){
            // 查询邮箱
            $emails = array_column($emails,null,'id');
            $uids = [];
            foreach ($data as $datum){
                if(empty($uids[$datum['email_id']])){
                    $uids[$datum['email_id']][$datum['folder_id']] = [];
                }
                $uids[$datum['email_id']][$datum['folder_id']][] = [
                    'uid'   =>   $datum['uid'],
                    'id'   =>   $datum['id'],
                ];
            }

            foreach ($uids as $eid=>$arr){
                foreach ($arr as $fid=>$uid){
                    // 查询目录
                    $folder = db()->first(folderSql::first($fid));
                    if($folder){
                        // 开始远程
                        $mailInstance = new Mail($emails[$eid]['email'],base64_decode($emails[$eid]['password']),$emails[$eid]['imap']);

                        if($mailInstance->login()){
                            switch ($d){
                                // 已读 未读
                                case 'seen':{
                                    $mailInstance->seen(array_column($uid,'uid'),$folder['origin_folder'],$fv);
                                    break;
                                }
                                // 未回复/已回复
                                case 'answered':{
                                    $mailInstance->answered(array_column($uid,'uid'),$folder['origin_folder'],$fv);
                                    break;
                                }
                                // 回收站，已删 未删，软删
//                                case 'deleted':{
//                                    $mailInstance->recycle(array_column($uid,'uid'),$folder['origin_folder'],$fv);
//                                    break;
//                                }
                            }

                            $mailInstance = null;
                            // 更新数据
                            db()->update(listsSql::$table,[
                                $d  =>  $fv
                            ],dbWhere([
                                'id'    =>  array_column($uid,'id')
                            ]));
                        }

                    }
                    $folder = null;
                }
            }

        }


        app()->_json([
            'mail_id'    =>  $mail_ids
        ]);

    }


    /**
     * @author：dc
     * @time 2023/4/1 9:24
     */
    public function info(){
        $id =   app()->request('id',0,'intval');
        // 没有，说明没有同步过来
        $email = $this->getEmail();
        $data    =   db()->first(listsSql::first(dbWhere(['id'=>$id,'email_id'=>$email['id']])));

        if($data){
            $sync_num = 0;
            $data['to_name'] = $data['to_name'] ? json_decode($data['to_name'],true) : [];
            $data['cc'] = $data['cc'] ? json_decode($data['cc'],true) : [];
            $data['bcc'] = $data['bcc'] ? json_decode($data['bcc'],true) : [];

            HOME_INFO_BODY:
            $body   =   db()->first(bodySql::first($id));
            if($body){
                $data['body'] = json_decode($body['text_html'],true);
                $charset = 'utf-8';
                $htmlbody = '';
                foreach ($data['body'] as $bd){
//                    if(!empty($bd['charset'])){
//                        $charset = $bd['charset'];
//                    }
                    if(($bd['type']??'') == 'text/html'){
                        $htmlbody = base64_decode($bd['body']);
                    }
                }
                foreach ($data['body'] as $bdk=>$bd){

                    if(!empty($bd['path'])){

                        $data['body'][$bdk]['name'] = @base64_decode($bd['name']);
                        $data['body'][$bdk]['filename'] = @base64_decode($bd['filename']);
                        // 进行编码转换 会出现未知bug
//                        if($charset && strtolower($charset) != 'utf-8' && strtolower($charset) != 'utf8'){
//                            $data['body'][$bdk]['name'] = @iconv($charset,'utf-8',$data['body'][$bdk]['name']);
//                            $data['body'][$bdk]['filename'] = @iconv($charset,'utf-8',$data['body'][$bdk]['filename']);
//                        }

                        $data['body'][$bdk]['size'] = 0;
                        $data['body'][$bdk]['url'] = '';
                        if(is_file($bd['path'])){
                            // 文件大小
                            $data['body'][$bdk]['size'] = filesize($bd['path']);
                            // 文件访问地址
                            $data['body'][$bdk]['url'] = APP_HOST.str_replace(PUBLIC_PATH,'',$bd['path']);
                        }

                        // 验证编码是否有其他编码字符,这里编辑了未知编码
                        if(!@json_encode($data['body'][$bdk])){
                            // 抛弃原有的名字，显示已存储到服务器的名字
                            $data['body'][$bdk]['name'] = $data['body'][$bdk]['signName'];
                            $data['body'][$bdk]['filename'] = $data['body'][$bdk]['signName'];
                        }

                        unset($data['body'][$bdk]['path']);

                        // 内容区是有有cid
                        if ($htmlbody && !empty($bd['content-id'])){
                            if(!strpos($htmlbody,"\"cid:{$bd['content-id']}\"")){
                                unset($data['body'][$bdk]['content-id']);
                            }
                        }
                        // 没有html内容，content-id是不可能有的
                        else if(!$htmlbody){
                            unset($data['body'][$bdk]['content-id']);
                        }
                    }
                }
                return [
                    'data'  =>  $data
                ];
            }// 草稿
            else if(!$data['uid'] && $data['draft']){
                $data['body'] = [];
                return [
                    'data'  =>  $data
                ];
            }
            // 循环几次
            if($data['uid']&&$sync_num < 1){
                $mail   =   new Mail($email['email'],base64_decode($email['password']),$email['imap']);

                if($mail->login()){

                    $folder = db()->value(folderSql::first(['id'=>$data['folder_id']],'origin_folder'));
                    if($folder){
                        $ret = $mail->syncBody($folder,$data['uid'],$id);
                        $sync_num++;
                        if($ret){
                            goto HOME_INFO_BODY;
                        }
                    }

                }
            }
        }

        app()->e('mail_body_error');

    }


}