周海龙 / mail-serve · 提交

转到一个项目

作者 邓超
提交 434bb4241b42ef97ee19b3be761c40d93b429957 1 个父辈 e691f49d

x

内嵌 并排对比
正在显示 3 个修改的文件 包含 15 行增加 和 290 行删除
... ... @@ -131,6 +131,7 @@ class Login {
'smtp' => $formData['smtp'],
'status' => 1,
'pwd_error' => 0,
'group_table' => get_request_origin(),
];
if($id){
... ...
<?php
namespace Controller\fob_ai;
use Controller\Base;
use Lib\Verify;
use Model\folderSql;
use function Swoole\Coroutine\Http\request;
/**
* 黑格 fob 那边专用 业务
* 为定制逻辑
* @author：dc
* @time 2024/7/18 11:40
* Class MailList
* @package Controller\fob_ai
*/
class MailList extends Base {
/**
* 当前邮箱下指定的文件夹
* @param string $folder
* @return array
* @throws \Lib\Err
* @author：dc
* @time 2024/7/19 11:37
*/
private function getFolderId(string $folder){
// 查询 文件夹
static $folderList;
if(!$folderList){
$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');
}
return $folder_id;
}
private function from_not_in(){
$where = [];
/**
* 不查询哪些发件人的邮件
*/
$form_not_in = app()->request('from_not_in');
if($form_not_in){
if(is_string($form_not_in)){
$form_not_in = explode(',',$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){
$where = array_merge($where,$form_not_in);
}
}
// 过滤掉
foreach ($where as $k=>$item){
if(stripos($item,'postmaster@') === 0){
unset($where[$k]);
}
}
return $where;
}
/**
* 邮件列表
* 接收参数
* 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,['收件箱','发件箱','垃圾箱','星标邮件','预热收件箱','预热发件箱','Starred'])){
app()->e('folder_not_fount');
}
$extSql = ''; // 扩展sql
// $origin_folder = $folder;
if($folder=='星标邮件'||$folder=='Starred'){
$folder = '收件箱';
$where['flagged'] = 1; // 星标
}elseif ($folder=='预热收件箱'){
$folder = '收件箱';
$extSql = "s";
}elseif ($folder=='预热发件箱'){
$folder = '发件箱';
$extSql = "f";
}
$folder_id = $this->getFolderId($folder);
//目录
$where['folder_id'] = $folder_id;
if($ids) $where['id'] = $ids;
if(app()->request('attachment',0,'bool_Val')){
// 附件
$where['is_file'] = 1; //附件
}
// 软删
$where['deleted'] = 0;
$where['from.notin'] = $this->from_not_in();
$where['_'] = "`from` not like 'postmaster@%%'";
if(!$where['from.notin']) unset($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{
if(in_array($folder,['收件箱','发件箱','垃圾箱'])){
$sql = "select %s from `lists` left join `fob_hot_mail` on `lists`.`id` = `fob_hot_mail`.`lists_id` where ISNULL(`lists_id`) 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()->cache(600)->count(sprintf($sql,"count(*)"));
app()->_json(listsPage($lists,$total,$page,$limit));
}
/**
* 统计收件箱的数量
* @author：dc
* @time 2024/7/19 10:15
*/
public function count(){
$emails = $this->getEmails('id');
// show_count_filed
$show_count_filed = app()->requestArr('show_count_filed',['inbox', 'send', 'unseen', 'flagged', 'junk', 'hot_inbox', 'hot_send']);
$sql = "select count(*) from `lists` left join `fob_hot_mail` on `lists`.`id` = `fob_hot_mail`.`lists_id` where ";
$where = ['lists|email_id'=>$emails];
$where['lists|deleted'] = 0; //未删状态
// 屏蔽哪些邮件
$where['from.notin'] = $this->from_not_in();
$where['_'] = "`from` not like 'postmaster@%'";
if(!$where['from.notin']) unset($where['from.notin']);
// 发件箱
if(in_array('hot_send',$show_count_filed)){
$where['lists|folder_id'] = $this->getFolderId('发件箱');
// 预热发件箱
$where['fob_hot_mail|folder'] = 'f';
$fCount = db()->cache(600)->count($sql.dbWhere($where));
}
// 预热收件箱
if(in_array('hot_inbox',$show_count_filed)) {
$where['lists|folder_id'] = $this->getFolderId('收件箱');
$where['fob_hot_mail|folder'] = 's';
$sCount = db()->cache(600)->count($sql . dbWhere($where));
}
unset($where['fob_hot_mail|folder']);
$sql = $sql." ISNULL(`lists_id`) and ";
if(in_array('send',$show_count_filed)) {
$where['lists|folder_id'] = $this->getFolderId('发件箱');
$faCount = db()->cache(600)->count($sql . dbWhere($where));
}
// 垃圾箱
if(in_array('junk',$show_count_filed)) {
$where['lists|folder_id'] = $this->getFolderId('垃圾箱');
$lajiCount = db()->cache(600)->count($sql . dbWhere($where));
}
// 收件箱
if(in_array('inbox',$show_count_filed)) {
$where['lists|folder_id'] = $this->getFolderId('收件箱');
$shouCount = db()->cache(600)->count($sql . dbWhere($where));
}
// 未读
if(in_array('unseen',$show_count_filed)) {
$where['seen'] = 0;
$seenCount = db()->cache(600)->count($sql . dbWhere($where));
unset($where['seen']);
}
// 星标
if(in_array('flagged',$show_count_filed)) {
$where['flagged'] = 1;
$flaggedCount = db()->cache(600)->count($sql . dbWhere($where));
}
$data = [];
if(isset($shouCount)) $data['inbox'] = $shouCount;
if(isset($faCount)) $data['send'] = $faCount;
if(isset($seenCount)) $data['unseen'] = $seenCount;
if(isset($flaggedCount)) $data['flagged'] = $flaggedCount;
if(isset($lajiCount)) $data['junk'] = $lajiCount;
if(isset($sCount)) $data['hot_inbox'] = $sCount;
if(isset($fCount)) $data['hot_send'] = $fCount;
app()->_json($data);
}
}
... ... @@ -510,3 +510,17 @@ function mb_iconv($str, $to, $from = null) {
}
}
/**
* 数据元，就是那个表 分表 list_xxxx body_xxx
* @return array|false|float|int|mixed|string|null
* @author：dc
* @time 2024/9/9 16:47
*/
function get_request_origin(){
$request_origin = app()->request('request_origin');
if(preg_match("/^[a-z]{1,10}_\d{1,10}$/",$request_origin)){
return $request_origin;
}
return '';
}
... ...