Procházet zdrojové kódy

端原生分销商品库上传

zhaotx před 1 rokem
rodič
revize
eaf965b288

+ 12 - 10
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/FeishuDocSyncServiceImpl.java

@@ -83,16 +83,18 @@ public class FeishuDocSyncServiceImpl implements IFeishuDocSyncService {
             }
             }
 
 
 
 
-            //iap
-            List<AigcProductAlbum> iapMovies = readMovieFromDoc(productDocProperties.getObjToken(), table.getTableId(), table.getIapViewId(), readToken, null);
-            if (iapMovies != null && !iapMovies.isEmpty()){
-                iapMovies.forEach(m -> {
-                    m.setSource(Integer.valueOf(table.getMovieSource()));
-                    m.setBusinessMethod("IAP");
-                    m.setPlayletId(getQueryParam(m.getAlbumLink(), "playlet_id"));
-                    m.setPlayletPurchasePanelId(getQueryParam(m.getAlbumLink(), "playlet_purchase_panel_id"));
-                });
-                bytedanceProductUpdateMapper.batchInsertDysDistributePlayletInfo(iapMovies);
+            if (StringUtils.isNotEmpty(table.getIapViewId())){
+                //iap
+                List<AigcProductAlbum> iapMovies = readMovieFromDoc(productDocProperties.getObjToken(), table.getTableId(), table.getIapViewId(), readToken, null);
+                if (iapMovies != null && !iapMovies.isEmpty()){
+                    iapMovies.forEach(m -> {
+                        m.setSource(Integer.valueOf(table.getMovieSource()));
+                        m.setBusinessMethod("IAP");
+                        m.setPlayletId(getQueryParam(m.getAlbumLink(), "playlet_id"));
+                        m.setPlayletPurchasePanelId(getQueryParam(m.getAlbumLink(), "playlet_purchase_panel_id"));
+                    });
+                    bytedanceProductUpdateMapper.batchInsertDysDistributePlayletInfo(iapMovies);
+                }
             }
             }
         }
         }
     }
     }