Method CreateStrategyEvent

controller/mysql.go:127–193

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

}

func (this *db) CreateStrategyEvent(strategy_event *types.StrategyEvent, trigger_events map[string]*types.TriggerEvent) (int64, error) {
	tx, err := this.Begin()
	defer tx.Rollback()
	if err != nil {
		lg.Error(err.Error())
		return -1, err
	}
	stmt, err := tx.Prepare("INSERT INTO `strategy_event` VALUES (DEFAULT, ?, ?, ?, ?, ?, ?, ?, ?, ?, DEFAULT, ?, ?, ?, ?, ?)")
	if err != nil {
		lg.Error(err.Error())
		return -1, err
	}

	result, err := stmt.Exec(
		strategy_event.ProductID,
		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.Count,
		strategy_event.Status,
		strategy_event.HostID,
		strategy_event.HostName,
		strategy_event.IP)
	if err != nil {
		lg.Error(err.Error())
		return -1, err
	}

	last_id, err := result.LastInsertId()
	if err != nil {
		lg.Error(err.Error())
		return -1, err
	}

	for _, trigger_event := range trigger_events {
		stmt_insert, err := tx.Prepare("INSERT INTO `trigger_event` VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)")
		if err != nil {
			lg.Error(err.Error())
			return -1, err
		}
		_, err = stmt_insert.Exec(
			last_id,
			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 {