diff --git a/rpc/message/pb/message.pb.go b/rpc/message/pb/message.pb.go index c4cf61c..04effb7 100644 --- a/rpc/message/pb/message.pb.go +++ b/rpc/message/pb/message.pb.go @@ -7,12 +7,13 @@ package message import ( - _ "google.golang.org/genproto/googleapis/api/annotations" - protoreflect "google.golang.org/protobuf/reflect/protoreflect" - protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" unsafe "unsafe" + + _ "google.golang.org/genproto/googleapis/api/annotations" + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" ) const ( diff --git a/services/analysis/internal/callback/persist.go b/services/analysis/internal/callback/persist.go index e3f9ee7..be1c8d4 100644 --- a/services/analysis/internal/callback/persist.go +++ b/services/analysis/internal/callback/persist.go @@ -41,8 +41,7 @@ func SaveTask(ts dao.TaskTimeStamp, userId int64, path *dao.HandleZipResource, c if coverPath != utils.StringEmpty { updateData["cover"] = coverPath } - _, err := m.Edit(w, updateData) - return err + return m.Session().Where("task_id = ?", ts.TaskId).Updates(updateData).Error } func SaveSubTask(ts dao.TaskTimeStamp, path *dao.HandleZipResource) error { diff --git a/services/analysis/internal/callback/process.go b/services/analysis/internal/callback/process.go index 6ef8c23..cde20b2 100644 --- a/services/analysis/internal/callback/process.go +++ b/services/analysis/internal/callback/process.go @@ -68,7 +68,7 @@ func ProcessUpload(ctx context.Context, payload analysisoss.CallbackPayload) err ts := dao.TaskTimeStamp{ TaskId: payload.TaskId, SubTaskId: subTaskId, - ProcessStartTs: strconv.FormatInt(time.Now().UnixMilli(), 10), + ProcessStartTs: time.Now().UnixMilli(), } userId := sess.SkinUserId() if userId < utils.NumberOne { diff --git a/services/analysis/internal/dao/analysis_sub.go b/services/analysis/internal/dao/analysis_sub.go index 730f567..9b32b26 100644 --- a/services/analysis/internal/dao/analysis_sub.go +++ b/services/analysis/internal/dao/analysis_sub.go @@ -10,10 +10,10 @@ type ImageAnalysisSub struct { FilePath string `gorm:"column:file_path" json:"file_path"` ImageDir string `gorm:"column:image_dir" json:"image_dir"` Scene string `gorm:"column:scene" json:"scene"` - UploadStartTs string `gorm:"column:upload_start_ts" json:"upload_start_ts"` - UploadEndTs string `gorm:"column:upload_end_ts" json:"upload_end_ts"` - ProcessStartTs string `gorm:"column:process_start_ts" json:"process_start_ts"` - ProcessEndTs string `gorm:"column:process_end_ts" json:"process_end_ts"` + UploadStartTs int64 `gorm:"column:upload_start_ts" json:"upload_start_ts"` + UploadEndTs int64 `gorm:"column:upload_end_ts" json:"upload_end_ts"` + ProcessStartTs int64 `gorm:"column:process_start_ts" json:"process_start_ts"` + ProcessEndTs int64 `gorm:"column:process_end_ts" json:"process_end_ts"` CreatedAt utils.CustomTime `gorm:"column:created_at" json:"created_at"` UpdatedAt utils.CustomTime `gorm:"column:updated_at" json:"updated_at"` } @@ -27,7 +27,7 @@ type HandleZipResource struct { type TaskTimeStamp struct { TaskId string SubTaskId string - UploadStartTs string - UploadEndTs string - ProcessStartTs string + UploadStartTs int64 + UploadEndTs int64 + ProcessStartTs int64 }