queencloud-mesh/mesh/api/service-database-upload-image.go

package api

import (
	"mats/db/model"
	"mats/db/repo"
	"time"

	"go.mongodb.org/mongo-driver/bson/primitive"
)

func UploadImage(apictx *ApiSession, dbConf *model.AssetDbConf, body *model.AssetImage) (interface{}, error) {
	asset := body
	// source := asset.Source
	asset.Enable = BoolValue(false)
	asset.AssetState = model.AssetState_Succ

	asset.CreateTime = time.Now()
	asset.UpdateTime = time.Now()
	collectionName := dbConf.AssetConf.Collection
	return repo.RepoDbAddDoc(apictx.CreateRepoCtx(), dbConf.Db.Name, collectionName, asset)
}

func UpdateImageComm(apictx *ApiSession, dbConf *model.AssetDbConf, body *model.AssetImage) (interface{}, error) {
	asset := body
	asset.UpdateTime = time.Now()
	id := asset.Id.Hex()
	asset.Id = primitive.NilObjectID

	collectionName := dbConf.AssetConf.Collection
	return repo.RepoUpdateSeDbDoc(apictx.CreateRepoCtx(), dbConf.Db.Name, collectionName, id, asset)
}

func UpdateImageSource(apictx *ApiSession, dbConf *model.AssetDbConf, body *model.AssetImage) (interface{}, error) {
	asset := body
	asset.UpdateTime = time.Now()
	id := asset.Id.Hex()
	asset.Id = primitive.NilObjectID

	collectionName := dbConf.AssetConf.Collection
	return repo.RepoUpdateSeDbDoc(apictx.CreateRepoCtx(), dbConf.Db.Name, collectionName, id, asset)
}