eta_api/services/data/data_manage_permission/message.go

package data_manage_permission

import (
	"eta/eta_api/models/data_manage/data_manage_permission"
	"eta/eta_api/utils"
)

type MessageDetailItem struct {
	DataPermissionMoveRecordId int64  ` orm:"column(data_permission_move_record_id);pk"` // 数据操作记录id
	Source                     int32  // 数据来源，1：手工数据指标 2：钢联化工数据库 3：ETA指标库 4：ETA预测指标 5：图库 6：ETA表格
	SubSource                  int32  // 子来源 ：ETA表格中的各种表格类型，以及图表的来源（这个是后续的扩展方向）
	OpUniqueCode               string // 操作的唯一编码，主要是记录统一操作的日志
	DataId                     string // 资产id（指标、图表、表格）
	DataCode                   string // 资产code（指标、图表、表格）
	DataName                   string // 资产名称（指标、图表、表格）
	OriginalUserId             int32  // 原创建人id
	OriginalUserName           string // 原创建人名称
	NewUserId                  int32  // 新创建人id
	NewUserName                string // 新创建人名称
	CreateTime                 string
}

// GetMessageDetail
// @Description: 获取消息详情
// @author: Roc
// @datetime 2024-04-07 10:07:06
// @param messageInfo *data_manage_permission.DataPermissionMessage
// @param source int
// @param subSource int
// @param startSize int
// @param pageSize int
// @return resp interface{}
// @return err error
func GetMessageDetail(messageInfo *data_manage_permission.DataPermissionMessage, source, subSource, startSize, pageSize int) (total int, resp interface{}, err error) {
	switch messageInfo.OpType {
	// 操作类型，1：单个资产转移，2：资产模块转移，3：资产授权，4：资产分类授权
	case 1, 2:
		tmpTotal, list, tmpErr := data_manage_permission.GetListByOpUniqueCode(messageInfo.OpUniqueCode, source, subSource, startSize, pageSize)
		if tmpErr != nil {
			err = tmpErr
			return
		}
		total = tmpTotal
		resp, err = formatMessageDetailItem(list)

	}

	return
}

func formatMessageDetailItem(items []*data_manage_permission.DataPermissionMoveRecord) (resp []*MessageDetailItem, err error) {
	resp = make([]*MessageDetailItem, 0)
	for _, v := range items {
		resp = append(resp, &MessageDetailItem{
			DataPermissionMoveRecordId: v.DataPermissionMoveRecordId,
			Source:                     v.Source,
			SubSource:                  v.SubSource,
			OpUniqueCode:               v.OpUniqueCode,
			DataId:                     v.DataId,
			DataCode:                   v.DataCode,
			DataName:                   v.DataName,
			OriginalUserId:             v.OriginalUserId,
			OriginalUserName:           v.OriginalUserName,
			NewUserId:                  v.NewUserId,
			NewUserName:                v.NewUserName,
			CreateTime:                 utils.TimeTransferString(utils.FormatDateTime, v.CreateTime),
		})
	}

	return
}