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 <[email protected]> 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 {
