1
This commit is contained in:
@@ -46,6 +46,7 @@ func UpdateEntityByKV(db *DaoDB, item interface{}, kvs map[string]interface{}, c
|
|||||||
if db == nil {
|
if db == nil {
|
||||||
db = GetDB()
|
db = GetDB()
|
||||||
}
|
}
|
||||||
|
globals.SugarLogger.Debugf("item==============%s", utils.Format4Output(item, false))
|
||||||
qs := db.Db.QueryTable(item)
|
qs := db.Db.QueryTable(item)
|
||||||
if conditions == nil {
|
if conditions == nil {
|
||||||
qs = qs.Filter(model.FieldID, refutil.GetObjFieldByName(item, model.FieldID))
|
qs = qs.Filter(model.FieldID, refutil.GetObjFieldByName(item, model.FieldID))
|
||||||
@@ -134,6 +135,7 @@ func UpdateEntityLogicallyAndUpdateSyncStatus(db *DaoDB, item interface{}, kvs m
|
|||||||
rows := valueRows.Interface()
|
rows := valueRows.Interface()
|
||||||
if err = GetEntitiesByKV(db, rows, conditions, false); err == nil {
|
if err = GetEntitiesByKV(db, rows, conditions, false); err == nil {
|
||||||
valueRows = reflect.Indirect(valueRows)
|
valueRows = reflect.Indirect(valueRows)
|
||||||
|
globals.SugarLogger.Debugf("valueRows =========== := %s", utils.Format4Output(valueRows, false))
|
||||||
for i := 0; i < valueRows.Len(); i++ {
|
for i := 0; i < valueRows.Len(); i++ {
|
||||||
value := reflect.Indirect(valueRows.Index(i))
|
value := reflect.Indirect(valueRows.Index(i))
|
||||||
status := value.FieldByName(syncStatusFieldName).Int() | int64(valueMask)
|
status := value.FieldByName(syncStatusFieldName).Int() | int64(valueMask)
|
||||||
|
|||||||
Reference in New Issue
Block a user