调整曲目专辑数

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

@@ -122,6 +122,8 @@ public class MusicSheetServiceImpl extends ServiceImpl<MusicSheetDao, MusicSheet
     private UserOrderService userOrderService;
     @Autowired
     private MusicAlbumDao musicAlbumMapper;
+    @Autowired
+    private MusicSheetService musicSheetService;
 
     public MusicSheetDao getDao() {
         return musicSheetDao;
@@ -430,12 +432,31 @@ public class MusicSheetServiceImpl extends ServiceImpl<MusicSheetDao, MusicSheet
     @Override
     public IPage<MusicSheetVo> myMusic(IPage<MusicSheetVo> page, StudentMusicSheetSearch query) {
         query.setDelFlag(null);
+
+        List<MusicSheetVo> records = baseMapper.selectMyMusicPage(page, query);
+
+        // 统计曲目专辑数
+        if (CollectionUtils.isNotEmpty(records)) {
+
+            // 更新曲目专辑数量
+            musicSheetService.updateMusicAlbumNumInfo(records);
+        }
+
         return page.setRecords(baseMapper.selectMyMusicPage(page, query));
     }
 
     @Override
     public IPage<MusicSheetVo> favoriteMusic(IPage<MusicSheetVo> page, StudentMusicSheetSearch query, ClientEnum clientType) {
-        return page.setRecords(baseMapper.selectFavoriteMusicPage(page, query, clientType));
+
+        List<MusicSheetVo> records = baseMapper.selectFavoriteMusicPage(page, query, clientType);
+
+        if (CollectionUtils.isNotEmpty(records)) {
+
+            // 更新曲目专辑数量
+            musicSheetService.updateMusicAlbumNumInfo(records);
+        }
+
+        return page.setRecords(records);
     }
 
     @Override
@@ -457,6 +478,12 @@ public class MusicSheetServiceImpl extends ServiceImpl<MusicSheetDao, MusicSheet
         page.setCurrent(practiceMusicIdPage.getCurrent());
         page.setSize(practiceMusicIdPage.getSize());
         page.setTotal(practiceMusicIdPage.getTotal());
+
+        if (CollectionUtils.isNotEmpty(page.getRecords())) {
+
+            // 更新曲目专辑数量
+            musicSheetService.updateMusicAlbumNumInfo(page.getRecords());
+        }
         return page;
     }