增加导出日志

api/controller/export.go

@@ -3,6 +3,7 @@ package controller
 import (
 	"github.com/gin-gonic/gin"
 	"hospital-admin-api/api/dao"
+	"hospital-admin-api/api/model"
 	"hospital-admin-api/api/requests"
 	"hospital-admin-api/api/responses"
 	"hospital-admin-api/api/service"
@@ -44,6 +45,20 @@ func (r *Export) DoctorWithdrawal(c *gin.Context) {
 		return
 	}
 
+	// 获取当前登陆用户id
+	userId := c.GetInt64("UserId")
+	if userId != 0 {
+		// 记录日志
+		logExport := &model.LogExport{
+			AdminUserId:  userId,
+			ExportModule: "提现记录",
+			ExportFile:   utils.RemoveOssDomain(ossAddress),
+		}
+
+		logExportDao := dao.LogExportDao{}
+		_, _ = logExportDao.AddLogExportUnTransaction(logExport)
+	}
+
 	responses.OkWithData(ossAddress, c)
 }
 
@@ -78,6 +93,20 @@ func (r *Export) DoctorWithdrawalOrder(c *gin.Context) {
 		return
 	}
 
+	// 获取当前登陆用户id
+	userId := c.GetInt64("UserId")
+	if userId != 0 {
+		// 记录日志
+		logExport := &model.LogExport{
+			AdminUserId:  userId,
+			ExportModule: "提现记录-关联订单",
+			ExportFile:   utils.RemoveOssDomain(ossAddress),
+		}
+
+		logExportDao := dao.LogExportDao{}
+		_, _ = logExportDao.AddLogExportUnTransaction(logExport)
+	}
+
 	responses.OkWithData(ossAddress, c)
 }
 
@@ -114,6 +143,20 @@ func (r *Export) UserDoctor(c *gin.Context) {
 		return
 	}
 
+	// 获取当前登陆用户id
+	userId := c.GetInt64("UserId")
+	if userId != 0 {
+		// 记录日志
+		logExport := &model.LogExport{
+			AdminUserId:  userId,
+			ExportModule: "医生列表",
+			ExportFile:   utils.RemoveOssDomain(ossAddress),
+		}
+
+		logExportDao := dao.LogExportDao{}
+		_, _ = logExportDao.AddLogExportUnTransaction(logExport)
+	}
+
 	responses.OkWithData(ossAddress, c)
 }
 
@@ -149,6 +192,20 @@ func (r *Export) UserDoctorBankCard(c *gin.Context) {
 		return
 	}
 
+	// 获取当前登陆用户id
+	userId := c.GetInt64("UserId")
+	if userId != 0 {
+		// 记录日志
+		logExport := &model.LogExport{
+			AdminUserId:  userId,
+			ExportModule: "医生银行卡列表",
+			ExportFile:   utils.RemoveOssDomain(ossAddress),
+		}
+
+		logExportDao := dao.LogExportDao{}
+		_, _ = logExportDao.AddLogExportUnTransaction(logExport)
+	}
+
 	responses.OkWithData(ossAddress, c)
 }
 
@@ -183,6 +240,20 @@ func (r *Export) DoctorAccount(c *gin.Context) {
 		return
 	}
 
+	// 获取当前登陆用户id
+	userId := c.GetInt64("UserId")
+	if userId != 0 {
+		// 记录日志
+		logExport := &model.LogExport{
+			AdminUserId:  userId,
+			ExportModule: "医生账户",
+			ExportFile:   utils.RemoveOssDomain(ossAddress),
+		}
+
+		logExportDao := dao.LogExportDao{}
+		_, _ = logExportDao.AddLogExportUnTransaction(logExport)
+	}
+
 	responses.OkWithData(ossAddress, c)
 }
 
@@ -217,6 +288,20 @@ func (r *Export) OrderInquiryForAccount(c *gin.Context) {
 		return
 	}
 
+	// 获取当前登陆用户id
+	userId := c.GetInt64("UserId")
+	if userId != 0 {
+		// 记录日志
+		logExport := &model.LogExport{
+			AdminUserId:  userId,
+			ExportModule: "医生账户-关联订单",
+			ExportFile:   utils.RemoveOssDomain(ossAddress),
+		}
+
+		logExportDao := dao.LogExportDao{}
+		_, _ = logExportDao.AddLogExportUnTransaction(logExport)
+	}
+
 	responses.OkWithData(ossAddress, c)
 }
 
@@ -251,6 +336,20 @@ func (r *Export) UserPatient(c *gin.Context) {
 		return
 	}
 
+	// 获取当前登陆用户id
+	userId := c.GetInt64("UserId")
+	if userId != 0 {
+		// 记录日志
+		logExport := &model.LogExport{
+			AdminUserId:  userId,
+			ExportModule: "患者列表",
+			ExportFile:   utils.RemoveOssDomain(ossAddress),
+		}
+
+		logExportDao := dao.LogExportDao{}
+		_, _ = logExportDao.AddLogExportUnTransaction(logExport)
+	}
+
 	responses.OkWithData(ossAddress, c)
 }
 
@@ -285,6 +384,20 @@ func (r *Export) PatientFamily(c *gin.Context) {
 		return
 	}
 
+	// 获取当前登陆用户id
+	userId := c.GetInt64("UserId")
+	if userId != 0 {
+		// 记录日志
+		logExport := &model.LogExport{
+			AdminUserId:  userId,
+			ExportModule: "就诊人列表",
+			ExportFile:   utils.RemoveOssDomain(ossAddress),
+		}
+
+		logExportDao := dao.LogExportDao{}
+		_, _ = logExportDao.AddLogExportUnTransaction(logExport)
+	}
+
 	responses.OkWithData(ossAddress, c)
 }
 
@@ -320,6 +433,20 @@ func (r *Export) OrderInquiry(c *gin.Context) {
 		return
 	}
 
+	// 获取当前登陆用户id
+	userId := c.GetInt64("UserId")
+	if userId != 0 {
+		// 记录日志
+		logExport := &model.LogExport{
+			AdminUserId:  userId,
+			ExportModule: "问诊订单",
+			ExportFile:   utils.RemoveOssDomain(ossAddress),
+		}
+
+		logExportDao := dao.LogExportDao{}
+		_, _ = logExportDao.AddLogExportUnTransaction(logExport)
+	}
+
 	responses.OkWithData(ossAddress, c)
 }
 
@@ -355,6 +482,20 @@ func (r *Export) OrderProduct(c *gin.Context) {
 		return
 	}
 
+	// 获取当前登陆用户id
+	userId := c.GetInt64("UserId")
+	if userId != 0 {
+		// 记录日志
+		logExport := &model.LogExport{
+			AdminUserId:  userId,
+			ExportModule: "药品订单",
+			ExportFile:   utils.RemoveOssDomain(ossAddress),
+		}
+
+		logExportDao := dao.LogExportDao{}
+		_, _ = logExportDao.AddLogExportUnTransaction(logExport)
+	}
+
 	responses.OkWithData(ossAddress, c)
 }
 
@@ -389,5 +530,19 @@ func (r *Export) OrderPrescription(c *gin.Context) {
 		return
 	}
 
+	// 获取当前登陆用户id
+	userId := c.GetInt64("UserId")
+	if userId != 0 {
+		// 记录日志
+		logExport := &model.LogExport{
+			AdminUserId:  userId,
+			ExportModule: "处方",
+			ExportFile:   utils.RemoveOssDomain(ossAddress),
+		}
+
+		logExportDao := dao.LogExportDao{}
+		_, _ = logExportDao.AddLogExportUnTransaction(logExport)
+	}
+
 	responses.OkWithData(ossAddress, c)
 }

api/dao/logExport.go

@@ -0,0 +1,51 @@
+package dao
+
+import (
+	"gorm.io/gorm"
+	"hospital-admin-api/api/model"
+	"hospital-admin-api/global"
+)
+
+type LogExportDao struct {
+}
+
+func (r *LogExportDao) GetLogExportListByPhone(adminUserId int64) (m []*model.LogExport, err error) {
+	err = global.Db.Where("admin_user_id = ?", adminUserId).Find(&m).Error
+	if err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+// AddLogExport 新增导出
+func (r *LogExportDao) AddLogExport(tx *gorm.DB, model *model.LogExport) (*model.LogExport, error) {
+	if err := tx.Create(model).Error; err != nil {
+		return nil, err
+	}
+	return model, nil
+}
+
+// AddLogExportUnTransaction 新增导出-无事物
+func (r *LogExportDao) AddLogExportUnTransaction(model *model.LogExport) (*model.LogExport, error) {
+	if err := global.Db.Create(model).Error; err != nil {
+		return nil, err
+	}
+	return model, nil
+}
+
+// GetLogExportList 获取导出列表
+func (r *LogExportDao) GetLogExportList(maps interface{}) (m []*model.LogExport, err error) {
+	err = global.Db.Where(maps).Find(&m).Error
+	if err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+// DeleteLogExportById 删除导出-导出id
+func (r *LogExportDao) DeleteLogExportById(tx *gorm.DB, logId int64) error {
+	if err := tx.Delete(&model.LogExport{}, logId).Error; err != nil {
+		return err
+	}
+	return nil
+}

api/model/logExport.go

@@ -0,0 +1,33 @@
+package model
+
+import (
+	"gorm.io/gorm"
+	"hospital-admin-api/global"
+	"time"
+)
+
+type LogExport struct {
+	ExportId     int64  `gorm:"column:export_id;type:bigint(19);primary_key;comment:主键id" json:"export_id"`
+	AdminUserId  int64  `gorm:"column:admin_user_id;type:bigint(19);comment:后台用户id" json:"admin_user_id"`
+	ExportModule string `gorm:"column:export_module;type:varchar(255);comment:导出模块" json:"export_module"`
+	ExportFile   string `gorm:"column:export_file;type:varchar(255);comment:导出文件名称" json:"export_file"`
+	Model
+}
+
+func (m *LogExport) TableName() string {
+	return "gdxz_log_export"
+}
+
+func (m *LogExport) BeforeCreate(tx *gorm.DB) error {
+	if m.ExportId == 0 {
+		m.ExportId = global.Snowflake.Generate().Int64()
+	}
+
+	m.CreatedAt = LocalTime(time.Now())
+	tx.Statement.SetColumn("CreatedAt", m.CreatedAt)
+
+	m.UpdatedAt = LocalTime(time.Now())
+	tx.Statement.SetColumn("UpdatedAt", m.UpdatedAt)
+
+	return nil
+}