Merge branch 'master' into code-gen

# Conflicts:
#	src/main/java/com/qiniu/storage/Api.java

Author: YangSen-qn

src/main/java/com/qiniu/processing/OperationManager.java

@@ -80,7 +80,7 @@ public String pfop(String bucket, String key, String fops) throws QiniuException
      * @param bucket 空间名
      * @param key    文件名
      * @param fops   fops指令，如果有多个指令，需要使用分号(;)进行拼接，例如 avthumb/mp4/xxx|saveas/xxx;vframe/jpg/xxx|saveas/xxx
-     * @param params notifyURL、force、pipeline 等参数
+     * @param params notifyURL、force、pipeline、type等参数
      * @return persistentId 请求返回的任务ID，可以根据该ID查询任务状态
      * @throws QiniuException 触发失败异常，包含错误响应等信息
      *                        <a href="http://developer.qiniu.com/dora/api/persistent-data-processing-pfop"> 相关链接 </a>
@@ -154,8 +154,34 @@ public String pfop(String bucket, String key, String fops, String pipeline, bool
      */
     public String pfop(String bucket, String key, String fops, String pipeline, String notifyURL, boolean force)
             throws QiniuException {
-        StringMap params = new StringMap().putNotEmpty("pipeline", pipeline).
-                putNotEmpty("notifyURL", notifyURL).putWhen("force", 1, force);
+        StringMap params = new StringMap()
+                .putNotEmpty("pipeline", pipeline)
+                .putNotEmpty("notifyURL", notifyURL)
+                .putWhen("force", 1, force);
+        return pfop(bucket, key, fops, params);
+    }
+
+    /**
+     * 发送请求对空间中的文件进行持久化处理
+     *
+     * @param bucket    空间名
+     * @param key       文件名
+     * @param fops      fop指令
+     * @param pipeline  持久化数据处理队列名称
+     * @param notifyURL 处理结果通知地址，任务完成后自动以POST方式将处理结果提交到指定的地址
+     * @param type      任务类型，0：非闲时任务，1：闲时任务
+     * @param force     用于对同一个指令进行强制处理时指定，一般用于覆盖空间已有文件或者重试失败的指令
+     * @return persistentId 请求返回的任务ID，可以根据该ID查询任务状态
+     * @throws QiniuException 触发失败异常，包含错误响应等信息
+     *                        <a href="http://developer.qiniu.com/dora/api/persistent-data-processing-pfop"> 相关链接 </a>
+     */
+    public String pfop(String bucket, String key, String fops, String pipeline, String notifyURL, String type, boolean force)
+            throws QiniuException {
+        StringMap params = new StringMap()
+                .putNotEmpty("type", type)
+                .putNotEmpty("pipeline", pipeline)
+                .putNotEmpty("notifyURL", notifyURL)
+                .putWhen("force", 1, force);
         return pfop(bucket, key, fops, params);
     }
 

src/main/java/com/qiniu/processing/OperationStatus.java

@@ -9,30 +9,49 @@ public class OperationStatus {
      * 持久化处理的进程ID，即 persistentId
      */
     public String id;
+
     /**
      * 状态码 0 成功，1 等待处理，2 正在处理，3 处理失败，4 通知提交失败
      */
     public int code;
+
     /**
      * 与状态码相对应的详细描述
      */
     public String desc;
+
     /**
      * 处理源文件的文件名
      */
     public String inputKey;
+
     /**
      * 处理源文件所在的空间名
      */
     public String inputBucket;
+
     /**
      * 云处理操作的处理队列
      */
     public String pipeline;
+
     /**
      * 云处理请求的请求id，主要用于七牛技术人员的问题排查
      */
     public String reqid;
+
+    /**
+     * 是否是闲时任务
+     * 0：非闲时任务
+     * 1：显示任务
+     */
+    public String type;
+
+    /**
+     * 任务创建时间
+     */
+    public String creationDate;
+
     /**
      * 云处理操作列表，包含每个云处理操作的状态信息
      */

src/main/java/com/qiniu/storage/Api.java

@@ -1251,7 +1251,7 @@ private static okhttp3.MultipartBody createFormRequestBody(MultipartBody formBod
                     }
 
                     final okhttp3.MultipartBody.Builder b = new okhttp3.MultipartBody.Builder();
-                    if (StringUtils.isNullOrEmpty(formBody.name)) {
+                    if (!StringUtils.isNullOrEmpty(formBody.name)) {
                         b.addFormDataPart(formBody.name, formBody.fileName, body);
                     }
 
@@ -1299,17 +1299,17 @@ private MultipartBody(String name, String fileName, StringMap fields, File body,
 
                 private void setupBody() throws QiniuException {
                     okhttp3.MultipartBody formBody = createFormRequestBody(this);
-                    Buffer buffer = new Buffer();
-                    try {
-                        formBody.writeTo(buffer);
-                    } catch (IOException e) {
-                        throw QiniuException.unrecoverable(e);
-                    }
 
                     // 只有使用 bytesBody 和 fileBody 都没有时才会处理，其他不处理
                     // bytes 用作签名，Multipart 不做签名
                     // bytes
                     if (this.bytesBody == null && this.fileBody == null) {
+                        Buffer buffer = new Buffer();
+                        try {
+                            formBody.writeTo(buffer);
+                        } catch (IOException e) {
+                            throw QiniuException.unrecoverable(e);
+                        }
                         this.bytes = buffer.readByteArray();
                     }
 

src/main/java/com/qiniu/util/Auth.java

@@ -48,6 +48,7 @@ public final class Auth {
             "fsizeMin",
             "trafficLimit",
 
+            "persistentType",
             "persistentOps",
             "persistentNotifyUrl",
             "persistentPipeline",

src/test/java/test/com/qiniu/processing/PfopTest.java

@@ -7,6 +7,7 @@
 import com.qiniu.processing.OperationStatus;
 import com.qiniu.storage.Configuration;
 import com.qiniu.storage.Region;
+import com.qiniu.util.Auth;
 import com.qiniu.util.StringUtils;
 import com.qiniu.util.UrlSafeBase64;
 import org.junit.jupiter.api.Tag;
@@ -138,4 +139,34 @@ private void testPfopIsSuccess(String jobid) {
         assertEquals(0, status.code);
     }
 
+    @Test
+    @Tag("IntegrationTest")
+    void testPfopA() {
+        try {
+            Auth auth = TestConfig.testAuth;
+            Map<String, Region> bucketKeyMap = new HashMap<String, Region>();
+            TestConfig.TestFile[] files = TestConfig.getTestFileArray();
+            for (TestConfig.TestFile testFile : files) {
+                bucketKeyMap.put(testFile.getBucketName(), testFile.getRegion());
+            }
+            for (Map.Entry<String, Region> entry : bucketKeyMap.entrySet()) {
+                String bucket = entry.getKey();
+                Region region = entry.getValue();
+
+                Configuration cfg = new Configuration(region);
+                OperationManager operationManager = new OperationManager(auth, cfg);
+                String jobID = operationManager.pfop(bucket, TestConfig.testMp4FileKey, "avinfo", "", "", "1", true);
+
+                OperationStatus status = operationManager.prefop(bucket, jobID);
+                assertNotNull(status, "1. prefop type error");
+                assertNotNull(status.creationDate, "1. prefop type error");
+                assertTrue(status.code == 0 || status.code == 1 || status.code == 3, "2. prefop type error");
+                assertEquals("1", status.type, "3. prefop type error");
+            }
+
+        } catch (QiniuException ex) {
+            ex.printStackTrace();
+            assertTrue(ResCode.find(ex.code(), ResCode.getPossibleResCode(612)));
+        }
+    }
 }