|
|
@@ -254,6 +254,7 @@ func SyncIndex(cont context.Context) (err error) {
|
|
|
var currLogId int64
|
|
|
// 当前已经操作的最大ID
|
|
|
currLogId, err = utils.Rc.GetInt64(utils.CACHE_EDB_UPDATE_LOG_ID)
|
|
|
+ err = fmt.Errorf("当前已经操作的最大ID：%d", currLogId)
|
|
|
if err != nil {
|
|
|
// 如果不是没找到key，那么说明是redis报错
|
|
|
if err.Error() != utils.RedisNoKeyErr {
|
|
|
@@ -272,8 +273,10 @@ func SyncIndex(cont context.Context) (err error) {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ fmt.Println("logMaxId:", logMaxId)
|
|
|
// 遍历获取下一页的数据
|
|
|
for currId := currLogId; currId < logMaxId; {
|
|
|
+ fmt.Println("currId:", currId)
|
|
|
currId = handlePush(currId, logMaxId)
|
|
|
}
|
|
|
|
|
|
@@ -310,6 +313,7 @@ func handlePush(currLogIdStr, logMaxId int64) (lastId int64) {
|
|
|
idList := make([]int64, 0)
|
|
|
for _, v := range list {
|
|
|
lastId = v.Id
|
|
|
+ fmt.Println("lastId", lastId)
|
|
|
idList = append(idList, v.Id)
|
|
|
pushIndexData, pushEdbClassifyData, pushIndexValueData, tmpErr := handleData(v)
|
|
|
if tmpErr != nil {
|
