dao/user.go

@@ -150,9 +150,3 @@ type UserSyncResp struct {
 	Add    []User            `json:"add" form:"add"`       //添加用户
 	Delete []proto.UserDelID `json:"delete" form:"delete"` //删除用户
 }
-
-// 清空用户表
-func ClearAllUsers() error {
-	res := DB.Exec("TRUNCATE TABLE users")
-	return res.Error
-}

service/userService.go

@@ -115,12 +115,6 @@ func UserSyncDataFromMaster() {
 	var is_all bool //是否全量同步
 	if all == "" || all == "1" {
 		is_all = true
-		//清空数据表
-		err := dao.ClearAllUsers()
-		if err != nil {
-			fmt.Println("All ClearAllUsers error:", err)
-			return
-		}
 		worker.SetRedis("user_sync_all", "1")
 		req.Types = 1
 	} else {
@@ -128,11 +122,7 @@ func UserSyncDataFromMaster() {
 		req.Types = 2
 	}
 
-	user_sync_data, err := worker.SyncDataFromMasterReq2(url, req)
-	if err != nil {
-		fmt.Println("UserSyncDataFromMaster error:", err)
-		return
-	}
+	user_sync_data := worker.SyncDataFromMasterReq2(url, req)
 	add_users := user_sync_data.Add
 	update_users := user_sync_data.Update
 	delete_users := user_sync_data.Delete
@@ -183,8 +173,6 @@ func UserSyncDataFromMaster() {
 		confirm_req.Types = 3
 		confirm_req.Confirm = data
 		worker.SyncDataFromMasterReq2(url, confirm_req)
-	} else {
-
 	}
 }
 

worker/req.go

@@ -7,7 +7,6 @@ import (
 	"io"
 	"io/ioutil"
 	"net/http"
-	"strconv"
 	"strings"
 	"videoplayer/proto"
 )
@@ -131,22 +130,16 @@ func SyncDataFromMasterReq(url string, token string) proto.UserSync {
 }
 
 // 获取数据,全量及增量
-func SyncDataFromMasterReq2(url string, data proto.SyncUserReq) (proto.UserSync, error) {
-	defer func() {
-		if r := recover(); r != nil {
-			fmt.Println("SyncDataFromMasterReq2 error:", r)
-		}
-	}()
-
+func SyncDataFromMasterReq2(url string, data proto.SyncUserReq) proto.UserSync {
 	var res proto.UserSync
 	//从接口获取数据
 	json_data, err := json.Marshal(data)
 	if err != nil {
-		return res, err
+		return res
 	}
 	req, err := http.NewRequest("POST", url, bytes.NewBuffer(json_data))
 	if err != nil {
-		return res, err
+		return res
 	}
 	req.Header.Set("Content-Type", "application/json")
 	//传输数据
@@ -156,24 +149,23 @@ func SyncDataFromMasterReq2(url string, data proto.SyncUserReq) (proto.UserSync,
 	//获取数据
 	resp, err := client.Do(req)
 	if err != nil {
-		return res, err
+		return res
 	}
 	defer resp.Body.Close()
 	//解析数据
-	var m map[string]string
+	var m map[string]interface{}
 	err = json.NewDecoder(resp.Body).Decode(&m)
 	if err != nil {
-		return res, err
+		return res
 	}
-	code, _ := strconv.Atoi(m["code"])
-	if code != 0 {
-		return res, err
+	if m["code"].(float64) != 0 {
+		return res
 	}
-	err = json.Unmarshal([]byte(m["data"]), &res)
+	err = json.Unmarshal([]byte(m["data"].(string)), &res)
 	if err != nil {
 		fmt.Println("SyncDataFromMasterReq2 error decode data:", err)
-		return res, err
+		return res
 	}
 	fmt.Println("SyncDataFromMasterReq2 result add data:", len(res.Add), "update data:", len(res.Update), "delete data:", len(res.Delete))
-	return res, nil
+	return res
 }