下载视频

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

@@ -7,6 +7,7 @@ import com.yanzuoguang.mq.service.MqService;
 import com.yanzuoguang.mq.vo.MessageVo;
 import com.yanzuoguang.mq.vo.QueueVo;
 import com.yanzuoguang.util.cache.MemoryCache;
+import com.yanzuoguang.util.exception.CodeException;
 import com.yanzuoguang.util.helper.DateHelper;
 import com.yanzuoguang.util.helper.JsonHelper;
 import com.yanzuoguang.util.helper.StringHelper;
@@ -151,8 +152,11 @@ public class YzgFileProcedure implements InitializingBean {
      * @param req
      */
     public void fileCreate(YzgFileCreateReqVo req) {
-        if (StringHelper.isEmpty(req.getCallbackMQ(), req.getFileName())) {
-            return;
+        if (StringHelper.isEmpty(req.getFileName())) {
+            throw new CodeException("下载文件名不能为空");
+        }
+        if (StringHelper.isEmpty(req.getCallbackMQ())) {
+            throw new CodeException("回调callbackMQ不能为空，请检查后端程序");
         }
         req.init();
         fileCreate(JsonHelper.serialize(req));