diff --git a/command/auto.go b/command/auto.go
index 43b9625..e19d21c 100644
--- a/command/auto.go
+++ b/command/auto.go
@@ -342,14 +342,16 @@ func (cmdAutoBidDeal *CmdAutoBidDeal) sendAutobidDeal(offlineDeal *libmodel.Offl
 				dealConfig.Duration = verifreg.MinimumVerifiedAllocationTerm
 				allocationId, err = boost.GetClient(cmdAutoBidDeal.SwanRepo).WithClient(lotusClient).AllocateDeal(&dealConfig)
 			} else {
-				dealCid, err = boost.GetClient(cmdAutoBidDeal.SwanRepo).WithClient(lotusClient).StartDeal(&dealConfig)
+				pieceSize, _ := utils.CalculatePieceSize(dealConfig.FileSize, true)
+				dealCid, err = boost.GetClient(cmdAutoBidDeal.SwanRepo).WithClient(lotusClient).StartDealDirect(pieceSize, big.Int{}, &dealConfig)
 			}
 			if err != nil {
 				logs.GetLogger().Error(err)
 				continue
 			}
 		} else {
-			lotusDealCid, err := lotusClient.LotusClientStartDeal(&dealConfig)
+			pieceSize, _ := utils.CalculatePieceSize(dealConfig.FileSize, false)
+			lotusDealCid, err := lotusClient.StartDeal(pieceSize, big.Int{}, &dealConfig)
 			if err != nil {
 				logs.GetLogger().Error("tried ", i+1, " times,", err)
 
diff --git a/command/deal.go b/command/deal.go
index 32440b9..00c9f9d 100644
--- a/command/deal.go
+++ b/command/deal.go
@@ -2,6 +2,7 @@ package command
 
 import (
 	"fmt"
+	"math/big"
 	"path/filepath"
 	"strings"
 	"time"
@@ -269,11 +270,13 @@ func (cmdDeal *CmdDeal) sendDeals2Miner(taskName string, outputDir string, fileD
 					dealConfig.Duration = verifreg.MinimumVerifiedAllocationTerm
 					allocationId, err = boost.GetClient(cmdDeal.SwanRepo).WithClient(lotusClient).AllocateDeal(&dealConfig)
 				} else {
-					dealCid, err = boost.GetClient(cmdDeal.SwanRepo).WithClient(lotusClient).StartDeal(&dealConfig)
+					pieceSize, _ := utils.CalculatePieceSize(dealConfig.FileSize, true)
+					dealCid, err = boost.GetClient(cmdDeal.SwanRepo).WithClient(lotusClient).StartDealDirect(pieceSize, big.Int{}, &dealConfig)
 				}
 			} else {
 				var cidPtr *string
-				cidPtr, err = lotusClient.LotusClientStartDeal(&dealConfig)
+				pieceSize, _ := utils.CalculatePieceSize(dealConfig.FileSize, false)
+				cidPtr, err = lotusClient.StartDeal(pieceSize, big.Int{}, &dealConfig)
 				if err == nil {
 					dealCid = *cidPtr
 					dealInfo, err := lotusClient.LotusClientGetDealInfo(*cidPtr)