下载视频

yzg-util-cloud/src/main/java/com/yanzuoguang/cloud/file/YzgFileProcedure.java

 package com.yanzuoguang.cloud.file;
 
 import com.yanzuoguang.cloud.vo.req.YzgFileCallbackReqVo;
+import com.yanzuoguang.cloud.vo.req.YzgFileCreateReqVo;
 import com.yanzuoguang.cloud.vo.req.YzgFileStatusReqVo;
 import com.yanzuoguang.mq.service.MqService;
 import com.yanzuoguang.mq.vo.MessageVo;
@@ -149,7 +150,11 @@ public class YzgFileProcedure implements InitializingBean {
      *
      * @param req
      */
-    public void fileCreate(YzgFileStatusReqVo req) {
+    public void fileCreate(YzgFileCreateReqVo req) {
+        if (StringHelper.isEmpty(req.getCallbackMQ(), req.getFileName())) {
+            return;
+        }
+        req.init();
         fileCreate(JsonHelper.serialize(req));
     }
 
@@ -177,6 +182,9 @@ public class YzgFileProcedure implements InitializingBean {
      * @param req
      */
     public void fileStatus(YzgFileStatusReqVo req) {
+        if (StringHelper.isEmpty(req.getFileId(), req.getFileStatus())) {
+            return;
+        }
         fileStatus(JsonHelper.serialize(req));
     }