add log

liuxiaolong

2019-10-10 974a818237c989fa7e4a5accaf848c49f97a5ca0

add log

 agent.go

@@ -135,11 +135,10 @@
            }
            if sqlUe.Owner != a.conf.NodeName {

                evTime := uint64(ev.LTime)
                logger.Info("ev.LTime:",evTime,",SqlUserEvent.sql:",sqlUe.Sql)
                flag, e := ExecuteSqlByGorm(sqlUe.Sql)

                flag, _ := ExecuteSqlByGorm(sqlUe.Sql)
                logger.Info("userEvent exec ",sqlUe.Sql,",Result:",flag)
                evTime := uint64(ev.LTime)
                logger.Info("ev.LTime:",evTime,"userEvent exec ",sqlUe.Sql,",Result:",flag,", err:",e)
            }
        } else if ev.Name == UserEventSyncDbTablePersonCache {
            logger.Info("LTime:",ev.LTime,",ev.Payload.len:",len(ev.Payload))
@@ -517,19 +516,25 @@
    wg.Add(1)
    go func() {
        defer wg.Done()
        respCh := resp.ResponseCh()
        //respCh := resp.ResponseCh()
        for {
            select {
            case r := <-respCh:
                logger.Info("Query response's len:", len(r.Payload))
                err := json.Unmarshal(r.Payload, &dumpSqls)
                if err ==nil {
                    logger.Error("dumpSql:",dumpSqls)
                    logger.Error("data dump success")
                }
                return
            //case r := <-respCh:
            //    logger.Info("Query response's len:", len(r.Payload))
            //    err := json.Unmarshal(r.Payload, &dumpSqls)
            //    if err ==nil {
            //        logger.Error("dumpSql:",dumpSqls)
            //        logger.Error("data dump success")
            //    }
            //    return
            case msg := <-QueryTcpResponseChan:
                logger.Debug("QueryTcpResponseChan receive msg len:",len(msg))
                err := json.Unmarshal(msg, &dumpSqls)
                if err ==nil {
                    logger.Error("dumpSql success:",dumpSqls)
                } else {
                    logger.Error("data dump err:",err)
                }
                return
            }


 userDelegate.go

@@ -31,7 +31,7 @@
    if err == nil {
        logger.Debug("dumpSqls:", dumpSqls)
    } else {
        logger.Error("UserDelete unmarshal msg to dumpSqls err:",err)
        logger.Error("UserDelegate unmarshal msg to dumpSqls err:",err)
    }
}