|
@@ -120,6 +120,8 @@ func ExamEndTicker() {
|
|
|
var keysToDelete []string
|
|
|
for teamName, heartBeatTime := range cacheTeamName {
|
|
|
if time.Since(heartBeatTime) > heartBeatTimeThreshold { // 检查缓存中的队名,如果超过心跳时间,则代表考试结束,删除缓存中的队名
|
|
|
+ c_log.GlobalLogger.Infof("队伍 %v 心跳超时,比赛结束。", teamName)
|
|
|
+
|
|
|
keysToDelete = append(keysToDelete, teamName)
|
|
|
}
|
|
|
}
|
|
@@ -163,10 +165,11 @@ func ExamEndTicker() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+ c_log.GlobalLogger.Info("更新数据结束时间,id为:", resultId[0])
|
|
|
sqlTemplate, _ := util.ReadFile(c_db.SqlFilesMap["exam-update-end_time-by-id.sql"])
|
|
|
if err := c_db.DoTx(sqlTemplate, []any{
|
|
|
time.Now(),
|
|
|
- util.ToString(resultId[0]),
|
|
|
+ resultId[0],
|
|
|
}); err != nil {
|
|
|
c_log.GlobalLogger.Error("插入数据报错:", err)
|
|
|
return
|