// main.go - 我们将在单个文件中模拟两个服务，以方便演示。实际中它们是两个独立程序。

package main

import (
	"encoding/json"
	"fmt"
	"log"
	"net/http"
	"sync"
)

// ===================== 共享数据模型 =====================
type User struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

type Order struct {
	ID       string `json:"id"`
	UserID   string `json:"user_id"`
	Product  string `json:"product"`
}

// ===================== 用户服务 (独立进程/端口) =====================
var userStore = map[string]User{ // 模拟数据库
	"u1": {ID: "u1", Name: "Alice"},
	"u2": {ID: "u2", Name: "Bob"},
}

// 用户服务的处理器：根据ID获取用户
func userServiceHandler(w http.ResponseWriter, r *http.Request) {
	// 从URL路径中提取用户ID，例如 /users/u1 -> u1
	userID := r.URL.Path[len("/users/"):]
	user, exists := userStore[userID]
	if !exists {
		http.Error(w, "User not found", http.StatusNotFound)
		return
	}

	w.Header().Set("Content-Type", "application/json")
	json.NewEncoder(w).Encode(user)
}

// ===================== 订单服务 (独立进程/端口) =====================
var orderStore = map[string]Order{ // 模拟数据库
	"o1": {ID: "o1", UserID: "u1", Product: "Go并发编程实战"},
}

// 订单服务的处理器：根据ID获取订单，需要校验用户是否存在
func orderServiceHandler(w http.ResponseWriter, r *http.Request) {
	orderID := r.URL.Path[len("/orders/"):]
	order, exists := orderStore[orderID]
	if !exists {
		http.Error(w, "Order not found", http.StatusNotFound)
		return
	}

	// 关键点：订单服务通过HTTP API调用用户服务，获取用户信息进行校验
	// 在真实微服务中，这里应调用另一个服务的地址（如 http://user-service:8081/users/u1）
	userServiceURL := fmt.Sprintf("http://localhost:8081/users/%s", order.UserID)
	resp, err := http.Get(userServiceURL)
	if err != nil {
		// 简单的错误处理，真实场景需要更复杂的重试/熔断逻辑
		http.Error(w, "Failed to call user service", http.StatusInternalServerError)
		log.Printf("Error calling user service: %v", err)
		return
	}
	defer resp.Body.Close()

	if resp.StatusCode != http.StatusOK {
		http.Error(w, "User validation failed", http.StatusBadRequest)
		return
	}

	// 解码用户信息
	var user User
	json.NewDecoder(resp.Body).Decode(&user)

	// 组合信息返回
	response := struct {
		Order Order `json:"order"`
		User  User  `json:"user"`
	}{
		Order: order,
		User:  user,
	}

	w.Header().Set("Content-Type", "application/json")
	json.NewEncoder(w).Encode(response)
}

func main() {
	var wg sync.WaitGroup

	// 启动用户服务 (端口 8081)
	wg.Add(1)
	go func() {
		defer wg.Done()
		http.HandleFunc("/users/", userServiceHandler)
		fmt.Println("User Service listening on :8081")
		log.Fatal(http.ListenAndServe(":8081", nil))
	}()

	// 启动订单服务 (端口 8082)
	wg.Add(1)
	go func() {
		defer wg.Done()
		http.HandleFunc("/orders/", orderServiceHandler)
		fmt.Println("Order Service listening on :8082")
		log.Fatal(http.ListenAndServe(":8082", nil))
	}()

	// 等待两个服务（理论上会永久运行，但程序会在这里阻塞）
	wg.Wait()
}