圈子消息通知-插入

community-service/src/main/java/com/tanpu/community/service/NotificationService.java

@@ -14,7 +14,6 @@ import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.util.List;
-import java.util.TreeSet;
 
 @Service
 public class NotificationService {
@@ -25,20 +24,21 @@ public class NotificationService {
     @Autowired
     private UuidGenHelper uuidGenHelper;
 
-    @Transactional
+
     public void insert(String operatorId,String notifierId,NotificationTypeEnum type,String targetId,String content){
-        NotificationEntity.builder().operatorId(operatorId)
+        NotificationEntity entity = NotificationEntity.builder().operatorId(operatorId)
                 .notificationId(uuidGenHelper.getUuidStr())
                 .notifiedUserId(notifierId)
                 .messageType(type.getCode())
                 .content(content)
                 .operatorId(targetId).build();
+        insert(entity);
     }
 
-    @Transactional
+
     public void insertForward(String operatorId,String notifierId,String themeId,String topicId,String text){
         NotificationForwardDO forwardDO = NotificationForwardDO.builder().topicId(topicId).content(text).build();
-        NotificationEntity.builder().operatorId(operatorId)
+        NotificationEntity entity = NotificationEntity.builder().operatorId(operatorId)
                 .notificationId(uuidGenHelper.getUuidStr())
                 .notifiedUserId(notifierId)
                 .messageType(NotificationTypeEnum.LIKE.getCode())
@@ -46,11 +46,11 @@ public class NotificationService {
                 .operatorId(operatorId)
                 .targetId(themeId)
                 .build();
-
+        insert(entity);
 
     }
 
-    @Transactional
+
     public void insertLike(String operatorId,String notifierId,String targetId){
         NotificationEntity entity = notificationMapper.selectOne(new LambdaQueryWrapper<NotificationEntity>()
                 .eq(NotificationEntity::getMessageType, NotificationTypeEnum.LIKE.getCode())
@@ -73,9 +73,13 @@ public class NotificationService {
                     .operatorId(operatorId)
                     .build();
         }
+        insert(entity);
     }
 
-
+    @Transactional
+    public void insert(NotificationEntity entity){
+        notificationMapper.insert(entity);
+    }
 
 
     public NotificationEntity queryById(String notificationId){