(event *QueueEvent)
| 71 | } |
| 72 | |
| 73 | func processSingleEvent(event *QueueEvent) { |
| 74 | switch event.status { |
| 75 | case NEW_ALARM: |
| 76 | lastID, _ := mydb.CreateStrategyEvent(event.strategy_event, event.trigger_events) |
| 77 | event.strategy_event.ID = lastID |
| 78 | go doAlarmAction(event.strategy_event, event.trigger_events) |
| 79 | case OLD_ALARM: |
| 80 | mydb.UpdateStrategyEvent(event.strategy_event, event.trigger_events) |
| 81 | go doAlarmAction(event.strategy_event, event.trigger_events) |
| 82 | case RESTORE_ALARM: |
| 83 | mydb.UpdateStrategyEvent(event.strategy_event, event.trigger_events) |
| 84 | mydb.CreateStrategyEventProcess(event.strategy_event.ID, event.strategy_event.Status, "系统", "报警恢复", time.Now().Format("2006-01-02 15:04:05")) |
| 85 | go doRestoreAction(event.strategy_event, event.trigger_events) |
| 86 | event.strategy_event.Count++ |
| 87 | default: |
| 88 | lg.Error(fmt.Sprintf("unknow event type %d from event queue.", event.status)) |
| 89 | } |
| 90 | mydb.CreateStrategyEventRecord(event.strategy_event, event.trigger_events) |
| 91 | } |
| 92 | |
| 93 | //发送报警 |
| 94 | func doAlarmAction(strategy_event *types.StrategyEvent, trigger_events map[string]*types.TriggerEvent) { |
no test coverage detected