fix(video): delete connection close

src/models/rawvideo.go

@@ -1,9 +1,17 @@
 package models
 
+import "GuGoTik/src/storage/database"
+
 type RawVideo struct {
 	ActorId   uint32
 	VideoId   uint32
 	Title     string
 	FileName  string
 	CoverName string
 }
+
+func init() {
+	if err := database.Client.AutoMigrate(&RawVideo{}); err != nil {
+		panic(err)
+	}
+}

src/services/publish/main.go

@@ -48,7 +48,7 @@ func main() {
 
 	var srv PublishServiceImpl
 	var probe healthImpl.ProbeImpl
-	defer CloseMQConn()
+	//defer CloseMQConn()
 	publish.RegisterPublishServiceServer(s, srv)
 	health.RegisterHealthServer(s, &probe)
 	if err := consul.RegisterConsul(config.PublishRpcServerName, config.PublishRpcServerPort); err != nil {

src/services/videoprocessor/summary.go

@@ -113,6 +113,10 @@ func SummaryConsume(channel *amqp.Channel) {
 			}).Errorf("Failed to get summary of an audio from ChatGPT")
 			logging.SetSpanError(span, err)
 			summary = ""
+
+			errorHandler(d, true, logger, &span)
+			span.End()
+			continue
 		}
 
 		select {
@@ -124,6 +128,10 @@ func SummaryConsume(channel *amqp.Channel) {
 			}).Errorf("Failed to get keywords of an audio from ChatGPT")
 			logging.SetSpanError(span, err)
 			keywords = ""
+
+			errorHandler(d, true, logger, &span)
+			span.End()
+			continue
 		}
 
 		// Update summary information to database