saga grpc 加上ctx入参 about dtm HOT 5 CLOSED

workflow.Register("step", func(wf *workflow.Workflow, data []byte) error {
	var req Request
	err := json.Unmarshal(data, &req)
	if err != nil {
		fmt.Println(err)
		return nil
	}
        traceID := req.TraceID

	_, err = wf.NewBranch().OnRollback(func(bb *dtmcli.BranchBarrier) error {
		_, err = wf.NewRequest().SetHeader("Trace-Id", traceID).SetBody(...).Post("http://127.0.0.1:29091/step1_rollback")
		return err
	}).NewRequest().SetHeader("Trace-Id", traceID).SetBody(...).Post("http://127.0.0.1:29091/step1")
	if err != nil {
		return err
	}
	
	... ...

	return nil
})

// 扣产品库存事务
	decreaseProductReq := &productPBV1.DecreaseStockRequest{}
	decreaseProductReq.Quantity = 1
	decreaseProductReq.Id = request.ProductId

	productDecreaseStock := "product.rgrpc-dev:50051/proto.product.v1.ProductService/DecreaseStock"
	productDecreaseStockRevert := "product.rgrpc-dev:50051/proto.product.v1.ProductService/DecreaseStockRevert"

	// 创建订单事务
	orderNo := uuid.NewString()
	request.OrderNo = orderNo
	createOrder := "order.rgrpc-dev:50051/proto.order.v1.OrderService/Create"
	createOrderRevert := "order.rgrpc-dev:50051/proto.order.v1.OrderService/CreateRevert"

	saga := dtmgrpc.NewSagaGrpc("dtm-svc.dtm:36790", uuid.NewString())
	saga.Add(createOrder, createOrderRevert, request)
	saga.Add(productDecreaseStock, productDecreaseStockRevert, decreaseProductReq)
	saga.WaitResult = true
	if err := saga.Submit(); err != nil {
		_ = level.Error(s.logger).Log("msg", "创建订单失败，错误："+err.Error())
		return nil, status.Error(codes.Aborted, "创建订单失败")
	}
	return &emptypb.Empty{}, nil