转并评论 fix

community-service/src/main/java/com/tanpu/community/manager/ThemeManager.java

@@ -410,8 +410,8 @@ public class ThemeManager {
             themeService.insertTheme(themeEntity);
             // 消息通知
             ThemeEntity formerTheme = themeService.queryByThemeId(req.getFormerThemeId());
-            if (formerTheme!=null){
-                notificationService.insertForward(userId, formerTheme.getAuthorId(), themeEntity.getThemeId(), req.getTopicId(), req.getContent().get(0).getValue(), themeEntity.getThemeId());
+            if (formerTheme != null) {
+                notificationService.insertForward(userId, formerTheme.getAuthorId(), req.getFormerThemeId(), req.getTopicId(), req.getContent().get(0).getValue(), themeEntity.getThemeId());
                 notificationService.putNotifyCache(formerTheme.getAuthorId(), userId, NotificationTypeEnum.FORWARD);
             }
 
@@ -426,7 +426,7 @@ public class ThemeManager {
         if (req.getSyncComment() == BizConstant.SyncCommentType.SYNC_COMMENT) {
             String commentId = commentService.forwardSyncComment(req, userId);
             ThemeEntity formerTheme = themeService.queryByThemeId(req.getFormerThemeId());
-            if (formerTheme!=null){
+            if (formerTheme != null) {
                 notificationService.insert(userId, formerTheme.getAuthorId(), NotificationTypeEnum.COMMENT, commentId, req.getContent().get(0).getValue());
                 notificationService.putNotifyCache(formerTheme.getAuthorId(), userId, NotificationTypeEnum.COMMENT);
             }