fix

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/MusicSheetServiceImpl.java

@@ -2313,11 +2313,11 @@ public class MusicSheetServiceImpl extends ServiceImpl<MusicSheetDao, MusicSheet
         ThreadPoolExecutor executorService =  new ThreadPoolExecutor(50, 50,
             0L, TimeUnit.MILLISECONDS,
             new LinkedBlockingQueue<>());
-        while (true) {
-            IPage<MusicSheet> page = baseMapper.selectSyncPage(new Page<>(curPage, pageSize));
+//        while (true) {
+            IPage<MusicSheet> page = baseMapper.selectSyncPage(new Page<>(1, -1));
             List<MusicSheet> records = page.getRecords();
             if (CollectionUtils.isEmpty(records)) {
-                break;
+                return;
             }
             for (MusicSheet record : records) {
                 if (record.getCbsMusicSheetId() != null && !DateUtil.format(record.getCreateTime(),"yyyy-MM-dd HH:mm:ss").equals("2024-06-25 00:00:00")) {
@@ -2338,7 +2338,7 @@ public class MusicSheetServiceImpl extends ServiceImpl<MusicSheetDao, MusicSheet
             }
 
             curPage++;
-        }
+//        }
 
         while (!executorService.getQueue().isEmpty()) {
             try {
@@ -2372,7 +2372,7 @@ public class MusicSheetServiceImpl extends ServiceImpl<MusicSheetDao, MusicSheet
             musicSheet1.setMusicSheetName(musicSheet.getName());
             this.updateById(musicSheet1);
         } catch (Exception e){
-            log.error("曲目同步失败，曲目ID：{}", record.getId());
+            log.error("曲目同步失败，曲目ID：{}", record.getId(),e);
         }
 
     }

cooleshow-user/user-biz/src/main/resources/config/mybatis/MusicSheetMapper.xml

@@ -1020,7 +1020,7 @@
     <select id="selectSyncPage" resultType="com.yonge.cooleshow.biz.dal.entity.MusicSheet">
         select *
         from music_sheet
-        where del_flag_ = 0 and audit_status_ = 'PASS'
+        where del_flag_ = 0 and audit_status_ = 'PASS' and cbs_music_sheet_id_ is null
     </select>
     <!--单曲专辑数量统计-->
 </mapper>