crm_hdl/application/admin/controller/EmailSends.php

<?php
/**
 * Created by PhpStorm.
 * User: Kevin
 * Date: 2018/11/14
 * Time: 15:51
 */
namespace app\admin\controller;
use app\admin\model\CustomerModel;
use app\admin\model\EmailSendModel;
use app\admin\model\EmailsModel;
use app\admin\model\EmailTemplateModel;
use app\admin\model\UserModel;
use PHPMailer\PHPMailer\PHPMailer;
use think\Db;
class EmailSends extends Base
{
    public function index(){
        if (request()->isAjax()) {
            extract(input());
            $map = [];

            if (isset($email) && $email != "") {
                $map['email'] = ['like', "%" . $email . "%"];
            }
            $map['is_deleted'] = 0;
            //$map['spread_id']=session('uid');


            $Nowpage = input('page') ? input('page') : 1;
            $limits = input("limit") ? input("limit") : 10;//获取总条数;
            $field = input('field');//字段
            $order = input('order');//排序方式
            if ($field && $order) {
                $od = $field . " " . $order;
            } else {
                $od = "create_time desc";
            }
            $emails =new EmailTemplateModel();
            $emailSend = new EmailSendModel();
            $count = $emails->getCount($map);
            $lists = $emailSend->getByWhere($map, $od, $Nowpage, $limits);



            foreach($lists as $k=>&$v){
                $v['shou']='<a href="export?uni='.$v['uni'].'" style="color:#3BA1FF">下载全部收件人邮箱</a>';
                $v['count']=Db::table('think_email_send')->where('uni',$v['uni'])->count();//全部
                $v['count1']=Db::table('think_email_send')->where('uni',$v['uni'])->where('status',1)->count();//已发送
                $v['count2']=Db::table('think_email_send')->where('uni',$v['uni'])->where('status',0)->count();//未发送
                $v['count3']=Db::table('think_email_send')->where('uni',$v['uni'])->where('status',2)->count();//已取消


//                if($v['type']==2){
//                    $v['remark']='草稿';
//                    $v['is_edit']=1;
//                }else
                if($v['count']>0 && $v['count2']>0 && $v['count3']==0){
                    $v['remark']='发送中('.$v['count1'].'/'.$v['count'].')';
                    $v['is_edit']=0;
                    $v['is_stop']=1;
                }elseif ($v['count2']==0 && $v['count3']>0){
                    $v['remark']='已取消('.$v['count1'].'/'.$v['count'].')';
                    $v['is_edit']=1;
                    $v['is_go']=1;
                }elseif(!$v['count']){
                    $v['remark']='未发送';
                    $v['is_edit']=1;
                }elseif($v['count2']==0 && $v['count3']==0){
                    $v['remark']='已完成';
                    $v['is_edit']=1;
                }else{
                    $v['remark']='处理中';
                    $v['is_edit']=1;
                }

                $v['send_time']=Db::table('think_email_send')->where('uni',$v['uni'])->where('status', 1)->order('send_time desc')->value('send_time');
                if($v['send_time']){
                    $v['send_time']=date('Y-m-d H:i:s',$v['send_time']).'-('.$v['count1'].'/'.$v['count'].')';

                }else{
                    $n['send_time']=Db::table('think_email_send')->where('uni',$v['uni'])->order('send_time desc')->value('send_time');
                    $v['send_time']=date('Y-m-d H:i:s',$n['send_time']).'-('.$v['count1'].'/'.$v['count'].')';
                }

                $v['username']=Db::table('think_admin')->where('id',$v['spread_id'])->value('username');
            }


            return json(['code' => 220, 'msg' => '', 'count' => $count, 'data' => $lists]);
        }

        $this->assign('status', 100);
        return $this->fetch('index');
    }

    public function add(){
        $emails =new EmailsModel();
        if(request()->isPost()){
            $param = input('param.');
            if($param['send_type']==1){
                if(empty($param['send_time'])){
                    return json(['code' => 100,  'msg' => '请先选择发送时间']);
                }
            }

            if(empty($param['email_id'])){
                return json(['code' => 100,  'msg' => '请先选择发件人']);
            }

            if(empty($param['to'])){
                return json(['code' => 100,  'msg' => '请先输入收件人邮箱']);
            }

            if(empty($param['theme'])){
                return json(['code' => 100,  'msg' => '请先选择邮件主题']);
            }

            if(empty($param['content'])){
                return json(['code' => 100,  'msg' => '请先填写邮件内容']);
            }

            $to_email=Db::table('think_email')->where('id',$param['email_id'])->find();

            $count=Db::table('think_email_send')->where('is_deleted',0)->where('email_id',$to_email['id'])->count();
            if($count+1>$to_email['max_num']){
                return json(['code' => 100,  'msg' => '请切换邮箱发送,该邮箱已超过最大发送次数']);
            }
            $theme=Db::table('think_email_template')->where('id',$param['theme'])->value('theme');
            $data['from']=$to_email['email'];
            $data['from_name']='发件人姓名';
            $data['to']=$param['to'];
            $data['theme']=$theme;
            $data['theme_id']=$param['theme'];
            $data['content']=$param['content'];
            $data['email_id']=$param['email_id'];
            $data['send_type']=$param['send_type'];
            $data['spread_id']=session('uid');
            $data['create_time']=time();

            if($data['send_type']==0){

                $mail= new PHPMailer();
                $mail->SMTPDebug = 1;
                $mail->isSMTP();
                $mail->SMTPDebug = false;
                $mail->SMTPAuth = true;
                $mail->Host =$to_email['smtp'];
                $mail->SMTPSecure = $to_email['encryption'];
                $mail->Port = $to_email['port'];
                $mail->CharSet = 'UTF-8';
                $mail->FromName = '发件人昵称';
                $mail->Username = $to_email['email'];
                $mail->Password = $to_email['password'];
                $mail->From = $to_email['email'];
                $mail->isHTML(true);
                $mail->addAddress($param['to']);
                $mail->Subject = $theme;
                $mail->Body = $param['content'];
                $status = $mail->send();

                $data['status']=1;
                $data['send_status']=!$status?0:1;
                $data['send_time']=time();


            }else{
                $data['send_time']=strtotime($param['send_time']);
            }
            $r=Db::table('think_email_send')->insertGetId($data);

            if($r){
                return json(['code' => 200,  'msg' => '提交成功']);
            }else{
                return json(['code' => 100,  'msg' => '提交失败']);

            }

        }

        $emails=Db::table('think_email')
            ->where('is_deleted',0)
            ->where('spread_id',session('uid'))
            ->select();
        $this->assign('emails',$emails);

        $templates=Db::table('think_email_template')
            ->where('is_deleted',0)
            ->where('type',1)
            ->where('spread_id',session('uid'))
            ->select();
        $this->assign('templates',$templates);
        return $this->fetch();
    }

    public function edit(){

        $emails =new EmailsModel();
        if(request()->isPost()){
            $param = input('param.');
            $flag = $emails->edit($param);

            return json(['code' => $flag['code'],  'msg' => $flag['msg']]);
        }
        $id = input('id');
        $map = [];

        $this->assign('res',$emails->getInfo($id));
        return $this->fetch();

    }

    public function del(){

        $id = input('param.id');

        $emails =new EmailsModel();
        $flag = $emails->del($id);
        return json(['code' => $flag['code'], 'data' => $flag['data'], 'msg' => $flag['msg']]);

    }

    /**
     * batchDelUser 批量删除
     * @return \think\response\Json
     */
    public function batchDelUser()
    {
        extract(input());
        if (empty($ids)) {
            return json(['code' => 100, 'msg' => '请选择要删除的记录！']);
        }
        $ids = explode(',', $ids);

        $emails =new EmailsModel();

        $flag = $emails->batchDel($ids);

        return json(['code' => $flag['code'], 'msg' => $flag['msg']]);
    }

    public function email_template_info(){
        $id = input('param.id');
        if(empty($id)){
            return json(['code' => 100, 'msg' => '参数错误！']);
        }
        $model=new EmailTemplateModel();
        $res=$model->getInfo($id);
        return json(['code' => 200, 'data' => $res, 'msg' => '请求成功']);
    }

    public function edit_status(){
        $id = input('param.id');
        $status = input('param.status');
        if(empty($id) || empty($status)){
            return json(['code' => 100, 'msg' => '参数错误']);
        }

        $map['spread_id']=session('uid');
        $map['is_deleted']=0;
        $map['theme_id']=$id;
        if($status==1){
            $map['status']=2;
            $status=0;
        }else{
            $map['status']=0;
            $status=2;
        }
        $ids=Db::table('think_email_send')->where($map)->column('id');
        if(empty($ids)){
            return json(['code' => 200, 'msg' => '操作成功']);
        }
        Db::table('think_email_send')->whereIn('id',$ids)->update(['status'=>$status]);

        return json(['code' => 200, 'msg' => '操作成功']);

    }

    public function export(){

        $id = input('param.id');
        //$map['spread_id']=session('uid');
        $map['is_deleted']=0;
        $map['theme_id']=$id;
        $data=Db::table('think_email_send')->where($map)->field('to')->select();
        $cellname = [
            ['to', '邮箱', 15, 'LEFT'],
        ];


        $res = exportExcels('收件邮箱', 'email', $cellname, $data);
        return json($res);
    }


}