getmyafsorders

business/model/dao/dao_order.go

@@ -1296,3 +1296,43 @@ func GetSimpleOrderSkus(db *DaoDB, vendorOrderID string) (skus []*model.OrderSku
 	err = GetRows(db, &skus, sql, sqlParams)
 	return skus, err
 }
+
+func GetAfsOrdersByPage(db *DaoDB, vendorOrderID, afsOrderID, userID string, fromTime, toTime time.Time, offset, pageSize int) (afsOrderList []*model.AfsOrder, totalCount int, err error) {
+	sql := `
+	SELECT SQL_CALC_FOUND_ROWS *
+	FROM afs_order t1
+	LEFT JOIN goods_order t2 ON t2.vendor_order_id = t1.vendor_order_id AND t2.vendor_id = t1.vendor_id
+	WHERE 1 = 1
+	`
+	sqlParams := []interface{}{}
+	if vendorOrderID != "" {
+		sql += " AND t1.vendor_order_id = ?"
+		sqlParams = append(sqlParams, vendorOrderID)
+	}
+	if afsOrderID != "" {
+		sql += " AND t1.afs_order_id = ?"
+		sqlParams = append(sqlParams, afsOrderID)
+	}
+	if !utils.IsTimeZero(fromTime) {
+		sql += " AND t1.afs_created_at >= ?"
+		sqlParams = append(sqlParams, fromTime)
+	}
+	if !utils.IsTimeZero(toTime) {
+		sql += " AND t1.afs_created_at <= ?"
+		sqlParams = append(sqlParams, toTime)
+	}
+	if userID != "" {
+		sql += " AND t2.user_id = ?"
+		sqlParams = append(sqlParams, userID)
+	}
+	sql += ` ORDER BY t1.afs_order_id DESC 
+			 LIMIT ? OFFSET ?
+			`
+	sqlParams = append(sqlParams, pageSize, offset)
+	Begin(db)
+	defer Commit(db)
+	if err = GetRows(db, &afsOrderList, sql, sqlParams...); err == nil {
+		totalCount = GetLastTotalRowCount(db)
+	}
+	return afsOrderList, totalCount, err
+}