FranklinWH-Toolbox/service/repositories/pgsql/alarmSnapshot/siteAlarmSnapshotData.go

package alarmSnapshot

import (
	"context"
	"fwh-toolbox-server/models/model_pgsql/model_alarm_snapshot"
	"fwh-toolbox-server/models/model_pgsql/query_alarm_snapshot"
	"time"

	"go.uber.org/zap"
	"gorm.io/gorm/clause"
)

type SnapshotData = model_alarm_snapshot.SiteAlarmSnapshotData

func InsertSnapshotData(c context.Context, data *SnapshotData) error {
	ctx, cancel := context.WithTimeout(c, 5*time.Second)
	defer cancel()

	SnapshotDataModel := query_alarm_snapshot.SiteAlarmSnapshotData
	err := SnapshotDataModel.WithContext(ctx).Clauses(clause.OnConflict{
		UpdateAll: true,
	}).Create(data)
	if err != nil {
		zap.L().Error("文件解析记录数据库创建失败", zap.String("err", err.Error()))
		return err
	}

	return nil
}