From 43bf56c8962b585ff0b98b003746939481d5bdd7 Mon Sep 17 00:00:00 2001
From: aichy126 <16996097+aichy126@users.noreply.github.com>
Date: Tue, 16 May 2023 16:46:58 +0800
Subject: [PATCH] update v13
---
internal/migrations/v13.go | 66 ++++++++++++++++++++++++++++++++++++++
1 file changed, 66 insertions(+)
diff --git a/internal/migrations/v13.go b/internal/migrations/v13.go
index e69de29b..45c64ae7 100644
--- a/internal/migrations/v13.go
+++ b/internal/migrations/v13.go
@@ -0,0 +1,66 @@
+package migrations
+
+import (
+ "encoding/json"
+ "fmt"
+
+ "github.com/answerdev/answer/internal/base/constant"
+ "github.com/answerdev/answer/internal/entity"
+ "github.com/answerdev/answer/internal/schema"
+ "github.com/segmentfault/pacman/log"
+ "xorm.io/xorm"
+)
+
+func addGravatarBaseURL(x *xorm.Engine) error {
+ usersSiteInfo := &entity.SiteInfo{
+ Type: constant.SiteTypeUsers,
+ }
+ exist, err := x.Get(usersSiteInfo)
+ if err != nil {
+ return fmt.Errorf("get config failed: %w", err)
+ }
+ if exist {
+ content := &schema.SiteUsersReq{}
+ _ = json.Unmarshal([]byte(usersSiteInfo.Content), content)
+ content.GravatarBaseURL = "https://www.gravatar.com/avatar/"
+ data, _ := json.Marshal(content)
+ usersSiteInfo.Content = string(data)
+
+ _, err = x.ID(usersSiteInfo.ID).Cols("content").Update(usersSiteInfo)
+ if err != nil {
+ return fmt.Errorf("update site info failed: %w", err)
+ }
+ }
+
+ //search all answers
+ answers := make([]entity.Answer, 0)
+ err = x.Find(&answers, &entity.Answer{Status: entity.AnswerStatusAvailable})
+ if err != nil {
+ return fmt.Errorf("get answers failed: %w", err)
+ }
+ questionAnswerCount := make(map[string]int)
+ for _, answer := range answers {
+ _, ok := questionAnswerCount[answer.QuestionID]
+ if !ok {
+ questionAnswerCount[answer.QuestionID] = 1
+ } else {
+ questionAnswerCount[answer.QuestionID]++
+ }
+ }
+ questionList := make([]entity.Question, 0)
+ err = x.Find(&questionList, &entity.Question{})
+ if err != nil {
+ return fmt.Errorf("get questions failed: %w", err)
+ }
+ for _, item := range questionList {
+ _, ok := questionAnswerCount[item.ID]
+ if ok {
+ item.AnswerCount = questionAnswerCount[item.ID]
+ if _, err = x.Update(item, &entity.Question{ID: item.ID}); err != nil {
+ log.Errorf("update %+v config failed: %s", item, err)
+ return fmt.Errorf("update question failed: %w", err)
+ }
+ }
+ }
+ return nil
+}