|
@ -298,6 +298,7 @@ func StartQueueTaskPrefixHigHead3A60Temp3A60() { |
|
|
|
|
|
|
|
|
session := onec.getXorm().NewSession() |
|
|
session := onec.getXorm().NewSession() |
|
|
defer session.Close() |
|
|
defer session.Close() |
|
|
|
|
|
session = session.Table(onec) |
|
|
whereQuery, whereArgs := onec.wherePrimaryKey() |
|
|
whereQuery, whereArgs := onec.wherePrimaryKey() |
|
|
whereCond := onec.wherePrimaryKeyWithCond() |
|
|
whereCond := onec.wherePrimaryKeyWithCond() |
|
|
if whereQuery != "" { |
|
|
if whereQuery != "" { |
|
@ -307,7 +308,7 @@ func StartQueueTaskPrefixHigHead3A60Temp3A60() { |
|
|
session = session.Where(whereCond) |
|
|
session = session.Where(whereCond) |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
i, err := session.Table(onec).Where(fmt.Sprintf("`%s`=?", f), TempLowHead3A60_AutoQueueStatusNone).Update(map[string]interface{}{f: TempLowHead3A60_AutoQueueStatusIng}) |
|
|
|
|
|
|
|
|
i, err := session.Where(fmt.Sprintf("`%s`=?", f), TempLowHead3A60_AutoQueueStatusNone).Update(map[string]interface{}{f: TempLowHead3A60_AutoQueueStatusIng}) |
|
|
if err == nil && i == 1 { |
|
|
if err == nil && i == 1 { |
|
|
func() { |
|
|
func() { |
|
|
{ |
|
|
{ |
|
|