diff --git a/chat/core/src/main/java/com/tencent/supersonic/chat/persistence/repository/StatisticsRepository.java b/chat/core/src/main/java/com/tencent/supersonic/chat/persistence/repository/StatisticsRepository.java index e6b457754..2b5967808 100644 --- a/chat/core/src/main/java/com/tencent/supersonic/chat/persistence/repository/StatisticsRepository.java +++ b/chat/core/src/main/java/com/tencent/supersonic/chat/persistence/repository/StatisticsRepository.java @@ -7,5 +7,5 @@ import java.util.List; public interface StatisticsRepository { - boolean batchSaveStatistics(List list); + void batchSaveStatistics(List list); } diff --git a/chat/core/src/main/java/com/tencent/supersonic/chat/persistence/repository/impl/StatisticsRepositoryImpl.java b/chat/core/src/main/java/com/tencent/supersonic/chat/persistence/repository/impl/StatisticsRepositoryImpl.java index 7a8593944..476a80267 100644 --- a/chat/core/src/main/java/com/tencent/supersonic/chat/persistence/repository/impl/StatisticsRepositoryImpl.java +++ b/chat/core/src/main/java/com/tencent/supersonic/chat/persistence/repository/impl/StatisticsRepositoryImpl.java @@ -20,10 +20,9 @@ public class StatisticsRepositoryImpl implements StatisticsRepository { this.statisticsMapper = statisticsMapper; } - public boolean batchSaveStatistics(List list) { - return statisticsMapper.batchSaveStatistics(list); + public void batchSaveStatistics(List list) { + statisticsMapper.batchSaveStatistics(list); } - ; } diff --git a/chat/core/src/main/java/com/tencent/supersonic/chat/service/StatisticsService.java b/chat/core/src/main/java/com/tencent/supersonic/chat/service/StatisticsService.java index ce62d9e8b..d3908fe49 100644 --- a/chat/core/src/main/java/com/tencent/supersonic/chat/service/StatisticsService.java +++ b/chat/core/src/main/java/com/tencent/supersonic/chat/service/StatisticsService.java @@ -5,5 +5,5 @@ import com.tencent.supersonic.chat.persistence.dataobject.StatisticsDO; import java.util.List; public interface StatisticsService { - boolean batchSaveStatistics(List list); + void batchSaveStatistics(List list); } diff --git a/chat/core/src/main/java/com/tencent/supersonic/chat/service/impl/ChatServiceImpl.java b/chat/core/src/main/java/com/tencent/supersonic/chat/service/impl/ChatServiceImpl.java index 220d10bce..209262b8f 100644 --- a/chat/core/src/main/java/com/tencent/supersonic/chat/service/impl/ChatServiceImpl.java +++ b/chat/core/src/main/java/com/tencent/supersonic/chat/service/impl/ChatServiceImpl.java @@ -33,6 +33,7 @@ import com.tencent.supersonic.common.util.JsonUtil; import lombok.extern.slf4j.Slf4j; import org.apache.commons.compress.utils.Lists; import org.springframework.context.annotation.Primary; +import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; diff --git a/chat/core/src/main/java/com/tencent/supersonic/chat/service/impl/StatisticsServiceImpl.java b/chat/core/src/main/java/com/tencent/supersonic/chat/service/impl/StatisticsServiceImpl.java index 9309152e4..cb162d237 100644 --- a/chat/core/src/main/java/com/tencent/supersonic/chat/service/impl/StatisticsServiceImpl.java +++ b/chat/core/src/main/java/com/tencent/supersonic/chat/service/impl/StatisticsServiceImpl.java @@ -4,6 +4,7 @@ import com.tencent.supersonic.chat.persistence.dataobject.StatisticsDO; import com.tencent.supersonic.chat.persistence.repository.StatisticsRepository; import com.tencent.supersonic.chat.service.StatisticsService; import lombok.extern.slf4j.Slf4j; +import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import java.util.List; @@ -18,8 +19,9 @@ public class StatisticsServiceImpl implements StatisticsService { this.statisticsRepository = statisticsRepository; } + @Async @Override - public boolean batchSaveStatistics(List list) { - return statisticsRepository.batchSaveStatistics(list); + public void batchSaveStatistics(List list) { + statisticsRepository.batchSaveStatistics(list); } } diff --git a/chat/core/src/main/resources/mapper/ChatParseMapper.xml b/chat/core/src/main/resources/mapper/ChatParseMapper.xml index 88f8dbc86..3c442fe2a 100644 --- a/chat/core/src/main/resources/mapper/ChatParseMapper.xml +++ b/chat/core/src/main/resources/mapper/ChatParseMapper.xml @@ -28,7 +28,7 @@ update s2_chat_parse set parse_info = #{parseInfo} - where parse_id = #{parseId} + where question_id = #{questionId} and parse_id = #{parseId}