Browse Source

fix: 还原临时数据修复

hsun 3 years ago
parent
commit
793011e3ef
3 changed files with 0 additions and 58 deletions
  1. 0 52
      controller/activity/activity.go
  2. 0 5
      models/tables/yb_activity_voice/query.go
  3. 0 1
      routers/activity.go

+ 0 - 52
controller/activity/activity.go

@@ -4,9 +4,7 @@ import (
 	"fmt"
 	"github.com/gin-gonic/gin"
 	"hongze/hongze_yb/controller/response"
-	"hongze/hongze_yb/global"
 	"hongze/hongze_yb/models/tables/yb_activity"
-	"hongze/hongze_yb/models/tables/yb_activity_voice"
 	"hongze/hongze_yb/services/activity"
 	"hongze/hongze_yb/services/user"
 	"hongze/hongze_yb/utils"
@@ -254,54 +252,4 @@ func calcuDrawXandY(drawText string, fontSize, canvasLength, canvasWidth int) (x
 	}
 
 	return
-}
-
-func SyncActivityVoice(c *gin.Context) {
-
-	// 1.获取35-186之间的音频数据
-	min := 35
-	max := 186
-	originList, err := yb_activity_voice.GetTempVoicesList(min, max)
-	if err != nil {
-		response.Fail("同步失败" + err.Error(), c)
-		return
-	}
-
-	// 开启事务
-	tx := global.DEFAULT_MYSQL.Begin()
-	defer func() {
-		if err != nil {
-			tx.Rollback()
-		} else {
-			tx.Commit()
-		}
-	}()
-
-	// 反向插入数据
-	nowTime := time.Now()
-	num := 0
-	listIndex := len(originList) - 1
-	for i := listIndex; i >= 0; i-- {
-		newVoice := &yb_activity_voice.YbActivityVoice{
-			ActivityID: originList[i].ActivityID,
-			VoiceURL: originList[i].VoiceURL,
-			VoiceName: originList[i].VoiceName,
-			VoicePlaySeconds: originList[i].VoicePlaySeconds,
-			CreateTime: nowTime,
-		}
-		voiceCreate := tx.Debug().Create(newVoice)
-		if voiceCreate.Error != nil {
-			response.Fail("新增失败" + voiceCreate.Error.Error(), c)
-			return
-		}
-		// 删除源数据
-		voiceDel := tx.Debug().Where("activity_voice_id = ?", originList[i].ActivityVoiceID).Delete(yb_activity_voice.YbActivityVoice{})
-		if voiceDel.Error != nil {
-			response.Fail("删除失败" + voiceDel.Error.Error(), c)
-			return
-		}
-		num += 1
-	}
-
-	response.OkData("同步成功", num, c)
 }

+ 0 - 5
models/tables/yb_activity_voice/query.go

@@ -12,9 +12,4 @@ func GetVoicesByActivityId(activityId int) (voices []*YbActivityVoice, err error
 func GetVoicesByActivityIds(activityIds []int) (voices []*YbActivityVoice, err error) {
 	err = global.DEFAULT_MYSQL.Model(YbActivityVoice{}).Where("activity_id IN (?)", activityIds).Scan(&voices).Error
 	return
-}
-
-func GetTempVoicesList(min, max int) (voices []*YbActivityVoice, err error) {
-	err = global.DEFAULT_MYSQL.Model(YbActivityVoice{}).Where("activity_voice_id >= ? AND activity_voice_id <= ?", min, max).Scan(&voices).Error
-	return
 }

+ 0 - 1
routers/activity.go

@@ -22,6 +22,5 @@ func InitActivity(r *gin.Engine) {
 	rGroup2 := r.Group("activity")
 	{
 		rGroup2.GET("/getActivityShareImg", activity.GetActivityShareImg)
-		rGroup2.GET("/tempSync", activity.SyncActivityVoice)
 	}
 }