diff --git a/cli/storage-deals.go b/cli/storage-deals.go
index cbb2e227..b378f184 100644
--- a/cli/storage-deals.go
+++ b/cli/storage-deals.go
@@ -66,7 +66,7 @@ var dealsImportDataCmd = &cli.Command{
 			Usage: "Actually send transaction performing the action",
 		},
 	},
-	ArgsUsage: "<proposal CID> <file>",
+	ArgsUsage: "<proposal CID or uuid> <file>",
 	Action: func(cctx *cli.Context) error {
 		api, closer, err := NewMarketNode(cctx)
 		if err != nil {
@@ -117,7 +117,7 @@ var dealsBatchImportDataCmd = &cli.Command{
 	Flags: []cli.Flag{
 		&cli.StringSliceFlag{
 			Name:  "proposals",
-			Usage: "proposal cid and car file, eg. --proposals <proposal_cid>,<path_to_car_file>  --proposals <proposal_cid>,<path_to_car_file>",
+			Usage: "proposal cid(or uuid) and car file, eg. --proposals <proposal_cid>,<path_to_car_file>  --proposals <uuid>,<path_to_car_file>",
 		},
 		&cli.StringFlag{
 			Name: "manifest",
@@ -125,6 +125,10 @@ var dealsBatchImportDataCmd = &cli.Command{
 proposalCID,pieceCID
 baadfdxxx,badddxxx
 basdefxxx,baefaxxx
+or
+uuid,pieceCID
+baad-xxx,badddxxx
+bass-xxx,baefaxxx
 `,
 		},
 		&cli.BoolFlag{
diff --git a/storageprovider/stream.go b/storageprovider/stream.go
index 14995ed9..53a5eda8 100644
--- a/storageprovider/stream.go
+++ b/storageprovider/stream.go
@@ -401,7 +401,7 @@ func (storageDealStream *StorageDealStream) HandleNewDealStream(s network2.Strea
 	}
 
 	deal := &types.MinerDeal{
-		ID:                 uuid.New(),
+		ID:                 proposal.DealUUID,
 		Client:             s.Conn().RemotePeer(),
 		Miner:              storageDealStream.net.ID(),
 		ClientDealProposal: proposal.ClientDealProposal,