|
|
@ -313,8 +313,8 @@ func StartQueueTaskPrefixHigHead3A60Temp3A60() { |
|
|
|
{ |
|
|
|
err := onec.queueEvent() |
|
|
|
session := onec.getXorm().NewSession() |
|
|
|
session.Table(onec) |
|
|
|
defer session.Close() |
|
|
|
session = session.Table(onec) |
|
|
|
whereQuery, whereArgs := onec.wherePrimaryKey() |
|
|
|
whereCond := onec.wherePrimaryKeyWithCond() |
|
|
|
if whereQuery != "" { |
|
|
@ -324,9 +324,9 @@ func StartQueueTaskPrefixHigHead3A60Temp3A60() { |
|
|
|
session = session.Where(whereCond) |
|
|
|
} |
|
|
|
if err != nil { |
|
|
|
session.Where(fmt.Sprintf("`%s`=?", f), TempLowHead3A60_AutoQueueStatusIng).Update(map[string]interface{}{f: TempLowHead3A60_AutoQueueStatusFail}) |
|
|
|
session.Update(map[string]interface{}{f: TempLowHead3A60_AutoQueueStatusFail}) |
|
|
|
} else { |
|
|
|
session.Where(fmt.Sprintf("`%s`=?", f), TempLowHead3A60_AutoQueueStatusIng).Update(map[string]interface{}{f: TempLowHead3A60_AutoQueueStatusSuccess}) |
|
|
|
session.Update(map[string]interface{}{f: TempLowHead3A60_AutoQueueStatusSuccess}) |
|
|
|
} |
|
|
|
} |
|
|
|
}() |
|
|
|