This commit is contained in:
gazebo
2019-09-06 15:33:12 +08:00
parent a89928a366
commit a12f15af52

View File

@@ -1032,7 +1032,7 @@ func CreateConsumerFromOrders(ctx *jxcontext.Context, vendorIDs []int, fromDate,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
curDate := batchItemList[0].(time.Time) curDate := batchItemList[0].(time.Time)
sql := ` sql := `
SELECT * SELECT t1.*, t2.original_data
FROM goods_order t1 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 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 < ?` WHERE t1.order_created_at >= ? AND t1.order_created_at < ?`