# 下载 fabric-samples 仓库
curl -sSL https://raw.githubusercontent.com/hyperledger/fabric/main/scripts/bootstrap.sh | bash -s -- 2.5.0
cd fabric-samples/test-network

# 启动网络（创建 Org1、Org2 及 Orderer 节点）
./network.sh up

# 创建通道（默认通道名 mychannel）
./network.sh createChannel

# 部署链码（以 fabcar 为例）
./network.sh deployCC -ccn basic -ccp ../asset-transfer-basic/chaincode-go -ccl go

# crypto-config.yaml 片段
OrdererOrgs:
  - Name: Orderer
    Domain: example.com
    Specs:
      - Hostname: orderer

PeerOrgs:
  - Name: Org1
    Domain: org1.example.com
    EnableNodeOUs: true
    Template:
      Count: 2  # 2 个 peer 节点
    Users:
      Count: 1  # 1 个普通用户

crypto-config/
├── ordererOrganizations/
│   └── example.com/
│       ├── msp/       ← 组织级 MSP
│       ├── orderers/  ← Orderer 节点证书
│       └── tlsca/     ← TLS 证书
└── peerOrganizations/
    └── org1.example.com/
        ├── peers/     ← peer0, peer1 节点
        ├── users/     ← Admin, User1
        └── msp/

# 1. 生成系统通道创世块（Orderer 启动所需）
configtxgen -profile TwoOrgsOrdererGenesis -outputBlock ./system-genesis-block/genesis.block -channelID system-channel

# 2. 生成应用通道创建交易
configtxgen -profile TwoOrgsChannel -outputCreateChannelTx ./channel-artifacts/channel.tx -channelID mychannel

# 3. 生成锚节点更新交易
configtxgen -profile TwoOrgsChannel -outputAnchorPeersUpdate ./channel-artifacts/Org1MSPanchors.tx -channelID mychannel -asOrg Org1MSP

# 核心服务
services:
  peer0.org1.example.com:
    image: hyperledger/fabric-peer:2.5
    environment:
      - CORE_PEER_ID=peer0.org1.example.com
      - CORE_PEER_ADDRESS=peer0.org1.example.com:7051
      - CORE_PEER_MSPCONFIGPATH=/etc/hyperledger/fabric/msp
      - CORE_PEER_LOCALMSPID=Org1MSP
    volumes:
      - ./crypto-config/peerOrganizations/org1.example.com/peers/peer0.org1.example.com/msp:/etc/hyperledger/fabric/msp

  orderer.example.com:
    image: hyperledger/fabric-orderer:2.5
    environment:
      - ORDERER_GENERAL_LISTENADDRESS=0.0.0.0
      - ORDERER_GENERAL_GENESISMETHOD=file
      - ORDERER_GENERAL_GENESISFILE=/var/hyperledger/orderer/genesis.block

  cli:
    image: hyperledger/fabric-tools:2.5
    tty: true

# 进入 CLI 容器
docker exec -it cli bash

# 加入通道
peer channel join -b mychannel.block

# 安装链码
peer lifecycle chaincode install basic.tar.gz

# 查询已安装链码
peer lifecycle chaincode queryinstalled

# 启动 CA 容器（通常由 docker-compose 管理）

# 登记（Enroll）管理员身份
export FABRIC_CA_CLIENT_HOME=/etc/hyperledger/fabric-ca-client
fabric-ca-client enroll -u https://admin:adminpw@localhost:7054

# 注册（Register）新用户
fabric-ca-client register --id.name user1 --id.type user --id.affiliation org1 --id.attrs 'hf.Registrar.Roles=*'

# 为新用户登记获取 MSP 证书
fabric-ca-client enroll -u https://user1:user1pw@localhost:7054 -M /etc/hyperledger/fabric-ca-client/user1/msp

type Chaincode interface {
    // 初始化链码状态（通常在实例化或升级时调用一次）
    Init(stub shim.ChaincodeStubInterface) peer.Response
    // 路由所有业务调用
    Invoke(stub shim.ChaincodeStubInterface) peer.Response
}

// 读取键值
value, err := stub.GetState("key")

// 写入或更新键值
err := stub.PutState("key", []byte(jsonData))

// 删除键值
err := stub.DelState("key")

// 范围查询（基于前缀）
resultsIterator, err := stub.GetStateByRange("startKey", "endKey")

// 默认策略：两个组织都需要签名
// AND('Org1MSP.peer','Org2MSP.peer')

// 任一组织签名即可
// OR('Org1MSP.peer','Org2MSP.peer')

// 多数规则：3个组织中至少2个签名
// OutOf(2, 'Org1MSP.peer', 'Org2MSP.peer', 'Org3MSP.peer')

package main

import (
    "encoding/json"
    "fmt"
    "github.com/hyperledger/fabric-contract-api-go/contractapi"
)

// Asset 汽车资产结构体
type Asset struct {
    ID              string          `json:"id"`          // VIN码
    Owner           string          `json:"owner"`       // 当前车主
    Model           string          `json:"model"`       // 车型
    Mileage         int             `json:"mileage"`     // 当前里程
    ServiceHistory  []ServiceRecord `json:"serviceHistory"` // 维修历史
}

// ServiceRecord 维修记录
type ServiceRecord struct {
    Date          string `json:"date"`
    Description   string `json:"description"`
    ServiceCenter string `json:"serviceCenter"`
}

// SmartContract 链码结构体
type SmartContract struct {
    contractapi.Contract
}

// RegisterCar 注册新车辆（仅授权经销商调用）
func (s *SmartContract) RegisterCar(ctx contractapi.TransactionContextInterface, vin, owner, model string) error {
    // 检查 VIN 是否已存在
    existing, _ := ctx.GetStub().GetState(vin)
    if existing != nil {
        return fmt.Errorf("car with VIN %s already exists", vin)
    }

    asset := Asset{
        ID:    vin,
        Owner: owner,
        Model: model,
    }

    assetJSON, _ := json.Marshal(asset)
    return ctx.GetStub().PutState(vin, assetJSON)
}

// TransferCar 转移车辆所有权
func (s *SmartContract) TransferCar(ctx contractapi.TransactionContextInterface, vin, newOwner string) error {
    assetJSON, _ := ctx.GetStub().GetState(vin)
    if assetJSON == nil {
        return fmt.Errorf("car %s not found", vin)
    }

    var asset Asset
    json.Unmarshal(assetJSON, &asset)

    // 检查调用者是否为当前车主
    callerID, _ := ctx.GetClientIdentity().GetID()
    // 简化处理：实际应校验 callerID 与 asset.Owner 的匹配关系
    asset.Owner = newOwner

    updatedJSON, _ := json.Marshal(asset)
    return ctx.GetStub().PutState(vin, updatedJSON)
}

// AddServiceRecord 添加维修记录
func (s *SmartContract) AddServiceRecord(ctx contractapi.TransactionContextInterface, vin, date, description, serviceCenter string) error {
    assetJSON, _ := ctx.GetStub().GetState(vin)
    if assetJSON == nil {
        return fmt.Errorf("car %s not found", vin)
    }

    var asset Asset
    json.Unmarshal(assetJSON, &asset)

    record := ServiceRecord{
        Date:          date,
        Description:   description,
        ServiceCenter: serviceCenter,
    }
    asset.ServiceHistory = append(asset.ServiceHistory, record)

    updatedJSON, _ := json.Marshal(asset)
    return ctx.GetStub().PutState(vin, updatedJSON)
}

// QueryCar 查询车辆信息
func (s *SmartContract) QueryCar(ctx contractapi.TransactionContextInterface, vin string) (*Asset, error) {
    assetJSON, _ := ctx.GetStub().GetState(vin)
    if assetJSON == nil {
        return nil, fmt.Errorf("car %s not found", vin)
    }

    var asset Asset
    json.Unmarshal(assetJSON, &asset)
    return &asset, nil
}

// QueryAllCars 查询所有车辆
func (s *SmartContract) QueryAllCars(ctx contractapi.TransactionContextInterface) ([]*Asset, error) {
    resultsIterator, _ := ctx.GetStub().GetStateByRange("", "")
    defer resultsIterator.Close()

    var assets []*Asset
    for resultsIterator.HasNext() {
        queryResponse, _ := resultsIterator.Next()
        var asset Asset
        json.Unmarshal(queryResponse.Value, &asset)
        assets = append(assets, &asset)
    }
    return assets, nil
}

func main() {
    chaincode, _ := contractapi.NewChaincode(&SmartContract{})
    chaincode.Start()
}

# 1. 打包链码
peer lifecycle chaincode package basic.tar.gz \
    --path ./asset-transfer-basic/chaincode-go/ \
    --lang golang \
    --label basic_1.0

# 2. 在 Org1 的 peer 上安装
export CORE_PEER_LOCALMSPID=Org1MSP
export CORE_PEER_ADDRESS=localhost:7051
peer lifecycle chaincode install basic.tar.gz

# 3. 在 Org2 的 peer 上安装
export CORE_PEER_LOCALMSPID=Org2MSP
export CORE_PEER_ADDRESS=localhost:9051
peer lifecycle chaincode install basic.tar.gz

# 4. 查询已安装链码的包 ID
peer lifecycle chaincode queryinstalled
# 输出示例: Package ID: basic_1.0:hash...

# 5. 各组织审批
peer lifecycle chaincode approveformyorg \
    --channelID mychannel \
    --name basic \
    --version 1.0 \
    --package-id basic_1.0:hash... \
    --sequence 1 \
    --signature-policy "AND('Org1MSP.peer','Org2MSP.peer')"

# 6. 提交链码定义（满足审批条件后）
peer lifecycle chaincode commit \
    --channelID mychannel \
    --name basic \
    --version 1.0 \
    --sequence 1 \
    --signature-policy "AND('Org1MSP.peer','Org2MSP.peer')"

# 7. 调用链码：注册车辆
peer chaincode invoke \
    -o localhost:7050 \
    --channelID mychannel \
    --name basic \
    -c '{"Args":["RegisterCar","WBA3A5G50BNT001","Alice","BMW X5"]}'

# 8. 查询车辆信息
peer chaincode query \
    --channelID mychannel \
    --name basic \
    -c '{"Args":["QueryCar","WBA3A5G50BNT001"]}'