调整

server/apigate/service/sapi_forward.go

@@ -1,9 +1,9 @@
 package service
 
 import (
-	"apigate/constant"
 	"f5"
 	"fmt"
+	"main/constant"
 	"main/mt"
 	"math/rand"
 	"q5"

server/gamesapi/middleware/caforward.go

@@ -40,7 +40,7 @@ func CaForward(c *gin.Context) {
 		costTime := q5.GetTickCount() - beginTick
 		service.SApiForward.UpdateCostTime(costTime)
 	}()
-	downStreamUrl, downStreamHost := service.SApiForward.GetDownStreamHost();
+	downStreamUrl, downStreamHost := service.SApiForward.GetDownStreamHost()
 	newUrl := downStreamUrl + c.Request.URL.Path[5:]
 	if !q5.StrContains(newUrl, "?") {
 		newUrl = newUrl + "?"

server/jccommon/utils.go

@@ -1,6 +1,8 @@
 package jccommon
 
 import (
+	"f5"
+	"q5"
 	"strconv"
 )
 
@@ -85,8 +87,33 @@ func CalcContributionScore(nfts []*NftStacking) float64 {
 	return score
 }
 
+func ExtractChannel(accountId string) string {
+	strs := q5.StrSplit(accountId, "_")
+	return strs[0]
+}
+
 func IsValidSessionId(accountId string, sessionId string) bool {
-	return true
+	if accountId == "" || sessionId == "" {
+		return false
+	}
+
+	strs := q5.StrSplit(sessionId, "_")
+	if len(strs) < 4 {
+		return false
+	}
+
+	if f5.IsOnlineEnv() {
+		channel := ExtractChannel(accountId)
+		if channel == "6000" {
+			return false
+		}
+	}
+
+	session_createtime := strs[0]
+	account_regtime := strs[1]
+	md51 := strs[2]
+	// md52:=strs[3]
+	return q5.Md5Str(accountId + "f3a6a9a5-217a-4079-ab99-b5d69b8212be" + account_regtime + session_createtime) == md51
 }
 
 func GenTransId(funcId int8, time int32, seqId int32, params []int64) (string, error) {