Compare commits

..
14 Commits
Author SHA1 Message Date
haomingming 1a2dcdd2be 去除注释2 2025-10-11 14:46:50 +08:00
haomingming 058ea3f8d6 去除注释 2025-10-11 14:43:50 +08:00
haomingming e45d806d91 同时修改平台id 2025-10-11 14:27:01 +08:00
haomingming e261364482 打印日志 2025-10-11 14:14:01 +08:00
haomingming 48a5141054 调试信息 2025-10-11 14:02:53 +08:00
haomingming 410933e5b0 添加调试信息 2025-10-11 13:58:20 +08:00
haomingming 8fab74e064 优质留言 2025-10-11 13:52:39 +08:00
haomingming 54b66ed80a 修改优质留言发放逻辑 2025-10-11 11:31:30 +08:00
haomingming b1605f025f 修改优质留言发放积分逻辑 2025-10-10 14:08:06 +08:00
haomingming 30ab9f8fa0 测试分支 2025-10-10 13:59:28 +08:00
admin 8a1845ae52 新增了用户参与记录导出3 2025-09-11 10:50:07 +08:00
admin a1eb176239 新增了用户参与记录导出2 2025-09-11 10:36:10 +08:00
admin 88a884b6ff 新增了用户参与记录导出1 2025-08-26 15:09:44 +08:00
admin 269c95f4af 新增了用户参与记录导出 2025-08-26 14:29:25 +08:00
9 changed files with 520 additions and 60 deletions
+1
View File
@@ -16,4 +16,5 @@ type Api struct {
StatsCase // 统计数据-病例
Platform // 平台
CaseComment // 病例-评论
Export // 导出
}
+14 -3
View File
@@ -269,17 +269,28 @@ func (b *CaseComment) AddCaseCommentHighQuality(c *gin.Context) {
}
}()
// 发放积分-优质留言
// println(user)
// str := fmt.Sprintf("%+v", user) // %+v 会带上字段名
// fmt.Println(str)
// fmt.Println(caseComment.PlatformId)
// println("========")
// 发放积分-优质留言-1010 修改
userService := service.UserService{}
err = userService.ReportUserScore(tx, result.ProjectId, caseComment.CaseId, caseComment.PlatformId, scoreType, user)
reportPlatformId := caseComment.PlatformId
reportPlatformId,user,err = userService.ReportUserScore(tx, result.ProjectId, caseComment.CaseId, caseComment.PlatformId, scoreType, user)
if err != nil {
tx.Rollback()
responses.FailWithMessage(err.Error(), c)
return
}
// println(user)
// str2 := fmt.Sprintf("%+v", user) // %+v 会带上字段名
// fmt.Println(str2)
// fmt.Println(reportPlatformId)
// 上报用户参与情况-只上报优质留言-佳动力
if caseComment.PlatformId == 2 {
if reportPlatformId == 2 {
err = userService.ReportCaseRecord(tx, result.ProjectId, caseComment.CaseId, user)
if err != nil {
tx.Rollback()
+52
View File
@@ -0,0 +1,52 @@
package controller
import (
"case-admin-api/api/dao"
"case-admin-api/api/requests"
"case-admin-api/api/responses"
"case-admin-api/api/service"
"case-admin-api/global"
"case-admin-api/utils"
"github.com/gin-gonic/gin"
)
type Export struct{}
// ExportUserRecord 用户参与记录导出
func (b *Export) ExportUserRecord(c *gin.Context) {
exportRequest := requests.ExportRequest{}
req := exportRequest.ExportUserRecord
if err := c.ShouldBind(&req); err != nil {
responses.FailWithMessage(err.Error(), c)
return
}
// 参数验证
if err := global.Validate.Struct(req); err != nil {
responses.FailWithMessage(utils.Translate(err), c)
return
}
// 获取数据
userBehaviorRecordDao := dao.UserBehaviorRecordDao{}
userBehaviorRecords, err := userBehaviorRecordDao.GetExportUserRecordListSearch(req)
if err != nil {
responses.FailWithMessage(err.Error(), c)
return
}
if len(userBehaviorRecords) <= 0 {
responses.FailWithMessage("无数据,不可导出", c)
return
}
// 业务处理
exportService := service.ExportService{}
ossAddress, err := exportService.ExportUserRecord(userBehaviorRecords)
if err != nil {
responses.FailWithMessage(err.Error(), c)
return
}
responses.OkWithData(ossAddress, c)
}
+215
View File
@@ -0,0 +1,215 @@
package dao
import (
"case-admin-api/api/model"
"case-admin-api/api/requests"
"case-admin-api/global"
"errors"
"gorm.io/gorm"
"gorm.io/gorm/clause"
"strings"
)
type UserBehaviorRecordDao struct {
}
// GetUserBehaviorRecordById 获取数据-id
func (r *UserBehaviorRecordDao) GetUserBehaviorRecordById(recordId int64) (m *model.UserBehaviorRecord, err error) {
err = global.Db.First(&m, recordId).Error
if err != nil {
return nil, err
}
return m, nil
}
// GetUserBehaviorRecordPreloadById 获取数据-加载全部关联-id
func (r *UserBehaviorRecordDao) GetUserBehaviorRecordPreloadById(recordId int64) (m *model.UserBehaviorRecord, err error) {
err = global.Db.Preload(clause.Associations).First(&m, recordId).Error
if err != nil {
return nil, err
}
return m, nil
}
// DeleteUserBehaviorRecord 删除
func (r *UserBehaviorRecordDao) DeleteUserBehaviorRecord(tx *gorm.DB, maps interface{}) error {
err := tx.Where(maps).Delete(&model.UserBehaviorRecord{}).Error
if err != nil {
return err
}
return nil
}
// DeleteUserBehaviorRecordById 删除-id
func (r *UserBehaviorRecordDao) DeleteUserBehaviorRecordById(tx *gorm.DB, recordId int64) error {
if err := tx.Delete(&model.UserBehaviorRecord{}, recordId).Error; err != nil {
return err
}
return nil
}
// EditUserBehaviorRecord 修改
func (r *UserBehaviorRecordDao) EditUserBehaviorRecord(tx *gorm.DB, maps interface{}, data interface{}) error {
err := tx.Model(&model.UserBehaviorRecord{}).Where(maps).Updates(data).Error
if err != nil {
return err
}
return nil
}
// EditUserBehaviorRecordById 修改-id
func (r *UserBehaviorRecordDao) EditUserBehaviorRecordById(tx *gorm.DB, recordId int64, data interface{}) error {
err := tx.Model(&model.UserBehaviorRecord{}).Where("record_id = ?", recordId).Updates(data).Error
if err != nil {
return err
}
return nil
}
// GetUserBehaviorRecordList 获取列表
func (r *UserBehaviorRecordDao) GetUserBehaviorRecordList(maps interface{}) (m []*model.UserBehaviorRecord, err error) {
err = global.Db.Where(maps).Find(&m).Error
if err != nil {
return nil, err
}
return m, nil
}
// GetUserBehaviorRecordCount 获取数量
func (r *UserBehaviorRecordDao) GetUserBehaviorRecordCount(maps interface{}) (total int64, err error) {
err = global.Db.Model(&model.UserBehaviorRecord{}).Where(maps).Count(&total).Error
if err != nil {
return 0, err
}
return total, nil
}
// GetUserBehaviorRecordListRand 获取列表-随机
func (r *UserBehaviorRecordDao) GetUserBehaviorRecordListRand(maps interface{}, limit int) (m []*model.UserBehaviorRecord, err error) {
err = global.Db.Where(maps).Order("rand()").Limit(limit).Find(&m).Error
if err != nil {
return nil, err
}
return m, nil
}
// AddUserBehaviorRecord 新增
func (r *UserBehaviorRecordDao) AddUserBehaviorRecord(tx *gorm.DB, model *model.UserBehaviorRecord) (*model.UserBehaviorRecord, error) {
if err := tx.Create(model).Error; err != nil {
return nil, err
}
return model, nil
}
// GetUserBehaviorRecord 获取
func (r *UserBehaviorRecordDao) GetUserBehaviorRecord(maps interface{}) (m *model.UserBehaviorRecord, err error) {
err = global.Db.Where(maps).First(&m).Error
if err != nil {
return nil, err
}
return m, nil
}
// GetUserBehaviorRecordPreload 获取
func (r *UserBehaviorRecordDao) GetUserBehaviorRecordPreload(maps interface{}) (m *model.UserBehaviorRecord, err error) {
err = global.Db.Preload(clause.Associations).Where(maps).First(&m).Error
if err != nil {
return nil, err
}
return m, nil
}
// GetUserBehaviorRecordUseTx 获取
func (r *UserBehaviorRecordDao) GetUserBehaviorRecordUseTx(tx *gorm.DB, maps interface{}) (m *model.UserBehaviorRecord, err error) {
err = tx.Where(maps).First(&m).Error
if err != nil {
return nil, err
}
return m, nil
}
// Inc 自增
func (r *UserBehaviorRecordDao) Inc(tx *gorm.DB, recordId int64, field string, numeral int) error {
err := tx.Model(&model.UserBehaviorRecord{}).Where("record_id = ?", recordId).UpdateColumn(field, gorm.Expr(field+" + ?", numeral)).Error
if err != nil {
return err
}
return nil
}
// Dec 自减
func (r *UserBehaviorRecordDao) Dec(tx *gorm.DB, recordId int64, field string, numeral int) error {
err := tx.Model(&model.UserBehaviorRecord{}).Where("record_id = ?", recordId).UpdateColumn(field, gorm.Expr(field+" - ?", numeral)).Error
if err != nil {
return err
}
return nil
}
// GetExportUserRecordListSearch 列表-导出
func (r *UserBehaviorRecordDao) GetExportUserRecordListSearch(req requests.ExportUserRecord) (m []*model.UserBehaviorRecord, err error) {
// 构建查询条件
query := global.Db.Model(&model.UserBehaviorRecord{})
// 病例
query = query.Preload("Case")
// 用户
query = query.Preload("User")
// 平台
query = query.Preload("Platform")
// 用户医院
query = query.Preload("User.Hospital")
if req.CaseId != "" {
query = query.Where("case_id = ?", req.CaseId)
}
if req.PlatformId != "" {
query = query.Where("platform_id = ?", req.PlatformId)
}
if req.ProjectId != "" {
subQuery := global.Db.Model(&model.Case{}).
Select("case_id").
Where("project_id = ?", req.ProjectId)
query = query.Where(gorm.Expr("case_id IN (?)", subQuery))
}
// 当前搜索数据
if req.Type == 1 {
if req.PlatformId != "" {
query = query.Where("platform_id = ?", req.PlatformId)
}
// 搜索关键字
if req.Keyword != "" {
keyword := "%" + req.Keyword + "%" //
// 执行组建
query = query.Where("step LIKE ?", keyword)
}
}
// 当前选择数据
if req.Type == 2 {
if req.Id == "" {
return nil, errors.New("未提供需导出数据编号")
}
id := strings.Split(req.Id, ",")
query = query.Where("record_id IN (?)", id)
}
// 排序
query = query.Order("created_at desc")
err = query.Find(&m).Error
if err != nil {
return nil, err
}
return m, nil
}
+3
View File
@@ -16,6 +16,9 @@ type UserBehaviorRecord struct {
StartTime LocalTime `gorm:"column:start_time;type:datetime;comment:开始时间" json:"start_time"`
EndTime LocalTime `gorm:"column:end_time;type:datetime;comment:结束时间" json:"end_time"`
Model
Platform *Platform `gorm:"foreignKey:PlatformId;references:platform_id" json:"platform"`
Case *Case `gorm:"foreignKey:CaseId;references:case_id" json:"case"`
User *User `gorm:"foreignKey:UserId;references:user_id" json:"user"`
}
func (m *UserBehaviorRecord) TableName() string {
+15
View File
@@ -0,0 +1,15 @@
package requests
type ExportRequest struct {
ExportUserRecord // 用户参与记录导出
}
// ExportUserRecord 用户参与记录导出
type ExportUserRecord struct {
Type int `json:"type" form:"type" label:"类型" validate:"required,oneof=1 2 3"` // 1:当前搜索数据 2:当前选择数据 3:全部数据
Id string `json:"id" form:"id" label:"id"`
PlatformId string `json:"platform_id" form:"platform_id" label:"平台id"`
CaseId string `json:"case_id" form:"case_id" label:"病例id"`
ProjectId string `json:"project_id" form:"project_id" label:"项目id" validate:"required"`
Keyword string `json:"Keyword" form:"Keyword" label:"关键词" validate:"required"`
}
+7
View File
@@ -355,4 +355,11 @@ func privateRouter(r *gin.Engine, api controller.Api) {
editorGroup.POST("", api.Editor.EditorUpload)
}
}
// 导出
exportGroup := adminGroup.Group("/export")
{
// 用户参与记录导出
exportGroup.POST("/record", api.Export.ExportUserRecord)
}
}
+106 -57
View File
@@ -63,21 +63,109 @@ func (r *UserService) HandleUserImage(wxAvatar string) (ossPath string, err erro
// ReportUserScore 发放积分
// scoreType : 积分类型(1:完成阅读 2:阅读时间满足 3:优质留言 4:再次优质留言 )
func (r *UserService) ReportUserScore(tx *gorm.DB, projectId, caseId, platformId int64, scoreType int, user *model.User) (err error) {
func (r *UserService) ReportUserScore(tx *gorm.DB, projectId, caseId, platformId int64, scoreType int, user *model.User) (reportPlatformId int64, reportUser *model.User, err error) {
maps := make(map[string]interface{})
// // 获取项目关联平台
// projectPlatformDao := dao.ProjectPlatformDao{}
// maps["project_id"] = projectId
// maps["platform_id"] = platformId
// projectPlatform, err := projectPlatformDao.GetProjectPlatform(maps)
// if err != nil {
// return err
// }
// // 检测福利开关
// if projectPlatform.IsWelfare == 0 {
// // 福利未开
// return nil
// }
// // 获取需发放积分
// score := 0
// appScoreTypeStr := "" // 积分发放原因-app
// superScoreTypeStr := "" // 积分发放原因-超级袋鼠
// nodeName := "" // 获取积分节点名称
// if scoreType == 1 {
// // 完成阅读
// score = projectPlatform.CompleteRead
// appScoreTypeStr = "互动病例-完成阅读"
// superScoreTypeStr = "调研奖励(完成阅读)"
// nodeName = "学习"
// } else if scoreType == 2 {
// // 阅读时间满足
// score = projectPlatform.CompleteReadTime
// appScoreTypeStr = "互动病例-阅读时间满足"
// superScoreTypeStr = "调研奖励(阅读质量)"
// nodeName = "阅读达标"
// } else if scoreType == 3 {
// // 优质留言
// score = projectPlatform.FirstHighQuality
// appScoreTypeStr = "互动病例-优质留言"
// superScoreTypeStr = "调研奖励(社区贡献)"
// nodeName = "优质留言"
// } else if scoreType == 4 {
// // 再次优质留言
// score = projectPlatform.OnceMoreHighQuality
// appScoreTypeStr = "互动病例-优质留言"
// superScoreTypeStr = "调研奖励(社区贡献)"
// nodeName = "优质留言"
// }
recordScoreDao := dao.RecordScoreDao{}
// 检测是否有相同手机号用户
userDao := dao.UserDao{}
maps = make(map[string]interface{})
maps["mobile_encryption"] = user.MobileEncryption
users, err := userDao.GetUserList(maps)
if err != nil {
return platformId,user,nil
}
for _, m := range users {
// 检测积分是否已在其他平台发放过
maps = make(map[string]interface{})
maps["project_id"] = projectId
maps["case_id"] = caseId
maps["user_id"] = m.UserId
recordScore, _ := recordScoreDao.GetRecordScoreUseTx(tx, maps)
if recordScore != nil {
if recordScore.PlatformId != platformId {
// 由其他平台进行发放积分 修改平台id为其他平台id
platformId = recordScore.PlatformId
user = m
}
}
// 检测该类型积分是否已经发放(其他平台也算)
maps = make(map[string]interface{})
maps["project_id"] = projectId
maps["case_id"] = caseId
maps["platform_id"] = platformId
maps["user_id"] = m.UserId
maps["type"] = scoreType
recordScore, _ = recordScoreDao.GetRecordScore(maps)
if recordScore != nil {
// 积分已发放过
return platformId,user,nil
}
}
// 获取项目关联平台
projectPlatformDao := dao.ProjectPlatformDao{}
maps := make(map[string]interface{})
maps = make(map[string]interface{})
maps["project_id"] = projectId
maps["platform_id"] = platformId
projectPlatform, err := projectPlatformDao.GetProjectPlatform(maps)
if err != nil {
return err
return platformId,user,err
}
// 检测福利开关
if projectPlatform.IsWelfare == 0 {
// 福利未开
return nil
return platformId,user,nil
}
// 获取需发放积分
@@ -111,53 +199,14 @@ func (r *UserService) ReportUserScore(tx *gorm.DB, projectId, caseId, platformId
nodeName = "优质留言"
}
recordScoreDao := dao.RecordScoreDao{}
// 检测是否有相同手机号用户
userDao := dao.UserDao{}
maps = make(map[string]interface{})
maps["mobile_encryption"] = user.MobileEncryption
users, err := userDao.GetUserList(maps)
if err != nil {
return nil
}
for _, m := range users {
// 检测积分是否已在其他平台发放过
maps = make(map[string]interface{})
maps["project_id"] = projectId
maps["case_id"] = caseId
maps["user_id"] = m.UserId
recordScore, _ := recordScoreDao.GetRecordScoreUseTx(tx, maps)
if recordScore != nil {
if recordScore.PlatformId != platformId {
// 由其他平台进行发放积分 修改平台id为其他平台id
platformId = recordScore.PlatformId
user = m
}
}
// 检测该类型积分是否已经发放(其他平台也算)
maps = make(map[string]interface{})
maps["project_id"] = projectId
maps["case_id"] = caseId
maps["platform_id"] = platformId
maps["user_id"] = m.UserId
maps["type"] = scoreType
recordScore, _ = recordScoreDao.GetRecordScore(maps)
if recordScore != nil {
// 积分已发放过
return nil
}
}
// 默认为白名单用户
isWhite := true
if projectPlatform.IsWhite == 1 {
projectPlatformWhiteService := ProjectPlatformWhiteService{}
isWhite, err = projectPlatformWhiteService.CheckProjectPlatformWhiteByUser(user, projectId, platformId)
if err != nil {
return err
return platformId,user,err
}
}
@@ -174,14 +223,14 @@ func (r *UserService) ReportUserScore(tx *gorm.DB, projectId, caseId, platformId
maps["platform_id"] = platformId
casePlatform, err := casePlatformDao.GetCasePlatform(maps)
if err != nil {
return err
return platformId,user,err
}
// 检测全部积分是否已发放完毕
remainingScore := projectPlatform.SingleCaseScore - casePlatform.IssuedScore
if remainingScore <= 0 {
// 积分已发放完毕
return nil
return platformId,user,nil
}
// 新增发放记录-每发一次记录一次
@@ -198,7 +247,7 @@ func (r *UserService) ReportUserScore(tx *gorm.DB, projectId, caseId, platformId
recordScore, err = recordScoreDao.AddRecordScore(tx, recordScore)
if err != nil {
return err
return platformId,user,err
}
// 获取用户参与记录
@@ -209,38 +258,38 @@ func (r *UserService) ReportUserScore(tx *gorm.DB, projectId, caseId, platformId
maps["user_id"] = user.UserId
caseUser, _ := caseUserDao.GetCaseUserUseTx(tx, maps)
if caseUser == nil {
return errors.New("用户还未完成该病例阅读,请稍后再试")
return platformId,user,errors.New("用户还未完成该病例阅读,请稍后再试")
}
// 累计用户领取积分数据
err = caseUserDao.Inc(tx, caseUser.CaseUserId, "total_score", score)
if err != nil {
return err
return platformId,user,err
}
// 累计平台发放积分数据
err = casePlatformDao.Inc(tx, casePlatform.CasePlatformId, "issued_score", score)
if err != nil {
return err
return platformId,user,err
}
// 累计发放积分数据
caseDao := dao.CaseDao{}
err = caseDao.Inc(tx, caseId, "issued_score", score)
if err != nil {
return err
return platformId,user,err
}
// 发放积分-
if platformId != 1 && platformId != 2 {
return errors.New("积分发放失败")
return platformId,user,errors.New("积分发放失败")
}
// 肝胆相照
if platformId == 1 && score > 0 {
_, err = app.ReportUserScore(appScoreTypeStr, user.UserIden, score)
if err != nil {
return err
return platformId,user,err
}
}
@@ -250,16 +299,16 @@ func (r *UserService) ReportUserScore(tx *gorm.DB, projectId, caseId, platformId
caseDao := dao.CaseDao{}
result, err := caseDao.GetCaseById(caseId)
if err != nil {
return err
return platformId,user,err
}
_, err = superKangaroo.ReportUserScore(caseId, user.UserIden, superScoreTypeStr, recordScore, result)
if err != nil {
return err
return platformId,user,err
}
}
return nil
return platformId,user,nil
}
// ReportCaseRecord 上报用户参与情况-只上报优质留言
+107
View File
@@ -49,6 +49,20 @@ type StatsCaseUserData struct {
EndTime string // 结束参与时间
}
// UserRecordData 用户参与记录
type UserRecordData struct {
Id string // id标识
CaseName string // 病历名称
UserName string // 姓名
Province string // 省份
UserMobile string // 手机号
DoctorTitle string // 职称
HospitalName string // 医院
DepartmentName string // 科室
PlatformName string // 平台名称
OperateTime string // 操作时间
}
// ProjectPlatformHospital 医院白名单
func (r *ExportService) ProjectPlatformHospital(projectPlatformHospitals []*model.ProjectPlatformHospital) (string, error) {
header := []utils.HeaderCellData{
@@ -250,3 +264,96 @@ func (r *ExportService) StatsCaseUser(statsCaseUsers []*model.CaseUser) (string,
ossPath = utils.AddOssDomain("/" + ossPath)
return ossPath, nil
}
// ExportUserRecord 用户参与记录导出
func (r *ExportService) ExportUserRecord(userBehaviorRecords []*model.UserBehaviorRecord) (string, error) {
header := []utils.HeaderCellData{
{Value: "id标识", CellType: "string", NumberFmt: "", ColWidth: 25},
{Value: "病历名称", CellType: "string", NumberFmt: "", ColWidth: 50},
{Value: "姓名", CellType: "string", NumberFmt: "", ColWidth: 25},
{Value: "省份", CellType: "string", NumberFmt: "", ColWidth: 25},
{Value: "手机号", CellType: "string", NumberFmt: "", ColWidth: 18},
{Value: "职称", CellType: "string", NumberFmt: "", ColWidth: 18},
{Value: "医院", CellType: "string", NumberFmt: "", ColWidth: 35},
{Value: "科室", CellType: "string", NumberFmt: "", ColWidth: 18},
{Value: "平台名称", CellType: "string", NumberFmt: "", ColWidth: 18},
{Value: "操作时间", CellType: "date", NumberFmt: "yyyy-mm-dd hh:mm:ss", ColWidth: 30},
}
var dataSlice []interface{}
for _, v := range userBehaviorRecords {
var createdAt string
if v.CreatedAt != (model.LocalTime{}) {
createdAt = time.Time(v.StartTime).Format("2006-01-02 15:04:05")
}
userRecordData := UserRecordData{
Id: fmt.Sprintf("%d", v.RecordId),
CaseName: "",
UserName: "",
Province: "",
UserMobile: "",
DoctorTitle: "",
HospitalName: "",
DepartmentName: "",
PlatformName: "",
OperateTime: createdAt,
}
// 加载数据-平台名称
if v.Platform != nil {
userRecordData.PlatformName = v.Platform.PlatformName
}
if v.Case != nil {
userRecordData.CaseName = v.Case.CaseName
}
if v.User != nil {
// 加载数据-手机号
userRecordData.UserMobile = v.User.UserMobile
// 加载数据-科室
userRecordData.DepartmentName = v.User.DepartmentName
// 加载数据-职称
userRecordData.DoctorTitle = utils.DoctorTitleToString(v.User.Title)
// 加载数据-用户名称
userRecordData.UserName = v.User.UserName
// 加载数据-省份
if v.User.Hospital != nil {
userRecordData.Province = v.User.Hospital.Province
userRecordData.HospitalName = v.User.Hospital.HospitalName
}
}
dataSlice = append(dataSlice, userRecordData)
}
file, err := utils.Export(header, dataSlice)
if err != nil {
return "", err
}
ossPath := "dev/"
if config.C.Env == "prod" {
ossPath = "prod/"
}
// 设置文件名字
now := time.Now()
dateTimeString := now.Format("20060102150405") // 当前时间字符串
rand.New(rand.NewSource(time.Now().UnixNano())) // 设置随机数
ossPath = ossPath + "export/用户参与记录" + dateTimeString + fmt.Sprintf("%d", rand.Intn(9000)+1000) + ".xlsx"
// 上传oss
_, err = aliyun.PutObjectByte(ossPath, file.Bytes())
if err != nil {
return "", err
}
ossPath = utils.AddOssDomain("/" + ossPath)
return ossPath, nil
}