|
|
@@ -297,7 +297,7 @@ func handlePush(currLogIdStr, logMaxId int64) (lastId int64) {
|
|
|
var condition string
|
|
|
var pars []interface{}
|
|
|
|
|
|
- condition += " AND id > ? AND id < ?"
|
|
|
+ condition += " AND id > ? AND id <= ?"
|
|
|
pars = append(pars, currLogIdStr, logMaxId)
|
|
|
|
|
|
list, err := data_manage.GetEdbUpdateLogByCondition(condition, pars)
|
|
|
@@ -318,6 +318,7 @@ func handlePush(currLogIdStr, logMaxId int64) (lastId int64) {
|
|
|
pushIndexData, pushEdbClassifyData, pushIndexValueData, tmpErr := handleData(v)
|
|
|
if tmpErr != nil {
|
|
|
err = tmpErr
|
|
|
+ utils.FileLog.Error("获取待处理的数据失败:" + err.Error())
|
|
|
fmt.Println(err)
|
|
|
continue
|
|
|
}
|
