Method CreateStrategyEventRecord

controller/mysql.go:340–402

(strategy_event *types.StrategyEvent, trigger_events map[string]*types.TriggerEvent)

}

func (this *db) CreateStrategyEventRecord(strategy_event *types.StrategyEvent, trigger_events map[string]*types.TriggerEvent) error {
	tx, err := this.Begin()
	defer tx.Rollback()
	if err != nil {
		lg.Error(err.Error())
		return err
	}
	stmt, err := tx.Prepare("INSERT INTO `strategy_event_record` VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)")
	if err != nil {
		lg.Error(err.Error())
		return err
	}
	_, err = stmt.Exec(
		strategy_event.ID,
		strategy_event.Count,
		strategy_event.StrategyID,
		strategy_event.StrategyName,
		strategy_event.Priority,
		strategy_event.Cycle,
		strategy_event.AlarmCount,
		strategy_event.Expression,
		strategy_event.CreateTime,
		strategy_event.UpdateTime,
		strategy_event.AwareEndTime,
		strategy_event.Status,
		strategy_event.HostID,
		strategy_event.HostName,
		strategy_event.IP)
	if err != nil {
		lg.Error(err.Error())
		return err
	}

	for _, trigger_event := range trigger_events {
		stmt_insert, err := tx.Prepare("INSERT INTO `trigger_event_record` VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)")
		if err != nil {
			lg.Error(err.Error())
			return err
		}
		_, err = stmt_insert.Exec(
			strategy_event.ID,
			strategy_event.Count,
			trigger_event.Index,
			trigger_event.Metric,
			trigger_event.Tags,
			trigger_event.Number,
			trigger_event.AggregateTags,
			trigger_event.CurrentThreshold,
			trigger_event.Method,
			trigger_event.Symbol,
			trigger_event.Threshold,
			trigger_event.Triggered)
		if err != nil {
			lg.Error(err.Error())
			return err
		}

	}