Method UpdateStrategyEvent

controller/mysql.go:204–270

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

}

func (this *db) UpdateStrategyEvent(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("UPDATE `strategy_event` SET `strategy_name` = ?, `priority` = ?, `cycle` = ?, `alarm_count` = ?, `expression` = ?, `update_time` = ?, `count` = ?, `status` = ?, `host_id` = ?, `host_name` = ?, `ip` = ? WHERE `id` = ?")
	if err != nil {
		lg.Error(err.Error())
		return err
	}

	_, err = stmt.Exec(
		strategy_event.StrategyName,
		strategy_event.Priority,
		strategy_event.Cycle,
		strategy_event.AlarmCount,
		strategy_event.Expression,
		strategy_event.UpdateTime,
		strategy_event.Count,
		strategy_event.Status,
		strategy_event.HostID,
		strategy_event.HostName,
		strategy_event.IP,
		strategy_event.ID)
	if err != nil {
		lg.Error(err.Error())
		return err
	}

	stmt_delete, err := tx.Prepare("DELETE FROM `trigger_event` WHERE `strategy_event_id` = ?")
	_, err = stmt_delete.Exec(strategy_event.ID)
	if err != nil {
		lg.Error(err.Error())
		return 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 err
		}
		_, err = stmt_insert.Exec(
			strategy_event.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 {
			lg.Error(err.Error())