<?php
namespace app\api\job;
use think\queue\Job;
use app\common\QueueJob;
use app\common\Reviewer;
class SendReviewEmail
{
    // 发送审稿邀请邮件任务
    public function fire(Job $job, $data)
    {

        //获取任务ID
        $iLogId = 0;
        try {
            //实例化
            $oQueueJob = new QueueJob;
            $sMsg = '发送邮件成功';
            if(!empty($job->getRawBody())){
                $aJob = json_decode($job->getRawBody(), true);
                $aParam = [
                    'job_id'     => empty($aJob['id']) ? '' : $aJob['id'],
                    'job_class'  => get_class($this),
                    'status'     => 0,
                    'create_time' => time(),
                    'params'     => json_encode($aJob, JSON_UNESCAPED_UNICODE)
                ];          
                $iLogId = $oQueueJob->addLog($aParam);
                //文章ID
                $iArticleId = empty($data['article_id']) ? 0 : $data['article_id'];
                //作者邮箱
                $email = empty($data['email']) ? '' : $data['email'];
                //邮件主题
                $title = empty($data['title']) ? '' : $data['title'];
                //发送来源
                $from_name = empty($data['from_name']) ? '' : $data['from_name'];
                //邮件内容
                $content = empty($data['content']) ? '' : $data['content'];
                //邮箱
                $memail = empty($data['memail']) ? '' : $data['memail'];
                //密码
                $mpassword = empty($data['mpassword']) ? '' : $data['mpassword'];
                //审稿记录表主键ID
                $art_rev_id = empty($data['art_rev_id']) ? 0 : $data['art_rev_id'];
                //审稿人ID
                $reviewer_id = empty($data['reviewer_id']) ? 0 : $data['reviewer_id'];
                //邮件类型
                $type = empty($data['type']) ? 1 : $data['type'];
                //发送邮件
                if (!empty($email) && !empty($memail) && !empty($mpassword)) {

                    //查询是否发送过邮件
                    $oReviewer = new Reviewer;
                    if($type != 3){
                        $aLog = json_decode($oReviewer->getLog(['article_id' => $iArticleId,'art_rev_id' => $art_rev_id,'reviewer_id' => $reviewer_id,'is_success' => 1,'type' => $type]),true);
                        $aLog = empty($aLog['data']) ? [] : $aLog['data'];
                        $sMsg = '邮件已发送:'.json_encode($aLog);
                    }
                    if(empty($aLog)){
                        $aResult = sendEmail($email,$title,$from_name,$content,$memail,$mpassword);
                        $iStatus = empty($aResult['status']) ? 1 : $aResult['status'];
                        $iIsSuccess = 2;
                        $sMsg = empty($aResult['data']) ? '失败' : $aResult['data'];
                        if($iStatus == 1){
                            $iIsSuccess = 1;
                            $sMsg = '成功';
                        }
                        //记录邮件发送日志
                        $aEmailLog = ['article_id' => $iArticleId,'art_rev_id' => $art_rev_id,'reviewer_id' => $reviewer_id,'type' => $type,'email' => $email,'content' => $content,'create_time' => time(),'is_success' => $iIsSuccess,'msg' => $sMsg];
                        //添加邮件发送日志
                        $iId = $oReviewer->addLog($aEmailLog);
                    }
                }
            }
            $job->delete();

            //更新任务状态
            $aParam = ['log_id' => $iLogId,'status' => 1,'update_time' => time(),'error' => $sMsg];
            $oQueueJob->updateLog($aParam);
            // // 记录日志
            // \think\Log::info("RelatedArticle延迟任务执行成功: ".json_encode($data));
        } catch (\Exception $e) {

            //实例化
            $oQueueJob = new QueueJob;
            //更新任务状态
            $sMsg = empty($e->getMessage()) ? '任务出错' : $e->getMessage();
            $aParam = ['log_id' => $iLogId,'status' => 2,'update_time' => time(),'error' => $sMsg];
            $oQueueJob->updateLog($aParam);
            $job->delete();
            // // 记录错误日志
            // \think\Log::error("RelatedArticle延迟任务失败: ".$e->getMessage());
        }finally {
            gc_collect_cycles(); // 强制垃圾回收
        }
    }

}