穿山甲资源上传oss 测试

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/CsjResourceServiceImpl.java

@@ -90,8 +90,9 @@ public class CsjResourceServiceImpl implements ICsjResourceService {
                     String ossVideoUrl = uploadToOss(videoUrl, fileName);
                     if (StringUtils.isNotEmpty(ossVideoUrl)){
                         seq.setOssSeqVideo(ossVideoUrl);
-                        csjResourceMapper.updateSeq(seq);
                     }
+                    csjResourceMapper.updateSeq(seq);
+
                 }
             }
         }
@@ -107,8 +108,8 @@ public class CsjResourceServiceImpl implements ICsjResourceService {
                         String ossCoverImg = uploadToOss(coverUrl, fileName);
                         if (StringUtils.isNotEmpty(ossCoverImg)){
                             album.setOssCoverImg(ossCoverImg);
-                            csjResourceMapper.updateAlbum(album);
                         }
+                        csjResourceMapper.updateAlbum(album);
                     }
                 } else {
                     CsjAlbumSeqResourceInfo seq = seqMap.get(seqNum);
@@ -122,8 +123,8 @@ public class CsjResourceServiceImpl implements ICsjResourceService {
                         String ossSeqImg = uploadToOss(coverUrl, fileName);
                         if (StringUtils.isNotEmpty(ossSeqImg)){
                             seq.setOssSeqImg(ossSeqImg);
-                            csjResourceMapper.updateSeq(seq);
                         }
+                        csjResourceMapper.updateSeq(seq);
                     }
                 }
             }
@@ -144,7 +145,6 @@ public class CsjResourceServiceImpl implements ICsjResourceService {
         String ossUrl = ossProperties.getCsjDomain() + objectKey;
         try {
             System.out.println("文件: "+fileName + ", from: " + url);
-//            return null;
             ossUtil.uploadFromUrl(objectKey, url);
             log.info("上传成功: " + ossUrl);
             return ossUrl;

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/CsjResoureJob.java

@@ -35,7 +35,7 @@ public class CsjResoureJob {
                 log.info("资源已被处理，跳过: " + album.getAlbumId());
                 continue;
             }
-            if (++count > 5){
+            if (++count > 10){
                 break; //剧目数限制
             }
             linkRefreshExecutorService.submit(() -> {

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/utils/OssUtil.java

@@ -71,8 +71,6 @@ public class OssUtil {
 
             // 执行上传
             PutObjectResult result = ossClient.putObject(putRequest);
-            System.out.println("File uploaded to OSS: " + objectKey);
-            System.out.println(result);
 
         } catch (OSSException oe) {
             System.out.println("Caught an OSSException, which means your request made it to OSS, "
@@ -88,8 +86,6 @@ public class OssUtil {
                     + "such as not being able to access the network.");
             System.out.println("Error Message:" + ce.getMessage());
             throw ce;
-        } catch (Exception e){
-            throw e;
         } finally {
             // 关闭资源
             if (inputStream != null) inputStream.close();