19904408334
1ca25abca0
- price.go -> service/utils/media_type.go(媒体类型检测) - model_resolve.go -> service/utils/model_resolve.go(模型解析) - 删除 service/parse_error_test.go(逻辑迁往 utils 后无对应测试) - session_sync/session_stream/model_*_service/pricing_client 等调用方适配 - schema_mapping/model_call_dto 补字段路径
36 lines
1.2 KiB
Go
36 lines
1.2 KiB
Go
package service
|
||
|
||
import (
|
||
"context"
|
||
"model-gateway/model/dto"
|
||
|
||
commonHttp "gitea.redpowerfuture.com/red-future/common/http"
|
||
"gitea.redpowerfuture.com/red-future/common/oss"
|
||
"gitea.redpowerfuture.com/red-future/common/utils"
|
||
)
|
||
|
||
// IsSuperAdmin 调用admin-go服务检查是否是管理员
|
||
func IsSuperAdmin(ctx context.Context) (res bool, err error) {
|
||
headers := utils.HeadersFromCtx(ctx, utils.HeadersOptions{ResolveToken: true})
|
||
var r = make(map[string]bool)
|
||
if err = commonHttp.Get(ctx, "admin-go/api/v1/system/user/checkIsSuperAdmin", headers, &r); err != nil {
|
||
return false, err
|
||
}
|
||
return r["isSuperAdmin"], err
|
||
}
|
||
|
||
// Upload 上传文件到 OSS。统一走 common/oss（multipart field=file、X-User-Info 三态注入与旧 setCtxHeader 等价）。
|
||
func Upload(ctx context.Context, req *dto.UploadFileBytesReq) (*dto.UploadFileBytesRes, error) {
|
||
res, err := oss.UploadFileBytes(ctx, req.FileName, req.FileBytes)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return &dto.UploadFileBytesRes{
|
||
FileURL: res.FileURL,
|
||
FileSize: res.FileSize,
|
||
FileName: res.FileName,
|
||
FileFormat: res.FileFormat,
|
||
FileAddressPrefix: res.FileAddressPrefix,
|
||
}, nil
|
||
}
|