<?php

namespace Controller\fob_ai;



use Controller\Base;
use Lib\Verify;
use Model\folderSql;

/**
 * 黑格 fob 那边专用 业务
 * 为定制逻辑
 * @author：dc
 * @time 2024/7/18 11:40
 * Class MailList
 * @package Controller\fob_ai
 */
class MailList extends Base {


    /**
     * 邮件列表
     * 接收参数
     *  page 分页
     * limit 每页数量
     * mail_id 指定邮件id
     * attachment 是否附件
     * emails 邮箱
     * folder 文件夹
     * from_not_in 不在这些发件箱的邮件
     * @throws \Lib\Err
     * @author：dc
     * @time 2024/7/18 11:40
     */
    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]);
            }
        }

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

        // 目录
        $folder = app()->request('folder','收件箱');
        // 只允许查询这里文件夹
        if(!in_array($folder,['收件箱','发件箱','垃圾箱','星标邮件','预热收件箱','预热发件箱'])){
            app()->e('folder_not_fount');
        }
        $extSql = ''; // 扩展sql
//        $origin_folder = $folder;
        if($folder=='星标邮件'){
            $folder = '收件箱';
            $where['flagged'] = 1; // 星标
        }elseif ($folder=='预热收件箱'){
            $folder = '收件箱';
            $extSql = "s";
        }elseif ($folder=='预热发件箱'){
            $folder = '发件箱';
            $extSql = "f";
        }
            // 查询 文件夹
        $folderList = db()->all(folderSql::all($this->getEmails('id')));
        $folder_id = [];
        // 文件夹id
        if($folderList){
            foreach ($folderList as $item){
                if(folderAlias($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'] = app()->request('attachment',0,'bool_Val') ? 1 : 0; //附件
        }

        // 软删
        $where['deleted'] = 0;

        /**
         * 不查询哪些发件人的邮件
         */
        $form_not_in = app()->request('from_not_in');
        if($form_not_in){
            $form_not_in = is_array($form_not_in) ? $form_not_in : [$form_not_in];
            $form_not_in = array_filter($form_not_in,function ($v){
               if(is_string($v) && Verify::sEmail($v)){
                   return true;
               }
               return false;
            });
            if($form_not_in){
                if(isset($where['from.notin'])){
                    $where['from.notin'] = array_merge($where['from.notin'],$form_not_in);
                }else{
                    $where['from.notin'] = $form_not_in;
                }

            }
        }
        if(!empty($where['from.notin'])){
            $where['from.notin'] = array_unique($where['from.notin']);
        }


        $filed = '`id`,`uid`,`subject`,`from`,`from_name`,`flagged`,`seen`,`udate`,`folder_id`,`is_file`,`description`,`lists`.`email_id`,`to_name`';

        if($extSql){
            $sql = "select %s from `lists` left join `fob_hot_mail` on `lists`.`id` = `fob_hot_mail`.`lists_id` where `fob_hot_mail`.`folder` = '{$extSql}' and ".dbWhere($where);
        }else{
            $sql = "select %s from `lists` where ".dbWhere($where);
        }

        // 查询列表数据
        $lists = db()->all(sprintf($sql,$filed)." order by `udate` desc limit {$limit} offset ".(($page-1)*$limit));

        // map
        $lists = array_map(function ($v){
            $v['uuid'] = md5($v['email_id'].'-'.$v['folder_id'].'-'.$v['uid']);
            if(!empty($v['description'])){
                $v['description'] = @html_entity_decode($v['description'], ENT_COMPAT, 'UTF-8');
            }
            $v['to_name'] = @json_decode($v['to_name'],true);
            $v['to_name'] = $v['to_name']?:[];
            if($v['to_name']){
                if(!empty($v['to_name'][0]['email'])){
                    $v['to'] = $v['to_name'][0]['email'];
                }
                $v['to_name'] = $v['to_name'][0]['name']??'';
            }
            if(is_array($v['to_name'])){
                $v['to_name'] = '';
            }
            return $v;
        },$lists);

        // 总数
        $total  = db()->count(sprintf($sql,"count(*)"));

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

    }



}