xptracker service: only update last_updated after hiscores are saved
This commit is contained in:
@@ -96,17 +96,11 @@ public class XpTrackerService
|
|||||||
log.warn("Username update queue is full ({})", QUEUE_LIMIT);
|
log.warn("Username update queue is full ({})", QUEUE_LIMIT);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
con.createQuery("update player set last_updated = CURRENT_TIMESTAMP where id = :id")
|
|
||||||
.addParameter("id", playerEntity.getId())
|
|
||||||
.executeUpdate();
|
|
||||||
}
|
|
||||||
|
|
||||||
synchronized (usernameUpdateQueue)
|
|
||||||
{
|
|
||||||
usernameUpdateQueue.add(username);
|
usernameUpdateQueue.add(username);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
usernameFilter.put(username);
|
usernameFilter.put(username);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -190,7 +184,7 @@ public class XpTrackerService
|
|||||||
.addParameter("overall_rank", hiscoreResult.getOverall().getRank())
|
.addParameter("overall_rank", hiscoreResult.getOverall().getRank())
|
||||||
.executeUpdate();
|
.executeUpdate();
|
||||||
|
|
||||||
con.createQuery("update player set rank = :rank where id = :id")
|
con.createQuery("update player set rank = :rank, last_updated = CURRENT_TIMESTAMP where id = :id")
|
||||||
.addParameter("id", playerEntity.getId())
|
.addParameter("id", playerEntity.getId())
|
||||||
.addParameter("rank", hiscoreResult.getOverall().getRank())
|
.addParameter("rank", hiscoreResult.getOverall().getRank())
|
||||||
.executeUpdate();
|
.executeUpdate();
|
||||||
|
|||||||
Reference in New Issue
Block a user