20201112

application/api/job/imgFile.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace app\api\job;
+
+use think\queue\Job;
+
+class imgFile {
+
+    //put your code here
+
+    public function fire(Job $job, $data) {
+        $res = $this->send($data);
+            $job->delete();
+        if($res){
+            $job->delete();
+        }else{
+            if($job->attempts()>3){
+                // 第1种处理方式：重新发布任务,该任务延迟10秒后再执行
+                //$job->release(10); 
+                // 第2种处理方式：原任务的基础上1分钟执行一次并增加尝试次数
+                //$job->failed();   
+                // 第3种处理方式：删除任务
+                $job->delete();  
+            }
+        }
+    }
+    
+    /**
+     * 保存图片逻辑
+     * @param type $data
+     */
+    public function send($data){
+        $res = file_put_contents($data['mubiao'], file_get_contents($data['yum']));
+        if($res){
+            return true;
+        }else{
+            return false;
+        }
+    }
+
+}

application/api/job/mail.php

@@ -10,6 +10,7 @@ class mail {
 
     public function fire(Job $job, $data) {
         $res = $this->send($data);
+            $job->delete();
         if($res){
             $job->delete();
         }else{