商品库任务更新到新版

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

@@ -261,9 +261,14 @@ public class BytedanceProductUpdateServiceImpl implements IBytedanceProductUpdat
             if (toUpload.isEmpty()){
                 continue;
             }
+
+
+
             //获取未上传剧目的推广链接
-            List<AigcProductAlbum> douyinUploadList = toUpload.stream().filter(o -> Objects.equals(o.getPlatformType(), "1")).collect(Collectors.toList());
-            Map<String, String> albumIdToLinkMap = getBytedancePlayletPromoteLink(platform.getMiniAppAdvertiserId(), platform.getAccessToken(), platform.getMiniInstanceId(), douyinUploadList, errors, platform.getPlatformId(), platform.getDevAppId());
+//            List<AigcProductAlbum> douyinUploadList = toUpload.stream().filter(o -> Objects.equals(o.getPlatformType(), "1")).collect(Collectors.toList());
+//            Map<String, String> albumIdToLinkMap = getBytedancePlayletPromoteLink(platform.getMiniAppAdvertiserId(), platform.getAccessToken(), platform.getMiniInstanceId(), douyinUploadList, errors, platform.getPlatformId(), platform.getDevAppId());
+
+
             //未上传剧目：对比平台类型；确定商品分类；获取推广链接
             for (AigcProductAlbum album : toUpload){
                 if (!Objects.equals(album.getPlatformType(), String.valueOf(platform.getPlatformType()))){
@@ -276,13 +281,13 @@ public class BytedanceProductUpdateServiceImpl implements IBytedanceProductUpdat
                 }
                 String schemaLink = null;
                 if (platform.getIsBytedance()==1){
-                    if (!albumIdToLinkMap.containsKey(album.getAlbumId())){
-                        System.out.println(">>>>没有找到对应的推广链接，无法上传商品，剧目ID：" + album.getAlbumId() + ", 剧目名称：" + album.getName());
-                        System.out.println("\n\n\n");
-                        continue;
-                    }else {
-                        schemaLink = albumIdToLinkMap.get(album.getAlbumId());
-                    }
+//                    if (!albumIdToLinkMap.containsKey(album.getAlbumId())){
+//                        System.out.println(">>>>没有找到对应的推广链接，无法上传商品，剧目ID：" + album.getAlbumId() + ", 剧目名称：" + album.getName());
+//                        System.out.println("\n\n\n");
+//                        continue;
+//                    }else {
+//                        schemaLink = albumIdToLinkMap.get(album.getAlbumId());
+//                    }
                 }
                 uploadProduct(platform, album, schemaLink, errors, productTypeMap.get(album.getTheme()), businessType);
             }
@@ -452,7 +457,8 @@ public class BytedanceProductUpdateServiceImpl implements IBytedanceProductUpdat
 //        uploadAlbum(31084L, 1742489802322972L, "d22b45ce9033303d22c5f34abcd4600811b18d88");
 //        uploadAlbum();
 //        Thread.sleep(1000);
-        refreshAlbumStatus();
+        runMp();
+//        refreshAlbumStatus();
 //        List<String> errors = new ArrayList<>();
 //        iapProductUpdate(errors);
 //        System.out.println(errors);
@@ -581,9 +587,14 @@ public class BytedanceProductUpdateServiceImpl implements IBytedanceProductUpdat
         if (platform.getIsDys() == 1){
             ad_carrier.add("端原生组件");
         }
-        if (platform.getIsBytedance() == 1){
-            profession.put("micro_app_link", schemaLink);
-        }else if (platform.getIsWechat() == 1){
+//        if (platform.getIsBytedance() == 1){
+//            profession.put("micro_app_link", schemaLink);
+//        }else if (platform.getIsWechat() == 1){
+//            profession.put("album_id", album_id);
+//        }else if (platform.getIsDys() == 1){
+//            profession.put("album_link", album.getAlbumLink());
+//        }
+        if (platform.getIsBytedance() == 1 || platform.getIsWechat() == 1){
             profession.put("album_id", album_id);
         }else if (platform.getIsDys() == 1){
             profession.put("album_link", album.getAlbumLink());