|
|
@@ -1,6 +1,8 @@
|
|
|
package binlog
|
|
|
|
|
|
import (
|
|
|
+ "encoding/json"
|
|
|
+ "eta/eta_api/services/alarm_msg"
|
|
|
edbmonitorSvr "eta/eta_api/services/edb_monitor"
|
|
|
"eta/eta_api/utils"
|
|
|
"fmt"
|
|
|
@@ -107,11 +109,15 @@ func (h *EdbEventHandler) Update(e *canal.RowsEvent) error {
|
|
|
}
|
|
|
edbInfo := h.MapRowToStruct(e.Table.Columns, e.Rows[1])
|
|
|
if ok := edbmonitorSvr.EdbLocalSet.IsExist(edbInfo.EdbInfoId); ok {
|
|
|
+ sendBody, _ := json.Marshal(edbInfo)
|
|
|
+ alarm_msg.SendAlarmMsg(string(sendBody), 1)
|
|
|
err := utils.Rc.LPush(edbmonitorSvr.EDB_MONITOR_HANDLE_LIST_CACHE, edbInfo)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
} else {
|
|
|
+ sendBody, _ := json.Marshal(edbInfo)
|
|
|
+ alarm_msg.SendAlarmMsg(string(sendBody), 1)
|
|
|
ok, err := utils.Rc.SIsMember(edbmonitorSvr.EDB_MONITOR_ID_SET_CACHE, edbInfo)
|
|
|
if err != nil {
|
|
|
return err
|
zqbao