// patient.api
// API 語法版本
syntax = "v1"

// API 元數據
info(
    title: "患者服務"
    desc: "管理臨牀試驗項目中的患者信息"
    author: "阿亮"
    email: "liang@example.com"
    version: "1.0.0"
)

// 定義請求和響應的數據結構（DTO - Data Transfer Object）
type Patient {
    Id          string `json:"id"`           // 患者唯一標識
    Name        string `json:"name"`         // 患者姓名
    Mobile      string `json:"mobile"`       // 手機號（脱敏）
    TrialId     string `json:"trialId"`      // 所屬臨牀試驗項目ID
    CreatedAt   int64  `json:"createdAt"`    // 創建時間
}

type GetPatientInfoReq {
    PatientId   string `path:"patientId"`   // 從 URL 路徑中獲取患者ID
}

type GetPatientInfoResp {
    PatientInfo Patient `json:"patientInfo"`
}

// 定義服務和路由
@server(
    group: patient  // 路由分組
    prefix: /api/v1/patient // 路由前綴
)
service patient-api {
    @doc "獲取患者詳細信息"
    @handler GetPatientInfo
    get /info/:patientId (GetPatientInfoReq) returns (GetPatientInfoResp)
}

# goctl api go -api patient.api -dir ./patient-api

patient-api
├── etc
│   └── patient-api.yaml  # 配置文件
├── internal
│   ├── config
│   │   └── config.go     # 配置結構體
│   ├── handler
│   │   ├── getpatientinfohandler.go # 我們要寫業務邏輯的地方
│   │   └── routes.go     # 自動生成的路由
│   ├── logic
│   │   └── getpatientinfologic.go # 業務邏輯的核心文件
│   ├── svc
│   │   └── servicecontext.go # 服務上下文，用於依賴注入
│   └── types
│       └── types.go      # 根據 .api 文件生成的請求響應結構體
└── patient.go          # main 函數，程序入口

// patient.proto
syntax = "proto3";

// 定義包名，生成 Go 代碼時會用到
package patient;
option go_package = "./patient";

// 患者信息結構體
message PatientInfo {
  string id = 1;
  string name = 2;
  string mobile = 3;
  string trialId = 4;
  int64 createdAt = 5;
}

// 請求體
message GetPatientRequest {
  string id = 1;
}

// 響應體
message GetPatientResponse {
  PatientInfo patient = 1;
}

// 定義 gRPC 服務
service PatientService {
  // 定義 RPC 方法
  rpc getPatient(GetPatientRequest) returns (GetPatientResponse);
}

# goctl rpc protoc patient.proto --go_out=. --go-grpc_out=. --zrpc_out=.

// internal/logic/getpatientinfologic.go
package logic

import (
	"context"

	"patient-api/internal/svc"
	"patient-api/internal/types"

	"github.com/zeromicro/go-zero/core/logx"
)

type GetPatientInfoLogic struct {
	logx.Logger
	ctx    context.Context
	svcCtx *svc.ServiceContext
}

func NewGetPatientInfoLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetPatientInfoLogic {
	return &GetPatientInfoLogic{
		Logger: logx.WithContext(ctx),
		ctx:    ctx,
		svcCtx: svcCtx,
	}
}

func (l *GetPatientInfoLogic) GetPatientInfo(req *types.GetPatientInfoReq) (resp *types.GetPatientInfoResp, err error) {
	// TODO: 在這裏實現你的業務邏輯

	// 模擬從數據庫查詢
    // 在真實項目中，這裏會調用 l.svcCtx.PatientModel.FindOne(l.ctx, req.PatientId)
	logx.Infof("查詢患者信息，ID: %s", req.PatientId)

	if req.PatientId == "12345" {
		// 模擬找到患者
		patientData := types.Patient{
			Id:        "12345",
			Name:      "張三",
			Mobile:    "138****1234", // 注意數據脱敏
			TrialId:   "TRIAL-001",
			CreatedAt: 1672531200,
		}
		resp = &types.GetPatientInfoResp{
			PatientInfo: patientData,
		}
		return resp, nil
	}
    
    // 模擬未找到患者
    // 在真實項目中，應該返回一個明確的業務錯誤碼
	return nil, errors.New("患者不存在")
}

Name: patient-api
Host: 0.0.0.0
Port: 8888

# 新增數據庫配置
Mysql:
  DataSource: root:your_password@tcp(127.0.0.1:3306)/your_db?charset=utf8mb4&parseTime=true&loc=Asia%2FShanghai

// internal/config/config.go
import "github.com/zeromicro/go-zero/rest"

type Config struct {
	rest.RestConf
	Mysql struct { // 與 YAML 文件中的 key 對應
		DataSource string
	}
}

// internal/svc/servicecontext.go
package svc

import (
	"patient-api/internal/config"
	"github.com/zeromicro/go-zero/core/stores/sqlx"
)

type ServiceContext struct {
	Config config.Config
	PatientModel // 定義一個模型接口或具體實現，用於數據庫操作
}

func NewServiceContext(c config.Config) *ServiceContext {
	conn := sqlx.NewMysql(c.Mysql.DataSource)
	return &ServiceContext{
		Config: c,
		// 假設我們有一個 models.NewPatientModel(conn) 來創建數據庫操作對象
		// PatientModel: models.NewPatientModel(conn), 
	}
}

// patient.api

// ... 其他定義 ...

@server(
    jwt: Auth // 聲明需要名為 Auth 的 JWT 鑑權
    group: patient
    prefix: /api/v1/patient
)
service patient-api {
    // ...
}

# etc/patient-api.yaml

# ... 其他配置 ...

Auth:
  AccessSecret: "your-long-and-secure-secret-key"
  AccessExpire: 86400 # token 有效期，單位秒

// internal/logic/getpatientinfologic.go

func (l *GetPatientInfoLogic) GetPatientInfo(req *types.GetPatientInfoReq) (resp *types.GetPatientInfoResp, err error) {
    // 從 context 中獲取 JWT payload 裏的用户ID
    userId := l.ctx.Value("userId").(string) 
    logx.Infof("用户 %s 正在查詢患者 %s 的信息", userId, req.PatientId)
    
    // ... 後續業務邏輯，可以加入權限校驗，比如檢查該用户是否有權限查看該患者信息
    
	return
}

// 某個添加患者的 logic 中
func (l *AddPatientsLogic) AddPatients(req *types.AddPatientsReq) (*types.AddPatientsResp, error) {
    // 1. 先將患者信息同步寫入數據庫，確保數據持久化
    // ...
    
    // 2. 將耗時的異步任務（如生成隨訪計劃）扔到後台執行
    err := l.svcCtx.JobClient.Push(context.Background(), jobs.NewGeneratePlanJob(req.PatientIds))
    if err != nil {
        // 記錄日誌，啓動告警，但不要讓主流程失敗
        logx.Errorf("啓動生成隨訪計劃任務失敗: %v", err)
    }

    // 3. 立即返回成功響應給用户
    return &types.AddPatientsResp{Message: "患者添加成功，隨訪計劃正在後台生成中..."}, nil
}

// 在 ServiceContext 中初始化 Redis 客户端
// ...

// 在 logic 中使用緩存
func (l *GetDrugInfoLogic) GetDrugInfo(drugId string) (*Drug, error) {
    // 這裏的 FindOne 是經過 goctl model 增強的，它會自動處理緩存邏輯
    // 1. 先查 Redis
    // 2. Redis 沒有，再查 MySQL
    // 3. 查到後，寫回 Redis
    // 4. 整個過程對調用者透明
    return l.svcCtx.DrugModel.FindOne(l.ctx, drugId)
}