gdxz/case-admin-api
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: gdxz:88a884b6ffc41c14befdb6ced324aa4263112b45
Branches Tags
gdxz:master
gdxz:dev
..
compare: gdxz:2f975671f22f35a067e1541aa0deff48faab90dd
Branches Tags
gdxz:dev
gdxz:master

No commits in common. "88a884b6ffc41c14befdb6ced324aa4263112b45" and "2f975671f22f35a067e1541aa0deff48faab90dd" have entirely different histories.
88a884b6ff ... 2f975671f2

7 changed files with 0 additions and 400 deletions
Show Stats Expand all files Collapse all files

1
api/controller/Base.go
View File

@ -16,5 +16,4 @@ type Api struct {
StatsCase // 统计数据-病例 StatsCase // 统计数据-病例
Platform // 平台 Platform // 平台
CaseComment // 病例-评论 CaseComment // 病例-评论
Export // 导出
} }

52
api/controller/Export.go
View File

@ -1,52 +0,0 @@
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
api/dao/UserBehaviorRecord.go
View File

@ -1,215 +0,0 @@
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
api/model/UserBehaviorRecord.go
View File

@ -16,9 +16,6 @@ type UserBehaviorRecord struct {
StartTime LocalTime `gorm:"column:start_time;type:datetime;comment:开始时间" json:"start_time"` StartTime LocalTime `gorm:"column:start_time;type:datetime;comment:开始时间" json:"start_time"`
EndTime LocalTime `gorm:"column:end_time;type:datetime;comment:结束时间" json:"end_time"` EndTime LocalTime `gorm:"column:end_time;type:datetime;comment:结束时间" json:"end_time"`
Model 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 { func (m *UserBehaviorRecord) TableName() string {

15
api/requests/Export.go
View File

@ -1,15 +0,0 @@
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
api/router/router.go
View File

@ -355,11 +355,4 @@ func privateRouter(r *gin.Engine, api controller.Api) {
editorGroup.POST("", api.Editor.EditorUpload) editorGroup.POST("", api.Editor.EditorUpload)
} }
} }
// 导出
exportGroup := adminGroup.Group("/export")
{
// 用户参与记录导出
exportGroup.POST("/record", api.Export.ExportUserRecord)
}
} }

107
api/service/export.go
View File

@ -49,20 +49,6 @@ type StatsCaseUserData struct {
EndTime string // 结束参与时间 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 医院白名单 // ProjectPlatformHospital 医院白名单
func (r *ExportService) ProjectPlatformHospital(projectPlatformHospitals []*model.ProjectPlatformHospital) (string, error) { func (r *ExportService) ProjectPlatformHospital(projectPlatformHospitals []*model.ProjectPlatformHospital) (string, error) {
header := []utils.HeaderCellData{ header := []utils.HeaderCellData{
@ -264,96 +250,3 @@ func (r *ExportService) StatsCaseUser(statsCaseUsers []*model.CaseUser) (string,
ossPath = utils.AddOssDomain("/" + ossPath) ossPath = utils.AddOssDomain("/" + ossPath)
return ossPath, nil 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: 35},
{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.Platform.PlatformName
}
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
}