diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index 2ce24e036..2d7619ffe 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -1032,7 +1032,7 @@ func CreateConsumerFromOrders(ctx *jxcontext.Context, vendorIDs []int, fromDate,
 		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 			curDate := batchItemList[0].(time.Time)
 			sql := `
-			SELECT *
+			SELECT t1.*, t2.original_data
 			FROM goods_order t1
 			LEFT JOIN goods_order_original t2 ON t2.vendor_order_id = t1.vendor_order_id AND t2.vendor_id = t1.vendor_id
 			WHERE t1.order_created_at >= ? AND t1.order_created_at < ?`