From 664027a95582f8a97e20bafa5fef3922d707eeb4 Mon Sep 17 00:00:00 2001
From: junleea <354425203@qq.com>
Date: Sun, 15 Dec 2024 18:31:26 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E7=94=A8=E6=88=B7=E5=90=8C?=
 =?UTF-8?q?=E6=AD=A5=E8=AF=B7=E6=B1=82=E6=95=B0=E6=8D=AE=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 worker/req.go | 19 ++++++++++---------
 1 file changed, 10 insertions(+), 9 deletions(-)

diff --git a/worker/req.go b/worker/req.go
index 28ac772..a8a30a2 100644
--- a/worker/req.go
+++ b/worker/req.go
@@ -7,7 +7,6 @@ import (
 	"io"
 	"io/ioutil"
 	"net/http"
-	"strconv"
 	"strings"
 	"videoplayer/proto"
 )
@@ -130,6 +129,12 @@ func SyncDataFromMasterReq(url string, token string) proto.UserSync {
 	return userSync
 }
 
+type Response struct {
+	Code    int            `json:"code"`
+	Message string         `json:"message"`
+	Data    proto.UserSync `json:"data"`
+}
+
 // 获取数据,全量及增量
 func SyncDataFromMasterReq2(url string, data proto.SyncUserReq) (proto.UserSync, error) {
 	defer func() {
@@ -160,20 +165,16 @@ func SyncDataFromMasterReq2(url string, data proto.SyncUserReq) (proto.UserSync,
 	}
 	defer resp.Body.Close()
 	//解析数据
-	var m map[string]string
-	err = json.NewDecoder(resp.Body).Decode(&m)
+	responseBod, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return res, err
 	}
-	code, _ := strconv.Atoi(m["code"])
-	if code != 0 {
-		return res, err
-	}
-	err = json.Unmarshal([]byte(m["data"]), &res)
+	var response Response
+	err = json.Unmarshal(responseBod, &response)
 	if err != nil {
-		fmt.Println("SyncDataFromMasterReq2 error decode data:", err)
 		return res, err
 	}
+	res = response.Data
 	fmt.Println("SyncDataFromMasterReq2 result add data:", len(res.Add), "update data:", len(res.Update), "delete data:", len(res.Delete))
 	return res, nil
 }