You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@answer.apache.org by li...@apache.org on 2024/10/16 03:28:35 UTC
(incubator-answer) 04/05: Fix err
This is an automated email from the ASF dual-hosted git repository.
linkinstar pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-answer.git
commit 2fd6ac37d08039254e98b386edb9ed3dfb416d18
Author: Anan <14...@qq.com>
AuthorDate: Wed Oct 16 02:57:27 2024 +0000
Fix err
---
internal/service/importer/importer_service.go | 6 +++---
internal/service/plugin_common/plugin_common_service.go | 2 --
2 files changed, 3 insertions(+), 5 deletions(-)
diff --git a/internal/service/importer/importer_service.go b/internal/service/importer/importer_service.go
index d775ee76..82572f85 100644
--- a/internal/service/importer/importer_service.go
+++ b/internal/service/importer/importer_service.go
@@ -77,14 +77,13 @@ func (ip *ImporterService) ImportQuestion(ctx context.Context, questionInfo plug
// if reject {
// return
// }
- user_info, exist, err := ip.userCommon.GetByEmail(ctx, questionInfo.UserEmail)
+ userInfo, exist, err := ip.userCommon.GetByEmail(ctx, questionInfo.UserEmail)
if err != nil {
log.Errorf("error: %v", err)
return err
}
if !exist {
log.Errorf("error: User Email not found")
- return err
}
// To limit rate, remove the following code from comment: Part 2/2
@@ -94,7 +93,7 @@ func (ip *ImporterService) ImportQuestion(ctx context.Context, questionInfo plug
// ipc.rateLimitMiddleware.DuplicateRequestClear(ctx, rejectKey)
// }
// }()
- req.UserID = user_info.ID
+ req.UserID = userInfo.ID
req.Title = questionInfo.Title
req.Content = questionInfo.Content
req.HTML = "<p>" + questionInfo.Content + "</p>"
@@ -162,6 +161,7 @@ func (ip *ImporterService) ImportQuestion(ctx context.Context, questionInfo plug
errFields = append(errFields, errlist...)
}
}
+
if len(errFields) > 0 {
log.Errorf("error: RequestFormatError")
return errors.BadRequest(reason.RequestFormatError)
diff --git a/internal/service/plugin_common/plugin_common_service.go b/internal/service/plugin_common/plugin_common_service.go
index 920a8a03..ea6701bd 100644
--- a/internal/service/plugin_common/plugin_common_service.go
+++ b/internal/service/plugin_common/plugin_common_service.go
@@ -22,7 +22,6 @@ package plugin_common
import (
"context"
"encoding/json"
- "fmt"
"github.com/apache/incubator-answer/internal/base/data"
"github.com/apache/incubator-answer/internal/repo/search_sync"
@@ -135,7 +134,6 @@ func (ps *PluginCommonService) GetUserPluginConfig(ctx context.Context, req *sch
}
func (ps *PluginCommonService) initPluginData() {
- fmt.Println("init plugin data")
// init plugin status
pluginStatus, err := ps.configService.GetStringValue(context.TODO(), constant.PluginStatus)
if err != nil {