commit

aarch64/pjisuv/master/service/for_competition.go

@@ -76,7 +76,11 @@ func examBegin() {
 				if !util.ContainsKey(cacheTeamName, teamName) { // 1 如果缓存数组中没有此队名，代表考试开始，缓存此队名，和当前时间戳
 					examBeginTime := time.Now()
 					cacheTeamName[teamName] = examBeginTime
-					_, _ = util.PostJsonResponseString(urlExamBegin, map[string]string{"teamName": teamName})
+					_, _ = util.HttpPostJsonWithHeaders(
+						urlExamBegin,
+						map[string]string{"Authorization": "U9yKpD6kZZDDe4LFKK6myAxBUT1XRrDM"},
+						map[string]string{"teamName": teamName},
+					)
 					c_log.GlobalLogger.Infof("队伍 %v 的考试开始。", teamName)
 				} else { // 2 如果缓存数组中有此队名，代表考试进行中，刷新时间戳
 					cacheTeamName[teamName] = time.Now()
@@ -100,7 +104,11 @@ func examEnd() {
 			}
 			for _, teamName := range keysToDelete { // 检查缓存中的队名，如果超过心跳时间，则代表考试结束，删除缓存中的队名
 				delete(cacheTeamName, teamName)
-				_, _ = util.PostJsonResponseString(urlExamEnd, map[string]string{"teamName": teamName})
+				_, _ = util.HttpPostJsonWithHeaders(
+					urlExamEnd,
+					map[string]string{"Authorization": "U9yKpD6kZZDDe4LFKK6myAxBUT1XRrDM"},
+					map[string]string{"teamName": teamName},
+				)
 				c_log.GlobalLogger.Infof("队伍 %v 的考试结束。", teamName)
 			}
 		}

common/util/u_http.go

@@ -135,24 +135,3 @@ func HttpGetStringAddHeadersResponseString(baseUrl string, headers map[string]st
 	//log.GlobalLogger.Info("发送http请求，请求路径=", baseUrl, "，请求头=", headers, "请求参数=", params, "请求结果=", result)
 	return result, nil
 }
-
-func PostJsonResponseString(url string, params map[string]string) (string, error) {
-	jsonData, err := json.Marshal(params)
-	if err != nil {
-		return "", err
-	}
-	resp, err := http.Post(url, "application/json", bytes.NewBuffer(jsonData))
-	if err != nil {
-		return "", err
-	}
-	defer func(Body io.ReadCloser) {
-		err := Body.Close()
-		if err != nil {
-		}
-	}(resp.Body)
-	body, err := io.ReadAll(resp.Body)
-	if err != nil {
-		return "", err
-	}
-	return string(body), nil
-}