Go développement linguistique du système de cuisson porte-à-porte : comment mettre en œuvre la fonction de gestion des adresses des utilisateurs ?

type Address struct {
    UserID       int    `json:"user_id"`
    ReceiverName string `json:"receiver_name"`
    PhoneNumber  string `json:"phone_number"`
    Province     string `json:"province"`
    City         string `json:"city"`
    District     string `json:"district"`
    Detail       string `json:"detail"`
    IsDefault    bool   `json:"is_default"`
}

// 添加用户地址
func AddAddress(address Address) error {
    // 连接数据库
    db, err := sql.Open("mysql", "root:123456@tcp(localhost:3306)/mydb")
    if err != nil {
        return err
    }
    defer db.Close()

    // 执行插入操作
    _, err = db.Exec("INSERT INTO address(user_id, receiver_name, phone_number, province, city, district, detail, is_default) VALUES (?, ?, ?, ?, ?, ?, ?, ?)", address.UserID, address.ReceiverName, address.PhoneNumber, address.Province, address.City, address.District, address.Detail, address.IsDefault)
    if err != nil {
        return err
    }

    return nil
}

// 根据用户ID查询地址列表
func GetAddressesByUserID(userID int) ([]Address, error) {
    // 连接数据库
    db, err := sql.Open("mysql", "root:123456@tcp(localhost:3306)/mydb")
    if err != nil {
        return nil, err
    }
    defer db.Close()

    // 执行查询操作
    rows, err := db.Query("SELECT * FROM address WHERE user_id = ?", userID)
    if err != nil {
        return nil, err
    }
    defer rows.Close()

    // 解析查询结果
    addresses := []Address{}
    for rows.Next() {
        var address Address
        err := rows.Scan(&address.UserID, &address.ReceiverName, &address.PhoneNumber, &address.Province, &address.City, &address.District, &address.Detail, &address.IsDefault)
        if err != nil {
            return nil, err
        }
        addresses = append(addresses, address)
    }

    return addresses, nil
}

// 删除用户地址
func DeleteAddress(userID int, addressID int) error {
    // 连接数据库
    db, err := sql.Open("mysql", "root:123456@tcp(localhost:3306)/mydb")
    if err != nil {
        return err
    }
    defer db.Close()

    // 执行删除操作
    _, err = db.Exec("DELETE FROM address WHERE user_id = ? AND id = ?", userID, addressID)
    if err != nil {
        return err
    }

    return nil
}

// 添加用户地址
func AddAddressHandler(w http.ResponseWriter, r *http.Request) {
    // 解析请求体
    decoder := json.NewDecoder(r.Body)
    var address Address
    err := decoder.Decode(&address)
    if err != nil {
        http.Error(w, err.Error(), http.StatusBadRequest)
        return
    }

    // 调用数据库操作方法
    err = AddAddress(address)
    if err != nil {
        http.Error(w, err.Error(), http.StatusInternalServerError)
        return
    }

    // 返回成功响应
    w.WriteHeader(http.StatusOK)
}

// 查询用户地址列表
func GetAddressesHandler(w http.ResponseWriter, r *http.Request) {
    // 解析URL参数
    userID, err := strconv.Atoi(r.URL.Query().Get("user_id"))
    if err != nil {
        http.Error(w, err.Error(), http.StatusBadRequest)
        return
    }

    // 调用数据库操作方法
    addresses, err := GetAddressesByUserID(userID)
    if err != nil {
        http.Error(w, err.Error(), http.StatusInternalServerError)
        return
    }

    // 返回JSON响应
    w.Header().Set("Content-Type", "application/json")
    encoder := json.NewEncoder(w)
    err = encoder.Encode(addresses)
    if err != nil {
        http.Error(w, err.Error(), http.StatusInternalServerError)
        return
    }
}

// 删除用户地址
func DeleteAddressHandler(w http.ResponseWriter, r *http.Request) {
    // 解析URL参数
    userID, err := strconv.Atoi(r.URL.Query().Get("user_id"))
    if err != nil {
        http.Error(w, err.Error(), http.StatusBadRequest)
        return
    }
    addressID, err := strconv.Atoi(r.URL.Query().Get("address_id"))
    if err != nil {
        http.Error(w, err.Error(), http.StatusBadRequest)
        return
    }

    // 调用数据库操作方法
    err = DeleteAddress(userID, addressID)
    if err != nil {
        http.Error(w, err.Error(), http.StatusInternalServerError)
        return
    }

    // 返回成功响应
    w.WriteHeader(http.StatusOK)
}

// 注册HTTP路由
func RegisterHandlers() {
    http.HandleFunc("/address/add", AddAddressHandler)
    http.HandleFunc("/address/get", GetAddressesHandler)
    http.HandleFunc("/address/delete", DeleteAddressHandler)
}