diff --git a/server/video/model/video.sql b/server/video/model/video.sql index 60ed681..0cbf004 100644 --- a/server/video/model/video.sql +++ b/server/video/model/video.sql @@ -12,5 +12,5 @@ CREATE TABLE `video` PRIMARY KEY (`id`), UNIQUE KEY `id` (`id`), KEY `idx_user_id_create_time` (`user_id`,`create_time`) -) ENGINE=InnoDB AUTO_INCREMENT=1721574251233812481 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci +) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci diff --git a/server/video/model/videomodel_gen.go b/server/video/model/videomodel_gen.go index d818c6b..547258b 100755 --- a/server/video/model/videomodel_gen.go +++ b/server/video/model/videomodel_gen.go @@ -40,15 +40,15 @@ type ( } Video struct { - Id int64 `db:"id"` - UserId int64 `db:"user_id"` - Title string `db:"title"` - Partition int64 `db:"partition"` - PlayUrl string `db:"play_url"` - CoverUrl string `db:"cover_url"` - CreateTime time.Time `db:"create_time"` - UpdateTime time.Time `db:"update_time"` - DeleteTime time.Time `db:"delete_time"` + Id int64 `db:"id" json:"id"` + UserId int64 `db:"user_id" json:"user_id"` + Title string `db:"title" json:"title"` + Partition int64 `db:"partition" json:"partition"` + PlayUrl string `db:"play_url" json:"play_url"` + CoverUrl string `db:"cover_url" json:"cover_url"` + CreateTime time.Time `db:"create_time" json:"create_time"` + UpdateTime time.Time `db:"update_time" json:"update_time"` + DeleteTime time.Time `db:"delete_time" json:"delete_time"` } ) diff --git a/server/video/mq/internal/service/service.go b/server/video/mq/internal/service/service.go index 519d6dc..66fbd81 100644 --- a/server/video/mq/internal/service/service.go +++ b/server/video/mq/internal/service/service.go @@ -149,7 +149,6 @@ func (s *Service) consume(ch chan *model.Video) { vJson, err := jsonx.MarshalToString(v) if err != nil { logx.Error("解析json对象,err:", err) - return } _, err = s.ESClient.Index().