|
|
@@ -309,6 +309,7 @@ func handlePush(currLogIdStr, logMaxId int64) (lastId int64) {
|
|
|
|
|
|
idList := make([]int64, 0)
|
|
|
for _, v := range list {
|
|
|
+ lastId = v.Id
|
|
|
idList = append(idList, v.Id)
|
|
|
pushIndexData, pushEdbClassifyData, pushIndexValueData, tmpErr := handleData(v)
|
|
|
if tmpErr != nil {
|
|
|
@@ -327,8 +328,6 @@ func handlePush(currLogIdStr, logMaxId int64) (lastId int64) {
|
|
|
if pushIndexValueData != nil {
|
|
|
pushIndexValueList = append(pushIndexValueList, pushIndexValueData)
|
|
|
}
|
|
|
-
|
|
|
- lastId = v.Id
|
|
|
}
|
|
|
|
|
|
pushIndex(pushIndexList)
|
